Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 14 for rootHash (0.16 sec)

  1. cmd/data-usage-cache.go

    	}
    	return n
    }
    
    // root returns the root of the cache.
    func (d *dataUsageCache) root() *dataUsageEntry {
    	return d.find(d.Info.Name)
    }
    
    // rootHash returns the root of the cache.
    func (d *dataUsageCache) rootHash() dataUsageHash {
    	return hashPath(d.Info.Name)
    }
    
    // clone returns a copy of the cache with no references to the existing.
    func (d *dataUsageCache) clone() dataUsageCache {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 34.7K bytes
    - Viewed (0)
  2. 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,
    			PreferServerCipherSuites: true,
    			MinVersion:               tls.VersionTLS12,
    			NextProtos:               []string{"http/1.1", "h2"},
    			ClientSessionCache:       tls.NewLRUClientSessionCache(64),
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 28 23:17:22 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  3. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 12.9K bytes
    - Viewed (0)
  4. cmd/server-startup-msg.go

    	if color.IsTerminal() && (!globalServerCtxt.Anonymous && !globalServerCtxt.JSON && globalAPIConfig.permitRootAccess()) {
    		logger.Startup(color.Blue("   RootUser: ") + color.Bold("%s ", cred.AccessKey))
    		logger.Startup(color.Blue("   RootPass: ") + color.Bold("%s \n", cred.SecretKey))
    		if region != "" {
    			logger.Startup(color.Blue("   Region: ") + color.Bold("%s", fmt.Sprintf(getFormatStr(len(region), 2), region)))
    		}
    	}
    
    	if globalBrowserEnabled {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Aug 23 14:11:35 UTC 2024
    - 6.2K bytes
    - Viewed (0)
  5. internal/event/target/kafka.go

    	config.Net.TLS.Config = tlsConfig
    	config.Net.TLS.Config.InsecureSkipVerify = args.TLS.SkipVerify
    	config.Net.TLS.Config.ClientAuth = args.TLS.ClientAuth
    	config.Net.TLS.Config.RootCAs = args.TLS.RootCAs
    
    	// These settings are needed to ensure that kafka client doesn't hang on brokers
    	// refer https://github.com/IBM/sarama/issues/765#issuecomment-254333355
    	config.Producer.Retry.Max = 2
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  6. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 47K bytes
    - Viewed (0)
  7. cmd/grid.go

    		Dialer: grid.ConnectWS(
    			grid.ContextDialer(xhttp.DialContextWithLookupHost(lookupHost, xhttp.NewInternodeDialContext(rest.DefaultTimeout, globalTCPOptions.ForWebsocket()))),
    			newCachedAuthToken(),
    			&tls.Config{
    				RootCAs:          globalRootCAs,
    				CipherSuites:     fips.TLSCiphers(),
    				CurvePreferences: fips.TLSCurveIDs(),
    			}),
    		Local:        local,
    		Hosts:        hosts,
    		AuthToken:    validateStorageRequestToken,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  8. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 11:46:39 UTC 2024
    - 14.2K bytes
    - Viewed (0)
  9. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  10. internal/config/identity/ldap/config.go

    			NextProtos:         []string{"h2", "http/1.1"},
    			ClientSessionCache: tls.NewLRUClientSessionCache(100),
    			CipherSuites:       fips.TLSCiphersBackwardCompatible(), // Contains RSA key exchange
    			RootCAs:            rootCAs,
    		},
    	}
    
    	// Parse explicitly set enable=on/off flag.
    	isEnableFlagExplicitlySet := false
    	if v := getCfgVal(config.Enable); v != "" {
    		isEnableFlagExplicitlySet = true
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 07 12:59:47 UTC 2024
    - 8.4K bytes
    - Viewed (0)
Back to top