- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 140 for registered (0.15 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/globals.go
// and Storage/OS calls info to registered listeners. globalTrace = pubsub.New[madmin.TraceInfo, madmin.TraceType](8) // global Listen system to send S3 API events to registered listeners globalHTTPListen = pubsub.New[event.Event, pubsub.Mask](0) // global console system to send console logs to // registered listeners globalConsoleSys *HTTPConsoleLoggerSys
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 16.5K bytes - Viewed (0) -
cmd/license-update.go
licenseUpdateTimer := time.NewTimer(licUpdateCycle) defer licenseUpdateTimer.Stop() for { select { case <-ctx.Done(): return case <-licenseUpdateTimer.C: if globalSubnetConfig.Registered() { performLicenseUpdate(ctx, objAPI) } // Reset the timer for next cycle. licenseUpdateTimer.Reset(licUpdateCycle) } } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 3.3K bytes - Viewed (0) -
internal/config/subnet/subnet.go
) // Upload given file content (payload) to specified URL 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 {
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/config/subnet/config.go
// Transport configured with proxy_url if set optionally. transport http.RoundTripper // The subnet base URL BaseURL string } var configLock sync.RWMutex // Registered indicates if cluster is registered or not func (c *Config) Registered() bool { configLock.RLock() defer configLock.RUnlock() return len(c.APIKey) > 0 }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Nov 24 17:59:35 GMT 2023 - 3.8K bytes - Viewed (0) -
helm/minio/README.md
``` ### Installing certificates from third party CAs
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Jan 24 07:27:57 GMT 2024 - 10.9K bytes - Viewed (0) -
internal/grid/errors.go
"fmt" ) var ( // ErrUnknownHandler is returned when an unknown handler is requested. ErrUnknownHandler = errors.New("unknown mux handler") // ErrHandlerAlreadyExists is returned when a handler is already registered. ErrHandlerAlreadyExists = errors.New("mux handler already exists") // ErrIncorrectSequence is returned when an out-of-sequence item is received. ErrIncorrectSequence = errors.New("out-of-sequence item received") )
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 1.4K bytes - Viewed (0) -
cmd/config-current.go
if err != nil { return err } // callhome cannot be enabled if license is not registered yet, throw an error. if cfg.Enabled() && !globalSubnetConfig.Registered() { return errors.New("Deployment is not registered with SUBNET. Please register the deployment via 'mc license register ALIAS'") } case config.DriveSubSys:
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 30.8K bytes - Viewed (0) -
cmd/test-utils_test.go
return globalObjectAPI }, } // Register ListBuckets handler. apiRouter.Methods(http.MethodGet).HandlerFunc(api.ListBucketsHandler) // Register all bucket level handlers. registerBucketLevelFunc(bucketRouter, api, apiFunctions...) } // Takes in Erasure object layer, and the list of API end points to be tested/required, registers the API end points and returns the HTTP handler.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 17:26:51 GMT 2024 - 76.2K bytes - Viewed (0) -
cmd/consolelogger.go
if err != nil { logger.FatalIf(err, "Unable to start console logging subsystem") } sys.nodeName = host.Name } // HasLogListeners returns true if console log listeners are registered // for this node or peers func (sys *HTTPConsoleLoggerSys) HasLogListeners() bool { return sys != nil && sys.pubsub.Subscribers() > 0 } // Subscribe starts console logging for this node.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:57:52 GMT 2024 - 5.5K bytes - Viewed (0)