Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 110 for first (0.13 sec)

  1. internal/logger/target/kafka/kafka_scram_client_contrib.go

    	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
    // 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
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Nov 09 04:04:01 GMT 2023
    - 3.3K bytes
    - Viewed (1)
  2. cmd/encryption-v1_test.go

    			}
    			if skip != 0 || sn != 0 || ps != 0 || o != 0 || l != getEncSize(test.decSz) {
    				t.Errorf("Case %d: test failed: %d %d %d %d %d", i, o, l, skip, sn, ps)
    			}
    		}
    
    		if test.decSz >= 10 {
    			// first 10 bytes
    			o, l, skip, sn, ps, err := test.oi.GetDecryptedRange(&HTTPRangeSpec{false, 0, 9})
    			if err != nil {
    				t.Errorf("Case %d: unexpected err: %v", i, err)
    			}
    			rLen := pkgSz + 32
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Sep 24 04:17:08 GMT 2022
    - 19.9K bytes
    - Viewed (0)
  3. internal/s3select/sql/value.go

    // assumed to be numeric. Attempts conversion to numeric type for `a`
    // (first int, then float) only if the underlying values do not have a
    // type.
    func (v *Value) minmax(a *Value, isMax, isFirstRow bool) error {
    	err := inferTypeForArithOp(a)
    	if err != nil {
    		return err
    	}
    
    	if !a.isNumeric() {
    		return errArithMismatchedTypes
    	}
    
    	// In case of first row, set v to a.
    	if isFirstRow {
    		intA, okI := a.ToInt()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Feb 25 20:31:19 GMT 2022
    - 20.2K bytes
    - Viewed (0)
  4. cmd/server_test.go

    	}{
    		// request for byte range 10-11.
    		// expecting the result to contain only putContent[10:12] bytes.
    		{"10-11", putContent[10:12]},
    		// request for object data after the first byte.
    		{"1-", putContent[1:]},
    		// request for object data after the first byte.
    		{"6-", putContent[6:]},
    		// request for last 2 bytes of the object.
    		{"-2", putContent[len(putContent)-2:]},
    		// request for last 7 bytes of the object.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 108K bytes
    - Viewed (0)
  5. cmd/bootstrap-peer-server.go

    // ServerSystemConfig - captures information about server configuration.
    type ServerSystemConfig struct {
    	NEndpoints int
    	CmdLines   []string
    	MinioEnv   map[string]string
    }
    
    // Diff - returns error on first difference found in two configs.
    func (s1 *ServerSystemConfig) Diff(s2 *ServerSystemConfig) error {
    	ns1 := s1.NEndpoints
    	ns2 := s2.NEndpoints
    	if ns1 != ns2 {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 7.5K bytes
    - Viewed (0)
  6. cmd/api-errors.go

    		HTTPStatusCode: http.StatusBadRequest,
    	},
    	ErrInvalidCopyPartRange: {
    		Code:           "InvalidArgument",
    		Description:    "The x-amz-copy-source-range value must be of the form bytes=first-last where first and last are the zero-based offsets of the first and last bytes to copy",
    		HTTPStatusCode: http.StatusBadRequest,
    	},
    	ErrInvalidCopyPartRangeSource: {
    		Code:           "InvalidArgument",
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 91.4K bytes
    - Viewed (7)
  7. internal/handlers/proxy.go

    	forwarded = http.CanonicalHeaderKey("Forwarded")
    	// Allows for a sub-match of the first value after 'for=' to the next
    	// comma, semi-colon or space. The match is case-insensitive.
    	forRegex = regexp.MustCompile(`(?i)(?:for=)([^(;|,| )]+)(.*)`)
    	// Allows for a sub-match for the first instance of scheme (http|https)
    	// prefixed by 'proto='. The match is case-insensitive.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Dec 22 00:56:55 GMT 2023
    - 5.1K bytes
    - Viewed (0)
  8. cmd/xl-storage-meta-inline.go

    // If any error occurs the unmodified data is returned.
    func xlMetaV2TrimData(buf []byte) []byte {
    	metaBuf, min, maj, err := checkXL2V1(buf)
    	if err != nil {
    		return buf
    	}
    	if maj == 1 && min < 1 {
    		// First version to carry data.
    		return buf
    	}
    	// Skip header
    	_, metaBuf, err = msgp.ReadBytesZC(metaBuf)
    	if err != nil {
    		storageLogIf(GlobalContext, err)
    		return buf
    	}
    	// Skip CRC
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 9.5K bytes
    - Viewed (0)
  9. cmd/erasure-server-pool-rebalance.go

    						stopFn(err)
    						continue
    					}
    
    					stopFn(nil)
    					failure = false
    					break
    				}
    				if ignore {
    					continue
    				}
    				if failure {
    					break // break out on first error
    				}
    				z.updatePoolStats(poolIdx, bucket, version)
    				rebalanced++
    			}
    
    			// if all versions were rebalanced, we can delete the object versions.
    			if rebalanced == len(fivs.Versions) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 19:29:28 GMT 2024
    - 27.2K bytes
    - Viewed (0)
  10. cmd/erasure-server-pool.go

    			errs[idx] = err
    			results[idx] = result
    		}(idx, pool)
    	}
    	wg.Wait()
    
    	// Return the first nil error
    	for idx, err := range errs {
    		if err == nil {
    			return results[idx], nil
    		}
    	}
    
    	// No pool returned a nil error, return the first non 'not found' error
    	for idx, err := range errs {
    		if !isErrObjectNotFound(err) && !isErrVersionNotFound(err) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 80.5K bytes
    - Viewed (0)
Back to top