- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 33 for Final (0.12 sec)
-
internal/http/server.go
return srv } // UseReadHeaderTimeout configure read header timeout func (srv *Server) UseReadHeaderTimeout(d time.Duration) *Server { srv.ReadHeaderTimeout = d return srv } // UseHandler configure final handler for this HTTP *Server func (srv *Server) UseHandler(h http.Handler) *Server { srv.Handler = h return srv } // UseTLSConfig pass configured TLSConfig for this HTTP *Server
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Feb 09 21:25:16 GMT 2024 - 7.7K bytes - Viewed (0) -
internal/bucket/versioning/versioning_test.go
} tests := []struct { prefix string excluded bool }{ { prefix: "app1-jobs/output/_temporary/attempt1/data.csv", excluded: true, }, { prefix: "app1-jobs/output/final/attempt1/data.csv", excluded: false, }, } for i, test := range tests { if v.PrefixSuspended(test.prefix) != test.excluded { if test.excluded {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 08 05:06:44 GMT 2022 - 8.8K bytes - Viewed (0) -
cmd/erasure-object_test.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jan 30 20:43:25 GMT 2024 - 36.8K bytes - Viewed (0) -
cmd/erasure-object.go
partsMetadata[index].SetInlineData() } if opts.DataMovement { partsMetadata[index].SetDataMov() } } // Rename the successfully written temporary object to final location. onlineDisks, versions, oldDataDir, err := renameData(ctx, onlineDisks, minioMetaTmpBucket, tempObj, partsMetadata, bucket, object, writeQuorum) if err != nil { if errors.Is(err, errFileNotFound) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 77.2K bytes - Viewed (2) -
cmd/storage-rest-common_gen.go
if dc.IsNil() { err = dc.ReadNil() if err != nil { err = msgp.WrapError(err, "Final") return } z.Final = nil } else { if z.Final == nil { z.Final = new(dataUsageCache) } err = z.Final.DecodeMsg(dc) if err != nil { err = msgp.WrapError(err, "Final") return } } default: err = dc.Skip() if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 7.9K bytes - Viewed (0) -
cmd/storage-rest-client.go
Cache: &cache, }) if err != nil { return cache, toStorageErr(err) } var final *dataUsageCache err = st.Results(func(resp *nsScannerResp) error { if resp.Update != nil { select { case <-ctx.Done(): case updates <- *resp.Update: } } if resp.Final != nil { final = resp.Final } // We can't reuse the response since it is sent upstream. return nil })
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 26.1K bytes - Viewed (0) -
cmd/endpoint-ellipses.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 15:54:03 GMT 2024 - 14.7K bytes - Viewed (0) -
cmd/streaming-signature-v4.go
// newSignV4ChunkedReader returns a new s3ChunkedReader that translates the data read from r // out of HTTP "chunked" format before returning it. // The s3ChunkedReader returns io.EOF when the final 0-length chunk is read. // // NewChunkedReader is not needed by normal applications. The http package // automatically decodes chunking when reading response bodies.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 18.2K bytes - Viewed (0) -
cmd/post-policy_test.go
} // get random bucket name. bucketName := getRandomBucketName() // Key specified in Form data keyName := "test/object" var opts ObjectOptions // The final name of the upload object targetObj := keyName + "/upload.txt" // The url of success_action_redirect field redirectURL, err := url.Parse("http://www.google.com?query=value") if err != nil { t.Fatal(err)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:45:54 GMT 2024 - 29.6K bytes - Viewed (0) -
cmd/peer-s3-client.go
// - Return an error when a pool cannot return N/2+1 valid bucket information // - For each pool, check if the bucket exists in N/2+1 nodes before including it in the final result func (sys *S3PeerSys) ListBuckets(ctx context.Context, opts BucketOptions) ([]BucketInfo, error) { g := errgroup.WithNErrs(len(sys.peerClients)) nodeBuckets := make([][]BucketInfo, len(sys.peerClients))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.8K bytes - Viewed (0)