Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 134 for Listen (0.17 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()
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 6K bytes
    - Viewed (0)
  2. internal/grid/debug.go

    		}
    	}
    }
    
    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())
    		listeners = append(listeners, l)
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Feb 08 18:15:27 GMT 2024
    - 4.2K bytes
    - Viewed (0)
  3. internal/http/listener.go

    		Control: setTCPParametersFn(opts),
    	}
    
    	for i, serverAddr := range serverAddrs {
    		var (
    			l net.Listener
    			e error
    		)
    		if l, e = listenCfg.Listen(ctx, "tcp", serverAddr); e != nil {
    			if opts.Trace != nil {
    				opts.Trace(fmt.Sprint("listenCfg.Listen: ", e.Error()))
    			}
    
    			listenErrs[i] = e
    			continue
    		}
    
    		tcpListener, ok := l.(*net.TCPListener)
    		if !ok {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Mar 01 16:00:42 GMT 2024
    - 5.8K bytes
    - Viewed (0)
  4. 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
    
    Plain Text
    - Registered: Sun Apr 28 07:19:10 GMT 2024
    - Last Modified: Fri Mar 22 01:42:11 GMT 2024
    - 10.4K bytes
    - Viewed (0)
  5. cni/pkg/nodeagent/cni-watcher.go

    		}
    	}()
    
    	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
    }
    
    func (s *CniPluginServer) handleAddEvent(w http.ResponseWriter, req *http.Request) {
    	if req.Body == nil {
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Thu Feb 08 18:52:24 GMT 2024
    - 6.1K bytes
    - Viewed (0)
  6. 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):
    
    === "Python 3.9+"
    
        ```Python hl_lines="18"
    Plain Text
    - Registered: Sun Apr 28 07:19:10 GMT 2024
    - Last Modified: Sat Mar 30 20:26:47 GMT 2024
    - 8.7K bytes
    - Viewed (0)
  7. .github/workflows/iam-integrations.yaml

            env:
              LDAP_ORGANIZATION: "MinIO Inc"
              LDAP_DOMAIN: "min.io"
              LDAP_ADMIN_PASSWORD: "admin"
          etcd:
            image: "quay.io/coreos/etcd:v3.5.1"
            env:
              ETCD_LISTEN_CLIENT_URLS: "http://0.0.0.0:2379"
              ETCD_ADVERTISE_CLIENT_URLS: "http://0.0.0.0:2379"
            ports:
              - "2379:2379"
            options: >-
              --health-cmd "etcdctl endpoint health"
    Others
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 25 15:49:53 GMT 2024
    - 4.2K bytes
    - Viewed (0)
  8. cmd/peer-rest-client.go

    		select {
    		case listenCh <- *b:
    		default:
    			// Do not block on slow receivers.
    			b.Recycle()
    		}
    		return nil
    	})
    }
    
    // Listen - listen on peers.
    func (client *peerRESTClient) Listen(ctx context.Context, listenCh chan<- []byte, v url.Values) {
    	go func() {
    		for {
    			client.doListen(ctx, listenCh, v)
    			select {
    			case <-ctx.Done():
    				return
    			default:
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 25.8K bytes
    - Viewed (0)
  9. cni/pkg/nodeagent/ztunnelserver.go

    		return nil, fmt.Errorf("failed to remove unix://%s: %w", addr, err)
    	}
    
    	l, err := net.ListenUnix("unixpacket", resolvedAddr)
    	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
    }
    
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Fri Apr 12 21:47:31 GMT 2024
    - 12.4K bytes
    - Viewed (0)
  10. cmd/sftp-server.go

    		SSHConfig:            sshConfig,
    		HandleSFTPSession:    handleSFTPSession,
    	})
    	if err != nil {
    		logger.Fatal(err, "Unable to start SFTP Server")
    	}
    
    	err = sftpServer.Listen()
    	if err != nil {
    		logger.Fatal(err, "SFTP Server had an unrecoverable error while accepting connections")
    	}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 5.6K bytes
    - Viewed (0)
Back to top