- Sort Score
- Result 10 results
- Languages All
Results 181 - 190 of 245 for rubbish (0.05 sec)
-
internal/event/target/nsq.go
data, err := json.Marshal(event.Log{EventName: eventData.EventName, Key: key, Records: []event.Event{eventData}}) if err != nil { return err } return target.producer.Publish(target.args.Topic, data) } // SendFromStore - reads an event from store and sends it to NSQ. func (target *NSQTarget) SendFromStore(key store.Key) error { if err := target.init(); err != nil { return err }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 7.1K bytes - Viewed (0) -
gradle/libs.versions.toml
gradlePlugin-kotlinSerialization = { module = "org.jetbrains.kotlin:kotlin-serialization", version.ref = "org-jetbrains-kotlin" } gradlePlugin-mavenPublish = "com.vanniktech:gradle-maven-publish-plugin:0.29.0" gradlePlugin-mavenSympathy = "io.github.usefulness.maven-sympathy:io.github.usefulness.maven-sympathy.gradle.plugin:0.3.0" gradlePlugin-shadow = "gradle.plugin.com.github.johnrengelman:shadow:8.0.0"
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Oct 28 11:53:44 UTC 2024 - 7.5K bytes - Viewed (0) -
cmd/os-instrumented.go
return func(err error) { osAction() } } startTime := time.Now() return func(err error) { duration := time.Since(startTime) globalOSMetrics.incTime(s, duration) globalTrace.Publish(osTrace(s, startTime, duration, strings.Join(paths, " -> "), err)) } } // RemoveAll captures time taken to call the underlying os.RemoveAll func RemoveAll(dirPath string) (err error) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Feb 15 01:09:38 UTC 2024 - 6.3K bytes - Viewed (0) -
compat/maven-compat/src/main/java/org/apache/maven/repository/RepositorySystem.java
ArtifactResolutionResult resolve(ArtifactResolutionRequest request); // Install // Deploy // Map types of artifacts // // Raw file transfers // void publish( ArtifactRepository repository, File source, String remotePath, ArtifactTransferListener transferListener) throws ArtifactTransferFailedException; void retrieve(
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 7.7K bytes - Viewed (0) -
LICENSE
of this software and associated documentation files (the "Software"), to deal in the Software without restriction, including without limitation the rights to use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of the Software, and to permit persons to whom the Software is furnished to do so, subject to the following conditions:
Registered: Wed Nov 06 11:36:14 UTC 2024 - Last Modified: Tue Jan 23 11:07:23 UTC 2024 - 23.1K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/kt/WiresharkExample.kt
) : EventListener() { var random: String? = null lateinit var currentThread: Thread private val loggerHandler = object : Handler() { override fun publish(record: LogRecord) { // Try to avoid multi threading issues with concurrent requests if (Thread.currentThread() != currentThread) { return }
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 10.7K bytes - Viewed (0) -
cmd/peer-rest-server.go
// Trace Publisher uses nonblocking publish and hence does not wait for slow subscribers. // Use buffered channel to take care of burst sends or slow w.Write() err = globalTrace.SubscribeJSON(traceOpts.TraceTypes(), out, ctx.Done(), func(entry madmin.TraceInfo) bool { return shouldTrace(entry, traceOpts) }, &wg) if err != nil { return grid.NewRemoteErr(err) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Oct 04 11:32:32 UTC 2024 - 53.2K bytes - Viewed (0) -
cmd/batch-handlers.go
if globalTrace.NumSubscribers(madmin.TraceBatch) > 0 { globalTrace.Publish(batchJobTrace(d, job, startTime, duration, info, attempts, err)) return } switch d { case batchJobMetricReplication: if globalTrace.NumSubscribers(madmin.TraceBatchReplication) > 0 { globalTrace.Publish(batchJobTrace(d, job, startTime, duration, info, attempts, err)) } case batchJobMetricKeyRotation:
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Oct 18 15:32:09 UTC 2024 - 62.2K bytes - Viewed (0) -
licenses/github.com/klauspost/compress/LICENSE
of this software and associated documentation files (the "Software"), to deal in the Software without restriction, including without limitation the rights to use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of the Software, and to permit persons to whom the Software is furnished to do so, subject to the following conditions:
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Tue Nov 30 19:13:15 UTC 2021 - 16.3K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/OkHttpClientTestRule.kt
).joinToString(separator = "|"), ) append(").*") }, ) private val testLogHandler = object : Handler() { override fun publish(record: LogRecord) { val recorded = when (record.loggerName) { TaskRunner::class.java.name -> recordTaskRunner Http2::class.java.name -> recordFrames
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 10.5K bytes - Viewed (0)