Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for StreamHandler (0.22 sec)

  1. internal/grid/grid_test.go

    		}
    	}
    
    	// We fake a local and remote server.
    	remoteHost := remote.HostName()
    
    	// 1: Echo
    	register := func(manager *Manager) {
    		errFatal(manager.RegisterStreamingHandler(handlerTest, StreamHandler{
    			Handle: func(ctx context.Context, payload []byte, request <-chan []byte, resp chan<- []byte) *RemoteErr {
    				for in := range request {
    					b := append([]byte{}, payload...)
    					b = append(b, in...)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 30 15:03:35 GMT 2024
    - 30.1K bytes
    - Viewed (0)
  2. internal/grid/handlers.go

    	// Buffers sent on out can not be referenced once sent.
    	StreamHandlerFn func(ctx context.Context, payload []byte, in <-chan []byte, out chan<- []byte) *RemoteErr
    
    	// StreamHandler handles fully bidirectional streams,
    	// There is flow control in both directions.
    	StreamHandler struct {
    		// Handle an incoming request. Initial payload is sent.
    		// Additional input packets (if any) are streamed to request.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 27.1K bytes
    - Viewed (0)
  3. 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)
  4. internal/grid/benchmark_test.go

    	const responses = 10
    	// Create n managers.
    	for _, remote := range grid.Managers {
    		// Register a single handler which echos the payload.
    		errFatal(remote.RegisterStreamingHandler(handlerTest, StreamHandler{
    			// Send 10x response.
    			Handle: func(ctx context.Context, payload []byte, _ <-chan []byte, out chan<- []byte) *RemoteErr {
    				for i := 0; i < responses; i++ {
    					toSend := GetByteBuffer()[:0]
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Nov 21 01:09:35 GMT 2023
    - 12.2K bytes
    - Viewed (0)
  5. 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)
  6. internal/grid/muxserver.go

    		LastPing:  time.Now().Unix(),
    		BaseFlags: c.baseFlags,
    	}
    	go func() {
    		// TODO: Handle
    	}()
    
    	return &m
    }
    
    func newMuxStream(ctx context.Context, msg message, c *Connection, handler StreamHandler) *muxServer {
    	var cancel context.CancelFunc
    	ctx = setCaller(ctx, c.remote)
    	if len(handler.Subroute) > 0 {
    		ctx = setSubroute(ctx, handler.Subroute)
    	}
    	if msg.DeadlineMS > 0 {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 9.1K bytes
    - Viewed (0)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top