v1alpha1

package
v0.0.0-...-ecdda16 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 28, 2024 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Overview

Package v1alpha1 contains API Schema definitions for the trino v1alpha1 API group +kubebuilder:object:generate=true +groupName=trino.zncdata.dev

Index

Constants

View Source 
const (
	NodePropertiesFileName            = "node.properties"
	JvmConfigFileName                 = "jvm.config"
	ConfigPropertiesFileName          = "config.properties"
	LogPropertiesFileName             = "log.properties"
	ExchangeManagerPropertiesFileName = "exchange-manager.properties"
	VectorYamlName                    = "vector.yaml"
)

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.

View Source 
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

View Source 
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
	VectorAggregatorConfigMapName string `json:"vectorAggregatorConfigMapName,omitempty"`
	// +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 ClusterOperationSpec 

type ClusterOperationSpec struct {
	// +kubebuilder:validation:Optional
	// +kubebuilder:default:=false
	ReconciliationPaused bool `json:"reconciliationPaused,omitempty"`

	// +kubebuilder:validation:Optional
	// +kubebuilder:default:=false
	Stopped bool `json:"stopped,omitempty"`
}

func (*ClusterOperationSpec) DeepCopy 

func (in *ClusterOperationSpec) DeepCopy() *ClusterOperationSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterOperationSpec.

func (*ClusterOperationSpec) DeepCopyInto 

func (in *ClusterOperationSpec) DeepCopyInto(out *ClusterOperationSpec)

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
	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"`

	// Use time.ParseDuration to parse the string
	// +kubebuilder:validation:Optional
	GracefulShutdownTimeout *string `json:"gracefulShutdownTimeout,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 ConnectorSpec 

type ConnectorSpec struct {
	// +kubebuilder:validation:optional
	Generic *GenericConnectorSpec `json:"generic,omitempty"`

	// +kubebuilder:validation:optional
	Hive *HiveConnectorSpec `json:"hive,omitempty"`

	// +kubebuilder:validation:optional
	IceBerg *IcebergConnectorSpec `json:"iceberg,omitempty"`

	// +kubebuilder:validation:optional
	Tpcds *TpcdsConnectorSpec `json:"tpcds,omitempty"`

	// +kubebuilder:validation:optional
	Tpch *TpchConnectorSpec `json:"tpch,omitempty"`
}

func (*ConnectorSpec) DeepCopy 

func (in *ConnectorSpec) DeepCopy() *ConnectorSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConnectorSpec.

func (*ConnectorSpec) DeepCopyInto 

func (in *ConnectorSpec) DeepCopyInto(out *ConnectorSpec)

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
	// +kubebuilder:default:=false
	EnableVectorAgent bool `json:"enableVectorAgent,omitempty"`
	// +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 GenericConnectorSpec 

type GenericConnectorSpec struct {
	// +kubebuilder:validation:required
	Name string `json:"name"`

	// +kubebuilder:validation:Optional
	Properties *PropertiesSpec `json:"properties,omitempty"`
}

func (*GenericConnectorSpec) DeepCopy 

func (in *GenericConnectorSpec) DeepCopy() *GenericConnectorSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GenericConnectorSpec.

func (*GenericConnectorSpec) DeepCopyInto 

func (in *GenericConnectorSpec) DeepCopyInto(out *GenericConnectorSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type HdfsConnectionSpec 

type HdfsConnectionSpec struct {
	// +kubebuilder:validation:required
	ConfigMap string `json:"configMap,omitempty"`
}

func (*HdfsConnectionSpec) DeepCopy 

func (in *HdfsConnectionSpec) DeepCopy() *HdfsConnectionSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new HdfsConnectionSpec.

func (*HdfsConnectionSpec) DeepCopyInto 

func (in *HdfsConnectionSpec) DeepCopyInto(out *HdfsConnectionSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type HiveConnectorSpec 

type HiveConnectorSpec struct {
	// +kubebuilder:validation:required
	Metastore *MetastoreConnectionSpec `json:"metastore,omitempty"`

	// +kubebuilder:validation:optional
	S3 *s3v1alpha1.S3BucketSpec `json:"s3,omitempty"`

	// +kubebuilder:validation:optional
	Hdfs *HdfsConnectionSpec `json:"hdfs,omitempty"`
}

func (*HiveConnectorSpec) DeepCopy 

func (in *HiveConnectorSpec) DeepCopy() *HiveConnectorSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new HiveConnectorSpec.

func (*HiveConnectorSpec) DeepCopyInto 

func (in *HiveConnectorSpec) DeepCopyInto(out *HiveConnectorSpec)

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 

func (in *HttpsSpec) DeepCopy() *HttpsSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new HttpsSpec.

func (*HttpsSpec) DeepCopyInto 

func (in *HttpsSpec) DeepCopyInto(out *HttpsSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type IcebergConnectorSpec 

type IcebergConnectorSpec struct {
	// +kubebuilder:validation:required
	Metastore *MetastoreConnectionSpec `json:"metastore,omitempty"`

	// +kubebuilder:validation:optional
	S3 *s3v1alpha1.S3BucketSpec `json:"s3,omitempty"`

	// +kubebuilder:validation:optional
	Hdfs *HdfsConnectionSpec `json:"hdfs,omitempty"`
}

func (*IcebergConnectorSpec) DeepCopy 

func (in *IcebergConnectorSpec) DeepCopy() *IcebergConnectorSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new IcebergConnectorSpec.

func (*IcebergConnectorSpec) DeepCopyInto 

func (in *IcebergConnectorSpec) DeepCopyInto(out *IcebergConnectorSpec)

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 

func (in *ImageSpec) DeepCopy() *ImageSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ImageSpec.

func (*ImageSpec) DeepCopyInto 

func (in *ImageSpec) DeepCopyInto(out *ImageSpec)

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 MetastoreConnectionSpec 

type MetastoreConnectionSpec struct {
	// +kubebuilder:validation:required
	ConfigMap string `json:"configMap,omitempty"`
}

func (*MetastoreConnectionSpec) DeepCopy 

func (in *MetastoreConnectionSpec) DeepCopy() *MetastoreConnectionSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MetastoreConnectionSpec.

func (*MetastoreConnectionSpec) DeepCopyInto 

func (in *MetastoreConnectionSpec) DeepCopyInto(out *MetastoreConnectionSpec)

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"`

	// +kubebuilder:validation:Optional
	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 PropertiesSpec 

