- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for Meister (0.27 sec)
-
internal/grid/README.md
// Due to current generics limitations, a constructor of the empty type must be provided. instance := grid.NewSingleHandler[*grid.MSS, *grid.MSS](h, grid.NewMSS, grid.NewMSS) // Register the handler on the manager instance.Register(manager, handler) // The typed instance is also used for calls conn := manager.Connection("host")
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 9.4K bytes - Viewed (0) -
cmd/bootstrap-peer-server.go
// registerBootstrapRESTHandlers - register bootstrap rest router. func registerBootstrapRESTHandlers(gm *grid.Manager) { server := &bootstrapRESTServer{} logger.FatalIf(serverVerifyHandler.Register(gm, server.VerifyHandler), "unable to register handler") } // client to talk to bootstrap NEndpoints. type bootstrapRESTClient struct {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 7.5K bytes - Viewed (0) -
docs/extensions/s3zip/examples/boto3/main.py
region_name='us-east-1') def _add_header(request, **kwargs): request.headers.add_header('x-minio-extract', 'true') event_system = s3.meta.events event_system.register_first('before-sign.s3.*', _add_header) # List zip contents response = s3.list_objects_v2(Bucket="your-bucket", Prefix="path/to/file.zip/") print(response) # Download data.csv stored in the zip file
Python - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Aug 04 21:15:45 GMT 2021 - 771 bytes - Viewed (0) -
internal/grid/manager.go
// If the host does not exist nil will be returned. func (m *Manager) Connection(host string) *Connection { return m.targets[host] } // RegisterSingleHandler will register a stateless handler that serves // []byte -> ([]byte, error) requests. // subroutes are joined with "/" to a single subroute. func (m *Manager) RegisterSingleHandler(id HandlerID, h SingleHandlerFn, subroute ...string) error {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.5K bytes - Viewed (0) -
internal/config/subnet/subnet.go
func (c Config) Upload(reqURL string, filename string, payload []byte) (string, error) { if !c.Registered() { return "", errors.New("Deployment is not registered with SUBNET. Please register the deployment via 'mc license register ALIAS'") } var body bytes.Buffer writer := multipart.NewWriter(&body) part, e := writer.CreateFormFile("file", filename) if e != nil { return "", e }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 27 16:35:36 GMT 2023 - 2.9K bytes - Viewed (0) -
internal/s3select/simdj/reader_amd64_test.go
"github.com/klauspost/compress/zstd" "github.com/minio/minio/internal/s3select/json" "github.com/minio/minio/internal/s3select/sql" "github.com/minio/simdjson-go" ) type tester interface { Fatal(args ...interface{}) } func loadCompressed(t tester, file string) (js []byte) { dec, err := zstd.NewReader(nil) if err != nil { t.Fatal(err) } defer dec.Close()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 19 18:05:16 GMT 2022 - 3.9K bytes - Viewed (0) -
cmd/routers.go
func registerDistErasureRouters(router *mux.Router, endpointServerPools EndpointServerPools) { // Register storage REST router only if its a distributed setup. registerStorageRESTHandlers(router, endpointServerPools, globalGrid.Load()) // Register peer REST router only if its a distributed setup. registerPeerRESTHandlers(router, globalGrid.Load()) // Register bootstrap REST router for distributed setups. registerBootstrapRESTHandlers(globalGrid.Load())
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 08 19:08:18 GMT 2024 - 3.6K bytes - Viewed (1) -
cmd/metrics-router.go
metricsRouter.Handle(prometheusMetricsV2ResourcePath, auth(metricsResourceHandler())) // Metrics v3! metricsV3Server := newMetricsV3Server(authType) // Register metrics v3 handler. It also accepts an optional query // parameter `?list` - see handler for details. metricsRouter.Methods(http.MethodGet).Path(metricsV3Path + "{pathComps:.*}").Handler(metricsV3Server)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Mar 10 09:15:15 GMT 2024 - 2.5K bytes - Viewed (0) -
cmd/lock-rest-server.go
logger.FatalIf(lockRPCUnlock.Register(globalGrid.Load(), lockServer.UnlockHandler), "unable to register handler") logger.FatalIf(lockRPCRLock.Register(globalGrid.Load(), lockServer.RLockHandler), "unable to register handler") logger.FatalIf(lockRPCRUnlock.Register(globalGrid.Load(), lockServer.RUnlockHandler), "unable to register handler") globalLockServer = lockServer.ll
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 5.9K bytes - Viewed (0) -
cmd/main.go
// allowed number of typed errors if words.DamerauLevenshteinDistance(command, value) < 2 { closestCommands = append(closestCommands, value) } } return closestCommands } // Register all commands. registerCommand(serverCmd) // Set up app. cli.HelpFlag = cli.BoolFlag{ Name: "help, h", Usage: "show help", } cli.VersionPrinter = printMinIOVersion
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:57:52 GMT 2024 - 6.4K bytes - Viewed (0)