auroraclient

package

Go to main page

Versions in this module

v1

v1.11.1

Jun 10, 2024

Changes in this version

+ var AuroraTimeout = 60 * time.Second

+ var ErrAccountRequiresMemo = errors.New("destination account requires a memo in the transaction")

+ func IsNotFoundError(err error) bool

type AccountRequest

+ func (ar AccountRequest) HTTPRequest(auroraURL string) (*http.Request, error)

+ type AccountsRequest struct

+ Asset string

+ Cursor string

+ Limit uint

+ LiquidityPool string

+ Order Order

+ Signer string

+ Sponsor string

+ func (r AccountsRequest) BuildURL() (endpoint string, err error)

+ func (r AccountsRequest) HTTPRequest(auroraURL string) (*http.Request, error)

+ type AdminClient struct

+ func NewAdminClient(port uint16, host string, timeout time.Duration) (*AdminClient, error)

+ func (c *AdminClient) GetIngestionAccountFilter() (hProtocol.AccountFilterConfig, error)

+ func (c *AdminClient) GetIngestionAssetFilter() (hProtocol.AssetFilterConfig, error)

+ func (c *AdminClient) SetIngestionAccountFilter(filter hProtocol.AccountFilterConfig) error

+ func (c *AdminClient) SetIngestionAssetFilter(filter hProtocol.AssetFilterConfig) error

+ type AdminClientInterface interface

+ GetIngestionAccountFilter func() (hProtocol.AccountFilterConfig, error)

+ GetIngestionAssetFilter func() (hProtocol.AssetFilterConfig, error)

+ SetIngestionAccountFilter func(hProtocol.AccountFilterConfig) error

+ SetIngestionAssetFilter func(hProtocol.AssetFilterConfig) error

type AssetRequest

+ func (ar AssetRequest) HTTPRequest(auroraURL string) (*http.Request, error)

type AuroraRequest

+ HTTPRequest func(auroraURL string) (*http.Request, error)

+ type ClaimableBalanceRequest struct

+ Asset string

+ Claimant string

+ Cursor string

+ ID string

+ Limit uint

+ Sponsor string

+ func (cbr ClaimableBalanceRequest) BuildURL() (endpoint string, err error)

+ func (cbr ClaimableBalanceRequest) HTTPRequest(auroraURL string) (*http.Request, error)

type Client

+ Headers map[string]string

+ func (c *Client) Accounts(request AccountsRequest) (accounts hProtocol.AccountsPage, err error)

+ func (c *Client) AsyncSubmitFeeBumpTransaction(transaction *txnbuild.FeeBumpTransaction) (txResp hProtocol.AsyncTransactionSubmissionResponse, err error)

+ func (c *Client) AsyncSubmitFeeBumpTransactionWithOptions(transaction *txnbuild.FeeBumpTransaction, opts SubmitTxOpts) (txResp hProtocol.AsyncTransactionSubmissionResponse, err error)

+ func (c *Client) AsyncSubmitTransaction(transaction *txnbuild.Transaction) (txResp hProtocol.AsyncTransactionSubmissionResponse, err error)

+ func (c *Client) AsyncSubmitTransactionWithOptions(transaction *txnbuild.Transaction, opts SubmitTxOpts) (txResp hProtocol.AsyncTransactionSubmissionResponse, err error)

+ func (c *Client) AsyncSubmitTransactionXDR(transactionXdr string) (txResp hProtocol.AsyncTransactionSubmissionResponse, err error)

+ func (c *Client) AuroraTimeout() time.Duration

+ func (c *Client) ClaimableBalance(id string) (cb hProtocol.ClaimableBalance, err error)

+ func (c *Client) ClaimableBalances(cbr ClaimableBalanceRequest) (cb hProtocol.ClaimableBalances, err error)

+ func (c *Client) LiquidityPoolDetail(request LiquidityPoolRequest) (lp hProtocol.LiquidityPool, err error)

+ func (c *Client) LiquidityPools(request LiquidityPoolsRequest) (lp hProtocol.LiquidityPoolsPage, err error)

+ func (c *Client) NextAccountsPage(page hProtocol.AccountsPage) (accounts hProtocol.AccountsPage, err error)

+ func (c *Client) NextLiquidityPoolsPage(page hProtocol.LiquidityPoolsPage) (lp hProtocol.LiquidityPoolsPage, err error)

+ func (c *Client) NextTradeAggregationsPage(page hProtocol.TradeAggregationsPage) (ta hProtocol.TradeAggregationsPage, err error)

