history

package

Go to main page

Versions in this module

v1

v1.11.1

Jun 10, 2024

Changes in this version

+ const AllTrades

+ const HistoryTradesTableName

+ const LiquidityPoolTradeType

+ const LiquidityPoolTrades

+ const OrderbookTradeType

+ const OrderbookTrades

+ type AccountDataBatchInsertBuilder interface

+ Add func(data Data) error

+ Exec func(ctx context.Context) error

+ Len func() int

+ 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

+ SequenceLedger zero.Int

+ SequenceNumber int64

+ SequenceTime zero.Int

+ 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 AccountFilterConfig struct

+ Enabled bool

+ LastModified int64

+ Whitelist pq.StringArray

+ type AccountLoader struct

+ func NewAccountLoader() *AccountLoader

+ func (a *AccountLoader) Exec(ctx context.Context, session db.SessionInterface) error

+ func (a *AccountLoader) GetFuture(address string) FutureAccountID

+ func (a *AccountLoader) GetNow(address string) (int64, error)

+ func (a *AccountLoader) Name() string

+ func (a *AccountLoader) Stats() LoaderStats

+ type AccountLoaderStub struct

+ Loader *AccountLoader

+ func NewAccountLoaderStub() AccountLoaderStub

+ func (a AccountLoaderStub) Insert(address string, id int64)

type AccountSigner

+ Sponsor null.String

+ type AccountSignersBatchInsertBuilder interface

+ Add func(signer AccountSigner) error

+ Exec func(ctx context.Context) error

+ Len func() int

+ type AccountsBatchInsertBuilder interface

+ Add func(account AccountEntry) error

+ Exec func(ctx context.Context) error

+ Len func() int

+ type AssetAndContractStat struct

+ Contracts ContractStat

+ type AssetFilterConfig struct

+ Enabled bool

+ LastModified int64

+ Whitelist pq.StringArray

+ type AssetKey struct

+ Code string

+ Issuer string

+ Type string

+ func AssetKeyFromXDR(asset xdr.Asset) AssetKey

+ func (key AssetKey) String() string

+ type AssetLoader struct

+ func NewAssetLoader() *AssetLoader

+ func (a *AssetLoader) Exec(ctx context.Context, session db.SessionInterface) error

+ func (a *AssetLoader) GetFuture(asset AssetKey) FutureAssetID

+ func (a *AssetLoader) GetNow(asset AssetKey) (int64, error)

+ func (a *AssetLoader) Name() string

+ func (a *AssetLoader) Stats() LoaderStats

+ type AssetLoaderStub struct

+ Loader *AssetLoader

+ func NewAssetLoaderStub() AssetLoaderStub

+ func (a AssetLoaderStub) Insert(asset AssetKey, id int64)

+ type ClaimableBalance struct

+ Amount xdr.Int64

+ Asset xdr.Asset

+ BalanceID string

+ Claimants Claimants

+ Flags uint32

+ LastModifiedLedger uint32

+ Sponsor null.String

+ type ClaimableBalanceBatchInsertBuilder interface

+ Add func(claimableBalance ClaimableBalance) error

+ Exec func(ctx context.Context) error

+ Len func() int

+ type ClaimableBalanceClaimant struct

+ BalanceID string

+ Destination string

+ LastModifiedLedger uint32

+ type ClaimableBalanceClaimantBatchInsertBuilder interface

+ Add func(claimableBalanceClaimant ClaimableBalanceClaimant) error

+ Exec func(ctx context.Context) error

+ Len func() int

+ type ClaimableBalanceLoader struct

+ func NewClaimableBalanceLoader() *ClaimableBalanceLoader

+ func (a *ClaimableBalanceLoader) Exec(ctx context.Context, session db.SessionInterface) error

+ func (a *ClaimableBalanceLoader) GetFuture(id string) FutureClaimableBalanceID

+ func (a *ClaimableBalanceLoader) Name() string

+ func (a *ClaimableBalanceLoader) Stats() LoaderStats

+ type ClaimableBalancesQuery struct

+ Asset *xdr.Asset

+ Claimant *xdr.AccountId

+ PageQuery db2.PageQuery

+ Sponsor *xdr.AccountId

+ 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 ContractAssetBalance struct

+ Amount string

+ ContractID []byte

+ ExpirationLedger uint32

+ KeyHash []byte

+ type ContractAssetStatRow struct

+ ContractID []byte

+ Stat ContractStat

+ type ContractStat struct

+ ActiveBalance string

+ ActiveHolders int32

+ ArchivedBalance string

+ ArchivedHolders int32

+ func (c *ContractStat) Scan(src interface{}) error

+ func (c ContractStat) Value() (driver.Value, error)

+ type Data struct

+ AccountID string

+ LastModifiedLedger uint32

+ Name string

+ Sponsor null.String

+ Value AccountDataValue

type Effect

+ AccountMuxed null.String

+ type EffectBatchInsertBuilder interface

+ Add func(accountID FutureAccountID, muxedAccount null.String, operationID int64, ...) error

+ Exec func(ctx context.Context, session db.SessionInterface) error

type EffectType

+ const EffectAccountSponsorshipCreated

+ const EffectAccountSponsorshipRemoved

+ const EffectAccountSponsorshipUpdated

+ const EffectClaimableBalanceClaimantCreated

+ const EffectClaimableBalanceClaimed

+ const EffectClaimableBalanceClawedBack

+ const EffectClaimableBalanceCreated

+ const EffectClaimableBalanceSponsorshipCreated

+ const EffectClaimableBalanceSponsorshipRemoved

+ const EffectClaimableBalanceSponsorshipUpdated

+ const EffectContractCredited

+ const EffectContractDebited

+ const EffectDataSponsorshipCreated

+ const EffectDataSponsorshipRemoved

+ const EffectDataSponsorshipUpdated

+ const EffectLiquidityPoolCreated

+ const EffectLiquidityPoolDeposited

+ const EffectLiquidityPoolRemoved

+ const EffectLiquidityPoolRevoked

+ const EffectLiquidityPoolTrade

+ const EffectLiquidityPoolWithdrew

+ const EffectSignerSponsorshipCreated

+ const EffectSignerSponsorshipRemoved

+ const EffectSignerSponsorshipUpdated

+ const EffectTrustlineAuthorizedToMaintainLiabilities

