jobqueue

Documentation

Index

• func NewFIFOQueue(capacity int) *fifoqueue
• func NewRabbitMQ(cfg config.RabbitMQ, loggingFormat string) *rabbitmq
• func NewRedisQueue(cfg config.Redis, loggingFormat string) *redisqueue

Functions

func NewFIFOQueue

func NewFIFOQueue(capacity int) *fifoqueue

NewFIFOQueue creates and returns a new fifoqueue instance.

func NewRabbitMQ

func NewRabbitMQ(cfg config.RabbitMQ, loggingFormat string) *rabbitmq

NewRabbitMQ creates and returns a new rabbitmq instance.

func NewRedisQueue

func NewRedisQueue(cfg config.Redis, loggingFormat string) *redisqueue

NewRedisQueue returns a redis queue.