- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for RegisterSingleHandler (0.11 sec)
-
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) -
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) -
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)