v1alpha2

package
v0.14.2 Latest Latest
Warning

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

Go to latest
Published: Apr 30, 2020 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Overview

Package v1alpha2 contains API Schema definitions for the sources v1beta1 API group +k8s:deepcopy-gen=package +groupName=sources.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 (
	// ReferenceMode produces payloads of ObjectReference
	ReferenceMode = "Reference"
	// ResourceMode produces payloads of ResourceEvent
	ResourceMode = "Resource"
)
View Source
const (
	// ContainerSourceConditionReady has status True when the ContainerSource is ready to send events.
	ContainerSourceConditionReady = apis.ConditionReady

	// ContainerSourceConditionSinkBindingReady has status True when the ContainerSource's SinkBinding is ready.
	ContainerSourceConditionSinkBindingReady apis.ConditionType = "SinkBindingReady"

	// ContainerSourceConditionReceiveAdapterReady has status True when the ContainerSource's ReceiveAdapter is ready.
	ContainerSourceConditionReceiveAdapterReady apis.ConditionType = "ReceiveAdapterReady"
)
View Source
const (
	// PingSourceConditionReady has status True when the PingSource is ready to send events.
	PingSourceConditionReady = apis.ConditionReady

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

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

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

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

	// PingSourceConditionResources is True when the resources listed for the PingSource have been properly
	// parsed and match specified syntax for resource quantities
	PingSourceConditionResources apis.ConditionType = "ResourcesCorrect"
)
View Source
const (
	// PingSourceEventType is the default PingSource CloudEvent type.
	PingSourceEventType = "dev.knative.sources.ping"
)
View Source
const (
	// SinkBindingConditionReady is configured to indicate whether the Binding
	// has been configured for resources subject to its runtime contract.
	SinkBindingConditionReady = apis.ConditionReady
)

Variables

View Source
var (
	SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes)
	AddToScheme   = SchemeBuilder.AddToScheme
)

ApiServerSourceEventTypes is the list of CloudEvent types the ApiServerSource emits.

View Source
var SchemeGroupVersion = schema.GroupVersion{Group: sources.GroupName, Version: "v1alpha2"}

SchemeGroupVersion is group version used to register these objects

Functions

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 PingSourceSource

func PingSourceSource(namespace, name string) string

PingSourceSource returns the PingSource CloudEvent source.

func Resource

func Resource(resource string) schema.GroupResource

Resource takes an unqualified resource and returns a Group qualified GroupResource

func ValidateAnnotations added in v0.14.0

func ValidateAnnotations(errs *apis.FieldError, annotations map[string]string) *apis.FieldError

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 APIVersionKind

type APIVersionKind struct {
	// APIVersion - the 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"`
}

APIVersionKind is an APIVersion and Kind tuple.

func (*APIVersionKind) DeepCopy

func (in *APIVersionKind) DeepCopy() *APIVersionKind

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

func (*APIVersionKind) DeepCopyInto

func (in *APIVersionKind) DeepCopyInto(out *APIVersionKind)

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

type APIVersionKindSelector added in v0.14.0

type APIVersionKindSelector struct {
	// APIVersion - the 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 filters this source to objects to those resources pass the
	// label selector.
	// More info: http://kubernetes.io/docs/concepts/overview/working-with-objects/labels/#label-selectors
	// +optional
	LabelSelector *metav1.LabelSelector `json:"selector,omitempty"`
}

APIVersionKindSelector is an APIVersion Kind tuple with a LabelSelector.

func (*APIVersionKindSelector) DeepCopy added in v0.14.0

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

func (*APIVersionKindSelector) DeepCopyInto added in v0.14.0

func (in *APIVersionKindSelector) DeepCopyInto(out *APIVersionKindSelector)

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

func (sink *ApiServerSource) ConvertFrom(ctx context.Context, source apis.Convertible) error

ConvertFrom implements apis.Convertible

func (*ApiServerSource) ConvertTo

