worker

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

type JobPayload struct {
	ScriptPath string                 `json:"script_path"`
	Data       map[string]interface{} `json:"data"`
	CreatedAt  time.Time              `json:"created_at"`
}

type JobQueue interface {
	// Push adds a job to the queue
	Push(ctx context.Context, queue string, payload []byte) error

	// Pop retrieves a job from one of the specified queues (blocking or polling)
	// Returns queue name, payload, and error
	Pop(ctx context.Context, queues []string) (string, []byte, error)

	// Close cleans up resources
	Close() error
}