Documentation
¶
Overview ¶
Package v1alpha1 contains API Schema definitions for the operator v1alpha1 API group +k8s:deepcopy-gen=package,register +groupName=operator.serverless.openshift.io
Package v1alpha1 contains API Schema definitions for the operator v1alpha1 API group +k8s:deepcopy-gen=package,register +groupName=operator.serverless.openshift.io
Index ¶
- Variables
- type Channel
- type KnativeKafka
- type KnativeKafkaList
- type KnativeKafkaSpec
- type KnativeKafkaStatus
- func (in *KnativeKafkaStatus) DeepCopy() *KnativeKafkaStatus
- func (in *KnativeKafkaStatus) DeepCopyInto(out *KnativeKafkaStatus)
- func (is *KnativeKafkaStatus) InitializeConditions()
- func (is *KnativeKafkaStatus) IsReady() bool
- func (is *KnativeKafkaStatus) MarkInstallFailed(msg string)
- func (is *KnativeKafkaStatus) MarkInstallSucceeded()
- type Source
Constants ¶
This section is empty.
Variables ¶
var ( // SchemeGroupVersion is group version used to register these objects SchemeGroupVersion = schema.GroupVersion{Group: "operator.serverless.openshift.io", Version: "v1alpha1"} // SchemeBuilder is used to add go types to the GroupVersionKind scheme SchemeBuilder = &scheme.Builder{GroupVersion: SchemeGroupVersion} )
Functions ¶
This section is empty.
Types ¶
type Channel ¶
type Channel struct {
// Enabled defines if the KafkaChannel installation is enabled
Enabled bool `json:"enabled"`
// BootstrapServers is comma separated string of bootstrapservers that the
// KafkaChannels will use
// +optional
BootstrapServers string `json:"bootstrapServers"`
}
Channel allows configuration for KafkaSource installation
func (*Channel) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Channel.
func (*Channel) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type KnativeKafka ¶
type KnativeKafka struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
Spec KnativeKafkaSpec `json:"spec,omitempty"`
Status KnativeKafkaStatus `json:"status,omitempty"`
}
KnativeKafka is the Schema for the knativekafkas API +k8s:openapi-gen=true +kubebuilder:subresource:status
func (*KnativeKafka) DeepCopy ¶
func (in *KnativeKafka) DeepCopy() *KnativeKafka
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KnativeKafka.
func (*KnativeKafka) DeepCopyInto ¶
func (in *KnativeKafka) DeepCopyInto(out *KnativeKafka)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*KnativeKafka) DeepCopyObject ¶
func (in *KnativeKafka) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type KnativeKafkaList ¶
type KnativeKafkaList struct {
metav1.TypeMeta `json:",inline"`
metav1.ListMeta `json:"metadata,omitempty"`
Items []KnativeKafka `json:"items"`
}
KnativeKafkaList contains a list of KnativeKafka
func (*KnativeKafkaList) DeepCopy ¶
func (in *KnativeKafkaList) DeepCopy() *KnativeKafkaList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KnativeKafkaList.
func (*KnativeKafkaList) DeepCopyInto ¶
func (in *KnativeKafkaList) DeepCopyInto(out *KnativeKafkaList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*KnativeKafkaList) DeepCopyObject ¶
func (in *KnativeKafkaList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type KnativeKafkaSpec ¶
type KnativeKafkaSpec struct {
// Allows configuration for KafkaSource installation
// +optional
Source Source `json:"source,omitempty"`
// Allows configuration for KafkaChannel installation
// +optional
Channel Channel `json:"channel,omitempty"`
}
KnativeKafkaSpec defines the desired state of KnativeKafka +k8s:openapi-gen=true
func (*KnativeKafkaSpec) DeepCopy ¶
func (in *KnativeKafkaSpec) DeepCopy() *KnativeKafkaSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KnativeKafkaSpec.
func (*KnativeKafkaSpec) DeepCopyInto ¶
func (in *KnativeKafkaSpec) DeepCopyInto(out *KnativeKafkaSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type KnativeKafkaStatus ¶
type KnativeKafkaStatus struct {
duckv1.Status `json:",inline"`
// The version of the installed release
// +optional
Version string `json:"version,omitempty"`
}
KnativeKafkaStatus defines the observed state of KnativeKafka +k8s:openapi-gen=true
func (*KnativeKafkaStatus) DeepCopy ¶
func (in *KnativeKafkaStatus) DeepCopy() *KnativeKafkaStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KnativeKafkaStatus.
func (*KnativeKafkaStatus) DeepCopyInto ¶
func (in *KnativeKafkaStatus) DeepCopyInto(out *KnativeKafkaStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*KnativeKafkaStatus) InitializeConditions ¶
func (is *KnativeKafkaStatus) InitializeConditions()
InitializeConditions initializes conditions of an KnativeKafkaStatus
func (*KnativeKafkaStatus) IsReady ¶
func (is *KnativeKafkaStatus) IsReady() bool
IsReady looks at the conditions returns true if they are all true.
func (*KnativeKafkaStatus) MarkInstallFailed ¶
func (is *KnativeKafkaStatus) MarkInstallFailed(msg string)
MarkInstallFailed marks the InstallationSucceeded status as false with the given message.
func (*KnativeKafkaStatus) MarkInstallSucceeded ¶
func (is *KnativeKafkaStatus) MarkInstallSucceeded()
MarkInstallSucceeded marks the InstallationSucceeded status as true.
type Source ¶
type Source struct {
// Enabled defines if the KafkaSource installation is enabled
Enabled bool `json:"enabled"`
}
Source allows configuration for KafkaSource installation
func (*Source) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Source.
func (*Source) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.