Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 198 for Unmarshal (0.12 sec)

  1. cni/pkg/plugin/plugin.go

    	conf := Config{}
    
    	if err := json.Unmarshal(stdin, &conf); err != nil {
    		return nil, fmt.Errorf("failed to parse network configuration: %v", err)
    	}
    
    	log.Debugf("istio-cni: Config is: %+v", conf)
    	// Parse previous result. Remove this if your plugin is not chained.
    	if conf.RawPrevResult != nil {
    		resultBytes, err := json.Marshal(conf.RawPrevResult)
    		if err != nil {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Aug 14 19:36:19 UTC 2024
    - 10.5K bytes
    - Viewed (0)
  2. cmd/format-erasure_test.go

    	}
    
    	b, err = os.ReadFile(pathJoin(rootPath, minioMetaBucket, formatConfigFile))
    	if err != nil {
    		t.Fatal(err)
    	}
    	formatV3 := &formatErasureV3{}
    	if err = json.Unmarshal(b, formatV3); err != nil {
    		t.Fatal(err)
    	}
    	if formatV3.Erasure.This != m.Erasure.Disk {
    		t.Fatalf("expected drive uuid: %s, got: %s", m.Erasure.Disk, formatV3.Erasure.This)
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Apr 15 08:25:46 UTC 2024
    - 12.9K bytes
    - Viewed (0)
  3. internal/config/storageclass/storage-class.go

    	type Alias Config
    	aux := &struct {
    		*Alias
    	}{
    		Alias: (*Alias)(sCfg),
    	}
    	return json.Unmarshal(data, &aux)
    }
    
    // IsValid - returns true if input string is a valid
    // storage class kind supported.
    func IsValid(sc string) bool {
    	return sc == RRS || sc == STANDARD
    }
    
    // UnmarshalText unmarshals storage class from its textual form into
    // storageClass structure.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 12:24:04 UTC 2024
    - 12.3K bytes
    - Viewed (0)
  4. istioctl/pkg/kubeinject/kubeinject.go

    			valuesConfigMapKey, injectConfigMapName)
    	}
    
    	return valuesData, nil
    }
    
    func readInjectConfigFile(f []byte) (inject.RawTemplates, error) {
    	var injectConfig inject.Config
    	err := yaml.Unmarshal(f, &injectConfig)
    	if err != nil || len(injectConfig.RawTemplates) == 0 {
    		// This must be a direct template, instead of an inject.Config. We support both formats
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Aug 15 16:31:46 UTC 2024
    - 21K bytes
    - Viewed (0)
  5. cmd/admin-handlers-site-replication.go

    		data, err = madmin.DecryptData(encryptionKey, bytes.NewReader(data))
    		if err != nil {
    			return SRError{
    				Cause: err,
    				Code:  ErrSiteReplicationInvalidRequest,
    			}
    		}
    	}
    	return json.Unmarshal(data, v)
    }
    
    // SiteReplicationStatus - GET /minio/admin/v3/site-replication/status
    func (a adminAPIHandlers) SiteReplicationStatus(w http.ResponseWriter, r *http.Request) {
    	ctx := r.Context()
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 19.4K bytes
    - Viewed (0)
  6. cmd/bucket-metadata-sys.go

    		if e != nil && !errors.Is(e, errConfigNotFound) {
    			return updatedAt, e
    		}
    		var expiryRuleRemoved bool
    		if len(meta.LifecycleConfigXML) > 0 {
    			var lcCfg lifecycle.Lifecycle
    			if err := xml.Unmarshal(meta.LifecycleConfigXML, &lcCfg); err != nil {
    				return updatedAt, err
    			}
    			// find a single expiry rule set the flag
    			for _, rl := range lcCfg.Rules {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 28 15:32:18 UTC 2024
    - 20.4K bytes
    - Viewed (0)
  7. cni/pkg/nodeagent/ztunnelserver.go

    		return nil, 0, fmt.Errorf("truncated message")
    	}
    	if flags&unix.MSG_CTRUNC != 0 {
    		return nil, 0, fmt.Errorf("truncated control message")
    	}
    	var resp T
    	var respPtr PT = &resp
    	err = proto.Unmarshal(buf[:n], respPtr)
    	if err != nil {
    		return nil, 0, err
    	}
    	return respPtr, oobn, nil
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Jul 29 16:08:35 UTC 2024
    - 13.2K bytes
    - Viewed (0)
  8. cmd/iam-etcd-store.go

    func getIAMConfig(item interface{}, data []byte, itemPath string) error {
    	data, err := decryptData(data, itemPath)
    	if err != nil {
    		return err
    	}
    	json := jsoniter.ConfigCompatibleWithStandardLibrary
    	return json.Unmarshal(data, item)
    }
    
    func (ies *IAMEtcdStore) loadIAMConfig(ctx context.Context, item interface{}, path string) error {
    	data, err := readKeyEtcd(ctx, ies.client, path)
    	if err != nil {
    		return err
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 01:29:20 UTC 2024
    - 14K bytes
    - Viewed (0)
  9. internal/bucket/object/lock/lock.go

    func NewObjectLockConfig() *Config {
    	return &Config{
    		ObjectLockEnabled: Enabled,
    	}
    }
    
    // RetentionDate is a embedded type containing time.Time to unmarshal
    // Date in Retention
    type RetentionDate struct {
    	time.Time
    }
    
    // UnmarshalXML parses date from Retention and validates date format
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Jun 29 01:20:27 UTC 2024
    - 17.1K bytes
    - Viewed (0)
  10. istioctl/pkg/multixds/gather.go

    			Component: "MISSING",
    			ID:        "MISSING",
    			Info: istioversion.BuildInfo{
    				Version: "MISSING CP ID",
    			},
    		}
    	}
    
    	cpID := pilotxds.IstioControlPlaneInstance{}
    	err := json.Unmarshal([]byte(xdsResponse.ControlPlane.Identifier), &cpID)
    	if err != nil {
    		return pilotxds.IstioControlPlaneInstance{
    			Component: "INVALID",
    			ID:        "INVALID",
    			Info: istioversion.BuildInfo{
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 13.6K bytes
    - Viewed (0)
Back to top