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=knative.dev/eventing-contrib/pkg/apis/sources +k8s:defaulter-gen=TypeMeta +groupName=sources.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=knative.dev/eventing-contrib/pkg/apis/sources +k8s:defaulter-gen=TypeMeta +groupName=sources.knative.dev
Index ¶
- Constants
- Variables
- func Resource(resource string) schema.GroupResource
- type CamelSource
- type CamelSourceList
- type CamelSourceOriginSpec
- type CamelSourceSpec
- type CamelSourceStatus
- func (in *CamelSourceStatus) DeepCopy() *CamelSourceStatus
- func (in *CamelSourceStatus) DeepCopyInto(out *CamelSourceStatus)
- func (s *CamelSourceStatus) GetCondition(t apis.ConditionType) *apis.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)
- func (s *CamelSourceStatus) MarkSinkWarnRefDeprecated(uri string)
- type Flow
Constants ¶
const ( // CamelSourceConditionReady has status True when the CamelSource is ready to send events. CamelConditionReady = apis.ConditionReady // CamelConditionSinkProvided has status True when the CamelSource has been configured with a sink target. CamelConditionSinkProvided apis.ConditionType = "SinkProvided" // CamelConditionDeployed has status True when the CamelSource has had it's deployment created. CamelConditionDeployed apis.ConditionType = "Deployed" )
Variables ¶
var ( // SchemeGroupVersion is group version used to register these objects SchemeGroupVersion = schema.GroupVersion{Group: "sources.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.
func (*CamelSource) GetGroupVersionKind ¶ added in v0.13.0
func (s *CamelSource) GetGroupVersionKind() schema.GroupVersionKind
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 CamelSourceOriginSpec ¶
type CamelSourceOriginSpec struct { // Integration is a kind of source that contains a Camel K integration Integration *camelv1.IntegrationSpec `json:"integration,omitempty"` // Flow is a kind of source that contains a single Camel YAML flow route Flow *Flow `json:"flow,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"` // Sink is a reference to an object that will resolve to a domain name to use as the sink. // +optional Sink *duckv1beta1.Destination `json:"sink,omitempty"` // CloudEventOverrides defines overrides to control the output format and // modifications of the event sent to the sink. // +optional CloudEventOverrides *duckv1.CloudEventOverrides `json:"ceOverrides,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. duckv1.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 apis.ConditionType) *apis.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.
func (*CamelSourceStatus) MarkSinkWarnRefDeprecated ¶ added in v0.10.2
func (s *CamelSourceStatus) MarkSinkWarnRefDeprecated(uri string)
MarkSinkWarnDeprecated sets the condition that the source has a sink configured and warns ref is deprecated.
type Flow ¶ added in v0.10.0
type Flow map[string]interface{}
Flow is an unstructured object representing a Camel Flow in YAML/JSON DSL
func (Flow) DeepCopyInto ¶ added in v0.10.0
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.