Refactor Instance Watcher

internal/bus/topics.go

@@ -6,9 +6,7 @@
 package bus
 
 const (
-	AddInstancesTopic                = "add-instances"
 	UpdatedInstancesTopic            = "updated-instances"
-	DeletedInstancesTopic            = "deleted-instances"
 	ResourceUpdateTopic              = "resource-update"
 	NginxConfigUpdateTopic           = "nginx-config-update"
 	InstanceHealthTopic              = "instance-health"
@@ -19,11 +17,7 @@ const (
 	ConnectionResetTopic             = "connection-reset"
 	ConfigApplyRequestTopic          = "config-apply-request"
 	WriteConfigSuccessfulTopic       = "write-config-successful"
-	ReloadSuccessfulTopic            = "reload-successful"
 	EnableWatchersTopic              = "enable-watchers"
-	ConfigApplyFailedTopic           = "config-apply-failed"
-	ConfigApplyCompleteTopic         = "config-apply-complete"
-	RollbackWriteTopic               = "rollback-write"
 	DataPlaneHealthRequestTopic      = "data-plane-health-request"
 	DataPlaneHealthResponseTopic     = "data-plane-health-response"
 	APIActionRequestTopic            = "api-action-request"

internal/file/file_manager_service.go

@@ -31,7 +31,7 @@ import (
 //counterfeiter:generate . fileOperator
 
 //go:generate go run github.com/maxbrunsfeld/counterfeiter/v6@v6.11.2 -generate
-//counterfeiter:generate . fileManagerServiceInterface
+//counterfeiter:generate . FileManagerServiceInterface
 
 //go:generate go run github.com/maxbrunsfeld/counterfeiter/v6@v6.11.2 -generate
 //counterfeiter:generate . fileServiceOperatorInterface
@@ -88,7 +88,7 @@ type (
 		UpdateClient(ctx context.Context, fileServiceClient mpi.FileServiceClient)
 	}
 
-	fileManagerServiceInterface interface {
+	FileManagerServiceInterface interface {
 		ConfigApply(ctx context.Context, configApplyRequest *mpi.ConfigApplyRequest) (writeStatus model.WriteStatus,
 			err error)
 		Rollback(ctx context.Context, instanceID string) error