events

Documentation

Index

• type AccountCredited
  • func (a AccountCredited) Decode(data []byte) (interface{}, error)
  • func (a AccountCredited) Encode(data interface{}) ([]byte, error)
• type AccountDebited
  • func (ad AccountDebited) Decode(data []byte) (interface{}, error)
  • func (ad AccountDebited) Encode(data interface{}) ([]byte, error)
• type AccountDetailsUpdated
  • func (a AccountDetailsUpdated) Decode(data []byte) (interface{}, error)
  • func (a AccountDetailsUpdated) Encode(data interface{}) ([]byte, error)
• type CustomerProfileUpdated
  • func (c CustomerProfileUpdated) Decode(data []byte) (interface{}, error)
  • func (c CustomerProfileUpdated) Encode(data interface{}) ([]byte, error)
• type MessageCreated
  • func (m MessageCreated) Decode(data []byte) (interface{}, error)
  • func (m MessageCreated) Encode(data interface{}) ([]byte, error)

Types

type AccountCredited

type AccountCredited struct {
	ID   string `json:"id"`
	Type string `json:"type"`
	Body struct {
		AccountNo     int64   `json:"account_no"`
		TransactionId int64   `json:"transaction_id"`
		Amount        float64 `json:"amount"`
		Reason        string  `json:"reason"`
		DebitedFrom   int64   `json:"debited_from"`
		CreditedAt    int64   `json:"credited_at"`
		Location      string  `json:"location"`
	} `json:"body"`
	Timestamp int64 `json:"timestamp"`
}

func (AccountCredited) Decode

func (a AccountCredited) Decode(data []byte) (interface{}, error)

func (AccountCredited) Encode

func (a AccountCredited) Encode(data interface{}) ([]byte, error)

type AccountDebited

type AccountDebited struct {
	ID   string `json:"id"`
	Type string `json:"type"`
	Body struct {
		AccountNo     int64   `json:"account_no"`
		Amount        float64 `json:"amount"`
		TransactionId int64   `json:"transaction_id"`
		Reason        string  `json:"reason"`
		CreditedTo    int64   `json:"credited_to"`
		DebitedAt     int64   `json:"debited_at"`
		Location      string  `json:"location"`
	} `json:"body"`
	Timestamp int64 `json:"timestamp"`
}

func (AccountDebited) Decode

func (ad AccountDebited) Decode(data []byte) (interface{}, error)

func (AccountDebited) Encode

func (ad AccountDebited) Encode(data interface{}) ([]byte, error)

type AccountDetailsUpdated

type AccountDetailsUpdated struct {
	ID   string `json:"id"`
	Type string `json:"type"`
	Body struct {
		AccountNo   int64     `json:"account_no"`
		AccountType string    `json:"account_type"`
		CustomerID  uuid.UUID `json:"customer_id"`
		Branch      string    `json:"branch"`
		BranchCode  int       `json:"branch_code"`
		UpdatedAt   int64     `json:"updated_at"`
	} `json:"body"`
	Timestamp int64 `json:"timestamp"`
}

func (AccountDetailsUpdated) Decode

func (a AccountDetailsUpdated) Decode(data []byte) (interface{}, error)

func (AccountDetailsUpdated) Encode

func (a AccountDetailsUpdated) Encode(data interface{}) ([]byte, error)

type CustomerProfileUpdated

type CustomerProfileUpdated struct {
	ID   uuid.UUID `json:"id"`
	Type string    `json:"type"`
	Body struct {
		CustomerID     uuid.UUID `json:"customer_id"`
		CustomerName   string    `json:"customer_name"`
		NIC            string    `json:"nic"`
		ContactDetails struct {
			Phone   string `json:"phone"`
			Email   string `json:"email"`
			Address string `json:"address"`
		} `json:"contact_details"`
		DateOfBirth string `json:"date_of_birth"`
		UpdatedAt   int64  `json:"updated_at"`
	} `json:"body"`
	Timestamp int64 `json:"timestamp"`
}

func (CustomerProfileUpdated) Decode

func (c CustomerProfileUpdated) Decode(data []byte) (interface{}, error)

func (CustomerProfileUpdated) Encode

func (c CustomerProfileUpdated) Encode(data interface{}) ([]byte, error)

type MessageCreated

type MessageCreated struct {
	ID   string `json:"id"`
	Type string `json:"type"`
	Body struct {
		CustomerID uuid.UUID `json:"customer_id"`
		Text       string    `json:"text"`
		Phone      string    `json:"phone"`
		Email      string    `json:"email"`
		Address    string    `json:"address"`
	} `json:"body"`
	Timestamp int64 `json:"timestamp"`
}

func (MessageCreated) Decode

func (m MessageCreated) Decode(data []byte) (interface{}, error)

func (MessageCreated) Encode

func (m MessageCreated) Encode(data interface{}) ([]byte, error)