Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for nsq (0.01 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/config.go

    	MQTT          map[string]target.MQTTArgs          `json:"mqtt"`
    	MySQL         map[string]target.MySQLArgs         `json:"mysql"`
    	NATS          map[string]target.NATSArgs          `json:"nats"`
    	NSQ           map[string]target.NSQArgs           `json:"nsq"`
    	PostgreSQL    map[string]target.PostgreSQLArgs    `json:"postgresql"`
    	Redis         map[string]target.RedisArgs         `json:"redis"`
    	Webhook       map[string]target.WebhookArgs       `json:"webhook"`
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 2.8K bytes
    - Viewed (0)
  3. 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)
Back to top