execution

package

v1.0.0 Latest Latest Go to latest Published: Mar 7, 2026 License: MIT Imports: 8 Imported by: 0

Details

This section is empty.

This section is empty.

func ApplyDeadlinePolicy(
	ctx context.Context,
	policy core.DeadlinePolicy,
) (admissionCtx context.Context, postAdmissionDeadline time.Time)

ApplyDeadlinePolicy decides how deadlines behave around admission.

func ReapplyDeadline(
	ctx context.Context,
	deadline time.Time,
) (context.Context, context.CancelFunc)

ReapplyDeadline reapplies deadline after admission.

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

Executor is the ONLY component allowed to run user code.

func NewExecutor(
	admission *admission.Controller,
	shutdown core.ShutdownCoordinator,
) *Executor

func (e *Executor) Execute(
	exec core.Execution,
	fn func(context.Context) error,
) Result

type Result struct {
	Err          error
	Kind         ierrors.Kind
	CancelSource core.CancellationSource
	Completed    bool
}

Result represents the final execution outcome.

func BuildResult(ctx context.Context, execErr error) Result

BuildResult normalizes execution outcome.