executor

package
v0.0.1-beta Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 26, 2022 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type DelayExecutor

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

func NewDelayExecutor

func NewDelayExecutor(container *container.DIContiner, wg *sync.WaitGroup) *DelayExecutor

func (*DelayExecutor) Name

func (ex *DelayExecutor) Name() string

func (*DelayExecutor) Start

func (ex *DelayExecutor) Start() error

func (*DelayExecutor) Stop

func (ex *DelayExecutor) Stop() error

type Executor

type Executor interface {
	Start() error
	Stop() error
	Name() string
}

type RetryExecutor

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

func NewRetryExecutor

func NewRetryExecutor(container *container.DIContiner, wg *sync.WaitGroup) *RetryExecutor

func (*RetryExecutor) Name

func (ex *RetryExecutor) Name() string

func (*RetryExecutor) Start

func (ex *RetryExecutor) Start() error

func (*RetryExecutor) Stop

func (ex *RetryExecutor) Stop() error

type TimeoutExecutor

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

func NewTimeoutExecutor

func NewTimeoutExecutor(container *container.DIContiner, wg *sync.WaitGroup) *TimeoutExecutor

func (*TimeoutExecutor) Name

func (ex *TimeoutExecutor) Name() string

func (*TimeoutExecutor) Start

func (ex *TimeoutExecutor) Start() error

func (*TimeoutExecutor) Stop

func (ex *TimeoutExecutor) Stop() error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL