Package org.zalando.nakadiproducer

Interface NakadiProducerFlywayCallback

  • public interface NakadiProducerFlywayCallback
    This is the main callback interface that should be implemented to get access to flyway lifecycle notifications. Simply add code to the callback method you are interested in having.

    Each callback method will run within its own transaction.

    • Method Detail

      • beforeClean

        default void beforeClean​(Connection connection)
        Runs before the clean task executes.
        Parameters:
        connection - A valid connection to the database.

      • afterClean

        default void afterClean​(Connection connection)
        Runs after the clean task executes.
        Parameters:
        connection - A valid connection to the database.

      • beforeMigrate

        default void beforeMigrate​(Connection connection)
        Runs before the migrate task executes.
        Parameters:
        connection - A valid connection to the database.

      • afterMigrate

        default void afterMigrate​(Connection connection)
        Runs after the migrate task executes.
        Parameters:
        connection - A valid connection to the database.

      • beforeUndo

        default void beforeUndo​(Connection connection)
        Runs before the undo task executes.
        Parameters:
        connection - A valid connection to the database.

      • beforeEachUndo

        default void beforeEachUndo​(Connection connection,
                            org.flywaydb.core.api.MigrationInfo info)
        Runs before each migration script is undone.
        Parameters:
        connection - A valid connection to the database.
        info - The current MigrationInfo for the migration to be undone.

      • afterEachUndo

        default void afterEachUndo​(Connection connection,
                           org.flywaydb.core.api.MigrationInfo info)
        Runs after each migration script is undone.
        Parameters:
        connection - A valid connection to the database.
        info - The current MigrationInfo for the migration just undone.

      • afterUndo

        default void afterUndo​(Connection connection)
        Runs after the undo task executes.
        Parameters:
        connection - A valid connection to the database.

      • beforeEachMigrate

        default void beforeEachMigrate​(Connection connection,
                               org.flywaydb.core.api.MigrationInfo info)
        Runs before each migration script is executed.
        Parameters:
        connection - A valid connection to the database.
        info - The current MigrationInfo for this migration.

      • afterEachMigrate

        default void afterEachMigrate​(Connection connection,
                              org.flywaydb.core.api.MigrationInfo info)
        Runs after each migration script is executed.
        Parameters:
        connection - A valid connection to the database.
        info - The current MigrationInfo for this migration.

      • beforeValidate

        default void beforeValidate​(Connection connection)
        Runs before the validate task executes.
        Parameters:
        connection - A valid connection to the database.

      • afterValidate

        default void afterValidate​(Connection connection)
        Runs after the validate task executes.
        Parameters:
        connection - A valid connection to the database.

      • beforeBaseline

        default void beforeBaseline​(Connection connection)
        Runs before the baseline task executes.
        Parameters:
        connection - A valid connection to the database.

      • afterBaseline

        default void afterBaseline​(Connection connection)
        Runs after the baseline task executes.
        Parameters:
        connection - A valid connection to the database.

      • beforeRepair

        default void beforeRepair​(Connection connection)
        Runs before the repair task executes.
        Parameters:
        connection - A valid connection to the database.

      • afterRepair

        default void afterRepair​(Connection connection)
        Runs after the repair task executes.
        Parameters:
        connection - A valid connection to the database.

      • beforeInfo

        default void beforeInfo​(Connection connection)
        Runs before the info task executes.
        Parameters:
        connection - A valid connection to the database.

      • afterInfo

        default void afterInfo​(Connection connection)
        Runs after the info task executes.
        Parameters:
        connection - A valid connection to the database.