Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 1 of 1 for queueDir (0.13 sec)

  2. github.com/minio/minio

    internal/event/target/nsq.go 

    func NewNSQTarget(id string, args NSQArgs, loggerOnce logger.LogOnce) (*NSQTarget, error) {
	var queueStore store.Store[event.Event]
	if args.QueueDir != "" {
		queueDir := filepath.Join(args.QueueDir, storePrefix+"-nsq-"+id)
		queueStore = store.NewQueueStore[event.Event](queueDir, args.QueueLimit, event.StoreExtension)
		if err := queueStore.Open(); err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Oct 07 15:07:38 GMT 2023
    - 7.1K bytes
    - Viewed (0)
Back to top