core

package
v0.0.0-...-d683214 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 8, 2019 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Overview

Package core contains database record definitions useable for reading rows from a Stellar Core db

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AssetFromDB 

func AssetFromDB(typ xdr.AssetType, code string, issuer string) (result xdr.Asset, err error)

AssetFromDB produces an xdr.Asset by combining the constituent type, code and issuer, as often retrieved from the DB in 3 separate columns.

Types

type Account 

type Account struct {
	Accountid          string
	Balance            xdr.Int64
	Seqnum             string
	Numsubentries      int32
	Inflationdest      null.String
	HomeDomain         null.String
	Thresholds         xdr.Thresholds
	Flags              xdr.AccountFlags
	BuyingLiabilities  xdr.Int64 `db:"buyingliabilities"`
	SellingLiabilities xdr.Int64 `db:"sellingliabilities"`
}

Account is a row of data from the `accounts` table

func (Account) IsAuthImmutable 

func (ac Account) IsAuthImmutable() bool

IsAuthImmutable returns true if the account has the "AUTH_IMMUTABLE" option turned on.

func (Account) IsAuthRequired 

func (ac Account) IsAuthRequired() bool

IsAuthRequired returns true if the account has the "AUTH_REQUIRED" option turned on.

func (Account) IsAuthRevocable 

func (ac Account) IsAuthRevocable() bool

IsAuthRevocable returns true if the account has the "AUTH_REVOCABLE" option turned on.

type AccountData 

type AccountData struct {
	Accountid string
	Key       string `db:"dataname"`
	Value     string `db:"datavalue"`
}

AccountData is a row of data from the `accountdata` table

func (AccountData) Raw 

func (ad AccountData) Raw() ([]byte, error)

Raw returns the decoded, raw value of the account data

type AggregateBalanceString 

type AggregateBalanceString struct {
	AccountId string `json:"account_id"`
	Balance   string `json:"aggregate_balance"`
}

func (AggregateBalanceString) PagingToken 

func (r AggregateBalanceString) PagingToken() string

type ControlledAccountString 

type ControlledAccountString struct {
	AccountId string `json:"account_id"`
	Balance   string `json:"balance"`
}

func (ControlledAccountString) PagingToken 

func (r ControlledAccountString) PagingToken() string

type LedgerHeader 

type LedgerHeader struct {
	LedgerHash     string           `db:"ledgerhash"`
	PrevHash       string           `db:"prevhash"`
	BucketListHash string           `db:"bucketlisthash"`
	CloseTime      int64            `db:"closetime"`
	Sequence       uint32           `db:"ledgerseq"`
	Data           xdr.LedgerHeader `db:"data"`
}

LedgerHeader is row of data from the `ledgerheaders` table

func (*LedgerHeader) DataXDR 

func (lh *LedgerHeader) DataXDR() string

DataXDR returns the base64 encoded ledger header

type Offer 

type Offer struct {
	SellerID string `db:"sellerid"`
	OfferID  int64  `db:"offerid"`

	SellingAssetType xdr.AssetType `db:"sellingassettype"`
	SellingAssetCode null.String   `db:"sellingassetcode"`
	SellingIssuer    null.String   `db:"sellingissuer"`

	BuyingAssetType xdr.AssetType `db:"buyingassettype"`
	BuyingAssetCode null.String   `db:"buyingassetcode"`
	BuyingIssuer    null.String   `db:"buyingissuer"`

	Amount       xdr.Int64 `db:"amount"`
	Pricen       int32     `db:"pricen"`
	Priced       int32     `db:"priced"`
	Price        float64   `db:"price"`
	Flags        int32     `db:"flags"`
	Lastmodified int32     `db:"lastmodified"`
}

Offer is row of data from the `offers` table from stellar-core

func (Offer) PagingToken 

func (r Offer) PagingToken() string

PagingToken returns a suitable paging token for the Offer

func (Offer) PriceAsString 

func (r Offer) PriceAsString() string

PriceAsString return the price fraction as a floating point approximate.

type OrderBookSummary 

type OrderBookSummary []OrderBookSummaryPriceLevel

OrderBookSummary is a summary of a set of offers for a given base and counter currency

func (*OrderBookSummary) Asks 

func (o *OrderBookSummary) Asks() []OrderBookSummaryPriceLevel

Asks filters the summary into a slice of PriceLevelRecords where the type is 'ask'

func (*OrderBookSummary) Bids 

func (o *OrderBookSummary) Bids() []OrderBookSummaryPriceLevel

Bids filters the summary into a slice of PriceLevelRecords where the type is 'bid'

