agent

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: 33 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CreateBeaconBadBlobFileName added in v0.0.16

func CreateBeaconBadBlobFileName(
	node string,
	network string,
	slot phase0.Slot,
	blockRoot string,
	index uint64,
) string

func CreateBeaconBadBlockFileName added in v0.0.16

func CreateBeaconBadBlockFileName(
	node string,
	network string,
	slot phase0.Slot,
	blockRoot string,
) string

func CreateBeaconBlockFileName added in v0.0.16

func CreateBeaconBlockFileName(
	node string,
	network string,
	slot phase0.Slot,
	blockRoot string,
) string

func CreateBeaconStateFileName

func CreateBeaconStateFileName(
	node string,
	network string,
	slot phase0.Slot,
	stateRoot string,
) string

func CreateExecutionBadBlockFileName

func CreateExecutionBadBlockFileName(
	node string,
	network string,
	blockHash string,
) string

func CreateExecutionBlockTraceFileName

func CreateExecutionBlockTraceFileName(
	node string,
	network string,
	blockNumber uint64,
	blockHash string,
) string

func New

func New(ctx context.Context, log logrus.FieldLogger, config *Config) (*agent, error)

Types

type BeaconBadBlobRequest added in v0.0.16

type BeaconBadBlobRequest struct {
	Path string
}

type BeaconBadBlockRequest added in v0.0.16

type BeaconBadBlockRequest struct {
	Path string
}

type BeaconBlockRequest added in v0.0.16

type BeaconBlockRequest struct {
	Slot phase0.Slot
}

type BeaconStateRequest

type BeaconStateRequest struct {
	Slot phase0.Slot
}

type Config

type Config struct {
	LoggingLevel string  `yaml:"logging" default:"info"`
	MetricsAddr  string  `yaml:"metricsAddr" default:":9090"`
	PProfAddr    *string `yaml:"pprofAddr"`

	// The name of the agent
	Name string `yaml:"name"`

	// Ethereum configuration
	Ethereum ethereum.Config `yaml:"ethereum"`

	// Indexer configuration
	Indexer *indexer.Config `yaml:"indexer"`

	// Store configuration
	Store *store.Config `yaml:"store"`
}

func (*Config) Validate

func (c *Config) Validate() error

type ExecutionBadBlockRequest added in v0.0.16

type ExecutionBadBlockRequest struct {
}

type ExecutionBlockTraceRequest

type ExecutionBlockTraceRequest struct {
	BlockNumber uint64
	BlockHash   string
}

type Metrics

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

func NewMetrics

func NewMetrics(namespace string) *Metrics

func (*Metrics) IncrementItemExported added in v0.0.11

func (m *Metrics) IncrementItemExported(queue Queue)

func (*Metrics) ObserveQueueItemProcessingTime

func (m *Metrics) ObserveQueueItemProcessingTime(queue Queue, duration time.Duration)

func (*Metrics) SetQueueSize

func (m *Metrics) SetQueueSize(queue Queue, count int)

type Queue

type Queue string
var (
	BeaconStateQueue         Queue = "beacon_state"
	BeaconBlockQueue         Queue = "beacon_block"
	BeaconBadBlockQueue      Queue = "beacon_bad_block"
	BeaconBadBlobQueue       Queue = "beacon_bad_blob"
	ExecutionBlockTraceQueue Queue = "execution_block_trace"
	ExecutionBadBlockQueue   Queue = "execution_bad_block"
)

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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