Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 44 for decode (0.15 sec)

  1. cmd/admin-handlers_test.go

    	}
    
    	rec := httptest.NewRecorder()
    	adminTestBed.router.ServeHTTP(rec, req)
    	if rec.Code != http.StatusOK {
    		t.Errorf("Expected to succeed but failed with %d", rec.Code)
    	}
    
    	results := madmin.InfoMessage{}
    	err = json.NewDecoder(rec.Body).Decode(&results)
    	if err != nil {
    		t.Fatalf("Failed to decode set config result json %v", err)
    	}
    
    	if results.Region != globalMinioDefaultRegion {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Feb 22 06:26:06 UTC 2024
    - 13.8K bytes
    - Viewed (0)
  2. internal/bucket/lifecycle/lifecycle.go

    	for _, rule := range lc.Rules {
    		if !rule.Expiration.IsNull() || !rule.NoncurrentVersionExpiration.IsNull() {
    			return true
    		}
    	}
    	return false
    }
    
    // UnmarshalXML - decodes XML data.
    func (lc *Lifecycle) UnmarshalXML(d *xml.Decoder, start xml.StartElement) (err error) {
    	switch start.Name.Local {
    	case "LifecycleConfiguration", "BucketLifecycleConfiguration":
    	default:
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu May 23 01:12:48 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  3. cmd/erasure-decode_test.go

    			bitrotReaders[index] = newBitrotReader(disk, nil, "testbucket", "object", tillOffset, writeAlgorithm, bitrotWriterSum(writers[index]), erasure.ShardSize())
    		}
    
    		writer := bytes.NewBuffer(nil)
    		_, err = erasure.Decode(context.Background(), writer, bitrotReaders, test.offset, test.length, test.data, nil)
    		closeBitrotReaders(bitrotReaders)
    		if err != nil && !test.shouldFail {
    			t.Errorf("Test %d: should pass but failed with: %v", i, err)
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 21.1K bytes
    - Viewed (0)
  4. cmd/erasure-server-pool-rebalance_gen_test.go

    	v := rebalanceInfo{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    
    	m := v.Msgsize()
    	if buf.Len() > m {
    		t.Log("WARNING: TestEncodeDecoderebalanceInfo Msgsize() is inaccurate")
    	}
    
    	vn := rebalanceInfo{}
    	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 Oct 25 19:36:57 UTC 2022
    - 11K bytes
    - Viewed (0)
  5. cmd/bucket-stats_gen_test.go

    	v := BucketReplicationStat{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    
    	m := v.Msgsize()
    	if buf.Len() > m {
    		t.Log("WARNING: TestEncodeDecodeBucketReplicationStat Msgsize() is inaccurate")
    	}
    
    	vn := BucketReplicationStat{}
    	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: Wed Aug 30 08:00:59 UTC 2023
    - 20.5K bytes
    - Viewed (0)
  6. internal/bucket/object/lock/lock.go

    	return !l.Status.Valid()
    }
    
    // ParseObjectLegalHold decodes the XML into ObjectLegalHold
    func ParseObjectLegalHold(reader io.Reader) (hold *ObjectLegalHold, err error) {
    	buf, err := io.ReadAll(io.LimitReader(reader, maxObjectLockConfigSize))
    	if err != nil {
    		return nil, err
    	}
    
    	hold = &ObjectLegalHold{}
    	if err = xml.NewDecoder(bytes.NewReader(buf)).Decode(hold); err != nil {
    		return nil, err
    	}
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 17.1K bytes
    - Viewed (0)
  7. cmd/postpolicyform.go

    			for _, kv := range kvs {
    				if sset.Contains(kv.Key) {
    					// Reject duplicate conditions or expiration.
    					return nil, fmt.Errorf("input policy has multiple %s, please fix your client code", kv.Key)
    				}
    				sset.Add(kv.Key)
    			}
    			e.Encode(kvs)
    		}
    	}
    	return &buf, d.Err()
    }
    
    // parsePostPolicyForm - Parse JSON policy string into typed PostPolicyForm structure.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon May 06 10:52:41 UTC 2024
    - 12.3K bytes
    - Viewed (0)
  8. 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)
  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/event/target/elasticsearch.go

    		c.Info.WithContext(ctx),
    	)
    	if err != nil {
    		return ESSUnknown, "", store.ErrNotConnected
    	}
    
    	defer resp.Body.Close()
    
    	m := make(map[string]interface{})
    	err = json.NewDecoder(resp.Body).Decode(&m)
    	if err != nil {
    		return ESSUnknown, "", fmt.Errorf("unable to get ES Server version - json parse error: %v", err)
    	}
    
    	if v, ok := m["version"].(map[string]interface{}); ok {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 15K bytes
    - Viewed (0)
Back to top