- Sort Score
- Num 10 results
- Language All
Results 91 - 100 of 315 for eventbus (0.05 seconds)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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 {} @OverrideCreated: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Fri Nov 29 20:53:26 GMT 2024 - 2.2K bytes - Click Count (0) -
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) -
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)