Documentation
¶
Overview ¶
Package v1 is the v1 version of the API.
Index ¶
- Variables
- func Kind(kind string) schema.GroupKind
- func Resource(resource string) schema.GroupResource
- type BatchJobBackend
- type CronJobBackend
- type ExecutionSettings
- type MockStreamDefinition
- type MockStreamDefinitionList
- type MockStreamDefinitionSpec
- type MockStreamDefinitionStatus
- type StreamingBackend
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: "v2"}
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 BatchJobBackend ¶
type BatchJobBackend struct {
// 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,omitempty"`
}
BatchJobBackend represents the backend configuration for real-time streaming, including the change capture interval and a reference to the job template.
func (*BatchJobBackend) DeepCopy ¶
func (in *BatchJobBackend) DeepCopy() *BatchJobBackend
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BatchJobBackend.
func (*BatchJobBackend) DeepCopyInto ¶
func (in *BatchJobBackend) DeepCopyInto(out *BatchJobBackend)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type CronJobBackend ¶
type CronJobBackend struct {
// Schedule represents the cron schedule for batch processing.
Schedule string `json:"schedule"`
// JobTemplateRef represents a reference to the job template.
JobTemplateRef v1.ObjectReference `json:"jobTemplateRef"`
}
CronJobBackend represents the backend configuration for batch processing, including the cron schedule and a reference to the job template.
func (*CronJobBackend) DeepCopy ¶
func (in *CronJobBackend) DeepCopy() *CronJobBackend
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CronJobBackend.
func (*CronJobBackend) DeepCopyInto ¶
func (in *CronJobBackend) DeepCopyInto(out *CronJobBackend)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ExecutionSettings ¶
type ExecutionSettings struct {
// LayoutVersion represents the layout version of the execution settings.
LayoutVersion string `json:"layoutVersion"`
// Suspended indicates whether the stream is suspended.
Suspended bool `json:"suspended"`
// BackfillJobTemplateRef represents a reference to the job template.
BackfillJobTemplateRef *v1.ObjectReference `json:"backfillJobTemplateRef,omitempty"`
// StreamingBackend represents the backend configuration for streaming.
StreamingBackend StreamingBackend `json:"streamingBackend"`
}
ExecutionSettings represents the execution settings for a stream, including suspension status and backend configuration.
func (*ExecutionSettings) DeepCopy ¶
func (in *ExecutionSettings) DeepCopy() *ExecutionSettings
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ExecutionSettings.
func (*ExecutionSettings) DeepCopyInto ¶
func (in *ExecutionSettings) DeepCopyInto(out *ExecutionSettings)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
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 {
// Execution represents the execution settings of the stream.
ExecutionSettings ExecutionSettings `json:"execution"`
// Source represents the source of the stream.
Source string `json:"source"`
// Destination represents the destination of the stream.
Destination string `json:"destination"`
// 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.
type StreamingBackend ¶
type StreamingBackend struct {
// BatchJobBackend represents the backend configuration for real-time streaming.
BatchJobBackend *BatchJobBackend `json:"changeCapture,omitempty"`
// CronJobBackend represents the backend configuration for batch processing.
CronJobBackend *CronJobBackend `json:"batch,omitempty"`
}
StreamingBackend represents the backend configuration for streaming, including both real-time and batch processing options.
func (*StreamingBackend) DeepCopy ¶
func (in *StreamingBackend) DeepCopy() *StreamingBackend
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamingBackend.
func (*StreamingBackend) DeepCopyInto ¶
func (in *StreamingBackend) DeepCopyInto(out *StreamingBackend)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
Source Files