Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

tasks

package

Go to main page

Versions in this module

v1

v1.1.0

Mar 5, 2023

Changes in this version

type Runner

+ func NewScriptRunnerPool(poolSize int, ctx context.Context) Runner

+ ExecuteAsync func(task *Task, execArgs interface{})

+ GetAsyncResults func() <-chan *TaskResult

+ SetLogger func(logger *logrus.Logger)

+ WaitUntilComplete func()

type ScriptRunner

+ func (s *ScriptRunner) GetAsyncResults() <-chan *TaskResult

+ func (s *ScriptRunner) GetAsyncResultsCount() int

+ func (s *ScriptRunner) SetLogger(logger *logrus.Logger)

+ type ScriptRunnerPool struct

+ func (p *ScriptRunnerPool) ExecuteAsync(task *Task, execArgs interface{})

v1.0.0

Feb 26, 2023

Changes in this version

+ type Header struct

+ Data interface{}

+ Meta struct{ ... }

+ type JsonSchema struct

+ ID string

+ Properties map[string]*JsonSchema

+ Required []string

+ Schema string

+ Type string

+ type Runner interface

+ Execute func(task *Task) *TaskResult

+ type ScriptRunner struct

+ func NewScriptRunner() *ScriptRunner

+ func (s *ScriptRunner) Execute(task *Task, execArgs interface{}) *TaskResult

+ func (s *ScriptRunner) ExecuteAsync(task *Task, execArgs interface{})

+ func (s *ScriptRunner) WaitUntilComplete()

+ type ScriptSchema struct

+ Description string

+ Inputs *JsonSchema

+ Name string

+ Outputs *JsonSchema

+ func NewScriptSchema(name string, description string, inputs *JsonSchema, outputs *JsonSchema) *ScriptSchema

+ func NewScriptSchemaFromJSON(jsonSchema string) (*ScriptSchema, error)

+ type Task struct

+ Accept *JsonSchema

+ Location string

+ Name string

+ func NewTask(name string, location string) *Task

+ func (t *Task) JsonSchema() string

+ func (t *Task) ParseArgs(args interface{}) (map[string]interface{}, error)

+ func (t *Task) SetSchemaFromBytes(schema []byte) error

+ type TaskResult struct

+ Caller *Task

+ Payload interface{}

+ Reason string

+ Status int

+ func (tr *TaskResult) SetFail(reason string)

+ type TaskStore struct

+ func NewTaskStore(filename string) (*TaskStore, error)

+ func (s *TaskStore) AddTask(task *Task) error

+ func (s *TaskStore) Clear() error

+ func (s *TaskStore) DeleteTask(name string) error

+ func (s *TaskStore) GetTask(name string) (*Task, error)

+ func (s *TaskStore) GetTasks() []*Task