repository

Documentation

Index

• Variables
• func NewDemoRepository() *demoRepository
• type BackupAccountRepository
  • func NewBackupAccountRepository() BackupAccountRepository
• type ClusterBackupFileRepository
  • func NewClusterBackupFileRepository() ClusterBackupFileRepository
• type ClusterBackupStrategyRepository
  • func NewClusterBackupStrategyRepository() ClusterBackupStrategyRepository
• type ClusterManifestRepository
  • func NewClusterManifestRepository() ClusterManifestRepository
• type ClusterNodeRepository
  • func NewClusterNodeRepository() ClusterNodeRepository
• type ClusterRepository
  • func NewClusterRepository() ClusterRepository
• type ClusterSecretRepository
  • func NewClusterSecretRepository() ClusterSecretRepository
• type ClusterSpecRepository
  • func NewClusterSpecRepository() ClusterSpecRepository
• type ClusterStorageProvisionerRepository
  • func NewClusterStorageProvisionerRepository() ClusterStorageProvisionerRepository
• type ClusterToolRepository
  • func NewClusterToolRepository() ClusterToolRepository
• type CredentialRepository
  • func NewCredentialRepository() CredentialRepository
• type DemoRepository
• type HostRepository
  • func NewHostRepository() HostRepository
• type IpPoolRepository
  • func NewIpPoolRepository() IpPoolRepository
• type LicenseRepository
  • func NewLicenseRepository() LicenseRepository
• type NtpServerRepository
  • func NewNtpServerRepository() NtpServerRepository
• type PlanRepository
  • func NewPlanRepository() PlanRepository
• type ProjectMemberRepository
  • func NewProjectMemberRepository() ProjectMemberRepository
• type ProjectRepository
  • func NewProjectRepository() ProjectRepository
• type ProjectResourceRepository
  • func NewProjectResourceRepository() ProjectResourceRepository
• type RegionRepository
  • func NewRegionRepository() RegionRepository
• type SystemRegistryRepository
  • func NewSystemRegistryRepository() SystemRegistryRepository
• type SystemSettingRepository
  • func NewSystemSettingRepository() SystemSettingRepository
• type UserRepository
  • func NewUserRepository() UserRepository
• type VmConfigRepository
  • func NewVmConfigRepository() VmConfigRepository
• type ZoneRepository
  • func NewZoneRepository() ZoneRepository

Variables

var (
	DeleteFailedError     = "DELETE_FAILED_RESOURCE"
	DeleteFailedErrorZone = "DELETE_FAILED_RESOURCE_ZONE"
)

var (
	DeleteHostFailed          = "DELETE_HOST_FAILED"
	DeleteHostFailedByProject = "DELETE_HOST_FAILED_BY_PROJECT"
)

var (
	DeleteRegionError = "DELETE_REGION_FAILED_RESOURCE"
)

Functions

func NewDemoRepository

func NewDemoRepository() *demoRepository

Types

type BackupAccountRepository

type BackupAccountRepository interface {
	Get(name string) (*model.BackupAccount, error)
	List(projectName string) ([]model.BackupAccount, error)
	Save(backupAccount *model.BackupAccount) error
	Page(num, size int) (int, []model.BackupAccount, error)
	Batch(operation string, items []model.BackupAccount) error
	Delete(name string) error
}

func NewBackupAccountRepository

func NewBackupAccountRepository() BackupAccountRepository

type ClusterBackupFileRepository

type ClusterBackupFileRepository interface {
	Page(num, size int, clusterId string) (int, []model.ClusterBackupFile, error)
	Save(file *model.ClusterBackupFile) error
	Batch(operation string, items []model.ClusterBackupFile) error
	Get(name string) (model.ClusterBackupFile, error)
	Delete(name string) error
}

func NewClusterBackupFileRepository

func NewClusterBackupFileRepository() ClusterBackupFileRepository

type ClusterBackupStrategyRepository

type ClusterBackupStrategyRepository interface {
	Get(clusterName string) (*model.ClusterBackupStrategy, error)
	Save(clusterBackupStrategy *model.ClusterBackupStrategy) error
	List() ([]model.ClusterBackupStrategy, error)
}

func NewClusterBackupStrategyRepository

func NewClusterBackupStrategyRepository() ClusterBackupStrategyRepository

type ClusterManifestRepository

type ClusterManifestRepository interface {
	List() ([]model.ClusterManifest, error)
	ListByStatus() ([]model.ClusterManifest, error)
	Save(manifest model.ClusterManifest) error
	Get(version string) (model.ClusterManifest, error)
}

