indexer

package
v0.0.30 Latest Latest
Warning

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

 Go to latest Published: May 5, 2025 License: GPL-3.0 Imports: 22 Imported by: 0

Documentation

Index

Constants

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

Variables

This section is empty.

Functions

func DBBeaconBadBlobToProtoBeaconBadBlob added in v0.0.16 

func DBBeaconBadBlobToProtoBeaconBadBlob(bs *persistence.BeaconBadBlob) *indexer.BeaconBadBlob

func DBBeaconBadBlockToProtoBeaconBadBlock added in v0.0.16 

func DBBeaconBadBlockToProtoBeaconBadBlock(bs *persistence.BeaconBadBlock) *indexer.BeaconBadBlock

func DBBeaconBlockToProtoBeaconBlock added in v0.0.16 

func DBBeaconBlockToProtoBeaconBlock(bs *persistence.BeaconBlock) *indexer.BeaconBlock

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 ProtoBeaconBadBlobToDBBeaconBadBlob added in v0.0.16 

func ProtoBeaconBadBlobToDBBeaconBadBlob(bs *indexer.BeaconBadBlob) *persistence.BeaconBadBlob

func ProtoBeaconBadBlockToDBBeaconBadBlock added in v0.0.16 

func ProtoBeaconBadBlockToDBBeaconBadBlock(bs *indexer.BeaconBadBlock) *persistence.BeaconBadBlock

func ProtoBeaconBlockToDBBeaconBlock added in v0.0.16 

func ProtoBeaconBlockToDBBeaconBlock(bs *indexer.BeaconBlock) *persistence.BeaconBlock

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 BlockConfig added in v0.0.27 

type BlockConfig struct {
	Enabled bool `yaml:"enabled" default:"false"`
}

type Config 

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

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, ethereumConfig *ethereum.Config) (*Indexer, error)

func NewMockIndexer added in v0.0.15 

func NewMockIndexer(ctx context.Context, config *Config) (*Indexer, func() error, error)

func (*Indexer) CountBeaconBadBlob added in v0.0.16 

func (i *Indexer) CountBeaconBadBlob(ctx context.Context, req *indexer.CountBeaconBadBlobRequest) (*indexer.CountBeaconBadBlobResponse, error)

func (*Indexer) CountBeaconBadBlock added in v0.0.16 

func (i *Indexer) CountBeaconBadBlock(ctx context.Context, req *indexer.CountBeaconBadBlockRequest) (*indexer.CountBeaconBadBlockResponse, error)

func (*Indexer) CountBeaconBlock added in v0.0.16 

func (i *Indexer) CountBeaconBlock(ctx context.Context, req *indexer.CountBeaconBlockRequest) (*indexer.CountBeaconBlockResponse, error)

func (*Indexer) CountBeaconState 

func (i *Indexer) CountBeaconState(ctx context.Context, req *indexer.CountBeaconStateRequest) (*indexer.CountBeaconStateResponse, error)

func (*Indexer) CountExecutionBadBlock 

func (i *Indexer) CountExecutionBadBlock(ctx context.Context, req *indexer.CountExecutionBadBlockRequest) (*indexer.CountExecutionBadBlockResponse, error)

func (*Indexer) CountExecutionBlockTrace 

func (i *Indexer) CountExecutionBlockTrace(ctx context.Context, req *indexer.CountExecutionBlockTraceRequest) (*indexer.CountExecutionBlockTraceResponse, error)

func (*Indexer) CreateBeaconBadBlob added in v0.0.16 

func (i *Indexer) CreateBeaconBadBlob(ctx context.Context, req *indexer.CreateBeaconBadBlobRequest) (*indexer.CreateBeaconBadBlobResponse, error)

func (*Indexer) CreateBeaconBadBlock added in v0.0.16 

func (i *Indexer) CreateBeaconBadBlock(ctx context.Context, req *indexer.CreateBeaconBadBlockRequest) (*indexer.CreateBeaconBadBlockResponse, error)

func (*Indexer) CreateBeaconBlock added in v0.0.16 

func (i *Indexer) CreateBeaconBlock(ctx context.Context, req *indexer.CreateBeaconBlockRequest) (*indexer.CreateBeaconBlockResponse, error)

func (*Indexer) CreateBeaconState 

func (i *Indexer) CreateBeaconState(ctx context.Context, req *indexer.CreateBeaconStateRequest) (*indexer.CreateBeaconStateResponse, error)

func (*Indexer) CreateExecutionBadBlock 

func (i *Indexer) CreateExecutionBadBlock(ctx context.Context, req *indexer.CreateExecutionBadBlockRequest) (*indexer.CreateExecutionBadBlockResponse, error)

func (*Indexer) CreateExecutionBlockTrace 

func (i *Indexer) CreateExecutionBlockTrace(ctx context.Context, req *indexer.CreateExecutionBlockTraceRequest) (*indexer.CreateExecutionBlockTraceResponse, error)

func (*Indexer) GetConfig added in v0.0.22 

func (i *Indexer) GetConfig(ctx context.Context, req *indexer.GetConfigRequest) (*indexer.GetConfigResponse, error)

func (*Indexer) GetStorageHandshakeToken 

func (i *Indexer) GetStorageHandshakeToken(ctx context.Context, req *indexer.GetStorageHandshakeTokenRequest) (*indexer.GetStorageHandshakeTokenResponse, error)

