v1alpha1

package
v0.99.0 Latest Latest
Warning

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

 Go to latest Published: Jan 21, 2020 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Overview

Package v1alpha1 contains API Schema definitions for the sources v1alpha1 API group +k8s:deepcopy-gen=package +groupName=sources.eventing.knative.dev

Index

Constants

View Source 
const (
	// ApiServerConditionReady has status True when the ApiServerSource is ready to send events.
	ApiServerConditionReady = apis.ConditionReady

	// ApiServerConditionSinkProvided has status True when the ApiServerSource has been configured with a sink target.
	ApiServerConditionSinkProvided apis.ConditionType = "SinkProvided"

	// ApiServerConditionDeployed has status True when the ApiServerSource has had it's deployment created.
	ApiServerConditionDeployed apis.ConditionType = "Deployed"

	// ApiServerConditionSufficientPermissions has status True when the ApiServerSource has sufficient permissions to access resources.
	ApiServerConditionSufficientPermissions apis.ConditionType = "SufficientPermissions"

	// ApiServerConditionEventTypeProvided has status True when the ApiServerSource has been configured with its event types.
	ApiServerConditionEventTypeProvided apis.ConditionType = "EventTypesProvided"
)
View Source 
const (
	// ApiServerSourceAddEventType is the ApiServerSource CloudEvent type for adds.
	ApiServerSourceAddEventType = "dev.knative.apiserver.resource.add"
	// ApiServerSourceUpdateEventType is the ApiServerSource CloudEvent type for updates.
	ApiServerSourceUpdateEventType = "dev.knative.apiserver.resource.update"
	// ApiServerSourceDeleteEventType is the ApiServerSource CloudEvent type for deletions.
	ApiServerSourceDeleteEventType = "dev.knative.apiserver.resource.delete"

	// ApiServerSourceAddRefEventType is the ApiServerSource CloudEvent type for ref adds.
	ApiServerSourceAddRefEventType = "dev.knative.apiserver.ref.add"
	// ApiServerSourceUpdateRefEventType is the ApiServerSource CloudEvent type for ref updates.
	ApiServerSourceUpdateRefEventType = "dev.knative.apiserver.ref.update"
	// ApiServerSourceDeleteRefEventType is the ApiServerSource CloudEvent type for ref deletions.
	ApiServerSourceDeleteRefEventType = "dev.knative.apiserver.ref.delete"
)
View Source 
const (
	// RefMode produces payloads of ObjectReference
	RefMode = "Ref"
	// ResourceMode produces payloads of ResourceEvent
	ResourceMode = "Resource"
)
View Source 
const (
	// ContainerSourceConditionReady has status True when the ContainerSource is ready to send events.
	ContainerConditionReady = apis.ConditionReady

	// ContainerConditionSinkProvided has status True when the ContainerSource has been configured with a sink target.
	ContainerConditionSinkProvided apis.ConditionType = "SinkProvided"

	// ContainerConditionDeployed has status True when the ContainerSource has had it's deployment created.
	ContainerConditionDeployed apis.ConditionType = "Deployed"
)
View Source 
const (
	// CronJobConditionReady has status True when the CronJobSource is ready to send events.
	CronJobConditionReady = apis.ConditionReady

	// CronJobConditionValidSchedule has status True when the CronJobSource has been configured with a valid schedule.
	CronJobConditionValidSchedule apis.ConditionType = "ValidSchedule"

	// CronJobConditionSinkProvided has status True when the CronJobSource has been configured with a sink target.
	CronJobConditionSinkProvided apis.ConditionType = "SinkProvided"

	// CronJobConditionDeployed has status True when the CronJobSource has had it's receive adapter deployment created.
	CronJobConditionDeployed apis.ConditionType = "Deployed"

	// CronJobConditionEventTypeProvided has status True when the CronJobSource has been configured with its event type.
	CronJobConditionEventTypeProvided apis.ConditionType = "EventTypeProvided"

	// CronJobConditionResources is True when the resources listed for the CronJobSource have been properly
	// parsed and match specified syntax for resource quantities
	CronJobConditionResources apis.ConditionType = "ResourcesCorrect"
)
View Source 
const (
	// CronJobEventType is the CronJob CloudEvent type.
	CronJobEventType = "dev.knative.cronjob.event"
)
View Source 
const (
	// SinkBindingConditionReady is configured to indicate whether the Binding
	// has been configured for resources subject to its runtime contract.
	SinkBindingConditionReady = apis.ConditionReady
)
View Source 
const (
	// StatusConditionTypeDeprecated is the status.conditions.type used to provide deprecation
	// warnings.
	StatusConditionTypeDeprecated = "Deprecated"
)

