Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for rulesMap (0.1 sec)

  1. cmd/event-notification.go

    func (evnot *EventNotifier) AddRulesMap(bucketName string, rulesMap event.RulesMap) {
    	evnot.Lock()
    	defer evnot.Unlock()
    
    	rulesMap = rulesMap.Clone()
    
    	// Do not add for an empty rulesMap.
    	if len(rulesMap) == 0 {
    		delete(evnot.bucketRulesMap, bucketName)
    	} else {
    		evnot.bucketRulesMap[bucketName] = rulesMap
    	}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 21 22:22:24 UTC 2024
    - 7.7K bytes
    - Viewed (0)
  2. internal/event/rulesmap_test.go

    		rulesMap       RulesMap
    		rulesMapToAdd  RulesMap
    		expectedResult RulesMap
    	}{
    		{rulesMapCase1, rulesMapToAddCase1, expectedResultCase1},
    		{rulesMapCase2, rulesMapToAddCase2, expectedResultCase2},
    		{rulesMapCase3, rulesMapToAddCase3, expectedResultCase3},
    	}
    
    	for i, testCase := range testCases {
    		testCase.rulesMap.Remove(testCase.rulesMapToAdd)
    
    		if !reflect.DeepEqual(testCase.rulesMap, testCase.expectedResult) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jan 05 18:43:06 UTC 2024
    - 6.8K bytes
    - Viewed (0)
  3. cmd/bucket-notification-handlers.go

    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	rulesMap := config.ToRulesMap()
    	globalEventNotifier.AddRulesMap(bucketName, rulesMap)
    
    	writeSuccessResponseHeadersOnly(w)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.1K bytes
    - Viewed (0)
  4. cmd/listen-notification-handlers.go

    	}
    
    	if bucketName != "" {
    		if _, err := objAPI.GetBucketInfo(ctx, bucketName, BucketOptions{}); err != nil {
    			writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    			return
    		}
    	}
    
    	rulesMap := event.NewRulesMap(eventNames, pattern, event.TargetID{ID: mustGetUUID()})
    
    	setEventStreamHeaders(w)
    
    	// Listen Publisher and peer-listen-client uses nonblocking send and hence does not wait for slow receivers.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 6K bytes
    - Viewed (0)
  5. cmd/peer-rest-server.go

    		return
    	}
    
    	var rulesMap event.RulesMap
    	if r.ContentLength < 0 {
    		s.writeErrorResponse(w, errInvalidArgument)
    		return
    	}
    
    	err := gob.NewDecoder(r.Body).Decode(&rulesMap)
    	if err != nil {
    		s.writeErrorResponse(w, err)
    		return
    	}
    
    	globalEventNotifier.AddRulesMap(bucketName, rulesMap)
    }
    
    // HealthHandler - returns true of health
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 53.2K bytes
    - Viewed (0)
  6. internal/event/config_test.go

    	rulesMapCase2 := NewRulesMap([]Name{ObjectCreatedPut}, "images/*jpg", TargetID{"1", "webhook"})
    
    	testCases := []struct {
    		queue          *Queue
    		expectedResult RulesMap
    	}{
    		{queueCase1, rulesMapCase1},
    		{queueCase2, rulesMapCase2},
    	}
    
    	for i, testCase := range testCases {
    		result := testCase.queue.ToRulesMap()
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Dec 05 10:16:33 UTC 2023
    - 29K bytes
    - Viewed (0)
  7. cmd/iam.go

    				authZLogIf(ctx, errMsg, logger.WarningKind)
    			}
    		}
    		sys.rolesMap[arn] = rolePolicies
    	}
    }
    
    // Prints IAM role ARNs.
    func (sys *IAMSys) printIAMRoles() {
    	if len(sys.rolesMap) == 0 {
    		return
    	}
    	var arns []string
    	for arn := range sys.rolesMap {
    		arns = append(arns, arn.String())
    	}
    	sort.Strings(arns)
    	msgs := make([]string, 0, len(arns))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 29 16:01:48 UTC 2024
    - 74.6K bytes
    - Viewed (0)
Back to top