machinery

package
v0.2.4 Latest Latest
Warning

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

Go to latest
Published: May 27, 2021 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewMachineryTaskClient

func NewMachineryTaskClient(config *MachineryConfig) task.TaskClientInterface

Types

type MachineryConfig

type MachineryConfig struct {
	BrokerConnectionUri        string
	DefaultQueueName           string
	ResultBackendConnectionUri string
	ResultsExpireInSeconds     int
	WorkersEnabled             bool
	WorkerAlias                string
	WorkerConcurrencyLimit     int // 0 == no limit
	MaxRetryCount              int // When set to -1
	RetryTimeoutSeconds        int
}

type MachineryTaskClient

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

func (*MachineryTaskClient) RegisterChainTaskHandler

func (m *MachineryTaskClient) RegisterChainTaskHandler(taskName string, chainTaskHandler task.ChainTaskHandler) error

func (*MachineryTaskClient) RegisterTaskHandler

func (m *MachineryTaskClient) RegisterTaskHandler(taskName string, taskHandler task.TaskHandler) error

func (*MachineryTaskClient) SubmitTask

func (m *MachineryTaskClient) SubmitTask(task *task.Task) error

Jump to

Keyboard shortcuts

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