ARCO-209: fix PR comments

internal/k8s_watcher/watcher.go

@@ -28,7 +28,7 @@ type K8sClient interface {
 
 type Watcher struct {
 	metamorphClient   metamorph.TransactionMaintainer
-	blocktxClient     blocktx.BlockClient
+	blocktxClient     blocktx.Watcher
 	k8sClient         K8sClient
 	logger            *slog.Logger
 	tickerMetamorph   Ticker
@@ -55,7 +55,7 @@ func WithRetryInterval(d time.Duration) func(*Watcher) {
 type ServerOption func(f *Watcher)
 
 // New The K8s watcher listens to events coming from Kubernetes. If it detects a metamorph pod which was terminated, then it sets records locked by this pod to unlocked. This is a safety measure for the case that metamorph is terminated ungracefully where it misses to unlock its records itself.
-func New(metamorphClient metamorph.TransactionMaintainer, blocktxClient blocktx.BlockClient, k8sClient K8sClient, namespace string, opts ...ServerOption) *Watcher {
+func New(metamorphClient metamorph.TransactionMaintainer, blocktxClient blocktx.Watcher, k8sClient K8sClient, namespace string, opts ...ServerOption) *Watcher {
 	watcher := &Watcher{
 		metamorphClient: metamorphClient,
 		blocktxClient:   blocktxClient,

internal/k8s_watcher/watcher_test.go

@@ -69,7 +69,7 @@ func TestStartMetamorphWatcher(t *testing.T) {
 					return 3, nil
 				},
 			}
-			blocktxMock := &btxMocks.BlockClientMock{}
+			blocktxMock := &btxMocks.WatcherMock{}
 
 			iteration := 0
 			getPodNamesErrTest := tc.getPodNamesErr
@@ -157,7 +157,7 @@ func TestStartBlocktxWatcher(t *testing.T) {
 	for _, tc := range tt {
 		t.Run(tc.name, func(t *testing.T) {
 			metamorphMock := &mtmMocks.TransactionMaintainerMock{}
-			blocktxMock := &btxMocks.BlockClientMock{
+			blocktxMock := &btxMocks.WatcherMock{
 				DelUnfinishedBlockProcessingFunc: func(_ context.Context, _ string) (int64, error) { return 0, nil },
 			}
 

pkg/blocktx/client.go

@@ -10,10 +10,10 @@ import (
 )
 
 // check if Client implements all necessary interfaces
-var _ BlockClient = &Client{}
+var _ Watcher = &Client{}
 var _ MerkleRootsVerifier = &Client{}
 
-type BlockClient interface {
+type Watcher interface {
 	Health(ctx context.Context) error
 	ClearTransactions(ctx context.Context, retentionDays int32) (int64, error)
 	ClearBlocks(ctx context.Context, retentionDays int32) (int64, error)

pkg/blocktx/client_mocks.go

@@ -2,4 +2,4 @@ package blocktx
 
 //go:generate moq -pkg mocks -out ./mocks/merkle_roots_verifier_mock.go . MerkleRootsVerifier
 
-//go:generate moq -pkg mocks -out ./mocks/blocktx_client_mock.go . BlockClient
+//go:generate moq -pkg mocks -out ./mocks/blocktx_client_mock.go . Watcher