- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 49 for task (0.18 sec)
-
cmd/listen-notification-handlers.go
} pattern := event.NewPattern(prefix, suffix) var eventNames []event.Name var mask pubsub.Mask for _, s := range values[peerRESTListenEvents] { eventName, err := event.ParseName(s) if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } mask.MergeMaskable(eventName) eventNames = append(eventNames, eventName) } if bucketName != "" {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6K bytes - Viewed (0) -
cmd/globals.go
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 // All unique drives for this deployment globalEndpoints EndpointServerPools
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/metrics-v2.go
expiryPendingTasks MetricName = "expiry_pending_tasks" expiryMissedTasks MetricName = "expiry_missed_tasks" expiryMissedFreeVersions MetricName = "expiry_missed_freeversions" expiryMissedTierJournalTasks MetricName = "expiry_missed_tierjournal_tasks" expiryNumWorkers MetricName = "expiry_num_workers" transitionPendingTasks MetricName = "transition_pending_tasks"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 22:01:31 GMT 2024 - 132.6K bytes - Viewed (0) -
cni/pkg/nodeagent/cni-watcher.go
var podIps []netip.Addr for _, configuredPodIPs := range addCmd.IPs { // net.ip is implicitly convertible to netip as slice ip, _ := netip.AddrFromSlice(configuredPodIPs.Address.IP) // We ignore the mask of the IPNet - it's fine if the IPNet defines // a block grant of addresses, we just need one for checking routes. podIps = append(podIps, ip) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Feb 08 18:52:24 GMT 2024 - 6.1K bytes - Viewed (0) -
cmd/bootstrap-peer-server.go
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 { gridConn *grid.Connection } // Verify function verifies the server config.
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) -
internal/bucket/encryption/bucket-sse-config.go
return nil, errors.New("MasterKeyID contains unsupported characters") } } } if config.XMLNS == "" { config.XMLNS = xmlNS } return &config, nil } // ApplyOptions ask for specific features to be enabled, // when bucketSSEConfig is empty. type ApplyOptions struct { AutoEncrypt bool } // Apply applies the SSE bucket configuration on the given HTTP headers and
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Oct 25 00:44:15 GMT 2022 - 4.9K bytes - Viewed (0) -
cmd/erasure-server-pool.go
return pinfo, z.poolsWithObject(poolObjInfos, opts), nil } if isErrReadQuorum(pinfo.Err) && !opts.MetadataChg { // read quorum is returned when the object is visibly // present but its unreadable, we simply ask the writes to // schedule to this pool instead. If there is no quorum // it will fail anyways, however if there is quorum available // with enough disks online but sufficiently inconsistent to
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 80.5K bytes - Viewed (0) -
cmd/update.go
internalLogIf(GlobalContext, err) return err == nil } // MinIO Helm chart uses DownwardAPIFile to write pod label info to /podinfo/labels // More info: https://kubernetes.io/docs/tasks/inject-data-application/downward-api-volume-expose-pod-information/#store-pod-fields // Check if this is Helm package installation and report helm chart version func getHelmVersion(helmInfoFilePath string) string {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 18.7K bytes - Viewed (0) -
istioctl/pkg/precheck/precheck.go
messages.Add(msg.NewUpdateIncompatibility(res, "meshConfig.defaultConfig.tracer", "1.21", "tracing is no longer by default enabled to send to 'zipkin.istio-system.svc'; "+ "follow https://istio.io/latest/docs/tasks/observability/distributed-tracing/telemetry-api/", "1.21")) return nil } func checkPassthroughTargetPorts(cli kube.CLIClient, messages *diag.Messages) error {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 02:57:30 GMT 2024 - 19.3K bytes - Viewed (0) -
istioctl/pkg/multicluster/remote_secret.go
secret := item if secretReferencesServiceAccount(serviceAccount, &secret) == nil { return &secret, nil } } // finally, create the sa token secret manually // https://kubernetes.io/docs/tasks/configure-pod-container/configure-service-account/#manually-create-a-service-account-api-token // TODO ephemeral time-based tokens are preferred; we should re-think this
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Oct 11 01:43:17 GMT 2023 - 24K bytes - Viewed (0)