Documentation
¶
Overview ¶
Package v1alpha1 contains API Schema definitions for the xo v1alpha1 API group +kubebuilder:object:generate=true +groupName=xo.ninetypercent.io
Index ¶
Constants ¶
This section is empty.
Variables ¶
var ( // GroupVersion is group version used to register these objects GroupVersion = schema.GroupVersion{Group: "xo.ninetypercent.io", Version: "v1alpha1"} // SchemeBuilder is used to add go types to the GroupVersionKind scheme SchemeBuilder = &scheme.Builder{GroupVersion: GroupVersion} // AddToScheme adds the types in this group-version to the given scheme. AddToScheme = SchemeBuilder.AddToScheme )
Functions ¶
This section is empty.
Types ¶
type KafkaSchema ¶
type KafkaSchema struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
Spec KafkaSchemaSpec `json:"spec,omitempty"`
Status KafkaSchemaStatus `json:"status,omitempty"`
}
KafkaSchema is the Schema for the kafkaschemas API
func (*KafkaSchema) DeepCopy ¶
func (in *KafkaSchema) DeepCopy() *KafkaSchema
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaSchema.
func (*KafkaSchema) DeepCopyInto ¶
func (in *KafkaSchema) DeepCopyInto(out *KafkaSchema)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*KafkaSchema) DeepCopyObject ¶
func (in *KafkaSchema) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type KafkaSchemaList ¶
type KafkaSchemaList struct {
metav1.TypeMeta `json:",inline"`
metav1.ListMeta `json:"metadata,omitempty"`
Items []KafkaSchema `json:"items"`
}
KafkaSchemaList contains a list of KafkaSchema
func (*KafkaSchemaList) DeepCopy ¶
func (in *KafkaSchemaList) DeepCopy() *KafkaSchemaList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaSchemaList.
func (*KafkaSchemaList) DeepCopyInto ¶
func (in *KafkaSchemaList) DeepCopyInto(out *KafkaSchemaList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*KafkaSchemaList) DeepCopyObject ¶
func (in *KafkaSchemaList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type KafkaSchemaSpec ¶
type KafkaSchemaSpec struct {
// +required
// +kubebuilder:validation:Required
// +kubebuilder:validation:MinLength=3
// +kubebuilder:validation:MaxLength=255
// +kubebuilder:validation:Pattern=`^[a-zA-Z0-9\\._\\-]{1,255}$`
Name string `json:"name"`
// +required
// +kubebuilder:validation:Required
// +kubebuilder:validation:MinLength=2
// +kubebuilder:default={}
Schema string `json:"schema"`
// +optional
// +kubebuilder:validation:Required
// +kubebuilder:validation:Pattern=`^(backward|backward_transitive|forward|forward_transitive|full|full_transitive|none)$`
// +kubebuilder:default=backward
Compatibility string `json:"compatibility,omitempty"`
}
KafkaSchemaSpec defines the desired state of KafkaSchema
func (*KafkaSchemaSpec) DeepCopy ¶
func (in *KafkaSchemaSpec) DeepCopy() *KafkaSchemaSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaSchemaSpec.
func (*KafkaSchemaSpec) DeepCopyInto ¶
func (in *KafkaSchemaSpec) DeepCopyInto(out *KafkaSchemaSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type KafkaSchemaStatus ¶
type KafkaSchemaStatus struct {
// Conditions store the status conditions of the KafkaSchema instances
// +operator-sdk:csv:customresourcedefinitions:type=status
Conditions []metav1.Condition `json:"conditions,omitempty" patchStrategy:"merge" patchMergeKey:"type" protobuf:"bytes,1,rep,name=conditions"`
}
KafkaSchemaStatus defines the observed state of KafkaSchema
func (*KafkaSchemaStatus) DeepCopy ¶
func (in *KafkaSchemaStatus) DeepCopy() *KafkaSchemaStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaSchemaStatus.
func (*KafkaSchemaStatus) DeepCopyInto ¶
func (in *KafkaSchemaStatus) DeepCopyInto(out *KafkaSchemaStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type KafkaTopic ¶
type KafkaTopic struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
Spec KafkaTopicSpec `json:"spec,omitempty"`
Status KafkaTopicStatus `json:"status,omitempty"`
}
KafkaTopic is the Schema for the kafkatopics API
func (*KafkaTopic) DeepCopy ¶
func (in *KafkaTopic) DeepCopy() *KafkaTopic
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaTopic.
func (*KafkaTopic) DeepCopyInto ¶
func (in *KafkaTopic) DeepCopyInto(out *KafkaTopic)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*KafkaTopic) DeepCopyObject ¶
func (in *KafkaTopic) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type KafkaTopicList ¶
type KafkaTopicList struct {
metav1.TypeMeta `json:",inline"`
metav1.ListMeta `json:"metadata,omitempty"`
Items []KafkaTopic `json:"items"`
}
KafkaTopicList contains a list of KafkaTopic
func (*KafkaTopicList) DeepCopy ¶
func (in *KafkaTopicList) DeepCopy() *KafkaTopicList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaTopicList.
func (*KafkaTopicList) DeepCopyInto ¶
func (in *KafkaTopicList) DeepCopyInto(out *KafkaTopicList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*KafkaTopicList) DeepCopyObject ¶
func (in *KafkaTopicList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type KafkaTopicSpec ¶
type KafkaTopicSpec struct {
// +required
// +kubebuilder:validation:Required
// +kubebuilder:validation:MinLength=3
// +kubebuilder:validation:MaxLength=255
// +kubebuilder:validation:Pattern=`^[a-zA-Z0-9\\._\\-]{1,255}$`
Name string `json:"name"`
// +optional
// +kubebuilder:validation:Required
// +kubebuilder:validation:Pattern=`^(delete|compact)$`
// +kubebuilder:default=delete
CleanupPolicy string `json:"cleanuppolicy,omitempty"`
Segment Segment `json:"segment,omitempty"`
// +required
// +kubebuilder:validation:Required
// +kubebuilder:validation:Minimum=1
Partitions uint `json:"partitions"`
// +optional
// +kubebuilder:validation:Required
// +kubebuilder:validation:Minimum=1
// +kubebuilder:default=1
MinInSyncReplicas uint `json:"mininsyncreplicas,omitempty"`
// +optional
// +kubebuilder:default=-1
RetentionHours int `json:"retentionhours,omitempty"`
// +optional
// +kubebuilder:default=-1
RetentionBytes int `json:"retentionbytes,omitempty"`
// +optional
// +kubebuilder:default=1048576
MaxMessageBytes int64 `json:"maxmessagebytes,omitempty"`
// +required
// +kubebuilder:validation:Required
// +kubebuilder:validation:Minimum=1
// +kubebuilder:default=2
Replication uint `json:"replication"`
}
KafkaTopicSpec defines the desired state of KafkaTopic
func (*KafkaTopicSpec) DeepCopy ¶
func (in *KafkaTopicSpec) DeepCopy() *KafkaTopicSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaTopicSpec.
func (*KafkaTopicSpec) DeepCopyInto ¶
func (in *KafkaTopicSpec) DeepCopyInto(out *KafkaTopicSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type KafkaTopicStatus ¶
type KafkaTopicStatus struct {
// Conditions store the status conditions of the KafkaTopic instances
// +operator-sdk:csv:customresourcedefinitions:type=status
Conditions []metav1.Condition `json:"conditions,omitempty" patchStrategy:"merge" patchMergeKey:"type" protobuf:"bytes,1,rep,name=conditions"`
}
KafkaTopicStatus defines the observed state of KafkaTopic
func (*KafkaTopicStatus) DeepCopy ¶
func (in *KafkaTopicStatus) DeepCopy() *KafkaTopicStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaTopicStatus.
func (*KafkaTopicStatus) DeepCopyInto ¶
func (in *KafkaTopicStatus) DeepCopyInto(out *KafkaTopicStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Segment ¶
type Segment struct {
// This configuration controls the segment file size for the log.
// Retention and cleaning is always done a file at a time so a larger segment size
// means fewer files but less granular control over retention.
// +optional
// +kubebuilder:default=0
Bytes uint `json:"bytes,omitempty"`
// This configuration controls the period of time after which Kafka will force the log
// to roll even if the segment file isn't full to ensure that retention can delete or
// compact old data.
// +optional
// +kubebuilder:default=0
MS uint64 `json:"ms,omitempty"`
}
Segment to note Kafka segment size
func (*Segment) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Segment.
func (*Segment) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
Source Files