leash - Code Search

common-protos/k8s.io/api/coordination/v1/generated.proto

option go_package = "k8s.io/api/coordination/v1";

// Lease defines a lease concept.
message Lease {
  // More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#metadata
  // +optional
  optional k8s.io.apimachinery.pkg.apis.meta.v1.ObjectMeta metadata = 1;

  // spec contains the specification of the Lease.

Plain Text

- Registered: Wed May 08 22:53:08 GMT 2024

- Last Modified: Mon Mar 11 18:43:24 GMT 2024

- 2.6K bytes

- Viewed (0)

github.com/google/guava

guava-tests/test/com/google/common/collect/TopKSelectorTest.java

    TopKSelector<Integer> top = TopKSelector.least(0);
    for (int i = 0; i < 10; i++) {
      top.offer(i);
    }
    assertThat(top.topK()).isEmpty();
  }

  public void testNoElementsOffered() {
    TopKSelector<Integer> top = TopKSelector.least(10);
    assertThat(top.topK()).isEmpty();
  }

  public void testOfferedFewerThanK() {
    TopKSelector<Integer> top = TopKSelector.least(10);
    top.offer(3);
    top.offer(5);

Java

- Registered: Fri Apr 19 12:43:09 GMT 2024

- Last Modified: Thu Mar 07 18:34:03 GMT 2024

- 3.9K bytes

- Viewed (0)

github.com/google/guava

android/guava-tests/test/com/google/common/primitives/SignedBytesTest.java

    List<byte[]> ordered =
        Arrays.asList(
            new byte[] {},
            new byte[] {LEAST},
            new byte[] {LEAST, LEAST},
            new byte[] {LEAST, (byte) 1},
            new byte[] {(byte) 1},
            new byte[] {(byte) 1, LEAST},
            new byte[] {GREATEST, GREATEST - (byte) 1},
            new byte[] {GREATEST, GREATEST},

Java

- Registered: Fri May 03 12:43:13 GMT 2024

- Last Modified: Tue Feb 20 17:00:05 GMT 2024

- 7K bytes

- Viewed (0)

github.com/istio/istio

common-protos/k8s.io/api/coordination/v1beta1/generated.proto

option go_package = "k8s.io/api/coordination/v1beta1";

// Lease defines a lease concept.
message Lease {
  // More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#metadata
  // +optional
  optional k8s.io.apimachinery.pkg.apis.meta.v1.ObjectMeta metadata = 1;

  // spec contains the specification of the Lease.

Plain Text

- Registered: Wed May 08 22:53:08 GMT 2024

- Last Modified: Mon Mar 11 18:43:24 GMT 2024

- 2.7K bytes

- Viewed (0)

github.com/google/guava

guava-tests/test/com/google/common/primitives/SignedBytesTest.java

    List<byte[]> ordered =
        Arrays.asList(
            new byte[] {},
            new byte[] {LEAST},
            new byte[] {LEAST, LEAST},
            new byte[] {LEAST, (byte) 1},
            new byte[] {(byte) 1},
            new byte[] {(byte) 1, LEAST},
            new byte[] {GREATEST, GREATEST - (byte) 1},
            new byte[] {GREATEST, GREATEST},

Java

- Registered: Fri Apr 12 12:43:09 GMT 2024

- Last Modified: Tue Feb 20 17:00:05 GMT 2024

- 7K bytes

- Viewed (0)

github.com/google/guava

android/guava-tests/test/com/google/common/collect/TopKSelectorTest.java

    TopKSelector<Integer> top = TopKSelector.least(0);
    for (int i = 0; i < 10; i++) {
      top.offer(i);
    }
    assertThat(top.topK()).isEmpty();
  }

  public void testNoElementsOffered() {
    TopKSelector<Integer> top = TopKSelector.least(10);
    assertThat(top.topK()).isEmpty();
  }

  public void testOfferedFewerThanK() {
    TopKSelector<Integer> top = TopKSelector.least(10);
    top.offer(3);
    top.offer(5);

Java

- Registered: Fri May 03 12:43:13 GMT 2024

- Last Modified: Thu Mar 07 18:34:03 GMT 2024

- 3.9K bytes

- Viewed (0)

github.com/google/guava

android/guava/src/com/google/common/hash/AbstractStreamingHasher.java

   * Constructor for use by subclasses. This hasher instance will process chunks of the specified
   * size.
   *
   * @param chunkSize the number of bytes available per {@link #process(ByteBuffer)} invocation;
   *     must be at least 4
   */
  protected AbstractStreamingHasher(int chunkSize) {
    this(chunkSize, chunkSize);
  }

  /**
   * Constructor for use by subclasses. This hasher instance will process chunks of the specified

Java

- Registered: Fri Apr 26 12:43:10 GMT 2024

- Last Modified: Wed Jun 15 20:59:00 GMT 2022

- 7.1K bytes

- Viewed (0)

github.com/minio/minio

cmd/etcd.go

	timeoutCtx, cancel := context.WithTimeout(ctx, defaultContextTimeout)
	defer cancel()
	lease, err := client.Grant(timeoutCtx, ttl)
	if err != nil {
		return etcdErrToErr(err, client.Endpoints())
	}
	_, err = client.Put(timeoutCtx, key, string(data), etcd.WithLease(lease.ID))
	etcdLogIf(ctx, err)
	return etcdErrToErr(err, client.Endpoints())
}

Go

- Registered: Sun May 05 19:28:20 GMT 2024

- Last Modified: Thu Apr 04 12:04:40 GMT 2024

- 2.9K bytes

- Viewed (0)

github.com/google/guava

guava-tests/test/com/google/common/hash/AbstractNonStreamingHashFunctionTest.java

    // the output, so the input must be at least 32 bits, since the output has to be that long
    assertPutString(new char[] {'p', HashTestUtils.randomLowSurrogate(new Random())});
  }

  public void testPutStringWithHighSurrogate() {
    // we pad because the dummy hash function we use to test this, merely copies the input into
    // the output, so the input must be at least 32 bits, since the output has to be that long

Java

- Registered: Fri Apr 19 12:43:09 GMT 2024

- Last Modified: Mon Dec 04 17:37:03 GMT 2017

- 4.4K bytes

- Viewed (0)

github.com/google/guava

android/guava-tests/test/com/google/common/hash/AbstractNonStreamingHashFunctionTest.java

    // the output, so the input must be at least 32 bits, since the output has to be that long
    assertPutString(new char[] {'p', HashTestUtils.randomLowSurrogate(new Random())});
  }

  public void testPutStringWithHighSurrogate() {
    // we pad because the dummy hash function we use to test this, merely copies the input into
    // the output, so the input must be at least 32 bits, since the output has to be that long

Java

- Registered: Fri May 03 12:43:13 GMT 2024

- Last Modified: Mon Dec 04 17:37:03 GMT 2017

- 4.4K bytes

- Viewed (0)

Search Options