Documentation ¶
Overview ¶
Package v1alpha2 contains API Schema definitions for the sources v1beta1 API group +k8s:deepcopy-gen=package +groupName=sources.knative.dev
Index ¶
- Constants
- Variables
- func GetSinkURI(ctx context.Context) *apis.URL
- func Kind(kind string) schema.GroupKind
- func PingSourceSource(namespace, name string) string
- func Resource(resource string) schema.GroupResource
- func ValidateAnnotations(errs *apis.FieldError, annotations map[string]string) *apis.FieldError
- func WithSinkURI(ctx context.Context, uri *apis.URL) context.Context
- type APIVersionKind
- type APIVersionKindSelector
- type ApiServerSource
- func (sink *ApiServerSource) ConvertFrom(ctx context.Context, source apis.Convertible) error
- func (source *ApiServerSource) ConvertTo(ctx context.Context, sink apis.Convertible) error
- func (in *ApiServerSource) DeepCopy() *ApiServerSource
- func (in *ApiServerSource) DeepCopyInto(out *ApiServerSource)
- func (in *ApiServerSource) DeepCopyObject() runtime.Object
- func (*ApiServerSource) GetConditionSet() apis.ConditionSet
- func (*ApiServerSource) GetGroupVersionKind() schema.GroupVersionKind
- func (a *ApiServerSource) GetStatus() *duckv1.Status
- func (s *ApiServerSource) GetUntypedSpec() interface{}
- func (s *ApiServerSource) SetDefaults(ctx context.Context)
- func (c *ApiServerSource) Validate(ctx context.Context) *apis.FieldError
- type ApiServerSourceList
- type ApiServerSourceSpec
- type ApiServerSourceStatus
- func (in *ApiServerSourceStatus) DeepCopy() *ApiServerSourceStatus
- func (in *ApiServerSourceStatus) DeepCopyInto(out *ApiServerSourceStatus)
- func (s *ApiServerSourceStatus) GetCondition(t apis.ConditionType) *apis.Condition
- func (s *ApiServerSourceStatus) GetTopLevelCondition() *apis.Condition
- func (s *ApiServerSourceStatus) InitializeConditions()
- func (s *ApiServerSourceStatus) IsReady() bool
- func (s *ApiServerSourceStatus) MarkEventTypes()
- func (s *ApiServerSourceStatus) MarkNoEventTypes(reason, messageFormat string, messageA ...interface{})
- func (s *ApiServerSourceStatus) MarkNoSink(reason, messageFormat string, messageA ...interface{})
- func (s *ApiServerSourceStatus) MarkNoSufficientPermissions(reason, messageFormat string, messageA ...interface{})
- func (s *ApiServerSourceStatus) MarkSink(uri *apis.URL)
- func (s *ApiServerSourceStatus) MarkSufficientPermissions()
- func (s *ApiServerSourceStatus) PropagateDeploymentAvailability(d *appsv1.Deployment)
- type ContainerSource
- func (in *ContainerSource) DeepCopy() *ContainerSource
- func (in *ContainerSource) DeepCopyInto(out *ContainerSource)
- func (in *ContainerSource) DeepCopyObject() runtime.Object
- func (*ContainerSource) GetConditionSet() apis.ConditionSet
- func (*ContainerSource) GetGroupVersionKind() schema.GroupVersionKind
- func (c *ContainerSource) GetStatus() *duckv1.Status
- func (c *ContainerSource) GetUntypedSpec() interface{}
- func (s *ContainerSource) SetDefaults(ctx context.Context)
- func (c *ContainerSource) Validate(ctx context.Context) *apis.FieldError
- type ContainerSourceList
- type ContainerSourceSpec
- type ContainerSourceStatus
- func (in *ContainerSourceStatus) DeepCopy() *ContainerSourceStatus
- func (in *ContainerSourceStatus) DeepCopyInto(out *ContainerSourceStatus)
- func (s *ContainerSourceStatus) GetCondition(t apis.ConditionType) *apis.Condition
- func (s *ContainerSourceStatus) GetTopLevelCondition() *apis.Condition
- func (s *ContainerSourceStatus) InitializeConditions()
- func (s *ContainerSourceStatus) IsReady() bool
- func (s *ContainerSourceStatus) PropagateReceiveAdapterStatus(d *appsv1.Deployment)
- func (s *ContainerSourceStatus) PropagateSinkBindingStatus(status *SinkBindingStatus)
- type PingSource
- func (sink *PingSource) ConvertFrom(ctx context.Context, source apis.Convertible) error
- func (source *PingSource) ConvertTo(ctx context.Context, sink apis.Convertible) error
- func (in *PingSource) DeepCopy() *PingSource
- func (in *PingSource) DeepCopyInto(out *PingSource)
- func (in *PingSource) DeepCopyObject() runtime.Object
- func (*PingSource) GetConditionSet() apis.ConditionSet
- func (s *PingSource) GetGroupVersionKind() schema.GroupVersionKind
- func (p *PingSource) GetStatus() *duckv1.Status
- func (s *PingSource) GetUntypedSpec() interface{}
- func (s *PingSource) SetDefaults(ctx context.Context)
- func (c *PingSource) Validate(ctx context.Context) *apis.FieldError
- type PingSourceList
- type PingSourceSpec
- type PingSourceStatus
- func (in *PingSourceStatus) DeepCopy() *PingSourceStatus
- func (in *PingSourceStatus) DeepCopyInto(out *PingSourceStatus)
- func (s *PingSourceStatus) GetCondition(t apis.ConditionType) *apis.Condition
- func (ps *PingSourceStatus) GetTopLevelCondition() *apis.Condition
- func (s *PingSourceStatus) InitializeConditions()
- func (s *PingSourceStatus) IsReady() bool
- func (s *PingSourceStatus) MarkEventType()
- func (s *PingSourceStatus) MarkInvalidSchedule(reason, messageFormat string, messageA ...interface{})
- func (s *PingSourceStatus) MarkNoEventType(reason, messageFormat string, messageA ...interface{})
- func (s *PingSourceStatus) MarkNoSink(reason, messageFormat string, messageA ...interface{})
- func (s *PingSourceStatus) MarkResourcesCorrect()
- func (s *PingSourceStatus) MarkResourcesIncorrect(reason, messageFormat string, messageA ...interface{})
- func (s *PingSourceStatus) MarkSchedule()
- func (s *PingSourceStatus) MarkSink(uri *apis.URL)
- func (s *PingSourceStatus) PropagateDeploymentAvailability(d *appsv1.Deployment)
- type SinkBinding
- func (sink *SinkBinding) ConvertFrom(ctx context.Context, source apis.Convertible) error
- func (source *SinkBinding) ConvertTo(ctx context.Context, sink apis.Convertible) error
- func (in *SinkBinding) DeepCopy() *SinkBinding
- func (in *SinkBinding) DeepCopyInto(out *SinkBinding)
- func (in *SinkBinding) DeepCopyObject() runtime.Object
- func (sb *SinkBinding) Do(ctx context.Context, ps *duckv1.WithPod)
- func (sb *SinkBinding) GetBindingStatus() duck.BindableStatus
- func (*SinkBinding) GetConditionSet() apis.ConditionSet
- func (*SinkBinding) GetGroupVersionKind() schema.GroupVersionKind
- func (s *SinkBinding) GetStatus() *duckv1.Status
- func (sb *SinkBinding) GetSubject() tracker.Reference
- func (s *SinkBinding) GetUntypedSpec() interface{}
- func (fb *SinkBinding) SetDefaults(ctx context.Context)
- func (sb *SinkBinding) Undo(ctx context.Context, ps *duckv1.WithPod)
- func (fb *SinkBinding) Validate(ctx context.Context) *apis.FieldError
- type SinkBindingList
- type SinkBindingSpec
- type SinkBindingStatus
- func (in *SinkBindingStatus) DeepCopy() *SinkBindingStatus
- func (in *SinkBindingStatus) DeepCopyInto(out *SinkBindingStatus)
- func (sbs *SinkBindingStatus) InitializeConditions()
- func (sbs *SinkBindingStatus) MarkBindingAvailable()
- func (sbs *SinkBindingStatus) MarkBindingUnavailable(reason, message string)
- func (sbs *SinkBindingStatus) SetObservedGeneration(gen int64)
Constants ¶
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" )
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" )
const ( // ReferenceMode produces payloads of ObjectReference ReferenceMode = "Reference" // ResourceMode produces payloads of ResourceEvent ResourceMode = "Resource" )
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" )
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" )
const (
// PingSourceEventType is the default PingSource CloudEvent type.
PingSourceEventType = "dev.knative.sources.ping"
)
const ( // SinkBindingConditionReady is configured to indicate whether the Binding // has been configured for resources subject to its runtime contract. SinkBindingConditionReady = apis.ConditionReady )
Variables ¶
var ( SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes) AddToScheme = SchemeBuilder.AddToScheme )
var ApiServerSourceEventTypes = []string{ ApiServerSourceAddEventType, ApiServerSourceDeleteEventType, ApiServerSourceUpdateEventType, ApiServerSourceAddRefEventType, ApiServerSourceDeleteRefEventType, ApiServerSourceUpdateRefEventType, }
ApiServerSourceEventTypes is the list of CloudEvent types the ApiServerSource emits.
var PingSourceCondSet = apis.NewLivingConditionSet( PingSourceConditionValidSchedule, PingSourceConditionSinkProvided, PingSourceConditionDeployed)
var SchemeGroupVersion = schema.GroupVersion{Group: sources.GroupName, Version: "v1alpha2"}
SchemeGroupVersion is group version used to register these objects
var TestHelper = testHelper{}
TestHelper contains helpers for unit tests.
Functions ¶
func GetSinkURI ¶
GetSinkURI accesses the apis.URL for the Sink URI that has been associated with this context.
func PingSourceSource ¶
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
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
func (in *APIVersionKindSelector) DeepCopy() *APIVersionKindSelector
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) GetConditionSet ¶ added in v0.16.0
func (*ApiServerSource) GetConditionSet() apis.ConditionSet
GetConditionSet retrieves the condition set for this resource. Implements the KRShaped interface.
func (*ApiServerSource) GetGroupVersionKind ¶
func (*ApiServerSource) GetGroupVersionKind() schema.GroupVersionKind
GetGroupVersionKind returns the GroupVersionKind.
func (*ApiServerSource) GetStatus ¶ added in v0.16.0
func (a *ApiServerSource) GetStatus() *duckv1.Status
GetStatus retrieves the status of the ApiServerSource . Implements the KRShaped interface.
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 ¶
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) GetTopLevelCondition ¶ added in v0.16.0
func (s *ApiServerSourceStatus) GetTopLevelCondition() *apis.Condition
GetTopLevelCondition returns the top level condition.
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) GetConditionSet ¶ added in v0.16.0
func (*ContainerSource) GetConditionSet() apis.ConditionSet
GetConditionSet retrieves the condition set for this resource. Implements the KRShaped interface.
func (*ContainerSource) GetGroupVersionKind ¶ added in v0.14.0
func (*ContainerSource) GetGroupVersionKind() schema.GroupVersionKind
GetGroupVersionKind returns the GroupVersionKind.
func (*ContainerSource) GetStatus ¶ added in v0.16.0
func (c *ContainerSource) GetStatus() *duckv1.Status
GetStatus retrieves the status of the ContainerSource. Implements the KRShaped interface.
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
func (in *ContainerSourceStatus) DeepCopy() *ContainerSourceStatus
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
func (s *ContainerSourceStatus) GetCondition(t apis.ConditionType) *apis.Condition
GetCondition returns the condition currently associated with the given type, or nil.
func (*ContainerSourceStatus) GetTopLevelCondition ¶ added in v0.16.0
func (s *ContainerSourceStatus) GetTopLevelCondition() *apis.Condition
GetTopLevelCondition returns the top level condition.
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) GetConditionSet ¶ added in v0.16.0
func (*PingSource) GetConditionSet() apis.ConditionSet
GetConditionSet retrieves the condition set for this resource. Implements the KRShaped interface.
func (*PingSource) GetGroupVersionKind ¶
func (s *PingSource) GetGroupVersionKind() schema.GroupVersionKind
GetGroupVersionKind returns the GroupVersionKind.
func (*PingSource) GetStatus ¶ added in v0.16.0
func (p *PingSource) GetStatus() *duckv1.Status
GetStatus retrieves the status of the PingSource. Implements the KRShaped interface.
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) GetConditionSet ¶ added in v0.16.0
func (*SinkBinding) GetConditionSet() apis.ConditionSet
GetConditionSet retrieves the condition set for this resource. Implements the KRShaped interface.
func (*SinkBinding) GetGroupVersionKind ¶
func (*SinkBinding) GetGroupVersionKind() schema.GroupVersionKind
GetGroupVersionKind returns the GroupVersionKind.
func (*SinkBinding) GetStatus ¶ added in v0.16.0
func (s *SinkBinding) GetStatus() *duckv1.Status
GetStatus retrieves the status of the SinkBinding. Implements the KRShaped interface.
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) 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
Source Files ¶
- apiserver_conversion.go
- apiserver_defaults.go
- apiserver_lifecycle.go
- apiserver_types.go
- apiserver_validation.go
- container_defaults.go
- container_lifecycle.go
- container_types.go
- container_validation.go
- doc.go
- ping_conversion.go
- ping_defaults.go
- ping_lifecycle.go
- ping_types.go
- ping_validation.go
- register.go
- sinkbinding_context.go
- sinkbinding_conversion.go
- sinkbinding_defaults.go
- sinkbinding_lifecycle.go
- sinkbinding_types.go
- sinkbinding_validation.go
- test_helper.go
- zz_generated.deepcopy.go