Search Options

Results per page
Sort
Preferred Languages
Advance

Results 141 - 150 of 295 for eventbus (0.32 sec)

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