- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 84 for Dialer (0.11 sec)
-
tests/integration/pilot/common/traffic.go
"istio.io/istio/pkg/test/framework/resource" "istio.io/istio/pkg/test/util/tmpl" "istio.io/istio/pkg/test/util/yml" ) type TrafficCall struct { name string call func(t test.Failer, options echo.CallOptions) echo.CallResult opts echo.CallOptions } type skip struct { skip bool reason string } type TrafficTestCase struct { name string
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jan 03 19:10:01 UTC 2024 - 11.4K bytes - Viewed (0) -
pilot/pkg/networking/core/listener_builder_test.go
} } } func TestSidecarInboundListenerFilters(t *testing.T) { services := []*model.Service{buildServiceWithPort("test.com", 80, protocol.HTTPS, tnow)} expectIstioMTLS := func(t test.Failer, filterChain *listener.FilterChain) { tlsContext := &tls.DownstreamTlsContext{} if err := filterChain.GetTransportSocket().GetTypedConfig().UnmarshalTo(tlsContext); err != nil { t.Fatal(err) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 24.7K bytes - Viewed (0) -
pkg/test/framework/components/echo/deployment/builder.go
// Build and initialize all Echo Instances. Upon returning, the Instance pointers // are assigned and all Instances are ready to communicate with each other. Build() (echo.Instances, error) BuildOrFail(t test.Failer) echo.Instances } var _ Builder = &builder{} // New builder for echo deployments. func New(ctx resource.Context, clusters ...cluster.Cluster) Builder { // use all workload clusters unless otherwise specified
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 12K bytes - Viewed (0) -
pkg/test/framework/testcontext.go
"istio.io/istio/pkg/test/util/yml" "istio.io/istio/pkg/tracing" ) // TestContext is a test-level context that can be created as part of test executing tests. type TestContext interface { resource.Context test.Failer Context() context.Context // NewSubTest creates a new sub-test under the current running Test. The lifecycle of a sub-Test is scoped to the
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 11.4K bytes - Viewed (0) -
pkg/test/framework/components/echo/echotest/filters_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 - 13.1K bytes - Viewed (0) -
pkg/test/framework/components/istio/config.go
return Config{}, err } return s, nil } // DefaultConfigOrFail calls DefaultConfig and fails t if an error occurs. func DefaultConfigOrFail(t test.Failer, ctx resource.Context) Config { cfg, err := DefaultConfig(ctx) if err != nil { t.Fatalf("Get istio config: %v", err) } return cfg } func checkFileExists(path string) error {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 10 20:33:28 UTC 2024 - 14.8K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/serviceimportcache_test.go
ic.checkServiceInstances(t) updatedVIPs := []string{"1.1.1.1", "1.1.1.2"} ic.setServiceImportVIPs(t, updatedVIPs) } func newTestServiceImportCache(t test.Failer) (*FakeController, *serviceImportCacheImpl) { test.SetForTest(t, &features.EnableMCSHost, true) c, _ := NewFakeControllerWithOptions(t, FakeControllerOptions{ ClusterID: serviceImportCluster,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Aug 14 18:50:38 UTC 2023 - 15.2K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/pod_test.go
assert.EventuallyEqual(t, fetch, nil) } func waitForPod(t test.Failer, c *FakeController, ip string) { retry.UntilOrFail(t, func() bool { c.pods.RLock() defer c.pods.RUnlock() if _, ok := c.pods.podsByIP[ip]; ok { return true } return false }) } func waitForNode(t test.Failer, c *FakeController, name string) { retry.UntilOrFail(t, func() bool {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 16 18:27:40 UTC 2024 - 12.3K bytes - Viewed (0) -
src/net/lookup_test.go
} } type lookupCustomResolver struct { *Resolver mu sync.RWMutex dialed bool } func (lcr *lookupCustomResolver) dial() func(ctx context.Context, network, address string) (Conn, error) { return func(ctx context.Context, network, address string) (Conn, error) { lcr.mu.Lock() lcr.dialed = true lcr.mu.Unlock() return Dial(network, address) } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 41.4K bytes - Viewed (0) -
manifests/charts/gateways/istio-ingress/templates/deployment.yaml
maxUnavailable: {{ $gateway.rollingMaxUnavailable }} template: metadata: labels: {{ $gateway.labels | toYaml | indent 8 }} {{- if eq .Release.Namespace "istio-system"}} heritage: Tiller release: istio chart: gateways {{- end }} service.istio.io/canonical-name: {{ $gateway.name }}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 18 18:16:49 UTC 2024 - 12.1K bytes - Viewed (0)