state

Documentation

Index

• func NewmessageBusLockerMock(t minimock.Tester) *messageBusLockerMock
• type NetworkSwitcher
  • func NewNetworkSwitcher() (*NetworkSwitcher, error)
  • func (ns *NetworkSwitcher) Acquire(ctx context.Context)
  • func (ns *NetworkSwitcher) GetState() core.NetworkState
  • func (ns *NetworkSwitcher) OnPulse(ctx context.Context, pulse core.Pulse) error
  • func (ns *NetworkSwitcher) Release(ctx context.Context)

Functions

func NewmessageBusLockerMock

func NewmessageBusLockerMock(t minimock.Tester) *messageBusLockerMock

NewmessageBusLockerMock returns a mock for github.com/insolar/insolar/network/state.messageBusLocker

Types

type NetworkSwitcher

type NetworkSwitcher struct {
	NodeNetwork        core.NodeNetwork        `inject:""`
	SwitcherWorkAround core.SwitcherWorkAround `inject:""`
	MBLocker           messageBusLocker        `inject:""`
	// contains filtered or unexported fields
}

NetworkSwitcher is a network FSM using for bootstrapping

func NewNetworkSwitcher

func NewNetworkSwitcher() (*NetworkSwitcher, error)

NewNetworkSwitcher creates new NetworkSwitcher

func (*NetworkSwitcher) Acquire

func (ns *NetworkSwitcher) Acquire(ctx context.Context)

Acquire increases lock counter and locks message bus if it wasn't lock before

func (*NetworkSwitcher) GetState

func (ns *NetworkSwitcher) GetState() core.NetworkState

GetState method returns current network state

func (*NetworkSwitcher) OnPulse

func (ns *NetworkSwitcher) OnPulse(ctx context.Context, pulse core.Pulse) error

OnPulse method checks current state and finds out reasons to update this state

func (*NetworkSwitcher) Release

func (ns *NetworkSwitcher) Release(ctx context.Context)

Release decreases lock counter and unlocks message bus if it wasn't lock by someone else