tests

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, additionalAssert func(*testing.T, *batchv1.CronJob))

func AssertCronJobNotExists(t *testing.T, k8sClient client.Client, name types.NamespacedName)

func AssertJobConfiguration(t *testing.T, k8sClient client.Client, name types.NamespacedName, expectedConfiguration string)

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, phase stream.Phase)

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, definition func(definition *testv2.MockStreamDefinition), addResources func(client2 *crfake.ClientBuilder)) 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)