Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for xEqual (0.2 sec)

  1. pkg/kubelet/kuberuntime/kuberuntime_manager_test.go

    	assert.NoError(t, result.Error())
    	assert.Equal(t, 2, len(fakeRuntime.Containers))
    	assert.Equal(t, 2, len(fakeImage.Images))
    	assert.Equal(t, 1, len(fakeRuntime.Sandboxes))
    	for _, sandbox := range fakeRuntime.Sandboxes {
    		assert.Equal(t, runtimeapi.PodSandboxState_SANDBOX_READY, sandbox.State)
    	}
    	for _, c := range fakeRuntime.Containers {
    		assert.Equal(t, runtimeapi.ContainerState_CONTAINER_RUNNING, c.State)
    	}
    }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 96K bytes
    - Viewed (0)
  2. pilot/pkg/model/telemetry_logging_test.go

    			expected:     "[%START_TIME%] %REQ(:METHOD)% %REQ(X-ENVOY-ORIGINAL-PATH?:PATH)%\n",
    		},
    	}
    
    	for _, tc := range cases {
    		t.Run(tc.name, func(t *testing.T) {
    			got := fileAccessLogFormat(tc.formatString)
    			assert.Equal(t, tc.expected, got)
    		})
    	}
    }
    
    func TestAccessLogging(t *testing.T) {
    	labels := map[string]string{"app": "test"}
    	sidecar := &Proxy{
    		ConfigNamespace: "default",
    		Labels:          labels,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:30 UTC 2024
    - 54K bytes
    - Viewed (0)
  3. pkg/kubelet/kubelet_test.go

    		ID:        pod.UID,
    		Name:      pod.Name,
    		Namespace: pod.Namespace,
    	}
    	apiStatus := kubelet.generateAPIPodStatus(pod, status, false)
    	require.Equal(t, v1.PodFailed, apiStatus.Phase)
    	require.Equal(t, "Evicted", apiStatus.Reason)
    	require.Equal(t, "because", apiStatus.Message)
    }
    
    func TestSyncTerminatingPodKillPod(t *testing.T) {
    	testKubelet := newTestKubelet(t, false /* controllerAttachDetachEnabled */)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 106.9K bytes
    - Viewed (0)
  4. pilot/pkg/model/telemetry_test.go

    					},
    				},
    			},
    			want: false,
    		},
    	}
    	for _, tt := range tests {
    		t.Run(tt.name, func(t *testing.T) {
    			if got := tt.computedTelemetries.Equal(tt.args.other); got != tt.want {
    				t.Errorf("computedTelemetries.Equal() = %v, want %v", got, tt.want)
    			}
    		})
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:30 UTC 2024
    - 39.6K bytes
    - Viewed (0)
  5. pilot/pkg/networking/core/accesslog_test.go

    			expected: &tcp.TcpProxy{},
    		},
    	}
    
    	for _, tc := range cases {
    		t.Run(tc.name, func(t *testing.T) {
    			b.setTCPAccessLog(tc.push, tc.proxy, tc.tcp, tc.class, nil)
    			assert.Equal(t, tc.expected, tc.tcp)
    		})
    	}
    }
    
    func TestSetHttpAccessLog(t *testing.T) {
    	b := newAccessLogBuilder()
    
    	env := newTestEnviroment()
    
    	cases := []struct {
    		name     string
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:30 UTC 2024
    - 19.9K bytes
    - Viewed (0)
  6. pkg/config/analysis/analyzers/analyzers_test.go

    		existingNames.Insert(n)
    	}
    }
    
    func TestAnalyzersHaveDescription(t *testing.T) {
    	g := NewWithT(t)
    
    	for _, a := range All() {
    		g.Expect(a.Metadata().Description).ToNot(Equal(""))
    	}
    }
    
    func setupAnalyzerForCase(tc testCase, cr local.CollectionReporterFn) (*local.IstiodAnalyzer, error) {
    	sa := local.NewSourceAnalyzer(analysis.Combine("testCase", tc.analyzer), "", "istio-system", cr)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 07:22:31 UTC 2024
    - 42.6K bytes
    - Viewed (0)
  7. pilot/pkg/config/kube/gateway/conversion.go

    	"istio.io/istio/pkg/slices"
    	"istio.io/istio/pkg/util/sets"
    )
    
    func sortConfigByCreationTime(configs []config.Config) {
    	sort.Slice(configs, func(i, j int) bool {
    		if configs[i].CreationTimestamp.Equal(configs[j].CreationTimestamp) {
    			in := configs[i].Namespace + "/" + configs[i].Name
    			jn := configs[j].Namespace + "/" + configs[j].Name
    			return in < jn
    		}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:37 UTC 2024
    - 84.7K bytes
    - Viewed (0)
  8. pkg/kubelet/kubelet.go

    	for _, c := range pod.Spec.Containers {
    		if cs, ok := podutil.GetContainerStatus(podStatus.ContainerStatuses, c.Name); ok {
    			if cs.Resources == nil {
    				continue
    			}
    			if !cmp.Equal(c.Resources.Limits, cs.Resources.Limits) || !cmp.Equal(cs.AllocatedResources, cs.Resources.Requests) {
    				return true
    			}
    		}
    	}
    	return false
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 126.1K bytes
    - Viewed (0)
  9. pkg/kubelet/kubelet_pods.go

    	hostname, hostDomainName, err := kl.GeneratePodHostNameAndDomain(pod)
    	if err != nil {
    		return nil, nil, err
    	}
    	// nodename will be equal to hostname if SetHostnameAsFQDN is nil or false. If SetHostnameFQDN
    	// is true and hostDomainName is defined, nodename will be the FQDN (hostname.hostDomainName)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 101.2K bytes
    - Viewed (0)
Back to top