Versions in this module Expand all Collapse all v0 v0.1.3 May 6, 2026 Changes in this version + func ExtractArchiveFromReader(ctx context.Context, dest string, fileName string, r io.Reader) error + type Config struct + HumanReadable bool + LoggingLevel zerolog.Level + RegistryPassword string + RegistryUsername string + RootDest string + S3 s3.ObjectStore + Store *store.RedisStore + Sub *pubgo.Subscription + type Engine struct + func New(sub *pubgo.Subscription, opts ...Opts) *Engine + func (e *Engine) ConsumeEvent(ctx context.Context, cli *client.Client, event *types.BenchEvent) error + func (e *Engine) PullDataset(ctx context.Context, url string, outputPath string, fromS3 bool) error + func (e *Engine) PullDatasetFromS3(ctx context.Context, url string, outputPath string) error + func (e *Engine) RecordRun(ctx context.Context, event *types.BenchEvent, result string) error + func (e *Engine) RunContainer(ctx context.Context, image, datasetName, datasetPath, checkpointPath string) (string, error) + func (e *Engine) Start(ctx context.Context) + type Opts func(cfg *Config) + func WithHostSourceVolume(source string) Opts + func WithHumanReadableLogs() Opts + func WithLoggingLevel(lvl zerolog.Level) Opts + func WithRedisStore(store *store.RedisStore) Opts + func WithRegistryCreds(username, password string) Opts + func WithRootDest(dest string) Opts + func WithS3(store s3.ObjectStore) Opts
Go to main page