Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 82 for Listen (0.08 seconds)

  1. 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`.
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 05 18:13:19 GMT 2026
    - 15.8K bytes
    - Click Count (0)
  2. 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:
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 26.1K bytes
    - Click Count (0)
  3. 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
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue May 27 15:18:36 GMT 2025
    - 35.9K bytes
    - Click Count (4)
  4. docs/en/docs/deployment/concepts.md

    Here are some possible combinations and strategies:
    
    * **Uvicorn** with `--workers`
        * One Uvicorn **process manager** would listen on the **IP** and **port**, and it would start **multiple Uvicorn worker processes**.
    * **Kubernetes** and other distributed **container systems**
        * Something in the **Kubernetes** layer would listen on the **IP** and **port**. The replication would be by having **multiple containers**, each with **one Uvicorn process** running.
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 05 18:13:19 GMT 2026
    - 18.5K bytes
    - Click Count (1)
  5. cmd/globals.go

    	// global Trace system to send HTTP request/response
    	// and Storage/OS calls info to registered listeners.
    	globalTrace = pubsub.New[madmin.TraceInfo, madmin.TraceType](8)
    
    	// global Listen system to send S3 API events to registered listeners
    	globalHTTPListen = pubsub.New[event.Event, pubsub.Mask](0)
    
    	// global console system to send console logs to
    	// registered listeners
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Sep 03 18:23:41 GMT 2024
    - 16.2K bytes
    - Click Count (1)
  6. mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt

        (dispatcher as QueueDispatcher).enqueue(response)
      }
    
      /**
       * Starts the server on the loopback interface for the given port.
       *
       * @param port the port to listen to, or 0 for any available port. Automated tests should always
       * use port 0 to avoid flakiness when a specific port is unavailable.
       */
      @Throws(IOException::class)
      @JvmOverloads
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 40.3K bytes
    - Click Count (0)
  7. internal/grid/muxclient.go

    		ticker := time.NewTicker(m.clientPingInterval)
    		defer ticker.Stop()
    		pingTimer = ticker.C
    		atomic.StoreInt64(&m.LastPong, time.Now().UnixNano())
    	}
    
    	// Listen for client messages.
    reqLoop:
    	for !errState {
    		select {
    		case <-m.ctx.Done():
    			if debugPrint {
    				fmt.Println("Client sending disconnect to mux", m.MuxID)
    			}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 15.9K bytes
    - Click Count (0)
  8. android/guava/src/com/google/common/util/concurrent/ServiceManager.java

            public String toString() {
              return "stopped()";
            }
          };
    
      /**
       * A listener for the aggregate state changes of the services that are under management. Users
       * that need to listen to more fine-grained events (such as when each particular {@linkplain
       * Service service} starts, or terminates), should attach {@linkplain Service.Listener service
       * listeners} to each individual service.
       *
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Feb 23 19:19:10 GMT 2026
    - 33.2K bytes
    - Click Count (1)
  9. api/go1.11.txt

    pkg go/types, func NewInterfaceType([]*Func, []Type) *Interface
    pkg go/types, method (*Interface) EmbeddedType(int) Type
    pkg go/types, method (*Var) Embedded() bool
    pkg net, method (*ListenConfig) Listen(context.Context, string, string) (Listener, error)
    pkg net, method (*ListenConfig) ListenPacket(context.Context, string, string) (PacketConn, error)
    pkg net, type Dialer struct, Control func(string, string, syscall.RawConn) error
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Wed Aug 22 03:48:56 GMT 2018
    - 25K bytes
    - Click Count (0)
  10. TESTING.asciidoc

    This will instruct all JVMs (including any that run cli tools such as creating the keyring or adding users)
    to suspend and initiate a debug connection on port incrementing from `5005`.
    As such the IDE needs to be instructed to listen for connections on this port.
    Since we might run multiple JVMs as part of configuring and starting the cluster it's
    recommended to configure the IDE to initiate multiple listening attempts. In case of IntelliJ, this option
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Mon Jun 07 13:55:20 GMT 2021
    - 32.5K bytes
    - Click Count (0)
Back to Top