support

package

v0.0.15 Latest Latest Go to latest Published: Oct 27, 2026 License: Apache-2.0 Imports: 33 Imported by: 0

Details

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

Repository

github.com/dapr/kubernetes-operator

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func ConditionReason[T conditions.GenericConditionType](conditionType T) func(any) string
func ConditionStatus[T conditions.GenericConditionType](conditionType T) func(any) corev1.ConditionStatus
func CustomResourceDefinition(t Test, name string) func(g gomega.Gomega) (*apiextv1.CustomResourceDefinition, error)
func Deployment(t Test, name string, namespace string) func(g gomega.Gomega) (*appsv1.Deployment, error)
func Deployments(t Test, namespace string, selector labels.Selector) func(g gomega.Gomega) ([]appsv1.Deployment, error)
func ExtractFirstLoadBalancerIngressHostname() func(*netv1.Ingress) string
func Ingress(t Test, name string, namespace string) func(g gomega.Gomega) (*netv1.Ingress, error)
func Pod(t Test, name string, namespace string) func(g gomega.Gomega) (*corev1.Pod, error)
func PodList(t Test, selector string, namespace string) func(g gomega.Gomega) (*corev1.PodList, error)
func Resource(t Test, ri dynamic.ResourceInterface, un *unstructured.Unstructured) func(g gomega.Gomega) (*unstructured.Unstructured, error)
func Service(t Test, name string, namespace string) func(g gomega.Gomega) (*corev1.Service, error)
type Option
type T
type Test
- func With(t *testing.T) Test

Constants ¶

View Source

const (
	DefaultTestTimeoutMini   = 5 * time.Second
	DefaultTestTimeoutShort  = 1 * time.Minute
	DefaultTestTimeoutMedium = 2 * time.Minute
	DefaultTestTimeoutLong   = 5 * time.Minute
)

Variables ¶

View Source

var (
	TestTimeoutMini   = durationFromEnvOrDefault("E2E_TEST_TIMEOUT_MINI", DefaultTestTimeoutMini)
	TestTimeoutShort  = durationFromEnvOrDefault("E2E_TEST_TIMEOUT_SHORT", DefaultTestTimeoutShort)
	TestTimeoutMedium = durationFromEnvOrDefault("E2E_TEST_TIMEOUT_MEDIUM", DefaultTestTimeoutMedium)
	TestTimeoutLong   = durationFromEnvOrDefault("E2E_TEST_TIMEOUT_LONG", DefaultTestTimeoutLong)

	DefaultEventuallyPollingInterval   = 500 * time.Millisecond
	DefaultEventuallyTimeout           = TestTimeoutLong
	DefaultConsistentlyDuration        = 500 * time.Millisecond
	DefaultConsistentlyPollingInterval = 500 * time.Millisecond
)

Functions ¶

func ConditionReason ¶

func ConditionReason[T conditions.GenericConditionType](conditionType T) func(any) string

func ConditionStatus ¶

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

func CustomResourceDefinition ¶

func CustomResourceDefinition(t Test, name string) func(g gomega.Gomega) (*apiextv1.CustomResourceDefinition, error)

func Deployment ¶

func Deployment(t Test, name string, namespace string) func(g gomega.Gomega) (*appsv1.Deployment, error)

func Deployments ¶

func Deployments(t Test, namespace string, selector labels.Selector) func(g gomega.Gomega) ([]appsv1.Deployment, error)

func ExtractFirstLoadBalancerIngressHostname ¶

func ExtractFirstLoadBalancerIngressHostname() func(*netv1.Ingress) string

func Ingress ¶

func Ingress(t Test, name string, namespace string) func(g gomega.Gomega) (*netv1.Ingress, error)

func Pod ¶

func Pod(t Test, name string, namespace string) func(g gomega.Gomega) (*corev1.Pod, error)

func PodList ¶

func PodList(t Test, selector string, namespace string) func(g gomega.Gomega) (*corev1.PodList, error)

func Resource ¶

func Resource(t Test, ri dynamic.ResourceInterface, un *unstructured.Unstructured) func(g gomega.Gomega) (*unstructured.Unstructured, error)

func Service ¶

func Service(t Test, name string, namespace string) func(g gomega.Gomega) (*corev1.Service, error)

Types ¶

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) Cleanup ¶

func (t *T) Cleanup(f func() []runtime.Object)

func (*T) Client ¶

func (t *T) Client() *supportclient.Client

func (*T) Ctx ¶

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

func (*T) HTTPClient ¶

func (t *T) HTTPClient() *http.Client

func (*T) Helm ¶

func (t *T) Helm() *helmsupport.Helm

func (*T) ID ¶

func (t *T) ID() string

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 {
	gomega.Gomega

	T() *testing.T
	Ctx() context.Context

	ID() string
	Cleanup(f func() []runtime.Object)

	Client() *supportclient.Client
	Helm() *helmsupport.Helm
	HTTPClient() *http.Client

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

func With ¶

func With(t *testing.T) Test

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
client
dapr
helm
olm

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