- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for Early (0.15 sec)
-
cmd/routers.go
var globalMiddlewares = []mux.MiddlewareFunc{ // set x-amz-request-id header and others addCustomHeadersMiddleware, // The generic tracer needs to be the first middleware to catch all requests // returned early by any other middleware (but after the middleware that // sets the amz request id). httpTracerMiddleware, // Auth middleware verifies incoming authorization headers and routes them
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 08 19:08:18 GMT 2024 - 3.6K bytes - Viewed (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) -
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) -
cmd/bucket-metadata.go
} // migrate config for remote targets by encrypting data if currently unencrypted and kms is configured. func (b *BucketMetadata) migrateTargetConfig(ctx context.Context, objectAPI ObjectLayer) error { var err error // early return if no targets or already encrypted if len(b.BucketTargetsConfigJSON) == 0 || GlobalKMS == nil || len(b.BucketTargetsConfigMetaJSON) != 0 { return nil }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 16.5K bytes - Viewed (0) -
cmd/admin-router.go
r = r.WithContext(newContext(r, w, handlerName)) defer logger.AuditLog(r.Context(), w, r, mustGetClaimsFromToken(r)) // Check if object layer is available, if not return error early. if !handlerFlags.Has(noObjLayerFlag) { objectAPI := newObjectLayerFn() if objectAPI == nil || globalNotificationSys == nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Mar 10 21:09:36 GMT 2024 - 25.5K bytes - Viewed (0) -
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) -
cmd/object-api-utils.go
// algorithms completes a roundtrip. If any algorithm // produces an incorrect checksum it fails with a hard error. // // compressSelfTest tries to catch any issue in the compression implementation // early instead of silently corrupting data. func compressSelfTest() { // 4 MB block. // Approx runtime ~30ms data := make([]byte, 4<<20) rng := rand.New(rand.NewSource(0)) for i := range data {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 11 11:55:34 GMT 2024 - 35.6K bytes - Viewed (1) -
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) -
src/cmd/cgo/doc.go
of an error message on a given line to deduce the information it needs. The program is syntactically valid regardless of whether each name is a type or an ordinary identifier, so there will be no syntax errors that might stop parsing early. An error on not-declared:1 indicates that foo is undeclared. An error on not-type:1 indicates that foo is not a type (if declared at all, it is an identifier).
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Sun Mar 31 09:02:45 GMT 2024 - 42.1K bytes - Viewed (0) -
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)