Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 117 for step (0.15 sec)

  1. internal/event/target/kafka_scram_client_contrib.go

    	return nil
    }
    
    // Step takes a string provided from a server (or just an empty string for the
    // very first conversation step) and attempts to move the authentication
    // conversation forward.  It returns a string to be sent to the server or an
    // error if the server message is invalid.  Calling Step after a conversation
    // completes is also an error.
    func (x *XDGSCRAMClient) Step(challenge string) (response string, err error) {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Nov 09 04:04:01 GMT 2023
    - 3.2K bytes
    - Viewed (0)
  2. internal/logger/target/kafka/kafka_scram_client_contrib.go

    	return nil
    }
    
    // Step takes a string provided from a server (or just an empty string for the
    // very first conversation step) and attempts to move the authentication
    // conversation forward.  It returns a string to be sent to the server or an
    // error if the server message is invalid.  Calling Step after a conversation
    // completes is also an error.
    func (x *XDGSCRAMClient) Step(challenge string) (response string, err error) {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Nov 09 04:04:01 GMT 2023
    - 3.3K bytes
    - Viewed (1)
  3. src/bufio/bufio_test.go

    // A scriptedReader is an io.Reader that executes its steps sequentially.
    type scriptedReader []func(p []byte) (n int, err error)
    
    func (sr *scriptedReader) Read(p []byte) (n int, err error) {
    	if len(*sr) == 0 {
    		panic("too many Read calls on scripted Reader. No steps remain.")
    	}
    	step := (*sr)[0]
    	*sr = (*sr)[1:]
    	return step(p)
    }
    
    func newScriptedReader(steps ...func(p []byte) (n int, err error)) io.Reader {
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Fri Feb 10 18:56:01 GMT 2023
    - 51.5K bytes
    - Viewed (0)
  4. src/cmd/cgo/doc.go

    present to create such a binary.
    
    Most builds both compile source code and invoke the linker to create a
    binary. When cgo is involved, the compile step already requires gcc, so
    it is not problematic for the link step to require gcc too.
    
    An important exception is builds using a pre-compiled copy of the
    standard library. In particular, package net uses cgo on most systems,
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Sun Mar 31 09:02:45 GMT 2024
    - 42.1K bytes
    - Viewed (0)
  5. src/cmd/api/main_test.go

    		log.Fatal(err)
    	}
    	s := string(bs)
    
    	// Diagnose common mistakes people make,
    	// since there is no apifmt to format these files.
    	// The missing final newline is important for the
    	// final release step of cat next/*.txt >go1.X.txt.
    	// If the files don't end in full lines, the concatenation goes awry.
    	if strings.Contains(s, "\r") {
    		log.Printf("%s: contains CRLFs", filename)
    		exitCode = 1
    	}
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Tue Apr 09 20:48:51 GMT 2024
    - 31.4K bytes
    - Viewed (0)
  6. cmd/namespace-lock_test.go

    		//    successfully acquiring the lock.
    		// 2) lk2 then needs to advance and remove the resource from lockMap.
    		// 3) lk3 or lk4 (whichever didn't execute in step 1) then executes and creates
    		//    a new entry in lockMap and acquires a lock for the same resource.
    
    		<-lk2ch
    		lk3ok := <-lk3ch
    		lk4ok := <-lk4ch
    
    		if lk3ok && lk4ok {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 23 18:58:53 GMT 2021
    - 3.1K bytes
    - Viewed (0)
  7. cmd/erasure-object_test.go

    	}
    
    	for i, testCase := range testCases {
    		// Step 1: create a bucket
    		err = z.MakeBucket(ctx, testCase.bucket, MakeBucketOptions{VersioningEnabled: testCase.versioned})
    		if err != nil {
    			t.Fatalf("Test %d: Failed to create a bucket: %v", i+1, err)
    		}
    
    		// Step 2: Upload an object with a random content
    		initialData := bytes.Repeat([]byte{'b'}, len(testCase.content))
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Jan 30 20:43:25 GMT 2024
    - 36.8K bytes
    - Viewed (0)
  8. istioctl/pkg/version/version.go

      istioctl x version
    
      # Retrieve version information directly from the control plane, using RSA certificate security
      # (Certificates must be obtained before this step.  The --cert-dir flag lets istioctl bypass the Kubernetes API server.)
      istioctl x version --xds-address istio.example.com:15012 --cert-dir ~/.istio-certs
    
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Fri Mar 15 01:18:49 GMT 2024
    - 8.3K bytes
    - Viewed (0)
  9. src/bytes/bytes_test.go

    		buf[n-7] = '\x00'
    	})
    }
    
    func BenchmarkCountSingle(b *testing.B) {
    	benchBytes(b, indexSizes, func(b *testing.B, n int) {
    		buf := bmbuf[0:n]
    		step := 8
    		for i := 0; i < len(buf); i += step {
    			buf[i] = 1
    		}
    		expect := (len(buf) + (step - 1)) / step
    		for i := 0; i < b.N; i++ {
    			j := Count(buf, []byte{1})
    			if j != expect {
    				b.Fatal("bad count", j, expect)
    			}
    		}
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Wed Jan 24 16:07:25 GMT 2024
    - 56.2K bytes
    - Viewed (0)
  10. istioctl/pkg/internaldebug/internal-debug.go

      istioctl x internal-debug syncz
    
      # Retrieve syncz debug information directly from the control plane, using RSA certificate security
      # (Certificates must be obtained before this step.  The --cert-dir flag lets istioctl bypass the Kubernetes API server.)
      istioctl x internal-debug syncz --xds-address istio.example.com:15012 --cert-dir ~/.istio-certs
    
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Fri Mar 15 04:16:55 GMT 2024
    - 6.9K bytes
    - Viewed (0)
Back to top