Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Acceptor ¶
type Acceptor struct { //config Cfg *util.Config //Status Status uint //chosen inet Inet net.Interface //listening port ListenPort uint //Listener Listener net.Listener //channel used to serve incoming TCP connections EnteringChan chan net.Conn //channel used for generic incoming requests RequestChan chan util.Request // contains filtered or unexported fields }
func (*Acceptor) WaitForStatus ¶
type MCastHelper ¶
type MCastHelper struct { //config Cfg *util.Config //Status Status uint //Node ID NodeID uint64 //chosen inet Inet net.Interface //channels used to receive Alive messages (UDP) AliveChanIncoming chan []byte //channels used to receive Incremental messages (UDP) IncrementalChanIncoming chan []byte //channels used to send UPD messages MCastChanOutgoing chan []byte //channel used for generic incoming requests RequestChan chan util.Request // contains filtered or unexported fields }
func (*MCastHelper) Init ¶
func (m *MCastHelper) Init() error
func (*MCastHelper) Run ¶
func (m *MCastHelper) Run() error
func (*MCastHelper) WaitForStatus ¶
func (m *MCastHelper) WaitForStatus(status uint) error
type Streamer ¶
func (*Streamer) DialAndReceiveSnapshotBuffer ¶
Click to show internal directories.
Click to hide internal directories.