clusters

package
v0.0.0-...-94e4715 Latest Latest
Warning

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

 Go to latest Published: Nov 20, 2024 License: Apache-2.0 Imports: 35 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetMachineDriver 

func GetMachineDriver(d models.IClusterDriver, mT api.MachineResourceType) models.IMachineDriver

Types

type SBaseDriver 

type SBaseDriver struct {
	// contains filtered or unexported fields
}

func (*SBaseDriver) CreateMachines 

func (d *SBaseDriver) CreateMachines(ctx context.Context, userCred mcclient.TokenCredential, cluster *models.SCluster, data []*api.CreateMachineData) ([]manager.IMachine, error)

func (*SBaseDriver) GetAddonsHelmCharts 

func (d *SBaseDriver) GetAddonsHelmCharts(cluster *models.SCluster, conf *api.ClusterAddonsManifestConfig) ([]*models.ClusterHelmChartInstallOption, error)

func (*SBaseDriver) GetAddonsManifest 

func (d *SBaseDriver) GetAddonsManifest(cluster *models.SCluster, conf *api.ClusterAddonsManifestConfig) (string, error)

func (*SBaseDriver) GetClusterUserGroups 

func (d *SBaseDriver) GetClusterUserGroups(cluster *models.SCluster, config *rest.Config) ([]api.ClusterUserGroup, error)

func (*SBaseDriver) GetClusterUsers 

func (d *SBaseDriver) GetClusterUsers(cluster *models.SCluster, config *rest.Config) ([]api.ClusterUser, error)

func (*SBaseDriver) GetKubesprayConfig 

func (d *SBaseDriver) GetKubesprayConfig(ctx context.Context, cluster *models.SCluster) (*api.ClusterKubesprayConfig, error)

func (*SBaseDriver) GetMode 

func (d *SBaseDriver) GetMode() api.ModeType

func (*SBaseDriver) GetProvider 

func (d *SBaseDriver) GetProvider() api.ProviderType

func (*SBaseDriver) GetResourceType 

func (d *SBaseDriver) GetResourceType() api.ClusterResourceType

func (*SBaseDriver) GetUsableInstances 

func (d *SBaseDriver) GetUsableInstances(s *mcclient.ClientSession) ([]api.UsableInstance, error)

func (*SBaseDriver) NeedCreateMachines 

func (d *SBaseDriver) NeedCreateMachines() bool

func (*SBaseDriver) PreCheck 

func (d *SBaseDriver) PreCheck(s *mcclient.ClientSession, data jsonutils.JSONObject) (*api.ClusterPreCheckResp, error)

func (*SBaseDriver) RequestDeleteMachines 

func (d *SBaseDriver) RequestDeleteMachines(ctx context.Context, userCred mcclient.TokenCredential, cluster *models.SCluster, machines []manager.IMachine, task taskman.ITask) error

func (*SBaseDriver) RequestDeployMachines 

func (d *SBaseDriver) RequestDeployMachines(ctx context.Context, userCred mcclient.TokenCredential, cluster *models.SCluster, action api.ClusterDeployAction, machines []manager.IMachine, skipDownloads bool, task taskman.ITask) error

func (*SBaseDriver) ValidateCreateData 

func (d *SBaseDriver) ValidateCreateData(userCred mcclient.TokenCredential, ownerId mcclient.IIdentityProvider, query jsonutils.JSONObject, input *api.ClusterCreateInput) error

func (*SBaseDriver) ValidateCreateMachines 

func (d *SBaseDriver) ValidateCreateMachines(
	ctx context.Context,
	userCred mcclient.TokenCredential,
	cluster *models.SCluster,
	_ *api.ClusterMachineCommonInfo,
	data []*api.CreateMachineData,
) ([]*api.CreateMachineData, []*api.CreateMachineData, error)

func (*SBaseDriver) ValidateDeleteCondition 

func (d *SBaseDriver) ValidateDeleteCondition() error

func (*SBaseDriver) ValidateDeleteMachines 

func (d *SBaseDriver) ValidateDeleteMachines(ctx context.Context, userCred mcclient.TokenCredential, cluster *models.SCluster, machines []manager.IMachine) error

type SCloudImportBaseDriver 

type SCloudImportBaseDriver struct {
	// contains filtered or unexported fields
}

func (SCloudImportBaseDriver) GetClusterUserGroups 

func (d SCloudImportBaseDriver) GetClusterUserGroups(cluster *models.SCluster, config *rest.Config) ([]api.ClusterUserGroup, error)

func (SCloudImportBaseDriver) GetClusterUsers 

func (d SCloudImportBaseDriver) GetClusterUsers(cluster *models.SCluster, config *rest.Config) ([]api.ClusterUser, error)

func (SCloudImportBaseDriver) GetK8sVersions 

func (d SCloudImportBaseDriver) GetK8sVersions() []string

func (SCloudImportBaseDriver) GetKubeconfig 

