Search Options

Results per page
Sort
Preferred Languages
Advance

Results 71 - 80 of 265 for eventbus (0.24 sec)

  1. impl/maven-core/src/main/java/org/apache/maven/execution/ExecutionListener.java

     * specific language governing permissions and limitations
     * under the License.
     */
    package org.apache.maven.execution;
    
    /**
     * Defines events that Maven fires during a build. <strong>Warning:</strong> This interface might be extended in future
     * Maven versions to support further events. Hence it is strongly recommended to derive custom listeners from
     * {@link AbstractExecutionListener} in order to avoid interoperability problems.
     *
     */
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 2K bytes
    - Viewed (0)
  2. cmd/bootstrap-messages.go

    	bs.mu.Lock()
    	defer bs.mu.Unlock()
    
    	if len(bs.info) > bootstrapTraceLimit {
    		return
    	}
    	bs.info = append(bs.info, info)
    }
    
    func (bs *bootstrapTracer) Events() []madmin.TraceInfo {
    	traceInfo := make([]madmin.TraceInfo, 0, bootstrapTraceLimit)
    
    	bs.mu.RLock()
    	for _, i := range bs.info {
    		traceInfo = append(traceInfo, i)
    	}
    	bs.mu.RUnlock()
    
    	return traceInfo
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 23 10:07:06 UTC 2023
    - 1.7K bytes
    - Viewed (0)
  3. internal/event/target/kafka.go

    			// Such events will not exist and wouldve been already been sent successfully.
    			if os.IsNotExist(err) {
    				return nil
    			}
    			return err
    		}
    		err = target.send(event)
    	case key.ItemCount > 1:
    		var events []event.Event
    		events, err = target.store.GetMultiple(key)
    		if err != nil {
    			if os.IsNotExist(err) {
    				return nil
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  4. cmd/metrics-v3-cluster-notification.go

    	notificationEventsErrorsTotalMD     = NewCounterMD(notificationEventsErrorsTotal, "Events that were failed to be sent to the targets")
    	notificationEventsSentTotalMD       = NewCounterMD(notificationEventsSentTotal, "Total number of events sent to the targets")
    	notificationEventsSkippedTotalMD    = NewCounterMD(notificationEventsSkippedTotal, "Events that were skipped to be sent to the targets due to the in-memory queue being full")
    )
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Apr 24 04:10:35 UTC 2024
    - 2.2K bytes
    - Viewed (0)
  5. .github/workflows/osv-scanner-scheduled.yml

    name: OSV-Scanner Scheduled Scan
    
    on:
      schedule:
        - cron: 0 4 * * 1
    
    permissions:
      # Require writing security events to upload SARIF file to security tab
      security-events: write
      # Only need to read contents
      contents: read
    
    jobs:
      scan-scheduled:
        if: github.repository == 'tensorflow/tensorflow'
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Fri Nov 01 08:40:10 UTC 2024
    - 1.6K bytes
    - Viewed (0)
  6. compat/maven-compat/src/test/java/org/apache/maven/repository/legacy/DefaultWagonManagerTest.java

    import org.apache.maven.wagon.TransferFailedException;
    import org.apache.maven.wagon.UnsupportedProtocolException;
    import org.apache.maven.wagon.Wagon;
    import org.apache.maven.wagon.events.TransferEvent;
    import org.apache.maven.wagon.events.TransferListener;
    import org.apache.maven.wagon.observers.AbstractTransferListener;
    import org.apache.maven.wagon.observers.Debug;
    import org.codehaus.plexus.testing.PlexusTest;
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  7. internal/config/notify/help.go

    	queueLimitComment = `maximum limit for undelivered messages, defaults to '100000'`
    )
    
    // Help template inputs for all notification targets
    var (
    	HelpWebhook = config.HelpKVS{
    		config.HelpKV{
    			Key:         target.WebhookEndpoint,
    			Description: "webhook server endpoint e.g. http://localhost:8080/minio/events",
    			Type:        "url",
    			Sensitive:   true,
    		},
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 19.2K bytes
    - Viewed (0)
  8. okhttp-sse/Module.md

    # Module okhttp-sse
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Tue Apr 02 11:27:49 UTC 2019
    - 53 bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java

        return NANOSECONDS.toMillis(stopwatch.instant - startTime);
      }
    
      private void assertEvents(String... events) {
        assertEquals(Arrays.toString(events), stopwatch.readEventsAndClear());
      }
    
      /**
       * The stopwatch gathers events and presents them as strings. R0.6 means a delay of 0.6 seconds
       * caused by the (R)ateLimiter U1.0 means the (U)ser caused the stopwatch to sleep for a second.
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 14:28:19 UTC 2024
    - 21.8K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java

        return NANOSECONDS.toMillis(stopwatch.instant - startTime);
      }
    
      private void assertEvents(String... events) {
        assertEquals(Arrays.toString(events), stopwatch.readEventsAndClear());
      }
    
      /**
       * The stopwatch gathers events and presents them as strings. R0.6 means a delay of 0.6 seconds
       * caused by the (R)ateLimiter U1.0 means the (U)ser caused the stopwatch to sleep for a second.
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 14:28:19 UTC 2024
    - 21.8K bytes
    - Viewed (0)
Back to top