queue

type Config struct {
	MaxSize           int           `mapstructure:"max_size"           yaml:"max_size"`
	RequestExpiration time.Duration `mapstructure:"request_expiration" yaml:"request_expiration"`
}

type MemoryXTRequestQueue struct {
	// contains filtered or unexported fields
}

type PriorityQueue []*QueuedXTRequest

type QueuedXTRequest struct {
	Request     *pb.XTRequest `json:"request"`
	XtID        []byte        `json:"xt_id"`
	Priority    int64         `json:"priority"`
	SubmittedAt time.Time     `json:"submitted_at"`
	ExpiresAt   time.Time     `json:"expires_at"`
	Attempts    int           `json:"attempts"`
	From        string        `json:"from"`
}

type XTRequestQueue interface {
	Enqueue(ctx context.Context, request *QueuedXTRequest) error
	Dequeue(ctx context.Context) (*QueuedXTRequest, error)
	Peek(ctx context.Context) (*QueuedXTRequest, error)
	Size(ctx context.Context) (int, error)
	RemoveExpired(ctx context.Context) (int, error)
	RequeueForSlot(ctx context.Context, requests []*QueuedXTRequest) error
}