Documentation
¶
Index ¶
- func ConnectDB(dns string) (*sql.DB, error)
- type Datasource
- func (d Datasource) CreateAccount(account model.Account) (model.Account, error)
- func (d Datasource) CreateBalance(balance model.Balance) (model.Balance, error)
- func (d Datasource) CreateIdentity(identity model.Identity) (model.Identity, error)
- func (d Datasource) CreateLedger(ledger model.Ledger) (model.Ledger, error)
- func (d Datasource) CreateMonitor(monitor model.BalanceMonitor) (model.BalanceMonitor, error)
- func (d Datasource) DeleteAccount(id string) error
- func (d Datasource) DeleteIdentity(id string) error
- func (d Datasource) DeleteMonitor(id string) error
- func (d Datasource) GetAccountByID(id string, include []string) (*model.Account, error)
- func (d Datasource) GetAccountByNumber(number string) (*model.Account, error)
- func (d Datasource) GetAllAccounts() ([]model.Account, error)
- func (d Datasource) GetAllBalances() ([]model.Balance, error)
- func (d Datasource) GetAllIdentities() ([]model.Identity, error)
- func (d Datasource) GetAllLedgers() ([]model.Ledger, error)
- func (d Datasource) GetAllMonitors() ([]model.BalanceMonitor, error)
- func (d Datasource) GetAllTransactions() ([]model.Transaction, error)
- func (d Datasource) GetBalanceByID(id string, include []string) (*model.Balance, error)
- func (d Datasource) GetBalanceByIDLite(id string) (*model.Balance, error)
- func (d Datasource) GetBalanceByIndicator(indicator string) (*model.Balance, error)
- func (d Datasource) GetBalanceMonitors(balanceID string) ([]model.BalanceMonitor, error)
- func (d Datasource) GetIdentityByID(id string) (*model.Identity, error)
- func (d Datasource) GetLedgerByID(id string) (*model.Ledger, error)
- func (d Datasource) GetMonitorByID(id string) (*model.BalanceMonitor, error)
- func (d Datasource) GetTransaction(id string) (*model.Transaction, error)
- func (d Datasource) GetTransactionByRef(ctx context.Context, reference string) (model.Transaction, error)
- func (d Datasource) RecordTransaction(cxt context.Context, txn *model.Transaction) (*model.Transaction, error)
- func (d Datasource) TransactionExistsByRef(ctx context.Context, reference string) (bool, error)
- func (d Datasource) UpdateAccount(account *model.Account) error
- func (d Datasource) UpdateBalance(balance *model.Balance) error
- func (d Datasource) UpdateBalances(ctx context.Context, sourceBalance, destinationBalance *model.Balance) error
- func (d Datasource) UpdateIdentity(identity *model.Identity) error
- func (d Datasource) UpdateMonitor(monitor *model.BalanceMonitor) error
- func (d Datasource) UpdateTransactionStatus(id string, status string) error
- type IDataSource
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Datasource ¶
func GetDBConnection ¶
func GetDBConnection(configuration *config.Configuration) (*Datasource, error)
GetDBConnection provides a global access point to the instance and initializes it if it's not already.
func (Datasource) CreateAccount ¶
CreateAccount inserts a new Account into the database
func (Datasource) CreateBalance ¶
CreateBalance inserts a new Balance into the database
func (Datasource) CreateIdentity ¶
CreateIdentity inserts a new Identity into the database
func (Datasource) CreateLedger ¶
func (Datasource) CreateMonitor ¶
func (d Datasource) CreateMonitor(monitor model.BalanceMonitor) (model.BalanceMonitor, error)
func (Datasource) DeleteAccount ¶
func (d Datasource) DeleteAccount(id string) error
DeleteAccount deletes a specific account from the database
func (Datasource) DeleteIdentity ¶
func (d Datasource) DeleteIdentity(id string) error
DeleteIdentity deletes an identity from the database by ID
func (Datasource) DeleteMonitor ¶
func (d Datasource) DeleteMonitor(id string) error
func (Datasource) GetAccountByID ¶
func (Datasource) GetAccountByNumber ¶
func (d Datasource) GetAccountByNumber(number string) (*model.Account, error)
GetAccountByNumber retrieves an account based on its number
func (Datasource) GetAllAccounts ¶
func (d Datasource) GetAllAccounts() ([]model.Account, error)
GetAllAccounts retrieves all accounts
func (Datasource) GetAllBalances ¶
func (d Datasource) GetAllBalances() ([]model.Balance, error)
GetAllBalances retrieves all balances from the database
func (Datasource) GetAllIdentities ¶
func (d Datasource) GetAllIdentities() ([]model.Identity, error)
GetAllIdentities retrieves all identities from the database
func (Datasource) GetAllLedgers ¶
func (d Datasource) GetAllLedgers() ([]model.Ledger, error)
GetAllLedgers retrieves all ledgers from the database
func (Datasource) GetAllMonitors ¶
func (d Datasource) GetAllMonitors() ([]model.BalanceMonitor, error)
func (Datasource) GetAllTransactions ¶
func (d Datasource) GetAllTransactions() ([]model.Transaction, error)
func (Datasource) GetBalanceByID ¶
func (Datasource) GetBalanceByIDLite ¶
func (d Datasource) GetBalanceByIDLite(id string) (*model.Balance, error)
func (Datasource) GetBalanceByIndicator ¶
func (d Datasource) GetBalanceByIndicator(indicator string) (*model.Balance, error)
func (Datasource) GetBalanceMonitors ¶
func (d Datasource) GetBalanceMonitors(balanceID string) ([]model.BalanceMonitor, error)
func (Datasource) GetIdentityByID ¶
func (d Datasource) GetIdentityByID(id string) (*model.Identity, error)
GetIdentityByID retrieves an identity from the database by ID
func (Datasource) GetLedgerByID ¶
func (d Datasource) GetLedgerByID(id string) (*model.Ledger, error)
GetLedgerByID retrieves a single ledger from the database by ID
func (Datasource) GetMonitorByID ¶
func (d Datasource) GetMonitorByID(id string) (*model.BalanceMonitor, error)
func (Datasource) GetTransaction ¶
func (d Datasource) GetTransaction(id string) (*model.Transaction, error)
func (Datasource) GetTransactionByRef ¶
func (d Datasource) GetTransactionByRef(ctx context.Context, reference string) (model.Transaction, error)
func (Datasource) RecordTransaction ¶
func (d Datasource) RecordTransaction(cxt context.Context, txn *model.Transaction) (*model.Transaction, error)
func (Datasource) TransactionExistsByRef ¶
func (Datasource) UpdateAccount ¶
func (d Datasource) UpdateAccount(account *model.Account) error
UpdateAccount updates a specific account in the database
func (Datasource) UpdateBalance ¶
func (d Datasource) UpdateBalance(balance *model.Balance) error
UpdateBalance updates a balance in the database
func (Datasource) UpdateBalances ¶
func (Datasource) UpdateIdentity ¶
func (d Datasource) UpdateIdentity(identity *model.Identity) error
UpdateIdentity updates an identity in the database
func (Datasource) UpdateMonitor ¶
func (d Datasource) UpdateMonitor(monitor *model.BalanceMonitor) error
func (Datasource) UpdateTransactionStatus ¶
func (d Datasource) UpdateTransactionStatus(id string, status string) error
type IDataSource ¶
type IDataSource interface {
// contains filtered or unexported methods
}
func NewDataSource ¶
func NewDataSource(configuration *config.Configuration) (IDataSource, error)
Source Files
Click to show internal directories.
Click to hide internal directories.