queue

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

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

type Job struct {
	ID       string
	Priority int64
	Fn       vm.Value
	Args     []vm.Value
	Payload  vm.Value

	Enqueued time.Time
	ReadyAt  time.Time
	Timeout  time.Duration
	Attempts int
	Retries  int
	Backoff  time.Duration
	// contains filtered or unexported fields
}

type Metrics struct {
	Enqueued  int64
	Processed int64
	Succeeded int64
	Failed    int64
	Retried   int64
	Expired   int64
	Dropped   int64

	TotalWait time.Duration
	TotalExec time.Duration
	MaxWait   time.Duration
	MaxExec   time.Duration
}

type Outcome int

type Result int