cluster

Documentation

Index

• type Cluster
  • func New(opts Opts) (csr *Cluster, err error)
  • func (c *Cluster) Connect(opts ...grpc.DialOption) error
  • func (c *Cluster) Get(k int32) (*Node, bool)
  • func (c *Cluster) GetOther(accessToken string) (*Node, bool)
  • func (c *Cluster) Len() int
  • func (c *Cluster) Listen() string
  • func (c *Cluster) Nodes() []*Node
• type Node
• type Opts

Types

type Cluster

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

Cluster ...

func New

func New(opts Opts) (csr *Cluster, err error)

New ...

func (*Cluster) Connect

func (c *Cluster) Connect(opts ...grpc.DialOption) error

Connect ...

func (*Cluster) Get

func (c *Cluster) Get(k int32) (*Node, bool)

Get if possible returns node for a hiven bucket id.

func (*Cluster) GetOther

func (c *Cluster) GetOther(accessToken string) (*Node, bool)

GetOther returns node for given access token. Returns false if cluster is nil, has only one element or if node that was found has same listen address as current one.

func (*Cluster) Len

func (c *Cluster) Len() int

Len returns number of nodes.

func (*Cluster) Listen

func (c *Cluster) Listen() string

Listen returns address of current node.

func (*Cluster) Nodes

func (c *Cluster) Nodes() []*Node

Nodes returns all available nodes.

type Node

type Node struct {
	Addr   string
	Client mnemosynerpc.SessionManagerClient
}

Node ...

type Opts

type Opts struct {
	Listen string
	Seeds  []string
	Logger *zap.Logger
}

Opts ...