Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 16 of 16 for StreamHandler (0.26 sec)

  1. internal/grid/connection_test.go

    	defer close(cleanReqs)
    	// 1: Block forever
    	h1 := func(payload []byte) ([]byte, *RemoteErr) {
    		gotCall <- struct{}{}
    		<-cleanReqs
    		return nil, nil
    	}
    	// 2: Also block, but with streaming.
    	h2 := StreamHandler{
    		Handle: func(ctx context.Context, payload []byte, request <-chan []byte, resp chan<- []byte) *RemoteErr {
    			gotCall <- struct{}{}
    			select {
    			case <-ctx.Done():
    				gotCall <- struct{}{}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Nov 21 01:09:35 GMT 2023
    - 6K bytes
    - Viewed (0)
  2. internal/grid/README.md

                }
            }
            // out is closed by the caller and should never be closed by the handler.
            return nil
        }
    
        err := manager.RegisterStreamingHandler(grid.HandlerDiskInfo, StreamHandler{
            Handle: handler,
            Subroute: "asubroute",
            OutCapacity: 1,
            InCapacity: 1,
        })
    ```
    
    Sample call:
    ```go
        // Get a connection to the remote host
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 9.4K bytes
    - Viewed (0)
  3. internal/grid/manager.go

    	return nil
    }
    */
    
    // RegisterStreamingHandler will register a stateless handler that serves
    // two-way streaming requests.
    func (m *Manager) RegisterStreamingHandler(id HandlerID, h StreamHandler) error {
    	if !id.valid() {
    		return ErrUnknownHandler
    	}
    	if debugPrint {
    		fmt.Println("RegisterStreamingHandler: subroute:", h.Subroute)
    	}
    	if h.Subroute == "" {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 9.5K bytes
    - Viewed (0)
  4. cmd/storage-rest-server.go

    			logger.FatalIf(storageStatVolRPC.Register(gm, server.StatVolHandler, endpoint.Path), "unable to register handler")
    			logger.FatalIf(gm.RegisterStreamingHandler(grid.HandlerWalkDir, grid.StreamHandler{
    				Subroute:    endpoint.Path,
    				Handle:      server.WalkDirHandler,
    				OutCapacity: 1,
    			}), "unable to register handler")
    
    			createStorage := func(server *storageRESTServer) bool {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 44.8K bytes
    - Viewed (0)
  5. cmd/peer-rest-server.go

    	logger.FatalIf(updateMetacacheListingRPC.Register(gm, server.UpdateMetacacheListingHandler), "unable to register handler")
    
    	logger.FatalIf(gm.RegisterStreamingHandler(grid.HandlerTrace, grid.StreamHandler{
    		Handle:      server.TraceHandler,
    		Subroute:    "",
    		OutCapacity: 100000,
    		InCapacity:  0,
    	}), "unable to register handler")
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 51.8K bytes
    - Viewed (0)
  6. internal/grid/connection.go

    			return
    		}
    		_, _ = c.inStream.LoadOrCompute(m.MuxID, func() *muxServer {
    			return newMuxStateless(ctx, m, c, *handler)
    		})
    	} else {
    		// Stream:
    		var handler *StreamHandler
    		if subID == nil {
    			if !m.Handler.valid() {
    				gridLogIf(ctx, c.queueMsg(m, muxConnectError{Error: "Invalid Handler"}))
    				return
    			}
    			handler = c.handlers.streams[m.Handler]
    		} else {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 42.6K bytes
    - Viewed (0)
Back to top