Search Options

Results per page
Sort
Preferred Languages
Advance

Results 321 - 330 of 956 for sekond (0.12 sec)

  1. cmd/batch-expire.go

    func (r BatchJobExpire) Notify(ctx context.Context, body io.Reader) error {
    	if r.NotificationCfg.Endpoint == "" {
    		return nil
    	}
    
    	ctx, cancel := context.WithTimeout(ctx, 10*time.Second)
    	defer cancel()
    
    	req, err := http.NewRequestWithContext(ctx, http.MethodPost, r.NotificationCfg.Endpoint, body)
    	if err != nil {
    		return err
    	}
    
    	if r.NotificationCfg.Token != "" {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 18 17:59:03 UTC 2024
    - 21.9K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/util/concurrent/FluentFutureTest.java

    import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
    import static java.util.concurrent.Executors.newScheduledThreadPool;
    import static java.util.concurrent.TimeUnit.SECONDS;
    import static org.junit.Assert.assertThrows;
    
    import com.google.common.annotations.GwtCompatible;
    import com.google.common.annotations.GwtIncompatible;
    import com.google.common.annotations.J2ktIncompatible;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Feb 13 14:28:25 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  3. build-logic/binary-compatibility/src/test/kotlin/gradlebuild/binarycompatibility/AbstractAcceptedApiChangesMaintenanceTaskIntegrationTest.kt

            firstAcceptedApiChangesFile = projectDir.resolve("src/changes/accepted-changes/accepted-public-api-changes.json")
            secondAcceptedApiChangesFile = projectDir.resolve("src/changes/accepted-changes/second-accepted-public-api-changes.json")
    
            projectDir.resolve("build.gradle.kts")
                .writeText(
                    """
                        plugins {
                            id("gradlebuild.binary-compatibility")
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Tue Jun 04 14:00:46 UTC 2024
    - 6K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/hash/SipHashFunction.java

      /**
       * @param c the number of compression rounds (must be positive)
       * @param d the number of finalization rounds (must be positive)
       * @param k0 the first half of the key
       * @param k1 the second half of the key
       */
      SipHashFunction(int c, int d, long k0, long k1) {
        checkArgument(
            c > 0, "The number of SipRound iterations (c=%s) during Compression must be positive.", c);
        checkArgument(
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Apr 20 18:43:59 UTC 2021
    - 5.3K bytes
    - Viewed (0)
  5. docs/en/docs/tutorial/dependencies/sub-dependencies.md

    ```
    
    ////
    
    It declares an optional query parameter `q` as a `str`, and then it just returns it.
    
    This is quite simple (not very useful), but will help us focus on how the sub-dependencies work.
    
    ## Second dependency, "dependable" and "dependant"
    
    Then you can create another dependency function (a "dependable") that at the same time declares a dependency of its own (so it is a "dependant" too):
    
    //// tab | Python 3.10+
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  6. okhttp/src/test/java/okhttp3/CallTest.kt

        // First CONNECT call needs a new connection.
        assertThat(server.takeRequest().sequenceNumber).isEqualTo(0)
    
        // Second CONNECT call needs a new connection.
        assertThat(server.takeRequest().sequenceNumber).isEqualTo(0)
    
        // GET reuses the connection from the second connect.
        assertThat(server.takeRequest().sequenceNumber).isEqualTo(1)
      }
    
      @Test
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Apr 10 19:46:48 UTC 2024
    - 142.5K bytes
    - Viewed (0)
  7. android/guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java

     * the License.
     */
    
    package com.google.common.util.concurrent.testing;
    
    import static java.util.concurrent.TimeUnit.MILLISECONDS;
    import static java.util.concurrent.TimeUnit.SECONDS;
    import static org.junit.Assert.assertThrows;
    
    import com.google.common.annotations.GwtIncompatible;
    import com.google.common.util.concurrent.ListenableFuture;
    import java.util.concurrent.CancellationException;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Sep 06 18:30:30 UTC 2023
    - 6K bytes
    - Viewed (0)
  8. internal/http/dial_linux.go

    			_ = syscall.SetsockoptInt(fd, syscall.IPPROTO_TCP, unix.TCP_QUICKACK, 1)
    
    			/// Enable keep-alive
    			{
    				_ = unix.SetsockoptInt(fd, unix.SOL_SOCKET, unix.SO_KEEPALIVE, 1)
    
    				// The time (in seconds) the connection needs to remain idle before
    				// TCP starts sending keepalive probes
    				_ = syscall.SetsockoptInt(fd, syscall.IPPROTO_TCP, syscall.TCP_KEEPIDLE, 15)
    
    				// Number of probes.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 23 10:53:03 UTC 2024
    - 5K bytes
    - Viewed (0)
  9. guava/src/com/google/common/util/concurrent/AtomicLongMap.java

       * {@code key} (or zero, if there is none) is passed as the first argument to {@code
       * accumulatorFunction}, and {@code x} is passed as the second argument.
       *
       * @since 21.0
       */
      @CanIgnoreReturnValue
      public long accumulateAndGet(K key, long x, LongBinaryOperator accumulatorFunction) {
        checkNotNull(accumulatorFunction);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Apr 01 16:15:01 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  10. istioctl/pkg/waypoint/waypoint.go

    	waypointName    = constants.DefaultNamespaceWaypoint
    	enrollNamespace bool
    	overwrite       bool
    )
    
    const waitTimeout = 90 * time.Second
    
    func Cmd(ctx cli.Context) *cobra.Command {
    	makeGateway := func(forApply bool) (*gateway.Gateway, error) {
    		ns := ctx.NamespaceOrDefault(ctx.Namespace())
    		if ctx.Namespace() == "" && !forApply {
    			ns = ""
    		}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 19.6K bytes
    - Viewed (0)
Back to top