control

Documentation

Index

• Constants
• type State
  • func New(cfg *pod.Config, stateCfg *state.Config, node *chainrpc.Node, ...) (s *State)
  • func (s *State) Advertise()
  • func (s *State) GetMsgBlockTemplate(prev *util.Block, addr util.Address) (mbt *templates.Message, e error)
  • func (s *State) GetNewAddressFromMiningAddrs() (addr util.Address, e error)
  • func (s *State) GetNewAddressFromWallet() (addr util.Address, e error)
  • func (s *State) Run()
  • func (s *State) Shutdown()
  • func (s *State) Start()
  • func (s *State) Stop()

Constants

const (
	MaxDatagramSize      = 8192
	UDP4MulticastAddress = "224.0.0.1:11049"
	BufferSize           = 4096
)

Types

type State

type State struct {
	// contains filtered or unexported fields
}

State stores the state of the controller

func New

func New(
	cfg *pod.Config,
	stateCfg *state.Config,
	node *chainrpc.Node,
	rpcServer *chainrpc.Server,
	otherNodeCount *atomic.Int32,
	mempoolUpdateChan qu.C,
	uuid uint64,
	killall qu.C,
) (s *State)

New creates a new controller

func (*State) Advertise

func (s *State) Advertise()

func (*State) GetMsgBlockTemplate

func (s *State) GetMsgBlockTemplate(prev *util.Block, addr util.Address) (mbt *templates.Message, e error)

GetMsgBlockTemplate gets a Message building on given block paying to a given address

func (*State) GetNewAddressFromMiningAddrs

func (s *State) GetNewAddressFromMiningAddrs() (addr util.Address, e error)

GetNewAddressFromMiningAddrs tries to get an address from the mining addresses list in the configuration file

func (*State) GetNewAddressFromWallet

func (s *State) GetNewAddressFromWallet() (addr util.Address, e error)

GetNewAddressFromWallet gets a new address from the wallet if it is connected, or returns an error

func (*State) Run

func (s *State) Run()

Run must be started as a goroutine, central routing for the business of the controller

For increased simplicity, every type of work runs in one thread, only signalling from background goroutines to trigger state changes.

func (*State) Shutdown

func (s *State) Shutdown()

Shutdown the controller

func (*State) Start

func (s *State) Start()

Start up the controller

func (*State) Stop

func (s *State) Stop()

Stop the controller