type OrderBookSummaryPriceLevel 

type OrderBookSummaryPriceLevel struct {
	Type string `db:"type"`
	PriceLevel
}

OrderBookSummaryPriceLevel is a collapsed view of multiple offers at the same price that contains the summed amount from all the member offers. Used by OrderBookSummary

type PriceLevel 

type PriceLevel struct {
	Pricen int32   `db:"pricen"`
	Priced int32   `db:"priced"`
	Pricef float64 `db:"pricef"`
	Amount int64   `db:"amount"`
}

PriceLevel represents an aggregation of offers to trade at a certain price.

func (*PriceLevel) AmountAsString 

func (p *PriceLevel) AmountAsString() string

AmountAsString returns the amount as a string, formatted using the amount.String() utility from github.com/kinecosystem/go.

func (*PriceLevel) InvertPricef 

func (p *PriceLevel) InvertPricef() float64

InvertPricef returns the inverted price of the price-level, i.e. what the price would be if you were viewing the price level from the other side of the bid/ask dichotomy.

func (*PriceLevel) PriceAsString 

func (p *PriceLevel) PriceAsString() string

PriceAsString returns the price as a string

type Q 

type Q struct {
	*db.Session
}

Q is a helper struct on which to hang common queries against a stellar core database.

func (*Q) AccountByAddress 

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

AccountByAddress loads a row from `accounts`, by address

func (*Q) AccountDataByKey 

func (q *Q) AccountDataByKey(dest interface{}, addy string, key string) error

AccountDataByKey loads a row from `accountdata`, by key

func (*Q) AggregateBalanceByAccountId 

func (q *Q) AggregateBalanceByAccountId(dest *ControlledAccountString) error

AggregateBaalanceByAccountId returns the aggregate balance by the master account id

func (*Q) AllAssets 

func (q *Q) AllAssets(dest interface{}) error

AllAssets loads all (unique) assets from core DB

func (*Q) AllDataByAddress 

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

AllDataByAddress loads all data for `addy`

func (*Q) AssetsForAddress 

func (q *Q) AssetsForAddress(dest interface{}, addy string, protocolVersion int32) error

AssetsForAddress loads `dest` as `[]xdr.Asset` with every asset the account at `addy` can hold.

func (*Q) BalancesForAsset 

func (q *Q) BalancesForAsset(
	assetType int32,
	assetCode string,
	assetIssuer string,
) (int32, string, error)

BalancesForAsset returns all the balances by asset type, code, issuer

func (*Q) ConnectedAssets 

func (q *Q) ConnectedAssets(dest interface{}, selling xdr.Asset) error

ConnectedAssets loads xdr.Asset records for the purposes of path finding. Given the input asset type, a list of xdr.Assets is returned that each have some available trades for the input asset.

func (*Q) ControlledAccountsByAccountId 

func (q *Q) ControlledAccountsByAccountId(controlledAccountsSlice *[]*ControlledAccountString, aid string) error

ControlledAccountsByAccountId returns the list of controlled accounts with their respective balance

func (*Q) ElderLedger 

func (q *Q) ElderLedger(dest *int32) error

ElderLedger represents the oldest "ingestable" ledger known to the stellar-core database this ingestion system is communicating with. Horizon, which wants to operate on a contiguous range of ledger data (i.e. free from gaps) uses the elder ledger to start importing in the case of an empty database. NOTE: This current query used is correct, but slow. Please keep this query out of latency sensitive or frequently trafficked code paths.

func (*Q) GetOrderBookSummary 

func (q *Q) GetOrderBookSummary(dest interface{}, selling xdr.Asset, buying xdr.Asset, limit uint64) error

GetOrderBookSummary loads a summary of an order book identified by a selling/buying pair. It is designed to drive an order book summary client interface (bid/ask spread, prices and volume, etc).

func (*Q) LatestLedger 

func (q *Q) LatestLedger(dest interface{}) error

LatestLedger loads the latest known ledger

func (*Q) LedgerHeaderBySequence 

func (q *Q) LedgerHeaderBySequence(dest interface{}, seq int32) error

LedgerHeaderBySequence is a query that loads a single row from the `ledgerheaders` table.

func (*Q) OffersByAddress 

func (q *Q) OffersByAddress(dest interface{}, addy string, pq db2.PageQuery) error

OffersByAddress loads a page of active offers for the given address.

func (*Q) SequenceProvider 

func (q *Q) SequenceProvider() *SequenceProvider

SequenceProvider returns a new sequence provider.

func (*Q) SequencesForAddresses 

func (q *Q) SequencesForAddresses(dest interface{}, addys []string) error