+ func (c *Client) OfferDetails(offerID string) (offer hProtocol.Offer, err error)

+ func (c *Client) PrevLiquidityPoolsPage(page hProtocol.LiquidityPoolsPage) (lp hProtocol.LiquidityPoolsPage, err error)

+ func (c *Client) PrevTradeAggregationsPage(page hProtocol.TradeAggregationsPage) (ta hProtocol.TradeAggregationsPage, err error)

+ func (c *Client) SetAuroraTimeout(t time.Duration) *Client

+ func (c *Client) StrictReceivePaths(request PathsRequest) (paths hProtocol.PathsPage, err error)

+ func (c *Client) StrictSendPaths(request StrictSendPathsRequest) (paths hProtocol.PathsPage, err error)

+ func (c *Client) SubmitFeeBumpTransaction(transaction *txnbuild.FeeBumpTransaction) (tx hProtocol.Transaction, err error)

+ func (c *Client) SubmitFeeBumpTransactionWithOptions(transaction *txnbuild.FeeBumpTransaction, opts SubmitTxOpts) (tx hProtocol.Transaction, err error)

+ func (c *Client) SubmitTransactionWithOptions(transaction *txnbuild.Transaction, opts SubmitTxOpts) (tx hProtocol.Transaction, err error)

type ClientInterface

+ Accounts func(request AccountsRequest) (hProtocol.AccountsPage, error)

+ AsyncSubmitFeeBumpTransaction func(transaction *txnbuild.FeeBumpTransaction) (hProtocol.AsyncTransactionSubmissionResponse, error)

+ AsyncSubmitFeeBumpTransactionWithOptions func(transaction *txnbuild.FeeBumpTransaction, opts SubmitTxOpts) (hProtocol.AsyncTransactionSubmissionResponse, error)

+ AsyncSubmitTransaction func(transaction *txnbuild.Transaction) (hProtocol.AsyncTransactionSubmissionResponse, error)

+ AsyncSubmitTransactionWithOptions func(transaction *txnbuild.Transaction, opts SubmitTxOpts) (hProtocol.AsyncTransactionSubmissionResponse, error)

+ AsyncSubmitTransactionXDR func(transactionXdr string) (hProtocol.AsyncTransactionSubmissionResponse, error)

+ LiquidityPoolDetail func(request LiquidityPoolRequest) (hProtocol.LiquidityPool, error)

+ LiquidityPools func(request LiquidityPoolsRequest) (hProtocol.LiquidityPoolsPage, error)

+ NextAccountsPage func(hProtocol.AccountsPage) (hProtocol.AccountsPage, error)

+ NextLiquidityPoolsPage func(hProtocol.LiquidityPoolsPage) (hProtocol.LiquidityPoolsPage, error)

+ NextTradeAggregationsPage func(hProtocol.TradeAggregationsPage) (hProtocol.TradeAggregationsPage, error)

+ OfferDetails func(offerID string) (offer hProtocol.Offer, err error)

+ PrevLiquidityPoolsPage func(hProtocol.LiquidityPoolsPage) (hProtocol.LiquidityPoolsPage, error)

+ PrevTradeAggregationsPage func(hProtocol.TradeAggregationsPage) (hProtocol.TradeAggregationsPage, error)

+ SubmitFeeBumpTransaction func(transaction *txnbuild.FeeBumpTransaction) (hProtocol.Transaction, error)

+ SubmitFeeBumpTransactionWithOptions func(transaction *txnbuild.FeeBumpTransaction, opts SubmitTxOpts) (hProtocol.Transaction, error)

+ SubmitTransactionWithOptions func(transaction *txnbuild.Transaction, opts SubmitTxOpts) (hProtocol.Transaction, error)

type EffectRequest

+ ForLiquidityPool string

+ func (er EffectRequest) HTTPRequest(auroraURL string) (*http.Request, error)

type Error

+ func GetError(err error) *Error

type LedgerRequest

+ func (lr LedgerRequest) HTTPRequest(auroraURL string) (*http.Request, error)

+ type LiquidityPoolRequest struct

+ LiquidityPoolID string

+ func (r LiquidityPoolRequest) BuildURL() (endpoint string, err error)

+ func (r LiquidityPoolRequest) HTTPRequest(auroraURL string) (*http.Request, error)

+ type LiquidityPoolsRequest struct

+ Cursor string

+ Limit uint

