Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 3 of 3 for remotePeer (0.06 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. internal/grid/grid_test.go

    	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.")
    		err := RemoteErr(payload)
    		return nil, &err
    	}))
    
    	remote := grid.Managers[1]
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 36.1K bytes
    - Click Count (0)
  2. internal/grid/README.md

    The server handler function has this signature: `type SingleHandlerFn func(payload []byte) ([]byte, *RemoteErr)`.
    
    Sample handler:
    ```go
        handler :=  func(payload []byte) ([]byte, *grid.RemoteErr) {
            // Do something with payload
            return []byte("response"), nil
        }
    
        err := manager.RegisterSingleHandler(grid.HandlerDiskInfo, handler)
    ```
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Oct 10 18:57:03 GMT 2025
    - 9.4K bytes
    - Click Count (0)
  3. internal/grid/connection.go

    		}
    		PutByteBuffer(m.Payload)
    		return
    	}
    	if m.Flags&FlagPayloadIsErr != 0 {
    		v.response(m.Seq, Response{
    			Msg: nil,
    			Err: RemoteErr(m.Payload),
    		})
    		if v.cancelFn != nil {
    			v.cancelFn(RemoteErr(m.Payload))
    		}
    		PutByteBuffer(m.Payload)
    		v.close()
    		c.outgoing.Delete(m.MuxID)
    		return
    	}
    	// Return payload.
    	if m.Payload != nil {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 46.9K bytes
    - Click Count (0)
Back to Top