- Sort Score
- Num 10 results
- Language All
Results 101 - 110 of 154 for routers (0.06 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
cmd/lock-rest-server.go
return &dsync.LockArgs{} }, func() *dsync.LockResp { return &dsync.LockResp{} }) } // registerLockRESTHandlers - register lock rest router. func registerLockRESTHandlers(gm *grid.Manager) { lockServer := &lockRESTServer{ ll: newLocker(), } logger.FatalIf(lockRPCForceUnlock.Register(gm, lockServer.ForceUnlockHandler), "unable to register handler")
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Jan 31 19:54:34 GMT 2025 - 6.3K bytes - Click Count (0) -
internal/kms/kms.go
// latency and update its and all subsequent counters. bucket := slices.IndexFunc(k.latencyBuckets, func(b time.Duration) bool { return latency < b }) if bucket < 0 { bucket = len(k.latencyBuckets) - 1 } for i := bucket; i < len(k.latency); i++ { k.latency[i].Add(1) } // Next, update the request counters if err == nil { k.reqOK.Add(1) return }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Thu Apr 24 15:33:57 GMT 2025 - 11.4K bytes - Click Count (0) -
cmd/storage-rest-server.go
// // Any updates to this must be serialized via globalLocalDrivesMu (locker) var globalLocalSetDrives [][][]StorageAPI // registerStorageRESTHandlers - register storage rpc router. func registerStorageRESTHandlers(router *mux.Router, endpointServerPools EndpointServerPools, gm *grid.Manager) { h := func(f http.HandlerFunc) http.HandlerFunc { return collectInternodeStats(httpTraceHdrs(f)) }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue May 27 15:19:03 GMT 2025 - 45.7K bytes - Click Count (0) -
cmd/bootstrap-peer-server.go
var serverVerifyHandler = grid.NewSingleHandler[*grid.MSS, *ServerSystemConfig](grid.HandlerServerVerify, grid.NewMSS, func() *ServerSystemConfig { return &ServerSystemConfig{} }) // registerBootstrapRESTHandlers - register bootstrap rest router. func registerBootstrapRESTHandlers(gm *grid.Manager) { server := &bootstrapRESTServer{} logger.FatalIf(serverVerifyHandler.Register(gm, server.VerifyHandler), "unable to register handler") }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Oct 01 22:13:18 GMT 2024 - 8.4K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/app/pager/RelatedContentPager.java
public String createdTime; /** Version number for optimistic locking. */ public String versionNo; /** * Clears all pagination state and filter parameters. * Resets pagination counters to default values and clears all filter fields. */ public void clear() { allRecordCount = 0; allPageCount = 0; existPrePage = false; existNextPage = false;Created: Sat Dec 20 09:19:18 GMT 2025 - Last Modified: Thu Jul 17 08:28:31 GMT 2025 - 6.8K bytes - Click Count (0) -
src/test/java/jcifs/audit/SecurityAuditLoggerTest.java
logger.resetStatistics(); Map<EventType, Long> statsAfter = logger.getStatistics(); // After reset, all counters should be 0 for (Long count : statsAfter.values()) { assertEquals(Long.valueOf(0), count, "All statistics should be 0 after reset"); } } @TestCreated: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Sat Aug 30 05:58:03 GMT 2025 - 8.6K bytes - Click Count (0) -
compat/maven-model-builder/src/test/resources/dag.txt
quarkus/extensions/arc/runtime/pom.xml quarkus/extensions/vertx-http/runtime/pom.xml quarkus/extensions/reactive-routes/deployment/pom.xml quarkus/extensions/vertx-http/deployment/pom.xml quarkus/extensions/vertx/deployment/pom.xml quarkus/extensions/jackson/deployment/pom.xml quarkus/extensions/reactive-routes/runtime/pom.xml quarkus/extensions/hibernate-validator/spi/pom.xml quarkus/extensions/jsonp/deployment/pom.xml
Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Fri Oct 25 12:31:46 GMT 2024 - 224K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/HttpOverHttp2Test.kt
assertThat(response.body.string()).isEqualTo("abc") assertThat(server.takeRequest().exchangeIndex).isEqualTo(0) // Note that although we have two routes available, we only use one. The retry is permitted // because there are routes available, but it chooses the existing connection since it isn't // yet considered unhealthy. assertThat(server.takeRequest().exchangeIndex).isEqualTo(1) } @Test
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Sat Nov 01 12:18:11 GMT 2025 - 67.4K bytes - Click Count (0) -
docs/en/docs/features.md
* <a href="https://github.com/OAI/OpenAPI-Specification" class="external-link" target="_blank"><strong>OpenAPI</strong></a> for API creation, including declarations of <abbr title="also known as: endpoints, routes">path</abbr> <abbr title="also known as HTTP methods, as POST, GET, PUT, DELETE">operations</abbr>, parameters, request bodies, security, etc.
Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Sat Oct 11 17:48:49 GMT 2025 - 9.5K bytes - Click Count (0) -
docs/tr/docs/features.md
### Açık standartları temel alır * API oluşturma işlemlerinde <a href="https://github.com/OAI/OpenAPI-Specification" class="external-link" target="_blank"><strong>OpenAPI</strong></a> buna <abbr title="also known as: endpoints, routes">path</abbr> <abbr title=" HTTP metodları olarak bilinen, POST, GET, PUT, DELETE">operasyonları </abbr>parametreleri, body talebi, güvenlik gibi şeyler dahil olmak üzere deklare bunların deklare edilmesi.
Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Sat Oct 11 17:48:49 GMT 2025 - 11.1K bytes - Click Count (0)