Versions in this module Expand all Collapse all v0 v0.2.0 Dec 1, 2025 v0.1.0 Nov 28, 2025 Changes in this version + const FixerApiKeyConfigEnvName + type BlockchainData interface + GetBlockchainAccountDataAfterBlock func(ctx context.Context, account string, slot uint64) ([]byte, uint64, error) + GetBlockchainAccountInfo func(ctx context.Context, account string, commitment solana.Commitment) (*solana.AccountInfo, error) + GetBlockchainBalance func(ctx context.Context, account string) (uint64, uint64, error) + GetBlockchainBlock func(ctx context.Context, slot uint64) (*solana.Block, error) + GetBlockchainBlockSignatures func(ctx context.Context, slot uint64) ([]string, error) + GetBlockchainBlocksWithLimit func(ctx context.Context, start uint64, limit uint64) ([]uint64, error) + GetBlockchainFilteredProgramAccounts func(ctx context.Context, program string, offset uint, filterValue []byte) ([]string, uint64, error) + GetBlockchainHistory func(ctx context.Context, account string, commitment solana.Commitment, ...) ([]*solana.TransactionSignature, error) + GetBlockchainLatestBlockhash func(ctx context.Context) (solana.Blockhash, error) + GetBlockchainMinimumBalanceForRentExemption func(ctx context.Context, size uint64) (uint64, error) + GetBlockchainSignatureStatuses func(ctx context.Context, signatures []solana.Signature) ([]*solana.SignatureStatus, error) + GetBlockchainSlot func(ctx context.Context, commitment solana.Commitment) (uint64, error) + GetBlockchainTokenAccountInfo func(ctx context.Context, account, mint string, commitment solana.Commitment) (*token.Account, error) + GetBlockchainTokenAccountsByOwner func(ctx context.Context, account string) ([]ed25519.PublicKey, error) + GetBlockchainTransaction func(ctx context.Context, sig string, commitment solana.Commitment) (*solana.ConfirmedTransaction, error) + GetBlockchainTransactionTokenBalances func(ctx context.Context, sig string) (*solana.TransactionTokenBalances, error) + SubmitBlockchainTransaction func(ctx context.Context, tx *solana.Transaction) (solana.Signature, error) + func NewBlockchainProvider(solanaEndpoint string) (BlockchainData, error) + type BlockchainProvider struct + func (dp *BlockchainProvider) GetBlockchainAccountDataAfterBlock(ctx context.Context, account string, slot uint64) ([]byte, uint64, error) + func (dp *BlockchainProvider) GetBlockchainAccountInfo(ctx context.Context, account string, commitment solana.Commitment) (*solana.AccountInfo, error) + func (dp *BlockchainProvider) GetBlockchainBalance(ctx context.Context, account string) (uint64, uint64, error) + func (dp *BlockchainProvider) GetBlockchainBlock(ctx context.Context, slot uint64) (*solana.Block, error) + func (dp *BlockchainProvider) GetBlockchainBlockSignatures(ctx context.Context, slot uint64) ([]string, error) + func (dp *BlockchainProvider) GetBlockchainBlocksWithLimit(ctx context.Context, start uint64, limit uint64) ([]uint64, error) + func (dp *BlockchainProvider) GetBlockchainFilteredProgramAccounts(ctx context.Context, program string, offset uint, filterValue []byte) ([]string, uint64, error) + func (dp *BlockchainProvider) GetBlockchainHistory(ctx context.Context, account string, commitment solana.Commitment, ...) ([]*solana.TransactionSignature, error) + func (dp *BlockchainProvider) GetBlockchainLatestBlockhash(ctx context.Context) (solana.Blockhash, error) + func (dp *BlockchainProvider) GetBlockchainMinimumBalanceForRentExemption(ctx context.Context, size uint64) (uint64, error) + func (dp *BlockchainProvider) GetBlockchainSignatureStatuses(ctx context.Context, signatures []solana.Signature) ([]*solana.SignatureStatus, error) + func (dp *BlockchainProvider) GetBlockchainSlot(ctx context.Context, commitment solana.Commitment) (uint64, error) + func (dp *BlockchainProvider) GetBlockchainTokenAccountInfo(ctx context.Context, account, mint string, commitment solana.Commitment) (*token.Account, error) + func (dp *BlockchainProvider) GetBlockchainTokenAccountsByOwner(ctx context.Context, account string) ([]ed25519.PublicKey, error) + func (dp *BlockchainProvider) GetBlockchainTransaction(ctx context.Context, sig string, commitment solana.Commitment) (*solana.ConfirmedTransaction, error) + func (dp *BlockchainProvider) GetBlockchainTransactionTokenBalances(ctx context.Context, sig string) (*solana.TransactionTokenBalances, error) + func (dp *BlockchainProvider) SubmitBlockchainTransaction(ctx context.Context, tx *solana.Transaction) (solana.Signature, error) + type ConfigProvider func() *conf + func WithEnvConfigs() ConfigProvider + type DataProvider struct + func (p *DataProvider) GetBlockchainDataProvider() BlockchainData + func (p *DataProvider) GetDatabaseDataProvider() DatabaseData + func (p *DataProvider) GetWebDataProvider() WebData + type DatabaseData interface + AdvanceCachedBalanceVersion func(ctx context.Context, account string, currentVersion uint64) error + BatchClaimAvailableNoncesByPurpose func(ctx context.Context, env nonce.Environment, instance string, ...) ([]*nonce.Record, error) + CheckNotClosedForBalanceUpdate func(ctx context.Context, account string) error + CountFeeActions func(ctx context.Context, intent string, ...) (uint64, error) + CreateAccountInfo func(ctx context.Context, record *account.Record) error + CreateMessage func(ctx context.Context, record *messaging.Record) error + DeleteMessage func(ctx context.Context, account string, messageID uuid.UUID) error + DeleteRendezvous func(ctx context.Context, key, address string) error + ExecuteInTx func(ctx context.Context, isolation sql.IsolationLevel, ...) error + ExtendRendezvousExpiry func(ctx context.Context, key, address string, expiry time.Time) error + FindAnyVmStorageWithAvailableCapacity func(ctx context.Context, vm string, purpose cvm_storage.Purpose, ...) (*cvm_storage.Record, error) + FreeVmMemoryByAddress func(ctx context.Context, address string) error + FreeVmMemoryByIndex func(ctx context.Context, memoryAccount string, index uint16) error + GetAccountInfoByAuthorityAddress func(ctx context.Context, address string) (map[string]*account.Record, error) + GetAccountInfoByTokenAddress func(ctx context.Context, address string) (*account.Record, error) + GetAccountInfoByTokenAddressBatch func(ctx context.Context, addresses ...string) (map[string]*account.Record, error) + GetAccountInfoCountRequiringAutoReturnCheck func(ctx context.Context) (uint64, error) + GetAccountInfoCountRequiringDepositSync func(ctx context.Context) (uint64, error) + GetActionById func(ctx context.Context, intent string, actionId uint32) (*action.Record, error) + GetAllActionsByAddress func(ctx context.Context, address string) ([]*action.Record, error) + GetAllActionsByIntent func(ctx context.Context, intent string) ([]*action.Record, error) + GetAllExchangeRates func(ctx context.Context, t time.Time) (*currency.MultiRateRecord, error) + GetAllFulfillmentsByAction func(ctx context.Context, intentId string, actionId uint32) ([]*fulfillment.Record, error) + GetAllFulfillmentsByIntent func(ctx context.Context, intent string, opts ...query.Option) ([]*fulfillment.Record, error) + GetAllFulfillmentsByState func(ctx context.Context, state fulfillment.State, ...) ([]*fulfillment.Record, error) + GetAllFulfillmentsByTypeAndAction func(ctx context.Context, fulfillmentType fulfillment.Type, intentId string, ...) ([]*fulfillment.Record, error) + GetAllIntentsByOwner func(ctx context.Context, owner string, opts ...query.Option) ([]*intent.Record, error) + GetAllKeysByState func(ctx context.Context, state vault.State, opts ...query.Option) ([]*vault.Record, error) + GetAllNonceByState func(ctx context.Context, env nonce.Environment, instance string, state nonce.State, ...) ([]*nonce.Record, error) + GetAllSwapsByOwnerAndState func(ctx context.Context, owner string, state swap.State) ([]*swap.Record, error) + GetAllSwapsByState func(ctx context.Context, state swap.State, opts ...query.Option) ([]*swap.Record, error) + GetAllTimelocksByState func(ctx context.Context, state timelock_token.TimelockState, opts ...query.Option) ([]*timelock.Record, error) + GetCachedBalanceVersion func(ctx context.Context, account string) (uint64, error) + GetCurrencyMetadata func(ctx context.Context, mint string) (*currency.MetadataRecord, error) + GetCurrencyReserveAtTime func(ctx context.Context, mint string, t time.Time) (*currency.ReserveRecord, error) + GetExchangeRate func(ctx context.Context, code currency_lib.Code, t time.Time) (*currency.ExchangeRateRecord, error) + GetExchangeRateHistory func(ctx context.Context, code currency_lib.Code, opts ...query.Option) ([]*currency.ExchangeRateRecord, error) + GetExternalBalanceCheckpoint func(ctx context.Context, account string) (*balance.ExternalCheckpointRecord, error) + GetExternalDeposit func(ctx context.Context, signature, destination string) (*deposit.Record, error) + GetFirstSchedulableFulfillmentByAddressAsDestination func(ctx context.Context, address string) (*fulfillment.Record, error) + GetFirstSchedulableFulfillmentByAddressAsSource func(ctx context.Context, address string) (*fulfillment.Record, error) + GetFirstSchedulableFulfillmentByType func(ctx context.Context, fulfillmentType fulfillment.Type) (*fulfillment.Record, error) + GetFulfillmentById func(ctx context.Context, id uint64) (*fulfillment.Record, error) + GetFulfillmentBySignature func(ctx context.Context, signature string) (*fulfillment.Record, error) + GetFulfillmentByVirtualSignature func(ctx context.Context, signature string) (*fulfillment.Record, error) + GetFulfillmentCount func(ctx context.Context) (uint64, error) + GetFulfillmentCountByIntent func(ctx context.Context, intent string) (uint64, error) + GetFulfillmentCountByIntentAndState func(ctx context.Context, intent string, state fulfillment.State) (uint64, error) + GetFulfillmentCountByState func(ctx context.Context, state fulfillment.State) (uint64, error) + GetFulfillmentCountByStateAndAddress func(ctx context.Context, state fulfillment.State, address string) (uint64, error) + GetFulfillmentCountByStateGroupedByType func(ctx context.Context, state fulfillment.State) (map[fulfillment.Type]uint64, error) + GetFulfillmentCountByTypeActionAndState func(ctx context.Context, intentId string, actionId uint32, ...) (uint64, error) + GetFulfillmentCountByTypeStateAndAddress func(ctx context.Context, fulfillmentType fulfillment.Type, state fulfillment.State, ...) (uint64, error) + GetFulfillmentCountByTypeStateAndAddressAsSource func(ctx context.Context, fulfillmentType fulfillment.Type, state fulfillment.State, ...) (uint64, error) + GetFulfillmentCountForMetrics func(ctx context.Context, state fulfillment.State) (map[fulfillment.Type]uint64, error) + GetGiftCardAutoReturnAction func(ctx context.Context, giftCardVault string) (*action.Record, error) + GetGiftCardClaimedAction func(ctx context.Context, giftCardVault string) (*action.Record, error) + GetGiftCardClaimedIntent func(ctx context.Context, giftCardVault string) (*intent.Record, error) + GetIntent func(ctx context.Context, intentID string) (*intent.Record, error) + GetIntentBySignature func(ctx context.Context, signature string) (*intent.Record, error) + GetKey func(ctx context.Context, public_key string) (*vault.Record, error) + GetKeyCount func(ctx context.Context) (uint64, error) + GetKeyCountByState func(ctx context.Context, state vault.State) (uint64, error) + GetLatestAccountInfoByOwnerAddressAndType func(ctx context.Context, address string, accountType commonpb.AccountType) (map[string]*account.Record, error) + GetLatestAccountInfosByOwnerAddress func(ctx context.Context, address string) (map[string]map[commonpb.AccountType][]*account.Record, error) + GetMessages func(ctx context.Context, account string) ([]*messaging.Record, error) + GetNetBalanceFromActions func(ctx context.Context, address string) (int64, error) + GetNetBalanceFromActionsBatch func(ctx context.Context, accounts ...string) (map[string]int64, error) + GetNextSchedulableFulfillmentByAddress func(ctx context.Context, address string, intentOrderingIndex uint64, ...) (*fulfillment.Record, error) + GetNonce func(ctx context.Context, address string) (*nonce.Record, error) + GetNonceCount func(ctx context.Context, env nonce.Environment, instance string) (uint64, error) + GetNonceCountByState func(ctx context.Context, env nonce.Environment, instance string, state nonce.State) (uint64, error) + GetNonceCountByStateAndPurpose func(ctx context.Context, env nonce.Environment, instance string, state nonce.State, ...) (uint64, error) + GetOriginalGiftCardIssuedIntent func(ctx context.Context, giftCardVault string) (*intent.Record, error) + GetPendingFulfillmentCountByType func(ctx context.Context) (map[fulfillment.Type]uint64, error) + GetPrioritizedAccountInfosRequiringAutoReturnCheck func(ctx context.Context, maxAge time.Duration, limit uint64) ([]*account.Record, error) + GetPrioritizedAccountInfosRequiringDepositSync func(ctx context.Context, limit uint64) ([]*account.Record, error) + GetRendezvous func(ctx context.Context, key string) (*rendezvous.Record, error) + GetSwapByFundingId func(ctx context.Context, fundingId string) (*swap.Record, error) + GetSwapById func(ctx context.Context, id string) (*swap.Record, error) + GetSwapCountByState func(ctx context.Context, state swap.State) (uint64, error) + GetTimelockByAddress func(ctx context.Context, address string) (*timelock.Record, error) + GetTimelockByDepositPda func(ctx context.Context, depositPda string) (*timelock.Record, error) + GetTimelockBySwapPda func(ctx context.Context, swapPda string) (*timelock.Record, error) + GetTimelockByVault func(ctx context.Context, vault string) (*timelock.Record, error) + GetTimelockByVaultBatch func(ctx context.Context, vaults ...string) (map[string]*timelock.Record, error) + GetTimelockCountByState func(ctx context.Context, state timelock_token.TimelockState) (uint64, error) + GetTotalExternalDepositedAmountInQuarks func(ctx context.Context, account string) (uint64, error) + GetTotalExternalDepositedAmountInQuarksBatch func(ctx context.Context, accounts ...string) (map[string]uint64, error) + GetTotalExternalDepositedAmountInUsd func(ctx context.Context, account string) (float64, error) + GetTransactedAmountForAntiMoneyLaundering func(ctx context.Context, owner string, since time.Time) (uint64, float64, error) + GetTransaction func(ctx context.Context, sig string) (*transaction.Record, error) + HasFeeAction func(ctx context.Context, intent string, ...) (bool, error) + ImportExchangeRates func(ctx context.Context, record *currency.MultiRateRecord) error + InitializeVmMemory func(ctx context.Context, record *cvm_ram.Record) error + InitializeVmStorage func(ctx context.Context, record *cvm_storage.Record) error + MarkAsClosedForBalanceUpdate func(ctx context.Context, account string) error + PutAllActions func(ctx context.Context, records ...*action.Record) error + PutAllFulfillments func(ctx context.Context, records ...*fulfillment.Record) error + PutCurrencyMetadata func(ctx context.Context, record *currency.MetadataRecord) error + PutCurrencyReserve func(ctx context.Context, record *currency.ReserveRecord) error + PutRendezvous func(ctx context.Context, record *rendezvous.Record) error + ReserveVmMemory func(ctx context.Context, vm string, accountType cvm.VirtualAccountType, ...) (string, uint16, error) + ReserveVmStorage func(ctx context.Context, vm string, purpose cvm_storage.Purpose, address string) (string, error) + SaveExternalBalanceCheckpoint func(ctx context.Context, record *balance.ExternalCheckpointRecord) error + SaveExternalDeposit func(ctx context.Context, record *deposit.Record) error + SaveIntent func(ctx context.Context, record *intent.Record) error + SaveKey func(ctx context.Context, record *vault.Record) error + SaveNonce func(ctx context.Context, record *nonce.Record) error + SaveSwap func(ctx context.Context, record *swap.Record) error + SaveTimelock func(ctx context.Context, record *timelock.Record) error + SaveTransaction func(ctx context.Context, record *transaction.Record) error + UpdateAccountInfo func(ctx context.Context, record *account.Record) error + UpdateAction func(ctx context.Context, record *action.Record) error + UpdateFulfillment func(ctx context.Context, record *fulfillment.Record) error + func NewDatabaseProvider(dbConfig *pg.Config) (DatabaseData, error) + func NewTestDatabaseProvider() DatabaseData + type DatabaseProvider struct + func (dp *DatabaseProvider) AdvanceCachedBalanceVersion(ctx context.Context, account string, currentVersion uint64) error + func (dp *DatabaseProvider) BatchClaimAvailableNoncesByPurpose(ctx context.Context, env nonce.Environment, instance string, ...) ([]*nonce.Record, error) + func (dp *DatabaseProvider) CheckNotClosedForBalanceUpdate(ctx context.Context, account string) error + func (dp *DatabaseProvider) CountFeeActions(ctx context.Context, intent string, ...) (uint64, error) + func (dp *DatabaseProvider) CreateAccountInfo(ctx context.Context, record *account.Record) error + func (dp *DatabaseProvider) CreateMessage(ctx context.Context, record *messaging.Record) error + func (dp *DatabaseProvider) DeleteMessage(ctx context.Context, account string, messageID uuid.UUID) error + func (dp *DatabaseProvider) DeleteRendezvous(ctx context.Context, key, address string) error + func (dp *DatabaseProvider) ExecuteInTx(ctx context.Context, isolation sql.IsolationLevel, ...) error + func (dp *DatabaseProvider) ExtendRendezvousExpiry(ctx context.Context, key, address string, expiry time.Time) error + func (dp *DatabaseProvider) FindAnyVmStorageWithAvailableCapacity(ctx context.Context, vm string, purpose cvm_storage.Purpose, ...) (*cvm_storage.Record, error) + func (dp *DatabaseProvider) FreeVmMemoryByAddress(ctx context.Context, address string) error + func (dp *DatabaseProvider) FreeVmMemoryByIndex(ctx context.Context, memoryAccount string, index uint16) error + func (dp *DatabaseProvider) GetAccountInfoByAuthorityAddress(ctx context.Context, address string) (map[string]*account.Record, error) + func (dp *DatabaseProvider) GetAccountInfoByTokenAddress(ctx context.Context, address string) (*account.Record, error) + func (dp *DatabaseProvider) GetAccountInfoByTokenAddressBatch(ctx context.Context, addresses ...string) (map[string]*account.Record, error) + func (dp *DatabaseProvider) GetAccountInfoCountRequiringAutoReturnCheck(ctx context.Context) (uint64, error) + func (dp *DatabaseProvider) GetAccountInfoCountRequiringDepositSync(ctx context.Context) (uint64, error) + func (dp *DatabaseProvider) GetActionById(ctx context.Context, intent string, actionId uint32) (*action.Record, error) + func (dp *DatabaseProvider) GetAllActionsByAddress(ctx context.Context, address string) ([]*action.Record, error) + func (dp *DatabaseProvider) GetAllActionsByIntent(ctx context.Context, intent string) ([]*action.Record, error) + func (dp *DatabaseProvider) GetAllExchangeRates(ctx context.Context, t time.Time) (*currency.MultiRateRecord, error) + func (dp *DatabaseProvider) GetAllFulfillmentsByAction(ctx context.Context, intentId string, actionId uint32) ([]*fulfillment.Record, error) + func (dp *DatabaseProvider) GetAllFulfillmentsByIntent(ctx context.Context, intent string, opts ...query.Option) ([]*fulfillment.Record, error) + func (dp *DatabaseProvider) GetAllFulfillmentsByState(ctx context.Context, state fulfillment.State, ...) ([]*fulfillment.Record, error) + func (dp *DatabaseProvider) GetAllFulfillmentsByTypeAndAction(ctx context.Context, fulfillmentType fulfillment.Type, intentId string, ...) ([]*fulfillment.Record, error) + func (dp *DatabaseProvider) GetAllIntentsByOwner(ctx context.Context, owner string, opts ...query.Option) ([]*intent.Record, error) + func (dp *DatabaseProvider) GetAllKeysByState(ctx context.Context, state vault.State, opts ...query.Option) ([]*vault.Record, error) + func (dp *DatabaseProvider) GetAllNonceByState(ctx context.Context, env nonce.Environment, instance string, state nonce.State, ...) ([]*nonce.Record, error) + func (dp *DatabaseProvider) GetAllSwapsByOwnerAndState(ctx context.Context, owner string, state swap.State) ([]*swap.Record, error) + func (dp *DatabaseProvider) GetAllSwapsByState(ctx context.Context, state swap.State, opts ...query.Option) ([]*swap.Record, error) + func (dp *DatabaseProvider) GetAllTimelocksByState(ctx context.Context, state timelock_token.TimelockState, opts ...query.Option) ([]*timelock.Record, error) + func (dp *DatabaseProvider) GetCachedBalanceVersion(ctx context.Context, account string) (uint64, error) + func (dp *DatabaseProvider) GetCurrencyMetadata(ctx context.Context, mint string) (*currency.MetadataRecord, error) + func (dp *DatabaseProvider) GetCurrencyReserveAtTime(ctx context.Context, mint string, t time.Time) (*currency.ReserveRecord, error) + func (dp *DatabaseProvider) GetExchangeRate(ctx context.Context, code currency_lib.Code, t time.Time) (*currency.ExchangeRateRecord, error) + func (dp *DatabaseProvider) GetExchangeRateHistory(ctx context.Context, code currency_lib.Code, opts ...query.Option) ([]*currency.ExchangeRateRecord, error) + func (dp *DatabaseProvider) GetExternalBalanceCheckpoint(ctx context.Context, account string) (*balance.ExternalCheckpointRecord, error) + func (dp *DatabaseProvider) GetExternalDeposit(ctx context.Context, signature, account string) (*deposit.Record, error) + func (dp *DatabaseProvider) GetFirstSchedulableFulfillmentByAddressAsDestination(ctx context.Context, address string) (*fulfillment.Record, error) + func (dp *DatabaseProvider) GetFirstSchedulableFulfillmentByAddressAsSource(ctx context.Context, address string) (*fulfillment.Record, error) + func (dp *DatabaseProvider) GetFirstSchedulableFulfillmentByType(ctx context.Context, fulfillmentType fulfillment.Type) (*fulfillment.Record, error) + func (dp *DatabaseProvider) GetFulfillmentById(ctx context.Context, id uint64) (*fulfillment.Record, error) + func (dp *DatabaseProvider) GetFulfillmentBySignature(ctx context.Context, signature string) (*fulfillment.Record, error) + func (dp *DatabaseProvider) GetFulfillmentByVirtualSignature(ctx context.Context, signature string) (*fulfillment.Record, error) + func (dp *DatabaseProvider) GetFulfillmentCount(ctx context.Context) (uint64, error) + func (dp *DatabaseProvider) GetFulfillmentCountByIntent(ctx context.Context, intent string) (uint64, error) + func (dp *DatabaseProvider) GetFulfillmentCountByIntentAndState(ctx context.Context, intent string, state fulfillment.State) (uint64, error) + func (dp *DatabaseProvider) GetFulfillmentCountByState(ctx context.Context, state fulfillment.State) (uint64, error) + func (dp *DatabaseProvider) GetFulfillmentCountByStateAndAddress(ctx context.Context, state fulfillment.State, address string) (uint64, error) + func (dp *DatabaseProvider) GetFulfillmentCountByStateGroupedByType(ctx context.Context, state fulfillment.State) (map[fulfillment.Type]uint64, error) + func (dp *DatabaseProvider) GetFulfillmentCountByTypeActionAndState(ctx context.Context, intentId string, actionId uint32, ...) (uint64, error) + func (dp *DatabaseProvider) GetFulfillmentCountByTypeStateAndAddress(ctx context.Context, fulfillmentType fulfillment.Type, state fulfillment.State, ...) (uint64, error) + func (dp *DatabaseProvider) GetFulfillmentCountByTypeStateAndAddressAsSource(ctx context.Context, fulfillmentType fulfillment.Type, state fulfillment.State, ...) (uint64, error) + func (dp *DatabaseProvider) GetFulfillmentCountForMetrics(ctx context.Context, state fulfillment.State) (map[fulfillment.Type]uint64, error) + func (dp *DatabaseProvider) GetGiftCardAutoReturnAction(ctx context.Context, giftCardVault string) (*action.Record, error) + func (dp *DatabaseProvider) GetGiftCardClaimedAction(ctx context.Context, giftCardVault string) (*action.Record, error) + func (dp *DatabaseProvider) GetGiftCardClaimedIntent(ctx context.Context, giftCardVault string) (*intent.Record, error) + func (dp *DatabaseProvider) GetIntent(ctx context.Context, intentID string) (*intent.Record, error) + func (dp *DatabaseProvider) GetIntentBySignature(ctx context.Context, signature string) (*intent.Record, error) + func (dp *DatabaseProvider) GetKey(ctx context.Context, public_key string) (*vault.Record, error) + func (dp *DatabaseProvider) GetKeyCount(ctx context.Context) (uint64, error) + func (dp *DatabaseProvider) GetKeyCountByState(ctx context.Context, state vault.State) (uint64, error) + func (dp *DatabaseProvider) GetLatestAccountInfoByOwnerAddressAndType(ctx context.Context, address string, accountType commonpb.AccountType) (map[string]*account.Record, error) + func (dp *DatabaseProvider) GetLatestAccountInfosByOwnerAddress(ctx context.Context, address string) (map[string]map[commonpb.AccountType][]*account.Record, error) + func (dp *DatabaseProvider) GetMessages(ctx context.Context, account string) ([]*messaging.Record, error) + func (dp *DatabaseProvider) GetNetBalanceFromActions(ctx context.Context, address string) (int64, error) + func (dp *DatabaseProvider) GetNetBalanceFromActionsBatch(ctx context.Context, accounts ...string) (map[string]int64, error) + func (dp *DatabaseProvider) GetNextSchedulableFulfillmentByAddress(ctx context.Context, address string, intentOrderingIndex uint64, ...) (*fulfillment.Record, error) + func (dp *DatabaseProvider) GetNonce(ctx context.Context, address string) (*nonce.Record, error) + func (dp *DatabaseProvider) GetNonceCount(ctx context.Context, env nonce.Environment, instance string) (uint64, error) + func (dp *DatabaseProvider) GetNonceCountByState(ctx context.Context, env nonce.Environment, instance string, state nonce.State) (uint64, error) + func (dp *DatabaseProvider) GetNonceCountByStateAndPurpose(ctx context.Context, env nonce.Environment, instance string, state nonce.State, ...) (uint64, error) + func (dp *DatabaseProvider) GetOriginalGiftCardIssuedIntent(ctx context.Context, giftCardVault string) (*intent.Record, error) + func (dp *DatabaseProvider) GetPendingFulfillmentCountByType(ctx context.Context) (map[fulfillment.Type]uint64, error) + func (dp *DatabaseProvider) GetPrioritizedAccountInfosRequiringAutoReturnCheck(ctx context.Context, maxAge time.Duration, limit uint64) ([]*account.Record, error) + func (dp *DatabaseProvider) GetPrioritizedAccountInfosRequiringDepositSync(ctx context.Context, limit uint64) ([]*account.Record, error) + func (dp *DatabaseProvider) GetRendezvous(ctx context.Context, key string) (*rendezvous.Record, error) + func (dp *DatabaseProvider) GetSwapByFundingId(ctx context.Context, fundingId string) (*swap.Record, error) + func (dp *DatabaseProvider) GetSwapById(ctx context.Context, id string) (*swap.Record, error) + func (dp *DatabaseProvider) GetSwapCountByState(ctx context.Context, state swap.State) (uint64, error) + func (dp *DatabaseProvider) GetTimelockByAddress(ctx context.Context, address string) (*timelock.Record, error) + func (dp *DatabaseProvider) GetTimelockByDepositPda(ctx context.Context, depositPda string) (*timelock.Record, error) + func (dp *DatabaseProvider) GetTimelockBySwapPda(ctx context.Context, swapPda string) (*timelock.Record, error) + func (dp *DatabaseProvider) GetTimelockByVault(ctx context.Context, vault string) (*timelock.Record, error) + func (dp *DatabaseProvider) GetTimelockByVaultBatch(ctx context.Context, vaults ...string) (map[string]*timelock.Record, error) + func (dp *DatabaseProvider) GetTimelockCountByState(ctx context.Context, state timelock_token.TimelockState) (uint64, error) + func (dp *DatabaseProvider) GetTotalExternalDepositedAmountInQuarks(ctx context.Context, account string) (uint64, error) + func (dp *DatabaseProvider) GetTotalExternalDepositedAmountInQuarksBatch(ctx context.Context, accounts ...string) (map[string]uint64, error) + func (dp *DatabaseProvider) GetTotalExternalDepositedAmountInUsd(ctx context.Context, account string) (float64, error) + func (dp *DatabaseProvider) GetTransactedAmountForAntiMoneyLaundering(ctx context.Context, owner string, since time.Time) (uint64, float64, error) + func (dp *DatabaseProvider) GetTransaction(ctx context.Context, sig string) (*transaction.Record, error) + func (dp *DatabaseProvider) HasFeeAction(ctx context.Context, intent string, ...) (bool, error) + func (dp *DatabaseProvider) ImportExchangeRates(ctx context.Context, data *currency.MultiRateRecord) error + func (dp *DatabaseProvider) InitializeVmMemory(ctx context.Context, record *cvm_ram.Record) error + func (dp *DatabaseProvider) InitializeVmStorage(ctx context.Context, record *cvm_storage.Record) error + func (dp *DatabaseProvider) MarkAsClosedForBalanceUpdate(ctx context.Context, account string) error + func (dp *DatabaseProvider) PutAllActions(ctx context.Context, records ...*action.Record) error + func (dp *DatabaseProvider) PutAllFulfillments(ctx context.Context, records ...*fulfillment.Record) error + func (dp *DatabaseProvider) PutCurrencyMetadata(ctx context.Context, record *currency.MetadataRecord) error + func (dp *DatabaseProvider) PutCurrencyReserve(ctx context.Context, record *currency.ReserveRecord) error + func (dp *DatabaseProvider) PutRendezvous(ctx context.Context, record *rendezvous.Record) error + func (dp *DatabaseProvider) ReserveVmMemory(ctx context.Context, vm string, accountType cvm.VirtualAccountType, ...) (string, uint16, error) + func (dp *DatabaseProvider) ReserveVmStorage(ctx context.Context, vm string, purpose cvm_storage.Purpose, address string) (string, error) + func (dp *DatabaseProvider) SaveExternalBalanceCheckpoint(ctx context.Context, record *balance.ExternalCheckpointRecord) error + func (dp *DatabaseProvider) SaveExternalDeposit(ctx context.Context, record *deposit.Record) error + func (dp *DatabaseProvider) SaveIntent(ctx context.Context, record *intent.Record) error + func (dp *DatabaseProvider) SaveKey(ctx context.Context, record *vault.Record) error + func (dp *DatabaseProvider) SaveNonce(ctx context.Context, record *nonce.Record) error + func (dp *DatabaseProvider) SaveSwap(ctx context.Context, record *swap.Record) error + func (dp *DatabaseProvider) SaveTimelock(ctx context.Context, record *timelock.Record) error + func (dp *DatabaseProvider) SaveTransaction(ctx context.Context, record *transaction.Record) error + func (dp *DatabaseProvider) UpdateAccountInfo(ctx context.Context, record *account.Record) error + func (dp *DatabaseProvider) UpdateAction(ctx context.Context, record *action.Record) error + func (dp *DatabaseProvider) UpdateFulfillment(ctx context.Context, record *fulfillment.Record) error + type Provider interface + GetBlockchainDataProvider func() BlockchainData + GetDatabaseDataProvider func() DatabaseData + GetWebDataProvider func() WebData + func NewDataProvider(dbConfig *pg.Config, solanaEnv string, configProvider ConfigProvider) (Provider, error) + func NewDataProviderWithoutBlockchain(dbConfig *pg.Config, configProvider ConfigProvider) (Provider, error) + func NewTestDataProvider() Provider + type WebData interface + GetCurrentExchangeRatesFromExternalProviders func(ctx context.Context) (*currency.MultiRateRecord, error) + GetPastExchangeRatesFromExternalProviders func(ctx context.Context, t time.Time) (*currency.MultiRateRecord, error) + func NewWebProvider(configProvider ConfigProvider) (WebData, error) + type WebProvider struct + func (dp *WebProvider) GetCurrentExchangeRatesFromExternalProviders(ctx context.Context) (*currency.MultiRateRecord, error) + func (dp *WebProvider) GetPastExchangeRatesFromExternalProviders(ctx context.Context, t time.Time) (*currency.MultiRateRecord, error)
Go to main page