Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 91 for rootTask (0.14 sec)

  1. internal/config/etcd/etcd.go

    	// Default path prefix for all keys on etcd, other than CoreDNSPath.
    	cfg.PathPrefix = env.Get(EnvEtcdPathPrefix, kvs.Get(PathPrefix))
    	if etcdSecure {
    		cfg.TLS = &tls.Config{
    			RootCAs: rootCAs,
    		}
    		// This is only to support client side certificate authentication
    		// https://coreos.com/etcd/docs/latest/op-guide/security.html
    		etcdClientCertFile := env.Get(EnvEtcdClientCert, kvs.Get(ClientCert))
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4.8K bytes
    - Viewed (0)
  2. pilot/pkg/model/disabled_ledger.go

    	return "", nil
    }
    
    func (d *DisabledLedger) Delete(key string) error {
    	return nil
    }
    
    func (d *DisabledLedger) Get(key string) (string, error) {
    	return "", nil
    }
    
    func (d *DisabledLedger) RootHash() string {
    	return ""
    }
    
    func (d *DisabledLedger) GetPreviousValue(previousHash, key string) (result string, err error) {
    	return "", errors.New("distribution tracking is disabled")
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 23 17:08:31 UTC 2023
    - 1.3K bytes
    - Viewed (0)
  3. internal/config/notify/parse.go

    			if !args.Enable {
    				continue
    			}
    			args.TLS.RootCAs = transport.TLSClientConfig.RootCAs
    			t, err := target.NewKafkaTarget(id, args, logOnceIf)
    			if err != nil {
    				return nil, err
    			}
    			targets = append(targets, t)
    
    		}
    
    	case config.NotifyMQTTSubSys:
    		mqttTargets, err := GetNotifyMQTT(cfg[config.NotifyMQTTSubSys], transport.TLSClientConfig.RootCAs)
    		if err != nil {
    			return nil, err
    		}
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 46.4K bytes
    - Viewed (0)
  4. internal/event/target/mqtt.go

    		SetCleanSession(true).
    		SetUsername(args.User).
    		SetPassword(args.Password).
    		SetMaxReconnectInterval(args.MaxReconnectInterval).
    		SetKeepAlive(args.KeepAlive).
    		SetTLSConfig(&tls.Config{RootCAs: args.RootCAs}).
    		AddBroker(args.Broker.String())
    
    	target.client = mqtt.NewClient(options)
    
    	token := target.client.Connect()
    	ok := token.WaitTimeout(reconnectInterval)
    	if !ok {
    		return store.ErrNotConnected
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/testing/webhook_server.go

    	if err != nil {
    		t.Error(err)
    		t.FailNow()
    	}
    	rootCAs := x509.NewCertPool()
    	rootCAs.AppendCertsFromPEM(testcerts.CACert)
    	testServer := httptest.NewUnstartedServer(http.HandlerFunc(handler))
    	testServer.TLS = &tls.Config{
    		Certificates: []tls.Certificate{sCert},
    		ClientCAs:    rootCAs,
    		ClientAuth:   tls.RequireAndVerifyClientCert,
    	}
    	return testServer
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Nov 15 11:11:25 UTC 2021
    - 6.3K bytes
    - Viewed (0)
  6. internal/event/target/nats.go

    	}
    	if n.Secure || n.TLS && n.TLSSkipVerify {
    		connOpts = append(connOpts, nats.Secure(nil))
    	} else if n.TLS {
    		connOpts = append(connOpts, nats.Secure(&tls.Config{RootCAs: n.RootCAs}))
    	}
    	if n.CertAuthority != "" {
    		connOpts = append(connOpts, nats.RootCAs(n.CertAuthority))
    	}
    	if n.ClientCert != "" && n.ClientKey != "" {
    		connOpts = append(connOpts, nats.ClientCert(n.ClientCert, n.ClientKey))
    	}
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 12.8K bytes
    - Viewed (0)
  7. internal/config/identity/ldap/config.go

    		return val
    	}
    
    	ldapServer := getCfgVal(ServerAddr)
    	if ldapServer == "" {
    		return l, nil
    	}
    	l.LDAP = ldap.Config{
    		RootCAs:       rootCAs,
    		ServerAddr:    ldapServer,
    		SRVRecordName: getCfgVal(SRVRecordName),
    	}
    
    	// Parse explicitly set enable=on/off flag.
    	isEnableFlagExplicitlySet := false
    	if v := getCfgVal(config.Enable); v != "" {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  8. src/crypto/tls/handshake_client_test.go

    	if err != nil {
    		panic(err)
    	}
    
    	rootCAs := x509.NewCertPool()
    	rootCAs.AddCert(issuer)
    
    	clientConfig := &Config{
    		MaxVersion:         version,
    		CipherSuites:       []uint16{TLS_RSA_WITH_RC4_128_SHA},
    		ClientSessionCache: NewLRUClientSessionCache(32),
    		RootCAs:            rootCAs,
    		ServerName:         "example.golang",
    	}
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 03:10:12 UTC 2024
    - 88.7K bytes
    - Viewed (0)
  9. cmd/server-startup-msg.go

    	if color.IsTerminal() && (!globalServerCtxt.Anonymous && !globalServerCtxt.JSON && globalAPIConfig.permitRootAccess()) {
    		logger.Info(color.Blue("   RootUser: ") + color.Bold("%s ", cred.AccessKey))
    		logger.Info(color.Blue("   RootPass: ") + color.Bold("%s \n", cred.SecretKey))
    		if region != "" {
    			logger.Info(color.Blue("   Region: ") + color.Bold("%s", fmt.Sprintf(getFormatStr(len(region), 2), region)))
    		}
    	}
    
    	if globalBrowserEnabled {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 6.8K bytes
    - Viewed (0)
  10. internal/kms/config.go

    		if err != nil {
    			return nil, err
    		}
    
    		key, err := kms.ParseAPIKey(env.Get(EnvKMSAPIKey, ""))
    		if err != nil {
    			return nil, err
    		}
    
    		var rootCAs *x509.CertPool
    		if opts != nil && opts.CADir != "" {
    			rootCAs, err = certs.GetRootCAs(opts.CADir)
    			if err != nil {
    				return nil, err
    			}
    		}
    
    		client, err := kms.NewClient(&kms.Config{
    			Endpoints: endpoints,
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Wed Jun 12 14:31:26 UTC 2024
    - 13.9K bytes
    - Viewed (0)
Back to top