udp

package
v1.1.1-0...-40efbf4 Latest Latest
Warning

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

Go to latest
Published: May 5, 2022 License: GPL-3.0 Imports: 13 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewFromMap

func NewFromMap(node api.Node, t map[string]interface{}) api.Transport

NewFromMap : Makes a new instance of this transport module from a map of arguments (for deserialization support)

Types

type Module

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

Module : UDP Implementation of a Transport module

func New

func New(node api.Node) *Module

New : Makes a new instance of this transport module

func (*Module) ByteLimit

func (m *Module) ByteLimit() int64

ByteLimit - get limit on bytes per bundle for this transport

func (*Module) IsRunning

func (m *Module) IsRunning() bool

IsRunning - returns true if this node is running

func (*Module) Listen

func (m *Module) Listen(listen string, adminMode bool)

Listen : opens a UDP socket and listens

func (*Module) MarshalJSON

func (m *Module) MarshalJSON() (b []byte, e error)

MarshalJSON : Create a serialied representation of the config of this module

func (*Module) Name

func (m *Module) Name() string

Name : Returns name of module

func (*Module) RPC

func (m *Module) RPC(host string, method api.Action, args ...interface{}) (interface{}, error)

RPC : transmit data via UDP

func (*Module) SetByteLimit

func (m *Module) SetByteLimit(limit int64)

SetByteLimit - set limit on bytes per bundle for this transport

func (*Module) Stop

func (m *Module) Stop()

Stop : Stops module

Jump to

Keyboard shortcuts

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