traces

Documentation

Index

• type Downloader
• type Engine
  • func NewTracesIngestionEngine(initEVMHeight uint64, blocksBroadcaster *engine.Broadcaster, ...) *Engine
  • func (e *Engine) Done() <-chan struct{}
  • func (e *Engine) Notify()
  • func (e *Engine) Ready() <-chan struct{}
  • func (e *Engine) Run(ctx context.Context) error
  • func (e *Engine) Stop()
• type GCPDownloader
  • func NewGCPDownloader(bucketName string, logger zerolog.Logger) (*GCPDownloader, error)
  • func (g *GCPDownloader) Download(txID common.Hash, blockID flow.Identifier) (json.RawMessage, error)

Types

type Downloader

type Downloader interface {
	// Download traces or returning an error with the failure
	Download(txID common.Hash, blockIO flow.Identifier) (json.RawMessage, error)
}

type Engine

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

func NewTracesIngestionEngine

func NewTracesIngestionEngine(
	initEVMHeight uint64,
	blocksBroadcaster *engine.Broadcaster,
	blocks storage.BlockIndexer,
	traces storage.TraceIndexer,
	downloader Downloader,
	logger zerolog.Logger,
) *Engine

func (*Engine) Done

func (e *Engine) Done() <-chan struct{}

func (*Engine) Notify

func (e *Engine) Notify()

Notify is a handler that is being used to subscribe for new EVM block notifications. This method should be non-blocking.

func (*Engine) Ready

func (e *Engine) Ready() <-chan struct{}

func (*Engine) Run

func (e *Engine) Run(ctx context.Context) error

func (*Engine) Stop

func (e *Engine) Stop()

type GCPDownloader

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

func NewGCPDownloader

func NewGCPDownloader(bucketName string, logger zerolog.Logger) (*GCPDownloader, error)

func (*GCPDownloader) Download

func (g *GCPDownloader) Download(txID common.Hash, blockID flow.Identifier) (json.RawMessage, error)