- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 25 for SRV (0.08 sec)
-
pkg/kubelet/lifecycle/handlers_test.go
metrics.Register() legacyregistry.Reset() var actualHeaders http.Header srv := httptest.NewServer(http.HandlerFunc(func(_ http.ResponseWriter, r *http.Request) { actualHeaders = r.Header.Clone() })) defer srv.Close() _, port, err := net.SplitHostPort(srv.Listener.Addr().String()) if err != nil { t.Fatal(err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 24.4K bytes - Viewed (0) -
src/net/http/pprof/pprof.go
case <-time.After(d): case <-r.Context().Done(): } } func configureWriteDeadline(w http.ResponseWriter, r *http.Request, seconds float64) { srv, ok := r.Context().Value(http.ServerContextKey).(*http.Server) if ok && srv.WriteTimeout > 0 { timeout := srv.WriteTimeout + time.Duration(seconds*float64(time.Second)) rc := http.NewResponseController(w) rc.SetWriteDeadline(time.Now().Add(timeout)) } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 27 17:34:05 UTC 2024 - 14.1K bytes - Viewed (0) -
src/crypto/tls/boring_test.go
clientConfig.MaxVersion = VersionTLS13 clientConfig.CipherSuites = allCipherSuites() clientConfig.CurvePreferences = defaultCurvePreferences() go Client(c, clientConfig).Handshake() srv := Server(s, testConfig) msg, err := srv.readHandshake(nil) if err != nil { t.Fatal(err) } hello, ok := msg.(*clientHelloMsg) if !ok { t.Fatalf("unexpected message type %T", msg) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 21:45:37 UTC 2024 - 19.4K bytes - Viewed (0) -
cmd/api-router.go
} func newConsoleServerFn() *consoleapi.Server { globalObjLayerMutex.RLock() defer globalObjLayerMutex.RUnlock() return globalConsoleSrv } func setConsoleSrv(srv *consoleapi.Server) { globalObjLayerMutex.Lock() globalConsoleSrv = srv globalObjLayerMutex.Unlock() } func newObjectLayerFn() ObjectLayer { globalObjLayerMutex.RLock() defer globalObjLayerMutex.RUnlock() return globalObjectAPI }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 22.8K bytes - Viewed (0) -
pkg/dns/client/dns_test.go
} func initDNS(t test.Failer, forwardToUpstreamParallel bool) *LocalDNSServer { srv := makeUpstream(t, map[string]string{"www.bing.com.": "1.1.1.1"}) testAgentDNS, err := NewLocalDNSServer("ns1", "ns1.svc.cluster.local", "localhost:0", forwardToUpstreamParallel) if err != nil { t.Fatal(err) } testAgentDNS.resolvConfServers = []string{srv} testAgentDNS.StartDNS() fillTable(testAgentDNS) t.Cleanup(testAgentDNS.Close)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 29 16:17:34 UTC 2024 - 20.4K bytes - Viewed (0) -
pilot/pkg/model/service.go
TrafficDirectionOutbound TrafficDirection = "outbound" // trafficDirectionOutboundSrvPrefix the prefix for a DNS SRV type subset key trafficDirectionOutboundSrvPrefix = string(TrafficDirectionOutbound) + "_" // trafficDirectionInboundSrvPrefix the prefix for a DNS SRV type subset key trafficDirectionInboundSrvPrefix = string(TrafficDirectionInbound) + "_" )
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 02:03:58 UTC 2024 - 46.3K bytes - Viewed (0) -
cmd/kubemark/app/hollow_node.go
fs.StringVar(&c.BootstrapKubeconfigPath, "bootstrap-kubeconfig", "", "Path to bootstrap kubeconfig file.") fs.StringVar(&c.CertDirectory, "cert-dir", "/etc/srv/", "Path to cert directory for bootstraping.") fs.IntVar(&c.KubeletPort, "kubelet-port", ports.KubeletPort, "Port on which HollowKubelet should be listening.")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 08:58:18 UTC 2024 - 11K bytes - Viewed (0) -
src/net/rpc/server.go
func (server *Server) ServeConn(conn io.ReadWriteCloser) { buf := bufio.NewWriter(conn) srv := &gobServerCodec{ rwc: conn, dec: gob.NewDecoder(conn), enc: gob.NewEncoder(buf), encBuf: buf, } server.ServeCodec(srv) } // ServeCodec is like [ServeConn] but uses the specified codec to // decode requests and encode responses.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 21.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/apis/apiserver/types.go
type UDSTransport struct { // UDSName is the name of the unix domain socket to connect to konnectivity server // This does not use a unix:// prefix. (Eg: /etc/srv/kubernetes/konnectivity-server/konnectivity-server.socket) UDSName string } // TLSConfig provides the authentication information to connect to konnectivity server // Only used with TCPTransport
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 04 00:57:24 UTC 2024 - 14.2K bytes - Viewed (0) -
src/os/os_windows_test.go
//LanmanWorkstation is the service name, and Workstation is the display name. srv, err := windows.OpenService(mar, syscall.StringToUTF16Ptr("LanmanWorkstation"), windows.SERVICE_QUERY_STATUS) if err != nil { return } defer syscall.CloseHandle(srv) var state windows.SERVICE_STATUS err = windows.QueryServiceStatus(srv, &state) if err != nil { return } if state.CurrentState != windows.SERVICE_RUNNING {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 41.8K bytes - Viewed (0)