Versions in this module Expand all Collapse all v1 v1.2.3 Aug 25, 2022 v1.0.2 Aug 25, 2022 v1.0.1 Aug 25, 2022 Changes in this version + type CDCPorts struct + DaemonPort int + MetricsPort int + type CNPorts struct + AccessPort int + DebugPort int + HtapPort int + LogPort int + MetricsPort int + MgrPort int + MppPort int + ProbePort int + type EnvFactory interface + NewEnvVarsForCDCEngine func(gmsConn StorageConnection) []corev1.EnvVar + NewEnvVarsForCNEngine func(gmsConn StorageConnection, ports CNPorts) []corev1.EnvVar + NewSystemEnvVars func() []corev1.EnvVar + func NewEnvFactory(rc *polardbxv1reconcile.Context, polardbx *polardbxv1.PolarDBXCluster) (EnvFactory, error) + type ObjectFactory interface + NewCDCMetricsService func() (*corev1.Service, error) + NewConfigMap func(cmType convention.ConfigMapType) (*corev1.ConfigMap, error) + NewDeployments4CDC func() (map[string]appsv1.Deployment, error) + NewDeployments4CN func() (map[string]appsv1.Deployment, error) + NewReadOnlyService func() (*corev1.Service, error) + NewSecret func() (*corev1.Secret, error) + NewSecuritySecret func() (*corev1.Secret, error) + NewService func() (*corev1.Service, error) + NewServiceMonitors func() (map[string]promv1.ServiceMonitor, error) + NewXStoreDN func(idx int) (*polardbxv1.XStore, error) + NewXStoreGMS func() (*polardbxv1.XStore, error) + NewXStoreMyCnfOverlay4DN func(idx int) (string, error) + NewXStoreMyCnfOverlay4GMS func() (string, error) + func NewObjectFactory(rc *polardbxv1reconcile.Context) ObjectFactory + type PortsFactory interface + NewPortsForCDCEngine func() CDCPorts + NewPortsForCNEngine func() CNPorts + func NewPortsFactory(rc *polardbxv1reconcile.Context, polardbx *polardbxv1.PolarDBXCluster) PortsFactory + type ProbeConfigure interface + ConfigureForCDCEngine func(container *corev1.Container, ports CDCPorts) + ConfigureForCDCExporter func(container *corev1.Container, ports CDCPorts) + ConfigureForCNEngine func(container *corev1.Container, ports CNPorts) + ConfigureForCNExporter func(container *corev1.Container, ports CNPorts) + func NewProbeConfigure(rc *polardbxv1reconcile.Context, pxc *polardbxv1.PolarDBXCluster) ProbeConfigure + type StorageConnection struct + Database string + Host string + Passwd string + Port int + User string + type VolumeFactory interface + NewSystemVolumeMounts func() []corev1.VolumeMount + NewSystemVolumes func() []corev1.Volume + NewVolumeMountsForCDCEngine func() []corev1.VolumeMount + NewVolumeMountsForCNEngine func() []corev1.VolumeMount + NewVolumeMountsForCNExporter func() []corev1.VolumeMount + NewVolumesForCDC func() []corev1.Volume + NewVolumesForCN func() []corev1.Volume + func NewVolumeFactory(rc *polardbxv1reconcile.Context, polardbx *polardbxv1.PolarDBXCluster) VolumeFactory