Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 112 for Vars (0.03 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. clause/expression_test.go

    			clause.NamedExpr{SQL: result.SQL, Vars: result.Vars}.Build(stmt)
    			if stmt.SQL.String() != result.Result {
    				t.Errorf("generated SQL is not equal, expects %v, but got %v", result.Result, stmt.SQL.String())
    			}
    
    			if !reflect.DeepEqual(result.ExpectedVars, stmt.Vars) {
    				t.Errorf("generated vars is not equal, expects %v, but got %v", result.ExpectedVars, stmt.Vars)
    			}
    		})
    	}
    }
    
    Created: Sun Apr 05 09:35:12 GMT 2026
    - Last Modified: Tue Nov 04 07:04:52 GMT 2025
    - 8.9K bytes
    - Click Count (0)
  2. cmd/dummy-handlers.go

    func (api objectAPIHandlers) GetBucketWebsiteHandler(w http.ResponseWriter, r *http.Request) {
    	ctx := newContext(r, w, "GetBucketWebsite")
    
    	defer logger.AuditLog(ctx, w, r, mustGetClaimsFromToken(r))
    
    	vars := mux.Vars(r)
    	bucket := vars["bucket"]
    
    	objAPI := api.ObjectAPI()
    	if objAPI == nil {
    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrServerNotInitialized), r.URL)
    		return
    	}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Aug 13 15:25:16 GMT 2024
    - 8.8K bytes
    - Click Count (0)
  3. cmd/acl-handlers.go

    	ctx := newContext(r, w, "PutObjectACL")
    
    	defer logger.AuditLog(ctx, w, r, mustGetClaimsFromToken(r))
    
    	vars := mux.Vars(r)
    	bucket := vars["bucket"]
    	object, err := unescapePath(vars["object"])
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	objAPI := api.ObjectAPI()
    	if objAPI == nil {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri May 24 23:05:23 GMT 2024
    - 8.4K bytes
    - Click Count (0)
  4. cmd/bucket-listobjects-handlers.go

    	ctx := newContext(r, w, "ListObjectVersions")
    
    	defer logger.AuditLog(ctx, w, r, mustGetClaimsFromToken(r))
    
    	vars := mux.Vars(r)
    	bucket := vars["bucket"]
    
    	objectAPI := api.ObjectAPI()
    	if objectAPI == nil {
    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrServerNotInitialized), r.URL)
    		return
    	}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 11.6K bytes
    - Click Count (0)
  5. cmd/bucket-handlers.go

    func (api objectAPIHandlers) GetBucketLocationHandler(w http.ResponseWriter, r *http.Request) {
    	ctx := newContext(r, w, "GetBucketLocation")
    
    	defer logger.AuditLog(ctx, w, r, mustGetClaimsFromToken(r))
    
    	vars := mux.Vars(r)
    	bucket := vars["bucket"]
    
    	objectAPI := api.ObjectAPI()
    	if objectAPI == nil {
    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrServerNotInitialized), r.URL)
    		return
    	}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 63.9K bytes
    - Click Count (0)
  6. callbacks/query.go

    											vars := onStmt.Vars
    											for idx, v := range vars {
    												bindvar := strings.Builder{}
    												onStmt.Vars = vars[0 : idx+1]
    												db.Dialector.BindVarTo(&bindvar, &onStmt, v)
    												onSQL = strings.Replace(onSQL, bindvar.String(), "?", 1)
    											}
    
    											exprs = append(exprs, clause.Expr{SQL: onSQL, Vars: vars})
    										}
    									}
    								}
    Created: Sun Apr 05 09:35:12 GMT 2026
    - Last Modified: Sun May 25 07:40:40 GMT 2025
    - 10.4K bytes
    - Click Count (3)
  7. cmd/bucket-lifecycle-handlers.go

    	objAPI := api.ObjectAPI()
    	if objAPI == nil {
    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrServerNotInitialized), r.URL)
    		return
    	}
    
    	vars := mux.Vars(r)
    	bucket := vars["bucket"]
    
    	// PutBucketLifecycle always needs a Content-Md5
    	if !validateLengthAndChecksum(r) {
    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrMissingContentMD5), r.URL)
    		return
    	}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon Jan 20 14:49:07 GMT 2025
    - 7K bytes
    - Click Count (0)
  8. generics.go

    			}
    
    			subdb.Statement.SQL.Reset()
    			subdb.Statement.Vars = stmt.Vars
    			if strings.Contains(sql, "@") {
    				clause.NamedExpr{SQL: sql, Vars: vars}.Build(subdb.Statement)
    			} else {
    				clause.Expr{SQL: sql, Vars: vars}.Build(subdb.Statement)
    			}
    		} else {
    			subdb.Statement.Vars = append(stmt.Vars, subdb.Statement.Vars...)
    			subdb.callbacks.Query().Execute(subdb)
    		}
    
    Created: Sun Apr 05 09:35:12 GMT 2026
    - Last Modified: Sat Mar 21 11:34:24 GMT 2026
    - 26K bytes
    - Click Count (0)
  9. cmd/bucket-policy-handlers.go

    	objAPI := api.ObjectAPI()
    	if objAPI == nil {
    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrServerNotInitialized), r.URL)
    		return
    	}
    
    	vars := mux.Vars(r)
    	bucket := vars["bucket"]
    
    	if s3Error := checkRequestAuthType(ctx, r, policy.PutBucketPolicyAction, bucket, ""); s3Error != ErrNone {
    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Error), r.URL)
    		return
    	}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri May 24 23:05:23 GMT 2024
    - 6.1K bytes
    - Click Count (0)
  10. cmd/tier-handlers.go

    	ctx := r.Context()
    
    	objAPI, cred := validateAdminReq(ctx, w, r, policy.SetTierAction)
    	if objAPI == nil {
    		return
    	}
    	vars := mux.Vars(r)
    	scName := vars["tier"]
    
    	password := cred.SecretKey
    	reqBytes, err := madmin.DecryptData(password, io.LimitReader(r.Body, r.ContentLength))
    	if err != nil {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Thu Sep 12 20:44:05 GMT 2024
    - 7.5K bytes
    - Click Count (0)
Back to Top