extractor

Documentation

Index

• func Extract(address string, outputHandler output.OutputHandler, ...) error
• func ExtractBlocksAndTransactions(ctx context.Context, grpcConn *grpc.ClientConn, ...) error
• func ExtractLiveBlocksAndTransactions(ctx context.Context, grpcConn *grpc.ClientConn, ...) error
• func ProcessSingleBlockWithRetry(ctx context.Context, grpcConn *grpc.ClientConn, ...) error

Functions

func Extract

func Extract(address string, outputHandler output.OutputHandler, config config.ExtractConfig) error

Extract extracts blocks and transactions from a gRPC server.

func ExtractBlocksAndTransactions

func ExtractBlocksAndTransactions(ctx context.Context, grpcConn *grpc.ClientConn, resolver *reflection.CustomResolver, start, stop uint64, outputHandler output.OutputHandler, maxConcurrency, maxRetries uint) error

func ExtractLiveBlocksAndTransactions

func ExtractLiveBlocksAndTransactions(ctx context.Context, grpcConn *grpc.ClientConn, resolver *reflection.CustomResolver, start uint64, outputHandler output.OutputHandler, blockTime, maxConcurrency, maxRetries uint) error

ExtractLiveBlocksAndTransactions monitors the chain and processes new blocks as they are produced.

func ProcessSingleBlockWithRetry

func ProcessSingleBlockWithRetry(ctx context.Context, grpcConn *grpc.ClientConn, resolver *reflection.CustomResolver, blockHeight uint64, outputHandler output.OutputHandler, maxRetries uint) error