v1alpha1

package
v0.0.5 Latest Latest
Warning

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

 Go to latest Published: Mar 16, 2024 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Overview

Package v1alpha1 contains the v1alpha1 group Sample resources of the SpringCloudDataFlow provider. +kubebuilder:object:generate=true +groupName=core.springclouddataflow.crossplane.io +versionName=v1alpha1

Index

Constants

View Source 
const (
	Group   = "core.springclouddataflow.crossplane.io"
	Version = "v1alpha1"
)

Package type metadata.

Variables

View Source 
var (
	ApplicationKind             = reflect.TypeOf(Application{}).Name()
	ApplicationGroupKind        = schema.GroupKind{Group: Group, Kind: ApplicationKind}.String()
	ApplicationKindAPIVersion   = ApplicationKind + "." + SchemeGroupVersion.String()
	ApplicationGroupVersionKind = SchemeGroupVersion.WithKind(ApplicationKind)
)

Application type metadata.

View Source 
var (
	// SchemeGroupVersion is group version used to register these objects
	SchemeGroupVersion = schema.GroupVersion{Group: Group, Version: Version}

	// SchemeBuilder is used to add go types to the GroupVersionKind scheme
	SchemeBuilder = &scheme.Builder{GroupVersion: SchemeGroupVersion}
)
View Source 
var (
	StreamKind             = reflect.TypeOf(Stream{}).Name()
	StreamGroupKind        = schema.GroupKind{Group: Group, Kind: StreamKind}.String()
	StreamKindAPIVersion   = StreamKind + "." + SchemeGroupVersion.String()
	StreamGroupVersionKind = SchemeGroupVersion.WithKind(StreamKind)
)

Stream type metadata.

View Source 
var (
	TaskDefinitionKind             = reflect.TypeOf(TaskDefinition{}).Name()
	TaskDefinitionGroupKind        = schema.GroupKind{Group: Group, Kind: TaskDefinitionKind}.String()
	TaskDefinitionKindAPIVersion   = TaskDefinitionKind + "." + SchemeGroupVersion.String()
	TaskDefinitionGroupVersionKind = SchemeGroupVersion.WithKind(TaskDefinitionKind)
)

TaskDefinition type metadata.

View Source 
var (
	TaskScheduleKind             = reflect.TypeOf(TaskSchedule{}).Name()
	TaskScheduleGroupKind        = schema.GroupKind{Group: Group, Kind: TaskScheduleKind}.String()
	TaskScheduleKindAPIVersion   = TaskScheduleKind + "." + SchemeGroupVersion.String()
	TaskScheduleGroupVersionKind = SchemeGroupVersion.WithKind(TaskScheduleKind)
)

TaskSchedule type metadata.

Functions

This section is empty.

Types

type Application 

type Application struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   ApplicationSpec   `json:"spec"`
	Status ApplicationStatus `json:"status,omitempty"`
}

A Application is an example API type. +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:subresource:status +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,springclouddataflow}

func (*Application) DeepCopy 

func (in *Application) DeepCopy() *Application

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Application.

func (*Application) DeepCopyInto 

func (in *Application) DeepCopyInto(out *Application)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*Application) DeepCopyObject 

func (in *Application) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*Application) GetCondition 

func (mg *Application) GetCondition(ct xpv1.ConditionType) xpv1.Condition

GetCondition of this Application.

func (*Application) GetDeletionPolicy 

func (mg *Application) GetDeletionPolicy() xpv1.DeletionPolicy

GetDeletionPolicy of this Application.

func (*Application) GetManagementPolicies 

func (mg *Application) GetManagementPolicies() xpv1.ManagementPolicies

GetManagementPolicies of this Application.

func (*Application) GetProviderConfigReference 

func (mg *Application) GetProviderConfigReference() *xpv1.Reference

GetProviderConfigReference of this Application.

func (*Application) GetProviderReference 

func (mg *Application) GetProviderReference() *xpv1.Reference

GetProviderReference of this Application. Deprecated: Use GetProviderConfigReference.

func (*Application) GetPublishConnectionDetailsTo 

