discovery

Documentation

Overview

Package discovery supports suffrage nodes network.

Index

• func LoadNodeChannel(connInfo network.ConnInfo, encs *encoder.Encoders, ...) (network.Channel, error)
• type Discovery
• type NodeConnInfo
• type NodepoolDelegate
  • func NewNodepoolDelegate(nodepool *network.Nodepool, encs *encoder.Encoders, ...) *NodepoolDelegate
  • func (dg *NodepoolDelegate) NotifyJoin(ci NodeConnInfo)
  • func (dg *NodepoolDelegate) NotifyLeave(ci NodeConnInfo, lefts []NodeConnInfo)
  • func (dg *NodepoolDelegate) NotifyUpdate(ci NodeConnInfo)

Functions

func LoadNodeChannel

func LoadNodeChannel(
	connInfo network.ConnInfo,
	encs *encoder.Encoders,
	connectionTimeout time.Duration,
) (network.Channel, error)

Types

type Discovery

type Discovery interface {
	util.Daemon
	LenNodes() int
	Nodes() []NodeConnInfo
	SetNotifyJoin(func(NodeConnInfo)) Discovery
	SetNotifyLeave(func(NodeConnInfo, []NodeConnInfo)) Discovery
	SetNotifyUpdate(func(NodeConnInfo)) Discovery
}

type NodeConnInfo

type NodeConnInfo interface {
	network.ConnInfo
	Node() base.Address
}

type NodepoolDelegate

type NodepoolDelegate struct {
	sync.Mutex
	*logging.Logging
	// contains filtered or unexported fields
}

func NewNodepoolDelegate

func NewNodepoolDelegate(
	nodepool *network.Nodepool,
	encs *encoder.Encoders,
	connectionTimeout time.Duration,
) *NodepoolDelegate

func (*NodepoolDelegate) NotifyJoin

func (dg *NodepoolDelegate) NotifyJoin(ci NodeConnInfo)

func (*NodepoolDelegate) NotifyLeave

func (dg *NodepoolDelegate) NotifyLeave(ci NodeConnInfo, lefts []NodeConnInfo)

func (*NodepoolDelegate) NotifyUpdate

func (dg *NodepoolDelegate) NotifyUpdate(ci NodeConnInfo)