util

Documentation

Index

• func BeaconNodeAddresses(path string) []string
• func BeaconNodeAddressesForAttesting() []string
• func BeaconNodeAddressesForProposing() []string
• func CommitHash() string
• func EpochToInt64(epoch phase0.Epoch) int64
• func ExpectedGasLimit(lastBlockGasLimit uint64, targetGasLimit uint64) uint64
• func FetchBuilderClient(ctx context.Context, service string, address string, monitor metrics.Service, ...) (builder.Service, error)
• func HierarchicalBool(variable string, path string) bool
• func Int64ToUint64(val int64) uint64
• func IntToUint64(val int) uint64
• func LogLevel(path string) zerolog.Level
• func LogWithID(_ context.Context, log zerolog.Logger, tag string) zerolog.Logger
• func ProcessConcurrency(path string) int64
• func SetBuilderClientTimeoutDefaults()
• func SlotToInt64(slot phase0.Slot) int64
• func Timeout(path string) time.Duration
• func ValidatorPubkey(account e2wtypes.Account) phase0.BLSPubKey
• type ScatterResult
  • func Scatter(inputLen int, concurrency int, ...) ([]*ScatterResult, error)

Functions

func BeaconNodeAddresses

func BeaconNodeAddresses(path string) []string

BeaconNodeAddresses returns the best beacon node addresses for the path.

func BeaconNodeAddressesForAttesting

func BeaconNodeAddressesForAttesting() []string

BeaconNodeAddressesForAttesting obtains the beacon node addresses used for attesting from the configuration. This takes into account the used styles in strategies, and removes duplicates.

func BeaconNodeAddressesForProposing

func BeaconNodeAddressesForProposing() []string

BeaconNodeAddressesForProposing obtains the beacon node addresses used for proposing from the configuration. This takes into account the used styles in strategies, and removes duplicates.

func CommitHash

func CommitHash() string

CommitHash returns the commit hash of the build, if available.

func EpochToInt64

func EpochToInt64(epoch phase0.Epoch) int64

EpochToInt64 converts an epoch to an int64.

func ExpectedGasLimit

func ExpectedGasLimit(
	lastBlockGasLimit uint64,
	targetGasLimit uint64,
) uint64

ExpectedGasLimit returns the expected gas limit for a block given the gas limit of the previous block and the target gas limit for the subsequent proposer.

func FetchBuilderClient

func FetchBuilderClient(ctx context.Context, service string, address string, monitor metrics.Service, releaseVersion string) (builder.Service, error)

FetchBuilderClient fetches a builder client, instantiating it if required.

func HierarchicalBool

func HierarchicalBool(variable string, path string) bool

HierarchicalBool returns the best configuration value for the path.

func Int64ToUint64

func Int64ToUint64(val int64) uint64

Int64ToUint64 converts an int64 to a uint64.

func IntToUint64

func IntToUint64(val int) uint64

IntToUint64 converts an int to a uint64.

func LogLevel

func LogLevel(path string) zerolog.Level

LogLevel returns the best log level for the path.

func LogWithID

func LogWithID(_ context.Context, log zerolog.Logger, tag string) zerolog.Logger

LogWithID returns a new logger based on the supplied logger with an additional ID field.

func ProcessConcurrency

func ProcessConcurrency(path string) int64

ProcessConcurrency returns the best process concurrency for the path.

func SetBuilderClientTimeoutDefaults

func SetBuilderClientTimeoutDefaults()

SetBuilderClientTimeoutDefaults sets default timeouts for builderclient services only if not already configured.

func SlotToInt64

func SlotToInt64(slot phase0.Slot) int64

SlotToInt64 converts a slot to an int64.

func Timeout

func Timeout(path string) time.Duration

Timeout returns the best timeout for the path.

func ValidatorPubkey

func ValidatorPubkey(account e2wtypes.Account) phase0.BLSPubKey

ValidatorPubkey returns the public key of the validator associated with the account.

Types

type ScatterResult

type ScatterResult struct {
	// Offset is the offset at which the worker started.
	Offset int
	// Extent is the user-defined result of running the scatter function.
	Extent interface{}
}

ScatterResult is the result of a single scatter worker.

func Scatter

func Scatter(inputLen int, concurrency int, work func(int, int, *sync.RWMutex) (interface{}, error)) ([]*ScatterResult, error)

Scatter scatters a computation across multiple goroutines, returning a set of per-worker results.