- Sort Score
- Num 10 results
- Language All
Results 1 - 6 of 6 for HandlerID (0.05 seconds)
-
internal/grid/muxclient.go
clientPingInterval: parent.clientPingInterval, } } // roundtrip performs a roundtrip, returning the first response. // This cannot be used concurrently. func (m *muxClient) roundtrip(h HandlerID, req []byte) ([]byte, error) { if m.init { return nil, errors.New("mux client already used") } m.init = true m.singleResp = true msg := message{ Op: OpRequest, MuxID: m.MuxID,
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 15.9K bytes - Click Count (0) -
internal/grid/README.md
From this connection individual requests can be made. Each handler, with optional subroutes can be registered with the manager using `Manager.RegisterXHandler(handlerID, handler, subroutes...)`. A `Handler()` function provides an HTTP handler, which should be hooked up to the appropriate route on the server.
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Oct 10 18:57:03 GMT 2025 - 9.4K bytes - Click Count (0) -
internal/grid/connection.go
// Request allows to do a single remote request. // 'req' will not be used after the call and caller can reuse. // If no deadline is set on ctx, a 1-minute deadline will be added. func (c *Connection) Request(ctx context.Context, h HandlerID, req []byte) ([]byte, error) { if !h.valid() { return nil, ErrUnknownHandler } if c.State() != StateConnected { return nil, ErrDisconnected } // Create mux client and call.
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 46.9K bytes - Click Count (0) -
internal/grid/grid_test.go
return nil }, OutCapacity: 1, InCapacity: 1, })) } register(local) register(remote) // local to remote testHandler := func(t *testing.T, handler HandlerID, sendReq bool) { remoteConn := local.Connection(remoteHost) const testPayload = "Hello Grid World!" ctx, cancel := context.WithCancel(t.Context())
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 36.1K bytes - Click Count (0) -
internal/grid/msg_gen.go
return } // DecodeMsg implements msgp.Decodable func (z *HandlerID) DecodeMsg(dc *msgp.Reader) (err error) { { var zb0001 uint8 zb0001, err = dc.ReadUint8() if err != nil { err = msgp.WrapError(err) return } (*z) = HandlerID(zb0001) } return } // EncodeMsg implements msgp.Encodable func (z HandlerID) EncodeMsg(en *msgp.Writer) (err error) { err = en.WriteUint8(uint8(z))
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 22.4K bytes - Click Count (0) -
cmd/xl-storage.go
} dstFilePath := pathutil.Join(dstVolumeDir, dstPath) if err = checkPathLength(dstFilePath); err != nil { return err } // when skipParent is from rpc. it’s ok for not adding another rpc HandlerID like HandlerRenamePart2 // For this case, skipParent is empty, destBaseDir is equal to dstVolumeDir, that behavior is the same as the previous one destBaseDir := pathutil.Join(dstVolumeDir, skipParent)
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 91.7K bytes - Click Count (0)