- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 181 for dispatchTo (0.26 sec)
-
staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/generic/webhook.go
*admission.Handler sourceFactory sourceFactory hookSource Source clientManager *webhookutil.ClientManager namespaceMatcher *namespace.Matcher objectMatcher *object.Matcher dispatcher Dispatcher filterCompiler cel.FilterCompiler authorizer authorizer.Authorizer } var ( _ genericadmissioninit.WantsExternalKubeClientSet = &Webhook{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 22:07:40 UTC 2024 - 9.3K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/api/DaemonConnection.java
*/ void onCancel(@Nullable Runnable handler); /** * Dispatches a daemon unavailable message to the client. */ void daemonUnavailable(DaemonUnavailable unavailable); /** * Dispatches a build started message to the client. */ void buildStarted(BuildStarted buildStarted); /** * Dispatches a log event message to the client. */ void logEvent(OutputEvent logEvent);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:51:37 UTC 2024 - 3.8K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/SynchronizedDispatchConnection.java
// Safety check: dispatching a message should not cause the thread to dispatch another message (eg should not do any logging) throw new IllegalStateException("This thread is already dispatching a message."); } dispatching = true; try { delegate.dispatch(message); delegate.flush(); } finally {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jan 26 14:58:23 UTC 2024 - 3K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/dispatch/ContextClassLoaderProxy.java
* limitations under the License. */ package org.gradle.internal.dispatch; /** * Creates a proxy object which sets the context ClassLoader when invoking methods on the target object. */ public class ContextClassLoaderProxy<T> { private final ProxyDispatchAdapter<T> adapter; /** * Creates a proxy which dispatches to the given target object. */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 13:09:37 UTC 2024 - 1.2K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/dispatch/DispatchFailureHandler.java
* See the License for the specific language governing permissions and * limitations under the License. */ package org.gradle.internal.dispatch; public interface DispatchFailureHandler<T> { /** * Called when a message could not be dispatched. This method can throw an exception to abort further dispatching. */ void dispatchFailed(T message, Throwable failure);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 892 bytes - Viewed (0) -
samples/bookinfo/src/ratings/ratings.js
ratings: { 'Reviewer1': 5, 'Reviewer2': 4 } } } function handleRequest (request, response) { try { console.log(request.method + ' ' + request.url) dispatcher.dispatch(request, response) } catch (err) { console.log(err) } } var server = http.createServer(handleRequest) process.on('SIGTERM', function () { console.log("SIGTERM received")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Sep 02 00:29:57 UTC 2022 - 8.8K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/exec/DaemonConnectionBackedEventConsumer.java
import java.util.concurrent.BlockingQueue; import java.util.concurrent.LinkedBlockingQueue; import java.util.concurrent.TimeUnit; /** * An event consumer that asynchronously dispatches events to the client. */ class DaemonConnectionBackedEventConsumer implements BuildEventConsumer { private final DaemonCommandExecution execution;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 2.9K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/ObjectConnectionBuilder.java
public interface ObjectConnectionBuilder { /** * Creates a transmitter for outgoing messages on the given type. The returned object is thread-safe. * * <p>Method invocations on the transmitter object are dispatched asynchronously to a corresponding handler in the peer. Method invocations are * called on the handler in the same order that they were called on the transmitter object.</p> * * @param type The type
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 05 19:36:14 UTC 2023 - 2.8K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/eventspy/internal/EventSpyExecutionListener.java
private final EventSpyDispatcher dispatcher; private final ExecutionListener delegate; EventSpyExecutionListener(EventSpyDispatcher dispatcher, ExecutionListener delegate) { this.dispatcher = dispatcher; this.delegate = delegate; } @Override public void projectDiscoveryStarted(ExecutionEvent event) { dispatcher.onEvent(event);
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Tue Nov 22 13:26:01 UTC 2022 - 3.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/validating/plugin.go
}, func(a authorizer.Authorizer, m *matching.Matcher) generic.Dispatcher[PolicyHook] { return NewDispatcher(a, generic.NewPolicyMatcher(m)) }, ), } } // Validate makes an admission decision based on the request attributes. func (a *Plugin) Validate(ctx context.Context, attr admission.Attributes, o admission.ObjectInterfaces) error { return a.Plugin.Dispatch(ctx, attr, o) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 22:07:40 UTC 2024 - 7.5K bytes - Viewed (0)