Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for t$ (0.09 sec)

  1. pkg/kubelet/kubelet_test.go

    	checkPodStatus(t, kl, fittingPod, v1.PodPending)
    	checkPodStatus(t, kl, emptyPod, v1.PodFailed)
    	checkPodStatus(t, kl, missingPod, v1.PodPending)
    	checkPodStatus(t, kl, failedPod, v1.PodFailed)
    }
    
    // TODO(filipg): This test should be removed once StatusSyncer can do garbage collection without external signal.
    func TestPurgingObsoleteStatusMapEntries(t *testing.T) {
    	ctx := context.Background()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 106.9K bytes
    - Viewed (0)
  2. 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)
  3. pkg/kubelet/kuberuntime/kuberuntime_manager_test.go

    	t.Run("sidecar containers disabled", func(t *testing.T) {
    		testComputePodActionsWithInitContainers(t, false)
    	})
    	t.Run("sidecar containers enabled", func(t *testing.T) {
    		testComputePodActionsWithInitContainers(t, true)
    	})
    }
    
    func testComputePodActionsWithInitContainers(t *testing.T, sidecarContainersEnabled bool) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 96K bytes
    - Viewed (0)
  4. pilot/pkg/model/telemetry_logging_test.go

    	}
    	for _, tt := range tests {
    		t.Run(tt.name, func(t *testing.T) {
    			telemetry, ctx := createTestTelemetries(tt.cfgs, t)
    			telemetry.meshConfig.DefaultProviders.AccessLogging = tt.defaultProviders
    			got := telemetry.AccessLogging(ctx, tt.proxy, networking.ListenerClassSidecarOutbound, nil)
    			assert.Equal(t, tt.excepted, got)
    		})
    	}
    }
    
    func TestAccessLoggingCache(t *testing.T) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:30 UTC 2024
    - 54K bytes
    - Viewed (0)
  5. pilot/pkg/model/telemetry_test.go

    			expected:   durationpb.New(1 * time.Second),
    		},
    	}
    
    	for _, tc := range cases {
    		t.Run(tc.name, func(t *testing.T) {
    			actual := getInterval(tc.input, tc.defaultVal)
    			assert.Equal(t, tc.expected, actual)
    		})
    	}
    }
    
    func Test_appendApplicableTelemetries(t *testing.T) {
    	namespacedName := types.NamespacedName{
    		Name:      "my-telemetry",
    		Namespace: "my-namespace",
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:30 UTC 2024
    - 39.6K bytes
    - Viewed (0)
  6. pkg/config/analysis/analyzers/analyzers_test.go

    func TestAnalyzers(t *testing.T) {
    	requestedInputsByAnalyzer := make(map[string]map[config.GroupVersionKind]struct{})
    
    	// For each test case, verify we get the expected messages as output
    	for _, tc := range testGrid {
    		tc := tc // Capture range variable so subtests work correctly
    		t.Run(tc.name, func(t *testing.T) {
    			g := NewWithT(t)
    
    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

    				se := obj.Spec.(*istio.ServiceEntry)
    				return se.Hosts
    			}
    		}
    	}
    	return []string{}
    }
    
    func buildMeshAndGatewayRoutes[T any](parentRefs []routeParentReference, convertRules func(mesh bool) T) (T, T) {
    	var meshResult, gwResult T
    	needMesh, needGw := parentTypes(parentRefs)
    	if needMesh {
    		meshResult = convertRules(true)
    	}
    	if needGw {
    		gwResult = convertRules(false)
    	}
    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_pods.go

    		// dual-stack feature flag is not enabled.
    		for _, hostIP := range hostIPs {
    			buffer.WriteString(fmt.Sprintf("%s\t%s.%s\t%s\n", hostIP, hostName, hostDomainName, hostName))
    		}
    	} else {
    		for _, hostIP := range hostIPs {
    			buffer.WriteString(fmt.Sprintf("%s\t%s\n", hostIP, hostName))
    		}
    	}
    	buffer.Write(hostsEntriesFromHostAliases(hostAliases))
    	return buffer.Bytes()
    }
    
    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