func (source *ApiServerSource) ConvertTo(ctx context.Context, sink apis.Convertible) error

ConvertTo implements apis.Convertible

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 (s *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 {
	// inherits duck/v1 SourceSpec, which currently provides:
	// * Sink - a reference to an object that will resolve to a domain name or
	//   a URI directly to use as the sink.
	// * CloudEventOverrides - defines overrides to control the output format
	//   and modifications of the event sent to the sink.
	duckv1.SourceSpec `json:",inline"`

	// Resource are the resources this source will track and send related
	// lifecycle events from the Kubernetes ApiServer, with an optional label
	// selector to help filter.
	// +required
	Resources []APIVersionKindSelector `json:"resources,omitempty"`

	// ResourceOwner is an additional filter to only track resources that are
	// owned by a specific resource type. If ResourceOwner matches Resources[n]
	// then Resources[n] is allowed to pass the ResourceOwner filter.
	// +optional
	ResourceOwner *APIVersionKind `json:"owner,omitempty"`

	// EventMode controls the format of the event.
	// `Reference` sends a dataref event type for the resource under watch.
	// `Resource` send the full resource lifecycle event.
	// Defaults to `Reference`
	// +optional
	EventMode string `json:"mode,omitempty"`

	// ServiceAccountName is the name of the ServiceAccount to use to run this
	// source. Defaults to default if not set.
	// +optional
	ServiceAccountName string `json:"serviceAccountName,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 SourceStatus, 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.
	// * SinkURI - the current active sink URI that has been configured for the
	//   Source.
	duckv1.SourceStatus `json:",inline"`
}

ApiServerSourceStatus defines the observed state of ApiServerSource

func (*ApiServerSourceStatus) DeepCopy

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

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 *apis.URL)

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

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

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

func (in *ContainerSource) DeepCopy() *ContainerSource

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

func (*ContainerSource) DeepCopyInto added in v0.14.0

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

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

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

func (*ContainerSource) GetGroupVersionKind added in v0.14.0

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

GetGroupVersionKind returns the GroupVersionKind.

func (*ContainerSource) GetUntypedSpec added in v0.14.0

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

GetUntypedSpec returns the spec of the ContainerSource.

func (*ContainerSource) SetDefaults added in v0.14.0

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

func (*ContainerSource) Validate added in v0.14.0

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

type ContainerSourceList added in v0.14.0

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

func (in *ContainerSourceList) DeepCopy() *ContainerSourceList

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

func (*ContainerSourceList) DeepCopyInto added in v0.14.0

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

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

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

type ContainerSourceSpec added in v0.14.0

type ContainerSourceSpec struct {
	// inherits duck/v1 SourceSpec, which currently provides:
	// * Sink - a reference to an object that will resolve to a domain name or
	//   a URI directly to use as the sink.
	// * CloudEventOverrides - defines overrides to control the output format
	//   and modifications of the event sent to the sink.
	duckv1.SourceSpec `json:",inline"`

	// Template describes the pods that will be created
	Template corev1.PodTemplateSpec `json:"template"`
}

ContainerSourceSpec defines the desired state of ContainerSource

func (*ContainerSourceSpec) DeepCopy added in v0.14.0

func (in *ContainerSourceSpec) DeepCopy() *ContainerSourceSpec

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

func (*ContainerSourceSpec) DeepCopyInto added in v0.14.0

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.14.0

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

func (*ContainerSourceSpec) Validate added in v0.14.0

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

type ContainerSourceStatus added in v0.14.0

type ContainerSourceStatus struct {
	// inherits duck/v1 SourceStatus, 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.
	// * SinkURI - the current active sink URI that has been configured for the
	//   Source.
	duckv1.SourceStatus `json:",inline"`
}

ContainerSourceStatus defines the observed state of ContainerSource

func (*ContainerSourceStatus) DeepCopy added in v0.14.0

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

func (*ContainerSourceStatus) DeepCopyInto added in v0.14.0

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

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

func (*ContainerSourceStatus) InitializeConditions added in v0.14.0

func (s *ContainerSourceStatus) InitializeConditions()

InitializeConditions sets relevant unset conditions to Unknown state.

func (*ContainerSourceStatus) IsReady added in v0.14.0

func (s *ContainerSourceStatus) IsReady() bool

IsReady returns true if the resource is ready overall.

func (*ContainerSourceStatus) PropagateReceiveAdapterStatus added in v0.14.0

func (s *ContainerSourceStatus) PropagateReceiveAdapterStatus(d *appsv1.Deployment)

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

func (*ContainerSourceStatus) PropagateSinkBindingStatus added in v0.14.0

func (s *ContainerSourceStatus) PropagateSinkBindingStatus(status *SinkBindingStatus)

PropagateSinkBindingStatus uses the availability of the provided Deployment to determine if ContainerSourceConditionSinkBindingReady should be marked as true, false or unknown.

type PingSource

type PingSource struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   PingSourceSpec   `json:"spec,omitempty"`
	Status PingSourceStatus `json:"status,omitempty"`
}

PingSource is the Schema for the PingSources API.

func (*PingSource) ConvertFrom

func (sink *PingSource) ConvertFrom(ctx context.Context, source apis.Convertible) error

ConvertFrom implements apis.Convertible

func (*PingSource) ConvertTo

func (source *PingSource) ConvertTo(ctx context.Context, sink apis.Convertible) error

ConvertTo implements apis.Convertible

func (*PingSource) DeepCopy

func (in *PingSource) DeepCopy() *PingSource

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

func (*PingSource) DeepCopyInto

func (in *PingSource) DeepCopyInto(out *PingSource)

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

func (*PingSource) DeepCopyObject

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

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

func (*PingSource) GetGroupVersionKind

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

GetGroupVersionKind returns the GroupVersionKind.

func (*PingSource) GetUntypedSpec

func (s *PingSource) GetUntypedSpec() interface{}

GetUntypedSpec returns the spec of the PingSource.

func (*PingSource) SetDefaults

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

func (*PingSource) Validate

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

type PingSourceList

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

PingSourceList contains a list of PingSources.

func (*PingSourceList) DeepCopy

func (in *PingSourceList) DeepCopy() *PingSourceList

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

func (*PingSourceList) DeepCopyInto

func (in *PingSourceList) DeepCopyInto(out *PingSourceList)

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

func (*PingSourceList) DeepCopyObject

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

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

type PingSourceSpec

type PingSourceSpec struct {
	// inherits duck/v1 SourceSpec, which currently provides:
	// * Sink - a reference to an object that will resolve to a domain name or
	//   a URI directly to use as the sink.
	// * CloudEventOverrides - defines overrides to control the output format
	//   and modifications of the event sent to the sink.
	duckv1.SourceSpec `json:",inline"`

	// Schedule is the cronjob schedule. Defaults to `* * * * *`.
	// +optional
	Schedule string `json:"schedule"`

	// JsonData is json encoded data used as the body of the event posted to
	// the sink. Default is empty. If set, datacontenttype will also be set
	// to "application/json".
	// +optional
	JsonData string `json:"jsonData,omitempty"`
}

PingSourceSpec defines the desired state of the PingSource.

func (*PingSourceSpec) DeepCopy

func (in *PingSourceSpec) DeepCopy() *PingSourceSpec

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

func (*PingSourceSpec) DeepCopyInto

func (in *PingSourceSpec) DeepCopyInto(out *PingSourceSpec)

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

func (*PingSourceSpec) SetDefaults

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

func (*PingSourceSpec) Validate

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

type PingSourceStatus

type PingSourceStatus struct {
	// inherits duck/v1 SourceStatus, 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.
	// * SinkURI - the current active sink URI that has been configured for the
	//   Source.
	duckv1.SourceStatus `json:",inline"`
}

PingSourceStatus defines the observed state of PingSource.

func (*PingSourceStatus) DeepCopy

func (in *PingSourceStatus) DeepCopy() *PingSourceStatus

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

func (*PingSourceStatus) DeepCopyInto

func (in *PingSourceStatus) DeepCopyInto(out *PingSourceStatus)

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

func (*PingSourceStatus) GetCondition

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

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

func (*PingSourceStatus) GetTopLevelCondition

func (ps *PingSourceStatus) GetTopLevelCondition() *apis.Condition

GetTopLevelCondition returns the top level Condition.

func (*PingSourceStatus) InitializeConditions

func (s *PingSourceStatus) InitializeConditions()

InitializeConditions sets relevant unset conditions to Unknown state.

func (*PingSourceStatus) IsReady

func (s *PingSourceStatus) IsReady() bool

IsReady returns true if the resource is ready overall.

func (*PingSourceStatus) MarkEventType

func (s *PingSourceStatus) MarkEventType()

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

func (*PingSourceStatus) MarkInvalidSchedule

func (s *PingSourceStatus) MarkInvalidSchedule(reason, messageFormat string, messageA ...interface{})

MarkInvalidSchedule sets the condition that the source does not have a valid schedule configured.

func (*PingSourceStatus) MarkNoEventType

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

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

func (*PingSourceStatus) MarkNoSink

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

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

func (*PingSourceStatus) MarkResourcesCorrect

func (s *PingSourceStatus) MarkResourcesCorrect()

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

func (*PingSourceStatus) MarkResourcesIncorrect

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

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

func (*PingSourceStatus) MarkSchedule

func (s *PingSourceStatus) MarkSchedule()

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

func (*PingSourceStatus) MarkSink

func (s *PingSourceStatus) MarkSink(uri *apis.URL)

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

func (*PingSourceStatus) PropagateDeploymentAvailability

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

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

type SinkBinding

type SinkBinding struct {
	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) ConvertFrom

func (sink *SinkBinding) ConvertFrom(ctx context.Context, source apis.Convertible) error

ConvertFrom implements apis.Convertible

func (*SinkBinding) ConvertTo

func (source *SinkBinding) ConvertTo(ctx context.Context, sink apis.Convertible) error

ConvertTo implements apis.Convertible

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 (sb *SinkBinding) Do(ctx context.Context, ps *duckv1.WithPod)

Do implements psbinding.Bindable

func (*SinkBinding) GetBindingStatus

func (sb *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 (sb *SinkBinding) GetSubject() tracker.Reference

GetSubject implements psbinding.Bindable

func (*SinkBinding) GetUntypedSpec

func (s *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 (sb *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 {
	// inherits duck/v1 SourceSpec, which currently provides:
	// * Sink - a reference to an object that will resolve to a domain name or
	//   a URI directly to use as the sink.
	// * CloudEventOverrides - defines overrides to control the output format
	//   and modifications of the event sent to the sink.
	duckv1.SourceSpec `json:",inline"`

	// inherits duck/v1alpha1 BindingSpec, which currently provides:
	// * Subject - Subject references the resource(s) whose "runtime contract"
	//   should be augmented by Binding implementations.
	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 {
	// inherits duck/v1 SourceStatus, 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.
	// * SinkURI - the current active sink URI that has been configured for the
	//   Source.
	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 (sbs *SinkBindingStatus) InitializeConditions()

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

func (*SinkBindingStatus) MarkBindingAvailable

func (sbs *SinkBindingStatus) MarkBindingAvailable()

MarkBindingAvailable marks the SinkBinding's Ready condition to True.

func (*SinkBindingStatus) MarkBindingUnavailable

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

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

func (*SinkBindingStatus) SetObservedGeneration

func (sbs *SinkBindingStatus) SetObservedGeneration(gen int64)

SetObservedGeneration implements psbinding.BindableStatus

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL