database

Documentation

Index

• Variables
• func SyncWithDynamo(opType, primaryIndex, txData, txStatus, resId string, ...) error
• func SyncWithPortalDB(...)
• type DynamoClient
  • func (dc *DynamoClient) AddTransactionData(transactionID, data, status, redId, paymentInfo string) error
  • func (dc *DynamoClient) CreateConnection() error
  • func (dc *DynamoClient) DeleteTransactionData(transactionID string) error
  • func (dc *DynamoClient) GetTransactionData(transactionID string) (*string, *string, *string, *string, error)
  • func (dc *DynamoClient) UpdateTransactionData(transactionID, data, status, resId, paymentInfo string) error
• type Item
• type Key
• type TransactionInfo
• type TransactionInfoUpdate

Variables

var LOGGER = logging.MustGetLogger("database-client")

Functions

func SyncWithDynamo

func SyncWithDynamo(opType, primaryIndex, txData, txStatus, resId string, logHandler transaction.Payment) error

func SyncWithPortalDB

func SyncWithPortalDB(
	operationType, msgType, msgName, originalMsgId, orginalInstructionId, instructionId, txHash, creditorPaymentAddress string,
	logHandler transaction.Payment,
	fundHandler *transaction.CreateFundingOpereations,
	firebaseData *sendmodel.StatusData)

Types

type DynamoClient

type DynamoClient struct {
	ProfileFile string
	ProfileName string
	Region      string
	TableName   string
	// contains filtered or unexported fields
}

var DC DynamoClient

func (*DynamoClient) AddTransactionData

func (dc *DynamoClient) AddTransactionData(transactionID, data, status, redId, paymentInfo string) error

func (*DynamoClient) CreateConnection

func (dc *DynamoClient) CreateConnection() error

func (*DynamoClient) DeleteTransactionData

func (dc *DynamoClient) DeleteTransactionData(transactionID string) error

func (*DynamoClient) GetTransactionData

func (dc *DynamoClient) GetTransactionData(transactionID string) (*string, *string, *string, *string, error)

func (*DynamoClient) UpdateTransactionData

func (dc *DynamoClient) UpdateTransactionData(transactionID, data, status, resId, paymentInfo string) error

type Item

type Item struct {
	Transactionid string          `json:"transactionid"`
	Info          TransactionInfo `json:"info"`
}

type Key

type Key struct {
	Transactionid string `json:"transactionid"`
}

type TransactionInfo

type TransactionInfo struct {
	TxData      string `json:"tx_data"`
	TxStatus    string `json:"tx_status"`
	ResId       string `json:"res_id"`
	PaymentInfo string `json:"payment_info"`
}

type TransactionInfoUpdate

type TransactionInfoUpdate struct {
	TxData      string `json:":d,omitempty"`
	TxStatus    string `json:":s,omitempty"`
	ResId       string `json:":i,omitempty"`
	PaymentInfo string `json:":p,omitempty"`
}