mq

Documentation

Index

• Variables
• func Close()
• func FatalWorker(timeout time.Duration)
• func Init(uri string) (err error)
• 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)
  • func (q Queue) RunConsumerWithCancelAndDbConnConcurrent(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 RunConsumerForChannelWithCancelAndDbConn

func RunConsumerForChannelWithCancelAndDbConn(consumer ConsumerWithDbConn, messageChannel MessageChannel, database *db.Instance, concurrent bool, 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"
	RawTransactionsTokenIndexer Queue = "rawTransactionsTokenIndexer"
	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)

func (Queue) RunConsumerWithCancelAndDbConnConcurrent

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