machinery

Documentation

Index

• func NewMachineryTaskClient(config *MachineryConfig) task.TaskClientInterface
• type MachineryConfig
• type MachineryTaskClient
  • func (m *MachineryTaskClient) RegisterChainTaskHandler(taskName string, chainTaskHandler task.ChainTaskHandler) error
  • func (m *MachineryTaskClient) RegisterTaskHandler(taskName string, taskHandler task.TaskHandler) error
  • func (m *MachineryTaskClient) SubmitTask(task *task.Task) error

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