bqueue

Jul 18, 2025

Changes in this version

type OperationMode

+ func (i OperationMode) String() string

Jun 10, 2025

Changes in this version

type Queue

+ func (bq *Queue[Q]) Cap() int

Feb 11, 2025

Changes in this version

+ type Indexable interface

+ GetIndex func() uint32

type Queue

+ func (bq *Queue[Q]) Put(element Q) error

+ type Queueable interface

+ type Queuer interface

+ AddItem func(Q) error

+ AddItems func(...Q) error

+ Height func() uint32

Dec 3, 2024

Changes in this version

+ const DefaultCacheSize

+ type OperationMode byte

+ const Blocking

+ const NonBlocking

Mar 17, 2023

Changes in this version

+ const CacheSize

+ type Blockqueuer interface

+ AddBlock func(block *block.Block) error

+ AddHeaders func(...*block.Header) error

+ BlockHeight func() uint32

+ type Queue struct

+ func New(bc Blockqueuer, log *zap.Logger, relayer func(*block.Block), ...) *Queue

+ func (bq *Queue) Discard()

+ func (bq *Queue) LastQueued() (uint32, int)

+ func (bq *Queue) PutBlock(block *block.Block) error

+ func (bq *Queue) Run()