Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for star (0.18 sec)

  1. cmd/site-replication.go

    		}
    	}
    	for p, stat := range sinfo.PolicyStats {
    		for dID, st := range stat {
    			if st.PolicyMismatch || opts.Entity == madmin.SRPolicyEntity {
    				if _, ok := info.PolicyStats[p]; !ok {
    					info.PolicyStats[p] = make(map[string]madmin.SRPolicyStatsSummary, numSites)
    				}
    				info.PolicyStats[p][dID] = st.SRPolicyStatsSummary
    			}
    		}
    	}
    	for p, stat := range sinfo.ILMExpiryRulesStats {
    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)
  2. cmd/bucket-replication.go

    		}
    	}
    	for i := 0; i < resyncParallelRoutines; i++ {
    		xioutil.SafeClose(workers[i])
    	}
    	wg.Wait()
    	resyncStatus = ResyncCompleted
    }
    
    // start replication resync for the remote target ARN specified
    func (s *replicationResyncer) start(ctx context.Context, objAPI ObjectLayer, opts resyncOpts) error {
    	if opts.bucket == "" {
    		return fmt.Errorf("bucket name is empty")
    	}
    	if opts.arn == "" {
    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/metrics-v2.go

    					Value:          stat.Failed.LastMinute.Count,
    					VariableLabels: map[string]string{"endpoint": stat.Endpoint},
    				})
    				ml = append(ml, MetricV2{
    					Description:    getRepFailedBytesLastHourMD(clusterMetricNamespace),
    					Value:          float64(stat.Failed.LastHour.Bytes),
    					VariableLabels: map[string]string{"endpoint": stat.Endpoint},
    				})
    				ml = append(ml, MetricV2{
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 22:01:31 GMT 2024
    - 132.6K bytes
    - Viewed (0)
  4. cmd/object-handlers.go

    						}
    
    						// For providing ranged content
    						start, rangeLen, err := rs.GetOffsetLength(ci.Size)
    						if err != nil {
    							start, rangeLen = 0, ci.Size
    						}
    
    						// Set content length.
    						w.Header().Set(xhttp.ContentLength, strconv.FormatInt(rangeLen, 10))
    						if rs != nil {
    							contentRange := fmt.Sprintf("bytes %d-%d/%d", start, start+rangeLen-1, ci.Size)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu May 02 20:15:54 GMT 2024
    - 125.2K bytes
    - Viewed (0)
  5. cmd/server_test.go

    	s.testServer.cancel = cancel
    	s.testServer = initTestServerWithBackend(ctx, c, s.testServer, s.testServer.Obj, s.testServer.rawDiskPaths)
    	if s.secure {
    		s.testServer.Server.StartTLS()
    	} 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()
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 108K bytes
    - Viewed (0)
  6. cmd/admin-handlers.go

    		return
    	}
    
    	stat, err := GlobalKMS.Stat(ctx)
    	if err != nil {
    		writeCustomErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrInternalError), err.Error(), r.URL)
    		return
    	}
    
    	status := madmin.KMSStatus{
    		Name:         stat.Name,
    		DefaultKeyID: stat.DefaultKey,
    		Endpoints:    make(map[string]madmin.ItemState, len(stat.Endpoints)),
    	}
    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)
Back to top