Variables

View Source 
var (
	SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes)
	AddToScheme   = SchemeBuilder.AddToScheme
)
View Source 
var SchemeGroupVersion = schema.GroupVersion{Group: legacysources.GroupName, Version: "v1alpha1"}

SchemeGroupVersion is group version used to register these objects

Functions

func CronJobEventSource 

func CronJobEventSource(namespace, cronJobName string) string

CronJobEventSource returns the CronJob CloudEvent source.

func GetSinkURI 

func GetSinkURI(ctx context.Context) *apis.URL

GetSinkURI accesses the apis.URL for the Sink URI that has been associated with this context.

func Kind 

func Kind(kind string) schema.GroupKind

Kind takes an unqualified kind and returns back a Group qualified GroupKind

func Resource 

func Resource(resource string) schema.GroupResource

Resource takes an unqualified resource and returns a Group qualified GroupResource

func WithSinkURI 

func WithSinkURI(ctx context.Context, uri *apis.URL) context.Context

WithSinkURI notes on the context for binding that the resolved SinkURI is the provided apis.URL.

Types

type ApiServerResource 

type ApiServerResource struct {
	// API version of the resource to watch.
	APIVersion string `json:"apiVersion"`

	// Kind of the resource to watch.
	// More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#types-kinds
	Kind string `json:"kind"`

	// LabelSelector restricts this source to objects with the selected labels
	// More info: http://kubernetes.io/docs/concepts/overview/working-with-objects/labels/#label-selectors
	LabelSelector metav1.LabelSelector `json:"labelSelector"`

	// ControllerSelector restricts this source to objects with a controlling owner reference of the specified kind.
	// Only apiVersion and kind are used. Both are optional.
	ControllerSelector metav1.OwnerReference `json:"controllerSelector"`

	// If true, send an event referencing the object controlling the resource
	Controller bool `json:"controller"`
}

ApiServerResource defines the resource to watch

func (*ApiServerResource) DeepCopy 

func (in *ApiServerResource) DeepCopy() *ApiServerResource

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ApiServerResource.

func (*ApiServerResource) DeepCopyInto 

func (in *ApiServerResource) DeepCopyInto(out *ApiServerResource)

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

type ApiServerSource 

type ApiServerSource struct {
	// Deprecated allows ApiServerSource to have a deprecated message.
	Deprecated

	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   ApiServerSourceSpec   `json:"spec,omitempty"`
	Status ApiServerSourceStatus `json:"status,omitempty"`
}

ApiServerSource is the Schema for the apiserversources API

func (*ApiServerSource) DeepCopy 

func (in *ApiServerSource) DeepCopy() *ApiServerSource

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ApiServerSource.

func (*ApiServerSource) DeepCopyInto 

func (in *ApiServerSource) DeepCopyInto(out *ApiServerSource)

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

func (*ApiServerSource) DeepCopyObject 

func (in *ApiServerSource) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*ApiServerSource) GetGroupVersionKind 

func (s *ApiServerSource) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind returns the GroupVersionKind.

func (*ApiServerSource) GetUntypedSpec 

func (a *ApiServerSource) GetUntypedSpec() interface{}

GetUntypedSpec returns the spec of the ApiServerSource.

func (*ApiServerSource) SetDefaults 

func (s *ApiServerSource) SetDefaults(ctx context.Context)

func (*ApiServerSource) Validate 

func (c *ApiServerSource) Validate(ctx context.Context) *apis.FieldError

type ApiServerSourceList 

type ApiServerSourceList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []ApiServerSource `json:"items"`
}

ApiServerSourceList contains a list of ApiServerSource

