indexer

package
v0.0.4 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 14, 2024 License: GPL-3.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

View Source
const (
	ServiceType = "tracoor.indexer"
)

Variables

This section is empty.

Functions

func DBBeaconStateToProtoBeaconState

func DBBeaconStateToProtoBeaconState(bs *persistence.BeaconState) *indexer.BeaconState

func DBExecutionBadBlockToProtoExecutionBadBlock

func DBExecutionBadBlockToProtoExecutionBadBlock(eb *persistence.ExecutionBadBlock) *indexer.ExecutionBadBlock

func DBExecutionBlockTraceToProtoExecutionBlockTrace

func DBExecutionBlockTraceToProtoExecutionBlockTrace(eb *persistence.ExecutionBlockTrace) *indexer.ExecutionBlockTrace

func DBPaginationCursorToProtoPaginationCursor

func DBPaginationCursorToProtoPaginationCursor(pc *persistence.PaginationCursor) *indexer.PaginationCursor

func ProtoBeaconStateToDBBeaconState

func ProtoBeaconStateToDBBeaconState(bs *indexer.BeaconState) *persistence.BeaconState

func ProtoExecutionBadBlockToDBExecutionBadBlock

func ProtoExecutionBadBlockToDBExecutionBadBlock(eb *indexer.ExecutionBadBlock) *persistence.ExecutionBadBlock

func ProtoExecutionBlockTraceToDBExecutionBlockTrace

func ProtoExecutionBlockTraceToDBExecutionBlockTrace(eb *indexer.ExecutionBlockTrace) *persistence.ExecutionBlockTrace

func ProtoPaginationCursorToDBPaginationCursor

func ProtoPaginationCursorToDBPaginationCursor(pc *indexer.PaginationCursor) *persistence.PaginationCursor

Types

type Config

type Config struct {
	Retention RetentionConfig `yaml:"retention"`
}

func (*Config) Validate

func (c *Config) Validate() error

type Indexer

type Indexer struct {
	indexer.IndexerServer
	// contains filtered or unexported fields
}

func NewIndexer

func NewIndexer(ctx context.Context, log logrus.FieldLogger, conf *Config, db *persistence.Indexer, st store.Store) (*Indexer, error)

func (*Indexer) ListBeaconState

func (*Indexer) Start

func (e *Indexer) Start(ctx context.Context, grpcServer *grpc.Server) error

func (*Indexer) Stop

func (e *Indexer) Stop(ctx context.Context) error

type Metrics

type Metrics struct {
}

func NewMetrics

func NewMetrics(namespace string) *Metrics

type RetentionConfig

type RetentionConfig struct {
	BeaconStates         human.Duration `yaml:"beaconStates" default:"30m"`
	ExecutionBlockTraces human.Duration `yaml:"executionBlockTraces" default:"30m"`
	ExecutionBadBlocks   human.Duration `yaml:"executionBadBlocks" default:"312480m"` // 6 months
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL