Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 18 for task (0.13 sec)

  1. cmd/bucket-lifecycle.go

    							task.event.StorageClass, task.objInfo.Bucket, task.objInfo.Name, task.objInfo.VersionID, err))
    					}
    				}
    			} else {
    				ts := tierStats{
    					TotalSize:   uint64(task.objInfo.Size),
    					NumVersions: 1,
    				}
    				if task.objInfo.IsLatest {
    					ts.NumObjects = 1
    				}
    				t.addLastDayStats(task.event.StorageClass, ts)
    			}
    			t.activeTasks.Add(-1)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 17 05:09:58 GMT 2024
    - 33.1K bytes
    - Viewed (0)
  2. docs/ftp/README.md

    | append              | no        |
    | rename              | no        |
    
    MinIO supports following FTP/SFTP based protocols to access and manage data.
    
    - Secure File Transfer Protocol (SFTP) – Defined by the Internet Engineering Task Force (IETF) as an
      extended version of SSH 2.0, allowing file transfer over SSH and for use with Transport Layer
      Security (TLS) and VPN applications.
    
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 30 15:15:45 GMT 2024
    - 7.1K bytes
    - Viewed (0)
  3. internal/event/name.go

    		}
    		return res
    	default:
    		return []Name{name}
    	}
    }
    
    // Mask returns the type as mask.
    // Compound "All" types are expanded.
    func (name Name) Mask() uint64 {
    	if name < objectSingleTypesEnd {
    		return 1 << (name - 1)
    	}
    	var mask uint64
    	for _, n := range name.Expand() {
    		mask |= 1 << (n - 1)
    	}
    	return mask
    }
    
    // String - returns string representation of event type.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:11:10 GMT 2024
    - 10.4K bytes
    - Viewed (0)
  4. cmd/globals.go

    	globalTrace = pubsub.New[madmin.TraceInfo, madmin.TraceType](8)
    
    	// global Listen system to send S3 API events to registered listeners
    	globalHTTPListen = pubsub.New[event.Event, pubsub.Mask](0)
    
    	// global console system to send console logs to
    	// registered listeners
    	globalConsoleSys *HTTPConsoleLoggerSys
    
    	// All unique drives for this deployment
    	globalEndpoints EndpointServerPools
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 16.5K bytes
    - Viewed (0)
  5. helm/minio/values.yaml

      ## https://kubernetes.io/docs/tasks/access-application-cluster/configure-cloud-provider-firewall/#restrict-access-for-loadbalancer-service
      ##
      #loadBalancerSourceRanges:
      #   - 10.10.10.0/24
      loadBalancerSourceRanges: []
    
      ## service.externalTrafficPolicy minio service external traffic policy
    Others
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 10:14:37 GMT 2024
    - 18.4K bytes
    - Viewed (0)
  6. cmd/metrics-v2.go

    	expiryPendingTasks           MetricName = "expiry_pending_tasks"
    	expiryMissedTasks            MetricName = "expiry_missed_tasks"
    	expiryMissedFreeVersions     MetricName = "expiry_missed_freeversions"
    	expiryMissedTierJournalTasks MetricName = "expiry_missed_tierjournal_tasks"
    	expiryNumWorkers             MetricName = "expiry_num_workers"
    	transitionPendingTasks       MetricName = "transition_pending_tasks"
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 22:01:31 GMT 2024
    - 132.6K bytes
    - Viewed (0)
  7. cmd/erasure-server-pool.go

    			return pinfo, z.poolsWithObject(poolObjInfos, opts), nil
    		}
    
    		if isErrReadQuorum(pinfo.Err) && !opts.MetadataChg {
    			// read quorum is returned when the object is visibly
    			// present but its unreadable, we simply ask the writes to
    			// schedule to this pool instead. If there is no quorum
    			// it will fail anyways, however if there is quorum available
    			// with enough disks online but sufficiently inconsistent to
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 80.5K bytes
    - Viewed (0)
  8. cmd/update.go

    	internalLogIf(GlobalContext, err)
    
    	return err == nil
    }
    
    // MinIO Helm chart uses DownwardAPIFile to write pod label info to /podinfo/labels
    // More info: https://kubernetes.io/docs/tasks/inject-data-application/downward-api-volume-expose-pod-information/#store-pod-fields
    // Check if this is Helm package installation and report helm chart version
    func getHelmVersion(helmInfoFilePath string) string {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 18.7K bytes
    - Viewed (0)
  9. cmd/erasure-server-pool-rebalance.go

    	disks, _ := set.getOnlineDisksWithHealing(false)
    	if len(disks) == 0 {
    		return fmt.Errorf("no online drives found for set with endpoints %s", set.getEndpoints())
    	}
    
    	// However many we ask, versions must exist on ~50%
    	listingQuorum := (set.setDriveCount + 1) / 2
    
    	// How to resolve partial results.
    	resolver := metadataResolutionParams{
    		dirQuorum: listingQuorum, // make sure to capture all quorum ratios
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 19:29:28 GMT 2024
    - 27.2K bytes
    - Viewed (0)
  10. cmd/erasure-object.go

    	disks := er.getDisks()
    
    	ropts := ReadOptions{
    		ReadData: readData,
    		Healing:  false,
    	}
    
    	mrfCheck := make(chan FileInfo)
    	defer xioutil.SafeClose(mrfCheck)
    
    	var rw sync.Mutex
    
    	// Ask for all disks first;
    	go func() {
    		ctx, cancel := context.WithCancel(ctx)
    		defer cancel()
    
    		wg := sync.WaitGroup{}
    		for i, disk := range disks {
    			if disk == nil {
    				done <- false
    				continue
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 77.2K bytes
    - Viewed (2)
Back to top