hccm

Documentation

Overview

Cluster Membership based on memberlist.

Index

• func CreateConfig(conf *memberlist.Config, ne *core.NodeEngine, port int) (*rpcdp.Dispatcher, *gorpc.Server)
• type ObserverDelegate
  • func (o *ObserverDelegate) NotifyAlive(peer *memberlist.Node) error
  • func (o *ObserverDelegate) NotifyJoin(n *memberlist.Node)
  • func (o *ObserverDelegate) NotifyLeave(n *memberlist.Node)
  • func (o *ObserverDelegate) NotifyMerge(peers []*memberlist.Node) error
  • func (o *ObserverDelegate) NotifyUpdate(*memberlist.Node)

Functions

func CreateConfig

func CreateConfig(conf *memberlist.Config, ne *core.NodeEngine, port int) (*rpcdp.Dispatcher, *gorpc.Server)

Types

type ObserverDelegate

type ObserverDelegate struct {
	Obs *nodes.ClusterObserver
}

func (*ObserverDelegate) NotifyAlive

func (o *ObserverDelegate) NotifyAlive(peer *memberlist.Node) error

func (*ObserverDelegate) NotifyJoin

func (o *ObserverDelegate) NotifyJoin(n *memberlist.Node)

NotifyJoin is invoked when a node is detected to have joined. The Node argument must not be modified.

func (*ObserverDelegate) NotifyLeave

func (o *ObserverDelegate) NotifyLeave(n *memberlist.Node)

NotifyLeave is invoked when a node is detected to have left. The Node argument must not be modified.

func (*ObserverDelegate) NotifyMerge

func (o *ObserverDelegate) NotifyMerge(peers []*memberlist.Node) error

func (*ObserverDelegate) NotifyUpdate

func (o *ObserverDelegate) NotifyUpdate(*memberlist.Node)

NotifyUpdate is invoked when a node is detected to have updated, usually involving the meta data. The Node argument must not be modified.