routine

Jan 11, 2024

Changes in this version

+ func Child(ctx context.Context, exec Executor) chan error

Sep 30, 2020

Changes in this version

type Routine

+ func (r *Routine) Close() <-chan struct{}

+ func (r *Routine) Serving() <-chan struct{}

Feb 19, 2020

Changes in this version

type Opt

+ func CancelSignals(sigs ...os.Signal) Opt

+ func Signal(sig os.Signal, handler SigHandler) Opt

+ type SigHandler func()

+ type SigTrap struct

Jan 20, 2020

Changes in this version

+ type ProfilingExecutor struct

+ func Profiling(addr string) *ProfilingExecutor

+ func (d *ProfilingExecutor) Execute(ctx context.Context) error

Dec 4, 2019

Changes in this version

+ type AppendExecutor struct

+ func Append(execs ...Executor) *AppendExecutor

+ func (ae *AppendExecutor) Append(execs ...Executor)

+ func (ae *AppendExecutor) Execute(ctx context.Context) error

Dec 4, 2019

Changes in this version

+ type CommandOpt func(*CommandExecutor)

+ func ARG(arg string) CommandOpt

+ func ENV(env string) CommandOpt

+ func Stderr(wr io.Writer) CommandOpt

+ func Stdin(rd io.Reader) CommandOpt

+ func Stdout(wr io.Writer) CommandOpt

Dec 3, 2019

Changes in this version

type CrontabExecutor

+ func (c *CrontabExecutor) Everyday(flag bool)

+ func (c *CrontabExecutor) IsTimeMuted(tm time.Time) bool

+ func (c *CrontabExecutor) Mute(begin time.Time, end time.Time)

+ func (c *CrontabExecutor) Weekend(flag bool)

+ func (c *CrontabExecutor) Workday(flag bool)

+ type CrontabMute struct

Nov 20, 2019

Changes in this version

type Executor

+ func Parallel(execs ...Executor) Executor

+ type ParallelExecutor struct

+ func (pe *ParallelExecutor) Execute(ctx context.Context) error

Nov 11, 2019

Changes in this version

+ func WithParent(ctx context.Context, parent *Routine) context.Context

type Routine

+ func New(exec Executor, opts ...Opt) *Routine

+ func ParentFrom(ctx context.Context) (*Routine, bool)

+ func (r *Routine) Execute(ctx context.Context) error

+ func (r *Routine) Stop()

Jul 29, 2019

Changes in this version

+ func WithRoutine(ctx context.Context, routine Routine) context.Context

type Opt

+ func WithPool(p *Pool) Opt

type Routine

+ func RoutineFrom(ctx context.Context) (Routine, bool)

May 27, 2019

Changes in this version

+ func ArgumentsFrom(ctx context.Context) ([]interface{}, bool)

+ func EnvironFrom(ctx context.Context) []string

+ func StderrFrom(ctx context.Context) io.Writer

+ func StdinFrom(ctx context.Context) io.Reader

+ func StdoutFrom(ctx context.Context) io.Writer

+ type CountReader struct

+ func NewCountReader(rd io.Reader) *CountReader

+ func (rc *CountReader) Count() int

+ func (rc *CountReader) Read(p []byte) (int, error)

+ type CountWriter struct

+ func NewCountWriter(wr io.Writer) *CountWriter

+ func (wc *CountWriter) Count() int

+ func (wc *CountWriter) Write(p []byte) (int, error)

type Opt

+ func Context(ctx context.Context) Opt

+ type Pool struct

+ func NewPool(opts ...PoolOpt) *Pool

+ func (p *Pool) Close()

+ func (p *Pool) Go(ctx context.Context, exec Executor) chan error

+ func (p *Pool) Open(ctx context.Context)

+ type PoolOpt func(*Pool)

+ func MaxOfRequestBufferSize(n int) PoolOpt

+ func NumOfRoutines(n int) PoolOpt

May 7, 2019

Changes in this version

+ var DefaultCancelInterruptors []Interruptor

+ var ErrNoneContext = errors.New("none context")

+ var ErrNoneExecutor = errors.New("none executor")

+ var ErrNonePlan = errors.New("none plan")

+ func Debug(ctx context.Context, args ...interface{})

+ func Error(ctx context.Context, args ...interface{})

+ func FromArguments(ctx context.Context) []interface

+ func FromConcurrent(ctx context.Context) int

+ func FromCrontab(ctx context.Context) time.Time

+ func FromEnviron(ctx context.Context) []string

+ func FromRepeat(ctx context.Context) int

+ func FromRetry(ctx context.Context) int

+ func FromStderr(ctx context.Context) io.Writer

+ func FromStdin(ctx context.Context) io.Reader

+ func FromStdout(ctx context.Context) io.Writer

