- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 91 for rootTask (0.14 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)