Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for ep (0.16 sec)

  1. cmd/site-replication.go

    func getS3Client(pc madmin.PeerSite) (*minioClient.Client, error) {
    	ep, err := url.Parse(pc.Endpoint)
    	if err != nil {
    		return nil, err
    	}
    	if globalBucketTargetSys.isOffline(ep) {
    		return nil, RemoteTargetConnectionErr{Endpoint: ep.String(), Err: fmt.Errorf("remote target is offline for endpoint %s", ep.String())}
    	}
    
    	return minioClient.New(ep.Host, &minioClient.Options{
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 184.3K bytes
    - Viewed (0)
  2. cmd/metrics-v2.go

    				currTransferRate,
    				avgTransferRate,
    				maxTransferRate,
    				mrfCount,
    			}
    		}
    		for ep, health := range globalBucketTargetSys.healthStats() {
    			// link latency current
    			m := MetricV2{
    				Description: getClusterRepLinkLatencyCurrMD(),
    				VariableLabels: map[string]string{
    					"endpoint": ep,
    				},
    			}
    			m.Value = float64(health.latency.curr / time.Millisecond)
    			ml = append(ml, m)
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Jun 13 22:26:54 UTC 2024
    - 131.9K bytes
    - Viewed (0)
  3. pkg/proxy/nftables/proxier_test.go

    				}},
    				AddressType: discovery.AddressTypeIPv4,
    			}
    			for _, ep := range tc.endpoints {
    				endpointSlice.Endpoints = append(endpointSlice.Endpoints, discovery.Endpoint{
    					Addresses:  []string{ep.ip},
    					Conditions: discovery.EndpointConditions{Ready: ptr.To(true)},
    					NodeName:   ptr.To(ep.hostname),
    				})
    			}
    
    			fp.OnEndpointSliceAdd(endpointSlice)
    			fp.syncProxyRules()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Apr 27 01:31:57 UTC 2024
    - 173.5K bytes
    - Viewed (0)
  4. pkg/proxy/ipvs/proxier_test.go

    			}},
    			AddressType: discovery.AddressTypeIPv4,
    		}
    
    		for _, ep := range tc.endpoints {
    			endpointSlice.Endpoints = append(endpointSlice.Endpoints, discovery.Endpoint{
    				Addresses:  []string{ep.ip},
    				Conditions: discovery.EndpointConditions{Ready: ptr.To(true)},
    				NodeName:   ptr.To(ep.hostname),
    			})
    		}
    
    		fp.OnEndpointSliceAdd(endpointSlice)
    		fp.syncProxyRules()
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Apr 27 01:31:57 UTC 2024
    - 186.8K bytes
    - Viewed (0)
  5. cmd/admin-handlers.go

    	hostAnonymizer := map[string]string{
    		globalLocalNodeName: "server1",
    	}
    
    	apiEndpoints := getAPIEndpoints()
    	for _, ep := range apiEndpoints {
    		if len(ep) == 0 {
    			continue
    		}
    		if url, err := xnet.ParseHTTPURL(ep); err == nil {
    			// In FS mode the drive names don't include the host.
    			// So mapping just the host should be sufficient.
    			hostAnonymizer[url.Host] = "server1"
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 98K bytes
    - Viewed (0)
  6. src/crypto/x509/verify_test.go

    	badCert, err := Pa...
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 110.2K bytes
    - Viewed (0)
Back to top