chrono_utils

Documentation

Index

• func NewContextTaskExecutor() chrono.TaskExecutor
• func NewContextTaskRunner(ctx context.Context) chrono.TaskRunner
• func NewContextTaskScheduler() chrono.TaskScheduler
• type ContextTaskExecutor
  • func (e *ContextTaskExecutor) Shutdown() chan bool
• type ContextTaskRunner
  • func (runner *ContextTaskRunner) Run(task chrono.Task)

Functions

func NewContextTaskExecutor

func NewContextTaskExecutor() chrono.TaskExecutor

func NewContextTaskRunner

func NewContextTaskRunner(ctx context.Context) chrono.TaskRunner

func NewContextTaskScheduler

func NewContextTaskScheduler() chrono.TaskScheduler

Types

type ContextTaskExecutor

type ContextTaskExecutor struct {
	chrono.SimpleTaskExecutor
	// contains filtered or unexported fields
}

ContextTaskExecutor is a TaskExecutor that actually cancels the context passed to the executed tasks.

func (*ContextTaskExecutor) Shutdown

func (e *ContextTaskExecutor) Shutdown() chan bool

type ContextTaskRunner

type ContextTaskRunner struct {
	// contains filtered or unexported fields
}

func (*ContextTaskRunner) Run

func (runner *ContextTaskRunner) Run(task chrono.Task)