Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 91 - 100 of 315 for eventbus (0.05 seconds)

  1. internal/event/config.go

    	parsedQueue := queue{}
    	if err := d.DecodeElement(&parsedQueue, &start); err != nil {
    		return err
    	}
    
    	if len(parsedQueue.Events) == 0 {
    		return errors.New("missing event name(s)")
    	}
    
    	eventStringSet := set.NewStringSet()
    	for _, eventName := range parsedQueue.Events {
    		if eventStringSet.Contains(eventName.String()) {
    			return &ErrDuplicateEventName{eventName}
    		}
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 8.4K bytes
    - Click Count (0)
  2. docs/bucket/lifecycle/README.md

    aws s3api restore-object --bucket srcbucket \
    --key object \
    --restore-request Days=3
    ```
    
    ### 4.1 Monitoring transition events
    
    `s3:ObjectTransition:Complete` and `s3:ObjectTransition:Failed` events can be used to monitor transition events between the source cluster and transition tier. To watch lifecycle events, you can enable bucket notification on the source bucket with `mc event add`  and specify `--event ilm` flag.
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 9.1K bytes
    - Click Count (0)
  3. okhttp-sse/src/main/kotlin/okhttp3/sse/EventSourceListener.kt

     */
    package okhttp3.sse
    
    import okhttp3.Response
    
    abstract class EventSourceListener {
      /**
       * Invoked when an event source has been accepted by the remote peer and may begin transmitting
       * events.
       */
      open fun onOpen(
        eventSource: EventSource,
        response: Response,
      ) {
      }
    
      open fun onEvent(
        eventSource: EventSource,
        id: String?,
        type: String?,
        data: String,
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Fri Oct 03 07:51:20 GMT 2025
    - 1.4K bytes
    - Click Count (0)
  4. docs/de/docs/advanced/async-tests.md

    /// tip | Tipp
    
    Beachten Sie, dass wir async/await mit dem neuen `AsyncClient` verwenden – der Request ist asynchron.
    
    ///
    
    /// warning | Achtung
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Wed Dec 17 20:41:43 GMT 2025
    - 4.5K bytes
    - Click Count (1)
  5. compat/maven-compat/src/main/java/org/apache/maven/repository/legacy/TransferListenerAdapter.java

    import org.apache.maven.repository.ArtifactTransferEvent;
    import org.apache.maven.repository.ArtifactTransferListener;
    import org.apache.maven.repository.ArtifactTransferResource;
    import org.apache.maven.wagon.events.TransferEvent;
    import org.apache.maven.wagon.events.TransferListener;
    import org.apache.maven.wagon.repository.Repository;
    import org.apache.maven.wagon.resource.Resource;
    
    /**
     * TransferListenerAdapter
     */
    @Deprecated
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Fri Jun 06 14:28:57 GMT 2025
    - 5.1K bytes
    - Click Count (0)
  6. internal/event/targetlist.go

    	targetStats map[TargetID]targetStat
    }
    
    type targetStat struct {
    	// The number of concurrent async Send calls per targets
    	currentSendCalls int64
    	// The number of total events per target
    	totalEvents int64
    	// The number of failed events per target
    	failedEvents int64
    }
    
    func (list *TargetList) getStatsByTargetID(id TargetID) (stat targetStat) {
    	list.statLock.RLock()
    	defer list.statLock.RUnlock()
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 9.2K bytes
    - Click Count (0)
  7. docs/es/docs/advanced/openapi-callbacks.md

    https://yourapi.com/invoices/?callback_url=https://www.external.org/events
    ```
    
    con un JSON body de:
    
    ```JSON
    {
        "id": "2expen51ve",
        "customer": "Mr. Richie Rich",
        "total": "9999"
    }
    ```
    
    luego *tu API* procesará la factura y, en algún momento después, enviará un request de callback al `callback_url` (la *API externa*):
    
    ```
    https://www.external.org/events/invoices/2expen51ve
    ```
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Tue Dec 16 16:33:45 GMT 2025
    - 8.3K bytes
    - Click Count (0)
  8. impl/maven-core/src/main/java/org/apache/maven/internal/impl/EventSpyImpl.java

    import org.apache.maven.api.EventType;
    import org.apache.maven.api.Listener;
    import org.apache.maven.eventspy.EventSpy;
    import org.apache.maven.execution.ExecutionEvent;
    
    /**
     * Bridges between Maven3 events and Maven4 events.
     */
    @Named
    @Singleton
    public class EventSpyImpl implements EventSpy {
        @Override
        public void init(Context context) throws Exception {}
    
        @Override
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Fri Nov 29 20:53:26 GMT 2024
    - 2.2K bytes
    - Click Count (0)
  9. okhttp-testing-support/src/main/kotlin/okhttp3/RecordingConnectionListener.kt

       * EventListeners added by Interceptors will not see all events.
       */
      private val enforceOrder: Boolean = true,
    ) : ConnectionListener() {
      val eventSequence: Deque<ConnectionEvent> = ConcurrentLinkedDeque()
    
      private val forbiddenLocks = mutableSetOf<Any>()
    
      /** The timestamp of the last taken event, used to measure elapsed time between events. */
      private var lastTimestampNs: Long? = null
    
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Fri May 30 21:28:20 GMT 2025
    - 5.7K bytes
    - Click Count (0)
  10. docs/en/docs/advanced/openapi-callbacks.md

    https://yourapi.com/invoices/?callback_url=https://www.external.org/events
    ```
    
    with a JSON body of:
    
    ```JSON
    {
        "id": "2expen51ve",
        "customer": "Mr. Richie Rich",
        "total": "9999"
    }
    ```
    
    then *your API* will process the invoice, and at some point later, send a callback request to the `callback_url` (the *external API*):
    
    ```
    https://www.external.org/events/invoices/2expen51ve
    ```
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Wed Dec 10 08:55:32 GMT 2025
    - 8K bytes
    - Click Count (0)
Back to Top