v1alpha1

package
v0.4.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 7, 2019 License: Apache-2.0 Imports: 7 Imported by: 0

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

View Source 
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"
)
View Source 
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"
)
View Source 
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"
)
View Source 
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"
)
View Source 
const (
	// GitHubSourceEventPrefix is what all GitHub event types get
	// prefixed with when converting to CloudEvent EventType
	GitHubSourceEventPrefix = "dev.knative.source.github"
)
View Source 
const (
	// KubernetesEventSourceConditionReady has status True when the
	// source is ready to send events.
	KubernetesEventSourceConditionReady = duckv1alpha1.ConditionReady
)

Variables

View Source 
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:subresource:status +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:subresource:status +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:subresource:status +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:subresource:status +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:subresource:status +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.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.