routine

Documentation

Index

• type DelayTask
  • func NewDelayTask(cb Task, d time.Duration) *DelayTask
  • func (t *DelayTask) Start(ctx context.Context) error
  • func (t *DelayTask) Stop(ctx context.Context) error
• type RecurringTask
  • func NewRecurringTask(t Task, i time.Duration) *RecurringTask
  • func (t *RecurringTask) Start(ctx context.Context) error
  • func (t *RecurringTask) Stop(_ context.Context) error
• type Task

Types

type DelayTask

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

DelayTask represents a timeout task

func NewDelayTask

func NewDelayTask(cb Task, d time.Duration) *DelayTask

NewDelayTask creates an instance of DelayTask

func (*DelayTask) Start

func (t *DelayTask) Start(ctx context.Context) error

Start executes the delayed task after given timeout.

func (*DelayTask) Stop

func (t *DelayTask) Stop(ctx context.Context) error

Stop stops the timeout

type RecurringTask

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

RecurringTask represents a recurring task

func NewRecurringTask

func NewRecurringTask(t Task, i time.Duration) *RecurringTask

NewRecurringTask creates an instance of RecurringTask

func (*RecurringTask) Start

func (t *RecurringTask) Start(ctx context.Context) error

Start starts the timer

func (*RecurringTask) Stop

func (t *RecurringTask) Stop(_ context.Context) error

Stop stops the timer

type Task

type Task func()

Task is the task logic to run.