Versions in this module Expand all Collapse all v0 v0.0.1 Nov 25, 2022 Changes in this version + func ValidateLedgerRange(start, end, latestNum uint32) error + type Base64Ledger xdr.LedgerCloseMeta + func (r *Base64Ledger) UnmarshalJSON(b []byte) error + func (r Base64Ledger) MarshalJSON() ([]byte, error) + type CaptiveCoreConfig struct + BinaryPath string + CheckpointFrequency uint32 + Context context.Context + HistoryArchiveURLs []string + LedgerHashStore TrustedLedgerHashStore + Log *log.Entry + NetworkPassphrase string + StoragePath string + Toml *CaptiveCoreToml + UseDB bool + UserAgent string + type CaptiveCoreToml struct + func NewCaptiveCoreToml(params CaptiveCoreTomlParams) (*CaptiveCoreToml, error) + func NewCaptiveCoreTomlFromFile(configPath string, params CaptiveCoreTomlParams) (*CaptiveCoreToml, error) + func (c *CaptiveCoreToml) AddExamplePubnetValidators() + func (c *CaptiveCoreToml) CatchupToml() (*CaptiveCoreToml, error) + func (c *CaptiveCoreToml) HistoryIsConfigured() bool + func (c *CaptiveCoreToml) Marshal() ([]byte, error) + func (c *CaptiveCoreToml) QuorumSetIsConfigured() bool + type CaptiveCoreTomlParams struct + HTTPPort *uint + HistoryArchiveURLs []string + LogPath *string + NetworkPassphrase string + PeerPort *uint + Strict bool + UseDB bool + type CaptiveStellarCore struct + func NewCaptive(config CaptiveCoreConfig) (*CaptiveStellarCore, error) + func (c *CaptiveStellarCore) Close() error + func (c *CaptiveStellarCore) GetLatestLedgerSequence(ctx context.Context) (uint32, error) + func (c *CaptiveStellarCore) GetLedger(ctx context.Context, sequence uint32) (xdr.LedgerCloseMeta, error) + func (c *CaptiveStellarCore) IsPrepared(ctx context.Context, ledgerRange Range) (bool, error) + func (c *CaptiveStellarCore) PrepareRange(ctx context.Context, ledgerRange Range) error + type DatabaseBackend struct + func NewDatabaseBackend(dataSourceName, networkPassphrase string) (*DatabaseBackend, error) + func NewDatabaseBackendFromSession(session db.SessionInterface, networkPassphrase string) (*DatabaseBackend, error) + func (*DatabaseBackend) IsPrepared(ctx context.Context, ledgerRange Range) (bool, error) + func (dbb *DatabaseBackend) Close() error + func (dbb *DatabaseBackend) GetLatestLedgerSequence(ctx context.Context) (uint32, error) + func (dbb *DatabaseBackend) GetLedger(ctx context.Context, sequence uint32) (xdr.LedgerCloseMeta, error) + func (dbb *DatabaseBackend) PrepareRange(ctx context.Context, ledgerRange Range) error + type GCSBackend struct + GCSBackendLock sync.RWMutex + GCSBackendRunner stellarCoreRunnerInterface + GCSBackendRunnerFactory func() stellarCoreRunnerInterface + func (b *GCSBackend) Close() error + func (b *GCSBackend) GetLatestLedgerSequence(ctx context.Context) (uint32, error) + func (b *GCSBackend) GetLedger(ctx context.Context, sequence uint32) (xdr.LedgerCloseMeta, error) + func (b *GCSBackend) IsPrepared(ctx context.Context, ledgerRange Range) (bool, error) + func (b *GCSBackend) PrepareRange(ctx context.Context, ledgerRange Range) error + type History struct + Get string + Mkdir string + Put string + type HomeDomain struct + HomeDomain string + Quality string + type HorizonDBLedgerHashStore struct + func (h HorizonDBLedgerHashStore) Close() error + func (h HorizonDBLedgerHashStore) GetLedgerHash(ctx context.Context, seq uint32) (string, bool, error) + type LatestLedgerSequenceResponse struct + Sequence uint32 + type LedgerBackend interface + Close func() error + GetLatestLedgerSequence func(ctx context.Context) (sequence uint32, err error) + GetLedger func(ctx context.Context, sequence uint32) (xdr.LedgerCloseMeta, error) + IsPrepared func(ctx context.Context, ledgerRange Range) (bool, error) + PrepareRange func(ctx context.Context, ledgerRange Range) error + func CreateGCSBackend(gcsCredentials, bucketName string, start, end uint32) (LedgerBackend, error) + type LedgerResponse struct + Ledger Base64Ledger + type MockDatabaseBackend struct + func (m *MockDatabaseBackend) Close() error + func (m *MockDatabaseBackend) GetLatestLedgerSequence(ctx context.Context) (uint32, error) + func (m *MockDatabaseBackend) GetLedger(ctx context.Context, sequence uint32) (xdr.LedgerCloseMeta, error) + func (m *MockDatabaseBackend) IsPrepared(ctx context.Context, ledgerRange Range) (bool, error) + func (m *MockDatabaseBackend) PrepareRange(ctx context.Context, ledgerRange Range) error + type MockLedgerHashStore struct + func (m *MockLedgerHashStore) Close() error + func (m *MockLedgerHashStore) GetLedgerHash(ctx context.Context, seq uint32) (string, bool, error) + type PrepareRangeResponse struct + LedgerRange Range + Ready bool + ReadyDuration int + StartTime time.Time + type QuorumSet struct + ThresholdPercent int + Validators []string + type Range struct + func BoundedRange(from uint32, to uint32) Range + func SingleLedgerRange(ledger uint32) Range + func UnboundedRange(from uint32) Range + func (r *Range) UnmarshalJSON(b []byte) error + func (r Range) Contains(other Range) bool + func (r Range) MarshalJSON() ([]byte, error) + func (r Range) String() string + type RemoteCaptiveOption func(c *RemoteCaptiveStellarCore) + func PrepareRangePollInterval(d time.Duration) RemoteCaptiveOption + type RemoteCaptiveStellarCore struct + func NewRemoteCaptive(captiveCoreURL string, options ...RemoteCaptiveOption) (RemoteCaptiveStellarCore, error) + func (c RemoteCaptiveStellarCore) Close() error + func (c RemoteCaptiveStellarCore) GetLatestLedgerSequence(ctx context.Context) (sequence uint32, err error) + func (c RemoteCaptiveStellarCore) GetLedger(ctx context.Context, sequence uint32) (xdr.LedgerCloseMeta, error) + func (c RemoteCaptiveStellarCore) IsPrepared(ctx context.Context, ledgerRange Range) (bool, error) + func (c RemoteCaptiveStellarCore) PrepareRange(ctx context.Context, ledgerRange Range) error + type TrustedLedgerHashStore interface + Close func() error + GetLedgerHash func(ctx context.Context, seq uint32) (string, bool, error) + func NewHorizonDBLedgerHashStore(session db.SessionInterface) TrustedLedgerHashStore + type Validator struct + Address string + History string + HomeDomain string + Name string + PublicKey string + Quality string