pools

Documentation

Index

• func BuildIteratorPools() encoding.IteratorPools
• func BuildWorkerPools(instrumentOptions instrument.Options, ...) (xsync.PooledWorkerPool, xsync.PooledWorkerPool, error)
• type PoolWrapper
  • func NewAsyncPoolsWrapper() *PoolWrapper
  • func NewPoolsWrapper(pools encoding.IteratorPools) *PoolWrapper
  • func (w *PoolWrapper) Init(sessionPools encoding.IteratorPools, err error)
  • func (w *PoolWrapper) IteratorPools() (bool, encoding.IteratorPools, error, <-chan encoding.IteratorPools, ...)
  • func (w *PoolWrapper) WaitForIteratorPools(timeout time.Duration) (encoding.IteratorPools, error)

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)

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

func (*PoolWrapper) WaitForIteratorPools

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.