oceanus

package
v0.0.0-...-9c04300 Latest Latest
Warning

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

Go to latest
Published: Apr 29, 2020 License: BSD-3-Clause Imports: 2 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrTimeout       = errors.New("timeout")
	ErrNodeNotFound  = errors.New("node not found")
	ErrInvalidSwitch = errors.New("invalid switch")
	ErrDisconnected  = errors.New("connection disconnected")
)

Functions

This section is empty.

Types

type ID

type ID = proto.NodeID

type Key

type Key = proto.NodeKey

type Pkg

type Pkg struct {
	IDs     []proto.NodeID
	Type    proto.NodeType
	Keys    []proto.NodeKey
	Headers proto.Headers
	Message interface{}
}

func NewPackage

func NewPackage() *Pkg

func (*Pkg) SetHeader

func (pack *Pkg) SetHeader(key string, value interface{}) *Pkg

func (*Pkg) SetHeaders

func (pack *Pkg) SetHeaders(headers map[string]interface{}) *Pkg

func (*Pkg) SetMessage

func (pack *Pkg) SetMessage(message interface{}) *Pkg

type Type

type Type = proto.NodeType

Jump to

Keyboard shortcuts

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