Documentation ¶
Overview ¶
Package v1alpha1 contains API Schema definitions for the trino v1alpha1 API group +kubebuilder:object:generate=true +groupName=trino.zncdata.dev
Index ¶
- Constants
- Variables
- type CPUResource
- type ClusterConfigSpec
- type ConfigOverridesSpec
- type ConfigPropertiesSpec
- type ConfigSpec
- type ContainerLoggingSpec
- type CoordinatorSpec
- type ExchangeManagerSpec
- type HttpsSpec
- type ImageSpec
- type IngressSpec
- type JvmPropertiesRoleConfigSpec
- type LogLevelSpec
- type LoggingConfigSpec
- type MemoryResource
- type NodePropertiesSpec
- type PodDisruptionBudgetSpec
- type ResourcesSpec
- type RoleGroupSpec
- type ServiceSpec
- type StorageResource
- type StorageResourceSpec
- type TrinoCluster
- func (in *TrinoCluster) DeepCopy() *TrinoCluster
- func (in *TrinoCluster) DeepCopyInto(out *TrinoCluster)
- func (in *TrinoCluster) DeepCopyObject() runtime.Object
- func (r *TrinoCluster) GetNameWithSuffix(suffix string) string
- func (r *TrinoCluster) InitStatusConditions()
- func (r *TrinoCluster) SetStatusCondition(condition metav1.Condition)
- type TrinoClusterList
- type TrinoSpec
- type WorkerSpec
Constants ¶
const ( NodePropertiesFileName = "node.properties" JvmConfigFileName = "jvm.config" ConfigPropertiesFileName = "config.properties" LogPropertiesFileName = "log.properties" ExchangeManagerPropertiesFileName = "exchange-manager.properties" )
EDIT THIS FILE! THIS IS SCAFFOLDING FOR YOU TO OWN! NOTE: json tags are required. Any new fields you add must have json tags for the fields to be serialized.
const ( // resource CpuMin = "1" CpuMax = "1.5" MemoryLimit = "1.5Gi" //service ServiceType = "ClusterIP" ServicePort = 18080 //exchange manager ExchangeManagerName = "filesystem" ExchangeManagerBaseDir = "/tmp/TrinoCluster-local-file-system-exchange-manager" )
Variables ¶
var ( // GroupVersion is group version used to register these objects GroupVersion = schema.GroupVersion{Group: "trino.zncdata.dev", 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 CPUResource ¶
type CPUResource struct { // +kubebuilder:validation:Optional Max *resource.Quantity `json:"max,omitempty"` // +kubebuilder:validation:Optional Min *resource.Quantity `json:"min,omitempty"` }
func (*CPUResource) DeepCopy ¶
func (in *CPUResource) DeepCopy() *CPUResource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CPUResource.
func (*CPUResource) DeepCopyInto ¶
func (in *CPUResource) DeepCopyInto(out *CPUResource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ClusterConfigSpec ¶
type ClusterConfigSpec struct { // +kubebuilder:validation:Optional Service *ServiceSpec `json:"service,omitempty"` // +kubebuilder:validation:Optional Ingress *IngressSpec `json:"ingress,omitempty"` // +kubebuilder:validation:Optional Catalogs map[string]string `json:"catalogs,omitempty"` // +kubebuilder:validation:Required // +kubebuilder:default:=true ClusterMode bool `json:"clusterMode"` }
func (*ClusterConfigSpec) DeepCopy ¶
func (in *ClusterConfigSpec) DeepCopy() *ClusterConfigSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterConfigSpec.
func (*ClusterConfigSpec) DeepCopyInto ¶
func (in *ClusterConfigSpec) DeepCopyInto(out *ClusterConfigSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ConfigOverridesSpec ¶
type ConfigOverridesSpec struct { Node map[string]string `json:"node.properties,omitempty"` Jvm string `json:"jvm.config,omitempty"` Config map[string]string `json:"config.properties,omitempty"` Log map[string]string `json:"log.properties,omitempty"` ExchangeManager map[string]string `json:"exchange-manager.properties,omitempty"` }
func (*ConfigOverridesSpec) DeepCopy ¶
func (in *ConfigOverridesSpec) DeepCopy() *ConfigOverridesSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConfigOverridesSpec.
func (*ConfigOverridesSpec) DeepCopyInto ¶
func (in *ConfigOverridesSpec) DeepCopyInto(out *ConfigOverridesSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ConfigPropertiesSpec ¶
type ConfigPropertiesSpec struct { // +kubebuilder:validation:Optional // +kubebuilder:default:="/etc/TrinoCluster" Path string `json:"path,omitempty"` // +kubebuilder:validation:Optional Https *HttpsSpec `json:"https,omitempty"` // +kubebuilder:validation:Optional // +kubebuilder:default:="4GB" QueryMaxMemory string `json:"queryMaxMemory,omitempty"` // +kubebuilder:validation:Optional // +kubebuilder:default:="" AuthenticationType string `json:"authenticationType,omitempty"` // +kubebuilder:validation:Optional // +kubebuilder:default:="" MemoryHeapHeadroomPerNode string `json:"memoryHeapHeadroomPerNode,omitempty"` // +kubebuilder:validation:Optional // +kubebuilder:default:="1GB" QueryMaxMemoryPerNode string `json:"queryMaxMemoryPerNode,omitempty"` }
func (*ConfigPropertiesSpec) DeepCopy ¶
func (in *ConfigPropertiesSpec) DeepCopy() *ConfigPropertiesSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConfigPropertiesSpec.
func (*ConfigPropertiesSpec) DeepCopyInto ¶
func (in *ConfigPropertiesSpec) DeepCopyInto(out *ConfigPropertiesSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ConfigSpec ¶
type ConfigSpec struct { // +kubebuilder:validation:Optional Resources *ResourcesSpec `json:"resources,omitempty"` // +kubebuilder:validation:Optional SecurityContext *corev1.PodSecurityContext `json:"securityContext"` // +kubebuilder:validation:Optional Affinity *corev1.Affinity `json:"affinity"` // +kubebuilder:validation:Optional NodeSelector map[string]string `json:"nodeSelector,omitempty"` // +kubebuilder:validation:Optional Tolerations []corev1.Toleration `json:"tolerations"` // +kubebuilder:validation:Optional PodDisruptionBudget *PodDisruptionBudgetSpec `json:"podDisruptionBudget,omitempty"` // +kubebuilder:validation:Optional StorageClass string `json:"storageClass,omitempty"` // +kubebuilder:validation:Optional NodeProperties *NodePropertiesSpec `json:"nodeProperties,omitempty"` // +kubebuilder:validation:Optional ConfigProperties *ConfigPropertiesSpec `json:"configProperties,omitempty"` // +kubebuilder:validation:Optional JvmProperties *JvmPropertiesRoleConfigSpec `json:"jvmProperties,omitempty"` // +kubebuilder:validation:Optional ExchangeManager *ExchangeManagerSpec `json:"exchangeManager,omitempty"` // +kubebuilder:validation:Optional Logging *ContainerLoggingSpec `json:"logging,omitempty"` }
func (*ConfigSpec) DeepCopy ¶
func (in *ConfigSpec) DeepCopy() *ConfigSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConfigSpec.
func (*ConfigSpec) DeepCopyInto ¶
func (in *ConfigSpec) DeepCopyInto(out *ConfigSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ContainerLoggingSpec ¶
type ContainerLoggingSpec struct { // +kubebuilder:validation:Optional Trino *LoggingConfigSpec `json:"TrinoCluster,omitempty"` }
func (*ContainerLoggingSpec) DeepCopy ¶
func (in *ContainerLoggingSpec) DeepCopy() *ContainerLoggingSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ContainerLoggingSpec.
func (*ContainerLoggingSpec) DeepCopyInto ¶
func (in *ContainerLoggingSpec) DeepCopyInto(out *ContainerLoggingSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type CoordinatorSpec ¶
type CoordinatorSpec struct { // +kubebuilder:validation:Optional Config *ConfigSpec `json:"config,omitempty"` // +kubebuilder:validation:Optional RoleGroups map[string]*RoleGroupSpec `json:"roleGroups,omitempty"` // +kubebuilder:validation:Optional PodDisruptionBudget *PodDisruptionBudgetSpec `json:"podDisruptionBudget,omitempty"` // +kubebuilder:validation:Optional CommandArgsOverrides []string `json:"commandArgsOverrides,omitempty"` // +kubebuilder:validation:Optional ConfigOverrides *ConfigOverridesSpec `json:"configOverrides,omitempty"` // +kubebuilder:validation:Optional EnvOverrides map[string]string `json:"envOverrides,omitempty"` }
func (*CoordinatorSpec) DeepCopy ¶
func (in *CoordinatorSpec) DeepCopy() *CoordinatorSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CoordinatorSpec.
func (*CoordinatorSpec) DeepCopyInto ¶
func (in *CoordinatorSpec) DeepCopyInto(out *CoordinatorSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ExchangeManagerSpec ¶
type ExchangeManagerSpec struct { // +kubebuilder:validation:Optional // +kubebuilder:default:="filesystem" Name string `json:"name,omitempty"` // +kubebuilder:validation:Optional // +kubebuilder:default:="/tmp/TrinoCluster-local-file-system-exchange-manager" BaseDir string `json:"baseDir,omitempty"` }
func (*ExchangeManagerSpec) DeepCopy ¶
func (in *ExchangeManagerSpec) DeepCopy() *ExchangeManagerSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ExchangeManagerSpec.
func (*ExchangeManagerSpec) DeepCopyInto ¶
func (in *ExchangeManagerSpec) DeepCopyInto(out *ExchangeManagerSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type HttpsSpec ¶
type HttpsSpec struct { // +kubebuilder:validation:Optional // +kubebuilder:default:=false Enabled bool `json:"enabled,omitempty"` // +kubebuilder:validation:Optional // +kubebuilder:default:=8443 Port int `json:"port,omitempty"` // +kubebuilder:validation:Optional // +kubebuilder:default:="" KeystorePath string `json:"keystorePath,omitempty"` }
func (*HttpsSpec) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new HttpsSpec.
func (*HttpsSpec) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ImageSpec ¶
type ImageSpec struct { // +kubebuilder:validation:Optional // +kubebuilder:default=trinodb/TrinoCluster Repository string `json:"repository,omitempty"` // +kubebuilder:validation:Optional // +kubebuilder:default:="423" Tag string `json:"tag,omitempty"` // +kubebuilder:validation:Optional // +kubebuilder:default:=IfNotPresent PullPolicy corev1.PullPolicy `json:"pullPolicy,omitempty"` }
func (*ImageSpec) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ImageSpec.
func (*ImageSpec) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type IngressSpec ¶
type IngressSpec struct { // +kubebuilder:validation:Optional // +kubebuilder:default:=true Enabled bool `json:"enabled,omitempty"` // +kubebuilder:validation:Optional TLS *networkingv1.IngressTLS `json:"tls,omitempty"` // +kubebuilder:validation:Optional Annotations map[string]string `json:"annotations,omitempty"` // +kubebuilder:validation:Optional // +kubebuilder:default:="TrinoCluster.example.com" Host string `json:"host,omitempty"` }
func (*IngressSpec) DeepCopy ¶
func (in *IngressSpec) DeepCopy() *IngressSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new IngressSpec.
func (*IngressSpec) DeepCopyInto ¶
func (in *IngressSpec) DeepCopyInto(out *IngressSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type JvmPropertiesRoleConfigSpec ¶
type JvmPropertiesRoleConfigSpec struct { // +kubebuilder:validation:Optional // +kubebuilder:default:="8G" MaxHeapSize string `json:"maxHeapSize,omitempty"` // +kubebuilder:validation:Optional // +kubebuilder:default:="UseG1GC" GcMethodType string `json:"gcMethodType,omitempty"` // +kubebuilder:validation:Optional // +kubebuilder:default:="32M" G1HeapRegionSize string `json:"gcHeapRegionSize,omitempty"` }
func (*JvmPropertiesRoleConfigSpec) DeepCopy ¶
func (in *JvmPropertiesRoleConfigSpec) DeepCopy() *JvmPropertiesRoleConfigSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new JvmPropertiesRoleConfigSpec.
func (*JvmPropertiesRoleConfigSpec) DeepCopyInto ¶
func (in *JvmPropertiesRoleConfigSpec) DeepCopyInto(out *JvmPropertiesRoleConfigSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type LogLevelSpec ¶
type LogLevelSpec struct { // +kubebuilder:validation:Optional // +kubebuilder:default:="INFO" // +kubebuilder:validation:Enum=FATAL;ERROR;WARN;INFO;DEBUG;TRACE Level string `json:"level,omitempty"` }
LogLevelSpec level mapping example |---------------------|-----------------| | superset log level | zds log level | |---------------------|-----------------| | CRITICAL | FATAL | | ERROR | ERROR | | WARNING | WARN | | INFO | INFO | | DEBUG | DEBUG | | DEBUG | TRACE | |---------------------|-----------------|
func (*LogLevelSpec) DeepCopy ¶
func (in *LogLevelSpec) DeepCopy() *LogLevelSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LogLevelSpec.
func (*LogLevelSpec) DeepCopyInto ¶
func (in *LogLevelSpec) DeepCopyInto(out *LogLevelSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type LoggingConfigSpec ¶
type LoggingConfigSpec struct { // +kubebuilder:validation:Optional Loggers map[string]*LogLevelSpec `json:"loggers,omitempty"` // +kubebuilder:validation:Optional Console *LogLevelSpec `json:"console,omitempty"` }
func (*LoggingConfigSpec) DeepCopy ¶
func (in *LoggingConfigSpec) DeepCopy() *LoggingConfigSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LoggingConfigSpec.
func (*LoggingConfigSpec) DeepCopyInto ¶
func (in *LoggingConfigSpec) DeepCopyInto(out *LoggingConfigSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type MemoryResource ¶
type MemoryResource struct { // +kubebuilder:validation:Optional Limit *resource.Quantity `json:"limit,omitempty"` }
func (*MemoryResource) DeepCopy ¶
func (in *MemoryResource) DeepCopy() *MemoryResource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MemoryResource.
func (*MemoryResource) DeepCopyInto ¶
func (in *MemoryResource) DeepCopyInto(out *MemoryResource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type NodePropertiesSpec ¶
type NodePropertiesSpec struct { // +kubebuilder:validation:Optional // +kubebuilder:default:="production" Environment string `json:"environment,omitempty"` // +kubebuilder:validation:Optional // +kubebuilder:default:=/data/TrinoCluster DataDir string `json:"dataDir,omitempty"` // +kubebuilder:validation:Optional // +kubebuilder:default:=/usr/lib/TrinoCluster/plugin PluginDir string `json:"pluginDir,omitempty"` }
func (*NodePropertiesSpec) DeepCopy ¶
func (in *NodePropertiesSpec) DeepCopy() *NodePropertiesSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NodePropertiesSpec.
func (*NodePropertiesSpec) DeepCopyInto ¶
func (in *NodePropertiesSpec) DeepCopyInto(out *NodePropertiesSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type PodDisruptionBudgetSpec ¶
type PodDisruptionBudgetSpec struct { // +kubebuilder:validation:Optional MinAvailable int32 `json:"minAvailable,omitempty"` MaxUnavailable int32 `json:"maxUnavailable,omitempty"` }
func (*PodDisruptionBudgetSpec) DeepCopy ¶
func (in *PodDisruptionBudgetSpec) DeepCopy() *PodDisruptionBudgetSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PodDisruptionBudgetSpec.
func (*PodDisruptionBudgetSpec) DeepCopyInto ¶
func (in *PodDisruptionBudgetSpec) DeepCopyInto(out *PodDisruptionBudgetSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ResourcesSpec ¶
type ResourcesSpec struct { // +kubebuilder:validation:Optional CPU *CPUResource `json:"cpu,omitempty"` // +kubebuilder:validation:Optional Memory *MemoryResource `json:"memory,omitempty"` // +kubebuilder:validation:Optional Storage *StorageResource `json:"storage,omitempty"` }
func (*ResourcesSpec) DeepCopy ¶
func (in *ResourcesSpec) DeepCopy() *ResourcesSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ResourcesSpec.
func (*ResourcesSpec) DeepCopyInto ¶
func (in *ResourcesSpec) DeepCopyInto(out *ResourcesSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type RoleGroupSpec ¶
type RoleGroupSpec struct { // +kubebuilder:validation:Optional // +kubebuilder:default:=1 Replicas int32 `json:"replicas,omitempty"` Config *ConfigSpec `json:"config,omitempty"` // +kubebuilder:validation:Optional CommandArgsOverrides []string `json:"commandArgsOverrides,omitempty"` // +kubebuilder:validation:Optional ConfigOverrides *ConfigOverridesSpec `json:"configOverrides,omitempty"` // +kubebuilder:validation:Optional EnvOverrides map[string]string `json:"envOverrides,omitempty"` }
func (*RoleGroupSpec) DeepCopy ¶
func (in *RoleGroupSpec) DeepCopy() *RoleGroupSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RoleGroupSpec.
func (*RoleGroupSpec) DeepCopyInto ¶
func (in *RoleGroupSpec) DeepCopyInto(out *RoleGroupSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ServiceSpec ¶
type ServiceSpec struct { // +kubebuilder:validation:Optional Annotations map[string]string `json:"annotations,omitempty"` // +kubebuilder:validation:Optional // +kubebuilder:validation:enum=ClusterIP;NodePort;LoadBalancer;ExternalName // +kubebuilder:default=ClusterIP Type corev1.ServiceType `json:"type,omitempty"` // +kubebuilder:validation:Optional // +kubebuilder:validation:Minimum=1 // +kubebuilder:validation:Maximum=65535 // +kubebuilder:default=18080 Port int32 `json:"port,omitempty"` }
func (*ServiceSpec) DeepCopy ¶
func (in *ServiceSpec) DeepCopy() *ServiceSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ServiceSpec.
func (*ServiceSpec) DeepCopyInto ¶
func (in *ServiceSpec) DeepCopyInto(out *ServiceSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type StorageResource ¶
type StorageResource struct { // +kubebuilder:validation:Optional // +kubebuilder:default="10Gi" Capacity resource.Quantity `json:"capacity,omitempty"` // +kubebuilder:validation:Optional StorageClass string `json:"storageClass,omitempty"` }
func (*StorageResource) DeepCopy ¶
func (in *StorageResource) DeepCopy() *StorageResource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StorageResource.
func (*StorageResource) DeepCopyInto ¶
func (in *StorageResource) DeepCopyInto(out *StorageResource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type StorageResourceSpec ¶
type StorageResourceSpec struct {
Data *StorageResource `json:"data"`
}
func (*StorageResourceSpec) DeepCopy ¶
func (in *StorageResourceSpec) DeepCopy() *StorageResourceSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StorageResourceSpec.
func (*StorageResourceSpec) DeepCopyInto ¶
func (in *StorageResourceSpec) DeepCopyInto(out *StorageResourceSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type TrinoCluster ¶
type TrinoCluster struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec TrinoSpec `json:"spec,omitempty"` Status status.Status `json:"status,omitempty"` }
TrinoCluster is the Schema for the trinoclusters API
func (*TrinoCluster) DeepCopy ¶
func (in *TrinoCluster) DeepCopy() *TrinoCluster
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TrinoCluster.
func (*TrinoCluster) DeepCopyInto ¶
func (in *TrinoCluster) DeepCopyInto(out *TrinoCluster)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*TrinoCluster) DeepCopyObject ¶
func (in *TrinoCluster) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*TrinoCluster) GetNameWithSuffix ¶
func (r *TrinoCluster) GetNameWithSuffix(suffix string) string
func (*TrinoCluster) InitStatusConditions ¶
func (r *TrinoCluster) InitStatusConditions()
InitStatusConditions initializes the status conditions to the provided conditions.
func (*TrinoCluster) SetStatusCondition ¶
func (r *TrinoCluster) SetStatusCondition(condition metav1.Condition)
SetStatusCondition updates the status condition using the provided arguments. If the condition already exists, it updates the condition; otherwise, it appends the condition. If the condition status has changed, it updates the condition's LastTransitionTime.
type TrinoClusterList ¶
type TrinoClusterList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` Items []TrinoCluster `json:"items"` }
TrinoClusterList contains a list of TrinoCluster
func (*TrinoClusterList) DeepCopy ¶
func (in *TrinoClusterList) DeepCopy() *TrinoClusterList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TrinoClusterList.
func (*TrinoClusterList) DeepCopyInto ¶
func (in *TrinoClusterList) DeepCopyInto(out *TrinoClusterList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*TrinoClusterList) DeepCopyObject ¶
func (in *TrinoClusterList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type TrinoSpec ¶
type TrinoSpec struct { // +kubebuilder:validation:Required Image *ImageSpec `json:"image"` // +kubebuilder:validation:Required Coordinator *CoordinatorSpec `json:"coordinator"` // +kubebuilder:validation:Required Worker *WorkerSpec `json:"worker"` // +kubebuilder:validation:Optional ClusterConfig *ClusterConfigSpec `json:"clusterConfig,omitempty"` }
TrinoSpec defines the desired state of TrinoCluster
func (*TrinoSpec) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TrinoSpec.
func (*TrinoSpec) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type WorkerSpec ¶
type WorkerSpec struct { // +kubebuilder:validation:Optional Config *ConfigSpec `json:"config,omitempty"` RoleGroups map[string]*RoleGroupSpec `json:"roleGroups,omitempty"` PodDisruptionBudget *PodDisruptionBudgetSpec `json:"podDisruptionBudget,omitempty"` // +kubebuilder:validation:Optional CommandArgsOverrides []string `json:"commandArgsOverrides,omitempty"` // +kubebuilder:validation:Optional ConfigOverrides *ConfigOverridesSpec `json:"configOverrides,omitempty"` // +kubebuilder:validation:Optional EnvOverrides map[string]string `json:"envOverrides,omitempty"` }
func (*WorkerSpec) DeepCopy ¶
func (in *WorkerSpec) DeepCopy() *WorkerSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkerSpec.
func (*WorkerSpec) DeepCopyInto ¶
func (in *WorkerSpec) DeepCopyInto(out *WorkerSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.