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) Len() int
  • 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 that corresponds to given access token.

func (*Cluster) Len

func (c *Cluster) Len() int

Len returns number of nodes.

func (*Cluster) Nodes

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

Nodes ...

type Node

type Node struct {
	Addr   string
	Client mnemosynerpc.SessionManagerClient
}

Node ...

type Opts

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

Opts ...