chaindatafetcher

Documentation

Index

• Constants
• Variables
• type BlockChain
• type ChainDataFetcher
  • func NewChainDataFetcher(ctx *node.ServiceContext, cfg *ChainDataFetcherConfig) (*ChainDataFetcher, error)
  • func (f *ChainDataFetcher) APIs() []rpc.API
  • func (f *ChainDataFetcher) Components() []interface{}
  • func (f *ChainDataFetcher) Protocols() []p2p.Protocol
  • func (f *ChainDataFetcher) SetComponents(components []interface{})
  • func (f *ChainDataFetcher) Start(server p2p.Server) error
  • func (f *ChainDataFetcher) Stop() error
• type ChainDataFetcherConfig
• type ChainDataFetcherMode
• type CheckpointDB
• type ComponentSetter
• type HandleChainEventFn
• type PublicChainDataFetcherAPI
  • func NewPublicChainDataFetcherAPI(f *ChainDataFetcher) *PublicChainDataFetcherAPI
  • func (api *PublicChainDataFetcherAPI) GetConfig() *ChainDataFetcherConfig
  • func (api *PublicChainDataFetcherAPI) ReadCheckpoint() (int64, error)
  • func (api *PublicChainDataFetcherAPI) StartFetching() error
  • func (api *PublicChainDataFetcherAPI) StartRangeFetching(start, end uint64, reqType uint) error
  • func (api *PublicChainDataFetcherAPI) Status() string
  • func (api *PublicChainDataFetcherAPI) StopFetching() error
  • func (api *PublicChainDataFetcherAPI) StopRangeFetching() error
  • func (api *PublicChainDataFetcherAPI) WriteCheckpoint(checkpoint int64) error
• type Repository

Constants

const (
	ModeKAS = ChainDataFetcherMode(iota)
	ModeKafka
)

const (
	DefaultNumHandlers      = 10
	DefaultJobChannelSize   = 50
	DefaultBlockChannelSize = 500
	DefaultDBPort           = "3306"
)

const (
	InsertRetryInterval = 500 * time.Millisecond
	InsertMaxRetry      = 100
)

Variables

var DefaultChainDataFetcherConfig = &ChainDataFetcherConfig{
	EnabledChainDataFetcher: false,
	Mode:                    ModeKAS,
	NoDefaultStart:          false,
	NumHandlers:             DefaultNumHandlers,
	JobChannelSize:          DefaultJobChannelSize,
	BlockChannelSize:        DefaultBlockChannelSize,

	KasConfig:   kas.DefaultKASConfig,
	KafkaConfig: kafka.GetDefaultKafkaConfig(),
}

Types

type BlockChain

type BlockChain interface {
	SubscribeChainEvent(ch chan<- blockchain.ChainEvent) event.Subscription
	CurrentHeader() *types.Header
	GetBlockByNumber(number uint64) *types.Block
	GetReceiptsByBlockHash(blockHash common.Hash) types.Receipts
}

type ChainDataFetcher

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

func NewChainDataFetcher

func NewChainDataFetcher(ctx *node.ServiceContext, cfg *ChainDataFetcherConfig) (*ChainDataFetcher, error)

func (*ChainDataFetcher) APIs

func (f *ChainDataFetcher) APIs() []rpc.API

func (*ChainDataFetcher) Components

func (f *ChainDataFetcher) Components() []interface{}

func (*ChainDataFetcher) Protocols

func (f *ChainDataFetcher) Protocols() []p2p.Protocol

func (*ChainDataFetcher) SetComponents

func (f *ChainDataFetcher) SetComponents(components []interface{})

func (*ChainDataFetcher) Start

func (f *ChainDataFetcher) Start(server p2p.Server) error

func (*ChainDataFetcher) Stop

func (f *ChainDataFetcher) Stop() error

type ChainDataFetcherConfig

type ChainDataFetcherConfig struct {
	EnabledChainDataFetcher bool
	Mode                    ChainDataFetcherMode
	NoDefaultStart          bool
	NumHandlers             int
	JobChannelSize          int
	BlockChannelSize        int

	KasConfig   *kas.KASConfig `json:"-"` // Deprecated: This configuration is not used anymore.
	KafkaConfig *kafka.KafkaConfig
}

type ChainDataFetcherMode

type ChainDataFetcherMode int

type CheckpointDB

type CheckpointDB interface {
	ReadCheckpoint() (int64, error)
	WriteCheckpoint(checkpoint int64) error
}

type ComponentSetter

type ComponentSetter interface {
	SetComponent(component interface{})
}

type HandleChainEventFn

type HandleChainEventFn func(blockchain.ChainEvent, types.RequestType) error

type PublicChainDataFetcherAPI

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

func NewPublicChainDataFetcherAPI

func NewPublicChainDataFetcherAPI(f *ChainDataFetcher) *PublicChainDataFetcherAPI

func (*PublicChainDataFetcherAPI) GetConfig

func (api *PublicChainDataFetcherAPI) GetConfig() *ChainDataFetcherConfig

GetConfig returns the configuration setting of the launched chaindata fetcher.

func (*PublicChainDataFetcherAPI) ReadCheckpoint

func (api *PublicChainDataFetcherAPI) ReadCheckpoint() (int64, error)

func (*PublicChainDataFetcherAPI) StartFetching

func (api *PublicChainDataFetcherAPI) StartFetching() error

func (*PublicChainDataFetcherAPI) StartRangeFetching

func (api *PublicChainDataFetcherAPI) StartRangeFetching(start, end uint64, reqType uint) error

func (*PublicChainDataFetcherAPI) Status

func (api *PublicChainDataFetcherAPI) Status() string

func (*PublicChainDataFetcherAPI) StopFetching

func (api *PublicChainDataFetcherAPI) StopFetching() error

func (*PublicChainDataFetcherAPI) StopRangeFetching

func (api *PublicChainDataFetcherAPI) StopRangeFetching() error

func (*PublicChainDataFetcherAPI) WriteCheckpoint

func (api *PublicChainDataFetcherAPI) WriteCheckpoint(checkpoint int64) error

type Repository

type Repository interface {
	HandleChainEvent(event blockchain.ChainEvent, dataType types.RequestType) error
}