broadcast

Documentation

Index

• type BroadcastGroup
  • func New(opts ...Option) (*BroadcastGroup, merry.Error)
  • func NewBroadcastGroup(logger *zap.Logger, groupName string, doMultipleRequestsIfSplit bool, ...) (*BroadcastGroup, merry.Error)
  • 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

Types

type BroadcastGroup

type BroadcastGroup struct {
	// contains filtered or unexported fields
}

func New

func New(opts ...Option) (*BroadcastGroup, merry.Error)

func NewBroadcastGroup

func NewBroadcastGroup(logger *zap.Logger, groupName string, doMultipleRequestsIfSplit bool, servers []types.BackendServer, expireDelaySec int32, concurrencyLimit, maxBatchSize int, timeouts types.Timeouts, tldCacheDisabled bool) (*BroadcastGroup, merry.Error)

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

func (bg *BroadcastGroup) ProbeTLDs(ctx context.Context) ([]string, merry.Error)

func (*BroadcastGroup) SetDoMultipleRequestIfSplit

func (bg *BroadcastGroup) SetDoMultipleRequestIfSplit(v bool)

func (*BroadcastGroup) Stats

func (bg *BroadcastGroup) Stats(ctx context.Context) (*protov3.MetricDetailsResponse, *types.Stats, merry.Error)

func (*BroadcastGroup) TagNames

func (bg *BroadcastGroup) TagNames(ctx context.Context, query string, limit int64) ([]string, merry.Error)

func (*BroadcastGroup) TagValues

func (bg *BroadcastGroup) TagValues(ctx context.Context, query string, limit int64) ([]string, merry.Error)

type Option

type Option func(group *BroadcastGroup)

func WithBackends

func WithBackends(backends []types.BackendServer) Option

func WithDialer

func WithDialer(dialer *net.Dialer) Option

func WithGroupName

func WithGroupName(name string) Option

func WithLimiter

func WithLimiter(concurrencyLimit int) Option

func WithLogger

func WithLogger(logger *zap.Logger) Option

func WithMaxMetricsPerRequest

func WithMaxMetricsPerRequest(maxMetricsPerRequest int) Option

func WithPathCache

func WithPathCache(expireDelaySec int32) Option

func WithSplitMultipleRequests

func WithSplitMultipleRequests(multiRequests bool) Option

func WithTLDCache

func WithTLDCache(enableTLDCache bool) Option

func WithTimeouts

func WithTimeouts(timeouts types.Timeouts) Option