prometheus

Documentation

Index

• func DeleteExpired[MT any](tx *gorm.DB, expiredAt time.Time) ([]MT, error)
• func GetMasterGRPCConn() (*grpc.ClientConn, error)
• type APPLabelLayoutUpdater
  • func GetAPPLabelLayoutUpdater() *APPLabelLayoutUpdater
  • func (au *APPLabelLayoutUpdater) Init(ctx context.Context, cfg *prometheuscfg.Config)
  • func (e *APPLabelLayoutUpdater) Start() error
  • func (au *APPLabelLayoutUpdater) Stop()
• type Cleaner
  • func GetCleaner() *Cleaner
  • func (c *Cleaner) Clear(expiredAt time.Time) error
  • func (c *Cleaner) Init(ctx context.Context, cfg *prometheuscfg.Config)
  • func (c *Cleaner) Start() error
  • func (c *Cleaner) Stop()
• type GRPCURL
  • func (s *GRPCURL) Sync(req *controller.SyncPrometheusRequest) (*controller.SyncPrometheusResponse, error)
• type LabelSynchronizer
  • func NewLabelSynchronizer() *LabelSynchronizer
  • func (s *LabelSynchronizer) GetStatsdCounter() *statsd.PrometheusLabelIDsCounter
  • func (s *LabelSynchronizer) Sync(req *trident.PrometheusLabelRequest) (*trident.PrometheusLabelResponse, error)
• type PrometheusManager
  • func GetSingleton() *PrometheusManager
• type Synchronizer
  • func NewSynchronizer() *Synchronizer
• type TargetSynchronizer
  • func NewTargetSynchronizer() *TargetSynchronizer
  • func (s *TargetSynchronizer) GetTargets(in *trident.PrometheusTargetRequest) (*trident.PrometheusTargetResponse, error)

Functions

func DeleteExpired

func DeleteExpired[MT any](tx *gorm.DB, expiredAt time.Time) ([]MT, error)

func GetMasterGRPCConn

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

Types

type APPLabelLayoutUpdater

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

func GetAPPLabelLayoutUpdater

func GetAPPLabelLayoutUpdater() *APPLabelLayoutUpdater

func (*APPLabelLayoutUpdater) Init

func (au *APPLabelLayoutUpdater) Init(ctx context.Context, cfg *prometheuscfg.Config)

func (*APPLabelLayoutUpdater) Start

func (e *APPLabelLayoutUpdater) Start() error

func (*APPLabelLayoutUpdater) Stop

func (au *APPLabelLayoutUpdater) Stop()

type Cleaner

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

func GetCleaner

func GetCleaner() *Cleaner

func (*Cleaner) Clear

func (c *Cleaner) Clear(expiredAt time.Time) error

func (*Cleaner) Init

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

func (*Cleaner) Start

func (c *Cleaner) Start() 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 NewLabelSynchronizer

func NewLabelSynchronizer() *LabelSynchronizer

func (*LabelSynchronizer) GetStatsdCounter

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

func (*LabelSynchronizer) Sync

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

type PrometheusManager

type PrometheusManager struct {
	Encoder               *encoder.Encoder
	SynchronizerCache     *cache.Cache
	APPLabelLayoutUpdater *APPLabelLayoutUpdater
	Clear                 *Cleaner
}

func GetSingleton

func GetSingleton() *PrometheusManager

type Synchronizer

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

func NewSynchronizer

func NewSynchronizer() *Synchronizer

type TargetSynchronizer

type TargetSynchronizer struct {
	Synchronizer
}

func NewTargetSynchronizer

func NewTargetSynchronizer() *TargetSynchronizer

func (*TargetSynchronizer) GetTargets

func (s *TargetSynchronizer) GetTargets(in *trident.PrometheusTargetRequest) (*trident.PrometheusTargetResponse, error)