- Sort Score
- Num 10 results
- Language All
Results 431 - 440 of 1,924 for form (0.02 seconds)
-
docs/distributed/DECOMMISSION.md
- All versioned buckets maintain the same order for "versions" for each object after being decommissioned to the other pools. - A pool interrupted during the decommission process, such as for a cluster restart, resumes from where it left off. ## How to decommission a pool ``` λ mc admin decommission start alias/ http://minio{1...2}/data{1...4} ``` ## Status decommissioning a pool
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Mon Jul 11 14:59:49 GMT 2022 - 8.3K bytes - Click Count (0) -
internal/config/legacy.go
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the // GNU Affero General Public License for more details. // // You should have received a copy of the GNU Affero General Public License // along with this program. If not, see <http://www.gnu.org/licenses/>. package config // One time migration code section // SetRegion - One time migration code needed, for migrating from older config to new for server Region.
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Mon Dec 19 20:27:06 GMT 2022 - 1.1K bytes - Click Count (0) -
cmd/metrics-v3-system-process.go
processStarttimeSecondsMD = NewGaugeMD(processStartTimeSeconds, "Start time for MinIO process in seconds since Unix epoc") processUptimeSecondsMD = NewGaugeMD(processUptimeSeconds, "Uptime for MinIO process in seconds") processFileDescriptorLimitTotalMD = NewGaugeMD(processFileDescriptorLimitTotal, "Limit on total number of open file descriptors for the MinIO Server process")
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Thu Jun 20 17:55:03 GMT 2024 - 6.5K bytes - Click Count (0) -
cmd/batch-expire_test.go
// // This program is distributed in the hope that it will be useful // but WITHOUT ANY WARRANTY; without even the implied warranty of // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the // GNU Affero General Public License for more details. // // You should have received a copy of the GNU Affero General Public License // along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Thu Aug 01 12:53:30 GMT 2024 - 5.5K bytes - Click Count (0) -
internal/etag/reader.go
return nil } return r.Tagger.ETag() } // Wrap returns an io.Reader that reads from the wrapped // io.Reader and implements the Tagger interaface. // // If content implements Tagger then the returned Reader // returns ETag of the content. Otherwise, it returns // nil as ETag. // // Wrap provides an adapter for io.Reader implementations // that don't implement the Tagger interface.
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Mar 30 00:56:02 GMT 2025 - 4.8K bytes - Click Count (0) -
internal/store/queuestore_test.go
} } itemKeys := store.List() // Get 10 items. if len(itemKeys) == 10 { for _, key := range itemKeys { item, eErr := store.Get(key) if eErr != nil { t.Fatal("Failed to Get the item from the queue store ", eErr) } if !reflect.DeepEqual(testItem, item) { t.Fatalf("Failed to read the item: error: expected = %v, got = %v", testItem, item) } }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 10.2K bytes - Click Count (0) -
internal/logger/target/kafka/kafka.go
h.wg.Add(1) defer h.wg.Done() } h.logChMu.RUnlock() if logCh == nil { return } // Create a routine which sends json logs received // from an internal channel. for entry := range logCh { h.logEntry(entry) } } func (h *Target) logEntry(entry any) { atomic.AddInt64(&h.totalMessages, 1) if err := h.send(entry); err != nil {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 10.2K bytes - Click Count (0) -
.teamcity/src/main/kotlin/util/RerunFlakyTest.kt
) text( testNameParameterName, """org.gradle.api.tasks.CachedTaskExecutionIntegrationTest.outputs*are*correctly*loaded*from*cache""", display = ParameterDisplay.PROMPT, allowEmpty = false, description = "The name of the test to run, as should be passed to --tests. " +Created: Wed Dec 31 11:36:14 GMT 2025 - Last Modified: Wed Feb 19 08:02:04 GMT 2025 - 5.1K bytes - Click Count (0) -
build-logic/jvm/src/main/kotlin/gradlebuild/jvm/JvmCompileExtension.kt
return compilations.create(sourceSet.name) { from(sourceSet) } } fun Project.addCompilationFrom(sourceSet: SourceSet, configure: JvmCompilation.() -> Unit): JvmCompilation { return compilations.create(sourceSet.name) { from(sourceSet) configure() } }
Created: Wed Dec 31 11:36:14 GMT 2025 - Last Modified: Tue Jun 24 14:00:52 GMT 2025 - 1.9K bytes - Click Count (0) -
cmd/iam-object-store.go
// (removed during loadUser() in the loop above) are removed from memory. for _, item := range listedConfigItems[policyDBSTSUsersListKey] { stsName := strings.TrimSuffix(item, ".json") err := iamOS.loadMappedPolicy(ctx, stsName, stsUser, false, stsAccPoliciesFromStore) if err != nil && !errors.Is(err, errNoSuchPolicy) { iamLogIf(ctx, err) }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 26.6K bytes - Click Count (0)