eventmesh

Documentation

Index

• func NewEventMeshUpgradeTest(appConnectorCli appconnectorclientset.Interface, k8sCli kubernetes.Interface, ...) runner.UpgradeTest
• type EventMeshUpgradeTest
  • func (e *EventMeshUpgradeTest) CreateResources(stop <-chan struct{}, log logrus.FieldLogger, namespace string) error
  • func (e *EventMeshUpgradeTest) TestResources(stop <-chan struct{}, log logrus.FieldLogger, namespace string) error
• type EventingUpgradeTest
  • func NewEventingUpgradeTest(k8sClient kubernetes.Interface, dynamicClient dynamic.Interface) *EventingUpgradeTest
  • func (e *EventingUpgradeTest) CreateResources(stop <-chan struct{}, log logrus.FieldLogger, namespace string) error
  • func (e *EventingUpgradeTest) TestResources(stop <-chan struct{}, log logrus.FieldLogger, namespace string) error

Functions

func NewEventMeshUpgradeTest

func NewEventMeshUpgradeTest(
	appConnectorCli appconnectorclientset.Interface,
	k8sCli kubernetes.Interface,
	messagingCli messagingv1alpha1clientset.MessagingV1alpha1Interface,
	sourcesCli sourcesv1alpha1.SourcesV1alpha1Interface,
	appBrokerCli appbrokerclientset.Interface,
	scCli scclientset.Interface,
	eventingCli eventingv1alpha1clientset.EventingV1alpha1Interface,
	subscriberImage string) runner.UpgradeTest

Types

type EventMeshUpgradeTest

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

TODO remove this test when Kyma is fully integrated with the new Eventing solution https://github.com/kyma-project/kyma/issues/10866

func (*EventMeshUpgradeTest) CreateResources

func (e *EventMeshUpgradeTest) CreateResources(stop <-chan struct{}, log logrus.FieldLogger, namespace string) error

func (*EventMeshUpgradeTest) TestResources

func (e *EventMeshUpgradeTest) TestResources(stop <-chan struct{}, log logrus.FieldLogger, namespace string) error

type EventingUpgradeTest

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

func NewEventingUpgradeTest

func NewEventingUpgradeTest(k8sClient kubernetes.Interface, dynamicClient dynamic.Interface) *EventingUpgradeTest

func (*EventingUpgradeTest) CreateResources

func (e *EventingUpgradeTest) CreateResources(stop <-chan struct{}, log logrus.FieldLogger, namespace string) error

func (*EventingUpgradeTest) TestResources

func (e *EventingUpgradeTest) TestResources(stop <-chan struct{}, log logrus.FieldLogger, namespace string) error