zipper

package
v0.15.1 Latest Latest
Warning

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

Go to latest
Published: Mar 3, 2021 License: BSD-2-Clause Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Zipper

type Zipper struct {
	ProbeQuit  chan struct{}
	ProbeForce chan int

	ScaleToCommonStep bool
	// contains filtered or unexported fields
}

Zipper provides interface to Zipper-related functions

func NewZipper

func NewZipper(sender func(*types.Stats), cfg *config.Config, logger *zap.Logger) (*Zipper, merry.Error)

NewZipper allows to create new Zipper

func (Zipper) FetchProtoV2

func (z Zipper) FetchProtoV2(ctx context.Context, query []string, startTime, stopTime int32) (*protov2.MultiFetchResponse, *types.Stats, merry.Error)

PB3-compatible methods

func (Zipper) FetchProtoV3

GRPC-compatible methods

func (Zipper) FindProtoV2

func (z Zipper) FindProtoV2(ctx context.Context, query []string) ([]*protov2.GlobResponse, *types.Stats, merry.Error)

func (Zipper) FindProtoV3

func (Zipper) InfoProtoV2

func (z Zipper) InfoProtoV2(ctx context.Context, targets []string) (*protov2.ZipperInfoResponse, *types.Stats, merry.Error)

func (Zipper) InfoProtoV3

func (Zipper) ListProtoV2

func (Zipper) ListProtoV3

func (Zipper) StatsProtoV2

func (Zipper) StatsProtoV3

func (Zipper) TagNames

func (z Zipper) TagNames(ctx context.Context, query string, limit int64) ([]string, merry.Error)

func (Zipper) TagValues

func (z Zipper) TagValues(ctx context.Context, query string, limit int64) ([]string, merry.Error)

Jump to

Keyboard shortcuts

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