rabbitmqchanneltaskmanager

Documentation

Index

• type Consumer
  • func NewTaskConsumer(messageChannel <-chan channel.Message, channelSize int) 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(inputChannel chan<- []byte) *TaskPublisher
  • func (tm *TaskPublisher) Publish(pe event.ProcessedEvent) error

Types

type Consumer

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

func NewTaskConsumer

func NewTaskConsumer(messageChannel <-chan channel.Message, channelSize int) 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(inputChannel chan<- []byte) *TaskPublisher

func (*TaskPublisher) Publish

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