+ const EffectTrustlineFlagsUpdated

+ const EffectTrustlineSponsorshipCreated

+ const EffectTrustlineSponsorshipRemoved

+ const EffectTrustlineSponsorshipUpdated

+ type ExpAssetStat struct

+ Accounts ExpAssetStatAccounts

+ Amount string

+ AssetCode string

+ AssetIssuer string

+ AssetType xdr.AssetType

+ Balances ExpAssetStatBalances

+ ContractID *[]byte

+ NumAccounts int32

+ func (e *ExpAssetStat) Equals(o ExpAssetStat) bool

+ func (e *ExpAssetStat) GetContractID() ([32]byte, bool)

+ func (e *ExpAssetStat) SetContractID(contractID [32]byte)

+ 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) IsZero() bool

+ 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

+ 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 FutureAccountID struct

+ func (a FutureAccountID) Value() (driver.Value, error)

+ type FutureAssetID struct

+ func (a FutureAssetID) Value() (driver.Value, error)

+ type FutureClaimableBalanceID struct

+ func (a FutureClaimableBalanceID) Value() (driver.Value, error)

+ type FutureLiquidityPoolID struct

+ func (a FutureLiquidityPoolID) Value() (driver.Value, error)

+ type HistoryClaimableBalance struct

+ BalanceID string

+ InternalID int64

+ type HistoryLiquidityPool struct

+ InternalID int64

+ PoolID string

+ type IngestionQ interface

+ Begin func(context.Context) error

+ BeginTx func(context.Context, *sql.TxOptions) error

+ CloneIngestionQ func() IngestionQ

+ Close func() error

+ 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

+ DeleteTransactionsFilteredTmpOlderThan func(ctx context.Context, howOldInSeconds uint64) (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() OperationParticipantBatchInsertBuilder

+ NewTradeBatchInsertBuilder func() TradeBatchInsertBuilder

+ NewTransactionParticipantsBatchInsertBuilder func() TransactionParticipantsBatchInsertBuilder

+ ReapLookupTables func(ctx context.Context, offsets map[string]int64) (map[string]int64, map[string]int64, error)

+ RebuildTradeAggregationBuckets func(ctx context.Context, fromLedger, toLedger uint32, roundingSlippageFilter int) error

+ RebuildTradeAggregationTimes func(ctx context.Context, from, to strtime.Millis, roundingSlippageFilter int) error

+ Rollback func() error

+ TruncateIngestStateTables func(context.Context) error

+ TryStateVerificationLock func(ctx context.Context) (bool, error)

+ UpdateExpStateInvalid func(context.Context, bool) error

+ UpdateIngestVersion func(context.Context, int) error

+ type InsertTrade struct

+ BaseAccountID null.Int

+ BaseAmount int64

+ BaseAssetID int64

+ BaseIsExact null.Bool

+ 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

+ RoundingSlippage null.Int

+ Type TradeType

type Ledger

+ TxSetOperationCount *int32

+ type LedgerBatchInsertBuilder interface

+ Add func(ledger xdr.LedgerHeaderHistoryEntry, successTxsCount int, failedTxsCount int, ...) error

+ Exec func(ctx context.Context, session db.SessionInterface) error

+ type LedgerBounds struct

+ MaxLedger null.Int

+ MinLedger null.Int

+ Null bool

+ func (t *LedgerBounds) Scan(src interface{}) error

+ func (t LedgerBounds) Value() (driver.Value, error)

+ type LedgerRange struct

+ EndSequence uint32

+ StartSequence uint32

+ 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 LiquidityPoolLoader struct

+ func NewLiquidityPoolLoader() *LiquidityPoolLoader

+ func (a *LiquidityPoolLoader) Exec(ctx context.Context, session db.SessionInterface) error

+ func (a *LiquidityPoolLoader) GetFuture(id string) FutureLiquidityPoolID

+ func (a *LiquidityPoolLoader) GetNow(id string) (int64, error)

+ func (a *LiquidityPoolLoader) Name() string

+ func (a *LiquidityPoolLoader) Stats() LoaderStats

+ type LiquidityPoolLoaderStub struct

+ Loader *LiquidityPoolLoader

+ func NewLiquidityPoolLoaderStub() LiquidityPoolLoaderStub

+ func (a LiquidityPoolLoaderStub) Insert(lp string, id int64)

+ type LiquidityPoolsQuery struct

+ Account string

+ Assets []xdr.Asset

+ PageQuery db2.PageQuery

+ type LoaderStats struct

+ Inserted int

+ Total int

+ type ManageOffer struct

+ OfferID int64

+ type MockAccountDataBatchInsertBuilder struct

+ func (m *MockAccountDataBatchInsertBuilder) Add(data Data) error

+ func (m *MockAccountDataBatchInsertBuilder) Exec(ctx context.Context) error

+ func (m *MockAccountDataBatchInsertBuilder) Len() int

+ type MockAccountSignersBatchInsertBuilder struct

+ func (m *MockAccountSignersBatchInsertBuilder) Add(signer AccountSigner) error

+ func (m *MockAccountSignersBatchInsertBuilder) Exec(ctx context.Context) error

+ func (m *MockAccountSignersBatchInsertBuilder) Len() int

+ type MockAccountsBatchInsertBuilder struct

+ func (m *MockAccountsBatchInsertBuilder) Add(account AccountEntry) error

+ func (m *MockAccountsBatchInsertBuilder) Exec(ctx context.Context) error

+ func (m *MockAccountsBatchInsertBuilder) Len() int

+ type MockClaimableBalanceBatchInsertBuilder struct

+ func (m *MockClaimableBalanceBatchInsertBuilder) Add(claimableBalance ClaimableBalance) error

+ func (m *MockClaimableBalanceBatchInsertBuilder) Exec(ctx context.Context) error

+ func (m *MockClaimableBalanceBatchInsertBuilder) Len() int

+ type MockClaimableBalanceClaimantBatchInsertBuilder struct

+ func (m *MockClaimableBalanceClaimantBatchInsertBuilder) Add(claimableBalanceClaimant ClaimableBalanceClaimant) error

+ func (m *MockClaimableBalanceClaimantBatchInsertBuilder) Exec(ctx context.Context) error

+ func (m *MockClaimableBalanceClaimantBatchInsertBuilder) Len() int

+ type MockEffectBatchInsertBuilder struct

+ func (m *MockEffectBatchInsertBuilder) Add(accountID FutureAccountID, muxedAccount null.String, operationID int64, ...) error

+ func (m *MockEffectBatchInsertBuilder) Exec(ctx context.Context, session db.SessionInterface) error

+ type MockLedgersBatchInsertBuilder struct

+ func (m *MockLedgersBatchInsertBuilder) Add(ledger xdr.LedgerHeaderHistoryEntry, successTxsCount int, failedTxsCount int, ...) error

+ func (m *MockLedgersBatchInsertBuilder) Exec(ctx context.Context, session db.SessionInterface) error

+ type MockOffersBatchInsertBuilder struct

+ func (m *MockOffersBatchInsertBuilder) Add(offer Offer) error

+ func (m *MockOffersBatchInsertBuilder) Exec(ctx context.Context) error

+ func (m *MockOffersBatchInsertBuilder) Len() int

+ type MockOperationClaimableBalanceBatchInsertBuilder struct

+ func (m *MockOperationClaimableBalanceBatchInsertBuilder) Add(operationID int64, claimableBalance FutureClaimableBalanceID) error

+ func (m *MockOperationClaimableBalanceBatchInsertBuilder) Exec(ctx context.Context, session db.SessionInterface) error

+ type MockOperationLiquidityPoolBatchInsertBuilder struct

+ func (m *MockOperationLiquidityPoolBatchInsertBuilder) Add(operationID int64, lp FutureLiquidityPoolID) error

+ func (m *MockOperationLiquidityPoolBatchInsertBuilder) Exec(ctx context.Context, session db.SessionInterface) error

+ type MockOperationParticipantBatchInsertBuilder struct

+ func (m *MockOperationParticipantBatchInsertBuilder) Add(operationID int64, account FutureAccountID) error

+ func (m *MockOperationParticipantBatchInsertBuilder) Exec(ctx context.Context, session db.SessionInterface) error

+ type MockOperationsBatchInsertBuilder struct

+ func (m *MockOperationsBatchInsertBuilder) Add(id int64, transactionID int64, applicationOrder uint32, ...) error

+ func (m *MockOperationsBatchInsertBuilder) Exec(ctx context.Context, session db.SessionInterface) error

+ type MockQAccounts struct

+ func (m *MockQAccounts) GetAccountsByIDs(ctx context.Context, ids []string) ([]AccountEntry, error)

+ func (m *MockQAccounts) NewAccountsBatchInsertBuilder() AccountsBatchInsertBuilder

+ 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) CountContractIDs(ctx context.Context) (int, error)

