distributedrunner

package
v0.15.0 Latest Latest
Warning

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

 Go to latest Published: Sep 9, 2026 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// ShutdownTimeout is the deadline passed through the distributed runner
	// graph. Stop functions whose underlying Close APIs do not accept a context
	// cannot be forcibly interrupted by it.
	ShutdownTimeout = 3 * time.Minute
)

Variables

This section is empty.

Functions

This section is empty.

Types

type Runtime 

type Runtime struct {
	Runner *runner.Runner
	// contains filtered or unexported fields
}

Runtime owns the started distributed-runner graph and its role-level handle.

func Start 

func Start(options StartOptions) (*Runtime, error)

Start assembles, validates, and starts the distributed-runner dependency graph.

func (*Runtime) Stop 

func (r *Runtime) Stop(ctx context.Context) error

Stop tears down the graph once, in reverse dependency order.

type StartOptions 

type StartOptions struct {
	Log          *slog.Logger
	Context      context.Context
	Group        *errgroup.Group
	Config       *runnerconfig.Config
	ClientConfig *clientconfig.Config
	ListenAddr   string
	DataPath     string

	// ContainerdSocket selects an external daemon. When it is empty,
	// ContainerdBinary and ContainerdBinDir describe the embedded daemon the
	// command selected before constructing the graph.
	ContainerdSocket string
	ContainerdBinary string
	ContainerdBinDir string
}

StartOptions contains the resolved command inputs used to assemble one fixed distributed-runner boot graph.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.