func (*ApiServerSourceList) DeepCopy 

func (in *ApiServerSourceList) DeepCopy() *ApiServerSourceList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ApiServerSourceList.

func (*ApiServerSourceList) DeepCopyInto 

func (in *ApiServerSourceList) DeepCopyInto(out *ApiServerSourceList)

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

func (*ApiServerSourceList) DeepCopyObject 

func (in *ApiServerSourceList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type ApiServerSourceSpec 

type ApiServerSourceSpec struct {
	// Resources is the list of resources to watch
	Resources []ApiServerResource `json:"resources"`

	// 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 *duckv1beta1.Destination `json:"sink,omitempty"`

	// Mode is the mode the receive adapter controller runs under: Ref or Resource.
	// `Ref` sends only the reference to the resource.
	// `Resource` send the full resource.
	Mode string `json:"mode,omitempty"`
}

ApiServerSourceSpec defines the desired state of ApiServerSource

func (*ApiServerSourceSpec) DeepCopy 

func (in *ApiServerSourceSpec) DeepCopy() *ApiServerSourceSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ApiServerSourceSpec.

func (*ApiServerSourceSpec) DeepCopyInto 

func (in *ApiServerSourceSpec) DeepCopyInto(out *ApiServerSourceSpec)

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

func (*ApiServerSourceSpec) SetDefaults 

func (ss *ApiServerSourceSpec) SetDefaults(ctx context.Context)

func (*ApiServerSourceSpec) Validate 

func (cs *ApiServerSourceSpec) Validate(ctx context.Context) *apis.FieldError

type ApiServerSourceStatus 

type ApiServerSourceStatus struct {
	// inherits duck/v1 Status, which currently provides:
	// * ObservedGeneration - the 'Generation' of the Service that was last processed by the controller.
	// * Conditions - the latest available observations of a resource's current state.
	duckv1.Status `json:",inline"`

	// SinkURI is the current active sink URI that has been configured for the ApiServerSource.
	// +optional
	SinkURI string `json:"sinkUri,omitempty"`
}

ApiServerSourceStatus defines the observed state of ApiServerSource

func (*ApiServerSourceStatus) DeepCopy 

func (in *ApiServerSourceStatus) DeepCopy() *ApiServerSourceStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ApiServerSourceStatus.

func (*ApiServerSourceStatus) DeepCopyInto 

func (in *ApiServerSourceStatus) DeepCopyInto(out *ApiServerSourceStatus)

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

func (*ApiServerSourceStatus) GetCondition 

func (s *ApiServerSourceStatus) GetCondition(t apis.ConditionType) *apis.Condition

GetCondition returns the condition currently associated with the given type, or nil.

func (*ApiServerSourceStatus) InitializeConditions 

func (s *ApiServerSourceStatus) InitializeConditions()

InitializeConditions sets relevant unset conditions to Unknown state.

func (*ApiServerSourceStatus) IsReady 

func (s *ApiServerSourceStatus) IsReady() bool

IsReady returns true if the resource is ready overall.

func (*ApiServerSourceStatus) MarkEventTypes 

func (s *ApiServerSourceStatus) MarkEventTypes()

MarkEventTypes sets the condition that the source has set its event type.

func (*ApiServerSourceStatus) MarkNoEventTypes 

func (s *ApiServerSourceStatus) MarkNoEventTypes(reason, messageFormat string, messageA ...interface{})

MarkNoEventTypes sets the condition that the source does not its event type configured.

func (*ApiServerSourceStatus) MarkNoSink 

func (s *ApiServerSourceStatus) MarkNoSink(reason, messageFormat string, messageA ...interface{})

MarkNoSink sets the condition that the source does not have a sink configured.

func (*ApiServerSourceStatus) MarkNoSufficientPermissions 

func (s *ApiServerSourceStatus) MarkNoSufficientPermissions(reason, messageFormat string, messageA ...interface{})

MarkNoSufficientPermissions sets the condition that the source does not have enough permissions to access the resources

func (*ApiServerSourceStatus) MarkSink 

func (s *ApiServerSourceStatus) MarkSink(uri string)

MarkSink sets the condition that the source has a sink configured.

func (*ApiServerSourceStatus) MarkSinkWarnRefDeprecated 

func (s *ApiServerSourceStatus) MarkSinkWarnRefDeprecated(uri string)

MarkSinkWarnDeprecated sets the condition that the source has a sink configured and warns ref is deprecated.

func (*ApiServerSourceStatus) MarkSufficientPermissions 

func (s *ApiServerSourceStatus) MarkSufficientPermissions()

MarkSufficientPermissions sets the condition that the source has enough permissions to access the resources.

func (*ApiServerSourceStatus) PropagateDeploymentAvailability 

func (s *ApiServerSourceStatus) PropagateDeploymentAvailability(d *appsv1.Deployment)

PropagateDeploymentAvailability uses the availability of the provided Deployment to determine if ApiServerConditionDeployed should be marked as true or false.

type ContainerSource 

type ContainerSource struct {
	// Deprecated allows ContainerSource to have a deprecated message.
	Deprecated

	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

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.

func (*ContainerSource) GetGroupVersionKind 

func (s *ContainerSource) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind returns the GroupVersionKind.

func (*ContainerSource) GetUntypedSpec 

func (c *ContainerSource) GetUntypedSpec() interface{}

GetUntypedSpec returns the spec of the ContainerSource.

func (*ContainerSource) SetDefaults 

func (s *ContainerSource) SetDefaults(ctx context.Context)

func (*ContainerSource) Validate 

func (c *ContainerSource) Validate(ctx context.Context) *apis.FieldError

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 {
	// Template describes the pods that will be created
	// +optional
	Template *corev1.PodTemplateSpec `json:"template,omitempty"`

	// DeprecatedImage is the image to run inside of the container.
	// This field is to be deprecated. Use `Template` instead.
	// When `Template` is set, this field is ignored.
	// +kubebuilder:validation:MinLength=1
	DeprecatedImage string `json:"image,omitempty"`

	// DeprecatedArgs are passed to the ContainerSpec as they are.
	// This field is to be deprecated. Use `Template` instead.
	// When `Template` is set, this field is ignored.
	DeprecatedArgs []string `json:"args,omitempty"`

	// DeprecatedEnv is the list of environment variables to set in the container.
	// Cannot be updated.
	// This field is to be deprecated. Use `Template` instead.
	// When `Template` is set, this field is ignored.
	// +optional
	// +patchMergeKey=name
	// +patchStrategy=merge
	DeprecatedEnv []corev1.EnvVar `json:"env,omitempty" patchStrategy:"merge" patchMergeKey:"name"`

	// DeprecatedServiceAccountName is the name of the ServiceAccount to use to run this
	// source.
	// This field is to be deprecated. Use `Template` instead.
	// When `Template` is set, this field is ignored.
	// +optional
	DeprecatedServiceAccountName string `json:"serviceAccountName,omitempty"`

	// Sink is a reference to an object that will resolve to a domain name to use as the sink.
	Sink *duckv1beta1.Destination `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.

func (*ContainerSourceSpec) SetDefaults 

func (ss *ContainerSourceSpec) SetDefaults(ctx context.Context)

func (*ContainerSourceSpec) Validate 

func (cs *ContainerSourceSpec) Validate(ctx context.Context) *apis.FieldError

type ContainerSourceStatus 

type ContainerSourceStatus struct {
	// inherits duck/v1 Status, which currently provides:
	// * ObservedGeneration - the 'Generation' of the Service that was last processed by the controller.
	// * Conditions - the latest available observations of a resource's current state.
	duckv1.Status `json:",inline"`

	// SinkURI is the current active sink URI that has been configured for the 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 apis.ConditionType) *apis.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) IsDeployed 

func (s *ContainerSourceStatus) IsDeployed() bool

IsDeployed returns true if the Deployed condition has status true, otherwise false.

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)

MarkSink sets the condition that the source has a sink configured.

func (*ContainerSourceStatus) MarkSinkWarnRefDeprecated 

func (s *ContainerSourceStatus) MarkSinkWarnRefDeprecated(uri string)

MarkSinkWarnDeprecated sets the condition that the source has a sink configured and warns ref is deprecated.

type CronJobLimitsSpec 

type CronJobLimitsSpec struct {
	ResourceCPU    string `json:"cpu,omitempty"`
	ResourceMemory string `json:"memory,omitempty"`
}

func (*CronJobLimitsSpec) DeepCopy 

func (in *CronJobLimitsSpec) DeepCopy() *CronJobLimitsSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CronJobLimitsSpec.

func (*CronJobLimitsSpec) DeepCopyInto 

func (in *CronJobLimitsSpec) DeepCopyInto(out *CronJobLimitsSpec)

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

type CronJobRequestsSpec 

type CronJobRequestsSpec struct {
	ResourceCPU    string `json:"cpu,omitempty"`
	ResourceMemory string `json:"memory,omitempty"`
}

func (*CronJobRequestsSpec) DeepCopy 

func (in *CronJobRequestsSpec) DeepCopy() *CronJobRequestsSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CronJobRequestsSpec.

func (*CronJobRequestsSpec) DeepCopyInto 

func (in *CronJobRequestsSpec) DeepCopyInto(out *CronJobRequestsSpec)

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

type CronJobResourceSpec 

type CronJobResourceSpec struct {
	Requests CronJobRequestsSpec `json:"requests,omitempty"`
	Limits   CronJobLimitsSpec   `json:"limits,omitempty"`
}

func (*CronJobResourceSpec) DeepCopy 

func (in *CronJobResourceSpec) DeepCopy() *CronJobResourceSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CronJobResourceSpec.

func (*CronJobResourceSpec) DeepCopyInto 

func (in *CronJobResourceSpec) DeepCopyInto(out *CronJobResourceSpec)

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

type CronJobSource 

type CronJobSource struct {
	// Deprecated allows CronJobSource to have a deprecated message.
	Deprecated

	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.

func (*CronJobSource) DeepCopy 

func (in *CronJobSource) DeepCopy() *CronJobSource

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CronJobSource.

func (*CronJobSource) DeepCopyInto 

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 

func (in *CronJobSource) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*CronJobSource) GetGroupVersionKind 

func (s *CronJobSource) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind returns the GroupVersionKind.

func (*CronJobSource) GetUntypedSpec 

func (c *CronJobSource) GetUntypedSpec() interface{}

GetUntypedSpec returns the spec of the CronJobSource.

func (*CronJobSource) SetDefaults 

func (s *CronJobSource) SetDefaults(ctx context.Context)

func (*CronJobSource) Validate 

func (c *CronJobSource) Validate(ctx context.Context) *apis.FieldError

type CronJobSourceList 

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 

func (in *CronJobSourceList) DeepCopy() *CronJobSourceList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CronJobSourceList.

func (*CronJobSourceList) DeepCopyInto 

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 

func (in *CronJobSourceList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type CronJobSourceSpec 

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.
	Sink *duckv1beta1.Destination `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"`

	// Resource limits and Request specifications of the Receive Adapter Deployment
	Resources CronJobResourceSpec `json:"resources,omitempty"`
}

CronJobSourceSpec defines the desired state of the CronJobSource.

func (*CronJobSourceSpec) DeepCopy 

func (in *CronJobSourceSpec) DeepCopy() *CronJobSourceSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CronJobSourceSpec.

func (*CronJobSourceSpec) DeepCopyInto 

func (in *CronJobSourceSpec) DeepCopyInto(out *CronJobSourceSpec)

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

func (*CronJobSourceSpec) SetDefaults 

func (ss *CronJobSourceSpec) SetDefaults(ctx context.Context)

func (*CronJobSourceSpec) Validate 

func (cs *CronJobSourceSpec) Validate(ctx context.Context) *apis.FieldError

type CronJobSourceStatus 

type CronJobSourceStatus struct {
	// inherits duck/v1 Status, which currently provides:
	// * ObservedGeneration - the 'Generation' of the Service that was last processed by the controller.
	// * Conditions - the latest available observations of a resource's current state.
	duckv1.Status `json:",inline"`

	// SinkURI is the current active sink URI that has been configured for the CronJobSource.
	// +optional
	SinkURI string `json:"sinkUri,omitempty"`
}

CronJobSourceStatus defines the observed state of CronJobSource.

func (*CronJobSourceStatus) DeepCopy 

func (in *CronJobSourceStatus) DeepCopy() *CronJobSourceStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CronJobSourceStatus.

func (*CronJobSourceStatus) DeepCopyInto 

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 

func (s *CronJobSourceStatus) GetCondition(t apis.ConditionType) *apis.Condition

GetCondition returns the condition currently associated with the given type, or nil.

func (*CronJobSourceStatus) InitializeConditions 

func (s *CronJobSourceStatus) InitializeConditions()

InitializeConditions sets relevant unset conditions to Unknown state.

func (*CronJobSourceStatus) IsReady 

func (s *CronJobSourceStatus) IsReady() bool

IsReady returns true if the resource is ready overall.

func (*CronJobSourceStatus) MarkEventType 

func (s *CronJobSourceStatus) MarkEventType()

MarkEventType sets the condition that the source has set its event type.

func (*CronJobSourceStatus) MarkInvalidSchedule 

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) MarkNoEventType 

func (s *CronJobSourceStatus) MarkNoEventType(reason, messageFormat string, messageA ...interface{})

MarkNoEventType sets the condition that the source does not its event type configured.

func (*CronJobSourceStatus) MarkNoSink 

func (s *CronJobSourceStatus) MarkNoSink(reason, messageFormat string, messageA ...interface{})

MarkNoSink sets the condition that the source does not have a sink configured.

func (*CronJobSourceStatus) MarkResourcesCorrect 

func (s *CronJobSourceStatus) MarkResourcesCorrect()

MarkResourcesCorrect sets the condition that the source resources are properly parsable quantities

func (*CronJobSourceStatus) MarkResourcesIncorrect 

func (s *CronJobSourceStatus) MarkResourcesIncorrect(reason, messageFormat string, messageA ...interface{})

MarkResourcesIncorrect sets the condition that the source resources are not properly parsable quantities

func (*CronJobSourceStatus) MarkSchedule 

func (s *CronJobSourceStatus) MarkSchedule()

TODO: this is a bad method name, change it. MarkSchedule sets the condition that the source has a valid schedule configured.

func (*CronJobSourceStatus) MarkSink 

func (s *CronJobSourceStatus) MarkSink(uri string)

MarkSink sets the condition that the source has a sink configured.

func (*CronJobSourceStatus) MarkSinkWarnRefDeprecated 

func (s *CronJobSourceStatus) MarkSinkWarnRefDeprecated(uri string)

MarkSinkWarnDeprecated sets the condition that the source has a sink configured and warns ref is deprecated.

func (*CronJobSourceStatus) PropagateDeploymentAvailability 

func (s *CronJobSourceStatus) PropagateDeploymentAvailability(d *appsv1.Deployment)

PropagateDeploymentAvailability uses the availability of the provided Deployment to determine if CronJobConditionDeployed should be marked as true or false.

type Deprecated 

type Deprecated struct{}

func (*Deprecated) DeepCopy 

func (in *Deprecated) DeepCopy() *Deprecated

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Deprecated.

func (*Deprecated) DeepCopyInto 

func (in *Deprecated) DeepCopyInto(out *Deprecated)

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

func (*Deprecated) MarkDeprecated 

func (d *Deprecated) MarkDeprecated(s *duckv1.Status, reason, msg string)

MarkDeprecated adds a warning condition that this object's spec is using deprecated fields and will stop working in the future.

type SinkBinding 

type SinkBinding struct {
	// Deprecated allows ApiServerSource to have a deprecated message.
	Deprecated

	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   SinkBindingSpec   `json:"spec"`
	Status SinkBindingStatus `json:"status"`
}

SinkBinding describes a Binding that is also a Source. The `sink` (from the Source duck) is resolved to a URL and then projected into the `subject` by augmenting the runtime contract of the referenced containers to have a `K_SINK` environment variable holding the endpoint to which to send cloud events.

func (*SinkBinding) DeepCopy 

func (in *SinkBinding) DeepCopy() *SinkBinding

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SinkBinding.

func (*SinkBinding) DeepCopyInto 

func (in *SinkBinding) DeepCopyInto(out *SinkBinding)

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

func (*SinkBinding) DeepCopyObject 

func (in *SinkBinding) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*SinkBinding) Do 

