wallet

Documentation

Index

• func ConsumeOrderResponseForWalletService()
• func ProcessWalletData(txn *models.Transaction)
• func PublishWalletUpdates(walletData *models.Wallet) error
• func SaveWalletData(walletData *models.Wallet) error

Functions

func ConsumeOrderResponseForWalletService

func ConsumeOrderResponseForWalletService()

ConsumeOrderResponseForWalletService consumes messages from the processed orders topic to save them to the merchant wallet

func ProcessWalletData

func ProcessWalletData(txn *models.Transaction)

update the merchant wallet with the data from the successful tranactions

func PublishWalletUpdates

func PublishWalletUpdates(walletData *models.Wallet) error

PublishWalletUpdates publishes the wallet updates for a merchant to the wallet-update-topic then the notification service picks up the message and notifies the merchant about the order

func SaveWalletData

func SaveWalletData(walletData *models.Wallet) error