Versions in this module Expand all Collapse all v0 v0.1.2 Nov 14, 2024 v0.1.1 Jan 25, 2024 Changes in this version + const AllTrades + const LiquidityPoolTradeType + const LiquidityPoolTrades + const OrderbookTradeType + const OrderbookTrades + var AllowedResolutions = map[time.Duration]struct + var StrictResolutionFiltering = true + type Account struct + Address string + ID int64 + type AccountDataKey struct + AccountID string + DataName string + 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 + NumSponsored uint32 + NumSponsoring uint32 + NumSubEntries uint32 + SellingLiabilities int64 + SequenceNumber int64 + Sponsor null.String + ThresholdHigh byte + ThresholdLow byte + ThresholdMedium byte + func (account AccountEntry) IsAuthClawbackEnabled() bool + func (account AccountEntry) IsAuthImmutable() bool + func (account AccountEntry) IsAuthRequired() bool + func (account AccountEntry) IsAuthRevocable() bool + type AccountSigner struct + Account string + Signer string + Sponsor null.String + Weight int32 + type AccountSignersBatchInsertBuilder interface + Add func(ctx context.Context, signer AccountSigner) error + Exec func(ctx context.Context) error + type Asset struct + Code string + ID int64 + Issuer string + Type string + type ClaimableBalance struct + Amount xdr.Int64 + Asset xdr.Asset + BalanceID string + Claimants Claimants + Flags uint32 + LastModifiedLedger uint32 + Sponsor null.String + type ClaimableBalancesQuery struct + Asset *xdr.Asset + Claimant *xdr.AccountId + PageQuery db2.PageQuery + Sponsor *xdr.AccountId + func (cbq ClaimableBalancesQuery) ApplyCursor(sql sq.SelectBuilder) (sq.SelectBuilder, error) + func (cbq ClaimableBalancesQuery) Cursor() (int64, string, error) + type Claimant struct + Destination string + Predicate xdr.ClaimPredicate + type Claimants []Claimant + func (c *Claimants) Scan(value interface{}) error + func (c Claimants) Value() (driver.Value, error) + type Data struct + AccountID string + LastModifiedLedger uint32 + Name string + Sponsor null.String + Value AccountDataValue + type Effect struct + Account string + AccountMuxed null.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(ctx context.Context, accountID int64, muxedAccount null.String, ...) error + Exec func(ctx context.Context) error + type EffectType int + const EffectAccountCreated + const EffectAccountCredited + const EffectAccountDebited + const EffectAccountFlagsUpdated + const EffectAccountHomeDomainUpdated + const EffectAccountInflationDestinationUpdated + const EffectAccountRemoved + const EffectAccountSponsorshipCreated + const EffectAccountSponsorshipRemoved + const EffectAccountSponsorshipUpdated + const EffectAccountThresholdsUpdated + const EffectClaimableBalanceClaimantCreated + const EffectClaimableBalanceClaimed + const EffectClaimableBalanceClawedBack + const EffectClaimableBalanceCreated + const EffectClaimableBalanceSponsorshipCreated + const EffectClaimableBalanceSponsorshipRemoved + const EffectClaimableBalanceSponsorshipUpdated + const EffectDataCreated + const EffectDataRemoved + const EffectDataSponsorshipCreated + const EffectDataSponsorshipRemoved + const EffectDataSponsorshipUpdated + const EffectDataUpdated + const EffectLiquidityPoolCreated + const EffectLiquidityPoolDeposited + const EffectLiquidityPoolRemoved + const EffectLiquidityPoolRevoked + const EffectLiquidityPoolTrade + const EffectLiquidityPoolWithdrew + const EffectSequenceBumped + const EffectSignerCreated + const EffectSignerRemoved + const EffectSignerSponsorshipCreated + const EffectSignerSponsorshipRemoved + const EffectSignerSponsorshipUpdated + const EffectSignerUpdated + const EffectTrade + const EffectTrustlineAuthorized + const EffectTrustlineAuthorizedToMaintainLiabilities + const EffectTrustlineCreated + const EffectTrustlineDeauthorized + const EffectTrustlineFlagsUpdated + const EffectTrustlineRemoved + const EffectTrustlineSponsorshipCreated + const EffectTrustlineSponsorshipRemoved + const EffectTrustlineSponsorshipUpdated + const EffectTrustlineUpdated + type EffectsQ struct + Err error + func (q *EffectsQ) ForAccount(ctx context.Context, aid string) *EffectsQ + func (q *EffectsQ) ForLedger(ctx context.Context, seq int32) *EffectsQ + func (q *EffectsQ) ForLiquidityPool(ctx context.Context, page db2.PageQuery, id string) *EffectsQ + func (q *EffectsQ) ForOperation(id int64) *EffectsQ + func (q *EffectsQ) ForTransaction(ctx context.Context, hash string) *EffectsQ + func (q *EffectsQ) Page(page db2.PageQuery) *EffectsQ + func (q *EffectsQ) Select(ctx context.Context, dest interface{}) error + type ExpAssetStat struct + Accounts ExpAssetStatAccounts + Amount string + AssetCode string + AssetIssuer string + AssetType xdr.AssetType + Balances ExpAssetStatBalances + NumAccounts int32 + func (e ExpAssetStat) PagingToken() string + type ExpAssetStatAccounts struct + Authorized int32 + AuthorizedToMaintainLiabilities int32 + ClaimableBalances int32 + LiquidityPools int32 + Unauthorized int32 + func (a ExpAssetStatAccounts) Add(b ExpAssetStatAccounts) ExpAssetStatAccounts + func (a ExpAssetStatAccounts) IsZero() bool + func (e *ExpAssetStatAccounts) Scan(src interface{}) error + func (e ExpAssetStatAccounts) Value() (driver.Value, error) + type ExpAssetStatBalances struct + Authorized string + AuthorizedToMaintainLiabilities string + ClaimableBalances string + LiquidityPools string + Unauthorized string + func (e *ExpAssetStatBalances) Scan(src interface{}) error + func (e ExpAssetStatBalances) Value() (driver.Value, error) + 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 HistoryClaimableBalance struct + BalanceID string + InternalID int64 + type HistoryLiquidityPool struct + InternalID int64 + PoolID string + type IngestionQ interface + Begin func() error + BeginTx func(*sql.TxOptions) error + CloneIngestionQ func() IngestionQ + Commit func() error + CreateAssets func(ctx context.Context, assets []xdr.Asset, batchSize int) (map[string]Asset, error) + DeleteRangeAll func(ctx context.Context, start, end int64) error + GetExpStateInvalid func(context.Context) (bool, error) + GetIngestVersion func(context.Context) (int, error) + GetLatestHistoryLedger func(context.Context) (uint32, error) + GetLiquidityPoolCompactionSequence func(context.Context) (uint32, error) + GetOfferCompactionSequence func(context.Context) (uint32, error) + GetTx func() *sqlx.Tx + NewOperationParticipantBatchInsertBuilder func(maxBatchSize int) OperationParticipantBatchInsertBuilder + NewTradeBatchInsertBuilder func(maxBatchSize int) TradeBatchInsertBuilder + NewTransactionParticipantsBatchInsertBuilder func(maxBatchSize int) TransactionParticipantsBatchInsertBuilder + RebuildTradeAggregationBuckets func(ctx context.Context, fromLedger, toLedger uint32) error + RebuildTradeAggregationTimes func(ctx context.Context, from, to strtime.Millis) error + Rollback func() error + TruncateIngestStateTables func(context.Context) error + UpdateExpStateInvalid func(context.Context, bool) error + UpdateIngestVersion func(context.Context, int) error + type InsertTrade struct + BaseAccountID null.Int + BaseAmount int64 + BaseAssetID int64 + BaseIsSeller bool + BaseLiquidityPoolID null.Int + BaseOfferID null.Int + CounterAccountID null.Int + CounterAmount int64 + CounterAssetID int64 + CounterLiquidityPoolID null.Int + CounterOfferID null.Int + HistoryOperationID int64 + LedgerCloseTime time.Time + LiquidityPoolFee null.Int + Order int32 + PriceD int64 + PriceN int64 + Type TradeType + 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 + TxSetOperationCount *int32 + UpdatedAt time.Time + type LedgerCache struct + Records map[int32]Ledger + func (lc *LedgerCache) Load(ctx context.Context, q *Q) error + func (lc *LedgerCache) Queue(seq int32) + type LedgerCapacityUsageStats struct + CapacityUsage null.String + type LedgerRange struct + EndSequence uint32 + StartSequence uint32 + type LedgersQ struct + Err error + func (q *LedgersQ) Page(page db2.PageQuery) *LedgersQ + func (q *LedgersQ) Select(ctx context.Context, dest interface{}) error + type LiquidityPool struct + AssetReserves LiquidityPoolAssetReserves + Deleted bool + Fee uint32 + LastModifiedLedger uint32 + PoolID string + ShareCount uint64 + TrustlineCount uint64 + Type xdr.LiquidityPoolType + func MakeTestPool(A xdr.Asset, a uint64, B xdr.Asset, b uint64) LiquidityPool + type LiquidityPoolAssetReserve struct + Asset xdr.Asset + Reserve uint64 + func (lpar *LiquidityPoolAssetReserve) UnmarshalJSON(data []byte) error + func (lpar LiquidityPoolAssetReserve) MarshalJSON() ([]byte, error) + type LiquidityPoolAssetReserves []LiquidityPoolAssetReserve + func (c *LiquidityPoolAssetReserves) Scan(value interface{}) error + func (c LiquidityPoolAssetReserves) Value() (driver.Value, error) + type LiquidityPoolsQuery struct + Account string + Assets []xdr.Asset + PageQuery db2.PageQuery + type ManageOffer struct + OfferID int64 + type MockAccountSignersBatchInsertBuilder struct + func (m *MockAccountSignersBatchInsertBuilder) Add(ctx context.Context, signer AccountSigner) error + func (m *MockAccountSignersBatchInsertBuilder) Exec(ctx context.Context) error + type MockEffectBatchInsertBuilder struct + func (m *MockEffectBatchInsertBuilder) Add(ctx context.Context, accountID int64, muxedAccount null.String, ...) error + func (m *MockEffectBatchInsertBuilder) Exec(ctx context.Context) error + type MockOperationClaimableBalanceBatchInsertBuilder struct + func (m *MockOperationClaimableBalanceBatchInsertBuilder) Add(ctx context.Context, transactionID, accountID int64) error + func (m *MockOperationClaimableBalanceBatchInsertBuilder) Exec(ctx context.Context) error + type MockOperationLiquidityPoolBatchInsertBuilder struct + func (m *MockOperationLiquidityPoolBatchInsertBuilder) Add(ctx context.Context, transactionID, accountID int64) error + func (m *MockOperationLiquidityPoolBatchInsertBuilder) Exec(ctx context.Context) error + type MockOperationParticipantBatchInsertBuilder struct + func (m *MockOperationParticipantBatchInsertBuilder) Add(ctx context.Context, operationID int64, accountID int64) error + func (m *MockOperationParticipantBatchInsertBuilder) Exec(ctx context.Context) error + type MockOperationsBatchInsertBuilder struct + func (m *MockOperationsBatchInsertBuilder) Add(ctx context.Context, id int64, transactionID int64, applicationOrder uint32, ...) error + func (m *MockOperationsBatchInsertBuilder) Exec(ctx context.Context) error + type MockQAccounts struct + func (m *MockQAccounts) GetAccountsByIDs(ctx context.Context, ids []string) ([]AccountEntry, error) + func (m *MockQAccounts) RemoveAccounts(ctx context.Context, accountIDs []string) (int64, error) + func (m *MockQAccounts) UpsertAccounts(ctx context.Context, accounts []AccountEntry) error + type MockQAssetStats struct + func (m *MockQAssetStats) CountTrustLines(ctx context.Context) (int, error) + func (m *MockQAssetStats) GetAssetStat(ctx context.Context, assetType xdr.AssetType, assetCode, assetIssuer string) (ExpAssetStat, error) + func (m *MockQAssetStats) GetAssetStats(ctx context.Context, assetCode, assetIssuer string, page db2.PageQuery) ([]ExpAssetStat, error) + func (m *MockQAssetStats) InsertAssetStat(ctx context.Context, assetStat ExpAssetStat) (int64, error) + func (m *MockQAssetStats) InsertAssetStats(ctx context.Context, assetStats []ExpAssetStat, batchSize int) error + func (m *MockQAssetStats) RemoveAssetStat(ctx context.Context, assetType xdr.AssetType, assetCode, assetIssuer string) (int64, error) + func (m *MockQAssetStats) UpdateAssetStat(ctx context.Context, assetStat ExpAssetStat) (int64, error) + type MockQClaimableBalances struct + func (m *MockQClaimableBalances) CountClaimableBalances(ctx context.Context) (int, error) + func (m *MockQClaimableBalances) GetClaimableBalancesByID(ctx context.Context, ids []string) ([]ClaimableBalance, error) + func (m *MockQClaimableBalances) RemoveClaimableBalances(ctx context.Context, ids []string) (int64, error) + func (m *MockQClaimableBalances) UpsertClaimableBalances(ctx context.Context, cbs []ClaimableBalance) error + type MockQData struct + func (m *MockQData) CountAccountsData(ctx context.Context) (int, error) + func (m *MockQData) GetAccountDataByKeys(ctx context.Context, keys []AccountDataKey) ([]Data, error) + func (m *MockQData) RemoveAccountData(ctx context.Context, keys []AccountDataKey) (int64, error) + func (m *MockQData) UpsertAccountData(ctx context.Context, data []Data) error + type MockQEffects struct + func (m *MockQEffects) CreateAccounts(ctx context.Context, addresses []string, maxBatchSize int) (map[string]int64, error) + func (m *MockQEffects) NewEffectBatchInsertBuilder(maxBatchSize int) EffectBatchInsertBuilder + type MockQHistoryClaimableBalances struct + func (m *MockQHistoryClaimableBalances) CreateHistoryClaimableBalances(ctx context.Context, ids []string, maxBatchSize int) (map[string]int64, error) + func (m *MockQHistoryClaimableBalances) NewOperationClaimableBalanceBatchInsertBuilder(maxBatchSize int) OperationClaimableBalanceBatchInsertBuilder + func (m *MockQHistoryClaimableBalances) NewTransactionClaimableBalanceBatchInsertBuilder(maxBatchSize int) TransactionClaimableBalanceBatchInsertBuilder + type MockQHistoryLiquidityPools struct + func (m *MockQHistoryLiquidityPools) CreateHistoryLiquidityPools(ctx context.Context, poolIDs []string, maxBatchSize int) (map[string]int64, error) + func (m *MockQHistoryLiquidityPools) NewOperationLiquidityPoolBatchInsertBuilder(maxBatchSize int) OperationLiquidityPoolBatchInsertBuilder + func (m *MockQHistoryLiquidityPools) NewTransactionLiquidityPoolBatchInsertBuilder(maxBatchSize int) TransactionLiquidityPoolBatchInsertBuilder + type MockQLedgers struct + func (m *MockQLedgers) InsertLedger(ctx context.Context, ledger xdr.LedgerHeaderHistoryEntry, successTxsCount int, ...) (int64, error) + type MockQLiquidityPools struct + func (m *MockQLiquidityPools) CompactLiquidityPools(ctx context.Context, cutOffSequence uint32) (int64, error) + func (m *MockQLiquidityPools) CountLiquidityPools(ctx context.Context) (int, error) + func (m *MockQLiquidityPools) FindLiquidityPoolByID(ctx context.Context, liquidityPoolID string) (LiquidityPool, error) + func (m *MockQLiquidityPools) GetAllLiquidityPools(ctx context.Context) ([]LiquidityPool, error) + func (m *MockQLiquidityPools) GetLiquidityPoolsByID(ctx context.Context, poolIDs []string) ([]LiquidityPool, error) + func (m *MockQLiquidityPools) GetUpdatedLiquidityPools(ctx context.Context, sequence uint32) ([]LiquidityPool, error) + func (m *MockQLiquidityPools) UpsertLiquidityPools(ctx context.Context, lps []LiquidityPool) error + type MockQOffers struct + func (m *MockQOffers) CompactOffers(ctx context.Context, cutOffSequence uint32) (int64, error) + func (m *MockQOffers) CountOffers(ctx context.Context) (int, error) + func (m *MockQOffers) GetAllOffers(ctx context.Context) ([]Offer, error) + func (m *MockQOffers) GetOffersByIDs(ctx context.Context, ids []int64) ([]Offer, error) + func (m *MockQOffers) GetUpdatedOffers(ctx context.Context, newerThanSequence uint32) ([]Offer, error) + func (m *MockQOffers) UpsertOffers(ctx context.Context, rows []Offer) error + type MockQOperations struct + func (m *MockQOperations) NewOperationBatchInsertBuilder(maxBatchSize int) OperationBatchInsertBuilder + type MockQParticipants struct + func (m *MockQParticipants) CreateAccounts(ctx context.Context, 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(ctx context.Context, signer string, page db2.PageQuery) ([]AccountSigner, error) + func (m *MockQSigners) CountAccounts(ctx context.Context) (int, error) + func (m *MockQSigners) CreateAccountSigner(ctx context.Context, account, signer string, weight int32, sponsor *string) (int64, error) + func (m *MockQSigners) GetLastLedgerIngest(ctx context.Context) (uint32, error) + func (m *MockQSigners) GetLastLedgerIngestNonBlocking(ctx context.Context) (uint32, error) + func (m *MockQSigners) NewAccountSignersBatchInsertBuilder(maxBatchSize int) AccountSignersBatchInsertBuilder + func (m *MockQSigners) RemoveAccountSigner(ctx context.Context, account, signer string) (int64, error) + func (m *MockQSigners) SignersForAccounts(ctx context.Context, accounts []string) ([]AccountSigner, error) + func (m *MockQSigners) UpdateLastLedgerIngest(ctx context.Context, ledgerSequence uint32) error + type MockQTrades struct + func (m *MockQTrades) CreateAccounts(ctx context.Context, addresses []string, maxBatchSize int) (map[string]int64, error) + func (m *MockQTrades) CreateAssets(ctx context.Context, assets []xdr.Asset, maxBatchSize int) (map[string]Asset, error) + func (m *MockQTrades) CreateHistoryLiquidityPools(ctx context.Context, poolIDs []string, maxBatchSize int) (map[string]int64, error) + func (m *MockQTrades) NewTradeBatchInsertBuilder(maxBatchSize int) TradeBatchInsertBuilder + func (m *MockQTrades) RebuildTradeAggregationBuckets(ctx context.Context, fromLedger, toLedger uint32) error + type MockQTransactions struct + func (m *MockQTransactions) NewTransactionBatchInsertBuilder(maxBatchSize int) TransactionBatchInsertBuilder + type MockQTrustLines struct + func (m *MockQTrustLines) GetTrustLinesByKeys(ctx context.Context, keys []string) ([]TrustLine, error) + func (m *MockQTrustLines) RemoveTrustLines(ctx context.Context, ledgerKeys []string) (int64, error) + func (m *MockQTrustLines) UpsertTrustLines(ctx context.Context, trustLines []TrustLine) error + type MockTradeBatchInsertBuilder struct + func (m *MockTradeBatchInsertBuilder) Add(ctx context.Context, entries ...InsertTrade) error + func (m *MockTradeBatchInsertBuilder) Exec(ctx context.Context) error + type MockTransactionClaimableBalanceBatchInsertBuilder struct + func (m *MockTransactionClaimableBalanceBatchInsertBuilder) Add(ctx context.Context, transactionID, accountID int64) error + func (m *MockTransactionClaimableBalanceBatchInsertBuilder) Exec(ctx context.Context) error + type MockTransactionLiquidityPoolBatchInsertBuilder struct + func (m *MockTransactionLiquidityPoolBatchInsertBuilder) Add(ctx context.Context, transactionID, accountID int64) error + func (m *MockTransactionLiquidityPoolBatchInsertBuilder) Exec(ctx context.Context) error + type MockTransactionParticipantsBatchInsertBuilder struct + func (m *MockTransactionParticipantsBatchInsertBuilder) Add(ctx context.Context, transactionID, accountID int64) error + func (m *MockTransactionParticipantsBatchInsertBuilder) Exec(ctx context.Context) error + type MockTransactionsBatchInsertBuilder struct + func (m *MockTransactionsBatchInsertBuilder) Add(ctx context.Context, transaction ingest.LedgerTransaction, sequence uint32) error + func (m *MockTransactionsBatchInsertBuilder) Exec(ctx context.Context) error + type Offer struct + Amount int64 + BuyingAsset xdr.Asset + Deleted bool + Flags int32 + LastModifiedLedger uint32 + OfferID int64 + Price float64 + Priced int32 + Pricen int32 + SellerID string + SellingAsset xdr.Asset + Sponsor null.String + type OffersQuery struct + Buying *xdr.Asset + PageQuery db2.PageQuery + SellerID string + Selling *xdr.Asset + Sponsor string + type Operation struct + ApplicationOrder int32 + DetailsString null.String + SourceAccount string + SourceAccountMuxed null.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(ctx context.Context, id int64, transactionID int64, applicationOrder uint32, ...) error + Exec func(ctx context.Context) error + type OperationClaimableBalanceBatchInsertBuilder interface + Add func(ctx context.Context, operationID, internalID int64) error + Exec func(ctx context.Context) error + type OperationLiquidityPoolBatchInsertBuilder interface + Add func(ctx context.Context, operationID, internalID int64) error + Exec func(ctx context.Context) error + type OperationParticipantBatchInsertBuilder interface + Add func(ctx context.Context, operationID int64, accountID int64) error + Exec func(ctx context.Context) error + type OperationsQ struct + Err error + func (q *OperationsQ) Fetch(ctx context.Context) ([]Operation, []Transaction, error) + func (q *OperationsQ) ForAccount(ctx context.Context, aid string) *OperationsQ + func (q *OperationsQ) ForClaimableBalance(ctx context.Context, cbID string) *OperationsQ + func (q *OperationsQ) ForLedger(ctx context.Context, seq int32) *OperationsQ + func (q *OperationsQ) ForLiquidityPool(ctx context.Context, lpID string) *OperationsQ + func (q *OperationsQ) ForTransaction(ctx context.Context, 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(ctx context.Context, dest interface{}, addy string) error + func (q *Q) AccountEntriesForSigner(ctx context.Context, signer string, page db2.PageQuery) ([]AccountEntry, error) + func (q *Q) AccountsByAddresses(ctx context.Context, dest interface{}, addresses []string) error + func (q *Q) AccountsForAsset(ctx context.Context, asset xdr.Asset, page db2.PageQuery) ([]AccountEntry, error) + func (q *Q) AccountsForLiquidityPool(ctx context.Context, poolID string, page db2.PageQuery) ([]AccountEntry, error) + func (q *Q) AccountsForSigner(ctx context.Context, signer string, page db2.PageQuery) ([]AccountSigner, error) + func (q *Q) AccountsForSponsor(ctx context.Context, sponsor string, page db2.PageQuery) ([]AccountEntry, error) + func (q *Q) ClaimableBalanceByID(ctx context.Context, id string) (dest HistoryClaimableBalance, err error) + func (q *Q) ClaimableBalancesByIDs(ctx context.Context, ids []string) (dest []HistoryClaimableBalance, err error) + func (q *Q) CloneIngestionQ() IngestionQ + func (q *Q) CompactLiquidityPools(ctx context.Context, cutOffSequence uint32) (int64, error) + func (q *Q) CompactOffers(ctx context.Context, cutOffSequence uint32) (int64, error) + func (q *Q) CountAccounts(ctx context.Context) (int, error) + func (q *Q) CountAccountsData(ctx context.Context) (int, error) + func (q *Q) CountClaimableBalances(ctx context.Context) (int, error) + func (q *Q) CountLiquidityPools(ctx context.Context) (int, error) + func (q *Q) CountOffers(ctx context.Context) (int, error) + func (q *Q) CountTrustLines(ctx context.Context) (int, error) + func (q *Q) CreateAccountSigner(ctx context.Context, account, signer string, weight int32, sponsor *string) (int64, error) + func (q *Q) CreateAccounts(ctx context.Context, addresses []string, batchSize int) (map[string]int64, error) + func (q *Q) CreateAssets(ctx context.Context, assets []xdr.Asset, batchSize int) (map[string]Asset, error) + func (q *Q) CreateHistoryClaimableBalances(ctx context.Context, ids []string, batchSize int) (map[string]int64, error) + func (q *Q) CreateHistoryLiquidityPools(ctx context.Context, poolIDs []string, batchSize int) (map[string]int64, error) + func (q *Q) DeleteRangeAll(ctx context.Context, start, end int64) error + func (q *Q) Effects() *EffectsQ + func (q *Q) ElderLedger(ctx context.Context, dest interface{}) error + func (q *Q) FeeStats(ctx context.Context, currentSeq int32, dest *FeeStats) error + func (q *Q) FindClaimableBalanceByID(ctx context.Context, balanceID string) (ClaimableBalance, error) + func (q *Q) FindLiquidityPoolByID(ctx context.Context, liquidityPoolID string) (LiquidityPool, error) + func (q *Q) GetAccountByID(ctx context.Context, id string) (AccountEntry, error) + func (q *Q) GetAccountDataByAccountID(ctx context.Context, id string) ([]Data, error) + func (q *Q) GetAccountDataByAccountsID(ctx context.Context, id []string) ([]Data, error) + func (q *Q) GetAccountDataByKeys(ctx context.Context, keys []AccountDataKey) ([]Data, error) + func (q *Q) GetAccountDataByName(ctx context.Context, id, name string) (Data, error) + func (q *Q) GetAccountSignersByAccountID(ctx context.Context, id string) ([]AccountSigner, error) + func (q *Q) GetAccountsByIDs(ctx context.Context, ids []string) ([]AccountEntry, error) + func (q *Q) GetAllLiquidityPools(ctx context.Context) ([]LiquidityPool, error) + func (q *Q) GetAllOffers(ctx context.Context) ([]Offer, error) + func (q *Q) GetAssetID(ctx context.Context, asset xdr.Asset) (id int64, err error) + func (q *Q) GetAssetStat(ctx context.Context, assetType xdr.AssetType, assetCode, assetIssuer string) (ExpAssetStat, error) + func (q *Q) GetAssetStats(ctx context.Context, assetCode, assetIssuer string, page db2.PageQuery) ([]ExpAssetStat, error) + func (q *Q) GetClaimableBalances(ctx context.Context, query ClaimableBalancesQuery) ([]ClaimableBalance, error) + func (q *Q) GetClaimableBalancesByID(ctx context.Context, ids []string) ([]ClaimableBalance, error) + func (q *Q) GetExpStateInvalid(ctx context.Context) (bool, error) + func (q *Q) GetIngestVersion(ctx context.Context) (int, error) + func (q *Q) GetLastLedgerIngest(ctx context.Context) (uint32, error) + func (q *Q) GetLastLedgerIngestNonBlocking(ctx context.Context) (uint32, error) + func (q *Q) GetLatestHistoryLedger(ctx context.Context) (uint32, error) + func (q *Q) GetLedgerGaps(ctx context.Context) ([]LedgerRange, error) + func (q *Q) GetLedgerGapsInRange(ctx context.Context, start, end uint32) ([]LedgerRange, error) + func (q *Q) GetLiquidityPoolCompactionSequence(ctx context.Context) (uint32, error) + func (q *Q) GetLiquidityPools(ctx context.Context, query LiquidityPoolsQuery) ([]LiquidityPool, error) + func (q *Q) GetLiquidityPoolsByID(ctx context.Context, poolIDs []string) ([]LiquidityPool, error) + func (q *Q) GetOfferByID(ctx context.Context, id int64) (Offer, error) + func (q *Q) GetOfferCompactionSequence(ctx context.Context) (uint32, error) + func (q *Q) GetOffers(ctx context.Context, query OffersQuery) ([]Offer, error) + func (q *Q) GetOffersByIDs(ctx context.Context, ids []int64) ([]Offer, error) + func (q *Q) GetOrderBookSummary(ctx context.Context, sellingAsset, buyingAsset xdr.Asset, maxPriceLevels int) (OrderBookSummary, error) + func (q *Q) GetSequenceNumbers(ctx context.Context, addresses []string) (map[string]uint64, error) + func (q *Q) GetSortedTrustLinesByAccountID(ctx context.Context, id string) ([]TrustLine, error) + func (q *Q) GetSortedTrustLinesByAccountIDs(ctx context.Context, id []string) ([]TrustLine, error) + func (q *Q) GetTrades(ctx context.Context, page db2.PageQuery, account string, tradeType string) ([]Trade, error) + func (q *Q) GetTradesForAssets(ctx context.Context, page db2.PageQuery, account, tradeType string, ...) ([]Trade, error) + func (q *Q) GetTradesForLiquidityPool(ctx context.Context, page db2.PageQuery, poolID string) ([]Trade, error) + func (q *Q) GetTradesForOffer(ctx context.Context, page db2.PageQuery, offerID int64) ([]Trade, error) + func (q *Q) GetTrustLinesByKeys(ctx context.Context, ledgerKeys []string) ([]TrustLine, error) + func (q *Q) GetUpdatedLiquidityPools(ctx context.Context, newerThanSequence uint32) ([]LiquidityPool, error) + func (q *Q) GetUpdatedOffers(ctx context.Context, newerThanSequence uint32) ([]Offer, error) + func (q *Q) InsertAssetStat(ctx context.Context, assetStat ExpAssetStat) (int64, error) + func (q *Q) InsertAssetStats(ctx context.Context, assetStats []ExpAssetStat, batchSize int) error + func (q *Q) InsertLedger(ctx context.Context, ledger xdr.LedgerHeaderHistoryEntry, successTxsCount int, ...) (int64, error) + func (q *Q) LatestLedger(ctx context.Context, dest interface{}) error + func (q *Q) LatestLedgerBaseFeeAndSequence(ctx context.Context, dest interface{}) error + func (q *Q) LatestLedgerSequenceClosedAt(ctx context.Context) (int32, time.Time, error) + func (q *Q) LedgerBySequence(ctx context.Context, dest interface{}, seq int32) error + func (q *Q) LedgerCapacityUsageStats(ctx context.Context, currentSeq int32, dest *LedgerCapacityUsageStats) error + func (q *Q) Ledgers() *LedgersQ + func (q *Q) LedgersBySequence(ctx context.Context, dest interface{}, seqs ...int32) error + func (q *Q) LiquidityPoolByID(ctx context.Context, poolID string) (dest HistoryLiquidityPool, err error) + func (q *Q) LiquidityPoolsByIDs(ctx context.Context, poolIDs []string) (dest []HistoryLiquidityPool, err error) + func (q *Q) NewAccountSignersBatchInsertBuilder(maxBatchSize int) AccountSignersBatchInsertBuilder + func (q *Q) NewEffectBatchInsertBuilder(maxBatchSize int) EffectBatchInsertBuilder + func (q *Q) NewOperationBatchInsertBuilder(maxBatchSize int) OperationBatchInsertBuilder + func (q *Q) NewOperationClaimableBalanceBatchInsertBuilder(maxBatchSize int) OperationClaimableBalanceBatchInsertBuilder + func (q *Q) NewOperationLiquidityPoolBatchInsertBuilder(maxBatchSize int) OperationLiquidityPoolBatchInsertBuilder + func (q *Q) NewOperationParticipantBatchInsertBuilder(maxBatchSize int) OperationParticipantBatchInsertBuilder + func (q *Q) NewTradeBatchInsertBuilder(maxBatchSize int) TradeBatchInsertBuilder + func (q *Q) NewTransactionBatchInsertBuilder(maxBatchSize int) TransactionBatchInsertBuilder + func (q *Q) NewTransactionClaimableBalanceBatchInsertBuilder(maxBatchSize int) TransactionClaimableBalanceBatchInsertBuilder + func (q *Q) NewTransactionLiquidityPoolBatchInsertBuilder(maxBatchSize int) TransactionLiquidityPoolBatchInsertBuilder + func (q *Q) NewTransactionParticipantsBatchInsertBuilder(maxBatchSize int) TransactionParticipantsBatchInsertBuilder + func (q *Q) OperationByID(ctx context.Context, includeTransactions bool, id int64) (Operation, *Transaction, error) + func (q *Q) Operations() *OperationsQ + func (q *Q) RemoveAccountData(ctx context.Context, keys []AccountDataKey) (int64, error) + func (q *Q) RemoveAccountSigner(ctx context.Context, account, signer string) (int64, error) + func (q *Q) RemoveAccounts(ctx context.Context, accountIDs []string) (int64, error) + func (q *Q) RemoveAssetStat(ctx context.Context, assetType xdr.AssetType, assetCode, assetIssuer string) (int64, error) + func (q *Q) RemoveClaimableBalances(ctx context.Context, ids []string) (int64, error) + func (q *Q) RemoveTrustLines(ctx context.Context, ledgerKeys []string) (int64, error) + func (q *Q) SignersForAccounts(ctx context.Context, accounts []string) ([]AccountSigner, error) + func (q *Q) TransactionByHash(ctx context.Context, dest interface{}, hash string) error + func (q *Q) Transactions() *TransactionsQ + func (q *Q) TransactionsByHashesSinceLedger(ctx context.Context, hashes []string, sinceLedgerSeq uint32) ([]Transaction, error) + func (q *Q) TransactionsByIDs(ctx context.Context, ids ...int64) (map[int64]Transaction, error) + func (q *Q) TruncateIngestStateTables(ctx context.Context) error + func (q *Q) UpdateAssetStat(ctx context.Context, assetStat ExpAssetStat) (int64, error) + func (q *Q) UpdateExpStateInvalid(ctx context.Context, val bool) error + func (q *Q) UpdateIngestVersion(ctx context.Context, version int) error + func (q *Q) UpdateLastLedgerIngest(ctx context.Context, ledgerSequence uint32) error + func (q *Q) UpdateLiquidityPoolCompactionSequence(ctx context.Context, sequence uint32) error + func (q *Q) UpdateOfferCompactionSequence(ctx context.Context, sequence uint32) error + func (q *Q) UpsertAccountData(ctx context.Context, data []Data) error + func (q *Q) UpsertAccounts(ctx context.Context, accounts []AccountEntry) error + func (q *Q) UpsertClaimableBalances(ctx context.Context, cbs []ClaimableBalance) error + func (q *Q) UpsertLiquidityPools(ctx context.Context, lps []LiquidityPool) error + func (q *Q) UpsertOffers(ctx context.Context, offers []Offer) error + func (q *Q) UpsertTrustLines(ctx context.Context, trustLines []TrustLine) error + func (q Q) GetTradeAggregationsQ(baseAssetID int64, counterAssetID int64, resolution int64, offset int64, ...) (*TradeAggregationsQ, error) + func (q Q) RebuildTradeAggregationBuckets(ctx context.Context, fromSeq, toSeq uint32) error + func (q Q) RebuildTradeAggregationTimes(ctx context.Context, from, to strtime.Millis) error + type QAccounts interface + GetAccountsByIDs func(ctx context.Context, ids []string) ([]AccountEntry, error) + RemoveAccounts func(ctx context.Context, accountIDs []string) (int64, error) + UpsertAccounts func(ctx context.Context, accounts []AccountEntry) error + type QAssetStats interface + CountTrustLines func(ctx context.Context) (int, error) + GetAssetStat func(ctx context.Context, assetType xdr.AssetType, assetCode, assetIssuer string) (ExpAssetStat, error) + GetAssetStats func(ctx context.Context, assetCode, assetIssuer string, page db2.PageQuery) ([]ExpAssetStat, error) + InsertAssetStat func(ctx context.Context, stat ExpAssetStat) (int64, error) + InsertAssetStats func(ctx context.Context, stats []ExpAssetStat, batchSize int) error + RemoveAssetStat func(ctx context.Context, assetType xdr.AssetType, assetCode, assetIssuer string) (int64, error) + UpdateAssetStat func(ctx context.Context, stat ExpAssetStat) (int64, error) + type QClaimableBalances interface + CountClaimableBalances func(ctx context.Context) (int, error) + GetClaimableBalancesByID func(ctx context.Context, ids []string) ([]ClaimableBalance, error) + RemoveClaimableBalances func(ctx context.Context, ids []string) (int64, error) + UpsertClaimableBalances func(ctx context.Context, cb []ClaimableBalance) error + type QCreateAccountsHistory interface + CreateAccounts func(ctx context.Context, addresses []string, maxBatchSize int) (map[string]int64, error) + type QData interface + CountAccountsData func(ctx context.Context) (int, error) + GetAccountDataByKeys func(ctx context.Context, keys []AccountDataKey) ([]Data, error) + RemoveAccountData func(ctx context.Context, keys []AccountDataKey) (int64, error) + UpsertAccountData func(ctx context.Context, data []Data) error + type QEffects interface + NewEffectBatchInsertBuilder func(maxBatchSize int) EffectBatchInsertBuilder + type QHistoryClaimableBalances interface + CreateHistoryClaimableBalances func(ctx context.Context, ids []string, batchSize int) (map[string]int64, error) + NewOperationClaimableBalanceBatchInsertBuilder func(maxBatchSize int) OperationClaimableBalanceBatchInsertBuilder + NewTransactionClaimableBalanceBatchInsertBuilder func(maxBatchSize int) TransactionClaimableBalanceBatchInsertBuilder + type QHistoryLiquidityPools interface + CreateHistoryLiquidityPools func(ctx context.Context, poolIDs []string, batchSize int) (map[string]int64, error) + NewOperationLiquidityPoolBatchInsertBuilder func(maxBatchSize int) OperationLiquidityPoolBatchInsertBuilder + NewTransactionLiquidityPoolBatchInsertBuilder func(maxBatchSize int) TransactionLiquidityPoolBatchInsertBuilder + type QLedgers interface + InsertLedger func(ctx context.Context, ledger xdr.LedgerHeaderHistoryEntry, successTxsCount int, ...) (int64, error) + type QLiquidityPools interface + CompactLiquidityPools func(ctx context.Context, cutOffSequence uint32) (int64, error) + CountLiquidityPools func(ctx context.Context) (int, error) + FindLiquidityPoolByID func(ctx context.Context, liquidityPoolID string) (LiquidityPool, error) + GetAllLiquidityPools func(ctx context.Context) ([]LiquidityPool, error) + GetLiquidityPoolsByID func(ctx context.Context, poolIDs []string) ([]LiquidityPool, error) + GetUpdatedLiquidityPools func(ctx context.Context, newerThanSequence uint32) ([]LiquidityPool, error) + UpsertLiquidityPools func(ctx context.Context, lps []LiquidityPool) error + type QOffers interface + CompactOffers func(ctx context.Context, cutOffSequence uint32) (int64, error) + CountOffers func(ctx context.Context) (int, error) + GetAllOffers func(ctx context.Context) ([]Offer, error) + GetOffersByIDs func(ctx context.Context, ids []int64) ([]Offer, error) + GetUpdatedOffers func(ctx context.Context, newerThanSequence uint32) ([]Offer, error) + UpsertOffers func(ctx context.Context, offers []Offer) 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(ctx context.Context, signer string, page db2.PageQuery) ([]AccountSigner, error) + CountAccounts func(ctx context.Context) (int, error) + CreateAccountSigner func(ctx context.Context, account, signer string, weight int32, sponsor *string) (int64, error) + GetLastLedgerIngest func(ctx context.Context) (uint32, error) + GetLastLedgerIngestNonBlocking func(ctx context.Context) (uint32, error) + NewAccountSignersBatchInsertBuilder func(maxBatchSize int) AccountSignersBatchInsertBuilder + RemoveAccountSigner func(ctx context.Context, account, signer string) (int64, error) + SignersForAccounts func(ctx context.Context, accounts []string) ([]AccountSigner, error) + UpdateLastLedgerIngest func(ctx context.Context, ledgerSequence uint32) error + type QTrades interface + CreateAssets func(ctx context.Context, assets []xdr.Asset, maxBatchSize int) (map[string]Asset, error) + CreateHistoryLiquidityPools func(ctx context.Context, poolIDs []string, batchSize int) (map[string]int64, error) + NewTradeBatchInsertBuilder func(maxBatchSize int) TradeBatchInsertBuilder + RebuildTradeAggregationBuckets func(ctx context.Context, fromledger, toLedger uint32) error + type QTransactions interface + NewTransactionBatchInsertBuilder func(maxBatchSize int) TransactionBatchInsertBuilder + type QTrustLines interface + GetTrustLinesByKeys func(ctx context.Context, ledgerKeys []string) ([]TrustLine, error) + RemoveTrustLines func(ctx context.Context, ledgerKeys []string) (int64, error) + UpsertTrustLines func(ctx context.Context, trustlines []TrustLine) 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 null.String + BaseAmount int64 + BaseAssetCode string + BaseAssetIssuer string + BaseAssetType string + BaseIsSeller bool + BaseLiquidityPoolID null.String + BaseOfferID null.Int + CounterAccount null.String + CounterAmount int64 + CounterAssetCode string + CounterAssetIssuer string + CounterAssetType string + CounterLiquidityPoolID null.String + CounterOfferID null.Int + HistoryOperationID int64 + LedgerCloseTime time.Time + LiquidityPoolFee null.Int + Order int32 + PriceD null.Int + PriceN null.Int + Type TradeType + func FilterTradesByType(trades []Trade, tradeType string) []Trade + func (r *Trade) HasPrice() bool + func (r *Trade) PagingToken() string + type TradeAggregation struct + Average float64 + BaseVolume string + CloseD int64 + CloseN int64 + CounterVolume string + HighD int64 + HighN int64 + LowD int64 + LowN int64 + OpenD int64 + OpenN int64 + 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(ctx context.Context, entries ...InsertTrade) error + Exec func(ctx context.Context) error + type TradeEffectDetails struct + BoughtAmount string + BoughtAssetCode string + BoughtAssetIssuer string + BoughtAssetType string + OfferID int64 + Seller string + SellerMuxed string + SellerMuxedID uint64 + SoldAmount string + SoldAssetCode string + SoldAssetIssuer string + SoldAssetType string + type TradeFixtures struct + Addresses []string + Assets []xdr.Asset + LiquidityPools []string + Trades []Trade + TradesByAccount map[string][]Trade + TradesByAsset map[string][]Trade + TradesByOffer map[int64][]Trade + TradesByPool map[string][]Trade + func TradeScenario(tt *test.T, q *Q) TradeFixtures + func (f TradeFixtures) TradesByAssetPair(a, b xdr.Asset) []Trade + type TradeType int16 + type Transaction struct + LedgerCloseTime time.Time + type TransactionBatchInsertBuilder interface + Add func(ctx context.Context, transaction ingest.LedgerTransaction, sequence uint32) error + Exec func(ctx context.Context) error + type TransactionClaimableBalanceBatchInsertBuilder interface + Add func(ctx context.Context, transactionID, internalID int64) error + Exec func(ctx context.Context) error + type TransactionLiquidityPoolBatchInsertBuilder interface + Add func(ctx context.Context, transactionID, internalID int64) error + Exec func(ctx context.Context) error + type TransactionParticipantsBatchInsertBuilder interface + Add func(ctx context.Context, transactionID, accountID int64) error + Exec func(ctx context.Context) error + type TransactionWithoutLedger struct + Account string + AccountMuxed null.String + AccountSequence string + ApplicationOrder int32 + CreatedAt time.Time + FeeAccount null.String + FeeAccountMuxed 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(ctx context.Context, aid string) *TransactionsQ + func (q *TransactionsQ) ForClaimableBalance(ctx context.Context, cbID string) *TransactionsQ + func (q *TransactionsQ) ForLedger(ctx context.Context, seq int32) *TransactionsQ + func (q *TransactionsQ) ForLiquidityPool(ctx context.Context, poolID string) *TransactionsQ + func (q *TransactionsQ) IncludeFailed() *TransactionsQ + func (q *TransactionsQ) Page(page db2.PageQuery) *TransactionsQ + func (q *TransactionsQ) Select(ctx context.Context, dest interface{}) error + type TrustLine struct + AccountID string + AssetCode string + AssetIssuer string + AssetType xdr.AssetType + Balance int64 + BuyingLiabilities int64 + Flags uint32 + LastModifiedLedger uint32 + LedgerKey string + Limit int64 + LiquidityPoolID string + SellingLiabilities int64 + Sponsor null.String + func MakeTestTrustline(account string, asset xdr.Asset, poolId string) TrustLine + func (trustLine TrustLine) IsAuthorized() bool + func (trustLine TrustLine) IsAuthorizedToMaintainLiabilities() bool + func (trustLine TrustLine) IsClawbackEnabled() bool