Documentation
¶
Index ¶
Constants ¶
View Source
const ( SolutionQueueName = "solution_queue" SolutionResultQueueName = "solution_result_queue" )
...
View Source
const SolutionResultConsumerName = SolutionResultQueueName + "_consumer"
SolutionResultConsumerName ...
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
Client ...
type MessageHandler ¶
MessageHandler ...
type SolutionQueue ¶
type SolutionQueue struct {
// contains filtered or unexported fields
}
SolutionQueue ...
func (SolutionQueue) AddSolution ¶
func (queue SolutionQueue) AddSolution(solution entities.Solution) error
AddSolution ...
type SolutionResultConsumer ¶
type SolutionResultConsumer struct {
// contains filtered or unexported fields
}
SolutionResultConsumer ...
func NewSolutionResultConsumer ¶
func NewSolutionResultConsumer( client Client, messageHandler MessageHandler, ) (SolutionResultConsumer, error)
NewSolutionResultConsumer ...
func (SolutionResultConsumer) StartConcurrently ¶
func (consumer SolutionResultConsumer) StartConcurrently(concurrency int)
StartConcurrently ...
type SolutionResultHandler ¶
type SolutionResultHandler struct {
SolutionResultRegister SolutionResultRegister
Logger log.Logger
}
SolutionResultHandler ...
func (SolutionResultHandler) HandleMessage ¶
func (handler SolutionResultHandler) HandleMessage(message amqp.Delivery)
HandleMessage ...
type SolutionResultRegister ¶
SolutionResultRegister ...
Click to show internal directories.
Click to hide internal directories.