mocks

package
v1.0.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 10, 2026 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Overview

Copyright 2024 Blnk Finance Authors.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockDataSource 

type MockDataSource struct {
	mock.Mock
}

MockDataSource is a mock implementation of the IDataSource interface

func (*MockDataSource) ChainPendingTransactions 

func (m *MockDataSource) ChainPendingTransactions(ctx context.Context, cutoff time.Time, batchSize int) (int, error)

func (*MockDataSource) ClaimPendingOutboxEntries 

func (m *MockDataSource) ClaimPendingOutboxEntries(ctx context.Context, batchSize int, lockDuration time.Duration) ([]model.LineageOutbox, error)

func (*MockDataSource) CountQueuedTransactionsForPairLane 

func (m *MockDataSource) CountQueuedTransactionsForPairLane(ctx context.Context, source, destination, currency, lane string) (int, error)

func (*MockDataSource) CountUnchainedTransactions 

func (m *MockDataSource) CountUnchainedTransactions(ctx context.Context, cutoff time.Time) (int64, error)

func (*MockDataSource) CreateAPIKey 

func (m *MockDataSource) CreateAPIKey(ctx context.Context, name, ownerID string, scopes []string, expiresAt time.Time) (*model.APIKey, error)

func (*MockDataSource) CreateAccount 

func (m *MockDataSource) CreateAccount(account model.Account) (model.Account, error)

func (*MockDataSource) CreateBalance 

func (m *MockDataSource) CreateBalance(balance model.Balance) (model.Balance, error)

func (*MockDataSource) CreateIdentity 

func (m *MockDataSource) CreateIdentity(identity model.Identity) (model.Identity, error)

func (*MockDataSource) CreateLedger 

func (m *MockDataSource) CreateLedger(ledger model.Ledger) (model.Ledger, error)

func (*MockDataSource) CreateMonitor 

func (m *MockDataSource) CreateMonitor(monitor model.BalanceMonitor) (model.BalanceMonitor, error)

func (*MockDataSource) DeleteAccount 

func (m *MockDataSource) DeleteAccount(id string) error

func (*MockDataSource) DeleteIdentity 

func (m *MockDataSource) DeleteIdentity(id string) error

func (*MockDataSource) DeleteLineageMapping 

func (m *MockDataSource) DeleteLineageMapping(ctx context.Context, id int64) error

func (*MockDataSource) DeleteMatchingRule 

func (m *MockDataSource) DeleteMatchingRule(ctx context.Context, id string) error

func (*MockDataSource) DeleteMonitor 

func (m *MockDataSource) DeleteMonitor(id string) error

func (*MockDataSource) FetchAndGroupExternalTransactions 

func (m *MockDataSource) FetchAndGroupExternalTransactions(ctx context.Context, uploadID string, groupCriteria string, batchSize int, offset int64) (map[string][]*model.Transaction, error)

func (*MockDataSource) GetAPIKey 

func (m *MockDataSource) GetAPIKey(ctx context.Context, id string) (*model.APIKey, error)

func (*MockDataSource) GetAccountByID 

func (m *MockDataSource) GetAccountByID(id string, include []string) (*model.Account, error)

func (*MockDataSource) GetAccountByNumber 

func (m *MockDataSource) GetAccountByNumber(number string) (*model.Account, error)

func (*MockDataSource) GetAllAccounts 

func (m *MockDataSource) GetAllAccounts() ([]model.Account, error)

func (*MockDataSource) GetAllAccountsWithFilter 

func (m *MockDataSource) GetAllAccountsWithFilter(ctx context.Context, filters *filter.QueryFilterSet, limit, offset int) ([]model.Account, error)

func (*MockDataSource) GetAllAccountsWithFilterAndOptions 

func (m *MockDataSource) GetAllAccountsWithFilterAndOptions(ctx context.Context, filters *filter.QueryFilterSet, opts *filter.QueryOptions, limit, offset int) ([]model.Account, *int64, error)

func (*MockDataSource) GetAllBalances 

func (m *MockDataSource) GetAllBalances(limit, offset int) ([]model.Balance, error)

func (*MockDataSource) GetAllBalancesWithFilter 

func (m *MockDataSource) GetAllBalancesWithFilter(ctx context.Context, filters *filter.QueryFilterSet, limit, offset int) ([]model.Balance, error)

