- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 105 for MUX (0.07 sec)
-
pkg/kubelet/config/mux.go
sources map[string]chan interface{} } // newMux creates a new mux that can merge changes from multiple sources. func newMux(merger merger) *mux { mux := &mux{ sources: make(map[string]chan interface{}), merger: merger, } return mux } // ChannelWithContext returns a channel where a configuration source // can send updates of new configurations. Multiple calls with the same
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jan 30 20:02:23 UTC 2024 - 2.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/healthz/healthz_test.go
} } func TestInstallPathHandler(t *testing.T) { mux := http.NewServeMux() InstallPathHandler(mux, "/healthz/test") InstallPathHandler(mux, "/healthz/ready") req, err := http.NewRequest("GET", "http://example.com/healthz/test", nil) if err != nil { t.Fatalf("unexpected error: %v", err) } w := httptest.NewRecorder() mux.ServeHTTP(w, req) if w.Code != http.StatusOK {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 15 20:43:16 UTC 2023 - 11.4K bytes - Viewed (0) -
src/net/http/servemux121.go
} // Formerly ServeMux.Handle. func (mux *serveMux121) handle(pattern string, handler Handler) { mux.mu.Lock() defer mux.mu.Unlock() if pattern == "" { panic("http: invalid pattern") } if handler == nil { panic("http: nil handler") } if _, exist := mux.m[pattern]; exist { panic("http: multiple registrations for " + pattern) } if mux.m == nil { mux.m = make(map[string]muxEntry) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 18 15:40:38 UTC 2024 - 5.8K bytes - Viewed (0) -
prepare_stmt.go
} return nil, ErrInvalidDB } func (db *PreparedStmtDB) Close() { db.Mux.Lock() defer db.Mux.Unlock() for _, query := range db.PreparedSQL { if stmt, ok := db.Stmts[query]; ok { delete(db.Stmts, query) go stmt.Close() } } } func (sdb *PreparedStmtDB) Reset() { sdb.Mux.Lock() defer sdb.Mux.Unlock() for _, stmt := range sdb.Stmts { go stmt.Close() }
Registered: Wed Jun 12 16:27:09 UTC 2024 - Last Modified: Thu Mar 28 08:47:39 UTC 2024 - 6.4K bytes - Viewed (0) -
src/net/http/server_test.go
fmt.Fprintf(w, "OK") } mux := NewServeMux() mux.HandleFunc("/", fn) mux.HandleFunc("/index", fn) mux.HandleFunc("/home", fn) mux.HandleFunc("/about", fn) mux.HandleFunc("/contact", fn) mux.HandleFunc("/robots.txt", fn) mux.HandleFunc("/products/", fn) mux.HandleFunc("/products/1", fn) mux.HandleFunc("/products/2", fn) mux.HandleFunc("/products/3", fn) mux.HandleFunc("/products/3/image.jpg", fn)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 13 13:54:22 UTC 2024 - 7.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/healthz/healthz.go
// "/readyz" 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 InstallReadyzHandler(mux mux, checks ...HealthChecker) { InstallPathHandler(mux, "/readyz", checks...) } // InstallLivezHandler registers handlers for liveness checking on the path // "/livez" to mux. *All handlers* for mux must be specified in
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 19:11:24 UTC 2024 - 10.5K bytes - Viewed (0) -
pilot/pkg/xds/debug.go
s.addDebugHandler(mux, internalMux, "/debug/edsz", "Status and debug interface for EDS", s.Edsz) s.addDebugHandler(mux, internalMux, "/debug/ndsz", "Status and debug interface for NDS", s.ndsz) s.addDebugHandler(mux, internalMux, "/debug/adsz", "Status and debug interface for ADS", s.adsz) s.addDebugHandler(mux, internalMux, "/debug/adsz?push=true", "Initiates push of the current state to all connected endpoints", s.adsz)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 00:26:45 UTC 2024 - 39.5K bytes - Viewed (0) -
pkg/controller/util/selectors/bimultimap.go
func (m *BiMultimap) Exists(key Key) bool { m.mux.RLock() defer m.mux.RUnlock() _, exists := m.labeledObjects[key] return exists } // PutSelector inserts or updates an object with a selector. Associations // are created or updated based on the selector. func (m *BiMultimap) PutSelector(key Key, selector pkglabels.Selector) { m.mux.Lock() defer m.mux.Unlock() selectorKey := selectorKey{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 27 21:41:32 UTC 2023 - 9.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_progress.go
defer timer.Stop() for { stopped := func() bool { pr.mux.Lock() defer pr.mux.Unlock() for pr.waiting == 0 && !pr.stopped { pr.cond.Wait() } return pr.stopped }() if stopped { return } select { case <-timer.C(): shouldRequest := func() bool { pr.mux.Lock() defer pr.mux.Unlock() return pr.waiting > 0 && !pr.stopped }()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 24 09:56:38 UTC 2024 - 3K bytes - Viewed (0) -
src/cmd/trace/main.go
{Type: traceviewer.ViewThread, Ranges: ranges}, })) // Catapult handlers. mux.Handle("/trace", traceviewer.TraceHandler()) mux.Handle("/jsontrace", JSONTraceHandler(parsed)) mux.Handle("/static/", traceviewer.StaticHandler()) // Goroutines handlers. mux.HandleFunc("/goroutines", GoroutinesHandlerFunc(parsed.summary.Goroutines)) mux.HandleFunc("/goroutine", GoroutineHandler(parsed.summary.Goroutines)) // MMU handler.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 10.4K bytes - Viewed (0)