Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 11 for listen (0.04 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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 access
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Oct 15 17:00:45 GMT 2025
    - 50.6K bytes
    - Click Count (0)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to Top