SequencesForAddresses loads the current sequence number for every accountid specified in `addys`

func (*Q) SignersByAddress 

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

SignersByAddress loads all signer rows for `addy`

func (*Q) TransactionByHashAfterLedger 

func (q *Q) TransactionByHashAfterLedger(
	dest interface{},
	hash string,
	ledger int32,
) error

TransactionByHashAfterLedger is a query that loads a single row from the `txhistory`.

func (*Q) TransactionFeesByLedger 

func (q *Q) TransactionFeesByLedger(dest interface{}, seq int32) error

TransactionFeesByLedger is a query that loads all rows from `txfeehistory` where ledgerseq matches `Sequence.`

func (*Q) TransactionsByLedger 

func (q *Q) TransactionsByLedger(dest interface{}, seq int32) error

TransactionsByLedger is a query that loads all rows from `txhistory` where ledgerseq matches `Sequence.`

func (*Q) TrustlinesByAddress 

func (q *Q) TrustlinesByAddress(dest interface{}, addy string, protocolVersion int32) error

TrustlinesByAddress loads all trustlines for `addy`

type SequenceProvider 

type SequenceProvider struct {
	Q *Q
}

SequenceProvider implements `txsub.SequenceProvider`

func (*SequenceProvider) Get 

func (sp *SequenceProvider) Get(addys []string) (map[string]uint64, error)

Get implements `txsub.SequenceProvider`

type Signer 

type Signer struct {
	Accountid string
	Publickey string
	Weight    int32
}

Signer is a row of data from the `signers` table from stellar-core

type Transaction 

type Transaction struct {
	TransactionHash string                    `db:"txid"`
	LedgerSequence  int32                     `db:"ledgerseq"`
	Index           int32                     `db:"txindex"`
	Envelope        xdr.TransactionEnvelope   `db:"txbody"`
	Result          xdr.TransactionResultPair `db:"txresult"`
	ResultMeta      xdr.TransactionMeta       `db:"txmeta"`
}

Transaction is row of data from the `txhistory` table from stellar-core

func (*Transaction) Base64Signatures 

func (tx *Transaction) Base64Signatures() []string

Base64Signatures returns a slice of strings where each element is a base64 encoded representation of a signature attached to this transaction.

func (*Transaction) EnvelopeXDR 

func (tx *Transaction) EnvelopeXDR() string

EnvelopeXDR returns the XDR encoded envelope for this transaction

func (*Transaction) Fee 

func (tx *Transaction) Fee(whiteListData map[string]string) int32

Fee returns the fee that was paid for `tx`

func (*Transaction) IsSuccessful 

func (tx *Transaction) IsSuccessful() bool

IsSuccessful returns true when the transaction was successful.

func (*Transaction) Memo 

func (tx *Transaction) Memo() null.String

Memo returns the memo for this transaction, if there is one.

func (*Transaction) MemoType 

func (tx *Transaction) MemoType() string

MemoType returns the memo type for this transaction

func (*Transaction) ResultMetaXDR 

func (tx *Transaction) ResultMetaXDR() string

ResultMetaXDR returns the XDR encoded result meta for this transaction

func (*Transaction) ResultXDR 

func (tx *Transaction) ResultXDR() string

ResultXDR returns the XDR encoded result for this transaction

func (*Transaction) Sequence 

func (tx *Transaction) Sequence() int64

Sequence returns the sequence number for `tx`

func (*Transaction) SourceAddress 

func (tx *Transaction) SourceAddress() string

SourceAddress returns the strkey-encoded account id that paid the fee for `tx`.

type TransactionFee 

type TransactionFee struct {
	TransactionHash string                 `db:"txid"`
	LedgerSequence  int32                  `db:"ledgerseq"`
	Index           int32                  `db:"txindex"`
	Changes         xdr.LedgerEntryChanges `db:"txchanges"`
}

TransactionFee is row of data from the `txfeehistory` table from stellar-core

func (*TransactionFee) ChangesXDR 

func (fee *TransactionFee) ChangesXDR() string

ChangesXDR returns the XDR encoded changes for this transaction fee

type Trustline 

type Trustline struct {
	Accountid          string
	Assettype          xdr.AssetType
	Issuer             string
	Assetcode          string
	Tlimit             xdr.Int64
	Balance            xdr.Int64
	Flags              int32
	BuyingLiabilities  xdr.Int64 `db:"buyingliabilities"`
	SellingLiabilities xdr.Int64 `db:"sellingliabilities"`
}

Trustline is a row of data from the `trustlines` table from stellar-core

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.