Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  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

crew

package

Go to main page

Versions in this module

v1

v1.0.5

Sep 21, 2023

Changes in this version

+ func BuildRestApi(e *echo.Echo, prefix string, controller *TaskController, ...)

+ func ServeRestApi(wg *sync.WaitGroup, controller *TaskController, ...) (*http.Server, *echo.Echo)

+ type ChildTask struct

+ ErrorDelayInSeconds int

+ Id string

+ Input interface{}

+ IsPaused bool

+ Key string

+ Name string

+ ParentIds []string

+ RemainingAttempts int

+ RunAfter time.Time

+ Worker string

+ Workgroup string

+ type HttpPostClient struct

+ UrlForTask func(task *Task) (url string, err error)

+ func NewHttpPostClient() *HttpPostClient

+ func (client *HttpPostClient) Post(task *Task, parents []*Task) (response WorkerResponse, err error)

+ type MemoryTaskStorage struct

+ func NewMemoryTaskStorage() *MemoryTaskStorage

+ func (storage *MemoryTaskStorage) AllTaskGroups() (taskGroups []*TaskGroup, err error)

+ func (storage *MemoryTaskStorage) AllTasksInGroup(taskGroupId string) (tasks []*Task, err error)

+ func (storage *MemoryTaskStorage) DeleteTask(taskId string) (err error)

+ func (storage *MemoryTaskStorage) DeleteTaskGroup(taskGroupId string) (err error)

+ func (storage *MemoryTaskStorage) FindTask(taskId string) (task *Task, err error)

+ func (storage *MemoryTaskStorage) FindTaskGroup(taskGroupId string) (taskGroup *TaskGroup, err error)

+ func (storage *MemoryTaskStorage) GetTaskChildren(taskId string) (tasks []*Task, err error)

+ func (storage *MemoryTaskStorage) GetTaskParents(taskId string) (tasks []*Task, err error)

+ func (storage *MemoryTaskStorage) GetTasksInWorkgroup(workgroup string) (tasks []*Task, err error)

+ func (storage *MemoryTaskStorage) GetTasksWithKey(key string) (tasks []*Task, err error)

+ func (storage *MemoryTaskStorage) SaveTask(task *Task, create bool) (err error)

+ func (storage *MemoryTaskStorage) SaveTaskGroup(taskGroup *TaskGroup, create bool) (err error)

+ func (storage *MemoryTaskStorage) TryLockTask(taskId string) (unlocker func() error, err error)

+ type RedisTaskStorage struct

+ Client *goredislib.Client

+ RedSync *redsync.Redsync

+ func NewRedisTaskStorage(Addr string, Password string, DB int) *RedisTaskStorage

+ func (storage *RedisTaskStorage) AllTaskGroups() (taskGroups []*TaskGroup, err error)

+ func (storage *RedisTaskStorage) AllTasksInGroup(taskGroupId string) (tasks []*Task, err error)

+ func (storage *RedisTaskStorage) AllTasksInList(path string) (tasks []*Task, err error)

+ func (storage *RedisTaskStorage) DeleteTask(taskId string) (err error)

+ func (storage *RedisTaskStorage) DeleteTaskGroup(taskGroupId string) (err error)

+ func (storage *RedisTaskStorage) FindTask(taskId string) (task *Task, err error)

+ func (storage *RedisTaskStorage) FindTaskAtPath(path string) (task *Task, err error)

+ func (storage *RedisTaskStorage) FindTaskGroup(taskGroupId string) (taskGroup *TaskGroup, err error)

+ func (storage *RedisTaskStorage) FindTaskGroupAtPath(path string) (taskGroup *TaskGroup, err error)

+ func (storage *RedisTaskStorage) GetExpiration() time.Duration

+ func (storage *RedisTaskStorage) GetLockExpiration() time.Duration

+ func (storage *RedisTaskStorage) GetTaskChildren(taskId string) (tasks []*Task, err error)

+ func (storage *RedisTaskStorage) GetTaskParents(taskId string) (tasks []*Task, err error)

+ func (storage *RedisTaskStorage) GetTasksInWorkgroup(workgroup string) (tasks []*Task, err error)

+ func (storage *RedisTaskStorage) GetTasksWithKey(key string) (tasks []*Task, err error)

+ func (storage *RedisTaskStorage) SaveTask(task *Task, create bool) (err error)

+ func (storage *RedisTaskStorage) SaveTaskGroup(taskGroup *TaskGroup, create bool) (err error)

+ func (storage *RedisTaskStorage) TaskGroupKey(taskGroupId string) string

+ func (storage *RedisTaskStorage) TaskGroupsPrefix() string

+ func (storage *RedisTaskStorage) TaskKey(taskId string) string

+ func (storage *RedisTaskStorage) TaskMutexKey(taskId string) string

+ func (storage *RedisTaskStorage) TryLockTask(taskId string) (unlocker func() error, err error)

+ type Task struct

+ BusyExecuting bool

+ CreatedAt time.Time

+ ErrorDelayInSeconds int

+ Errors []string

+ Id string

+ Input interface{}

+ IsComplete bool

+ IsPaused bool

+ IsSeed bool

+ Key string

+ Name string

+ Output interface{}

+ ParentIds []string

+ RemainingAttempts int

+ RunAfter time.Time

+ Storage TaskStorage

+ TaskGroupId string

