v1alpha1

package
v0.0.0-...-c3f5ad8 Latest Latest
Warning

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

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

Documentation

Overview

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

Index

Constants

View Source 
const (
	DolphinCommonPropertiesName     = "common.properties"
	DolphinConfigPath               = "/opt/dolphinscheduler/conf"
	LogbackPropertiesFileName       = "logback-spring.xml"
	ApplicationServerConfigFileName = "application.yaml"

	DbInitImage              = "apache/dolphinscheduler-tools:3.2.1"
	MaxLogFileSize           = "10Mi"
	ConsoleConversionPattern = "%d{ISO8601} - %-5p [%t:%C{1}@%L] - %m%n"
)
View Source 
const (
	ConfigVolumeName              = "common-config"
	LogbackVolumeName             = "logback"
	WorkerDataVolumeName          = "worker-data"
	LoggingVolumeName             = "log"
	LdapBindCredintialsVolumeName = "ldap-bind-credentials"
)
View Source 
const (
	MasterPortName       = "port"
	MasterActualPortName = "actual-port"
	MasterPort           = 5678
	MasterActualPort     = 5679

	WorkerPortName       = "port"
	WorkerActualPortName = "actual-port"
	WorkerPort           = 1234
	WorkerActualPort     = 1235

	ApiPortName       = "port"
	ApiPythonPortName = "python-port"
	ApiPort           = 12345
	ApiPythonPort     = 25333

	AlerterPortName       = "port"
	AlerterActualPortName = "actual-port"
	AlerterPort           = 50052
	AlerterActualPort     = 50053
)
View Source 
const (
	DefaultRepository      = "quay.io/zncdatadev"
	DefaultProductVersion  = "3.2.2"
	DefaultProductName     = "dolphinscheduler"
	DefaultKubedoopVersion = "0.0.0-dev"
)

Variables

View Source 
var (
	// GroupVersion is group version used to register these objects
	GroupVersion = schema.GroupVersion{Group: "dolphinscheduler.kubedoop.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

func TransformImage 

func TransformImage(imageSpec *ImageSpec) *util.Image

Types

type AuthenticationSpec 

type AuthenticationSpec struct {
	// +kubebuilder:validation:Required
	AuthenticationClass string `json:"authenticationClass,omitempty"`

	// +kubebuilder:validation:Optional
	Oidc *OidcCredentialSecretSpec `json:"oidc,omitempty"`
}

func (*AuthenticationSpec) DeepCopy 

func (in *AuthenticationSpec) DeepCopy() *AuthenticationSpec

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

func (*AuthenticationSpec) DeepCopyInto 

func (in *AuthenticationSpec) DeepCopyInto(out *AuthenticationSpec)

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
	// +kubebuilder:default:="cluster.local"
	ClusterDomain string `json:"clusterDomain,omitempty"`

	// +kubebuilder:validation:Optional
	// +kubebuilder:default:="example.com"
	IngressHost string `json:"ingressHost,omitempty"`

	// +kubebuilder:validation:Optional
	VectorAggregatorConfigMapName string `json:"vectorAggregatorConfigMapName,omitempty"`

	// +kubebuilder:validation:Required
	ZookeeperConfigMapName string `json:"zookeeperConfigMapName,omitempty"`

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

	// +kubebuilder:validation:Required
	Database *DatabaseSpec `json:"database,omitempty"`

	// +kubebuilder:validation:Optional
	Authentication []AuthenticationSpec `json:"authentication,omitempty"`
}

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 ConfigSpec 

type ConfigSpec struct {
	*commonsv1alpha1.RoleGroupConfigSpec `json:",inline"`
}

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 DatabaseSpec 

type DatabaseSpec struct {
	// +kubebuilder:validation:Required
	ConnectionString string `json:"connectionString,omitempty"`

	// +kubebuilder:validation:Required
	// +kubebuilder:default="h2"
	DatabaseType string `json:"databaseType,omitempty"`

	// +kubebuilder:validation:Optional
	CredentialsSecret string `json:"credentialsSecret,omitempty"`
}

func (*DatabaseSpec) DeepCopy 

func (in *DatabaseSpec) DeepCopy() *DatabaseSpec

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

func (*DatabaseSpec) DeepCopyInto 

func (in *DatabaseSpec) DeepCopyInto(out *DatabaseSpec)

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

type DolphinschedulerCluster 

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

	Spec   DolphinschedulerClusterSpec `json:"spec,omitempty"`
	Status status.Status               `json:"status,omitempty"`
}

DolphinschedulerCluster is the Schema for the dolphinschedulerclusters API

func (*DolphinschedulerCluster) DeepCopy 