func (mg *Application) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

GetPublishConnectionDetailsTo of this Application.

func (*Application) GetWriteConnectionSecretToReference 

func (mg *Application) GetWriteConnectionSecretToReference() *xpv1.SecretReference

GetWriteConnectionSecretToReference of this Application.

func (*Application) SetConditions 

func (mg *Application) SetConditions(c ...xpv1.Condition)

SetConditions of this Application.

func (*Application) SetDeletionPolicy 

func (mg *Application) SetDeletionPolicy(r xpv1.DeletionPolicy)

SetDeletionPolicy of this Application.

func (*Application) SetManagementPolicies 

func (mg *Application) SetManagementPolicies(r xpv1.ManagementPolicies)

SetManagementPolicies of this Application.

func (*Application) SetProviderConfigReference 

func (mg *Application) SetProviderConfigReference(r *xpv1.Reference)

SetProviderConfigReference of this Application.

func (*Application) SetProviderReference 

func (mg *Application) SetProviderReference(r *xpv1.Reference)

SetProviderReference of this Application. Deprecated: Use SetProviderConfigReference.

func (*Application) SetPublishConnectionDetailsTo 

func (mg *Application) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

SetPublishConnectionDetailsTo of this Application.

func (*Application) SetWriteConnectionSecretToReference 

func (mg *Application) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

SetWriteConnectionSecretToReference of this Application.

type ApplicationList 

type ApplicationList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []Application `json:"items"`
}

ApplicationList contains a list of Application

func (*ApplicationList) DeepCopy 

func (in *ApplicationList) DeepCopy() *ApplicationList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ApplicationList.

func (*ApplicationList) DeepCopyInto 

func (in *ApplicationList) DeepCopyInto(out *ApplicationList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*ApplicationList) DeepCopyObject 

func (in *ApplicationList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*ApplicationList) GetItems 

func (l *ApplicationList) GetItems() []resource.Managed

GetItems of this ApplicationList.

type ApplicationObservation 

type ApplicationObservation struct {
	Name           string `json:"name"`
	Type           string `json:"type"`
	Version        string `json:"version"`
	Uri            string `json:"uri"`
	DefaultVersion bool   `json:"defaultVersion"`
	BootVersion    string `json:"bootVersion"`
}

ApplicationObservation are the observable fields of a Application.

func (*ApplicationObservation) DeepCopy 

func (in *ApplicationObservation) DeepCopy() *ApplicationObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ApplicationObservation.

func (*ApplicationObservation) DeepCopyInto 

func (in *ApplicationObservation) DeepCopyInto(out *ApplicationObservation)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ApplicationParameters 

type ApplicationParameters struct {

	// Name of the Application (immutable)
	// +kubebuilder:validation:Required
	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Name is immutable"
	Name string `json:"name"`

	// Type of the Application (immutable)
	// +kubebuilder:validation:Required
	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Type is immutable"
	// +kubebuilder:validation:Enum=app;source;processor;sink;task
	Type string `json:"type"`

	// Version of the Application (immutable)
	// +kubebuilder:validation:Required
	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Version is immutable"
	Version string `json:"version"`

	// Uri of the Application (immutable)
	// +kubebuilder:validation:Required
	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Uri is immutable"
	Uri string `json:"uri"`

	// Is this Application the Default
	// +kubebuilder:validation:Required
	DefaultVersion bool `json:"defaultVersion"`

	// BootVersion of the Application (immutable)
	// +kubebuilder:validation:Required
	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="BootVersion is immutable"
	BootVersion string `json:"bootVersion"`
}

ApplicationParameters are the configurable fields of a Application.

func (*ApplicationParameters) DeepCopy 

func (in *ApplicationParameters) DeepCopy() *ApplicationParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ApplicationParameters.

func (*ApplicationParameters) DeepCopyInto 

