- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 18 for Kromer (0.15 sec)
-
internal/event/target/kafka.go
config.Metadata.Retry.Backoff = (1 * time.Second) config.Metadata.RefreshFrequency = (15 * time.Minute) target.config = config brokers := []string{} for _, broker := range args.Brokers { brokers = append(brokers, broker.String()) } client, err := sarama.NewClient(brokers, config) if err != nil { if !errors.Is(err, sarama.ErrOutOfBrokers) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 20 08:16:35 GMT 2024 - 13K bytes - Viewed (0) -
internal/logger/target/kafka/kafka.go
sconfig.Metadata.Retry.Backoff = (10 * time.Second) sconfig.Metadata.RefreshFrequency = (15 * time.Minute) h.config = sconfig var brokers []string for _, broker := range h.kconfig.Brokers { brokers = append(brokers, broker.String()) } client, err := sarama.NewClient(brokers, sconfig) if err != nil { return err } producer, err := sarama.NewSyncProducerFromClient(client)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 10.1K bytes - Viewed (1) -
cmd/iam-etcd-store.go
// a large number of users r, err := ies.client.Get(cctx, basePrefix, etcd.WithPrefix()) if err != nil { return err } // Parse all users values to create the proper data model for _, userKv := range r.Kvs { if err = ies.getUserKV(ctx, userKv, userType, m, basePrefix); err != nil && err != errNoSuchUser { return err } } return nil }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 13.6K bytes - Viewed (0) -
helm-releases/minio-5.0.14.tgz
"minio.fullname" .) | trunc 63 | trimSuffix "-" -}} {{- end -}} {{/* Properly format optional additional arguments to MinIO binary */}} {{- define "minio.extraArgs" -}} {{- range .Values.extraArgs -}} {{ " " }}{{ . }} {{- end -}} {{- end -}} {{/* Return the proper Docker Image Registry Secret Names */}} {{- define "minio.imagePullSecrets" -}} {{/* Helm 2.11 supports the assignment of a value to a variable defined in a different scope, but Helm 2.9 and 2.10 does not support it, so we need to implement this if-else...
Others - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Sep 30 20:46:10 GMT 2023 - 20.6K bytes - Viewed (0) -
cmd/signature-v4-utils_test.go
// "X-Amz-Content-Sha256" not set and PreSigned Signature v4 not enabled, sha256 checksum calculation is not skipped. {"", "", "X-Amz-Credential", "", true}, // Test case - 8. // "X-Amz-Content-Sha256" has a proper value cannot skip. {"X-Amz-Content-Sha256", "somevalue", "", "", false}, } for i, testCase := range testCases { // creating an input HTTP request. // Only the headers are relevant for this particular test.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 05 21:26:41 GMT 2024 - 14.3K bytes - Viewed (0) -
cmd/erasure-metadata.go
return 0, 0, nil } partOffset = offset // Seek until object offset maps to a particular part offset. for i, part := range fi.Parts { partIndex = i // Offset is smaller than size we have reached the proper part offset. if partOffset < part.Size { return partIndex, partOffset, nil } // Continue to towards the next part. partOffset -= part.Size } internalLogIf(ctx, InvalidRange{})
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 19.2K bytes - Viewed (1) -
helm-releases/minio-5.0.15.tgz
"minio.fullname" .) | trunc 63 | trimSuffix "-" -}} {{- end -}} {{/* Properly format optional additional arguments to MinIO binary */}} {{- define "minio.extraArgs" -}} {{- range .Values.extraArgs -}} {{ " " }}{{ . }} {{- end -}} {{- end -}} {{/* Return the proper Docker Image Registry Secret Names */}} {{- define "minio.imagePullSecrets" -}} {{/* Helm 2.11 supports the assignment of a value to a variable defined in a different scope, but Helm 2.9 and 2.10 does not support it, so we need to implement this if-else...
Others - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Jan 12 18:18:57 GMT 2024 - 20.8K bytes - Viewed (0) -
helm-releases/minio-5.1.0.tgz
"minio.fullname" .) | trunc 63 | trimSuffix "-" -}} {{- end -}} {{/* Properly format optional additional arguments to MinIO binary */}} {{- define "minio.extraArgs" -}} {{- range .Values.extraArgs -}} {{ " " }}{{ . }} {{- end -}} {{- end -}} {{/* Return the proper Docker Image Registry Secret Names */}} {{- define "minio.imagePullSecrets" -}} {{/* Helm 2.11 supports the assignment of a value to a variable defined in a different scope, but Helm 2.9 and 2.10 does not support it, so we need to implement this if-else...
Others - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Mar 03 18:49:37 GMT 2024 - 21.3K bytes - Viewed (0) -
internal/config/notify/legacy.go
config.KV{ 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 May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 19 04:37:54 GMT 2024 - 13.1K bytes - Viewed (0) -
internal/config/notify/help.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 19 04:37:54 GMT 2024 - 18.8K bytes - Viewed (0)