service

package
v1.0.0 Latest Latest
Warning

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

Go to latest
Published: Oct 15, 2021 License: Apache-2.0 Imports: 4 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL