Documentation
¶
Index ¶
- type SyncOption
- func WithAdaptive(adaptive bool) SyncOption
- func WithBenchmark(benchmark bool) SyncOption
- func WithEpochFrom(epochFrom uint64) SyncOption
- func WithEpochTo(epochTo uint64) SyncOption
- func WithMaxDbRows(dbRows int) SyncOption
- func WithMinBatchDbRows(dbRows int) SyncOption
- func WithWorkers(workers []*worker) SyncOption
- type Syncer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type SyncOption ¶
type SyncOption func(*Syncer)
functional options for syncer
func WithAdaptive ¶
func WithAdaptive(adaptive bool) SyncOption
func WithBenchmark ¶
func WithBenchmark(benchmark bool) SyncOption
func WithEpochFrom ¶
func WithEpochFrom(epochFrom uint64) SyncOption
func WithEpochTo ¶
func WithEpochTo(epochTo uint64) SyncOption
func WithMaxDbRows ¶
func WithMaxDbRows(dbRows int) SyncOption
func WithMinBatchDbRows ¶
func WithMinBatchDbRows(dbRows int) SyncOption
func WithWorkers ¶
func WithWorkers(workers []*worker) SyncOption
type Syncer ¶
type Syncer struct {
// contains filtered or unexported fields
}
Syncer accelerates core space epoch data catch-up using concurrently workers. Specifically, each worker will be dispatched as round-robin load balancing.
func MustNewSyncer ¶
func MustNewSyncer(cfx sdk.ClientOperator, db store.StackOperable, opts ...SyncOption) *Syncer
func (*Syncer) Range ¶
func (s *Syncer) Range() types.RangeUint64
Source Files
Click to show internal directories.
Click to hide internal directories.