Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 160 for listen (0.3 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/http/listener.go

    		}
    	case <-listener.ctx.Done():
    	}
    	return nil, syscall.EINVAL
    }
    
    // Close - closes underneath all TCP listeners.
    func (listener *httpListener) Close() (err error) {
    	listener.ctxCanceler()
    
    	for i := range listener.tcpListeners {
    		listener.tcpListeners[i].Close()
    	}
    
    	return nil
    }
    
    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)
  3. 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)
    	}
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Fri Jan 26 20:34:28 GMT 2024
    - 1.7K 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. 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())
    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)
  6. 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
    }
    
    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)
  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):
    
    === "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)
  8. cmd/peer-rest-client.go

    		}
    		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:
    				// There was error in the REST request, retry after sometime as probably the peer is down.
    				time.Sleep(5 * time.Second)
    			}
    		}
    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. .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)
  10. cni/pkg/install/install_test.go

    			expectedFailure:   true,
    			cniConfigFilename: "list.conflist",
    			chainedCNIPlugin:  true,
    			existingConfFiles: map[string]string{"list.conflist": "list.conflist"},
    		},
    		{
    			name:              "chained CNI plugin",
    			cniConfigFilename: "list.conflist",
    			chainedCNIPlugin:  true,
    			existingConfFiles: map[string]string{"list.conflist.golden": "list.conflist"},
    		},
    		{
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Fri Jan 26 20:34:28 GMT 2024
    - 11.1K bytes
    - Viewed (0)
Back to top