reflector

type DownloadMetric struct {
	StartTime  int    `json:"startTime,omitempty"`
	Downloaded string `json:"downloaded"`
	Compressed string `json:"compressed"`
}

type MonitorConfig struct {
	PollInterval               time.Duration
	Path                       string
	WALCheckpointThresholdSize int64
}

type MonitorOps func(config *WALMonitor)

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
	// How often to poll the WAL stats
	WALPollInterval time.Duration // optional
	// Performs a checkpoint after the WAL file exceeds this size in bytes
	WALCheckpointThresholdSize int // optional
	// What type of checkpoint to perform
	WALCheckpointType ldbwriter.CheckpointType // optional
	DoMonitorWAL      bool                     // optional
	BusyTimeoutMS     int                      // optional
	ID                string
	Logger            *events.Logger
}

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 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
}

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