- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 54 for idempotency (0.35 sec)
-
pkg/volume/downwardapi/downwardapi.go
klog.V(3).Infof("Setting up a downwardAPI volume %v for pod %v/%v at %v", b.volName, b.pod.Namespace, b.pod.Name, dir) // Wrap EmptyDir. Here we rely on the idempotency of the wrapped plugin to avoid repeatedly mounting wrapped, err := b.plugin.host.NewWrapperMounter(b.volName, wrappedVolumeSpec(), b.pod, *b.opts) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 10.4K bytes - Viewed (0) -
pilot/pkg/xds/cds_test.go
names.Insert(n.GetExact()) } assert.Equal(t, sets.SortedList(names), sets.SortedList(sets.New(sans...))) } // Run multiple assertions to verify idempotency; previous versions had issues here. for i := 0; i < 2; i++ { clusters := s.Clusters(s.SetupProxy(&model.Proxy{ConfigNamespace: "test"}))
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 01 02:06:39 UTC 2024 - 9.2K bytes - Viewed (0) -
pkg/kube/inject/inject_test.go
if actual != tc.want { t.Fatalf("Unexpected result.\nExpected:\n%v\nActual:\n%v", tc.want, actual) } t.Run("idempotency", func(t *testing.T) { actual := appendMultusNetwork(actual, "istio-cni") if actual != tc.want { t.Fatalf("Function is not idempotent.\nExpected:\n%v\nActual:\n%v", tc.want, actual) } }) }) } } func Test_updateClusterEnvs(t *testing.T) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 31 20:35:11 UTC 2024 - 34.1K bytes - Viewed (0) -
src/net/http/request.go
case "GET", "HEAD", "OPTIONS", "TRACE": return true } // The Idempotency-Key, while non-standard, is widely used to // mean a POST or other request is idempotent. See // https://golang.org/issue/19943#issuecomment-421092421 if r.Header.has("Idempotency-Key") || r.Header.has("X-Idempotency-Key") { return true } } return false }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 49.4K bytes - Viewed (0) -
src/math/big/float_test.go
toBinary(r1), toBinary(r), ) return } // h and f should be the same // (repeated rounding should be idempotent) h := new(Float).SetMode(mode).SetPrec(prec).Set(f) if !alike(h, f) { t.Errorf("round %s (%d bits, %s) not idempotent: got %s and %s; want %s", toBinary(x), prec, mode, toBinary(h.int64()), toBinary(r1), toBinary(r), ) return } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 11 20:22:45 UTC 2024 - 51.9K bytes - Viewed (0) -
pkg/kube/inject/inject.go
pod := req.pod.DeepCopy() prevStatus := injectionStatus(pod) if prevStatus == nil { return req.pod } // We found a previous status annotation. Possibly we are re-injecting the pod // To ensure idempotency, remove our injected containers first for _, c := range prevStatus.Containers { pod.Spec.Containers = modifyContainers(pod.Spec.Containers, c, Remove) } for _, c := range prevStatus.InitContainers {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 31 20:35:11 UTC 2024 - 28.8K bytes - Viewed (0) -
cmd/kubeadm/app/phases/kubeconfig/kubeconfig_test.go
existingKubeConfig: invalidConfig, kubeConfig: invalidConfig, expectedError: true, }, { // if KubeConfig is equal to the existingKubeConfig - refers to the same cluster -, use the existing (Test idempotency) name: "KubeConfig refers to the same cluster", existingKubeConfig: config, kubeConfig: config, },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 17:04:18 UTC 2024 - 39.5K bytes - Viewed (0) -
src/net/http/transport.go
// request is idempotent and either has no body or has its [Request.GetBody] // defined. HTTP requests are considered idempotent if they have HTTP methods // GET, HEAD, OPTIONS, or TRACE; or if their [Header] map contains an // "Idempotency-Key" or "X-Idempotency-Key" entry. If the idempotency key // value is a zero-length slice, the request is treated as idempotent but the // header is not sent on the wire.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 06 21:59:21 UTC 2024 - 91K bytes - Viewed (0) -
src/net/http/transport_test.go
req: &Request{Method: "POST", Header: Header{"Idempotency-Key": {"x"}}}, want: true, }, { name: "POST_x-idempotency-key", req: &Request{Method: "POST", Header: Header{"X-Idempotency-Key": {"x"}}}, want: true, }, { name: "POST_body", req: &Request{Method: "POST", Header: Header{"Idempotency-Key": {"x"}}, Body: someBody}, want: false, }, }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 06 21:59:21 UTC 2024 - 192.6K bytes - Viewed (0) -
pkg/kube/inject/webhook.go
parsedContainers.InitContainers = parser(InitContainers, unMarshalledStatus) return parsedContainers } // reinsertOverrides applies the containers listed in OverrideAnnotation to a pod. This is to achieve // idempotency by handling an edge case where an injection template is modifying a container already // present in the pod spec. In these cases, the logic to strip injected containers would remove the
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 17:59:39 UTC 2024 - 42.2K bytes - Viewed (0)