Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for HandleFunc (0.42 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. istioctl/pkg/admin/istiodconfig_test.go

    	case http.MethodGet:
    		_, _ = writer.Write([]byte(getResponse))
    	}
    }
    
    func setupHTTPServer() (*httptest.Server, *url.URL) {
    	handler := http.NewServeMux()
    	handler.HandleFunc("/scopej/ads", adsHandler)
    	handler.HandleFunc("/scopej/resource", resourceHandler)
    	server := httptest.NewServer(handler)
    	url, _ := url.Parse(server.URL)
    	return server, url
    }
    
    func Test_flagState_run(t *testing.T) {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Jun 15 15:02:17 UTC 2023
    - 6.2K bytes
    - Viewed (0)
  4. 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)
  5. docs/sts/web-identity.go

    			TokenURL: ddoc.TokenEndpoint,
    		},
    		RedirectURL: fmt.Sprintf("http://10.0.0.67:%d/oauth2/callback", port),
    		Scopes:      scopes,
    	}
    
    	state := randomState()
    
    	http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
    		log.Printf("%s %s", r.Method, r.RequestURI)
    		if r.RequestURI != "/" {
    			http.NotFound(w, r)
    			return
    		}
    		if clientSec != "" {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 19 09:13:33 UTC 2023
    - 7.8K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. 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