+ 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) GetAssetStatByContract(ctx context.Context, contractID xdr.Hash) (ExpAssetStat, error)

+ func (m *MockQAssetStats) GetAssetStatByContracts(ctx context.Context, contractIDs []xdr.Hash) ([]ExpAssetStat, error)

+ func (m *MockQAssetStats) GetAssetStats(ctx context.Context, assetCode, assetIssuer string, page db2.PageQuery) ([]AssetAndContractStat, error)

+ func (m *MockQAssetStats) GetContractAssetBalances(ctx context.Context, keys []xdr.Hash) ([]ContractAssetBalance, error)

+ func (m *MockQAssetStats) GetContractAssetBalancesExpiringAt(ctx context.Context, ledger uint32) ([]ContractAssetBalance, error)

+ func (m *MockQAssetStats) GetContractAssetStat(ctx context.Context, contractID []byte) (ContractAssetStatRow, error)

+ func (m *MockQAssetStats) InsertAssetStat(ctx context.Context, assetStat ExpAssetStat) (int64, error)

+ func (m *MockQAssetStats) InsertAssetStats(ctx context.Context, assetStats []ExpAssetStat) error

+ func (m *MockQAssetStats) InsertContractAssetBalances(ctx context.Context, rows []ContractAssetBalance) error

+ func (m *MockQAssetStats) InsertContractAssetStat(ctx context.Context, row ContractAssetStatRow) (int64, error)

+ func (m *MockQAssetStats) InsertContractAssetStats(ctx context.Context, rows []ContractAssetStatRow) error

+ func (m *MockQAssetStats) RemoveAssetContractStat(ctx context.Context, contractID []byte) (int64, error)

+ func (m *MockQAssetStats) RemoveAssetStat(ctx context.Context, assetType xdr.AssetType, assetCode, assetIssuer string) (int64, error)

+ func (m *MockQAssetStats) RemoveContractAssetBalances(ctx context.Context, keys []xdr.Hash) error

+ func (m *MockQAssetStats) UpdateAssetStat(ctx context.Context, assetStat ExpAssetStat) (int64, error)

+ func (m *MockQAssetStats) UpdateContractAssetBalanceAmounts(ctx context.Context, keys []xdr.Hash, amounts []string) error

+ func (m *MockQAssetStats) UpdateContractAssetBalanceExpirations(ctx context.Context, keys []xdr.Hash, expirationLedgers []uint32) error

+ func (m *MockQAssetStats) UpdateContractAssetStat(ctx context.Context, row ContractAssetStatRow) (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) GetClaimantsByClaimableBalances(ctx context.Context, ids []string) (map[string][]ClaimableBalanceClaimant, error)

+ func (m *MockQClaimableBalances) NewClaimableBalanceBatchInsertBuilder() ClaimableBalanceBatchInsertBuilder

+ func (m *MockQClaimableBalances) NewClaimableBalanceClaimantBatchInsertBuilder() ClaimableBalanceClaimantBatchInsertBuilder

+ func (m *MockQClaimableBalances) RemoveClaimableBalanceClaimants(ctx context.Context, ids []string) (int64, 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) NewAccountDataBatchInsertBuilder() AccountDataBatchInsertBuilder

+ 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() EffectBatchInsertBuilder

+ type MockQFilter struct

+ func (m *MockQFilter) GetAccountFilterConfig(ctx context.Context) (AccountFilterConfig, error)

+ func (m *MockQFilter) GetAssetFilterConfig(ctx context.Context) (AssetFilterConfig, error)

+ func (m *MockQFilter) UpdateAccountFilterConfig(ctx context.Context, config AccountFilterConfig) (AccountFilterConfig, error)

+ func (m *MockQFilter) UpdateAssetFilterConfig(ctx context.Context, config AssetFilterConfig) (AssetFilterConfig, error)

