mocks

package
v0.13.2 Latest Latest
Warning

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

 Go to latest Published: Feb 12, 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) ClaimPendingOutboxEntries added in v0.13.0 

func (m *MockDataSource) ClaimPendingOutboxEntries(ctx context.Context, batchSize int, lockDuration time.Duration) ([]model.LineageOutbox, 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 added in v0.13.0 

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 added in v0.13.2 

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

func (*MockDataSource) GetAllAccountsWithFilterAndOptions added in v0.13.2 

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 added in v0.13.2 

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

func (*MockDataSource) GetAllBalancesWithFilterAndOptions added in v0.13.2 

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 added in v0.13.1 

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

func (*MockDataSource) GetAllIdentitiesWithFilter added in v0.13.2 

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

func (*MockDataSource) GetAllIdentitiesWithFilterAndOptions added in v0.13.2 

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 added in v0.13.2 

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

func (*MockDataSource) GetAllLedgersWithFilterAndOptions added in v0.13.2 

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 added in v0.13.2 

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

func (*MockDataSource) GetAllTransactionsWithFilterAndOptions added in v0.13.2 

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 added in v0.13.0 

func (m *MockDataSource) GetBalancesByIDsLite(ctx context.Context, ids []string) (map[string]*model.Balance, 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 added in v0.13.0 

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

func (*MockDataSource) GetLineageMappings added in v0.13.0 

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 added in v0.13.0 

func (m *MockDataSource) GetOutboxByTransactionID(ctx context.Context, transactionID string) (*model.LineageOutbox, 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 added in v0.13.2 

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 added in v0.11.4 

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 added in v0.13.0 

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 added in v0.13.0 

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

func (*MockDataSource) InsertLineageOutbox added in v0.13.0 

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

func (*MockDataSource) InsertLineageOutboxInTx added in v0.13.0 

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) LoadReconciliationProgress 

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

func (*MockDataSource) MarkOutboxCompleted added in v0.13.0 

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

func (*MockDataSource) MarkOutboxFailed added in v0.13.0 

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 added in v0.13.0 

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

func (*MockDataSource) RecordTransactionWithBalancesAndOutbox added in v0.13.0 

func (m *MockDataSource) RecordTransactionWithBalancesAndOutbox(ctx context.Context, txn *model.Transaction, sourceBalance, destinationBalance *model.Balance, outbox *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) UpdateTransactionStatus 

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

func (*MockDataSource) UpsertLineageMapping added in v0.13.0 

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.