Versions in this module Expand all Collapse all v1 v1.1.1 Mar 17, 2026 v1.1.0 Mar 16, 2026 Changes in this version + func AssertBackfillRequestCompleted(t *testing.T, k8sClient client.Client, objectName types.NamespacedName) + func AssertBackfillRequestNotCompleted(t *testing.T, k8sClient client.Client, objectName types.NamespacedName) + func AssertCronJobExists(t *testing.T, k8sClient client.Client, name types.NamespacedName, ...) + func AssertCronJobNotExists(t *testing.T, k8sClient client.Client, name types.NamespacedName) + func AssertJobConfiguration(t *testing.T, k8sClient client.Client, name types.NamespacedName, ...) + func AssertJobExists(t *testing.T, k8sClient client.Client, name types.NamespacedName) + func AssertJobNotExists(t *testing.T, k8sClient client.Client, name types.NamespacedName) + func AssertStreamDefinitionPhase(t *testing.T, k8sClient client.Client, name types.NamespacedName, ...) + func Combined(funcs ...func(definition *testv2.MockStreamDefinition)) func(definition *testv2.MockStreamDefinition) + func CombinedB(funcs ...func(definition *crfake.ClientBuilder)) func(definition *crfake.ClientBuilder) + func SetupClient(objectName types.NamespacedName, ...) client.Client + func WithBackfillRequest(n types.NamespacedName) func(definition *crfake.ClientBuilder) + func WithCompletedJob(n types.NamespacedName) func(definition *crfake.ClientBuilder) + func WithConsistentCronJob(n types.NamespacedName, hash string) func(definition *crfake.ClientBuilder) + func WithConsistentJob(n types.NamespacedName, hash string) func(definition *crfake.ClientBuilder) + func WithFailedJob(n types.NamespacedName) func(definition *crfake.ClientBuilder) + func WithNamedStreamDefinition(n types.NamespacedName) func(definition *testv2.MockStreamDefinition) + func WithOutdatedCronJob(n types.NamespacedName) func(definition *crfake.ClientBuilder) + func WithOutdatedJob(n types.NamespacedName) func(definition *crfake.ClientBuilder) + func WithPhase(phase stream.Phase) func(definition *testv2.MockStreamDefinition) + func WithSchedule(schedule string) func(definition *testv2.MockStreamDefinition) + func WithSuspendedSpec(spec bool) func(definition *testv2.MockStreamDefinition)
Go to main page