Versions in this module Expand all Collapse all v1 v1.0.1 Jun 28, 2020 Changes in this version + var ErrorTimeOut = fmt.Errorf("TimeOut") + var ErrorUsingActuator = fmt.Errorf("ErrorUsingActuator") + func DurationPtr(t time.Duration) *time.Duration + func Exec(tasks ...Task) bool + func ExecWithError(tasks ...Task) error + type Actuator struct + func NewActuator(opt ...*Options) *Actuator + func (c *Actuator) Exec(tasks ...Task) error + func (c *Actuator) ExecWithContext(ctx context.Context, tasks ...Task) error + func (c *Actuator) GetTimeout() *time.Duration + type BaseActuator interface + Exec func(tasks ...Task) error + ExecWithContext func(ctx context.Context, tasks ...Task) error + type GoroutinePool interface + Release func() + Submit func(f func()) error + type Options struct + TimeOut *time.Duration + type PooledActuator struct + func NewPooledActuator(workerNum int, opt ...*Options) *PooledActuator + func (c *PooledActuator) Exec(tasks ...Task) error + func (c *PooledActuator) ExecWithContext(ctx context.Context, tasks ...Task) error + func (c *PooledActuator) GetTimeout() *time.Duration + func (c *PooledActuator) Release() + func (c *PooledActuator) WithPool(pool GoroutinePool) *PooledActuator + type Task func() error + type TimedActuator interface + GetTimeout func() *time.Duration
Go to main page