Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for Tepper (0.4 sec)

  1. internal/grid/grid_test.go

    	"strings"
    	"testing"
    	"time"
    
    	"github.com/minio/minio/internal/logger/target/testlogger"
    )
    
    func TestSingleRoundtrip(t *testing.T) {
    	defer testlogger.T.SetLogTB(t)()
    	errFatal := func(err error) {
    		t.Helper()
    		if err != nil {
    			t.Fatal(err)
    		}
    	}
    	grid, err := SetupTestGrid(2)
    	errFatal(err)
    	remoteHost := grid.Hosts[1]
    	local := grid.Managers[0]
    
    	// 1: Echo
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 30 15:03:35 GMT 2024
    - 30.1K bytes
    - Viewed (0)
  2. cmd/test-utils_test.go

    		// return FS backend by default.
    		obj, disk, err := prepareFS(ctx)
    		if err != nil {
    			return nil, nil, err
    		}
    		return obj, []string{disk}, nil
    	}
    }
    
    // ExecObjectLayerAPIAnonTest - Helper function to validate object Layer API handler
    // response for anonymous/unsigned and unknown signature type HTTP request.
    
    // Here is the brief description of some of the arguments to the function below.
    //
    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)
  3. cmd/site-replication.go

    		opts := replication.Options{
    			// Set the ID so we can identify the rule as being
    			// created for site-replication and include the
    			// destination cluster's deployment ID.
    			ID: ruleID,
    
    			// Use a helper to generate unique priority numbers.
    			Priority: fmt.Sprintf("%d", getPriorityHelper(replicationConfig)),
    
    			Op:         replication.AddOption,
    			RuleStatus: "enable",
    			DestBucket: targetARN,
    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)
  4. cmd/metrics-v3-types.go

    		CollectorPath: path,
    		Descriptors:   descriptors,
    		bucketLoader:  loader,
    	}
    	mg.validate()
    	return mg
    }
    
    // AddExtraLabels - adds extra (constant) label KV pairs to the metrics group.
    // This is a helper to initialize the `ExtraLabels` field. The argument is a
    // list of ordered label name and value pairs.
    func (mg *MetricsGroup) AddExtraLabels(labels ...string) {
    	if len(labels)%2 != 0 {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 30 15:05:22 GMT 2024
    - 14.7K bytes
    - Viewed (0)
  5. cmd/utils.go

    	}
    	return object
    }
    
    func isDirObject(object string) bool {
    	if obj := encodeDirObject(object); obj != object {
    		object = obj
    	}
    	return HasSuffix(object, globalDirSuffix)
    }
    
    // Helper method to return total number of nodes in cluster
    func totalNodeCount() int {
    	totalNodesCount := len(globalEndpoints.Hostnames())
    	if totalNodesCount == 0 {
    		totalNodesCount = 1 // For standalone erasure coding
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 15:18:21 GMT 2024
    - 31.4K bytes
    - Viewed (0)
  6. cmd/metrics-v3.go

    		systemGoCollectorPath: collectors.NewGoCollector(),
    	}
    
    	// Add all `MetricGroup` collectors to the map.
    	for _, mg := range allMetricGroups {
    		collectors[mg.CollectorPath] = mg
    	}
    
    	// Helper function to register a collector and return a gatherer for it.
    	mustRegister := func(c ...prometheus.Collector) prometheus.Gatherer {
    		subRegistry := prometheus.NewRegistry()
    		for _, col := range c {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu May 02 17:37:57 GMT 2024
    - 10.7K bytes
    - Viewed (0)
Back to top