+ type MockQHistoryClaimableBalances struct

+ func (m *MockQHistoryClaimableBalances) CreateHistoryClaimableBalances(ctx context.Context, ids []string, maxBatchSize int) (map[string]int64, error)

+ func (m *MockQHistoryClaimableBalances) NewOperationClaimableBalanceBatchInsertBuilder() OperationClaimableBalanceBatchInsertBuilder

+ func (m *MockQHistoryClaimableBalances) NewTransactionClaimableBalanceBatchInsertBuilder() TransactionClaimableBalanceBatchInsertBuilder

+ type MockQHistoryLiquidityPools struct

+ func (m *MockQHistoryLiquidityPools) CreateHistoryLiquidityPools(ctx context.Context, poolIDs []string, maxBatchSize int) (map[string]int64, error)

+ func (m *MockQHistoryLiquidityPools) NewOperationLiquidityPoolBatchInsertBuilder() OperationLiquidityPoolBatchInsertBuilder

+ func (m *MockQHistoryLiquidityPools) NewTransactionLiquidityPoolBatchInsertBuilder() TransactionLiquidityPoolBatchInsertBuilder

+ type MockQLedgers struct

+ func (m *MockQLedgers) NewLedgerBatchInsertBuilder() LedgerBatchInsertBuilder

+ 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) GetLiquidityPoolsByID(ctx context.Context, poolIDs []string) ([]LiquidityPool, error)

+ func (m *MockQLiquidityPools) GetUpdatedLiquidityPools(ctx context.Context, sequence uint32) ([]LiquidityPool, error)

+ func (m *MockQLiquidityPools) StreamAllLiquidityPools(ctx context.Context, callback func(LiquidityPool) error) error

+ func (m *MockQLiquidityPools) UpsertLiquidityPools(ctx context.Context, lps []LiquidityPool) error

type MockQOffers

+ func (m *MockQOffers) CompactOffers(ctx context.Context, cutOffSequence uint32) (int64, error)

+ func (m *MockQOffers) CountOffers(ctx context.Context) (int, 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) NewOffersBatchInsertBuilder() OffersBatchInsertBuilder

+ func (m *MockQOffers) StreamAllOffers(ctx context.Context, callback func(Offer) error) error

+ func (m *MockQOffers) UpsertOffers(ctx context.Context, rows []Offer) error

+ type MockQOperations struct

+ func (m *MockQOperations) NewOperationBatchInsertBuilder() OperationBatchInsertBuilder

+ type MockQParticipants struct

+ func (m *MockQParticipants) CreateAccounts(ctx context.Context, addresses []string, maxBatchSize int) (map[string]int64, error)

+ func (m *MockQParticipants) NewOperationParticipantBatchInsertBuilder() OperationParticipantBatchInsertBuilder

+ func (m *MockQParticipants) NewTransactionParticipantsBatchInsertBuilder() TransactionParticipantsBatchInsertBuilder

type MockQSigners

+ func (m *MockQSigners) CountAccounts(ctx context.Context) (int, error)

+ func (m *MockQSigners) GetLastLedgerIngest(ctx context.Context) (uint32, error)

+ func (m *MockQSigners) GetLastLedgerIngestNonBlocking(ctx context.Context) (uint32, error)

+ func (m *MockQSigners) NewAccountSignersBatchInsertBuilder() AccountSignersBatchInsertBuilder

+ func (m *MockQSigners) RemoveAccountSigners(ctx context.Context, account string, signers []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() TradeBatchInsertBuilder

+ func (m *MockQTrades) RebuildTradeAggregationBuckets(ctx context.Context, fromLedger, toLedger uint32, roundingSlippageFilter int) error

+ type MockQTransactions struct

+ func (m *MockQTransactions) NewTransactionBatchInsertBuilder() TransactionBatchInsertBuilder

+ func (m *MockQTransactions) NewTransactionFilteredTmpBatchInsertBuilder() TransactionBatchInsertBuilder

+ type MockQTrustLines struct

+ func (m *MockQTrustLines) GetTrustLinesByKeys(ctx context.Context, keys []string) ([]TrustLine, error)

+ func (m *MockQTrustLines) NewTrustLinesBatchInsertBuilder() TrustLinesBatchInsertBuilder

+ 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(entries ...InsertTrade) error

+ func (m *MockTradeBatchInsertBuilder) Exec(ctx context.Context, session db.SessionInterface) error

+ type MockTransactionClaimableBalanceBatchInsertBuilder struct

+ func (m *MockTransactionClaimableBalanceBatchInsertBuilder) Add(transactionID int64, claimableBalance FutureClaimableBalanceID) error

+ func (m *MockTransactionClaimableBalanceBatchInsertBuilder) Exec(ctx context.Context, session db.SessionInterface) error

+ type MockTransactionLiquidityPoolBatchInsertBuilder struct

+ func (m *MockTransactionLiquidityPoolBatchInsertBuilder) Add(transactionID int64, lp FutureLiquidityPoolID) error

+ func (m *MockTransactionLiquidityPoolBatchInsertBuilder) Exec(ctx context.Context, session db.SessionInterface) error

+ type MockTransactionParticipantsBatchInsertBuilder struct

+ func (m *MockTransactionParticipantsBatchInsertBuilder) Add(transactionID int64, accountID FutureAccountID) error

+ func (m *MockTransactionParticipantsBatchInsertBuilder) Exec(ctx context.Context, session db.SessionInterface) error

+ type MockTransactionsBatchInsertBuilder struct

+ func (m *MockTransactionsBatchInsertBuilder) Add(transaction ingest.LedgerTransaction, sequence uint32) error

+ func (m *MockTransactionsBatchInsertBuilder) Exec(ctx context.Context, session db.SessionInterface) error

+ type MockTrustLinesBatchInsertBuilder struct

+ func (m *MockTrustLinesBatchInsertBuilder) Add(line TrustLine) error

+ func (m *MockTrustLinesBatchInsertBuilder) Exec(ctx context.Context) error

+ func (m *MockTrustLinesBatchInsertBuilder) Len() int

type Offer

+ Deleted bool

+ Sponsor null.String

+ type OffersBatchInsertBuilder interface

+ Add func(offer Offer) error

+ Exec func(ctx context.Context) error

+ Len func() int

+ type OffersQuery struct

+ Buying *xdr.Asset

+ PageQuery db2.PageQuery

+ SellerID string

+ Selling *xdr.Asset

+ Sponsor string

type Operation

+ IsPayment bool

+ SourceAccountMuxed null.String

+ type OperationBatchInsertBuilder interface

+ Add func(id int64, transactionID int64, applicationOrder uint32, ...) error

+ Exec func(ctx context.Context, session db.SessionInterface) error

+ type OperationClaimableBalanceBatchInsertBuilder interface

+ Add func(operationID int64, claimableBalance FutureClaimableBalanceID) error

+ Exec func(ctx context.Context, session db.SessionInterface) error

+ type OperationLiquidityPoolBatchInsertBuilder interface

+ Add func(operationID int64, lp FutureLiquidityPoolID) error

+ Exec func(ctx context.Context, session db.SessionInterface) error

+ type OperationParticipantBatchInsertBuilder interface

+ Add func(operationID int64, accountID FutureAccountID) error

+ Exec func(ctx context.Context, session db.SessionInterface) error

type OperationsQ

+ func (q *OperationsQ) ForClaimableBalance(ctx context.Context, cbID string) *OperationsQ

+ func (q *OperationsQ) ForLiquidityPool(ctx context.Context, lpID string) *OperationsQ

+ type OrderBookSummary struct

+ Asks []PriceLevel

+ Bids []PriceLevel

+ type PriceLevel struct

+ Amount string

+ Priced int32

+ Pricef string

+ Pricen int32

type Q

+ func (q *Q) AccountEntriesForSigner(ctx context.Context, signer string, page db2.PageQuery) ([]AccountEntry, 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) AccountsForSponsor(ctx context.Context, sponsor string, page db2.PageQuery) ([]AccountEntry, error)

+ func (q *Q) AllTransactionsByHashesSinceLedger(ctx context.Context, hashes []string, sinceLedgerSeq uint32) ([]Transaction, 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) 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) DeleteTransactionsFilteredTmpOlderThan(ctx context.Context, howOldInSeconds uint64) (int64, error)

