source

Documentation

Index

• type FileMetadata
• type ISource
• type ParquetBlockData
• type S3Source
  • func NewS3Source(chainId *big.Int, cfg *config.S3SourceConfig) (*S3Source, error)
  • func (s *S3Source) Close()
  • func (s *S3Source) GetFullBlocks(ctx context.Context, blockNumbers []*big.Int) []rpc.GetFullBlockResult
  • func (s *S3Source) GetSupportedBlockRange(ctx context.Context) (minBlockNumber *big.Int, maxBlockNumber *big.Int, err error)
• type StagingSource
  • func NewStagingSource(chainId *big.Int, storage storage.IStagingStorage) (*StagingSource, error)
  • func (s *StagingSource) Close()
  • func (s *StagingSource) GetFullBlocks(ctx context.Context, blockNumbers []*big.Int) []rpc.GetFullBlockResult
  • func (s *StagingSource) GetSupportedBlockRange(ctx context.Context) (minBlockNumber *big.Int, maxBlockNumber *big.Int, err error)

Types

type FileMetadata

type FileMetadata struct {
	Key      string
	MinBlock *big.Int
	MaxBlock *big.Int
	Size     int64
}

FileMetadata represents cached information about S3 files

type ISource

type ISource interface {
	GetFullBlocks(ctx context.Context, blockNumbers []*big.Int) []rpc.GetFullBlockResult
	GetSupportedBlockRange(ctx context.Context) (minBlockNumber *big.Int, maxBlockNumber *big.Int, err error)
	Close()
}

type ParquetBlockData

type ParquetBlockData struct {
	ChainId        uint64 `parquet:"chain_id"`
	BlockNumber    uint64 `parquet:"block_number"`
	BlockHash      string `parquet:"block_hash"`
	BlockTimestamp int64  `parquet:"block_timestamp"`
	Block          []byte `parquet:"block_json"`
	Transactions   []byte `parquet:"transactions_json"`
	Logs           []byte `parquet:"logs_json"`
	Traces         []byte `parquet:"traces_json"`
}

ParquetBlockData represents the block data structure in parquet files

type S3Source

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

func NewS3Source

func NewS3Source(chainId *big.Int, cfg *config.S3SourceConfig) (*S3Source, error)

func (*S3Source) Close

func (s *S3Source) Close()

func (*S3Source) GetFullBlocks

func (s *S3Source) GetFullBlocks(ctx context.Context, blockNumbers []*big.Int) []rpc.GetFullBlockResult

func (*S3Source) GetSupportedBlockRange

func (s *S3Source) GetSupportedBlockRange(ctx context.Context) (minBlockNumber *big.Int, maxBlockNumber *big.Int, err error)

type StagingSource

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

func NewStagingSource

func NewStagingSource(chainId *big.Int, storage storage.IStagingStorage) (*StagingSource, error)

func (*StagingSource) Close

func (s *StagingSource) Close()

func (*StagingSource) GetFullBlocks

func (s *StagingSource) GetFullBlocks(ctx context.Context, blockNumbers []*big.Int) []rpc.GetFullBlockResult

func (*StagingSource) GetSupportedBlockRange

func (s *StagingSource) GetSupportedBlockRange(ctx context.Context) (minBlockNumber *big.Int, maxBlockNumber *big.Int, err error)