- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 1,136 for corev2 (0.17 sec)
-
plugin/pkg/auth/authenticator/token/bootstrap/bootstrap_test.go
import ( "context" "reflect" "testing" corev1 "k8s.io/api/core/v1" "k8s.io/apimachinery/pkg/api/errors" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/labels" "k8s.io/apimachinery/pkg/runtime/schema" "k8s.io/apiserver/pkg/authentication/user" bootstrapapi "k8s.io/cluster-bootstrap/token/api" ) type lister struct { secrets []*corev1.Secret }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 04 18:36:05 UTC 2020 - 8.3K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/network_test.go
clienttest.Wrap(t, c.services).Create(&corev1.Service{ ObjectMeta: metav1.ObjectMeta{Name: "istio-meshnetworks-gw", Namespace: "istio-system"}, Spec: corev1.ServiceSpec{ Type: corev1.ServiceTypeLoadBalancer, Ports: []corev1.ServicePort{{Port: 15443, Protocol: corev1.ProtocolTCP}}, }, Status: corev1.ServiceStatus{LoadBalancer: corev1.LoadBalancerStatus{Ingress: []corev1.LoadBalancerIngress{{ IP: "1.2.3.4",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 18 19:09:43 UTC 2024 - 10.7K bytes - Viewed (0) -
pkg/kube/krt/informer_test.go
func TestNewInformer(t *testing.T) { c := kube.NewFakeClient() ConfigMaps := krt.NewInformer[*corev1.ConfigMap](c) c.RunAndWait(test.NewStop(t)) cmt := clienttest.NewWriter[*corev1.ConfigMap](t, c) tt := assert.NewTracker[string](t) ConfigMaps.Register(TrackerHandler[*corev1.ConfigMap](tt)) assert.Equal(t, ConfigMaps.List(), nil) cmA := &corev1.ConfigMap{ ObjectMeta: metav1.ObjectMeta{ Name: "a", Namespace: "ns",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 16:38:40 UTC 2024 - 3.3K bytes - Viewed (0) -
cni/pkg/nodeagent/informers_test.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 05:10:23 UTC 2024 - 22.2K bytes - Viewed (0) -
pkg/controlplane/controller/clusterauthenticationtrust/cluster_authentication_trust_controller_test.go
} func getFinalConfigMaps(t *testing.T, client *fake.Clientset) (map[string]*corev1.ConfigMap, bool) { ret := map[string]*corev1.ConfigMap{} created := false for _, action := range client.Actions() { t.Log(dump.Pretty(action)) if action.Matches("create", "configmaps") { created = true obj := action.(clienttesting.CreateAction).GetObject().(*corev1.ConfigMap) ret[obj.Name] = obj }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 14 00:05:53 UTC 2023 - 14.6K bytes - Viewed (0) -
istioctl/pkg/tag/tag_test.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Nov 17 22:41:06 UTC 2023 - 8.7K bytes - Viewed (0) -
pkg/registry/discovery/endpointslice/strategy_test.go
DeprecatedTopology: map[string]string{corev1.LabelHostname: "valid-node-1"}, }, { Hostname: ptr.To("hostname-2"), DeprecatedTopology: map[string]string{corev1.LabelHostname: "invalid node-2"}, }, { Hostname: ptr.To("hostname-3"), DeprecatedTopology: map[string]string{corev1.LabelHostname: "valid-node-3"}, }, {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 27.3K bytes - Viewed (0) -
pkg/kube/client_test.go
package kube import ( "testing" corev1 "k8s.io/api/core/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" ) func Test_findIstiodMonitoringPort(t *testing.T) { tests := []struct { name string pod *corev1.Pod expected int }{ { name: "Annotation exists", pod: &corev1.Pod{ ObjectMeta: metav1.ObjectMeta{ Annotations: map[string]string{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 01 15:24:34 UTC 2024 - 1.4K bytes - Viewed (0) -
cni/pkg/nodeagent/cni-watcher_test.go
ctx, cancel := context.WithCancel(context.Background()) defer cancel() pod := &corev1.Pod{ ObjectMeta: metav1.ObjectMeta{ Name: "pod-bingo", Namespace: "funkyns", }, Spec: corev1.PodSpec{ NodeName: NodeName, }, Status: corev1.PodStatus{ PodIP: fakePodIP, }, } ns := &corev1.Namespace{ObjectMeta: metav1.ObjectMeta{Name: "funkyns"}} client := kube.NewFakeClient(ns, pod)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 21:31:35 UTC 2024 - 7.6K bytes - Viewed (0) -
pkg/controlplane/controller/kubernetesservice/controller.go
}} serviceType := corev1.ServiceTypeClusterIP if nodePort > 0 { servicePorts[0].NodePort = int32(nodePort) serviceType = corev1.ServiceTypeNodePort } return servicePorts, serviceType } // createEndpointPortSpec creates the endpoint ports func createEndpointPortSpec(endpointPort int, endpointPortName string) []corev1.EndpointPort { return []corev1.EndpointPort{{ Protocol: corev1.ProtocolTCP,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Aug 16 16:33:01 UTC 2023 - 9.3K bytes - Viewed (0)