Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 431 - 440 of 1,924 for form (0.03 seconds)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. .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)
  9. 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)
  10. 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)
Back to Top