- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 548 for listener2 (0.47 sec)
-
staging/src/k8s.io/apiextensions-apiserver/test/integration/ratcheting_test_cases/invalid/gateway/invalid-listener-port.yaml
apiVersion: gateway.networking.k8s.io/v1beta1 kind: Gateway metadata: name: invalid-listener-port spec: gatewayClassName: acme-lb listeners: - name: foo protocol: HTTP
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 27 17:15:18 UTC 2023 - 200 bytes - Viewed (0) -
istioctl/pkg/writer/compare/listener.go
} diff := difflib.UnifiedDiff{ FromFile: "Istiod Listeners", A: difflib.SplitLines(istiodBytes.String()), ToFile: "Envoy Listeners", B: difflib.SplitLines(envoyBytes.String()), Context: c.context, } text, err := difflib.GetUnifiedDiffString(diff) if err != nil { return err } if text != "" { fmt.Fprintln(c.w, "Listeners Don't Match") fmt.Fprintln(c.w, text) } else {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 04 20:29:08 UTC 2024 - 2K bytes - Viewed (0) -
cni/pkg/pluginlistener/listener.go
} var err error listener, err := net.Listen("unix", path) if err != nil { return nil, fmt.Errorf("failed to listen on unix socket %q: %v", path, err) } // Update file permission so that cni plugin has permission to access it. if _, err := os.Stat(path); err != nil { return nil, fmt.Errorf("cni listener file %q doesn't exist", path) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 26 20:34:28 UTC 2024 - 1.7K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/test/integration/ratcheting_test_cases/invalid/gateway/duplicate-listeners.yaml
apiVersion: gateway.networking.k8s.io/v1beta1 kind: Gateway metadata: name: duplicate-listeners spec: gatewayClassName: acme-lb listeners: - name: same protocol: HTTP port: 80 - name: same protocol: HTTP
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 27 17:15:18 UTC 2023 - 240 bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/event/ListenerManager.java
* T, the listener will be unregistered with it if <code>(listener instanceof T)</code> returns true. * * <p>When this method returns, the listener will not be in use and will not receive any further events. * * @param listener the listener to remove. */ void removeListener(Object listener); /** * Allows a client to query if any listeners of a particular type are currently registered.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Mar 12 02:21:10 UTC 2024 - 5.6K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/lifecycle/internal/CompoundProjectExecutionListener.java
private final Collection<ProjectExecutionListener> listeners; CompoundProjectExecutionListener(Collection<ProjectExecutionListener> listeners) { this.listeners = listeners; // NB this is live injected collection } @Override public void beforeProjectExecution(ProjectExecutionEvent event) throws LifecycleExecutionException { for (ProjectExecutionListener listener : listeners) {
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Wed Jan 10 12:55:54 UTC 2024 - 2.3K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/event/ListenerBroadcast.java
} /** * Adds a listener. * * @param listener The listener. */ public void add(T listener) { broadcast = broadcast.add(listener); } /** * Adds the given listeners. * * @param listeners The listeners */ public void addAll(Collection<? extends T> listeners) { broadcast = broadcast.addAll(listeners); } /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 4.5K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/tooling/internal/provider/SubscribableBuildActionExecutor.java
for (Object listener : factory.createListeners(clientSubscriptions, eventConsumer)) { registerListener(listener); } } private void registerListener(Object listener) { listeners.add(listener); listenerManager.addListener(listener); if (listener instanceof BuildOperationListener) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 3.9K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ListenerCallQueue.java
*/ public void addListener(L listener, Executor executor) { checkNotNull(listener, "listener"); checkNotNull(executor, "executor"); listeners.add(new PerListenerQueue<>(listener, executor)); } /** * Enqueues an event to be run on currently known listeners. * * <p>The {@code toString} method of the Event itself will be used to describe the event in the * case of an error.
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Dec 13 19:45:20 UTC 2023 - 8.2K bytes - Viewed (0) -
internal/grid/debug.go
} } addr := l.Addr() hosts = append(hosts, "http://"+addr.String()) listeners = append(listeners, l) } return } func startHTTPServer(listener net.Listener, handler http.Handler) (server *httptest.Server) { server = httptest.NewUnstartedServer(handler) server.Config.Addr = listener.Addr().String() server.Listener = listener server.Start() return server
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 4.2K bytes - Viewed (0)