Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 867 for net (0.02 sec)

  1. internal/logger/target/kafka/kafka.go

    	if err != nil {
    		return err
    	}
    
    	sconfig.Net.TLS.Enable = h.kconfig.TLS.Enable
    	sconfig.Net.TLS.Config = tlsConfig
    	sconfig.Net.TLS.Config.InsecureSkipVerify = h.kconfig.TLS.SkipVerify
    	sconfig.Net.TLS.Config.ClientAuth = h.kconfig.TLS.ClientAuth
    	sconfig.Net.TLS.Config.RootCAs = h.kconfig.TLS.RootCAs
    
    	// These settings are needed to ensure that kafka client doesn't hang on brokers
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Sun Jun 02 03:03:39 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  2. platforms/extensibility/plugin-use/src/integTest/groovy/org/gradle/plugin/repository/PluginManagementDslSpec.groovy

                        ivy {
                            url "http://repo.internal.net/ivy"
                            layout("maven")
                        }
                        ivy {
                            url "http://repo.internal.net/ivy"
                            layout("ivy")
                        }
                        ivy {
                            url "http://repo.internal.net/ivy"
                            layout("gradle")
                        }
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Mar 28 15:16:47 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  3. pkg/registry/core/service/portallocator/allocator_test.go

    	type args struct {
    		pr net.PortRange
    	}
    	tests := []struct {
    		name string
    		args args
    		want int
    	}{
    		{
    			name: "default node port range",
    			args: args{
    				pr: net.PortRange{
    					Base: 30000,
    					Size: 2768,
    				},
    			},
    			want: 86,
    		},
    		{
    			name: "very small node port range",
    			args: args{
    				pr: net.PortRange{
    					Base: 30000,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 08 07:15:02 UTC 2024
    - 14K bytes
    - Viewed (0)
  4. src/net/net_fake.go

    		uaddr, ok := addr.(*UnixAddr)
    		if !ok && addr != nil {
    			return &AddrError{
    				Err:  "non-Unix address for " + ffd.fd.net + " network",
    				Addr: addr.String(),
    			}
    		}
    		if uaddr == nil {
    			return validate(&UnixAddr{Net: ffd.fd.net})
    		}
    		return validate(&UnixAddr{Net: ffd.fd.net, Name: uaddr.Name})
    
    	default:
    		return &AddrError{
    			Err:  syscall.EAFNOSUPPORT.Error(),
    			Addr: addr.String(),
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Feb 27 19:24:21 UTC 2024
    - 26.4K bytes
    - Viewed (0)
  5. internal/event/target/kafka.go

    		target.loggerOnce(context.Background(), err, target.ID().String())
    		return err
    	}
    
    	config.Net.TLS.Enable = args.TLS.Enable
    	config.Net.TLS.Config = tlsConfig
    	config.Net.TLS.Config.InsecureSkipVerify = args.TLS.SkipVerify
    	config.Net.TLS.Config.ClientAuth = args.TLS.ClientAuth
    	config.Net.TLS.Config.RootCAs = args.TLS.RootCAs
    
    	// These settings are needed to ensure that kafka client doesn't hang on brokers
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Sat Jun 01 15:02:59 UTC 2024
    - 13.1K bytes
    - Viewed (0)
  6. okhttp/src/test/java/okhttp3/KotlinDeprecationErrorTest.kt

    package okhttp3
    
    import java.io.File
    import java.net.InetSocketAddress
    import java.net.Proxy
    import java.net.ProxySelector
    import java.net.Socket
    import java.net.URI
    import java.net.URL
    import java.nio.charset.Charset
    import java.security.KeyPair
    import java.security.Principal
    import java.security.cert.Certificate
    import java.security.cert.X509Certificate
    import javax.net.ServerSocketFactory
    import javax.net.SocketFactory
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  7. platforms/extensibility/plugin-development/src/integTest/groovy/org/gradle/plugin/devel/tasks/ValidatePluginsPart2IntegrationTest.groovy

                contextualLabel == 'Type \'MyTask\' property \'direct\' has @Input annotation used on type \'java.net.URL\' or a property of this type'
                details == 'Type \'java.net.URL\' is not supported on properties annotated with @Input because Java Serialization can be inconsistent for this type'
                solutions == [ 'Use type \'java.net.URI\' instead' ]
                additionalData.asMap == [
                    'typeName' : 'MyTask',
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue May 28 09:03:53 UTC 2024
    - 40K bytes
    - Viewed (0)
  8. okhttp/src/main/kotlin/okhttp3/internal/cache/CacheStrategy.kt

    package okhttp3.internal.cache
    
    import java.net.HttpURLConnection.HTTP_BAD_METHOD
    import java.net.HttpURLConnection.HTTP_GONE
    import java.net.HttpURLConnection.HTTP_MOVED_PERM
    import java.net.HttpURLConnection.HTTP_MOVED_TEMP
    import java.net.HttpURLConnection.HTTP_MULT_CHOICE
    import java.net.HttpURLConnection.HTTP_NOT_AUTHORITATIVE
    import java.net.HttpURLConnection.HTTP_NOT_FOUND
    import java.net.HttpURLConnection.HTTP_NOT_IMPLEMENTED
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Mon Apr 15 13:24:48 UTC 2024
    - 12K bytes
    - Viewed (0)
  9. okhttp/src/main/kotlin/okhttp3/internal/platform/Platform.kt

    import java.io.IOException
    import java.net.InetSocketAddress
    import java.net.Socket
    import java.security.GeneralSecurityException
    import java.security.KeyStore
    import java.security.Security
    import java.util.logging.Level
    import java.util.logging.Logger
    import javax.net.ssl.ExtendedSSLSession
    import javax.net.ssl.SNIHostName
    import javax.net.ssl.SSLContext
    import javax.net.ssl.SSLSocket
    import javax.net.ssl.SSLSocketFactory
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 9.8K bytes
    - Viewed (0)
  10. src/net/http/httputil/persist.go

    // Use of this source code is governed by a BSD-style
    // license that can be found in the LICENSE file.
    
    package httputil
    
    import (
    	"bufio"
    	"errors"
    	"io"
    	"net"
    	"net/http"
    	"net/textproto"
    	"sync"
    )
    
    var (
    	// Deprecated: No longer used.
    	ErrPersistEOF = &http.ProtocolError{ErrorString: "persistent connection closed"}
    
    	// Deprecated: No longer used.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jan 10 03:29:50 UTC 2024
    - 11.1K bytes
    - Viewed (0)
Back to top