func (in *DolphinschedulerCluster) DeepCopy() *DolphinschedulerCluster

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

func (*DolphinschedulerCluster) DeepCopyInto 

func (in *DolphinschedulerCluster) DeepCopyInto(out *DolphinschedulerCluster)

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

func (*DolphinschedulerCluster) DeepCopyObject 

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

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

type DolphinschedulerClusterList 

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

DolphinschedulerClusterList contains a list of DolphinschedulerCluster

func (*DolphinschedulerClusterList) DeepCopy 

func (in *DolphinschedulerClusterList) DeepCopy() *DolphinschedulerClusterList

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

func (*DolphinschedulerClusterList) DeepCopyInto 

func (in *DolphinschedulerClusterList) DeepCopyInto(out *DolphinschedulerClusterList)

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

func (*DolphinschedulerClusterList) DeepCopyObject 

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

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

type DolphinschedulerClusterSpec 

type DolphinschedulerClusterSpec struct {
	// +kubebuilder:validation:Optional
	Image *ImageSpec `json:"image"`

	// +kubebuilder:validation:Optional
	ClusterConfig *ClusterConfigSpec `json:"clusterConfig,omitempty"`

	// +kubebuilder:validation:Optional
	ClusterOperationSpec *commonsv1alpha1.ClusterOperationSpec `json:"clusterOperation,omitempty"`

	// +kubebuilder:validation:Required
	Master *RoleSpec `json:"master,omitempty"`

	// +kubebuilder:validation:Required
	Worker *RoleSpec `json:"worker,omitempty"`

	// +kubebuilder:validation:Required
	Alerter *RoleSpec `json:"alerter,omitempty"`

	// +kubebuilder:validation:Required
	Api *RoleSpec `json:"api,omitempty"`
}

DolphinschedulerClusterSpec defines the desired state of DolphinschedulerCluster

func (*DolphinschedulerClusterSpec) DeepCopy 

func (in *DolphinschedulerClusterSpec) DeepCopy() *DolphinschedulerClusterSpec

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

func (*DolphinschedulerClusterSpec) DeepCopyInto 

func (in *DolphinschedulerClusterSpec) DeepCopyInto(out *DolphinschedulerClusterSpec)

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
	Custom string `json:"custom,omitempty"`

	// +kubebuilder:validation:Optional
	// +kubebuilder:default=quay.io/zncdatadev
	Repo string `json:"repository,omitempty"`

	// +kubebuilder:validation:Optional
	// +kubebuilder:default="0.0.0-dev"
	KubedoopVersion string `json:"koobdoopVersion,omitempty"`

	// +kubebuilder:validation:Optional
	// +kubebuilder:default="3.2.2"
	ProductVersion string `json:"productVersion,omitempty"`

	// +kubebuilder:validation:Optional
	// +kubebuilder:default:=IfNotPresent
	PullPolicy *corev1.PullPolicy `json:"pullPolicy,omitempty"`

	// +kubebuilder:validation:Optional
	PullSecretName string `json:"pullSecretName,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 OidcCredentialSecretSpec 

type OidcCredentialSecretSpec struct {
	// +kubebuilder:validation:Required
	Secret string `json:"secret,omitempty"`

	// +kubebuilder:validation:Optional
	ExtraScopes []string `json:"extraScopes,omitempty"`
}

func (*OidcCredentialSecretSpec) DeepCopy 

func (in *OidcCredentialSecretSpec) DeepCopy() *OidcCredentialSecretSpec

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

func (*OidcCredentialSecretSpec) DeepCopyInto 

func (in *OidcCredentialSecretSpec) DeepCopyInto(out *OidcCredentialSecretSpec)

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

	// +kubebuilder:validation:Optional
	Config *ConfigSpec `json:"config,omitempty"`

	*commonsv1alpha1.OverridesSpec `json:",inline"`
}

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 RoleSpec 

type RoleSpec struct {
	// +kubebuilder:validation:Optional
	Config *ConfigSpec `json:"config,omitempty"`

	// +kubebuilder:validation:Optional
	RoleGroups map[string]RoleGroupSpec `json:"roleGroups,omitempty"`

	// +kubebuilder:validation:Optional
	RoleConfig *commonsv1alpha1.RoleConfigSpec `json:"roleConfig,omitempty"`

	*commonsv1alpha1.OverridesSpec `json:",inline"`
}

func (*RoleSpec) DeepCopy 

func (in *RoleSpec) DeepCopy() *RoleSpec

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

func (*RoleSpec) DeepCopyInto 

func (in *RoleSpec) DeepCopyInto(out *RoleSpec)

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.