Documentation ¶
Overview ¶
Package v1beta1 contains API Schema definitions for the datainfra.io v1beta1 API group +kubebuilder:object:generate=true +groupName=datainfra.io
Index ¶
- Variables
- type Auth
- type AuthType
- type DeepStorageConfig
- type DeepStorageSpec
- type ExternalSpec
- type K8sConfig
- type Metadata
- type NodeSpec
- type Pinot
- type PinotList
- type PinotNodeConfig
- type PinotNodeType
- type PinotSchema
- type PinotSchemaList
- type PinotSchemaSpec
- type PinotSchemaStatus
- type PinotSpec
- type PinotStatus
- type PinotTable
- type PinotTableList
- type PinotTableSpec
- type PinotTableStatus
- type PinotTableType
- type PinotTenant
- type PinotTenantList
- type PinotTenantSpec
- type PinotTenantStatus
- type PinotTenantType
- type StorageConfig
- type ZookeeperConfig
- type ZookeeperSpec
Constants ¶
This section is empty.
Variables ¶
var ( // GroupVersion is group version used to register these objects GroupVersion = schema.GroupVersion{Group: "datainfra.io", Version: "v1beta1"} // 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 Auth ¶ added in v0.0.7
type Auth struct { // +required Type AuthType `json:"type"` // +required SecretRef v1.SecretReference `json:"secretRef"` }
func (*Auth) DeepCopy ¶ added in v0.0.7
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Auth.
func (*Auth) DeepCopyInto ¶ added in v0.0.7
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type DeepStorageConfig ¶
type DeepStorageConfig struct { // +optional NodeType PinotNodeType `json:"nodeType"` // +optional Data string `json:"data"` }
func (*DeepStorageConfig) DeepCopy ¶
func (in *DeepStorageConfig) DeepCopy() *DeepStorageConfig
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DeepStorageConfig.
func (*DeepStorageConfig) DeepCopyInto ¶
func (in *DeepStorageConfig) DeepCopyInto(out *DeepStorageConfig)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type DeepStorageSpec ¶
type DeepStorageSpec struct { // +optional Spec []DeepStorageConfig `json:"spec"` }
func (*DeepStorageSpec) DeepCopy ¶
func (in *DeepStorageSpec) DeepCopy() *DeepStorageSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DeepStorageSpec.
func (*DeepStorageSpec) DeepCopyInto ¶
func (in *DeepStorageSpec) DeepCopyInto(out *DeepStorageSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ExternalSpec ¶
type ExternalSpec struct { // +required Zookeeper ZookeeperSpec `json:"zookeeper"` // +optional DeepStorage DeepStorageSpec `json:"deepStorage"` }
func (*ExternalSpec) DeepCopy ¶
func (in *ExternalSpec) DeepCopy() *ExternalSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ExternalSpec.
func (*ExternalSpec) DeepCopyInto ¶
func (in *ExternalSpec) DeepCopyInto(out *ExternalSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type K8sConfig ¶
type K8sConfig struct { // +required Name string `json:"name"` // +optional Volumes []v1.Volume `json:"volumes,omitempty"` // +required Port []v1.ContainerPort `json:"port"` // +optional VolumeMount []v1.VolumeMount `json:"volumeMount,omitempty"` // +required Image string `json:"image"` // +optional ImagePullPolicy v1.PullPolicy `json:"imagePullPolicy,omitempty"` // +optional ServiceAccountName string `json:"serviceAccountName,omitempty"` // +optional Env []v1.EnvVar `json:"env,omitempty"` // +optional Tolerations []v1.Toleration `json:"tolerations,omitempty"` // +optional PodMetadata Metadata `json:"podMetadata,omitempty"` // +optional StorageConfig []StorageConfig `json:"storageConfig,omitempty"` // +optional NodeSelector map[string]string `json:"nodeSelector,omitempty"` // +required Service *v1.ServiceSpec `json:"service"` // +optional LivenessProbe *v1.Probe `json:"livenessProbe,omitempty"` // +optional ReadinessProbe *v1.Probe `json:"readinessProbe,omitempty"` // +optional StartUpProbe *v1.Probe `json:"startUpProbe,omitempty"` // +optional Resources v1.ResourceRequirements `json:"resources,omitempty"` }
func (*K8sConfig) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new K8sConfig.
func (*K8sConfig) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Metadata ¶
type Metadata struct { // +optional Annotations map[string]string `json:"annotations,omitempty"` // +optional Labels map[string]string `json:"labels,omitempty"` }
func (*Metadata) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Metadata.
func (*Metadata) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type NodeSpec ¶
type NodeSpec struct { // +required Name string `json:"name"` // +required Kind string `json:"kind"` // +required NodeType PinotNodeType `json:"nodeType"` // +required Replicas int `json:"replicas"` // +required K8sConfig string `json:"k8sConfig"` // +required PinotNodeConfig string `json:"pinotNodeConfig"` }
func (*NodeSpec) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NodeSpec.
func (*NodeSpec) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Pinot ¶
type Pinot struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec PinotSpec `json:"spec,omitempty"` Status PinotStatus `json:"status,omitempty"` }
+kubebuilder:object:root=true +kubebuilder:subresource:status +kubebuilder:printcolumn:name="Age",type="date",JSONPath=".metadata.creationTimestamp" Pinot is the Schema for the pinots API
func (*Pinot) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Pinot.
func (*Pinot) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Pinot) DeepCopyObject ¶
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type PinotList ¶
type PinotList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` Items []Pinot `json:"items"` }
+kubebuilder:object:root=true PinotList contains a list of Pinot
func (*PinotList) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PinotList.
func (*PinotList) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*PinotList) DeepCopyObject ¶
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type PinotNodeConfig ¶
type PinotNodeConfig struct { // +required Name string `json:"name"` // +required JavaOpts string `json:"java_opts"` // +required Data string `json:"data"` }
func (*PinotNodeConfig) DeepCopy ¶
func (in *PinotNodeConfig) DeepCopy() *PinotNodeConfig
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PinotNodeConfig.
func (*PinotNodeConfig) DeepCopyInto ¶
func (in *PinotNodeConfig) DeepCopyInto(out *PinotNodeConfig)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type PinotNodeType ¶
type PinotNodeType string
const ( Controller PinotNodeType = "controller" Broker PinotNodeType = "broker" Server PinotNodeType = "server" Minion PinotNodeType = "minion" )
type PinotSchema ¶
type PinotSchema struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec PinotSchemaSpec `json:"spec,omitempty"` Status PinotSchemaStatus `json:"status,omitempty"` }
+kubebuilder:object:root=true +kubebuilder:subresource:status +kubebuilder:printcolumn:name="Age",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:printcolumn:name="Pinot_Cluster",type="string",JSONPath=".spec.pinotCluster" PinotSchema is the Schema for the pinotschemas API
func (*PinotSchema) DeepCopy ¶
func (in *PinotSchema) DeepCopy() *PinotSchema
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PinotSchema.
func (*PinotSchema) DeepCopyInto ¶
func (in *PinotSchema) DeepCopyInto(out *PinotSchema)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*PinotSchema) DeepCopyObject ¶
func (in *PinotSchema) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type PinotSchemaList ¶
type PinotSchemaList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` Items []PinotSchema `json:"items"` }
PinotSchemaList contains a list of PinotSchema
func (*PinotSchemaList) DeepCopy ¶
func (in *PinotSchemaList) DeepCopy() *PinotSchemaList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PinotSchemaList.
func (*PinotSchemaList) DeepCopyInto ¶
func (in *PinotSchemaList) DeepCopyInto(out *PinotSchemaList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*PinotSchemaList) DeepCopyObject ¶
func (in *PinotSchemaList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type PinotSchemaSpec ¶
type PinotSchemaSpec struct { // +required PinotCluster string `json:"pinotCluster"` // +required PinotSchemaJson string `json:"schema.json"` }
PinotSchemaSpec defines the desired state of PinotSchema
func (*PinotSchemaSpec) DeepCopy ¶
func (in *PinotSchemaSpec) DeepCopy() *PinotSchemaSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PinotSchemaSpec.
func (*PinotSchemaSpec) DeepCopyInto ¶
func (in *PinotSchemaSpec) DeepCopyInto(out *PinotSchemaSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type PinotSchemaStatus ¶
type PinotSchemaStatus struct { Type string `json:"type,omitempty"` Status v1.ConditionStatus `json:"status,omitempty"` Reason string `json:"reason,omitempty"` Message string `json:"message,omitempty"` LastUpdateTime metav1.Time `json:"lastUpdateTime,omitempty"` CurrentSchemasJson string `json:"currentSchemas.json"` }
PinotSchemaStatus defines the observed state of PinotSchema
func (*PinotSchemaStatus) DeepCopy ¶
func (in *PinotSchemaStatus) DeepCopy() *PinotSchemaStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PinotSchemaStatus.
func (*PinotSchemaStatus) DeepCopyInto ¶
func (in *PinotSchemaStatus) DeepCopyInto(out *PinotSchemaStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type PinotSpec ¶
type PinotSpec struct { // +optional Auth Auth `json:"auth"` // +optional Plugins []string `json:"plugins"` // +required DeploymentOrder []PinotNodeType `json:"deploymentOrder"` // +required External ExternalSpec `json:"external,omitempty"` // +required K8sConfig []K8sConfig `json:"k8sConfig"` // +required PinotNodeConfig []PinotNodeConfig `json:"pinotNodeConfig"` // +required Nodes []NodeSpec `json:"nodes"` }
PinotSpec defines the desired state of Pinot
func (*PinotSpec) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PinotSpec.
func (*PinotSpec) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type PinotStatus ¶
type PinotStatus struct { }
PinotStatus defines the observed state of Pinot
func (*PinotStatus) DeepCopy ¶
func (in *PinotStatus) DeepCopy() *PinotStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PinotStatus.
func (*PinotStatus) DeepCopyInto ¶
func (in *PinotStatus) DeepCopyInto(out *PinotStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type PinotTable ¶ added in v0.0.4
type PinotTable struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec PinotTableSpec `json:"spec,omitempty"` Status PinotTableStatus `json:"status,omitempty"` }
+kubebuilder:object:root=true +kubebuilder:subresource:status +kubebuilder:printcolumn:name="Age",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:printcolumn:name="Pinot_Cluster",type="string",JSONPath=".spec.pinotCluster" +kubebuilder:printcolumn:name="Pinot_Schema",type="string",JSONPath=".spec.pinotSchema" PinotTable is the Schema for the pinottables API
func (*PinotTable) DeepCopy ¶ added in v0.0.4
func (in *PinotTable) DeepCopy() *PinotTable
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PinotTable.
func (*PinotTable) DeepCopyInto ¶ added in v0.0.4
func (in *PinotTable) DeepCopyInto(out *PinotTable)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*PinotTable) DeepCopyObject ¶ added in v0.0.4
func (in *PinotTable) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type PinotTableList ¶ added in v0.0.4
type PinotTableList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` Items []PinotTable `json:"items"` }
PinotTableList contains a list of PinotTable
func (*PinotTableList) DeepCopy ¶ added in v0.0.4
func (in *PinotTableList) DeepCopy() *PinotTableList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PinotTableList.
func (*PinotTableList) DeepCopyInto ¶ added in v0.0.4
func (in *PinotTableList) DeepCopyInto(out *PinotTableList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*PinotTableList) DeepCopyObject ¶ added in v0.0.4
func (in *PinotTableList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type PinotTableSpec ¶ added in v0.0.4
type PinotTableSpec struct { // +required PinotCluster string `json:"pinotCluster"` // +required PinotSchema string `json:"pinotSchema"` // +required PinotTableType PinotTableType `json:"pinotTableType"` // +required PinotTablesJson string `json:"tables.json"` // +optional SegmentReload bool `json:"segmentReload"` }
PinotTableSpec defines the desired state of PinotTable
func (*PinotTableSpec) DeepCopy ¶ added in v0.0.4
func (in *PinotTableSpec) DeepCopy() *PinotTableSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PinotTableSpec.
func (*PinotTableSpec) DeepCopyInto ¶ added in v0.0.4
func (in *PinotTableSpec) DeepCopyInto(out *PinotTableSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type PinotTableStatus ¶ added in v0.0.4
type PinotTableStatus struct { Type string `json:"type,omitempty"` Status v1.ConditionStatus `json:"status,omitempty"` Reason string `json:"reason,omitempty"` Message string `json:"message,omitempty"` LastUpdateTime metav1.Time `json:"lastUpdateTime,omitempty"` CurrentTableJson string `json:"currentTable.json"` ReloadStatus []string `json:"reloadStatus"` }
PinotTableStatus defines the observed state of PinotTable
func (*PinotTableStatus) DeepCopy ¶ added in v0.0.4
func (in *PinotTableStatus) DeepCopy() *PinotTableStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PinotTableStatus.
func (*PinotTableStatus) DeepCopyInto ¶ added in v0.0.4
func (in *PinotTableStatus) DeepCopyInto(out *PinotTableStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type PinotTableType ¶ added in v0.0.4
type PinotTableType string
const ( RealTimeTable PinotTableType = "realtime" OfflineTimeTable PinotTableType = "offline" HybridTable PinotTableType = "hybrid" )
type PinotTenant ¶ added in v0.0.5
type PinotTenant struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec PinotTenantSpec `json:"spec,omitempty"` Status PinotTenantStatus `json:"status,omitempty"` }
PinotTenant is the Schema for the pinottenants API
func (*PinotTenant) DeepCopy ¶ added in v0.0.5
func (in *PinotTenant) DeepCopy() *PinotTenant
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PinotTenant.
func (*PinotTenant) DeepCopyInto ¶ added in v0.0.5
func (in *PinotTenant) DeepCopyInto(out *PinotTenant)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*PinotTenant) DeepCopyObject ¶ added in v0.0.5
func (in *PinotTenant) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type PinotTenantList ¶ added in v0.0.5
type PinotTenantList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` Items []PinotTenant `json:"items"` }
PinotTenantList contains a list of PinotTenant
func (*PinotTenantList) DeepCopy ¶ added in v0.0.5
func (in *PinotTenantList) DeepCopy() *PinotTenantList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PinotTenantList.
func (*PinotTenantList) DeepCopyInto ¶ added in v0.0.5
func (in *PinotTenantList) DeepCopyInto(out *PinotTenantList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*PinotTenantList) DeepCopyObject ¶ added in v0.0.5
func (in *PinotTenantList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type PinotTenantSpec ¶ added in v0.0.5
type PinotTenantSpec struct { // +required PinotCluster string `json:"pinotCluster"` // +required PinotTenantType PinotTenantType `json:"pinotTenantType"` // +required PinotTenantsJson string `json:"tenants.json"` }
PinotTenantSpec defines the desired state of PinotTenant
func (*PinotTenantSpec) DeepCopy ¶ added in v0.0.5
func (in *PinotTenantSpec) DeepCopy() *PinotTenantSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PinotTenantSpec.
func (*PinotTenantSpec) DeepCopyInto ¶ added in v0.0.5
func (in *PinotTenantSpec) DeepCopyInto(out *PinotTenantSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type PinotTenantStatus ¶ added in v0.0.5
type PinotTenantStatus struct { Type string `json:"type,omitempty"` Status v1.ConditionStatus `json:"status,omitempty"` Reason string `json:"reason,omitempty"` Message string `json:"message,omitempty"` LastUpdateTime metav1.Time `json:"lastUpdateTime,omitempty"` CurrentTenantsJson string `json:"currentTenants.json"` }
PinotTenantStatus defines the observed state of PinotTenant
func (*PinotTenantStatus) DeepCopy ¶ added in v0.0.5
func (in *PinotTenantStatus) DeepCopy() *PinotTenantStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PinotTenantStatus.
func (*PinotTenantStatus) DeepCopyInto ¶ added in v0.0.5
func (in *PinotTenantStatus) DeepCopyInto(out *PinotTenantStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type PinotTenantType ¶ added in v0.0.5
type PinotTenantType string
const ( BrokerTenant PinotTenantType = "BROKER" ServerTenant PinotTenantType = "SERVER" )
type StorageConfig ¶
type StorageConfig struct { // +required Name string `json:"name"` // +required MountPath string `json:"mountPath"` // +required PvcSpec v1.PersistentVolumeClaimSpec `json:"spec"` }
func (*StorageConfig) DeepCopy ¶
func (in *StorageConfig) DeepCopy() *StorageConfig
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StorageConfig.
func (*StorageConfig) DeepCopyInto ¶
func (in *StorageConfig) DeepCopyInto(out *StorageConfig)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ZookeeperConfig ¶
type ZookeeperConfig struct { // +required ZkAddress string `json:"zkAddress"` }
func (*ZookeeperConfig) DeepCopy ¶
func (in *ZookeeperConfig) DeepCopy() *ZookeeperConfig
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ZookeeperConfig.
func (*ZookeeperConfig) DeepCopyInto ¶
func (in *ZookeeperConfig) DeepCopyInto(out *ZookeeperConfig)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ZookeeperSpec ¶
type ZookeeperSpec struct { // +required Spec ZookeeperConfig `json:"spec"` }
func (*ZookeeperSpec) DeepCopy ¶
func (in *ZookeeperSpec) DeepCopy() *ZookeeperSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ZookeeperSpec.
func (*ZookeeperSpec) DeepCopyInto ¶
func (in *ZookeeperSpec) DeepCopyInto(out *ZookeeperSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.