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 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 GcpPubSubSource
- type GcpPubSubSourceList
- type GcpPubSubSourceSpec
- type GcpPubSubSourceStatus
- func (in *GcpPubSubSourceStatus) DeepCopy() *GcpPubSubSourceStatus
- func (in *GcpPubSubSourceStatus) DeepCopyInto(out *GcpPubSubSourceStatus)
- func (s *GcpPubSubSourceStatus) GetCondition(t duckv1alpha1.ConditionType) *duckv1alpha1.Condition
- func (s *GcpPubSubSourceStatus) InitializeConditions()
- func (s *GcpPubSubSourceStatus) IsReady() bool
- func (s *GcpPubSubSourceStatus) MarkDeployed()
- func (s *GcpPubSubSourceStatus) MarkDeploying(reason, messageFormat string, messageA ...interface{})
- func (s *GcpPubSubSourceStatus) MarkNoSink(reason, messageFormat string, messageA ...interface{})
- func (s *GcpPubSubSourceStatus) MarkNotDeployed(reason, messageFormat string, messageA ...interface{})
- func (s *GcpPubSubSourceStatus) MarkSink(uri string)
- func (s *GcpPubSubSourceStatus) MarkSubscribed()
- 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 ( // 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 ( // GcpPubSubConditionReady has status True when the GcpPubSubSource is ready to send events. GcpPubSubConditionReady = duckv1alpha1.ConditionReady // GcpPubSubConditionSinkProvided has status True when the GcpPubSubSource has been configured with a sink target. GcpPubSubConditionSinkProvided duckv1alpha1.ConditionType = "SinkProvided" // GcpPubSubConditionDeployed has status True when the GcpPubSubSource has had it's receive adapter deployment created. GcpPubSubConditionDeployed duckv1alpha1.ConditionType = "Deployed" // GcpPubSubConditionSubscribed has status True when a GCP PubSub Subscription has been created pointing at the created receive adapter deployment. GcpPubSubConditionSubscribed duckv1alpha1.ConditionType = "Subscribed" )
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 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 GcpPubSubSource ¶
type GcpPubSubSource struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec GcpPubSubSourceSpec `json:"spec,omitempty"` Status GcpPubSubSourceStatus `json:"status,omitempty"` }
GcpPubSubSource is the Schema for the gcppubsubsources API. +k8s:openapi-gen=true +kubebuilder:categories=all,knative,eventing,sources
func (*GcpPubSubSource) CheckImmutableFields ¶
func (current *GcpPubSubSource) CheckImmutableFields(og apis.Immutable) *apis.FieldError
func (*GcpPubSubSource) DeepCopy ¶
func (in *GcpPubSubSource) DeepCopy() *GcpPubSubSource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GcpPubSubSource.
func (*GcpPubSubSource) DeepCopyInto ¶
func (in *GcpPubSubSource) DeepCopyInto(out *GcpPubSubSource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*GcpPubSubSource) DeepCopyObject ¶
func (in *GcpPubSubSource) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type GcpPubSubSourceList ¶
type GcpPubSubSourceList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` Items []GcpPubSubSource `json:"items"` }
GcpPubSubSourceList contains a list of GcpPubSubSources.
func (*GcpPubSubSourceList) DeepCopy ¶
func (in *GcpPubSubSourceList) DeepCopy() *GcpPubSubSourceList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GcpPubSubSourceList.
func (*GcpPubSubSourceList) DeepCopyInto ¶
func (in *GcpPubSubSourceList) DeepCopyInto(out *GcpPubSubSourceList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*GcpPubSubSourceList) DeepCopyObject ¶
func (in *GcpPubSubSourceList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type GcpPubSubSourceSpec ¶
type GcpPubSubSourceSpec struct { // GcpCredsSecret is the credential to use to poll the GCP PubSub Subscription. It is not used // to create or delete the Subscription, only to poll it. The value of the secret entry must be // a service account key in the JSON format (see // https://cloud.google.com/iam/docs/creating-managing-service-account-keys). GcpCredsSecret corev1.SecretKeySelector `json:"gcpCredsSecret,omitempty"` // GoogleCloudProject is the ID of the Google Cloud Project that the PubSub Topic exists in. GoogleCloudProject string `json:"googleCloudProject,omitempty"` // Topic is the ID of the GCP PubSub Topic to Subscribe to. It must be in the form of the // unique identifier within the project, not the entire name. E.g. it must be 'laconia', not // 'projects/my-gcp-project/topics/laconia'. Topic string `json:"topic,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"` }
GcpPubSubSourceSpec defines the desired state of the GcpPubSubSource.
func (*GcpPubSubSourceSpec) DeepCopy ¶
func (in *GcpPubSubSourceSpec) DeepCopy() *GcpPubSubSourceSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GcpPubSubSourceSpec.
func (*GcpPubSubSourceSpec) DeepCopyInto ¶
func (in *GcpPubSubSourceSpec) DeepCopyInto(out *GcpPubSubSourceSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type GcpPubSubSourceStatus ¶
type GcpPubSubSourceStatus 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 GcpPubSubSource. // +optional SinkURI string `json:"sinkUri,omitempty"` }
GcpPubSubSourceStatus defines the observed state of GcpPubSubSource.
func (*GcpPubSubSourceStatus) DeepCopy ¶
func (in *GcpPubSubSourceStatus) DeepCopy() *GcpPubSubSourceStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GcpPubSubSourceStatus.
func (*GcpPubSubSourceStatus) DeepCopyInto ¶
func (in *GcpPubSubSourceStatus) DeepCopyInto(out *GcpPubSubSourceStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*GcpPubSubSourceStatus) GetCondition ¶
func (s *GcpPubSubSourceStatus) GetCondition(t duckv1alpha1.ConditionType) *duckv1alpha1.Condition
GetCondition returns the condition currently associated with the given type, or nil.
func (*GcpPubSubSourceStatus) InitializeConditions ¶
func (s *GcpPubSubSourceStatus) InitializeConditions()
InitializeConditions sets relevant unset conditions to Unknown state.
func (*GcpPubSubSourceStatus) IsReady ¶
func (s *GcpPubSubSourceStatus) IsReady() bool
IsReady returns true if the resource is ready overall.
func (*GcpPubSubSourceStatus) MarkDeployed ¶
func (s *GcpPubSubSourceStatus) MarkDeployed()
MarkDeployed sets the condition that the source has been deployed.
func (*GcpPubSubSourceStatus) MarkDeploying ¶
func (s *GcpPubSubSourceStatus) MarkDeploying(reason, messageFormat string, messageA ...interface{})
MarkDeploying sets the condition that the source is deploying.
func (*GcpPubSubSourceStatus) MarkNoSink ¶
func (s *GcpPubSubSourceStatus) MarkNoSink(reason, messageFormat string, messageA ...interface{})
MarkNoSink sets the condition that the source does not have a sink configured.
func (*GcpPubSubSourceStatus) MarkNotDeployed ¶
func (s *GcpPubSubSourceStatus) MarkNotDeployed(reason, messageFormat string, messageA ...interface{})
MarkNotDeployed sets the condition that the source has not been deployed.
func (*GcpPubSubSourceStatus) MarkSink ¶
func (s *GcpPubSubSourceStatus) MarkSink(uri string)
MarkSink sets the condition that the source has a sink configured.
func (*GcpPubSubSourceStatus) MarkSubscribed ¶
func (s *GcpPubSubSourceStatus) MarkSubscribed()
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.