Versions in this module Expand all Collapse all v0 v0.1.0 Jun 1, 2022 Changes in this version + var ErrBusy = errors.New("failed to acquire events semaphore") + type Callback struct + Event EventCallback + HighestLamport func() idx.Lamport + type Config struct + EventsBufferLimit dag.Metric + EventsSemaphoreTimeout time.Duration + MaxTasks int + func DefaultConfig(scale cachescale.Func) Config + type EventCallback struct + CheckParentless func(e dag.Event, checked func(error)) + CheckParents func(e dag.Event, parents dag.Events) error + Exists func(hash.Event) bool + Get func(hash.Event) dag.Event + 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