Versions in this module Expand all Collapse all v0 v0.1.0 Nov 3, 2020 Changes in this version + type Connection struct + func (c *Connection) GetDestAddress() string + func (c *Connection) GetMessage() string + func (c *Connection) GetSourceAddress() string + func (c *Connection) SendRequest(action string, content []byte, callback func(byte []byte)) + type DataFormat struct + Action string + Content []byte + Dest string + Id uint64 + Source string + type ReplyChannel struct + func (c *ReplyChannel) GetDestAddress() string + func (c *ReplyChannel) GetSourceAddress() string + func (c *ReplyChannel) SendMessage(action string, content []byte) (n int, err error) + type Transport struct + LocalAddress string + LocalNodeId string + RequestHandlers map[string]transport.RequestHandler + SeedHosts []string + func NewTransport(port int, seedHost string, nodeId string) *Transport + func (t *Transport) GetHandler(action string) transport.RequestHandler + func (t *Transport) GetLocalAddress() string + func (t *Transport) GetNodeId() string + func (t *Transport) GetSeedHosts() []string + func (t *Transport) OpenConnection(address string, callback func(conn transport.Connection)) + func (t *Transport) Register(action string, handler transport.RequestHandler) + func (t *Transport) Start(port int)