+ func (q *Q) EffectsForAccount(ctx context.Context, aid string, page db2.PageQuery) ([]Effect, error)

+ func (q *Q) EffectsForLedger(ctx context.Context, seq int32, page db2.PageQuery) ([]Effect, error)

+ func (q *Q) EffectsForLiquidityPool(ctx context.Context, id string, page db2.PageQuery) ([]Effect, error)

+ func (q *Q) EffectsForOperation(ctx context.Context, id int64, page db2.PageQuery) ([]Effect, error)

+ func (q *Q) EffectsForTransaction(ctx context.Context, hash string, page db2.PageQuery) ([]Effect, 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) GetAccountFilterConfig(ctx context.Context) (AccountFilterConfig, 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) GetAssetFilterConfig(ctx context.Context) (AssetFilterConfig, error)

+ func (q *Q) GetAssetStat(ctx context.Context, assetType xdr.AssetType, assetCode, assetIssuer string) (ExpAssetStat, error)

+ func (q *Q) GetAssetStatByContract(ctx context.Context, contractID xdr.Hash) (ExpAssetStat, error)

+ func (q *Q) GetAssetStats(ctx context.Context, assetCode, assetIssuer string, page db2.PageQuery) ([]AssetAndContractStat, 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) GetClaimantsByClaimableBalances(ctx context.Context, ids []string) (map[string][]ClaimableBalanceClaimant, error)

+ func (q *Q) GetContractAssetBalances(ctx context.Context, keys []xdr.Hash) ([]ContractAssetBalance, error)

+ func (q *Q) GetContractAssetBalancesExpiringAt(ctx context.Context, ledger uint32) ([]ContractAssetBalance, error)

+ func (q *Q) GetContractAssetStat(ctx context.Context, contractID []byte) (ContractAssetStatRow, 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) 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) error

+ func (q *Q) InsertContractAssetBalances(ctx context.Context, rows []ContractAssetBalance) error

+ func (q *Q) InsertContractAssetStat(ctx context.Context, row ContractAssetStatRow) (int64, error)

+ func (q *Q) InsertContractAssetStats(ctx context.Context, rows []ContractAssetStatRow) error

+ func (q *Q) LatestLedgerSequenceClosedAt(ctx context.Context) (int32, time.Time, 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) NewAccountDataBatchInsertBuilder() AccountDataBatchInsertBuilder

+ func (q *Q) NewAccountSignersBatchInsertBuilder() AccountSignersBatchInsertBuilder

+ func (q *Q) NewAccountsBatchInsertBuilder() AccountsBatchInsertBuilder

+ func (q *Q) NewClaimableBalanceBatchInsertBuilder() ClaimableBalanceBatchInsertBuilder

+ func (q *Q) NewClaimableBalanceClaimantBatchInsertBuilder() ClaimableBalanceClaimantBatchInsertBuilder

+ func (q *Q) NewEffectBatchInsertBuilder() EffectBatchInsertBuilder

+ func (q *Q) NewLedgerBatchInsertBuilder() LedgerBatchInsertBuilder

+ func (q *Q) NewOffersBatchInsertBuilder() OffersBatchInsertBuilder

+ func (q *Q) NewOperationBatchInsertBuilder() OperationBatchInsertBuilder

+ func (q *Q) NewOperationClaimableBalanceBatchInsertBuilder() OperationClaimableBalanceBatchInsertBuilder

+ func (q *Q) NewOperationLiquidityPoolBatchInsertBuilder() OperationLiquidityPoolBatchInsertBuilder

+ func (q *Q) NewOperationParticipantBatchInsertBuilder() OperationParticipantBatchInsertBuilder

+ func (q *Q) NewTradeBatchInsertBuilder() TradeBatchInsertBuilder

+ func (q *Q) NewTransactionBatchInsertBuilder() TransactionBatchInsertBuilder

+ func (q *Q) NewTransactionClaimableBalanceBatchInsertBuilder() TransactionClaimableBalanceBatchInsertBuilder

+ func (q *Q) NewTransactionFilteredTmpBatchInsertBuilder() TransactionBatchInsertBuilder

+ func (q *Q) NewTransactionLiquidityPoolBatchInsertBuilder() TransactionLiquidityPoolBatchInsertBuilder

+ func (q *Q) NewTransactionParticipantsBatchInsertBuilder() TransactionParticipantsBatchInsertBuilder

