- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 267 for spotify (0.2 sec)
-
docs/bucket/notifications/README.md
``` $ mc admin config get myminio | grep notify notify_webhook publish bucket notifications to webhook endpoints notify_amqp publish bucket notifications to AMQP endpoints notify_kafka publish bucket notifications to Kafka endpoints notify_mqtt publish bucket notifications to MQTT endpoints notify_nats publish bucket notifications to NATS endpoints
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 84K bytes - Viewed (2) -
internal/config/notify/help.go
Description: "specify the version of the Kafka cluster", Optional: true, Type: "string", }, config.HelpKV{ Key: config.Comment, Description: config.DefaultComment, Optional: true, Type: "sentence", }, config.HelpKV{ Key: target.KafkaCompressionCodec, Description: "specify compression_codec of the Kafka cluster",
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 19 04:37:54 GMT 2024 - 18.8K bytes - Viewed (0) -
istioctl/pkg/dashboard/dashboard.go
if err != nil { return fmt.Errorf("failed to create k8s client: %v", err) } if labelSelector == "" && len(args) < 1 { c.Println(c.UsageString()) return fmt.Errorf("specify a pod or --selector") } if labelSelector != "" && len(args) > 0 { c.Println(c.UsageString()) return fmt.Errorf("name cannot be provided when a selector is specified") }
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Mon Apr 15 01:29:35 GMT 2024 - 20.5K bytes - Viewed (0) -
cmd/server-main.go
EnvVar: "MINIO_RECV_BUF_SIZE", Hidden: true, }, cli.StringFlag{ Name: "log-dir", Usage: "specify the directory to save the server log", EnvVar: "MINIO_LOG_DIR", Hidden: true, }, cli.IntFlag{ Name: "log-size", Usage: "specify the maximum server log file size in bytes before its rotated", Value: 10 * humanize.MiByte, EnvVar: "MINIO_LOG_SIZE", Hidden: true,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 15:54:03 GMT 2024 - 34.9K bytes - Viewed (1) -
cmd/iam.go
hasSessionPolicy = false isAllowed = false // Now check if we have a sessionPolicy. spolicy, ok := args.Claims[sessionPolicyNameExtracted] if !ok { return } hasSessionPolicy = true spolicyStr, ok := spolicy.(string) if !ok { // Sub policy if set, should be a string reject // malformed/malicious requests. return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 21:28:16 GMT 2024 - 71.1K bytes - Viewed (1) -
src/main/java/org/codelibs/fess/helper/SuggestHelper.java
cb.specify().columnAccessType(); cb.specify().columnUserSessionId(); cb.specify().columnHitCount(); cb.specify().columnClientIp(); cb.specify().columnSearchWord(); cb.specify().columnRequestedAt(); cb.specify().columnHitCount(); cb.specify().columnVirtualHost(); cb.specify().columnLanguages();
Java - Registered: Mon Apr 29 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 18K bytes - Viewed (0) -
cni/pkg/util/pluginutil.go
watcher: watcher, Events: fileModified, Errors: errChan, }, nil } func watchFiles(watcher *fsnotify.Watcher, fileModified chan struct{}, errChan chan error) { for { select { case event, ok := <-watcher.Events: if !ok { return } if event.Op&(fsnotify.Create|fsnotify.Write|fsnotify.Remove) != 0 { log.Infof("file modified: %v", event.Name) fileModified <- struct{}{} }
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 3.6K bytes - Viewed (0) -
cmd/admin-handlers-pools.go
} } else { idx = globalEndpoints.GetPoolIdx(v) } if idx == -1 { apiErr := toAdminAPIErr(ctx, errInvalidArgument) apiErr.Description = fmt.Sprintf("specified pool '%s' not found, please specify a valid pool", v) // We didn't find any matching pools, invalid input writeErrorResponseJSON(ctx, w, apiErr, r.URL) return } status, err := pools.Status(r.Context(), idx) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 10.9K bytes - Viewed (0) -
cmd/signals.go
daemon.SdNotify(false, daemon.SdNotifyStopping) exit(stopProcess()) case signal := <-globalServiceSignalCh: switch signal { case serviceRestart: logger.Info("Restarting on service signal") daemon.SdNotify(false, daemon.SdNotifyReloading) stop := stopProcess() rerr := restartProcess() if rerr == nil { daemon.SdNotify(false, daemon.SdNotifyReady) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:57:52 GMT 2024 - 2.8K bytes - Viewed (0) -
internal/event/target/nats.go
NATSJetStream = "jetstream" EnvNATSEnable = "MINIO_NOTIFY_NATS_ENABLE" EnvNATSAddress = "MINIO_NOTIFY_NATS_ADDRESS" EnvNATSSubject = "MINIO_NOTIFY_NATS_SUBJECT" EnvNATSUsername = "MINIO_NOTIFY_NATS_USERNAME" NATSUserCredentials = "MINIO_NOTIFY_NATS_USER_CREDENTIALS" EnvNATSPassword = "MINIO_NOTIFY_NATS_PASSWORD" EnvNATSToken = "MINIO_NOTIFY_NATS_TOKEN" EnvNATSTLS = "MINIO_NOTIFY_NATS_TLS"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 27 18:11:55 GMT 2024 - 12.8K bytes - Viewed (0)