pusher

Documentation

Index

• type Payload
• type Publisher
  • func NewPublisher(conn *grpc.ClientConn, publishCh <-chan Payload, tenantCh <-chan sm.Tenant, ...) *Publisher
  • func (p *Publisher) Run(ctx context.Context) error

Types

type Payload

type Payload interface {
	Tenant() int64
	Metrics() []prompb.TimeSeries
	Streams() []logproto.Stream
}

type Publisher

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

func NewPublisher

func NewPublisher(conn *grpc.ClientConn, publishCh <-chan Payload, tenantCh <-chan sm.Tenant, logger zerolog.Logger, promRegisterer prometheus.Registerer) *Publisher

func (*Publisher) Run

func (p *Publisher) Run(ctx context.Context) error