queue.go

package queue

import (
	"context"
	"time"
)

type Task struct {
	ID            string
	Payload       []byte
	Metadata      map[string]interface{}
	CreatedAt     time.Time
	StartedAt     time.Time
	FinishedAt    time.Time
	LastHeartbeat time.Time
}

type Manager interface {
	Enqueue(ctx context.Context, queue string, task *Task) error
	Dequeue(ctx context.Context, queue string) (*Task, error)
	Heartbeat(ctx context.Context, queue, taskID string, metadata map[string]interface{}) error
	Finish(ctx context.Context, queue, taskID string, metadata map[string]interface{}) error
	Inspect(ctx context.Context, queue string, offset uint64) (chan *Task, error)
}