Documentation
¶
Overview ¶
Package v1 is the v1 version of the API.
Index ¶
Constants ¶
This section is empty.
Variables ¶
var ( // SchemeBuilder initializes a scheme builder SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes) // AddToScheme is a global function that registers this API group & version to a scheme AddToScheme = SchemeBuilder.AddToScheme )
var SchemeGroupVersion = schema.GroupVersion{Group: streaming.GroupName, Version: "v1"}
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 MockStreamDefinition ¶
type MockStreamDefinition struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
Spec MockStreamDefinitionSpec `json:"spec,omitempty"`
Status MockStreamDefinitionStatus `json:"status,omitempty"`
}
MockStreamDefinition is a mock implementation of the StreamDefinition for testing purposes. +genclient +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object +kubebuilder:subresource:status +kubebuilder:object:root=true
func (*MockStreamDefinition) DeepCopy ¶
func (in *MockStreamDefinition) DeepCopy() *MockStreamDefinition
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MockStreamDefinition.
func (*MockStreamDefinition) DeepCopyInto ¶
func (in *MockStreamDefinition) DeepCopyInto(out *MockStreamDefinition)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*MockStreamDefinition) DeepCopyObject ¶
func (in *MockStreamDefinition) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type MockStreamDefinitionList ¶
type MockStreamDefinitionList struct {
metav1.TypeMeta `json:",inline"`
metav1.ListMeta `json:"metadata,omitempty"`
Items []MockStreamDefinition `json:"items"`
}
MockStreamDefinitionList contains a list of MockStreamDefinition resources +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
func (*MockStreamDefinitionList) DeepCopy ¶
func (in *MockStreamDefinitionList) DeepCopy() *MockStreamDefinitionList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MockStreamDefinitionList.
func (*MockStreamDefinitionList) DeepCopyInto ¶
func (in *MockStreamDefinitionList) DeepCopyInto(out *MockStreamDefinitionList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*MockStreamDefinitionList) DeepCopyObject ¶
func (in *MockStreamDefinitionList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type MockStreamDefinitionSpec ¶
type MockStreamDefinitionSpec struct {
// Source represents the source of the stream.
Source string `json:"source"`
// Destination represents the destination of the stream.
Destination string `json:"destination"`
// Suspended indicates whether the stream is suspended.
Suspended bool `json:"suspended"`
// JobTemplateRef represents a reference to the job template.
JobTemplateRef v1.ObjectReference `json:"jobTemplateRef"`
// BackfillJobTemplateRef represents a reference to the job template.
BackfillJobTemplateRef v1.ObjectReference `json:"backfillJobTemplateRef"`
// SecretRef
SecretRef v1.LocalObjectReference `json:"secretRef,omitempty"`
}
MockStreamDefinitionSpec is a mock implementation of the StreamDefinitionSpec for testing purposes.
func (*MockStreamDefinitionSpec) DeepCopy ¶
func (in *MockStreamDefinitionSpec) DeepCopy() *MockStreamDefinitionSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MockStreamDefinitionSpec.
func (*MockStreamDefinitionSpec) DeepCopyInto ¶
func (in *MockStreamDefinitionSpec) DeepCopyInto(out *MockStreamDefinitionSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type MockStreamDefinitionStatus ¶
type MockStreamDefinitionStatus struct {
// Phase represents the current phase of the stream.
Phase string `json:"phase"`
// ConfigurationHash represents the hash of the current configuration.
ConfigurationHash string `json:"configurationHash"`
}
func (*MockStreamDefinitionStatus) DeepCopy ¶
func (in *MockStreamDefinitionStatus) DeepCopy() *MockStreamDefinitionStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MockStreamDefinitionStatus.
func (*MockStreamDefinitionStatus) DeepCopyInto ¶
func (in *MockStreamDefinitionStatus) DeepCopyInto(out *MockStreamDefinitionStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
Source Files