sync

type AfterFunc = func(time.Duration) <-chan time.Time

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

type BlockFetcherOption = func(f *BlockFetcher)

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

type BlockValidatorOption func(*BlockValidator)

type Config struct {
	SyncPoolSize             uint64
	FetchTimeout             time.Duration
	RetryInterval            time.Duration
	CheckBlockHeightInterval time.Duration
	CheckPrevBlockInterval   time.Duration
	WatchInterval            time.Duration
	// contains filtered or unexported fields
}

type Doer interface {
	Do(*http.Request) (*http.Response, error)
}

type Fetcher interface {
	Fetch(ctx context.Context, syncInfo *SyncInfo) (*SyncInfo, error)
}

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

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

type SyncController interface {
	SetSyncTargetBlock(ctx context.Context, height uint64, nodeAddressList []string) error
}

type SyncInfo struct {
	Height uint64
	Block  *block.Block
	Bts    []*block.BlockTransaction
	Ptx    *ballot.ProposerTransaction

	// Fetching target node addresses, NodeList is  the validators which
	// participated and confirmed the consensus of latest ballot.
	NodeList *NodeList
}

type SyncProgress struct {
	StartingBlock uint64 // Block number where sync began
	CurrentBlock  uint64 // Current block number where sync is at
	HighestBlock  uint64 // Highest alleged block number in the chain
}

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

type SyncerOption func(s *Syncer)

type TryFunc func(attempt int) (retry bool, err error)

type Validator interface {
	Validate(context.Context, *SyncInfo) error
}

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

type WatcherOption func(*Watcher)