handler

package
Version: v0.2.5 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 3, 2021 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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 (*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)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL