v1alpha1

Nov 26, 2024

Changes in this version

+ const AccountKey

+ const AccountName

+ const DefaultDataSizeForMonitoring

+ type AZBlobStorage struct

+ Container string

+ Endpoint string

+ Root string

+ SecretName string

+ func (in *AZBlobStorage) DeepCopy() *AZBlobStorage

+ func (in *AZBlobStorage) DeepCopyInto(out *AZBlobStorage)

+ func (in *AZBlobStorage) GetRoot() string

+ func (in *AZBlobStorage) GetSecretName() string

type DatanodeSpec

+ RollingUpdate *appsv1.RollingUpdateStatefulSetStrategy

type FlownodeSpec

+ RollingUpdate *appsv1.RollingUpdateStatefulSetStrategy

type FrontendSpec

+ RollingUpdate *appsv1.RollingUpdateDeployment

type GreptimeDBStandaloneSpec

+ RollingUpdate *appsv1.RollingUpdateStatefulSetStrategy

type LoggingSpec

+ Filters []string

+ SlowQuery *SlowQuery

type MainContainerSpec

+ SecurityContext *corev1.SecurityContext

+ StartupProbe *corev1.Probe

type MetaSpec

+ RollingUpdate *appsv1.RollingUpdateDeployment

type ObjectStorageProviderAccessor

+ GetAZBlobStorage func() *AZBlobStorage

type ObjectStorageProviderSpec

+ AZBlob *AZBlobStorage

+ func (in *ObjectStorageProviderSpec) GetAZBlobStorage() *AZBlobStorage

type SlimPodSpec

+ SecurityContext *corev1.PodSecurityContext

+ type SlowQuery struct

+ Enabled bool

+ SampleRatio string

+ Threshold string

+ func (in *SlowQuery) DeepCopy() *SlowQuery

+ func (in *SlowQuery) DeepCopyInto(out *SlowQuery)

Oct 18, 2024

Changes in this version

type VectorSpec

+ Resources corev1.ResourceRequirements

Oct 16, 2024

Changes in this version

+ const DefaultGreptimeDBImage

+ const DefaultHealthEndpoint

+ const DefaultVectorCPURequest

+ const DefaultVectorImage

+ const DefaultVectorMemoryRequest

type FrontendSpec

+ HTTPPort int32

+ MySQLPort int32

+ PostgreSQLPort int32

+ RPCPort int32

type GCSStorage

+ func (in *GCSStorage) GetRoot() string

type GreptimeDBCluster

+ func (in *GreptimeDBCluster) GetMonitoring() *MonitoringSpec

+ func (in *GreptimeDBCluster) MergeLogging() error

+ func (in *GreptimeDBCluster) MergeTemplate() error

type GreptimeDBClusterSpec

+ Monitoring *MonitoringSpec

type GreptimeDBClusterStatus

+ Monitoring MonitoringStatus

+ type LogPipeline struct

+ Data string

+ func (in *LogPipeline) DeepCopy() *LogPipeline

+ func (in *LogPipeline) DeepCopyInto(out *LogPipeline)

+ func (in *LogPipeline) GetData() string

+ type LogsCollectionSpec struct

+ Pipeline *LogPipeline

+ func (in *LogsCollectionSpec) DeepCopy() *LogsCollectionSpec

+ func (in *LogsCollectionSpec) DeepCopyInto(out *LogsCollectionSpec)

+ func (in *LogsCollectionSpec) GetPipeline() *LogPipeline

+ type MonitoringSpec struct

+ Enabled bool

+ LogsCollection *LogsCollectionSpec

+ Standalone *GreptimeDBStandaloneSpec

+ Vector *VectorSpec

+ func (in *MonitoringSpec) DeepCopy() *MonitoringSpec

+ func (in *MonitoringSpec) DeepCopyInto(out *MonitoringSpec)

+ func (in *MonitoringSpec) GetLogsCollection() *LogsCollectionSpec

+ func (in *MonitoringSpec) GetStandalone() *GreptimeDBStandaloneSpec

+ func (in *MonitoringSpec) GetVector() *VectorSpec

+ func (in *MonitoringSpec) IsEnabled() bool

+ type MonitoringStatus struct

+ InternalDNSName string

+ func (in *MonitoringStatus) DeepCopy() *MonitoringStatus