func (*MockDataSource) GetAllBalancesWithFilterAndOptions 

func (m *MockDataSource) GetAllBalancesWithFilterAndOptions(ctx context.Context, filters *filter.QueryFilterSet, opts *filter.QueryOptions, limit, offset int) ([]model.Balance, *int64, error)

func (*MockDataSource) GetAllIdentities 

func (m *MockDataSource) GetAllIdentities() ([]model.Identity, error)

func (*MockDataSource) GetAllIdentitiesPaginated 

func (m *MockDataSource) GetAllIdentitiesPaginated(limit, offset int) ([]model.Identity, error)

func (*MockDataSource) GetAllIdentitiesWithFilter 

func (m *MockDataSource) GetAllIdentitiesWithFilter(ctx context.Context, filters *filter.QueryFilterSet, limit, offset int) ([]model.Identity, error)

func (*MockDataSource) GetAllIdentitiesWithFilterAndOptions 

func (m *MockDataSource) GetAllIdentitiesWithFilterAndOptions(ctx context.Context, filters *filter.QueryFilterSet, opts *filter.QueryOptions, limit, offset int) ([]model.Identity, *int64, error)

func (*MockDataSource) GetAllLedgers 

func (m *MockDataSource) GetAllLedgers(limit, offset int) ([]model.Ledger, error)

func (*MockDataSource) GetAllLedgersWithFilter 

func (m *MockDataSource) GetAllLedgersWithFilter(ctx context.Context, filters *filter.QueryFilterSet, limit, offset int) ([]model.Ledger, error)

func (*MockDataSource) GetAllLedgersWithFilterAndOptions 

func (m *MockDataSource) GetAllLedgersWithFilterAndOptions(ctx context.Context, filters *filter.QueryFilterSet, opts *filter.QueryOptions, limit, offset int) ([]model.Ledger, *int64, error)

func (*MockDataSource) GetAllMonitors 

func (m *MockDataSource) GetAllMonitors() ([]model.BalanceMonitor, error)

func (*MockDataSource) GetAllTransactions 

func (m *MockDataSource) GetAllTransactions(ctx context.Context, limit, offset int) ([]model.Transaction, error)

func (*MockDataSource) GetAllTransactionsWithFilter 

func (m *MockDataSource) GetAllTransactionsWithFilter(ctx context.Context, filters *filter.QueryFilterSet, limit, offset int) ([]model.Transaction, error)

func (*MockDataSource) GetAllTransactionsWithFilterAndOptions 

func (m *MockDataSource) GetAllTransactionsWithFilterAndOptions(ctx context.Context, filters *filter.QueryFilterSet, opts *filter.QueryOptions, limit, offset int) ([]model.Transaction, *int64, error)

func (*MockDataSource) GetBalanceAtTime 

func (m *MockDataSource) GetBalanceAtTime(ctx context.Context, balanceID string, targetTime time.Time, fromSource bool) (*model.Balance, error)

func (*MockDataSource) GetBalanceByID 

func (m *MockDataSource) GetBalanceByID(id string, include []string, withQueued bool) (*model.Balance, error)

func (*MockDataSource) GetBalanceByIDLite 

func (m *MockDataSource) GetBalanceByIDLite(id string) (*model.Balance, error)

func (*MockDataSource) GetBalanceByIndicator 

func (m *MockDataSource) GetBalanceByIndicator(indicator, currency string) (*model.Balance, error)

func (*MockDataSource) GetBalanceMonitors 

func (m *MockDataSource) GetBalanceMonitors(balanceID string) ([]model.BalanceMonitor, error)

func (*MockDataSource) GetBalancesByIDsLite 

func (m *MockDataSource) GetBalancesByIDsLite(ctx context.Context, ids []string) (map[string]*model.Balance, error)

func (*MockDataSource) GetChainState 

func (m *MockDataSource) GetChainState(ctx context.Context) (*model.ChainState, error)

func (*MockDataSource) GetChainedTransactionsAfter 

func (m *MockDataSource) GetChainedTransactionsAfter(ctx context.Context, afterSeq int64, limit int) ([]model.ChainedTransaction, error)

func (*MockDataSource) GetExistingTransactionReferences 

func (m *MockDataSource) GetExistingTransactionReferences(ctx context.Context, references []string) (map[string]struct{}, error)

