Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 11 - 11 of 11 for stop_prefix (0.08 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  2. github.com/minio/minio

    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 {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Apr 27 04:30:57 GMT 2025
    - 13.5K bytes
    - Click Count (0)
Back to Top