handler

Documentation

Index

• type BufferPool
• type CollectiveEndpoint
  • func NewCollectiveEndpoint() *CollectiveEndpoint
  • func (e *CollectiveEndpoint) Handle(conn connection.Connection) (int, error)
  • func (e *CollectiveEndpoint) Recv(a plan.Addr) connection.Message
  • func (e *CollectiveEndpoint) RecvInto(a plan.Addr, m connection.Message) error
• type ControlHandler
  • func (h *ControlHandler) Handle(conn connection.Connection) (int, error)
• type PeerToPeerEndpoint
  • func NewPeerToPeerEndpoint(client *client.Client) *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
  • func (h *PingHandler) Handle(conn connection.Connection) (int, error)

Types

type BufferPool

type BufferPool struct {
	sync.Mutex
	// contains filtered or unexported fields
}

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)