func (in *ApplicationParameters) DeepCopyInto(out *ApplicationParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ApplicationSpec 

type ApplicationSpec struct {
	xpv1.ResourceSpec `json:",inline"`
	ForProvider       ApplicationParameters `json:"forProvider"`
}

A ApplicationSpec defines the desired state of a Application.

func (*ApplicationSpec) DeepCopy 

func (in *ApplicationSpec) DeepCopy() *ApplicationSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ApplicationSpec.

func (*ApplicationSpec) DeepCopyInto 

func (in *ApplicationSpec) DeepCopyInto(out *ApplicationSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ApplicationStatus 

type ApplicationStatus struct {
	xpv1.ResourceStatus `json:",inline"`
	AtProvider          ApplicationObservation `json:"atProvider,omitempty"`
}

A ApplicationStatus represents the observed state of a Application.

func (*ApplicationStatus) DeepCopy 

func (in *ApplicationStatus) DeepCopy() *ApplicationStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ApplicationStatus.

func (*ApplicationStatus) DeepCopyInto 

func (in *ApplicationStatus) DeepCopyInto(out *ApplicationStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Stream added in v0.0.5 

type Stream struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   StreamSpec   `json:"spec"`
	Status StreamStatus `json:"status,omitempty"`
}

A Stream is an example API type. +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:subresource:status +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,springclouddataflow}

func (*Stream) DeepCopy added in v0.0.5 

func (in *Stream) DeepCopy() *Stream

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Stream.

func (*Stream) DeepCopyInto added in v0.0.5 

func (in *Stream) DeepCopyInto(out *Stream)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*Stream) DeepCopyObject added in v0.0.5 

func (in *Stream) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*Stream) GetCondition added in v0.0.5 

func (mg *Stream) GetCondition(ct xpv1.ConditionType) xpv1.Condition

GetCondition of this Stream.

func (*Stream) GetDeletionPolicy added in v0.0.5 

func (mg *Stream) GetDeletionPolicy() xpv1.DeletionPolicy

GetDeletionPolicy of this Stream.

func (*Stream) GetManagementPolicies added in v0.0.5 

func (mg *Stream) GetManagementPolicies() xpv1.ManagementPolicies

GetManagementPolicies of this Stream.

func (*Stream) GetProviderConfigReference added in v0.0.5 

func (mg *Stream) GetProviderConfigReference() *xpv1.Reference

GetProviderConfigReference of this Stream.

func (*Stream) GetProviderReference added in v0.0.5 

func (mg *Stream) GetProviderReference() *xpv1.Reference

GetProviderReference of this Stream. Deprecated: Use GetProviderConfigReference.

func (*Stream) GetPublishConnectionDetailsTo added in v0.0.5 

func (mg *Stream) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

GetPublishConnectionDetailsTo of this Stream.

func (*Stream) GetWriteConnectionSecretToReference added in v0.0.5 

func (mg *Stream) GetWriteConnectionSecretToReference() *xpv1.SecretReference

GetWriteConnectionSecretToReference of this Stream.

func (*Stream) SetConditions added in v0.0.5 

func (mg *Stream) SetConditions(c ...xpv1.Condition)

SetConditions of this Stream.

func (*Stream) SetDeletionPolicy added in v0.0.5 

func (mg *Stream) SetDeletionPolicy(r xpv1.DeletionPolicy)

SetDeletionPolicy of this Stream.

func (*Stream) SetManagementPolicies added in v0.0.5 

func (mg *Stream) SetManagementPolicies(r xpv1.ManagementPolicies)

SetManagementPolicies of this Stream.

func (*Stream) SetProviderConfigReference added in v0.0.5 

func (mg *Stream) SetProviderConfigReference(r *xpv1.Reference)

SetProviderConfigReference of this Stream.

func (*Stream) SetProviderReference added in v0.0.5 

func (mg *Stream) SetProviderReference(r *xpv1.Reference)

SetProviderReference of this Stream. Deprecated: Use SetProviderConfigReference.

func (*Stream) SetPublishConnectionDetailsTo added in v0.0.5 

func (mg *Stream) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

SetPublishConnectionDetailsTo of this Stream.

func (*Stream) SetWriteConnectionSecretToReference added in v0.0.5 

func (mg *Stream) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

