Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 65 for kv (0.01 sec)

  1. internal/config/legacy.go

    // SetRegion - One time migration code needed, for migrating from older config to new for server Region.
    func SetRegion(c Config, name string) {
    	if name == "" {
    		return
    	}
    	c[RegionSubSys][Default] = KVS{
    		KV{
    			Key:   RegionName,
    			Value: name,
    		},
    	}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Mon Dec 19 20:27:06 UTC 2022
    - 1.1K bytes
    - Viewed (0)
  2. internal/s3select/jstream/decoder_test.go

    	}
    
    	// test at depth level 1
    	counter = 0
    	kvcounter := 0
    	decoder = NewDecoder(mkReader(body), 1)
    
    	for mv = range decoder.Stream() {
    		switch mv.Value.(type) {
    		case KV:
    			kvcounter++
    		default:
    			counter++
    		}
    		t.Logf("depth=%d offset=%d len=%d (%v)", mv.Depth, mv.Offset, mv.Length, mv.Value)
    	}
    	if err := decoder.Err(); err != nil {
    		t.Fatalf("decoder error: %s", err)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 6.6K bytes
    - Viewed (0)
  3. cmd/batch-handlers.go

    					return false
    				}
    				tagMap = t.ToMap()
    			}
    			for _, kv := range r.Flags.Filter.Tags {
    				for t, v := range tagMap {
    					if kv.Match(BatchJobKV{Key: t, Value: v}) {
    						return true
    					}
    				}
    			}
    
    			// None of the provided tags filter match skip the object
    			return false
    		}
    
    		for _, kv := range r.Flags.Filter.Metadata {
    			for k, v := range oi.UserDefined {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 63.5K bytes
    - Viewed (0)
  4. docs/language_names.yml

    iu: ᐃᓄᒃᑎᑐᑦ
    ja: 日本語
    jv: basa Jawa
    ka: ქართული
    kg: Kikongo
    ki: Gĩkũyũ
    kj: Kuanyama
    kk: қазақ тілі
    kl: kalaallisut
    km: ខេមរភាសា
    kn: ಕನ್ನಡ
    ko: 한국어
    kr: Kanuri
    ks: कश्मीरी
    ku: Kurdî
    kv: коми кыв
    kw: Kernewek
    ky: Кыргызча
    la: latine
    lb: Lëtzebuergesch
    lg: Luganda
    li: Limburgs
    ln: Lingála
    lo: ພາສາ
    lt: lietuvių kalba
    lu: Tshiluba
    lv: latviešu valoda
    mg: fiteny malagasy
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Mon Jan 22 19:42:53 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  5. internal/config/drive/drive.go

    	EnvMaxDriveTimeoutLegacy = "_MINIO_DRIVE_MAX_TIMEOUT"
    	EnvMaxDiskTimeoutLegacy  = "_MINIO_DISK_MAX_TIMEOUT"
    )
    
    // DefaultKVS - default KVS for drive
    var DefaultKVS = config.KVS{
    	config.KV{
    		Key:   MaxTimeout,
    		Value: "30s",
    	},
    }
    
    var configLk sync.RWMutex
    
    // Config represents the subnet related configuration
    type Config struct {
    	// MaxTimeout - maximum timeout for a drive operation
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Mon Nov 11 14:51:43 UTC 2024
    - 3K bytes
    - Viewed (0)
  6. cmd/batch-expire.go

    			t, err := tags.ParseObjectTags(obj.UserTags)
    			if err != nil {
    				return false
    			}
    			tagMap = t.ToMap()
    		}
    
    		for _, kv := range ef.Tags {
    			// Object (version) must match all tags specified in
    			// the filter
    			var match bool
    			for t, v := range tagMap {
    				if kv.Match(BatchJobKV{Key: t, Value: v}) {
    					match = true
    				}
    			}
    			if !match {
    				return false
    			}
    		}
    	}
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Apr 22 11:16:32 UTC 2025
    - 23K bytes
    - Viewed (0)
  7. internal/s3select/json/reader.go

    	} else {
    		// To be AWS S3 compatible Select for JSON needs to
    		// output non-object JSON as single column value
    		// i.e. a map with `_1` as key and value as the
    		// non-object.
    		kvs = jstream.KVS{jstream.KV{Key: "_1", Value: v.Value}}
    	}
    
    	dstRec, ok := dst.(*Record)
    	if !ok {
    		dstRec = &Record{}
    	}
    	dstRec.KVS = kvs
    	dstRec.SelectFormat = sql.SelectFmtJSON
    	return dstRec, nil
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Feb 18 16:25:55 UTC 2025
    - 3.2K bytes
    - Viewed (0)
  8. docs/bigdata/README.md

    ![s3a-config](https://github.com/minio/minio/blob/master/docs/bigdata/images/image5.png?raw=true "custom core-site")
    
    ```
    sudo pip install yq
    alias kv-pairify='yq ".configuration[]" | jq ".[]" | jq -r ".name + \"=\" + .value"'
    ```
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 14.7K bytes
    - Viewed (0)
  9. internal/config/identity/tls/config.go

    	}
    	return cfg, nil
    }
    
    const (
    	skipVerify = "skip_verify"
    )
    
    // DefaultKVS is the default K/V config system for
    // the STS TLS API.
    var DefaultKVS = config.KVS{
    	config.KV{
    		Key:   skipVerify,
    		Value: "off",
    	},
    }
    
    // Help is the help and description for the STS API K/V configuration.
    var Help = config.HelpKVS{
    	config.HelpKV{
    		Key:         skipVerify,
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  10. internal/s3select/parquet/reader.go

    		var value any
    		if v, ok := nextRow[col.FlatName()]; ok {
    			value, err = convertFromAnnotation(col.Element(), v)
    			if err != nil {
    				return nil, errParquetParsingError(err)
    			}
    		}
    		kvs = append(kvs, jstream.KV{Key: col.FlatName(), Value: value})
    	}
    
    	// Reuse destination if we can.
    	dstRec, ok := dst.(*jsonfmt.Record)
    	if !ok {
    		dstRec = &jsonfmt.Record{}
    	}
    	dstRec.SelectFormat = sql.SelectFmtParquet
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 4.5K bytes
    - Viewed (0)
Back to top