networkcoordinator

Documentation

Index

• func ExtractNodeRef(rawJSON []byte) (string, error)
• func ExtractRegisterNodeResponse(data []byte) ([]byte, error)
• func RandomUint64() uint64
• type NetworkCoordinator
  • func New() (*NetworkCoordinator, error)
  • func (nc *NetworkCoordinator) Authorize(ctx context.Context, nodeRef core.RecordRef, seed []byte, signatureRaw []byte) (string, []core.NodeRole, error)
  • func (nc *NetworkCoordinator) RegisterNode(ctx context.Context, publicKey string, numberOfBootstrapNodes int, ...) ([]byte, error)
  • func (nc *NetworkCoordinator) Start(ctx context.Context, c core.Components) error
  • func (nc *NetworkCoordinator) Stop(ctx context.Context) error
  • func (nc *NetworkCoordinator) WriteActiveNodes(ctx context.Context, number core.PulseNumber, activeNodes []*core.Node) 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

func RandomUint64

func RandomUint64() uint64

RandomUint64 generates random uint64

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(ctx context.Context, 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(ctx context.Context, publicKey string, numberOfBootstrapNodes int, majorityRule int, roles []string, ip string) ([]byte, error)

RegisterNode registers node in nodedomain

func (*NetworkCoordinator) Start

func (nc *NetworkCoordinator) Start(ctx context.Context, c core.Components) error

Start implements interface of Component

func (*NetworkCoordinator) Stop

func (nc *NetworkCoordinator) Stop(ctx context.Context) error

Stop implements interface of Component

func (*NetworkCoordinator) WriteActiveNodes

func (nc *NetworkCoordinator) WriteActiveNodes(ctx context.Context, number core.PulseNumber, activeNodes []*core.Node) error

WriteActiveNodes writes active nodes to ledger