SetWriteConnectionSecretToReference of this Stream.

type StreamList added in v0.0.5 

type StreamList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []Stream `json:"items"`
}

StreamList contains a list of Stream

func (*StreamList) DeepCopy added in v0.0.5 

func (in *StreamList) DeepCopy() *StreamList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamList.

func (*StreamList) DeepCopyInto added in v0.0.5 

func (in *StreamList) DeepCopyInto(out *StreamList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*StreamList) DeepCopyObject added in v0.0.5 

func (in *StreamList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*StreamList) GetItems added in v0.0.5 

func (l *StreamList) GetItems() []resource.Managed

GetItems of this StreamList.

type StreamObservation added in v0.0.5 

type StreamObservation struct {
	Name              string `json:"name"`
	Description       string `json:"description"`
	Definition        string `json:"definition"`
	Status            string `json:"status"`
	StatusDescription string `json:"statusDescription"`
}

StreamObservation are the observable fields of a Stream.

func (*StreamObservation) DeepCopy added in v0.0.5 

func (in *StreamObservation) DeepCopy() *StreamObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamObservation.

func (*StreamObservation) DeepCopyInto added in v0.0.5 

func (in *StreamObservation) DeepCopyInto(out *StreamObservation)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type StreamParameters added in v0.0.5 

type StreamParameters struct {
	// Name of the stream (immutable)
	// +kubebuilder:validation:Required
	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Name is immutable"
	Name string `json:"name"`

	// Description of the stream (immutable)
	// +kubebuilder:validation:Required
	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Description is immutable"
	Description string `json:"description"`

	// The definition for the stream, using Data Flow DSL (immutable)
	// +kubebuilder:validation:Required
	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Definition is immutable"
	Definition string `json:"definition"`

	// If true, the stream is deployed upon creation (immutable)
	// +kubebuilder:validation:Required
	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Deploy is immutable"
	Deploy bool `json:"deploy"`
}

StreamParameters are the configurable fields of a Stream.

func (*StreamParameters) DeepCopy added in v0.0.5 

func (in *StreamParameters) DeepCopy() *StreamParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamParameters.

func (*StreamParameters) DeepCopyInto added in v0.0.5 

func (in *StreamParameters) DeepCopyInto(out *StreamParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type StreamSpec added in v0.0.5 

type StreamSpec struct {
	xpv1.ResourceSpec `json:",inline"`
	ForProvider       StreamParameters `json:"forProvider"`
}

A StreamSpec defines the desired state of a Stream.

func (*StreamSpec) DeepCopy added in v0.0.5 

func (in *StreamSpec) DeepCopy() *StreamSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamSpec.

func (*StreamSpec) DeepCopyInto added in v0.0.5 

func (in *StreamSpec) DeepCopyInto(out *StreamSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type StreamStatus added in v0.0.5 

type StreamStatus struct {
	xpv1.ResourceStatus `json:",inline"`
	AtProvider          StreamObservation `json:"atProvider,omitempty"`
}

A StreamStatus represents the observed state of a Stream.

func (*StreamStatus) DeepCopy added in v0.0.5 

func (in *StreamStatus) DeepCopy() *StreamStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamStatus.

func (*StreamStatus) DeepCopyInto added in v0.0.5 

func (in *StreamStatus) DeepCopyInto(out *StreamStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type TaskDefinition added in v0.0.3 

type TaskDefinition struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   TaskDefinitionSpec   `json:"spec"`
	Status TaskDefinitionStatus `json:"status,omitempty"`
}

A TaskDefinition is an example API type. +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:subresource:status +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,springclouddataflow}

func (*TaskDefinition) DeepCopy added in v0.0.3 

func (in *TaskDefinition) DeepCopy() *TaskDefinition

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TaskDefinition.

func (*TaskDefinition) DeepCopyInto added in v0.0.3 

func (in *TaskDefinition) DeepCopyInto(out *TaskDefinition)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*TaskDefinition) DeepCopyObject added in v0.0.3 

func (in *TaskDefinition) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*TaskDefinition) GetCondition added in v0.0.3 

