queue

type Config struct {
	MaxSize    int
	MaxPending int
	Timeout    time.Duration
}

type Error string

type Interface interface {
	Enqueue(ctx context.Context, content string, priority Priority) (<-chan *Result, error)
	EnqueueBatch(ctx context.Context, items []string, priority Priority) ([]<-chan *Result, error)
	OutputChan() <-chan *Item
	Complete(item *Item, result *Result)
	Size() int
	Pending() int
	GetStats() Stats
	Clear()
	Close()
}

type Item struct {
	ID        string
	Content   string
	Priority  Priority
	CreatedAt time.Time
	Ch        chan *Result
}

type Priority int

type Result struct {
	Output   string
	Error    error
	Duration time.Duration
}

type Stats struct {
	Size           int           `json:"size"`
	Pending        int           `json:"pending"`
	TotalEnqueued  int64         `json:"total_enqueued"`
	TotalProcessed int64         `json:"total_processed"`
	AvgWaitTime    time.Duration `json:"avg_wait_time"`
}