Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 55 for desc (0.12 sec)

  1. internal/bucket/replication/rule.go

    	}
    	return nil
    }
    
    // UnmarshalXML - decodes XML data.
    func (d *DeleteReplication) UnmarshalXML(dec *xml.Decoder, start xml.StartElement) (err error) {
    	// Make subtype to avoid recursive UnmarshalXML().
    	type deleteReplication DeleteReplication
    	drep := deleteReplication{}
    
    	if err := dec.DecodeElement(&drep, &start); err != nil {
    		return err
    	}
    	if len(drep.Status) == 0 {
    		drep.Status = Disabled
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Jan 24 23:22:20 GMT 2022
    - 8.3K bytes
    - Viewed (0)
  2. cmd/storage-rest-client.go

    	respBody, err := client.call(ctx, storageRESTMethodReadVersion, values, nil, -1)
    	if err != nil {
    		return fi, err
    	}
    	defer xhttp.DrainBody(respBody)
    
    	dec := msgpNewReader(respBody)
    	defer readMsgpReaderPoolPut(dec)
    
    	err = fi.DecodeMsg(dec)
    	return fi, err
    }
    
    // ReadXL - reads all contents of xl.meta of a file.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 26.1K bytes
    - Viewed (0)
  3. cmd/bucket-lifecycle_test.go

    		restoreHdr     string
    		expectedStatus restoreObjStatus
    		expectedErr    error
    	}{
    		{
    			// valid: represents a restored object, 'pending' expiry.
    			restoreHdr: `ongoing-request="false", expiry-date="Fri, 21 Dec 2012 00:00:00 GMT"`,
    			expectedStatus: restoreObjStatus{
    				ongoing: false,
    				expiry:  time.Date(2012, 12, 21, 0, 0, 0, 0, time.UTC),
    			},
    			expectedErr: nil,
    		},
    		{
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue May 31 09:57:57 GMT 2022
    - 7K bytes
    - Viewed (0)
  4. docs/sts/web-identity.go

    	if err != nil {
    		return d, err
    	}
    	defer resp.Body.Close()
    	if resp.StatusCode != http.StatusOK {
    		return d, fmt.Errorf("unexpected error returned by %s : status(%s)", ustr, resp.Status)
    	}
    	dec := json.NewDecoder(resp.Body)
    	if err = dec.Decode(&d); err != nil {
    		return d, err
    	}
    	return d, nil
    }
    
    func init() {
    	flag.StringVar(&stsEndpoint, "sts-ep", "http://localhost:9000", "STS endpoint")
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 19 09:13:33 GMT 2023
    - 7.8K bytes
    - Viewed (3)
  5. internal/s3select/simdj/reader_amd64_test.go

    type tester interface {
    	Fatal(args ...interface{})
    }
    
    func loadCompressed(t tester, file string) (js []byte) {
    	dec, err := zstd.NewReader(nil)
    	if err != nil {
    		t.Fatal(err)
    	}
    	defer dec.Close()
    	js, err = os.ReadFile(filepath.Join("testdata", file+".json.zst"))
    	if err != nil {
    		t.Fatal(err)
    	}
    	js, err = dec.DecodeAll(js, nil)
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	return js
    }
    
    var testCases = []struct {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Sep 19 18:05:16 GMT 2022
    - 3.9K bytes
    - Viewed (0)
  6. internal/crypto/doc.go

    //     -   SealedKey <- metadata
    //     -   KeyEncKey := HMAC-SHA256(ClientKey, IV || 'SSE-C' || 'DAREv2-HMAC-SHA256' || bucket || '/' || object)
    //     -   ObjectKey := DAREv2_Dec(KeyEncKey, SealedKey)
    //     - object_data := DAREv2_Dec(ObjectKey, enc_object_data)
    //     Output: object_data
    //
    // ## SSE-S3
    //
    // SSE-S3 can use either a master key or a KMS as root-of-trust.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Aug 26 19:52:29 GMT 2022
    - 5K bytes
    - Viewed (0)
  7. internal/s3select/sql/jsonpath_test.go

    	"github.com/alecthomas/participle"
    	"github.com/bcicen/jstream"
    )
    
    func getJSONStructs(b []byte) ([]interface{}, error) {
    	dec := jstream.NewDecoder(bytes.NewBuffer(b), 0).ObjectAsKVS()
    	var result []interface{}
    	for parsedVal := range dec.Stream() {
    		result = append(result, parsedVal.Value)
    	}
    	if err := dec.Err(); err != nil {
    		return nil, err
    	}
    	return result, nil
    }
    
    func TestJsonpathEval(t *testing.T) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Sep 19 18:05:16 GMT 2022
    - 2.8K bytes
    - Viewed (0)
  8. internal/bucket/lifecycle/delmarker-expiration.go

    	return de.Days == 0
    }
    
    // UnmarshalXML decodes a single XML element into a DelMarkerExpiration value
    func (de *DelMarkerExpiration) UnmarshalXML(dec *xml.Decoder, start xml.StartElement) error {
    	type delMarkerExpiration DelMarkerExpiration
    	var dexp delMarkerExpiration
    	err := dec.DecodeElement(&dexp, &start)
    	if err != nil {
    		return err
    	}
    
    	if dexp.Days <= 0 {
    		return errInvalidDaysDelMarkerExpiration
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:11:10 GMT 2024
    - 2.3K bytes
    - Viewed (0)
  9. internal/config/subnet/config.go

    var DefaultKVS = config.KVS{
    	config.KV{
    		Key:   config.License, // Deprecated Dec 2021
    		Value: "",
    	},
    	config.KV{
    		Key:   config.APIKey,
    		Value: "",
    	},
    	config.KV{
    		Key:   config.Proxy,
    		Value: "",
    	},
    }
    
    // Config represents the subnet related configuration
    type Config struct {
    	// The subnet license token - Deprecated Dec 2021
    	License string `json:"license"`
    
    	// The subnet api key
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Nov 24 17:59:35 GMT 2023
    - 3.8K bytes
    - Viewed (0)
  10. internal/config/subnet/help.go

    		return config.DefaultHelpPostfix(DefaultKVS, key)
    	}
    
    	// HelpSubnet - provides help for subnet api key config
    	HelpSubnet = config.HelpKVS{
    		config.HelpKV{
    			Key:         config.License, // Deprecated Dec 2021
    			Type:        "string",
    			Description: "[DEPRECATED use api_key] Subnet license token for the cluster" + defaultHelpPostfix(config.License),
    			Optional:    true,
    			Sensitive:   true,
    		},
    		config.HelpKV{
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jul 13 19:24:47 GMT 2023
    - 1.7K bytes
    - Viewed (0)
Back to top