Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 9 of 9 for NSQ (0.04 seconds)

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

  1. internal/event/target/nsq.go

    			return errors.New("queueDir path should be absolute")
    		}
    	}
    
    	return nil
    }
    
    // NSQTarget - NSQ target.
    type NSQTarget struct {
    	initOnce once.Init
    
    	id         event.TargetID
    	args       NSQArgs
    	producer   *nsq.Producer
    	store      store.Store[event.Event]
    	config     *nsq.Config
    	loggerOnce logger.LogOnce
    	quitCh     chan struct{}
    }
    
    // ID - returns target ID.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Mar 30 00:56:02 GMT 2025
    - 7.1K bytes
    - Click Count (0)
  2. docs/bucket/notifications/README.md

    ```
    
    ## Publish MinIO events to NSQ
    
    Install an NSQ Daemon from [here](https://nsq.io/). Or use the following Docker
    command for starting an nsq daemon:
    
    ```
    podman run --rm -p 4150-4151:4150-4151 nsqio/nsq /nsqd
    ```
    
    ### Step 1: Add NSQ endpoint to MinIO
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 84.2K bytes
    - Click Count (0)
  3. go.mod

    	github.com/mitchellh/go-homedir v1.1.0
    	github.com/nats-io/nats-server/v2 v2.11.1
    	github.com/nats-io/nats.go v1.41.2
    	github.com/nats-io/stan.go v0.10.4
    	github.com/ncw/directio v1.0.5
    	github.com/nsqio/go-nsq v1.1.0
    	github.com/philhofer/fwd v1.2.0
    	github.com/pierrec/lz4/v4 v4.1.22
    	github.com/pkg/errors v0.9.1
    	github.com/pkg/sftp v1.13.9
    	github.com/pkg/xattr v0.4.10
    	github.com/prometheus/client_golang v1.22.0
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Oct 10 18:57:03 GMT 2025
    - 12.2K bytes
    - Click Count (0)
  4. docs/config/README.md

    notify_mqtt           publish bucket notifications to MQTT endpoints
    notify_nats           publish bucket notifications to NATS endpoints
    notify_nsq            publish bucket notifications to NSQ endpoints
    notify_mysql          publish bucket notifications to MySQL databases
    notify_postgres       publish bucket notifications to Postgres databases
    notify_elasticsearch  publish bucket notifications to Elasticsearch endpoints
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 18.1K bytes
    - Click Count (1)
  5. internal/config/notify/parse.go

    		}
    
    		if err = natsArgs.Validate(); err != nil {
    			return nil, err
    		}
    
    		natsTargets[k] = natsArgs
    	}
    	return natsTargets, nil
    }
    
    // DefaultNSQKVS - NSQ KV for config
    var (
    	DefaultNSQKVS = config.KVS{
    		config.KV{
    			Key:   config.Enable,
    			Value: config.EnableOff,
    		},
    		config.KV{
    			Key:   target.NSQAddress,
    			Value: "",
    		},
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 47.5K bytes
    - Click Count (0)
  6. cmd/config-current.go

    			Description:     "publish bucket notifications to NATS endpoints",
    			MultipleTargets: true,
    		},
    		config.HelpKV{
    			Key:             config.NotifyNSQSubSys,
    			Description:     "publish bucket notifications to NSQ endpoints",
    			MultipleTargets: true,
    		},
    		config.HelpKV{
    			Key:             config.NotifyMySQLSubSys,
    			Description:     "publish bucket notifications to MySQL databases",
    			MultipleTargets: true,
    		},
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 28.5K bytes
    - Click Count (0)
  7. go.sum

    github.com/ncw/directio v1.0.5 h1:JSUBhdjEvVaJvOoyPAbcW0fnd0tvRXD76wEfZ1KcQz4=
    github.com/ncw/directio v1.0.5/go.mod h1:rX/pKEYkOXBGOggmcyJeJGloCkleSvphPx2eV3t6ROk=
    github.com/nsqio/go-nsq v1.1.0 h1:PQg+xxiUjA7V+TLdXw7nVrJ5Jbl3sN86EhGCQj4+FYE=
    github.com/nsqio/go-nsq v1.1.0/go.mod h1:vKq36oyeVXgsS5Q8YEO7WghqidAVXQlcFxzQbQTuDEY=
    github.com/oklog/ulid v1.3.1 h1:EGfNDEx6MqHz8B3uNV6QAib1UR2Lm97sHi3ocA6ESJ4=
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 79.8K bytes
    - Click Count (0)
  8. src/main/java/org/codelibs/fess/mylasta/direction/FessConfig.java

                defaultMap.put(FessConfig.QUERY_BOOST_TITLE, "0.5");
    Created: Sat Dec 20 09:19:18 GMT 2025
    - Last Modified: Sat Dec 13 02:21:17 GMT 2025
    - 525.7K bytes
    - Click Count (2)
  9. CREDITS

    OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
    THE SOFTWARE.
    
    
    ================================================================
    
    github.com/nsqio/go-nsq
    https://github.com/nsqio/go-nsq
    ----------------------------------------------------------------
    Permission is hereby granted, free of charge, to any person obtaining a copy
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu Mar 13 05:29:51 GMT 2025
    - 1.8M bytes
    - Click Count (0)
Back to Top