Search Options

Results per page
Sort
Preferred Languages
Advance

Results 411 - 420 of 791 for Breaters (0.09 sec)

  1. internal/event/target/elasticsearch.go

    	if err != nil {
    		if err != store.ErrNotConnected {
    			target.loggerOnce(context.Background(), err, target.ID().String())
    		}
    		return err
    	}
    
    	return nil
    }
    
    // NewElasticsearchTarget - creates new Elasticsearch target.
    func NewElasticsearchTarget(id string, args ElasticsearchArgs, loggerOnce logger.LogOnce) (*ElasticsearchTarget, error) {
    	var queueStore store.Store[event.Event]
    	if args.QueueDir != "" {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 15K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/collect/TopKSelector.java

      private final @Nullable T[] buffer;
      private int bufferSize;
    
      /**
       * The largest of the lowest k elements we've seen so far relative to this comparator. If
       * bufferSize ≥ k, then we can ignore any elements greater than this value.
       */
      @CheckForNull private T threshold;
    
      @SuppressWarnings("unchecked") // TODO(cpovirk): Consider storing Object[] instead of T[].
      private TopKSelector(Comparator<? super T> comparator, int k) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  3. guava/src/com/google/common/base/FinalizableReferenceQueue.java

     * finalizeReferent()} on the remaining references.
     *
     * <p>As an example of how this is used, imagine you have a class {@code MyServer} that creates a
     * {@link java.net.ServerSocket ServerSocket}, and you would like to ensure that the {@code
     * ServerSocket} is closed even if the {@code MyServer} object is garbage-collected without calling
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Jul 11 20:51:36 UTC 2024
    - 13.1K bytes
    - Viewed (0)
  4. android/guava-testlib/src/com/google/common/collect/testing/google/SetMultimapTestSuiteBuilder.java

    import java.util.Collections;
    import java.util.EnumSet;
    import java.util.List;
    import java.util.Map.Entry;
    import java.util.Set;
    import junit.framework.TestSuite;
    
    /**
     * Creates, based on your criteria, a JUnit test suite that exhaustively tests a {@code SetMultimap}
     * implementation.
     *
     * @author Louis Wasserman
     */
    @GwtIncompatible
    public class SetMultimapTestSuiteBuilder<K, V>
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  5. guava/src/com/google/common/eventbus/Subscriber.java

     * class). This property is used to ensure that no subscriber method is registered more than once.
     *
     * @author Colin Decker
     */
    @ElementTypesAreNonnullByDefault
    class Subscriber {
    
      /** Creates a {@code Subscriber} for {@code method} on {@code listener}. */
      static Subscriber create(EventBus bus, Object listener, Method method) {
        return isDeclaredThreadSafe(method)
            ? new Subscriber(bus, listener, method)
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 06 00:47:57 UTC 2021
    - 4.7K bytes
    - Viewed (0)
  6. compat/maven-embedder/src/main/java/org/apache/maven/cli/transfer/SimplexTransferListener.java

            this.delegate = requireNonNull(delegate);
            if (queueSize < 1 || batchMaxSize < 1) {
                throw new IllegalArgumentException("Queue and batch sizes must be greater than 1");
            }
            this.batchMaxSize = batchMaxSize;
            this.blockOnLastEvent = blockOnLastEvent;
    
            this.eventQueue = new ArrayBlockingQueue<>(queueSize);
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  7. cmd/consolelogger.go

    	totalMessages  int64
    	failedMessages int64
    
    	sync.RWMutex
    	pubsub   *pubsub.PubSub[log.Info, madmin.LogMask]
    	console  *console.Target
    	nodeName string
    	logBuf   *ring.Ring
    }
    
    // NewConsoleLogger - creates new HTTPConsoleLoggerSys with all nodes subscribed to
    // the console logging pub sub system
    func NewConsoleLogger(ctx context.Context, w io.Writer) *HTTPConsoleLoggerSys {
    	return &HTTPConsoleLoggerSys{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/graph/ValueGraphBuilder.java

     *     #from(ValueGraph)}.
     * @since 20.0
     */
    @Beta
    @ElementTypesAreNonnullByDefault
    public final class ValueGraphBuilder<N, V> extends AbstractGraphBuilder<N> {
    
      /** Creates a new instance with the specified edge directionality. */
      private ValueGraphBuilder(boolean directed) {
        super(directed);
      }
    
      /** Returns a {@link ValueGraphBuilder} for building directed graphs. */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Jun 03 01:21:31 UTC 2022
    - 8K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/io/ByteSourceTester.java

          suite.addTest(
              suiteForBytes(
                  slicedLongMaxValue, bytes, name + ".slice[long, Long.MAX_VALUE]", desc, false));
    
          // test a slice() of the ByteSource starting at an offset greater than its size
          ByteSourceFactory slicedOffsetPastEnd =
              SourceSinkFactories.asSlicedByteSourceFactory(
                  factory, expected.length + 2, expected.length + 10);
          suite.addTest(
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jul 23 14:22:54 UTC 2024
    - 8.6K bytes
    - Viewed (0)
  10. guava/src/com/google/common/hash/Fingerprint2011.java

        seedA += part2;
        seedA += part3;
        seedB += rotateRight(seedA, 23);
        output[0] = seedA + part4;
        output[1] = seedB + c;
      }
    
      /*
       * Compute an 8-byte hash of a byte array of length greater than 64 bytes.
       */
      private static long fullFingerprint(byte[] bytes, int offset, int length) {
        // For lengths over 64 bytes we hash the end first, and then as we
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Dec 28 17:50:25 UTC 2021
    - 6.5K bytes
    - Viewed (0)
Back to top