Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for Early (0.2 sec)

  1. cni/pkg/util/podutil.go

    }
    
    // Get any IPs currently assigned to the Pod.
    //
    // If 'PodIPs' exists, it is preferred (and should be guaranteed to contain the address in 'PodIP'),
    // otherwise fallback to 'PodIP'.
    //
    // Note that very early in the pod's lifecycle (before all the node CNI plugin invocations finish)
    // K8S may not have received the pod IPs yet, and may not report the pod as having any.
    func GetPodIPsIfPresent(pod *corev1.Pod) []netip.Addr {
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Wed May 01 18:04:40 GMT 2024
    - 4.1K bytes
    - Viewed (0)
  2. cmd/iam-store.go

    		d.CreateDate = now
    	}
    	d.Policy = p
    }
    
    // parseJSON parses both the old and the new format for storing policy
    // definitions.
    //
    // The on-disk format of policy definitions has changed (around early 12/2021)
    // from policy.Policy to PolicyDoc. To avoid a migration, loading supports
    // both the old and the new formats.
    func (d *PolicyDoc) parseJSON(data []byte) error {
    	json := jsoniter.ConfigCompatibleWithStandardLibrary
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Apr 27 10:04:10 GMT 2024
    - 75.2K bytes
    - Viewed (2)
  3. internal/bucket/lifecycle/lifecycle_test.go

    			objectName:     "foxdir/fooobject/foo.txt",
    			objectModTime:  time.Now().UTC().Add(-10 * 24 * time.Hour), // Created 10 days ago
    			expectedAction: DeleteAction,
    		},
    		// Too early to remove (test Days)
    		{
    			inputConfig:    `<LifecycleConfiguration><Rule><Filter><Prefix>foodir/</Prefix></Filter><Status>Enabled</Status><Expiration><Days>5</Days></Expiration></Rule></LifecycleConfiguration>`,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:11:10 GMT 2024
    - 53.2K bytes
    - Viewed (0)
  4. cmd/bucket-replication.go

    			EventName: event.ObjectReplicationNotTracked,
    		})
    		if dobj.VersionID == "" {
    			rinfo.ReplicationStatus = replication.Failed
    		} else {
    			rinfo.VersionPurgeStatus = Failed
    		}
    		return
    	}
    	// early return if already replicated delete marker for existing object replication/ healing delete markers
    	if dobj.DeleteMarkerVersionID != "" {
    		toi, err := tgt.StatObject(ctx, tgt.Bucket, dobj.ObjectName, minio.StatObjectOptions{
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 112.2K bytes
    - Viewed (1)
  5. cmd/test-utils_test.go

    	req, err := newTestRequest(method, urlStr, contentLength, body)
    	if err != nil {
    		return nil, err
    	}
    
    	// Anonymous request return early.
    	if accessKey == "" || secretKey == "" {
    		return req, nil
    	}
    
    	if signer == signerV2 {
    		err = signRequestV2(req, accessKey, secretKey)
    		req.Header.Del("x-amz-content-sha256")
    	} else {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 17:26:51 GMT 2024
    - 76.2K bytes
    - Viewed (0)
  6. cmd/xl-storage-format-v2.go

    		return errDoneForNow
    	})
    	return isDeleteMarker
    }
    
    // AllHidden returns true are no versions that would show up in a listing (ie all free markers)
    // Optionally also return early if top is a delete marker.
    func (x xlMetaBuf) AllHidden(topDeleteMarker bool) bool {
    	vers, headerV, _, buf, err := decodeXLHeaders(x)
    	if err != nil {
    		return false
    	}
    	if vers == 0 {
    		return true
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 05:07:37 GMT 2024
    - 63.6K bytes
    - Viewed (1)
Back to top