Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for Stateless (0.63 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/msg.go

    	// message will be sent after the serialized message as little endian.
    	FlagCRCxxh3 Flags = 1 << iota
    
    	// FlagEOF the stream (either direction) is at EOF.
    	FlagEOF
    
    	// FlagStateless indicates the message is stateless.
    	// This will retain clients across reconnections or
    	// if sequence numbers are unexpected.
    	FlagStateless
    
    	// FlagPayloadIsErr can be used by individual ops to signify that
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jul 25 21:07:21 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. RELEASE.md

    *   `tf.cond` emits a StatelessIf op if the branch functions are stateless and
        do not touch any resources.
    *   `tf.cond`, `tf.while` and `if` and `while` in AutoGraph now accept a
        nonscalar predicate if has a single element. This does not affect non-V2
        control flow.
    *   `tf.while_loop` emits a StatelessWhile op if the cond and body functions are
        stateless and do not touch any resources.
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Tue Oct 22 14:33:53 UTC 2024
    - 735.3K bytes
    - Viewed (0)
  10. CHANGELOG/CHANGELOG-1.27.md

    - By enabling the `UserNamespacesStatelessPodsSupport` feature gate in kubelet, you can now run a stateless pod in a separate user namespace ([#116377](https://github.com/kubernetes/kubernetes/pull/116377), [@giuseppe](https://github.com/giuseppe)) [SIG Apps, Node and Storage]
    Registered: Fri Nov 01 09:05:11 UTC 2024
    - Last Modified: Wed Jul 17 07:48:22 UTC 2024
    - 466.3K bytes
    - Viewed (1)
Back to top