Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 21 - 27 of 27 for KeepAlive (0.05 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

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

    	if h.kconfig.Version != "" {
    		kafkaVersion, err := sarama.ParseKafkaVersion(h.kconfig.Version)
    		if err != nil {
    			return err
    		}
    		sconfig.Version = kafkaVersion
    	}
    
    	sconfig.Net.KeepAlive = 60 * time.Second
    	sconfig.Net.SASL.User = h.kconfig.SASL.User
    	sconfig.Net.SASL.Password = h.kconfig.SASL.Password
    	initScramClient(h.kconfig, sconfig) // initializes configured scram client.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 10.2K bytes
    - Click Count (0)
  2. build-logic/cleanup/src/main/java/gradlebuild/cleanup/services/KillLeakingJavaProcesses.java

                + ").*";
        }
    
        static String generateLeakingProcessKillPattern(String rootProjectDir) {
            String kotlinCompilerDaemonPattern = "(?:" + quote("-Dkotlin.environment.keepalive") + ".+org\\.jetbrains\\.kotlin\\.daemon\\.KotlinCompileDaemon)";
            String quotedRootProjectDir = quote(rootProjectDir);
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Tue Sep 23 13:49:45 GMT 2025
    - 12K bytes
    - Click Count (0)
  3. fastapi/routing.py

                        ObjectReceiveStream[bytes]
                    ]:
                        # Use a memory stream to decouple generator iteration
                        # from the keepalive timer. A producer task pulls items
                        # from the generator independently, so
                        # `anyio.fail_after` never wraps the generator's
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Sun Mar 15 11:44:39 GMT 2026
    - 193K bytes
    - Click Count (0)
  4. internal/config/notify/legacy.go

    			Value: cfg.Password,
    		},
    		config.KV{
    			Key:   target.MqttReconnectInterval,
    			Value: cfg.MaxReconnectInterval.String(),
    		},
    		config.KV{
    			Key:   target.MqttKeepAliveInterval,
    			Value: cfg.KeepAlive.String(),
    		},
    		config.KV{
    			Key:   target.MqttQueueDir,
    			Value: cfg.QueueDir,
    		},
    		config.KV{
    			Key:   target.MqttQueueLimit,
    			Value: strconv.Itoa(int(cfg.QueueLimit)),
    		},
    	}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Apr 27 04:30:57 GMT 2025
    - 13.3K bytes
    - Click Count (0)
  5. CHANGELOG/CHANGELOG-1.12.md

    - "kubectl delete" no longer waits for dependent objects to be deleted when removing parent resources ([#65908](https://github.com/kubernetes/kubernetes/pull/65908), [@juanvallejo](https://github.com/juanvallejo))
    - A new flag, `--keepalive`, has been introduced, for kubectl proxy to allow setting keep-alive period for long-running request. ([#63793](https://github.com/kubernetes/kubernetes/pull/63793), [@hzxuzhonghu](https://github.com/hzxuzhonghu))
    Created: Fri Apr 03 09:05:14 GMT 2026
    - Last Modified: Thu Feb 06 06:04:15 GMT 2020
    - 293.8K bytes
    - Click Count (0)
  6. api/go1.3.txt

    pkg math/big, method (*Int) UnmarshalText([]uint8) error
    pkg math/big, method (*Rat) MarshalText() ([]uint8, error)
    pkg math/big, method (*Rat) UnmarshalText([]uint8) error
    pkg net, type Dialer struct, KeepAlive time.Duration
    pkg net/http, const StateActive = 1
    pkg net/http, const StateActive ConnState
    pkg net/http, const StateClosed = 4
    pkg net/http, const StateClosed ConnState
    pkg net/http, const StateHijacked = 3
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Mon Jun 02 02:45:00 GMT 2014
    - 117K bytes
    - Click Count (0)
  7. api/go1.13.txt

    pkg net, method (*DNSConfigError) Unwrap() error
    pkg net, method (*OpError) Unwrap() error
    pkg net, type DNSError struct, IsNotFound bool
    pkg net, type ListenConfig struct, KeepAlive time.Duration
    pkg net/url, method (*Error) Unwrap() error
    pkg os/exec, method (*Cmd) String() string
    pkg os/exec, method (*Error) Unwrap() error
    pkg os, func UserConfigDir() (string, error)
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Thu Aug 08 18:44:16 GMT 2019
    - 452.6K bytes
    - Click Count (0)
Back to Top