Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for authenticateNode (0.23 sec)

  1. cmd/jwt_test.go

    	if err != nil {
    		b.Fatal(err)
    	}
    	defer os.RemoveAll(fsDir)
    	if err = newTestConfig(globalMinioDefaultRegion, obj); err != nil {
    		b.Fatal(err)
    	}
    
    	creds := globalActiveCred
    	token, err := authenticateNode(creds.AccessKey, creds.SecretKey)
    	if err != nil {
    		b.Fatal(err)
    	}
    
    	b.ResetTimer()
    	b.ReportAllocs()
    	b.RunParallel(func(pb *testing.PB) {
    		for pb.Next() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 22 07:04:48 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  2. cmd/lock-rest-server-common_test.go

    	}
    
    	locker := &lockRESTServer{
    		ll: &localLocker{
    			mutex:   sync.Mutex{},
    			lockMap: make(map[string][]lockRequesterInfo),
    		},
    	}
    	creds := globalActiveCred
    	token, err := authenticateNode(creds.AccessKey, creds.SecretKey)
    	if err != nil {
    		t.Fatal(err)
    	}
    	return fsDir, locker, token
    }
    
    // Test function to remove lock entries from map based on name & uid combination
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 24 10:24:01 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  3. cmd/jwt.go

    	errNoAuthToken        = errors.New("JWT token missing")
    	errSkewedAuthTime     = errors.New("Skewed authentication date/time")
    	errMalformedAuth      = errors.New("Malformed authentication input")
    )
    
    func authenticateNode(accessKey, secretKey string) (string, error) {
    	claims := xjwt.NewStandardClaims()
    	claims.SetExpiry(UTCNow().Add(defaultInterNodeJWTExpiry))
    	claims.SetAccessKey(accessKey)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 22 07:04:48 UTC 2024
    - 4.5K bytes
    - Viewed (0)
  4. cmd/storage-rest_test.go

    	if err != nil {
    		t.Fatalf("unexpected error %v", err)
    	}
    	url.Path = t.TempDir()
    
    	globalMinioHost, globalMinioPort = mustSplitHostPort(url.Host)
    	globalNodeAuthToken, _ = authenticateNode(globalActiveCred.AccessKey, globalActiveCred.SecretKey)
    
    	endpoint, err := NewEndpoint(url.String())
    	if err != nil {
    		t.Fatalf("NewEndpoint failed %v", endpoint)
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 22 07:04:48 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  5. cmd/common-main.go

    			logger.Info(color.RedBold(msg))
    		}
    		globalActiveCred = cred
    		globalCredViaEnv = true
    	} else {
    		globalActiveCred = auth.DefaultCredentials
    	}
    
    	var err error
    	globalNodeAuthToken, err = authenticateNode(globalActiveCred.AccessKey, globalActiveCred.SecretKey)
    	if err != nil {
    		logger.Fatal(err, "Unable to generate internode credentials")
    	}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 21:50:11 UTC 2024
    - 31.7K bytes
    - Viewed (0)
  6. cmd/test-utils_test.go

    	globalIsTesting = true
    
    	globalIsCICD = globalIsTesting
    
    	globalActiveCred = auth.Credentials{
    		AccessKey: auth.DefaultAccessKey,
    		SecretKey: auth.DefaultSecretKey,
    	}
    
    	globalNodeAuthToken, _ = authenticateNode(auth.DefaultAccessKey, auth.DefaultSecretKey)
    
    	// disable ENVs which interfere with tests.
    	for _, env := range []string{
    		crypto.EnvKMSAutoEncryption,
    		config.EnvAccessKey,
    		config.EnvSecretKey,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 77K bytes
    - Viewed (0)
Back to top