Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for streamHandler (0.06 sec)

  1. 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.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 27.7K bytes
    - Viewed (0)
  2. cmd/peer-rest-server.go

    	logger.FatalIf(cleanupUploadIDCacheMetaRPC.Register(gm, server.HandlerClearUploadID), "unable to register handler")
    
    	logger.FatalIf(gm.RegisterStreamingHandler(grid.HandlerTrace, grid.StreamHandler{
    		Handle:      server.TraceHandler,
    		Subroute:    "",
    		OutCapacity: 100000,
    		InCapacity:  0,
    	}), "unable to register handler")
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 53.2K bytes
    - Viewed (0)
Back to top