task

Documentation

Index

• type State
  • func (s State) In(mask State) bool
  • func (s State) String() string
• type Task
  • func (t1 *Task) Equals(t2 *Task) bool
  • func (t *Task) String() string
• type TaskRecord
  • func (r *TaskRecord) Task() (*Task, error)

Types

type State

type State int

const (
	Init      State = 1 << iota // 1
	Enqueued                    // 2
	Claimed                     // 4
	Completed                   // 8
	Timedout                    // 16
)

func (State) In

func (s State) In(mask State) bool

func (State) String

func (s State) String() string

type Task

type Task struct {
	Id            string          `json:"id"`
	Counter       int             `json:"counter"`
	Timeout       int64           `json:"timeout"`
	ProcessId     *string         `json:"processId,omitempty"`
	State         State           `json:"-"`
	RootPromiseId string          `json:"-"`
	Recv          json.RawMessage `json:"-"`
	Mesg          *message.Mesg   `json:"-"`
	Attempt       int             `json:"-"`
	Ttl           int             `json:"-"`
	ExpiresAt     int64           `json:"-"`
	CreatedOn     *int64          `json:"createdOn,omitempty"`
	CompletedOn   *int64          `json:"completedOn,omitempty"`
}

func (*Task) Equals

func (t1 *Task) Equals(t2 *Task) bool

func (*Task) String

func (t *Task) String() string

type TaskRecord

type TaskRecord struct {
	Id            string
	ProcessId     *string
	State         State
	RootPromiseId string
	Recv          []byte
	Mesg          []byte
	Timeout       int64
	Counter       int
	Attempt       int
	Ttl           int
	ExpiresAt     int64
	CreatedOn     *int64
	CompletedOn   *int64
}

func (*TaskRecord) Task

func (r *TaskRecord) Task() (*Task, error)