state

package
v0.0.0-...-370eddc Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 18, 2018 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NotHandled 

func NotHandled()

Types

type DiscoveryState 

type DiscoveryState struct {
	NullState
	Ctx *common.Context
	// contains filtered or unexported fields
}

func (*DiscoveryState) ActionLeave 

func (s *DiscoveryState) ActionLeave() bool

func (*DiscoveryState) ActionStartChRo 

func (h *DiscoveryState) ActionStartChRo()

func (*DiscoveryState) ActionSync 

func (h *DiscoveryState) ActionSync()

func (*DiscoveryState) ChRoIdReceived 

func (h *DiscoveryState) ChRoIdReceived(sender common.PeerAddr, id int)

func (*DiscoveryState) Init 

func (s *DiscoveryState) Init()

func (*DiscoveryState) LeaderChanged 

func (h *DiscoveryState) LeaderChanged(sender common.PeerAddr, leader common.PeerAddr, value int)

func (*DiscoveryState) Name 

func (h *DiscoveryState) Name() string

func (*DiscoveryState) NewPeer 

func (h *DiscoveryState) NewPeer(sender common.PeerAddr, addr common.PeerAddr,
	name string, shouldReply bool)

func (*DiscoveryState) PeerRemoved 

func (s *DiscoveryState) PeerRemoved(sender common.PeerAddr, removedPeer common.PeerAddr, direction int)

func (*DiscoveryState) Ping 

func (h *DiscoveryState) Ping(sender common.PeerAddr, source common.PeerAddr)

func (*DiscoveryState) Pong 

func (h *DiscoveryState) Pong(sender common.PeerAddr, source common.PeerAddr)

func (*DiscoveryState) SyncPeers 

func (h *DiscoveryState) SyncPeers(sender common.PeerAddr, values []string)

type LeaderState 

type LeaderState struct {
	DiscoveryState
	Value int
}

func (*LeaderState) ActionGetValue 

func (s *LeaderState) ActionGetValue()

func (*LeaderState) ActionLeave 

func (s *LeaderState) ActionLeave() bool

func (*LeaderState) ActionReportPeer 

func (s *LeaderState) ActionReportPeer(addr common.PeerAddr)

func (*LeaderState) ActionSetValue 

func (s *LeaderState) ActionSetValue(value int)

func (*LeaderState) ActionStartChRo 

func (s *LeaderState) ActionStartChRo()

func (*LeaderState) ActionSync 

func (s *LeaderState) ActionSync()

func (*LeaderState) DistanceReceived 

func (s *LeaderState) DistanceReceived(sender common.PeerAddr, distance int, direction int)

func (*LeaderState) DistanceRequested 

func (s *LeaderState) DistanceRequested(sender common.PeerAddr, source common.PeerAddr)

func (*LeaderState) EmitDistanceBroadcast 

func (s *LeaderState) EmitDistanceBroadcast()

func (*LeaderState) Init 

func (s *LeaderState) Init()

func (*LeaderState) LeaderChanged 

func (s *LeaderState) LeaderChanged(sender common.PeerAddr, leader common.PeerAddr, value int)

func (*LeaderState) Name 

func (s *LeaderState) Name() string

func (*LeaderState) NewPeer 

func (s *LeaderState) NewPeer(sender common.PeerAddr, addr common.PeerAddr,
	name string, shouldReply bool)

func (*LeaderState) PeerRemoved 

func (s *LeaderState) PeerRemoved(sender common.PeerAddr, reportedPeer common.PeerAddr, direction int)

func (*LeaderState) PeerReported 

func (s *LeaderState) PeerReported(reportedPeer common.PeerAddr)

func (*LeaderState) ValueGetRequested 

func (s *LeaderState) ValueGetRequested(sender common.PeerAddr, source common.PeerAddr)

func (*LeaderState) ValueSetRequested 

func (s *LeaderState) ValueSetRequested(sender common.PeerAddr,
	source common.PeerAddr, value int)

type LinkedState 

type LinkedState struct {
	DiscoveryState
}

