Documentation
¶
Index ¶
- func NewClientGRPCGroup(logger *zap.Logger, config types.BackendV2) (types.BackendServer, *errors.Errors)
- func NewClientGRPCGroupWithLimiter(logger *zap.Logger, config types.BackendV2, limiter limiter.ServerLimiter) (types.BackendServer, *errors.Errors)
- type ClientGRPCGroup
- func (c ClientGRPCGroup) Backends() []string
- func (c *ClientGRPCGroup) Children() []types.BackendServer
- func (c *ClientGRPCGroup) Fetch(ctx context.Context, request *protov3.MultiFetchRequest) (*protov3.MultiFetchResponse, *types.Stats, *errors.Errors)
- func (c *ClientGRPCGroup) Find(ctx context.Context, request *protov3.MultiGlobRequest) (*protov3.MultiGlobResponse, *types.Stats, *errors.Errors)
- func (c *ClientGRPCGroup) Info(ctx context.Context, request *protov3.MultiMetricsInfoRequest) (*protov3.ZipperInfoResponse, *types.Stats, *errors.Errors)
- func (c *ClientGRPCGroup) List(ctx context.Context) (*protov3.ListMetricsResponse, *types.Stats, *errors.Errors)
- func (c ClientGRPCGroup) MaxMetricsPerRequest() int
- func (c ClientGRPCGroup) Name() string
- func (c *ClientGRPCGroup) ProbeTLDs(ctx context.Context) ([]string, *errors.Errors)
- func (c *ClientGRPCGroup) Stats(ctx context.Context) (*protov3.MetricDetailsResponse, *types.Stats, *errors.Errors)
- func (c *ClientGRPCGroup) TagNames(ctx context.Context, query string, limit int64) ([]string, *errors.Errors)
- func (c *ClientGRPCGroup) TagValues(ctx context.Context, query string, limit int64) ([]string, *errors.Errors)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewClientGRPCGroup ¶
func NewClientGRPCGroupWithLimiter ¶
func NewClientGRPCGroupWithLimiter(logger *zap.Logger, config types.BackendV2, limiter limiter.ServerLimiter) (types.BackendServer, *errors.Errors)
Types ¶
type ClientGRPCGroup ¶
type ClientGRPCGroup struct {
// contains filtered or unexported fields
}
RoundRobin is used to connect to backends inside clientGRPCGroups, implements BackendServer interface
func (ClientGRPCGroup) Backends ¶
func (c ClientGRPCGroup) Backends() []string
func (*ClientGRPCGroup) Children ¶
func (c *ClientGRPCGroup) Children() []types.BackendServer
func (*ClientGRPCGroup) Fetch ¶
func (c *ClientGRPCGroup) Fetch(ctx context.Context, request *protov3.MultiFetchRequest) (*protov3.MultiFetchResponse, *types.Stats, *errors.Errors)
func (*ClientGRPCGroup) Find ¶
func (c *ClientGRPCGroup) Find(ctx context.Context, request *protov3.MultiGlobRequest) (*protov3.MultiGlobResponse, *types.Stats, *errors.Errors)
func (*ClientGRPCGroup) Info ¶
func (c *ClientGRPCGroup) Info(ctx context.Context, request *protov3.MultiMetricsInfoRequest) (*protov3.ZipperInfoResponse, *types.Stats, *errors.Errors)
func (*ClientGRPCGroup) List ¶
func (c *ClientGRPCGroup) List(ctx context.Context) (*protov3.ListMetricsResponse, *types.Stats, *errors.Errors)
func (ClientGRPCGroup) MaxMetricsPerRequest ¶
func (c ClientGRPCGroup) MaxMetricsPerRequest() int
func (ClientGRPCGroup) Name ¶
func (c ClientGRPCGroup) Name() string
func (*ClientGRPCGroup) Stats ¶
func (c *ClientGRPCGroup) Stats(ctx context.Context) (*protov3.MetricDetailsResponse, *types.Stats, *errors.Errors)
Source Files
Click to show internal directories.
Click to hide internal directories.