- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 156 for Dialer (0.11 sec)
-
android/guava-tests/test/com/google/common/cache/CacheReferencesTest.java
} catch (InterruptedException e) { /* ignore */ } try { // Fill up heap so soft references get cleared. filler = new byte[Math.max(filler.length, filler.length * 2)]; } catch (OutOfMemoryError e) { } } CacheTesting.processPendingNotifications(cache); assertEquals(1, cache.size()); assertEquals(1, removalListener.getCount()); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Dec 04 17:37:03 UTC 2017 - 6.1K bytes - Viewed (0) -
pilot/pkg/serviceregistry/util/xdsfake/updater.go
func (fx *Updater) MatchOrFail(t test.Failer, events ...Event) { t.Helper() fx.matchOrFail(t, false, events...) } // StrictMatchOrFail expects the provided events to arrive, and nothing else func (fx *Updater) StrictMatchOrFail(t test.Failer, events ...Event) { t.Helper() fx.matchOrFail(t, true, events...) } func (fx *Updater) matchOrFail(t test.Failer, strict bool, events ...Event) { t.Helper()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 29 18:40:34 UTC 2024 - 6.2K bytes - Viewed (0) -
pkg/kube/kclient/clienttest/crd.go
"istio.io/istio/pkg/config/schema/gvr" "istio.io/istio/pkg/kube" "istio.io/istio/pkg/test" ) func MakeCRD(t test.Failer, c kube.Client, g schema.GroupVersionResource) { t.Helper() MakeCRDWithAnnotations(t, c, g, nil) } func MakeCRDWithAnnotations(t test.Failer, c kube.Client, g schema.GroupVersionResource, annotations map[string]string) { t.Helper() crd := &v1.CustomResourceDefinition{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 25 14:44:17 UTC 2024 - 2K bytes - Viewed (0) -
pkg/test/framework/components/istioctl/istioctl.go
// stdout and stderr will be returned as different strings Invoke(args []string) (string, string, error) // InvokeOrFail calls Invoke and fails tests if it returns en err InvokeOrFail(t test.Failer, args []string) (string, string) } // Config is structured config for the istioctl component type Config struct { // Cluster to be used in a multicluster environment Cluster cluster.Cluster }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Feb 14 22:20:09 UTC 2022 - 1.9K bytes - Viewed (0) -
pilot/pkg/networking/core/listenertest/match.go
Type FilterChainType // Port the filter chain matches Port uint32 NetworkFilters []string HTTPFilters []string ValidateHCM func(t test.Failer, hcm *hcm.HttpConnectionManager) TotalMatch bool } type FilterChainType string const ( PlainTCP FilterChainType = "plaintext TCP" PlainHTTP FilterChainType = "plaintext HTTP"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 6.4K bytes - Viewed (0) -
pkg/test/framework/components/echo/workload.go
type WorkloadContainer interface { // Workloads retrieves the list of all deployed workloads for this Echo service. // Guarantees at least one workload, if error == nil. Workloads() (Workloads, error) WorkloadsOrFail(t test.Failer) Workloads MustWorkloads() Workloads // Clusters where the workloads are deployed. Clusters() cluster.Clusters } // Workload provides an interface for a single deployed echo server. type Workload interface {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Oct 25 19:46:28 UTC 2023 - 2.7K bytes - Viewed (0) -
pilot/pkg/xds/deltaadstest.go
) func NewDeltaAdsTest(t test.Failer, conn *grpc.ClientConn) *DeltaAdsTest { test.SetForTest(t, &features.DeltaXds, true) return NewDeltaXdsTest(t, conn, func(conn *grpc.ClientConn) (DeltaDiscoveryClient, error) { xds := discovery.NewAggregatedDiscoveryServiceClient(conn) return xds.DeltaAggregatedResources(context.Background()) }) } func NewDeltaXdsTest(t test.Failer, conn *grpc.ClientConn,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Feb 04 03:39:42 UTC 2024 - 6.9K bytes - Viewed (0) -
pkg/kube/krt/krttest/helpers.go
) type MockCollection struct { t test.Failer inputs []any } // NewMock creates a helper to build Collections of static inputs for use with testing. // Example usage: // // mock := krttest.NewMock(t, []any{serviceFoo, podBar, namespaceBaz}) // pods := krttest.GetMockCollection[Pod](mock) // makes a collection of all Pod types from inputs func NewMock(t test.Failer, inputs []any) *MockCollection { t.Helper()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 21 19:33:01 UTC 2024 - 2.1K bytes - Viewed (0) -
pkg/test/framework/components/echo/match/matchers_test.go
func (f fakeInstance) Addresses() []string { panic("implement me") } func (f fakeInstance) Workloads() (echo.Workloads, error) { panic("implement me") } func (f fakeInstance) WorkloadsOrFail(test.Failer) echo.Workloads { panic("implement me") } func (f fakeInstance) MustWorkloads() echo.Workloads { panic("implement me") } func (f fakeInstance) Clusters() cluster.Clusters { panic("implement me")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 5.2K bytes - Viewed (0) -
pilot/pkg/bootstrap/istio_ca_test.go
// Should do nothing because certs already exist locally. err = s.loadCACerts(caOpts, dir) g.Expect(err).Should(BeNil()) } func createCATLSSecret(t test.Failer, client kube.Client) { var caCert, caKey, rootCert []byte var err error if caCert, err = readSampleCertFromFile("ca-cert.pem"); err != nil { t.Fatal(err) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Oct 31 14:48:28 UTC 2023 - 4.3K bytes - Viewed (0)