v2

Documentation

Index

• Constants
• func NewPublisher(ctx context.Context, tenantProvider pusher.TenantProvider, ...) pusher.Publisher
• type SnappyConcatReader
  • func (s *SnappyConcatReader) Read(out []byte) (n int, err error)

Constants

const Name = "v2"

Functions

func NewPublisher

func NewPublisher(ctx context.Context, tenantProvider pusher.TenantProvider, logger zerolog.Logger, pr prometheus.Registerer) pusher.Publisher

NewPublisher creates a new instance of the v2 Publisher.

The provider context is used to control the lifetime of the publisher.

Types

type SnappyConcatReader

type SnappyConcatReader struct {
	Streams [][]byte
	// contains filtered or unexported fields
}

SnappyConcatReader is an io.Reader that takes a list of snappy-compressed buffers (Streams) and returns a single valid snappy-compressed stream equivalent to the concatenation of those buffers without additional allocation.

func (*SnappyConcatReader) Read

func (s *SnappyConcatReader) Read(out []byte) (n int, err error)

Read fulfills the io.Reader interface.