- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 134 for dispatchTo (0.18 sec)
-
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/metrics/metrics.go
) apiserverDispatchR = compbasemetrics.NewGaugeVec( &compbasemetrics.GaugeOpts{ Namespace: namespace, Subsystem: subsystem, Name: "dispatch_r", Help: "R(time of last dispatch)", StabilityLevel: compbasemetrics.ALPHA, }, []string{priorityLevel}, ) apiserverLatestS = compbasemetrics.NewGaugeVec( &compbasemetrics.GaugeOpts{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 24 19:40:05 UTC 2023 - 25.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/queueset.go
// win in the case that the virtual finish times are the same qs.robinIndex = minIndex if minQueue.nextDispatchR < oldestReqFromMinQueue.arrivalR { klog.ErrorS(errors.New("dispatch before arrival"), "Inconceivable!", "QS", qs.qCfg.Name, "queue", minQueue.index, "dispatchR", minQueue.nextDispatchR, "request", oldestReqFromMinQueue) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jan 04 16:59:21 UTC 2024 - 42.4K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt
/** * The dispatcher used to respond to HTTP requests. The default dispatcher is a [QueueDispatcher], * which serves a fixed sequence of responses from a [queue][enqueue]. * * Other dispatchers can be configured. They can vary the response based on timing or the content * of the request. */ var dispatcher: Dispatcher = QueueDispatcher() private var portField: Int = -1
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sun Mar 31 17:16:15 UTC 2024 - 37.4K bytes - Viewed (0) -
mockwebserver-deprecated/api/mockwebserver.api
public abstract class okhttp3/mockwebserver/Dispatcher { public fun <init> ()V public abstract fun dispatch (Lokhttp3/mockwebserver/RecordedRequest;)Lokhttp3/mockwebserver/MockResponse; public fun peek ()Lokhttp3/mockwebserver/MockResponse; public fun shutdown ()V } public final class okhttp3/mockwebserver/MockResponse : java/lang/Cloneable { public static final field Companion Lokhttp3/mockwebserver/MockResponse$Companion;
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Jul 22 12:28:51 UTC 2023 - 10.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/generic/policy_dispatcher.go
matcher *matching.Matcher, delegate dispatcherDelegate[P, B, E], ) Dispatcher[PolicyHook[P, B, E]] { return &policyDispatcher[P, B, E]{ newPolicyAccessor: newPolicyAccessor, newBindingAccessor: newBindingAccessor, matcher: NewPolicyMatcher(matcher), delegate: delegate, } } // Dispatch implements generic.Dispatcher. It loops through all active hooks
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 12.1K bytes - Viewed (0) -
mockwebserver/api/mockwebserver3.api
public abstract class mockwebserver3/Dispatcher { public fun <init> ()V public abstract fun dispatch (Lmockwebserver3/RecordedRequest;)Lmockwebserver3/MockResponse; public fun peek ()Lmockwebserver3/MockResponse; public fun shutdown ()V } public final class mockwebserver3/MockResponse { public static final field Companion Lmockwebserver3/MockResponse$Companion; public fun <init> ()V public fun <init> (I)V public fun <init> (ILokhttp3/Headers;)V
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Tue Jan 03 21:59:45 UTC 2023 - 12.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/KotlinSourceModernTest.kt
} @Test fun dispatcher() { var dispatcher = Dispatcher() dispatcher = Dispatcher(Executors.newCachedThreadPool()) val maxRequests: Int = dispatcher.maxRequests dispatcher.maxRequests = 0 val maxRequestsPerHost: Int = dispatcher.maxRequestsPerHost dispatcher.maxRequestsPerHost = 0 val executorService: ExecutorService = dispatcher.executorService
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Apr 01 14:21:25 UTC 2024 - 46.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/DispatcherTest.kt
object : WebSocketListener() { } val dispatcher = Dispatcher(executor) val listener = RecordingEventListener() var client = clientTestRule.newClientBuilder() .dns { throw UnknownHostException() } .dispatcher(dispatcher) .eventListenerFactory(clientTestRule.wrap(listener)) .build() @BeforeEach fun setUp() { dispatcher.maxRequests = 20 dispatcher.maxRequestsPerHost = 10
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Fri Apr 05 03:30:42 UTC 2024 - 12.7K bytes - Viewed (0) -
maven-core/src/test/java/org/apache/maven/internal/impl/TestApi.java
// If caller wants only a classpath, JUnit shall move there. dispatched = session.resolveDependencies(coord, PathScope.TEST_COMPILE, Arrays.asList(JavaPathType.CLASSES)); classes = dispatched.get(JavaPathType.CLASSES); modules = dispatched.get(JavaPathType.MODULES); unresolved = dispatched.get(PathType.UNRESOLVED); assertEquals(2, dispatched.size()); assertEquals(1, unresolved.size());
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Thu Apr 25 14:13:36 UTC 2024 - 9.9K bytes - Viewed (0) -
src/runtime/asm_wasm.s
DISPATCH(runtime·call128, 128) DISPATCH(runtime·call256, 256) DISPATCH(runtime·call512, 512) DISPATCH(runtime·call1024, 1024) DISPATCH(runtime·call2048, 2048) DISPATCH(runtime·call4096, 4096) DISPATCH(runtime·call8192, 8192) DISPATCH(runtime·call16384, 16384) DISPATCH(runtime·call32768, 32768) DISPATCH(runtime·call65536, 65536) DISPATCH(runtime·call131072, 131072) DISPATCH(runtime·call262144, 262144)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Nov 20 21:26:51 UTC 2023 - 11.8K bytes - Viewed (0)