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
Click to show internal directories.
Click to hide internal directories.