cluster

Documentation

Index

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

Functions

func IsInternalRequest

func IsInternalRequest(ctx context.Context) bool

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(ctx context.Context, opts ...grpc.DialOption) error

Connect ...

func (*Cluster) ExternalNodes

func (c *Cluster) ExternalNodes() (res []*Node)

ExternalNodes returns all available nodes except host.

func (*Cluster) Get

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

Get if possible returns node for a given 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) GoString

func (c *Cluster) GoString() string

GoString implements fmt GoStringer interface.

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 {
	ID     int
	Addr   string                            `json:"addr"`
	Client mnemosynerpc.SessionManagerClient `json:"-"`
	Health grpc_health_v1.HealthClient       `json:"-"`
}

Node ...

type Opts

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

Opts ...