factory

Documentation

Index

• type CDCPorts
• type CNPorts
• type EnvFactory
  • func NewEnvFactory(rc *polardbxv1reconcile.Context, polardbx *polardbxv1.PolarDBXCluster) (EnvFactory, error)
• type ObjectFactory
  • func NewObjectFactory(rc *polardbxv1reconcile.Context) ObjectFactory
• type PortsFactory
  • func NewPortsFactory(rc *polardbxv1reconcile.Context, polardbx *polardbxv1.PolarDBXCluster) PortsFactory
• type ProbeConfigure
  • func NewProbeConfigure(rc *polardbxv1reconcile.Context, pxc *polardbxv1.PolarDBXCluster) ProbeConfigure
• type StorageConnection
• type VolumeFactory
  • func NewVolumeFactory(rc *polardbxv1reconcile.Context, polardbx *polardbxv1.PolarDBXCluster) VolumeFactory

Types

type CDCPorts

type CDCPorts struct {
	DaemonPort  int
	MetricsPort int
}

type CNPorts

type CNPorts struct {
	AccessPort  int
	MgrPort     int
	MppPort     int
	HtapPort    int
	LogPort     int
	DebugPort   int
	MetricsPort int
	ProbePort   int
}

type EnvFactory

type EnvFactory interface {
	NewSystemEnvVars() []corev1.EnvVar
	NewEnvVarsForCNEngine(gmsConn StorageConnection, ports CNPorts) []corev1.EnvVar
	NewEnvVarsForCDCEngine(gmsConn StorageConnection) []corev1.EnvVar
}

func NewEnvFactory

func NewEnvFactory(rc *polardbxv1reconcile.Context, polardbx *polardbxv1.PolarDBXCluster) (EnvFactory, error)

type ObjectFactory

type ObjectFactory interface {
	NewService() (*corev1.Service, error)
	NewReadOnlyService() (*corev1.Service, error)
	NewCDCMetricsService() (*corev1.Service, error)

	NewDeployments4CN() (map[string]appsv1.Deployment, error)
	NewDeployments4CDC() (map[string]appsv1.Deployment, error)

	NewXStoreMyCnfOverlay4GMS() (string, error)
	NewXStoreMyCnfOverlay4DN(idx int) (string, error)
	NewXStoreGMS() (*polardbxv1.XStore, error)
	NewXStoreDN(idx int) (*polardbxv1.XStore, error)

	NewSecret() (*corev1.Secret, error)
	NewSecuritySecret() (*corev1.Secret, error)
	NewConfigMap(cmType convention.ConfigMapType) (*corev1.ConfigMap, error)

	NewServiceMonitors() (map[string]promv1.ServiceMonitor, error)
}

func NewObjectFactory

func NewObjectFactory(rc *polardbxv1reconcile.Context) ObjectFactory

type PortsFactory

type PortsFactory interface {
	NewPortsForCNEngine() CNPorts
	NewPortsForCDCEngine() CDCPorts
}

func NewPortsFactory

func NewPortsFactory(rc *polardbxv1reconcile.Context, polardbx *polardbxv1.PolarDBXCluster) PortsFactory

type ProbeConfigure

type ProbeConfigure interface {
	ConfigureForCNEngine(container *corev1.Container, ports CNPorts)
	ConfigureForCNExporter(container *corev1.Container, ports CNPorts)
	ConfigureForCDCEngine(container *corev1.Container, ports CDCPorts)
	ConfigureForCDCExporter(container *corev1.Container, ports CDCPorts)
}

func NewProbeConfigure

func NewProbeConfigure(rc *polardbxv1reconcile.Context, pxc *polardbxv1.PolarDBXCluster) ProbeConfigure

type StorageConnection

type StorageConnection struct {
	Host     string
	Port     int
	User     string
	Passwd   string
	Database string
}

type VolumeFactory

type VolumeFactory interface {
	NewSystemVolumes() []corev1.Volume
	NewSystemVolumeMounts() []corev1.VolumeMount
	NewVolumesForCN() []corev1.Volume
	NewVolumeMountsForCNEngine() []corev1.VolumeMount
	NewVolumeMountsForCNExporter() []corev1.VolumeMount
	NewVolumesForCDC() []corev1.Volume
	NewVolumeMountsForCDCEngine() []corev1.VolumeMount
}

func NewVolumeFactory

func NewVolumeFactory(rc *polardbxv1reconcile.Context, polardbx *polardbxv1.PolarDBXCluster) VolumeFactory