Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type FragmentCollector ¶
type FragmentCollector struct { Track chan *desc.LocalFragmentDesc Collect chan desc.IterumID // contains filtered or unexported fields }
FragmentCollector keeps track of all incoming and outgoing fragments It is responsible for clearing the actual data associated with the fragments once they are no longer needed
func NewFragmentCollector ¶
func NewFragmentCollector() FragmentCollector
NewFragmentCollector insatiates a FragmentCollector
func (*FragmentCollector) Start ¶
func (fgb *FragmentCollector) Start(wg *sync.WaitGroup)
Start asychronously calls StartBlocking via Gorouting
func (*FragmentCollector) StartBlocking ¶
func (fgb *FragmentCollector) StartBlocking()
StartBlocking listens on the two channels for new messages: one channel for fragments to track, and one for unneeded ones that can now be removed
Click to show internal directories.
Click to hide internal directories.