util

package
v1.8.1 Latest Latest
Warning

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

Go to latest
Published: Mar 18, 2024 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func BeaconNodeAddresses added in v1.5.0

func BeaconNodeAddresses(path string) []string

BeaconNodeAddresses returns the best beacon node addresses for the path.

func BeaconNodeAddressesForAttesting added in v1.8.0

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 added in v1.8.0

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 added in v1.8.0

func CommitHash() string

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

func FetchBuilderClient added in v1.6.0

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

FetchBuilderClient fetches a builder client, instantiating it if required.

func LogLevel added in v1.2.0

func LogLevel(path string) zerolog.Level

LogLevel returns the best log level for the path.

func LogWithID added in v1.2.0

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 added in v1.2.0

func ProcessConcurrency(path string) int64

ProcessConcurrency returns the best process concurrency for the path.

func Timeout added in v1.2.0

func Timeout(path string) time.Duration

Timeout returns the best timeout for the path.

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.

Jump to

Keyboard shortcuts

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