Versions in this module Expand all Collapse all v0 v0.5.10 Aug 9, 2023 v0.5.9 Aug 4, 2023 Changes in this version + const DefaultLatencyResolution + type FilterFunc func(r *Request) bool + type Queue interface + AvgLatency func() int64 + Empty func() bool + Enqueue func(*Request) (enqueued bool) + EnqueuePending func(discardOlderThan time.Duration) (queued int) + Filter func(f FilterFunc) + IsPending func(hash hornet.Hash) bool + IsProcessing func(hash hornet.Hash) bool + IsQueued func(hash hornet.Hash) bool + Next func() *Request + Peek func() *Request + Processed func(hash hornet.Hash) *Request + Received func(hash hornet.Hash) *Request + Requests func() (queued []*Request, pending []*Request, processing []*Request) + Size func() (queued int, pending int, processing int) + func New(latencyResolution ...int32) Queue + type Request struct + EnqueueTime time.Time + Hash hornet.Hash + MilestoneIndex milestone.Index + PreventDiscard bool
Go to main page