Rename UpdateQueueState to SetQueueState (#4187)

temporalio · Apr 19, 2023 · bdbec13 · bdbec13
1 parent becc2f3
commit bdbec13
Show file tree

Hide file tree

Showing 5 changed files with 18 additions and 18 deletions.
diff --git a/service/history/queues/queue_base.go b/service/history/queues/queue_base.go
@@ -483,7 +483,7 @@ func (p *queueBase) updateQueueState(
 		}
 	}
 
-	err := p.shard.UpdateQueueState(p.category, ToPersistenceQueueState(&queueState{
+	err := p.shard.SetQueueState(p.category, ToPersistenceQueueState(&queueState{
 		readerScopes:                 readerScopes,
 		exclusiveReaderHighWatermark: p.nonReadableScope.Range.InclusiveMin,
 	}))

diff --git a/service/history/shard/context.go b/service/history/shard/context.go
@@ -82,7 +82,7 @@ type (
 		GetQueueClusterAckLevel(category tasks.Category, cluster string) tasks.Key
 		UpdateQueueClusterAckLevel(category tasks.Category, cluster string, ackLevel tasks.Key) error
 		GetQueueState(category tasks.Category) (*persistencespb.QueueState, bool)
-		UpdateQueueState(category tasks.Category, state *persistencespb.QueueState) error
+		SetQueueState(category tasks.Category, state *persistencespb.QueueState) error
 
 		GetReplicatorDLQAckLevel(sourceCluster string) int64
 		UpdateReplicatorDLQAckLevel(sourCluster string, ackLevel int64) error

diff --git a/service/history/shard/context_impl.go b/service/history/shard/context_impl.go
@@ -438,7 +438,7 @@ func (s *ContextImpl) GetQueueState(
 	return queueState, ok
 }
 
-func (s *ContextImpl) UpdateQueueState(
+func (s *ContextImpl) SetQueueState(
 	category tasks.Category,
 	state *persistencespb.QueueState,
 ) error {

diff --git a/service/history/shard/context_mock.go b/service/history/shard/context_mock.go
diff --git a/service/history/visibilityQueueTaskExecutor_test.go b/service/history/visibilityQueueTaskExecutor_test.go
@@ -522,7 +522,7 @@ func (s *visibilityQueueTaskExecutorSuite) TestProcessorDeleteExecution() {
 	})
 	s.Run("MultiCursorQueue", func() {
 		const highWatermark int64 = 5
-		s.NoError(s.mockShard.UpdateQueueState(tasks.CategoryVisibility, &persistencespb.QueueState{
+		s.NoError(s.mockShard.SetQueueState(tasks.CategoryVisibility, &persistencespb.QueueState{
 			ReaderStates: nil,
 			ExclusiveReaderHighWatermark: &persistencespb.TaskKey{
 				TaskId:   highWatermark,