Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for install_handler (0.17 sec)

  1. src/cmd/cgo/internal/testcarchive/testdata/main.c

    // license that can be found in the LICENSE file.
    
    #include <stdint.h>
    #include <stdio.h>
    #include <string.h>
    
    #include "p.h"
    #include "libgo.h"
    
    extern int install_handler();
    extern int check_handler();
    
    int main(void) {
    	int32_t res;
    
    	int r1 = install_handler();
    	if (r1!=0) {
    		return r1;
    	}
    
    	if (!DidInitRun()) {
    		fprintf(stderr, "ERROR: buildmode=c-archive init should run\n");
    		return 2;
    	}
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 12 11:59:56 UTC 2023
    - 847 bytes
    - Viewed (0)
  2. src/cmd/cgo/internal/testcarchive/testdata/main_windows.c

    // Use of this source code is governed by a BSD-style
    // license that can be found in the LICENSE file.
    
    /*
     * Dummy implementations for Windows, because Windows doesn't
     * support Unix-style signal handling.
     */
    
    int install_handler() {
    	return 0;
    }
    
    
    int check_handler() {
    	return 0;
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 12 11:59:56 UTC 2023
    - 343 bytes
    - Viewed (0)
  3. src/cmd/cgo/internal/testcarchive/testdata/main_unix.c

    struct sigaction osa;
    
    static void (*oldHandler)(int, siginfo_t*, void*);
    
    static void handler(int signo, siginfo_t* info, void* ctxt) {
    	if (oldHandler) {
    		oldHandler(signo, info, ctxt);
    	}
    }
    
    int install_handler() {
    	// Install our own signal handler.
    	memset(&sa, 0, sizeof sa);
    	sa.sa_sigaction = handler;
    	sigemptyset(&sa.sa_mask);
    	sa.sa_flags = SA_ONSTACK | SA_SIGINFO;
    	memset(&osa, 0, sizeof osa);
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 12 11:59:56 UTC 2023
    - 1.4K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/server/healthz/healthz.go

    	return &healthzCheck{name, check}
    }
    
    // InstallHandler registers handlers for health checking on the path
    // "/healthz" to mux. *All handlers* for mux must be specified in
    // exactly one call to InstallHandler. Calling InstallHandler more
    // than once for the same mux will result in a panic.
    func InstallHandler(mux mux, checks ...HealthChecker) {
    	InstallPathHandler(mux, "/healthz", checks...)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 27 19:11:24 UTC 2024
    - 10.5K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/server/healthz.go

    */
    
    package server
    
    import (
    	"fmt"
    	"net/http"
    	"sync"
    	"time"
    
    	"k8s.io/apiserver/pkg/server/healthz"
    	"k8s.io/utils/clock"
    )
    
    // healthMux is an interface describing the methods InstallHandler requires.
    type healthMux interface {
    	Handle(pattern string, handler http.Handler)
    }
    
    type healthCheckRegistry struct {
    	path            string
    	lock            sync.Mutex
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 27 19:11:24 UTC 2024
    - 6K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiserver/pkg/server/healthz/doc.go

    limitations under the License.
    */
    
    // Package healthz implements basic http server health checking.
    // Usage:
    //
    //	import "k8s.io/apiserver/pkg/server/healthz"
    //	healthz.InstallHandler(mux)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jul 26 17:14:05 UTC 2022
    - 792 bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiserver/pkg/server/healthz/healthz_test.go

    	"k8s.io/apiserver/pkg/endpoints/metrics"
    	"k8s.io/component-base/metrics/legacyregistry"
    	"k8s.io/component-base/metrics/testutil"
    )
    
    func TestInstallHandler(t *testing.T) {
    	mux := http.NewServeMux()
    	InstallHandler(mux)
    	req, err := http.NewRequest("GET", "http://example.com/healthz", nil)
    	if err != nil {
    		t.Fatalf("unexpected error: %v", err)
    	}
    	w := httptest.NewRecorder()
    	mux.ServeHTTP(w, req)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 15 20:43:16 UTC 2023
    - 11.4K bytes
    - Viewed (0)
  8. cmd/kube-scheduler/app/server.go

    	return handler
    }
    
    func installMetricHandler(pathRecorderMux *mux.PathRecorderMux, informers informers.SharedInformerFactory, isLeader func() bool) {
    	configz.InstallHandler(pathRecorderMux)
    	pathRecorderMux.Handle("/metrics", legacyregistry.HandlerWithReset())
    
    	resourceMetricsHandler := resources.Handler(informers.Core().V1().Pods().Lister())
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 27 19:11:24 UTC 2024
    - 14.3K bytes
    - Viewed (0)
  9. pkg/kubelet/server/server.go

    }
    
    // InstallDefaultHandlers registers the default set of supported HTTP request
    // patterns with the restful Container.
    func (s *Server) InstallDefaultHandlers() {
    	s.addMetricsBucketMatcher("healthz")
    	healthz.InstallHandler(s.restfulCont,
    		healthz.PingHealthz,
    		healthz.LogHealthz,
    		healthz.NamedCheck("syncloop", s.syncLoopHealthCheck),
    	)
    
    	slis.SLIMetricsWithReset{}.Install(s.restfulCont)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 40.1K bytes
    - Viewed (0)
  10. cmd/kube-proxy/app/server.go

    func serveMetrics(bindAddress string, proxyMode kubeproxyconfig.ProxyMode, enableProfiling bool, errCh chan error) {
    	if len(bindAddress) == 0 {
    		return
    	}
    
    	proxyMux := mux.NewPathRecorderMux("kube-proxy")
    	healthz.InstallHandler(proxyMux)
    	slis.SLIMetricsWithReset{}.Install(proxyMux)
    
    	proxyMux.HandleFunc("/proxyMode", func(w http.ResponseWriter, r *http.Request) {
    		w.Header().Set("Content-Type", "text/plain; charset=utf-8")
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 26 13:27:41 UTC 2024
    - 46.8K bytes
    - Viewed (0)
Back to top