Versions in this module Expand all Collapse all v0 v0.1.0 Jun 22, 2023 Changes in this version + type Entry struct + Item T + Verified *bool + type Pool struct + func NewPool[T any](maxItemsPerSender int) *Pool[T] + func (p *Pool[M]) Entries(seqNr uint64) map[commontypes.OracleID]*Entry[M] + func (p *Pool[M]) EntriesWithMinSeqNr() map[commontypes.OracleID]*Entry[M] + func (p *Pool[M]) ReapDelivered(deliveredSeqNr uint64) + func (p *Pool[M]) StoreVerified(seqNr uint64, sender commontypes.OracleID, verified bool) + func (p *Pool[T]) Put(seqNr uint64, sender commontypes.OracleID, item T) PutResult + type PutResult string + const PutResultAlreadyDelivered + const PutResultDuplicate + const PutResultFull + const PutResultOK
Go to main page