v1alpha1

package
v0.0.0-...-cb3e436 Latest Latest
Warning

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

 Go to latest Published: Sep 18, 2019 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Overview

+k8s:deepcopy-gen=package +groupName=sources.knative.dev

Package v1alpha1 implements Version 1, Alpha 1 of the sources API.

Index

Constants

View Source 
const (
	CronJobSourceConditionReady = apis.ConditionReady

	// CronJobSourceConditionCronJobCreated becomes true when the underlying CronJob exists.
	CronJobSourceConditionCronJobCreated apis.ConditionType = "CronJobCreated"
)
View Source 
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"
)
View Source 
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
)
View Source 
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

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

SchemeGroupVersion is group version used to register these objects

Functions

func Kind 

func Kind(kind string) schema.GroupKind

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

func Resource 

func Resource(resource string) schema.GroupResource

Resource takes an unqualified resource and returns a Group qualified GroupResource

Types

type 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 

func (in *JobSource) DeepCopy() *JobSource

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

func (*JobSource) DeepCopyInto 

func (in *JobSource) DeepCopyInto(out *JobSource)

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

func (*JobSource) DeepCopyObject 

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

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 

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

SetDefaults implements apis.Defaultable

func (*JobSource) Validate 

func (js *JobSource) Validate(ctx context.Context) *apis.FieldError

Validate implements apis.Validatable

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 

type NOPBinding corev1.Binding

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 

type SourcePod corev1.Pod

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 

func (in *SourcePod) DeepCopy() *SourcePod

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

func (*SourcePod) DeepCopyInto 

func (in *SourcePod) DeepCopyInto(out *SourcePod)

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

func (*SourcePod) DeepCopyObject 

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

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

func (*SourcePod) SetDefaults 

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

func (*SourcePod) Validate 

func (s *SourcePod) Validate(context.Context) *apis.FieldError

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

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.