Versions in this module Expand all Collapse all v0 v0.1.7 Aug 24, 2021 v0.1.6 Aug 17, 2021 v0.1.5 Aug 15, 2021 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 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