Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 146 for idempotent (0.39 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top