Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 41 for atomic (0.21 sec)

  1. common-protos/k8s.io/api/admissionregistration/v1/generated.proto

      // If '*' is present, the length of the slice must be one.
      // Required.
      // +listType=atomic
      repeated string apiGroups = 1;
    
      // APIVersions is the API versions the resources belong to. '*' is all versions.
      // If '*' is present, the length of the slice must be one.
      // Required.
      // +listType=atomic
      repeated string apiVersions = 2;
    
      // Resources is a list of resources this rule applies to.
      //
    Plain Text
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Mon Mar 11 18:43:24 GMT 2024
    - 24.4K bytes
    - Viewed (0)
  2. okhttp/src/test/java/okhttp3/WholeOperationTimeoutTest.kt

    import java.io.InterruptedIOException
    import java.net.HttpURLConnection
    import java.time.Duration
    import java.util.concurrent.CountDownLatch
    import java.util.concurrent.TimeUnit
    import java.util.concurrent.atomic.AtomicReference
    import kotlin.test.assertFailsWith
    import mockwebserver3.MockResponse
    import mockwebserver3.MockWebServer
    import okhttp3.MediaType.Companion.toMediaTypeOrNull
    import okhttp3.TestUtil.repeat
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 10.5K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt

    import java.util.concurrent.ExecutorService
    import java.util.concurrent.RejectedExecutionException
    import java.util.concurrent.TimeUnit.MILLISECONDS
    import java.util.concurrent.atomic.AtomicBoolean
    import java.util.concurrent.atomic.AtomicInteger
    import java.util.concurrent.locks.ReentrantLock
    import okhttp3.Call
    import okhttp3.Callback
    import okhttp3.EventListener
    import okhttp3.Interceptor
    import okhttp3.OkHttpClient
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 17.9K bytes
    - Viewed (2)
  4. common-protos/k8s.io/api/autoscaling/v2/generated.proto

      // policies is a list of potential scaling polices which can be used during scaling.
      // At least one policy must be specified, otherwise the HPAScalingRules will be discarded as invalid
      // +listType=atomic
      // +optional
      repeated HPAScalingPolicy policies = 2;
    }
    
    // HorizontalPodAutoscaler is the configuration for a horizontal pod
    // autoscaler, which automatically manages the replica count of any resource
    Plain Text
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Mon Mar 11 18:43:24 GMT 2024
    - 21.3K bytes
    - Viewed (0)
  5. docs/bigdata/README.md

    the connector to use S3 and other S3-compatible object stores such as MinIO. MapReduce workloads typically interact with object stores in the same way they do with HDFS. These workloads rely on HDFS atomic rename functionality to complete writing data to the datastore. Object storage operations are atomic by nature and they do not require/implement rename API. The default S3A committer emulates renames through copy and delete APIs. This interaction pattern causes significant loss of performance because...
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Sep 29 04:28:45 GMT 2022
    - 14.7K bytes
    - Viewed (0)
  6. api/go1.17.txt

    pkg runtime/cgo (openbsd-amd64-cgo), type Handle uintptr
    pkg strconv, func QuotedPrefix(string) (string, error)
    pkg sync/atomic, method (*Value) CompareAndSwap(interface{}, interface{}) bool
    pkg sync/atomic, method (*Value) Swap(interface{}) interface{}
    pkg syscall (netbsd-386), const SYS_WAIT6 = 481
    pkg syscall (netbsd-386), const SYS_WAIT6 ideal-int
    Plain Text
    - Registered: Tue May 07 11:14:38 GMT 2024
    - Last Modified: Fri Feb 17 20:31:46 GMT 2023
    - 18K bytes
    - Viewed (0)
  7. api/go1.4.txt

    pkg runtime, type MemStats struct, PauseEnd [256]uint64
    pkg runtime/debug, type GCStats struct, PauseEnd []time.Time
    
    # CL 136710045 sync/atomic: add Value, Dmitriy Vyukov <******@****.***>
    pkg sync/atomic, method (*Value) Load() interface{}
    pkg sync/atomic, method (*Value) Store(interface{})
    pkg sync/atomic, type Value struct
    
    # CL 126190043 syscall: support UID/GID map files for Linux user namespaces, Mrunal Patel <******@****.***>
    Plain Text
    - Registered: Tue May 07 11:14:38 GMT 2024
    - Last Modified: Fri Dec 12 03:01:01 GMT 2014
    - 34K bytes
    - Viewed (0)
  8. okhttp/src/test/java/okhttp3/DispatcherTest.kt

    import java.io.IOException
    import java.io.InterruptedIOException
    import java.net.UnknownHostException
    import java.util.concurrent.CountDownLatch
    import java.util.concurrent.TimeUnit
    import java.util.concurrent.atomic.AtomicBoolean
    import kotlin.test.assertFailsWith
    import org.junit.jupiter.api.BeforeEach
    import org.junit.jupiter.api.Tag
    import org.junit.jupiter.api.Test
    import org.junit.jupiter.api.extension.RegisterExtension
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Fri Apr 05 03:30:42 GMT 2024
    - 12.7K bytes
    - Viewed (0)
  9. okhttp/src/test/java/okhttp3/ResponseBodyJvmTest.kt

    import assertk.assertions.isEqualTo
    import assertk.assertions.isTrue
    import java.io.IOException
    import java.io.InputStreamReader
    import java.io.Reader
    import java.nio.charset.StandardCharsets
    import java.util.concurrent.atomic.AtomicBoolean
    import kotlin.test.assertFailsWith
    import okhttp3.MediaType.Companion.toMediaType
    import okhttp3.ResponseBody.Companion.toResponseBody
    import okhttp3.internal.and
    import okio.Buffer
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 13K bytes
    - Viewed (0)
  10. okhttp/src/main/kotlin/okhttp3/internal/publicsuffix/PublicSuffixDatabase.kt

     */
    package okhttp3.internal.publicsuffix
    
    import java.io.IOException
    import java.io.InterruptedIOException
    import java.net.IDN
    import java.util.concurrent.CountDownLatch
    import java.util.concurrent.atomic.AtomicBoolean
    import okhttp3.internal.and
    import okhttp3.internal.platform.Platform
    import okio.FileSystem
    import okio.GzipSource
    import okio.Path
    import okio.Path.Companion.toPath
    import okio.buffer
    
    /**
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 11.7K bytes
    - Viewed (0)
Back to top