subscriber

Documentation

Index

• func CalculateWorkerCount(amountOfTopics int) int
• type Connector
  • func NewConnector(config *config.Controller, client types.Invoker, ...) Connector
• type Subscriber
  • func NewSubscriber(name string, topic string, consumer rabbitmq.QueueConsumer, ...) Subscriber

Functions

func CalculateWorkerCount

func CalculateWorkerCount(amountOfTopics int) int

CalculateWorkerCount will calculate the amount of workers that will be spawned based on the following formula: Available CPU's * 2 / Amount of Topics

Types

type Connector

type Connector interface {
	Start()
	End()
}

Connector is the interface for the RabbitMQ Connector. Allowing for starting & stopping it.

func NewConnector

func NewConnector(config *config.Controller, client types.Invoker, factory rabbitmq.QueueConsumerFactory) Connector

NewConnector generates a connector using the provided parameters.

type Subscriber

type Subscriber interface {
	Start() error
	Stop() error

	IsRunning() bool
}

Subscriber subscribes to an topic on Rabbit MQ. It can also be seen as a worker.

func NewSubscriber

func NewSubscriber(name string, topic string, consumer rabbitmq.QueueConsumer, client types.Invoker) Subscriber

NewSubscriber setups a new subscriber for the given topic.