+ func (q *Q) NewTrustLinesBatchInsertBuilder() TrustLinesBatchInsertBuilder

+ func (q *Q) PreFilteredTransactionByHash(ctx context.Context, dest interface{}, hash string) error

+ func (q *Q) RemoveAccountData(ctx context.Context, keys []AccountDataKey) (int64, error)

+ func (q *Q) RemoveAccountSigners(ctx context.Context, account string, signers []string) (int64, error)

+ func (q *Q) RemoveAccounts(ctx context.Context, accountIDs []string) (int64, error)

+ func (q *Q) RemoveAssetContractStat(ctx context.Context, contractID []byte) (int64, error)

+ func (q *Q) RemoveAssetStat(ctx context.Context, assetType xdr.AssetType, assetCode, assetIssuer string) (int64, error)

+ func (q *Q) RemoveClaimableBalanceClaimants(ctx context.Context, ids []string) (int64, error)

+ func (q *Q) RemoveClaimableBalances(ctx context.Context, ids []string) (int64, error)

+ func (q *Q) RemoveContractAssetBalances(ctx context.Context, keys []xdr.Hash) 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) StreamAllLiquidityPools(ctx context.Context, callback func(LiquidityPool) error) error

+ func (q *Q) StreamAllOffers(ctx context.Context, callback func(Offer) error) error

+ func (q *Q) TruncateIngestStateTables(ctx context.Context) error

+ func (q *Q) TryStateVerificationLock(ctx context.Context) (bool, error)

+ func (q *Q) UpdateAccountFilterConfig(ctx context.Context, config AccountFilterConfig) (AccountFilterConfig, error)

+ func (q *Q) UpdateAssetFilterConfig(ctx context.Context, config AssetFilterConfig) (AssetFilterConfig, error)

+ func (q *Q) UpdateAssetStat(ctx context.Context, assetStat ExpAssetStat) (int64, error)

+ func (q *Q) UpdateContractAssetBalanceAmounts(ctx context.Context, keys []xdr.Hash, amounts []string) error

+ func (q *Q) UpdateContractAssetBalanceExpirations(ctx context.Context, keys []xdr.Hash, expirationLedgers []uint32) error

+ func (q *Q) UpdateContractAssetStat(ctx context.Context, row ContractAssetStatRow) (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) ReapLookupTables(ctx context.Context, offsets map[string]int64) (map[string]int64, map[string]int64, error)

+ func (q Q) RebuildTradeAggregationBuckets(ctx context.Context, fromSeq, toSeq uint32, roundingSlippageFilter int) error

+ func (q Q) RebuildTradeAggregationTimes(ctx context.Context, from, to strtime.Millis, roundingSlippageFilter int) error

+ type QAccounts interface

+ GetAccountsByIDs func(ctx context.Context, ids []string) ([]AccountEntry, error)

+ NewAccountsBatchInsertBuilder func() AccountsBatchInsertBuilder

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

+ GetAssetStatByContract func(ctx context.Context, contractID xdr.Hash) (ExpAssetStat, error)

+ GetAssetStats func(ctx context.Context, assetCode, assetIssuer string, page db2.PageQuery) ([]AssetAndContractStat, error)

+ GetContractAssetBalances func(ctx context.Context, keys []xdr.Hash) ([]ContractAssetBalance, error)

+ GetContractAssetBalancesExpiringAt func(ctx context.Context, ledger uint32) ([]ContractAssetBalance, error)

+ GetContractAssetStat func(ctx context.Context, contractID []byte) (ContractAssetStatRow, error)

+ InsertAssetStat func(ctx context.Context, stat ExpAssetStat) (int64, error)

+ InsertAssetStats func(ctx context.Context, stats []ExpAssetStat) error

+ InsertContractAssetBalances func(ctx context.Context, rows []ContractAssetBalance) error

+ InsertContractAssetStat func(ctx context.Context, row ContractAssetStatRow) (int64, error)

+ InsertContractAssetStats func(ctx context.Context, rows []ContractAssetStatRow) error

+ RemoveAssetContractStat func(ctx context.Context, contractID []byte) (int64, error)

+ RemoveAssetStat func(ctx context.Context, assetType xdr.AssetType, assetCode, assetIssuer string) (int64, error)

+ RemoveContractAssetBalances func(ctx context.Context, keys []xdr.Hash) error

+ UpdateAssetStat func(ctx context.Context, stat ExpAssetStat) (int64, error)

+ UpdateContractAssetBalanceAmounts func(ctx context.Context, keys []xdr.Hash, amounts []string) error

+ UpdateContractAssetBalanceExpirations func(ctx context.Context, keys []xdr.Hash, expirationLedgers []uint32) error

+ UpdateContractAssetStat func(ctx context.Context, row ContractAssetStatRow) (int64, error)

+ type QClaimableBalances interface

+ CountClaimableBalances func(ctx context.Context) (int, error)

+ GetClaimableBalancesByID func(ctx context.Context, ids []string) ([]ClaimableBalance, error)

+ GetClaimantsByClaimableBalances func(ctx context.Context, ids []string) (map[string][]ClaimableBalanceClaimant, error)

+ NewClaimableBalanceBatchInsertBuilder func() ClaimableBalanceBatchInsertBuilder

+ NewClaimableBalanceClaimantBatchInsertBuilder func() ClaimableBalanceClaimantBatchInsertBuilder

+ RemoveClaimableBalanceClaimants func(ctx context.Context, ids []string) (int64, 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)

+ NewAccountDataBatchInsertBuilder func() AccountDataBatchInsertBuilder

+ RemoveAccountData func(ctx context.Context, keys []AccountDataKey) (int64, error)

+ UpsertAccountData func(ctx context.Context, data []Data) error

+ type QEffects interface

+ NewEffectBatchInsertBuilder func() EffectBatchInsertBuilder

+ type QFilter interface

+ GetAccountFilterConfig func(ctx context.Context) (AccountFilterConfig, error)

+ GetAssetFilterConfig func(ctx context.Context) (AssetFilterConfig, error)

+ UpdateAccountFilterConfig func(ctx context.Context, config AccountFilterConfig) (AccountFilterConfig, error)

+ UpdateAssetFilterConfig func(ctx context.Context, config AssetFilterConfig) (AssetFilterConfig, error)

+ type QHistoryClaimableBalances interface

