prometheus

Documentation

Index

• func NewPromEncoder(seriesLimit int) extensions.Encoder
• type Encoder
  • func (p *Encoder) EncodeBatchV1(logGroups []*protocol.LogGroup) ([][]byte, error)
  • func (p *Encoder) EncodeBatchV2(groupEventsSlice []*models.PipelineGroupEvents) ([][]byte, error)
  • func (p *Encoder) EncodeV1(logGroups *protocol.LogGroup) ([][]byte, error)
  • func (p *Encoder) EncodeV2(groupEvents *models.PipelineGroupEvents) ([][]byte, error)
• type Option

Functions

func NewPromEncoder

func NewPromEncoder(seriesLimit int) extensions.Encoder

Types

type Encoder

type Encoder struct {
	SeriesLimit int
}

func (*Encoder) EncodeBatchV1

func (p *Encoder) EncodeBatchV1(logGroups []*protocol.LogGroup) ([][]byte, error)

func (*Encoder) EncodeBatchV2

func (p *Encoder) EncodeBatchV2(groupEventsSlice []*models.PipelineGroupEvents) ([][]byte, error)

func (*Encoder) EncodeV1

func (p *Encoder) EncodeV1(logGroups *protocol.LogGroup) ([][]byte, error)

func (*Encoder) EncodeV2

func (p *Encoder) EncodeV2(groupEvents *models.PipelineGroupEvents) ([][]byte, error)

type Option

type Option struct {
	SeriesLimit int // config for prometheus encoder
}