Search Options

Results per page
Sort
Preferred Languages
Advance

Results 361 - 370 of 391 for ctx_ (0.04 sec)

  1. cmd/api-errors.go

    	}
    
    	// Only return ErrClientDisconnected if the provided context is actually canceled.
    	// This way downstream context.Canceled will still report ErrRequestTimedout
    	if contextCanceled(ctx) && errors.Is(ctx.Err(), context.Canceled) {
    		return ErrClientDisconnected
    	}
    
    	// Unwrap the error first
    	err = unwrapAll(err)
    
    	switch err {
    	case errInvalidArgument:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 92.1K bytes
    - Viewed (0)
  2. compat/maven-compat/src/test/java/org/apache/maven/profiles/manager/DefaultProfileManagerTest.java

            osActivation.setOs( activationOS );
    
            osActivated.setActivation( osActivation );
    
            Properties props = System.getProperties();
            ProfileActivationContext ctx = new ProfileActivationContext( props, false );
    
            ProfileManager profileManager = new DefaultProfileManager( getContainer(), props );
    
            profileManager.addProfile( osActivated );
    
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 7.3K bytes
    - Viewed (0)
  3. cmd/main.go

    	app.Flags = GlobalFlags
    	app.HideHelpCommand = true // Hide `help, h` command, we already have `minio --help`.
    	app.Commands = commands
    	app.CustomAppHelpTemplate = minioHelpTemplate
    	app.CommandNotFound = func(ctx *cli.Context, command string) {
    		console.Printf("‘%s’ is not a minio sub-command. See ‘minio --help’.\n", command)
    		closestCommands := findClosestCommands(command)
    		if len(closestCommands) > 0 {
    			console.Println()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 30 22:59:48 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  4. tests/scanner_valuer_test.go

    }
    
    type NullString struct {
    	sql.NullString
    }
    
    type Point struct {
    	X, Y int
    }
    
    func (point Point) GormDataType() string {
    	return "geo"
    }
    
    func (point Point) GormValue(ctx context.Context, db *gorm.DB) clause.Expr {
    	return clause.Expr{
    		SQL:  "ST_PointFromText(?)",
    		Vars: []interface{}{fmt.Sprintf("POINT(%d %d)", point.X, point.Y)},
    	}
    }
    
    func TestGORMValuer(t *testing.T) {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Wed Jun 07 07:02:07 UTC 2023
    - 10.6K bytes
    - Viewed (0)
  5. internal/hash/checksum.go

    	"strconv"
    	"strings"
    
    	"github.com/minio/minio/internal/hash/sha256"
    	xhttp "github.com/minio/minio/internal/http"
    	"github.com/minio/minio/internal/logger"
    )
    
    func hashLogIf(ctx context.Context, err error) {
    	logger.LogIf(ctx, "hash", err)
    }
    
    // MinIOMultipartChecksum is as metadata on multipart uploads to indicate checksum type.
    const MinIOMultipartChecksum = "x-minio-multipart-checksum"
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 19 12:59:07 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  6. schema/relationship.go

    			} else {
    				constraint.Schema = rel.Schema
    				constraint.ReferenceSchema = ref.PrimaryKey.Schema
    			}
    		}
    	}
    
    	return &constraint
    }
    
    func (rel *Relationship) ToQueryConditions(ctx context.Context, reflectValue reflect.Value) (conds []clause.Expression) {
    	table := rel.FieldSchema.Table
    	foreignFields := []*Field{}
    	relForeignKeys := []string{}
    
    	if rel.JoinTable != nil {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Wed Jun 12 03:46:59 UTC 2024
    - 22.7K bytes
    - Viewed (0)
  7. cmd/object-api-utils.go

    	rng := rand.New(rand.NewSource(time.Now().UTC().UnixNano()))
    	var d net.Dialer
    	var retry int
    	for retry < len(hosts) {
    		ctx, cancel := context.WithTimeout(GlobalContext, 300*time.Millisecond)
    
    		host = hosts[rng.Intn(len(hosts))]
    		conn, err := d.DialContext(ctx, "tcp", host)
    		cancel()
    		if err != nil {
    			retry++
    			continue
    		}
    		conn.Close()
    		break
    	}
    
    	return host
    }
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 08 15:29:58 UTC 2024
    - 37.1K bytes
    - Viewed (0)
  8. docs/lambda/README.md

    ```
    
    ## Invoke Lambda transformation via PresignedGET
    
    Following example shows how you can use [`minio-go` PresignedGetObject](https://min.io/docs/minio/linux/developers/go/API.html#presignedgetobject-ctx-context-context-bucketname-objectname-string-expiry-time-duration-reqparams-url-values-url-url-error)
    ```go
    package main
    
    import (
    	"context"
    	"log"
    	"net/url"
    	"time"
    	"fmt"
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Apr 04 19:15:28 UTC 2023
    - 7.6K bytes
    - Viewed (0)
  9. src/cmd/api/main_test.go

    		Importer:         w,
    		Sizes:            sizes,
    	}
    	tpkg, err := conf.Check(name, fset, files, nil)
    	if err != nil {
    		ctxt := "<no context>"
    		if w.context != nil {
    			ctxt = fmt.Sprintf("%s-%s", w.context.GOOS, w.context.GOARCH)
    		}
    		log.Fatalf("error typechecking package %s: %s (%s)", name, err, ctxt)
    	}
    	pkg = &apiPackage{tpkg, files}
    
    	if usePkgCache {
    		pkgCache[key] = pkg
    	}
    
    	w.imported[name] = pkg
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Sep 04 18:16:59 UTC 2024
    - 31.4K bytes
    - Viewed (0)
  10. cmd/object-api-utils_test.go

    	apiRouter.ServeHTTP(rec, req)
    
    	ctx, cancel := context.WithCancel(GlobalContext)
    	defer cancel()
    
    	// Now check if we actually wrote to backend (regardless of the response
    	// returned by the server).
    	z := obj.(*erasureServerPools)
    	xl := z.serverPools[0].sets[0]
    	erasureDisks := xl.getDisks()
    	parts, errs := readAllFileInfo(ctx, erasureDisks, "", bucketName, objectName, "", false, false)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 08 15:29:58 UTC 2024
    - 24.1K bytes
    - Viewed (0)
Back to top