Search Options

Results per page
Sort
Preferred Languages
Advance

Results 71 - 80 of 272 for eventbus (0.31 sec)

  1. internal/logger/help.go

    			Description: "mTLS certificate key for webhook authentication",
    			Optional:    true,
    			Type:        "string",
    			Sensitive:   true,
    		},
    		config.HelpKV{
    			Key:         BatchSize,
    			Description: "Number of events per HTTP send to webhook target",
    			Optional:    true,
    			Type:        "number",
    		},
    		config.HelpKV{
    			Key:         QueueSize,
    			Description: "configure channel queue size for webhook targets",
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 11 22:20:42 UTC 2024
    - 7.4K bytes
    - Viewed (0)
  2. impl/maven-core/src/main/java/org/apache/maven/execution/ExecutionListener.java

     * specific language governing permissions and limitations
     * under the License.
     */
    package org.apache.maven.execution;
    
    /**
     * Defines events that Maven fires during a build. <strong>Warning:</strong> This interface might be extended in future
     * Maven versions to support further events. Hence it is strongly recommended to derive custom listeners from
     * {@link AbstractExecutionListener} in order to avoid interoperability problems.
     *
     */
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 2K bytes
    - Viewed (0)
  3. cmd/bootstrap-messages.go

    	bs.mu.Lock()
    	defer bs.mu.Unlock()
    
    	if len(bs.info) > bootstrapTraceLimit {
    		return
    	}
    	bs.info = append(bs.info, info)
    }
    
    func (bs *bootstrapTracer) Events() []madmin.TraceInfo {
    	traceInfo := make([]madmin.TraceInfo, 0, bootstrapTraceLimit)
    
    	bs.mu.RLock()
    	for _, i := range bs.info {
    		traceInfo = append(traceInfo, i)
    	}
    	bs.mu.RUnlock()
    
    	return traceInfo
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 23 10:07:06 UTC 2023
    - 1.7K bytes
    - Viewed (0)
  4. build-logic-commons/gradle-plugin/src/main/kotlin/gradlebuild.collect-failed-tasks.gradle.kts

     */
    import gradlebuild.AbstractBuildScanInfoCollectingService
    import gradlebuild.registerBuildScanInfoCollectingService
    import io.gitlab.arturbosch.detekt.Detekt
    import org.gradle.tooling.events.task.TaskFailureResult
    import org.gradle.tooling.events.task.TaskOperationResult
    import java.io.Serializable
    import java.util.concurrent.CopyOnWriteArrayList
    
    /**
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Thu Jun 20 08:07:01 UTC 2024
    - 2.3K bytes
    - Viewed (0)
  5. internal/event/target/kafka.go

    			// Such events will not exist and wouldve been already been sent successfully.
    			if os.IsNotExist(err) {
    				return nil
    			}
    			return err
    		}
    		err = target.send(event)
    	case key.ItemCount > 1:
    		var events []event.Event
    		events, err = target.store.GetMultiple(key)
    		if err != nil {
    			if os.IsNotExist(err) {
    				return nil
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  6. cmd/metrics-v3-cluster-notification.go

    	notificationEventsErrorsTotalMD     = NewCounterMD(notificationEventsErrorsTotal, "Events that were failed to be sent to the targets")
    	notificationEventsSentTotalMD       = NewCounterMD(notificationEventsSentTotal, "Total number of events sent to the targets")
    	notificationEventsSkippedTotalMD    = NewCounterMD(notificationEventsSkippedTotal, "Events that were skipped to be sent to the targets due to the in-memory queue being full")
    )
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Apr 24 04:10:35 UTC 2024
    - 2.2K bytes
    - Viewed (0)
  7. .github/workflows/osv-scanner-scheduled.yml

    name: OSV-Scanner Scheduled Scan
    
    on:
      schedule:
        - cron: 0 4 * * 1
    
    permissions:
      # Require writing security events to upload SARIF file to security tab
      security-events: write
      # Only need to read contents
      contents: read
    
    jobs:
      scan-scheduled:
        if: github.repository == 'tensorflow/tensorflow'
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Fri Nov 01 08:40:10 UTC 2024
    - 1.6K bytes
    - Viewed (0)
  8. build-logic-commons/gradle-plugin/src/main/kotlin/gradlebuild/testcleanup/TestFilesCleanupService.kt

    import org.gradle.internal.exceptions.DefaultMultiCauseException
    import org.gradle.tooling.events.FinishEvent
    import org.gradle.tooling.events.OperationCompletionListener
    import org.gradle.tooling.events.task.TaskFailureResult
    import org.gradle.tooling.events.task.TaskFinishEvent
    import org.gradle.tooling.events.task.TaskSuccessResult
    import java.io.File
    import java.io.FileOutputStream
    import java.io.IOException
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Fri Jul 28 16:19:47 UTC 2023
    - 12.5K bytes
    - Viewed (0)
  9. compat/maven-compat/src/test/java/org/apache/maven/repository/legacy/DefaultWagonManagerTest.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.TransferEvent;
    import org.apache.maven.wagon.events.TransferListener;
    import org.apache.maven.wagon.observers.AbstractTransferListener;
    import org.apache.maven.wagon.observers.Debug;
    import org.codehaus.plexus.testing.PlexusTest;
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  10. internal/config/notify/help.go

    	queueLimitComment = `maximum limit for undelivered messages, defaults to '100000'`
    )
    
    // Help template inputs for all notification targets
    var (
    	HelpWebhook = config.HelpKVS{
    		config.HelpKV{
    			Key:         target.WebhookEndpoint,
    			Description: "webhook server endpoint e.g. http://localhost:8080/minio/events",
    			Type:        "url",
    			Sensitive:   true,
    		},
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 19.2K bytes
    - Viewed (0)
Back to top