k8s

package

v2.0.0 Latest Latest Go to latest Published: Dec 22, 2025 License: Apache-2.0 Imports: 9 Imported by: 0

Details

This section is empty.

This section is empty.

func InitScheme() error

InitScheme adds the executor API types to the scheme

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

QueueClient implements queue operations using Kubernetes TaskAction CRs

func NewQueueClient(k8sClient client.Client, namespace string) *QueueClient

NewQueueClient creates a new Kubernetes-based queue client

func (q *QueueClient) AbortQueuedAction(ctx context.Context, actionID *common.ActionIdentifier, reason *string) error

AbortQueuedAction deletes a specific TaskAction CR If the action has children, Kubernetes will cascade delete them via OwnerReferences

func (q *QueueClient) AbortQueuedRun(ctx context.Context, runID *common.RunIdentifier, reason *string) error

AbortQueuedRun deletes the root TaskAction CR for a run Kubernetes will automatically cascade delete all child TaskActions via OwnerReferences

func (q *QueueClient) EnqueueAction(ctx context.Context, req *workflow.EnqueueActionRequest) error

EnqueueAction creates a TaskAction CR in Kubernetes