+ Order Order

+ Reserves []string

+ func (r LiquidityPoolsRequest) BuildURL() (endpoint string, err error)

+ func (r LiquidityPoolsRequest) HTTPRequest(auroraURL string) (*http.Request, error)

+ type MockAdminClient struct

+ func (m *MockAdminClient) GetIngestionAccountFilter() (hProtocol.AccountFilterConfig, error)

+ func (m *MockAdminClient) GetIngestionAssetFilter() (hProtocol.AssetFilterConfig, error)

+ func (m *MockAdminClient) SetIngestionAccountFilter(resource hProtocol.AccountFilterConfig) error

+ func (m *MockAdminClient) SetIngestionAssetFilter(resource hProtocol.AssetFilterConfig) error

type MockClient

+ func (m *MockClient) Accounts(request AccountsRequest) (hProtocol.AccountsPage, error)

+ func (m *MockClient) AsyncSubmitFeeBumpTransaction(transaction *txnbuild.FeeBumpTransaction) (hProtocol.AsyncTransactionSubmissionResponse, error)

+ func (m *MockClient) AsyncSubmitFeeBumpTransactionWithOptions(transaction *txnbuild.FeeBumpTransaction, opts SubmitTxOpts) (hProtocol.AsyncTransactionSubmissionResponse, error)

+ func (m *MockClient) AsyncSubmitTransaction(transaction *txnbuild.Transaction) (hProtocol.AsyncTransactionSubmissionResponse, error)

+ func (m *MockClient) AsyncSubmitTransactionWithOptions(transaction *txnbuild.Transaction, opts SubmitTxOpts) (hProtocol.AsyncTransactionSubmissionResponse, error)

+ func (m *MockClient) AsyncSubmitTransactionXDR(transactionXdr string) (hProtocol.AsyncTransactionSubmissionResponse, error)

+ func (m *MockClient) LiquidityPoolDetail(request LiquidityPoolRequest) (hProtocol.LiquidityPool, error)

+ func (m *MockClient) LiquidityPools(request LiquidityPoolsRequest) (hProtocol.LiquidityPoolsPage, error)

+ func (m *MockClient) NextAccountsPage(page hProtocol.AccountsPage) (hProtocol.AccountsPage, error)

+ func (m *MockClient) NextLiquidityPoolsPage(page hProtocol.LiquidityPoolsPage) (hProtocol.LiquidityPoolsPage, error)

+ func (m *MockClient) NextTradeAggregationsPage(page hProtocol.TradeAggregationsPage) (hProtocol.TradeAggregationsPage, error)

+ func (m *MockClient) OfferDetails(offerID string) (hProtocol.Offer, error)

+ func (m *MockClient) PrevLiquidityPoolsPage(page hProtocol.LiquidityPoolsPage) (hProtocol.LiquidityPoolsPage, error)

+ func (m *MockClient) PrevTradeAggregationsPage(page hProtocol.TradeAggregationsPage) (hProtocol.TradeAggregationsPage, error)

+ func (m *MockClient) SubmitFeeBumpTransaction(transaction *txnbuild.FeeBumpTransaction) (hProtocol.Transaction, error)

+ func (m *MockClient) SubmitFeeBumpTransactionWithOptions(transaction *txnbuild.FeeBumpTransaction, opts SubmitTxOpts) (hProtocol.Transaction, error)

+ func (m *MockClient) SubmitTransactionWithOptions(transaction *txnbuild.Transaction, opts SubmitTxOpts) (hProtocol.Transaction, error)

type OfferRequest

+ Buying string

+ OfferID string

+ Seller string

+ Selling string

+ func (or OfferRequest) HTTPRequest(auroraURL string) (*http.Request, error)

type OperationRequest

+ ForClaimableBalance string

+ ForLiquidityPool string

+ Join string

+ func (op OperationRequest) HTTPRequest(auroraURL string) (*http.Request, error)

type OrderBookRequest

+ func (obr OrderBookRequest) HTTPRequest(auroraURL string) (*http.Request, error)

type PathsRequest

+ SourceAssets string

+ func (pr PathsRequest) HTTPRequest(auroraURL string) (*http.Request, error)

+ type StrictSendPathsRequest struct

+ DestinationAccount string

+ DestinationAssets string

+ SourceAmount string

+ SourceAssetCode string

+ SourceAssetIssuer string

+ SourceAssetType AssetType

+ func (pr StrictSendPathsRequest) BuildURL() (endpoint string, err error)

