- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 53 for Mayers (0.19 sec)
-
cmd/test-utils_test.go
} } // ExecObjectLayerAPINilTest - Sets the object layer to `nil`, and calls the registered object layer API endpoint, // and assert the error response. The purpose is to validate the API handlers response when the object layer is uninitialized.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:06:57 GMT 2024 - 75.7K bytes - Viewed (0) -
cmd/server-main_test.go
obj, err := newObjectLayer(ctx, mustGetPoolEndpoints(0, disks...)) if err != nil { t.Fatal("Unexpected object layer initialization error", err) } _, ok := obj.(*erasureServerPools) if !ok { t.Fatal("Unexpected object layer detected", reflect.TypeOf(obj)) } // Tests for Erasure object layer initialization. // Create temporary backend for the test server. nDisks = 16 disks, err = getRandomDisks(nDisks)
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Dec 07 09:33:56 GMT 2023 - 3.1K bytes - Viewed (0) -
cmd/erasure-metadata.go
func (fi *FileInfo) TierFreeVersionID() string { return fi.Metadata[ReservedMetadataPrefixLower+tierFVID] } // SetTierFreeVersion sets fi as a free-version. This method is used by // lower layers to indicate a free-version. func (fi *FileInfo) SetTierFreeVersion() { if fi.Metadata == nil { fi.Metadata = make(map[string]string) } fi.Metadata[ReservedMetadataPrefixLower+tierFVMarker] = "" }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 19.2K bytes - Viewed (1) -
cmd/erasure-server-pool-decom_test.go
meta := objLayer1.(*erasureServerPools).poolMeta pools := objLayer1.(*erasureServerPools).serverPools objLayer2, fsDirs, err := prepareErasurePools() if err != nil { t.Fatalf("Initialization of object layer failed for Erasure setup: %s", err) } defer removeRoots(fsDirs) newPools := objLayer2.(*erasureServerPools).serverPools reducedPools := pools[1:] orderChangePools := []*erasureSets{ pools[1], pools[0],
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Jul 03 16:47:40 GMT 2023 - 4.8K bytes - Viewed (0) -
cmd/admin-router.go
const ( // this flag disables gzip compression of responses noGZFlag = 1 << iota // this flag enables tracing body and headers instead of just headers traceAllFlag // pass this flag to skip checking if object layer is available noObjLayerFlag ) // Has checks if the given flag is enabled in `h`. func (h hFlag) Has(flag hFlag) bool { // Use bitwise-AND and check if the result is non-zero. return h&flag != 0 }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Mar 10 21:09:36 GMT 2024 - 25.5K bytes - Viewed (0) -
cmd/metacache-manager.go
} const metacacheMaxEntries = 5000 // initManager will start async saving the cache. func (m *metacacheManager) initManager() { // Add a transient bucket. // Start saver when object layer is ready. go func() { objAPI := newObjectLayerFn() for objAPI == nil { time.Sleep(time.Second) objAPI = newObjectLayerFn() } t := time.NewTicker(time.Minute) defer t.Stop()
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Oct 25 00:44:15 GMT 2022 - 5.2K bytes - Viewed (0) -
cmd/warm-backend-azure.go
serviceURL: serviceURL, Bucket: conf.Bucket, Prefix: strings.TrimSuffix(conf.Prefix, slashSeparator), StorageClass: conf.StorageClass, }, nil } // Convert azure errors to minio object layer errors. func azureToObjectError(err error, params ...string) error { if err == nil { return nil } bucket := "" object := "" if len(params) >= 1 { bucket = params[0] }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Mar 05 16:44:08 GMT 2024 - 7.8K bytes - Viewed (1) -
cmd/peer-rest-client.go
return gc }, } } // Wrapper to restClient.Call to handle network errors, in case of network error the connection is marked disconnected // permanently. The only way to restore the connection is at the xl-sets layer by xlsets.monitorAndConnectEndpoints() // after verifying format.json func (client *peerRESTClient) call(method string, values url.Values, body io.Reader, length int64) (respBody io.ReadCloser, err error) {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.8K bytes - Viewed (0) -
cmd/endpoint-ellipses.go
} return totalSizes } // Parses all arguments and returns an endpointSet which is a collection // of endpoints following the ellipses pattern, this is what is used // by the object layer for initializing itself. func parseEndpointSet(customSetDriveCount uint64, args ...string) (ep endpointSet, err error) { argPatterns := make([]ellipses.ArgPattern, len(args)) for i, arg := range args {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 11 21:22:47 GMT 2024 - 14.8K bytes - Viewed (0) -
cmd/bucket-replication.go
// a synchronous manner. func mustReplicate(ctx context.Context, bucket, object string, mopts mustReplicateOptions) (dsc ReplicateDecision) { // object layer not initialized we return with no decision. if newObjectLayerFn() == nil { return } // Disable server-side replication on object prefixes which are excluded
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 112.2K bytes - Viewed (1)