func (fb *SinkBinding) Do(ctx context.Context, ps *duckv1.WithPod)

Do implements psbinding.Bindable

func (*SinkBinding) GetBindingStatus 

func (fb *SinkBinding) GetBindingStatus() duck.BindableStatus

GetBindingStatus implements psbinding.Bindable

func (*SinkBinding) GetGroupVersionKind 

func (s *SinkBinding) GetGroupVersionKind() schema.GroupVersionKind

GetGroupVersionKind returns the GroupVersionKind.

func (*SinkBinding) GetSubject 

func (fb *SinkBinding) GetSubject() tracker.Reference

GetSubject implements psbinding.Bindable

func (*SinkBinding) GetUntypedSpec 

func (c *SinkBinding) GetUntypedSpec() interface{}

GetUntypedSpec implements apis.HasSpec

func (*SinkBinding) SetDefaults 

func (fb *SinkBinding) SetDefaults(ctx context.Context)

SetDefaults implements apis.Defaultable

func (*SinkBinding) Undo 

func (fb *SinkBinding) Undo(ctx context.Context, ps *duckv1.WithPod)

func (*SinkBinding) Validate 

func (fb *SinkBinding) Validate(ctx context.Context) *apis.FieldError

Validate implements apis.Validatable

type SinkBindingList 