+ CreateHistoryClaimableBalances func(ctx context.Context, ids []string, batchSize int) (map[string]int64, error)

+ NewOperationClaimableBalanceBatchInsertBuilder func() OperationClaimableBalanceBatchInsertBuilder

+ NewTransactionClaimableBalanceBatchInsertBuilder func() TransactionClaimableBalanceBatchInsertBuilder

+ type QHistoryLiquidityPools interface

+ CreateHistoryLiquidityPools func(ctx context.Context, poolIDs []string, batchSize int) (map[string]int64, error)

+ NewOperationLiquidityPoolBatchInsertBuilder func() OperationLiquidityPoolBatchInsertBuilder

+ NewTransactionLiquidityPoolBatchInsertBuilder func() TransactionLiquidityPoolBatchInsertBuilder

+ type QLedgers interface

+ NewLedgerBatchInsertBuilder func() LedgerBatchInsertBuilder

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

+ GetLiquidityPoolsByID func(ctx context.Context, poolIDs []string) ([]LiquidityPool, error)

+ GetUpdatedLiquidityPools func(ctx context.Context, newerThanSequence uint32) ([]LiquidityPool, error)

+ StreamAllLiquidityPools func(ctx context.Context, callback func(LiquidityPool) error) error

+ UpsertLiquidityPools func(ctx context.Context, lps []LiquidityPool) error

type QOffers

+ CompactOffers func(ctx context.Context, cutOffSequence uint32) (int64, error)

+ CountOffers func(ctx context.Context) (int, error)

+ GetOffersByIDs func(ctx context.Context, ids []int64) ([]Offer, error)

+ GetUpdatedOffers func(ctx context.Context, newerThanSequence uint32) ([]Offer, error)

+ NewOffersBatchInsertBuilder func() OffersBatchInsertBuilder

+ StreamAllOffers func(ctx context.Context, callback func(Offer) error) error

+ UpsertOffers func(ctx context.Context, offers []Offer) error

+ type QOperations interface

+ NewOperationBatchInsertBuilder func() OperationBatchInsertBuilder

+ type QParticipants interface

+ NewOperationParticipantBatchInsertBuilder func() OperationParticipantBatchInsertBuilder

+ NewTransactionParticipantsBatchInsertBuilder func() TransactionParticipantsBatchInsertBuilder

type QSigners

+ CountAccounts func(ctx context.Context) (int, error)

+ GetLastLedgerIngest func(ctx context.Context) (uint32, error)

+ GetLastLedgerIngestNonBlocking func(ctx context.Context) (uint32, error)

+ NewAccountSignersBatchInsertBuilder func() AccountSignersBatchInsertBuilder

+ RemoveAccountSigners func(ctx context.Context, account string, signers []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() TradeBatchInsertBuilder

+ RebuildTradeAggregationBuckets func(ctx context.Context, fromledger, toLedger uint32, roundingSlippageFilter int) error

+ type QTransactions interface

+ NewTransactionBatchInsertBuilder func() TransactionBatchInsertBuilder

+ NewTransactionFilteredTmpBatchInsertBuilder func() TransactionBatchInsertBuilder

+ type QTrustLines interface

+ GetTrustLinesByKeys func(ctx context.Context, ledgerKeys []string) ([]TrustLine, error)

+ NewTrustLinesBatchInsertBuilder func() TrustLinesBatchInsertBuilder

+ RemoveTrustLines func(ctx context.Context, ledgerKeys []string) (int64, error)

+ UpsertTrustLines func(ctx context.Context, trustlines []TrustLine) error

+ 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 Trade

+ BaseLiquidityPoolID null.String

+ CounterLiquidityPoolID null.String

+ LiquidityPoolFee null.Int

+ Type TradeType

+ func FilterTradesByType(trades []Trade, tradeType string) []Trade

type TradeAggregation

+ CloseD int64

+ CloseN int64

+ HighD int64

+ HighN int64

+ LowD int64

+ LowN int64

+ OpenD int64

+ OpenN int64

+ type TradeBatchInsertBuilder interface

+ Add func(entries ...InsertTrade) error

+ Exec func(ctx context.Context, session db.SessionInterface) 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

+ func (t *Transaction) HasPreconditions() bool

+ type TransactionBatchInsertBuilder interface

+ Add func(transaction ingest.LedgerTransaction, sequence uint32) error

+ Exec func(ctx context.Context, session db.SessionInterface) error

+ type TransactionClaimableBalanceBatchInsertBuilder interface

+ Add func(transactionID int64, claimableBalance FutureClaimableBalanceID) error

+ Exec func(ctx context.Context, session db.SessionInterface) error

+ type TransactionFilteredTmp struct

+ CreatedAt time.Time

+ type TransactionLiquidityPoolBatchInsertBuilder interface

+ Add func(transactionID int64, lp FutureLiquidityPoolID) error

+ Exec func(ctx context.Context, session db.SessionInterface) error

+ type TransactionParticipantsBatchInsertBuilder interface

+ Add func(transactionID int64, accountID FutureAccountID) error

+ Exec func(ctx context.Context, session db.SessionInterface) error

+ type TransactionWithoutLedger struct

+ Account string

+ AccountMuxed null.String

+ AccountSequence int64

+ ApplicationOrder int32

+ CreatedAt time.Time

+ ExtraSigners pq.StringArray

+ FeeAccount null.String

+ FeeAccountMuxed null.String

+ FeeCharged int64

+ InnerSignatures pq.StringArray

+ InnerTransactionHash null.String

+ LedgerBounds LedgerBounds

+ LedgerSequence int32

+ MaxFee int64

+ Memo null.String

+ MemoType string

+ MinAccountSequence null.Int

+ MinAccountSequenceAge null.String

+ MinAccountSequenceLedgerGap null.Int

+ 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

+ func (q *TransactionsQ) ForClaimableBalance(ctx context.Context, cbID string) *TransactionsQ

+ func (q *TransactionsQ) ForLiquidityPool(ctx context.Context, poolID string) *TransactionsQ

+ 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

+ type TrustLinesBatchInsertBuilder interface

+ Add func(line TrustLine) error

+ Exec func(ctx context.Context) error

+ Len func() int

v0

v0.11.0

Dec 23, 2019

Changes in this version

+ var AllowedResolutions = map[time.Duration]struct

+ var ExperimentalIngestionTables = []string

+ var StrictResolutionFiltering = true

+ func EncodeOfferId(id uint64, typ OfferIDType) int64

+ type Account struct

+ Address string

+ ID int64

+ type AccountSigner struct

+ Account string

+ Signer string

+ Weight int32

+ 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 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 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 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 FeeStats struct

+ Min null.Int

+ Mode null.Int

+ P10 null.Int

+ P20 null.Int

+ P30 null.Int

+ P40 null.Int

+ P50 null.Int

+ P60 null.Int

+ P70 null.Int

+ P80 null.Int

+ P90 null.Int

+ P95 null.Int

+ P99 null.Int

+ 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 MockQOffers struct

+ func (m *MockQOffers) GetAllOffers() ([]Offer, error)

+ func (m *MockQOffers) RemoveOffer(offerID xdr.Int64) error

+ func (m *MockQOffers) UpsertOffer(offer xdr.OfferEntry, lastModifiedLedger xdr.Uint32) error

+ type MockQSigners struct

+ func (m *MockQSigners) AccountsForSigner(signer string, page db2.PageQuery) ([]AccountSigner, error)

+ func (m *MockQSigners) CreateAccountSigner(account, signer string, weight int32) error

+ func (m *MockQSigners) GetLastLedgerExpIngest() (uint32, error)

+ func (m *MockQSigners) GetLastLedgerExpIngestNonBlocking() (uint32, error)

+ func (m *MockQSigners) RemoveAccountSigner(account, signer string) error

+ func (m *MockQSigners) UpdateLastLedgerExpIngest(ledgerSequence uint32) error

+ type Offer struct

+ Amount xdr.Int64

+ BuyingAsset xdr.Asset

+ 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 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

+ func (t *Operation) IsTransactionSuccessful() bool

+ 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 Q struct

+ func (q *Q) AccountByAddress(dest interface{}, addy string) error

+ func (q *Q) AccountByID(dest interface{}, id int64) error

+ func (q *Q) Accounts() *AccountsQ

+ func (q *Q) AccountsByAddresses(dest interface{}, addresses []string) error

+ func (q *Q) AccountsForSigner(signer string, page db2.PageQuery) ([]AccountSigner, error)

+ func (q *Q) CreateAccountSigner(account, signer string, weight int32) error

+ func (q *Q) CreateAccounts(dest interface{}, addresses []string) error

+ func (q *Q) Effects() *EffectsQ

+ func (q *Q) ElderLedger(dest interface{}) error

+ func (q *Q) GetAllOffers() ([]Offer, error)

+ func (q *Q) GetAssetByID(dest interface{}, id int64) (err error)

+ func (q *Q) GetAssetID(asset xdr.Asset) (id int64, err error)

+ func (q *Q) GetAssetIDs(assets []xdr.Asset) ([]int64, error)

+ func (q *Q) GetCreateAccountID(aid xdr.AccountId) (result int64, err error)

+ func (q *Q) GetCreateAssetID(asset xdr.Asset) (result int64, err error)

+ func (q *Q) GetExpIngestVersion() (int, error)

+ func (q *Q) GetLastLedgerExpIngest() (uint32, error)

+ func (q *Q) GetLastLedgerExpIngestNonBlocking() (uint32, error)

+ func (q *Q) GetOfferByID(id int64) (Offer, error)

+ func (q *Q) InsertTrade(opid int64, order int32, buyer xdr.AccountId, buyOfferExists bool, ...) 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) OldestOutdatedLedgers(dest interface{}, currentVersion int) error

