Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for RegisterSingleHandler (0.3 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.")
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Nov 21 01:09:35 GMT 2023
    - 6K 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.")
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Feb 08 18:15:27 GMT 2024
    - 30.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
    	}
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 9.5K 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
    Plain Text
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 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
    		}))
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Nov 21 01:09:35 GMT 2023
    - 12.2K 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
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 26.9K bytes
    - Viewed (0)
Back to top