task

package

v0.0.0-...-fd63c1f Latest Latest Go to latest Published: Mar 29, 2024 License: MIT Imports: 10 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/blockwatch-cc/tzindex

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
type Scheduler
- func NewScheduler() *Scheduler
type TaskCompletionCallback
type TaskRequest
type TaskResult
type TaskStatus
- func ParseTaskStatus(s string) TaskStatus

Constants ¶

View Source

const (
	TaskStatusInvalid = iota
	TaskStatusIdle
	TaskStatusRunning
	TaskStatusSuccess
	TaskStatusFailed
	TaskStatusTimeout
)

View Source

const TaskTableKey = "task"

Variables ¶

View Source

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

Functions ¶

This section is empty.

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

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
client

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL