prow/flagutil/kubernetes_cluster_clients.go
func (o *ExperimentalKubernetesOptions) BuildClusterClients(namespace string, dryRun bool) (buildClusterClients map[string]corev1.PodInterface, err error) {
	if err := o.resolve(dryRun); err != nil {
		return nil, err
	}

	if o.dryRun {
		return nil, errors.New("no dry-run pod client is supported for build clusters in dry-run mode")
	}

	buildClients := map[string]corev1.PodInterface{}
	for context, client := range o.kubernetesClientsByContext {
		buildClients[context] = client.CoreV1().Pods(namespace)
	}
	return buildClients, nil
}
func (o *ExperimentalKubernetesOptions) BuildClusterClients(namespace string, dryRun bool) (buildClusterClients map[string]corev1.PodInterface, err error) {
	if err := o.resolve(dryRun); err != nil {
		return nil, err
	}

	if o.dryRun {
		return nil, errors.New("no dry-run pod client is supported for build clusters in dry-run mode")
	}

	buildClients := map[string]corev1.PodInterface{}
	for context, client := range o.kubernetesClientsByContext {
		buildClients[context] = client.CoreV1().Pods(namespace)
	}
	return buildClients, nil
}
func ( o * ExperimentalKubernetesOptions ) BuildClusterClients ( namespace string , dryRun bool ) ( buildClusterClients map [ string ] corev1 . PodInterface , err error ) { if err := o . resolve ( dryRun ) ; err != nil { return nil , err } if o . dryRun { return nil , errors . New ( " " ) } buildClients := map [ string ] corev1 . PodInterface { } for context , client := range o . kubernetesClientsByContext { buildClients [ context ] = client . CoreV1 ( ) . Pods ( namespace ) } return buildClients , nil }
// BuildClusterClients returns Pod clients for build clusters.
BuildClusterClients returns Pod clients for build clusters .