garbage

Documentation

Index

• type FragmentCollector
  • func NewFragmentCollector() FragmentCollector
  • func (fgb *FragmentCollector) Start(wg *sync.WaitGroup)
  • func (fgb *FragmentCollector) StartBlocking()

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