+ func Go(ctx context.Context, exec Executor) chan error

+ func Info(ctx context.Context, args ...interface{})

+ func Main(parent context.Context, exec Executor, opts ...Opt) error

+ func NewReadCounter(rd io.Reader) io.Reader

+ func NewWriteCounter(wr io.Writer) io.Writer

+ func Trace(ctx context.Context, args ...interface{})

+ func Wait(ctx context.Context)

+ func WaitAdd(ctx context.Context, delta int)

+ func WaitDone(ctx context.Context)

+ func Warn(ctx context.Context, args ...interface{})

+ func WithArgments(ctx context.Context, args ...interface{}) context.Context

+ func WithEnviron(ctx context.Context, key string, value string) context.Context

+ func WithLogger(ctx context.Context, logger Logger) context.Context

+ func WithStderr(ctx context.Context, out io.Writer) context.Context

+ func WithStdin(ctx context.Context, in io.Reader) context.Context

+ func WithStdout(ctx context.Context, out io.Writer) context.Context

+ func WithWait(ctx context.Context) context.Context

+ type CancelInterruptor struct

+ func NewCancelInterruptor(sig syscall.Signal) *CancelInterruptor

+ func (c *CancelInterruptor) Interrupt() InterruptHandler

+ func (c *CancelInterruptor) Signal() syscall.Signal

+ type Code int32

+ const GeneralErr

+ const IllegalCommand

+ const InvalidArgments

+ const MisUseErr

+ const NotExecutable

+ const OK

+ func SignalCode(sig syscall.Signal) Code

+ func (c Code) Value() int32

+ func (i Code) String() string

+ type CommandExecutor struct

+ func (cmd *CommandExecutor) Execute(ctx context.Context) error

+ type ConcurrentExecutor struct

+ func (ce *ConcurrentExecutor) Execute(ctx context.Context) error

+ type CrontabExecutor struct

+ func (c *CrontabExecutor) Execute(ctx context.Context) error

+ type DeadlineExecutor struct

+ func (tm *DeadlineExecutor) Execute(ctx context.Context) error

+ type Executor interface

+ Execute func(context.Context) error

+ func Command(cmd string, args ...string) Executor

+ func Concurrent(c int, exec Executor) Executor

+ func Crontab(plan string, exec Executor) Executor

+ func Deadline(d time.Time, exec Executor) Executor

+ func Guarantee(exec Executor) Executor

+ func Repeat(repeat int, interval time.Duration, exec Executor) Executor

+ func Report(ch chan *Result, exec Executor) Executor

+ func Retry(retry int, exec Executor) Executor

+ func Timeout(d time.Duration, exec Executor) Executor

+ func UseExecutorMiddleware(exec Executor, middleware ...ExecutorMiddleware) Executor

+ type ExecutorFunc func(context.Context) error

+ func (f ExecutorFunc) Execute(ctx context.Context) error

+ type ExecutorMiddleware func(Executor) Executor

+ type GoFunc func(context.Context, Executor) chan error

+ func (f GoFunc) Go(ctx context.Context, exec Executor) chan error

+ type GuaranteeExecutor struct

+ func (g *GuaranteeExecutor) Execute(ctx context.Context) error

+ type InterruptHandler func(ctx context.Context) (exit bool)

+ type Interruptor interface

+ Interrupt func() InterruptHandler

+ Signal func() syscall.Signal

+ type Logger interface

+ Debug func(args ...interface{})

+ Error func(args ...interface{})

+ Info func(args ...interface{})

+ Trace func(args ...interface{})

+ Warn func(args ...interface{})

+ type Opt func(*options)

+ func Arguments(args ...interface{}) Opt

+ func Cleanup(exec Executor) Opt

+ func Interrupts(ints ...Interruptor) Opt

+ func Prepare(exec Executor) Opt

+ type ReadCounter struct

+ func (rc *ReadCounter) Count() int

+ func (rc *ReadCounter) Read(p []byte) (int, error)

+ type RepeatExecutor struct

+ func (r *RepeatExecutor) Execute(ctx context.Context) error

+ type ReportExecutor struct

+ func (re *ReportExecutor) Execute(ctx context.Context) error

+ type Result struct

+ Begin time.Time

+ Code int

+ ContentLength int

+ Duration time.Duration

+ Err error

+ type RetryExecutor struct

+ func (retry *RetryExecutor) Execute(ctx context.Context) error

+ type Routine interface

+ Go func(context.Context, Executor) chan error

+ type TimeoutExecutor struct

+ func (tm *TimeoutExecutor) Execute(ctx context.Context) error

+ type WriteCounter struct

+ func (wc *WriteCounter) Count() int

+ func (wc *WriteCounter) Write(p []byte) (int, error)