v1alpha1

package
v0.10.0 Latest Latest
Warning

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

 Go to latest Published: Oct 29, 2019 License: Apache-2.0 Imports: 14 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"

	// 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"
)

Variables

View Source 
var (
	SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes)
	AddToScheme   = SchemeBuilder.AddToScheme
)
View Source 
var SchemeGroupVersion = schema.GroupVersion{Group: sources.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 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

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 {
	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 added in v0.10.0 

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

GetUntypedSpec returns the spec of the ApiServerSource.

func (*ApiServerSource) SetDefaults added in v0.10.0 

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

func (*ApiServerSource) Validate added in v0.10.0 

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 *apisv1alpha1.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 added in v0.10.0 

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

func (*ApiServerSourceSpec) Validate added in v0.10.0 

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

func (s *ApiServerSourceStatus) MarkSink(uri string)

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

func (*ApiServerSourceStatus) MarkSinkWarnRefDeprecated added in v0.10.0 

func (s *ApiServerSourceStatus) MarkSinkWarnRefDeprecated(uri string)

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

func (*ApiServerSourceStatus) PropagateDeploymentAvailability added in v0.8.0 

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 {
	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 added in v0.10.0 

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

GetUntypedSpec returns the spec of the ContainerSource.

func (*ContainerSource) SetDefaults added in v0.10.0 

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

func (*ContainerSource) Validate added in v0.10.0 

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 *apisv1alpha1.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 added in v0.10.0 

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

func (*ContainerSourceSpec) Validate added in v0.10.0 

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 added in v0.10.0 

func (s *ContainerSourceStatus) MarkSinkWarnRefDeprecated(uri string)

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

type CronJobLimitsSpec added in v0.7.0 

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

func (*CronJobLimitsSpec) DeepCopy added in v0.7.0 

func (in *CronJobLimitsSpec) DeepCopy() *CronJobLimitsSpec

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

func (*CronJobLimitsSpec) DeepCopyInto added in v0.7.0 

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 added in v0.7.0 

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

func (*CronJobRequestsSpec) DeepCopy added in v0.7.0 

func (in *CronJobRequestsSpec) DeepCopy() *CronJobRequestsSpec

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

func (*CronJobRequestsSpec) DeepCopyInto added in v0.7.0 

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 added in v0.7.0 

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

func (*CronJobResourceSpec) DeepCopy added in v0.7.0 

func (in *CronJobResourceSpec) DeepCopy() *CronJobResourceSpec

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

func (*CronJobResourceSpec) DeepCopyInto added in v0.7.0 

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 {
	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 added in v0.10.0 

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

GetUntypedSpec returns the spec of the CronJobSource.

func (*CronJobSource) SetDefaults added in v0.10.0 

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

func (*CronJobSource) Validate added in v0.10.0 

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 *apisv1alpha1.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 added in v0.10.0 

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

func (*CronJobSourceSpec) Validate added in v0.10.0 

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 added in v0.7.0 

func (s *CronJobSourceStatus) MarkResourcesCorrect()

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

func (*CronJobSourceStatus) MarkResourcesIncorrect added in v0.7.0 

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 added in v0.10.0 

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 added in v0.8.0 

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.

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.