horizon

Documentation

Index

• Constants
• func ApplyFlags(config *Config, flags support.ConfigOptions)
• type App
  • func NewApp(config Config) (*App, error)
  • func NewAppFromFlags(config *Config, flags support.ConfigOptions) *App
  • func (a *App) Close()
  • func (a *App) CloseDB()
  • func (a *App) DeleteUnretainedHistory() error
  • func (a *App) GetCoreSettings() actions.CoreSettings
  • func (a *App) HistoryQ() *history.Q
  • func (a *App) HorizonSession(ctx context.Context) *db.Session
  • func (a *App) Ingestion() ingest.System
  • func (a *App) Serve()
  • func (a *App) Tick()
  • func (a *App) UpdateFeeStatsState()
  • func (a *App) UpdateLedgerState()
  • func (a *App) UpdateStellarCoreInfo()
• type Config
  • func Flags() (*Config, support.ConfigOptions)

Constants

const (
	// DatabaseURLFlagName is the command line flag for configuring the Horizon postgres URL
	DatabaseURLFlagName = "db-url"
	// StellarCoreDBURLFlagName is the command line flag for configuring the postgres Stellar Core URL
	StellarCoreDBURLFlagName = "stellar-core-db-url"
	// StellarCoreDBURLFlagName is the command line flag for configuring the URL fore Stellar Core HTTP endpoint
	StellarCoreURLFlagName = "stellar-core-url"
	// StellarCoreBinaryPathName is the command line flag for configuring the path to the stellar core binary
	StellarCoreBinaryPathName = "stellar-core-binary-path"
	// CaptiveCoreConfigAppendPathName is the command line flag for configuring the path to the captive core additional configuration
	CaptiveCoreConfigAppendPathName = "captive-core-config-append-path"
)

Functions

func ApplyFlags

func ApplyFlags(config *Config, flags support.ConfigOptions)

ApplyFlags applies the command line flags on the given Config instance

Types

type App

type App struct {
	// contains filtered or unexported fields
}

App represents the root of the state of a horizon instance.

func NewApp

func NewApp(config Config) (*App, error)

NewApp constructs an new App instance from the provided config.

func NewAppFromFlags

func NewAppFromFlags(config *Config, flags support.ConfigOptions) *App

NewAppFromFlags constructs a new Horizon App from the given command line flags

func (*App) Close

func (a *App) Close()

Close cancels the app. It does not close DB connections - use App.CloseDB().

func (*App) CloseDB

func (a *App) CloseDB()

CloseDB closes DB connections. When using during web server shut down make sure all requests are first properly finished to avoid "sql: database is closed" errors.

func (*App) DeleteUnretainedHistory

func (a *App) DeleteUnretainedHistory() error

DeleteUnretainedHistory forwards to the app's reaper. See `reap.DeleteUnretainedHistory` for details

func (*App) GetCoreSettings

func (a *App) GetCoreSettings() actions.CoreSettings

func (*App) HistoryQ

func (a *App) HistoryQ() *history.Q

HistoryQ returns a helper object for performing sql queries against the history portion of horizon's database.

func (*App) HorizonSession

func (a *App) HorizonSession(ctx context.Context) *db.Session

HorizonSession returns a new session that loads data from the horizon database. The returned session is bound to `ctx`.

func (*App) Ingestion

func (a *App) Ingestion() ingest.System

Ingestion returns the ingestion system associated with this Horizon instance

func (*App) Serve

func (a *App) Serve()

Serve starts the horizon web server, binding it to a socket, setting up the shutdown signals.

func (*App) Tick

func (a *App) Tick()

Tick triggers horizon to update all of it's background processes such as transaction submission, metrics, ingestion and reaping.

func (*App) UpdateFeeStatsState

func (a *App) UpdateFeeStatsState()

UpdateFeeStatsState triggers a refresh of several operation fee metrics.

func (*App) UpdateLedgerState

func (a *App) UpdateLedgerState()

UpdateLedgerState triggers a refresh of several metrics gauges, such as open db connections and ledger state

func (*App) UpdateStellarCoreInfo

func (a *App) UpdateStellarCoreInfo()

UpdateStellarCoreInfo updates the value of CoreVersion, CurrentProtocolVersion, and CoreSupportedProtocolVersion from the Stellar core API.

type Config

type Config struct {
	DatabaseURL        string
	HistoryArchiveURLs []string
	Port               uint
	AdminPort          uint

	EnableCaptiveCoreIngestion  bool
	CaptiveCoreBinaryPath       string
	CaptiveCoreConfigAppendPath string
	RemoteCaptiveCoreURL        string
	CaptiveCoreHTTPPort         uint

	StellarCoreDatabaseURL string
	StellarCoreURL         string

	// MaxDBConnections has a priority over all 4 values below.
	MaxDBConnections            int
	HorizonDBMaxOpenConnections int
	HorizonDBMaxIdleConnections int

	SSEUpdateFrequency time.Duration
	ConnectionTimeout  time.Duration
	RateQuota          *throttled.RateQuota
	FriendbotURL       *url.URL
	LogLevel           logrus.Level
	LogFile            string
	// MaxPathLength is the maximum length of the path returned by `/paths` endpoint.
	MaxPathLength     uint
	NetworkPassphrase string
	SentryDSN         string
	LogglyToken       string
	LogglyTag         string
	// TLSCert is a path to a certificate file to use for horizon's TLS config
	TLSCert string
	// TLSKey is the path to a private key file to use for horizon's TLS config
	TLSKey string
	// Ingest toggles whether this horizon instance should run the data ingestion subsystem.
	Ingest bool
	// CursorName is the cursor used for ingesting from stellar-core.
	// Setting multiple cursors in different Horizon instances allows multiple
	// Horizons to ingest from the same stellar-core instance without cursor
	// collisions.
	CursorName string
	// HistoryRetentionCount represents the minimum number of ledgers worth of
	// history data to retain in the horizon database. For the purposes of
	// determining a "retention duration", each ledger roughly corresponds to 10
	// seconds of real time.
	HistoryRetentionCount uint
	// StaleThreshold represents the number of ledgers a history database may be
	// out-of-date by before horizon begins to respond with an error to history
	// requests.
	StaleThreshold uint
	// SkipCursorUpdate causes the ingestor to skip reporting the "last imported
	// ledger" state to stellar-core.
	SkipCursorUpdate bool
	// IngestDisableStateVerification disables state verification
	// `System.verifyState()` when set to `true`.
	IngestDisableStateVerification bool
	// ApplyMigrations will apply pending migrations to the horizon database
	// before starting the horizon service
	ApplyMigrations bool
	// CheckpointFrequency establishes how many ledgers exist between checkpoints
	CheckpointFrequency uint32
}

Config is the configuration for horizon. It gets populated by the app's main function and is provided to NewApp.

func Flags

func Flags() (*Config, support.ConfigOptions)

Flags returns a Config instance and a list of commandline flags which modify the Config instance