Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for Bruns (0.15 sec)

  1. cmd/sts-handlers_test.go

    				suite.TestLDAPSTSServiceAccountsWithGroups(c)
    				suite.TearDownSuite(c)
    			},
    		)
    	}
    }
    
    // This test is for a fix added to handle non-normalized base DN values in the
    // LDAP configuration. It runs the existing LDAP sub-tests with a non-normalized
    // LDAP configuration.
    func TestIAMWithLDAPNonNormalizedBaseDNConfigServerSuite(t *testing.T) {
    	for i, testCase := range iamTestSuites {
    		t.Run(
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 15:50:16 GMT 2024
    - 85.7K bytes
    - Viewed (0)
  2. cmd/metrics-v3-system-cpu.go

    	cpuNiceVal := math.Round(ts.Nice/tot*100*100) / 100
    	m.Set(sysCPUNice, cpuNiceVal)
    	cpuStealVal := math.Round(ts.Steal/tot*100*100) / 100
    	m.Set(sysCPUSteal, cpuStealVal)
    
    	// metrics-resource.go runs a job to collect resource metrics including their Avg values and
    	// stores them in resourceMetricsMap. We can use it to get the Avg values of CPU idle and IOWait.
    	cpuResourceMetrics, found := resourceMetricsMap[cpuSubsystem]
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 23:56:12 GMT 2024
    - 3K bytes
    - Viewed (0)
  3. cmd/test-utils_test.go

    		}
    	}
    }
    
    // ExecObjectLayerAPITest - executes object layer API tests.
    // Creates single node and Erasure ObjectLayer instance, registers the specified API end points and runs test for both the layers.
    func ExecObjectLayerAPITest(t *testing.T, objAPITest objAPITestType, endpoints []string) {
    	ctx, cancel := context.WithCancel(context.Background())
    	defer cancel()
    
    	// reset globals.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 17:26:51 GMT 2024
    - 76.2K bytes
    - Viewed (0)
  4. internal/grid/connection.go

    		return err
    	}
    	return wsutil.WriteMessage(conn, c.side, ws.OpBinary, dst)
    }
    
    func (c *Connection) connect() {
    	c.updateState(StateConnecting)
    	rng := rand.New(rand.NewSource(time.Now().UnixNano()))
    	// Runs until the server is shut down.
    	for {
    		if c.State() == StateShutdown {
    			return
    		}
    		toDial := strings.Replace(c.Remote, "http://", "ws://", 1)
    		toDial = strings.Replace(toDial, "https://", "wss://", 1)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 42.6K bytes
    - Viewed (0)
  5. cmd/warm-backend.go

    // Its usage is remote tier cloud implementation specific.
    type remoteVersionID string
    
    // newWarmBackend instantiates the tier type specific WarmBackend, runs
    // checkWarmBackend on it.
    func newWarmBackend(ctx context.Context, tier madmin.TierConfig, probe bool) (d WarmBackend, err error) {
    	switch tier.Type {
    	case madmin.S3:
    		d, err = newWarmBackendS3(*tier.S3, tier.Name)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 21 11:43:18 GMT 2024
    - 3.9K bytes
    - Viewed (0)
  6. cmd/object-api-interface.go

    	// Object operations.
    
    	// GetObjectNInfo returns a GetObjectReader that satisfies the
    	// ReadCloser interface. The Close method runs any cleanup
    	// functions, so it must always be called after reading till EOF
    	//
    	// IMPORTANTLY, when implementations return err != nil, this
    	// function MUST NOT return a non-nil ReadCloser.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 17K bytes
    - Viewed (0)
  7. cmd/prepare-storage.go

    	//  |__ 33a58b40-aecc-4c9f-a22f-ff17bfa33b62
    	//  |__ e870a2c1-d09c-450c-a69c-6eaa54a89b3e
    	//
    	// In this example, `33a58b40-aecc-4c9f-a22f-ff17bfa33b62` directory contains
    	// temporary objects from one of the previous runs of minio server.
    	tmpID := mustGetUUID()
    	tmpOld := pathJoin(diskPath, minioMetaTmpBucket+"-old", tmpID)
    	if err := renameAll(pathJoin(diskPath, minioMetaTmpBucket),
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 15 08:25:46 GMT 2024
    - 11.1K bytes
    - Viewed (0)
  8. internal/ioutil/ioutil.go

    // To return values, use the WithDeadline helper instead.
    func NewDeadlineWorker(timeout time.Duration) *DeadlineWorker {
    	dw := &DeadlineWorker{
    		timeout: timeout,
    	}
    	return dw
    }
    
    // Run runs the given function, passing it a stopper channel. If the deadline passes before
    // the function finishes executing, Run returns context.DeadlineExceeded to the caller.
    // channel so that the work function can attempt to exit gracefully.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 11:26:59 GMT 2024
    - 10.3K bytes
    - Viewed (0)
Back to top