servicenetwork

Documentation

Index

• type ServiceNetwork
  • func NewServiceNetwork(conf configuration.Configuration, scheme core.PlatformCryptographyScheme, ...) (*ServiceNetwork, error)
  • func (n *ServiceNetwork) HandlePulse(ctx context.Context, pulse core.Pulse)
  • func (n *ServiceNetwork) Init(ctx context.Context) error
  • func (n *ServiceNetwork) RemoteProcedureRegister(name string, method core.RemoteProcedure)
  • func (n *ServiceNetwork) SendCascadeMessage(data core.Cascade, method string, msg core.Parcel) error
  • func (n *ServiceNetwork) SendMessage(nodeID core.RecordRef, method string, msg core.Parcel) ([]byte, error)
  • func (n *ServiceNetwork) Start(ctx context.Context) error
  • func (n *ServiceNetwork) Stop(ctx context.Context) error

Types

type ServiceNetwork

type ServiceNetwork struct {

	// dependencies
	CertificateManager  core.CertificateManager         `inject:""`
	NodeNetwork         core.NodeNetwork                `inject:""`
	PulseManager        core.PulseManager               `inject:""`
	PulseStorage        core.PulseStorage               `inject:""`
	CryptographyService core.CryptographyService        `inject:""`
	NetworkCoordinator  core.NetworkCoordinator         `inject:""`
	ArtifactManager     core.ArtifactManager            `inject:""`
	CryptographyScheme  core.PlatformCryptographyScheme `inject:""`
	NodeKeeper          network.NodeKeeper              `inject:""`
	NetworkSwitcher     core.NetworkSwitcher            `inject:""`

	// subcomponents
	PhaseManager     phases.PhaseManager      // `inject:""`
	MerkleCalculator merkle.Calculator        // `inject:""`
	ConsensusNetwork network.ConsensusNetwork // `inject:""`
	PulseHandler     network.PulseHandler
	Communicator     phases.Communicator
	// contains filtered or unexported fields
}

ServiceNetwork is facade for network.

func NewServiceNetwork

func NewServiceNetwork(conf configuration.Configuration, scheme core.PlatformCryptographyScheme, isGenesis bool) (*ServiceNetwork, error)

NewServiceNetwork returns a new ServiceNetwork.

func (*ServiceNetwork) HandlePulse

func (n *ServiceNetwork) HandlePulse(ctx context.Context, pulse core.Pulse)

func (*ServiceNetwork) Init

func (n *ServiceNetwork) Init(ctx context.Context) error

Start implements component.Initer

func (*ServiceNetwork) RemoteProcedureRegister

func (n *ServiceNetwork) RemoteProcedureRegister(name string, method core.RemoteProcedure)

RemoteProcedureRegister registers procedure for remote call on this host.

func (*ServiceNetwork) SendCascadeMessage

func (n *ServiceNetwork) SendCascadeMessage(data core.Cascade, method string, msg core.Parcel) error

SendCascadeMessage sends a message from MessageBus to a cascade of nodes

func (*ServiceNetwork) SendMessage

func (n *ServiceNetwork) SendMessage(nodeID core.RecordRef, method string, msg core.Parcel) ([]byte, error)

SendMessage sends a message from MessageBus.

func (*ServiceNetwork) Start

func (n *ServiceNetwork) Start(ctx context.Context) error

Start implements component.Starter

func (*ServiceNetwork) Stop

func (n *ServiceNetwork) Stop(ctx context.Context) error

Stop implements core.Component