Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 6 of 6 for HandlerID (0.05 seconds)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
Back to Top