reflector

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

type ReflectorConfig struct {
	LDBPath          string
	ChangelogPath    string
	ChangelogSize    int
	Upstream         UpstreamConfig
	BootstrapURL     string
	LedgerHealth     ledger.HealthConfig
	IsSupervisor     bool
	LDBWriteCallback ldbwriter.LDBWriteCallback // optional
	BootstrapRegion  string                     // optional
}

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

type ReflectorI interface {
	Start(ctx context.Context) error
	Close() error
}

type S3Client interface {
	s3iface.S3API
}

type S3Downloader struct {
	Region              string // optional
	Bucket              string
	Key                 string
	S3Client            S3Client
	StartOverOnNotFound bool // whether or not we should rebuild LDB if snapshot not found
}

type UpstreamConfig struct {
	Driver                string
	DSN                   string
	LedgerTable           string
	QueryBlockSize        int
	PollInterval          time.Duration
	PollTimeout           time.Duration
	PollJitterCoefficient float64
}