- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for SingleHandler (1.59 sec)
-
internal/grid/handlers.go
func (h *SingleHandler[Req, Resp]) WithSharedResponse() *SingleHandler[Req, Resp] { h.sharedResp = true return h } // NewResponse creates a new response. // Handlers can use this to create a reusable response. // The response may be reused, so caller should clear any fields. func (h *SingleHandler[Req, Resp]) NewResponse() Resp { return h.newResp() }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue Feb 18 16:25:55 UTC 2025 - 27.7K bytes - Viewed (0) -
cmd/lock-rest-client.go
return nil } // String - returns the remote host of the connection. func (c *lockRESTClient) String() string { return c.connection.Remote } func (c *lockRESTClient) call(ctx context.Context, h *grid.SingleHandler[*dsync.LockArgs, *dsync.LockResp], args *dsync.LockArgs) (ok bool, err error) { r, err := h.Call(ctx, c.connection, args) if err != nil { return false, err } defer h.PutResponse(r) ok = r.Code == dsync.RespOK
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Mon Jul 29 18:10:04 UTC 2024 - 3.3K bytes - Viewed (0) -
internal/grid/trace.go
OutputBytes: len(resp), TimeToFirstByte: end.Sub(start), }, }, } // If the context contains a TraceParamsKey, add it to the trace path. v := ctx.Value(TraceParamsKey{}) // Should match SingleHandler.Call checks. switch typed := v.(type) { case *MSS: trace.Path += typed.ToQuery() case map[string]string: m := MSS(typed) trace.Path += m.ToQuery() case *URLValues:
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sat Jun 01 05:17:37 UTC 2024 - 4.1K bytes - Viewed (0) -
cmd/lock-rest-server.go
lockRPCRLock = newLockHandler(grid.HandlerLockRLock) lockRPCRUnlock = newLockHandler(grid.HandlerLockRUnlock) ) func newLockHandler(h grid.HandlerID) *grid.SingleHandler[*dsync.LockArgs, *dsync.LockResp] { return grid.NewSingleHandler[*dsync.LockArgs, *dsync.LockResp](h, func() *dsync.LockArgs { return &dsync.LockArgs{} }, func() *dsync.LockResp { return &dsync.LockResp{} })
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Jan 31 19:54:34 UTC 2025 - 6.3K bytes - Viewed (0) -
internal/grid/README.md
Note that Responses sent for serialization are automatically reused for similar requests. If the response contains shared data it will cause issues, since each unique response is reused. To disable this behavior, use `(SingleHandler).WithSharedResponse()` to disable it. ## Streaming Requests Streams consists of an initial request with payload and allows for full two-way communication between the client and server.
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Oct 10 18:57:03 UTC 2025 - 9.4K bytes - Viewed (0)