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) GetWithFee(txId string) (*entity.Transfer, error)
  • func (tr Repository) GetWithPreloads(txId string) (*entity.Transfer, error)
  • func (tr Repository) Save(tx *entity.Transfer) error
  • func (tr *Repository) SaveRecoveredTxn(ct *model.Transfer) error
  • func (tr Repository) UpdateStatusCompleted(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)

Returns Transfer. Returns nil if not found

func (Repository) GetInitialAndSignatureSubmittedTx

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

func (*Repository) GetUnprocessedTransfers

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

func (Repository) GetWithFee

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

Returns Transfer with preloaded Fee table. Returns nil if not found

func (Repository) GetWithPreloads

func (tr Repository) GetWithPreloads(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) UpdateStatusCompleted

func (tr Repository) UpdateStatusCompleted(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