Versions in this module Expand all Collapse all v0 v0.1.0 May 4, 2022 Changes in this version + var ErrBusy = errors.New("failed to acquire events semaphore") + type Callback struct + Event EventCallback + HighestLamport func() idx.Lamport + PeerMisbehaviour func(peer string, err error) bool + type Config struct + EventsBufferLimit dag.Metric + EventsSemaphoreTimeout time.Duration + MaxUnorderedInsertions int + func DefaultConfig(scale cachescale.Func) Config + func (c Config) MaxTasks() int + type EventCallback struct + CheckParentless func(tasks []queuedcheck.EventTask, checked func(res []queuedcheck.EventTask)) + CheckParents func(e dag.Event, parents dag.Events) error + Exists func(hash.Event) bool + Get func(hash.Event) dag.Event + OnlyInterested func(ids hash.Events) hash.Events + Process func(e dag.Event) error + Released func(e dag.Event, peer string, err error) + type Processor struct + func New(eventsSemaphore *datasemaphore.DataSemaphore, cfg Config, callback Callback) *Processor + func (f *Processor) Clear() + func (f *Processor) Enqueue(peer string, events dag.Events, ordered bool, ...) error + func (f *Processor) IsBuffered(id hash.Event) bool + func (f *Processor) Overloaded() bool + func (f *Processor) Start() + func (f *Processor) Stop() + func (f *Processor) TasksCount() int + func (f *Processor) TotalBuffered() dag.Metric
Go to main page