Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for NSQ (0.07 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. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 26 15:03:08 UTC 2024
    - 1.6M bytes
    - Viewed (0)
Back to top