Documentation
¶
Index ¶
- Constants
- type DefaultUnknownManager
- type IntSyncer
- func (b *IntSyncer) AddSubscriberNewOutgoingMessageEvent(transport *transport.PhysicalCommunicator)
- func (b *IntSyncer) EventChannelPeerLeft() chan *og_interface.PeerLeftEvent
- func (b *IntSyncer) InitDefault()
- func (b *IntSyncer) Name() string
- func (b *IntSyncer) NewHeightDetectedEventChannel() chan *og_interface.NewHeightDetectedEvent
- func (b *IntSyncer) NewIncomingMessageEventChannel() chan *transport_interface.IncomingLetter
- func (b *IntSyncer) Start()
- func (b *IntSyncer) Stop()
Constants ¶
View Source
const MaxTolerantHeightDiff = 0 // ogsyncer will start syncing if myHeight + MaxTolerantHeightDiff < knownMaxPeerHeight
View Source
const SyncCheckIntervalSeconds int = 10 // max check interval for syncing a height
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DefaultUnknownManager ¶
func (*DefaultUnknownManager) Enqueue ¶
func (d *DefaultUnknownManager) Enqueue(task og_interface.Unknown)
type IntSyncer ¶
type IntSyncer struct {
Fetcher ogsyncer_interface.ResourceFetcher
// contains filtered or unexported fields
}
func (*IntSyncer) AddSubscriberNewOutgoingMessageEvent ¶
func (b *IntSyncer) AddSubscriberNewOutgoingMessageEvent(transport *transport.PhysicalCommunicator)
notify sending events
func (*IntSyncer) EventChannelPeerLeft ¶
func (b *IntSyncer) EventChannelPeerLeft() chan *og_interface.PeerLeftEvent
func (*IntSyncer) InitDefault ¶
func (b *IntSyncer) InitDefault()
func (*IntSyncer) NewHeightDetectedEventChannel ¶
func (b *IntSyncer) NewHeightDetectedEventChannel() chan *og_interface.NewHeightDetectedEvent
func (*IntSyncer) NewIncomingMessageEventChannel ¶
func (b *IntSyncer) NewIncomingMessageEventChannel() chan *transport_interface.IncomingLetter
Source Files
Click to show internal directories.
Click to hide internal directories.