func (mg *TaskDefinition) GetCondition(ct xpv1.ConditionType) xpv1.Condition

GetCondition of this TaskDefinition.

func (*TaskDefinition) GetDeletionPolicy added in v0.0.3 

func (mg *TaskDefinition) GetDeletionPolicy() xpv1.DeletionPolicy

GetDeletionPolicy of this TaskDefinition.

func (*TaskDefinition) GetManagementPolicies added in v0.0.3 

func (mg *TaskDefinition) GetManagementPolicies() xpv1.ManagementPolicies

GetManagementPolicies of this TaskDefinition.

func (*TaskDefinition) GetProviderConfigReference added in v0.0.3 

func (mg *TaskDefinition) GetProviderConfigReference() *xpv1.Reference

GetProviderConfigReference of this TaskDefinition.

func (*TaskDefinition) GetProviderReference added in v0.0.3 

func (mg *TaskDefinition) GetProviderReference() *xpv1.Reference

GetProviderReference of this TaskDefinition. Deprecated: Use GetProviderConfigReference.

func (*TaskDefinition) GetPublishConnectionDetailsTo added in v0.0.3 

func (mg *TaskDefinition) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

GetPublishConnectionDetailsTo of this TaskDefinition.

func (*TaskDefinition) GetWriteConnectionSecretToReference added in v0.0.3 

func (mg *TaskDefinition) GetWriteConnectionSecretToReference() *xpv1.SecretReference

GetWriteConnectionSecretToReference of this TaskDefinition.

func (*TaskDefinition) SetConditions added in v0.0.3 

func (mg *TaskDefinition) SetConditions(c ...xpv1.Condition)

SetConditions of this TaskDefinition.

func (*TaskDefinition) SetDeletionPolicy added in v0.0.3 

func (mg *TaskDefinition) SetDeletionPolicy(r xpv1.DeletionPolicy)

SetDeletionPolicy of this TaskDefinition.

func (*TaskDefinition) SetManagementPolicies added in v0.0.3 

func (mg *TaskDefinition) SetManagementPolicies(r xpv1.ManagementPolicies)

SetManagementPolicies of this TaskDefinition.

func (*TaskDefinition) SetProviderConfigReference added in v0.0.3 

func (mg *TaskDefinition) SetProviderConfigReference(r *xpv1.Reference)

SetProviderConfigReference of this TaskDefinition.

func (*TaskDefinition) SetProviderReference added in v0.0.3 

func (mg *TaskDefinition) SetProviderReference(r *xpv1.Reference)

SetProviderReference of this TaskDefinition. Deprecated: Use SetProviderConfigReference.

func (*TaskDefinition) SetPublishConnectionDetailsTo added in v0.0.3 

func (mg *TaskDefinition) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

SetPublishConnectionDetailsTo of this TaskDefinition.

func (*TaskDefinition) SetWriteConnectionSecretToReference added in v0.0.3 

func (mg *TaskDefinition) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

SetWriteConnectionSecretToReference of this TaskDefinition.

type TaskDefinitionList added in v0.0.3 

type TaskDefinitionList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []TaskDefinition `json:"items"`
}

TaskDefinitionList contains a list of TaskDefinition

func (*TaskDefinitionList) DeepCopy added in v0.0.3 

func (in *TaskDefinitionList) DeepCopy() *TaskDefinitionList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TaskDefinitionList.

func (*TaskDefinitionList) DeepCopyInto added in v0.0.3 

func (in *TaskDefinitionList) DeepCopyInto(out *TaskDefinitionList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*TaskDefinitionList) DeepCopyObject added in v0.0.3 

func (in *TaskDefinitionList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*TaskDefinitionList) GetItems added in v0.0.3 

func (l *TaskDefinitionList) GetItems() []resource.Managed

GetItems of this TaskDefinitionList.

type TaskDefinitionObservation added in v0.0.3 

type TaskDefinitionObservation struct {
	Name                string `json:"name"`
	Description         string `json:"description"`
	Definition          string `json:"definition"`
	Composed            bool   `json:"composed"`
	ComposedTaskElement bool   `json:"composedTaskElement"`
	Status              string `json:"status"`
}

