remove useless changes

streamnative · Oct 16, 2024 · 1d47a97 · 1d47a97
1 parent f559194
commit 1d47a97
Show file tree

Hide file tree

Showing 3 changed files with 2 additions and 15 deletions.
diff --git a/server/follower_controller.go b/server/follower_controller.go
@@ -178,7 +178,7 @@ func NewFollowerControllerWithContext(config Config, namespace string, shardId i
 			"oxia":  "follower-apply-committed-entries",
 			"shard": fmt.Sprintf("%d", fc.shardId),
 		},
-		fc.ApplyAllCommittedEntries,
+		fc.applyAllCommittedEntries,
 	)
 
 	fc.log.Info(
@@ -492,7 +492,7 @@ func (fc *followerController) handleReplicateSync(stream proto.OxiaLogReplicatio
 	}
 }
 
-func (fc *followerController) ApplyAllCommittedEntries() {
+func (fc *followerController) applyAllCommittedEntries() {
 	for {
 		fc.Lock()
 		if err := fc.applyEntriesCond.Wait(fc.ctx); err != nil {
@@ -788,7 +788,3 @@ func (fc *followerController) DeleteShard(request *proto.DeleteShardRequest) (*p
 
 	return &proto.DeleteShardResponse{}, nil
 }
-
-func (fc *followerController) GetDB() kv.DB {
-	return fc.db
-}
diff --git a/server/kv/db.go b/server/kv/db.go
@@ -803,10 +803,6 @@ func (d *db) ReadNextNotifications(ctx context.Context, startOffset int64) ([]*p
 	return d.notificationsTracker.ReadNextNotifications(ctx, startOffset)
 }
 
-func (d *db) GetKv() KV {
-	return d.kv
-}
-
 type noopCallback struct{}
 
 func (*noopCallback) OnPut(_ WriteBatch, _ *proto.PutRequest, _ *proto.StorageEntry) (proto.Status, error) {

diff --git a/server/server.go b/server/server.go
@@ -145,8 +145,3 @@ func (s *Server) Close() error {
 
 	return err
 }
-
-// GetShardDirector is using for testing
-func (s *Server) GetShardDirector() ShardsDirector {
-	return s.shardsDirector
-}