MCPcopy Index your code
hub / github.com/cloudflare/cloudflared / StartHelloWorldServer

Function StartHelloWorldServer

hello/hello.go:102–128  ·  view source on GitHub ↗
(log *zerolog.Logger, listener net.Listener, shutdownC <-chan struct{})

Source from the content-addressed store, hash-verified

100`
101
102func StartHelloWorldServer(log *zerolog.Logger, listener net.Listener, shutdownC <-chan struct{}) error {
103 log.Info().Msgf("Starting Hello World server at %s", listener.Addr())
104 serverName := defaultServerName
105 if hostname, err := os.Hostname(); err == nil {
106 serverName = hostname
107 }
108
109 upgrader := websocket.Upgrader{
110 ReadBufferSize: 1024,
111 WriteBufferSize: 1024,
112 }
113
114 muxer := http.NewServeMux()
115 muxer.HandleFunc(UptimeRoute, uptimeHandler(time.Now()))
116 muxer.HandleFunc(WSRoute, websocketHandler(log, upgrader))
117 muxer.HandleFunc(SSERoute, sseHandler(log))
118 muxer.HandleFunc(HealthRoute, healthHandler())
119 muxer.HandleFunc("/", rootHandler(serverName))
120 httpServer := &http.Server{Addr: listener.Addr().String(), Handler: muxer}
121 go func() {
122 <-shutdownC
123 _ = httpServer.Close()
124 }()
125
126 err := httpServer.Serve(listener)
127 return err
128}
129
130func CreateTLSListener(address string) (net.Listener, error) {
131 certificate, err := tlsconfig.GetHelloCertificate()

Callers 3

startMethod · 0.92
TestServeFunction · 0.92
TestWebsocketWrapperFunction · 0.92

Calls 10

uptimeHandlerFunction · 0.85
websocketHandlerFunction · 0.85
sseHandlerFunction · 0.85
healthHandlerFunction · 0.85
rootHandlerFunction · 0.85
AddrMethod · 0.80
StringMethod · 0.65
CloseMethod · 0.65
ServeMethod · 0.65
HostnameMethod · 0.45

Tested by 2

TestServeFunction · 0.74
TestWebsocketWrapperFunction · 0.74