- Sort Score
- Result 10 results
- Languages All
Results 141 - 150 of 295 for eventbus (0.07 sec)
-
architecture/networking/controllers.md
* Correctness at startup; with the sequencing above, items are only processed once all informers are synced. This means queries will not return stale data at startup. * Deduping of identical events * Automatic retrying of failed events (configurable) The above logic is critical to handle correctly to ensure correctness of a controller.
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Fri Feb 09 17:41:25 UTC 2024 - 4.9K bytes - Viewed (0) -
internal/event/target/mqtt.go
// Such events will not exist and wouldve been already been sent successfully. if os.IsNotExist(err) { return nil } return err } if err = target.send(eventData); err != nil { return err } // Delete the event from store. return target.store.Del(key) } // Save - saves the events to the store if queuestore is configured, which will
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 8.2K bytes - Viewed (0) -
impl/maven-core/src/main/java/org/apache/maven/eventspy/internal/EventSpyExecutionListener.java
import org.apache.maven.execution.AbstractExecutionListener; import org.apache.maven.execution.ExecutionEvent; import org.apache.maven.execution.ExecutionListener; /** * Forwards execution events to EventSpies. * @since 3.0.2 */ class EventSpyExecutionListener extends AbstractExecutionListener { private final EventSpyDispatcher dispatcher; private final ExecutionListener delegate;
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 3.9K bytes - Viewed (0) -
compat/maven-compat/src/main/java/org/apache/maven/repository/legacy/WagonManager.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.TransferListener; import org.apache.maven.wagon.repository.Repository; /** * WagonManager */ @Deprecated public interface WagonManager { @Deprecated
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 3.4K bytes - Viewed (0) -
.github/workflows/scorecard.yml
permissions: read-all jobs: analysis: name: Scorecard analysis runs-on: ubuntu-latest permissions: # Needed to upload the results to code-scanning dashboard. security-events: write # Needed to publish results and get a badge (see publish_results below). id-token: write # Uncomment the permissions below if installing in a private repository. # contents: read
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Oct 29 18:53:45 UTC 2024 - 2.9K bytes - Viewed (0) -
tests/migrate_test.go
} err = DB.Table("events").AutoMigrate(&Event2{}) if err != nil { t.Errorf("AutoMigrate err:%v", err) } DB.Table("events").Save(&Event2{}) DB.Table("events").Save(&Event2{}) DB.Table("events").Save(&Event2{}) events := make([]*Event, 0) DB.Table("events").Find(&events) AssertEqual(t, 3, len(events)) for _, v := range events { AssertEqual(t, v.ID, v.UID) } }
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Mon Mar 18 11:24:16 UTC 2024 - 56.2K bytes - Viewed (0) -
compat/maven-plugin-api/src/main/java/org/apache/maven/plugin/Mojo.java
*/ void execute() throws MojoExecutionException, MojoFailureException; /** * Inject a standard <code>Maven</code> logging mechanism to allow this <code>Mojo</code> to communicate events * and feedback to the user. * * @param log a new logger * * @deprecated Use SLF4J directly */ @Deprecated void setLog(Log log); /**
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 2.9K bytes - Viewed (0) -
impl/maven-core/src/main/java/org/apache/maven/eventspy/internal/EventSpyRepositoryListener.java
package org.apache.maven.eventspy.internal; import org.eclipse.aether.AbstractRepositoryListener; import org.eclipse.aether.RepositoryEvent; import org.eclipse.aether.RepositoryListener; /** * Forwards repository events to EventSpies. * @since 3.0.2 */ class EventSpyRepositoryListener extends AbstractRepositoryListener { private final EventSpyDispatcher dispatcher; private final RepositoryListener delegate;
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 4.3K bytes - Viewed (0) -
cni/pkg/nodeagent/informers_test.go
label.IoIstioDataplaneMode.Name)) _, err = client.Kube().CoreV1().Namespaces().Patch(ctx, ns.Name, types.MergePatchType, labelsPatch, metav1.PatchOptions{}) assert.NoError(t, err) // wait for another two update events // total 3 update at before unlabel point: 1. init ns reconcile 2. ns label reconcile 3. pod annotation update mt.Assert(EventTotals.Name(), map[string]string{"type": "update"}, monitortest.AtLeast(5)) waitForMockCalls()
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Wed Oct 09 16:05:45 UTC 2024 - 22.1K bytes - Viewed (0) -
compat/maven-compat/src/main/java/org/apache/maven/artifact/resolver/WarningResolutionListener.java
package org.apache.maven.artifact.resolver; import org.apache.maven.artifact.Artifact; import org.apache.maven.artifact.versioning.VersionRange; import org.codehaus.plexus.logging.Logger; /** * Send resolution warning events to the warning log. * */ @Deprecated public class WarningResolutionListener implements ResolutionListener { private Logger logger; public WarningResolutionListener(Logger logger) {
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 1.9K bytes - Viewed (0)