func (*Indexer) ListBeaconBadBlob added in v0.0.16 

func (i *Indexer) ListBeaconBadBlob(ctx context.Context, req *indexer.ListBeaconBadBlobRequest) (*indexer.ListBeaconBadBlobResponse, error)

func (*Indexer) ListBeaconBadBlock added in v0.0.16 

func (i *Indexer) ListBeaconBadBlock(ctx context.Context, req *indexer.ListBeaconBadBlockRequest) (*indexer.ListBeaconBadBlockResponse, error)

func (*Indexer) ListBeaconBlock added in v0.0.16 

func (i *Indexer) ListBeaconBlock(ctx context.Context, req *indexer.ListBeaconBlockRequest) (*indexer.ListBeaconBlockResponse, error)

func (*Indexer) ListBeaconState 

func (i *Indexer) ListBeaconState(ctx context.Context, req *indexer.ListBeaconStateRequest) (*indexer.ListBeaconStateResponse, error)

func (*Indexer) ListExecutionBadBlock 

func (i *Indexer) ListExecutionBadBlock(ctx context.Context, req *indexer.ListExecutionBadBlockRequest) (*indexer.ListExecutionBadBlockResponse, error)

func (*Indexer) ListExecutionBlockTrace 

func (i *Indexer) ListExecutionBlockTrace(ctx context.Context, req *indexer.ListExecutionBlockTraceRequest) (*indexer.ListExecutionBlockTraceResponse, error)

func (*Indexer) ListUniqueBeaconBadBlobValues added in v0.0.16 

func (i *Indexer) ListUniqueBeaconBadBlobValues(ctx context.Context, req *indexer.ListUniqueBeaconBadBlobValuesRequest) (*indexer.ListUniqueBeaconBadBlobValuesResponse, error)

func (*Indexer) ListUniqueBeaconBadBlockValues added in v0.0.16 

func (i *Indexer) ListUniqueBeaconBadBlockValues(ctx context.Context, req *indexer.ListUniqueBeaconBadBlockValuesRequest) (*indexer.ListUniqueBeaconBadBlockValuesResponse, error)

func (*Indexer) ListUniqueBeaconBlockValues added in v0.0.16 

func (i *Indexer) ListUniqueBeaconBlockValues(ctx context.Context, req *indexer.ListUniqueBeaconBlockValuesRequest) (*indexer.ListUniqueBeaconBlockValuesResponse, error)

func (*Indexer) ListUniqueBeaconStateValues 

func (i *Indexer) ListUniqueBeaconStateValues(ctx context.Context, req *indexer.ListUniqueBeaconStateValuesRequest) (*indexer.ListUniqueBeaconStateValuesResponse, error)

func (*Indexer) ListUniqueExecutionBadBlockValues 

func (i *Indexer) ListUniqueExecutionBadBlockValues(ctx context.Context, req *indexer.ListUniqueExecutionBadBlockValuesRequest) (*indexer.ListUniqueExecutionBadBlockValuesResponse, error)

func (*Indexer) ListUniqueExecutionBlockTraceValues 

func (i *Indexer) ListUniqueExecutionBlockTraceValues(ctx context.Context, req *indexer.ListUniqueExecutionBlockTraceValuesRequest) (*indexer.ListUniqueExecutionBlockTraceValuesResponse, error)

func (*Indexer) Start 

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

func (*Indexer) Stop 

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

func (*Indexer) Store added in v0.0.15 

func (i *Indexer) Store() store.Store

type Metrics 

type Metrics struct {
}

func NewMetrics 

func NewMetrics(namespace string) *Metrics

type PermanentStore added in v0.0.27 

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

PermanentStore ensures that at least one copy of each block per network is retained by copying it to a permanent location in the store.

func NewPermanentStore added in v0.0.27 

func NewPermanentStore(log logrus.FieldLogger, st store.Store, db *persistence.Indexer, nodeID string, conf *PermanentStoreConfig) (*PermanentStore, error)

NewPermanentStore creates a new permanent store.

func (*PermanentStore) GetPermanentLocation added in v0.0.28 

func (p *PermanentStore) GetPermanentLocation(block PermanentStoreBlock) string

GetPermanentLocation returns the permanent location for a block.

func (*PermanentStore) IsEnabled added in v0.0.27 

func (p *PermanentStore) IsEnabled() bool

func (*PermanentStore) QueueBlock added in v0.0.27 

func (p *PermanentStore) QueueBlock(block PermanentStoreBlock)

QueueBlock adds a block to the queue for processing.

func (*PermanentStore) Start added in v0.0.27 

func (p *PermanentStore) Start(ctx context.Context) error

Start starts the permanent store.

func (*PermanentStore) Stop added in v0.0.27 

func (p *PermanentStore) Stop(ctx context.Context) error

Stop stops the permanent store.

type PermanentStoreBlock added in v0.0.27 

type PermanentStoreBlock struct {
	Location      string
	BlockRoot     string
	Network       string
	Slot          phase0.Slot
	ProcessedChan chan struct{}
}

PermanentStoreBlock contains the minimal information needed to identify a block

type PermanentStoreConfig added in v0.0.27 

type PermanentStoreConfig struct {
	Blocks BlockConfig `yaml:"blocks"`
}

type RetentionConfig 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.