- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 235 for listeners (0.27 sec)
-
internal/http/listener.go
func (listener *httpListener) Close() (err error) { listener.ctxCanceler() for i := range listener.listeners { listener.listeners[i].Close() } return nil } // Addr - net.Listener interface compatible method returns net.Addr. In case of multiple TCP listeners, it returns '0.0.0.0' as IP address. func (listener *httpListener) Addr() (addr net.Addr) { addr = listener.listeners[0].Addr()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 5.6K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/configdump/listener.go
if l.Listener != nil { listenerTyped := &listener.Listener{} // Support v2 or v3 in config dump. See ads.go:RequestedTypes for more info. l.Listener.TypeUrl = v3.ListenerType err = l.Listener.UnmarshalTo(listenerTyped) if err != nil { return nil, fmt.Errorf("unmarshal listener: %v", err) } listeners = append(listeners, listenerTyped) } } if len(listeners) == 0 {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Nov 29 12:37:14 GMT 2023 - 18.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractService.java
} /** @since 13.0 */ @Override public final void addListener(Listener listener, Executor executor) { listeners.addListener(listener, executor); } @Override public String toString() { return getClass().getSimpleName() + " [" + state() + "]"; } /** * Attempts to execute all the listeners in {@link #listeners} while not holding the {@link * #monitor}. */
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Fri May 12 18:32:03 GMT 2023 - 20.4K bytes - Viewed (0) -
istioctl/pkg/authz/listener.go
return "", "" } return fmt.Sprintf("%s.%s", parts[2], parts[1]), parts[3] } // Print prints the AuthorizationPolicy in the listener. func Print(writer io.Writer, listeners []*listener.Listener) { parsedListeners := parse(listeners) if parsedListeners == nil { return } actionToPolicy := map[rbacpb.RBAC_Action]map[string]struct{}{} policyToRule := map[string]map[string]struct{}{}
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Sep 11 15:29:30 GMT 2023 - 6K 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 {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Apr 04 20:29:08 GMT 2024 - 2K bytes - Viewed (0) -
maven-compat/src/main/java/org/apache/maven/repository/legacy/resolver/DefaultLegacyArtifactCollector.java
return updateScope; } private void fireEvent(int event, List<ResolutionListener> listeners, ResolutionNode node) { fireEvent(event, listeners, node, null); } private void fireEvent(int event, List<ResolutionListener> listeners, ResolutionNode node, Artifact replacement) { fireEvent(event, listeners, node, replacement, null); } private void fireEvent( int event,
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Wed Sep 06 11:28:54 GMT 2023 - 36.7K bytes - Viewed (0) -
maven-core/src/test/java/org/apache/maven/lifecycle/DelegatingProjectExecutionListener.java
for (ProjectExecutionListener listener : listeners) { listener.afterProjectExecutionFailure(event); } } public void addProjectExecutionListener(ProjectExecutionListener listener) { this.listeners.add(listener); } public void removeProjectExecutionListener(ProjectExecutionListener listener) { this.listeners.remove(listener); }
Java - Registered: Sun Apr 28 03:35:10 GMT 2024 - Last Modified: Mon Dec 26 15:12:32 GMT 2022 - 2.4K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/plugin/CompoundMojoExecutionListener.java
private final Collection<MojoExecutionListener> listeners; CompoundMojoExecutionListener(Collection<MojoExecutionListener> listeners) { this.listeners = listeners; // NB this is live injected collection } public void beforeMojoExecution(MojoExecutionEvent event) throws MojoExecutionException { for (MojoExecutionListener listener : listeners) { listener.beforeMojoExecution(event); } }
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Mon Dec 26 15:12:32 GMT 2022 - 1.9K bytes - Viewed (0) -
futures/listenablefuture1/src/com/google/common/util/concurrent/ListenableFuture.java
* MoreExecutors#directExecutor}. Otherwise, avoid it: See the warnings on the docs for {@code * directExecutor}. * * <p>This is the most general listener interface. For common operations performed using * listeners, see {@link Futures}. For a simplified but general listener interface, see {@link * Futures#addCallback addCallback()}. *
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Jun 26 21:13:41 GMT 2023 - 8K bytes - Viewed (0) -
maven-core/src/test/java/org/apache/maven/lifecycle/DelegatingMojoExecutionListener.java
for (MojoExecutionListener listener : listeners) { listener.afterMojoExecutionSuccess(event); } } public void afterExecutionFailure(MojoExecutionEvent event) { for (MojoExecutionListener listener : listeners) { listener.afterExecutionFailure(event); } } public void addMojoExecutionListener(MojoExecutionListener listener) { this.listeners.add(listener);
Java - Registered: Sun Apr 28 03:35:10 GMT 2024 - Last Modified: Mon Dec 26 15:12:32 GMT 2022 - 2.2K bytes - Viewed (0)