Search Options

Results per page
Sort
Preferred Languages
Advance

Results 3311 - 3320 of 3,421 for list (0.03 sec)

  1. internal/event/target/mqtt.go

    	}
    
    	// Do not send if the connection is not active.
    	_, err := target.isActive()
    	if err != nil {
    		return err
    	}
    
    	eventData, err := target.store.Get(key)
    	if err != nil {
    		// The last event key in a successful batch will be sent in the channel atmost once by the replayEvents()
    		// Such events will not exist and wouldve been already been sent successfully.
    		if os.IsNotExist(err) {
    			return nil
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/escape/ArrayBasedCharEscaper.java

      private final char[][] replacements;
      // The number of elements in the replacement array.
      private final int replacementsLength;
      // The first character in the safe range.
      private final char safeMin;
      // The last character in the safe range.
      private final char safeMax;
    
      /**
       * Creates a new ArrayBasedCharEscaper instance with the given replacement map and specified safe
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jan 18 20:55:09 UTC 2022
    - 6.3K bytes
    - Viewed (0)
  3. cmd/bucket-metadata.go

    			XMLNS: "http://s3.amazonaws.com/doc/2006-03-01/",
    		},
    		bucketTargetConfig:     &madmin.BucketTargets{},
    		bucketTargetConfigMeta: make(map[string]string),
    	}
    }
    
    // Return the last update of this bucket metadata, which
    // means, the last update of any policy document.
    func (b BucketMetadata) lastUpdate() (t time.Time) {
    	if b.PolicyConfigUpdatedAt.After(t) {
    		t = b.PolicyConfigUpdatedAt
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 28 15:32:18 UTC 2024
    - 18.2K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/cache/Striped64.java

          int r = rng.nextInt(); // Avoid zero to allow xorShift rehash
          h = hc[0] = (r == 0) ? 1 : r;
        } else h = hc[0];
        boolean collide = false; // True if last slot nonempty
        for (; ; ) {
          Cell[] as;
          Cell a;
          int n;
          long v;
          if ((as = cells) != null && (n = as.length) > 0) {
            if ((a = as[(n - 1) & h]) == null) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Jun 14 17:55:55 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  5. internal/event/target/kafka.go

    	if err = target.init(); err != nil {
    		return err
    	}
    	switch {
    	case key.ItemCount == 1:
    		var event event.Event
    		event, err = target.store.Get(key)
    		if err != nil {
    			// The last event key in a successful batch will be sent in the channel atmost once by the replayEvents()
    			// Such events will not exist and wouldve been already been sent successfully.
    			if os.IsNotExist(err) {
    				return nil
    			}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  6. compat/maven-compat/src/main/java/org/apache/maven/repository/legacy/DefaultUpdateCheckManager.java

                    }
    
                    getLogger().debug("Writing resolution-state to: " + touchfile);
                    channel.truncate(0);
                    props.store(Channels.newOutputStream(channel), "Last modified on: " + new Date());
    
                    lock.release();
                    lock = null;
    
                    channel.close();
                    channel = null;
                } catch (IOException e) {
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 12.1K bytes
    - Viewed (0)
  7. docs/pt/docs/deployment/server-workers.md

    ## Conceitos de Implantação
    
    Aqui você viu como usar vários **trabalhadores** para **paralelizar** a execução do aplicativo, aproveitar **vários núcleos** na CPU e conseguir atender **mais solicitações**.
    
    Da lista de conceitos de implantação acima, o uso de trabalhadores ajudaria principalmente com a parte da **replicação** e um pouco com as **reinicializações**, mas você ainda precisa cuidar dos outros:
    
    * **Segurança - HTTPS**
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Fri Sep 20 11:01:03 UTC 2024
    - 9K bytes
    - Viewed (0)
  8. cmd/site-replication-metrics.go

    }
    
    // SRStatus has replication stats at deployment level
    type SRStatus struct {
    	ReplicatedSize int64 `json:"completedReplicationSize"`
    	// Total number of failed operations including metadata updates in the last minute
    	Failed RTimedMetrics `json:"failedReplication"`
    	// Total number of completed operations
    	ReplicatedCount int64 `json:"replicationCount"`
    	// Replication latency information
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Feb 06 06:00:45 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  9. docs/debugging/xl-meta/main.go

    								splitDataShards[i] += v
    							}
    						}
    						var hist [256]int
    						for _, v := range splitDataShards {
    							hist[v]++
    						}
    
    						for _, v := range hist[m.data-hasParity : m.shards] {
    							if attempt > 0 {
    								break
    							}
    							if v == 0 {
    								continue
    							}
    							for i, v := range hist[:m.shards] {
    								if v > 0 {
    									if i < m.data {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 05 11:57:44 UTC 2024
    - 40.3K bytes
    - Viewed (0)
  10. docs/sts/README.md

    - Temporary credentials are short-term, as the name implies. They can be configured to last for anywhere from a few minutes to several hours. After the credentials expire, MinIO no longer recognizes them or allows any kind of access from API requests made with them.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 25 00:44:15 UTC 2022
    - 7.8K bytes
    - Viewed (0)
Back to top