Documentation ¶
Index ¶
- type BufferPool
- type CollectiveEndpoint
- type ControlHandler
- type PeerToPeerEndpoint
- func (e *PeerToPeerEndpoint) Handle(conn connection.Connection) (int, error)
- func (e *PeerToPeerEndpoint) Request(a plan.Addr, version string, m connection.Message) (bool, error)
- func (e *PeerToPeerEndpoint) Save(name string, buf *kb.Vector) error
- func (e *PeerToPeerEndpoint) SaveVersion(version, name string, buf *kb.Vector) error
- type PingHandler
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BufferPool ¶
type CollectiveEndpoint ¶
type CollectiveEndpoint struct {
// contains filtered or unexported fields
}
func NewCollectiveEndpoint ¶
func NewCollectiveEndpoint() *CollectiveEndpoint
func (*CollectiveEndpoint) Handle ¶
func (e *CollectiveEndpoint) Handle(conn connection.Connection) (int, error)
Handle implements ConnHandler.Handle interface
func (*CollectiveEndpoint) Recv ¶
func (e *CollectiveEndpoint) Recv(a plan.Addr) connection.Message
func (*CollectiveEndpoint) RecvInto ¶
func (e *CollectiveEndpoint) RecvInto(a plan.Addr, m connection.Message) error
type ControlHandler ¶
type ControlHandler struct { }
func (*ControlHandler) Handle ¶
func (h *ControlHandler) Handle(conn connection.Connection) (int, error)
type PeerToPeerEndpoint ¶
type PeerToPeerEndpoint struct {
// contains filtered or unexported fields
}
func NewPeerToPeerEndpoint ¶
func NewPeerToPeerEndpoint(client *client.Client) *PeerToPeerEndpoint
func (*PeerToPeerEndpoint) Handle ¶
func (e *PeerToPeerEndpoint) Handle(conn connection.Connection) (int, error)
Handle implements ConnHandler.Handle interface
func (*PeerToPeerEndpoint) Request ¶
func (e *PeerToPeerEndpoint) Request(a plan.Addr, version string, m connection.Message) (bool, error)
func (*PeerToPeerEndpoint) Save ¶
func (e *PeerToPeerEndpoint) Save(name string, buf *kb.Vector) error
func (*PeerToPeerEndpoint) SaveVersion ¶
func (e *PeerToPeerEndpoint) SaveVersion(version, name string, buf *kb.Vector) error
type PingHandler ¶
type PingHandler struct { }
func (*PingHandler) Handle ¶
func (h *PingHandler) Handle(conn connection.Connection) (int, error)
Click to show internal directories.
Click to hide internal directories.