+ func (pr StrictSendPathsRequest) HTTPRequest(auroraURL string) (*http.Request, error)

+ type SubmitTxOpts struct

+ SkipMemoRequiredCheck bool

type TradeAggregationRequest

+ func (ta TradeAggregationRequest) HTTPRequest(auroraURL string) (*http.Request, error)

type TradeRequest

+ ForLiquidityPool string

+ TradeType string

+ func (tr TradeRequest) HTTPRequest(auroraURL string) (*http.Request, error)

type TransactionRequest

+ ForClaimableBalance string

+ ForLiquidityPool string

+ func (tr TransactionRequest) HTTPRequest(auroraURL string) (*http.Request, error)

+ type UniversalTimeHandler func() int64

v0

v0.11.0

Dec 23, 2019

Changes in this version

+ const AssetType12

+ const AssetType4

+ const AssetTypeNative

+ const OrderAsc

+ const OrderDesc

+ var AuroraTimeOut = time.Duration(60)

+ var DayResolution = time.Duration(24 * time.Hour)

+ var DefaultPublicNetClient = &Client

+ var DefaultTestNetClient = &Client

+ var ErrEnvelopeNotPopulated = errors.New("envelope_xdr not populated")

+ var ErrResultCodesNotPopulated = errors.New("result_codes not populated")

+ var ErrResultNotPopulated = errors.New("result_xdr not populated")

+ var FifteenMinuteResolution = time.Duration(15 * time.Minute)

+ var FiveMinuteResolution = time.Duration(5 * time.Minute)

+ var HourResolution = time.Duration(1 * time.Hour)

+ var MinuteResolution = time.Duration(1 * time.Minute)

+ var ServerTimeMap = make(map[string]ServerTimeRecord)

+ var WeekResolution = time.Duration(168 * time.Hour)

+ type AccountRequest struct

+ AccountID string

+ DataKey string

+ func (ar AccountRequest) BuildURL() (endpoint string, err error)

+ type AssetRequest struct

+ Cursor string

+ ForAssetCode string

+ ForAssetIssuer string

+ Limit uint

+ Order Order

+ func (ar AssetRequest) BuildURL() (endpoint string, err error)

+ type AssetType string

+ type AuroraRequest interface

+ BuildURL func() (string, error)

+ type Client struct

+ AppName string

+ AppVersion string

+ AuroraURL string

+ HTTP HTTP

+ func (c *Client) AccountData(request AccountRequest) (accountData hProtocol.AccountData, err error)

+ func (c *Client) AccountDetail(request AccountRequest) (account hProtocol.Account, err error)

+ func (c *Client) Assets(request AssetRequest) (assets hProtocol.AssetsPage, err error)

+ func (c *Client) AuroraTimeOut() time.Duration

+ func (c *Client) Effects(request EffectRequest) (effects effects.EffectsPage, err error)

+ func (c *Client) FeeStats() (feestats hProtocol.FeeStats, err error)

+ func (c *Client) FetchTimebounds(seconds int64) (txnbuild.Timebounds, error)

+ func (c *Client) Fund(addr string) (txSuccess hProtocol.TransactionSuccess, err error)

+ func (c *Client) HomeDomainForAccount(aid string) (string, error)

+ func (c *Client) LedgerDetail(sequence uint32) (ledger hProtocol.Ledger, err error)

+ func (c *Client) Ledgers(request LedgerRequest) (ledgers hProtocol.LedgersPage, err error)

+ func (c *Client) Metrics() (metrics hProtocol.Metrics, err error)

+ func (c *Client) NextAssetsPage(page hProtocol.AssetsPage) (assets hProtocol.AssetsPage, err error)

+ func (c *Client) NextEffectsPage(page effects.EffectsPage) (efp effects.EffectsPage, err error)

+ func (c *Client) NextLedgersPage(page hProtocol.LedgersPage) (ledgers hProtocol.LedgersPage, err error)

+ func (c *Client) NextOffersPage(page hProtocol.OffersPage) (offers hProtocol.OffersPage, err error)

+ func (c *Client) NextOperationsPage(page operations.OperationsPage) (operations operations.OperationsPage, err error)

+ func (c *Client) NextPaymentsPage(page operations.OperationsPage) (operations.OperationsPage, error)

+ func (c *Client) NextTradesPage(page hProtocol.TradesPage) (trades hProtocol.TradesPage, err error)

