Versions in this module Expand all Collapse all v0 v0.0.1 Nov 25, 2022 Changes in this version + const AssetType12 + const AssetType4 + const AssetTypeNative + const OrderAsc + const OrderDesc + var DayResolution = time.Duration(24 * time.Hour) + var DefaultPublicNetClient = &Client + var DefaultTestNetClient = &Client + var ErrAccountRequiresMemo = errors.New("destination account requires a memo in the transaction") + 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 HorizonTimeout = 60 * time.Second + 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) + func IsNotFoundError(err error) bool + type AccountRequest struct + AccountID string + DataKey string + func (ar AccountRequest) BuildURL() (endpoint string, err error) + func (ar AccountRequest) HTTPRequest(horizonURL 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(horizonURL 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 struct + Cursor string + ForAssetCode string + ForAssetIssuer string + Limit uint + Order Order + func (ar AssetRequest) BuildURL() (endpoint string, err error) + func (ar AssetRequest) HTTPRequest(horizonURL string) (*http.Request, error) + type AssetType string + 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(horizonURL string) (*http.Request, error) + type Client struct + AppName string + AppVersion string + HTTP HTTP + HorizonURL string + 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) Accounts(request AccountsRequest) (accounts hProtocol.AccountsPage, err error) + func (c *Client) Assets(request AssetRequest) (assets hProtocol.AssetsPage, err error) + 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) 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) (tx hProtocol.Transaction, err error) + func (c *Client) HomeDomainForAccount(aid string) (string, error) + func (c *Client) HorizonTimeout() time.Duration + 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) 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) 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) NextLiquidityPoolsPage(page hProtocol.LiquidityPoolsPage) (lp hProtocol.LiquidityPoolsPage, 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) NextTradeAggregationsPage(page hProtocol.TradeAggregationsPage) (ta hProtocol.TradeAggregationsPage, err 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) OfferDetails(offerID string) (offer hProtocol.Offer, 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) PrevLiquidityPoolsPage(page hProtocol.LiquidityPoolsPage) (lp hProtocol.LiquidityPoolsPage, 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) PrevTradeAggregationsPage(page hProtocol.TradeAggregationsPage) (ta hProtocol.TradeAggregationsPage, err 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) SetHorizonTimeout(t time.Duration) *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) 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) SubmitTransaction(transaction *txnbuild.Transaction) (tx hProtocol.Transaction, err error) + func (c *Client) SubmitTransactionWithOptions(transaction *txnbuild.Transaction, opts SubmitTxOpts) (tx hProtocol.Transaction, err error) + func (c *Client) SubmitTransactionXDR(transactionXdr string) (tx hProtocol.Transaction, 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) + Accounts func(request AccountsRequest) (hProtocol.AccountsPage, 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.Transaction, error) + HomeDomainForAccount func(aid string) (string, error) + LedgerDetail func(sequence uint32) (hProtocol.Ledger, error) + Ledgers func(request LedgerRequest) (hProtocol.LedgersPage, error) + LiquidityPoolDetail func(request LiquidityPoolRequest) (hProtocol.LiquidityPool, error) + LiquidityPools func(request LiquidityPoolsRequest) (hProtocol.LiquidityPoolsPage, error) + NextAccountsPage func(hProtocol.AccountsPage) (hProtocol.AccountsPage, error) + NextAssetsPage func(hProtocol.AssetsPage) (hProtocol.AssetsPage, error) + NextEffectsPage func(effects.EffectsPage) (effects.EffectsPage, error) + NextLedgersPage func(hProtocol.LedgersPage) (hProtocol.LedgersPage, error) + NextLiquidityPoolsPage func(hProtocol.LiquidityPoolsPage) (hProtocol.LiquidityPoolsPage, error) + NextOffersPage func(hProtocol.OffersPage) (hProtocol.OffersPage, error) + NextOperationsPage func(operations.OperationsPage) (operations.OperationsPage, error) + NextPaymentsPage func(operations.OperationsPage) (operations.OperationsPage, error) + NextTradeAggregationsPage func(hProtocol.TradeAggregationsPage) (hProtocol.TradeAggregationsPage, error) + NextTradesPage func(hProtocol.TradesPage) (hProtocol.TradesPage, error) + NextTransactionsPage func(hProtocol.TransactionsPage) (hProtocol.TransactionsPage, error) + OfferDetails func(offerID string) (offer hProtocol.Offer, err 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) + PrevLiquidityPoolsPage func(hProtocol.LiquidityPoolsPage) (hProtocol.LiquidityPoolsPage, error) + PrevOffersPage func(hProtocol.OffersPage) (hProtocol.OffersPage, error) + PrevOperationsPage func(operations.OperationsPage) (operations.OperationsPage, error) + PrevPaymentsPage func(operations.OperationsPage) (operations.OperationsPage, error) + PrevTradeAggregationsPage func(hProtocol.TradeAggregationsPage) (hProtocol.TradeAggregationsPage, 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 + SubmitFeeBumpTransaction func(transaction *txnbuild.FeeBumpTransaction) (hProtocol.Transaction, error) + SubmitFeeBumpTransactionWithOptions func(transaction *txnbuild.FeeBumpTransaction, opts SubmitTxOpts) (hProtocol.Transaction, error) + SubmitTransaction func(transaction *txnbuild.Transaction) (hProtocol.Transaction, error) + SubmitTransactionWithOptions func(transaction *txnbuild.Transaction, opts SubmitTxOpts) (hProtocol.Transaction, error) + SubmitTransactionXDR func(transactionXdr string) (hProtocol.Transaction, 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 + ForLiquidityPool string + ForOperation string + ForTransaction string + Limit uint + Order Order + func (er EffectRequest) BuildURL() (endpoint string, err error) + func (er EffectRequest) HTTPRequest(horizonURL string) (*http.Request, error) + func (er EffectRequest) StreamEffects(ctx context.Context, client *Client, handler EffectHandler) error + type Error struct + Problem problem.P + Response *http.Response + func GetError(err error) *Error + 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 HorizonRequest interface + BuildURL func() (string, error) + HTTPRequest func(horizonURL string) (*http.Request, 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) HTTPRequest(horizonURL string) (*http.Request, error) + func (lr LedgerRequest) StreamLedgers(ctx context.Context, client *Client, handler LedgerHandler) (err error) + type LiquidityPoolRequest struct + LiquidityPoolID string + func (r LiquidityPoolRequest) BuildURL() (endpoint string, err error) + func (r LiquidityPoolRequest) HTTPRequest(horizonURL 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(horizonURL 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 struct + func (m *MockClient) AccountData(request AccountRequest) (hProtocol.AccountData, error) + func (m *MockClient) AccountDetail(request AccountRequest) (hProtocol.Account, error) + func (m *MockClient) Accounts(request AccountsRequest) (hProtocol.AccountsPage, 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.Transaction, 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) 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) 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) NextLiquidityPoolsPage(page hProtocol.LiquidityPoolsPage) (hProtocol.LiquidityPoolsPage, 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) NextTradeAggregationsPage(page hProtocol.TradeAggregationsPage) (hProtocol.TradeAggregationsPage, error) + func (m *MockClient) NextTradesPage(page hProtocol.TradesPage) (hProtocol.TradesPage, error) + func (m *MockClient) NextTransactionsPage(page hProtocol.TransactionsPage) (hProtocol.TransactionsPage, error) + func (m *MockClient) OfferDetails(offerID string) (hProtocol.Offer, 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) PrevLiquidityPoolsPage(page hProtocol.LiquidityPoolsPage) (hProtocol.LiquidityPoolsPage, 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) PrevTradeAggregationsPage(page hProtocol.TradeAggregationsPage) (hProtocol.TradeAggregationsPage, 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) SubmitFeeBumpTransaction(transaction *txnbuild.FeeBumpTransaction) (hProtocol.Transaction, error) + func (m *MockClient) SubmitFeeBumpTransactionWithOptions(transaction *txnbuild.FeeBumpTransaction, opts SubmitTxOpts) (hProtocol.Transaction, error) + func (m *MockClient) SubmitTransaction(transaction *txnbuild.Transaction) (hProtocol.Transaction, error) + func (m *MockClient) SubmitTransactionWithOptions(transaction *txnbuild.Transaction, opts SubmitTxOpts) (hProtocol.Transaction, error) + func (m *MockClient) SubmitTransactionXDR(transactionXdr string) (hProtocol.Transaction, 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 + Buying string + Cursor string + ForAccount string + Limit uint + OfferID string + Order Order + Seller string + Selling string + func (or OfferRequest) BuildURL() (endpoint string, err error) + func (or OfferRequest) HTTPRequest(horizonURL string) (*http.Request, 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 + ForClaimableBalance string + ForLedger uint + ForLiquidityPool string + ForTransaction string + IncludeFailed bool + Join string + 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) HTTPRequest(horizonURL string) (*http.Request, 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) HTTPRequest(horizonURL string) (*http.Request, 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 + SourceAssets string + func (pr PathsRequest) BuildURL() (endpoint string, err error) + func (pr PathsRequest) HTTPRequest(horizonURL string) (*http.Request, error) + type ServerTimeRecord struct + LocalTimeRecorded int64 + ServerTime int64 + 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(horizonURL string) (*http.Request, error) + type SubmitTxOpts struct + SkipMemoRequiredCheck bool + 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) + func (ta TradeAggregationRequest) HTTPRequest(horizonURL string) (*http.Request, 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 + ForLiquidityPool string + ForOfferID string + Limit uint + Order Order + TradeType string + func (tr TradeRequest) BuildURL() (endpoint string, err error) + func (tr TradeRequest) HTTPRequest(horizonURL string) (*http.Request, 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 + ForClaimableBalance string + ForLedger uint + ForLiquidityPool string + IncludeFailed bool + Limit uint + Order Order + func (tr TransactionRequest) BuildURL() (endpoint string, err error) + func (tr TransactionRequest) HTTPRequest(horizonURL string) (*http.Request, error) + func (tr TransactionRequest) StreamTransactions(ctx context.Context, client *Client, handler TransactionHandler) (err error) + type UniversalTimeHandler func() int64
Go to main page