TaskDefinitionObservation are the observable fields of a TaskDefinition.

func (*TaskDefinitionObservation) DeepCopy added in v0.0.3 

func (in *TaskDefinitionObservation) DeepCopy() *TaskDefinitionObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TaskDefinitionObservation.

func (*TaskDefinitionObservation) DeepCopyInto added in v0.0.3 

func (in *TaskDefinitionObservation) DeepCopyInto(out *TaskDefinitionObservation)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type TaskDefinitionParameters added in v0.0.3 

type TaskDefinitionParameters struct {

	// Name of the task definition (immutable)
	// +kubebuilder:validation:Required
	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Name is immutable"
	Name string `json:"name"`

	// Description of the task definition (immutable)
	// +kubebuilder:validation:Required
	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Description is immutable"
	Description string `json:"description"`

	// The definition for the task, using Data Flow DSL (immutable)
	// +kubebuilder:validation:Required
	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Definition is immutable"
	Definition string `json:"definition"`
}

TaskDefinitionParameters are the configurable fields of a TaskDefinition.

func (*TaskDefinitionParameters) DeepCopy added in v0.0.3 

func (in *TaskDefinitionParameters) DeepCopy() *TaskDefinitionParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TaskDefinitionParameters.

func (*TaskDefinitionParameters) DeepCopyInto added in v0.0.3 

func (in *TaskDefinitionParameters) DeepCopyInto(out *TaskDefinitionParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type TaskDefinitionSpec added in v0.0.3 

type TaskDefinitionSpec struct {
	xpv1.ResourceSpec `json:",inline"`
	ForProvider       TaskDefinitionParameters `json:"forProvider"`
}

A TaskDefinitionSpec defines the desired state of a TaskDefinition.

func (*TaskDefinitionSpec) DeepCopy added in v0.0.3 

func (in *TaskDefinitionSpec) DeepCopy() *TaskDefinitionSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TaskDefinitionSpec.

func (*TaskDefinitionSpec) DeepCopyInto added in v0.0.3 

func (in *TaskDefinitionSpec) DeepCopyInto(out *TaskDefinitionSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type TaskDefinitionStatus added in v0.0.3 

type TaskDefinitionStatus struct {
	xpv1.ResourceStatus `json:",inline"`
	AtProvider          TaskDefinitionObservation `json:"atProvider,omitempty"`
}

A TaskDefinitionStatus represents the observed state of a TaskDefinition.

func (*TaskDefinitionStatus) DeepCopy added in v0.0.3 

func (in *TaskDefinitionStatus) DeepCopy() *TaskDefinitionStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TaskDefinitionStatus.

func (*TaskDefinitionStatus) DeepCopyInto added in v0.0.3 

func (in *TaskDefinitionStatus) DeepCopyInto(out *TaskDefinitionStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type TaskSchedule added in v0.0.4 

type TaskSchedule struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   TaskScheduleSpec   `json:"spec"`
	Status TaskScheduleStatus `json:"status,omitempty"`
}

A TaskSchedule is an example API type. +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:subresource:status +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,springclouddataflow}

func (*TaskSchedule) DeepCopy added in v0.0.4 

func (in *TaskSchedule) DeepCopy() *TaskSchedule

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TaskSchedule.

func (*TaskSchedule) DeepCopyInto added in v0.0.4 

func (in *TaskSchedule) DeepCopyInto(out *TaskSchedule)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*TaskSchedule) DeepCopyObject added in v0.0.4 

func (in *TaskSchedule) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*TaskSchedule) GetCondition added in v0.0.4 

func (mg *TaskSchedule) GetCondition(ct xpv1.ConditionType) xpv1.Condition

GetCondition of this TaskSchedule.

func (*TaskSchedule) GetDeletionPolicy added in v0.0.4 

func (mg *TaskSchedule) GetDeletionPolicy() xpv1.DeletionPolicy

GetDeletionPolicy of this TaskSchedule.

