Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 15 for Jones (0.18 sec)

  1. internal/logger/target/kafka/kafka.go

    	// stop the replay go-routine.
    	if h.store != nil {
    		h.storeCtxCancel()
    	}
    
    	// Set logch to nil and close it.
    	// This will block all Send operations,
    	// and finish the existing ones.
    	// All future ones will be discarded.
    	h.logChMu.Lock()
    	xioutil.SafeClose(h.logCh)
    	h.logCh = nil
    	h.logChMu.Unlock()
    
    	if h.producer != nil {
    		h.producer.Close()
    		h.client.Close()
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 10.1K bytes
    - Viewed (1)
  2. cmd/post-policy_test.go

    	retStr := "{"
    	retStr = retStr + expirationStr + ","
    	retStr += conditionStr
    	retStr += "}"
    
    	return []byte(retStr)
    }
    
    // newPostPolicyBytesV4 - creates a bare bones postpolicy string with key and bucket matches.
    func newPostPolicyBytesV4(credential, bucketName, objectKey string, expiration time.Time) []byte {
    	t := UTCNow()
    	// Add the expiration date.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 16:45:54 GMT 2024
    - 29.6K bytes
    - Viewed (0)
  3. cmd/peer-s3-client.go

    		// of such a bucket. This is needed here as we identify such
    		// buckets here while listing buckets. As part of regular
    		// globalBucketMetadataSys.Init() call would get a valid
    		// buckets only and not the quourum lost ones like this, so
    		// explicit call
    		for bktName, count := range bucketsMap {
    			if count < quorum {
    				// Queue a bucket heal task
    				globalMRFState.addPartialOp(partialOperation{
    					bucket: bktName,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 14.8K bytes
    - Viewed (0)
  4. cmd/erasure-server-pool-decom.go

    	decomBuckets := make([]decomBucketInfo, len(buckets))
    	for i := range buckets {
    		decomBuckets[i] = decomBucketInfo{
    			Name: buckets[i].Name,
    		}
    	}
    
    	// Buckets data are dispersed in multiple zones/sets, make
    	// sure to decommission the necessary metadata.
    	decomMetaBuckets := []decomBucketInfo{
    		{
    			Name:   minioMetaBucket,
    			Prefix: minioConfigPrefix,
    		},
    		{
    			Name:   minioMetaBucket,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 15:18:21 GMT 2024
    - 41.5K bytes
    - Viewed (1)
  5. helm-releases/minio-1.0.3.tgz

    ## If defined, it must be a sub-directory of the path specified in {{ .Values.mountPath }} ## bucketRoot: "" # Number of drives attached to a node drivesPerNode: 1 # Number of MinIO containers running replicas: 4 # Number of expanded MinIO clusters zones: 1 ## TLS Settings for MinIO tls: enabled: false ## Create a secret with private.key and public.crt files and pass that here. Ref: https://github.com/minio/minio/tree/master/docs/tls/kubernetes#2-create-kubernetes-secret certSecret: "" publicCrt: public.crt...
    Others
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Aug 24 19:04:07 GMT 2021
    - 13.6K bytes
    - Viewed (0)
  6. README.md

    ```sh
    firewall-cmd --get-active-zones
    ```
    
    This command gets the active zone(s). Now, apply port rules to the relevant zones returned above. For example if the zone is `public`, use
    
    ```sh
    firewall-cmd --zone=public --add-port=9000/tcp --permanent
    ```
    
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Feb 14 17:51:34 GMT 2024
    - 18.7K bytes
    - Viewed (0)
  7. helm-releases/minio-1.0.0.tgz

    ## If defined, it must be a sub-directory of the path specified in {{ .Values.mountPath }} ## bucketRoot: "" # Number of drives attached to a node drivesPerNode: 1 # Number of MinIO containers running replicas: 4 # Number of expanded MinIO clusters zones: 1 ## TLS Settings for MinIO tls: enabled: false ## Create a secret with private.key and public.crt files and pass that here. Ref: https://github.com/minio/minio/tree/master/docs/tls/kubernetes#2-create-kubernetes-secret certSecret: "" publicCrt: public.crt...
    Others
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Aug 20 22:30:54 GMT 2021
    - 13.5K bytes
    - Viewed (0)
  8. internal/logger/target/http/http.go

    	h.storeCtxCancel()
    
    	// Wait for messages to be sent...
    	h.wg.Wait()
    
    	// Set logch to nil and close it.
    	// This will block all Send operations,
    	// and finish the existing ones.
    	// All future ones will be discarded.
    	h.logChMu.Lock()
    	xioutil.SafeClose(h.logCh)
    	h.logCh = nil
    	h.logChMu.Unlock()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Mar 25 16:44:20 GMT 2024
    - 14.9K bytes
    - Viewed (0)
  9. cmd/iam-object-store.go

    	if !ok {
    		// There has been no store yet. This should never happen!
    		iamLogIf(GlobalContext, errors.New("WARNING: no cached IAM listing found"))
    		return nil
    	}
    
    	// Scan STS users on disk and purge expired ones. We do not need to hold a
    	// lock with store.lock() here.
    	stsAccountsFromStore := map[string]UserIdentity{}
    	stsAccPoliciesFromStore := xsync.NewMapOf[string, MappedPolicy]()
    	for _, item := range iamListing[stsListKey] {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 05 21:26:41 GMT 2024
    - 19.9K bytes
    - Viewed (0)
  10. helm-releases/minio-1.0.1.tgz

    ## If defined, it must be a sub-directory of the path specified in {{ .Values.mountPath }} ## bucketRoot: "" # Number of drives attached to a node drivesPerNode: 1 # Number of MinIO containers running replicas: 4 # Number of expanded MinIO clusters zones: 1 ## TLS Settings for MinIO tls: enabled: false ## Create a secret with private.key and public.crt files and pass that here. Ref: https://github.com/minio/minio/tree/master/docs/tls/kubernetes#2-create-kubernetes-secret certSecret: "" publicCrt: public.crt...
    Others
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Aug 20 22:32:29 GMT 2021
    - 13.5K bytes
    - Viewed (0)
Back to top