type SinkBindingList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []SinkBinding `json:"items"`
}

SinkBindingList contains a list of SinkBinding

func (*SinkBindingList) DeepCopy 

func (in *SinkBindingList) DeepCopy() *SinkBindingList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SinkBindingList.

func (*SinkBindingList) DeepCopyInto 

func (in *SinkBindingList) DeepCopyInto(out *SinkBindingList)

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

func (*SinkBindingList) DeepCopyObject 

func (in *SinkBindingList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type SinkBindingSpec 

type SinkBindingSpec struct {
	duckv1.SourceSpec        `json:",inline"`
	duckv1alpha1.BindingSpec `json:",inline"`
}

SinkBindingSpec holds the desired state of the SinkBinding (from the client).

func (*SinkBindingSpec) DeepCopy 

func (in *SinkBindingSpec) DeepCopy() *SinkBindingSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SinkBindingSpec.

func (*SinkBindingSpec) DeepCopyInto 

func (in *SinkBindingSpec) DeepCopyInto(out *SinkBindingSpec)

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

func (*SinkBindingSpec) Validate 

func (fbs *SinkBindingSpec) Validate(ctx context.Context) *apis.FieldError

Validate implements apis.Validatable

type SinkBindingStatus 

type SinkBindingStatus struct {
	duckv1.SourceStatus `json:",inline"`
}

SinkBindingStatus communicates the observed state of the SinkBinding (from the controller).

func (*SinkBindingStatus) DeepCopy 

func (in *SinkBindingStatus) DeepCopy() *SinkBindingStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SinkBindingStatus.

func (*SinkBindingStatus) DeepCopyInto 

func (in *SinkBindingStatus) DeepCopyInto(out *SinkBindingStatus)

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

func (*SinkBindingStatus) InitializeConditions 

func (fbs *SinkBindingStatus) InitializeConditions()

InitializeConditions populates the SinkBindingStatus's conditions field with all of its conditions configured to Unknown.

func (*SinkBindingStatus) MarkBindingAvailable 

func (fbs *SinkBindingStatus) MarkBindingAvailable()

MarkBindingAvailable marks the SinkBinding's Ready condition to True.

func (*SinkBindingStatus) MarkBindingUnavailable 

func (fbs *SinkBindingStatus) MarkBindingUnavailable(reason, message string)

MarkBindingUnavailable marks the SinkBinding's Ready condition to False with the provided reason and message.

func (*SinkBindingStatus) SetObservedGeneration 

func (fbs *SinkBindingStatus) SetObservedGeneration(gen int64)

SetObservedGeneration implements psbinding.BindableStatus

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.