transporter

package
v0.0.0-...-10f83ba Latest Latest
Warning

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

Go to latest
Published: Jun 2, 2014 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type DummyTransporter

type DummyTransporter struct {
	Chs        []chan message.Message
	Self       uint8
	FastQuorum uint8
	All        uint8
}

func NewDummyTR

func NewDummyTR(self uint8, size int) *DummyTransporter

func (*DummyTransporter) Broadcast

func (tr *DummyTransporter) Broadcast(msg message.Message)

func (*DummyTransporter) MulticastFastquorum

func (tr *DummyTransporter) MulticastFastquorum(msg message.Message)

func (*DummyTransporter) RegisterChannel

func (tr *DummyTransporter) RegisterChannel(ch chan message.Message)

func (*DummyTransporter) RegisterChannels

func (tr *DummyTransporter) RegisterChannels(chs []chan message.Message)

only for dummyTR

func (*DummyTransporter) Send

func (tr *DummyTransporter) Send(to uint8, msg message.Message)

non-block

func (*DummyTransporter) Start

func (tr *DummyTransporter) Start() error

func (*DummyTransporter) Stop

func (tr *DummyTransporter) Stop()

type UDPTransporter

type UDPTransporter struct {
	Addrs      []*net.UDPAddr
	Self       uint8
	FastQuorum uint8
	All        uint8
	Conns      []*net.UDPConn
	// contains filtered or unexported fields
}

func NewUDPTransporter

func NewUDPTransporter(addrStrs []string,
	self uint8, size int) (*UDPTransporter, error)

func (*UDPTransporter) Broadcast

func (nt *UDPTransporter) Broadcast(msg message.Message)

func (*UDPTransporter) MulticastFastquorum

func (nt *UDPTransporter) MulticastFastquorum(msg message.Message)

func (*UDPTransporter) RegisterChannel

func (nt *UDPTransporter) RegisterChannel(ch chan message.Message)

func (*UDPTransporter) Send

func (nt *UDPTransporter) Send(to uint8, msg message.Message)

func (*UDPTransporter) Start

func (nt *UDPTransporter) Start() error

func (*UDPTransporter) Stop

func (nt *UDPTransporter) Stop()

Jump to

Keyboard shortcuts

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