upgrade

func BrokerContinualTests ¶

func BrokerContinualTests() []pkgupgrade.BackgroundOperation

BrokerContinualTests returns background operations to test broker functionality in continual manner during the whole upgrade and downgrade process asserting that all events are propagated.

func BrokerPostDowngradeTest ¶

func BrokerPostDowngradeTest() pkgupgrade.Operation

BrokerPostDowngradeTest tests channel basic channel operations after downgrade.

func BrokerPostUpgradeTest ¶

func BrokerPostUpgradeTest() pkgupgrade.Operation

BrokerPostUpgradeTest tests channel operations after upgrade.

func BrokerPreUpgradeTest ¶

func BrokerPreUpgradeTest() pkgupgrade.Operation

BrokerPreUpgradeTest tests broker basic operations before upgrade.

func ChannelContinualTests ¶ added in v0.31.0

func ChannelContinualTests() []pkgupgrade.BackgroundOperation

ChannelContinualTests returns background operations to test KafkaChannel functionality in continual manner during the whole upgrade and downgrade process asserting that all events are propagated.

func ChannelPostDowngradeTest ¶ added in v0.31.0

func ChannelPostDowngradeTest() pkgupgrade.Operation

ChannelPostDowngradeTest tests channel basic channel operations after downgrade.

func ChannelPostUpgradeTest ¶ added in v0.31.0

func ChannelPostUpgradeTest() pkgupgrade.Operation

ChannelPostUpgradeTest tests channel operations after upgrade.

func ChannelPreUpgradeTest ¶ added in v0.31.0

func ChannelPreUpgradeTest() pkgupgrade.Operation

ChannelPreUpgradeTest tests channel basic operations before upgrade.

func ContinualTests ¶ added in v0.29.0

func ContinualTests() []pkgupgrade.BackgroundOperation

ContinualTests returns all continual tests.

func NamespacedBrokerContinualTests ¶ added in v0.36.0

func NamespacedBrokerContinualTests() []pkgupgrade.BackgroundOperation

func NamespacedBrokerPostDowngradeTest ¶ added in v0.36.0

func NamespacedBrokerPostDowngradeTest() pkgupgrade.Operation

NamespacedBrokerPostDowngradeTest tests basic namespaced broker operations after downgrade.

func NamespacedBrokerPostUpgradeTest ¶ added in v0.36.0

func NamespacedBrokerPostUpgradeTest() pkgupgrade.Operation

NamespacedBrokerPostUpgradeTest tests channel operations after upgrade.

func NamespacedBrokerPreUpgradeTest ¶ added in v0.36.0

func NamespacedBrokerPreUpgradeTest() pkgupgrade.Operation

NamespacedBrokerPreUpgradeTest tests broker basic operations before upgrade.

func SinkContinualTests ¶ added in v0.29.0

func SinkContinualTests() []pkgupgrade.BackgroundOperation

SinkContinualTests returns background operations to test KafkaSink functionality in continual manner during the whole upgrade and downgrade process asserting that all events are propagated.

func SinkPostDowngradeTest ¶ added in v0.29.0

func SinkPostDowngradeTest() pkgupgrade.Operation

SinkPostDowngradeTest tests sink basic operations after downgrade.

func SinkPostUpgradeTest ¶ added in v0.29.0

func SinkPostUpgradeTest() pkgupgrade.Operation

SinkPostUpgradeTest tests sink basic operations post upgrade.

func SinkPreUpgradeTest ¶ added in v0.29.0

func SinkPreUpgradeTest() pkgupgrade.Operation

SinkPreUpgradeTest tests sink basic operations pre upgrade.

func SourcePostDowngradeTest ¶ added in v0.36.0

func SourcePostDowngradeTest(glob environment.GlobalEnvironment) pkgupgrade.Operation

SourcePostDowngradeTest tests source operations after downgrade.

func SourcePostUpgradeTest ¶ added in v0.36.0

func SourcePostUpgradeTest(glob environment.GlobalEnvironment) pkgupgrade.Operation

SourcePostUpgradeTest tests source operations after upgrade.

func SourcePreUpgradeTest ¶ added in v0.36.0

func SourcePreUpgradeTest(glob environment.GlobalEnvironment) pkgupgrade.Operation

SourcePreUpgradeTest tests source operations before upgrade.

func Suite ¶

func Suite(glob environment.GlobalEnvironment) pkgupgrade.Suite

Suite defines the whole upgrade test suite for Eventing Kafka.