- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 11 for listen (0.04 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
docs/bucket/notifications/README.md
``` Here we see that MinIO performed `HSET` on `minio_events` key. In case, `access` format was used, then `minio_events` would be a list, and the MinIO server would have performed an `RPUSH` to append to the list. A consumer of this list would ideally use `BLPOP` to remove list items from the left-end of the list. ## Publish MinIO events via NATS Install NATS from [here](http://nats.io/). ### Step 1: Add NATS endpoint to MinIO
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Aug 12 18:20:36 GMT 2025 - 84.2K bytes - Click Count (0) -
cmd/peer-rest-server.go
} mask.MergeMaskable(eventName) eventNames = append(eventNames, eventName) } rulesMap := event.NewRulesMap(eventNames, pattern, event.TargetID{ID: mustGetUUID()}) // Listen Publisher uses nonblocking publish and hence does not wait for slow subscribers. // Use buffered channel to take care of burst sends or slow w.Write() ch := make(chan event.Event, globalAPIConfig.getRequestsPoolCapacity())
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 53.6K bytes - Click Count (0) -
cmd/test-utils_test.go
return makeTestTargetURL(endPoint, bucketName, prefix, queryValue) } // return URL for listing objects in the bucket with V2 API. func getListObjectsV2URL(endPoint, bucketName, prefix, maxKeys, fetchOwner, encodingType, delimiter string) string { queryValue := url.Values{} queryValue.Set("list-type", "2") // Enables list objects V2 URL. if maxKeys != "" { queryValue.Set("max-keys", maxKeys) }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 77K bytes - Click Count (0) -
src/main/resources/fess_label_fr.properties
labels.related_content_list=Liste de contenu associé labels.plugin_list=Liste des plugins labels.pathmap_list=Liste de mappage de chemins labels.log_file_list=Liste des fichiers journaux labels.labeltype_list=Liste des types d'étiquettes labels.key_match_list=Liste de correspondance de clés labels.job_log_list=Liste des journaux de tâches labels.group_list=Liste des groupes labels.file_config_list=Liste de configuration de fichiers
Created: Sat Dec 20 09:19:18 GMT 2025 - Last Modified: Sat Dec 13 02:21:17 GMT 2025 - 49.2K bytes - Click Count (0) -
cmd/admin-handlers-users_test.go
if err != nil { c.Fatalf("Unable to set user: %v", err) } // 2. Check new user appears in listing usersMap, err := s.adm.ListUsers(ctx) if err != nil { c.Fatalf("error listing: %v", err) } v, ok := usersMap[accessKey] if !ok { c.Fatalf("user not listed: %s", accessKey) } c.Assert(v.Status, madmin.AccountEnabled) // 3. Associate policy and check that user can accessCreated: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Oct 15 17:00:45 GMT 2025 - 50.6K bytes - Click Count (0) -
cmd/erasure-server-pool.go
// repeatedly. This workaround recursively lists the top 3 entries including delete markers to reflect the // correct state of the directory in the list results. if strings.HasSuffix(opts.Prefix, SlashSeparator) { li, err := listFn(ctx, opts, maxKeys) if err != nil { return loi, err } if len(li.Objects) == 0 {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 89.2K bytes - Click Count (0) -
impl/maven-core/src/main/java/org/apache/maven/project/DefaultProjectBuilder.java
artifact.getGroupId() + ":" + artifact.getArtifactId() + ":" + artifact.getVersion())); } } List<ProjectBuildingResult> build(List<File> pomFiles, boolean recursive) throws ProjectBuildingException { List<ProjectBuildingResult> results = doBuild(pomFiles, recursive); if (results.stream() .flatMap(r -> r.getProblems().stream())
Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Tue Nov 18 17:20:31 GMT 2025 - 51.8K bytes - Click Count (0) -
tensorflow/BUILD
"//tensorflow/lite/c:common", "//tensorflow/lite/core/api", "//tensorflow/lite/delegates/flex:delegate", "//tensorflow/lite/kernels/internal:compatibility", "//tensorflow/lite/kernels:builtin_ops", "//tensorflow/lite/kernels:reference_ops", "//tensorflow/compiler/mlir/lite/schema:schema_fbs", "//tensorflow/lite/toco/logging:conversion_log_util",Created: Tue Dec 30 12:39:10 GMT 2025 - Last Modified: Wed Nov 12 19:21:56 GMT 2025 - 53.1K bytes - Click Count (0) -
cmd/object-api-listobjects_test.go
{"test-bucket-list-object", "", "", "", 5, resultCases[1], nil, true}, {"test-bucket-list-object", "", "", "", 4, resultCases[2], nil, true}, {"test-bucket-list-object", "", "", "", 3, resultCases[3], nil, true}, {"test-bucket-list-object", "", "", "", 1, resultCases[4], nil, true}, // Testing with prefix (25-28). {"test-bucket-list-object", "new", "", "", 3, resultCases[5], nil, true},Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Oct 10 18:57:03 GMT 2025 - 76.1K bytes - Click Count (0) -
cmd/xl-storage.go
} return err } // Stat succeeds we return errVolumeExists. return errVolumeExists } // ListVols - list volumes. func (s *xlStorage) ListVols(ctx context.Context) (volsInfo []VolInfo, err error) { return listVols(ctx, s.drivePath) } // List all the volumes from drivePath. func listVols(ctx context.Context, dirPath string) ([]VolInfo, error) { if err := checkPathLength(dirPath); err != nil {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 91.7K bytes - Click Count (0)