encoder

Documentation

Index

• type Encoder
  • func GetEncoder(orgID int) (*Encoder, error)
  • func (e *Encoder) Encode(req *controller.SyncPrometheusRequest) (*controller.SyncPrometheusResponse, error)
  • func (e *Encoder) Refresh() error
• type ORGEncoders
  • func GetORGEncoders() *ORGEncoders
  • func (e *ORGEncoders) Init(ctx context.Context, cfg prometheuscfg.Config)
  • func (e *ORGEncoders) NewEncoderAndInitIfNotExist(orgID int) (*Encoder, error)
  • func (e *ORGEncoders) Start(sCtx context.Context) error
  • func (e *ORGEncoders) Stop()

Types

type Encoder

type Encoder struct {
	LabelLayout *labelLayout
	// contains filtered or unexported fields
}

func GetEncoder

func GetEncoder(orgID int) (*Encoder, error)

func (*Encoder) Encode

func (e *Encoder) Encode(req *controller.SyncPrometheusRequest) (*controller.SyncPrometheusResponse, error)

func (*Encoder) Refresh

func (e *Encoder) Refresh() error

type ORGEncoders

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

func GetORGEncoders

func GetORGEncoders() *ORGEncoders

func (*ORGEncoders) Init

func (e *ORGEncoders) Init(ctx context.Context, cfg prometheuscfg.Config)

func (*ORGEncoders) NewEncoderAndInitIfNotExist

func (e *ORGEncoders) NewEncoderAndInitIfNotExist(orgID int) (*Encoder, error)

func (*ORGEncoders) Start

func (e *ORGEncoders) Start(sCtx context.Context) error

func (*ORGEncoders) Stop

func (e *ORGEncoders) Stop()