StackSaga SQL Database Partition Support

# Enable/disable starter (default: true)
stacksaga.partitioning.sql.enabled=true

# Validate database connectivity at startup (default: true)
stacksaga.partitioning.sql.validate-on-startup=true

# Validate user partition creation privileges at startup (default: true)
stacksaga.partitioning.sql.validate-privileges=true

# Run partition creation at application startup (default: true)
stacksaga.partitioning.sql.run-on-startup=true

# Scheduled cron (default: 12:00 PM noon every day)
stacksaga.partitioning.sql.cron=0 0 12 * * *

# Concurrency limit across datasources (default: 4)
stacksaga.partitioning.sql.concurrency=4

# Timeout for opening an R2DBC connection (default: 10s)
stacksaga.partitioning.sql.connect-timeout=10s

# --- Datasource 1: Order Service Database (MySQL) - Daily partitions ---
stacksaga.partitioning.sql.datasources.orderdb.url=r2dbc:mysql://localhost:3306/order_db
stacksaga.partitioning.sql.datasources.orderdb.username=partition_admin
stacksaga.partitioning.sql.datasources.orderdb.password=secret
stacksaga.partitioning.sql.datasources.orderdb.unit=DAYS
stacksaga.partitioning.sql.datasources.orderdb.ahead-count=2

# --- Datasource 2: Payment Service Database (PostgreSQL) - Weekly partitions ---
stacksaga.partitioning.sql.datasources.paymentdb.url=r2dbc:postgresql://localhost:5432/payment_db
stacksaga.partitioning.sql.datasources.paymentdb.username=partition_admin
stacksaga.partitioning.sql.datasources.paymentdb.password=secret
stacksaga.partitioning.sql.datasources.paymentdb.unit=WEEK
stacksaga.partitioning.sql.datasources.paymentdb.ahead-count=3

# --- Datasource 3: Inventory Service Database (MySQL) - Monthly partitions ---
stacksaga.partitioning.sql.datasources.inventorydb.url=r2dbc:mysql://localhost:3306/inventory_db
stacksaga.partitioning.sql.datasources.inventorydb.username=partition_admin
stacksaga.partitioning.sql.datasources.inventorydb.password=secret
stacksaga.partitioning.sql.datasources.inventorydb.unit=MONTH
stacksaga.partitioning.sql.datasources.inventorydb.ahead-count=1

apiVersion: batch/v1
kind: CronJob
metadata:
  name: stacksaga-partition-runner
  namespace: stacksaga
spec:
  schedule: "0 12 * * *"  # Trigger daily at 12:00 PM noon
  concurrencyPolicy: Forbid
  successfulJobsHistoryLimit: 3
  failedJobsHistoryLimit: 3
  jobTemplate:
    spec:
      template:
        spec:
          restartPolicy: OnFailure
          containers:
            - name: partition-runner
              image: your-docker-registry.internal/stacksaga/stacksaga-partition-runner:1.0.0
              env:
                # Execute partition creation immediately upon pod start
                - name: STACKSAGA_PARTITIONING_SQL_RUN_ON_STARTUP
                  value: "true"
                # Validate connectivity and permissions at startup
                - name: STACKSAGA_PARTITIONING_SQL_VALIDATE_ON_STARTUP
                  value: "true"
                - name: STACKSAGA_PARTITIONING_SQL_VALIDATE_PRIVILEGES
                  value: "true"
                # Disable the internal background cron since Kubernetes manages the schedule
                - name: STACKSAGA_PARTITIONING_SQL_CRON
                  value: "none"
                # Automatically exit with code 0 (or 1 on error) when finished
                - name: STACKSAGA_PARTITIONING_SQL_EXIT_ON_COMPLETION
                  value: "true"
              resources:
                requests:
                  memory: "256Mi"
                  cpu: "100m"
                limits:
                  memory: "512Mi"
                  cpu: "500m"

import lombok.extern.slf4j.Slf4j;
import org.springframework.context.event.EventListener;
import org.springframework.stereotype.Component;
import org.stacksaga.partition.event.PartitionExecutionCompletedEvent;

@Component
@Slf4j
public class PartitionMonitoringListener {

    @EventListener
    public void onPartitionCompleted(PartitionExecutionCompletedEvent event) {
        if (!event.isAllSuccessful()) {
            log.error("ALERT: Partition creation failed for {}/{} datasources in {} ms!",
                    event.getFailureCount(), event.getTotalDatasources(), event.getDuration().toMillis());

            event.getReports().forEach((dsName, report) -> {
                if (!report.isSuccess()) {
                    log.error("Datasource '{}' failed: {}", dsName, report.getErrorMessage(), report.getError());
                    // Example: send alert to Slack, Discord, PagerDuty, or Email
                    // alertService.sendAlert("Partition failure on datasource: " + dsName);
                }
            });
        } else {
            log.info("SUCCESS: All {} datasources partitioned successfully in {} ms.",
                    event.getTotalDatasources(), event.getDuration().toMillis());
        }
    }
}