pool

Documentation

Index

• type Entry
• type Pool
  • 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[T]) Put(seqNr uint64, sender commontypes.OracleID, item T) PutResult
  • func (p *Pool[M]) ReapDelivered(deliveredSeqNr uint64)
  • func (p *Pool[M]) StoreVerified(seqNr uint64, sender commontypes.OracleID, verified bool)
• type PutResult

Types

type Entry

type Entry[T any] struct {
	Item     T
	Verified *bool
}

type Pool

type Pool[T any] struct {
	// contains filtered or unexported fields
}

func NewPool

func NewPool[T any](maxItemsPerSender int) *Pool[T]

func (*Pool[M]) Entries

func (p *Pool[M]) Entries(seqNr uint64) map[commontypes.OracleID]*Entry[M]

func (*Pool[M]) EntriesWithMinSeqNr

func (p *Pool[M]) EntriesWithMinSeqNr() map[commontypes.OracleID]*Entry[M]

func (*Pool[T]) Put

func (p *Pool[T]) Put(seqNr uint64, sender commontypes.OracleID, item T) PutResult

func (*Pool[M]) ReapDelivered

func (p *Pool[M]) ReapDelivered(deliveredSeqNr uint64)

func (*Pool[M]) StoreVerified

func (p *Pool[M]) StoreVerified(seqNr uint64, sender commontypes.OracleID, verified bool)

type PutResult

type PutResult string

const (
	PutResultOK               PutResult = "ok"
	PutResultDuplicate        PutResult = "duplicate"
	PutResultFull             PutResult = "pool is full for sender"
	PutResultAlreadyDelivered PutResult = "seqNr too low"
)