Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 186 for replay (0.19 sec)

  1. cmd/notification.go

    	for index, err := range g.Wait() {
    		if err != nil {
    			sys.addNodeErr(&reply[index], sys.peerClients[index], err)
    		}
    	}
    	return reply
    }
    
    // GetNetInfo - Network information
    func (sys *NotificationSys) GetNetInfo(ctx context.Context) []madmin.NetInfo {
    	reply := make([]madmin.NetInfo, len(sys.peerClients))
    
    	g := errgroup.WithNErrs(len(sys.peerClients))
    	for index, client := range sys.peerClients {
    		if client == nil {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 12 18:13:36 GMT 2024
    - 44.5K bytes
    - Viewed (0)
  2. internal/config/config_test.go

    		},
    		// Keys and input order of k=v is same.
    		{
    			input: `connection_string="host=localhost port=2832" comment="really long comment"`,
    			keys:  []string{"connection_string", "comment"},
    			expectedFields: map[string]struct{}{
    				`connection_string="host=localhost port=2832"`: {},
    				`comment="really long comment"`:                {},
    			},
    		},
    		// Keys with spaces in between
    		{
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Aug 18 22:55:17 GMT 2022
    - 4.2K bytes
    - Viewed (0)
  3. internal/logger/target/http/http.go

    	// support reading multiple events on a stream for example
    	// like : Splunk HTTP Event collector, if you are unsure
    	// set this to '1'.
    	batchSize   int
    	payloadType string
    
    	// store to persist and replay the logs to the target
    	// to avoid missing events when the target is down.
    	store          store.Store[interface{}]
    	storeCtxCancel context.CancelFunc
    
    	initQueueOnce once.Init
    
    	config Config
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Mar 25 16:44:20 GMT 2024
    - 14.9K bytes
    - Viewed (0)
  4. internal/logger/target/kafka/kafka.go

    	// Reading logCh must hold read lock on logChMu (to avoid read race)
    	// Sending a value on logCh must hold read lock on logChMu (to avoid closing)
    	logCh   chan interface{}
    	logChMu sync.RWMutex
    
    	// store to persist and replay the logs to the target
    	// to avoid missing events when the target is down.
    	store          store.Store[interface{}]
    	storeCtxCancel context.CancelFunc
    
    	initKafkaOnce      once.Init
    	initQueueStoreOnce once.Init
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 10.1K bytes
    - Viewed (1)
  5. README.md

    ```sh
    wget https://dl.min.io/server/minio/release/linux-amd64/minio
    chmod +x minio
    ./minio server /data
    ```
    
    The following table lists supported architectures. Replace the `wget` URL with the architecture for your Linux host.
    
    Plain Text
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Wed Feb 14 17:51:34 GMT 2024
    - 18.7K bytes
    - Viewed (0)
  6. cmd/admin-handlers.go

    	for _, nerr := range globalNotificationSys.SignalService(serviceSig) {
    		if nerr.Err != nil {
    			logger.GetReqInfo(ctx).SetTags("peerAddress", nerr.Host.String())
    			adminLogIf(ctx, nerr.Err)
    		}
    	}
    
    	// Reply to the client before restarting, stopping MinIO server.
    	writeSuccessResponseHeadersOnly(w)
    
    	switch serviceSig {
    	case serviceFreeze:
    		freezeServices()
    	case serviceUnFreeze:
    		unfreezeServices()
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 21 11:43:18 GMT 2024
    - 97.3K bytes
    - Viewed (2)
  7. docs/bucket/replication/README.md

    a `X-Amz-Replication-Status` status of `REPLICA` indicates that the object was replicated successfully. Any replication failures are automatically re-attempted during a periodic disk scanner cycle.
    
    To perform bi-directional replication, repeat the above process on the target site - this time setting the source bucket as the replication target. It is recommended that replication be run in a system with at least two CPU's available to the process, so that replication can run in its own thread....
    Plain Text
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Jan 24 23:46:33 GMT 2023
    - 18.2K bytes
    - Viewed (0)
  8. cmd/admin-handlers-idp-config.go

    	// target, we need to check if a configuration value has been set previously
    	// to figure out if this is a valid create or update API call.
    
    	// This cannot really error (FIXME: improve the type for GetConfigInfo)
    	var cfgInfos []madmin.IDPCfgInfo
    	switch subSys {
    	case madmin.IdentityOpenIDSubSys:
    		cfgInfos, _ = globalIAMSys.OpenIDConfig.GetConfigInfo(s, cfgTarget)
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 12.7K bytes
    - Viewed (0)
  9. helm-releases/minio-5.0.3.tgz

    https://kubernetes.io/docs/concepts/containers/runtime-class/ ## runtimeClassName: "" ## Set default rootUser, rootPassword ## AccessKey and secretKey is generated when not set ## Distributed MinIO ref: https://min.io/docs/minio/linux/operations/install-deploy-manage/deploy-minio-multi-node-multi-drive.html ## rootUser: "" rootPassword: "" ## Use existing Secret that store following variables: ## ## | Chart var | .data.<key> in Secret | ## |:-------- ## | rootUser | rootUser | ## | rootPassword | rootPassword...
    Others
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Dec 19 08:53:02 GMT 2022
    - 20.3K bytes
    - Viewed (0)
  10. helm-releases/minio-5.0.6.tgz

    https://kubernetes.io/docs/concepts/containers/runtime-class/ ## runtimeClassName: "" ## Set default rootUser, rootPassword ## AccessKey and secretKey is generated when not set ## Distributed MinIO ref: https://min.io/docs/minio/linux/operations/install-deploy-manage/deploy-minio-multi-node-multi-drive.html ## rootUser: "" rootPassword: "" ## Use existing Secret that store following variables: ## ## | Chart var | .data.<key> in Secret | ## |:-------- ## | rootUser | rootUser | ## | rootPassword | rootPassword...
    Others
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Feb 13 06:53:06 GMT 2023
    - 20.3K bytes
    - Viewed (0)
Back to top