pod_group

func Create(namespace, name, queue string) *v2alpha2.PodGroup

func CreateDistributedJob(
	ctx context.Context, clientset *kubernetes.Clientset, k8sClient runtimeClient.WithWatch,
	ownerQueue *v2.Queue, count int, resources v1.ResourceRequirements,
	priorityClassName string,
) (*v2alpha2.PodGroup, []*v1.Pod)

func CreatePrefixedDistributedJob(
	ctx context.Context, clientset *kubernetes.Clientset, k8sClient runtimeClient.WithWatch,
	ownerQueue *v2.Queue, prefix string, count int, resources v1.ResourceRequirements,
	priorityClassName string,
) (*v2alpha2.PodGroup, []*v1.Pod)

func CreateWithPods(ctx context.Context, client *kubernetes.Clientset, kaiClient *kaiClient.Clientset,
	podGroupName string, q *v2.Queue, numPods int, priorityClassName *string,
	requirements v1.ResourceRequirements) (*v2alpha2.PodGroup, []*v1.Pod)

func DeleteAllInNamespace(
	ctx context.Context, client runtimeClient.Client, namespace string,
) error

func IsNotReadyForScheduling(event *v1.Event) bool