- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 52 for CoreV1 (0.14 sec)
-
istioctl/pkg/util/ambient/util.go
if obj == nil { return false } switch t := obj.(type) { case *corev1.Pod: return t.GetAnnotations()[constants.AmbientRedirection] == constants.AmbientRedirectionEnabled case *corev1.Namespace: if t.GetLabels()["istio-injection"] == "enabled" { return false } if v, ok := t.GetLabels()[label.IoIstioRev.Name]; ok && v != "" { return false }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu May 02 21:29:40 GMT 2024 - 1.7K bytes - Viewed (0) -
istioctl/pkg/util/handlers/handlers.go
} // this is used for testing. it should not be changed in regular code. var getFirstPodFunc func(client corev1client.PodsGetter, namespace string, selector string, timeout time.Duration, sortBy func([]*corev1.Pod) sort.Interface) (*corev1.Pod, int, error) // InferPodInfoFromTypedResource gets a pod name, from an expression like Deployment/httpbin, or Deployment/productpage-v1.bookinfo
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Feb 06 15:01:41 GMT 2024 - 6.2K bytes - Viewed (0) -
istioctl/pkg/proxystatus/proxystatus_test.go
_, err = client.Kube().CoreV1().Pods("istio-system").Create(context.TODO(), &corev1.Pod{ ObjectMeta: metav1.ObjectMeta{ Name: "istiod-test", Namespace: "istio-system", Labels: map[string]string{ "app": "istiod", label.IoIstioRev.Name: c.revision, }, }, Status: corev1.PodStatus{ Phase: corev1.PodRunning, },
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 08:28:50 GMT 2024 - 5.5K bytes - Viewed (0) -
istioctl/pkg/workload/workload_test.go
createClientFunc := func(client kube.CLIClient) { client.Kube().CoreV1().ServiceAccounts("bar").Create(context.Background(), &v1.ServiceAccount{ ObjectMeta: metav1.ObjectMeta{Namespace: "bar", Name: "vm-serviceaccount"}, Secrets: []v1.ObjectReference{{Name: "test"}}, }, metav1.CreateOptions{}) client.Kube().CoreV1().ConfigMaps("bar").Create(context.Background(), &v1.ConfigMap{
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Mar 27 16:59:05 GMT 2024 - 14.6K bytes - Viewed (0) -
cni/pkg/nodeagent/podcgroupns_test.go
// limitations under the License. package nodeagent import ( "testing" corev1 "k8s.io/api/core/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/types" "istio.io/istio/pkg/test/util/assert" ) func TestWithProcFs(t *testing.T) { n := NewPodNetnsProcFinder(fakeFs()) pod := &corev1.Pod{ObjectMeta: metav1.ObjectMeta{ Name: "foo", Namespace: "bar",
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 4.6K bytes - Viewed (0) -
istioctl/pkg/injector/injector-list.go
func getNamespaces(ctx context.Context, client kube.CLIClient, istioNamespace string) ([]corev1.Namespace, error) { nslist, err := client.Kube().CoreV1().Namespaces().List(ctx, metav1.ListOptions{}) if err != nil { return []corev1.Namespace{}, err } filtered := filterSystemNamespaces(nslist.Items, istioNamespace) filtered = slices.Filter(filtered, func(namespace corev1.Namespace) bool { return !ambient.InAmbient(&namespace) })
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Jan 04 03:08:06 GMT 2024 - 10.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)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu May 02 21:29:40 GMT 2024 - 5.4K bytes - Viewed (0) -
istioctl/pkg/injector/injector-list_test.go
func Test_extractRevisionFromPod(t *testing.T) { cases := []struct { name string pod *corev1.Pod expectedRevision string }{ { name: "no rev", pod: &corev1.Pod{}, expectedRevision: "", }, { name: "has rev annotation", pod: &corev1.Pod{ ObjectMeta: metav1.ObjectMeta{ Annotations: map[string]string{
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu May 02 21:29:40 GMT 2024 - 2.9K bytes - Viewed (0) -
cni/pkg/nodeagent/pod_cache.go
// See the License for the specific language governing permissions and // limitations under the License. package nodeagent import ( "errors" "fmt" "path/filepath" "runtime" "sync" corev1 "k8s.io/api/core/v1" "istio.io/istio/pkg/maps" "istio.io/istio/pkg/zdsapi" ) var ErrPodNotFound = errors.New("netns not provided, but is needed as pod is not in cache") type PodNetnsCache interface {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 4.5K bytes - Viewed (0) -
istioctl/pkg/checkinject/checkinject.go
if err != nil { return err } pod, err := kubeClient.Kube().CoreV1().Pods(podNs).Get(context.TODO(), podName, metav1.GetOptions{}) if err != nil { return err } ns, err := kubeClient.Kube().CoreV1().Namespaces().Get(context.TODO(), podNs, metav1.GetOptions{}) if err != nil { return err } podLabels = pod.GetLabels()
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 9.3K bytes - Viewed (0)