func NewClusterManifestRepository

func NewClusterManifestRepository() ClusterManifestRepository

type ClusterNodeRepository

type ClusterNodeRepository interface {
	Get(clusterName string, name string) (model.ClusterNode, error)
	Page(num, size int, clusterName string) (int, []model.ClusterNode, error)
	List(clusterName string) ([]model.ClusterNode, error)
	ListByRole(clusterName string, role string) ([]model.ClusterNode, error)
	Save(node *model.ClusterNode) error
	FirstMaster(clusterId string) (model.ClusterNode, error)
	AllMaster(clusterId string) ([]model.ClusterNode, error)
	Delete(id string) error
	BatchSave(nodes []*model.ClusterNode) error
}

func NewClusterNodeRepository

func NewClusterNodeRepository() ClusterNodeRepository

type ClusterRepository

type ClusterRepository interface {
	Get(name string) (model.Cluster, error)
	GetWithPreload(name string, preloads []string) (model.Cluster, error)
	List() ([]model.Cluster, error)
	Save(cluster *model.Cluster) error
	Delete(name string) error
	Page(num, size int, projectName string) (int, []model.Cluster, error)
}

func NewClusterRepository

func NewClusterRepository() ClusterRepository

type ClusterSecretRepository

type ClusterSecretRepository interface {
	Get(id string) (model.ClusterSecret, error)
	Save(status *model.ClusterSecret) error
	Delete(id string) error
}

func NewClusterSecretRepository

func NewClusterSecretRepository() ClusterSecretRepository

type ClusterSpecRepository

type ClusterSpecRepository interface {
	SaveConf(conf *model.ClusterSpecConf) error
}

func NewClusterSpecRepository

func NewClusterSpecRepository() ClusterSpecRepository

type ClusterStorageProvisionerRepository

type ClusterStorageProvisionerRepository interface {
	List(clusterName string) ([]model.ClusterStorageProvisioner, error)
	Save(clusterName string, provisioner *model.ClusterStorageProvisioner) error
	Delete(clusterName string, provisionerName string) error
	BatchDelete(clusterName string, items []dto.ClusterStorageProvisioner) error
}

func NewClusterStorageProvisionerRepository

func NewClusterStorageProvisionerRepository() ClusterStorageProvisionerRepository

type ClusterToolRepository

type ClusterToolRepository interface {
	List(clusterName string) ([]model.ClusterTool, error)
	Save(tool *model.ClusterTool) error
	Get(clusterName string, name string) (model.ClusterTool, error)
}

func NewClusterToolRepository

func NewClusterToolRepository() ClusterToolRepository

type CredentialRepository

type CredentialRepository interface {
	Get(name string) (model.Credential, error)
	List() ([]model.Credential, error)
	Page(num, size int) (int, []model.Credential, error)
	Save(credential *model.Credential) error
	Delete(name string) error
	GetById(id string) (model.Credential, error)
	Batch(operation string, items []model.Credential) error
}

func NewCredentialRepository

func NewCredentialRepository() CredentialRepository

type DemoRepository

type DemoRepository interface {
	List() ([]model.Demo, error)
	Get(name string) (model.Demo, error)
	Save(demo model.Demo) error
}

type HostRepository

type HostRepository interface {
	Get(name string) (model.Host, error)
	List(projectName string) ([]model.Host, error)
	ListByClusterId(clusterId string) ([]model.Host, error)
	Page(num, size int) (int, []model.Host, error)
	Save(host *model.Host) error
	BatchSave(hosts []*model.Host) error
	Delete(name string) error
	ListByCredentialID(credentialID string) ([]model.Host, error)
	Batch(operation string, items []model.Host) error
}

func NewHostRepository

func NewHostRepository() HostRepository

type IpPoolRepository

type IpPoolRepository interface {
	Get(name string) (model.IpPool, error)
	Save(ipPool *model.IpPool) error
	Page(num, size int) (int, []model.IpPool, error)
	Batch(operation string, items []model.IpPool) error
}

func NewIpPoolRepository

func NewIpPoolRepository() IpPoolRepository

type LicenseRepository

type LicenseRepository interface {
	Save(content string) error
	Get() (model.License, error)
}

func NewLicenseRepository

func NewLicenseRepository() LicenseRepository

type NtpServerRepository

type NtpServerRepository interface {
	Get(name string) (model.NtpServer, error)
	List() ([]model.NtpServer, error)
	GetAddressStr() (string, error)
	Page(num, size int) (int, []model.NtpServer, error)
	Save(ntpServer *model.NtpServer) error
	Delete(name string) error
}

