pools

package
v0.4.5 Latest Latest
Warning

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

Go to latest
Published: Sep 25, 2018 License: Apache-2.0 Imports: 13 Imported by: 9

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func BuildIteratorPools

func BuildIteratorPools() encoding.IteratorPools

BuildIteratorPools build iterator pools if they are unavailable from m3db (e.g. if running standalone query)

func BuildWorkerPools

func BuildWorkerPools(
	cfg config.Configuration,
	logger *zap.Logger,
	scope tally.Scope,
) (pool.ObjectPool, instrument.Options)

BuildWorkerPools builds a worker pool

Types

type PoolWrapper

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

PoolWrapper is an asynchronous wrapper for iterator pools

func NewAsyncPoolsWrapper

func NewAsyncPoolsWrapper() *PoolWrapper

NewAsyncPoolsWrapper creates a pool wrapper which must be initialized

func NewPoolsWrapper

func NewPoolsWrapper(pools encoding.IteratorPools) *PoolWrapper

NewPoolsWrapper creates an initialized pool wrapper

func (*PoolWrapper) Init

func (w *PoolWrapper) Init(
	sessionPools encoding.IteratorPools,
	err error,
)

Init initializes the wrapper with iterator pools and notifies any watchers

func (*PoolWrapper) IteratorPools

func (w *PoolWrapper) IteratorPools() (
	bool, encoding.IteratorPools, error, <-chan encoding.IteratorPools, <-chan error)

nolint IteratorPools either returns iterator pools and errors, or channels that will be notified when iterator pools become available

Jump to

Keyboard shortcuts

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