Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 200 for could (0.15 sec)

  1. internal/event/target/nats_contrib_test.go

    		Address: xnet.Host{
    			Name:      "localhost",
    			Port:      (xnet.Port(opts.Port)),
    			IsPortSet: true,
    		},
    		Subject: "test",
    	}
    	con, err := clientConfig.connectNats()
    	if err != nil {
    		t.Errorf("Could not connect to nats: %v", err)
    	}
    	defer con.Close()
    }
    
    func TestNatsConnUserPass(t *testing.T) {
    	opts := natsserver.DefaultTestOptions
    	opts.Port = 14223
    	opts.Username = "testminio"
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Sep 04 19:57:37 GMT 2023
    - 2.3K bytes
    - Viewed (0)
  2. internal/config/identity/ldap/ldap.go

    		return 0, auth.ErrInvalidDuration
    	}
    	return dur, nil
    }
    
    // ParsesAsDN determines if the given string could be a valid DN based on
    // parsing alone.
    func (l Config) ParsesAsDN(dn string) bool {
    	_, err := ldap.ParseDN(dn)
    	return err == nil
    }
    
    // IsLDAPUserDN determines if the given string could be a user DN from LDAP.
    func (l Config) IsLDAPUserDN(user string) bool {
    	udn, err := ldap.ParseDN(user)
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 18 15:15:02 GMT 2024
    - 9.2K bytes
    - Viewed (0)
  3. internal/s3select/sql/funceval.go

    		if !ok {
    			return 0, errCastFailure("could not parse as int")
    		}
    		return res, nil
    	case []byte:
    		// Parse as number, truncate floating point if
    		// needed.
    		// String might contain trimming spaces, which
    		// needs to be trimmed.
    		res, ok := strToInt(strings.TrimSpace(string(x)))
    		if !ok {
    			return 0, errCastFailure("could not parse as int")
    		}
    		return res, nil
    
    	default:
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 13.2K bytes
    - Viewed (0)
  4. cmd/callhome.go

    	}{Version: healthInfo.Version}
    
    	enc := json.NewEncoder(gzWriter)
    	if e := enc.Encode(header); e != nil {
    		internalLogIf(ctx, fmt.Errorf("Could not encode health info header: %w", e))
    		return nil
    	}
    
    	if e := enc.Encode(healthInfo); e != nil {
    		internalLogIf(ctx, fmt.Errorf("Could not encode health info: %w", e))
    		return nil
    	}
    
    	gzWriter.Flush()
    	gzWriter.Close()
    
    	return b.Bytes()
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 5.1K bytes
    - Viewed (1)
  5. internal/s3select/sql/value.go

    				a.setInt(iA)
    			} else if fA, ok := a.bytesToFloat(); ok {
    				a.setFloat(fA)
    			} else {
    				return fmt.Errorf("Could not convert %s to a number", a.String())
    			}
    
    		case bool:
    			if bA, ok := a.bytesToBool(); ok {
    				a.setBool(bA)
    			} else {
    				return fmt.Errorf("Could not convert %s to a boolean", a.String())
    			}
    
    		default:
    			return errCmpMismatchedTypes
    		}
    		return nil
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Feb 25 20:31:19 GMT 2022
    - 20.2K bytes
    - Viewed (0)
  6. cmd/admin-handlers-users_test.go

    	err = client.MakeBucket(ctx, getRandomBucketName(), minio.MakeBucketOptions{})
    	if err != nil {
    		c.Fatalf("user could not create bucket: %v", err)
    	}
    
    	// 4. Check that user can be disabled and verify it.
    	err = s.adm.SetUserStatus(ctx, accessKey, madmin.AccountDisabled)
    	if err != nil {
    		c.Fatalf("could not set user account to disabled")
    	}
    	usersMap, err = s.adm.ListUsers(ctx)
    	if err != nil {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Feb 12 16:36:16 GMT 2024
    - 45.7K bytes
    - Viewed (0)
  7. internal/event/target/nats_tls_contrib_test.go

    		},
    		Subject:       "test",
    		Secure:        true,
    		CertAuthority: path.Join("testdata", "contrib", "certs", "root_ca_cert.pem"),
    	}
    
    	con, err := clientConfig.connectNats()
    	if err != nil {
    		t.Errorf("Could not connect to nats: %v", err)
    	}
    	defer con.Close()
    }
    
    func TestNatsConnTLSClientAuthorization(t *testing.T) {
    	s, opts := natsserver.RunServerWithConfig(filepath.Join("testdata", "contrib", "nats_tls_client_cert.conf"))
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Sep 04 19:57:37 GMT 2023
    - 2.1K bytes
    - Viewed (0)
  8. cmd/signature-v4-utils.go

    			return auth.Credentials{}, false, ErrServerNotInitialized
    		}
    
    		// Check if the access key is part of users credentials.
    		u, ok := globalIAMSys.GetUser(r.Context(), accessKey)
    		if !ok {
    			// Credentials could be valid but disabled - return a different
    			// error in such a scenario.
    			if u.Credentials.Status == auth.AccountOff {
    				return cred, false, ErrAccessKeyDisabled
    			}
    			return cred, false, ErrInvalidAccessKeyID
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Wed Jan 31 18:56:45 GMT 2024
    - 9K bytes
    - Viewed (0)
  9. cmd/server-rlimit.go

    	"github.com/minio/pkg/v2/sys"
    )
    
    func oldLinux() bool {
    	currentKernel, err := kernel.CurrentVersion()
    	if err != nil {
    		// Could not probe the kernel version
    		return false
    	}
    
    	if currentKernel == 0 {
    		// We could not get any valid value return false
    		return false
    	}
    
    	// legacy linux indicator for printing warnings
    	// about older Linux kernels and Go runtime.
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:06:57 GMT 2024
    - 2.8K bytes
    - Viewed (0)
  10. cmd/metrics-v3-handler.go

    // ServeHTTP - implements http.Handler interface.
    //
    // When the `list` query parameter is provided (its value is ignored), the
    // server lists all metrics that could be returned for the requested path.
    //
    // The (repeatable) `buckets` query parameter is a list of bucket names (or it
    // could be a comma separated value) to return metrics with a bucket label.
    // Bucket metrics will be returned only for the provided buckets. If no buckets
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 7.4K bytes
    - Viewed (0)
Back to top