domain

type ILocalStorageClusterRepository interface {

	/**
	 * @Description: 获得所有LocalStorageCluster元数据
	 * @return []domain.LocalStorageCluster
	 * @return error
	 */
	GetAll() ([]*LocalStorageCluster, error)

	/**
	 * @Description: 根据名称获取LocalStorageCluster元数据
	 * @param name
	 * @param namespace
	 * @return *domain.LocalStorageCluster
	 */
	GetByName(name, namespace string) (*LocalStorageCluster, error)

	/**
	 * @Description: 根据视图模型获取LocalStorageCluster元数据
	 * @param data
	 * @return *domain.LocalStorageCluster
	 */
	GetByData(data interface{}, useModifyClass bool, useUpgradeVersion bool) *LocalStorageCluster

	/**
	 * @Description: 创建LocalStorageCluster
	 * @param *domain.LocalStorageCluster
	 * @return error
	 */
	Create(*LocalStorageCluster) error

	/**
	 * @Description: 更新LocalStorageCluster
	 * @param *domain.LocalStorageCluster
	 * @return error
	 */
	Update(*LocalStorageCluster) error

	/**
	 * @Description: 将LocalStorageCluster状态设置为Running
	 * @param name
	 * @param namespace
	 * @return error
	 */
	UpdateRunningStatus(name, namespace string) error
}

type ISharedStorageClusterRepository interface {

	/**
	 * @Description: 获得所有SharedStorageCluster元数据
	 * @return []domain.SharedStorageCluster
	 * @return error
	 */
	GetAll() ([]*SharedStorageCluster, error)

	/**
	 * @Description: 根据名称获取SharedStorageCluster元数据
	 * @param name
	 * @param namespace
	 * @return *domain.SharedStorageCluster
	 */
	GetByName(name, namespace string) (*SharedStorageCluster, error)

	/**
	 * @Description: 根据视图模型获取SharedStorageCluster元数据
	 * @param data
	 * @return *domain.SharedStorageCluster
	 */
	GetByData(data interface{}, useModifyClass bool, useUpgradeVersion bool) *SharedStorageCluster

	/**
	 * @Description: 创建SharedStorageCluster
	 * @param *domain.SharedStorageCluster
	 * @return error
	 */
	Create(*SharedStorageCluster) error

	/**
	 * @Description: 更新SharedStorageCluster
	 * @param *domain.SharedStorageCluster
	 * @return error
	 */
	Update(*SharedStorageCluster) error

	/**
	 * @Description: 将SharedStorageCluster状态设置为Running
	 * @param name
	 * @param namespace
	 * @return error
	 */
	UpdateRunningStatus(name, namespace string) error

	/**
	 * @Description: 更新引擎状态
	 * @param name
	 * @param namespace
	 * @return error
	 */
	UpdateInsStatus(*SharedStorageCluster) error
}

type LocalStorageCluster struct {
	commondomain.DbClusterBase
	RoReplicas int
	Port       int

	Ins         *commondomain.DbIns
	FollowerIns []*commondomain.DbIns
	// contains filtered or unexported fields
}

type SharedStorageCluster struct {
	commondomain.SharedStorageDbClusterBase
	RoReplicas  int
	Port        int
	RwIns       *commondomain.DbIns
	RoInses     map[string]*commondomain.DbIns
	TempRoInses map[string]*commondomain.DbIns
	TempRoIds   map[string]string
	// contains filtered or unexported fields
}