broadcast

package
v0.15.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 3, 2021 License: BSD-2-Clause Imports: 12 Imported by: 0

Documentation

Index

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 New added in v0.15.0

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 (*BroadcastGroup) Find

func (*BroadcastGroup) Info

func (*BroadcastGroup) List

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 added in v0.14.1

func (bg *BroadcastGroup) SetDoMultipleRequestIfSplit(v bool)

func (*BroadcastGroup) Stats

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 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 WithDialer(dialer *net.Dialer) Option

func WithGroupName added in v0.15.0

func WithGroupName(name string) Option

func WithLimiter added in v0.15.0

func WithLimiter(concurrencyLimit int) Option

func WithLogger added in v0.15.0

func WithLogger(logger *zap.Logger) Option

func WithMaxMetricsPerRequest added in v0.15.0

func WithMaxMetricsPerRequest(maxMetricsPerRequest int) Option

func WithPathCache added in v0.15.0

func WithPathCache(expireDelaySec int32) Option

func WithSplitMultipleRequests added in v0.15.0

func WithSplitMultipleRequests(multiRequests bool) Option

func WithTLDCache added in v0.15.0

func WithTLDCache(enableTLDCache bool) Option

func WithTimeouts added in v0.15.0

func WithTimeouts(timeouts types.Timeouts) Option

Jump to

Keyboard shortcuts

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