mqImpl

Documentation

Overview

description: sync_eth

@author: xwc1125 @date: 2020/10/05

description: sync_eth

@author: xwc1125 @date: 2020/10/05

Index

• Constants
• type NotifyInfo
• type TransactionNotifyMq
  • func NewTxNotifyMq(w *mq.Wrapper) *TransactionNotifyMq
  • func (m *TransactionNotifyMq) Produce(tx *models.Transaction) error
• type TransactionRawMq
  • func NewTxRawMq(w *mq.Wrapper, es *es.ES) *TransactionRawMq
  • func (m *TransactionRawMq) Consumer()
  • func (m *TransactionRawMq) Produce(tx *models.Transaction) error

Constants

const (
	MqTxNotifyEx       = "tx.notify.ex"
	MqTxNotifyQueue    = "tx.notify.queue"
	MqTxNotifyRouteKey = "tx.notify.routekey"
)

const (
	MqTxRawEx       = "tx.raw.ex"
	MqTxRawQueue    = "tx.raw.queue"
	MqTxRawRouteKey = "tx.raw.routekey"
)

Types

type NotifyInfo

type NotifyInfo struct {
	ChainName string
	ChainType int64
	Tx        *models.Transaction
}

type TransactionNotifyMq

type TransactionNotifyMq struct {
	// contains filtered or unexported fields
}

func NewTxNotifyMq

func NewTxNotifyMq(w *mq.Wrapper) *TransactionNotifyMq

func (*TransactionNotifyMq) Produce

func (m *TransactionNotifyMq) Produce(tx *models.Transaction) error

type TransactionRawMq

type TransactionRawMq struct {
	// contains filtered or unexported fields
}

func NewTxRawMq

func NewTxRawMq(w *mq.Wrapper, es *es.ES) *TransactionRawMq

func (*TransactionRawMq) Consumer

func (m *TransactionRawMq) Consumer()

func (*TransactionRawMq) Produce

func (m *TransactionRawMq) Produce(tx *models.Transaction) error