Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for listen (0.04 sec)

  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
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 84.2K bytes
    - Viewed (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())
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 53.4K bytes
    - Viewed (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)
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 77K bytes
    - Viewed (0)
  4. cmd/object-api-multipart_test.go

    					UploadID: uploadIDs[6],
    				},
    			},
    		},
    		// listMultipartResults - 32.
    		// checking listing with marker set to no of objects in the list.
    		// `NextUploadIDMarker` is expected to be empty since all results are listed.
    		// `NextKeyMarker` is expected to be empty since all results are listed.
    		{
    			MaxUploads:  6,
    			IsTruncated: false,
    			Uploads: []MultipartInfo{
    				{
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 89.4K bytes
    - Viewed (0)
  5. 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 {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 89.1K bytes
    - Viewed (0)
  6. 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},
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 76.1K bytes
    - Viewed (0)
  7. 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 {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Jun 13 11:33:47 UTC 2025
    - 91.7K bytes
    - Viewed (0)
  8. android/guava/src/com/google/thirdparty/publicsuffix/PublicSuffixPatterns.java

    g??y&golonys,srab,??a&g?n!.&reh.togrof,sih.togrof,???em?irp?orhc?w??n!goloc?i&lno!.&egats-oree,oree,redliubetisbew,ysrab,??w??o!.ecivres,hp?latipac?ts&der?e&gdirb?rif???z!.&amil,tikcats,???ruoblem??om?p!.&bog?gro?lim?mo&c?n??ten?ude??irg?yks??r!.&bilten,moc?nac,ossa??a&c!htlaeh??pmoc?wtfos??bc?eh?if?ots!.&e&rawpohs,saberots,?y&flles,srab,???taeht?u&ces?sni?t&inruf?necca??za???s!.&a!disnim321,?b!ibnal?rofmok??c!a??d!b?n&arb?ubroflanummok???e?f?g!ro??h!f??i!trap??k!shf??l?m!oc,t??n!mygskurbrutan??...
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue Aug 12 15:39:59 UTC 2025
    - 75.3K bytes
    - Viewed (0)
Back to top