- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 41 for crinal (0.14 sec)
-
cmd/batch-expire.go
// Close the saverQuitCh - this also triggers saving in-memory state // immediately one last time before we exit this method. xioutil.SafeClose(saverQuitCh) // Notify expire jobs final status to the configured endpoint buf, _ := json.Marshal(ri) if err := r.Notify(context.Background(), bytes.NewReader(buf)); err != nil { batchLogIf(context.Background(), fmt.Errorf("unable to notify %v", err)) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 21K bytes - Viewed (1) -
cmd/admin-router.go
// Apply http tracing "middleware" based on presence of flag. var f2 http.HandlerFunc if handlerFlags.Has(traceAllFlag) { f2 = httpTraceAll(f) } else { f2 = httpTraceHdrs(f) } // call the final handler f2(w, r) } // Enable compression of responses based on presence of flag. if !handlerFlags.Has(noGZFlag) { handler = gzipHandler(handler) } return handler }
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) -
cmd/site-replication.go
} var rules []lifecycle.Rule for _, rule := range rMap { rules = append(rules, rule) } // no rules, return if len(rules) == 0 { return []byte{}, nil } // get final list for write finalLcCfg := lifecycle.Lifecycle{ XMLName: xmlName, Rules: rules, ExpiryUpdatedAt: &updatedAt, } if err := finalLcCfg.Validate(); err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 184.2K bytes - Viewed (1) -
cmd/storage-rest-common.go
type nsScannerOptions struct { DiskID string `msg:"id"` ScanMode int `msg:"m"` Cache *dataUsageCache `msg:"c"` } type nsScannerResp struct { Update *dataUsageEntry `msg:"u"` Final *dataUsageCache `msg:"f"`
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 12 21:00:20 GMT 2024 - 2.9K bytes - Viewed (0) -
cmd/routers.go
setUploadForwardingMiddleware, // Add bucket forwarding middleware setBucketForwardingMiddleware, // Add new middlewares here. } // configureServer handler returns final handler for the http server. func configureServerHandler(endpointServerPools EndpointServerPools) (http.Handler, error) { // Initialize router. `SkipClean(true)` stops minio/mux from // normalizing URL path minio/minio#3256
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) -
cmd/signature-v4.go
canonicalRequestBytes := sha256.Sum256([]byte(canonicalRequest)) stringToSign += hex.EncodeToString(canonicalRequestBytes[:]) return stringToSign } // getSigningKey hmac seed to calculate final signature. func getSigningKey(secretKey string, t time.Time, region string, stype serviceType) []byte { date := sumHMAC([]byte("AWS4"+secretKey), []byte(t.Format(yyyymmdd))) regionBytes := sumHMAC(date, []byte(region))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:45:54 GMT 2024 - 12.3K bytes - Viewed (0) -
cmd/erasure-multipart.go
if opts.EncryptFn != nil { fi.Checksum = opts.EncryptFn("object-checksum", fi.Checksum) } } delete(fi.Metadata, hash.MinIOMultipartChecksum) // Not needed in final object. // Save the final object size and modtime. fi.Size = objectSize fi.ModTime = opts.MTime if opts.MTime.IsZero() { fi.ModTime = UTCNow() } // Save successfully calculated md5sum.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 43K bytes - Viewed (0) -
internal/s3select/sql/evaluate.go
// // If an aggregation node is present as a descendant (when // e.prop.isAggregation is true), we call evalNode on all child nodes, // check for errors, but do not perform any combining of the results // of child nodes. The final result row is returned after all rows are // processed, and the `getAggregate` function is called. func (e *AliasedExpression) evalNode(r Record, tableAlias string) (*Value, error) { return e.Expression.evalNode(r, tableAlias)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Dec 23 07:19:11 GMT 2023 - 12K bytes - Viewed (0) -
cmd/erasure.go
updates <- cache.clone() lastSave = cache.Info.LastUpdate case v, ok := <-bucketResults: if !ok { // Save final state... cache.Info.NextCycle = wantCycle cache.Info.LastUpdate = time.Now() scannerLogOnceIf(ctx, cache.save(ctx, er, dataUsageCacheName), "nsscanner-channel-closed") updates <- cache.clone()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 06:32:14 GMT 2024 - 16K bytes - Viewed (1) -
cmd/batch-handlers.go
if aerr == nil { return } batchLogIf(ctx, fmt.Errorf("trying %s: Unable to cleanup failed multipart replication %s on remote %s/%s: %w - this may consume space on remote cluster", humanize.Ordinal(attempts), res.UploadID, tgtBucket, tgtObject, aerr)) attempts++ time.Sleep(time.Second) } } }() var ( hr *hash.Reader pInfo PartInfo )
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 55.2K bytes - Viewed (0)