zipper

package

v0.12.1 Latest Latest Go to latest Published: Jul 7, 2019 License: BSD-2-Clause Imports: 19 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Zipper struct {
	ProbeQuit  chan struct{}
	ProbeForce chan int
	// contains filtered or unexported fields
}

Zipper provides interface to Zipper-related functions

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

NewZipper allows to create new Zipper

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

PB3-compatible methods

func (z Zipper) FetchProtoV3(ctx context.Context, request *protov3.MultiFetchRequest) (*protov3.MultiFetchResponse, *types.Stats, error)

GRPC-compatible methods

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

func (z Zipper) FindProtoV3(ctx context.Context, request *protov3.MultiGlobRequest) (*protov3.MultiGlobResponse, *types.Stats, error)

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

func (z Zipper) InfoProtoV3(ctx context.Context, request *protov3.MultiGlobRequest) (*protov3.ZipperInfoResponse, *types.Stats, error)

func (z Zipper) ListProtoV2(ctx context.Context) (*protov2.ListMetricsResponse, *types.Stats, error)

func (z Zipper) ListProtoV3(ctx context.Context) (*protov3.ListMetricsResponse, *types.Stats, error)

func (z Zipper) StatsProtoV2(ctx context.Context) (*protov2.MetricDetailsResponse, *types.Stats, error)

func (z Zipper) StatsProtoV3(ctx context.Context) (*protov3.MetricDetailsResponse, *types.Stats, error)

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

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