Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for OutCapacity (0.13 sec)

  1. internal/grid/grid_test.go

    				for in := range request {
    					b := append([]byte{}, payload...)
    					b = append(b, in...)
    					resp <- b
    				}
    				t.Log(GetCaller(ctx).Name, "Handler done")
    				return nil
    			},
    			OutCapacity: 1,
    			InCapacity:  1,
    		}))
    		// 2: Return as error
    		errFatal(manager.RegisterStreamingHandler(handlerTest2, StreamHandler{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 36.4K bytes
    - Viewed (0)
  2. internal/grid/handlers.go

    	// Stateless requests provide no incoming stream and there is no flow control
    	// on outgoing messages.
    	StatelessHandler struct {
    		Handle StatelessHandlerFn
    		// OutCapacity is the output capacity on the caller.
    		// If <= 0 capacity will be 1.
    		OutCapacity int
    	}
    
    	// StreamHandlerFn must process a request with an optional initial payload.
    	// It must keep consuming from 'in' until it returns.
    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/benchmark_test.go

    					select {
    					case <-ctx.Done():
    						return nil
    					case out <- toSend:
    					}
    				}
    				return nil
    			},
    
    			Subroute:    "some-subroute",
    			OutCapacity: 1, // Only one message buffered.
    			InCapacity:  0,
    		}))
    		errFatal(err)
    	}
    	const payloadSize = 512
    	rng := rand.New(rand.NewSource(time.Now().UnixNano()))
    	payload := make([]byte, payloadSize)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  4. internal/grid/connection.go

    	}
    
    	var requests chan []byte
    	var responses chan Response
    	if handler.InCapacity > 0 {
    		requests = make(chan []byte, handler.InCapacity)
    	}
    	if handler.OutCapacity > 0 {
    		responses = make(chan Response, handler.OutCapacity)
    	} else {
    		responses = make(chan Response, 1)
    	}
    
    	cl, err := c.newMuxClient(ctx)
    	if err != nil {
    		return nil, err
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 46.7K bytes
    - Viewed (0)
  5. cmd/storage-rest-server.go

    			logger.FatalIf(gm.RegisterStreamingHandler(grid.HandlerWalkDir, grid.StreamHandler{
    				Subroute:    endpoint.Path,
    				Handle:      server.WalkDirHandler,
    				OutCapacity: 1,
    			}), "unable to register handler")
    
    			createStorage := func(endpoint Endpoint) bool {
    				xl, err := newXLStorage(endpoint, false)
    				if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 45.7K bytes
    - Viewed (0)
Back to top