migration_003_entity

type EntityMigration ¶

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

EntityMigration adds the `entity` field to all tenant and destination records. This field is used by RediSearch FILTER to distinguish tenants from destinations since both share the same key prefix pattern (tenant:{id}:*).

- Tenants get `entity: "tenant"` - Destinations get `entity: "destination"`

This migration is idempotent - records with an existing entity field are skipped.

func New(client redis.Client, logger migratorredis.Logger, deploymentID string) *EntityMigration

func (m *EntityMigration) Apply(ctx context.Context, plan *migratorredis.Plan) (*migratorredis.State, error)

func (m *EntityMigration) AutoRunnable() bool

func (m *EntityMigration) Cleanup(ctx context.Context, state *migratorredis.State) error

func (m *EntityMigration) Description() string

func (m *EntityMigration) IsApplicable(ctx context.Context) (bool, string)

func (m *EntityMigration) Name() string

func (m *EntityMigration) Plan(ctx context.Context) (*migratorredis.Plan, error)

func (m *EntityMigration) PlanCleanup(ctx context.Context) (int, error)

func (m *EntityMigration) Verify(ctx context.Context, state *migratorredis.State) (*migratorredis.VerificationResult, error)

func (m *EntityMigration) Version() int