Versions in this module Expand all Collapse all v1 v1.6.1 Jul 9, 2019 Changes in this version + const DefaultMaximumWorkers + const PubSubTopicControl + const PubSubTopicTaskStatuses + var ContextJobUuid = "X-Pydio-Job-Uuid" + var ContextTaskUuid = "X-Pydio-Task-Uuid" + var PubSub *pubsub.PubSub + var RC int + type Dispatcher struct + JobQueue chan Runnable + WorkerPool chan chan Runnable + func NewDispatcher(maxWorkers int, tags map[string]string) *Dispatcher + func (d *Dispatcher) Run() + func (d *Dispatcher) Stop() + type ReconnectingClient struct + func NewTaskReconnectingClient(parentCtx context.Context) *ReconnectingClient + func (s *ReconnectingClient) StartListening(tasksChan chan interface{}) + func (s *ReconnectingClient) Stop() + type Runnable struct + Client client.Client + Context context.Context + Implementation actions.ConcreteAction + Message jobs.ActionMessage + Task *Task + func NewRunnable(ctx context.Context, cl client.Client, task *Task, action *jobs.Action, ...) Runnable + func RootRunnable(ctx context.Context, cl client.Client, task *Task) Runnable + func (r *Runnable) CreateChild(action *jobs.Action, message jobs.ActionMessage) Runnable + func (r *Runnable) Dispatch(input jobs.ActionMessage, actions []*jobs.Action, Queue chan Runnable) + func (r *Runnable) RunAction(Queue chan Runnable) error + type Subscriber struct + Client client.Client + Dispatchers map[string]*Dispatcher + JobsDefinitions map[string]*jobs.Job + MainQueue chan Runnable + RootContext context.Context + UpdateTasksChan chan *jobs.Task + func NewSubscriber(parentContext context.Context, client client.Client, server server.Server) *Subscriber + func (s *Subscriber) GetDispatcherForJob(job *jobs.Job) *Dispatcher + func (s *Subscriber) Init() error + func (s *Subscriber) ListenToMainQueue() + func (s *Subscriber) TaskChannelSubscription() + type Task struct + RC int + func NewTaskFromEvent(ctx context.Context, job *jobs.Job, event interface{}) *Task + func (t *Task) Add(delta int) + func (t *Task) AppendLog(a jobs.Action, in jobs.ActionMessage, out jobs.ActionMessage) + func (t *Task) Done(delta int) + func (t *Task) EnqueueRunnables(c client.Client, output chan Runnable) + func (t *Task) GetJobTaskClone() *jobs.Task + func (t *Task) GetRunnableChannels() (*actions.RunnableChannels, chan bool) + func (t *Task) GlobalError(e error) + func (t *Task) Save() + func (t *Task) SetControllable(canStop bool, canPause bool) + func (t *Task) SetEndTime(ti time.Time) + func (t *Task) SetHasProgress() + func (t *Task) SetProgress(progress float32) + func (t *Task) SetStartTime(ti time.Time) + func (t *Task) SetStatus(status jobs.TaskStatus, message ...string) + type Worker struct + JobChannel chan Runnable + JobReQueue chan Runnable + WorkerPool chan chan Runnable + func NewWorker(workerPool chan chan Runnable, requeue chan Runnable, activeChan chan int, ...) Worker + func (w Worker) Start() + func (w Worker) Stop() Incompatible versions in this module v2.0.6+incompatible Apr 23, 2020
Go to main page