Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for patchRewriteProbe (0.21 sec)

  1. pkg/kube/inject/app_probe.go

    	}
    	return string(b)
    }
    
    func allContainers(pod *corev1.Pod) []corev1.Container {
    	return append(slices.Clone(pod.Spec.InitContainers), pod.Spec.Containers...)
    }
    
    // patchRewriteProbe generates the patch for webhook.
    func patchRewriteProbe(annotations map[string]string, pod *corev1.Pod, defaultPort int32) {
    	statusPort := int(defaultPort)
    	if v, f := annotations[annotation.SidecarStatusPort.Name]; f {
    		p, err := strconv.Atoi(v)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Aug 04 15:06:24 UTC 2023
    - 8.4K bytes
    - Viewed (0)
  2. pkg/kube/inject/app_probe_test.go

    									},
    								},
    								TimeoutSeconds:      20,
    								PeriodSeconds:       10,
    								InitialDelaySeconds: 10,
    							},
    						},
    					},
    				},
    			},
    		},
    	} {
    		patchRewriteProbe(annotations, tc.pod, 15020)
    		if !reflect.DeepEqual(tc.pod, tc.expected) {
    			t.Errorf("[%v] failed, want %v, got %v", tc.name, tc.expected, tc.pod)
    		}
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Aug 04 15:06:24 UTC 2023
    - 8.6K bytes
    - Viewed (0)
  3. pkg/kube/inject/webhook.go

    			_, previouslyInjected := pod.Annotations[annotation.SidecarStatus.Name]
    			sidecar.Env = mergeOrAppendProbers(previouslyInjected, sidecar.Env, prober)
    		}
    		patchRewriteProbe(pod.Annotations, pod, req.meshConfig.GetDefaultConfig().GetStatusPort())
    	}
    	return nil
    }
    
    // mergeOrAppendProbers ensures that if sidecar has existing ISTIO_KUBE_APP_PROBERS,
    // then probers should be merged.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 14 17:59:39 UTC 2024
    - 42.2K bytes
    - Viewed (0)
Back to top