mq

Documentation

Index

• Variables
• func Close()
• func FatalWorker(timeout time.Duration)
• func Init(uri string) (err error)
• func RestoreConnectionWorker(uri string, queue Queue, timeout time.Duration)
• func RunConsumerForChannelWithCancelAndDbConn(consumer ConsumerWithDbConn, messageChannel MessageChannel, ...)
• type Consumer
• type ConsumerWithDbConn
• type MessageChannel
  • func (mc MessageChannel) GetMessage() amqp.Delivery
• type Queue
  • func (q Queue) Declare() error
  • func (q Queue) GetMessageChannel() MessageChannel
  • func (q Queue) Publish(body []byte) error
  • func (q Queue) RunConsumer(consumer Consumer)
  • func (q Queue) RunConsumerWithCancel(consumer Consumer, ctx context.Context)
  • func (q Queue) RunConsumerWithCancelAndDbConn(consumer ConsumerWithDbConn, database *db.Instance, ctx context.Context)

Variables

var (
	PrefetchCount int
)

Functions

func Close

func Close()

func FatalWorker

func FatalWorker(timeout time.Duration)

func Init

func Init(uri string) (err error)

func RestoreConnectionWorker

func RestoreConnectionWorker(uri string, queue Queue, timeout time.Duration)

func RunConsumerForChannelWithCancelAndDbConn

func RunConsumerForChannelWithCancelAndDbConn(consumer ConsumerWithDbConn, messageChannel MessageChannel, database *db.Instance, ctx context.Context)

Types

type Consumer

type Consumer func(amqp.Delivery)

type ConsumerWithDbConn

type ConsumerWithDbConn func(*db.Instance, amqp.Delivery)

type MessageChannel

type MessageChannel <-chan amqp.Delivery

func (MessageChannel) GetMessage

func (mc MessageChannel) GetMessage() amqp.Delivery

type Queue

type Queue string

const (
	TxNotifications         Queue = "txNotifications"
	Subscriptions           Queue = "subscriptions"
	RawTransactions         Queue = "rawTransactions"
	RawTransactionsSearcher Queue = "rawTransactionsSearcher"
	TokensRegistration      Queue = "tokensRegistration"
)

func (Queue) Declare

func (q Queue) Declare() error

func (Queue) GetMessageChannel

func (q Queue) GetMessageChannel() MessageChannel

func (Queue) Publish

func (q Queue) Publish(body []byte) error

func (Queue) RunConsumer

func (q Queue) RunConsumer(consumer Consumer)

func (Queue) RunConsumerWithCancel

func (q Queue) RunConsumerWithCancel(consumer Consumer, ctx context.Context)

func (Queue) RunConsumerWithCancelAndDbConn

func (q Queue) RunConsumerWithCancelAndDbConn(consumer ConsumerWithDbConn, database *db.Instance, ctx context.Context)