+ func (c *Client) NextTransactionsPage(page hProtocol.TransactionsPage) (transactions hProtocol.TransactionsPage, err error)

+ func (c *Client) Offers(request OfferRequest) (offers hProtocol.OffersPage, err error)

+ func (c *Client) OperationDetail(id string) (ops operations.Operation, err error)

+ func (c *Client) Operations(request OperationRequest) (ops operations.OperationsPage, err error)

+ func (c *Client) OrderBook(request OrderBookRequest) (obs hProtocol.OrderBookSummary, err error)

+ func (c *Client) Paths(request PathsRequest) (paths hProtocol.PathsPage, err error)

+ func (c *Client) Payments(request OperationRequest) (ops operations.OperationsPage, err error)

+ func (c *Client) PrevAssetsPage(page hProtocol.AssetsPage) (assets hProtocol.AssetsPage, err error)

+ func (c *Client) PrevEffectsPage(page effects.EffectsPage) (efp effects.EffectsPage, err error)

+ func (c *Client) PrevLedgersPage(page hProtocol.LedgersPage) (ledgers hProtocol.LedgersPage, err error)

+ func (c *Client) PrevOffersPage(page hProtocol.OffersPage) (offers hProtocol.OffersPage, err error)

+ func (c *Client) PrevOperationsPage(page operations.OperationsPage) (operations operations.OperationsPage, err error)

+ func (c *Client) PrevPaymentsPage(page operations.OperationsPage) (operations.OperationsPage, error)

+ func (c *Client) PrevTradesPage(page hProtocol.TradesPage) (trades hProtocol.TradesPage, err error)

+ func (c *Client) PrevTransactionsPage(page hProtocol.TransactionsPage) (transactions hProtocol.TransactionsPage, err error)

+ func (c *Client) Root() (root hProtocol.Root, err error)

+ func (c *Client) SetAuroraTimeOut(t uint) *Client

+ func (c *Client) StreamEffects(ctx context.Context, request EffectRequest, handler EffectHandler) error

+ func (c *Client) StreamLedgers(ctx context.Context, request LedgerRequest, handler LedgerHandler) error

+ func (c *Client) StreamOffers(ctx context.Context, request OfferRequest, handler OfferHandler) error

+ func (c *Client) StreamOperations(ctx context.Context, request OperationRequest, handler OperationHandler) error

+ func (c *Client) StreamOrderBooks(ctx context.Context, request OrderBookRequest, handler OrderBookHandler) error

+ func (c *Client) StreamPayments(ctx context.Context, request OperationRequest, handler OperationHandler) error

+ func (c *Client) StreamTrades(ctx context.Context, request TradeRequest, handler TradeHandler) (err error)

+ func (c *Client) StreamTransactions(ctx context.Context, request TransactionRequest, handler TransactionHandler) error

+ func (c *Client) SubmitTransaction(transaction txnbuild.Transaction) (txSuccess hProtocol.TransactionSuccess, err error)

+ func (c *Client) SubmitTransactionXDR(transactionXdr string) (txSuccess hProtocol.TransactionSuccess, err error)

+ func (c *Client) TradeAggregations(request TradeAggregationRequest) (tds hProtocol.TradeAggregationsPage, err error)

+ func (c *Client) Trades(request TradeRequest) (tds hProtocol.TradesPage, err error)

+ func (c *Client) TransactionDetail(txHash string) (tx hProtocol.Transaction, err error)

+ func (c *Client) Transactions(request TransactionRequest) (txs hProtocol.TransactionsPage, err error)

+ func (c *Client) Version() string

+ type ClientInterface interface

+ AccountData func(request AccountRequest) (hProtocol.AccountData, error)

+ AccountDetail func(request AccountRequest) (hProtocol.Account, error)

+ Assets func(request AssetRequest) (hProtocol.AssetsPage, error)

+ Effects func(request EffectRequest) (effects.EffectsPage, error)

+ FeeStats func() (hProtocol.FeeStats, error)

+ Fund func(addr string) (hProtocol.TransactionSuccess, error)

+ HomeDomainForAccount func(aid string) (string, error)

+ LedgerDetail func(sequence uint32) (hProtocol.Ledger, error)

+ Ledgers func(request LedgerRequest) (hProtocol.LedgersPage, error)

+ Metrics func() (hProtocol.Metrics, error)

+ NextAssetsPage func(hProtocol.AssetsPage) (hProtocol.AssetsPage, error)

+ NextEffectsPage func(effects.EffectsPage) (effects.EffectsPage, error)