func (*TaskSchedule) GetManagementPolicies added in v0.0.4 

func (mg *TaskSchedule) GetManagementPolicies() xpv1.ManagementPolicies

GetManagementPolicies of this TaskSchedule.

func (*TaskSchedule) GetProviderConfigReference added in v0.0.4 

func (mg *TaskSchedule) GetProviderConfigReference() *xpv1.Reference

GetProviderConfigReference of this TaskSchedule.

func (*TaskSchedule) GetProviderReference added in v0.0.4 

func (mg *TaskSchedule) GetProviderReference() *xpv1.Reference

GetProviderReference of this TaskSchedule. Deprecated: Use GetProviderConfigReference.

func (*TaskSchedule) GetPublishConnectionDetailsTo added in v0.0.4 

func (mg *TaskSchedule) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

GetPublishConnectionDetailsTo of this TaskSchedule.

func (*TaskSchedule) GetWriteConnectionSecretToReference added in v0.0.4 

func (mg *TaskSchedule) GetWriteConnectionSecretToReference() *xpv1.SecretReference

GetWriteConnectionSecretToReference of this TaskSchedule.

func (*TaskSchedule) ResolveReferences added in v0.0.4 

func (mg *TaskSchedule) ResolveReferences(ctx context.Context, c client.Reader) error

ResolveReferences of this TaskSchedule.

func (*TaskSchedule) SetConditions added in v0.0.4 

func (mg *TaskSchedule) SetConditions(c ...xpv1.Condition)

SetConditions of this TaskSchedule.

func (*TaskSchedule) SetDeletionPolicy added in v0.0.4 

func (mg *TaskSchedule) SetDeletionPolicy(r xpv1.DeletionPolicy)

SetDeletionPolicy of this TaskSchedule.

func (*TaskSchedule) SetManagementPolicies added in v0.0.4 

func (mg *TaskSchedule) SetManagementPolicies(r xpv1.ManagementPolicies)

SetManagementPolicies of this TaskSchedule.

func (*TaskSchedule) SetProviderConfigReference added in v0.0.4 

func (mg *TaskSchedule) SetProviderConfigReference(r *xpv1.Reference)

SetProviderConfigReference of this TaskSchedule.

func (*TaskSchedule) SetProviderReference added in v0.0.4 

func (mg *TaskSchedule) SetProviderReference(r *xpv1.Reference)

SetProviderReference of this TaskSchedule. Deprecated: Use SetProviderConfigReference.

func (*TaskSchedule) SetPublishConnectionDetailsTo added in v0.0.4 

func (mg *TaskSchedule) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

SetPublishConnectionDetailsTo of this TaskSchedule.

func (*TaskSchedule) SetWriteConnectionSecretToReference added in v0.0.4 

func (mg *TaskSchedule) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

SetWriteConnectionSecretToReference of this TaskSchedule.

type TaskScheduleList added in v0.0.4 

type TaskScheduleList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []TaskSchedule `json:"items"`
}

TaskScheduleList contains a list of TaskSchedule

func (*TaskScheduleList) DeepCopy added in v0.0.4 

func (in *TaskScheduleList) DeepCopy() *TaskScheduleList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TaskScheduleList.

func (*TaskScheduleList) DeepCopyInto added in v0.0.4 

func (in *TaskScheduleList) DeepCopyInto(out *TaskScheduleList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*TaskScheduleList) DeepCopyObject added in v0.0.4 

func (in *TaskScheduleList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*TaskScheduleList) GetItems added in v0.0.4 

func (l *TaskScheduleList) GetItems() []resource.Managed

GetItems of this TaskScheduleList.

type TaskScheduleObservation added in v0.0.4 

type TaskScheduleObservation struct {
	ScheduleName string `json:"scheduleName"`

	TaskDefinitionName *string `json:"taskDefinitionName,omitempty"`
}

TaskScheduleObservation are the observable fields of a TaskSchedule.

func (*TaskScheduleObservation) DeepCopy added in v0.0.4 

func (in *TaskScheduleObservation) DeepCopy() *TaskScheduleObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TaskScheduleObservation.

