- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for createDialer (0.3 sec)
-
staging/src/k8s.io/apiserver/pkg/server/egressselector/egress_selector.go
connector proxyServerConnector direct bool options metricsOptions } type metricsOptions struct { transport string protocol string } func (d *dialerCreator) createDialer() utilnet.DialFunc { if d.direct { return directDialer } return func(ctx context.Context, network, addr string) (net.Conn, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 29 15:48:39 UTC 2023 - 12.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/egressselector/egress_selector_test.go
connectorErr: tc.connectorErr, proxierErr: tc.proxierErr, }, options: metricsOptions{ transport: "fake_transport", protocol: "fake_protocol", }, } dialer := d.createDialer() dialer(context.TODO(), "", "") if err := testutil.GatherAndCompare(legacyregistry.DefaultGatherer, strings.NewReader(tc.want), tc.metrics...); err != nil { t.Errorf("Err in comparing metrics %v", err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jan 26 22:41:29 UTC 2023 - 12.3K bytes - Viewed (0)