Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 27 of 27 for idletimeout (0.2 sec)

  1. internal/http/server.go

    	srv.ShutdownTimeout = d
    	return srv
    }
    
    // UseIdleTimeout configure idle connection timeout
    func (srv *Server) UseIdleTimeout(d time.Duration) *Server {
    	srv.IdleTimeout = d
    	return srv
    }
    
    // UseReadHeaderTimeout configure read header timeout
    func (srv *Server) UseReadHeaderTimeout(d time.Duration) *Server {
    	srv.ReadHeaderTimeout = d
    	return srv
    }
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Feb 09 21:25:16 UTC 2024
    - 7.7K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/util/proxy/websocket.go

    	"k8s.io/apimachinery/pkg/util/httpstream/wsstream"
    	constants "k8s.io/apimachinery/pkg/util/remotecommand"
    	"k8s.io/apimachinery/pkg/util/runtime"
    	"k8s.io/client-go/tools/remotecommand"
    )
    
    const (
    	// idleTimeout is the read/write deadline set for websocket server connection. Reading
    	// or writing the connection will return an i/o timeout if this deadline is exceeded.
    	// Currently, we use the same value as the kubelet websocket server.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 26 16:28:45 UTC 2024
    - 6.2K bytes
    - Viewed (0)
  3. internal/event/target/redis.go

    		if err := queueStore.Open(); err != nil {
    			return nil, fmt.Errorf("unable to initialize the queue store of Redis `%s`: %w", id, err)
    		}
    	}
    
    	pool := &redis.Pool{
    		MaxIdle:     3,
    		IdleTimeout: 2 * 60 * time.Second,
    		Dial: func() (redis.Conn, error) {
    			conn, err := redis.Dial("tcp", args.Addr.String())
    			if err != nil {
    				return nil, err
    			}
    
    			if args.Password != "" {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  4. pkg/test/echo/server/endpoint/grpc.go

    		return err
    	}
    	// Store the actual listening port back to the argument.
    	s.Port.Port = p
    
    	opts := []grpc.ServerOption{
    		grpc.KeepaliveParams(keepalive.ServerParameters{
    			MaxConnectionIdle: idleTimeout,
    		}),
    	}
    	if s.Port.TLS {
    		epLog.Infof("Listening GRPC (over TLS) on %v", p)
    		// Create the TLS credentials
    		creds, errCreds := credentials.NewServerTLSFromFile(s.TLSCert, s.TLSKey)
    		if errCreds != nil {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Sep 25 17:30:37 UTC 2023
    - 8.7K bytes
    - Viewed (0)
  5. platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/configuration/DefaultDaemonServerConfiguration.java

            // The daemon that shouldn't use the agent won't have the agent applied.
            this(daemonUid, daemonBaseDir, idleTimeoutMs, periodicCheckIntervalMs, singleUse, priority, jvmOptions, true, nativeServicesMode);
        }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Mar 12 12:13:32 UTC 2024
    - 4K bytes
    - Viewed (0)
  6. platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/configuration/ForegroundDaemonConfiguration.java

            // Foreground daemon cannot be 'told' what's his startup options as the client sits in the same process so we will infer the jvm opts from the inputArguments()
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Mar 12 12:13:32 UTC 2024
    - 1.6K bytes
    - Viewed (0)
  7. releasenotes/notes/add-idle-timeout-to-destination-rule-tcp-settings.yaml

    apiVersion: release-notes/v2
    kind: feature
    area: traffic-management
    issue: []
    releaseNotes:
      - |
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Dec 19 15:18:18 UTC 2023
    - 189 bytes
    - Viewed (0)
Back to top