Versions in this module Expand all Collapse all v2 v2.0.1 Jun 3, 2020 Changes in this version + var AllowedResolutions = map[time.Duration]struct + var StrictResolutionFiltering = true + func EncodeOfferId(id uint64, typ OfferIDType) int64 + type Account struct + Address string + ID int64 + type AccountDataBatchInsertBuilder interface + Add func(data xdr.DataEntry, lastModifiedLedger xdr.Uint32) error + Exec func() error + type AccountDataValue []byte + func (t *AccountDataValue) Scan(src interface{}) error + func (value AccountDataValue) Base64() string + func (value AccountDataValue) Value() (driver.Value, error) + type AccountEntry struct + AccountID string + Balance int64 + BuyingLiabilities int64 + Flags uint32 + HomeDomain string + InflationDestination string + LastModifiedLedger uint32 + MasterWeight byte + NumSubEntries uint32 + SellingLiabilities int64 + SequenceNumber int64 + ThresholdHigh byte + ThresholdLow byte + ThresholdMedium byte + func (account AccountEntry) IsAuthImmutable() bool + func (account AccountEntry) IsAuthRequired() bool + func (account AccountEntry) IsAuthRevocable() bool + type AccountSigner struct + Account string + Signer string + Weight int32 + type AccountSignersBatchInsertBuilder interface + Add func(signer AccountSigner) error + Exec func() error + type AccountsBatchInsertBuilder interface + Add func(account xdr.AccountEntry, lastModifiedLedger xdr.Uint32) error + Exec func() error + type AccountsQ struct + Err error + func (q *AccountsQ) Page(page db2.PageQuery) *AccountsQ + func (q *AccountsQ) Select(dest interface{}) error + type Asset struct + Code string + ID int64 + Issuer string + Type string + type AssetStat struct + Amount string + Flags int8 + ID int64 + NumAccounts int32 + Toml string + type Data struct + AccountID string + LastModifiedLedger uint32 + Name string + Value AccountDataValue + type Effect struct + Account string + DetailsString null.String + HistoryAccountID int64 + HistoryOperationID int64 + Order int32 + Type EffectType + func (r *Effect) ID() string + func (r *Effect) LedgerSequence() int32 + func (r *Effect) PagingToken() string + func (r *Effect) UnmarshalDetails(dest interface{}) error + type EffectBatchInsertBuilder interface + Add func(accountID int64, operationID int64, order uint32, effectType EffectType, ...) error + Exec func() error + type EffectType int + const EffectAccountCreated + const EffectAccountCredited + const EffectAccountDebited + const EffectAccountFlagsUpdated + const EffectAccountHomeDomainUpdated + const EffectAccountInflationDestinationUpdated + const EffectAccountRemoved + const EffectAccountThresholdsUpdated + const EffectDataCreated + const EffectDataRemoved + const EffectDataUpdated + const EffectOfferCreated + const EffectOfferRemoved + const EffectOfferUpdated + const EffectSequenceBumped + const EffectSignerCreated + const EffectSignerRemoved + const EffectSignerUpdated + const EffectTrade + const EffectTrustlineAuthorized + const EffectTrustlineAuthorizedToMaintainLiabilities + const EffectTrustlineCreated + const EffectTrustlineDeauthorized + const EffectTrustlineRemoved + const EffectTrustlineUpdated + type EffectsQ struct + Err error + func (q *EffectsQ) ForAccount(aid string) *EffectsQ + func (q *EffectsQ) ForLedger(seq int32) *EffectsQ + func (q *EffectsQ) ForOperation(id int64) *EffectsQ + func (q *EffectsQ) ForOrderBook(selling, buying xdr.Asset) *EffectsQ + func (q *EffectsQ) ForTransaction(hash string) *EffectsQ + func (q *EffectsQ) OfType(typ EffectType) *EffectsQ + func (q *EffectsQ) Page(page db2.PageQuery) *EffectsQ + func (q *EffectsQ) Select(dest interface{}) error + type ExpAssetStat struct + Amount string + AssetCode string + AssetIssuer string + AssetType xdr.AssetType + NumAccounts int32 + func (e ExpAssetStat) PagingToken() string + type FeeBumpFixture struct + Envelope xdr.TransactionEnvelope + InnerHash string + Ledger Ledger + NormalTransaction Transaction + OuterHash string + Transaction Transaction + func FeeBumpScenario(tt *test.T, q *Q, successful bool) FeeBumpFixture + type FeeStats struct + FeeChargedMax null.Int + FeeChargedMin null.Int + FeeChargedMode null.Int + FeeChargedP10 null.Int + FeeChargedP20 null.Int + FeeChargedP30 null.Int + FeeChargedP40 null.Int + FeeChargedP50 null.Int + FeeChargedP60 null.Int + FeeChargedP70 null.Int + FeeChargedP80 null.Int + FeeChargedP90 null.Int + FeeChargedP95 null.Int + FeeChargedP99 null.Int + MaxFeeMax null.Int + MaxFeeMin null.Int + MaxFeeMode null.Int + MaxFeeP10 null.Int + MaxFeeP20 null.Int + MaxFeeP30 null.Int + MaxFeeP40 null.Int + MaxFeeP50 null.Int + MaxFeeP60 null.Int + MaxFeeP70 null.Int + MaxFeeP80 null.Int + MaxFeeP90 null.Int + MaxFeeP95 null.Int + MaxFeeP99 null.Int + type IngestionQ interface + Begin func() error + BeginTx func(*sql.TxOptions) error + CloneIngestionQ func() IngestionQ + Commit func() error + CreateAssets func(assets []xdr.Asset, batchSize int) (map[string]Asset, error) + DeleteRangeAll func(start, end int64) error + GetExpIngestVersion func() (int, error) + GetExpStateInvalid func() (bool, error) + GetLatestLedger func() (uint32, error) + GetOfferCompactionSequence func() (uint32, error) + GetTx func() *sqlx.Tx + NewOperationParticipantBatchInsertBuilder func(maxBatchSize int) OperationParticipantBatchInsertBuilder + NewTradeBatchInsertBuilder func(maxBatchSize int) TradeBatchInsertBuilder + NewTransactionParticipantsBatchInsertBuilder func(maxBatchSize int) TransactionParticipantsBatchInsertBuilder + Rollback func() error + TruncateExpingestStateTables func() error + UpdateExpIngestVersion func(int) error + UpdateExpStateInvalid func(bool) error + type InsertTrade struct + BoughtAssetID int64 + BuyOfferExists bool + BuyOfferID int64 + BuyerAccountID int64 + HistoryOperationID int64 + LedgerCloseTime time.Time + Order int32 + SellPrice xdr.Price + SellerAccountID int64 + SoldAssetID int64 + Trade xdr.ClaimOfferAtom + type KeyValueStoreRow struct + Key string + Value string + type LatestLedger struct + BaseFee int32 + Sequence int32 + type Ledger struct + BaseFee int32 + BaseReserve int32 + ClosedAt time.Time + CreatedAt time.Time + FailedTransactionCount *int32 + FeePool int64 + ImporterVersion int32 + LedgerHash string + LedgerHeaderXDR null.String + MaxTxSetSize int32 + OperationCount int32 + PreviousLedgerHash null.String + ProtocolVersion int32 + Sequence int32 + SuccessfulTransactionCount *int32 + TotalCoins int64 + TransactionCount int32 + UpdatedAt time.Time + type LedgerCache struct + Records map[int32]Ledger + func (lc *LedgerCache) Load(q *Q) error + func (lc *LedgerCache) Queue(seq int32) + type LedgerCapacityUsageStats struct + CapacityUsage null.String + type LedgersQ struct + Err error + func (q *LedgersQ) Page(page db2.PageQuery) *LedgersQ + func (q *LedgersQ) Select(dest interface{}) error + type ManageOffer struct + OfferID int64 + type MockAccountDataBatchInsertBuilder struct + func (m *MockAccountDataBatchInsertBuilder) Add(data xdr.DataEntry, lastModifiedLedger xdr.Uint32) error + func (m *MockAccountDataBatchInsertBuilder) Exec() error + type MockAccountSignersBatchInsertBuilder struct + func (m *MockAccountSignersBatchInsertBuilder) Add(signer AccountSigner) error + func (m *MockAccountSignersBatchInsertBuilder) Exec() error + type MockAccountsBatchInsertBuilder struct + func (m *MockAccountsBatchInsertBuilder) Add(accounts xdr.AccountEntry, lastModifiedLedger xdr.Uint32) error + func (m *MockAccountsBatchInsertBuilder) Exec() error + type MockEffectBatchInsertBuilder struct + func (m *MockEffectBatchInsertBuilder) Add(accountID int64, operationID int64, order uint32, effectType EffectType, ...) error + func (m *MockEffectBatchInsertBuilder) Exec() error + type MockOffersBatchInsertBuilder struct + func (m *MockOffersBatchInsertBuilder) Add(offer xdr.OfferEntry, lastModifiedLedger xdr.Uint32) error + func (m *MockOffersBatchInsertBuilder) Exec() error + type MockOperationParticipantBatchInsertBuilder struct + func (m *MockOperationParticipantBatchInsertBuilder) Add(operationID int64, accountID int64) error + func (m *MockOperationParticipantBatchInsertBuilder) Exec() error + type MockOperationsBatchInsertBuilder struct + func (m *MockOperationsBatchInsertBuilder) Add(id int64, transactionID int64, applicationOrder uint32, ...) error + func (m *MockOperationsBatchInsertBuilder) Exec() error + type MockQAccounts struct + func (m *MockQAccounts) GetAccountsByIDs(ids []string) ([]AccountEntry, error) + func (m *MockQAccounts) InsertAccount(account xdr.AccountEntry, lastModifiedLedger xdr.Uint32) (int64, error) + func (m *MockQAccounts) NewAccountsBatchInsertBuilder(maxBatchSize int) AccountsBatchInsertBuilder + func (m *MockQAccounts) RemoveAccount(accountID string) (int64, error) + func (m *MockQAccounts) UpdateAccount(account xdr.AccountEntry, lastModifiedLedger xdr.Uint32) (int64, error) + func (m *MockQAccounts) UpsertAccounts(accounts []xdr.LedgerEntry) error + type MockQAssetStats struct + func (m *MockQAssetStats) CountTrustLines() (int, error) + func (m *MockQAssetStats) GetAssetStat(assetType xdr.AssetType, assetCode, assetIssuer string) (ExpAssetStat, error) + func (m *MockQAssetStats) GetAssetStats(assetCode, assetIssuer string, page db2.PageQuery) ([]ExpAssetStat, error) + func (m *MockQAssetStats) InsertAssetStat(assetStat ExpAssetStat) (int64, error) + func (m *MockQAssetStats) InsertAssetStats(assetStats []ExpAssetStat, batchSize int) error + func (m *MockQAssetStats) RemoveAssetStat(assetType xdr.AssetType, assetCode, assetIssuer string) (int64, error) + func (m *MockQAssetStats) UpdateAssetStat(assetStat ExpAssetStat) (int64, error) + type MockQData struct + func (m *MockQData) CountAccountsData() (int, error) + func (m *MockQData) GetAccountDataByKeys(keys []xdr.LedgerKeyData) ([]Data, error) + func (m *MockQData) InsertAccountData(data xdr.DataEntry, lastModifiedLedger xdr.Uint32) (int64, error) + func (m *MockQData) NewAccountDataBatchInsertBuilder(maxBatchSize int) AccountDataBatchInsertBuilder + func (m *MockQData) RemoveAccountData(key xdr.LedgerKeyData) (int64, error) + func (m *MockQData) UpdateAccountData(data xdr.DataEntry, lastModifiedLedger xdr.Uint32) (int64, error) + type MockQEffects struct + func (m *MockQEffects) CreateAccounts(addresses []string, maxBatchSize int) (map[string]int64, error) + func (m *MockQEffects) NewEffectBatchInsertBuilder(maxBatchSize int) EffectBatchInsertBuilder + type MockQLedgers struct + func (m *MockQLedgers) InsertLedger(ledger xdr.LedgerHeaderHistoryEntry, successTxsCount int, failedTxsCount int, ...) (int64, error) + type MockQOffers struct + func (m *MockQOffers) CompactOffers(cutOffSequence uint32) (int64, error) + func (m *MockQOffers) CountOffers() (int, error) + func (m *MockQOffers) GetAllOffers() ([]Offer, error) + func (m *MockQOffers) GetOffersByIDs(ids []int64) ([]Offer, error) + func (m *MockQOffers) GetRemovedOffers(removedAfterSequence uint32) ([]xdr.Int64, error) + func (m *MockQOffers) GetUpdatedOffers(newerThanSequence uint32) ([]Offer, error) + func (m *MockQOffers) NewOffersBatchInsertBuilder(maxBatchSize int) OffersBatchInsertBuilder + func (m *MockQOffers) RemoveOffer(offerID xdr.Int64, lastModifiedLedger uint32) (int64, error) + func (m *MockQOffers) UpdateOffer(offer xdr.OfferEntry, lastModifiedLedger xdr.Uint32) (int64, error) + type MockQOperations struct + func (m *MockQOperations) NewOperationBatchInsertBuilder(maxBatchSize int) OperationBatchInsertBuilder + type MockQParticipants struct + func (m *MockQParticipants) CreateAccounts(addresses []string, maxBatchSize int) (map[string]int64, error) + func (m *MockQParticipants) NewOperationParticipantBatchInsertBuilder(maxBatchSize int) OperationParticipantBatchInsertBuilder + func (m *MockQParticipants) NewTransactionParticipantsBatchInsertBuilder(maxBatchSize int) TransactionParticipantsBatchInsertBuilder + type MockQSigners struct + func (m *MockQSigners) AccountsForSigner(signer string, page db2.PageQuery) ([]AccountSigner, error) + func (m *MockQSigners) CountAccounts() (int, error) + func (m *MockQSigners) CreateAccountSigner(account, signer string, weight int32) (int64, error) + func (m *MockQSigners) GetLastLedgerExpIngest() (uint32, error) + func (m *MockQSigners) GetLastLedgerExpIngestNonBlocking() (uint32, error) + func (m *MockQSigners) NewAccountSignersBatchInsertBuilder(maxBatchSize int) AccountSignersBatchInsertBuilder + func (m *MockQSigners) RemoveAccountSigner(account, signer string) (int64, error) + func (m *MockQSigners) SignersForAccounts(accounts []string) ([]AccountSigner, error) + func (m *MockQSigners) UpdateLastLedgerExpIngest(ledgerSequence uint32) error + type MockQTrades struct + func (m *MockQTrades) CreateAccounts(addresses []string, maxBatchSize int) (map[string]int64, error) + func (m *MockQTrades) CreateAssets(assets []xdr.Asset, maxBatchSize int) (map[string]Asset, error) + func (m *MockQTrades) NewTradeBatchInsertBuilder(maxBatchSize int) TradeBatchInsertBuilder + type MockQTransactions struct + func (m *MockQTransactions) NewTransactionBatchInsertBuilder(maxBatchSize int) TransactionBatchInsertBuilder + type MockQTrustLines struct + func (m *MockQTrustLines) GetTrustLinesByKeys(keys []xdr.LedgerKeyTrustLine) ([]TrustLine, error) + func (m *MockQTrustLines) InsertTrustLine(trustLine xdr.TrustLineEntry, lastModifiedLedger xdr.Uint32) (int64, error) + func (m *MockQTrustLines) NewTrustLinesBatchInsertBuilder(maxBatchSize int) TrustLinesBatchInsertBuilder + func (m *MockQTrustLines) RemoveTrustLine(key xdr.LedgerKeyTrustLine) (int64, error) + func (m *MockQTrustLines) UpdateTrustLine(trustLine xdr.TrustLineEntry, lastModifiedLedger xdr.Uint32) (int64, error) + func (m *MockQTrustLines) UpsertTrustLines(trustLines []xdr.LedgerEntry) error + type MockTradeBatchInsertBuilder struct + func (m *MockTradeBatchInsertBuilder) Add(entries ...InsertTrade) error + func (m *MockTradeBatchInsertBuilder) Exec() error + type MockTransactionParticipantsBatchInsertBuilder struct + func (m *MockTransactionParticipantsBatchInsertBuilder) Add(transactionID, accountID int64) error + func (m *MockTransactionParticipantsBatchInsertBuilder) Exec() error + type MockTransactionsBatchInsertBuilder struct + func (m *MockTransactionsBatchInsertBuilder) Add(transaction io.LedgerTransaction, sequence uint32) error + func (m *MockTransactionsBatchInsertBuilder) Exec() error + type MockTrustLinesBatchInsertBuilder struct + func (m *MockTrustLinesBatchInsertBuilder) Add(trustLines xdr.TrustLineEntry, lastModifiedLedger xdr.Uint32) error + func (m *MockTrustLinesBatchInsertBuilder) Exec() error + type Offer struct + Amount xdr.Int64 + BuyingAsset xdr.Asset + Deleted bool + Flags uint32 + LastModifiedLedger uint32 + OfferID xdr.Int64 + Price float64 + Priced int32 + Pricen int32 + SellerID string + SellingAsset xdr.Asset + type OfferIDType uint64 + const CoreOfferIDType + const TOIDType + func DecodeOfferID(encodedId int64) (uint64, OfferIDType) + type OffersBatchInsertBuilder interface + Add func(offer xdr.OfferEntry, lastModifiedLedger xdr.Uint32) error + Exec func() error + type OffersQuery struct + Buying *xdr.Asset + PageQuery db2.PageQuery + SellerID string + Selling *xdr.Asset + type Operation struct + ApplicationOrder int32 + DetailsString null.String + SourceAccount string + TransactionHash string + TransactionID int64 + TransactionSuccessful bool + TxResult string + Type xdr.OperationType + func (r *Operation) LedgerSequence() int32 + func (r *Operation) UnmarshalDetails(dest interface{}) error + type OperationBatchInsertBuilder interface + Add func(id int64, transactionID int64, applicationOrder uint32, ...) error + Exec func() error + type OperationParticipantBatchInsertBuilder interface + Add func(operationID int64, accountID int64) error + Exec func() error + type OperationsQ struct + Err error + func (q *OperationsQ) Fetch() ([]Operation, []Transaction, error) + func (q *OperationsQ) ForAccount(aid string) *OperationsQ + func (q *OperationsQ) ForLedger(seq int32) *OperationsQ + func (q *OperationsQ) ForTransaction(hash string) *OperationsQ + func (q *OperationsQ) IncludeFailed() *OperationsQ + func (q *OperationsQ) IncludeTransactions() *OperationsQ + func (q *OperationsQ) OnlyPayments() *OperationsQ + func (q *OperationsQ) Page(page db2.PageQuery) *OperationsQ + type OrderBookSummary struct + Asks []PriceLevel + Bids []PriceLevel + type PriceLevel struct + Amount string + Priced int32 + Pricef string + Pricen int32 + type Q struct + func (q *Q) AccountByAddress(dest interface{}, addy string) error + func (q *Q) AccountEntriesForSigner(signer string, page db2.PageQuery) ([]AccountEntry, error) + func (q *Q) Accounts() *AccountsQ + func (q *Q) AccountsByAddresses(dest interface{}, addresses []string) error + func (q *Q) AccountsForAsset(asset xdr.Asset, page db2.PageQuery) ([]AccountEntry, error) + func (q *Q) AccountsForSigner(signer string, page db2.PageQuery) ([]AccountSigner, error) + func (q *Q) CloneIngestionQ() IngestionQ + func (q *Q) CompactOffers(cutOffSequence uint32) (int64, error) + func (q *Q) CountAccounts() (int, error) + func (q *Q) CountAccountsData() (int, error) + func (q *Q) CountOffers() (int, error) + func (q *Q) CountTrustLines() (int, error) + func (q *Q) CreateAccountSigner(account, signer string, weight int32) (int64, error) + func (q *Q) CreateAccounts(addresses []string, batchSize int) (map[string]int64, error) + func (q *Q) CreateAssets(assets []xdr.Asset, batchSize int) (map[string]Asset, error) + func (q *Q) DeleteRangeAll(start, end int64) error + func (q *Q) Effects() *EffectsQ + func (q *Q) ElderLedger(dest interface{}) error + func (q *Q) FeeStats(currentSeq int32, dest *FeeStats) error + func (q *Q) GetAccountByID(id string) (AccountEntry, error) + func (q *Q) GetAccountDataByAccountID(id string) ([]Data, error) + func (q *Q) GetAccountDataByAccountsID(id []string) ([]Data, error) + func (q *Q) GetAccountDataByKeys(keys []xdr.LedgerKeyData) ([]Data, error) + func (q *Q) GetAccountDataByName(id, name string) (Data, error) + func (q *Q) GetAccountSignersByAccountID(id string) ([]AccountSigner, error) + func (q *Q) GetAccountsByIDs(ids []string) ([]AccountEntry, error) + func (q *Q) GetAllOffers() ([]Offer, error) + func (q *Q) GetAssetID(asset xdr.Asset) (id int64, err error) + func (q *Q) GetAssetStat(assetType xdr.AssetType, assetCode, assetIssuer string) (ExpAssetStat, error) + func (q *Q) GetAssetStats(assetCode, assetIssuer string, page db2.PageQuery) ([]ExpAssetStat, error) + func (q *Q) GetExpIngestVersion() (int, error) + func (q *Q) GetExpStateInvalid() (bool, error) + func (q *Q) GetLastLedgerExpIngest() (uint32, error) + func (q *Q) GetLastLedgerExpIngestNonBlocking() (uint32, error) + func (q *Q) GetLatestLedger() (uint32, error) + func (q *Q) GetOfferByID(id int64) (Offer, error) + func (q *Q) GetOfferCompactionSequence() (uint32, error) + func (q *Q) GetOffers(query OffersQuery) ([]Offer, error) + func (q *Q) GetOffersByIDs(ids []int64) ([]Offer, error) + func (q *Q) GetOrderBookSummary(sellingAsset, buyingAsset xdr.Asset, maxPriceLevels int) (OrderBookSummary, error) + func (q *Q) GetSequenceNumbers(addresses []string) (map[string]uint64, error) + func (q *Q) GetSortedTrustLinesByAccountID(id string) ([]TrustLine, error) + func (q *Q) GetSortedTrustLinesByAccountIDs(id []string) ([]TrustLine, error) + func (q *Q) GetTrustLinesByKeys(keys []xdr.LedgerKeyTrustLine) ([]TrustLine, error) + func (q *Q) GetUpdatedOffers(newerThanSequence uint32) ([]Offer, error) + func (q *Q) InsertAccountData(data xdr.DataEntry, lastModifiedLedger xdr.Uint32) (int64, error) + func (q *Q) InsertAssetStat(assetStat ExpAssetStat) (int64, error) + func (q *Q) InsertAssetStats(assetStats []ExpAssetStat, batchSize int) error + func (q *Q) InsertLedger(ledger xdr.LedgerHeaderHistoryEntry, successTxsCount int, failedTxsCount int, ...) (int64, error) + func (q *Q) InsertTrustLine(trustLine xdr.TrustLineEntry, lastModifiedLedger xdr.Uint32) (int64, error) + func (q *Q) LatestLedger(dest interface{}) error + func (q *Q) LatestLedgerBaseFeeAndSequence(dest interface{}) error + func (q *Q) LedgerBySequence(dest interface{}, seq int32) error + func (q *Q) LedgerCapacityUsageStats(currentSeq int32, dest *LedgerCapacityUsageStats) error + func (q *Q) Ledgers() *LedgersQ + func (q *Q) LedgersBySequence(dest interface{}, seqs ...int32) error + func (q *Q) NewAccountDataBatchInsertBuilder(maxBatchSize int) AccountDataBatchInsertBuilder + func (q *Q) NewAccountSignersBatchInsertBuilder(maxBatchSize int) AccountSignersBatchInsertBuilder + func (q *Q) NewAccountsBatchInsertBuilder(maxBatchSize int) AccountsBatchInsertBuilder + func (q *Q) NewEffectBatchInsertBuilder(maxBatchSize int) EffectBatchInsertBuilder + func (q *Q) NewOffersBatchInsertBuilder(maxBatchSize int) OffersBatchInsertBuilder + func (q *Q) NewOperationBatchInsertBuilder(maxBatchSize int) OperationBatchInsertBuilder + func (q *Q) NewOperationParticipantBatchInsertBuilder(maxBatchSize int) OperationParticipantBatchInsertBuilder + func (q *Q) NewTradeBatchInsertBuilder(maxBatchSize int) TradeBatchInsertBuilder + func (q *Q) NewTransactionBatchInsertBuilder(maxBatchSize int) TransactionBatchInsertBuilder + func (q *Q) NewTransactionParticipantsBatchInsertBuilder(maxBatchSize int) TransactionParticipantsBatchInsertBuilder + func (q *Q) NewTrustLinesBatchInsertBuilder(maxBatchSize int) TrustLinesBatchInsertBuilder + func (q *Q) OldestOutdatedLedgers(dest interface{}, currentVersion int) error + func (q *Q) OperationByID(includeTransactions bool, id int64) (Operation, *Transaction, error) + func (q *Q) Operations() *OperationsQ + func (q *Q) RemoveAccount(accountID string) (int64, error) + func (q *Q) RemoveAccountData(key xdr.LedgerKeyData) (int64, error) + func (q *Q) RemoveAccountSigner(account, signer string) (int64, error) + func (q *Q) RemoveAssetStat(assetType xdr.AssetType, assetCode, assetIssuer string) (int64, error) + func (q *Q) RemoveOffer(offerID xdr.Int64, lastModifiedLedger uint32) (int64, error) + func (q *Q) RemoveTrustLine(ledgerKey xdr.LedgerKeyTrustLine) (int64, error) + func (q *Q) ReverseTrades() *TradesQ + func (q *Q) SignersForAccounts(accounts []string) ([]AccountSigner, error) + func (q *Q) Trades() *TradesQ + func (q *Q) TradesForAssetPair(baseAssetId int64, counterAssetId int64) *TradesQ + func (q *Q) TransactionByHash(dest interface{}, hash string) error + func (q *Q) Transactions() *TransactionsQ + func (q *Q) TransactionsByIDs(ids ...int64) (map[int64]Transaction, error) + func (q *Q) TruncateExpingestStateTables() error + func (q *Q) UpdateAccountData(data xdr.DataEntry, lastModifiedLedger xdr.Uint32) (int64, error) + func (q *Q) UpdateAssetStat(assetStat ExpAssetStat) (int64, error) + func (q *Q) UpdateExpIngestVersion(ledgerSequence int) error + func (q *Q) UpdateExpStateInvalid(val bool) error + func (q *Q) UpdateLastLedgerExpIngest(ledgerSequence uint32) error + func (q *Q) UpdateOffer(offer xdr.OfferEntry, lastModifiedLedger xdr.Uint32) (int64, error) + func (q *Q) UpdateOfferCompactionSequence(sequence uint32) error + func (q *Q) UpdateTrustLine(trustLine xdr.TrustLineEntry, lastModifiedLedger xdr.Uint32) (int64, error) + func (q *Q) UpsertAccounts(accounts []xdr.LedgerEntry) error + func (q *Q) UpsertTrustLines(trustLines []xdr.LedgerEntry) error + func (q Q) GetTradeAggregationsQ(baseAssetID int64, counterAssetID int64, resolution int64, offset int64, ...) (*TradeAggregationsQ, error) + type QAccounts interface + GetAccountsByIDs func(ids []string) ([]AccountEntry, error) + NewAccountsBatchInsertBuilder func(maxBatchSize int) AccountsBatchInsertBuilder + RemoveAccount func(accountID string) (int64, error) + UpsertAccounts func(accounts []xdr.LedgerEntry) error + type QAssetStats interface + CountTrustLines func() (int, error) + GetAssetStat func(assetType xdr.AssetType, assetCode, assetIssuer string) (ExpAssetStat, error) + GetAssetStats func(assetCode, assetIssuer string, page db2.PageQuery) ([]ExpAssetStat, error) + InsertAssetStat func(stat ExpAssetStat) (int64, error) + InsertAssetStats func(stats []ExpAssetStat, batchSize int) error + RemoveAssetStat func(assetType xdr.AssetType, assetCode, assetIssuer string) (int64, error) + UpdateAssetStat func(stat ExpAssetStat) (int64, error) + type QCreateAccountsHistory interface + CreateAccounts func(addresses []string, maxBatchSize int) (map[string]int64, error) + type QData interface + CountAccountsData func() (int, error) + GetAccountDataByKeys func(keys []xdr.LedgerKeyData) ([]Data, error) + InsertAccountData func(data xdr.DataEntry, lastModifiedLedger xdr.Uint32) (int64, error) + NewAccountDataBatchInsertBuilder func(maxBatchSize int) AccountDataBatchInsertBuilder + RemoveAccountData func(key xdr.LedgerKeyData) (int64, error) + UpdateAccountData func(data xdr.DataEntry, lastModifiedLedger xdr.Uint32) (int64, error) + type QEffects interface + NewEffectBatchInsertBuilder func(maxBatchSize int) EffectBatchInsertBuilder + type QLedgers interface + InsertLedger func(ledger xdr.LedgerHeaderHistoryEntry, successTxsCount int, failedTxsCount int, ...) (int64, error) + type QOffers interface + CompactOffers func(cutOffSequence uint32) (int64, error) + CountOffers func() (int, error) + GetAllOffers func() ([]Offer, error) + GetOffersByIDs func(ids []int64) ([]Offer, error) + GetUpdatedOffers func(newerThanSequence uint32) ([]Offer, error) + NewOffersBatchInsertBuilder func(maxBatchSize int) OffersBatchInsertBuilder + RemoveOffer func(offerID xdr.Int64, lastModifiedLedger uint32) (int64, error) + UpdateOffer func(offer xdr.OfferEntry, lastModifiedLedger xdr.Uint32) (int64, error) + type QOperations interface + NewOperationBatchInsertBuilder func(maxBatchSize int) OperationBatchInsertBuilder + type QParticipants interface + NewOperationParticipantBatchInsertBuilder func(maxBatchSize int) OperationParticipantBatchInsertBuilder + NewTransactionParticipantsBatchInsertBuilder func(maxBatchSize int) TransactionParticipantsBatchInsertBuilder + type QSigners interface + AccountsForSigner func(signer string, page db2.PageQuery) ([]AccountSigner, error) + CountAccounts func() (int, error) + CreateAccountSigner func(account, signer string, weight int32) (int64, error) + GetLastLedgerExpIngest func() (uint32, error) + GetLastLedgerExpIngestNonBlocking func() (uint32, error) + NewAccountSignersBatchInsertBuilder func(maxBatchSize int) AccountSignersBatchInsertBuilder + RemoveAccountSigner func(account, signer string) (int64, error) + SignersForAccounts func(accounts []string) ([]AccountSigner, error) + UpdateLastLedgerExpIngest func(ledgerSequence uint32) error + type QTrades interface + CreateAssets func(assets []xdr.Asset, maxBatchSize int) (map[string]Asset, error) + NewTradeBatchInsertBuilder func(maxBatchSize int) TradeBatchInsertBuilder + type QTransactions interface + NewTransactionBatchInsertBuilder func(maxBatchSize int) TransactionBatchInsertBuilder + type QTrustLines interface + GetTrustLinesByKeys func(keys []xdr.LedgerKeyTrustLine) ([]TrustLine, error) + InsertTrustLine func(trustLine xdr.TrustLineEntry, lastModifiedLedger xdr.Uint32) (int64, error) + NewTrustLinesBatchInsertBuilder func(maxBatchSize int) TrustLinesBatchInsertBuilder + RemoveTrustLine func(key xdr.LedgerKeyTrustLine) (int64, error) + UpdateTrustLine func(trustLine xdr.TrustLineEntry, lastModifiedLedger xdr.Uint32) (int64, error) + UpsertTrustLines func(trustLines []xdr.LedgerEntry) error + type SequenceBumped struct + NewSeq int64 + type TimeBounds struct + Lower null.Int + Null bool + Upper null.Int + func (t *TimeBounds) Scan(src interface{}) error + func (t TimeBounds) Value() (driver.Value, error) + type TotalOrderID struct + ID int64 + func (r *TotalOrderID) PagingToken() string + type Trade struct + BaseAccount string + BaseAmount xdr.Int64 + BaseAssetCode string + BaseAssetIssuer string + BaseAssetType string + BaseIsSeller bool + BaseOfferID *int64 + CounterAccount string + CounterAmount xdr.Int64 + CounterAssetCode string + CounterAssetIssuer string + CounterAssetType string + CounterOfferID *int64 + HistoryOperationID int64 + LedgerCloseTime time.Time + OfferID int64 + Order int32 + PriceD null.Int + PriceN null.Int + func (r *Trade) HasPrice() bool + func (r *Trade) PagingToken() string + type TradeAggregation struct + Average float64 + BaseVolume string + Close xdr.Price + CounterVolume string + High xdr.Price + Low xdr.Price + Open xdr.Price + Timestamp int64 + TradeCount int64 + type TradeAggregationsQ struct + func (q *TradeAggregationsQ) GetSql() sq.SelectBuilder + func (q *TradeAggregationsQ) WithEndTime(endTime strtime.Millis) (*TradeAggregationsQ, error) + func (q *TradeAggregationsQ) WithStartTime(startTime strtime.Millis) (*TradeAggregationsQ, error) + type TradeBatchInsertBuilder interface + Add func(entries ...InsertTrade) error + Exec func() error + type TradeEffectDetails struct + BoughtAmount string + BoughtAssetCode string + BoughtAssetIssuer string + BoughtAssetType string + OfferID int64 + Seller string + SoldAmount string + SoldAssetCode string + SoldAssetIssuer string + SoldAssetType string + type TradesQ struct + Err error + func (q *TradesQ) ForAccount(aid string) *TradesQ + func (q *TradesQ) ForLedger(sequence int32, order string) *TradesQ + func (q *TradesQ) ForOffer(id int64) *TradesQ + func (q *TradesQ) Page(page db2.PageQuery) *TradesQ + func (q *TradesQ) Select(dest interface{}) error + type Transaction struct + LedgerCloseTime time.Time + type TransactionBatchInsertBuilder interface + Add func(transaction io.LedgerTransaction, sequence uint32) error + Exec func() error + type TransactionParticipantsBatchInsertBuilder interface + Add func(transactionID, accountID int64) error + Exec func() error + type TransactionWithoutLedger struct + Account string + AccountSequence string + ApplicationOrder int32 + CreatedAt time.Time + FeeAccount null.String + FeeCharged int64 + InnerSignatures pq.StringArray + InnerTransactionHash null.String + LedgerSequence int32 + MaxFee int64 + Memo null.String + MemoType string + NewMaxFee null.Int + OperationCount int32 + Signatures pq.StringArray + Successful bool + TimeBounds TimeBounds + TransactionHash string + TxEnvelope string + TxFeeMeta string + TxMeta string + TxResult string + UpdatedAt time.Time + type TransactionsQ struct + Err error + func (q *TransactionsQ) ForAccount(aid string) *TransactionsQ + func (q *TransactionsQ) ForLedger(seq int32) *TransactionsQ + func (q *TransactionsQ) IncludeFailed() *TransactionsQ + func (q *TransactionsQ) Page(page db2.PageQuery) *TransactionsQ + func (q *TransactionsQ) Select(dest interface{}) error + type TrustLine struct + AccountID string + AssetCode string + AssetIssuer string + AssetType xdr.AssetType + Balance int64 + BuyingLiabilities int64 + Flags uint32 + LastModifiedLedger uint32 + Limit int64 + SellingLiabilities int64 + func (trustLine TrustLine) IsAuthorized() bool + func (trustLine TrustLine) IsAuthorizedToMaintainLiabilities() bool + type TrustLinesBatchInsertBuilder interface + Add func(trustLine xdr.TrustLineEntry, lastModifiedLedger xdr.Uint32) error + Exec func() error
Go to main page