Search Options

Results per page
Sort
Preferred Languages
Advance

Results 341 - 350 of 496 for lister (0.06 sec)

  1. cmd/callhome.go

    				duration = time.Second
    			}
    			time.Sleep(duration)
    		}
    	}()
    }
    
    func runCallhome(ctx context.Context, objAPI ObjectLayer) bool {
    	// Make sure only 1 callhome is running on the cluster.
    	locker := objAPI.NewNSLock(minioMetaBucket, "callhome/runCallhome.lock")
    	lkctx, err := locker.GetLock(ctx, callhomeLeaderLockTimeout)
    	if err != nil {
    		// lock timedout means some other node is the leader,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 17 16:53:34 UTC 2024
    - 5.3K bytes
    - Viewed (0)
  2. common-protos/k8s.io/api/storage/v1/generated.proto

      // deployed on such a cluster and the deployment determines which mode that is, for example
      // via a command line parameter of the driver.
      //
      // This field is immutable.
      //
      // +optional
      optional bool podInfoOnMount = 2;
    
      // volumeLifecycleModes defines what kind of volumes this CSI volume driver supports.
      // The default if the list is empty is "Persistent", which is the usage defined by the
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 24.7K bytes
    - Viewed (0)
  3. cmd/fmt-gen.go

    )
    
    var fmtGenFlags = []cli.Flag{
    	cli.IntFlag{
    		Name:  "parity",
    		Usage: "specify erasure code parity",
    	},
    	cli.StringFlag{
    		Name:  "deployment-id",
    		Usage: "deployment-id of the MinIO cluster for which format.json is needed",
    	},
    	cli.StringFlag{
    		Name:   "address",
    		Value:  ":" + GlobalMinioDefaultPort,
    		Usage:  "bind to a specific ADDRESS:PORT, ADDRESS can be an IP or hostname",
    		EnvVar: "MINIO_ADDRESS",
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:22:04 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  4. cmd/sftp-server.go

    		SSHConfig:            sshConfig,
    		HandleSFTPSession:    handleSFTPSession,
    	})
    	if err != nil {
    		logger.Fatal(err, "Unable to start SFTP Server")
    	}
    
    	err = sftpServer.Listen()
    	if err != nil {
    		logger.Fatal(err, "SFTP Server had an unrecoverable error while accepting connections")
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 20 20:00:29 UTC 2024
    - 16K bytes
    - Viewed (0)
  5. architecture/tests/integration.md

      1. Testing of traffic management policies (e.g., routing, retries, timeouts).
      1. Validation of load balancing configurations.
      1. Specific `istioctl proxy-config` commands being tested: `bootstrap`, `cluster`, `endpoint`, `listener`, `route`, `all`.
    - **Setup**: The main test setup in this folder initializes the Istio control plane and configures the Pilot component.
    
    ### Ambient Integration Tests
    
    - **Location**: `tests/integration/ambient`
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 00:57:44 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  6. cmd/metrics-v3-replication.go

    	replicationRecentBacklogCountMD = NewGaugeMD(replicationRecentBacklogCount,
    		"Total number of objects seen in replication backlog in the last 5 minutes")
    )
    
    // loadClusterReplicationMetrics - `MetricsLoaderFn` for cluster replication metrics
    // such as transfer rate and objects queued.
    func loadClusterReplicationMetrics(ctx context.Context, m MetricValues, c *metricsCache) error {
    	st := globalReplicationStats.Load()
    	if st == nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  7. tensorflow/c/eager/c_api_test.cc

    // 5. Start the GRPC server for worker 0 using C.
    // 6. Create a context D using the full cluster server def E.
    // 7. Read the variable in D.
    TEST(CAPI, SingleHostServerDefV1Works) {
      // Create a server def that represents a 2-process cluster and a client.
      // Example:
      //
      // cluster { job { name: "worker"
      //                 tasks { key: 0 value: "localhost:14522" }
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Thu Aug 03 20:50:20 UTC 2023
    - 94.6K bytes
    - Viewed (0)
  8. architecture/ambient/ztunnel.md

    The obvious solution to this is to put the list of selected workloads into the policy itself.
    However, this means anytime a workload changes (often), we need to update the policy.
    
    Instead, the opposite was chosen: each workload will list the policies that select it.
    This works out to be more efficient in common cases where policies change much less often than workloads.
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Jul 17 23:10:17 UTC 2024
    - 16.8K bytes
    - Viewed (0)
  9. cmd/admin-handlers.go

    		} else {
    			targetIDStatus[targetID.ID] = madmin.Status{Status: string(madmin.ItemOffline)}
    		}
    		list := lambdaMap[targetID.Name]
    		list = append(list, targetIDStatus)
    		lambdaMap[targetID.Name] = list
    	}
    
    	notify := make([]map[string][]madmin.TargetIDStatus, len(lambdaMap))
    	counter := 0
    	for key, value := range lambdaMap {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 99.7K bytes
    - Viewed (0)
  10. docs/distributed/DECOMMISSION.md

    - A pool interrupted during the decommission process, such as for a cluster restart, resumes from where it left off.
    
    ## How to decommission a pool
    
    ```
    λ mc admin decommission start alias/ http://minio{1...2}/data{1...4}
    ```
    
    ## Status decommissioning a pool
    
    ### Decommissioning without args lists all pools
    
    ```
    λ mc admin decommission status alias/
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 11 14:59:49 UTC 2022
    - 8.3K bytes
    - Viewed (0)
Back to top