Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for NewTargetList (0.06 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
Back to top