m3db

Documentation

Index

• func NewAsyncClient(fn NewClientFn, done chan<- struct{}) clusterclient.Client
• type AsyncClient
  • func (c *AsyncClient) KV() (kv.Store, error)
  • func (c *AsyncClient) Services(opts services.OverrideOptions) (services.Services, error)
  • func (c *AsyncClient) Store(opts kv.OverrideOptions) (kv.Store, error)
  • func (c *AsyncClient) Txn() (kv.TxnStore, error)
  • func (c *AsyncClient) TxnStore(opts kv.OverrideOptions) (kv.TxnStore, error)
• type NewClientFn

Functions

func NewAsyncClient

func NewAsyncClient(
	fn NewClientFn,
	done chan<- struct{},
) clusterclient.Client

NewAsyncClient returns a new AsyncClient.

Types

type AsyncClient

type AsyncClient struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

AsyncClient is a thin wrapper around a cluster client that allows for lazy initialization.

func (*AsyncClient) KV

func (c *AsyncClient) KV() (kv.Store, error)

KV returns access to the distributed configuration store. To be deprecated.

func (*AsyncClient) Services

func (c *AsyncClient) Services(opts services.OverrideOptions) (services.Services, error)

Services returns access to the set of services.

func (*AsyncClient) Store

func (c *AsyncClient) Store(opts kv.OverrideOptions) (kv.Store, error)

Store returns access to the distributed configuration store with a namespace.

func (*AsyncClient) Txn

func (c *AsyncClient) Txn() (kv.TxnStore, error)

Txn returns access to the transaction store. To be deprecated.

func (*AsyncClient) TxnStore

func (c *AsyncClient) TxnStore(opts kv.OverrideOptions) (kv.TxnStore, error)

TxnStore returns access to the transaction store with a namespace.

type NewClientFn

type NewClientFn func() (clusterclient.Client, error)

NewClientFn creates a cluster client.