- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 122 for broken3 (0.14 sec)
-
platforms/core-runtime/concurrent/src/test/groovy/org/gradle/internal/concurrent/DefaultExecutorFactoryTest.groovy
def runnable1 = { instant.broken1 throw failure1 } def failure2 = new RuntimeException() def runnable2 = { instant.broken2 throw failure2 } when: def executor = factory.create('test') executor.execute(runnable1) thread.blockUntil.broken1 thread.block()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 19:07:35 UTC 2024 - 11.2K bytes - Viewed (0) -
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) { target.loggerOnce(context.Background(), err, target.ID().String())
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat Jun 01 15:02:59 UTC 2024 - 13.1K 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) if err != nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sun Jun 02 03:03:39 UTC 2024 - 10.2K bytes - Viewed (0) -
docs/logging/README.md
comment (sentence) optionally add a comment to this setting ``` Configure MinIO to send audit logs to locally running Kafka brokers ``` mc admin config set myminio/ audit_kafka:target1 brokers=localhost:29092 topic=auditlog mc admin service restart myminio/ ``` On another terminal assuming you have `kafkacat` installed ```
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu May 09 17:15:03 UTC 2024 - 10.4K bytes - Viewed (0) -
subprojects/core/src/integTest/groovy/org/gradle/api/FinalizerTaskIntegrationTest.groovy
} 2.times { fails "thing", "-Pthing.broken" result.assertTasksExecutedInOrder ":thing", ":finalizerDep", ":finalizer" } 2.times { fails "thing", "-PfinalizerDep.broken" result.assertTasksExecutedInOrder ":thing", ":finalizerDep" } 2.times { fails "thing", "-PfinalizerDep.broken", "--continue"
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri May 17 13:27:33 UTC 2024 - 32.3K bytes - Viewed (0) -
platforms/core-runtime/serialization/src/test/groovy/org/gradle/internal/serialize/MessageTest.groovy
} def "transports exception with broken methods"() { def broken = new CompletelyBrokenException() when: def transported = transport(broken) then: transported.class == CompletelyBrokenException } def "transports unserializable exception with broken methods"() { def broken = new CompletelyBrokenException() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Apr 15 16:06:56 UTC 2024 - 16.4K bytes - Viewed (0) -
platforms/core-configuration/configuration-cache/src/integTest/groovy/org/gradle/internal/cc/impl/ConfigurationCacheIncompatibleTasksIntegrationTest.groovy
withProblem("Task `:declared` of type `Broken`: cannot deserialize object of type 'org.gradle.api.artifacts.ConfigurationContainer' as these are not supported with the configuration cache.")
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:25 UTC 2024 - 10.3K bytes - Viewed (0) -
platforms/core-configuration/configuration-cache/src/integTest/groovy/org/gradle/internal/cc/impl/ConfigurationCacheUnsupportedTypesIntegrationTest.groovy
task other task broken(type: SomeTask) """ when: configurationCacheRunLenient "broken" then: problems.assertResultHasProblems(result) { withTotalProblemsCount(6) withUniqueProblems(
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:25 UTC 2024 - 28.3K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/DaemonStateCoordinator.java
} // Else, cancelled cleanly, so keep doing work break; case Broken: throw new IllegalStateException("This daemon is in a broken state."); case StopRequested: LOGGER.debug("daemon stop has been requested. Sleeping until state changes.");
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 06:47:38 UTC 2024 - 17.1K bytes - Viewed (0) -
subprojects/core/src/integTest/groovy/org/gradle/api/file/FileCollectionSymlinkIntegrationTest.groovy
"File" | InputFile "Directory" | InputDirectory } @Issue('https://github.com/gradle/gradle/issues/9904') def "task with a broken #classpathType.simpleName root input is accepted"() { def brokenClasspathEntry = file('broken.jar').createLink("broken.jar.target") def output = file("output.txt") buildFile << """ class CustomTask extends DefaultTask {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 09:03:53 UTC 2024 - 15.7K bytes - Viewed (0)