Documentation ¶
Index ¶
- func BrokerContinualTests() []pkgupgrade.BackgroundOperation
- func BrokerPostDowngradeTest() pkgupgrade.Operation
- func BrokerPostUpgradeTest() pkgupgrade.Operation
- func BrokerPreUpgradeTest() pkgupgrade.Operation
- func ChannelContinualTests() []pkgupgrade.BackgroundOperation
- func ChannelPostDowngradeTest() pkgupgrade.Operation
- func ChannelPostUpgradeTest() pkgupgrade.Operation
- func ChannelPreUpgradeTest() pkgupgrade.Operation
- func ContinualTests() []pkgupgrade.BackgroundOperation
- func SinkContinualTests() []pkgupgrade.BackgroundOperation
- func SinkPostDowngradeTest() pkgupgrade.Operation
- func SinkPostUpgradeTest() pkgupgrade.Operation
- func SinkPreUpgradeTest() pkgupgrade.Operation
- func Suite() pkgupgrade.Suite
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
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 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 Suite ¶
func Suite() pkgupgrade.Suite
Suite defines the whole upgrade test suite for Eventing Kafka.
Types ¶
This section is empty.