- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 17 for Grovers (0.19 sec)
-
internal/logger/config.go
break } brokers = append(brokers, *host) } if err != nil { return cfg, err } clientAuthCfgVal := getCfgVal(EnvKafkaTLSClientAuth, k, kv.Get(KafkaTLSClientAuth)) clientAuth, err := strconv.Atoi(clientAuthCfgVal) if err != nil { return cfg, err } kafkaArgs := kafka.Config{ Enabled: enabled, Brokers: brokers,
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Thu Mar 07 20:17:46 GMT 2024 - 15.8K bytes - Viewed (0) -
common-protos/k8s.io/api/storage/v1beta1/generated.proto
} // CSINodeSpec holds information about the specification of all CSI drivers installed on a node message CSINodeSpec { // drivers is a list of information of all CSI Drivers existing on a node. // If all drivers in the list are uninstalled, this can become empty. // +patchMergeKey=name // +patchStrategy=merge repeated CSINodeDriver drivers = 1; } // CSIStorageCapacity stores the result of one CSI GetCapacity call.
Plain Text - Registered: Wed Mar 27 22:53:09 GMT 2024 - Last Modified: Mon Mar 11 18:43:24 GMT 2024 - 24.9K bytes - Viewed (0) -
common-protos/k8s.io/api/storage/v1/generated.proto
} // CSINodeSpec holds information about the specification of all CSI drivers installed on a node message CSINodeSpec { // drivers is a list of information of all CSI Drivers existing on a node. // If all drivers in the list are uninstalled, this can become empty. // +patchMergeKey=name // +patchStrategy=merge repeated CSINodeDriver drivers = 1; } // CSIStorageCapacity stores the result of one CSI GetCapacity call.
Plain Text - Registered: Wed Mar 27 22:53:09 GMT 2024 - Last Modified: Mon Mar 11 18:43:24 GMT 2024 - 24.7K bytes - Viewed (0) -
internal/config/notify/legacy.go
Key: config.Enable, Value: config.EnableOn, }, config.KV{ Key: target.KafkaBrokers, Value: func() string { var brokers []string for _, broker := range cfg.Brokers { brokers = append(brokers, broker.String()) } return strings.Join(brokers, config.ValueSeparator) }(), }, config.KV{ Key: target.KafkaTopic, Value: cfg.Topic, }, config.KV{
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Tue Mar 19 04:37:54 GMT 2024 - 13.1K bytes - Viewed (0) -
internal/config/notify/parse.go
return nil, err } if !enabled { continue } var brokers []xnet.Host brokersEnv := target.EnvKafkaBrokers if k != config.Default { brokersEnv = brokersEnv + config.Default + k } kafkaBrokers := env.Get(brokersEnv, kv.Get(target.KafkaBrokers)) if len(kafkaBrokers) == 0 { return nil, config.Errorf("kafka 'brokers' cannot be empty") }
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Tue Mar 19 04:37:54 GMT 2024 - 46.3K bytes - Viewed (0) -
cmd/metacache-entries.go
return other, other.isDir() == e.isDir() } eVers, eErr := e.xlmeta() oVers, oErr := other.xlmeta() if eErr != nil || oErr != nil { return nil, false } // check both fileInfo's have same number of versions, if not skip // the `other` entry. if len(eVers.versions) != len(oVers.versions) { eTime := eVers.latestModtime() oTime := oVers.latestModtime() if !eTime.Equal(oTime) { if eTime.After(oTime) {
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Tue Mar 19 20:23:12 GMT 2024 - 23K bytes - Viewed (0) -
docs/en/docs/history-design-future.md
Plain Text - Registered: Sun Mar 24 07:19:08 GMT 2024 - Last Modified: Fri Mar 22 01:42:11 GMT 2024 - 4.1K bytes - Viewed (0) -
common-protos/k8s.io/api/storage/v1alpha1/generated.proto
// node. message CSIStorageCapacity { // Standard object's metadata. The name has no particular meaning. It must be // be a DNS subdomain (dots allowed, 253 characters). To ensure that // there are no conflicts with other CSI drivers on the cluster, the recommendation // is to use csisc-<uuid>, a generated name, or a reverse-domain name which ends // with the unique CSI driver name. // // Objects are namespaced. //
Plain Text - Registered: Wed Mar 27 22:53:09 GMT 2024 - Last Modified: Mon Mar 11 18:43:24 GMT 2024 - 9.4K bytes - Viewed (0) -
cmd/testdata/xl-meta-merge.zip
as the MinIO Client `mc` commandline tool. See [Test using MinIO Client `mc`](#test-using-minio-client-mc) for more information on using the `mc` commandline tool. For application developers, see <https://min.io/docs/minio/linux/developers/minio-drivers.html> to view MinIO SDKs for supported languages. > NOTE: Standalone MinIO servers are best suited for early development and evaluation. Certain features such as versioning, object locking, and bucket replication require distributed deploying MinIO...
ZIP Archive - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Fri Mar 08 17:50:48 GMT 2024 - 30.2K bytes - Viewed (0) -
common-protos/k8s.io/api/resource/v1alpha2/generated.proto
// DriverName defines the name of the dynamic resource driver that is // used for allocation of a ResourceClaim that uses this class. // // Resource drivers have a unique name in forward domain order // (acme.example.com). optional string driverName = 2; // ParametersRef references an arbitrary separate object that may hold
Plain Text - Registered: Wed Mar 27 22:53:09 GMT 2024 - Last Modified: Mon Mar 11 18:43:24 GMT 2024 - 14.4K bytes - Viewed (0)