transfer

Documentation

Index

• type Repository
  • func NewRepository(dbClient *gorm.DB) *Repository
  • func (tr Repository) Create(ct *model.Transfer) (*entity.Transfer, error)
  • func (tr Repository) GetByTransactionId(txId string) (*entity.Transfer, error)
  • func (tr Repository) GetInitialAndSignatureSubmittedTx() ([]*entity.Transfer, error)
  • func (tr *Repository) GetUnprocessedTransfers() ([]*entity.Transfer, error)
  • func (tr Repository) GetWithMessages(txId string) (*entity.Transfer, error)
  • func (tr Repository) Save(tx *entity.Transfer) error
  • func (tr *Repository) SaveRecoveredTxn(ct *model.Transfer) error
  • func (tr Repository) UpdateEthTxMined(txId string) error
  • func (tr Repository) UpdateEthTxReverted(txId string) error
  • func (tr Repository) UpdateEthTxSubmitted(txId string, hash string) error
  • func (tr Repository) UpdateStatusCompleted(txId string) error
  • func (tr Repository) UpdateStatusEthTxMsgFailed(txId string) error
  • func (tr Repository) UpdateStatusEthTxMsgMined(txId string) error
  • func (tr Repository) UpdateStatusEthTxMsgSubmitted(txId string) error
  • func (tr Repository) UpdateStatusInsufficientFee(txId string) error
  • func (tr Repository) UpdateStatusSignatureFailed(txId string) error
  • func (tr Repository) UpdateStatusSignatureMined(txId string) error
  • func (tr Repository) UpdateStatusSignatureSubmitted(txId string) error

Types

type Repository

type Repository struct {
	// contains filtered or unexported fields
}

func NewRepository

func NewRepository(dbClient *gorm.DB) *Repository

func (Repository) Create

func (tr Repository) Create(ct *model.Transfer) (*entity.Transfer, error)

Create creates new record of Transfer

func (Repository) GetByTransactionId

func (tr Repository) GetByTransactionId(txId string) (*entity.Transfer, error)

func (Repository) GetInitialAndSignatureSubmittedTx

func (tr Repository) GetInitialAndSignatureSubmittedTx() ([]*entity.Transfer, error)

func (*Repository) GetUnprocessedTransfers

func (tr *Repository) GetUnprocessedTransfers() ([]*entity.Transfer, error)

func (Repository) GetWithMessages

func (tr Repository) GetWithMessages(txId string) (*entity.Transfer, error)

func (Repository) Save

func (tr Repository) Save(tx *entity.Transfer) error

Save updates the provided Transfer instance

func (*Repository) SaveRecoveredTxn

func (tr *Repository) SaveRecoveredTxn(ct *model.Transfer) error

func (Repository) UpdateEthTxMined

func (tr Repository) UpdateEthTxMined(txId string) error

func (Repository) UpdateEthTxReverted

func (tr Repository) UpdateEthTxReverted(txId string) error

func (Repository) UpdateEthTxSubmitted

func (tr Repository) UpdateEthTxSubmitted(txId string, hash string) error

func (Repository) UpdateStatusCompleted

func (tr Repository) UpdateStatusCompleted(txId string) error

func (Repository) UpdateStatusEthTxMsgFailed

func (tr Repository) UpdateStatusEthTxMsgFailed(txId string) error

func (Repository) UpdateStatusEthTxMsgMined

func (tr Repository) UpdateStatusEthTxMsgMined(txId string) error

func (Repository) UpdateStatusEthTxMsgSubmitted

func (tr Repository) UpdateStatusEthTxMsgSubmitted(txId string) error

func (Repository) UpdateStatusInsufficientFee

func (tr Repository) UpdateStatusInsufficientFee(txId string) error

func (Repository) UpdateStatusSignatureFailed

func (tr Repository) UpdateStatusSignatureFailed(txId string) error

func (Repository) UpdateStatusSignatureMined

func (tr Repository) UpdateStatusSignatureMined(txId string) error

func (Repository) UpdateStatusSignatureSubmitted

func (tr Repository) UpdateStatusSignatureSubmitted(txId string) error