Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 26 for decode (0.15 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. cmd/peer-rest-client.go

    	respBody, err := client.call(peerRESTMethodDownloadProfilingData, nil, nil, -1)
    	if err != nil {
    		return
    	}
    	defer xhttp.DrainBody(respBody)
    	err = gob.NewDecoder(respBody).Decode(&data)
    	return data, err
    }
    
    // GetBucketStats - load bucket statistics
    func (client *peerRESTClient) GetBucketStats(ctx context.Context, bucket string) (BucketStats, error) {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  7. cmd/batch-expire.go

    // UnmarshalYAML - BatchJobExpirePurge extends unmarshal to extract line, col
    func (p *BatchJobExpirePurge) UnmarshalYAML(val *yaml.Node) error {
    	type purge BatchJobExpirePurge
    	var tmp purge
    	err := val.Decode(&tmp)
    	if err != nil {
    		return err
    	}
    
    	*p = BatchJobExpirePurge(tmp)
    	p.line, p.col = val.Line, val.Column
    	return nil
    }
    
    // Validate returns nil if value is valid, ie > 0.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue Jun 11 13:50:53 UTC 2024
    - 21.1K bytes
    - Viewed (0)
  8. docs/debugging/xl-meta/main.go

    		foundData := make(map[string][]byte)
    		partDataToVerID := make(map[string][2]string)
    		var baseName string
    		// versionID ->
    		combineFiles := make(map[string][]string)
    		decode := func(r io.Reader, file string) ([]byte, error) {
    			file = strings.ReplaceAll(file, ":", "_")
    			b, err := io.ReadAll(r)
    			if err != nil {
    				return nil, err
    			}
    			b, _, minor, err := checkXL2V1(b)
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 31 14:49:23 UTC 2024
    - 38.5K bytes
    - Viewed (0)
  9. cmd/auth-handler.go

    	// secret key, temporary credentials become invalid if
    	// server admin credentials change. This is done to ensure
    	// that clients cannot decode the token using the temp
    	// secret keys and generate an entirely new claim by essentially
    	// hijacking the policies. We need to make sure that this is
    	// based on admin credential such that token cannot be decoded
    	// on the client side and is treated like an opaque value.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 26K bytes
    - Viewed (0)
  10. internal/config/identity/plugin/config.go

    		}, nil
    
    	case 403:
    		var result AuthNErrorResponse
    		if err = json.NewDecoder(resp.Body).Decode(&result); err != nil {
    			return AuthNResponse{}, err
    		}
    		return AuthNResponse{
    			Failure: &result,
    		}, nil
    
    	default:
    		return AuthNResponse{}, fmt.Errorf("Invalid status code %d from auth plugin", resp.StatusCode)
    	}
    }
    
    // GetRoleInfo - returns ARN to policies map.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 13.3K bytes
    - Viewed (0)
Back to top