+ NextLedgersPage func(hProtocol.LedgersPage) (hProtocol.LedgersPage, error)

+ NextOffersPage func(hProtocol.OffersPage) (hProtocol.OffersPage, error)

+ NextOperationsPage func(operations.OperationsPage) (operations.OperationsPage, error)

+ NextPaymentsPage func(operations.OperationsPage) (operations.OperationsPage, error)

+ NextTradesPage func(hProtocol.TradesPage) (hProtocol.TradesPage, error)

+ NextTransactionsPage func(hProtocol.TransactionsPage) (hProtocol.TransactionsPage, error)

+ Offers func(request OfferRequest) (hProtocol.OffersPage, error)

+ OperationDetail func(id string) (operations.Operation, error)

+ Operations func(request OperationRequest) (operations.OperationsPage, error)

+ OrderBook func(request OrderBookRequest) (hProtocol.OrderBookSummary, error)

+ Paths func(request PathsRequest) (hProtocol.PathsPage, error)

+ Payments func(request OperationRequest) (operations.OperationsPage, error)

+ PrevAssetsPage func(hProtocol.AssetsPage) (hProtocol.AssetsPage, error)

+ PrevEffectsPage func(effects.EffectsPage) (effects.EffectsPage, error)

+ PrevLedgersPage func(hProtocol.LedgersPage) (hProtocol.LedgersPage, error)

+ PrevOffersPage func(hProtocol.OffersPage) (hProtocol.OffersPage, error)

+ PrevOperationsPage func(operations.OperationsPage) (operations.OperationsPage, error)

+ PrevPaymentsPage func(operations.OperationsPage) (operations.OperationsPage, error)

+ PrevTradesPage func(hProtocol.TradesPage) (hProtocol.TradesPage, error)

+ PrevTransactionsPage func(hProtocol.TransactionsPage) (hProtocol.TransactionsPage, error)

+ Root func() (hProtocol.Root, error)

+ StreamEffects func(ctx context.Context, request EffectRequest, handler EffectHandler) error

+ StreamLedgers func(ctx context.Context, request LedgerRequest, handler LedgerHandler) error

+ StreamOffers func(ctx context.Context, request OfferRequest, handler OfferHandler) error

+ StreamOperations func(ctx context.Context, request OperationRequest, handler OperationHandler) error

+ StreamOrderBooks func(ctx context.Context, request OrderBookRequest, handler OrderBookHandler) error

+ StreamPayments func(ctx context.Context, request OperationRequest, handler OperationHandler) error

+ StreamTrades func(ctx context.Context, request TradeRequest, handler TradeHandler) error

+ StreamTransactions func(ctx context.Context, request TransactionRequest, handler TransactionHandler) error

+ SubmitTransaction func(transactionXdr txnbuild.Transaction) (hProtocol.TransactionSuccess, error)

+ SubmitTransactionXDR func(transactionXdr string) (hProtocol.TransactionSuccess, error)

+ TradeAggregations func(request TradeAggregationRequest) (hProtocol.TradeAggregationsPage, error)

+ Trades func(request TradeRequest) (hProtocol.TradesPage, error)

+ TransactionDetail func(txHash string) (hProtocol.Transaction, error)

+ Transactions func(request TransactionRequest) (hProtocol.TransactionsPage, error)

+ type EffectHandler func(effects.Effect)

+ type EffectRequest struct

+ Cursor string

+ ForAccount string

+ ForLedger string

+ ForOperation string

+ ForTransaction string

+ Limit uint

+ Order Order

+ func (er EffectRequest) BuildURL() (endpoint string, err error)

+ func (er EffectRequest) StreamEffects(ctx context.Context, client *Client, handler EffectHandler) error

+ type Error struct

+ Problem problem.P

+ Response *http.Response

+ func (herr *Error) Envelope() (*xdr.TransactionEnvelope, error)

+ func (herr *Error) EnvelopeXDR() (string, error)

+ func (herr *Error) ResultCodes() (*hProtocol.TransactionResultCodes, error)

+ func (herr *Error) ResultString() (string, error)

+ func (herr Error) Error() string

+ type HTTP interface

+ Do func(req *http.Request) (resp *http.Response, err error)

+ Get func(url string) (resp *http.Response, err error)

+ PostForm func(url string, data url.Values) (resp *http.Response, err error)

+ type LedgerHandler func(hProtocol.Ledger)

+ type LedgerRequest struct

