Documentation ¶
Overview ¶
+k8s:deepcopy-gen=package +groupName=sources.knative.dev
Package v1alpha1 implements Version 1, Alpha 1 of the sources API.
Index ¶
- Constants
- Variables
- func Kind(kind string) schema.GroupKind
- func Resource(resource string) schema.GroupResource
- type BaseSourceSpec
- type BaseSourceStatus
- type CronJobSource
- func (in *CronJobSource) DeepCopy() *CronJobSource
- func (in *CronJobSource) DeepCopyInto(out *CronJobSource)
- func (in *CronJobSource) DeepCopyObject() runtime.Object
- func (js *CronJobSource) GetGroupVersionKind() schema.GroupVersionKind
- func (s *CronJobSource) GetSink() apisv1alpha1.Destination
- func (s *CronJobSource) GetStatus() SourceStatus
- func (s *CronJobSource) SetDefaults(ctx context.Context)
- func (s *CronJobSource) Validate(ctx context.Context) *apis.FieldError
- type CronJobSourceList
- type CronJobSourceSpec
- type CronJobSourceStatus
- func (in *CronJobSourceStatus) DeepCopy() *CronJobSourceStatus
- func (in *CronJobSourceStatus) DeepCopyInto(out *CronJobSourceStatus)
- func (s *CronJobSourceStatus) InitializeConditions()
- func (s *CronJobSourceStatus) MarkCronJobCreated()
- func (s *CronJobSourceStatus) MarkNoCronJob(reason, msgFmt string, messageA ...interface{})
- func (s *CronJobSourceStatus) MarkNoSink(reason, messageFormat string, messageA ...interface{})
- func (s *CronJobSourceStatus) MarkSink(uri string)
- func (s *CronJobSourceStatus) PropagateCronJobStatus(from *batchv1beta1.CronJobStatus)
- func (s *CronJobSourceStatus) Ready() bool
- type JobSource
- func (in *JobSource) DeepCopy() *JobSource
- func (in *JobSource) DeepCopyInto(out *JobSource)
- func (in *JobSource) DeepCopyObject() runtime.Object
- func (js *JobSource) GetGroupVersionKind() schema.GroupVersionKind
- func (s *JobSource) GetSink() apisv1alpha1.Destination
- func (s *JobSource) GetStatus() SourceStatus
- func (s *JobSource) SetDefaults(ctx context.Context)
- func (js *JobSource) Validate(ctx context.Context) *apis.FieldError
- type JobSourceList
- type JobSourceSpec
- type JobSourceStatus
- func (in *JobSourceStatus) DeepCopy() *JobSourceStatus
- func (in *JobSourceStatus) DeepCopyInto(out *JobSourceStatus)
- func (s *JobSourceStatus) InitializeConditions()
- func (s *JobSourceStatus) IsJobRunning() bool
- func (s *JobSourceStatus) JobSucceeded() bool
- func (s *JobSourceStatus) MarkJobFailed(reason, messageFormat string, messageA ...interface{})
- func (s *JobSourceStatus) MarkJobRunning(messageFormat string, messageA ...interface{})
- func (s *JobSourceStatus) MarkJobSucceeded()
- func (s *JobSourceStatus) MarkNoSink(reason, messageFormat string, messageA ...interface{})
- func (s *JobSourceStatus) MarkSink(uri string)
- func (s *JobSourceStatus) Succeeded() bool
- type NOPBinding
- type OutputFormatType
- type ServiceSource
- func (in *ServiceSource) DeepCopy() *ServiceSource
- func (in *ServiceSource) DeepCopyInto(out *ServiceSource)
- func (in *ServiceSource) DeepCopyObject() runtime.Object
- func (js *ServiceSource) GetGroupVersionKind() schema.GroupVersionKind
- func (s *ServiceSource) GetSink() apisv1alpha1.Destination
- func (s *ServiceSource) GetStatus() SourceStatus
- func (s *ServiceSource) SetDefaults(ctx context.Context)
- func (s *ServiceSource) Validate(ctx context.Context) *apis.FieldError
- type ServiceSourceList
- type ServiceSourceSpec
- type ServiceSourceStatus
- func (in *ServiceSourceStatus) DeepCopy() *ServiceSourceStatus
- func (in *ServiceSourceStatus) DeepCopyInto(out *ServiceSourceStatus)
- func (s *ServiceSourceStatus) InitializeConditions()
- func (s *ServiceSourceStatus) MarkAddress(addr *duckv1beta1.Addressable)
- func (s *ServiceSourceStatus) MarkNoAddress()
- func (s *ServiceSourceStatus) MarkNoSink(reason, messageFormat string, messageA ...interface{})
- func (s *ServiceSourceStatus) MarkNoURL()
- func (s *ServiceSourceStatus) MarkServiceDeploying()
- func (s *ServiceSourceStatus) MarkServiceNotReady(reason, messageFormat string, messageA ...interface{})
- func (s *ServiceSourceStatus) MarkServiceReady()
- func (s *ServiceSourceStatus) MarkServiceReadyUnknown(reason string, messageFormat string, messageA ...interface{})
- func (s *ServiceSourceStatus) MarkSink(uri string)
- func (s *ServiceSourceStatus) MarkURL(url *apis.URL)
- func (s *ServiceSourceStatus) Ready() bool
- type Source
- type SourcePod
- type SourceStatus
Constants ¶
const ( CronJobSourceConditionReady = apis.ConditionReady // CronJobSourceConditionCronJobCreated becomes true when the underlying CronJob exists. CronJobSourceConditionCronJobCreated apis.ConditionType = "CronJobCreated" )
const ( // JobSourceConditionSucceeded is set when the revision starts to // materialize runtime resources and becomes true when the Job finishes // successfully. JobSourceConditionSucceeded = apis.ConditionSucceeded // JobSourceConditionJobSucceeded becomes true when the underlying Job // succeeds. JobSourceConditionJobSucceeded apis.ConditionType = "JobSucceeded" )
const ( // ServiceSourceConditionServiceReady is set to true when the underlying Knative service is ready // to receive traffic. ServiceSourceConditionServiceReady apis.ConditionType = "ServiceReady" // ServiceSourceConditionReady is the happy condition for a service source, true if there is // a ready service with a properly configured sink. ServiceSourceConditionReady = apis.ConditionReady )
const ( // SourceConditionSinkProvided represents the condition that a sink with a URI has been // provided to the source. All sources will use this condition and set it true when the // source is configured with a sink. SourceConditionSinkProvided apis.ConditionType = "SinkProvided" )
Variables ¶
var ( SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes) AddToScheme = SchemeBuilder.AddToScheme )
var SchemeGroupVersion = schema.GroupVersion{Group: sources.GroupName, Version: "v1alpha1"}
SchemeGroupVersion is group version used to register these objects
Functions ¶
func Resource ¶
func Resource(resource string) schema.GroupResource
Resource takes an unqualified resource and returns a Group qualified GroupResource
Types ¶
type BaseSourceSpec ¶
type BaseSourceSpec struct { // Sink is a reference to an object that will resolve to a URI to send events to. // +required Sink apisv1alpha1.Destination `json:"sink,omitempty"` // OutputFormat describes the CloudEvent output format the source should send events in. // All formats are over HTTP. // Defaults to binary. // +optional OutputFormat OutputFormatType `json:"outputFormat,omitempty"` // CloudEventOverrides defines overrides to control the output format and // modifications of the event sent to the sink. // +optional // TODO(n3wscott) This is a stub; currently unused. CloudEventOverrides *duckv1beta1.CloudEventOverrides `json:"ceOverrides,omitempty"` }
BaseSourceSpec provides spec components that all sources share. It does not include any PodSpecable helpers.
func (*BaseSourceSpec) DeepCopy ¶
func (in *BaseSourceSpec) DeepCopy() *BaseSourceSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BaseSourceSpec.
func (*BaseSourceSpec) DeepCopyInto ¶
func (in *BaseSourceSpec) DeepCopyInto(out *BaseSourceSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*BaseSourceSpec) SetDefaults ¶
func (s *BaseSourceSpec) SetDefaults(ctx context.Context)
BaseSourceSpec implements apis.Defaultable. Currently, only the output format can be defaulted.
func (*BaseSourceSpec) Validate ¶
func (s *BaseSourceSpec) Validate(ctx context.Context) *apis.FieldError
Validate implements apis.Validatable
type BaseSourceStatus ¶
type BaseSourceStatus struct { duckv1beta1.Status `json:",inline"` // SinkURI is the current sink URI configured for the source. // +optional SinkURI string `json:"sinkUri,omitempty"` }
BaseSourceStatus holds status information that sources need. This base will not necessarily need to be extended.
func (*BaseSourceStatus) DeepCopy ¶
func (in *BaseSourceStatus) DeepCopy() *BaseSourceStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BaseSourceStatus.
func (*BaseSourceStatus) DeepCopyInto ¶
func (in *BaseSourceStatus) DeepCopyInto(out *BaseSourceStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*BaseSourceStatus) MarkNoSink ¶
func (s *BaseSourceStatus) MarkNoSink(mgr apis.ConditionManager, reason, messageFormat string, messageA ...interface{})
MarkNoSink sets the condition that the source does not have a sink configured. TODO(spencer-p) This method adds almost nothing -- would be nice to have MarkSinkInvalid, MarkSinkNotResolved, etc
func (*BaseSourceStatus) MarkSink ¶
func (s *BaseSourceStatus) MarkSink(mgr apis.ConditionManager, uri string)
MarkSink sets the conditions that the source has received a sink URI.
type CronJobSource ¶
type CronJobSource struct { metav1.TypeMeta `json:",inline"` // +optional metav1.ObjectMeta `json:"metadata,omitempty"` // Spec holds the desired state of the CronJobSource (from the client). // +required Spec CronJobSourceSpec `json:"spec,omitempty"` // Status communicates the observed state of the CronJobSource (from the controller). // +optional Status CronJobSourceStatus `json:"status,omitempty"` }
CronJobSource is a CronJob with a Sink.
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 (js *CronJobSource) GetGroupVersionKind() schema.GroupVersionKind
GetGroupVersionKind implements kmeta.OwnerRefable
func (*CronJobSource) GetSink ¶
func (s *CronJobSource) GetSink() apisv1alpha1.Destination
func (*CronJobSource) GetStatus ¶
func (s *CronJobSource) GetStatus() SourceStatus
func (*CronJobSource) SetDefaults ¶
func (s *CronJobSource) SetDefaults(ctx context.Context)
SetDefaults implements apis.Defaultable
func (*CronJobSource) Validate ¶
func (s *CronJobSource) Validate(ctx context.Context) *apis.FieldError
Validate implements apis.Validatable
type CronJobSourceList ¶
type CronJobSourceList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata"` Items []CronJobSource `json:"items"` }
CronJobSourceList is a list of CronJobSource resources
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 { BaseSourceSpec `json:",inline"` batchv1beta1.CronJobSpec `json:",inline"` }
CronJobSourceSpec holds the desired state of the CronJobSource (from the client).
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.
type CronJobSourceStatus ¶
type CronJobSourceStatus struct { BaseSourceStatus `json:",inline"` batchv1beta1.CronJobStatus `json:",inline"` // ActiveCount stores the length of the CronJobStatus.Active array. // This allows the controller to compute the length which can then be easily // parsed by kubectl, etc. K8s has special sauce to do this automatically // when getting resources, but we have to do it manually. ActiveCount int `json:"activeCount"` }
CronJobSourceStatus communicates the observed state of the CronJobSource (from the controller).
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) InitializeConditions ¶
func (s *CronJobSourceStatus) InitializeConditions()
func (*CronJobSourceStatus) MarkCronJobCreated ¶
func (s *CronJobSourceStatus) MarkCronJobCreated()
MarkCronJobCreated sets the condition that the CronJobSource owns a CronJob.
func (*CronJobSourceStatus) MarkNoCronJob ¶
func (s *CronJobSourceStatus) MarkNoCronJob(reason, msgFmt string, messageA ...interface{})
MarkCronJobCreated sets the condition that the CronJobSource does not yet have a CronJob.
func (*CronJobSourceStatus) MarkNoSink ¶
func (s *CronJobSourceStatus) MarkNoSink(reason, messageFormat string, messageA ...interface{})
func (*CronJobSourceStatus) MarkSink ¶
func (s *CronJobSourceStatus) MarkSink(uri string)
MarkSink sets the conditions that the source has received a sink URI.
func (*CronJobSourceStatus) PropagateCronJobStatus ¶
func (s *CronJobSourceStatus) PropagateCronJobStatus(from *batchv1beta1.CronJobStatus)
func (*CronJobSourceStatus) Ready ¶
func (s *CronJobSourceStatus) Ready() bool
Ready returns true if the CronJobSource has a sink and a CronJob.
type JobSource ¶
type JobSource struct { metav1.TypeMeta `json:",inline"` // +optional metav1.ObjectMeta `json:"metadata,omitempty"` // Spec holds the desired state of the JobSource (from the client). // +required Spec JobSourceSpec `json:"spec,omitempty"` // Status communicates the observed state of the JobSource (from the controller). // +optional Status JobSourceStatus `json:"status,omitempty"` }
JobSource is a Knative abstraction that encapsulates the interface by which Knative components express a desire to have a particular image cached.
func (*JobSource) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new JobSource.
func (*JobSource) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*JobSource) DeepCopyObject ¶
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*JobSource) GetGroupVersionKind ¶
func (js *JobSource) GetGroupVersionKind() schema.GroupVersionKind
GetGroupVersionKind implements kmeta.OwnerRefable
func (*JobSource) GetSink ¶
func (s *JobSource) GetSink() apisv1alpha1.Destination
func (*JobSource) GetStatus ¶
func (s *JobSource) GetStatus() SourceStatus
func (*JobSource) SetDefaults ¶
SetDefaults implements apis.Defaultable
type JobSourceList ¶
type JobSourceList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata"` Items []JobSource `json:"items"` }
JobSourceList is a list of JobSource resources
func (*JobSourceList) DeepCopy ¶
func (in *JobSourceList) DeepCopy() *JobSourceList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new JobSourceList.
func (*JobSourceList) DeepCopyInto ¶
func (in *JobSourceList) DeepCopyInto(out *JobSourceList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*JobSourceList) DeepCopyObject ¶
func (in *JobSourceList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type JobSourceSpec ¶
type JobSourceSpec struct { BaseSourceSpec `json:",inline"` batchv1.JobSpec `json:",inline"` }
JobSourceSpec holds the desired state of the JobSource (from the client).
func (*JobSourceSpec) DeepCopy ¶
func (in *JobSourceSpec) DeepCopy() *JobSourceSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new JobSourceSpec.
func (*JobSourceSpec) DeepCopyInto ¶
func (in *JobSourceSpec) DeepCopyInto(out *JobSourceSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type JobSourceStatus ¶
type JobSourceStatus struct {
BaseSourceStatus `json:",inline"`
}
JobSourceStatus communicates the observed state of the JobSource (from the controller).
func (*JobSourceStatus) DeepCopy ¶
func (in *JobSourceStatus) DeepCopy() *JobSourceStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new JobSourceStatus.
func (*JobSourceStatus) DeepCopyInto ¶
func (in *JobSourceStatus) DeepCopyInto(out *JobSourceStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*JobSourceStatus) InitializeConditions ¶
func (s *JobSourceStatus) InitializeConditions()
func (*JobSourceStatus) IsJobRunning ¶
func (s *JobSourceStatus) IsJobRunning() bool
IsJobRunning returns true if the job is currently running.
func (*JobSourceStatus) JobSucceeded ¶
func (s *JobSourceStatus) JobSucceeded() bool
JobSucceeded returns true if the underlying Job has succeeded.
func (*JobSourceStatus) MarkJobFailed ¶
func (s *JobSourceStatus) MarkJobFailed(reason, messageFormat string, messageA ...interface{})
MarkJobFailed sets the condition that the underlying Job failed.
func (*JobSourceStatus) MarkJobRunning ¶
func (s *JobSourceStatus) MarkJobRunning(messageFormat string, messageA ...interface{})
MarkJobRunning sets the condition of the underlying Job's success to unknown.
func (*JobSourceStatus) MarkJobSucceeded ¶
func (s *JobSourceStatus) MarkJobSucceeded()
MarkJobSucceeded sets the condition that the underlying Job succeeded.
func (*JobSourceStatus) MarkNoSink ¶
func (s *JobSourceStatus) MarkNoSink(reason, messageFormat string, messageA ...interface{})
func (*JobSourceStatus) MarkSink ¶
func (s *JobSourceStatus) MarkSink(uri string)
MarkSink sets the conditions that the source has received a sink URI.
func (*JobSourceStatus) Succeeded ¶
func (s *JobSourceStatus) Succeeded() bool
Succeeded returns true if the JobSource has succeeded.
type NOPBinding ¶
Pods have Binding subresources that we have to pretend to handle. +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
func (*NOPBinding) DeepCopy ¶
func (in *NOPBinding) DeepCopy() *NOPBinding
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NOPBinding.
func (*NOPBinding) DeepCopyInto ¶
func (in *NOPBinding) DeepCopyInto(out *NOPBinding)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*NOPBinding) DeepCopyObject ¶
func (in *NOPBinding) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*NOPBinding) SetDefaults ¶
func (_ *NOPBinding) SetDefaults(ctx context.Context)
func (*NOPBinding) Validate ¶
func (_ *NOPBinding) Validate(context.Context) *apis.FieldError
type OutputFormatType ¶
type OutputFormatType string
OutputFormatType describes the data format that a Source is expected to output when it sends Cloud Events.
const ( // Sources are required to support structured and binary output formats. // Any other format type is invalid. OutputFormatStructured OutputFormatType = "structured" OutputFormatBinary = "binary" )
func (OutputFormatType) Validate ¶
func (o OutputFormatType) Validate(ctx context.Context) *apis.FieldError
Validate ensures that the OutputFormatType is one of the two allowed types. It assumes that its field is "outputFormat".
type ServiceSource ¶
type ServiceSource struct { metav1.TypeMeta `json:",inline"` // +optional metav1.ObjectMeta `json:"metadata,omitempty"` // Spec holds the desired state of the ServiceSource (from the client). // +required Spec ServiceSourceSpec `json:"spec,omitempty"` // Status communicates the observed state of the ServiceSource (from the controller). // +optional Status ServiceSourceStatus `json:"status,omitempty"` }
ServiceSource is a Knative abstraction that encapsulates the interface by which Knative components express a desire to have a particular image cached.
func (*ServiceSource) DeepCopy ¶
func (in *ServiceSource) DeepCopy() *ServiceSource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ServiceSource.
func (*ServiceSource) DeepCopyInto ¶
func (in *ServiceSource) DeepCopyInto(out *ServiceSource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ServiceSource) DeepCopyObject ¶
func (in *ServiceSource) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*ServiceSource) GetGroupVersionKind ¶
func (js *ServiceSource) GetGroupVersionKind() schema.GroupVersionKind
GetGroupVersionKind implements kmeta.OwnerRefable
func (*ServiceSource) GetSink ¶
func (s *ServiceSource) GetSink() apisv1alpha1.Destination
func (*ServiceSource) GetStatus ¶
func (s *ServiceSource) GetStatus() SourceStatus
func (*ServiceSource) SetDefaults ¶
func (s *ServiceSource) SetDefaults(ctx context.Context)
SetDefaults implements apis.Defaultable
func (*ServiceSource) Validate ¶
func (s *ServiceSource) Validate(ctx context.Context) *apis.FieldError
Validate implements apis.Validatable
type ServiceSourceList ¶
type ServiceSourceList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata"` Items []ServiceSource `json:"items"` }
ServiceSourceList is a list of ServiceSource resources
func (*ServiceSourceList) DeepCopy ¶
func (in *ServiceSourceList) DeepCopy() *ServiceSourceList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ServiceSourceList.
func (*ServiceSourceList) DeepCopyInto ¶
func (in *ServiceSourceList) DeepCopyInto(out *ServiceSourceList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ServiceSourceList) DeepCopyObject ¶
func (in *ServiceSourceList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type ServiceSourceSpec ¶
type ServiceSourceSpec struct { BaseSourceSpec `json:",inline"` servingv1beta1.ServiceSpec `json:",inline"` }
ServiceSourceSpec holds the desired state of the ServiceSource (from the client).
func (*ServiceSourceSpec) DeepCopy ¶
func (in *ServiceSourceSpec) DeepCopy() *ServiceSourceSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ServiceSourceSpec.
func (*ServiceSourceSpec) DeepCopyInto ¶
func (in *ServiceSourceSpec) DeepCopyInto(out *ServiceSourceSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ServiceSourceStatus ¶
type ServiceSourceStatus struct { BaseSourceStatus `json:",inline"` // ServiceSource is an AddressableType via inheriting its Service's address status. // This enables the ServiceSource to also be a sink. duckv1beta1.AddressStatus `json:",inline"` // URL is the ServiceSource's pretty/public address. URL *apis.URL `json:"url,omitempty"` }
ServiceSourceStatus communicates the observed state of the ServiceSource (from the controller).
func (*ServiceSourceStatus) DeepCopy ¶
func (in *ServiceSourceStatus) DeepCopy() *ServiceSourceStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ServiceSourceStatus.
func (*ServiceSourceStatus) DeepCopyInto ¶
func (in *ServiceSourceStatus) DeepCopyInto(out *ServiceSourceStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ServiceSourceStatus) InitializeConditions ¶
func (s *ServiceSourceStatus) InitializeConditions()
func (*ServiceSourceStatus) MarkAddress ¶
func (s *ServiceSourceStatus) MarkAddress(addr *duckv1beta1.Addressable)
func (*ServiceSourceStatus) MarkNoAddress ¶
func (s *ServiceSourceStatus) MarkNoAddress()
func (*ServiceSourceStatus) MarkNoSink ¶
func (s *ServiceSourceStatus) MarkNoSink(reason, messageFormat string, messageA ...interface{})
func (*ServiceSourceStatus) MarkNoURL ¶
func (s *ServiceSourceStatus) MarkNoURL()
func (*ServiceSourceStatus) MarkServiceDeploying ¶
func (s *ServiceSourceStatus) MarkServiceDeploying()
func (*ServiceSourceStatus) MarkServiceNotReady ¶
func (s *ServiceSourceStatus) MarkServiceNotReady(reason, messageFormat string, messageA ...interface{})
func (*ServiceSourceStatus) MarkServiceReady ¶
func (s *ServiceSourceStatus) MarkServiceReady()
func (*ServiceSourceStatus) MarkServiceReadyUnknown ¶
func (s *ServiceSourceStatus) MarkServiceReadyUnknown(reason string, messageFormat string, messageA ...interface{})
func (*ServiceSourceStatus) MarkSink ¶
func (s *ServiceSourceStatus) MarkSink(uri string)
MarkSink sets the conditions that the source has received a sink URI.
func (*ServiceSourceStatus) MarkURL ¶
func (s *ServiceSourceStatus) MarkURL(url *apis.URL)
func (*ServiceSourceStatus) Ready ¶
func (s *ServiceSourceStatus) Ready() bool
type Source ¶
type Source interface { metav1.Object GetSink() apisv1alpha1.Destination GetStatus() SourceStatus }
Source describes a general source that one can reason about without knowing implementation details.
type SourcePod ¶
SourcePod is an alias for an actual Pod which allows us to put methods on it. +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
func (*SourcePod) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SourcePod.
func (*SourcePod) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*SourcePod) DeepCopyObject ¶
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*SourcePod) SetDefaults ¶
type SourceStatus ¶
type SourceStatus interface { MarkSink(uri string) MarkNoSink(reason, messageFormat string, messageA ...interface{}) }
SourceStatus describes a status that has a sink condition. Sources should have a Status member that satisfies this interface. BaseSourceStatus provides methods to help satisfy this interface.
Source Files ¶
- cronjobsource_defaults.go
- cronjobsource_lifecycle.go
- cronjobsource_types.go
- cronjobsource_validation.go
- doc.go
- jobsource_defaults.go
- jobsource_lifecycle.go
- jobsource_types.go
- jobsource_validation.go
- outputformattype.go
- pod_hack.go
- register.go
- servicesource_defaults.go
- servicesource_lifecycle.go
- servicesource_types.go
- servicesource_validation.go
- source_defaults.go
- source_lifecycle.go
- source_types.go
- source_validation.go
- zz_generated.deepcopy.go