func (d SCloudImportBaseDriver) GetKubeconfig(cluster *models.SCluster) (string, error)

func (SCloudImportBaseDriver) NeedCreateMachines 

func (d SCloudImportBaseDriver) NeedCreateMachines() bool

func (SCloudImportBaseDriver) NeedGenerateCertificate 

func (d SCloudImportBaseDriver) NeedGenerateCertificate() bool

func (SCloudImportBaseDriver) ValidateCreateData 

func (d SCloudImportBaseDriver) ValidateCreateData(ctx context.Context, userCred mcclient.TokenCredential, ownerId mcclient.IIdentityProvider, query jsonutils.JSONObject, createData *api.ClusterCreateInput) error

func (SCloudImportBaseDriver) ValidateCreateMachines 

func (d SCloudImportBaseDriver) ValidateCreateMachines(
	ctx context.Context,
	userCred mcclient.TokenCredential,
	c *models.SCluster,
	_ *api.ClusterMachineCommonInfo,
	imageRepo *api.ImageRepository,
	data []*api.CreateMachineData) error

type SExternalImportDriver 

type SExternalImportDriver struct {
	// contains filtered or unexported fields
}

func NewExternalImportDriver 

func NewExternalImportDriver() *SExternalImportDriver

func (SExternalImportDriver) GetClusterUserGroups 

func (d SExternalImportDriver) GetClusterUserGroups(cluster *models.SCluster, config *rest.Config) ([]api.ClusterUserGroup, error)

func (SExternalImportDriver) GetClusterUsers 

func (d SExternalImportDriver) GetClusterUsers(cluster *models.SCluster, config *rest.Config) ([]api.ClusterUser, error)

func (SExternalImportDriver) GetK8sVersions 

func (d SExternalImportDriver) GetK8sVersions() []string

func (SExternalImportDriver) GetKubeconfig 

func (d SExternalImportDriver) GetKubeconfig(cluster *models.SCluster) (string, error)

func (SExternalImportDriver) NeedCreateMachines 

func (d SExternalImportDriver) NeedCreateMachines() bool

func (SExternalImportDriver) NeedGenerateCertificate 

func (d SExternalImportDriver) NeedGenerateCertificate() bool

func (*SExternalImportDriver) ValidateCreateData 

func (d *SExternalImportDriver) ValidateCreateData(ctx context.Context, userCred mcclient.TokenCredential, ownerId mcclient.IIdentityProvider, query jsonutils.JSONObject, createData *api.ClusterCreateInput) error

func (SExternalImportDriver) ValidateCreateMachines 

func (d SExternalImportDriver) ValidateCreateMachines(
	ctx context.Context,
	userCred mcclient.TokenCredential,
	c *models.SCluster,
	_ *api.ClusterMachineCommonInfo,
	imageRepo *api.ImageRepository,
	data []*api.CreateMachineData) error

type SSystemImportDriver 

type SSystemImportDriver struct {
	*SExternalImportDriver
}

func NewDefaultSystemImportDriver 

func NewDefaultSystemImportDriver() *SSystemImportDriver

func (SSystemImportDriver) GetClusterUserGroups 

func (d SSystemImportDriver) GetClusterUserGroups(cluster *models.SCluster, config *rest.Config) ([]api.ClusterUserGroup, error)

func (SSystemImportDriver) GetClusterUsers 

func (d SSystemImportDriver) GetClusterUsers(cluster *models.SCluster, config *rest.Config) ([]api.ClusterUser, error)

func (SSystemImportDriver) GetK8sVersions 

func (d SSystemImportDriver) GetK8sVersions() []string

func (SSystemImportDriver) GetKubeconfig 

func (d SSystemImportDriver) GetKubeconfig(cluster *models.SCluster) (string, error)

func (SSystemImportDriver) NeedCreateMachines 

func (d SSystemImportDriver) NeedCreateMachines() bool

func (SSystemImportDriver) NeedGenerateCertificate 

func (d SSystemImportDriver) NeedGenerateCertificate() bool

func (*SSystemImportDriver) ValidateCreateData 

func (d *SSystemImportDriver) ValidateCreateData(ctx context.Context, userCred mcclient.TokenCredential, ownerId mcclient.IIdentityProvider, query jsonutils.JSONObject, createData *api.ClusterCreateInput) error

func (SSystemImportDriver) ValidateCreateMachines 

func (d SSystemImportDriver) ValidateCreateMachines(
	ctx context.Context,
	userCred mcclient.TokenCredential,
	c *models.SCluster,
	_ *api.ClusterMachineCommonInfo,
	imageRepo *api.ImageRepository,
	data []*api.CreateMachineData) error

func (*SSystemImportDriver) ValidateDeleteCondition 

func (d *SSystemImportDriver) ValidateDeleteCondition() error

Source Files

View all Source files

Directories

Path Synopsis
vm

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.