Search Options

Results per page
Sort
Preferred Languages
Advance

Results 131 - 140 of 395 for podutil (0.24 sec)

  1. test/fixedbugs/issue22662b.go

    	{"/*line foo.go:10:4*/", "foo.go:10:4:"},
    	{"/*line foo.go:10:4*/\n", "foo.go:11:1:"},
    }
    
    func main() {
    	f, err := ioutil.TempFile("", "issue22662b.go")
    	if err != nil {
    		log.Fatal(err)
    	}
    	f.Close()
    	defer os.Remove(f.Name())
    
    	for _, test := range tests {
    		if err := ioutil.WriteFile(f.Name(), []byte(test.src), 0660); err != nil {
    			log.Fatal(err)
    		}
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Oct 19 23:33:25 UTC 2023
    - 1.8K bytes
    - Viewed (0)
  2. test/fixedbugs/issue46234.go

    	if err != nil {
    		panic("bad")
    	}
    	println(nnr.eE)
    	gpi = pi
    }
    `
    
    func main() {
    	dir, err := ioutil.TempDir("", "46234")
    	if err != nil {
    		log.Fatal(err)
    	}
    	defer os.RemoveAll(dir)
    
    	file := filepath.Join(dir, "main.go")
    	if err := ioutil.WriteFile(file, []byte(prog), 0655); err != nil {
    		log.Fatalf("Write error %v", err)
    	}
    
    	cmd := exec.Command("go", "run", file)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Oct 19 23:33:25 UTC 2023
    - 1.7K bytes
    - Viewed (0)
  3. pkg/kubelet/apis/podresources/types.go

    	// GetCPUs returns information about the cpus assigned to pods and containers
    	GetCPUs(podUID, containerName string) []int64
    	// GetAllocatableCPUs returns the allocatable (not allocated) CPUs
    	GetAllocatableCPUs() []int64
    }
    
    type MemoryProvider interface {
    	// GetMemory returns information about the memory assigned to containers
    	GetMemory(podUID, containerName string) []*podresourcesapi.ContainerMemory
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 14 17:33:04 UTC 2023
    - 2.6K bytes
    - Viewed (0)
  4. pkg/controller/volume/attachdetach/populator/desired_state_of_world_populator.go

    		volumeAttachable := volutil.IsAttachableVolume(volumeToAttach.VolumeSpec, dswp.volumePluginMgr)
    		if !volumeAttachable {
    			logger.Info("Volume changes from attachable to non-attachable", "volumeName", volumeToAttach.VolumeName)
    			for _, scheduledPod := range volumeToAttach.ScheduledPods {
    				podUID := volutil.GetUniquePodName(scheduledPod)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 14 00:37:30 UTC 2023
    - 7.7K bytes
    - Viewed (0)
  5. cmd/kubeadm/app/cmd/phases/init/bootstraptoken.go

    	"k8s.io/kubernetes/cmd/kubeadm/app/cmd/phases/workflow"
    	cmdutil "k8s.io/kubernetes/cmd/kubeadm/app/cmd/util"
    	clusterinfophase "k8s.io/kubernetes/cmd/kubeadm/app/phases/bootstraptoken/clusterinfo"
    	nodebootstraptokenphase "k8s.io/kubernetes/cmd/kubeadm/app/phases/bootstraptoken/node"
    )
    
    var (
    	bootstrapTokenLongDesc = cmdutil.LongDesc(`
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 11 08:02:50 UTC 2022
    - 4.1K bytes
    - Viewed (0)
  6. cmd/kubeadm/app/cmd/phases/init/certs_test.go

    	"k8s.io/kubernetes/cmd/kubeadm/app/cmd/phases/workflow"
    	certstestutil "k8s.io/kubernetes/cmd/kubeadm/app/util/certs"
    	pkiutiltesting "k8s.io/kubernetes/cmd/kubeadm/app/util/pkiutil/testing"
    	testutil "k8s.io/kubernetes/cmd/kubeadm/test"
    )
    
    type testCertsData struct {
    	testInitData
    	cfg *kubeadmapi.InitConfiguration
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Aug 17 14:40:46 UTC 2021
    - 2.1K bytes
    - Viewed (0)
  7. test/linkobj.go

    	}
    	return string(out)
    }
    
    func cp(src, dst string) {
    	data, err := ioutil.ReadFile(src)
    	if err != nil {
    		fatalf("%v", err)
    	}
    	err = ioutil.WriteFile(dst, data, 0666)
    	if err != nil {
    		fatalf("%v", err)
    	}
    }
    
    func writeFile(name, data string) {
    	err := ioutil.WriteFile(name, []byte(data), 0666)
    	if err != nil {
    		fatalf("%v", err)
    	}
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Oct 19 23:33:25 UTC 2023
    - 3.5K bytes
    - Viewed (0)
  8. cmd/kubeadm/app/phases/certs/renewal/filerenewer_test.go

    	"crypto/x509"
    	"testing"
    
    	certutil "k8s.io/client-go/util/cert"
    
    	"k8s.io/kubernetes/cmd/kubeadm/app/util/pkiutil"
    )
    
    func TestFileRenewer(t *testing.T) {
    	// creates a File renewer using a test Certificate authority
    	fr := NewFileRenewer(testCACert, testCAKey)
    
    	// renews a certificate
    	certCfg := &pkiutil.CertConfig{
    		Config: certutil.Config{
    			CommonName: "test-certs",
    			AltNames: certutil.AltNames{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Sep 28 04:36:54 UTC 2022
    - 1.5K bytes
    - Viewed (0)
  9. pkg/kubelet/kuberuntime/kuberuntime_sandbox.go

    	}
    	if state != nil {
    		filter.State = &runtimeapi.PodSandboxStateValue{
    			State: *state,
    		}
    	}
    	sandboxes, err := m.runtimeService.ListPodSandbox(ctx, filter)
    	if err != nil {
    		klog.ErrorS(err, "Failed to list sandboxes for pod", "podUID", podUID)
    		return nil, err
    	}
    
    	if len(sandboxes) == 0 {
    		return nil, nil
    	}
    
    	// Sort with newest first.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 22:40:29 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  10. cmd/kubeadm/app/cmd/upgrade/node.go

    	if err != nil {
    		return nil, err
    	}
    
    	dryRun, ok := cmdutil.ValueFromFlagsOrConfig(cmd.Flags(), options.DryRun, upgradeCfg.Node.DryRun, &nodeOptions.dryRun).(*bool)
    	if !ok {
    		return nil, cmdutil.TypeMismatchErr("dryRun", "bool")
    	}
    	client, err := getClient(nodeOptions.kubeConfigPath, *dryRun)
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 16 08:34:39 UTC 2024
    - 10K bytes
    - Viewed (0)
Back to top