cluster

Documentation

Index

• func New(config Config) (*cluster, error)
• type Cluster
• type Config
• type Node

Functions

func New

func New(config Config) (*cluster, error)

Types

type Cluster

type Cluster interface {
	Shutdown() error
	FindNode(key string) (Node, error)
	Peers() []Node
	AuthToken() string

	// Returns its own node ID
	NodeId() string

	// Returns the number of nodes in the cluster
	Size() int
}

type Config

type Config struct {
	NodeId     string
	Membership membership.Membership
	Logger     logging.Logger
	Metrics    metrics.Metrics
	Debug      bool
	RpcAddr    string
	AuthToken  string
}

type Node

type Node struct {
	Id      string
	RpcAddr string
}