tasks

Documentation

Index

• func NewFunctionTask(name string, fn func(context.Context, task.RunOptions) ([]byte, error)) task.Task
• func NewSerivceTask(name string, service string, endpoint string, args ...task.Argument) task.Task
• func NewTickerTask(name string, tickInterval time.Duration, totalTime time.Duration) task.Task

Functions

func NewFunctionTask

func NewFunctionTask(name string, fn func(context.Context, task.RunOptions) ([]byte, error)) task.Task

NewFunctionTask build task that will be executed in same process

func NewSerivceTask

func NewSerivceTask(name string, service string, endpoint string, args ...task.Argument) task.Task

NewSerivceTask build task task calls a service with arguments

func NewTickerTask

func NewTickerTask(name string, tickInterval time.Duration, totalTime time.Duration) task.Task

NewTickerTask builds task that will send event every tickInterval till it stops on totalTime