cluster

Documentation

Index

• Constants
• type Cluster
  • func New(port int, seedAddr string) *Cluster
  • func (c *Cluster) Connect() error
  • func (c *Cluster) Shutdown()

Constants

const (
	DefaultPort                  = 17946
	MembershipChangeBufferWindow = 1 * time.Second
)

Types

type Cluster

type Cluster struct {
	OnMembershipChange func(n, total int)
	// contains filtered or unexported fields
}

Cluster maintains cluster membership and notifies on certain events

func New

func New(port int, seedAddr string) *Cluster

New returns a new Cluster instance that is not connected.

func (*Cluster) Connect

func (c *Cluster) Connect() error

Connect Initializes the Cluster based on a configuration passed via the New function. It then stores the seed address, starts gossiping and listens for gossip.

func (*Cluster) Shutdown

func (c *Cluster) Shutdown()

Shutdown safely shuts down the cluster.