func (*MockDataSource) GetExternalTransactionsPaginated 

func (m *MockDataSource) GetExternalTransactionsPaginated(ctx context.Context, uploadID string, batchSize int, offset int64) ([]*model.ExternalTransaction, error)

func (*MockDataSource) GetIdentityByID 

func (m *MockDataSource) GetIdentityByID(id string) (*model.Identity, error)

func (*MockDataSource) GetInflightTransactionsByParentID 

func (m *MockDataSource) GetInflightTransactionsByParentID(ctx context.Context, parentTransactionID string, batchSize int, offset int64) ([]*model.Transaction, error)

func (*MockDataSource) GetLedgerByID 

func (m *MockDataSource) GetLedgerByID(id string) (*model.Ledger, error)

func (*MockDataSource) GetLineageMappingByProvider 

func (m *MockDataSource) GetLineageMappingByProvider(ctx context.Context, balanceID, provider string) (*model.LineageMapping, error)

func (*MockDataSource) GetLineageMappings 

func (m *MockDataSource) GetLineageMappings(ctx context.Context, balanceID string) ([]model.LineageMapping, error)

func (*MockDataSource) GetMatchesByReconciliationID 

func (m *MockDataSource) GetMatchesByReconciliationID(ctx context.Context, reconciliationID string) ([]*model.Match, error)

func (*MockDataSource) GetMatchingRule 

func (m *MockDataSource) GetMatchingRule(ctx context.Context, id string) (*model.MatchingRule, error)

func (*MockDataSource) GetMatchingRules 

func (m *MockDataSource) GetMatchingRules(ctx context.Context) ([]*model.MatchingRule, error)

func (*MockDataSource) GetMonitorByID 

func (m *MockDataSource) GetMonitorByID(id string) (*model.BalanceMonitor, error)

func (*MockDataSource) GetOutboxByTransactionID 

func (m *MockDataSource) GetOutboxByTransactionID(ctx context.Context, transactionID string) (*model.LineageOutbox, error)

func (*MockDataSource) GetQueuedTransactionsForCoalescing 

func (m *MockDataSource) GetQueuedTransactionsForCoalescing(ctx context.Context, source, destination, currency, excludeTransactionID string, createdAtOrAfter time.Time, limit int) ([]*model.Transaction, error)

func (*MockDataSource) GetQueuedTransactionsForDestinationCoalescing 

func (m *MockDataSource) GetQueuedTransactionsForDestinationCoalescing(ctx context.Context, destination, currency, excludeTransactionID string, createdAtOrAfter time.Time, limit int) ([]*model.Transaction, error)

func (*MockDataSource) GetQueuedTransactionsForSourceCoalescing 

func (m *MockDataSource) GetQueuedTransactionsForSourceCoalescing(ctx context.Context, source, currency, excludeTransactionID string, createdAtOrAfter time.Time, limit int) ([]*model.Transaction, error)

func (*MockDataSource) GetReconciliation 

func (m *MockDataSource) GetReconciliation(ctx context.Context, id string) (*model.Reconciliation, error)

func (*MockDataSource) GetReconciliationsByUploadID 

func (m *MockDataSource) GetReconciliationsByUploadID(ctx context.Context, uploadID string) ([]*model.Reconciliation, error)

func (*MockDataSource) GetRefundableTransactionsByParentID 

func (m *MockDataSource) GetRefundableTransactionsByParentID(ctx context.Context, parentTransactionID string, batchSize int, offset int64) ([]*model.Transaction, error)

func (*MockDataSource) GetSourceDestination 

func (m *MockDataSource) GetSourceDestination(sourceId, destinationId string) ([]*model.Balance, error)

func (*MockDataSource) GetStuckQueuedTransactions 

func (m *MockDataSource) GetStuckQueuedTransactions(ctx context.Context, threshold time.Duration, batchSize int) ([]*model.Transaction, error)

func (*MockDataSource) GetTotalCommittedTransactions 

func (m *MockDataSource) GetTotalCommittedTransactions(ctx context.Context, parentID string) (*big.Int, error)

func (*MockDataSource) GetTransaction 

func (m *MockDataSource) GetTransaction(ctx context.Context, id string) (*model.Transaction, error)

func (*MockDataSource) GetTransactionByRef 