+ func (in *MonitoringStatus) DeepCopyInto(out *MonitoringStatus)

type OSSStorage

+ func (in *OSSStorage) GetRoot() string

type S3Storage

+ func (in *S3Storage) GetRoot() string

+ type VectorSpec struct

+ Image string

+ Resource corev1.ResourceRequirements

+ func (in *VectorSpec) DeepCopy() *VectorSpec

+ func (in *VectorSpec) DeepCopyInto(out *VectorSpec)

Sep 27, 2024

Changes in this version

+ const AccessKeyIDSecretKey

+ const DefaultDataHome

+ const DefaultDataSize

+ const DefaultDatanodeFileStorageName

+ const DefaultHTTPPort

+ const DefaultInitializerImage

+ const DefaultLoggingLevel

+ const DefaultLogsDir

+ const DefaultMetaRPCPort

+ const DefaultMySQLPort

+ const DefaultPostgreSQLPort

+ const DefaultRPCPort

+ const DefaultReplicas

+ const DefaultStorageRetainPolicyType

+ const DefaultVersion

+ const DefautlHealthEndpoint

+ const SecretAccessKeySecretKey

+ const ServiceAccountKey

+ const TLSCrtSecretKey

+ const TLSKeySecretKey

+ var AddToScheme = SchemeBuilder.AddToScheme

+ var GroupVersion = schema.GroupVersion

+ var SchemeBuilder = &scheme.Builder

+ type CacheStorage struct

+ CacheCapacity string

+ FileStorage *FileStorage

+ func (in *CacheStorage) DeepCopy() *CacheStorage

+ func (in *CacheStorage) DeepCopyInto(out *CacheStorage)

+ type ComponentKind string

+ const DatanodeComponentKind

+ const FlownodeComponentKind

+ const FrontendComponentKind

+ const MetaComponentKind

+ const StandaloneKind

+ type ComponentSpec struct

+ Config string

+ Logging *LoggingSpec

+ Replicas *int32

+ Template *PodTemplateSpec

+ func (in *ComponentSpec) DeepCopy() *ComponentSpec

+ func (in *ComponentSpec) DeepCopyInto(out *ComponentSpec)

+ type Condition struct

+ LastTransitionTime metav1.Time

+ LastUpdateTime metav1.Time

+ Message string

+ Reason string

+ Status corev1.ConditionStatus

+ Type ConditionType

+ func GetCondition(conditions []Condition, conditionType ConditionType) *Condition

+ func NewCondition(conditionType ConditionType, conditionStatus corev1.ConditionStatus, ...) *Condition

+ func SetCondition(conditions []Condition, condition Condition) []Condition

+ func (in *Condition) DeepCopy() *Condition

+ func (in *Condition) DeepCopyInto(out *Condition)

+ type ConditionType string

+ const ConditionTypeProgressing

+ const ConditionTypeReady

+ type DatanodeSpec struct

+ HTTPPort int32

+ RPCPort int32

+ Storage *DatanodeStorageSpec

+ func (in *DatanodeSpec) DeepCopy() *DatanodeSpec

+ func (in *DatanodeSpec) DeepCopyInto(out *DatanodeSpec)

+ func (in *DatanodeSpec) GetConfig() string

+ func (in *DatanodeSpec) GetDataHome() string

+ func (in *DatanodeSpec) GetFileStorage() *FileStorage

+ func (in *DatanodeSpec) GetLogging() *LoggingSpec

+ type DatanodeStatus struct

+ ReadyReplicas int32

+ Replicas int32

+ func (in *DatanodeStatus) DeepCopy() *DatanodeStatus

+ func (in *DatanodeStatus) DeepCopyInto(out *DatanodeStatus)

+ type DatanodeStorageSpec struct

+ DataHome string

+ FileStorage *FileStorage

+ func (in *DatanodeStorageSpec) DeepCopy() *DatanodeStorageSpec

+ func (in *DatanodeStorageSpec) DeepCopyInto(out *DatanodeStorageSpec)

+ type FileStorage struct

+ MountPath string

+ Name string

+ StorageClassName *string

+ StorageRetainPolicy StorageRetainPolicyType

+ StorageSize string

+ func (in *FileStorage) DeepCopy() *FileStorage

+ func (in *FileStorage) DeepCopyInto(out *FileStorage)

