hostnetwork

Documentation

Index

• func NewConsensusNetwork(address, nodeID string, shortID core.ShortNodeID, ...) (network.ConsensusNetwork, error)
• func NewHostTransport(transport network.InternalTransport, resolver network.RoutingTable) network.HostNetwork
• func NewInternalTransport(conf configuration.Configuration) (network.InternalTransport, error)
• type Builder
  • func (b *Builder) Build() network.Request
  • func (b *Builder) Data(data interface{}) network.RequestBuilder
  • func (b *Builder) GetData() interface{}
  • func (b *Builder) GetSender() core.RecordRef
  • func (b *Builder) GetSenderHost() *host.Host
  • func (b *Builder) GetType() types.PacketType
  • func (b *Builder) Type(packetType types.PacketType) network.RequestBuilder
• type TransportResolvable
  • func (tr *TransportResolvable) BuildResponse(request network.Request, responseData interface{}) network.Response
  • func (tr *TransportResolvable) GetNodeID() core.RecordRef
  • func (tr *TransportResolvable) NewRequestBuilder() network.RequestBuilder
  • func (tr *TransportResolvable) PublicAddress() string
  • func (tr *TransportResolvable) RegisterRequestHandler(t types.PacketType, handler network.RequestHandler)
  • func (tr *TransportResolvable) SendRequest(request network.Request, receiver core.RecordRef) (network.Future, error)
  • func (tr *TransportResolvable) Start(ctx context.Context)
  • func (tr *TransportResolvable) Stop()

Functions

func NewConsensusNetwork

func NewConsensusNetwork(address, nodeID string, shortID core.ShortNodeID,
	resolver network.RoutingTable) (network.ConsensusNetwork, error)

func NewHostTransport

func NewHostTransport(transport network.InternalTransport, resolver network.RoutingTable) network.HostNetwork

func NewInternalTransport

func NewInternalTransport(conf configuration.Configuration) (network.InternalTransport, error)

Types

type Builder

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

Builder implements RequestBuilder interface

func (*Builder) Build

func (b *Builder) Build() network.Request

func (*Builder) Data

func (b *Builder) Data(data interface{}) network.RequestBuilder

func (*Builder) GetData

func (b *Builder) GetData() interface{}

func (*Builder) GetSender

func (b *Builder) GetSender() core.RecordRef

func (*Builder) GetSenderHost

func (b *Builder) GetSenderHost() *host.Host

func (*Builder) GetType

func (b *Builder) GetType() types.PacketType

func (*Builder) Type

func (b *Builder) Type(packetType types.PacketType) network.RequestBuilder

type TransportResolvable

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

TransportResolvable is implementation of HostNetwork interface that is capable of address resolving.

func (*TransportResolvable) BuildResponse

func (tr *TransportResolvable) BuildResponse(request network.Request, responseData interface{}) network.Response

BuildResponse create response to an incoming request with Data set to responseData.

func (*TransportResolvable) GetNodeID

func (tr *TransportResolvable) GetNodeID() core.RecordRef

GetNodeID get current node ID.

func (*TransportResolvable) NewRequestBuilder

func (tr *TransportResolvable) NewRequestBuilder() network.RequestBuilder

NewRequestBuilder create packet Builder for an outgoing request with sender set to current node.

func (*TransportResolvable) PublicAddress

func (tr *TransportResolvable) PublicAddress() string

PublicAddress returns public address that can be published for all nodes.

func (*TransportResolvable) RegisterRequestHandler

func (tr *TransportResolvable) RegisterRequestHandler(t types.PacketType, handler network.RequestHandler)

RegisterRequestHandler register a handler function to process incoming requests of a specific type.

func (*TransportResolvable) SendRequest

func (tr *TransportResolvable) SendRequest(request network.Request, receiver core.RecordRef) (network.Future, error)

SendRequest send request to a remote node.

func (*TransportResolvable) Start

func (tr *TransportResolvable) Start(ctx context.Context)

Start listening to network requests.

func (*TransportResolvable) Stop

func (tr *TransportResolvable) Stop()

Stop listening to network requests.