Documentation ¶
Index ¶
- type Zipper
- func (z Zipper) FetchProtoV2(ctx context.Context, query []string, startTime, stopTime int32) (*protov2.MultiFetchResponse, *types.Stats, error)
- func (z Zipper) FetchProtoV3(ctx context.Context, request *protov3.MultiFetchRequest) (*protov3.MultiFetchResponse, *types.Stats, error)
- 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)
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 // contains filtered or unexported fields }
Zipper provides interface to Zipper-related functions
func NewZipper ¶
func NewZipper(sender func(*types.Stats), config *config.Config, logger *zap.Logger) (*Zipper, 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, error)
PB3-compatible methods
func (Zipper) FetchProtoV3 ¶
func (z Zipper) FetchProtoV3(ctx context.Context, request *protov3.MultiFetchRequest) (*protov3.MultiFetchResponse, *types.Stats, error)
GRPC-compatible methods
func (Zipper) FindProtoV2 ¶
func (Zipper) FindProtoV3 ¶
func (z Zipper) FindProtoV3(ctx context.Context, request *protov3.MultiGlobRequest) (*protov3.MultiGlobResponse, *types.Stats, error)
func (Zipper) InfoProtoV2 ¶
func (Zipper) InfoProtoV3 ¶
func (z Zipper) InfoProtoV3(ctx context.Context, request *protov3.MultiGlobRequest) (*protov3.ZipperInfoResponse, *types.Stats, error)
func (Zipper) ListProtoV2 ¶
func (Zipper) ListProtoV3 ¶
func (Zipper) StatsProtoV2 ¶
func (Zipper) StatsProtoV3 ¶
Click to show internal directories.
Click to hide internal directories.