dnet

Documentation

Index

• Constants
• type Controller
  • func NewController(application_controller common_types.ApplicationControllerI, ...) (*Controller, error)
  • func (self *Controller) GetInnodeRPC(calling_app_name *common_types.ModuleName) (*rpc.Client, error)
  • func (self *Controller) PossiblyNodeDiscoveredNotificationReceptor(module_name *common_types.ModuleName, address common_types.NetworkAddress) error
  • func (self *Controller) ServeConnection(who *common_types.Address, conn net.Conn)
  • func (self *Controller) TestOutgoingConnection(conn net.Conn) error
• type InnodeRPC
  • func NewInnodeRPC(controller *Controller, calling_app_name *common_types.ModuleName) *InnodeRPC
  • func (self *InnodeRPC) DiscoveredPossibleNodeMayBeProbe(arg interface{}, res interface{}) error

Constants

const DNET_UNIVERSAL_APPLICATION_NAME = "localDNet"

This is for cases when DNet (as a Controller), whises to access module instance or theyr some other parts. In this case, DNet controller will be presented as DNET_UNIVERSAL_APPLICATION_NAME

Types

type Controller

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

func NewController

func NewController(
	application_controller common_types.ApplicationControllerI,
	logger *gologger.Logger,
) (
	*Controller,
	error,
)

func (*Controller) GetInnodeRPC

func (self *Controller) GetInnodeRPC(calling_app_name *common_types.ModuleName) (
	*rpc.Client,
	error,
)

func (*Controller) PossiblyNodeDiscoveredNotificationReceptor

func (self *Controller) PossiblyNodeDiscoveredNotificationReceptor(
	module_name *common_types.ModuleName,
	address common_types.NetworkAddress,
) error

func (*Controller) ServeConnection

func (self *Controller) ServeConnection(
	who *common_types.Address,
	conn net.Conn,
)

func (*Controller) TestOutgoingConnection

func (self *Controller) TestOutgoingConnection(conn net.Conn) error

type InnodeRPC

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

func NewInnodeRPC

func NewInnodeRPC(
	controller *Controller,
	calling_app_name *common_types.ModuleName,
) *InnodeRPC

func (*InnodeRPC) DiscoveredPossibleNodeMayBeProbe

func (self *InnodeRPC) DiscoveredPossibleNodeMayBeProbe(
	arg interface{},
	res interface{},
) error