+ Cursor string

+ Limit uint

+ Order Order

+ func (lr LedgerRequest) BuildURL() (endpoint string, err error)

+ func (lr LedgerRequest) StreamLedgers(ctx context.Context, client *Client, handler LedgerHandler) (err error)

+ type MockClient struct

+ func (m *MockClient) AccountData(request AccountRequest) (hProtocol.AccountData, error)

+ func (m *MockClient) AccountDetail(request AccountRequest) (hProtocol.Account, error)

+ func (m *MockClient) Assets(request AssetRequest) (hProtocol.AssetsPage, error)

+ func (m *MockClient) Effects(request EffectRequest) (effects.EffectsPage, error)

+ func (m *MockClient) FeeStats() (hProtocol.FeeStats, error)

+ func (m *MockClient) Fund(addr string) (hProtocol.TransactionSuccess, error)

+ func (m *MockClient) HomeDomainForAccount(aid string) (string, error)

+ func (m *MockClient) LedgerDetail(sequence uint32) (hProtocol.Ledger, error)

+ func (m *MockClient) Ledgers(request LedgerRequest) (hProtocol.LedgersPage, error)

+ func (m *MockClient) Metrics() (hProtocol.Metrics, error)

+ func (m *MockClient) NextAssetsPage(page hProtocol.AssetsPage) (hProtocol.AssetsPage, error)

+ func (m *MockClient) NextEffectsPage(page effects.EffectsPage) (effects.EffectsPage, error)

+ func (m *MockClient) NextLedgersPage(page hProtocol.LedgersPage) (hProtocol.LedgersPage, error)

+ func (m *MockClient) NextOffersPage(page hProtocol.OffersPage) (hProtocol.OffersPage, error)

+ func (m *MockClient) NextOperationsPage(page operations.OperationsPage) (operations.OperationsPage, error)

+ func (m *MockClient) NextPaymentsPage(page operations.OperationsPage) (operations.OperationsPage, error)

+ func (m *MockClient) NextTradesPage(page hProtocol.TradesPage) (hProtocol.TradesPage, error)

+ func (m *MockClient) NextTransactionsPage(page hProtocol.TransactionsPage) (hProtocol.TransactionsPage, error)

+ func (m *MockClient) Offers(request OfferRequest) (hProtocol.OffersPage, error)

+ func (m *MockClient) OperationDetail(id string) (operations.Operation, error)

+ func (m *MockClient) Operations(request OperationRequest) (operations.OperationsPage, error)

+ func (m *MockClient) OrderBook(request OrderBookRequest) (hProtocol.OrderBookSummary, error)

+ func (m *MockClient) Paths(request PathsRequest) (hProtocol.PathsPage, error)

+ func (m *MockClient) Payments(request OperationRequest) (operations.OperationsPage, error)

+ func (m *MockClient) PrevAssetsPage(page hProtocol.AssetsPage) (hProtocol.AssetsPage, error)

+ func (m *MockClient) PrevEffectsPage(page effects.EffectsPage) (effects.EffectsPage, error)

+ func (m *MockClient) PrevLedgersPage(page hProtocol.LedgersPage) (hProtocol.LedgersPage, error)

+ func (m *MockClient) PrevOffersPage(page hProtocol.OffersPage) (hProtocol.OffersPage, error)

+ func (m *MockClient) PrevOperationsPage(page operations.OperationsPage) (operations.OperationsPage, error)

+ func (m *MockClient) PrevPaymentsPage(page operations.OperationsPage) (operations.OperationsPage, error)

+ func (m *MockClient) PrevTradesPage(page hProtocol.TradesPage) (hProtocol.TradesPage, error)

+ func (m *MockClient) PrevTransactionsPage(page hProtocol.TransactionsPage) (hProtocol.TransactionsPage, error)

+ func (m *MockClient) Root() (hProtocol.Root, error)

+ func (m *MockClient) StreamEffects(ctx context.Context, request EffectRequest, handler EffectHandler) error

+ func (m *MockClient) StreamLedgers(ctx context.Context, request LedgerRequest, handler LedgerHandler) error

+ func (m *MockClient) StreamOffers(ctx context.Context, request OfferRequest, handler OfferHandler) error

+ func (m *MockClient) StreamOperations(ctx context.Context, request OperationRequest, handler OperationHandler) error

+ func (m *MockClient) StreamOrderBooks(ctx context.Context, request OrderBookRequest, handler OrderBookHandler) error

