Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 122 for decode (0.2 sec)

  1. cmd/metacache-set_gen_test.go

    	v := listPathOptions{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    
    	m := v.Msgsize()
    	if buf.Len() > m {
    		t.Log("WARNING: TestEncodeDecodelistPathOptions Msgsize() is inaccurate")
    	}
    
    	vn := listPathOptions{}
    	err := msgp.Decode(&buf, &vn)
    	if err != nil {
    		t.Error(err)
    	}
    
    	buf.Reset()
    	msgp.Encode(&buf, &v)
    	err = msgp.NewReader(&buf).Skip()
    	if err != nil {
    		t.Error(err)
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Feb 19 22:54:46 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  2. cmd/metacache-walk_gen_test.go

    	v := WalkDirOptions{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    
    	m := v.Msgsize()
    	if buf.Len() > m {
    		t.Log("WARNING: TestEncodeDecodeWalkDirOptions Msgsize() is inaccurate")
    	}
    
    	vn := WalkDirOptions{}
    	err := msgp.Decode(&buf, &vn)
    	if err != nil {
    		t.Error(err)
    	}
    
    	buf.Reset()
    	msgp.Encode(&buf, &v)
    	err = msgp.NewReader(&buf).Skip()
    	if err != nil {
    		t.Error(err)
    	}
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue Nov 21 01:09:35 UTC 2023
    - 2.3K bytes
    - Viewed (0)
  3. internal/config/identity/openid/providercfg.go

    		// respBytes, _ := httputil.DumpResponse(resp, true)
    		// fmt.Println(string(respBytes))
    		return nil, errors.New(resp.Status)
    	}
    
    	claims := map[string]interface{}{}
    	if err = json.NewDecoder(resp.Body).Decode(&claims); err != nil {
    		// uncomment this for debugging when needed.
    		// reqBytes, _ := httputil.DumpRequest(req, false)
    		// fmt.Println(string(reqBytes))
    		// respBytes, _ := httputil.DumpResponse(resp, true)
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  4. internal/bucket/versioning/versioning.go

    }
    
    // ParseConfig - parses data in given reader to VersioningConfiguration.
    func ParseConfig(reader io.Reader) (*Versioning, error) {
    	var v Versioning
    	if err := xml.NewDecoder(reader).Decode(&v); err != nil {
    		return nil, err
    	}
    	if err := v.Validate(); err != nil {
    		return nil, err
    	}
    	return &v, nil
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  5. cmd/storage-rest-client.go

    	if err != nil {
    		for i := range errs {
    			errs[i] = toStorageErr(err)
    		}
    		return errs
    	}
    
    	dErrResp := &DeleteVersionsErrsResp{}
    	if err = gob.NewDecoder(reader).Decode(dErrResp); err != nil {
    		for i := range errs {
    			errs[i] = toStorageErr(err)
    		}
    		return errs
    	}
    
    	for i, dErr := range dErrResp.Errs {
    		errs[i] = toStorageErr(dErr)
    	}
    
    	return errs
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 27.4K bytes
    - Viewed (0)
  6. internal/event/config.go

    	if filter.isEmpty() {
    		return nil
    	}
    	type filterRuleWrapper FilterRule
    	return e.EncodeElement(filterRuleWrapper(filter), start)
    }
    
    // UnmarshalXML - decodes XML data.
    func (filter *FilterRule) UnmarshalXML(d *xml.Decoder, start xml.StartElement) error {
    	// Make subtype to avoid recursive UnmarshalXML().
    	type filterRule FilterRule
    	rule := filterRule{}
    	if err := d.DecodeElement(&rule, &start); err != nil {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue Nov 16 17:28:29 UTC 2021
    - 8.4K bytes
    - Viewed (0)
  7. cmd/background-newdisks-heal-ops_gen_test.go

    	v := healingTracker{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    
    	m := v.Msgsize()
    	if buf.Len() > m {
    		t.Log("WARNING: TestEncodeDecodehealingTracker Msgsize() is inaccurate")
    	}
    
    	vn := healingTracker{}
    	err := msgp.Decode(&buf, &vn)
    	if err != nil {
    		t.Error(err)
    	}
    
    	buf.Reset()
    	msgp.Encode(&buf, &v)
    	err = msgp.NewReader(&buf).Skip()
    	if err != nil {
    		t.Error(err)
    	}
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Apr 23 18:58:53 UTC 2021
    - 2.3K bytes
    - Viewed (0)
  8. internal/bucket/encryption/bucket-sse-config.go

    	XMLName xml.Name `xml:"ServerSideEncryptionConfiguration"`
    	Rules   []Rule   `xml:"Rule"`
    }
    
    // ParseBucketSSEConfig - Decodes given XML to a valid default bucket encryption config
    func ParseBucketSSEConfig(r io.Reader) (*BucketSSEConfig, error) {
    	var config BucketSSEConfig
    	err := xml.NewDecoder(r).Decode(&config)
    	if err != nil {
    		return nil, err
    	}
    
    	// Validates server-side encryption config rules
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue Oct 25 00:44:15 UTC 2022
    - 4.9K bytes
    - Viewed (0)
  9. internal/config/identity/openid/jwks_test.go

    	} else if len(jk.Keys) != 3 {
    		t.Fatalf("Expected 3 keys, got %d", len(jk.Keys))
    	}
    
    	var kids []string
    	for ii, jks := range jk.Keys {
    		_, err := jks.DecodePublicKey()
    		if err != nil {
    			t.Fatalf("Failed to decode key %d: %v", ii, err)
    		}
    		kids = append(kids, jks.Kid)
    	}
    	if len(kids) != 3 {
    		t.Fatalf("Failed to find the expected number of kids: 3, got %d", len(kids))
    	}
    }
    
    // A.1 - Example public keys
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Sun Jan 02 17:15:06 UTC 2022
    - 9.8K bytes
    - Viewed (0)
  10. internal/config/identity/openid/jwt.go

    )
    
    type publicKeys struct {
    	*sync.RWMutex
    
    	// map of kid to public key
    	pkMap map[string]interface{}
    }
    
    func (pk *publicKeys) parseAndAdd(b io.Reader) error {
    	var jwk JWKS
    	err := json.NewDecoder(b).Decode(&jwk)
    	if err != nil {
    		return err
    	}
    
    	for _, key := range jwk.Keys {
    		pkey, err := key.DecodePublicKey()
    		if err != nil {
    			return err
    		}
    		pk.add(key.Kid, pkey)
    	}
    
    	return nil
    }
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu May 30 18:10:41 UTC 2024
    - 8.3K bytes
    - Viewed (0)
Back to top