catchup

type BlockAuthenticator ¶

type BlockAuthenticator interface {
	Authenticate(*bookkeeping.Block, *agreement.Certificate) error
	Quit()
}

A BlockAuthenticator authenticates blocks given a certificate. 블록 인증자는 인증서에 지정된 블록을 인증합니다.

Note that Authenticate does not check if the block contents match their header as it only checks the block header. If the contents have not been checked yet, callers should also call block. ContentsMatchHeader and reject blocks that do not pass this check. Authenticate는 블록 헤더만 확인하므로 블록 내용이 헤더와 일치하는지 확인하지 않습니다. 내용이 아직 확인되지 않았다면 호출자도 블록을 호출해야 합니다. ContentsMatchHeader 및 이 검사를 통과하지 못한 블록을 거부합니다.

type CatchpointCatchupNodeServices ¶

type CatchpointCatchupNodeServices interface {
	SetCatchpointCatchupMode(bool) (newContextCh <-chan context.Context)
}

CatchpointCatchupNodeServices defines the extenal node support needed for the catchpoint service to switch the node between "regular" operational mode and catchup mode. CatchpointCatchupNodeServices는 캐치포인트 서비스가 "일반" 작동 모드와 캐치업 모드 사이에서 노드를 전환하는 데 필요한 외부 노드 지원을 정의합니다.

type CatchpointCatchupService ¶

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

CatchpointCatchupService represents the catchpoint catchup service. CatchpointCatchupService는 캐치포인트 캐치업 서비스를 나타냅니다.

func MakeNewCatchpointCatchupService(catchpoint string, node CatchpointCatchupNodeServices, log logging.Logger, net network.GossipNode, l *ledger.Ledger, cfg config.Local) (service *CatchpointCatchupService, err error)

func MakeResumedCatchpointCatchupService(ctx context.Context, node CatchpointCatchupNodeServices, log logging.Logger, net network.GossipNode, l *ledger.Ledger, cfg config.Local) (service *CatchpointCatchupService, err error)

func (cs *CatchpointCatchupService) Abort()

func (cs *CatchpointCatchupService) GetLatestBlockHeader() bookkeeping.BlockHeader

func (cs *CatchpointCatchupService) GetStatistics() (out CatchpointCatchupStats)

func (cs *CatchpointCatchupService) Start(ctx context.Context)

func (cs *CatchpointCatchupService) Stop()

type CatchpointCatchupStats ¶

type CatchpointCatchupStats struct {
	CatchpointLabel   string
	TotalAccounts     uint64
	ProcessedAccounts uint64
	VerifiedAccounts  uint64
	TotalBlocks       uint64
	AcquiredBlocks    uint64
	VerifiedBlocks    uint64
	ProcessedBytes    uint64
	StartTime         time.Time
}

CatchpointCatchupStats is used for querying and reporting the current state of the catchpoint catchup process CatchpointCatchupStats는 catchpoint catchup 프로세스의 현재 상태를 쿼리하고 보고하는 데 사용됩니다.

type HTTPFetcher ¶

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

HTTPFetcher implements FetcherClient doing an HTTP GET of the block HTTPFetcher는 블록의 HTTP GET을 수행하는 FetcherClient를 구현합니다.

type Ledger ¶

type Ledger interface {
	agreement.LedgerReader
	AddBlock(bookkeeping.Block, agreement.Certificate) error
	EnsureBlock(block *bookkeeping.Block, c agreement.Certificate)
	LastRound() basics.Round
	Block(basics.Round) (bookkeeping.Block, error)
	IsWritingCatchpointFile() bool
	Validate(ctx context.Context, blk bookkeeping.Block, executionPool execpool.BacklogPool) (*ledgercore.ValidatedBlock, error)
	AddValidatedBlock(vb ledgercore.ValidatedBlock, cert agreement.Certificate) error
}

Ledger represents the interface of a block database which the catchup server should interact with. Ledger는 캐치업 서버가 상호 작용해야 하는 블록 데이터베이스의 인터페이스를 나타냅니다.

type PendingUnmatchedCertificate ¶

type PendingUnmatchedCertificate struct {
	Cert         agreement.Certificate
	VoteVerifier *agreement.AsyncVoteVerifier
}

PendingUnmatchedCertificate is a single certificate that is being waited upon to have its corresponding block fetched. PendingUnmatchedCertificate는 해당 블록을 가져오기 위해 대기 중인 단일 인증서입니다.

type Service ¶

type Service struct {

	// The channel gets closed when the initial sync is complete.
	// This allows for other services to avoid the overhead of starting prematurely
	// (before this node is caught-up and can validate messages for example).
	// 초기 동기화가 완료되면 채널이 닫힙니다.
	// 이렇게 하면 다른 서비스가 조기에 시작하는 오버헤드를 피할 수 있습니다.
	// (예를 들어 이 노드가 따라잡혀 메시지를 확인할 수 있기 전에).
	InitialSyncDone chan struct{}
	// contains filtered or unexported fields
}

Service represents the catchup service. Once started and until it is stopped, it ensures that the ledger is up to date with network. 서비스는 캐치업 서비스를 나타냅니다. 일단 시작되고 중지될 때까지 원장이 네트워크에서 최신 상태인지 확인합니다.

func MakeService(log logging.Logger, config config.Local, net network.GossipNode, ledger Ledger, auth BlockAuthenticator, unmatchedPendingCertificates <-chan PendingUnmatchedCertificate, blockValidationPool execpool.BacklogPool) (s *Service)

func (s *Service) IsSynchronizing() (synchronizing bool, initialSync bool)

func (s *Service) Start()

func (s *Service) Stop()

func (s *Service) SynchronizingTime() time.Duration