Versions in this module Expand all Collapse all v1 v1.0.1 Sep 21, 2023 Changes in this version + type ActionData struct + type ActionResult struct + type ActionWorkRequest struct + ID string + ReqType RequestType + type ActionWorker struct + ID int + QuitChan chan bool + Work chan ActionWorkRequest + WorkerQueue chan chan ActionWorkRequest + func NewWorker(id int, runner *DirectRunner, workerQueue chan chan ActionWorkRequest) ActionWorker + func (w ActionWorker) Start() + func (w ActionWorker) Stop() + type AsyncResultHandler struct + func (rh *AsyncResultHandler) Done() + func (rh *AsyncResultHandler) HandleResult(results map[string]interface{}, err error) + type DirectRunner struct + func NewDirect() *DirectRunner + func (runner *DirectRunner) RunAction(ctx context.Context, act action.Action, inputs map[string]interface{}) (results map[string]interface{}, err error) + func (runner *DirectRunner) Start() error + func (runner *DirectRunner) Stop() error + type PooledConfig struct + NumWorkers int + WorkQueueSize int + type PooledRunner struct + func NewPooled(config *PooledConfig) *PooledRunner + func (runner *PooledRunner) RunAction(ctx context.Context, act action.Action, inputs map[string]interface{}) (results map[string]interface{}, err error) + func (runner *PooledRunner) Start() error + func (runner *PooledRunner) Stop() error + type RequestType int + const RtRun + type RunnerTracker struct + func NewRunnerTracker() *RunnerTracker + func (rt RunnerTracker) AddRunner() + func (rt RunnerTracker) RemoveRunner() + func (rt RunnerTracker) WaitForAllRunners() + func (rt RunnerTracker) WaitForRunnersCompletion(timeout time.Duration) bool + type SyncResultHandler struct + func (rh *SyncResultHandler) Done() + func (rh *SyncResultHandler) HandleResult(resultData map[string]interface{}, err error) + func (rh *SyncResultHandler) Result() (resultData map[string]interface{}, err error)
Go to main page