Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for Stateless (0.05 sec)

  1. internal/grid/manager.go

    }
    
    /*
    // RegisterStateless will register a stateless handler that serves
    // []byte -> stream of ([]byte, error) requests.
    func (m *Manager) RegisterStateless(id HandlerID, h StatelessHandler) error {
    	if !id.valid() {
    		return ErrUnknownHandler
    	}
    	if m.handlers.hasAny(id) && !id.isTestHandler() {
    		return ErrHandlerAlreadyExists
    	}
    
    	m.handlers.stateless[id] = &h
    	return nil
    }
    */
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  2. internal/grid/handlers.go

    	// StatelessHandlerFn must handle incoming stateless request.
    	// A non-nil error value will be returned as RemoteErr(msg) to client.
    	StatelessHandlerFn func(ctx context.Context, payload []byte, resp chan<- []byte) *RemoteErr
    
    	// StatelessHandler is handlers for one to many requests,
    	// where responses may be dropped.
    	// Stateless requests provide no incoming stream and there is no flow control
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 27.7K bytes
    - Viewed (0)
  3. internal/grid/connection.go

    	// Stateless stream:
    	if m.Flags&FlagStateless != 0 {
    		// Reject for now, so we can safely add it later.
    		if true {
    			gridLogIf(ctx, c.queueMsg(m, muxConnectError{Error: "Stateless streams not supported"}))
    			return
    		}
    
    		var handler *StatelessHandler
    		if subID == nil {
    			handler = c.handlers.stateless[m.Handler]
    		} else {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 46.7K bytes
    - Viewed (0)
  4. internal/grid/muxclient.go

    	cancelFn           context.CancelCauseFunc
    	parent             *Connection
    	respWait           chan<- Response
    	respMu             sync.Mutex
    	singleResp         bool
    	closed             bool
    	stateless          bool
    	acked              bool
    	init               bool
    	deadline           time.Duration
    	outBlock           chan struct{}
    	subroute           *subHandlerID
    	respErr            atomic.Pointer[error]
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 15.9K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/hash/BloomFilter.java

      /**
       * A strategy to translate T instances, to {@code numHashFunctions} bit indexes.
       *
       * <p>Implementations should be collections of pure functions (i.e. stateless).
       */
      interface Strategy extends java.io.Serializable {
    
        /**
         * Sets {@code numHashFunctions} bits of the given bit array, by hashing a user element.
         *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 23 16:45:30 UTC 2024
    - 26.6K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/hash/HashFunction.java

     *   <li><b>pure function:</b> the value produced must depend only on the input bytes, in the order
     *       they appear. Input data is never modified. {@link HashFunction} instances should always be
     *       stateless, and therefore thread-safe.
     *   <li><b>collision-averse:</b> while it can't be helped that a hash function will sometimes
     *       produce the same hash code for distinct inputs (a "collision"), every hash function strives
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue May 25 18:22:59 UTC 2021
    - 10.9K bytes
    - Viewed (0)
  7. guava/src/com/google/common/hash/HashFunction.java

     *   <li><b>pure function:</b> the value produced must depend only on the input bytes, in the order
     *       they appear. Input data is never modified. {@link HashFunction} instances should always be
     *       stateless, and therefore thread-safe.
     *   <li><b>collision-averse:</b> while it can't be helped that a hash function will sometimes
     *       produce the same hash code for distinct inputs (a "collision"), every hash function strives
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue May 25 18:22:59 UTC 2021
    - 10.9K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/escape/UnicodeEscaper.java

     * correctly if you are considering implementing a new escaper you should favor using UnicodeEscaper
     * wherever possible.
     *
     * <p>A {@code UnicodeEscaper} instance is required to be stateless, and safe when used concurrently
     * by multiple threads.
     *
     * <p>Popular escapers are defined as constants in classes like {@link
     * com.google.common.html.HtmlEscapers} and {@link com.google.common.xml.XmlEscapers}. To create
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jan 18 20:55:09 UTC 2022
    - 13.2K bytes
    - Viewed (0)
  9. android/guava-testlib/src/com/google/common/testing/ArbitraryInstances.java

     * Immutable empty instances are returned for collection types; {@code ""} for string; {@code 0} for
     * number types; reasonable default instance for other stateless types. For mutable types, a fresh
     * instance is created each time {@code get()} is called.
     *
     * @author Kevin Bourrillion
     * @author Ben Yu
     * @since 12.0
     */
    @GwtIncompatible
    @J2ktIncompatible
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 20.8K bytes
    - Viewed (0)
  10. guava-testlib/src/com/google/common/testing/ArbitraryInstances.java

     * Immutable empty instances are returned for collection types; {@code ""} for string; {@code 0} for
     * number types; reasonable default instance for other stateless types. For mutable types, a fresh
     * instance is created each time {@code get()} is called.
     *
     * @author Kevin Bourrillion
     * @author Ben Yu
     * @since 12.0
     */
    @GwtIncompatible
    @J2ktIncompatible
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 21.2K bytes
    - Viewed (0)
Back to top