Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for nsqTargets (0.05 sec)

  1. internal/config/notify/parse.go

    			if err != nil {
    				return nil, err
    			}
    			targets = append(targets, t)
    		}
    	case config.NotifyNSQSubSys:
    		nsqTargets, err := GetNotifyNSQ(cfg[config.NotifyNSQSubSys])
    		if err != nil {
    			return nil, err
    		}
    		for id, args := range nsqTargets {
    			if !args.Enable {
    				continue
    			}
    			t, err := target.NewNSQTarget(id, args, logOnceIf)
    			if err != nil {
    				return nil, err
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 47K bytes
    - Viewed (0)
  2. internal/event/target/nsq.go

    		}
    	}
    
    	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.
    func (target *NSQTarget) ID() event.TargetID {
    	return 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)
Back to top