Documentation ¶
Overview ¶
Package v1alpha1 contains API Schema definitions for the sources v1alpha1 API group +k8s:openapi-gen=true +k8s:deepcopy-gen=package,register +k8s:conversion-gen=github.com/knative/eventing-contrib/pkg/apis/sources +k8s:defaulter-gen=TypeMeta +groupName=sources.eventing.knative.dev
Package v1alpha1 contains API Schema definitions for the sources v1alpha1 API group +k8s:openapi-gen=true +k8s:deepcopy-gen=package,register +k8s:conversion-gen=github.com/knative/eventing-contrib/pkg/apis/sources +k8s:defaulter-gen=TypeMeta +groupName=sources.eventing.knative.dev
Index ¶
- Constants
- Variables
- func Resource(resource string) schema.GroupResource
- type CamelSource
- type CamelSourceList
- type CamelSourceOriginComponentSpec
- type CamelSourceOriginSpec
- type CamelSourceSpec
- type CamelSourceStatus
- func (in *CamelSourceStatus) DeepCopy() *CamelSourceStatus
- func (in *CamelSourceStatus) DeepCopyInto(out *CamelSourceStatus)
- func (s *CamelSourceStatus) GetCondition(t duckv1alpha1.ConditionType) *duckv1alpha1.Condition
- func (s *CamelSourceStatus) InitializeConditions()
- func (s *CamelSourceStatus) IsReady() bool
- func (s *CamelSourceStatus) MarkDeployed()
- func (s *CamelSourceStatus) MarkDeploying(reason, messageFormat string, messageA ...interface{})
- func (s *CamelSourceStatus) MarkNoSink(reason, messageFormat string, messageA ...interface{})
- func (s *CamelSourceStatus) MarkNotDeployed(reason, messageFormat string, messageA ...interface{})
- func (s *CamelSourceStatus) MarkSink(uri string)
Constants ¶
const ( // CamelSourceConditionReady has status True when the CamelSource is ready to send events. CamelConditionReady = duckv1alpha1.ConditionReady // CamelConditionSinkProvided has status True when the CamelSource has been configured with a sink target. CamelConditionSinkProvided duckv1alpha1.ConditionType = "SinkProvided" // CamelConditionDeployed has status True when the CamelSource has had it's deployment created. CamelConditionDeployed duckv1alpha1.ConditionType = "Deployed" )
Variables ¶
var ( // SchemeGroupVersion is group version used to register these objects SchemeGroupVersion = schema.GroupVersion{Group: "sources.eventing.knative.dev", Version: "v1alpha1"} // SchemeBuilder is used to add go types to the GroupVersionKind scheme SchemeBuilder = &scheme.Builder{GroupVersion: SchemeGroupVersion} AddToScheme = SchemeBuilder.AddToScheme )
Functions ¶
func Resource ¶
func Resource(resource string) schema.GroupResource
Resource takes an unqualified resource and returns a Group qualified GroupResource
Types ¶
type CamelSource ¶
type CamelSource struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec CamelSourceSpec `json:"spec,omitempty"` Status CamelSourceStatus `json:"status,omitempty"` }
CamelSource is the Schema for the camelsources API +k8s:openapi-gen=true +kubebuilder:subresource:status +kubebuilder:categories=all,knative,eventing,sources
func (*CamelSource) DeepCopy ¶
func (in *CamelSource) DeepCopy() *CamelSource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CamelSource.
func (*CamelSource) DeepCopyInto ¶
func (in *CamelSource) DeepCopyInto(out *CamelSource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*CamelSource) DeepCopyObject ¶
func (in *CamelSource) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type CamelSourceList ¶
type CamelSourceList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` Items []CamelSource `json:"items"` }
CamelSourceList contains a list of CamelSource
func (*CamelSourceList) DeepCopy ¶
func (in *CamelSourceList) DeepCopy() *CamelSourceList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CamelSourceList.
func (*CamelSourceList) DeepCopyInto ¶
func (in *CamelSourceList) DeepCopyInto(out *CamelSourceList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*CamelSourceList) DeepCopyObject ¶
func (in *CamelSourceList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type CamelSourceOriginComponentSpec ¶
type CamelSourceOriginComponentSpec struct { // URI is a Camel component URI to use as starting point (e.g. "timer:tick?period=2s") // +kubebuilder:validation:MinLength=1 URI string `json:"uri,omitempty"` Properties map[string]string `json:"properties,omitempty"` // ServiceAccountName is the name of the ServiceAccount to use to run this source. // +optional ServiceAccountName string `json:"serviceAccountName,omitempty"` // The Camel K context to use when running the source // +optional Context string `json:"context,omitempty"` }
func (*CamelSourceOriginComponentSpec) DeepCopy ¶
func (in *CamelSourceOriginComponentSpec) DeepCopy() *CamelSourceOriginComponentSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CamelSourceOriginComponentSpec.
func (*CamelSourceOriginComponentSpec) DeepCopyInto ¶
func (in *CamelSourceOriginComponentSpec) DeepCopyInto(out *CamelSourceOriginComponentSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type CamelSourceOriginSpec ¶
type CamelSourceOriginSpec struct { // Component is a kind of source that directly references a Camel component Component *CamelSourceOriginComponentSpec `json:"component,omitempty"` // Integration is a kind of source that contains a Camel K integration Integration *v1alpha1.IntegrationSpec `json:"integration,omitempty"` }
CamelSourceOriginSpec is the integration flow to run
func (*CamelSourceOriginSpec) DeepCopy ¶
func (in *CamelSourceOriginSpec) DeepCopy() *CamelSourceOriginSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CamelSourceOriginSpec.
func (*CamelSourceOriginSpec) DeepCopyInto ¶
func (in *CamelSourceOriginSpec) DeepCopyInto(out *CamelSourceOriginSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type CamelSourceSpec ¶
type CamelSourceSpec struct { // Source is the reference to the integration flow to run. Source CamelSourceOriginSpec `json:"source"` // DEPRECATED: moved inside the specific CamelSourceOriginSpec // ServiceAccountName is the name of the ServiceAccount to use to run this // source. // +optional DeprecatedServiceAccountName string `json:"serviceAccountName,omitempty"` // DEPRECATED: use the context field in CamelSourceOriginSpec // Image is an optional base image used to run the source. // +optional DeprecatedImage string `json:"image,omitempty"` // Sink is a reference to an object that will resolve to a domain name to use as the sink. // +optional Sink *corev1.ObjectReference `json:"sink,omitempty"` }
CamelSourceSpec defines the desired state of CamelSource
func (*CamelSourceSpec) DeepCopy ¶
func (in *CamelSourceSpec) DeepCopy() *CamelSourceSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CamelSourceSpec.
func (*CamelSourceSpec) DeepCopyInto ¶
func (in *CamelSourceSpec) DeepCopyInto(out *CamelSourceSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type CamelSourceStatus ¶
type CamelSourceStatus struct { // inherits duck/v1alpha1 Status, which currently provides: // * ObservedGeneration - the 'Generation' of the Service that was last processed by the controller. // * Conditions - the latest available observations of a resource's current state. duckv1alpha1.Status `json:",inline"` // SinkURI is the current active sink URI that has been configured for the CamelSource. // +optional SinkURI string `json:"sinkUri,omitempty"` }
CamelSourceStatus defines the observed state of CamelSource
func (*CamelSourceStatus) DeepCopy ¶
func (in *CamelSourceStatus) DeepCopy() *CamelSourceStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CamelSourceStatus.
func (*CamelSourceStatus) DeepCopyInto ¶
func (in *CamelSourceStatus) DeepCopyInto(out *CamelSourceStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*CamelSourceStatus) GetCondition ¶
func (s *CamelSourceStatus) GetCondition(t duckv1alpha1.ConditionType) *duckv1alpha1.Condition
GetCondition returns the condition currently associated with the given type, or nil.
func (*CamelSourceStatus) InitializeConditions ¶
func (s *CamelSourceStatus) InitializeConditions()
InitializeConditions sets relevant unset conditions to Unknown state.
func (*CamelSourceStatus) IsReady ¶
func (s *CamelSourceStatus) IsReady() bool
IsReady returns true if the resource is ready overall.
func (*CamelSourceStatus) MarkDeployed ¶
func (s *CamelSourceStatus) MarkDeployed()
MarkDeployed sets the condition that the source has been deployed.
func (*CamelSourceStatus) MarkDeploying ¶
func (s *CamelSourceStatus) MarkDeploying(reason, messageFormat string, messageA ...interface{})
MarkDeploying sets the condition that the source is deploying.
func (*CamelSourceStatus) MarkNoSink ¶
func (s *CamelSourceStatus) MarkNoSink(reason, messageFormat string, messageA ...interface{})
MarkNoSink sets the condition that the source does not have a sink configured.
func (*CamelSourceStatus) MarkNotDeployed ¶
func (s *CamelSourceStatus) MarkNotDeployed(reason, messageFormat string, messageA ...interface{})
MarkNotDeployed sets the condition that the source has not been deployed.
func (*CamelSourceStatus) MarkSink ¶
func (s *CamelSourceStatus) MarkSink(uri string)
MarSink sets the condition that the source has a sink configured.