Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for HandleFunc (0.06 sec)

  1. cni/pkg/nodeagent/healthServer.go

    	installReady = &atomic.Value{}
    	watchReady = &atomic.Value{}
    	installReady.Store(false)
    	watchReady.Store(false)
    
    	router.HandleFunc(constants.LivenessEndpoint, healthz)
    	router.HandleFunc(constants.ReadinessEndpoint, readyz(installReady, watchReady))
    
    	return
    }
    
    func healthz(w http.ResponseWriter, _ *http.Request) {
    	w.WriteHeader(http.StatusOK)
    }
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Apr 15 01:29:35 UTC 2024
    - 1.8K bytes
    - Viewed (0)
  2. docs/auditlog/auditlog-echo.go

    	var out bytes.Buffer
    	json.Indent(&out, body, "", "    ")
    	log.Printf("%s\n", out.String())
    
    	w.WriteHeader(http.StatusOK)
    }
    
    func main() {
    	flag.Parse()
    	http.HandleFunc("/", mainHandler)
    
    	log.Printf("Listening on :%d\n", port)
    	log.Fatal(http.ListenAndServe(fmt.Sprintf(":%d", port), nil))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 01 21:31:13 UTC 2024
    - 1.5K bytes
    - Viewed (0)
  3. docs/iam/access-manager-plugin.go

    			log.Fatal("Please provide both a key file and a cert file to enable TLS.")
    		}
    		serveFunc = func() error {
    			return http.ListenAndServeTLS(":8080", certFile, keyFile, nil)
    		}
    	}
    
    	http.HandleFunc("/", mainHandler)
    
    	log.Print("Listening on :8080")
    	log.Fatal(serveFunc())
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Feb 08 17:15:20 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  4. docs/iam/identity-manager-plugin.go

    		return
    	}
    
    	fmt.Printf("Allowed for token: %s user: %s\n", token, rsp.User)
    
    	w.WriteHeader(http.StatusOK)
    	json.NewEncoder(w).Encode(rsp)
    	return
    }
    
    func main() {
    	http.HandleFunc("/", mainHandler)
    
    	log.Print("Listening on :8081")
    	log.Fatal(http.ListenAndServe(":8081", nil))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 01 21:31:13 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  5. cni/pkg/nodeagent/cni-watcher.go

    		dataplane: dataplane,
    		cniListenServer: &http.Server{
    			Handler: mux,
    		},
    		cniListenServerCancel: cancel,
    		sockAddress:           pluginSocket,
    		ctx:                   ctx,
    	}
    
    	mux.HandleFunc(pconstants.CNIAddEventPath, s.handleAddEvent)
    	return s
    }
    
    func (s *CniPluginServer) Stop() {
    	s.cniListenServerCancel()
    }
    
    // Start starts up a UDS server which receives events from the CNI chain plugin.
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Jul 02 18:48:50 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  6. cni/pkg/log/uds.go

    	Msg       string         `json:"msg"`
    	Arbitrary map[string]any `json:"-"`
    }
    
    func NewUDSLogger(level istiolog.Level) *UDSLogger {
    	l := &UDSLogger{}
    	mux := http.NewServeMux()
    	mux.HandleFunc(constants.UDSLogPath, l.handleLog)
    	loggingServer := &http.Server{
    		Handler: mux,
    	}
    	l.loggingServer = loggingServer
    	pluginLog.SetOutputLevel(level)
    	return l
    }
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jun 28 19:12:54 UTC 2024
    - 4.7K bytes
    - Viewed (0)
Back to top