Search Options

Results per page
Sort
Preferred Languages
Advance

Results 181 - 190 of 245 for rubbish (0.08 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top