service

package
v0.0.0-...-693d502 Latest Latest
Warning

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

 Go to latest Published: May 9, 2022 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

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 {
	Repository            domain.ISharedStorageClusterRepository
	ParamsTemplateQuery   commondomain.IEngineParamsTemplateQuery
	ParamsClassQuery      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
	ClusterManagerClient  commondomain.IClusterManagerClient
	ClusterManagerRemover commondomain.IClusterManagerRemover
	// 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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.