Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for NewTargetList (0.17 sec)

  1. internal/event/targetlist_test.go

    	return nil
    }
    
    func TestTargetListAdd(t *testing.T) {
    	targetListCase1 := NewTargetList(context.Background())
    
    	targetListCase2 := NewTargetList(context.Background())
    	if err := targetListCase2.Add(&ExampleTarget{TargetID{"2", "testcase"}, false, false}); err != nil {
    		panic(err)
    	}
    
    	targetListCase3 := NewTargetList(context.Background())
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Dec 05 10:16:33 UTC 2023
    - 6.1K bytes
    - Viewed (0)
  2. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Mar 07 16:12:41 UTC 2023
    - 4.3K bytes
    - Viewed (0)
  3. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  4. cmd/event-notification.go

    func NewEventNotifier(ctx context.Context) *EventNotifier {
    	// targetList/bucketRulesMap/bucketRemoteTargetRulesMap are populated by NotificationSys.InitBucketTargets()
    	return &EventNotifier{
    		targetList:     event.NewTargetList(ctx),
    		bucketRulesMap: make(map[string]event.RulesMap),
    	}
    }
    
    // GetARNList - returns available ARNs.
    func (evnot *EventNotifier) GetARNList() []string {
    	arns := []string{}
    	if evnot == nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 21 22:22:24 UTC 2024
    - 7.7K bytes
    - Viewed (0)
  5. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 6K bytes
    - Viewed (0)
Back to top