+ func (in *FileStorage) GetMountPath() string

+ func (in *FileStorage) GetName() string

+ func (in *FileStorage) GetPolicy() StorageRetainPolicyType

+ func (in *FileStorage) GetSize() string

+ func (in *FileStorage) GetStorageClassName() *string

+ type FileStorageAccessor interface

+ GetMountPath func() string

+ GetName func() string

+ GetPolicy func() StorageRetainPolicyType

+ GetSize func() string

+ GetStorageClassName func() *string

+ type FlownodeSpec struct

+ RPCPort int32

+ func (in *FlownodeSpec) DeepCopy() *FlownodeSpec

+ func (in *FlownodeSpec) DeepCopyInto(out *FlownodeSpec)

+ func (in *FlownodeSpec) GetConfig() string

+ func (in *FlownodeSpec) GetLogging() *LoggingSpec

+ type FlownodeStatus struct

+ ReadyReplicas int32

+ Replicas int32

+ func (in *FlownodeStatus) DeepCopy() *FlownodeStatus

+ func (in *FlownodeStatus) DeepCopyInto(out *FlownodeStatus)

+ type FrontendSpec struct

+ Service *ServiceSpec

+ TLS *TLSSpec

+ func (in *FrontendSpec) DeepCopy() *FrontendSpec

+ func (in *FrontendSpec) DeepCopyInto(out *FrontendSpec)

+ func (in *FrontendSpec) GetConfig() string

+ func (in *FrontendSpec) GetLogging() *LoggingSpec

+ func (in *FrontendSpec) GetService() *ServiceSpec

+ func (in *FrontendSpec) GetTLS() *TLSSpec

+ type FrontendStatus struct

+ ReadyReplicas int32

+ Replicas int32

+ func (in *FrontendStatus) DeepCopy() *FrontendStatus

+ func (in *FrontendStatus) DeepCopyInto(out *FrontendStatus)

+ type GCSStorage struct

+ Bucket string

+ Endpoint string

+ Root string

+ Scope string

+ SecretName string

+ func (in *GCSStorage) DeepCopy() *GCSStorage

+ func (in *GCSStorage) DeepCopyInto(out *GCSStorage)

+ func (in *GCSStorage) GetSecretName() string

+ type GreptimeDBCluster struct

+ Spec GreptimeDBClusterSpec

+ Status GreptimeDBClusterStatus

+ func (in *GreptimeDBCluster) Check(ctx context.Context, client client.Client) error

+ func (in *GreptimeDBCluster) DeepCopy() *GreptimeDBCluster

+ func (in *GreptimeDBCluster) DeepCopyInto(out *GreptimeDBCluster)

+ func (in *GreptimeDBCluster) DeepCopyObject() runtime.Object

+ func (in *GreptimeDBCluster) GetBaseMainContainer() *MainContainerSpec

+ func (in *GreptimeDBCluster) GetDatanode() *DatanodeSpec

+ func (in *GreptimeDBCluster) GetFlownode() *FlownodeSpec

+ func (in *GreptimeDBCluster) GetFrontend() *FrontendSpec

+ func (in *GreptimeDBCluster) GetLogging() *LoggingSpec

+ func (in *GreptimeDBCluster) GetMeta() *MetaSpec

+ func (in *GreptimeDBCluster) GetObjectStorageProvider() *ObjectStorageProviderSpec

+ func (in *GreptimeDBCluster) GetPrometheusMonitor() *PrometheusMonitorSpec

+ func (in *GreptimeDBCluster) GetVersion() string

+ func (in *GreptimeDBCluster) GetWALDir() string

+ func (in *GreptimeDBCluster) GetWALProvider() *WALProviderSpec

+ func (in *GreptimeDBCluster) SetDefaults() error

+ func (in *GreptimeDBCluster) Validate() error

+ type GreptimeDBClusterList struct

+ Items []GreptimeDBCluster

+ func (in *GreptimeDBClusterList) DeepCopy() *GreptimeDBClusterList

+ func (in *GreptimeDBClusterList) DeepCopyInto(out *GreptimeDBClusterList)

+ func (in *GreptimeDBClusterList) DeepCopyObject() runtime.Object

+ type GreptimeDBClusterSpec struct

+ Base *PodTemplateSpec

+ Datanode *DatanodeSpec

