Versions in this module Expand all Collapse all v0 v0.1.2 Aug 6, 2021 v0.1.1 Jul 8, 2021 Changes in this version + var LOGGER = logging.MustGetLogger("message-handler") + func HandleErrMsg(pbsData sendmodel.SendPayload, op *kafka.KafkaOpreations) + func OFI_Camt026(sendPayload camt026pbstruct.SendPayload, op *kafka.KafkaOpreations) + func OFI_Camt029(data camt029pbstruct.SendPayload, op *kafka.KafkaOpreations) + func OFI_Ibwf001(data ibwf001pbstruct.SendPayload, op *kafka.KafkaOpreations) + func OFI_Pacs002(data pacs002Pbstruct.SendPayload, op *kafka.KafkaOpreations) + func RFI_Camt056(data camt056pbstruct.SendPayload, op *kafka.KafkaOpreations) + func RFI_Camt087(data camt087pbstruct.SendPayload, op *kafka.KafkaOpreations) + func RFI_Ibwf002(data ibwfPbStruct.SendPayload, op *kafka.KafkaOpreations) + func RFI_Pacs008(sendPayload pbstruct.SendPayload, op *kafka.KafkaOpreations) + func RFI_Pacs009(data pacs009Pbstruct.SendPayload, op *kafka.KafkaOpreations) + type FbTrxLog struct + ParticipantID string + TransactionMemo map[string]interface{} + type PaymentOperations struct + DbClient *DB.PostgreDatabaseClient + KafkaActor *kafka.KafkaOpreations + ResponseHandler *parse.ResponseHandler + XsdSchemas []*xsd.Schema + func InitiatePaymentOperations() (PaymentOperations, error) + func (op *PaymentOperations) Camt026(camt026 message_converter.Camt026) ([]byte, error) + func (op *PaymentOperations) Camt029(camt029 message_converter.Camt029) ([]byte, error) + func (op *PaymentOperations) Camt056(camt056 message_converter.Camt056) ([]byte, error) + func (op *PaymentOperations) Camt087(camt087 message_converter.Camt087) ([]byte, error) + func (op *PaymentOperations) Ibwf001(ibwf001 message_converter.Ibwf001) ([]byte, error) + func (op *PaymentOperations) Ibwf002(ibwf002 message_converter.Ibwf002) ([]byte, error) + func (op *PaymentOperations) Iso20022Validator(data []byte, bic, messageType, target string) ([]byte, error) + func (op *PaymentOperations) Pacs002(pacs002 message_converter.Pacs002, target, BIC string) ([]byte, error) + func (op *PaymentOperations) Pacs004_Cancellation(pacs004 message_converter.Pacs004) ([]byte, error) + func (op *PaymentOperations) Pacs004_Rdo(pacs004 message_converter.Pacs004) ([]byte, error) + func (op *PaymentOperations) Pacs008(pacs008 message_converter.Pacs008) ([]byte, error) + func (op *PaymentOperations) Pacs009(pacs009 message_converter.Pacs009) ([]byte, error) + func (op *PaymentOperations) ValidateRequest(raw *http.Request, bic, target string) ([]byte, []byte, string, error)