Documentation
¶
Index ¶
Constants ¶
View Source
const Name = "v2"
Variables ¶
This section is empty.
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.
Source Files
Click to show internal directories.
Click to hide internal directories.