+ Flownode *FlownodeSpec

+ Frontend *FrontendSpec

+ HTTPPort int32

+ Initializer *InitializerSpec

+ Logging *LoggingSpec

+ Meta *MetaSpec

+ MySQLPort int32

+ ObjectStorageProvider *ObjectStorageProviderSpec

+ PostgreSQLPort int32

+ PrometheusMonitor *PrometheusMonitorSpec

+ RPCPort int32

+ Version string

+ WALProvider *WALProviderSpec

+ func (in *GreptimeDBClusterSpec) DeepCopy() *GreptimeDBClusterSpec

+ func (in *GreptimeDBClusterSpec) DeepCopyInto(out *GreptimeDBClusterSpec)

+ type GreptimeDBClusterStatus struct

+ ClusterPhase Phase

+ Conditions []Condition

+ Datanode DatanodeStatus

+ Flownode FlownodeStatus

+ Frontend FrontendStatus

+ Meta MetaStatus

+ ObservedGeneration *int64

+ Version string

+ func (in *GreptimeDBClusterStatus) DeepCopy() *GreptimeDBClusterStatus

+ func (in *GreptimeDBClusterStatus) DeepCopyInto(out *GreptimeDBClusterStatus)

+ func (in *GreptimeDBClusterStatus) GetCondition(conditionType ConditionType) *Condition

+ func (in *GreptimeDBClusterStatus) SetCondition(condition Condition)

+ type GreptimeDBStandalone struct

+ Spec GreptimeDBStandaloneSpec

+ Status GreptimeDBStandaloneStatus

+ func (in *GreptimeDBStandalone) Check(ctx context.Context, client client.Client) error

+ func (in *GreptimeDBStandalone) DeepCopy() *GreptimeDBStandalone

+ func (in *GreptimeDBStandalone) DeepCopyInto(out *GreptimeDBStandalone)

+ func (in *GreptimeDBStandalone) DeepCopyObject() runtime.Object

+ func (in *GreptimeDBStandalone) GetBaseMainContainer() *MainContainerSpec

+ func (in *GreptimeDBStandalone) GetConfig() string

+ func (in *GreptimeDBStandalone) GetDataHome() string

+ func (in *GreptimeDBStandalone) GetDatanodeFileStorage() *FileStorage

+ func (in *GreptimeDBStandalone) GetLogging() *LoggingSpec

+ func (in *GreptimeDBStandalone) GetObjectStorageProvider() *ObjectStorageProviderSpec

+ func (in *GreptimeDBStandalone) GetPrometheusMonitor() *PrometheusMonitorSpec

+ func (in *GreptimeDBStandalone) GetTLS() *TLSSpec

+ func (in *GreptimeDBStandalone) GetVersion() string

+ func (in *GreptimeDBStandalone) GetWALDir() string

+ func (in *GreptimeDBStandalone) GetWALProvider() *WALProviderSpec

+ func (in *GreptimeDBStandalone) SetDefaults() error

+ func (in *GreptimeDBStandalone) Validate() error

+ type GreptimeDBStandaloneList struct

+ Items []GreptimeDBStandalone

+ func (in *GreptimeDBStandaloneList) DeepCopy() *GreptimeDBStandaloneList

+ func (in *GreptimeDBStandaloneList) DeepCopyInto(out *GreptimeDBStandaloneList)

+ func (in *GreptimeDBStandaloneList) DeepCopyObject() runtime.Object

+ type GreptimeDBStandaloneSpec struct

+ Base *PodTemplateSpec

+ Config string

+ DatanodeStorage *DatanodeStorageSpec

+ HTTPPort int32

+ Initializer *InitializerSpec

+ Logging *LoggingSpec

+ MySQLPort int32

+ ObjectStorageProvider *ObjectStorageProviderSpec

+ PostgreSQLPort int32

+ PrometheusMonitor *PrometheusMonitorSpec

+ RPCPort int32

+ Service *ServiceSpec

+ TLS *TLSSpec

+ Version string

+ WALProvider *WALProviderSpec

+ func (in *GreptimeDBStandaloneSpec) DeepCopy() *GreptimeDBStandaloneSpec

+ func (in *GreptimeDBStandaloneSpec) DeepCopyInto(out *GreptimeDBStandaloneSpec)

