networkcoordinator

Documentation

Index

• func ExtractNodeRef(rawJSON []byte) (string, error)
• func ExtractRegisterNodeResponse(data []byte) ([]byte, error)
• type NetworkCoordinator
  • func New() (*NetworkCoordinator, error)
  • func (nc *NetworkCoordinator) Authorize(nodeRef core.RecordRef, seed []byte, signatureRaw []byte) (string, []core.NodeRole, error)
  • func (nc *NetworkCoordinator) RegisterNode(publicKey string, numberOfBootstrapNodes int, majorityRule int, roles []string, ...) ([]byte, error)
  • func (nc *NetworkCoordinator) Start(c core.Components) error
  • func (nc *NetworkCoordinator) Stop() error
  • func (nc *NetworkCoordinator) WriteActiveNodes(number core.PulseNumber, activeNodes []*core.ActiveNode) error

Functions

func ExtractNodeRef

func ExtractNodeRef(rawJSON []byte) (string, error)

ExtractNodeRef extract reference from json response

func ExtractRegisterNodeResponse

func ExtractRegisterNodeResponse(data []byte) ([]byte, error)

ExtractRegisterNodeResponse extracts response of RegisterNode

Types

type NetworkCoordinator

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

NetworkCoordinator encapsulates logic of network configuration

func New

func New() (*NetworkCoordinator, error)

New creates new NetworkCoordinator

func (*NetworkCoordinator) Authorize

func (nc *NetworkCoordinator) Authorize(nodeRef core.RecordRef, seed []byte, signatureRaw []byte) (string, []core.NodeRole, error)

Authorize authorizes node by verifying it's signature

func (*NetworkCoordinator) RegisterNode

func (nc *NetworkCoordinator) RegisterNode(publicKey string, numberOfBootstrapNodes int, majorityRule int, roles []string, ip string) ([]byte, error)

RegisterNode registers node in nodedomain

func (*NetworkCoordinator) Start

func (nc *NetworkCoordinator) Start(c core.Components) error

Start implements interface of Component

func (*NetworkCoordinator) Stop

func (nc *NetworkCoordinator) Stop() error

Stop implements interface of Component

func (*NetworkCoordinator) WriteActiveNodes

func (nc *NetworkCoordinator) WriteActiveNodes(number core.PulseNumber, activeNodes []*core.ActiveNode) error

WriteActiveNodes writes active nodes to ledger