Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 21 - 26 of 26 for sub_router (0.06 seconds)

  1. internal/grid/grid_test.go

    					Embedded:  *i,
    				}
    				n++
    			}
    			return nil
    		}, "subroute", "1"))
    	}
    	register(local)
    	register(remote)
    
    	// local to remote
    	remoteConn := local.Connection(remoteHost)
    	const testPayload = "Hello Grid World!"
    	// Add subroute
    	remoteSub := remoteConn.Subroute(strings.Join([]string{"subroute", "1"}, "/"))
    
    	start := time.Now()
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 36.1K bytes
    - Click Count (0)
  2. cmd/storage-rest-client.go

    		return errDiskNotFound
    	}
    	return err
    }
    
    // Abstracts a remote disk.
    type storageRESTClient struct {
    	endpoint   Endpoint
    	restClient *rest.Client
    	gridConn   *grid.Subroute
    	diskID     atomic.Pointer[string]
    
    	diskInfoCache *cachevalue.Cache[DiskInfo]
    }
    
    // Retrieve location indexes.
    func (client *storageRESTClient) GetDiskLoc() (poolIdx, setIdx, diskIdx int) {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 08 02:38:41 GMT 2025
    - 30.4K bytes
    - Click Count (0)
  3. 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
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Oct 10 18:57:03 GMT 2025
    - 26.7K bytes
    - Click Count (0)
  4. cmd/test-utils_test.go

    		// Register all api endpoints by default.
    		registerAPIRouter(muxRouter)
    		return
    	}
    	// API Router.
    	apiRouter := muxRouter.PathPrefix(SlashSeparator).Subrouter()
    	// Bucket router.
    	bucketRouter := apiRouter.PathPrefix("/{bucket}").Subrouter()
    
    	// All object storage operations are registered as HTTP handlers on `objectAPIHandlers`.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 77K bytes
    - Click Count (0)
  5. android/guava-tests/test/com/google/common/reflect/TypeTokenTest.java

      }
    
      private abstract static class ToReproduceGenericSignatureFormatError<V> {
        private abstract class BaseOuter {
          abstract class BaseInner {}
        }
    
        private abstract class SubOuter extends BaseOuter {
          private abstract class SubInner extends BaseInner {}
        }
      }
    
      // For Guava bug https://github.com/google/guava/issues/1025
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Oct 28 18:44:53 GMT 2025
    - 89K bytes
    - Click Count (0)
  6. cmd/sts-handlers.go

    func registerSTSRouter(router *mux.Router) {
    	// Initialize STS.
    	sts := &stsAPIHandlers{}
    
    	// STS Router
    	stsRouter := router.NewRoute().PathPrefix(SlashSeparator).Subrouter()
    
    	// Assume roles with no JWT, handles AssumeRole.
    	stsRouter.Methods(http.MethodPost).MatcherFunc(func(r *http.Request, rm *mux.RouteMatch) bool {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 36.6K bytes
    - Click Count (0)
Back to Top