v1alpha1

package
v0.44.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 20, 2025 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewIntegrationSink added in v0.44.0 

func NewIntegrationSink(name, namespace string, o ...IntegrationSinkOption) *v1alpha1.IntegrationSink

NewIntegrationSink creates a v1 IntegrationSink with IntegrationSinkOptions

func NewIntegrationSource added in v0.44.0 

func NewIntegrationSource(name, namespace string, o ...IntegrationSourceOption) *v1alpha1.IntegrationSource

NewIntegrationSource creates a v1 IntegrationSource with IntegrationSourceOptions

func NewJobSink added in v0.42.0 

func NewJobSink(name, namespace string, o ...JobSinkOption) *sinksv1alpha1.JobSink

NewJobSink creates a JobSink with JobSinkOptions.

func WithInitIntegrationSinkConditions added in v0.44.0 

func WithInitIntegrationSinkConditions(s *v1alpha1.IntegrationSink)

WithInitIntegrationSinkConditions initializes the IntegrationSink's conditions.

func WithInitIntegrationSourceConditions added in v0.44.0 

func WithInitIntegrationSourceConditions(s *v1alpha1.IntegrationSource)

WithInitIntegrationSourceConditions initializes the IntegrationSource's conditions.

func WithInitJobSinkConditions added in v0.42.0 

func WithInitJobSinkConditions(js *sinksv1alpha1.JobSink)

WithInitJobSinkConditions initializes the JobSink's conditions.

Types

type IntegrationSinkOption added in v0.44.0 

type IntegrationSinkOption func(source *v1alpha1.IntegrationSink)

IntegrationSinkOption enables further configuration of a IntegrationSink.

func WithIntegrationSinkAddress added in v0.44.0 

func WithIntegrationSinkAddress(addr *duckv1.Addressable) IntegrationSinkOption

func WithIntegrationSinkAddressableReady added in v0.44.0 

func WithIntegrationSinkAddressableReady() IntegrationSinkOption

func WithIntegrationSinkEventPoliciesReadyBecauseOIDCDisabled added in v0.44.0 

func WithIntegrationSinkEventPoliciesReadyBecauseOIDCDisabled() IntegrationSinkOption

func WithIntegrationSinkPropagateDeploymenteStatus added in v0.44.0 

func WithIntegrationSinkPropagateDeploymenteStatus(status *appsv1.DeploymentStatus) IntegrationSinkOption

func WithIntegrationSinkSpec added in v0.44.0 

func WithIntegrationSinkSpec(spec v1alpha1.IntegrationSinkSpec) IntegrationSinkOption

func WithIntegrationSinkUID added in v0.44.0 

func WithIntegrationSinkUID(uid types.UID) IntegrationSinkOption

type IntegrationSourceOption added in v0.44.0 

type IntegrationSourceOption func(source *v1alpha1.IntegrationSource)

IntegrationSourceOption enables further configuration of a IntegrationSource.

func WithIntegrationSourceOIDCServiceAccountName added in v0.44.0 

func WithIntegrationSourceOIDCServiceAccountName(name string) IntegrationSourceOption

func WithIntegrationSourcePropagateContainerSourceStatus added in v0.44.0 

func WithIntegrationSourcePropagateContainerSourceStatus(status *v1.ContainerSourceStatus) IntegrationSourceOption

func WithIntegrationSourceSpec added in v0.44.0 

func WithIntegrationSourceSpec(spec v1alpha1.IntegrationSourceSpec) IntegrationSourceOption

func WithIntegrationSourceStatusObservedGeneration added in v0.44.0 

func WithIntegrationSourceStatusObservedGeneration(generation int64) IntegrationSourceOption

func WithIntegrationSourceUID added in v0.44.0 

func WithIntegrationSourceUID(uid types.UID) IntegrationSourceOption

type JobSinkOption added in v0.42.0 

type JobSinkOption func(*sinksv1alpha1.JobSink)

JobSinkOption enables further configuration of a JobSink.

func WithJobSinkAddress added in v0.42.0 

func WithJobSinkAddress(addr *duckv1.Addressable) JobSinkOption

func WithJobSinkAddressableReady added in v0.42.0 

func WithJobSinkAddressableReady() JobSinkOption

func WithJobSinkEventPoliciesListed added in v0.42.0 

func WithJobSinkEventPoliciesListed(policyNames ...string) JobSinkOption

WithJobSinkEventPoliciesListed adds Ready EventPolicies to the JobSink's status.

func WithJobSinkEventPoliciesNotReady added in v0.42.0 

func WithJobSinkEventPoliciesNotReady(reason, message string) JobSinkOption

WithJobSinkEventPoliciesNotReady sets the JobSink's EventPoliciesReady condition to false.

func WithJobSinkEventPoliciesReady added in v0.42.0 

func WithJobSinkEventPoliciesReady() JobSinkOption

WithJobSinkEventPoliciesReady sets the JobSink's EventPoliciesReady condition to true.

func WithJobSinkEventPoliciesReadyBecauseNoPolicyAndOIDCEnabled added in v0.42.0 

func WithJobSinkEventPoliciesReadyBecauseNoPolicyAndOIDCEnabled() JobSinkOption

WithJobSinkEventPoliciesReadyBecauseNoPolicyAndOIDCEnabled() sets the JobSink's EventPoliciesReady condition to true with reason.

func WithJobSinkEventPoliciesReadyBecauseOIDCDisabled added in v0.42.0 

func WithJobSinkEventPoliciesReadyBecauseOIDCDisabled() JobSinkOption

WithJobSinkEventPoliciesReadyBecauseNoPolicy() sets the JobSink's EventPoliciesReady condition to true with reason.

func WithJobSinkFinalizers added in v0.42.0 

func WithJobSinkFinalizers(finalizers ...string) JobSinkOption

func WithJobSinkGeneration added in v0.42.0 

func WithJobSinkGeneration(gen int64) JobSinkOption

func WithJobSinkJob added in v0.42.0 

func WithJobSinkJob(job *batchv1.Job) JobSinkOption

WithJobSinkJob sets the JobSink's Job.

func WithJobSinkJobStatusSelector added in v0.42.0 

func WithJobSinkJobStatusSelector() JobSinkOption

func WithJobSinkResourceVersion added in v0.42.0 

func WithJobSinkResourceVersion(rv string) JobSinkOption

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.