Versions in this module Expand all Collapse all v1 v1.0.1 Nov 14, 2025 Changes in this version + type Config struct + MaxSize int + RequestExpiration time.Duration + func DefaultConfig() Config + type MemoryXTRequestQueue struct + func NewMemoryXTRequestQueue(config Config) *MemoryXTRequestQueue + func (q *MemoryXTRequestQueue) Dequeue(context.Context) (*QueuedXTRequest, error) + func (q *MemoryXTRequestQueue) Enqueue(_ context.Context, request *QueuedXTRequest) error + func (q *MemoryXTRequestQueue) Peek(context.Context) (*QueuedXTRequest, error) + func (q *MemoryXTRequestQueue) RemoveExpired(context.Context) (int, error) + func (q *MemoryXTRequestQueue) RequeueForSlot(_ context.Context, requests []*QueuedXTRequest) error + func (q *MemoryXTRequestQueue) Size(context.Context) (int, error) + type PriorityQueue []*QueuedXTRequest + func (pq *PriorityQueue) Pop() interface{} + func (pq *PriorityQueue) Push(x interface{}) + func (pq PriorityQueue) Len() int + func (pq PriorityQueue) Less(i, j int) bool + func (pq PriorityQueue) Swap(i, j int) + type QueuedXTRequest struct + Attempts int + ExpiresAt time.Time + From string + Priority int64 + Request *pb.XTRequest + SubmittedAt time.Time + XtID []byte + type XTRequestQueue interface + Dequeue func(ctx context.Context) (*QueuedXTRequest, error) + Enqueue func(ctx context.Context, request *QueuedXTRequest) error + Peek func(ctx context.Context) (*QueuedXTRequest, error) + RemoveExpired func(ctx context.Context) (int, error) + RequeueForSlot func(ctx context.Context, requests []*QueuedXTRequest) error + Size func(ctx context.Context) (int, error)
Go to main page