brokers

package

v0.0.0-...-df48c48 Latest Latest Go to latest Published: Nov 21, 2015 License: BSD-2-Clause Imports: 11 Imported by: 1

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/TildaLabs/machinery

Links

Open Source Insights

Documentation ¶

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type AMQPBroker ¶

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

AMQPBroker represents an AMQP broker

func (*AMQPBroker) IsTaskRegistered ¶

func (amqpBroker *AMQPBroker) IsTaskRegistered(name string) bool

IsTaskRegistered returns true if the task is registered with this broker

func (*AMQPBroker) Publish ¶

func (amqpBroker *AMQPBroker) Publish(signature *signatures.TaskSignature) error

Publish places a new message on the default queue

func (*AMQPBroker) SetRegisteredTaskNames ¶

func (amqpBroker *AMQPBroker) SetRegisteredTaskNames(names []string)

SetRegisteredTaskNames sets registered task names

func (*AMQPBroker) StartConsuming ¶

func (amqpBroker *AMQPBroker) StartConsuming(consumerTag string, taskProcessor TaskProcessor) (bool, error)

StartConsuming enters a loop and waits for incoming messages

func (*AMQPBroker) StopConsuming ¶

func (amqpBroker *AMQPBroker) StopConsuming()

StopConsuming quits the loop

type Broker ¶

type Broker interface {
	SetRegisteredTaskNames(names []string)
	IsTaskRegistered(name string) bool
	StartConsuming(consumerTag string, p TaskProcessor) (bool, error)
	StopConsuming()
	Publish(task *signatures.TaskSignature) error
}

Broker - a common interface for all brokers

func NewAMQPBroker ¶

func NewAMQPBroker(cnf *config.Config) Broker

NewAMQPBroker creates new AMQPBroker instance

func NewEagerBroker ¶

func NewEagerBroker() Broker

func NewRedisBroker ¶

func NewRedisBroker(cnf *config.Config, host string) Broker

NewRedisBroker creates new RedisBroker instance

type EagerBroker ¶

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

func (*EagerBroker) AssignWorker ¶

func (e *EagerBroker) AssignWorker(p TaskProcessor)

Eager interface

func (*EagerBroker) IsTaskRegistered ¶

func (e *EagerBroker) IsTaskRegistered(name string) bool

func (*EagerBroker) Publish ¶

func (e *EagerBroker) Publish(task *signatures.TaskSignature) error

func (*EagerBroker) SetRegisteredTaskNames ¶

func (e *EagerBroker) SetRegisteredTaskNames(names []string)

Broker interface

func (*EagerBroker) StartConsuming ¶

func (e *EagerBroker) StartConsuming(consumerTag string, p TaskProcessor) (bool, error)

func (*EagerBroker) StopConsuming ¶

func (e *EagerBroker) StopConsuming()

type EagerMode ¶

type EagerMode interface {
	AssignWorker(p TaskProcessor)
}

type RedisBroker ¶

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

RedisBroker represents a Redis broker

func (*RedisBroker) IsTaskRegistered ¶

func (redisBroker *RedisBroker) IsTaskRegistered(name string) bool

IsTaskRegistered returns true if the task is registered with this broker

func (*RedisBroker) Publish ¶

func (redisBroker *RedisBroker) Publish(signature *signatures.TaskSignature) error

Publish places a new message on the default queue

func (*RedisBroker) SetRegisteredTaskNames ¶

func (redisBroker *RedisBroker) SetRegisteredTaskNames(names []string)

SetRegisteredTaskNames sets registered task names

func (*RedisBroker) StartConsuming ¶

func (redisBroker *RedisBroker) StartConsuming(consumerTag string, taskProcessor TaskProcessor) (bool, error)

StartConsuming enters a loop and waits for incoming messages

func (*RedisBroker) StopConsuming ¶

func (redisBroker *RedisBroker) StopConsuming()

StopConsuming quits the loop

type TaskProcessor ¶

type TaskProcessor interface {
	Process(signature *signatures.TaskSignature) error
}

TaskProcessor - can process a delivered task This will probably always be a worker instance

Source Files ¶

View all Source files

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