func (*LinkedState) ActionGetValue 

func (s *LinkedState) ActionGetValue()

func (*LinkedState) ActionLeave 

func (s *LinkedState) ActionLeave() bool

func (*LinkedState) ActionReportPeer 

func (s *LinkedState) ActionReportPeer(addr common.PeerAddr)

func (*LinkedState) ActionSetValue 

func (s *LinkedState) ActionSetValue(value int)

func (*LinkedState) ActionStartChRo 

func (s *LinkedState) ActionStartChRo()

func (*LinkedState) ActionSync 

func (s *LinkedState) ActionSync()

func (*LinkedState) DistanceReceived 

func (s *LinkedState) DistanceReceived(sender common.PeerAddr, distance int, direction int)

func (*LinkedState) GotValue 

func (s *LinkedState) GotValue(sender common.PeerAddr, value int)

func (*LinkedState) Init 

func (s *LinkedState) Init()

func (*LinkedState) LeaderChanged 

func (s *LinkedState) LeaderChanged(sender common.PeerAddr, leader common.PeerAddr, value int)

func (*LinkedState) Name 

func (s *LinkedState) Name() string

func (*LinkedState) PeerRemoved 

func (s *LinkedState) PeerRemoved(sender common.PeerAddr, removedPeer common.PeerAddr, direction int)

func (*LinkedState) RequestDistancesIfMissing 

func (s *LinkedState) RequestDistancesIfMissing()

func (*LinkedState) ValueSetConfirmed 

func (s *LinkedState) ValueSetConfirmed(sender common.PeerAddr)

type NullState 

type NullState struct{}

func (*NullState) ActionDisconnect 

func (s *NullState) ActionDisconnect()

func (*NullState) ActionGetValue 

func (s *NullState) ActionGetValue()

func (*NullState) ActionLeave 

func (s *NullState) ActionLeave() bool

func (*NullState) ActionReconnect 

func (s *NullState) ActionReconnect()

func (*NullState) ActionReportPeer 

func (s *NullState) ActionReportPeer(addr common.PeerAddr)

func (*NullState) ActionSetValue 

func (s *NullState) ActionSetValue(value int)

func (*NullState) ActionStartChRo 

func (s *NullState) ActionStartChRo()

func (*NullState) ActionSync 

func (s *NullState) ActionSync()

func (*NullState) ChRoIdReceived 

func (s *NullState) ChRoIdReceived(sender common.PeerAddr, id int)

func (*NullState) DistanceReceived 

func (s *NullState) DistanceReceived(sender common.PeerAddr, distance int, direction int)

func (*NullState) DistanceRequested 

func (s *NullState) DistanceRequested(sender common.PeerAddr, source common.PeerAddr)

func (*NullState) GotValue 

func (s *NullState) GotValue(sender common.PeerAddr, value int)

func (*NullState) Init 

func (s *NullState) Init()

func (*NullState) LeaderChanged 

func (s *NullState) LeaderChanged(sender common.PeerAddr, leader common.PeerAddr, value int)

func (*NullState) Name 

func (s *NullState) Name() string

func (*NullState) NewPeer 

func (s *NullState) NewPeer(sender common.PeerAddr, addr common.PeerAddr,
	name string, shouldReply bool)

func (*NullState) PeerRemoved 

func (s *NullState) PeerRemoved(sender common.PeerAddr, reportedPeer common.PeerAddr, direction int)

func (*NullState) PeerReported 

func (s *NullState) PeerReported(reportedPeer common.PeerAddr)

func (*NullState) SyncPeers 

func (s *NullState) SyncPeers(sender common.PeerAddr, values []string)

func (*NullState) ValueGetRequested 

func (s *NullState) ValueGetRequested(sender common.PeerAddr, source common.PeerAddr)

func (*NullState) ValueSetConfirmed 

func (s *NullState) ValueSetConfirmed(sender common.PeerAddr)

func (*NullState) ValueSetRequested 

func (s *NullState) ValueSetRequested(sender common.PeerAddr,
	source common.PeerAddr, value int)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.