notifier

Documentation

Index

• Constants
• Variables
• func GetTransactionsFromDelivery(delivery amqp.Delivery, ctx context.Context) (blockatlas.Txs, error)
• func RunNotifier(database *db.Instance, delivery amqp.Delivery)
• func ToUniqueAddresses(addresses []string) []string
• type TransactionNotification

Constants

const DefaultPushNotificationsBatchLimit = 50

Variables

var MaxPushNotificationsBatchLimit uint = DefaultPushNotificationsBatchLimit

Functions

func GetTransactionsFromDelivery

func GetTransactionsFromDelivery(delivery amqp.Delivery, ctx context.Context) (blockatlas.Txs, error)

func RunNotifier

func RunNotifier(database *db.Instance, delivery amqp.Delivery)

func ToUniqueAddresses

func ToUniqueAddresses(addresses []string) []string

Types

type TransactionNotification

type TransactionNotification struct {
	Action blockatlas.TransactionType `json:"action"`
	Result blockatlas.Tx              `json:"result"`
}