Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 22 for deserialize (0.19 sec)

  1. istioctl/pkg/admin/istiodconfig.go

    	if err != nil {
    		return nil, fmt.Errorf("cannot deserialize response %s", err)
    	}
    	return scopeInfos, nil
    }
    
    func (c *ControlzClient) PutScope(scope *ScopeInfo) error {
    	var jsonScopeInfo bytes.Buffer
    	err := json.NewEncoder(&jsonScopeInfo).Encode(scope)
    	if err != nil {
    		return fmt.Errorf("cannot serialize scope %+v", *scope)
    	}
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Sat Apr 13 05:23:38 GMT 2024
    - 13.5K bytes
    - Viewed (0)
  2. cmd/data-usage-cache.go

    						return true, nil
    					}
    					return false, err
    				}
    				err = d.deserialize(r)
    				r.Close()
    				return err != nil, nil
    			case InsufficientReadQuorum, StorageErr:
    				return true, nil
    			}
    			return false, err
    		}
    		err = d.deserialize(r)
    		r.Close()
    		return err != nil, nil
    	}
    
    	// Caches are read+written without locks,
    	retries := 0
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 22 17:49:30 GMT 2024
    - 41.4K bytes
    - Viewed (1)
  3. cmd/data-usage_test.go

    	var got dataUsageCache
    	err = got.deserialize(&buf)
    	if err != nil {
    		t.Fatal(err)
    	}
    	if got.Info.LastUpdate.IsZero() {
    		t.Error("lastupdate not set")
    	}
    
    	if !want.Info.LastUpdate.Equal(got.Info.LastUpdate) {
    		t.Fatalf("deserialize LastUpdate mismatch\nwant: %+v\ngot:  %+v", want, got)
    	}
    	if len(want.Cache) != len(got.Cache) {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Wed Mar 27 15:10:40 GMT 2024
    - 14.1K bytes
    - Viewed (0)
  4. cmd/streaming-v4-unsigned.go

    			return n, cr.err
    		}
    		if b == '\r' { // \r\n denotes end of size.
    			err := mustRead('\n')
    			if err != nil {
    				cr.err = err
    				return n, cr.err
    			}
    			break
    		}
    
    		// Manually deserialize the size since AWS specified
    		// the chunk size to be of variable width. In particular,
    		// a size of 16 is encoded as `10` while a size of 64 KB
    		// is `10000`.
    		switch {
    		case b >= '0' && b <= '9':
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sat May 06 02:53:12 GMT 2023
    - 6.1K bytes
    - Viewed (1)
  5. istioctl/pkg/kubeinject/kubeinject.go

    		return nil, err
    	}
    	defer resp.Body.Close()
    	body, err := io.ReadAll(resp.Body)
    	if err != nil {
    		return nil, err
    	}
    	var obj runtime.Object
    	var ar *kube.AdmissionReview
    	out, _, err := deserializer.Decode(body, nil, obj)
    	if err != nil {
    		return nil, fmt.Errorf("could not decode body: %v", err)
    	}
    	ar, err = kube.AdmissionReviewKubeToAdapter(out)
    	if err != nil {
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Fri Mar 29 02:29:02 GMT 2024
    - 21.6K bytes
    - Viewed (0)
  6. misc/go_android_exec/main.go

    	log.SetPrefix("go_android_exec: ")
    	exitCode, err := runMain()
    	if err != nil {
    		log.Fatal(err)
    	}
    	os.Exit(exitCode)
    }
    
    func runMain() (int, error) {
    	// Concurrent use of adb is flaky, so serialize adb commands.
    	// See https://github.com/golang/go/issues/23795 or
    	// https://issuetracker.google.com/issues/73230216.
    	lockPath := filepath.Join(os.TempDir(), "go_android_exec-adb-lock")
    Go
    - Registered: Tue Apr 23 11:13:09 GMT 2024
    - Last Modified: Mon Aug 21 17:46:57 GMT 2023
    - 15.3K bytes
    - Viewed (0)
  7. cmd/s3-zip-handlers.go

    	files, srcInfo, err := getFilesListFromZIPObject(ctx, objectAPI, bucket, object, opts)
    	if err != nil {
    		return nil, err
    	}
    	files.OptimizeSize()
    	zipInfo, err := files.Serialize()
    	if err != nil {
    		return nil, err
    	}
    	at := archiveType
    	zipInfoStr := string(zipInfo)
    	if opts.EncryptFn != nil {
    		at = archiveTypeEnc
    		zipInfoStr = string(opts.EncryptFn(archiveTypeEnc, zipInfo))
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Apr 09 10:41:25 GMT 2024
    - 15.8K bytes
    - Viewed (0)
  8. cmd/streaming-signature-v4.go

    		if err == io.EOF {
    			err = io.ErrUnexpectedEOF
    		}
    		if err != nil {
    			cr.err = err
    			return n, cr.err
    		}
    		if b == ';' { // separating character
    			break
    		}
    
    		// Manually deserialize the size since AWS specified
    		// the chunk size to be of variable width. In particular,
    		// a size of 16 is encoded as `10` while a size of 64 KB
    		// is `10000`.
    		switch {
    		case b >= '0' && b <= '9':
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 18.2K bytes
    - Viewed (0)
  9. misc/ios/go_ios_exec.go

    	"time"
    )
    
    const debug = false
    
    var tmpdir string
    
    var (
    	devID    string
    	appID    string
    	teamID   string
    	bundleID string
    	deviceID string
    )
    
    // lock is a file lock to serialize iOS runs. It is global to avoid the
    // garbage collector finalizing it, closing the file and releasing the
    // lock prematurely.
    var lock *os.File
    
    func main() {
    	log.SetFlags(0)
    	log.SetPrefix("go_ios_exec: ")
    Go
    - Registered: Tue Apr 23 11:13:09 GMT 2024
    - Last Modified: Mon Apr 11 16:34:30 GMT 2022
    - 23.4K bytes
    - Viewed (0)
  10. istioctl/pkg/tag/generate_test.go

    			whURL:          "",
    			whSVC:          "istiod-revision",
    			whCA:           "ca",
    			userManaged:    true,
    		},
    	}
    	scheme := runtime.NewScheme()
    	codecFactory := serializer.NewCodecFactory(scheme)
    	deserializer := codecFactory.UniversalDeserializer()
    
    	fail := admitv1.Fail
    	fakeClient := kube.NewFakeClient(&admitv1.ValidatingWebhookConfiguration{
    		TypeMeta: metav1.TypeMeta{},
    		ObjectMeta: metav1.ObjectMeta{
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Tue Jan 16 17:43:49 GMT 2024
    - 12.1K bytes
    - Viewed (0)
Back to top