task

Documentation

Index

• Constants
• Variables
• type Scheduler
  • func NewScheduler() *Scheduler
  • func (s *Scheduler) Run(req TaskRequest) error
  • func (s *Scheduler) SetLogLevel(lvl log.Level)
  • func (s *Scheduler) Start()
  • func (s *Scheduler) Stop()
  • func (s *Scheduler) WithCallback(cb TaskCompletionCallback) *Scheduler
  • func (s *Scheduler) WithContext(ctx context.Context) *Scheduler
  • func (s *Scheduler) WithLogger(logger log.Logger) *Scheduler
  • func (s *Scheduler) WithTable(t *pack.Table) *Scheduler
• type TaskCompletionCallback
• type TaskRequest
  • func (r TaskRequest) ID() uint64
  • func (r TaskRequest) IndexOpts(key string) pack.Options
  • func (r *TaskRequest) SetID(i uint64)
  • func (r TaskRequest) TableKey() string
  • func (r TaskRequest) TableOpts() pack.Options
• type TaskResult
• type TaskStatus
  • func ParseTaskStatus(s string) TaskStatus
  • func (t TaskStatus) IsValid() bool
  • func (t TaskStatus) MarshalText() ([]byte, error)
  • func (s TaskStatus) String() string
  • func (t *TaskStatus) UnmarshalText(data []byte) error

Constants

const (
	TaskStatusInvalid = iota
	TaskStatusIdle
	TaskStatusRunning
	TaskStatusSuccess
	TaskStatusFailed
	TaskStatusTimeout
)

const TaskTableKey = "task"

Variables

var (
	ErrAgain        = errors.New("try again later")
	ErrShuttingDown = errors.New("scheduler is shutting down")
	ErrShutdown     = errors.New("scheduler is shut down")
)

Types

type Scheduler

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

func NewScheduler

func NewScheduler() *Scheduler

func (*Scheduler) Run

func (s *Scheduler) Run(req TaskRequest) error

func (*Scheduler) SetLogLevel

func (s *Scheduler) SetLogLevel(lvl log.Level)

func (*Scheduler) Start

func (s *Scheduler) Start()

func (*Scheduler) Stop

func (s *Scheduler) Stop()

func (*Scheduler) WithCallback

func (s *Scheduler) WithCallback(cb TaskCompletionCallback) *Scheduler

func (*Scheduler) WithContext

func (s *Scheduler) WithContext(ctx context.Context) *Scheduler

func (*Scheduler) WithLogger

func (s *Scheduler) WithLogger(logger log.Logger) *Scheduler

func (*Scheduler) WithTable

func (s *Scheduler) WithTable(t *pack.Table) *Scheduler

type TaskCompletionCallback

type TaskCompletionCallback func(context.Context, *TaskResult) error

type TaskRequest

type TaskRequest struct {
	Id      uint64        `pack:"I,pk"      json:"id"`
	Index   string        `pack:"J"         json:"index"`
	Decoder uint64        `pack:"D"         json:"decoder"`
	Owner   tezos.Address `pack:"o,bloom=2" json:"owner"`
	Account uint64        `pack:"a,bloom=2" json:"account"`
	Ordered bool          `pack:"O"         json:"ordered"`
	Flags   uint64        `pack:"f,snappy"  json:"flags"`
	Url     string        `pack:"u,snappy"  json:"url"`
	Status  TaskStatus    `pack:"s,snappy"  json:"status"`
	Data    []byte        `pack:"d,snappy"  json:"data"`
}

func (TaskRequest) ID

func (r TaskRequest) ID() uint64

func (TaskRequest) IndexOpts

func (r TaskRequest) IndexOpts(key string) pack.Options

func (*TaskRequest) SetID

func (r *TaskRequest) SetID(i uint64)

func (TaskRequest) TableKey

func (r TaskRequest) TableKey() string

func (TaskRequest) TableOpts

func (r TaskRequest) TableOpts() pack.Options

type TaskResult

type TaskResult struct {
	Id      uint64
	Index   string
	Decoder uint64
	Owner   tezos.Address
	Account uint64
	Flags   uint64
	Status  TaskStatus
	Data    []byte
	Url     string
}

type TaskStatus

type TaskStatus byte

func ParseTaskStatus

func ParseTaskStatus(s string) TaskStatus

func (TaskStatus) IsValid

func (t TaskStatus) IsValid() bool

func (TaskStatus) MarshalText

func (t TaskStatus) MarshalText() ([]byte, error)

func (TaskStatus) String

func (s TaskStatus) String() string

func (*TaskStatus) UnmarshalText

func (t *TaskStatus) UnmarshalText(data []byte) error