agent

Documentation

Index

• func CreateBeaconBadBlobFileName(node string, network string, slot phase0.Slot, blockRoot string, index uint64) string
• func CreateBeaconBadBlockFileName(node string, network string, slot phase0.Slot, blockRoot string) string
• func CreateBeaconBlockFileName(node string, network string, slot phase0.Slot, blockRoot string) string
• func CreateBeaconStateFileName(node string, network string, slot phase0.Slot, stateRoot string) string
• func CreateExecutionBadBlockFileName(node string, network string, blockHash string) string
• func CreateExecutionBlockTraceFileName(node string, network string, blockNumber uint64, blockHash string) string
• func New(ctx context.Context, log logrus.FieldLogger, config *Config) (*agent, error)
• type BeaconBadBlobRequest
• type BeaconBadBlockRequest
• type BeaconBlockRequest
• type BeaconStateRequest
• type Config
  • func (c *Config) Validate() error
• type ExecutionBadBlockRequest
• type ExecutionBlockTraceRequest
• type Metrics
  • func GetMetricsInstance(namespace string) *Metrics
  • func (m *Metrics) IncrementItemExported(queue Queue, agentName string)
  • func (m *Metrics) ObserveQueueItemProcessingTime(queue Queue, duration time.Duration, agentName string)
  • func (m *Metrics) ServeMetrics(ctx context.Context, addr string)
  • func (m *Metrics) SetQueueSize(queue Queue, count int, agentName string)
• type Queue

Functions

func CreateBeaconBadBlobFileName

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

func CreateBeaconBadBlockFileName

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

func CreateBeaconBlockFileName

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

type BeaconBadBlobRequest struct {
	Path string
}

type BeaconBadBlockRequest

type BeaconBadBlockRequest struct {
	Path string
}

type BeaconBlockRequest

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

type ExecutionBadBlockRequest struct {
}

type ExecutionBlockTraceRequest

type ExecutionBlockTraceRequest struct {
	BlockNumber uint64
	BlockHash   string
}

type Metrics

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

func GetMetricsInstance

func GetMetricsInstance(namespace string) *Metrics

func (*Metrics) IncrementItemExported

func (m *Metrics) IncrementItemExported(queue Queue, agentName string)

func (*Metrics) ObserveQueueItemProcessingTime

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

func (*Metrics) ServeMetrics

func (m *Metrics) ServeMetrics(ctx context.Context, addr string)

func (*Metrics) SetQueueSize

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

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"
)