Documentation ¶
Index ¶
- type LocalStorageClusterService
- func (s *LocalStorageClusterService) CreatePod(ctx context.Context, cluster *domain.LocalStorageCluster, ...) error
- func (s *LocalStorageClusterService) GetByData(data interface{}, useModifyClass bool, useUpgradeVersion bool) *domain.LocalStorageCluster
- func (s *LocalStorageClusterService) InitStatusInfo(cluster *domain.LocalStorageCluster) error
- func (s *LocalStorageClusterService) InstallDBEngine(ctx context.Context, ins *commondomain.DbIns) error
- type SharedStorageClusterService
- func (s *SharedStorageClusterService) ConvertTempRoForRwToRo(ctx context.Context, cluster *domain.SharedStorageCluster) error
- func (s *SharedStorageClusterService) CreateAndInstallIns(ctx context.Context, cluster *domain.SharedStorageCluster, ...) error
- func (s *SharedStorageClusterService) CreateRoIns(ctx context.Context, cluster *domain.SharedStorageCluster, ...) error
- func (s *SharedStorageClusterService) CreateRwIns(ctx context.Context, cluster *domain.SharedStorageCluster, ...) error
- func (s *SharedStorageClusterService) CreateTempRoIns(ctx context.Context, cluster *domain.SharedStorageCluster, ...) error
- func (s *SharedStorageClusterService) DeleteAllInsPod(cluster *domain.SharedStorageCluster, ctx context.Context) error
- func (s *SharedStorageClusterService) DeleteCm(ctx context.Context, sb *domain.SharedStorageCluster) error
- func (s *SharedStorageClusterService) DeleteOldIns(ctx context.Context, cluster *domain.SharedStorageCluster, ...) error
- func (s *SharedStorageClusterService) DeleteOldRw(ctx context.Context, cluster *domain.SharedStorageCluster) error
- func (s *SharedStorageClusterService) DisableHA(ctx context.Context, sb *domain.SharedStorageCluster) error
- func (s *SharedStorageClusterService) EnableHA(ctx context.Context, sb *domain.SharedStorageCluster) error
- func (s *SharedStorageClusterService) EnsureCmAffinity(ctx context.Context, sb *domain.SharedStorageCluster) error
- func (s *SharedStorageClusterService) EnsureInsTypeMeta(ctx context.Context, cluster *domain.SharedStorageCluster) error
- func (s *SharedStorageClusterService) EnsureNewRoUpToDate(ctx context.Context, cluster *domain.SharedStorageCluster) error
- func (s *SharedStorageClusterService) FlushClusterParams(ctx context.Context, sb *domain.SharedStorageCluster) (bool, error)
- func (s *SharedStorageClusterService) FlushParamsIfNecessary(ctx context.Context, cluster *domain.SharedStorageCluster) error
- func (s *SharedStorageClusterService) GenerateNewRoTempId(ctx context.Context, cluster *domain.SharedStorageCluster) error
- func (s *SharedStorageClusterService) GenerateTempRoId(ctx context.Context, cluster *domain.SharedStorageCluster, insId string) error
- func (s *SharedStorageClusterService) GenerateTempRoIds(ctx context.Context, cluster *domain.SharedStorageCluster) error
- func (s *SharedStorageClusterService) GetAll() ([]*domain.SharedStorageCluster, error)
- func (s *SharedStorageClusterService) GetByData(data interface{}, useModifyClass bool, useUpgradeVersion bool) *domain.SharedStorageCluster
- func (s *SharedStorageClusterService) GetByName(name, namespace string) (*domain.SharedStorageCluster, error)
- func (s *SharedStorageClusterService) GrowStorage(ctx context.Context, sb *domain.SharedStorageCluster) error
- func (s *SharedStorageClusterService) InitImages(cluster *domain.SharedStorageCluster) error
- func (s *SharedStorageClusterService) InitMeta(cluster *domain.SharedStorageCluster) error
- func (s *SharedStorageClusterService) InitModifyClassMeta(cluster *domain.SharedStorageCluster) error
- func (s *SharedStorageClusterService) InitTempRoMeta(ctx context.Context, cluster *domain.SharedStorageCluster) error
- func (s *SharedStorageClusterService) PrepareStorage(ctx context.Context, cluster *domain.SharedStorageCluster) error
- func (s *SharedStorageClusterService) ReleaseStorage(ctx context.Context, cluster *domain.SharedStorageCluster) error
- func (s *SharedStorageClusterService) RestartCluster(ctx context.Context, sb *domain.SharedStorageCluster) error
- func (s *SharedStorageClusterService) RestartIns(ctx context.Context, sb *domain.SharedStorageCluster, insId string) error
- func (s *SharedStorageClusterService) SaveParamsLastUpdateTime(ctx context.Context, cluster *domain.SharedStorageCluster) error
- func (s *SharedStorageClusterService) SetInsState(ctx context.Context, endpoint, state, startAt, reason string, ...) error
- func (s *SharedStorageClusterService) SetRw(ctx context.Context, endpoint string, cluster *domain.SharedStorageCluster) error
- func (s *SharedStorageClusterService) SwitchNewRoToRw(ctx context.Context, cluster *domain.SharedStorageCluster) error
- func (s *SharedStorageClusterService) Switchover(ctx context.Context, cluster *domain.SharedStorageCluster, newRwInsId string) error
- func (s *SharedStorageClusterService) SyncInsStateFromClusterManager(ctx context.Context, cluster *domain.SharedStorageCluster) error
- func (s *SharedStorageClusterService) UpdateRunningStatus(name, namespace string) error
- func (s *SharedStorageClusterService) UpgradeCmVersion(ctx context.Context, sb *domain.SharedStorageCluster, cmImage string) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type LocalStorageClusterService ¶
type LocalStorageClusterService struct { Repository domain.ILocalStorageClusterRepository PodManager commondomain.IEnginePodManager IDGenerator commondomain.IIdGenerator PortGenerator commondomain.IPortGenerator ManagerClient commondomain.IManagerClient // contains filtered or unexported fields }
func NewLocalStorageClusterService ¶
func NewLocalStorageClusterService( repository domain.ILocalStorageClusterRepository, podManager commondomain.IEnginePodManager, idGenerator commondomain.IIdGenerator, portGenerator commondomain.IPortGenerator, managerClient commondomain.IManagerClient, logger logr.Logger, ) *LocalStorageClusterService
func (*LocalStorageClusterService) CreatePod ¶
func (s *LocalStorageClusterService) CreatePod(ctx context.Context, cluster *domain.LocalStorageCluster, ins *commondomain.DbIns) error
func (*LocalStorageClusterService) GetByData ¶
func (s *LocalStorageClusterService) GetByData(data interface{}, useModifyClass bool, useUpgradeVersion bool) *domain.LocalStorageCluster
func (*LocalStorageClusterService) InitStatusInfo ¶
func (s *LocalStorageClusterService) InitStatusInfo(cluster *domain.LocalStorageCluster) error
func (*LocalStorageClusterService) InstallDBEngine ¶
func (s *LocalStorageClusterService) InstallDBEngine(ctx context.Context, ins *commondomain.DbIns) error
type SharedStorageClusterService ¶
type SharedStorageClusterService struct { // contains filtered or unexported fields }
func NewShardStorageClusterService ¶
func NewShardStorageClusterService( repository domain.ISharedStorageClusterRepository, templateQuery commondomain.IEngineParamsTemplateQuery, paramClassQuery commondomain.IEngineParamsClassQuery, paramsRepo commondomain.IEngineParamsRepository, minorVersionQuery commondomain.IMinorVersionQuery, accountRepo commondomain.IAccountRepository, idGenerator commondomain.IIdGenerator, portGenerator commondomain.IPortGenerator, managerClient commondomain.IManagerClient, storageManager commondomain.IStorageManager, podManager commondomain.IEnginePodManager, classQuery commondomain.IClassQuery, cmClient commondomain.IClusterManagerClient, clusterManagerRemover commondomain.IClusterManagerRemover, logger logr.Logger, ) *SharedStorageClusterService
func (*SharedStorageClusterService) ConvertTempRoForRwToRo ¶
func (s *SharedStorageClusterService) ConvertTempRoForRwToRo(ctx context.Context, cluster *domain.SharedStorageCluster) error
func (*SharedStorageClusterService) CreateAndInstallIns ¶
func (s *SharedStorageClusterService) CreateAndInstallIns(ctx context.Context, cluster *domain.SharedStorageCluster, ins *commondomain.DbIns, writeLock bool) error
func (*SharedStorageClusterService) CreateRoIns ¶
func (s *SharedStorageClusterService) CreateRoIns(ctx context.Context, cluster *domain.SharedStorageCluster, ins *commondomain.DbIns) error
func (*SharedStorageClusterService) CreateRwIns ¶
func (s *SharedStorageClusterService) CreateRwIns(ctx context.Context, cluster *domain.SharedStorageCluster, ins *commondomain.DbIns) error
func (*SharedStorageClusterService) CreateTempRoIns ¶
func (s *SharedStorageClusterService) CreateTempRoIns(ctx context.Context, cluster *domain.SharedStorageCluster, ins *commondomain.DbIns) error
func (*SharedStorageClusterService) DeleteAllInsPod ¶
func (s *SharedStorageClusterService) DeleteAllInsPod(cluster *domain.SharedStorageCluster, ctx context.Context) error
func (*SharedStorageClusterService) DeleteCm ¶
func (s *SharedStorageClusterService) DeleteCm(ctx context.Context, sb *domain.SharedStorageCluster) error
func (*SharedStorageClusterService) DeleteOldIns ¶
func (s *SharedStorageClusterService) DeleteOldIns(ctx context.Context, cluster *domain.SharedStorageCluster, phyId, newInsId string, deleteOldInsMeta, minusRoReplicas bool) error
func (*SharedStorageClusterService) DeleteOldRw ¶
func (s *SharedStorageClusterService) DeleteOldRw(ctx context.Context, cluster *domain.SharedStorageCluster) error
func (*SharedStorageClusterService) DisableHA ¶
func (s *SharedStorageClusterService) DisableHA(ctx context.Context, sb *domain.SharedStorageCluster) error
func (*SharedStorageClusterService) EnableHA ¶
func (s *SharedStorageClusterService) EnableHA(ctx context.Context, sb *domain.SharedStorageCluster) error
func (*SharedStorageClusterService) EnsureCmAffinity ¶
func (s *SharedStorageClusterService) EnsureCmAffinity(ctx context.Context, sb *domain.SharedStorageCluster) error
func (*SharedStorageClusterService) EnsureInsTypeMeta ¶
func (s *SharedStorageClusterService) EnsureInsTypeMeta(ctx context.Context, cluster *domain.SharedStorageCluster) error
func (*SharedStorageClusterService) EnsureNewRoUpToDate ¶
func (s *SharedStorageClusterService) EnsureNewRoUpToDate(ctx context.Context, cluster *domain.SharedStorageCluster) error
func (*SharedStorageClusterService) FlushClusterParams ¶
func (s *SharedStorageClusterService) FlushClusterParams(ctx context.Context, sb *domain.SharedStorageCluster) (bool, error)
func (*SharedStorageClusterService) FlushParamsIfNecessary ¶
func (s *SharedStorageClusterService) FlushParamsIfNecessary(ctx context.Context, cluster *domain.SharedStorageCluster) error
func (*SharedStorageClusterService) GenerateNewRoTempId ¶
func (s *SharedStorageClusterService) GenerateNewRoTempId(ctx context.Context, cluster *domain.SharedStorageCluster) error
func (*SharedStorageClusterService) GenerateTempRoId ¶
func (s *SharedStorageClusterService) GenerateTempRoId(ctx context.Context, cluster *domain.SharedStorageCluster, insId string) error
func (*SharedStorageClusterService) GenerateTempRoIds ¶
func (s *SharedStorageClusterService) GenerateTempRoIds(ctx context.Context, cluster *domain.SharedStorageCluster) error
func (*SharedStorageClusterService) GetAll ¶
func (s *SharedStorageClusterService) GetAll() ([]*domain.SharedStorageCluster, error)
func (*SharedStorageClusterService) GetByData ¶
func (s *SharedStorageClusterService) GetByData(data interface{}, useModifyClass bool, useUpgradeVersion bool) *domain.SharedStorageCluster
func (*SharedStorageClusterService) GetByName ¶
func (s *SharedStorageClusterService) GetByName(name, namespace string) (*domain.SharedStorageCluster, error)
func (*SharedStorageClusterService) GrowStorage ¶
func (s *SharedStorageClusterService) GrowStorage(ctx context.Context, sb *domain.SharedStorageCluster) error
func (*SharedStorageClusterService) InitImages ¶
func (s *SharedStorageClusterService) InitImages(cluster *domain.SharedStorageCluster) error
func (*SharedStorageClusterService) InitMeta ¶
func (s *SharedStorageClusterService) InitMeta(cluster *domain.SharedStorageCluster) error
func (*SharedStorageClusterService) InitModifyClassMeta ¶
func (s *SharedStorageClusterService) InitModifyClassMeta(cluster *domain.SharedStorageCluster) error
func (*SharedStorageClusterService) InitTempRoMeta ¶
func (s *SharedStorageClusterService) InitTempRoMeta(ctx context.Context, cluster *domain.SharedStorageCluster) error
func (*SharedStorageClusterService) PrepareStorage ¶
func (s *SharedStorageClusterService) PrepareStorage(ctx context.Context, cluster *domain.SharedStorageCluster) error
func (*SharedStorageClusterService) ReleaseStorage ¶
func (s *SharedStorageClusterService) ReleaseStorage(ctx context.Context, cluster *domain.SharedStorageCluster) error
func (*SharedStorageClusterService) RestartCluster ¶
func (s *SharedStorageClusterService) RestartCluster(ctx context.Context, sb *domain.SharedStorageCluster) error
func (*SharedStorageClusterService) RestartIns ¶
func (s *SharedStorageClusterService) RestartIns(ctx context.Context, sb *domain.SharedStorageCluster, insId string) error
func (*SharedStorageClusterService) SaveParamsLastUpdateTime ¶
func (s *SharedStorageClusterService) SaveParamsLastUpdateTime(ctx context.Context, cluster *domain.SharedStorageCluster) error
func (*SharedStorageClusterService) SetInsState ¶
func (s *SharedStorageClusterService) SetInsState(ctx context.Context, endpoint, state, startAt, reason string, cluster *domain.SharedStorageCluster) error
func (*SharedStorageClusterService) SetRw ¶
func (s *SharedStorageClusterService) SetRw(ctx context.Context, endpoint string, cluster *domain.SharedStorageCluster) error
func (*SharedStorageClusterService) SwitchNewRoToRw ¶
func (s *SharedStorageClusterService) SwitchNewRoToRw(ctx context.Context, cluster *domain.SharedStorageCluster) error
func (*SharedStorageClusterService) Switchover ¶
func (s *SharedStorageClusterService) Switchover(ctx context.Context, cluster *domain.SharedStorageCluster, newRwInsId string) error
func (*SharedStorageClusterService) SyncInsStateFromClusterManager ¶
func (s *SharedStorageClusterService) SyncInsStateFromClusterManager(ctx context.Context, cluster *domain.SharedStorageCluster) error
func (*SharedStorageClusterService) UpdateRunningStatus ¶
func (s *SharedStorageClusterService) UpdateRunningStatus(name, namespace string) error
func (*SharedStorageClusterService) UpgradeCmVersion ¶
func (s *SharedStorageClusterService) UpgradeCmVersion(ctx context.Context, sb *domain.SharedStorageCluster, cmImage string) error
Click to show internal directories.
Click to hide internal directories.