Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for natsTargets (0.29 sec)

  1. internal/config/notify/parse.go

    			if err != nil {
    				return nil, err
    			}
    			targets = append(targets, t)
    		}
    	case config.NotifyNATSSubSys:
    		natsTargets, err := GetNotifyNATS(cfg[config.NotifyNATSSubSys], transport.TLSClientConfig.RootCAs)
    		if err != nil {
    			return nil, err
    		}
    		for id, args := range natsTargets {
    			if !args.Enable {
    				continue
    			}
    			t, err := target.NewNATSTarget(id, args, logOnceIf)
    			if err != nil {
    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/nats.go

    	quitCh     chan struct{}
    }
    
    // ID - returns target ID.
    func (target *NATSTarget) ID() event.TargetID {
    	return target.id
    }
    
    // Name - returns the Name of the target.
    func (target *NATSTarget) Name() string {
    	return target.ID().String()
    }
    
    // Store returns any underlying store if set.
    func (target *NATSTarget) Store() event.TargetStore {
    	return target.store
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 12.9K bytes
    - Viewed (0)
Back to top