support

package

v0.0.24 Latest Latest Go to latest Published: Apr 1, 2026 License: Apache-2.0 Imports: 25 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/kaotoIO/kaoto-operator

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func ClusterRoleBinding(t Test, kaoto *kaotoApi.Kaoto) func(g gomega.Gomega) (*rbacv1.ClusterRoleBinding, error)
func ConditionStatus[T conditionType](conditionType T) func(any) corev1.ConditionStatus
func ContainerImage(index int) func(*appsv1.Deployment) string
func Deployment(t Test, kaoto *kaotoApi.Kaoto) func(g gomega.Gomega) (*appsv1.Deployment, error)
func GetIngress(t Test, kaoto *kaotoApi.Kaoto) (*netv1.Ingress, error)
func Ingress(t Test, kaoto *kaotoApi.Kaoto) func(g gomega.Gomega) (*netv1.Ingress, error)
func Kaoto(t Test, namespace *corev1.Namespace, name string) func(g gomega.Gomega) *kaoto.Kaoto
func Service(t Test, kaoto *kaotoApi.Kaoto) func(g gomega.Gomega) (*corev1.Service, error)
func ServiceAccount(t Test, kaoto *kaotoApi.Kaoto) func(g gomega.Gomega) (*corev1.ServiceAccount, error)
type Client
type Option
type T
type Test
- func With(t *testing.T) Test

Constants ¶

View Source

const (
	TestTimeoutMini   = 5 * time.Second
	TestTimeoutShort  = 1 * time.Minute
	TestTimeoutMedium = 2 * time.Minute
	TestTimeoutLong   = 5 * time.Minute
)

Variables ¶

This section is empty.

Functions ¶

func ClusterRoleBinding ¶

func ClusterRoleBinding(t Test, kaoto *kaotoApi.Kaoto) func(g gomega.Gomega) (*rbacv1.ClusterRoleBinding, error)

func ConditionStatus ¶

func ConditionStatus[T conditionType](conditionType T) func(any) corev1.ConditionStatus

func ContainerImage ¶

func ContainerImage(index int) func(*appsv1.Deployment) string

func Deployment ¶

func Deployment(t Test, kaoto *kaotoApi.Kaoto) func(g gomega.Gomega) (*appsv1.Deployment, error)

func GetIngress ¶

func GetIngress(t Test, kaoto *kaotoApi.Kaoto) (*netv1.Ingress, error)

func Ingress ¶

func Ingress(t Test, kaoto *kaotoApi.Kaoto) func(g gomega.Gomega) (*netv1.Ingress, error)

func Kaoto ¶

func Kaoto(t Test, namespace *corev1.Namespace, name string) func(g gomega.Gomega) *kaoto.Kaoto

func Service ¶

func Service(t Test, kaoto *kaotoApi.Kaoto) func(g gomega.Gomega) (*corev1.Service, error)

func ServiceAccount ¶

func ServiceAccount(t Test, kaoto *kaotoApi.Kaoto) func(g gomega.Gomega) (*corev1.ServiceAccount, error)

Types ¶

type Client ¶

type Client struct {
	kubernetes.Interface

	Kaoto     kaoto.Interface
	Discovery discovery.DiscoveryInterface
	Route     route.Interface
	// contains filtered or unexported fields
}

type Option ¶

type Option[T any] interface {
	// contains filtered or unexported methods
}

type T ¶

type T struct {
	*gomega.WithT
	// contains filtered or unexported fields
}

func (*T) Client ¶

func (t *T) Client() *Client

func (*T) Ctx ¶

func (t *T) Ctx() context.Context

func (*T) NewTestNamespace ¶

func (t *T) NewTestNamespace(options ...Option[*corev1.Namespace]) *corev1.Namespace

func (*T) T ¶

func (t *T) T() *testing.T

type Test ¶

type Test interface {
	T() *testing.T
	Ctx() context.Context
	Client() *Client

	NewTestNamespace(...Option[*corev1.Namespace]) *corev1.Namespace

	gomega.Gomega
}

func With ¶

func With(t *testing.T) Test

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL