queue

Documentation

Index

• type DeadLetterQueue
  • func NewDeadLetterQueue(dataAccessLayer data.Dal) (*DeadLetterQueue, error)
  • func (d *DeadLetterQueue) Add(event_name string, payload string) error
  • func (d *DeadLetterQueue) AddEvent(event *entities.Event, callback string) error
  • func (d *DeadLetterQueue) StartConsuming(size int, poll_interval time.Duration, callback func(callbackItem interface{}))
• type Queue
• type RedisQueue
  • func NewRedisQueue(connectionString string, queueName string) (*RedisQueue, error)
  • func (r *RedisQueue) Add(eventName string, payload string) error
  • func (r *RedisQueue) AddEvent(event *entities.Event, callback string) error
  • func (r *RedisQueue) Consume(delivery rmq.Delivery)
  • func (r *RedisQueue) StartConsuming(size int, pollInterval time.Duration, callback func(callbackItem interface{}))

Types

type DeadLetterQueue

type DeadLetterQueue struct {
	Dal data.Dal
}

func NewDeadLetterQueue

func NewDeadLetterQueue(dataAccessLayer data.Dal) (*DeadLetterQueue, error)

func (*DeadLetterQueue) Add

func (d *DeadLetterQueue) Add(event_name string, payload string) error

func (*DeadLetterQueue) AddEvent

func (d *DeadLetterQueue) AddEvent(event *entities.Event, callback string) error

func (*DeadLetterQueue) StartConsuming

func (d *DeadLetterQueue) StartConsuming(size int, poll_interval time.Duration, callback func(callbackItem interface{}))

type Queue

type Queue interface {
	Add(eventName string, payload string) error
	AddEvent(event *entities.Event, callback string) error
	StartConsuming(size int, pollInterval time.Duration, callback func(callbackItem interface{}))
}

type RedisQueue

type RedisQueue struct {
	Queue rmq.Queue
	// contains filtered or unexported fields
}

func NewRedisQueue

func NewRedisQueue(connectionString string, queueName string) (*RedisQueue, error)

func (*RedisQueue) Add

func (r *RedisQueue) Add(eventName string, payload string) error

func (*RedisQueue) AddEvent

func (r *RedisQueue) AddEvent(event *entities.Event, callback string) error

func (*RedisQueue) Consume

func (r *RedisQueue) Consume(delivery rmq.Delivery)

Interface from rmq

func (*RedisQueue) StartConsuming

func (r *RedisQueue) StartConsuming(size int, pollInterval time.Duration, callback func(callbackItem interface{}))