- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for ToRulesMap (0.09 sec)
-
cmd/bucket-notification-handlers.go
} if _, err = globalBucketMetadataSys.Update(ctx, bucketName, bucketNotificationConfig, configData); err != nil { 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) -
cmd/event-notification.go
if err := config.Validate(region, globalEventNotifier.targetList); err != nil { if _, ok := err.(*event.ErrARNNotFound); !ok { internalLogIf(GlobalContext, err) } } evnot.AddRulesMap(bucket, config.ToRulesMap()) } // Targets returns all the registered targets func (evnot *EventNotifier) Targets() []event.Target { return evnot.targetList.Targets() }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jun 21 22:22:24 UTC 2024 - 7.7K bytes - Viewed (0) -
internal/event/config_test.go
queue *Queue expectedResult RulesMap }{ {queueCase1, rulesMapCase1}, {queueCase2, rulesMapCase2}, } for i, testCase := range testCases { result := testCase.queue.ToRulesMap() if !reflect.DeepEqual(result, testCase.expectedResult) { t.Fatalf("test %v: data: expected: %v, got: %v", i+1, testCase.expectedResult, result) } } }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Dec 05 10:16:33 UTC 2023 - 29K bytes - Viewed (0) -
cmd/peer-rest-server.go
return np, grid.NewRemoteErr(err) } globalBucketMetadataSys.Set(bucketName, meta) if meta.notificationConfig != nil { globalEventNotifier.AddRulesMap(bucketName, meta.notificationConfig.ToRulesMap()) } if meta.bucketTargetConfig != nil { globalBucketTargetSys.UpdateAllTargets(bucketName, meta.bucketTargetConfig) } return }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Oct 04 11:32:32 UTC 2024 - 53.2K bytes - Viewed (0)