task

Documentation

Index

• func GenerateID() string
• type Priority
  • func PriorityFromInt(i int) Priority
  • func PriorityFromString(s string) Priority
  • func (p Priority) Int() int
  • func (p Priority) String() string
• type Status
  • func StatusFromString(s string) Status
  • func (s Status) IsActive() bool
  • func (s Status) IsTerminal() bool
  • func (s Status) String() string
• type Task
  • func NewTask(topic string, payload json.RawMessage) *Task
  • func (t *Task) CanRetry() bool
  • func (t *Task) Reset()

Functions

func GenerateID

func GenerateID() string

Types

type Priority

type Priority int

const (
	PriorityHigh   Priority = 0
	PriorityNormal Priority = 1
	PriorityLow    Priority = 2
)

func PriorityFromInt

func PriorityFromInt(i int) Priority

func PriorityFromString

func PriorityFromString(s string) Priority

func (Priority) Int

func (p Priority) Int() int

func (Priority) String

func (p Priority) String() string

type Status

type Status string

const (
	StatusPending   Status = "pending"
	StatusRunning   Status = "running"
	StatusCompleted Status = "completed"
	StatusFailed    Status = "failed"
	StatusDead      Status = "dead"
)

func StatusFromString

func StatusFromString(s string) Status

func (Status) IsActive

func (s Status) IsActive() bool

func (Status) IsTerminal

func (s Status) IsTerminal() bool

func (Status) String

func (s Status) String() string

type Task

type Task struct {
	ID          string          `json:"id"`
	Topic       string          `json:"topic"`
	Payload     json.RawMessage `json:"payload"`
	Status      Status          `json:"status"`   // Now uses Status from status.go
	Priority    Priority        `json:"priority"` // Now uses Priority from priority.go
	RetryCount  int             `json:"retry_count"`
	MaxRetries  int             `json:"max_retries"`
	ExecuteAt   time.Time       `json:"execute_at"`
	LastError   string          `json:"last_error,omitempty"`
	WorkerID    string          `json:"worker_id,omitempty"`
	ClaimedAt   time.Time       `json:"claimed_at,omitempty"`
	CreatedAt   time.Time       `json:"created_at"`
	UpdatedAt   time.Time       `json:"updated_at"`
	CompletedAt time.Time       `json:"completed_at,omitempty"`
}

func NewTask

func NewTask(topic string, payload json.RawMessage) *Task

func (*Task) CanRetry

func (t *Task) CanRetry() bool

func (*Task) Reset

func (t *Task) Reset()