func NewNtpServerRepository

func NewNtpServerRepository() NtpServerRepository

type PlanRepository

type PlanRepository interface {
	Get(name string) (model.Plan, error)
	List(projectName string) ([]model.Plan, error)
	Page(num, size int) (int, []model.Plan, error)
	Save(plan *model.Plan, zones []string) error
	Delete(name string) error
	Batch(operation string, items []model.Plan) error

	GetById(id string) (model.Plan, error)
}

func NewPlanRepository

func NewPlanRepository() PlanRepository

type ProjectMemberRepository

type ProjectMemberRepository interface {
	PageByProjectId(num, size int, projectId string) (int, []model.ProjectMember, error)
	Batch(operation string, items []model.ProjectMember) error
	Create(member *model.ProjectMember) error
	ListByProjectId(projectId string) ([]model.ProjectMember, error)
}

func NewProjectMemberRepository

func NewProjectMemberRepository() ProjectMemberRepository

type ProjectRepository

type ProjectRepository interface {
	Get(name string) (model.Project, error)
	List() ([]model.Project, error)
	Page(num, size int, userId string) (int, []model.Project, error)
	Save(project *model.Project) error
	Batch(operation string, items []model.Project) error
	Delete(name string) error
}

func NewProjectRepository

func NewProjectRepository() ProjectRepository

type ProjectResourceRepository

type ProjectResourceRepository interface {
	PageByProjectIdAndType(num, size int, projectId string, resourceType string) (int, []model.ProjectResource, error)
	Batch(operation string, items []model.ProjectResource) error
	Create(resource model.ProjectResource) error
	ListByResourceIDAndType(resourceId string, resourceType string) ([]model.ProjectResource, error)
	DeleteByResourceIDAnyResourceType(resourceId string, resourceType string) error
	ListByProjectNameAndType(projectName string, resourceType string) ([]model.ProjectResource, error)
}

func NewProjectResourceRepository

func NewProjectResourceRepository() ProjectResourceRepository

type RegionRepository

type RegionRepository interface {
	Get(name string) (model.Region, error)
	List() ([]model.Region, error)
	Page(num, size int) (int, []model.Region, error)
	Save(region *model.Region) error
	Delete(name string) error
	Batch(operation string, items []model.Region) error
}

func NewRegionRepository

func NewRegionRepository() RegionRepository

type SystemRegistryRepository

type SystemRegistryRepository interface {
	Get(id string) (model.SystemRegistry, error)
	GetByArch(arch string) (model.SystemRegistry, error)
	List() ([]model.SystemRegistry, error)
	Save(registry *model.SystemRegistry) error
	Page(num, size int) (int, []model.SystemRegistry, error)
	Batch(operation string, items []model.SystemRegistry) error
	Delete(id string) error
}

func NewSystemRegistryRepository

func NewSystemRegistryRepository() SystemRegistryRepository

type SystemSettingRepository

type SystemSettingRepository interface {
	Get(key string) (model.SystemSetting, error)
	List() ([]model.SystemSetting, error)
	Save(systemSetting *model.SystemSetting) error
	ListByTab(tabName string) ([]model.SystemSetting, error)
}

func NewSystemSettingRepository

func NewSystemSettingRepository() SystemSettingRepository

type UserRepository

type UserRepository interface {
	Page(num, size int) (int, []model.User, error)
	List() ([]model.User, error)
	Get(name string) (model.User, error)
	Save(item *model.User) error
	Delete(name string) error
	Batch(operation string, items []model.User) error
	ListIsAdmin() ([]model.User, error)
	ListNames() (map[string]bool, error)
}

func NewUserRepository

func NewUserRepository() UserRepository

type VmConfigRepository

type VmConfigRepository interface {
	Page(num, size int) (int, []model.VmConfig, error)
	List() ([]model.VmConfig, error)
	Save(item *model.VmConfig) error
	Batch(operation string, items []model.VmConfig) error
	Get(name string) (model.VmConfig, error)
}

func NewVmConfigRepository

func NewVmConfigRepository() VmConfigRepository

type ZoneRepository

type ZoneRepository interface {
	Get(name string) (model.Zone, error)
	List() ([]model.Zone, error)
	Page(num, size int) (int, []model.Zone, error)
	Save(zone *model.Zone) error
	Delete(name string) error
	Batch(operation string, items []model.Zone) error
	ListByRegionId(id string) ([]model.Zone, error)
}

func NewZoneRepository

func NewZoneRepository() ZoneRepository