prometheus

Documentation

Index

• func DeleteBatch[MT any](resourceType string, db *mysql.DB, items []MT) error
• func GetMasterGRPCConn() (*grpc.ClientConn, error)
• type Cleaner
  • func GetCleaner() *Cleaner
  • func (c *Cleaner) Init(ctx context.Context, cfg prometheuscfg.Config)
  • func (c *Cleaner) Start(sCtx context.Context) error
  • func (c *Cleaner) Stop()
• type GRPCURL
  • func (s *GRPCURL) Sync(req *controller.SyncPrometheusRequest) (*controller.SyncPrometheusResponse, error)
• type LabelSynchronizer
  • func (s *LabelSynchronizer) GetStatsdCounter() *statsd.PrometheusLabelIDsCounter
• type ORGLabelSynchronizers
  • func NewORGLabelSynchronizer() (*ORGLabelSynchronizers, error)
  • func (s *ORGLabelSynchronizers) GetStatsdCounter() *statsd.PrometheusLabelIDsCounter
  • func (s *ORGLabelSynchronizers) Sync(req *trident.PrometheusLabelRequest) (*trident.PrometheusLabelResponse, error)
• type PrometheusManager
  • func GetSingleton() *PrometheusManager
• type Synchronizer
• type Version
  • func GetVersion() *Version
  • func (v *Version) Get() uint32
  • func (v *Version) Refresh() error

Functions

func DeleteBatch

func DeleteBatch[MT any](resourceType string, db *mysql.DB, items []MT) error

func GetMasterGRPCConn

func GetMasterGRPCConn() (*grpc.ClientConn, error)

Types

type Cleaner

type Cleaner struct {
	// contains filtered or unexported fields
}

func GetCleaner

func GetCleaner() *Cleaner

func (*Cleaner) Init

func (c *Cleaner) Init(ctx context.Context, cfg prometheuscfg.Config)

func (*Cleaner) Start

func (c *Cleaner) Start(sCtx context.Context) error

func (*Cleaner) Stop

func (c *Cleaner) Stop()

type GRPCURL

type GRPCURL struct{}

func (*GRPCURL) Sync

func (s *GRPCURL) Sync(req *controller.SyncPrometheusRequest) (*controller.SyncPrometheusResponse, error)

type LabelSynchronizer

type LabelSynchronizer struct {
	Synchronizer
	// contains filtered or unexported fields
}

func (*LabelSynchronizer) GetStatsdCounter

func (s *LabelSynchronizer) GetStatsdCounter() *statsd.PrometheusLabelIDsCounter

type ORGLabelSynchronizers

type ORGLabelSynchronizers struct {
	// contains filtered or unexported fields
}

func NewORGLabelSynchronizer

func NewORGLabelSynchronizer() (*ORGLabelSynchronizers, error)

func (*ORGLabelSynchronizers) GetStatsdCounter

func (s *ORGLabelSynchronizers) GetStatsdCounter() *statsd.PrometheusLabelIDsCounter

func (*ORGLabelSynchronizers) Sync

func (s *ORGLabelSynchronizers) Sync(req *trident.PrometheusLabelRequest) (*trident.PrometheusLabelResponse, error)

type PrometheusManager

type PrometheusManager struct {
	Encoders           *encoder.ORGEncoders
	SynchronizerCaches *cache.ORGCaches
	Clear              *Cleaner
}

func GetSingleton

func GetSingleton() *PrometheusManager

type Synchronizer

type Synchronizer struct {
	// contains filtered or unexported fields
}

type Version

type Version struct {
	// contains filtered or unexported fields
}

func GetVersion

func GetVersion() *Version

func (*Version) Get

func (v *Version) Get() uint32

func (*Version) Refresh

func (v *Version) Refresh() error