transporter

Documentation

Index

• type DummyTransporter
  • func NewDummyTR(self uint8, size int) *DummyTransporter
  • func (tr *DummyTransporter) Broadcast(msg message.Message)
  • func (tr *DummyTransporter) MulticastFastquorum(msg message.Message)
  • func (tr *DummyTransporter) RegisterChannel(ch chan message.Message)
  • func (tr *DummyTransporter) RegisterChannels(chs []chan message.Message)
  • func (tr *DummyTransporter) Send(to uint8, msg message.Message)
  • func (tr *DummyTransporter) Start() error
  • func (tr *DummyTransporter) Stop()
• type UDPTransporter
  • func NewUDPTransporter(addrStrs []string, self uint8, size int) (*UDPTransporter, error)
  • func (nt *UDPTransporter) Broadcast(msg message.Message)
  • func (nt *UDPTransporter) MulticastFastquorum(msg message.Message)
  • func (nt *UDPTransporter) RegisterChannel(ch chan message.Message)
  • func (nt *UDPTransporter) Send(to uint8, msg message.Message)
  • func (nt *UDPTransporter) Start() error
  • func (nt *UDPTransporter) Stop()

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()