udp

Documentation

Index

• type Network
  • func NewNetwork(addr string, enc network.Encoding) (*Network, error)
  • func (udpNet *Network) RegisterListener(listener h.Listener)
  • func (udpNet *Network) Send(identities []h.Identity, packet *h.Packet)
  • func (udpNet *Network) Stop()
  • func (udpNet *Network) Values() map[string]float64

Types

type Network

type Network struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

Network is a handel.Network implementation using UDP as its transport layer listens on 0.0.0.0

func NewNetwork

func NewNetwork(addr string, enc network.Encoding) (*Network, error)

NewNetwork creates Network baked by udp protocol

func (*Network) RegisterListener

func (udpNet *Network) RegisterListener(listener h.Listener)

RegisterListener registers listener for processing incoming packets

func (*Network) Send

func (udpNet *Network) Send(identities []h.Identity, packet *h.Packet)

Send sends a packet to supplied identities

func (*Network) Stop

func (udpNet *Network) Stop()

Stop closes

func (*Network) Values

func (udpNet *Network) Values() map[string]float64

Values implements the monitor.CounterMeasure interface