service

Documentation

Index

• type CmCreatorService
  • func NewCmCreatorService(cmCreator domain.IClusterManagerCreator) *CmCreatorService
  • func (s *CmCreatorService) CreateClusterManager(ctx context.Context, kubeObj metav1.Object, workMode domain.CmWorkMode, ...) error
• type EngineClassService
  • func NewEngineClassService(classQuery domain.IClassQuery) *EngineClassService
  • func (s *EngineClassService) GetEngineClasses(engineType domain.EngineType) (*domain.EngineClasses, error)
• type EngineParamsTemplateService
  • func NewEngineParamsTemplateService(templateQuery domain.IEngineParamsTemplateQuery, ...) *EngineParamsTemplateService
  • func (s *EngineParamsTemplateService) GetParamsTemplate(engineType domain.EngineType, className string) (*domain.ParamsTemplate, error)
• type MinorVersionService
  • func NewMinorVersionService(query domain.IMinorVersionQuery) *MinorVersionService
  • func (s *MinorVersionService) GetMinorVersions(engineType domain.EngineType) (*domain.MinorVersions, error)

Types

type CmCreatorService

type CmCreatorService struct {
	// contains filtered or unexported fields
}

func NewCmCreatorService

func NewCmCreatorService(
	cmCreator domain.IClusterManagerCreator,
) *CmCreatorService

func (*CmCreatorService) CreateClusterManager

func (s *CmCreatorService) CreateClusterManager(ctx context.Context, kubeObj metav1.Object, workMode domain.CmWorkMode, logicInsId, rwPhyId, cmImage string, port int, pluginConf map[string]interface{}, consensusPort int) error

*

• @Description: 创建ClusterManager
• @param ctx
• @param kubeObj dbcluster/standby k8s对象
• @param logicInsId
• @param rwPhyId
• @param cmImage
• @param port
• @return error

type EngineClassService

type EngineClassService struct {
	// contains filtered or unexported fields
}

func NewEngineClassService

func NewEngineClassService(
	classQuery domain.IClassQuery,
) *EngineClassService

func (*EngineClassService) GetEngineClasses

func (s *EngineClassService) GetEngineClasses(engineType domain.EngineType) (*domain.EngineClasses, error)

type EngineParamsTemplateService

type EngineParamsTemplateService struct {
	// contains filtered or unexported fields
}

func NewEngineParamsTemplateService

func NewEngineParamsTemplateService(
	templateQuery domain.IEngineParamsTemplateQuery,
	classQuery domain.IEngineParamsClassQuery,
	logger logr.Logger,
) *EngineParamsTemplateService

func (*EngineParamsTemplateService) GetParamsTemplate

func (s *EngineParamsTemplateService) GetParamsTemplate(engineType domain.EngineType, className string) (*domain.ParamsTemplate, error)

type MinorVersionService

type MinorVersionService struct {
	Query domain.IMinorVersionQuery
}

func NewMinorVersionService

func NewMinorVersionService(
	query domain.IMinorVersionQuery,
) *MinorVersionService

func (*MinorVersionService) GetMinorVersions

func (s *MinorVersionService) GetMinorVersions(engineType domain.EngineType) (*domain.MinorVersions, error)