- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for NewTargetList (0.06 sec)
-
internal/config/lambda/event/targetlist.go
for id, target := range list.targets { t.TargetStats[strings.ReplaceAll(id.String(), ":", "_")] = target.Stat() } return t } // NewTargetList - creates TargetList. func NewTargetList() *TargetList { return &TargetList{targets: make(map[TargetID]Target)}Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 4.3K bytes - Viewed (0) -
internal/event/targetlist.go
// Init initialize target send workers. func (list *TargetList) Init(workers int) *TargetList { startOnce.Do(func() { go list.startSendWorkers(workers) }) return list } // NewTargetList - creates TargetList. func NewTargetList(ctx context.Context) *TargetList { list := &TargetList{ targets: make(map[TargetID]Target), queue: make(chan asyncEvent, maxConcurrentAsyncSend),
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 9.2K bytes - Viewed (0) -
internal/config/lambda/parse.go
} // FetchEnabledTargets - Returns a set of configured TargetList func FetchEnabledTargets(ctx context.Context, cfg config.Config, transport *http.Transport) (*event.TargetList, error) { targetList := event.NewTargetList() for _, subSys := range config.LambdaSubSystems.ToSlice() { targets, err := fetchSubSysTargets(ctx, cfg, subSys, transport) if err != nil { return nil, err } for _, t := range targets {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 6K bytes - Viewed (0) -
internal/config/notify/parse.go
} // FetchEnabledTargets - Returns a set of configured TargetList func FetchEnabledTargets(ctx context.Context, cfg config.Config, transport *http.Transport) (_ *event.TargetList, err error) { targetList := event.NewTargetList(ctx) for _, subSys := range config.NotifySubSystems.ToSlice() { targets, err := fetchSubSysTargets(ctx, cfg, subSys, transport) if err != nil { return nil, err } for _, t := range targets {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 47.5K bytes - Viewed (0)