broadcast

package

v0.13.0-rc.3 Latest Latest Go to latest Published: May 20, 2020 License: BSD-2-Clause Imports: 10 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/go-graphite/carbonapi

Links

Open Source Insights

Documentation ¶

Index ¶

type BroadcastGroup
- func NewBroadcastGroup(logger *zap.Logger, groupName string, servers []types.BackendServer, ...) (*BroadcastGroup, merry.Error)
- func NewBroadcastGroupWithLimiter(logger *zap.Logger, groupName string, servers []types.BackendServer, ...) (*BroadcastGroup, merry.Error)

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 NewBroadcastGroup(logger *zap.Logger, groupName string, servers []types.BackendServer, expireDelaySec int32, concurrencyLimit, maxBatchSize int, timeout types.Timeouts, tldCacheDisabled bool) (*BroadcastGroup, merry.Error)

func NewBroadcastGroupWithLimiter ¶

func NewBroadcastGroupWithLimiter(logger *zap.Logger, groupName string, servers []types.BackendServer, serverNames []string, maxBatchSize int, pathCache pathcache.PathCache, limiter limiter.ServerLimiter, timeout 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) 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)

Source Files ¶

View all Source files

broadcast_group.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL