- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 532 for GetWork (0.23 sec)
-
okhttp-android/src/test/kotlin/okhttp3/android/ShadowDnsResolver.kt
var responder: (Request) -> Unit = { it.callback.onAnswer(listOf(), 0) } data class Request( val network: Network?, val domain: String, val nsType: Int, val flags: Int, val callback: DnsResolver.Callback<List<InetAddress>>, ) @Implementation fun query( network: Network?, domain: String, nsType: Int, flags: Int, executor: Executor,
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 22 20:07:09 UTC 2024 - 1.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http/RealInterceptorChain.kt
/** * A concrete interceptor chain that carries the entire interceptor chain: all application * interceptors, the OkHttp core, all network interceptors, and finally the network caller. * * If the chain is for an application interceptor then [exchange] must be null. Otherwise it is for * a network interceptor and [exchange] must be non-null. */ class RealInterceptorChain( internal val call: RealCall,
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 4.2K bytes - Viewed (0) -
pkg/hbone/dialer.go
func (d *dialer) DialContext(ctx context.Context, network, address string) (net.Conn, error) { if network != "tcp" { return net.Dial(network, address) } // TODO: use context c, s := net.Pipe() err := d.proxyTo(s, d.cfg, address) if err != nil { return nil, err } return c, nil } func (d dialer) Dial(network, address string) (c net.Conn, err error) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 24 15:56:41 UTC 2023 - 5.1K bytes - Viewed (0) -
src/net/iprawsock_test.go
t.Fatal("should not fail") } } } func TestIPConnRemoteName(t *testing.T) { network := "ip:tcp" if !testableNetwork(network) { t.Skipf("skipping %s test", network) } raddr := &IPAddr{IP: IPv4(127, 0, 0, 1).To4()} c, err := DialIP(network, &IPAddr{IP: IPv4(127, 0, 0, 1)}, raddr) if testenv.SyscallIsNotSupported(err) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Sep 18 17:20:52 UTC 2023 - 6K bytes - Viewed (0) -
container-tests/src/test/java/okhttp3/containers/SocksProxyTest.kt
import org.testcontainers.containers.MockServerContainer import org.testcontainers.containers.Network import org.testcontainers.junit.jupiter.Container import org.testcontainers.junit.jupiter.Testcontainers import org.testcontainers.utility.DockerImageName @Testcontainers class SocksProxyTest { val network: Network = Network.newNetwork() @Container val mockServer: MockServerContainer =
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Fri Apr 05 03:30:42 UTC 2024 - 2.6K bytes - Viewed (0) -
pkg/registry/core/rangeallocation/OWNERS
# See the OWNERS docs at https://go.k8s.io/owners approvers: - sig-network-approvers reviewers: - sig-network-reviewers labels:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 31 01:20:16 UTC 2023 - 149 bytes - Viewed (0) -
pkg/config/analysis/analyzers/envoyfilter/envoyfilter.go
} // check each operation type if patch.Patch.Operation == network.EnvoyFilter_Patch_ADD { // the ADD operation is an absolute operation but provide a warning // indicating that the operation will be ignored when applyTo is set to ROUTE_CONFIGURATION, // or HTTP_ROUTE if patch.ApplyTo == network.EnvoyFilter_ROUTE_CONFIGURATION || patch.ApplyTo == network.EnvoyFilter_HTTP_ROUTE {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Aug 08 16:43:05 UTC 2023 - 6.8K bytes - Viewed (0) -
internal/http/dial_others.go
// //nolint:unused func setTCPParametersFn(opts TCPOptions) func(network, address string, c syscall.RawConn) error { return func(network, address string, c syscall.RawConn) error { return nil } } // DialContext is a function to make custom Dial for internode communications type DialContext func(ctx context.Context, network, address string) (net.Conn, error)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed Apr 24 04:08:47 UTC 2024 - 1.6K bytes - Viewed (0) -
pkg/proxy/winkernel/testing/hcnutils_mock.go
endpoint.HostComputeNetwork = network.Id endpointMap[endpoint.Id] = endpoint endpointMap[endpoint.Name] = endpoint return endpoint, nil } func (hcnObj HcnMock) CreateRemoteEndpoint(network *hcn.HostComputeNetwork, endpoint *hcn.HostComputeEndpoint) (*hcn.HostComputeEndpoint, error) { return hcnObj.CreateEndpoint(network, endpoint) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Sep 18 06:29:01 UTC 2023 - 6.2K bytes - Viewed (0) -
pilot/pkg/config/kube/gateway/testdata/deployment/waypoint.yaml
metadata: annotations: {} labels: gateway.istio.io/managed: istio.io-mesh-controller gateway.networking.k8s.io/gateway-name: namespace istio.io/gateway-name: namespace topology.istio.io/network: network-1 name: namespace namespace: default ownerReferences: - apiVersion: gateway.networking.k8s.io/v1beta1 kind: Gateway name: namespace uid: "" --- apiVersion: apps/v1 kind: Deployment
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 22:41:03 UTC 2024 - 6.9K bytes - Viewed (0)