repository

Documentation

Index

• type MockFeeRepository
  • func (mfr *MockFeeRepository) Create(entity *entity.Fee) error
  • func (mfr *MockFeeRepository) Get(id string) (*entity.Fee, error)
  • func (mfr *MockFeeRepository) GetAllSubmittedIds() ([]*entity.Fee, error)
  • func (mfr *MockFeeRepository) UpdateStatusCompleted(id string) error
  • func (mfr *MockFeeRepository) UpdateStatusFailed(id string) error
• type MockMessageRepository
  • func (m *MockMessageRepository) Create(message *entity.Message) error
  • func (m *MockMessageRepository) Exist(transferID, signature, hash string) (bool, error)
  • func (m *MockMessageRepository) Get(transferID string) ([]entity.Message, error)
  • func (m *MockMessageRepository) GetMessageWith(transferID, signature, hash string) (*entity.Message, error)
• type MockScheduleRepository
  • func (m *MockScheduleRepository) Create(entity *entity.Schedule) error
  • func (m *MockScheduleRepository) Get(txId string) (*entity.Schedule, error)
  • func (m *MockScheduleRepository) GetAllSubmittedIds() ([]*entity.Schedule, error)
  • func (m *MockScheduleRepository) GetReceiverTransferByTransactionID(id string) (*entity.Schedule, error)
  • func (m *MockScheduleRepository) UpdateStatusCompleted(txId string) error
  • func (m *MockScheduleRepository) UpdateStatusFailed(txId string) error
• type MockStatusRepository
  • func (msr *MockStatusRepository) Create(entityID string, timestamp int64) error
  • func (msr *MockStatusRepository) Get(entityID string) (int64, error)
  • func (msr *MockStatusRepository) Update(entityID string, timestamp int64) error
• type MockTransferRepository
  • func (m *MockTransferRepository) Create(ct *payload.Transfer) (*entity.Transfer, error)
  • func (m *MockTransferRepository) GetByTransactionId(txId string) (*entity.Transfer, error)
  • func (m *MockTransferRepository) GetWithFee(txId string) (*entity.Transfer, error)
  • func (m *MockTransferRepository) GetWithPreloads(txId string) (*entity.Transfer, error)
  • func (m *MockTransferRepository) Paged(req *transfer.PagedRequest) ([]*entity.Transfer, int64, error)
  • func (m *MockTransferRepository) UpdateFee(txId, fee string) error
  • func (m *MockTransferRepository) UpdateStatusCompleted(txId string) error
  • func (m *MockTransferRepository) UpdateStatusFailed(txId string) error

Types

type MockFeeRepository

type MockFeeRepository struct {
	mock.Mock
}

func (*MockFeeRepository) Create

func (mfr *MockFeeRepository) Create(entity *entity.Fee) error

func (*MockFeeRepository) Get

func (mfr *MockFeeRepository) Get(id string) (*entity.Fee, error)

func (*MockFeeRepository) GetAllSubmittedIds

func (mfr *MockFeeRepository) GetAllSubmittedIds() ([]*entity.Fee, error)

func (*MockFeeRepository) UpdateStatusCompleted

func (mfr *MockFeeRepository) UpdateStatusCompleted(id string) error

func (*MockFeeRepository) UpdateStatusFailed

func (mfr *MockFeeRepository) UpdateStatusFailed(id string) error

type MockMessageRepository

type MockMessageRepository struct {
	mock.Mock
}

func (*MockMessageRepository) Create

func (m *MockMessageRepository) Create(message *entity.Message) error

func (*MockMessageRepository) Exist

func (m *MockMessageRepository) Exist(transferID, signature, hash string) (bool, error)

func (*MockMessageRepository) Get

func (m *MockMessageRepository) Get(transferID string) ([]entity.Message, error)

func (*MockMessageRepository) GetMessageWith

func (m *MockMessageRepository) GetMessageWith(transferID, signature, hash string) (*entity.Message, error)

type MockScheduleRepository

type MockScheduleRepository struct {
	mock.Mock
}

func (*MockScheduleRepository) Create

func (m *MockScheduleRepository) Create(entity *entity.Schedule) error

func (*MockScheduleRepository) Get

func (m *MockScheduleRepository) Get(txId string) (*entity.Schedule, error)

func (*MockScheduleRepository) GetAllSubmittedIds

func (m *MockScheduleRepository) GetAllSubmittedIds() ([]*entity.Schedule, error)

func (*MockScheduleRepository) GetReceiverTransferByTransactionID

func (m *MockScheduleRepository) GetReceiverTransferByTransactionID(id string) (*entity.Schedule, error)

func (*MockScheduleRepository) UpdateStatusCompleted

func (m *MockScheduleRepository) UpdateStatusCompleted(txId string) error

func (*MockScheduleRepository) UpdateStatusFailed

func (m *MockScheduleRepository) UpdateStatusFailed(txId string) error

type MockStatusRepository

type MockStatusRepository struct {
	mock.Mock
}

func (*MockStatusRepository) Create

func (msr *MockStatusRepository) Create(entityID string, timestamp int64) error

func (*MockStatusRepository) Get

func (msr *MockStatusRepository) Get(entityID string) (int64, error)

func (*MockStatusRepository) Update

func (msr *MockStatusRepository) Update(entityID string, timestamp int64) error

type MockTransferRepository

type MockTransferRepository struct {
	mock.Mock
}

func (*MockTransferRepository) Create

func (m *MockTransferRepository) Create(ct *payload.Transfer) (*entity.Transfer, error)

func (*MockTransferRepository) GetByTransactionId

func (m *MockTransferRepository) GetByTransactionId(txId string) (*entity.Transfer, error)

func (*MockTransferRepository) GetWithFee

func (m *MockTransferRepository) GetWithFee(txId string) (*entity.Transfer, error)

func (*MockTransferRepository) GetWithPreloads

func (m *MockTransferRepository) GetWithPreloads(txId string) (*entity.Transfer, error)

func (*MockTransferRepository) Paged

func (m *MockTransferRepository) Paged(req *transfer.PagedRequest) ([]*entity.Transfer, int64, error)

func (*MockTransferRepository) UpdateFee

func (m *MockTransferRepository) UpdateFee(txId, fee string) error

func (*MockTransferRepository) UpdateStatusCompleted

func (m *MockTransferRepository) UpdateStatusCompleted(txId string) error

func (*MockTransferRepository) UpdateStatusFailed

func (m *MockTransferRepository) UpdateStatusFailed(txId string) error