servicenetwork

Documentation

Index

• func NewConsensus(network network.HostNetwork) consensus.Processor
• func NewHostNetwork(conf configuration.Configuration, certificate core.Certificate, ...) (network.HostNetwork, error)
• func NewNetworkController(conf configuration.Configuration, network network.HostNetwork) (network.Controller, error)
• type ServiceNetwork
  • func NewServiceNetwork(conf configuration.Configuration) (*ServiceNetwork, error)
  • func (n *ServiceNetwork) GetAddress() string
  • func (n *ServiceNetwork) GetHostNetwork() (hosthandler.HostHandler, hosthandler.Context)
  • func (n *ServiceNetwork) GetNodeID() core.RecordRef
  • func (n *ServiceNetwork) GetPrivateKey() *ecdsa.PrivateKey
  • func (n *ServiceNetwork) RemoteProcedureRegister(name string, method core.RemoteProcedure)
  • func (n *ServiceNetwork) SendCascadeMessage(data core.Cascade, method string, msg core.SignedMessage) error
  • func (n *ServiceNetwork) SendMessage(nodeID core.RecordRef, method string, msg core.SignedMessage) ([]byte, error)
  • func (n *ServiceNetwork) Start(ctx context.Context, components core.Components) error
  • func (n *ServiceNetwork) Stop(ctx context.Context) error

Functions

func NewConsensus

func NewConsensus(network network.HostNetwork) consensus.Processor

func NewHostNetwork

func NewHostNetwork(conf configuration.Configuration, certificate core.Certificate, pulseCallback network.OnPulse) (network.HostNetwork, error)

NewHostNetwork create new HostNetwork. Certificate in new network should be removed and pulseCallback should be passed to NewNetworkController.

func NewNetworkController

func NewNetworkController(conf configuration.Configuration, network network.HostNetwork) (network.Controller, error)

NewNetworkController create new network.Controller. In new network it should read conf.

Types

type ServiceNetwork

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

ServiceNetwork is facade for network.

func NewServiceNetwork

func NewServiceNetwork(conf configuration.Configuration) (*ServiceNetwork, error)

NewServiceNetwork returns a new ServiceNetwork.

func (*ServiceNetwork) GetAddress

func (n *ServiceNetwork) GetAddress() string

GetAddress returns host public address.

func (*ServiceNetwork) GetHostNetwork

func (n *ServiceNetwork) GetHostNetwork() (hosthandler.HostHandler, hosthandler.Context)

GetHostNetwork returns pointer to host network layer(DHT), temp method, refactoring needed TODO: replace with GetNetworkHelper that returns a component with all needed data for interactive/rest API

func (*ServiceNetwork) GetNodeID

func (n *ServiceNetwork) GetNodeID() core.RecordRef

GetNodeID returns current node id.

func (*ServiceNetwork) GetPrivateKey

func (n *ServiceNetwork) GetPrivateKey() *ecdsa.PrivateKey

GetPrivateKey returns a private key. TODO: remove, use helper functions from certificate instead

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.SignedMessage) 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.SignedMessage) ([]byte, error)

SendMessage sends a message from MessageBus.

func (*ServiceNetwork) Start

func (n *ServiceNetwork) Start(ctx context.Context, components core.Components) error

Start implements core.Component

func (*ServiceNetwork) Stop

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

Stop implements core.Component