Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ClickhouseKafkaUserConfig ¶
type ClickhouseKafkaUserConfig struct {
// +kubebuilder:validation:MaxItems=100
// Tables to create
Tables []*Tables `groups:"create,update" json:"tables,omitempty"`
}
Integration user config
func (*ClickhouseKafkaUserConfig) DeepCopy ¶
func (in *ClickhouseKafkaUserConfig) DeepCopy() *ClickhouseKafkaUserConfig
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClickhouseKafkaUserConfig.
func (*ClickhouseKafkaUserConfig) DeepCopyInto ¶
func (in *ClickhouseKafkaUserConfig) DeepCopyInto(out *ClickhouseKafkaUserConfig)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Columns ¶
type Columns struct {
// +kubebuilder:validation:MinLength=1
// +kubebuilder:validation:MaxLength=40
// Column name
Name string `groups:"create,update" json:"name"`
// +kubebuilder:validation:MinLength=1
// +kubebuilder:validation:MaxLength=1000
// Column type
Type string `groups:"create,update" json:"type"`
}
Table column
func (*Columns) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Columns.
func (*Columns) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Tables ¶
type Tables struct {
// +kubebuilder:validation:MaxItems=100
// Table columns
Columns []*Columns `groups:"create,update" json:"columns"`
// +kubebuilder:validation:Enum="Avro";"CSV";"JSONAsString";"JSONCompactEachRow";"JSONCompactStringsEachRow";"JSONEachRow";"JSONStringsEachRow";"MsgPack";"TSKV";"TSV";"TabSeparated";"RawBLOB"
// Message data format
DataFormat string `groups:"create,update" json:"data_format"`
// +kubebuilder:validation:MinLength=1
// +kubebuilder:validation:MaxLength=249
// Kafka consumers group
GroupName string `groups:"create,update" json:"group_name"`
// +kubebuilder:validation:MinLength=1
// +kubebuilder:validation:MaxLength=40
// Name of the table
Name string `groups:"create,update" json:"name"`
// +kubebuilder:validation:MaxItems=100
// Kafka topics
Topics []*Topics `groups:"create,update" json:"topics"`
}
Table to create
func (*Tables) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Tables.
func (*Tables) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Topics ¶
type Topics struct {
// +kubebuilder:validation:MinLength=1
// +kubebuilder:validation:MaxLength=249
// Name of the topic
Name string `groups:"create,update" json:"name"`
}
Kafka topic
func (*Topics) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Topics.
func (*Topics) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
Source Files