Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 62 for Negated (0.2 sec)

  1. internal/s3select/sql/utils.go

    		e.And[0].Condition[0].Operand.ConditionRHS != nil {
    		return "", false
    	}
    
    	operand := e.And[0].Condition[0].Operand.Operand
    	if operand.Right != nil ||
    		operand.Left.Right != nil ||
    		operand.Left.Left.Negated != nil ||
    		operand.Left.Left.Primary.JPathExpr == nil {
    		return "", false
    	}
    
    	// Check if path expression ends in a key
    	jpath := operand.Left.Left.Primary.JPathExpr
    	n := len(jpath.PathExpr)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Nov 10 16:12:50 GMT 2021
    - 3.6K bytes
    - Viewed (0)
  2. internal/s3select/sql/evaluate.go

    	}
    	return lval, nil
    }
    
    func (e *UnaryTerm) evalNode(r Record, tableAlias string) (*Value, error) {
    	if e.Negated == nil {
    		return e.Primary.evalNode(r, tableAlias)
    	}
    
    	v, err := e.Negated.Term.evalNode(r, tableAlias)
    	if err != nil {
    		return nil, err
    	}
    
    	inferTypeForArithOp(v)
    	v.negate()
    	if v.isNumeric() {
    		return v, nil
    	}
    	return nil, errArithMismatchedTypes
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Dec 23 07:19:11 GMT 2023
    - 12K bytes
    - Viewed (0)
  3. internal/s3select/sql/aggregation.go

    		err = rt.Right.aggregateRow(r, tableAlias)
    		if err != nil {
    			return err
    		}
    	}
    	return nil
    }
    
    func (e *UnaryTerm) aggregateRow(r Record, tableAlias string) error {
    	if e.Negated != nil {
    		return e.Negated.Term.aggregateRow(r, tableAlias)
    	}
    	return e.Primary.aggregateRow(r, tableAlias)
    }
    
    func (e *PrimaryTerm) aggregateRow(r Record, tableAlias string) error {
    	switch {
    	case e.ListExpr != nil:
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Dec 23 07:19:11 GMT 2023
    - 7.9K bytes
    - Viewed (0)
  4. internal/s3select/sql/analysis.go

    	result.combine(e.Left.analyze(s))
    	for _, r := range e.Right {
    		result.combine(r.Right.analyze(s))
    	}
    	return
    }
    
    func (e *UnaryTerm) analyze(s *Select) (result qProp) {
    	if e.Negated != nil {
    		result = e.Negated.Term.analyze(s)
    	} else {
    		result = e.Primary.analyze(s)
    	}
    	return
    }
    
    func (e *PrimaryTerm) analyze(s *Select) (result qProp) {
    	switch {
    	case e.Value != nil:
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Dec 23 07:19:11 GMT 2023
    - 8.5K bytes
    - Viewed (0)
  5. internal/s3select/sql/value.go

    		return string(x)
    	case []Value:
    		b, _ := json.Marshal(x)
    		return string(b)
    
    	default:
    		return "CSV serialization not implemented for this type"
    	}
    }
    
    // negate negates a numeric value
    func (v *Value) negate() {
    	switch x := v.value.(type) {
    	case float64:
    		v.value = -x
    	case int64:
    		v.value = -x
    	}
    }
    
    // Value comparison functions: we do not expose them outside the
    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)
  6. internal/mcontext/ctxt.go

    type ContextTraceType string
    
    // ContextTraceKey is the key of TraceCtxt saved in a Golang context
    const ContextTraceKey = ContextTraceType("ctx-trace-info")
    
    // TraceCtxt holds related tracing data of a http request.
    type TraceCtxt struct {
    	RequestRecorder  *xhttp.RequestRecorder
    	ResponseRecorder *xhttp.ResponseRecorder
    
    	FuncName string
    	AmzReqID string
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Dec 06 17:27:26 GMT 2022
    - 1.3K bytes
    - Viewed (0)
  7. internal/rest/rpc-stats.go

    	}
    	if v := atomic.LoadUint64(&globalStats.tcpDialCount); v > 0 {
    		s.DialAvgDuration = atomic.LoadUint64(&globalStats.tcpDialTotalDur) / v
    	}
    	return s
    }
    
    // Return a function which update the global stats related to tcp connections
    func setupReqStatsUpdate(req *http.Request) (*http.Request, func()) {
    	var dialStart, dialEnd int64
    
    	trace := &httptrace.ClientTrace{
    		ConnectStart: func(network, addr string) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Sep 29 16:27:58 GMT 2022
    - 2.3K bytes
    - Viewed (0)
  8. cmd/mrf.go

    	versionID           string
    	versions            []byte
    	setIndex, poolIndex int
    	queued              time.Time
    	scanMode            madmin.HealScanMode
    }
    
    // mrfState sncapsulates all the information
    // related to the global background MRF.
    type mrfState struct {
    	opCh chan partialOperation
    }
    
    // Add a partial S3 operation (put/delete) when one or more disks are offline.
    func (m *mrfState) addPartialOp(op partialOperation) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 3.2K bytes
    - Viewed (0)
  9. cmd/object-api-errors.go

    }
    
    // Bucket related errors.
    
    // BucketNameInvalid - bucketname provided is invalid.
    type BucketNameInvalid GenericError
    
    // Error returns string an error formatted as the given text.
    func (e BucketNameInvalid) Error() string {
    	return "Bucket name invalid: " + e.Bucket
    }
    
    // Object related errors.
    
    // ObjectNameInvalid - object name provided is invalid.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 21.3K bytes
    - Viewed (0)
  10. internal/config/identity/openid/openid.go

    	return c, nil
    }
    
    // ErrProviderConfigNotFound - represents a non-existing provider error.
    var ErrProviderConfigNotFound = errors.New("provider configuration not found")
    
    // GetConfigInfo - returns configuration and related info for the given IDP
    // provider.
    func (r *Config) GetConfigInfo(s config.Config, cfgName string) ([]madmin.IDPCfgInfo, error) {
    	openIDConfigs, err := s.GetAvailableTargets(config.IdentityOpenIDSubSys)
    	if err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Nov 16 04:42:31 GMT 2023
    - 16.5K bytes
    - Viewed (0)
Back to top