+ type GreptimeDBStandaloneStatus struct

+ Conditions []Condition

+ ObservedGeneration *int64

+ StandalonePhase Phase

+ Version string

+ func (in *GreptimeDBStandaloneStatus) DeepCopy() *GreptimeDBStandaloneStatus

+ func (in *GreptimeDBStandaloneStatus) DeepCopyInto(out *GreptimeDBStandaloneStatus)

+ func (in *GreptimeDBStandaloneStatus) GetCondition(conditionType ConditionType) *Condition

+ func (in *GreptimeDBStandaloneStatus) SetCondition(condition Condition)

+ type InitializerSpec struct

+ Image string

+ func (in *InitializerSpec) DeepCopy() *InitializerSpec

+ func (in *InitializerSpec) DeepCopyInto(out *InitializerSpec)

+ type KafkaWAL struct

+ BrokerEndpoints []string

+ func (in *KafkaWAL) DeepCopy() *KafkaWAL

+ func (in *KafkaWAL) DeepCopyInto(out *KafkaWAL)

+ func (in *KafkaWAL) GetBrokerEndpoints() []string

+ type LogFormat string

+ const LogFormatJSON

+ const LogFormatText

+ type LoggingLevel string

+ const LoggingLevelDebug

+ const LoggingLevelError

+ const LoggingLevelInfo

+ const LoggingLevelWarn

+ type LoggingSpec struct

+ Format LogFormat

+ Level LoggingLevel

+ LogsDir string

+ OnlyLogToStdout *bool

+ PersistentWithData *bool

+ func (in *LoggingSpec) DeepCopy() *LoggingSpec

+ func (in *LoggingSpec) DeepCopyInto(out *LoggingSpec)

+ func (in *LoggingSpec) GetLevel() LoggingLevel

+ func (in *LoggingSpec) GetLogsDir() string

+ func (in *LoggingSpec) IsOnlyLogToStdout() bool

+ func (in *LoggingSpec) IsPersistentWithData() bool

+ type MainContainerSpec struct

+ Args []string

+ Command []string

+ Env []corev1.EnvVar

+ Image string

+ ImagePullPolicy corev1.PullPolicy

+ Lifecycle *corev1.Lifecycle

+ LivenessProbe *corev1.Probe

+ ReadinessProbe *corev1.Probe

+ Resources corev1.ResourceRequirements

+ VolumeMounts []corev1.VolumeMount

+ WorkingDir string

+ func (in *MainContainerSpec) DeepCopy() *MainContainerSpec

+ func (in *MainContainerSpec) DeepCopyInto(out *MainContainerSpec)

+ func (in *MainContainerSpec) GetImage() string

+ type MetaSpec struct

+ EnableCheckEtcdService bool

+ EnableRegionFailover *bool

+ EtcdEndpoints []string

+ HTTPPort int32

+ RPCPort int32

+ StoreKeyPrefix string

+ func (in *MetaSpec) DeepCopy() *MetaSpec

+ func (in *MetaSpec) DeepCopyInto(out *MetaSpec)

+ func (in *MetaSpec) GetConfig() string

+ func (in *MetaSpec) GetEtcdEndpoints() []string

+ func (in *MetaSpec) GetLogging() *LoggingSpec

+ func (in *MetaSpec) GetStoreKeyPrefix() string

+ func (in *MetaSpec) IsEnableCheckEtcdService() bool

+ func (in *MetaSpec) IsEnableRegionFailover() bool

+ type MetaStatus struct

+ EtcdEndpoints []string

+ ReadyReplicas int32

+ Replicas int32

+ func (in *MetaStatus) DeepCopy() *MetaStatus

+ func (in *MetaStatus) DeepCopyInto(out *MetaStatus)

+ type OSSStorage struct

+ Bucket string

+ Endpoint string

+ Region string

+ Root string

+ SecretName string

+ func (in *OSSStorage) DeepCopy() *OSSStorage

+ func (in *OSSStorage) DeepCopyInto(out *OSSStorage)

+ func (in *OSSStorage) GetSecretName() string

+ type ObjectStorageProviderAccessor interface

+ GetCacheFileStorage func() *FileStorage

+ GetGCSStorage func() *GCSStorage

+ GetOSSStorage func() *OSSStorage

+ GetS3Storage func() *S3Storage