func (*TaskScheduleObservation) DeepCopyInto added in v0.0.4 

func (in *TaskScheduleObservation) DeepCopyInto(out *TaskScheduleObservation)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type TaskScheduleParameters added in v0.0.4 

type TaskScheduleParameters struct {

	// Name of the task schedule (immutable)
	// +kubebuilder:validation:Required
	// +kubebuilder:validation:Pattern=[a-z0-9]([-a-z0-9]*[a-z0-9])?(\.[a-z0-9]([-a-z0-9]*[a-z0-9])?)*
	// +kubebuilder:validation:MaxLength=52
	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Name is immutable"
	ScheduleName string `json:"scheduleName"`

	// TaskDefinition Name that will be scheduled (immutable)
	// At least one of taskDefinitionName, taskDefinitionNameRef or taskDefinitionNameSelector is required.
	// +kubebuilder:validation:Optional
	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="TaskDefinitionName is immutable"
	// +crossplane:generate:reference:type=github.com/denniskniep/provider-springclouddataflow/apis/core/v1alpha1.TaskDefinition
	TaskDefinitionName *string `json:"taskDefinitionName,omitempty"`

	// TaskDefinition reference to retrieve the TaskDefinition Name, that will be scheduled
	// At least one of taskDefinitionName, taskDefinitionNameRef or taskDefinitionNameSelector is required.
	// +optional
	TaskDefinitionNameRef *xpv1.Reference `json:"taskDefinitionNameRef,omitempty"`

	// TaskDefinitionNameSelector selects a reference to a TaskDefinition and retrieves its name
	// At least one of temporalNamespaceName, temporalNamespaceNameRef or temporalNamespaceNameSelector is required.
	// +optional
	TaskDefinitionNameSelector *xpv1.Selector `json:"taskDefinitionNameSelector,omitempty"`

	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Platform is immutable"
	// +kubebuilder:validation:Required
	CronExpression string `json:"cronExpression,omitempty"`

	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Platform is immutable"
	// +kubebuilder:default=default
	Platform string `json:"platform,omitempty"`

	// +optional
	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Arguments is immutable"
	Arguments *string `json:"arguments,omitempty"`

	// +optional
	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Properties is immutable"
	Properties *string `json:"properties,omitempty"`
}

TaskScheduleParameters are the configurable fields of a TaskSchedule.

func (*TaskScheduleParameters) DeepCopy added in v0.0.4 

func (in *TaskScheduleParameters) DeepCopy() *TaskScheduleParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TaskScheduleParameters.

func (*TaskScheduleParameters) DeepCopyInto added in v0.0.4 

func (in *TaskScheduleParameters) DeepCopyInto(out *TaskScheduleParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type TaskScheduleSpec added in v0.0.4 

type TaskScheduleSpec struct {
	xpv1.ResourceSpec `json:",inline"`
	ForProvider       TaskScheduleParameters `json:"forProvider"`
}

A TaskScheduleSpec defines the desired state of a TaskSchedule.

func (*TaskScheduleSpec) DeepCopy added in v0.0.4 

func (in *TaskScheduleSpec) DeepCopy() *TaskScheduleSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TaskScheduleSpec.

func (*TaskScheduleSpec) DeepCopyInto added in v0.0.4 

func (in *TaskScheduleSpec) DeepCopyInto(out *TaskScheduleSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type TaskScheduleStatus added in v0.0.4 

type TaskScheduleStatus struct {
	xpv1.ResourceStatus `json:",inline"`
	AtProvider          TaskScheduleObservation `json:"atProvider,omitempty"`
}

A TaskScheduleStatus represents the observed state of a TaskSchedule.

func (*TaskScheduleStatus) DeepCopy added in v0.0.4 

func (in *TaskScheduleStatus) DeepCopy() *TaskScheduleStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TaskScheduleStatus.

func (*TaskScheduleStatus) DeepCopyInto added in v0.0.4 

func (in *TaskScheduleStatus) DeepCopyInto(out *TaskScheduleStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

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.