Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for zendpoints (0.1 sec)

  1. cmd/admin-handlers.go

    		kmsLogIf(ctx, err, "failed to fetch KMS status information")
    		return []madmin.KMS{}
    	}
    
    	stats := make([]madmin.KMS, 0, len(stat.Endpoints))
    	for endpoint, state := range stat.Endpoints {
    		stats = append(stats, madmin.KMS{
    			Status:   string(state),
    			Endpoint: endpoint,
    		})
    	}
    	return stats
    }
    
    func targetStatus(ctx context.Context, h logger.Target) madmin.Status {
    	if h.IsOnline(ctx) {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 99.6K bytes
    - Viewed (0)
  2. cmd/site-replication.go

    			successMsg = fmt.Sprintf("%s\n- sync state %s for peer %s", successMsg, peer.SyncState, peer.Name)
    		}
    		if peer.Endpoint != "" { // `admin replicate update` requested an endpoint change
    			pi.Endpoint = peer.Endpoint
    			successMsg = fmt.Sprintf("%s\n- endpoint %s for peer %s", successMsg, peer.Endpoint, peer.Name)
    		}
    
    		if peer.DefaultBandwidth.IsSet {
    			if peer.DeploymentID == globalDeploymentID() {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 184.7K bytes
    - Viewed (0)
  3. cmd/server_test.go

    		getURL          string
    		expectedStrings []string
    	}{
    		{getListObjectsV1URL(s.endPoint, bucketName, "", "1000", ""), []string{"<Key>foo bar 1</Key>", "<Key>foo bar 2</Key>"}},
    		{getListObjectsV1URL(s.endPoint, bucketName, "", "1000", "url"), []string{"<Key>foo+bar+1</Key>", "<Key>foo+bar+2</Key>"}},
    		{
    			getListObjectsV2URL(s.endPoint, bucketName, "", "1000", "", "", ""),
    			[]string{
    				"<Key>foo bar 1</Key>",
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 118.1K bytes
    - Viewed (0)
  4. cmd/sts-handlers_test.go

    		Client:      s.TestSuiteCommon.client,
    		STSEndpoint: s.endPoint,
    		Options: cr.STSAssumeRoleOptions{
    			AccessKey: accessKey,
    			SecretKey: secretKey,
    			Location:  "",
    		},
    	}
    
    	value, err := assumeRole.Retrieve()
    	if err != nil {
    		c.Fatalf("err calling assumeRole: %v", err)
    	}
    
    	minioClient, err := minio.New(s.endpoint, &minio.Options{
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 100.2K bytes
    - Viewed (1)
  5. cmd/object-handlers_test.go

    func TestAPIHeadObjectHandler(t *testing.T) {
    	ExecObjectLayerAPITest(ExecObjectLayerAPITestArgs{t: t, objAPITest: testAPIHeadObjectHandler, endpoints: []string{"HeadObject"}})
    }
    
    func testAPIHeadObjectHandler(obj ObjectLayer, instanceType, bucketName string, apiRouter http.Handler,
    	credentials auth.Credentials, t *testing.T,
    ) {
    	objectName := "test-object"
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 163.1K bytes
    - Viewed (0)
  6. cmd/metrics-v2.go

    					VariableLabels: map[string]string{"endpoint": stat.Endpoint},
    				})
    				ml = append(ml, MetricV2{
    					Description:    getRepFailedOperationsLastMinuteMD(clusterMetricNamespace),
    					Value:          stat.Failed.LastMinute.Count,
    					VariableLabels: map[string]string{"endpoint": stat.Endpoint},
    				})
    				ml = append(ml, MetricV2{
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 133.4K bytes
    - Viewed (0)
  7. cmd/bucket-replication.go

    			}
    		}
    		// if checked bucket, then check the ready is unnecessary
    		if !opts.CheckRemoteBucket && opts.CheckReady {
    			endpoint := clnt.EndpointURL().String()
    			if errInt, ok := opts.checkReadyErr.Load(endpoint); !ok {
    				err = checkRemoteEndpoint(ctx, clnt.EndpointURL())
    				opts.checkReadyErr.Store(endpoint, err)
    			} else {
    				if errInt == nil {
    					err = nil
    				} else {
    					err, _ = errInt.(error)
    				}
    			}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 118K bytes
    - Viewed (0)
  8. CHANGELOG/CHANGELOG-1.4.md

    * Update coreos node e2e image to a version that uses cgroupfs ([#28661](https://github.com/kubernetes/kubernetes/pull/28661), [@dubstack](https://github.com/dubstack))
    * Don't delete affinity when endpoints are empty ([#28655](https://github.com/kubernetes/kubernetes/pull/28655), [@freehan](https://github.com/freehan))
    Registered: Fri Sep 05 09:05:11 UTC 2025
    - Last Modified: Thu Dec 24 02:28:26 UTC 2020
    - 133.5K bytes
    - Viewed (0)
  9. cmd/storage-datatypes_gen.go

    		return
    	}
    	z.Scanning, err = dc.ReadBool()
    	if err != nil {
    		err = msgp.WrapError(err, "Scanning")
    		return
    	}
    	z.Endpoint, err = dc.ReadString()
    	if err != nil {
    		err = msgp.WrapError(err, "Endpoint")
    		return
    	}
    	z.MountPath, err = dc.ReadString()
    	if err != nil {
    		err = msgp.WrapError(err, "MountPath")
    		return
    	}
    	z.ID, err = dc.ReadString()
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Apr 25 05:41:04 UTC 2025
    - 152K bytes
    - Viewed (0)
  10. CHANGELOG/CHANGELOG-1.5.md

    * Fix kubectl get -f <file> -o <nondefault printer> so it prints all items in the file ([#39038](https://github.com/kubernetes/kubernetes/pull/39038), [@ncdc](https://github.com/ncdc))
    * Endpoints, that tolerate unready Pods, are now listing Pods in state Terminating as well ([#37093](https://github.com/kubernetes/kubernetes/pull/37093), [@simonswine](https://github.com/simonswine))
    Registered: Fri Sep 05 09:05:11 UTC 2025
    - Last Modified: Thu Dec 24 02:28:26 UTC 2020
    - 136.4K bytes
    - Viewed (0)
Back to top