Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 249 for Listeners (0.08 sec)

  1. internal/http/listener.go

    			}
    
    			listenErrs[i] = e
    			continue
    		}
    
    		if opts.Trace != nil {
    			opts.Trace(fmt.Sprint("adding listener to ", l.Addr()))
    		}
    
    		listeners = append(listeners, l)
    	}
    
    	if len(listeners) == 0 {
    		// No listeners initialized, no need to continue
    		return
    	}
    
    	listener = &httpListener{
    		listeners: listeners,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 23 10:53:03 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  2. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  3. compat/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,
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 36.7K bytes
    - Viewed (0)
  4. 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: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Apr 04 20:29:08 UTC 2024
    - 2K bytes
    - Viewed (0)
  5. 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 {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Nov 29 12:37:14 UTC 2023
    - 18.1K bytes
    - Viewed (0)
  6. impl/maven-core/src/main/java/org/apache/maven/internal/impl/EventSpyImpl.java

                        InternalMavenSession.from(ee.getSession().getSession());
                Collection<Listener> listeners = session.getListeners();
                if (!listeners.isEmpty()) {
                    Event event = new DefaultEvent(session, ee);
                    for (Listener listener : listeners) {
                        listener.onEvent(event);
                    }
                }
            }
        }
    
        @Override
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  7. compat/maven-compat/src/main/java/org/apache/maven/artifact/resolver/ArtifactResolutionRequest.java

        public List<ResolutionListener> getListeners() {
            return listeners;
        }
    
        public ArtifactResolutionRequest setListeners(List<ResolutionListener> listeners) {
            this.listeners = listeners;
    
            return this;
        }
    
        public ArtifactResolutionRequest addListener(ResolutionListener listener) {
            listeners.add(listener);
    
            return this;
        }
    
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  8. istioctl/pkg/authz/analyzer.go

    		// Support v2 or v3 in config dump. See ads.go:RequestedTypes for more info.
    		l.ActiveState.Listener.TypeUrl = v3.ListenerType
    		err := l.ActiveState.Listener.UnmarshalTo(listenerTyped)
    		if err != nil {
    			return
    		}
    		listeners = append(listeners, listenerTyped)
    	}
    	Print(writer, listeners)
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Jul 13 01:59:17 UTC 2022
    - 2.1K bytes
    - Viewed (0)
  9. 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}.
       */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri May 12 18:32:03 UTC 2023
    - 20.4K bytes
    - Viewed (0)
  10. 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{}{}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Sep 11 15:29:30 UTC 2023
    - 6K bytes
    - Viewed (0)
Back to top