+ type ObjectStorageProviderSpec struct

+ Cache *CacheStorage

+ GCS *GCSStorage

+ OSS *OSSStorage

+ S3 *S3Storage

+ func (in *ObjectStorageProviderSpec) DeepCopy() *ObjectStorageProviderSpec

+ func (in *ObjectStorageProviderSpec) DeepCopyInto(out *ObjectStorageProviderSpec)

+ func (in *ObjectStorageProviderSpec) GetCacheFileStorage() *FileStorage

+ func (in *ObjectStorageProviderSpec) GetGCSStorage() *GCSStorage

+ func (in *ObjectStorageProviderSpec) GetOSSStorage() *OSSStorage

+ func (in *ObjectStorageProviderSpec) GetS3Storage() *S3Storage

+ type Phase string

+ const PhaseError

+ const PhaseRunning

+ const PhaseStarting

+ const PhaseTerminating

+ const PhaseUpdating

+ type PodTemplateSpec struct

+ Annotations map[string]string

+ Labels map[string]string

+ MainContainer *MainContainerSpec

+ func (in *PodTemplateSpec) DeepCopy() *PodTemplateSpec

+ func (in *PodTemplateSpec) DeepCopyInto(out *PodTemplateSpec)

+ type PrometheusMonitorSpec struct

+ Enabled bool

+ Interval string

+ Labels map[string]string

+ func (in *PrometheusMonitorSpec) DeepCopy() *PrometheusMonitorSpec

+ func (in *PrometheusMonitorSpec) DeepCopyInto(out *PrometheusMonitorSpec)

+ func (in *PrometheusMonitorSpec) IsEnablePrometheusMonitor() bool

+ type RaftEngineWAL struct

+ FileStorage *FileStorage

+ func (in *RaftEngineWAL) DeepCopy() *RaftEngineWAL

+ func (in *RaftEngineWAL) DeepCopyInto(out *RaftEngineWAL)

+ func (in *RaftEngineWAL) GetFileStorage() *FileStorage

+ type S3Storage struct

+ Bucket string

+ Endpoint string

+ Region string

+ Root string

+ SecretName string

+ func (in *S3Storage) DeepCopy() *S3Storage

+ func (in *S3Storage) DeepCopyInto(out *S3Storage)

+ func (in *S3Storage) GetSecretName() string

+ type ServiceSpec struct

+ Annotations map[string]string

+ Labels map[string]string

+ LoadBalancerClass *string

+ Type corev1.ServiceType

+ func (in *ServiceSpec) DeepCopy() *ServiceSpec

+ func (in *ServiceSpec) DeepCopyInto(out *ServiceSpec)

+ type SlimPodSpec struct

+ ActiveDeadlineSeconds *int64

+ AdditionalContainers []corev1.Container

+ Affinity *corev1.Affinity

+ DNSPolicy corev1.DNSPolicy

+ HostNetwork bool

+ ImagePullSecrets []corev1.LocalObjectReference

+ InitContainers []corev1.Container

+ NodeSelector map[string]string

+ RestartPolicy corev1.RestartPolicy

+ SchedulerName string

+ ServiceAccountName string

+ TerminationGracePeriodSeconds *int64

+ Tolerations []corev1.Toleration

+ Volumes []corev1.Volume

+ func (in *SlimPodSpec) DeepCopy() *SlimPodSpec

+ func (in *SlimPodSpec) DeepCopyInto(out *SlimPodSpec)

+ type StorageRetainPolicyType string

+ const StorageRetainPolicyTypeDelete

+ const StorageRetainPolicyTypeRetain

+ type TLSSpec struct

+ SecretName string

+ func (in *TLSSpec) DeepCopy() *TLSSpec

+ func (in *TLSSpec) DeepCopyInto(out *TLSSpec)

+ func (in *TLSSpec) GetSecretName() string

+ type WALProviderSpec struct

+ KafkaWAL *KafkaWAL

+ RaftEngineWAL *RaftEngineWAL

+ func (in *WALProviderSpec) DeepCopy() *WALProviderSpec

+ func (in *WALProviderSpec) DeepCopyInto(out *WALProviderSpec)

+ func (in *WALProviderSpec) GetKafkaWAL() *KafkaWAL

+ func (in *WALProviderSpec) GetRaftEngineWAL() *RaftEngineWAL