garbage

package
Version: v0.4.0 Latest Latest
Warning

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

Go to latest
Published: Jul 24, 2020 License: MIT Imports: 5 Imported by: 0

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 (fgarbage *FragmentCollector) Start(wg *sync.WaitGroup)

Start asychronously calls StartBlocking via Gorouting

func (*FragmentCollector) StartBlocking

func (fgarbage *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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
t or T : Toggle theme light dark auto
y or Y : Canonical URL