func (m *MockDataSource) GetTransactionByRef(ctx context.Context, reference string) (model.Transaction, error)

func (*MockDataSource) GetTransactionsByCriteria 

func (m *MockDataSource) GetTransactionsByCriteria(ctx context.Context, minAmount, maxAmount *float64, currency *string, minDate, maxDate *time.Time, limit int, offset int64) ([]*model.Transaction, error)

func (*MockDataSource) GetTransactionsByParent 

func (m *MockDataSource) GetTransactionsByParent(ctx context.Context, parentID string, limit int, offset int64) ([]*model.Transaction, error)

func (*MockDataSource) GetTransactionsByShadowFor 

func (m *MockDataSource) GetTransactionsByShadowFor(ctx context.Context, parentTransactionID string) ([]model.Transaction, error)

func (*MockDataSource) GetTransactionsPaginated 

func (m *MockDataSource) GetTransactionsPaginated(ctx context.Context, id string, batchSize int, offset int64) ([]*model.Transaction, error)

func (*MockDataSource) GroupTransactions 

func (m *MockDataSource) GroupTransactions(ctx context.Context, groupCriteria string, batchSize int, offset int64) (map[string][]*model.Transaction, error)

func (*MockDataSource) HasPendingCreditOutbox 

func (m *MockDataSource) HasPendingCreditOutbox(ctx context.Context, balanceID string) (bool, error)

func (*MockDataSource) InsertLineageOutbox 

func (m *MockDataSource) InsertLineageOutbox(ctx context.Context, outbox *model.LineageOutbox) error

func (*MockDataSource) InsertLineageOutboxInTx 

func (m *MockDataSource) InsertLineageOutboxInTx(ctx context.Context, tx *sql.Tx, outbox *model.LineageOutbox) error

func (*MockDataSource) IsParentTransactionVoid 

func (m *MockDataSource) IsParentTransactionVoid(ctx context.Context, parentID string) (bool, error)

func (*MockDataSource) IsTransactionRefunded 

func (m *MockDataSource) IsTransactionRefunded(ctx context.Context, transaction *model.Transaction) (bool, error)

func (*MockDataSource) ListAPIKeys 

func (m *MockDataSource) ListAPIKeys(ctx context.Context, ownerID string) ([]*model.APIKey, error)

func (*MockDataSource) ListTransactionsByMetadataScope 

func (m *MockDataSource) ListTransactionsByMetadataScope(ctx context.Context, scopeID string, limit int, offset int64) ([]*model.Transaction, error)

func (*MockDataSource) LoadReconciliationProgress 

func (m *MockDataSource) LoadReconciliationProgress(ctx context.Context, reconciliationID string) (model.ReconciliationProgress, error)

func (*MockDataSource) MarkOutboxCompleted 

func (m *MockDataSource) MarkOutboxCompleted(ctx context.Context, id int64) error

func (*MockDataSource) MarkOutboxFailed 

func (m *MockDataSource) MarkOutboxFailed(ctx context.Context, id int64, errMsg string) error

func (*MockDataSource) RecordExternalTransaction 

func (m *MockDataSource) RecordExternalTransaction(ctx context.Context, tx *model.ExternalTransaction, reconciliationID string) error

func (*MockDataSource) RecordMatch 

func (m *MockDataSource) RecordMatch(ctx context.Context, match *model.Match) error

func (*MockDataSource) RecordMatches 

func (m *MockDataSource) RecordMatches(ctx context.Context, reconciliationID string, match []model.Match) error

func (*MockDataSource) RecordMatchingRule 

func (m *MockDataSource) RecordMatchingRule(ctx context.Context, rule *model.MatchingRule) error

func (*MockDataSource) RecordReconciliation 

func (m *MockDataSource) RecordReconciliation(ctx context.Context, rec *model.Reconciliation) error

func (*MockDataSource) RecordTransaction 

func (m *MockDataSource) RecordTransaction(ctx context.Context, txn *model.Transaction) (*model.Transaction, error)

func (*MockDataSource) RecordTransactionWithBalances 

func (m *MockDataSource) RecordTransactionWithBalances(ctx context.Context, txn *model.Transaction, sourceBalance, destinationBalance *model.Balance) (*model.Transaction, error)

func (*MockDataSource) RecordTransactionWithBalancesAndOutbox 

