Versions in this module Expand all Collapse all v2 v2.0.1 Jun 3, 2020 Changes in this version + const LRUCacheSize + func HandleMetrics(action metricsAction) http.HandlerFunc + func NewHistoryMiddleware(staleThreshold int32, session *db.Session) func(http.Handler) http.Handler + type Action struct + App *App + Log *log.Entry + func (action *Action) CoreQ() *core.Q + func (action *Action) EnsureHistoryFreshness() + func (action *Action) FullURL() *url.URL + func (action *Action) HistoryQ() *history.Q + func (action *Action) Prepare(w http.ResponseWriter, r *http.Request) + func (action *Action) ValidateCursorAsDefault() + func (action *Action) ValidateCursorWithinHistory() + type App struct + func AppFromContext(ctx context.Context) *App + func NewApp(config Config) *App + func (a *App) Close() + func (a *App) CloseDB() + func (a *App) CoreQ() *core.Q + func (a *App) CoreSession(ctx context.Context) *db.Session + func (a *App) DeleteUnretainedHistory() error + func (a *App) GetRateLimiter() *throttled.HTTPRateLimiter + func (a *App) HistoryQ() *history.Q + func (a *App) HorizonSession(ctx context.Context) *db.Session + func (a *App) IsHistoryStale() bool + func (a *App) Serve() + func (a *App) Tick() + func (a *App) UpdateFeeStatsState() + func (a *App) UpdateLedgerState() + func (a *App) UpdateMetrics() + func (a *App) UpdateStellarCoreInfo() + type Config struct + AdminPort uint + ApplyMigrations bool + ConnectionTimeout time.Duration + CoreDBMaxIdleConnections int + CoreDBMaxOpenConnections int + CursorName string + DatabaseURL string + FriendbotURL *url.URL + HistoryArchiveURLs []string + HistoryRetentionCount uint + HorizonDBMaxIdleConnections int + HorizonDBMaxOpenConnections int + Ingest bool + IngestDisableStateVerification bool + IngestFailedTransactions bool + LogFile string + LogLevel logrus.Level + LogglyTag string + LogglyToken string + MaxDBConnections int + MaxPathLength uint + NetworkPassphrase string + Port uint + RateQuota *throttled.RateQuota + SSEUpdateFrequency time.Duration + SentryDSN string + SkipCursorUpdate bool + StaleThreshold uint + StellarCoreDatabaseURL string + StellarCoreURL string + TLSCert string + TLSKey string + type DataShowAction struct + Address string + Data history.Data + Key string + func (action *DataShowAction) JSON() error + func (action *DataShowAction) Raw() error + func (action *DataShowAction) SSE(stream *sse.Stream) error + func (action DataShowAction) Handle(w http.ResponseWriter, r *http.Request) + type EffectIndexAction struct + AccountFilter string + LedgerFilter int32 + Ledgers *history.LedgerCache + OperationFilter int64 + Page hal.Page + PagingParams db2.PageQuery + Records []history.Effect + TransactionFilter string + func (action *EffectIndexAction) JSON() error + func (action *EffectIndexAction) SSE(stream *sse.Stream) error + func (action *EffectIndexAction) ValidateCursor() + func (action EffectIndexAction) Handle(w http.ResponseWriter, r *http.Request) + type FeeStatsAction struct + func (action *FeeStatsAction) JSON() error + func (action FeeStatsAction) Handle(w http.ResponseWriter, r *http.Request) + type FindFixedPathsHandler struct + func (handler FindFixedPathsHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) + type FindFixedPathsQuery struct + DestinationAccount string + DestinationAssets string + SourceAmount string + SourceAssetCode string + SourceAssetIssuer string + SourceAssetType string + func (q FindFixedPathsQuery) Amount() xdr.Int64 + func (q FindFixedPathsQuery) Assets() ([]xdr.Asset, error) + func (q FindFixedPathsQuery) SourceAsset() xdr.Asset + func (q FindFixedPathsQuery) URITemplate() string + func (q FindFixedPathsQuery) Validate() error + type FindPathsHandler struct + func (handler FindPathsHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) + type LedgerIndexAction struct + Page hal.Page + PagingParams db2.PageQuery + Records []history.Ledger + func (action *LedgerIndexAction) JSON() error + func (action *LedgerIndexAction) SSE(stream *sse.Stream) error + func (action LedgerIndexAction) Handle(w http.ResponseWriter, r *http.Request) + type LedgerShowAction struct + Record history.Ledger + Sequence int32 + func (action *LedgerShowAction) JSON() error + func (action LedgerShowAction) Handle(w http.ResponseWriter, r *http.Request) + type NotFoundAction struct + func (action *NotFoundAction) JSON() error + func (action NotFoundAction) Handle(w http.ResponseWriter, r *http.Request) + type NotImplementedAction struct + func (action *NotImplementedAction) JSON() error + func (action NotImplementedAction) Handle(w http.ResponseWriter, r *http.Request) + type OperationShowAction struct + ID int64 + IncludeTransactions bool + Ledger history.Ledger + OperationRecord history.Operation + Resource interface{} + TransactionRecord *history.Transaction + func (action *OperationShowAction) JSON() error + func (action OperationShowAction) Handle(w http.ResponseWriter, r *http.Request) + type RateLimitExceededAction struct + func (action RateLimitExceededAction) Handle(w http.ResponseWriter, r *http.Request) + func (action RateLimitExceededAction) ServeHTTP(w http.ResponseWriter, r *http.Request) + type RootAction struct + func (action *RootAction) JSON() error + func (action RootAction) Handle(w http.ResponseWriter, r *http.Request) + type StateMiddleware struct + HorizonSession *db.Session + NoStateVerification bool + func (m *StateMiddleware) Wrap(h http.Handler) http.Handler + func (m *StateMiddleware) WrapFunc(h http.HandlerFunc) http.HandlerFunc + type StrictReceivePathsQuery struct + DestinationAccount string + DestinationAmount string + DestinationAssetCode string + DestinationAssetIssuer string + DestinationAssetType string + SourceAccount string + SourceAssets string + func (q StrictReceivePathsQuery) Amount() xdr.Int64 + func (q StrictReceivePathsQuery) Assets() ([]xdr.Asset, error) + func (q StrictReceivePathsQuery) DestinationAsset() xdr.Asset + func (q StrictReceivePathsQuery) URITemplate() string + func (q StrictReceivePathsQuery) Validate() error + type TradeAggregateIndexAction struct + BaseAssetFilter xdr.Asset + CounterAssetFilter xdr.Asset + EndTimeFilter time.Millis + OffsetFilter int64 + Page hal.Page + PagingParams db2.PageQuery + Records []history.TradeAggregation + ResolutionFilter int64 + StartTimeFilter time.Millis + func (action *TradeAggregateIndexAction) JSON() error + func (action TradeAggregateIndexAction) Handle(w http.ResponseWriter, r *http.Request) + type TradeIndexAction struct + AccountFilter string + BaseAssetFilter xdr.Asset + CounterAssetFilter xdr.Asset + HasBaseAssetFilter bool + HasCounterAssetFilter bool + OfferFilter int64 + Page hal.Page + PagingParams db2.PageQuery + Records []history.Trade + func (action *TradeIndexAction) JSON() error + func (action *TradeIndexAction) SSE(stream *sse.Stream) error + func (action TradeIndexAction) Handle(w http.ResponseWriter, r *http.Request) + type TransactionCreateAction struct + Resource horizon.Transaction + Result txsub.Result + TX envelopeInfo + func (action *TransactionCreateAction) JSON() error + func (action TransactionCreateAction) Handle(w http.ResponseWriter, r *http.Request) + type VaryByRemoteIP struct + func (v VaryByRemoteIP) Key(r *http.Request) string