Search Options

Results per page
Sort
Preferred Languages
Advance

Results 871 - 880 of 1,105 for errC (0.02 sec)

  1. internal/event/target/kafka_scram_client_contrib.go

    // SASLprep fails, the method returns an error.
    func (x *XDGSCRAMClient) Begin(userName, password, authzID string) (err error) {
    	x.Client, err = x.HashGeneratorFcn.NewClient(userName, password, authzID)
    	if err != nil {
    		return err
    	}
    	x.ClientConversation = x.Client.NewConversation()
    	return nil
    }
    
    // Step takes a string provided from a server (or just an empty string for the
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Nov 09 04:04:01 UTC 2023
    - 3.2K bytes
    - Viewed (0)
  2. cmd/grid.go

    		TraceTo:   globalTrace,
    		RoutePath: grid.RoutePath,
    	})
    	if err != nil {
    		return err
    	}
    	globalGrid.Store(g)
    	return nil
    }
    
    func initGlobalLockGrid(ctx context.Context, eps EndpointServerPools) error {
    	hosts, local := eps.GridHosts()
    	lookupHost := globalDNSCache.LookupHost
    	g, err := grid.NewManager(ctx, grid.ManagerOptions{
    		// Pass Dialer for websocket grid, make sure we do not
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  3. istioctl/pkg/util/clusters/wrapper.go

    	return protomarshal.Marshal(w)
    }
    
    // UnmarshalJSON is a custom unmarshaller to handle protobuf pain
    func (w *Wrapper) UnmarshalJSON(b []byte) error {
    	cd := &admin.Clusters{}
    	err := protomarshal.UnmarshalAllowUnknown(b, cd)
    	*w = Wrapper{cd}
    	return err
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Nov 03 08:41:32 UTC 2022
    - 1.2K bytes
    - Viewed (0)
  4. cni/pkg/plugin/plugin_cni_conformance.go

    		"K8S_POD_INFRA_CONTAINER_ID=3c41e946cf17a32760ff86940a73b06982f1815e9083cf2f4bfccb9b7605f326" +
    		"K8S_POD_UID=a09038c7-df3c-4c0e-8667-487b1fe8055f"
    
    	k8sArgs := K8sArgs{}
    	if err := types.LoadArgs(kubeletArgs, &k8sArgs); err != nil {
    		t.Fatalf("LoadArgs failed with error: %v", err)
    	}
    
    	if string(k8sArgs.K8S_POD_NAMESPACE) == "" ||
    		string(k8sArgs.K8S_POD_NAME) == "" ||
    		string(k8sArgs.K8S_POD_UID) == "" {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed May 29 21:50:09 UTC 2024
    - 1.5K bytes
    - Viewed (0)
  5. src/cmd/asm/internal/lex/input.go

    	}
    	name, err := strconv.Unquote(in.Stack.Text())
    	if err != nil {
    		in.Error("unquoting include file name: ", err)
    	}
    	in.expectNewline("#include")
    	// Push tokenizer for file onto stack.
    	fd, err := os.Open(name)
    	if err != nil {
    		for _, dir := range in.includes {
    			fd, err = os.Open(filepath.Join(dir, name))
    			if err == nil {
    				break
    			}
    		}
    		if err != nil {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Sep 06 13:17:27 UTC 2024
    - 12.5K bytes
    - Viewed (0)
  6. internal/config/lambda/target/lazyinit.go

    		return l.doSlow(f)
    	}
    	return nil
    }
    
    func (l *lazyInit) doSlow(f func() error) error {
    	l.m.Lock()
    	defer l.m.Unlock()
    	if atomic.LoadUint32(&l.done) == 0 {
    		if err := f(); err != nil {
    			return err
    		}
    		// Mark as done only when f() is successful
    		atomic.StoreUint32(&l.done, 1)
    	}
    	return nil
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Mar 07 16:12:41 UTC 2023
    - 1.3K bytes
    - Viewed (0)
  7. internal/s3select/sql/stringfuncs_test.go

    		{`a%__%\`, `a?%?_?_?%\`, '?', true, nil},
    	}
    
    	for i, tc := range evalCases {
    		// fmt.Println("Case:", i)
    		res, err := evalSQLLike(tc.iText, tc.iPat, tc.iEsc)
    		if res != tc.matchExpected || err != tc.errExpected {
    			t.Errorf("Eval Case %d failed: %v %v", i, res, err)
    		}
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 3.1K bytes
    - Viewed (0)
  8. src/bytes/buffer.go

    // ReadBytes returns err != nil if and only if the returned data does not end in
    // delim.
    func (b *Buffer) ReadBytes(delim byte) (line []byte, err error) {
    	slice, err := b.readSlice(delim)
    	// return a copy of slice. The buffer's backing array may
    	// be overwritten by later calls.
    	line = append(line, slice...)
    	return line, err
    }
    
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Oct 29 16:47:05 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  9. internal/bucket/lifecycle/rule_test.go

    		t.Run(fmt.Sprintf("Test %d", i+1), func(t *testing.T) {
    			var rule Rule
    			err := xml.Unmarshal([]byte(tc.inputXML), &rule)
    			if err != nil {
    				t.Fatal(err)
    			}
    
    			if err := rule.Validate(); err != tc.expectedErr {
    				t.Fatalf("%d: Expected %v but got %v", i+1, tc.expectedErr, err)
    			}
    		})
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 01 01:11:10 UTC 2024
    - 4.9K bytes
    - Viewed (0)
  10. internal/crypto/header.go

    	}
    
    	clientKey, err := base64.StdEncoding.DecodeString(h.Get(xhttp.AmzServerSideEncryptionCopyCustomerKey))
    	if err != nil || len(clientKey) != 32 { // The client key must be 256 bits long
    		return key, ErrInvalidCustomerKey
    	}
    	keyMD5, err := base64.StdEncoding.DecodeString(h.Get(xhttp.AmzServerSideEncryptionCopyCustomerKeyMD5))
    	if md5Sum := md5.Sum(clientKey); err != nil || !bytes.Equal(md5Sum[:], keyMD5) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Feb 22 06:26:06 UTC 2024
    - 2.9K bytes
    - Viewed (0)
Back to top