queue

Oct 2, 2025

Changes in this version

+ type PayoutTimeoutQueue struct

+ func NewPayoutTimeoutQueue(builder *collections.SchemaBuilder) *PayoutTimeoutQueue

+ func (p *PayoutTimeoutQueue) Dequeue(ctx context.Context, periodTimeout int64, vaultAddr sdk.AccAddress) error

+ func (p *PayoutTimeoutQueue) Enqueue(ctx context.Context, periodTimeout int64, vaultAddr sdk.AccAddress) error

+ func (p *PayoutTimeoutQueue) RemoveAllForVault(ctx context.Context, vaultAddr sdk.AccAddress) error

+ func (p *PayoutTimeoutQueue) Walk(ctx context.Context, ...) error

+ func (p *PayoutTimeoutQueue) WalkDue(ctx context.Context, nowSec int64, ...) error

+ type PendingSwapOutIndexes struct

+ ByID *indexes.Unique[uint64, collections.Triple[int64, uint64, sdk.AccAddress], types.PendingSwapOut]

+ ByVault *indexes.Multi[sdk.AccAddress, collections.Triple[int64, uint64, sdk.AccAddress], types.PendingSwapOut]

+ func NewPendingSwapOutIndexes(sb *collections.SchemaBuilder) PendingSwapOutIndexes

+ func (i PendingSwapOutIndexes) IndexesList() ...

+ type PendingSwapOutQueue struct

+ IndexedMap *collections.IndexedMap[collections.Triple[int64, uint64, sdk.AccAddress], types.PendingSwapOut, PendingSwapOutIndexes]

+ Sequence collections.Sequence

+ func NewPendingSwapOutQueue(builder *collections.SchemaBuilder, cdc codec.BinaryCodec) *PendingSwapOutQueue

+ func (p *PendingSwapOutQueue) Dequeue(ctx context.Context, timestamp int64, vault sdk.AccAddress, id uint64) error

+ func (p *PendingSwapOutQueue) Enqueue(ctx context.Context, pendingTime int64, req *types.PendingSwapOut) (uint64, error)

+ func (p *PendingSwapOutQueue) ExpediteSwapOut(ctx context.Context, id uint64) error

+ func (p *PendingSwapOutQueue) Export(ctx context.Context) (*types.PendingSwapOutQueue, error)

+ func (p *PendingSwapOutQueue) GetByID(ctx context.Context, id uint64) (int64, *types.PendingSwapOut, error)

+ func (p *PendingSwapOutQueue) Import(ctx context.Context, genQueue *types.PendingSwapOutQueue) error

+ func (p *PendingSwapOutQueue) Walk(ctx context.Context, ...) error

+ func (p *PendingSwapOutQueue) WalkByVault(ctx context.Context, vaultAddr sdk.AccAddress, ...) error

+ func (p *PendingSwapOutQueue) WalkDue(ctx context.Context, now int64, ...) error