node

Documentation

Index

• Variables
• type Connection
  • func (conn *Connection) Close()
• type Entry
• type HostID
• type Manager
  • func NewManager() (*Manager, error)
  • func (man *Manager) Close()
  • func (man *Manager) StartClient(transport transport.ClientTransporter) error
  • func (man *Manager) StartServe(transporter transport.ServerTransporter) error
• type Node
• type RouteInfo

Variables

var ErrInvalidAction = errors.New("invalid action")

var ErrInvalidMetadata = errors.New("invalid metadata")

var ErrInvalidTarget = errors.New("invalid target")

Types

type Connection

type Connection struct {
	// contains filtered or unexported fields
}

func (*Connection) Close

func (conn *Connection) Close()

type Entry

type Entry struct {
	Index  int      `msgpack:"index"`
	Route  []HostID `msgpack:"route"`
	Action string   `msgpack:"action"`
}

type HostID

type HostID = uuid.UUID

type Manager

type Manager struct {
	HostId HostID

	Connections map[HostID]*Connection
	Nodes       map[HostID]*nodeImpl
	Callback    map[string]func([]byte, HostID) ([]byte, error)
	// contains filtered or unexported fields
}

func NewManager

func NewManager() (*Manager, error)

func (*Manager) Close

func (man *Manager) Close()

func (*Manager) StartClient

func (man *Manager) StartClient(transport transport.ClientTransporter) error

func (*Manager) StartServe

func (man *Manager) StartServe(transporter transport.ServerTransporter) error

type Node

type Node interface {
	Host() HostID
	WaitClose(ctx context.Context)
	Call(action string, arg []byte) ([]byte, error)
}

type RouteInfo

type RouteInfo struct {
	Host        HostID   `msgpack:"host"`
	Connections []HostID `msgpack:"connections"`
}