Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for RegisterSingleHandler (0.24 sec)

  1. 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 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

    	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 May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 27.1K bytes
    - Viewed (0)
Back to top