- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for natsTargets (0.05 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 Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 47K 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 Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 12.9K bytes - Viewed (0)