coordinator

type ApplyOptions struct {
	// SQLOnly skips Redis migrations.
	SQLOnly bool
	// RedisOnly skips SQL migrations.
	RedisOnly bool
}

type Config struct {
	SQLMigrator     *migrator.Migrator
	RedisClient     redis.Client
	RedisMigrations []migratorredis.Migration
	DeploymentID    string
	Logger          *logging.Logger
}

type Coordinator struct {
	// contains filtered or unexported fields
}

type MigrationInfo struct {
	// ID is a stable identifier used for output/reference, e.g.
	// "sql/000003" or "redis/001_hash_tags".
	ID string

	// Type indicates which subsystem owns this migration.
	Type MigrationType

	// Version orders migrations within a given Type.
	Version int

	// Name is a human-readable name (e.g. "init", "hash_tags").
	Name string

	// Description is a longer human-readable explanation. May be empty
	// for SQL migrations (which only have names).
	Description string

	// Status reflects the current state as tracked by the underlying
	// subsystem.
	Status MigrationStatus

	// Reason is populated when Status is StatusNotApplicable.
	Reason string
}

type MigrationStatus string

type MigrationType string

type PendingSummary struct {
	SQLPending   int
	RedisPending int
}

type Plan struct {
	// SQL summarizes pending SQL migrations.
	SQL SQLPlan
	// Redis lists pending Redis migrations that are applicable.
	Redis []RedisMigrationPlan
}

type RedisMigrationPlan struct {
	Name           string
	Description    string
	EstimatedItems int
	Scope          map[string]int
}

type RedisVerifyResult struct {
	Name         string
	Valid        bool
	ChecksRun    int
	ChecksPassed int
	Issues       []string
	VerifiedAt   time.Time
}

type SQLMigrationInfo struct {
	Version int
	Name    string
}

type SQLPlan struct {
	CurrentVersion int
	LatestVersion  int
	PendingCount   int
	Pending        []SQLMigrationInfo
}

type VerificationReport struct {
	SQLCurrentVersion int
	SQLLatestVersion  int
	RedisResults      []RedisVerifyResult
}