Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for asubroute (0.05 sec)

  1. internal/grid/README.md

        err := manager.RegisterStreamingHandler(grid.HandlerDiskInfo, StreamHandler{
            Handle: handler,
            Subroute: "asubroute",
            OutCapacity: 1,
            InCapacity: 1,
        })
    ```
    
    Sample call:
    ```go
        // Get a connection to the remote host
        conn := manager.Connection(host).Subroute("asubroute")
    
        payload := []byte("request")
        stream, err := conn.NewStream(ctx, grid.HandlerDiskInfo, payload)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Oct 10 18:57:03 UTC 2025
    - 9.4K bytes
    - Viewed (0)
  2. cmd/peer-rest-server.go

    		return collectInternodeStats(httpTraceHdrs(f))
    	}
    
    	server := &peerRESTServer{}
    	subrouter := router.PathPrefix(peerRESTPrefix).Subrouter()
    	subrouter.Methods(http.MethodPost).Path(peerRESTVersionPrefix + peerRESTMethodHealth).HandlerFunc(h(server.HealthHandler))
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 53.6K bytes
    - Viewed (0)
  3. internal/grid/muxclient.go

    	if err != nil {
    		return err
    	}
    	if msg.Flags&FlagSubroute != 0 {
    		if m.subroute == nil {
    			return fmt.Errorf("internal error: subroute not defined on client")
    		}
    		hid := m.subroute.withHandler(msg.Handler)
    		before := len(dst)
    		dst = append(dst, hid[:]...)
    		if debugPrint {
    			fmt.Println("Added subroute", hid.String(), "to message", msg, "len", len(dst)-before)
    		}
    	}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 15.9K bytes
    - Viewed (0)
  4. tests/test_sub_callbacks.py

    
    events_callback_router = APIRouter()
    
    
    @events_callback_router.get("{$callback_url}/events/{$request.body.title}")
    def event_callback(event: Event):
        pass  # pragma: nocover
    
    
    subrouter = APIRouter()
    
    
    @subrouter.post("/invoices/", callbacks=invoices_callback_router.routes)
    def create_invoice(invoice: Invoice, callback_url: Optional[HttpUrl] = None):
        """
        Create an invoice.
    
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Sat Dec 27 18:19:10 UTC 2025
    - 12.9K bytes
    - Viewed (0)
  5. tests/test_generate_unique_id_function.py

                                    }
                                },
                            },
                        },
                    }
                },
                "/subrouter": {
                    "post": {
                        "summary": "Post Subrouter",
                        "operationId": "bar_post_subrouter",
                        "requestBody": {
                            "content": {
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Wed Dec 17 21:25:59 UTC 2025
    - 66.7K bytes
    - Viewed (0)
  6. cmd/api-router.go

    				// to match for `<bucket>`
    				return host != minioReservedBucket+"."+domainName
    			}).Host("{bucket:.+}."+domainName).Subrouter())
    		} else {
    			routers = append(routers, apiRouter.Host("{bucket:.+}."+domainName).Subrouter())
    		}
    	}
    	routers = append(routers, apiRouter.PathPrefix("/{bucket}").Subrouter())
    
    	for _, router := range routers {
    		// Register all rejected object APIs
    		for _, r := range rejectedObjAPIs {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Oct 24 04:05:19 UTC 2025
    - 23.3K bytes
    - Viewed (0)
  7. cmd/admin-router.go

    func registerAdminRouter(router *mux.Router, enableConfigOps bool) {
    	adminAPI := adminAPIHandlers{}
    	// Admin router
    	adminRouter := router.PathPrefix(adminPathPrefix).Subrouter()
    
    	adminVersions := []string{
    		adminAPIVersionPrefix,
    	}
    
    	for _, adminVersion := range adminVersions {
    		// Restart and stop MinIO service type=2
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Oct 10 18:57:03 UTC 2025
    - 26.7K bytes
    - Viewed (0)
Back to top