function no longer referes to bulk endpoint

service/r2/routes.go

@@ -281,7 +281,7 @@ func fetchRollupRuleHistory(s *service, r *http.Request) (data interface{}, err
 	return models.NewRollupRuleSnapshots(hist), nil
 }
 
-func bulkUpdateRuleSet(s *service, r *http.Request) (data interface{}, err error) {
+func updateRuleSet(s *service, r *http.Request) (data interface{}, err error) {
 	vars := mux.Vars(r)
 	var req updateRuleSetRequest
 	if err := parseRequest(&req, r.Body); err != nil {

service/r2/routes_test.go

@@ -237,7 +237,7 @@ func TestRulesetUpdateRuleSet(t *testing.T) {
 	}).Return(newRuleSet(namespaceID, 2), nil)
 
 	service := newTestService(storeMock)
-	resp, err := bulkUpdateRuleSet(service, req)
+	resp, err := updateRuleSet(service, req)
 	require.NoError(t, err)
 	typedResp := resp.(models.RuleSet)
 	require.Equal(t, typedResp.Version, 2)
@@ -267,7 +267,7 @@ func TestRulesetUpdateRuleSetVersionMismatch(t *testing.T) {
 	storeMock.EXPECT().FetchRuleSet(namespaceID).Return(newRuleSet(namespaceID, 4), nil)
 
 	service := newTestService(storeMock)
-	_, err = bulkUpdateRuleSet(service, req)
+	_, err = updateRuleSet(service, req)
 	require.Error(t, err)
 	require.IsType(t, NewConflictError(""), err)
 }
@@ -295,7 +295,7 @@ func TestRulesetUpdateRuleSetKVFetchFailure(t *testing.T) {
 	storeMock := store.NewMockStore(ctrl)
 	storeMock.EXPECT().FetchRuleSet(namespaceID).Return(nil, NewInternalError("KV error"))
 	service := newTestService(storeMock)
-	_, err = bulkUpdateRuleSet(service, req)
+	_, err = updateRuleSet(service, req)
 	require.Error(t, err)
 	require.IsType(t, NewInternalError(""), err)
 }
@@ -325,7 +325,7 @@ func TestRulesetUpdateRuleSetKVUpdateFailure(t *testing.T) {
 	storeMock.EXPECT().UpdateRuleSet(gomock.Any()).Return(nil, NewInternalError("KV error"))
 
 	service := newTestService(storeMock)
-	_, err = bulkUpdateRuleSet(service, req)
+	_, err = updateRuleSet(service, req)
 	require.Error(t, err)
 	require.IsType(t, NewInternalError(""), err)
 }
@@ -367,7 +367,7 @@ func TestRulesetUpdateRuleSetBadInput(t *testing.T) {
 	storeMock.EXPECT().FetchRuleSet(namespaceID).Return(newRuleSet(namespaceID, 1), nil).Times(1)
 
 	service := newTestService(storeMock)
-	_, err = bulkUpdateRuleSet(service, req)
+	_, err = updateRuleSet(service, req)
 	require.Error(t, err)
 	require.IsType(t, NewBadInputError(""), err)
 }
@@ -452,7 +452,7 @@ func TestApplyChangesToRuleSetNoChanges(t *testing.T) {
 	)
 
 	service := newTestService(nil)
-	_, err = bulkUpdateRuleSet(service, req)
+	_, err = updateRuleSet(service, req)
 	require.Error(t, err)
 	require.IsType(t, NewBadInputError(""), err)
 }
@@ -488,7 +488,7 @@ func TestRulesetUpdateRuleSetMappingRuleMissingOp(t *testing.T) {
 	storeMock.EXPECT().FetchRuleSet(namespaceID).Return(newRuleSet(namespaceID, 1), nil).Times(1)
 
 	service := newTestService(storeMock)
-	_, err = bulkUpdateRuleSet(service, req)
+	_, err = updateRuleSet(service, req)
 	require.Error(t, err)
 	require.IsType(t, NewBadInputError(""), err)
 }
@@ -524,7 +524,7 @@ func TestRulesetUpdateRuleSetRollupRuleMissingOp(t *testing.T) {
 	storeMock.EXPECT().FetchRuleSet(namespaceID).Return(newRuleSet(namespaceID, 1), nil).Times(1)
 
 	service := newTestService(storeMock)
-	_, err = bulkUpdateRuleSet(service, req)
+	_, err = updateRuleSet(service, req)
 	require.Error(t, err)
 	require.IsType(t, NewBadInputError(""), err)
 }

service/r2/service.go

@@ -150,7 +150,7 @@ func NewService(
 	store store.Store,
 	iOpts instrument.Options,
 	clockOpts clock.Options,
-	rulePropigationDelay time.Duration,
+	rulePropagationDelay time.Duration,
 ) mservice.Service {
 	return &service{
 		rootPrefix:   rootPrefix,
@@ -159,7 +159,7 @@ func NewService(
 		logger:       iOpts.Logger(),
 		nowFn:        clockOpts.NowFn(),
 		metrics:      newServiceMetrics(iOpts.MetricsScope(), iOpts.MetricsSamplingRate()),
-		updateHelper: rules.NewRuleSetUpdateHelper(rulePropigationDelay),
+		updateHelper: rules.NewRuleSetUpdateHelper(rulePropagationDelay),
 	}
 }
 
@@ -178,7 +178,7 @@ func (s *service) RegisterHandlers(router *mux.Router) error {
 		{route: route{path: namespacePrefix, method: http.MethodGet}, handler: s.fetchNamespace},
 		{route: route{path: namespacePrefix, method: http.MethodDelete}, handler: s.deleteNamespace},
 		{route: route{path: validateRuleSetPath, method: http.MethodPost}, handler: s.validateNamespace},
-		{route: route{path: updateRuleSetPath, method: http.MethodPost}, handler: s.bulkUpdateRuleSet},
+		{route: route{path: updateRuleSetPath, method: http.MethodPost}, handler: s.updateRuleSet},
 
 		// Mapping Rule actions.
 		{route: route{path: mappingRuleRoot, method: http.MethodPost}, handler: s.createMappingRule},
@@ -369,8 +369,8 @@ func (s *service) fetchRollupRuleHistory(w http.ResponseWriter, r *http.Request)
 	return s.sendResponse(w, http.StatusOK, data)
 }
 
-func (s *service) bulkUpdateRuleSet(w http.ResponseWriter, r *http.Request) error {
-	data, err := s.handleRoute(bulkUpdateRuleSet, r, s.metrics.bulkUpdateRuleSet)
+func (s *service) updateRuleSet(w http.ResponseWriter, r *http.Request) error {
+	data, err := s.handleRoute(updateRuleSet, r, s.metrics.bulkUpdateRuleSet)
 	if err != nil {
 		return err
 	}