Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 321 for atomsvc (0.11 sec)

  1. internal/kms/config.go

    package kms
    
    import (
    	"bytes"
    	"context"
    	"crypto/tls"
    	"crypto/x509"
    	"encoding/pem"
    	"errors"
    	"fmt"
    	"os"
    	"path/filepath"
    	"strings"
    	"sync/atomic"
    	"syscall"
    	"time"
    
    	"github.com/minio/kms-go/kes"
    	"github.com/minio/kms-go/kms"
    	"github.com/minio/pkg/v3/certs"
    	"github.com/minio/pkg/v3/ellipses"
    	"github.com/minio/pkg/v3/env"
    )
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 11:46:39 UTC 2024
    - 14.2K bytes
    - Viewed (0)
  2. common-protos/k8s.io/api/certificates/v1/generated.proto

    message CertificateSigningRequestSpec {
      // request contains an x509 certificate signing request encoded in a "CERTIFICATE REQUEST" PEM block.
      // When serialized as JSON or YAML, the data is additionally base64-encoded.
      // +listType=atomic
      optional bytes request = 1;
    
      // signerName indicates the requested signer, and is a qualified name.
      //
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  3. common-protos/k8s.io/api/node/v1beta1/generated.proto

      // be rejected in admission.
      // +optional
      // +mapType=atomic
      map<string, string> nodeSelector = 1;
    
      // tolerations are appended (excluding duplicates) to pods running with this
      // RuntimeClass during admission, effectively unioning the set of nodes
      // tolerated by the pod and the RuntimeClass.
      // +optional
      // +listType=atomic
      repeated k8s.io.api.core.v1.Toleration tolerations = 2;
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  4. internal/logger/target/http/http.go

    // buffer is full, new logs are just ignored and an error
    // is returned to the caller.
    type Target struct {
    	totalMessages  atomic.Int64
    	failedMessages atomic.Int64
    	status         atomic.Int32
    
    	// Worker control
    	workers    atomic.Int64
    	maxWorkers int64
    
    	// workerStartMu sync.Mutex
    	lastStarted time.Time
    
    	wg sync.WaitGroup
    
    	// Channel of log entries.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 11 22:20:42 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  5. common-protos/k8s.io/api/flowcontrol/v1beta3/generated.proto

      // +listType=atomic
      // Required.
      repeated Subject subjects = 1;
    
      // `resourceRules` is a slice of ResourcePolicyRules that identify matching requests according to their verb and the
      // target resource.
      // At least one of `resourceRules` and `nonResourceRules` has to be non-empty.
      // +listType=atomic
      // +optional
      repeated ResourcePolicyRule resourceRules = 2;
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 19.5K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/hash/LongAddables.java

     * the License.
     */
    
    package com.google.common.hash;
    
    import com.google.common.base.Supplier;
    import java.util.concurrent.atomic.AtomicLong;
    
    /**
     * Source of {@link LongAddable} objects that deals with GWT, Unsafe, and all that.
     *
     * @author Louis Wasserman
     */
    @ElementTypesAreNonnullByDefault
    final class LongAddables {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jan 04 17:27:14 UTC 2022
    - 1.9K bytes
    - Viewed (0)
  7. cni/pkg/nodeagent/server.go

    	Stop()
    }
    
    type Server struct {
    	ctx        context.Context
    	kubeClient kube.Client
    
    	handlers  K8sHandlers
    	dataplane MeshDataplane
    
    	isReady *atomic.Value
    
    	cniServerStopFunc func()
    }
    
    func NewServer(ctx context.Context, ready *atomic.Value, pluginSocket string, args AmbientArgs) (*Server, error) {
    	client, err := buildKubeClient(args.KubeConfig)
    	if err != nil {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Sep 25 20:54:34 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/util/concurrent/AtomicsTest.java

     * limitations under the License.
     */
    
    package com.google.common.util.concurrent;
    
    import static org.junit.Assert.assertThrows;
    
    import com.google.common.testing.NullPointerTester;
    import java.util.concurrent.atomic.AtomicReferenceArray;
    import junit.framework.TestCase;
    
    /**
     * Unit test for {@link Atomics}.
     *
     * @author Kurt Alfred Kluever
     */
    public class AtomicsTest extends TestCase {
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 2.5K bytes
    - Viewed (0)
  9. android/guava-testlib/test/com/google/common/testing/ArbitraryInstancesTest.java

    import java.util.concurrent.SynchronousQueue;
    import java.util.concurrent.ThreadFactory;
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.atomic.AtomicBoolean;
    import java.util.concurrent.atomic.AtomicInteger;
    import java.util.concurrent.atomic.AtomicLong;
    import java.util.concurrent.atomic.AtomicReference;
    import java.util.regex.MatchResult;
    import java.util.regex.Pattern;
    import junit.framework.TestCase;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 21.8K bytes
    - Viewed (0)
  10. common-protos/k8s.io/api/flowcontrol/v1beta1/generated.proto

      // +listType=atomic
      // Required.
      repeated Subject subjects = 1;
    
      // `resourceRules` is a slice of ResourcePolicyRules that identify matching requests according to their verb and the
      // target resource.
      // At least one of `resourceRules` and `nonResourceRules` has to be non-empty.
      // +listType=atomic
      // +optional
      repeated ResourcePolicyRule resourceRules = 2;
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 19.4K bytes
    - Viewed (0)
Back to top