v2

package
v0.0.0-...-05b72f9 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 29, 2023 License: Apache-2.0 Imports: 24 Imported by: 0

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.

func (*SnappyConcatReader) Read

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

Read fulfills the io.Reader interface.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL