nats

package

v0.0.0-...-4670c47 Latest Latest Go to latest Published: Dec 2, 2020 License: MIT Imports: 11 Imported by: 0

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

View Source

const (
	// TaskEventChannel for task event pubsub
	TaskEventChannel string = "gocelerytaskevent"
)

This section is empty.

This section is empty.

type Broker struct {
	sync.Mutex
	// contains filtered or unexported fields
}

Broker implements Nats broker

func (b *Broker) Close() error

Close the broker and cleans up resources

func (b *Broker) Connect(uri string) error

Connect to rabbitmq

func (b *Broker) GetTaskResult(taskID string) <-chan *broker.Message

GetTaskResult fetchs task result for the specified taskID

func (b *Broker) GetTasks(queue string) <-chan *broker.Message

GetTasks waits and fetches the tasks from queue

func (b *Broker) PublishTask(queueName, key string, message *broker.Message, ignoreResults bool) error

PublishTask sends a task to queue

func (b *Broker) PublishTaskEvent(key string, message *broker.Message) error

PublishTaskEvent sends task events back to event queue

func (b *Broker) PublishTaskResult(key string, message *broker.Message) error

PublishTaskResult sends task result back to task queue