type PropertiesSpec struct {
	// +kubebuilder:validation:optional
	Value string `json:"value,omitempty"`

	// +kubebuilder:validation:optional
	ValueFromConfiguration *ValueFromConfigurationSpec `json:"valueFromConfiguration,omitempty"`
}

func (*PropertiesSpec) DeepCopy 

func (in *PropertiesSpec) DeepCopy() *PropertiesSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PropertiesSpec.

func (*PropertiesSpec) DeepCopyInto 

func (in *PropertiesSpec) DeepCopyInto(out *PropertiesSpec)

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"`

	// +kubebuilder:validation:Optional
	PodOverride *corev1.PodTemplateSpec `json:"podOverride,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 TpcdsConnectorSpec 

type TpcdsConnectorSpec struct {
}

func (*TpcdsConnectorSpec) DeepCopy 

func (in *TpcdsConnectorSpec) DeepCopy() *TpcdsConnectorSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TpcdsConnectorSpec.

func (*TpcdsConnectorSpec) DeepCopyInto 

func (in *TpcdsConnectorSpec) DeepCopyInto(out *TpcdsConnectorSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type TpchConnectorSpec 

type TpchConnectorSpec struct {
}

func (*TpchConnectorSpec) DeepCopy 

func (in *TpchConnectorSpec) DeepCopy() *TpchConnectorSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TpchConnectorSpec.

func (*TpchConnectorSpec) DeepCopyInto 

func (in *TpchConnectorSpec) DeepCopyInto(out *TpchConnectorSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type TrinoCatalog 

type TrinoCatalog struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   TrinoCatalogSpec   `json:"spec,omitempty"`
	Status TrinoCatalogStatus `json:"status,omitempty"`
}

TrinoCatalog is the Schema for the trinocatalogs API

func (*TrinoCatalog) DeepCopy 

func (in *TrinoCatalog) DeepCopy() *TrinoCatalog

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TrinoCatalog.

func (*TrinoCatalog) DeepCopyInto 

func (in *TrinoCatalog) DeepCopyInto(out *TrinoCatalog)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*TrinoCatalog) DeepCopyObject 

func (in *TrinoCatalog) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type TrinoCatalogList 

type TrinoCatalogList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []TrinoCatalog `json:"items"`
}

TrinoCatalogList contains a list of TrinoCatalog

func (*TrinoCatalogList) DeepCopy 

func (in *TrinoCatalogList) DeepCopy() *TrinoCatalogList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TrinoCatalogList.

func (*TrinoCatalogList) DeepCopyInto 

func (in *TrinoCatalogList) DeepCopyInto(out *TrinoCatalogList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*TrinoCatalogList) DeepCopyObject 

func (in *TrinoCatalogList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type TrinoCatalogSpec 

type TrinoCatalogSpec struct {
	// List of connectors in the catalog
	// +kubebuilder:validation:required
	Connectors []ConnectorSpec `json:"connectors"`

	// The configOverrides allow overriding arbitrary Trino settings. For example, for Hive you could add hive.metastore.username: trino.
	// +kubebuilder:validation:Optional
	ConfigOverrides map[string]string `json:"configOverrides,omitempty"`
}

TrinoCatalogSpec defines the desired state of TrinoCatalog

func (*TrinoCatalogSpec) DeepCopy 

func (in *TrinoCatalogSpec) DeepCopy() *TrinoCatalogSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TrinoCatalogSpec.

func (*TrinoCatalogSpec) DeepCopyInto 

func (in *TrinoCatalogSpec) DeepCopyInto(out *TrinoCatalogSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type TrinoCatalogStatus 

type TrinoCatalogStatus struct {
}

TrinoCatalogStatus defines the observed state of TrinoCatalog

func (*TrinoCatalogStatus) DeepCopy 

func (in *TrinoCatalogStatus) DeepCopy() *TrinoCatalogStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TrinoCatalogStatus.

func (*TrinoCatalogStatus) DeepCopyInto 

func (in *TrinoCatalogStatus) DeepCopyInto(out *TrinoCatalogStatus)

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"`

	// +kubebuilder:validation:Optional
	ClusterOperation *ClusterOperationSpec `json:"clusterOperation,omitempty"`
}

TrinoSpec defines the desired state of TrinoCluster

func (*TrinoSpec) DeepCopy 

func (in *TrinoSpec) DeepCopy() *TrinoSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TrinoSpec.

func (*TrinoSpec) DeepCopyInto 

func (in *TrinoSpec) DeepCopyInto(out *TrinoSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ValueFromConfigurationSpec 

type ValueFromConfigurationSpec struct {
	// +kubebuilder:validation:rquired
	// +kubebuilder:default=configmap
	// +kubebuilder:validation:Enum=configmap;secret
	Type string `json:"type,omitempty"`

	// +kubebuilder:validation:required
	Name string `json:"name"`

	// +kubebuilder:validation:required
	Key string `json:"key,omitempty"`
}

func (*ValueFromConfigurationSpec) DeepCopy 

func (in *ValueFromConfigurationSpec) DeepCopy() *ValueFromConfigurationSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ValueFromConfigurationSpec.

func (*ValueFromConfigurationSpec) DeepCopyInto 

func (in *ValueFromConfigurationSpec) DeepCopyInto(out *ValueFromConfigurationSpec)

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"`

	// +kubebuilder:validation:Optional
	PodOverride *corev1.PodTemplateSpec `json:"podOverride,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.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.