remote

Documentation

Index

• func NewWriteClient(conf *ClientConfig) (remote.WriteClient, error)
• type ClientConfig
• type Write
  • func NewWrite(opts ...WriteOpts) *Write
  • func (w *Write) Run(ctx context.Context, sampleCh chan pulsar.ReceivedSample, ...) error
• type WriteOpts
  • func WithLogger(l log.Logger) WriteOpts
  • func WithMetrics(m *metrics.Metrics) WriteOpts

Functions

func NewWriteClient

func NewWriteClient(conf *ClientConfig) (remote.WriteClient, error)

Types

type ClientConfig

type ClientConfig = remote.ClientConfig

type Write

type Write struct {

	// BatchSize is the amount of samples that are aggregated into a single
	// remote write request
	BatchSize int
	// BatchMaxDelay is the maximum delay acceptable for a batch to wait to
	// reach the BatchSize
	BatchMaxDelay time.Duration
	// contains filtered or unexported fields
}

func NewWrite

func NewWrite(opts ...WriteOpts) *Write

func (*Write) Run

func (w *Write) Run(ctx context.Context, sampleCh chan pulsar.ReceivedSample, client remote.WriteClient) error

type WriteOpts

type WriteOpts func(o *Write)

func WithLogger

func WithLogger(l log.Logger) WriteOpts

func WithMetrics

func WithMetrics(m *metrics.Metrics) WriteOpts