queues

May 23, 2022

Changes in this version

type SolutionQueue

+ func (queue SolutionQueue) EnqueueSolution(solution entities.Solution) error

Nov 17, 2021

Changes in this version

+ type MessagePublisher interface

+ PublishMessage func(queue string, messageID string, messageData interface{}) error

type SolutionQueue

+ MessagePublisher MessagePublisher

+ SolutionQueueName string

type SolutionResultHandler

+ func (handler SolutionResultHandler) MessageType() reflect.Type

Mar 27, 2021

Changes in this version

+ const SolutionQueueName

+ const SolutionResultConsumerName

+ const SolutionResultQueueName

+ type Client struct

+ func NewClient(queueDSN string, queueMaximalSize int) (Client, error)

+ func (client Client) Close() error

+ type MessageHandler interface

+ HandleMessage func(message amqp.Delivery)

+ type SolutionQueue struct

+ func NewSolutionQueue(client Client) SolutionQueue

+ func (queue SolutionQueue) AddSolution(solution entities.Solution) error

+ type SolutionResultConsumer struct

+ func NewSolutionResultConsumer(client Client, messageHandler MessageHandler) (SolutionResultConsumer, error)

+ func (consumer SolutionResultConsumer) Start()

+ func (consumer SolutionResultConsumer) StartConcurrently(concurrency int)

+ func (consumer SolutionResultConsumer) Stop() error

+ type SolutionResultHandler struct

+ Logger log.Logger

+ SolutionResultRegister SolutionResultRegister

+ func (handler SolutionResultHandler) HandleMessage(message amqp.Delivery)

+ type SolutionResultRegister interface

+ RegisterSolutionResult func(solution entities.Solution) error