core

May 4, 2023

Changes in this version

+ const AwsRegion

+ const EstimatedShardsCount

+ const MainnetBucketName

+ const MaxRetryCount

+ const TestnetBucketName

+ func Streamer(config LakeConfig, numWorkers int) chan types.StreamMessage

+ type IFetcher interface

+ ListBlocks func(s3Client *s3.S3, s3BucketName string, startFromBlockHeight uint64, ...) (map[string]interface{}, error)

+ type ILakeConfigBuilder interface

+ Build func() *LakeConfig

+ Mainnet func() ILakeConfigBuilder

+ SetBlocksPreloadPoolSize func(size uint64) ILakeConfigBuilder

+ SetS3BucketName func(name string) ILakeConfigBuilder

+ SetS3Config func(config *client.ConfigProvider) ILakeConfigBuilder

+ SetS3RegionName func(name string) ILakeConfigBuilder

+ SetStartBlockHeight func(height uint64) ILakeConfigBuilder

+ Testnet func() ILakeConfigBuilder

+ func DefaultLakeConfigBuilder() ILakeConfigBuilder

+ type LakeConfig struct

+ type LakeConfigBuilder struct

+ func (cf *LakeConfigBuilder) Build() *LakeConfig

+ func (cf *LakeConfigBuilder) Mainnet() ILakeConfigBuilder

+ func (cf *LakeConfigBuilder) SetBlocksPreloadPoolSize(size uint64) ILakeConfigBuilder

+ func (cf *LakeConfigBuilder) SetS3BucketName(name string) ILakeConfigBuilder

+ func (cf *LakeConfigBuilder) SetS3Config(config *client.ConfigProvider) ILakeConfigBuilder

+ func (cf *LakeConfigBuilder) SetS3RegionName(name string) ILakeConfigBuilder

+ func (cf *LakeConfigBuilder) SetStartBlockHeight(height uint64) ILakeConfigBuilder

+ func (cf *LakeConfigBuilder) Testnet() ILakeConfigBuilder

+ type S3Fetcher struct

+ func (s3fetcher *S3Fetcher) FetchShardOrRetry(s3Client *s3.S3, s3BucketName string, blockHeight uint64, shardId uint64) (*types.IndexerShard, error)

+ func (s3fetcher *S3Fetcher) FetchStreamerMessage(s3Client *s3.S3, s3BucketName string, blockHeight uint64) (*types.StreamMessage, error)

+ func (s3fetcher *S3Fetcher) ListBlocks(s3Client *s3.S3, s3BucketName string, startFromBlockHeight uint64, ...) ([]uint64, error)