Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 242 for Event (0.01 sec)

  1. impl/maven-core/src/test/java/org/apache/maven/lifecycle/LifecycleExecutorTest.java

    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Wed Sep 17 10:01:14 UTC 2025
    - 22.9K bytes
    - Viewed (0)
  2. internal/event/target/mysql.go

    	if target.args.Format == event.NamespaceFormat {
    		objectName, err := url.QueryUnescape(eventData.S3.Object.Key)
    		if err != nil {
    			return err
    		}
    		key := eventData.S3.Bucket.Name + "/" + objectName
    
    		if eventData.EventName == event.ObjectRemovedDelete {
    			_, err = target.deleteStmt.Exec(key)
    		} else {
    			var data []byte
    			if data, err = json.Marshal(struct{ Records []event.Event }{[]event.Event{eventData}}); err != nil {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 11.6K bytes
    - Viewed (0)
  3. impl/maven-cli/src/main/java/org/apache/maven/cling/event/ExecutionEventLogger.java

        @Override
        public void forkedProjectStarted(ExecutionEvent event) {
            if (logger.isInfoEnabled()
                    && event.getMojoExecution().getForkedExecutions().size() > 1) {
                init();
                logger.info("");
                infoLine('>');
    
                infoMain("Forking " + event.getProject().getName() + " "
                        + event.getProject().getVersion());
    
                infoLine('>');
            }
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Fri Dec 13 15:40:45 UTC 2024
    - 17.5K bytes
    - Viewed (0)
  4. compat/maven-embedder/src/test/java/org/apache/maven/cli/event/ExecutionEventLoggerTest.java

            when(session.getTopDirectory()).thenReturn(basedir.toPath());
            when(event.getSession()).thenReturn(session);
    
            // execute
            executionEventLogger.projectStarted(event);
    
            // verify
            InOrder inOrder = inOrder(logger);
            inOrder.verify(logger).info("");
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Sun Dec 01 19:41:22 UTC 2024
    - 12.3K bytes
    - Viewed (0)
  5. impl/maven-core/src/main/java/org/apache/maven/internal/aether/ReverseTreeRepositoryListener.java

        @Override
        public void artifactResolved(RepositoryEvent event) {
            requireNonNull(event, "event cannot be null");
    
            if (!isLocalRepositoryArtifactOrMissing(event.getSession(), event.getArtifact())) {
                return;
            }
    
            RequestTrace trace = event.getTrace();
    
            CollectStepData collectStepTrace = null;
            ArtifactRequest artifactRequest = null;
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Wed Jan 29 08:17:07 UTC 2025
    - 10.1K bytes
    - Viewed (0)
  6. internal/event/target/nats.go

    func NewNATSTarget(id string, args NATSArgs, loggerOnce logger.LogOnce) (*NATSTarget, error) {
    	var queueStore store.Store[event.Event]
    	if args.QueueDir != "" {
    		queueDir := filepath.Join(args.QueueDir, storePrefix+"-nats-"+id)
    		queueStore = store.NewQueueStore[event.Event](queueDir, args.QueueLimit, event.StoreExtension)
    		if err := queueStore.Open(); err != nil {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Apr 27 04:30:57 UTC 2025
    - 13.5K bytes
    - Viewed (0)
  7. internal/event/config_test.go

    	dataCase1 := []byte(`
    <QueueConfiguration>
       <Id>1</Id>
       <Filter></Filter>
       <Queue>arn:minio:sqs:us-east-1:1:webhook</Queue>
       <Event>s3:ObjectAccessed:*</Event>
       <Event>s3:ObjectCreated:*</Event>
       <Event>s3:ObjectRemoved:*</Event>
    </QueueConfiguration>`)
    
    	dataCase2 := []byte(`
    <QueueConfiguration>
       <Id>1</Id>
        <Filter>
            <S3Key>
                <FilterRule>
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed Apr 09 14:28:39 UTC 2025
    - 28.9K bytes
    - Viewed (0)
  8. compat/maven-embedder/src/main/java/org/apache/maven/cli/event/ExecutionEventLogger.java

        @Override
        public void forkedProjectStarted(ExecutionEvent event) {
            if (logger.isInfoEnabled()
                    && event.getMojoExecution().getForkedExecutions().size() > 1) {
                init();
                logger.info("");
                infoLine('>');
    
                infoMain("Forking " + event.getProject().getName() + " "
                        + event.getProject().getVersion());
    
                infoLine('>');
            }
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Fri Nov 08 08:49:11 UTC 2024
    - 17.2K bytes
    - Viewed (0)
  9. internal/event/target/elasticsearch.go

    	var queueStore store.Store[event.Event]
    	if args.QueueDir != "" {
    		queueDir := filepath.Join(args.QueueDir, storePrefix+"-elasticsearch-"+id)
    		queueStore = store.NewQueueStore[event.Event](queueDir, args.QueueLimit, event.StoreExtension)
    		if err := queueStore.Open(); err != nil {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 15K bytes
    - Viewed (0)
  10. internal/event/target/kafka.go

    	initOnce once.Init
    
    	id         event.TargetID
    	args       KafkaArgs
    	client     sarama.Client
    	producer   sarama.SyncProducer
    	config     *sarama.Config
    	store      store.Store[event.Event]
    	batch      *store.Batch[event.Event]
    	loggerOnce logger.LogOnce
    	quitCh     chan struct{}
    }
    
    // ID - returns target ID.
    func (target *KafkaTarget) ID() event.TargetID {
    	return target.id
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 13.6K bytes
    - Viewed (0)
Back to top