+ func (m *MockClient) StreamPayments(ctx context.Context, request OperationRequest, handler OperationHandler) error

+ func (m *MockClient) StreamTrades(ctx context.Context, request TradeRequest, handler TradeHandler) error

+ func (m *MockClient) StreamTransactions(ctx context.Context, request TransactionRequest, handler TransactionHandler) error

+ func (m *MockClient) SubmitTransaction(transaction txnbuild.Transaction) (hProtocol.TransactionSuccess, error)

+ func (m *MockClient) SubmitTransactionXDR(transactionXdr string) (hProtocol.TransactionSuccess, error)

+ func (m *MockClient) TradeAggregations(request TradeAggregationRequest) (hProtocol.TradeAggregationsPage, error)

+ func (m *MockClient) Trades(request TradeRequest) (hProtocol.TradesPage, error)

+ func (m *MockClient) TransactionDetail(txHash string) (hProtocol.Transaction, error)

+ func (m *MockClient) Transactions(request TransactionRequest) (hProtocol.TransactionsPage, error)

+ type OfferHandler func(hProtocol.Offer)

+ type OfferRequest struct

+ Cursor string

+ ForAccount string

+ Limit uint

+ Order Order

+ func (or OfferRequest) BuildURL() (endpoint string, err error)

+ func (or OfferRequest) StreamOffers(ctx context.Context, client *Client, handler OfferHandler) (err error)

+ type OperationHandler func(operations.Operation)

+ type OperationRequest struct

+ Cursor string

+ ForAccount string

+ ForLedger uint

+ ForTransaction string

+ IncludeFailed bool

+ Limit uint

+ Order Order

+ func (op *OperationRequest) SetOperationsEndpoint() *OperationRequest

+ func (op *OperationRequest) SetPaymentsEndpoint() *OperationRequest

+ func (op OperationRequest) BuildURL() (endpoint string, err error)

+ func (op OperationRequest) StreamOperations(ctx context.Context, client *Client, handler OperationHandler) error

+ type Order string

+ type OrderBookHandler func(hProtocol.OrderBookSummary)

+ type OrderBookRequest struct

+ BuyingAssetCode string

+ BuyingAssetIssuer string

+ BuyingAssetType AssetType

+ Limit uint

+ SellingAssetCode string

+ SellingAssetIssuer string

+ SellingAssetType AssetType

+ func (obr OrderBookRequest) BuildURL() (endpoint string, err error)

+ func (obr OrderBookRequest) StreamOrderBooks(ctx context.Context, client *Client, handler OrderBookHandler) error

+ type PathsRequest struct

+ DestinationAccount string

+ DestinationAmount string

+ DestinationAssetCode string

+ DestinationAssetIssuer string

+ DestinationAssetType AssetType

+ SourceAccount string

+ func (pr PathsRequest) BuildURL() (endpoint string, err error)

+ type ServerTimeRecord struct

+ LocalTimeRecorded int64

+ ServerTime int64

+ type TradeAggregationRequest struct

+ BaseAssetCode string

+ BaseAssetIssuer string

+ BaseAssetType AssetType

+ CounterAssetCode string

+ CounterAssetIssuer string

+ CounterAssetType AssetType

+ EndTime time.Time

+ Limit uint

+ Offset time.Duration

+ Order Order

+ Resolution time.Duration

+ StartTime time.Time

+ func (ta TradeAggregationRequest) BuildURL() (endpoint string, err error)

+ type TradeHandler func(hProtocol.Trade)

+ type TradeRequest struct

+ BaseAssetCode string

+ BaseAssetIssuer string

+ BaseAssetType AssetType

+ CounterAssetCode string

+ CounterAssetIssuer string

+ CounterAssetType AssetType

+ Cursor string

+ ForAccount string

+ ForOfferID string

+ Limit uint

+ Order Order

+ func (tr TradeRequest) BuildURL() (endpoint string, err error)

+ func (tr TradeRequest) StreamTrades(ctx context.Context, client *Client, handler TradeHandler) (err error)

+ type TransactionHandler func(hProtocol.Transaction)

+ type TransactionRequest struct

+ Cursor string

+ ForAccount string

+ ForLedger uint

+ IncludeFailed bool

+ Limit uint

+ Order Order

+ func (tr TransactionRequest) BuildURL() (endpoint string, err error)

+ func (tr TransactionRequest) StreamTransactions(ctx context.Context, client *Client, handler TransactionHandler) (err error)

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