Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 175 for podrest (0.42 sec)

  1. pkg/registry/core/pod/storage/storage.go

    	Eviction            *EvictionREST
    	Status              *StatusREST
    	EphemeralContainers *EphemeralContainersREST
    	Log                 *podrest.LogREST
    	Proxy               *podrest.ProxyREST
    	Exec                *podrest.ExecREST
    	Attach              *podrest.AttachREST
    	PortForward         *podrest.PortForwardREST
    }
    
    // REST implements a RESTStorage for pods
    type REST struct {
    	*genericregistry.Store
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Mar 20 14:29:25 UTC 2023
    - 13.7K bytes
    - Viewed (0)
  2. pkg/kubelet/util/format/pod_test.go

    		{"field_normal_case", "test-pod", metav1.NamespaceDefault, "551f5a43-9f2f-11e7-a589-fa163e148d75", "test-pod_default(551f5a43-9f2f-11e7-a589-fa163e148d75)"},
    	}
    
    	for _, testCase := range testCases {
    		realPodDesc := PodDesc(testCase.podName, testCase.podNamespace, testCase.podUID)
    		assert.Equalf(t, testCase.expectedValue, realPodDesc, "Failed to test: %s", testCase.caseName)
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jan 13 08:27:42 UTC 2023
    - 2.1K bytes
    - Viewed (0)
  3. pkg/kubelet/apis/podresources/server_v1_test.go

    	podResA := ResA.PodResources
    	podResB := ResB.PodResources
    	if podResA.Name != podResB.Name {
    		return false
    	}
    	if podResA.Namespace != podResB.Namespace {
    		return false
    	}
    	if len(podResA.Containers) != len(podResB.Containers) {
    		return false
    	}
    	for jdx := 0; jdx < len(podResA.Containers); jdx++ {
    		cntA := podResA.Containers[jdx]
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 45.9K bytes
    - Viewed (0)
  4. pilot/pkg/serviceregistry/kube/controller/pod_test.go

    John Howard <******@****.***> 1713292060 -0700
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 16 18:27:40 UTC 2024
    - 12.3K bytes
    - Viewed (0)
  5. pkg/util/pod/pod_test.go

    Michal Wozniak <******@****.***> 1667818676 +0100
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Nov 07 15:22:29 UTC 2022
    - 4.5K bytes
    - Viewed (0)
  6. pkg/kubelet/pod/pod_manager_test.go

    	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
    	"k8s.io/apimachinery/pkg/types"
    	podtest "k8s.io/kubernetes/pkg/kubelet/pod/testing"
    	kubetypes "k8s.io/kubernetes/pkg/kubelet/types"
    )
    
    // Stub out mirror client for testing purpose.
    func newTestManager() (*basicManager, *podtest.FakeMirrorClient) {
    	fakeMirrorClient := podtest.NewFakeMirrorClient()
    	manager := NewBasicPodManager().(*basicManager)
    	return manager, fakeMirrorClient
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 12 16:57:27 UTC 2023
    - 5.4K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiserver/pkg/storage/cacher/lister_watcher_test.go

    		t.Fatalf("List failed: %v", err)
    	}
    	pl, ok := obj.(*example.PodList)
    	if !ok {
    		t.Fatalf("Expected PodList but got %v", pl)
    	}
    	if len(pl.Items) != 3 {
    		t.Errorf("Expected PodList of length 3 but got %d", len(pl.Items))
    	}
    }
    
    func TestCacherListerWatcherPagination(t *testing.T) {
    	prefix := "pods"
    	fn := func() runtime.Object { return &example.PodList{} }
    	server, store := newEtcdTestStorage(t, prefix)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Mar 04 11:51:06 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/apis/example/v1/zz_generated.deepcopy.go

    // DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PodList.
    func (in *PodList) DeepCopy() *PodList {
    	if in == nil {
    		return nil
    	}
    	out := new(PodList)
    	in.DeepCopyInto(out)
    	return out
    }
    
    // DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
    func (in *PodList) DeepCopyObject() runtime.Object {
    	if c := in.DeepCopy(); c != nil {
    		return c
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Aug 24 19:47:49 UTC 2021
    - 4.4K bytes
    - Viewed (0)
  9. pkg/kubelet/util/format/pod.go

    // with pod UID as part of the string.
    func Pod(pod *v1.Pod) string {
    	if pod == nil {
    		return "<nil>"
    	}
    	return PodDesc(pod.Name, pod.Namespace, pod.UID)
    }
    
    // PodDesc returns a string representing a pod in a consistent human readable format,
    // with pod UID as part of the string.
    func PodDesc(podName, podNamespace string, podUID types.UID) string {
    	// Use underscore as the delimiter because it is not allowed in pod name
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jan 13 08:27:42 UTC 2023
    - 1.3K bytes
    - Viewed (0)
  10. pkg/registry/core/pod/rest/log.go

    	_ "k8s.io/kubernetes/pkg/apis/core/install"
    )
    
    // LogREST implements the log endpoint for a Pod
    type LogREST struct {
    	KubeletConn client.ConnectionInfoGetter
    	Store       *genericregistry.Store
    }
    
    // LogREST implements GetterWithOptions
    var _ = rest.GetterWithOptions(&LogREST{})
    
    // New creates a new Pod log options object
    func (r *LogREST) New() runtime.Object {
    	// TODO - return a resource that represents a log
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 24 10:50:43 UTC 2023
    - 4.4K bytes
    - Viewed (0)
Back to top