resourcelimit

package

v2.11.2 Latest Latest Go to latest Published: Jul 31, 2026 License: GPL-3.0 Imports: 8 Imported by: 0

Details

Rendered for

This section is empty.

This section is empty.

func WithGuard(ctx context.Context, guard *Guard) context.Context

WithGuard stores a resource guard in context.

type Guard struct {
	// contains filtered or unexported fields
}

Guard owns an OS-specific resource limit scope for a DAG run.

func FromContext(ctx context.Context) *Guard

FromContext returns the resource guard stored in context, if present.

func Start(ctx context.Context, opts Options) *Guard

Start attempts to prepare OS-native resource enforcement. It never returns an error because resource enforcement is a best-effort runtime capability.

func (g *Guard) AssignProcess(pid int) error

AssignProcess adds a process to the resource-limited scope.

func (g *Guard) Close(ctx context.Context) error

Close releases guard resources.

func (g *Guard) Result() Result

Result returns enforcement status for the guard.

type Options struct {
	DAGName  string
	DAGRunID string
	Limits   *core.ResourceLimits
}

Options describes resource limits for one DAG run.

type Result struct {
	Enforced bool
	Enforcer string
	Warning  string
}

Result describes whether the requested limits are enforced.