Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 341 - 350 of 889 for vary (0.04 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. cmd/global-heal.go

    		}
    
    		healingLogIf(ctx, tracker.update(ctx))
    		close(quitting)
    	}()
    
    	var retErr error
    
    	// Heal all buckets with all objects
    	for _, bucket := range healBuckets {
    		if tracker.isHealed(bucket) {
    			continue
    		}
    
    		var forwardTo string
    		// If we resume to the same bucket, forward to last known item.
    		b := tracker.getBucket()
    		if b == bucket {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Apr 04 13:49:12 GMT 2025
    - 16.2K bytes
    - Click Count (0)
  2. cmd/erasure-server-pool-decom.go

    	// add that many extra workers.
    	workerSize += len(pool.sets)
    
    	wk, err := workers.New(workerSize)
    	if err != nil {
    		return err
    	}
    
    	var vc *versioning.Versioning
    	var lc *lifecycle.Lifecycle
    	var lr objectlock.Retention
    	var rcfg *replication.Config
    	if bi.Name != minioMetaBucket {
    		vc, err = globalBucketVersioningSys.Get(bi.Name)
    		if err != nil {
    			return err
    		}
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 42.2K bytes
    - Click Count (1)
  3. cmd/prepare-storage.go

    	"net/url"
    	"path/filepath"
    	"sync"
    	"time"
    
    	"github.com/dustin/go-humanize"
    	xhttp "github.com/minio/minio/internal/http"
    	"github.com/minio/minio/internal/logger"
    )
    
    var printEndpointError = func() func(Endpoint, error, bool) {
    	var mutex sync.Mutex
    	printOnce := make(map[Endpoint]map[string]int)
    
    	return func(endpoint Endpoint, err error, once bool) {
    		reqInfo := (&logger.ReqInfo{}).AppendTags("endpoint", endpoint.String())
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Jul 12 20:51:54 GMT 2024
    - 11.1K bytes
    - Click Count (1)
  4. internal/event/target/kafka.go

    	EnvKafkaProducerCompressionCodec = "MINIO_NOTIFY_KAFKA_PRODUCER_COMPRESSION_CODEC"
    	EnvKafkaProducerCompressionLevel = "MINIO_NOTIFY_KAFKA_PRODUCER_COMPRESSION_LEVEL"
    )
    
    var codecs = map[string]sarama.CompressionCodec{
    	"none":   sarama.CompressionNone,
    	"gzip":   sarama.CompressionGZIP,
    	"snappy": sarama.CompressionSnappy,
    	"lz4":    sarama.CompressionLZ4,
    	"zstd":   sarama.CompressionZSTD,
    }
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Sep 06 23:06:30 GMT 2024
    - 13.6K bytes
    - Click Count (0)
  5. internal/bucket/replication/replication.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package replication
    
    import (
    	"encoding/xml"
    	"io"
    	"sort"
    	"strconv"
    	"strings"
    )
    
    var (
    	errReplicationTooManyRules          = Errorf("Replication configuration allows a maximum of 1000 rules")
    	errReplicationNoRule                = Errorf("Replication configuration should have at least one rule")
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Mar 30 00:56:02 GMT 2025
    - 8.9K bytes
    - Click Count (0)
  6. src/main/webapp/WEB-INF/view/admin/dict/stemmeroverride/admin_dict_stemmeroverride.jsp

                                                </tr>
                                                </thead>
                                                <tbody>
                                                <c:forEach var="data" varStatus="s"
                                                           items="${stemmerOverrideItemItems}">
                                                    <tr
    Created: Sat Dec 20 09:19:18 GMT 2025
    - Last Modified: Thu Nov 13 05:54:52 GMT 2025
    - 10.4K bytes
    - Click Count (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/-HeadersCommon.kt

    internal fun Headers.commonValue(index: Int): String =
      namesAndValues.getOrNull(index * 2 + 1) ?: throw IndexOutOfBoundsException("value[$index]")
    
    internal fun Headers.commonValues(name: String): List<String> {
      var result: MutableList<String>? = null
      for (i in 0 until size) {
        if (name.equals(name(i), ignoreCase = true)) {
          if (result == null) result = ArrayList(2)
          result.add(value(i))
        }
      }
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Mon May 05 16:01:00 GMT 2025
    - 5.8K bytes
    - Click Count (0)
  8. okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/Certificate.kt

            else -> error("unexpected signature algorithm: ${signature.algorithm}")
          }
        }
    
      // Avoid Long.hashCode(long) which isn't available on Android 5.
      override fun hashCode(): Int {
        var result = 0
        result = 31 * result + version.toInt()
        result = 31 * result + serialNumber.hashCode()
        result = 31 * result + signature.hashCode()
        result = 31 * result + issuer.hashCode()
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 6.4K bytes
    - Click Count (0)
  9. mockwebserver/src/test/java/mockwebserver3/internal/http2/Http2Server.kt

        sslSocket.startHandshake()
        return sslSocket
      }
    
      override fun onStream(stream: Http2Stream) {
        try {
          val requestHeaders = stream.takeHeaders()
          var path: String? = null
          var i = 0
          val size = requestHeaders.size
          while (i < size) {
            if (requestHeaders.name(i) == Header.TARGET_PATH_UTF8) {
              path = requestHeaders.value(i)
              break
            }
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Thu Jul 31 04:18:40 GMT 2025
    - 6.4K bytes
    - Click Count (0)
  10. cmd/config.go

    	// MinIO configuration file.
    	minioConfigFile = "config.json"
    )
    
    func listServerConfigHistory(ctx context.Context, objAPI ObjectLayer, withData bool, count int) (
    	[]madmin.ConfigHistoryEntry, error,
    ) {
    	var configHistory []madmin.ConfigHistoryEntry
    
    	// List all kvs
    	marker := ""
    	for {
    		res, err := objAPI.ListObjects(ctx, minioMetaBucket, minioConfigHistoryPrefix, marker, "", maxObjectList)
    		if err != nil {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 5.9K bytes
    - Click Count (0)
Back to Top