v1alpha1

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.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=knative.dev/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
  • func (in *CamelSource) DeepCopy() *CamelSource
  • func (in *CamelSource) DeepCopyInto(out *CamelSource)
  • func (in *CamelSource) DeepCopyObject() runtime.Object
• type CamelSourceList
  • func (in *CamelSourceList) DeepCopy() *CamelSourceList
  • func (in *CamelSourceList) DeepCopyInto(out *CamelSourceList)
  • func (in *CamelSourceList) DeepCopyObject() runtime.Object
• type CamelSourceOriginSpec
  • func (in *CamelSourceOriginSpec) DeepCopy() *CamelSourceOriginSpec
  • func (in *CamelSourceOriginSpec) DeepCopyInto(out *CamelSourceOriginSpec)
• type CamelSourceSpec
  • func (in *CamelSourceSpec) DeepCopy() *CamelSourceSpec
  • func (in *CamelSourceSpec) DeepCopyInto(out *CamelSourceSpec)
• type CamelSourceStatus
  • func (in *CamelSourceStatus) DeepCopy() *CamelSourceStatus
  • func (in *CamelSourceStatus) DeepCopyInto(out *CamelSourceStatus)
  • func (s *CamelSourceStatus) GetCondition(t duckapis.ConditionType) *duckapis.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)
• type Flow
  • func (in *Flow) DeepCopy() *Flow
  • func (in Flow) DeepCopyInto(out *Flow)

Constants

const (
	// CamelSourceConditionReady has status True when the CamelSource is ready to send events.
	CamelConditionReady = duckapis.ConditionReady

	// CamelConditionSinkProvided has status True when the CamelSource has been configured with a sink target.
	CamelConditionSinkProvided duckapis.ConditionType = "SinkProvided"

	// CamelConditionDeployed has status True when the CamelSource has had it's deployment created.
	CamelConditionDeployed duckapis.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 CamelSourceOriginSpec

type CamelSourceOriginSpec struct {
	// Integration is a kind of source that contains a Camel K integration
	Integration *v1alpha1.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 *corev1.ObjectReference `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 duckapis.ConditionType) *duckapis.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.

type Flow

type Flow map[string]interface{}

Flow is an unstructured object representing a Camel Flow in YAML/JSON DSL

func (*Flow) DeepCopy

func (in *Flow) DeepCopy() *Flow

DeepCopy copies the receiver, creating a new Flow.

func (Flow) DeepCopyInto

func (in Flow) DeepCopyInto(out *Flow)

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