- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for asubroute (0.05 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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)