func (m *MockDataSource) RecordTransactionWithBalancesAndOutbox(ctx context.Context, txn *model.Transaction, sourceBalance, destinationBalance *model.Balance, outbox *model.LineageOutbox) (*model.Transaction, error)

func (*MockDataSource) RecordTransactionsWithBalanceSetAndOutboxes 

func (m *MockDataSource) RecordTransactionsWithBalanceSetAndOutboxes(ctx context.Context, txns []*model.Transaction, balances []*model.Balance, outboxes []*model.LineageOutbox) ([]*model.Transaction, error)

func (*MockDataSource) RecordTransactionsWithBalancesAndOutboxes 

func (m *MockDataSource) RecordTransactionsWithBalancesAndOutboxes(ctx context.Context, txns []*model.Transaction, sourceBalance, destinationBalance *model.Balance, outboxes []*model.LineageOutbox) ([]*model.Transaction, error)

func (*MockDataSource) RecordUnmatched 

func (m *MockDataSource) RecordUnmatched(ctx context.Context, reconciliationID string, unmatched []string) error

func (*MockDataSource) RevokeAPIKey 

func (m *MockDataSource) RevokeAPIKey(ctx context.Context, id, ownerID string) error

func (*MockDataSource) SaveReconciliationProgress 

func (m *MockDataSource) SaveReconciliationProgress(ctx context.Context, reconciliationID string, progress model.ReconciliationProgress) error

func (*MockDataSource) TakeBalanceSnapshots 

func (m *MockDataSource) TakeBalanceSnapshots(ctx context.Context, batchSize int) (int, error)

func (*MockDataSource) TransactionExistsByIDOrParentID 

func (m *MockDataSource) TransactionExistsByIDOrParentID(ctx context.Context, id string) (bool, error)

func (*MockDataSource) TransactionExistsByRef 

func (m *MockDataSource) TransactionExistsByRef(ctx context.Context, reference string) (bool, error)

func (*MockDataSource) UpdateAccount 

func (m *MockDataSource) UpdateAccount(account *model.Account) error

func (*MockDataSource) UpdateBalance 

func (m *MockDataSource) UpdateBalance(balance *model.Balance) error

func (*MockDataSource) UpdateBalanceIdentity 

func (m *MockDataSource) UpdateBalanceIdentity(balanceID string, identityID string) error

func (*MockDataSource) UpdateBalanceMetadata 

func (m *MockDataSource) UpdateBalanceMetadata(ctx context.Context, id string, metadata map[string]interface{}) error

func (*MockDataSource) UpdateBalances 

func (m *MockDataSource) UpdateBalances(ctx context.Context, sourceBalance, destinationBalance *model.Balance) error

func (*MockDataSource) UpdateIdentity 

func (m *MockDataSource) UpdateIdentity(identity *model.Identity) error

func (*MockDataSource) UpdateIdentityMetadata 

func (m *MockDataSource) UpdateIdentityMetadata(id string, metadata map[string]interface{}) error

func (*MockDataSource) UpdateLastUsed 

func (m *MockDataSource) UpdateLastUsed(ctx context.Context, id string) error

func (*MockDataSource) UpdateLedger 

func (m *MockDataSource) UpdateLedger(id, name string) (*model.Ledger, error)

func (*MockDataSource) UpdateLedgerMetadata 

func (m *MockDataSource) UpdateLedgerMetadata(id string, metadata map[string]interface{}) error

Metadata update methods

func (*MockDataSource) UpdateMatchingRule 

func (m *MockDataSource) UpdateMatchingRule(ctx context.Context, rule *model.MatchingRule) error

func (*MockDataSource) UpdateMonitor 

func (m *MockDataSource) UpdateMonitor(monitor *model.BalanceMonitor) error

func (*MockDataSource) UpdateReconciliationStatus 

func (m *MockDataSource) UpdateReconciliationStatus(ctx context.Context, id string, status string, matchedCount, unmatchedCount int) error

func (*MockDataSource) UpdateTransactionMetadata 

func (m *MockDataSource) UpdateTransactionMetadata(ctx context.Context, id string, metadata map[string]interface{}) error

func (*MockDataSource) UpsertLineageMapping 

func (m *MockDataSource) UpsertLineageMapping(ctx context.Context, mapping model.LineageMapping) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.