Function AsyncContainers

pkg/workloads/k8s.go:239–250

(api spec.API, queueURL string)

}

func AsyncContainers(api spec.API, queueURL string) ([]kcore.Container, []kcore.Volume) {
	k8sName := K8sName(api.Name)

	containers, volumes := userPodContainers(api)
	dequeuerContainer, dequeuerVolume := asyncDequeuerProxyContainer(api, queueURL)
	dequeuerContainer.VolumeMounts = append(dequeuerContainer.VolumeMounts, APIConfigMount(k8sName))

	containers = append(containers, dequeuerContainer)
	volumes = append(volumes, dequeuerVolume, APIConfigVolume(k8sName))

	return containers, volumes
}

func TaskContainers(api spec.API, job *spec.JobKey) ([]kcore.Container, []kcore.Volume) {
	containers, volumes := userPodContainers(api)