Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for NewTargetList (0.18 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())
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Dec 05 10:16:33 GMT 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)}
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Mar 07 16:12:41 GMT 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),
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 9.2K bytes
    - Viewed (0)
  4. internal/event/config_test.go

       <Event>s3:ObjectRemoved:*</Event>
    </QueueConfiguration>`)
    	queue3 := &Queue{}
    	if err := xml.Unmarshal(data, queue3); err != nil {
    		panic(err)
    	}
    
    	targetList1 := NewTargetList(context.Background())
    
    	targetList2 := NewTargetList(context.Background())
    	if err := targetList2.Add(&ExampleTarget{TargetID{"1", "webhook"}, false, false}); err != nil {
    		panic(err)
    	}
    
    	testCases := []struct {
    		queue      *Queue
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Dec 05 10:16:33 GMT 2023
    - 29K 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 {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 6K bytes
    - Viewed (0)
  6. 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(onlyActive bool) []string {
    	arns := []string{}
    	if evnot == nil {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 7.8K bytes
    - Viewed (0)
  7. 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 {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 46.4K bytes
    - Viewed (0)
Back to top