+ Worker string

+ Workgroup string

+ func NewTask() *Task

+ func (task *Task) CanExecute(parents []*Task) bool

+ type TaskClient interface

+ Post func(task *Task, parents []*Task) (response WorkerResponse, err error)

+ type TaskController struct

+ AbandonedCheckMutex *sync.Mutex

+ AbandonedCheckScheduler *gocron.Scheduler

+ Client TaskClient

+ Feed chan interface{}

+ Pending *sync.WaitGroup

+ Storage TaskStorage

+ Throttler *Throttler

+ func NewTaskController(storage TaskStorage, client TaskClient, throttler *Throttler) *TaskController

+ func (controller *TaskController) CreateTask(task *Task) (err error)

+ func (controller *TaskController) CreateTaskGroup(taskGroup *TaskGroup) (err error)

+ func (controller *TaskController) DeleteTask(id string) (err error)

+ func (controller *TaskController) DeleteTaskGroup(id string) (err error)

+ func (controller *TaskController) EmitTaskFeedEvent(event string, task *Task)

+ func (controller *TaskController) EmitTaskGroupFeedEvent(event string, taskGroup *TaskGroup)

+ func (controller *TaskController) Evaluate(task *Task)

+ func (controller *TaskController) Execute(taskToExecute *Task)

+ func (controller *TaskController) GetTask(id string) (task *Task, err error)

+ func (controller *TaskController) GetTaskGroup(id string) (taskGroup *TaskGroup, err error)

+ func (controller *TaskController) GetTaskGroupProgress(id string) (completedPercent float64, err error)

+ func (controller *TaskController) GetTaskGroups(page int, pageSize int, search string) (taskGroups []*TaskGroup, total int, err error)

+ func (controller *TaskController) GetTasksInGroup(taskGroupId string, page int, pageSize int, search string, skipCompleted bool) (tasks []*Task, total int, err error)

+ func (controller *TaskController) HandleExecuteError(task *Task, message string)

+ func (controller *TaskController) PauseOrResumeTaskGroup(id string, isPaused bool) (err error)

+ func (controller *TaskController) ResetTask(task *Task, remainingAttempts int)

+ func (controller *TaskController) ResetTaskById(id string, remainingAttempts int) (task *Task, err error)

+ func (controller *TaskController) ResetTaskGroup(id string, remainingAttempts int) (err error)

+ func (controller *TaskController) RetryTaskById(id string, remainingAttempts int) (task *Task, err error)

+ func (controller *TaskController) RetryTaskGroup(id string, remainingAttempts int) (err error)

+ func (controller *TaskController) Shutdown() (err error)

+ func (controller *TaskController) Startup() (err error)

+ func (controller *TaskController) TriggerTaskEvaluate(id string) (err error)

+ func (controller *TaskController) UpdateTask(id string, update map[string]interface{}) (updatedTask *Task, err error)

+ func (controller *TaskController) UpdateTaskGroup(id string, update map[string]interface{}) (taskGroup *TaskGroup, err error)

+ type TaskFeedEvent struct

+ Event string

+ Task *Task

+ type TaskGroup struct

+ CreatedAt time.Time

+ Id string

+ Name string

+ func NewTaskGroup(id string, name string) *TaskGroup

+ type TaskGroupFeedEvent struct

+ Event string

+ TaskGroup *TaskGroup

+ type TaskGroupWatcher struct

+ Channel chan string

+ RequestId string

+ Socket *websocket.Conn

+ TaskGroupId string

+ type TaskStorage interface

+ AllTaskGroups func() (taskGroups []*TaskGroup, err error)

+ AllTasksInGroup func(taskGroupId string) (tasks []*Task, err error)

+ DeleteTask func(taskId string) (err error)

+ DeleteTaskGroup func(taskGroupId string) (err error)

+ FindTask func(taskId string) (task *Task, err error)

+ FindTaskGroup func(taskGroupId string) (taskGroup *TaskGroup, err error)

+ GetTaskChildren func(taskId string) (tasks []*Task, err error)

+ GetTaskParents func(taskId string) (tasks []*Task, err error)

+ GetTasksInWorkgroup func(workgroup string) (tasks []*Task, err error)

+ GetTasksWithKey func(key string) (tasks []*Task, err error)

+ SaveTask func(task *Task, create bool) (err error)

+ SaveTaskGroup func(taskGroup *TaskGroup, create bool) (err error)

+ TryLockTask func(taskId string) (unlocker func() error, err error)

+ type ThrottlePopQuery struct

+ TaskId string

+ Worker string

+ type ThrottlePushQuery struct

+ Resp chan bool

+ TaskId string

+ Worker string

+ type Throttler struct

+ Pop chan ThrottlePopQuery

+ Push chan ThrottlePushQuery

+ type WorkerPayload struct

+ Input interface{}

+ Parents []WorkerPayloadParentResult

+ TaskId string

+ Worker string

+ type WorkerPayloadParentResult struct

+ Input interface{}

+ Output interface{}

+ TaskId string

+ Worker string

+ type WorkerResponse struct

+ Children []*ChildTask

+ ChildrenDelayInSeconds int

+ Error interface{}

+ Output interface{}

+ WorkgroupDelayInSeconds int

v1.0.4

Jul 5, 2023

v1.0.3

Jun 27, 2023

v1.0.2

Jun 7, 2023