Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 145 for listen (0.11 sec)

  1. cmd/listen-notification-handlers.go

    			return
    		}
    	}
    
    	rulesMap := event.NewRulesMap(eventNames, pattern, event.TargetID{ID: mustGetUUID()})
    
    	setEventStreamHeaders(w)
    
    	// Listen Publisher and peer-listen-client uses nonblocking send and hence does not wait for slow receivers.
    	// Use buffered channel to take care of burst sends or slow w.Write()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 6K bytes
    - Viewed (0)
  2. docs/de/docs/tutorial/body-nested-models.md

    ```
    
    ////
    
    Das bewirkt, dass `tags` eine Liste ist, wenngleich es nichts über den Typ der Elemente der Liste aussagt.
    
    ## Listen mit Typ-Parametern als Felder
    
    Aber Python erlaubt es, Listen mit inneren Typen, auch „Typ-Parameter“ genannt, zu deklarieren.
    
    ### `List` von `typing` importieren
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  3. internal/http/listener.go

    		case <-listener.ctx.Done():
    			return false
    		}
    	}
    
    	// Closure to handle TCPListener until done channel is closed.
    	handleListener := func(idx int, listener net.Listener) {
    		for {
    			conn, err := listener.Accept()
    			send(acceptResult{conn, err, idx})
    		}
    	}
    
    	// Start separate goroutine for each TCP listener to handle connection.
    	for idx, tcpListener := range listener.listeners {
    		go handleListener(idx, tcpListener)
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 23 10:53:03 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  4. internal/grid/debug.go

    				panic(err)
    			}
    		}
    	}
    }
    
    func getHosts(n int) (hosts []string, listeners []net.Listener, err error) {
    	for i := 0; i < n; i++ {
    		l, err := net.Listen("tcp", "127.0.0.1:0")
    		if err != nil {
    			if l, err = net.Listen("tcp6", "[::1]:0"); err != nil {
    				return nil, nil, fmt.Errorf("httptest: failed to listen on a port: %v", err)
    			}
    		}
    		addr := l.Addr()
    		hosts = append(hosts, "http://"+addr.String())
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  5. cni/pkg/nodeagent/cni-watcher.go

    			// If the cniListener exits, at least we should record an error log
    			log.Errorf("CNI listener server exiting unexpectedly: %v", err)
    		}
    	}()
    
    	context.AfterFunc(s.ctx, func() {
    		if err := s.cniListenServer.Close(); err != nil {
    			log.Errorf("CNI listen server terminated with error: %v", err)
    		} else {
    			log.Debug("CNI listen server terminated")
    		}
    	})
    	return nil
    }
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Jul 02 18:48:50 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  6. internal/logger/logrotate.go

    	w.pw.CloseWithError(nil)
    
    	if w.f != nil {
    		if err := w.closeCurrentFile(); err != nil {
    			return err
    		}
    	}
    
    	return nil
    }
    
    var stdErrEnc = json.NewEncoder(os.Stderr)
    
    func (w *Writer) listen() {
    	for {
    		var r io.Reader = w.pr
    		if w.opts.MaximumFileSize > 0 {
    			r = io.LimitReader(w.pr, w.opts.MaximumFileSize)
    		}
    		if _, err := io.Copy(w.f, r); err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  7. docs/de/docs/tutorial/extra-models.md

    ## Listen von Modellen
    
    Genauso können Sie eine Response deklarieren, die eine Liste von Objekten ist.
    
    Verwenden Sie dafür Pythons Standard `typing.List` (oder nur `list` in Python 3.9 und darüber):
    
    //// tab | Python 3.9+
    
    ```Python hl_lines="18"
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 8.7K bytes
    - Viewed (0)
  8. docs/en/docs/advanced/behind-a-proxy.md

    Probably in many cases the default will be that the proxy doesn't have a stripped path prefix.
    
    In a case like that (without a stripped path prefix), the proxy would listen on something like `https://myawesomeapp.com`, and then if the browser goes to `https://myawesomeapp.com/api/v1/app` and your server (e.g. Uvicorn) listens on `http://127.0.0.1:8000` the proxy (without a stripped path prefix) would access Uvicorn at the same path: `http://127.0.0.1:8000/api/v1/app`.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 27 16:49:49 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  9. cmd/server-main.go

    			}
    		}
    	})
    }
    
    // Return the list of address that MinIO server needs to listen on:
    //   - Returning 127.0.0.1 is necessary so Console will be able to send
    //     requests to the local S3 API.
    //   - The returned List needs to be deduplicated as well.
    func getServerListenAddrs() []string {
    	// Use a string set to avoid duplication
    	addrs := set.NewStringSet()
    	// Listen on local interface to receive requests from Console
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 21:50:11 UTC 2024
    - 35.2K bytes
    - Viewed (1)
  10. cni/pkg/nodeagent/ztunnelserver.go

    	if err != nil {
    		return nil, fmt.Errorf("failed to listen unix: %w", err)
    	}
    
    	return &ztunnelServer{
    		listener: l,
    		conns: &connMgr{
    			connectionSet: map[*ZtunnelConnection]struct{}{},
    		},
    		pods: pods,
    	}, nil
    }
    
    func (z *ztunnelServer) Close() error {
    	return z.listener.Close()
    }
    
    func (z *ztunnelServer) Run(ctx context.Context) {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Jul 29 16:08:35 UTC 2024
    - 13.2K bytes
    - Viewed (0)
Back to top