rabbitmqtaskmanager

Documentation

Index

• type Consumer
  • func NewTaskConsumer(cnf dconfig.RabbitMQTaskManagerConnection, queueName string) Consumer
  • func (c Consumer) Consume(done <-chan bool, wg *sync.WaitGroup) (<-chan event.ProcessedEvent, error)
• type Queue
  • func (q *Queue) Enqueue(pe event.ProcessedEvent) error
• type TaskPublisher
  • func NewTaskPublisher(c dconfig.RabbitMQTaskManagerConnection, queueName string) *TaskPublisher
  • func (tm *TaskPublisher) Publish(pe event.ProcessedEvent) error

Types

type Consumer

type Consumer struct {
	ConnectionConfig dconfig.RabbitMQTaskManagerConnection
	QueueName        string
}

func NewTaskConsumer

func NewTaskConsumer(cnf dconfig.RabbitMQTaskManagerConnection, queueName string) Consumer

func (Consumer) Consume

func (c Consumer) Consume(done <-chan bool, wg *sync.WaitGroup) (<-chan event.ProcessedEvent, error)

type Queue

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

func (*Queue) Enqueue

func (q *Queue) Enqueue(pe event.ProcessedEvent) error

type TaskPublisher

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

func NewTaskPublisher

func NewTaskPublisher(c dconfig.RabbitMQTaskManagerConnection, queueName string) *TaskPublisher

func (*TaskPublisher) Publish

func (tm *TaskPublisher) Publish(pe event.ProcessedEvent) error