Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for stop (0.19 sec)

  1. cmd/server_test.go

    	} else {
    		s.testServer.Server.Start()
    	}
    
    	s.client = s.testServer.Server.Client()
    	s.endPoint = s.testServer.Server.URL
    }
    
    func (s *TestSuiteCommon) TearDownSuite(c *check) {
    	s.testServer.Stop()
    }
    
    func (s *TestSuiteCommon) TestBucketSQSNotificationWebHook(c *check) {
    	// Sample bucket notification.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 108K bytes
    - Viewed (0)
  2. cmd/bucket-replication.go

    func (s *replicationResyncer) PersistToDisk(ctx context.Context, objectAPI ObjectLayer) {
    	resyncTimer := time.NewTimer(resyncTimeInterval)
    	defer resyncTimer.Stop()
    
    	// For each bucket name, store the last timestamp of the
    	// successful save of replication status in the backend disks.
    	lastResyncStatusSave := make(map[string]time.Time)
    
    	for {
    		select {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 112.2K bytes
    - Viewed (1)
  3. cmd/admin-handlers.go

    // Supports following actions:
    // - restart (restarts all the MinIO instances in a setup)
    // - stop (stops all the MinIO instances in a setup)
    // - freeze (freezes all incoming S3 API calls)
    // - unfreeze (unfreezes previously frozen S3 API calls)
    //
    // This newer API now returns back status per remote peer and local regarding
    // if a "restart/stop" was successful or not. Service signal now supports
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 29 17:39:04 GMT 2024
    - 97.8K bytes
    - Viewed (2)
  4. cmd/site-replication.go

    func (c *SiteReplicationSys) startHealRoutine(ctx context.Context, objAPI ObjectLayer) {
    	ctx, cancel := globalLeaderLock.GetLock(ctx)
    	defer cancel()
    
    	healTimer := time.NewTimer(siteHealTimeInterval)
    	defer healTimer.Stop()
    
    	var maxRefreshDurationSecondsForLog float64 = 10 // 10 seconds..
    
    	for {
    		select {
    		case <-healTimer.C:
    			c.RLock()
    			enabled := c.enabled
    			c.RUnlock()
    			if enabled {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 184.2K bytes
    - Viewed (1)
  5. cmd/object-handlers_test.go

    		// if object upload fails stop the test.
    		if err != nil {
    			t.Fatalf("Put Object case %d:  Error uploading object: <ERROR> %v", i+1, err)
    		}
    	}
    
    	// test cases with inputs and expected result for HeadObject.
    	testCases := []struct {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 160K bytes
    - Viewed (0)
  6. docs/metrics/prometheus/grafana/bucket/minio-bucket.json

              "format": "time_series",
              "instant": false,
              "interval": "",
              "intervalFactor": 1,
              "legendFormat": "{{bucket,range}}",
              "refId": "A",
              "step": 300
            }
          ],
          "title": "Object Size Distribution",
          "type": "bargauge"
        },
        {
          "datasource": {
            "type": "prometheus",
            "uid": "${DS_PROMETHEUS}"
    Json
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 15 10:03:01 GMT 2024
    - 102K bytes
    - Viewed (0)
Back to top