Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 44 for WithCancel (0.22 sec)

  1. cmd/jwt_test.go

    	token := jwtgo.NewWithClaims(jwtgo.SigningMethodHS512, claims)
    	return token.SignedString([]byte(secretKey))
    }
    
    // Tests web request authenticator.
    func TestWebRequestAuthenticate(t *testing.T) {
    	ctx, cancel := context.WithCancel(t.Context())
    	defer cancel()
    
    	obj, fsDir, err := prepareFS(ctx)
    	if err != nil {
    		t.Fatal(err)
    	}
    	defer os.RemoveAll(fsDir)
    	if err = newTestConfig(globalMinioDefaultRegion, obj); err != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 4.4K bytes
    - Viewed (0)
  2. cmd/erasure-object_test.go

    	"runtime"
    	"strconv"
    	"testing"
    
    	"github.com/dustin/go-humanize"
    	"github.com/minio/minio/internal/config/storageclass"
    )
    
    func TestRepeatPutObjectPart(t *testing.T) {
    	ctx, cancel := context.WithCancel(t.Context())
    	defer cancel()
    
    	var objLayer ObjectLayer
    	var disks []string
    	var err error
    	var opts ObjectOptions
    
    	objLayer, disks, err = prepareErasure16(ctx)
    	if err != nil {
    		t.Fatal(err)
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 38.3K bytes
    - Viewed (0)
  3. cmd/server-startup-msg_test.go

    		t.Fatalf("Expected %#v, got %#v", apiEndpoints, newAPIEndpoints)
    	}
    }
    
    // Test printing server common message.
    func TestPrintServerCommonMessage(t *testing.T) {
    	ctx, cancel := context.WithCancel(t.Context())
    	defer cancel()
    
    	obj, fsDir, err := prepareFS(ctx)
    	if err != nil {
    		t.Fatal(err)
    	}
    	defer os.RemoveAll(fsDir)
    	if err = newTestConfig(globalMinioDefaultRegion, obj); err != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Apr 09 14:28:39 UTC 2025
    - 3K bytes
    - Viewed (0)
  4. cmd/signature-v2_test.go

    			break
    		}
    	}
    }
    
    // Tests presigned v2 signature.
    func TestDoesPresignedV2SignatureMatch(t *testing.T) {
    	ctx, cancel := context.WithCancel(t.Context())
    	defer cancel()
    
    	obj, fsDir, err := prepareFS(ctx)
    	if err != nil {
    		t.Fatal(err)
    	}
    	defer os.RemoveAll(fsDir)
    	if err = newTestConfig(globalMinioDefaultRegion, obj); err != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 8K bytes
    - Viewed (0)
  5. cmd/admin-handlers_test.go

    // prepareAdminErasureTestBed - helper function that setups a single-node
    // Erasure backend for admin-handler tests.
    func prepareAdminErasureTestBed(ctx context.Context) (*adminErasureTestBed, error) {
    	ctx, cancel := context.WithCancel(ctx)
    
    	// reset global variables to start afresh.
    	resetTestGlobals()
    
    	// Set globalIsErasure to indicate that the setup uses an erasure
    	// code backend.
    	globalIsErasure = true
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 13.9K bytes
    - Viewed (1)
  6. cmd/benchmark-utils_test.go

    func benchmarkPutObjectPart(b *testing.B, instanceType string, objSize int) {
    	// create a temp Erasure/FS backend.
    	ctx, cancel := context.WithCancel(b.Context())
    	defer cancel()
    	objLayer, disks, err := prepareTestBackend(ctx, instanceType)
    	if err != nil {
    		b.Fatalf("Failed obtaining Temp Backend: <ERROR> %s", err)
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 8.1K bytes
    - Viewed (0)
  7. cmd/erasure-healing_test.go

    				t.Errorf("Expected dangling %t, got %t", testCase.expectedDangling, dangling)
    			}
    		})
    	}
    }
    
    // Tests both object and bucket healing.
    func TestHealing(t *testing.T) {
    	ctx, cancel := context.WithCancel(t.Context())
    	defer cancel()
    
    	obj, fsDirs, err := prepareErasure16(ctx)
    	if err != nil {
    		t.Fatal(err)
    	}
    	defer obj.Shutdown(t.Context())
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 48.5K bytes
    - Viewed (0)
  8. cmd/erasure-metadata-utils_test.go

    	if hashedOrder := hashOrder("This will fail", 0); hashedOrder != nil {
    		t.Errorf("Test: Expect \"nil\" but failed \"%#v\"", hashedOrder)
    	}
    }
    
    func TestShuffleDisks(t *testing.T) {
    	ctx, cancel := context.WithCancel(t.Context())
    	defer cancel()
    
    	nDisks := 16
    	disks, err := getRandomDisks(nDisks)
    	if err != nil {
    		t.Fatal(err)
    	}
    	objLayer, _, err := initObjectLayer(ctx, mustGetPoolEndpoints(0, disks...))
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 7.3K bytes
    - Viewed (0)
  9. cmd/config-current_test.go

    package cmd
    
    import (
    	"context"
    	"os"
    	"testing"
    
    	"github.com/minio/minio/internal/config"
    )
    
    func TestServerConfig(t *testing.T) {
    	ctx, cancel := context.WithCancel(t.Context())
    	defer cancel()
    
    	objLayer, fsDir, err := prepareFS(ctx)
    	if err != nil {
    		t.Fatal(err)
    	}
    	defer os.RemoveAll(fsDir)
    
    	if err = newTestConfig(globalMinioDefaultRegion, objLayer); err != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Apr 09 14:28:39 UTC 2025
    - 1.9K bytes
    - Viewed (0)
  10. cmd/lock-rest-client_test.go

    	}
    	endpointLocal, err := NewEndpoint("http://localhost:9012")
    	if err != nil {
    		t.Fatalf("unexpected error %v", err)
    	}
    	endpointLocal.IsLocal = true
    
    	ctx, cancel := context.WithCancel(t.Context())
    	defer cancel()
    	err = initGlobalLockGrid(ctx, []PoolEndpoints{{Endpoints: Endpoints{endpoint, endpointLocal}}})
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	lkClient := newlockRESTClient(endpoint)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Apr 09 14:28:39 UTC 2025
    - 2K bytes
    - Viewed (0)
Back to top