queues

package
v1.0.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 29, 2021 License: MIT Imports: 7 Imported by: 0

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 ...

func NewClient

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

NewClient ...

func (Client) Close

func (client Client) Close() error

Close ...

type MessageHandler

type MessageHandler interface {
	HandleMessage(message amqp.Delivery)
}

MessageHandler ...

type SolutionQueue

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

SolutionQueue ...

func NewSolutionQueue

func NewSolutionQueue(client Client) SolutionQueue

NewSolutionQueue ...

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) Start

func (consumer SolutionResultConsumer) Start()

Start ...

func (SolutionResultConsumer) StartConcurrently

func (consumer SolutionResultConsumer) StartConcurrently(concurrency int)

StartConcurrently ...

func (SolutionResultConsumer) Stop

func (consumer SolutionResultConsumer) Stop() error

Stop ...

type SolutionResultHandler

type SolutionResultHandler struct {
	SolutionResultRegister SolutionResultRegister
	Logger                 log.Logger
}

SolutionResultHandler ...

func (SolutionResultHandler) HandleMessage

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

HandleMessage ...

type SolutionResultRegister

type SolutionResultRegister interface {
	RegisterSolutionResult(solution entities.Solution) error
}

SolutionResultRegister ...

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL