subpubtransport

Documentation

Index

• type SubPubContext
  • func (sc *SubPubContext) ConnectionType() string
  • func (sc *SubPubContext) Send(msg transports.Message) (err error)
• type SubPubHandle
  • func (s *SubPubHandle) AddNamespace(namespace string) error
  • func (s *SubPubHandle) AddPeer(peer string) error
  • func (s *SubPubHandle) Address() string
  • func (s *SubPubHandle) ConnectionType() string
  • func (p *SubPubHandle) Init(c *transports.Connection) error
  • func (s *SubPubHandle) Listen(reciever chan<- transports.Message)
  • func (s *SubPubHandle) Send(msg transports.Message) error
  • func (s *SubPubHandle) SendUnicast(address string, msg transports.Message) error
  • func (s *SubPubHandle) SetBootnodes(bootnodes []string)
  • func (s *SubPubHandle) String() string

Types

type SubPubContext

type SubPubContext struct {
	Sp     *SubPubHandle
	PeerID string
}

func (*SubPubContext) ConnectionType

func (sc *SubPubContext) ConnectionType() string

func (*SubPubContext) Send

func (sc *SubPubContext) Send(msg transports.Message) (err error)

type SubPubHandle

type SubPubHandle struct {
	Conn      *transports.Connection
	SubPub    *subpub.SubPub
	BootNodes []string
}

func (*SubPubHandle) AddNamespace

func (s *SubPubHandle) AddNamespace(namespace string) error

func (*SubPubHandle) AddPeer

func (s *SubPubHandle) AddPeer(peer string) error

func (*SubPubHandle) Address

func (s *SubPubHandle) Address() string

func (*SubPubHandle) ConnectionType

func (s *SubPubHandle) ConnectionType() string

func (*SubPubHandle) Init

func (p *SubPubHandle) Init(c *transports.Connection) error

func (*SubPubHandle) Listen

func (s *SubPubHandle) Listen(reciever chan<- transports.Message)

func (*SubPubHandle) Send

func (s *SubPubHandle) Send(msg transports.Message) error

func (*SubPubHandle) SendUnicast

func (s *SubPubHandle) SendUnicast(address string, msg transports.Message) error

func (*SubPubHandle) SetBootnodes

func (s *SubPubHandle) SetBootnodes(bootnodes []string)

func (*SubPubHandle) String

func (s *SubPubHandle) String() string