servicenetwork

Documentation

Index

• type ServiceNetwork
  • func NewServiceNetwork(hostConf configuration.HostNetwork, nodeConf configuration.NodeNetwork) (*ServiceNetwork, error)
  • func (network *ServiceNetwork) GetAddress() string
  • func (network *ServiceNetwork) GetHostNetwork() (hosthandler.HostHandler, hosthandler.Context)
  • func (network *ServiceNetwork) GetNodeID() core.RecordRef
  • func (network *ServiceNetwork) RemoteProcedureRegister(name string, method core.RemoteProcedure)
  • func (network *ServiceNetwork) SendCascadeEvent(data core.Cascade, method string, event core.Event) error
  • func (network *ServiceNetwork) SendEvent(nodeID core.RecordRef, method string, event core.Event) ([]byte, error)
  • func (network *ServiceNetwork) Start(components core.Components) error
  • func (network *ServiceNetwork) Stop() error

Types

type ServiceNetwork

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

ServiceNetwork is facade for network.

func NewServiceNetwork

func NewServiceNetwork(
	hostConf configuration.HostNetwork,
	nodeConf configuration.NodeNetwork,
) (*ServiceNetwork, error)

NewServiceNetwork returns a new ServiceNetwork.

func (*ServiceNetwork) GetAddress

func (network *ServiceNetwork) GetAddress() string

GetAddress returns host public address.

func (*ServiceNetwork) GetHostNetwork

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

GetHostNetwork returns pointer to host network layer(DHT), temp method, refactoring needed

func (*ServiceNetwork) GetNodeID

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

GetNodeID returns current node id.

func (*ServiceNetwork) RemoteProcedureRegister

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

RemoteProcedureRegister registers procedure for remote call on this host.

func (*ServiceNetwork) SendCascadeEvent

func (network *ServiceNetwork) SendCascadeEvent(data core.Cascade, method string, event core.Event) error

SendCascadeEvent sends a event from EventBus to a cascade of nodes. Event reference is ignored

func (*ServiceNetwork) SendEvent

func (network *ServiceNetwork) SendEvent(nodeID core.RecordRef, method string, event core.Event) ([]byte, error)

SendEvent sends a event from EventBus.

func (*ServiceNetwork) Start

func (network *ServiceNetwork) Start(components core.Components) error

Start implements core.Component

func (*ServiceNetwork) Stop

func (network *ServiceNetwork) Stop() error

Stop implements core.Component