indexer

package
v0.0.16 Latest Latest
Warning

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

 Go to latest Published: Mar 28, 2024 License: GPL-3.0 Imports: 17 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 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 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) 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 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.