- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 71 for dialFn (0.12 sec)
-
src/net/sock_posix.go
// datagram connection, known as a datagram listener // // - An endpoint holder that opens an active stream or a // destination-specific datagram connection, known as a // dialer // // - An endpoint holder that opens the other connection, such // as talking to the protocol stack inside the kernel // // For stream and datagram listeners, they will only require
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Sep 18 17:20:52 UTC 2023 - 6.3K bytes - Viewed (0) -
cmd/grid.go
hosts, local := eps.GridHosts() lookupHost := globalDNSCache.LookupHost g, err := grid.NewManager(ctx, grid.ManagerOptions{ // Pass Dialer for websocket grid, make sure we do not // provide any DriveOPTimeout() function, as that is not // useful over persistent connections. Dialer: grid.ContextDialer(xhttp.DialContextWithLookupHost(lookupHost, xhttp.NewInternodeDialContext(rest.DefaultTimeout, globalTCPOptions.ForWebsocket()))),
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 22 23:07:14 UTC 2024 - 2.2K bytes - Viewed (0) -
cmd/testdata/dillon_test_key.pub
ssh-ed25519 AAAAC3NzaC1lZDI1NTE5AAAAIDVGk/SRz4fwTPK0+Ra7WYUGf3o08YkpI0yTMPpHwYoq dillon@example.io...
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed Jun 05 07:51:13 UTC 2024 - 99 bytes - Viewed (0) -
internal/grid/connection_test.go
"github.com/minio/minio/internal/logger/target/testlogger" ) func TestDisconnect(t *testing.T) { defer testlogger.T.SetLogTB(t)() defer timeout(10 * time.Second)() hosts, listeners, _ := getHosts(2) dialer := &net.Dialer{ Timeout: 1 * time.Second, } errFatal := func(err error) { t.Helper() if err != nil { t.Fatal(err) } } wrapServer := func(handler http.Handler) http.Handler {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Nov 21 01:09:35 UTC 2023 - 6K bytes - Viewed (0) -
src/net/tcpsock_plan9.go
} if raddr == nil { return nil, errMissingAddress } fd, err := dialPlan9(ctx, sd.network, laddr, raddr) if err != nil { return nil, err } return newTCPConn(fd, sd.Dialer.KeepAlive, sd.Dialer.KeepAliveConfig, testPreHookSetKeepAlive, testHookSetKeepAlive), nil } func (ln *TCPListener) ok() bool { return ln != nil && ln.fd != nil && ln.fd.ctl != nil } func (ln *TCPListener) accept() (*TCPConn, error) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 20 06:04:31 UTC 2024 - 2.3K bytes - Viewed (0) -
doc/next/6-stdlib/99-minor/net/62254.md
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 12 20:57:18 UTC 2024 - 205 bytes - Viewed (0) -
pkg/kubelet/cm/dra/plugin/plugin.go
network := "unix" klog.V(4).InfoS(log("creating new gRPC connection"), "protocol", network, "endpoint", p.endpoint) conn, err := grpc.Dial( p.endpoint, grpc.WithTransportCredentials(insecure.NewCredentials()), grpc.WithContextDialer(func(ctx context.Context, target string) (net.Conn, error) { return (&net.Dialer{}).DialContext(ctx, network, target) }), ) if err != nil { return nil, err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 19 16:27:05 UTC 2024 - 6.2K bytes - Viewed (0) -
buildscripts/minio-iam-ldap-upgrade-import-test.sh
group_search_base_dn=ou=swengg,dc=min,dc=io \ group_search_filter="(&(objectclass=groupOfNames)(member=%d))" mc admin service restart old-minio mc idp ldap policy attach old-minio readwrite --user=UID=dillon,ou=people,ou=swengg,dc=min,dc=io mc idp ldap policy attach old-minio readwrite --group=CN=project.c,ou=groups,ou=swengg,dc=min,dc=io mc idp ldap policy entities old-minio mc admin cluster iam export old-minio set +x
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat May 18 18:19:01 UTC 2024 - 3.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/storagebackend/config.go
ServerList []string // TLS credentials KeyFile string CertFile string TrustedCAFile string // function to determine the egress dialer. (i.e. konnectivity server dialer) EgressLookup egressselector.Lookup // The TracerProvider can add tracing the connection TracerProvider oteltrace.TracerProvider } // Config is configuration for creating a storage backend.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 17:57:37 UTC 2024 - 4.3K bytes - Viewed (0) -
src/net/unixsock_posix.go
ctrlCtxFn := sd.Dialer.ControlContext if ctrlCtxFn == nil && sd.Dialer.Control != nil { ctrlCtxFn = func(ctx context.Context, network, address string, c syscall.RawConn) error { return sd.Dialer.Control(network, address, c) } } fd, err := unixSocket(ctx, sd.network, laddr, raddr, "dial", ctrlCtxFn) if err != nil { return nil, err }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 16 16:54:32 UTC 2024 - 6.6K bytes - Viewed (0)