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( instrumentOptions instrument.Options, readPoolPolicy, writePoolPolicy xconfig.WorkerPoolPolicy, scope tally.Scope, ) (xsync.PooledWorkerPool, xsync.PooledWorkerPool, error)
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
func (*PoolWrapper) WaitForIteratorPools ¶ added in v0.4.8
func (w *PoolWrapper) WaitForIteratorPools( timeout time.Duration, ) (encoding.IteratorPools, error)
WaitForIteratorPools will block until iterator pools are available. If given a timeout of 0, will block indefinitely