internal

Documentation

Index

• Constants
• Variables
• func InitConfig(confPath string)
• func InitEngine(ginMode string) *gin.Engine
• func InitMQ(url string)
• func ParseArgs(defaultPort, defaultConfigPath string) (string, string)
• type ConsumerDatabase
  • func (c ConsumerDatabase) Callback(msg amqp.Delivery) error

Constants

const (
	// End consumer of published transactions. Not consumed on blockatlas
	TxNotifications mq.Queue = "txNotifications"
	// Address:coin subscriptions
	Subscriptions       mq.Queue = "subscriptions"
	SubscriptionsTokens mq.Queue = "subscriptions_tokens"

	// Transactions to process, if match subscriptions, pushed to TxNotifications
	RawTransactions         mq.Queue    = "rawTransactions"
	RawTokens               mq.Queue    = "rawTokens"
	RawTransactionsExchange mq.Exchange = "raw_transactions"
)

Variables

var (
	Build = "dev"
	Date  = time.Now().String()
)

Functions

func InitConfig

func InitConfig(confPath string)

func InitEngine

func InitEngine(ginMode string) *gin.Engine

func InitMQ

func InitMQ(url string)

func ParseArgs

func ParseArgs(defaultPort, defaultConfigPath string) (string, string)

Types

type ConsumerDatabase

type ConsumerDatabase struct {
	Database *db.Instance
	Delivery func(*db.Instance, amqp.Delivery) error
	Tag      string
}

func (ConsumerDatabase) Callback

func (c ConsumerDatabase) Callback(msg amqp.Delivery) error