+ func (q *Q) OperationByID(includeTransactions bool, id int64) (Operation, *Transaction, error)

+ func (q *Q) OperationFeeStats(currentSeq int32, dest *FeeStats) error

+ func (q *Q) Operations() *OperationsQ

+ func (q *Q) RemoveAccountSigner(account, signer string) error

+ func (q *Q) RemoveOffer(offerID xdr.Int64) error

+ func (q *Q) ReverseTrades() *TradesQ

+ 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) UpdateExpIngestVersion(ledgerSequence int) error

+ func (q *Q) UpdateLastLedgerExpIngest(ledgerSequence uint32) error

+ func (q *Q) UpsertOffer(offer xdr.OfferEntry, lastModifiedLedger xdr.Uint32) error

+ func (q Q) GetTradeAggregationsQ(baseAssetID int64, counterAssetID int64, resolution int64, offset int64, ...) (*TradeAggregationsQ, error)

+ type QOffers interface

+ GetAllOffers func() ([]Offer, error)

+ RemoveOffer func(offerID xdr.Int64) error

+ UpsertOffer func(offer xdr.OfferEntry, lastModifiedLedger xdr.Uint32) error

+ type QSigners interface

+ AccountsForSigner func(signer string, page db2.PageQuery) ([]AccountSigner, error)

+ CreateAccountSigner func(account, signer string, weight int32) error

+ GetLastLedgerExpIngest func() (uint32, error)

+ GetLastLedgerExpIngestNonBlocking func() (uint32, error)

+ RemoveAccountSigner func(account, signer string) error

+ UpdateLastLedgerExpIngest func(ledgerSequence uint32) error

+ type SequenceBumped struct

+ NewSeq int64

+ 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 TradesQ struct

+ Err error

+ func (q *TradesQ) ForAccount(aid string) *TradesQ

+ func (q *TradesQ) ForOffer(id int64) *TradesQ

+ func (q *TradesQ) JoinAccounts() *TradesQ

+ func (q *TradesQ) JoinAssets() *TradesQ

+ func (q *TradesQ) Page(page db2.PageQuery) *TradesQ

+ func (q *TradesQ) Select(dest interface{}) error

+ type Transaction struct

+ Account string

+ AccountSequence string

+ ApplicationOrder int32

+ CreatedAt time.Time

+ FeeCharged int32

+ LedgerCloseTime time.Time

+ LedgerSequence int32

+ MaxFee int32

+ Memo null.String

+ MemoType string

+ OperationCount int32

+ SignatureString string

+ Successful *bool

+ TransactionHash string

+ TxEnvelope string

+ TxFeeMeta string

+ TxMeta string

+ TxResult string

+ UpdatedAt time.Time

+ ValidAfter null.Int

+ ValidBefore null.Int

+ func (t *Transaction) IsSuccessful() bool

+ 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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL