Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for HandlerID (0.19 sec)

  1. internal/grid/handlers_string.go

    func (i HandlerID) String() string {
    	if i >= HandlerID(len(_HandlerID_index)-1) {
    		return "HandlerID(" + strconv.FormatInt(int64(i), 10) + ")"
    	}
    	return _HandlerID_name[_HandlerID_index[i]:_HandlerID_index[i+1]]
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  2. internal/grid/msg.go

    //
    //go:generate msgp -unexported -file=$GOFILE
    //go:generate stringer -type=Op -output=msg_string.go -trimprefix=Op $GOFILE
    
    // Op is operation type messages.
    type Op uint8
    
    // HandlerID is the ID for the handler of a specific type.
    type HandlerID uint8
    
    const (
    	// OpConnect is a connect request.
    	OpConnect Op = iota + 1
    
    	// OpConnectResponse is a response to a connect request.
    	OpConnectResponse
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jul 25 21:07:21 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  3. 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.
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  4. internal/grid/trace.go

    	Local     string
    	Remote    string
    	Subroute  string
    }
    
    const (
    	httpScheme  = "http://"
    	httpsScheme = "https://"
    )
    
    func (c *muxClient) traceRoundtrip(ctx context.Context, t *tracer, h HandlerID, req []byte) ([]byte, error) {
    	if t == nil || t.Publisher.NumSubscribers(t.TraceType) == 0 {
    		return c.roundtrip(h, req)
    	}
    
    	// Following trimming is needed for consistency between outputs with other internode traces.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Jun 01 05:17:37 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  5. cmd/lock-rest-server.go

    	lockRPCUnlock      = newLockHandler(grid.HandlerLockUnlock)
    	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 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 5.8K bytes
    - Viewed (0)
Back to top