Documentation
¶
Index ¶
- type BroadcastGroup
- func (bg BroadcastGroup) Backends() []string
- func (bg *BroadcastGroup) Children() []types.BackendServer
- func (bg *BroadcastGroup) Fetch(ctx context.Context, request *protov3.MultiFetchRequest) (*protov3.MultiFetchResponse, *types.Stats, merry.Error)
- func (bg *BroadcastGroup) Find(ctx context.Context, request *protov3.MultiGlobRequest) (*protov3.MultiGlobResponse, *types.Stats, merry.Error)
- func (bg *BroadcastGroup) Info(ctx context.Context, request *protov3.MultiMetricsInfoRequest) (*protov3.ZipperInfoResponse, *types.Stats, merry.Error)
- func (bg *BroadcastGroup) List(ctx context.Context) (*protov3.ListMetricsResponse, *types.Stats, merry.Error)
- func (bg BroadcastGroup) MaxMetricsPerRequest() int
- func (bg BroadcastGroup) Name() string
- func (bg *BroadcastGroup) ProbeTLDs(ctx context.Context) ([]string, merry.Error)
- func (bg *BroadcastGroup) SetDoMultipleRequestIfSplit(v bool)
- func (bg *BroadcastGroup) Stats(ctx context.Context) (*protov3.MetricDetailsResponse, *types.Stats, merry.Error)
- func (bg *BroadcastGroup) TagNames(ctx context.Context, query string, limit int64) ([]string, merry.Error)
- func (bg *BroadcastGroup) TagValues(ctx context.Context, query string, limit int64) ([]string, merry.Error)
- type Option
- func WithBackends(backends []types.BackendServer) Option
- func WithDialer(dialer *net.Dialer) Option
- func WithGroupName(name string) Option
- func WithLimiter(concurrencyLimit int) Option
- func WithLogger(logger *zap.Logger) Option
- func WithMaxMetricsPerRequest(maxMetricsPerRequest int) Option
- func WithPathCache(expireDelaySec int32) Option
- func WithSplitMultipleRequests(multiRequests bool) Option
- func WithTLDCache(enableTLDCache bool) Option
- func WithTimeouts(timeouts types.Timeouts) Option
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BroadcastGroup ¶
type BroadcastGroup struct {
// contains filtered or unexported fields
}
func NewBroadcastGroup ¶
func (BroadcastGroup) Backends ¶
func (bg BroadcastGroup) Backends() []string
func (*BroadcastGroup) Children ¶
func (bg *BroadcastGroup) Children() []types.BackendServer
func (*BroadcastGroup) Fetch ¶
func (bg *BroadcastGroup) Fetch(ctx context.Context, request *protov3.MultiFetchRequest) (*protov3.MultiFetchResponse, *types.Stats, merry.Error)
func (*BroadcastGroup) Find ¶
func (bg *BroadcastGroup) Find(ctx context.Context, request *protov3.MultiGlobRequest) (*protov3.MultiGlobResponse, *types.Stats, merry.Error)
func (*BroadcastGroup) Info ¶
func (bg *BroadcastGroup) Info(ctx context.Context, request *protov3.MultiMetricsInfoRequest) (*protov3.ZipperInfoResponse, *types.Stats, merry.Error)
func (*BroadcastGroup) List ¶
func (bg *BroadcastGroup) List(ctx context.Context) (*protov3.ListMetricsResponse, *types.Stats, merry.Error)
func (BroadcastGroup) MaxMetricsPerRequest ¶
func (bg BroadcastGroup) MaxMetricsPerRequest() int
func (BroadcastGroup) Name ¶
func (bg BroadcastGroup) Name() string
func (*BroadcastGroup) SetDoMultipleRequestIfSplit ¶ added in v0.14.1
func (bg *BroadcastGroup) SetDoMultipleRequestIfSplit(v bool)
func (*BroadcastGroup) Stats ¶
func (bg *BroadcastGroup) Stats(ctx context.Context) (*protov3.MetricDetailsResponse, *types.Stats, merry.Error)
type Option ¶ added in v0.15.0
type Option func(group *BroadcastGroup)
func WithBackends ¶ added in v0.15.0
func WithBackends(backends []types.BackendServer) Option
func WithDialer ¶ added in v0.15.0
func WithGroupName ¶ added in v0.15.0
func WithLimiter ¶ added in v0.15.0
func WithLogger ¶ added in v0.15.0
func WithMaxMetricsPerRequest ¶ added in v0.15.0
func WithPathCache ¶ added in v0.15.0
func WithSplitMultipleRequests ¶ added in v0.15.0
func WithTLDCache ¶ added in v0.15.0
func WithTimeouts ¶ added in v0.15.0
Source Files
Click to show internal directories.
Click to hide internal directories.