util

Documentation

Index

• func BeaconNodeAddresses(path string) []string
• func FetchBuilderClient(ctx context.Context, address string, monitor metrics.Service) (builder.Service, error)
• func LogLevel(path string) zerolog.Level
• func LogWithID(_ context.Context, log zerolog.Logger, tag string) zerolog.Logger
• func ProcessConcurrency(path string) int64
• func Timeout(path string) time.Duration
• 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 FetchBuilderClient

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

FetchBuilderClient fetches a builder client, instantiating it if required.

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 Timeout

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