rebase, review fixes

Author: qrort

cmd/integration/make_backup/main.go

@@ -410,7 +410,7 @@ func main() {
 			{
 				event: RawEvent{
 					Action:      "ActionUpdate",
-					Component:   "backup_service",
+					Component:   "backup_schedule_service",
 					Status:      "NEW",
 					ContainerID: containerID,
 					Database:    databaseName,
@@ -427,8 +427,8 @@ func main() {
 			},
 			{
 				event: RawEvent{
-					Action:      "ActionUpdate",
-					Component:   "backup_service",
+					Action:      "ActionGet",
+					Component:   "backup_schedule_service",
 					Status:      "ERROR",
 					Reason:      "Recovery point objective failed for schedule",
 					ContainerID: containerID,

cmd/ydbcp/main.go

@@ -201,7 +201,9 @@ func main() {
 		os.Exit(1)
 	}
 
-	processor.NewOperationProcessor(ctx, &wg, configInstance.GetProcessorIntervalSeconds(), dbConnector, handlersRegistry)
+	processor.NewOperationProcessor(
+		ctx, &wg, configInstance.GetProcessorIntervalSeconds(), dbConnector, handlersRegistry,
+	)
 	xlog.Info(ctx, "Initialized OperationProcessor")
 
 	if configInstance.GetDisableTTLDeletion() {
@@ -214,7 +216,7 @@ func main() {
 	backupScheduleHandler := handlers.NewBackupScheduleHandler(queries.NewWriteTableQuery, clockwork.NewRealClock())
 
 	schedule_watcher.NewScheduleWatcher(
-		ctx, &wg, configInstance.ProcessorIntervalSeconds, dbConnector,
+		ctx, &wg, configInstance.GetProcessorIntervalSeconds(), dbConnector,
 		backupScheduleHandler, clockwork.NewRealClock(),
 	)
 	xlog.Info(ctx, "Created ScheduleWatcher")

internal/audit/audit_event.go

@@ -160,13 +160,15 @@ func ReportBackupStateAuditEvent(
 ) {
 	status := operation.GetState().String()
 	reason := ""
+	component := "backup_service"
 	switch operation.GetState() {
 	case types.OperationStateRunning:
 		{
 			if retry {
 				status = "RETRYING"
 				reason = "New backup attempt scheduled"
 			} else if new {
+				component = "backup_schedule_service"
 				status = "NEW"
 				reason = "New retryable backup attempt scheduled"
 			}
@@ -195,7 +197,7 @@ func ReportBackupStateAuditEvent(
 			SpecVersion:    "1.0",
 			Action:         ActionUpdate,
 			Resource:       Backup,
-			Component:      "backup_service",
+			Component:      component,
 			FolderID:       operation.GetContainerID(),
 			Subject:        types.OperationCreatorName,
 			//no token
@@ -234,7 +236,7 @@ func ReportFailedRPOAuditEvent(ctx context.Context, schedule *types.BackupSchedu
 			SpecVersion:    "1.0",
 			Action:         ActionGet,
 			Resource:       BackupSchedule,
-			Component:      "backup_service",
+			Component:      "backup_schedule_service",
 			FolderID:       schedule.ContainerID,
 			Subject:        types.OperationCreatorName,
 			//no token