fix: typo in batch job

vdaas · Oct 20, 2024 · 2a25c68 · 2a25c68
1 parent 0a8b332
commit 2a25c68
Show file tree

Hide file tree

Showing 7 changed files with 7 additions and 7 deletions.
diff --git a/pkg/gateway/mirror/usecase/vald.go b/pkg/gateway/mirror/usecase/vald.go
@@ -263,7 +263,7 @@ func (r *run) Stop(ctx context.Context) (errs error) {
 	return errs
 }
 
-// PtopStop is a method called after execution of Stop.
+// PostStop is a method called after execution of Stop.
 func (*run) PostStop(_ context.Context) error {
 	return nil
 }
diff --git a/pkg/index/job/creation/service/indexer.go b/pkg/index/job/creation/service/indexer.go
@@ -175,7 +175,7 @@ func (idx *index) doCreateIndex(
 				switch {
 				case errors.Is(err, context.Canceled):
 					err = status.WrapWithCanceled(
-						agent.CreateIndexRPCName+" API canceld", err,
+						agent.CreateIndexRPCName+" API canceled", err,
 					)
 					attrs = trace.StatusCodeCancelled(err.Error())
 				case errors.Is(err, context.DeadlineExceeded):

diff --git a/pkg/index/job/creation/usecase/creation.go b/pkg/index/job/creation/usecase/creation.go
@@ -208,7 +208,7 @@ func (r *run) Stop(ctx context.Context) (errs error) {
 	return errs
 }
 
-// PtopStop is a method called after execution of Stop.
+// PostStop is a method called after execution of Stop.
 func (*run) PostStop(_ context.Context) error {
 	return nil
 }
diff --git a/pkg/index/job/readreplica/rotate/usecase/rotate.go b/pkg/index/job/readreplica/rotate/usecase/rotate.go
@@ -165,7 +165,7 @@ func (r *run) Stop(ctx context.Context) (errs error) {
 	return errs
 }
 
-// PtopStop is a method called after execution of Stop.
+// PostStop is a method called after execution of Stop.
 func (*run) PostStop(_ context.Context) error {
 	return nil
 }
diff --git a/pkg/index/job/save/service/indexer.go b/pkg/index/job/save/service/indexer.go
@@ -171,7 +171,7 @@ func (idx *index) doSaveIndex(
 				switch {
 				case errors.Is(err, context.Canceled):
 					err = status.WrapWithCanceled(
-						agent.SaveIndexRPCName+" API canceld", err,
+						agent.SaveIndexRPCName+" API canceled", err,
 					)
 					attrs = trace.StatusCodeCancelled(err.Error())
 				case errors.Is(err, context.DeadlineExceeded):

diff --git a/pkg/index/job/save/usecase/save.go b/pkg/index/job/save/usecase/save.go
@@ -207,7 +207,7 @@ func (r *run) Stop(ctx context.Context) (errs error) {
 	return errs
 }
 
-// PtopStop is a method called after execution of Stop.
+// PostStop is a method called after execution of Stop.
 func (*run) PostStop(_ context.Context) error {
 	return nil
 }
diff --git a/pkg/index/operator/usecase/operator.go b/pkg/index/operator/usecase/operator.go
@@ -155,7 +155,7 @@ func (r *run) Stop(ctx context.Context) (errs error) {
 	return errs
 }
 
-// PtopStop is a method called after execution of Stop.
+// PostStop is a method called after execution of Stop.
 func (*run) PostStop(_ context.Context) error {
 	return nil
 }