- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for natsTargets (0.04 sec)
-
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 Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 47.5K bytes - Viewed (0) -
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 Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Apr 27 04:30:57 UTC 2025 - 13.5K bytes - Viewed (0)