- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 146 for idempotent (0.39 sec)
-
pkg/scheduler/framework/plugins/volumebinding/volume_binding.go
return framework.AsStatus(err) } logger.V(5).Info("Success binding volumes for pod", "pod", klog.KObj(pod)) return nil } // Unreserve clears assumed PV and PVC cache. // It's idempotent, and does nothing if no cache found for the given pod. func (pl *VolumeBinding) Unreserve(ctx context.Context, cs *framework.CycleState, pod *v1.Pod, nodeName string) { s, err := getStateData(cs) if err != nil { return
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 16 14:13:06 UTC 2024 - 16.4K bytes - Viewed (0) -
pkg/kubelet/volumemanager/cache/actual_state_of_world.go
// remounted to reflect changes in the referencing pod. Atomically updating // volumes, depend on this to update the contents of the volume. // All volume mounting calls should be idempotent so a second mount call for // volumes that do not need to update contents should not fail.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 09 07:34:33 UTC 2024 - 45.8K bytes - Viewed (0) -
src/go/token/position_test.go
checkPos(bpos3, "fileB:1:4") checkNumFiles(2) // After removal, queries on fileA fail. fset.RemoveFile(a) checkPos(apos3, "-") checkPos(bpos3, "fileB:1:4") checkNumFiles(1) // idempotent / no effect fset.RemoveFile(a) checkPos(apos3, "-") checkPos(bpos3, "fileB:1:4") checkNumFiles(1) } func TestFileAddLineColumnInfo(t *testing.T) { const ( filename = "test.go"
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 31 20:26:14 UTC 2024 - 14.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Reader.kt
* `ID > lastGoodStreamId` on a new connection. In- flight streams with * `ID <= lastGoodStreamId` can only be replayed on a new connection if they are idempotent. * * @param lastGoodStreamId the last stream ID the peer processed before sending this message. If * [lastGoodStreamId] is zero, the peer processed no frames.
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 19.9K bytes - Viewed (0) -
pilot/pkg/config/file/store.go
key := r.newKey() oldSha, found := s.shas[key] if !found || oldSha != r.sha { scope.Debugf("KubeSource.ApplyContent: Set: %v/%v", r.schema.GroupVersionKind(), r.fullName()) // apply is idempotent, but configstore is not, thus the odd logic here _, err := s.inner.Update(*r.config) if err != nil { _, err = s.inner.Create(*r.config) if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 02 17:36:47 UTC 2024 - 18.2K 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/crypto/tls/handshake_messages.go
// // For most messages, the message is marshalled using their marshal method, // since their wire representation is idempotent. For clientHelloMsg and // serverHelloMsg, we store the original wire representation of the message and // use that for hashing, since unmarshal/marshal are not idempotent due to // extension ordering and other malleable fields, which may cause differences // between what was received and what we marshal.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 03:10:12 UTC 2024 - 51.8K bytes - Viewed (0) -
pkg/kube/util.go
func IstioUserAgent() string { return adjustCommand(os.Args[0]) + "/" + istioversion.Info.Version } // SetRestDefaults is a helper function that sets default values for the given rest.Config. // This function is idempotent. func SetRestDefaults(config *rest.Config) *rest.Config { if config.GroupVersion == nil || config.GroupVersion.Empty() { config.GroupVersion = &corev1.SchemeGroupVersion } if len(config.APIPath) == 0 {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 05:10:23 UTC 2024 - 18.6K bytes - Viewed (0) -
common-protos/k8s.io/api/admissionregistration/v1beta1/generated.proto
// if the object being admitted is modified by other admission plugins after the initial webhook call. // Webhooks that specify this option *must* be idempotent, able to process objects they previously admitted. // Note: // * the number of additional invocations is not guaranteed to be exactly one.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Mar 11 18:43:24 UTC 2024 - 22.6K 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)