Home
last modified time | relevance | path

Searched refs:IsValidTopicName (Results 1 – 12 of 12) sorted by relevance

/dports/net/nsq/nsq-1.2.1/internal/protocol/
H A Dnames.go10 func IsValidTopicName(name string) bool { func
/dports/net/nsq/nsq-1.2.1/internal/http_api/
H A Dtopic_channel_args.go19 if !protocol.IsValidTopicName(topicName) {
/dports/net/nsq/nsq-1.2.1/vendor/github.com/nsqio/go-nsq/
H A Dprotocol.go27 func IsValidTopicName(name string) bool { func
H A Dconsumer.go154 if !IsValidTopicName(topic) {
/dports/net/nsq/nsq-1.2.1/apps/nsq_to_nsq/
H A Dnsq_to_nsq.go288 if !protocol.IsValidTopicName(topic) {
293 if *destTopic != "" && !protocol.IsValidTopicName(*destTopic) {
/dports/net/nsq/nsq-1.2.1/nsqd/
H A Dprotocol_v2.go599 if !protocol.IsValidTopicName(topicName) {
775 if !protocol.IsValidTopicName(topicName) {
825 if !protocol.IsValidTopicName(topicName) {
878 if !protocol.IsValidTopicName(topicName) {
H A Dhttp.go178 if !protocol.IsValidTopicName(topicName) {
330 if !protocol.IsValidTopicName(topicName) {
H A Dprotocol_v2_test.go124 test.Equal(t, true, protocol.IsValidTopicName("test"))
125 test.Equal(t, true, protocol.IsValidTopicName("test-with_period."))
126 test.Equal(t, true, protocol.IsValidTopicName("test#ephemeral"))
127 test.Equal(t, false, protocol.IsValidTopicName("test:ephemeral"))
H A Dnsqd.go327 if !protocol.IsValidTopicName(t.Name) {
/dports/net/nsq/nsq-1.2.1/nsqlookupd/
H A Dlookup_protocol_v1.go114 if !protocol.IsValidTopicName(topicName) {
H A Dhttp.go141 if !protocol.IsValidTopicName(topicName) {
/dports/net/nsq/nsq-1.2.1/nsqadmin/
H A Dhttp.go407 if !protocol.IsValidTopicName(body.Topic) {
447 if !protocol.IsValidTopicName(body.Topic) {