util

Documentation

Index

• func BLSID(id uint64) *bls.ID
• func InitMajordomo(ctx context.Context) (majordomo.Service, error)
• func LogLevel(path string) zerolog.Level
• func ResolvePath(path string) string
• type ScatterResult
  • func Scatter(inputLen int, work func(int, int, *sync.RWMutex) (interface{}, error)) ([]*ScatterResult, error)

Functions

func BLSID

func BLSID(id uint64) *bls.ID

BLSID turns a uint64 in to a BLS identifier.

func InitMajordomo

func InitMajordomo(ctx context.Context) (majordomo.Service, error)

func LogLevel

func LogLevel(path string) zerolog.Level

LogLevel returns the best log level for the path.

func ResolvePath

func ResolvePath(path string) string

ResolvePath resolves a potentially relative path to an absolute 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, work func(int, int, *sync.RWMutex) (interface{}, error)) ([]*ScatterResult, error)

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