Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for RegisterSingleHandler (0.08 sec)

  1. internal/grid/connection_test.go

    		BlockConnect: connReady,
    	})
    	errFatal(err)
    
    	// 1: Echo
    	errFatal(local.RegisterSingleHandler(handlerTest, func(payload []byte) ([]byte, *RemoteErr) {
    		t.Log("1: server payload: ", len(payload), "bytes.")
    		return append([]byte{}, payload...), nil
    	}))
    	// 2: Return as error
    	errFatal(local.RegisterSingleHandler(handlerTest2, func(payload []byte) ([]byte, *RemoteErr) {
    		t.Log("2: server payload: ", len(payload), "bytes.")
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed Apr 09 14:28:39 UTC 2025
    - 5.9K bytes
    - Viewed (0)
  2. internal/grid/grid_test.go

    	remoteHost := grid.Hosts[1]
    	local := grid.Managers[0]
    
    	// 1: Echo
    	errFatal(local.RegisterSingleHandler(handlerTest, func(payload []byte) ([]byte, *RemoteErr) {
    		t.Log("1: server payload: ", len(payload), "bytes.")
    		return append([]byte{}, payload...), nil
    	}))
    	// 2: Return as error
    	errFatal(local.RegisterSingleHandler(handlerTest2, func(payload []byte) ([]byte, *RemoteErr) {
    		t.Log("2: server payload: ", len(payload), "bytes.")
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 36.1K bytes
    - Viewed (0)
  3. internal/grid/manager.go

    func (m *Manager) Connection(host string) *Connection {
    	return m.targets[host]
    }
    
    // RegisterSingleHandler will register a stateless handler that serves
    // []byte -> ([]byte, error) requests.
    // subroutes are joined with "/" to a single subroute.
    func (m *Manager) RegisterSingleHandler(id HandlerID, h SingleHandlerFn, subroute ...string) error {
    	if !id.valid() {
    		return ErrUnknownHandler
    	}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Nov 12 20:41:41 UTC 2024
    - 10.8K bytes
    - Viewed (0)
  4. internal/grid/README.md

    In essence, they are `[]byte` -> `[]byte, error` functions.
    
    It is not possible to return *both* an error and a response.
    
    Handlers are registered on the manager using `(*Manager).RegisterSingleHandler(id HandlerID, h SingleHandlerFn, subroute ...string)`.
    
    The server handler function has this signature: `type SingleHandlerFn func(payload []byte) ([]byte, *RemoteErr)`.
    
    Sample handler:
    ```go
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Oct 10 18:57:03 UTC 2025
    - 9.4K bytes
    - Viewed (0)
  5. internal/grid/benchmark_test.go

    	grid, err := SetupTestGrid(n)
    	errFatal(err)
    	b.Cleanup(grid.Cleanup)
    	// Create n managers.
    	for _, remote := range grid.Managers {
    		// Register a single handler which echos the payload.
    		errFatal(remote.RegisterSingleHandler(handlerTest, func(payload []byte) ([]byte, *RemoteErr) {
    			defer PutByteBuffer(payload)
    			return append(GetByteBuffer()[:0], payload...), nil
    		}))
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 15.5K bytes
    - Viewed (0)
  6. internal/grid/handlers.go

    	if h.newReq == nil {
    		return errors.New("newReq nil in NewSingleHandler")
    	}
    	if h.newResp == nil {
    		return errors.New("newResp nil in NewSingleHandler")
    	}
    	return m.RegisterSingleHandler(h.id, func(payload []byte) ([]byte, *RemoteErr) {
    		req := h.NewRequest()
    		_, err := req.UnmarshalMsg(payload)
    		if err != nil {
    			PutByteBuffer(payload)
    			r := RemoteErr(err.Error())
    			return nil, &r
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Feb 18 16:25:55 UTC 2025
    - 27.7K bytes
    - Viewed (0)
Back to top