grpc

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)

Functions

func NewClientGRPCGroup

func NewClientGRPCGroup(logger *zap.Logger, config types.BackendV2) (types.BackendServer, *errors.Errors)

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) ProbeTLDs

func (c *ClientGRPCGroup) ProbeTLDs(ctx context.Context) ([]string, *errors.Errors)

func (*ClientGRPCGroup) Stats

func (c *ClientGRPCGroup) Stats(ctx context.Context) (*protov3.MetricDetailsResponse, *types.Stats, *errors.Errors)

func (*ClientGRPCGroup) TagNames

func (c *ClientGRPCGroup) TagNames(ctx context.Context, query string, limit int64) ([]string, *errors.Errors)

func (*ClientGRPCGroup) TagValues

func (c *ClientGRPCGroup) TagValues(ctx context.Context, query string, limit int64) ([]string, *errors.Errors)