analyzer

Documentation

Index

• Constants
• Variables
• type AggregateStatsAnalyzer
  • func NewAggregateStatsAnalyzer(cfg *config.AggregateStatsConfig, target storage.TargetStorage, ...) (*AggregateStatsAnalyzer, error)
  • func (a *AggregateStatsAnalyzer) Name() string
  • func (a *AggregateStatsAnalyzer) Start(ctx context.Context)
• type Analyzer
• type MetadataRegistryAnalyzer
  • func NewMetadataRegistryAnalyzer(cfg *config.MetadataRegistryConfig, target storage.TargetStorage, ...) (*MetadataRegistryAnalyzer, error)
  • func (a *MetadataRegistryAnalyzer) Name() string
  • func (a *MetadataRegistryAnalyzer) Start(ctx context.Context)

Constants

const (
	AggregateStatsAnalyzerName = "aggregate_stats"
)

const MetadataRegistryAnalyzerName = "metadata_registry"

Variables

var (
	// ErrOutOfRange is returned if the current block does not fall within the
	// analyzer's analysis range.
	ErrOutOfRange = errors.New("range not found. no data source available")

	// ErrLatestBlockNotFound is returned if the analyzer has not indexed any
	// blocks yet. This indicates to begin from the start of its range.
	ErrLatestBlockNotFound = errors.New("latest block not found")
)

Types

type AggregateStatsAnalyzer

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

func NewAggregateStatsAnalyzer

func NewAggregateStatsAnalyzer(cfg *config.AggregateStatsConfig, target storage.TargetStorage, logger *log.Logger) (*AggregateStatsAnalyzer, error)

func (*AggregateStatsAnalyzer) Name

func (a *AggregateStatsAnalyzer) Name() string

func (*AggregateStatsAnalyzer) Start

func (a *AggregateStatsAnalyzer) Start(ctx context.Context)

type Analyzer

type Analyzer interface {
	// Start starts the analyzer.
	Start(ctx context.Context)

	// Name returns the name of the analyzer.
	Name() string
}

Analyzer is a worker that analyzes a subset of the Oasis Network.

type MetadataRegistryAnalyzer

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

func NewMetadataRegistryAnalyzer

func NewMetadataRegistryAnalyzer(cfg *config.MetadataRegistryConfig, target storage.TargetStorage, logger *log.Logger) (*MetadataRegistryAnalyzer, error)

func (*MetadataRegistryAnalyzer) Name

func (a *MetadataRegistryAnalyzer) Name() string

func (*MetadataRegistryAnalyzer) Start

func (a *MetadataRegistryAnalyzer) Start(ctx context.Context)