Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 92 for waiters (0.19 sec)

  1. cmd/kubeadm/app/phases/upgrade/staticpods.go

    func StaticPodControlPlane(client clientset.Interface, waiter apiclient.Waiter, pathMgr StaticPodPathManager, cfg *kubeadmapi.InitConfiguration, etcdUpgrade, renewCerts bool, oldEtcdClient, newEtcdClient etcdutil.ClusterInterrogator) error {
    	recoverManifests := map[string]string{}
    	var isExternalEtcd bool
    
    	beforePodHashMap, err := waiter.WaitForStaticPodControlPlaneHashes(cfg.NodeRegistration.Name)
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 10:07:41 UTC 2024
    - 30.7K bytes
    - Viewed (0)
  2. cmd/kubeadm/app/cmd/upgrade/apply.go

    }
    
    // PerformControlPlaneUpgrade actually performs the upgrade procedure for the cluster of your type (self-hosted or static-pod-hosted)
    func PerformControlPlaneUpgrade(flags *applyFlags, client clientset.Interface, waiter apiclient.Waiter, initCfg *kubeadmapi.InitConfiguration, upgradeCfg *kubeadmapi.UpgradeConfiguration) error {
    	// OK, the cluster is hosted using static pods. Upgrade a static-pod hosted cluster
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 28 03:55:23 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  3. cmd/kubeadm/app/util/apiclient/wait.go

    }
    
    // KubeWaiter is an implementation of Waiter that is backed by a Kubernetes client
    type KubeWaiter struct {
    	client  clientset.Interface
    	timeout time.Duration
    	writer  io.Writer
    }
    
    // NewKubeWaiter returns a new Waiter object that talks to the given Kubernetes cluster
    func NewKubeWaiter(client clientset.Interface, timeout time.Duration, writer io.Writer) Waiter {
    	return &KubeWaiter{
    		client:  client,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jun 01 07:10:31 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  4. pkg/apis/core/v1/helper/helpers_test.go

    	tests := []struct {
    		size     int64
    		expected string
    		wantErr  bool
    	}{
    		{
    			size:     1024,
    			expected: "1KB",
    			wantErr:  false,
    		},
    		{
    			size:     33554432,
    			expected: "32MB",
    			wantErr:  false,
    		},
    		{
    			size:     3221225472,
    			expected: "3GB",
    			wantErr:  false,
    		},
    		{
    			size:     1024 * 1024 * 1023 * 3,
    			expected: "3069MB",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 30 23:03:54 UTC 2024
    - 16.9K bytes
    - Viewed (0)
  5. src/runtime/tracetype.go

    	// Insert the pointer to the type itself.
    	id, _ := t.tab.put(noescape(unsafe.Pointer(&typ)), goarch.PtrSize)
    	return id
    }
    
    // dump writes all previously cached types to trace buffers and
    // releases all memory and resets state. It must only be called once the caller
    // can guarantee that there are no more writers to the table.
    func (t *traceTypeTable) dump(gen uintptr) {
    	w := unsafeTraceExpWriter(gen, nil, traceExperimentAllocFree)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 22 20:31:27 UTC 2024
    - 2.3K bytes
    - Viewed (0)
  6. cmd/kubeadm/app/cmd/phases/join/kubelet.go

    	// Wait for the kubelet to create the /etc/kubernetes/kubelet.conf kubeconfig file. If this process
    	// times out, display a somewhat user-friendly message.
    	waiter := apiclient.NewKubeWaiter(nil, 0, os.Stdout)
    	waiter.SetTimeout(cfg.Timeouts.KubeletHealthCheck.Duration)
    	kubeletConfig := initCfg.ClusterConfiguration.ComponentConfigs[componentconfigs.KubeletGroup].Get()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jun 01 07:10:31 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  7. cmd/erasure-multipart.go

    	}
    
    	if len(buffer) > int(fi.Erasure.BlockSize) {
    		buffer = buffer[:fi.Erasure.BlockSize]
    	}
    	writers := make([]io.Writer, len(onlineDisks))
    	for i, disk := range onlineDisks {
    		if disk == nil {
    			continue
    		}
    		writers[i] = newBitrotWriter(disk, bucket, minioMetaTmpBucket, tmpPartPath, erasure.ShardFileSize(data.Size()), DefaultBitrotAlgorithm, erasure.ShardSize())
    	}
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Jun 13 06:56:12 UTC 2024
    - 44.8K bytes
    - Viewed (0)
  8. src/internal/trace/raw/doc.go

    /*
    Package raw provides an interface to interpret and emit Go execution traces.
    It can interpret and emit execution traces in its wire format as well as a
    bespoke but simple text format.
    
    The readers and writers in this package perform no validation on or ordering of
    the input, and so are generally unsuitable for analysis. However, they're very
    useful for testing and debugging the tracer in the runtime and more sophisticated
    trace parsers.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:48:18 UTC 2024
    - 2.3K bytes
    - Viewed (0)
  9. cmd/erasure-healing.go

    					inlineBuffers[i] = bytes.NewBuffer(buf[:0])
    					defer grid.PutByteBuffer(buf)
    
    					writers[i] = newStreamingBitrotWriterBuffer(inlineBuffers[i], DefaultBitrotAlgorithm, erasure.ShardSize())
    				} else {
    					writers[i] = newBitrotWriter(disk, bucket, minioMetaTmpBucket, partPath,
    						tillOffset, DefaultBitrotAlgorithm, erasure.ShardSize())
    				}
    			}
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 33.8K bytes
    - Viewed (0)
  10. cmd/erasure-object.go

    			inlineBuffers[i] = bytes.NewBuffer(buf[:0])
    			defer grid.PutByteBuffer(buf)
    			writers[i] = newStreamingBitrotWriterBuffer(inlineBuffers[i], DefaultBitrotAlgorithm, erasure.ShardSize())
    		}
    	}
    
    	n, erasureErr := erasure.Encode(ctx, data, writers, buffer, writeQuorum)
    	closeBitrotWriters(writers)
    	if erasureErr != nil {
    		return ObjectInfo{}, toObjectErr(erasureErr, minioMetaBucket, key)
    	}
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 78.6K bytes
    - Viewed (0)
Back to top