Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 46 for NewDecoder (0.07 sec)

  1. istioctl/pkg/admin/istiodconfig.go

    	if err != nil {
    		return nil, err
    	}
    	defer resp.Body.Close()
    	if resp.StatusCode != http.StatusOK {
    		return nil, fmt.Errorf("request not successful %s", resp.Status)
    	}
    
    	err = json.NewDecoder(resp.Body).Decode(&scopeInfos)
    	if err != nil {
    		return nil, fmt.Errorf("cannot deserialize response %s", err)
    	}
    	return scopeInfos, nil
    }
    
    func (c *ControlzClient) PutScope(scope *ScopeInfo) error {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Sat Apr 13 05:23:38 UTC 2024
    - 13.5K bytes
    - Viewed (0)
  2. schema/serializer.go

    		switch v := dbValue.(type) {
    		case []byte:
    			bytesValue = v
    		default:
    			return fmt.Errorf("failed to unmarshal gob value: %#v", dbValue)
    		}
    		if len(bytesValue) > 0 {
    			decoder := gob.NewDecoder(bytes.NewBuffer(bytesValue))
    			err = decoder.Decode(fieldValue.Interface())
    		}
    	}
    	field.ReflectValueOf(ctx, dst).Set(fieldValue.Elem())
    	return
    }
    
    // Value implements serializer interface
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Thu Jun 20 08:45:38 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  3. cmd/storage-datatypes_test.go

    	var buf bytes.Buffer
    	gob.NewEncoder(&buf).Encode(v)
    	encoded := buf.Bytes()
    	b.Log("Size:", buf.Len(), "bytes")
    	b.SetBytes(1)
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		dec := gob.NewDecoder(bytes.NewBuffer(encoded))
    		err := dec.Decode(&v)
    		if err != nil {
    			b.Fatal(err)
    		}
    	}
    }
    
    func BenchmarkEncodeDiskInfoMsgp(b *testing.B) {
    	v := DiskInfo{
    		Total:     1000,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 19 18:05:16 UTC 2022
    - 9.4K bytes
    - Viewed (0)
  4. internal/s3select/sql/jsonpath_test.go

    	"path/filepath"
    	"reflect"
    	"testing"
    
    	"github.com/alecthomas/participle"
    	"github.com/minio/minio/internal/s3select/jstream"
    )
    
    func getJSONStructs(b []byte) ([]interface{}, error) {
    	dec := jstream.NewDecoder(bytes.NewBuffer(b), 0).ObjectAsKVS().MaxDepth(100)
    	var result []interface{}
    	for parsedVal := range dec.Stream() {
    		result = append(result, parsedVal.Value)
    	}
    	if err := dec.Err(); err != nil {
    		return nil, err
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  5. internal/bucket/object/lock/lock.go

    const maxObjectLockConfigSize = 1 << 12
    
    // ParseObjectLockConfig parses ObjectLockConfig from xml
    func ParseObjectLockConfig(reader io.Reader) (*Config, error) {
    	config := Config{}
    	if err := xml.NewDecoder(io.LimitReader(reader, maxObjectLockConfigSize)).Decode(&config); err != nil {
    		return nil, err
    	}
    
    	return &config, nil
    }
    
    // NewObjectLockConfig returns a initialized lock.Config struct
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Jun 29 01:20:27 UTC 2024
    - 17.1K bytes
    - Viewed (0)
  6. 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)
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 02:46:36 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  7. internal/bucket/lifecycle/lifecycle.go

    }
    
    // ParseLifecycleConfigWithID - parses for a Lifecycle config and assigns
    // unique id to rules with empty ID.
    func ParseLifecycleConfigWithID(r io.Reader) (*Lifecycle, error) {
    	var lc Lifecycle
    	if err := xml.NewDecoder(r).Decode(&lc); err != nil {
    		return nil, err
    	}
    	// assign a unique id for rules with empty ID
    	for i := range lc.Rules {
    		if lc.Rules[i].ID == "" {
    			lc.Rules[i].ID = uuid.New().String()
    		}
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu May 23 01:12:48 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  8. internal/s3select/json/reader.go

    	}
    	return err
    }
    
    // NewReader - creates new JSON reader using readCloser.
    func NewReader(readCloser io.ReadCloser, args *ReaderArgs) *Reader {
    	readCloser = &syncReadCloser{rc: readCloser}
    	d := jstream.NewDecoder(io.LimitReader(readCloser, maxDocumentSize), 0).ObjectAsKVS().MaxDepth(100)
    	return &Reader{
    		args:       args,
    		decoder:    d,
    		valueCh:    d.Stream(),
    		readCloser: readCloser,
    	}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  9. internal/config/identity/plugin/config.go

    	o.serviceMetrics.accumRequestRTT(reqStartTime, float64(reqDurNanos)/1e6, true)
    
    	switch resp.StatusCode {
    	case 200:
    		var result AuthNSuccessResponse
    		if err = json.NewDecoder(resp.Body).Decode(&result); err != nil {
    			return AuthNResponse{}, err
    		}
    
    		if result.MaxValiditySeconds < minValidityDurationSeconds || result.MaxValiditySeconds > maxValidityDurationSeconds {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  10. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4.6K bytes
    - Viewed (0)
Back to top