Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for nsq (0.08 sec)

  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.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  2. cmd/config-migrate.go

    		// V30 -> V31
    		cfg.OpenID = openid.Config{}
    		cfg.Policy.OPA = opa.Args{
    			URL:       &xnet.URL{},
    			AuthToken: "",
    		}
    	case "31":
    		// V31 -> V32
    		cfg.Notify.NSQ = make(map[string]target.NSQArgs)
    		cfg.Notify.NSQ["1"] = target.NSQArgs{}
    	}
    
    	// Move to latest.
    	cfg.Version = "33"
    
    	newCfg := newServerConfig()
    
    	config.SetRegion(newCfg, cfg.Region)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  3. 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
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 84K bytes
    - Viewed (0)
  4. internal/config/notify/help.go

    		},
    	}
    
    	HelpNSQ = config.HelpKVS{
    		config.HelpKV{
    			Key:         target.NSQAddress,
    			Description: "NSQ server address e.g. '127.0.0.1:4150'",
    			Type:        "address",
    			Sensitive:   true,
    		},
    		config.HelpKV{
    			Key:         target.NSQTopic,
    			Description: "NSQ topic",
    			Type:        "string",
    		},
    		config.HelpKV{
    			Key:         target.NSQTLS,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 19.2K bytes
    - Viewed (0)
  5. go.mod

    	github.com/mitchellh/go-homedir v1.1.0
    	github.com/nats-io/nats-server/v2 v2.9.23
    	github.com/nats-io/nats.go v1.37.0
    	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.1.3-0.20240916144458-20a13a1f6b7c
    	github.com/pierrec/lz4/v4 v4.1.21
    	github.com/pkg/errors v0.9.1
    	github.com/pkg/sftp v1.13.6
    	github.com/pkg/xattr v0.4.10
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  6. 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
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Aug 16 08:43:49 UTC 2024
    - 17.9K bytes
    - Viewed (1)
  7. 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: "",
    		},
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 47K bytes
    - Viewed (0)
  8. 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,
    		},
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 03 18:23:41 UTC 2024
    - 30.1K bytes
    - Viewed (0)
  9. 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=
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 78K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/mylasta/direction/FessConfig.java

                defaultMap.put(FessConfig.QUERY_BOOST_TITLE, "0.5");
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Oct 11 21:11:58 UTC 2024
    - 468.5K bytes
    - Viewed (1)
Back to top