Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 81 - 90 of 300 for brokers (0.07 seconds)

  1. cmd/batch-expire.go

    	oi, ok := oiCache[fmt.Sprintf("%s-%s", toDel.ObjectName, toDel.VersionID)]
    	return oi, ok
    }
    
    func batchObjsForDelete(ctx context.Context, r *BatchJobExpire, ri *batchJobInfo, job BatchJobRequest, api ObjectLayer, wk *workers.Workers, expireCh <-chan []expireObjInfo) {
    	vc, _ := globalBucketVersioningSys.Get(r.Bucket)
    	retryAttempts := job.Expire.Retry.Attempts
    	if retryAttempts <= 0 {
    		retryAttempts = batchExpireJobDefaultRetries
    	}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Apr 22 11:16:32 GMT 2025
    - 23K bytes
    - Click Count (0)
  2. guava/src/com/google/common/collect/AbstractBiMap.java

        inverse.delegate.clear();
        Entry<K, V> broken = null;
        Iterator<Entry<K, V>> itr = this.delegate.entrySet().iterator();
        while (itr.hasNext()) {
          Entry<K, V> entry = itr.next();
          K k = entry.getKey();
          V v = entry.getValue();
          K conflict = inverse.delegate.putIfAbsent(v, k);
          if (conflict != null) {
            broken = entry;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Sep 22 15:50:50 GMT 2025
    - 14.3K bytes
    - Click Count (0)
  3. android/guava-testlib/test/com/google/common/testing/EqualsTesterTest.java

        } catch (AssertionFailedError e) {
          assertErrorMessage(e, "bar [group 1, item 2] must be Object#equals to foo [group 1, item 1]");
          return;
        }
        fail("should failed because symmetry is broken");
      }
    
      public void testTransitivityBrokenInEqualityGroup() {
        EqualsTester tester =
            new EqualsTester()
                .addEqualityGroup(
                    named("foo").addPeers("bar", "baz"),
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed May 14 19:40:47 GMT 2025
    - 13.1K bytes
    - Click Count (0)
  4. docs/uk/docs/deployment/docker.md

    COPY ./app /code/app
    
    # (1)!
    CMD ["fastapi", "run", "app/main.py", "--port", "80", "--workers", "4"]
    ```
    
    1. Тут ми використовуємо опцію командного рядка `--workers`, щоб встановити кількість працівників 4.
    
    Ось кілька прикладів, коли це може мати сенс:
    
    #### Простий застосунок { #a-simple-app }
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 18:27:41 GMT 2026
    - 44.2K bytes
    - Click Count (0)
  5. internal/config/heal/help.go

    			Optional:    true,
    			Type:        "int",
    		},
    		config.HelpKV{
    			Key:         DriveWorkers,
    			Description: `the number of workers per drive to heal a new disk replacement` + defaultHelpPostfix(DriveWorkers),
    			Optional:    true,
    			Type:        "int",
    		},
    	}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon Sep 11 21:48:54 GMT 2023
    - 1.8K bytes
    - Click Count (0)
  6. build-tools-internal/src/main/java/org/elasticsearch/gradle/internal/ElasticsearchJavaPlugin.java

                    toStringable(() -> Boolean.toString(VersionProperties.isElasticsearchSnapshot()))
                );
            });
    
            project.getPluginManager().apply("nebula.info-broker");
            project.getPluginManager().apply("nebula.info-basic");
            project.getPluginManager().apply("nebula.info-java");
            project.getPluginManager().apply("nebula.info-jar");
        }
    
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Mon Sep 27 16:04:42 GMT 2021
    - 7.3K bytes
    - Click Count (0)
  7. ci/README.md

    and deploy TensorFlow. This folder is typically used by continuous integration
    (CI) tools to build and test TensorFlow whenever there is a change to the
    code. This folder is broken into subfolders that represent the level of support
    Created: Tue Apr 07 12:39:13 GMT 2026
    - Last Modified: Tue Jun 06 21:00:01 GMT 2023
    - 825 bytes
    - Click Count (0)
  8. guava-testlib/test/com/google/common/testing/EqualsTesterTest.java

        } catch (AssertionFailedError e) {
          assertErrorMessage(e, "bar [group 1, item 2] must be Object#equals to foo [group 1, item 1]");
          return;
        }
        fail("should failed because symmetry is broken");
      }
    
      public void testTransitivityBrokenInEqualityGroup() {
        EqualsTester tester =
            new EqualsTester()
                .addEqualityGroup(
                    named("foo").addPeers("bar", "baz"),
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed May 14 19:40:47 GMT 2025
    - 13.1K bytes
    - Click Count (0)
  9. internal/config/notify/help.go

    			Optional:    true,
    			Type:        "on|off",
    		},
    		config.HelpKV{
    			Key:         target.AmqpDurable,
    			Description: "persist queue across broker restarts when set to 'on', default is 'off'",
    			Optional:    true,
    			Type:        "on|off",
    		},
    		config.HelpKV{
    			Key:         target.AmqpNoWait,
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Sep 06 23:06:30 GMT 2024
    - 19.2K bytes
    - Click Count (0)
  10. internal/logger/help.go

    			Optional:    true,
    			Type:        "sentence",
    		},
    	}
    
    	HelpKafka = config.HelpKVS{
    		config.HelpKV{
    			Key:         KafkaBrokers,
    			Description: "comma separated list of Kafka broker addresses",
    			Type:        "csv",
    		},
    		config.HelpKV{
    			Key:         KafkaTopic,
    			Description: "Kafka topic used for bucket notifications",
    			Optional:    true,
    			Type:        "string",
    		},
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed Sep 11 22:20:42 GMT 2024
    - 7.4K bytes
    - Click Count (0)
Back to Top