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-sources/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-sources/pkg/apis/sources +k8s:defaulter-gen=TypeMeta +groupName=sources.eventing.knative.dev
Index ¶
- Constants
- Variables
- func Resource(resource string) schema.GroupResource
- type AwsSqsSource
- type AwsSqsSourceList
- type AwsSqsSourceSpec
- type AwsSqsSourceStatus
- func (in *AwsSqsSourceStatus) DeepCopy() *AwsSqsSourceStatus
- func (in *AwsSqsSourceStatus) DeepCopyInto(out *AwsSqsSourceStatus)
- func (s *AwsSqsSourceStatus) GetCondition(t duckv1alpha1.ConditionType) *duckv1alpha1.Condition
- func (s *AwsSqsSourceStatus) InitializeConditions()
- func (s *AwsSqsSourceStatus) IsReady() bool
- func (s *AwsSqsSourceStatus) MarkDeployed()
- func (s *AwsSqsSourceStatus) MarkDeploying(reason, messageFormat string, messageA ...interface{})
- func (s *AwsSqsSourceStatus) MarkNoSink(reason, messageFormat string, messageA ...interface{})
- func (s *AwsSqsSourceStatus) MarkNotDeployed(reason, messageFormat string, messageA ...interface{})
- func (s *AwsSqsSourceStatus) MarkSink(uri string)
- type ContainerSource
- type ContainerSourceList
- type ContainerSourceSpec
- type ContainerSourceStatus
- func (in *ContainerSourceStatus) DeepCopy() *ContainerSourceStatus
- func (in *ContainerSourceStatus) DeepCopyInto(out *ContainerSourceStatus)
- func (s *ContainerSourceStatus) GetCondition(t duckv1alpha1.ConditionType) *duckv1alpha1.Condition
- func (s *ContainerSourceStatus) InitializeConditions()
- func (s *ContainerSourceStatus) IsReady() bool
- func (s *ContainerSourceStatus) MarkDeployed()
- func (s *ContainerSourceStatus) MarkDeploying(reason, messageFormat string, messageA ...interface{})
- func (s *ContainerSourceStatus) MarkNoSink(reason, messageFormat string, messageA ...interface{})
- func (s *ContainerSourceStatus) MarkNotDeployed(reason, messageFormat string, messageA ...interface{})
- func (s *ContainerSourceStatus) MarkSink(uri string)
- type CronJobSource
- type CronJobSourceList
- type CronJobSourceSpec
- type CronJobSourceStatus
- func (in *CronJobSourceStatus) DeepCopy() *CronJobSourceStatus
- func (in *CronJobSourceStatus) DeepCopyInto(out *CronJobSourceStatus)
- func (s *CronJobSourceStatus) GetCondition(t duckv1alpha1.ConditionType) *duckv1alpha1.Condition
- func (s *CronJobSourceStatus) InitializeConditions()
- func (s *CronJobSourceStatus) IsReady() bool
- func (s *CronJobSourceStatus) MarkDeployed()
- func (s *CronJobSourceStatus) MarkDeploying(reason, messageFormat string, messageA ...interface{})
- func (s *CronJobSourceStatus) MarkInvalidSchedule(reason, messageFormat string, messageA ...interface{})
- func (s *CronJobSourceStatus) MarkNoSink(reason, messageFormat string, messageA ...interface{})
- func (s *CronJobSourceStatus) MarkNotDeployed(reason, messageFormat string, messageA ...interface{})
- func (s *CronJobSourceStatus) MarkSchedule()
- func (s *CronJobSourceStatus) MarkSink(uri string)
- type GitHubSource
- type GitHubSourceList
- type GitHubSourceSpec
- type GitHubSourceStatus
- func (in *GitHubSourceStatus) DeepCopy() *GitHubSourceStatus
- func (in *GitHubSourceStatus) DeepCopyInto(out *GitHubSourceStatus)
- func (s *GitHubSourceStatus) GetCondition(t duckv1alpha1.ConditionType) *duckv1alpha1.Condition
- func (s *GitHubSourceStatus) InitializeConditions()
- func (s *GitHubSourceStatus) IsReady() bool
- func (s *GitHubSourceStatus) MarkNoSecrets(reason, messageFormat string, messageA ...interface{})
- func (s *GitHubSourceStatus) MarkNoSink(reason, messageFormat string, messageA ...interface{})
- func (s *GitHubSourceStatus) MarkSecrets()
- func (s *GitHubSourceStatus) MarkSink(uri string)
- type KubernetesEventSource
- type KubernetesEventSourceList
- type KubernetesEventSourceSpec
- type KubernetesEventSourceStatus
- func (in *KubernetesEventSourceStatus) DeepCopy() *KubernetesEventSourceStatus
- func (in *KubernetesEventSourceStatus) DeepCopyInto(out *KubernetesEventSourceStatus)
- func (s *KubernetesEventSourceStatus) GetCondition(t duckv1alpha1.ConditionType) *duckv1alpha1.Condition
- func (s *KubernetesEventSourceStatus) InitializeConditions()
- func (s *KubernetesEventSourceStatus) IsReady() bool
- func (s *KubernetesEventSourceStatus) MarkReady()
- func (s *KubernetesEventSourceStatus) MarkUnready(reason, messageFormat string, messageA ...interface{})
- type SecretValueFromSource
Constants ¶
const ( // AwsSqsSourceConditionReady has status True when the source is // ready to send events. AwsSqsSourceConditionReady = duckv1alpha1.ConditionReady // AwsSqsSourceConditionSinkProvided has status True when the // AwsSqsSource has been configured with a sink target. AwsSqsSourceConditionSinkProvided duckv1alpha1.ConditionType = "SinkProvided" // AwsSqsSourceConditionDeployed has status True when the // AwsSqsSource has had it's receive adapter deployment created. AwsSqsSourceConditionDeployed duckv1alpha1.ConditionType = "Deployed" )
const ( // ContainerSourceConditionReady has status True when the ContainerSource is ready to send events. ContainerConditionReady = duckv1alpha1.ConditionReady // ContainerConditionSinkProvided has status True when the ContainerSource has been configured with a sink target. ContainerConditionSinkProvided duckv1alpha1.ConditionType = "SinkProvided" // ContainerConditionDeployed has status True when the ContainerSource has had it's deployment created. ContainerConditionDeployed duckv1alpha1.ConditionType = "Deployed" )
const ( // CronJobConditionReady has status True when the CronJobSource is ready to send events. CronJobConditionReady = duckv1alpha1.ConditionReady // CronJobConditionValidSchedule has status True when the CronJobSource has been configured with a valid schedule. CronJobConditionValidSchedule duckv1alpha1.ConditionType = "ValidSchedule" // CronJobConditionSinkProvided has status True when the CronJobSource has been configured with a sink target. CronJobConditionSinkProvided duckv1alpha1.ConditionType = "SinkProvided" // CronJobConditionDeployed has status True when the CronJobSource has had it's receive adapter deployment created. CronJobConditionDeployed duckv1alpha1.ConditionType = "Deployed" )
const ( // GitHubSourceConditionReady has status True when the // GitHubSource is ready to send events. GitHubSourceConditionReady = duckv1alpha1.ConditionReady // GitHubSourceConditionSecretsProvided has status True when the // GitHubSource has valid secret references GitHubSourceConditionSecretsProvided duckv1alpha1.ConditionType = "SecretsProvided" // GitHubSourceConditionSinkProvided has status True when the // GitHubSource has been configured with a sink target. GitHubSourceConditionSinkProvided duckv1alpha1.ConditionType = "SinkProvided" )
const ( // GitHubSourceEventPrefix is what all GitHub event types get // prefixed with when converting to CloudEvent EventType GitHubSourceEventPrefix = "dev.knative.source.github" )
const ( // KubernetesEventSourceConditionReady has status True when the // source is ready to send events. KubernetesEventSourceConditionReady = duckv1alpha1.ConditionReady )
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 AwsSqsSource ¶ added in v0.3.0
type AwsSqsSource struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
Spec AwsSqsSourceSpec `json:"spec,omitempty"`
Status AwsSqsSourceStatus `json:"status,omitempty"`
}
AwsSqsSource is the Schema for the AWS SQS API +k8s:openapi-gen=true +kubebuilder:categories=all,knative,eventing,sources
func (*AwsSqsSource) DeepCopy ¶ added in v0.3.0
func (in *AwsSqsSource) DeepCopy() *AwsSqsSource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AwsSqsSource.
func (*AwsSqsSource) DeepCopyInto ¶ added in v0.3.0
func (in *AwsSqsSource) DeepCopyInto(out *AwsSqsSource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*AwsSqsSource) DeepCopyObject ¶ added in v0.3.0
func (in *AwsSqsSource) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type AwsSqsSourceList ¶ added in v0.3.0
type AwsSqsSourceList struct {
metav1.TypeMeta `json:",inline"`
metav1.ListMeta `json:"metadata,omitempty"`
Items []AwsSqsSource `json:"items"`
}
AwsSqsSourceList contains a list of AwsSqsSource
func (*AwsSqsSourceList) DeepCopy ¶ added in v0.3.0
func (in *AwsSqsSourceList) DeepCopy() *AwsSqsSourceList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AwsSqsSourceList.
func (*AwsSqsSourceList) DeepCopyInto ¶ added in v0.3.0
func (in *AwsSqsSourceList) DeepCopyInto(out *AwsSqsSourceList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*AwsSqsSourceList) DeepCopyObject ¶ added in v0.3.0
func (in *AwsSqsSourceList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type AwsSqsSourceSpec ¶ added in v0.3.0
type AwsSqsSourceSpec struct {
// QueueURL of the SQS queue that we will poll from.
QueueURL string `json:"queueUrl"`
// AwsCredsSecret is the credential to use to poll the AWS SQS
AwsCredsSecret corev1.SecretKeySelector `json:"awsCredsSecret,omitempty"`
// Sink is a reference to an object that will resolve to a domain name to
// use as the sink. This is where events will be received.
// +optional
Sink *corev1.ObjectReference `json:"sink,omitempty"`
// ServiceAccoutName is the name of the ServiceAccount that will be used to
// run the Receive Adapter Deployment.
ServiceAccountName string `json:"serviceAccountName,omitempty"`
}
AwsSqsSourceSpec defines the desired state of the source.
func (*AwsSqsSourceSpec) DeepCopy ¶ added in v0.3.0
func (in *AwsSqsSourceSpec) DeepCopy() *AwsSqsSourceSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AwsSqsSourceSpec.
func (*AwsSqsSourceSpec) DeepCopyInto ¶ added in v0.3.0
func (in *AwsSqsSourceSpec) DeepCopyInto(out *AwsSqsSourceSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type AwsSqsSourceStatus ¶ added in v0.3.0
type AwsSqsSourceStatus struct {
// Conditions holds the state of a source at a point in time.
// +optional
// +patchMergeKey=type
// +patchStrategy=merge
Conditions duckv1alpha1.Conditions `json:"conditions,omitempty" patchStrategy:"merge" patchMergeKey:"type"`
// SinkURI is the current active sink URI that has been configured for the source.
// +optional
SinkURI string `json:"sinkUri,omitempty"`
}
AwsSqsSourceStatus defines the observed state of the source.
func (*AwsSqsSourceStatus) DeepCopy ¶ added in v0.3.0
func (in *AwsSqsSourceStatus) DeepCopy() *AwsSqsSourceStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AwsSqsSourceStatus.
func (*AwsSqsSourceStatus) DeepCopyInto ¶ added in v0.3.0
func (in *AwsSqsSourceStatus) DeepCopyInto(out *AwsSqsSourceStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*AwsSqsSourceStatus) GetCondition ¶ added in v0.3.0
func (s *AwsSqsSourceStatus) GetCondition(t duckv1alpha1.ConditionType) *duckv1alpha1.Condition
GetCondition returns the condition currently associated with the given type, or nil.
func (*AwsSqsSourceStatus) InitializeConditions ¶ added in v0.3.0
func (s *AwsSqsSourceStatus) InitializeConditions()
InitializeConditions sets relevant unset conditions to Unknown state.
func (*AwsSqsSourceStatus) IsReady ¶ added in v0.3.0
func (s *AwsSqsSourceStatus) IsReady() bool
IsReady returns true if the resource is ready overall.
func (*AwsSqsSourceStatus) MarkDeployed ¶ added in v0.3.0
func (s *AwsSqsSourceStatus) MarkDeployed()
MarkDeployed sets the condition that the source has been deployed.
func (*AwsSqsSourceStatus) MarkDeploying ¶ added in v0.3.0
func (s *AwsSqsSourceStatus) MarkDeploying(reason, messageFormat string, messageA ...interface{})
MarkDeploying sets the condition that the source is deploying.
func (*AwsSqsSourceStatus) MarkNoSink ¶ added in v0.3.0
func (s *AwsSqsSourceStatus) MarkNoSink(reason, messageFormat string, messageA ...interface{})
MarkNoSink sets the condition that the source does not have a sink configured.
func (*AwsSqsSourceStatus) MarkNotDeployed ¶ added in v0.3.0
func (s *AwsSqsSourceStatus) MarkNotDeployed(reason, messageFormat string, messageA ...interface{})
MarkNotDeployed sets the condition that the source has not been deployed.
func (*AwsSqsSourceStatus) MarkSink ¶ added in v0.3.0
func (s *AwsSqsSourceStatus) MarkSink(uri string)
MarkSink sets the condition that the source has a sink configured.
type ContainerSource ¶
type ContainerSource struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
Spec ContainerSourceSpec `json:"spec,omitempty"`
Status ContainerSourceStatus `json:"status,omitempty"`
}
ContainerSource is the Schema for the containersources API +k8s:openapi-gen=true +kubebuilder:categories=all,knative,eventing,sources
func (*ContainerSource) DeepCopy ¶
func (in *ContainerSource) DeepCopy() *ContainerSource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ContainerSource.
func (*ContainerSource) DeepCopyInto ¶
func (in *ContainerSource) DeepCopyInto(out *ContainerSource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ContainerSource) DeepCopyObject ¶
func (in *ContainerSource) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type ContainerSourceList ¶
type ContainerSourceList struct {
metav1.TypeMeta `json:",inline"`
metav1.ListMeta `json:"metadata,omitempty"`
Items []ContainerSource `json:"items"`
}
ContainerSourceList contains a list of ContainerSource
func (*ContainerSourceList) DeepCopy ¶
func (in *ContainerSourceList) DeepCopy() *ContainerSourceList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ContainerSourceList.
func (*ContainerSourceList) DeepCopyInto ¶
func (in *ContainerSourceList) DeepCopyInto(out *ContainerSourceList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ContainerSourceList) DeepCopyObject ¶
func (in *ContainerSourceList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type ContainerSourceSpec ¶
type ContainerSourceSpec struct {
// Image is the image to run inside of the container.
// +kubebuilder:validation:MinLength=1
Image string `json:"image,omitempty"`
// Args are passed to the ContainerSpec as they are.
Args []string `json:"args,omitempty"`
// Env is the list of environment variables to set in the container.
// Cannot be updated.
// +optional
// +patchMergeKey=name
// +patchStrategy=merge
Env []corev1.EnvVar `json:"env,omitempty" patchStrategy:"merge" patchMergeKey:"name"`
// ServiceAccountName is the name of the ServiceAccount to use to run this
// source.
// +optional
ServiceAccountName string `json:"serviceAccountName,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"`
}
ContainerSourceSpec defines the desired state of ContainerSource
func (*ContainerSourceSpec) DeepCopy ¶
func (in *ContainerSourceSpec) DeepCopy() *ContainerSourceSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ContainerSourceSpec.
func (*ContainerSourceSpec) DeepCopyInto ¶
func (in *ContainerSourceSpec) DeepCopyInto(out *ContainerSourceSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ContainerSourceStatus ¶
type ContainerSourceStatus struct {
// Conditions holds the state of a source at a point in time.
// +optional
// +patchMergeKey=type
// +patchStrategy=merge
Conditions duckv1alpha1.Conditions `json:"conditions,omitempty" patchStrategy:"merge" patchMergeKey:"type"`
// SinkURI is the current active sink URI that has been configured for the ContainerSource.
// +optional
SinkURI string `json:"sinkUri,omitempty"`
}
ContainerSourceStatus defines the observed state of ContainerSource
func (*ContainerSourceStatus) DeepCopy ¶
func (in *ContainerSourceStatus) DeepCopy() *ContainerSourceStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ContainerSourceStatus.
func (*ContainerSourceStatus) DeepCopyInto ¶
func (in *ContainerSourceStatus) DeepCopyInto(out *ContainerSourceStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ContainerSourceStatus) GetCondition ¶
func (s *ContainerSourceStatus) GetCondition(t duckv1alpha1.ConditionType) *duckv1alpha1.Condition
GetCondition returns the condition currently associated with the given type, or nil.
func (*ContainerSourceStatus) InitializeConditions ¶
func (s *ContainerSourceStatus) InitializeConditions()
InitializeConditions sets relevant unset conditions to Unknown state.
func (*ContainerSourceStatus) IsReady ¶
func (s *ContainerSourceStatus) IsReady() bool
IsReady returns true if the resource is ready overall.
func (*ContainerSourceStatus) MarkDeployed ¶
func (s *ContainerSourceStatus) MarkDeployed()
MarkDeployed sets the condition that the source has been deployed.
func (*ContainerSourceStatus) MarkDeploying ¶
func (s *ContainerSourceStatus) MarkDeploying(reason, messageFormat string, messageA ...interface{})
MarkDeploying sets the condition that the source is deploying.
func (*ContainerSourceStatus) MarkNoSink ¶
func (s *ContainerSourceStatus) MarkNoSink(reason, messageFormat string, messageA ...interface{})
MarkNoSink sets the condition that the source does not have a sink configured.
func (*ContainerSourceStatus) MarkNotDeployed ¶
func (s *ContainerSourceStatus) MarkNotDeployed(reason, messageFormat string, messageA ...interface{})
MarkNotDeployed sets the condition that the source has not been deployed.
func (*ContainerSourceStatus) MarkSink ¶
func (s *ContainerSourceStatus) MarkSink(uri string)
MarSink sets the condition that the source has a sink configured.
type CronJobSource ¶ added in v0.3.0
type CronJobSource struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
Spec CronJobSourceSpec `json:"spec,omitempty"`
Status CronJobSourceStatus `json:"status,omitempty"`
}
CronJobSource is the Schema for the cronjobsources API. +k8s:openapi-gen=true +kubebuilder:categories=all,knative,eventing,sources
func (*CronJobSource) DeepCopy ¶ added in v0.3.0
func (in *CronJobSource) DeepCopy() *CronJobSource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CronJobSource.
func (*CronJobSource) DeepCopyInto ¶ added in v0.3.0
func (in *CronJobSource) DeepCopyInto(out *CronJobSource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*CronJobSource) DeepCopyObject ¶ added in v0.3.0
func (in *CronJobSource) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type CronJobSourceList ¶ added in v0.3.0
type CronJobSourceList struct {
metav1.TypeMeta `json:",inline"`
metav1.ListMeta `json:"metadata,omitempty"`
Items []CronJobSource `json:"items"`
}
CronJobSourceList contains a list of CronJobSources.
func (*CronJobSourceList) DeepCopy ¶ added in v0.3.0
func (in *CronJobSourceList) DeepCopy() *CronJobSourceList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CronJobSourceList.
func (*CronJobSourceList) DeepCopyInto ¶ added in v0.3.0
func (in *CronJobSourceList) DeepCopyInto(out *CronJobSourceList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*CronJobSourceList) DeepCopyObject ¶ added in v0.3.0
func (in *CronJobSourceList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type CronJobSourceSpec ¶ added in v0.3.0
type CronJobSourceSpec struct {
// Schedule is the cronjob schedule.
// +required
Schedule string `json:"schedule"`
// Data is the data posted to the target function.
Data string `json:"data,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"`
// ServiceAccoutName is the name of the ServiceAccount that will be used to run the Receive
// Adapter Deployment.
ServiceAccountName string `json:"serviceAccountName,omitempty"`
}
CronJobSourceSpec defines the desired state of the CronJobSource.
func (*CronJobSourceSpec) DeepCopy ¶ added in v0.3.0
func (in *CronJobSourceSpec) DeepCopy() *CronJobSourceSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CronJobSourceSpec.
func (*CronJobSourceSpec) DeepCopyInto ¶ added in v0.3.0
func (in *CronJobSourceSpec) DeepCopyInto(out *CronJobSourceSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type CronJobSourceStatus ¶ added in v0.3.0
type CronJobSourceStatus struct {
// Conditions holds the state of a source at a point in time.
// +optional
// +patchMergeKey=type
// +patchStrategy=merge
Conditions duckv1alpha1.Conditions `json:"conditions,omitempty" patchStrategy:"merge" patchMergeKey:"type"`
// SinkURI is the current active sink URI that has been configured for the CronJobSource.
// +optional
SinkURI string `json:"sinkUri,omitempty"`
}
CronJobSourceStatus defines the observed state of CronJobSource.
func (*CronJobSourceStatus) DeepCopy ¶ added in v0.3.0
func (in *CronJobSourceStatus) DeepCopy() *CronJobSourceStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CronJobSourceStatus.
func (*CronJobSourceStatus) DeepCopyInto ¶ added in v0.3.0
func (in *CronJobSourceStatus) DeepCopyInto(out *CronJobSourceStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*CronJobSourceStatus) GetCondition ¶ added in v0.3.0
func (s *CronJobSourceStatus) GetCondition(t duckv1alpha1.ConditionType) *duckv1alpha1.Condition
GetCondition returns the condition currently associated with the given type, or nil.
func (*CronJobSourceStatus) InitializeConditions ¶ added in v0.3.0
func (s *CronJobSourceStatus) InitializeConditions()
InitializeConditions sets relevant unset conditions to Unknown state.
func (*CronJobSourceStatus) IsReady ¶ added in v0.3.0
func (s *CronJobSourceStatus) IsReady() bool
IsReady returns true if the resource is ready overall.
func (*CronJobSourceStatus) MarkDeployed ¶ added in v0.3.0
func (s *CronJobSourceStatus) MarkDeployed()
MarkDeployed sets the condition that the source has been deployed.
func (*CronJobSourceStatus) MarkDeploying ¶ added in v0.3.0
func (s *CronJobSourceStatus) MarkDeploying(reason, messageFormat string, messageA ...interface{})
MarkDeploying sets the condition that the source is deploying.
func (*CronJobSourceStatus) MarkInvalidSchedule ¶ added in v0.3.0
func (s *CronJobSourceStatus) MarkInvalidSchedule(reason, messageFormat string, messageA ...interface{})
MarkInvalidSchedule sets the condition that the source does not have a valid schedule configured.
func (*CronJobSourceStatus) MarkNoSink ¶ added in v0.3.0
func (s *CronJobSourceStatus) MarkNoSink(reason, messageFormat string, messageA ...interface{})
MarkNoSink sets the condition that the source does not have a sink configured.
func (*CronJobSourceStatus) MarkNotDeployed ¶ added in v0.3.0
func (s *CronJobSourceStatus) MarkNotDeployed(reason, messageFormat string, messageA ...interface{})
MarkNotDeployed sets the condition that the source has not been deployed.
func (*CronJobSourceStatus) MarkSchedule ¶ added in v0.3.0
func (s *CronJobSourceStatus) MarkSchedule()
MarkSchedule sets the condition that the source has a valid schedule configured.
func (*CronJobSourceStatus) MarkSink ¶ added in v0.3.0
func (s *CronJobSourceStatus) MarkSink(uri string)
MarkSink sets the condition that the source has a sink configured.
type GitHubSource ¶
type GitHubSource struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
Spec GitHubSourceSpec `json:"spec,omitempty"`
Status GitHubSourceStatus `json:"status,omitempty"`
}
GitHubSource is the Schema for the githubsources API +k8s:openapi-gen=true +kubebuilder:categories=all,knative,eventing,sources
func (*GitHubSource) DeepCopy ¶
func (in *GitHubSource) DeepCopy() *GitHubSource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GitHubSource.
func (*GitHubSource) DeepCopyInto ¶
func (in *GitHubSource) DeepCopyInto(out *GitHubSource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*GitHubSource) DeepCopyObject ¶
func (in *GitHubSource) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type GitHubSourceList ¶
type GitHubSourceList struct {
metav1.TypeMeta `json:",inline"`
metav1.ListMeta `json:"metadata,omitempty"`
Items []GitHubSource `json:"items"`
}
GitHubSourceList contains a list of GitHubSource
func (*GitHubSourceList) DeepCopy ¶
func (in *GitHubSourceList) DeepCopy() *GitHubSourceList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GitHubSourceList.
func (*GitHubSourceList) DeepCopyInto ¶
func (in *GitHubSourceList) DeepCopyInto(out *GitHubSourceList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*GitHubSourceList) DeepCopyObject ¶
func (in *GitHubSourceList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type GitHubSourceSpec ¶
type GitHubSourceSpec struct {
// ServiceAccountName holds the name of the Kubernetes service account
// as which the underlying K8s resources should be run. If unspecified
// this will default to the "default" service account for the namespace
// in which the GitHubSource exists.
// +optional
ServiceAccountName string `json:"serviceAccountName,omitempty"`
// OwnerAndRepository is the GitHub owner/org and repository to
// receive events from. The repository may be left off to receive
// events from an entire organization.
// Examples:
// myuser/project
// myorganization
// +kubebuilder:validation:MinLength=1
OwnerAndRepository string `json:"ownerAndRepository"`
// EventType is the type of event to receive from GitHub. These
// correspond to the "Webhook event name" values listed at
// https://developer.github.com/v3/activity/events/types/ - ie
// "pull_request"
// +kubebuilder:validation:MinItems=1
// +kubebuilder:validation:Enum=commit_comment,create,delete,deployment,deployment_status,fork,gollum,installation,integration_installation,issue_comment,issues,label,member,membership,milestone,organization,org_block,page_build,ping,project_card,project_column,project,public,pull_request,pull_request_review,pull_request_review_comment,push,release,repository,status,team,team_add,watch
EventTypes []string `json:"eventTypes"`
// AccessToken is the Kubernetes secret containing the GitHub
// access token
AccessToken SecretValueFromSource `json:"accessToken"`
// SecretToken is the Kubernetes secret containing the GitHub
// secret token
SecretToken SecretValueFromSource `json:"secretToken"`
// 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"`
}
GitHubSourceSpec defines the desired state of GitHubSource +kubebuilder:categories=all,knative,eventing,sources
func (*GitHubSourceSpec) DeepCopy ¶
func (in *GitHubSourceSpec) DeepCopy() *GitHubSourceSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GitHubSourceSpec.
func (*GitHubSourceSpec) DeepCopyInto ¶
func (in *GitHubSourceSpec) DeepCopyInto(out *GitHubSourceSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type GitHubSourceStatus ¶
type GitHubSourceStatus struct {
// Conditions holds the state of a source at a point in time.
// +optional
// +patchMergeKey=type
// +patchStrategy=merge
Conditions duckv1alpha1.Conditions `json:"conditions,omitempty" patchStrategy:"merge" patchMergeKey:"type"`
// WebhookIDKey is the ID of the webhook registered with GitHub
WebhookIDKey string `json:"webhookIDKey,omitempty"`
// SinkURI is the current active sink URI that has been configured
// for the GitHubSource.
// +optional
SinkURI string `json:"sinkUri,omitempty"`
}
GitHubSourceStatus defines the observed state of GitHubSource
func (*GitHubSourceStatus) DeepCopy ¶
func (in *GitHubSourceStatus) DeepCopy() *GitHubSourceStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GitHubSourceStatus.
func (*GitHubSourceStatus) DeepCopyInto ¶
func (in *GitHubSourceStatus) DeepCopyInto(out *GitHubSourceStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*GitHubSourceStatus) GetCondition ¶
func (s *GitHubSourceStatus) GetCondition(t duckv1alpha1.ConditionType) *duckv1alpha1.Condition
GetCondition returns the condition currently associated with the given type, or nil.
func (*GitHubSourceStatus) InitializeConditions ¶
func (s *GitHubSourceStatus) InitializeConditions()
InitializeConditions sets relevant unset conditions to Unknown state.
func (*GitHubSourceStatus) IsReady ¶
func (s *GitHubSourceStatus) IsReady() bool
IsReady returns true if the resource is ready overall.
func (*GitHubSourceStatus) MarkNoSecrets ¶
func (s *GitHubSourceStatus) MarkNoSecrets(reason, messageFormat string, messageA ...interface{})
MarkNoSecrets sets the condition that the source does not have a valid spec
func (*GitHubSourceStatus) MarkNoSink ¶
func (s *GitHubSourceStatus) MarkNoSink(reason, messageFormat string, messageA ...interface{})
MarkNoSink sets the condition that the source does not have a sink configured.
func (*GitHubSourceStatus) MarkSecrets ¶
func (s *GitHubSourceStatus) MarkSecrets()
MarkSecrets sets the condition that the source has a valid spec
func (*GitHubSourceStatus) MarkSink ¶
func (s *GitHubSourceStatus) MarkSink(uri string)
MarkSink sets the condition that the source has a sink configured.
type KubernetesEventSource ¶
type KubernetesEventSource struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
Spec KubernetesEventSourceSpec `json:"spec,omitempty"`
Status KubernetesEventSourceStatus `json:"status,omitempty"`
}
KubernetesEventSource is the Schema for the kuberneteseventsources API +k8s:openapi-gen=true +kubebuilder:categories=all,knative,eventing,sources
func (*KubernetesEventSource) DeepCopy ¶
func (in *KubernetesEventSource) DeepCopy() *KubernetesEventSource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KubernetesEventSource.
func (*KubernetesEventSource) DeepCopyInto ¶
func (in *KubernetesEventSource) DeepCopyInto(out *KubernetesEventSource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*KubernetesEventSource) DeepCopyObject ¶
func (in *KubernetesEventSource) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type KubernetesEventSourceList ¶
type KubernetesEventSourceList struct {
metav1.TypeMeta `json:",inline"`
metav1.ListMeta `json:"metadata,omitempty"`
Items []KubernetesEventSource `json:"items"`
}
KubernetesEventSourceList contains a list of KubernetesEventSource
func (*KubernetesEventSourceList) DeepCopy ¶
func (in *KubernetesEventSourceList) DeepCopy() *KubernetesEventSourceList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KubernetesEventSourceList.
func (*KubernetesEventSourceList) DeepCopyInto ¶
func (in *KubernetesEventSourceList) DeepCopyInto(out *KubernetesEventSourceList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*KubernetesEventSourceList) DeepCopyObject ¶
func (in *KubernetesEventSourceList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type KubernetesEventSourceSpec ¶
type KubernetesEventSourceSpec struct {
// Namespace that we watch kubernetes events in.
Namespace string `json:"namespace"`
// ServiceAccountName is the name of the ServiceAccount to use to run this
// source.
// +optional
ServiceAccountName string `json:"serviceAccountName,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"`
}
KubernetesEventSourceSpec defines the desired state of the source.
func (*KubernetesEventSourceSpec) DeepCopy ¶
func (in *KubernetesEventSourceSpec) DeepCopy() *KubernetesEventSourceSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KubernetesEventSourceSpec.
func (*KubernetesEventSourceSpec) DeepCopyInto ¶
func (in *KubernetesEventSourceSpec) DeepCopyInto(out *KubernetesEventSourceSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type KubernetesEventSourceStatus ¶
type KubernetesEventSourceStatus struct {
// Conditions holds the state of a source at a point in time.
// +optional
// +patchMergeKey=type
// +patchStrategy=merge
Conditions duckv1alpha1.Conditions `json:"conditions,omitempty" patchStrategy:"merge" patchMergeKey:"type"`
// SinkURI is the current active sink URI that has been configured for the source.
// +optional
SinkURI string `json:"sinkUri,omitempty"`
}
KubernetesEventSourceStatus defines the observed state of the source.
func (*KubernetesEventSourceStatus) DeepCopy ¶
func (in *KubernetesEventSourceStatus) DeepCopy() *KubernetesEventSourceStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KubernetesEventSourceStatus.
func (*KubernetesEventSourceStatus) DeepCopyInto ¶
func (in *KubernetesEventSourceStatus) DeepCopyInto(out *KubernetesEventSourceStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*KubernetesEventSourceStatus) GetCondition ¶
func (s *KubernetesEventSourceStatus) GetCondition(t duckv1alpha1.ConditionType) *duckv1alpha1.Condition
GetCondition returns the condition currently associated with the given type, or nil.
func (*KubernetesEventSourceStatus) InitializeConditions ¶
func (s *KubernetesEventSourceStatus) InitializeConditions()
InitializeConditions sets relevant unset conditions to Unknown state.
func (*KubernetesEventSourceStatus) IsReady ¶
func (s *KubernetesEventSourceStatus) IsReady() bool
IsReady returns true if the resource is ready overall.
func (*KubernetesEventSourceStatus) MarkReady ¶
func (s *KubernetesEventSourceStatus) MarkReady()
MarkReady sets the condition that the ContainerSource owned by the source has Ready status True.
func (*KubernetesEventSourceStatus) MarkUnready ¶
func (s *KubernetesEventSourceStatus) MarkUnready(reason, messageFormat string, messageA ...interface{})
MarkUnready sets the condition that the ContainerSource owned by the source does not have Ready status True.
type SecretValueFromSource ¶
type SecretValueFromSource struct {
// The Secret key to select from.
SecretKeyRef *corev1.SecretKeySelector `json:"secretKeyRef,omitempty"`
}
SecretValueFromSource represents the source of a secret value
func (*SecretValueFromSource) DeepCopy ¶
func (in *SecretValueFromSource) DeepCopy() *SecretValueFromSource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SecretValueFromSource.
func (*SecretValueFromSource) DeepCopyInto ¶
func (in *SecretValueFromSource) DeepCopyInto(out *SecretValueFromSource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.