virtualcluster

Documentation

Index

• Constants
• func Add(mgr *vcmanager.VirtualClusterManager, masterProvisioner string) error
• type MasterProvisioner
• type MasterProvisionerAliyun
  • func NewMasterProvisionerAliyun(mgr manager.Manager) (*MasterProvisionerAliyun, error)
  • func (mpa *MasterProvisionerAliyun) CreateVirtualCluster(vc *tenancyv1alpha1.VirtualCluster) error
  • func (mpa *MasterProvisionerAliyun) DeleteVirtualCluster(vc *tenancyv1alpha1.VirtualCluster) error
  • func (mpa *MasterProvisionerAliyun) GetMasterProvisioner() string
• type MasterProvisionerNative
  • func NewMasterProvisionerNative(mgr manager.Manager) (*MasterProvisionerNative, error)
  • func (mpn *MasterProvisionerNative) CreateVirtualCluster(vc *tenancyv1alpha1.VirtualCluster) error
  • func (mpn *MasterProvisionerNative) DeleteVirtualCluster(vc *tenancyv1alpha1.VirtualCluster) error
  • func (mpn *MasterProvisionerNative) GetMasterProvisioner() string
• type ReconcileVirtualCluster
  • func (r *ReconcileVirtualCluster) Reconcile(request reconcile.Request) (rncilRslt reconcile.Result, err error)

Constants

const (
	DefaultETCDPeerPort    = 2380
	ComponentPollPeriodSec = 2
	// timeout for components deployment
	DeployTimeOutSec = 180
)

Functions

func Add

func Add(mgr *vcmanager.VirtualClusterManager, masterProvisioner string) error

Add creates a new VirtualCluster Controller and adds it to the Manager with default RBAC. The Manager will set fields on the Controller and Start it when the Manager is Started.

Types

type MasterProvisioner

type MasterProvisioner interface {
	CreateVirtualCluster(vc *tenancyv1alpha1.VirtualCluster) error
	DeleteVirtualCluster(vc *tenancyv1alpha1.VirtualCluster) error
	GetMasterProvisioner() string
}

type MasterProvisionerAliyun

type MasterProvisionerAliyun struct {
	client.Client
	// contains filtered or unexported fields
}

func NewMasterProvisionerAliyun

func NewMasterProvisionerAliyun(mgr manager.Manager) (*MasterProvisionerAliyun, error)

func (*MasterProvisionerAliyun) CreateVirtualCluster

func (mpa *MasterProvisionerAliyun) CreateVirtualCluster(vc *tenancyv1alpha1.VirtualCluster) error

CreateVirtualCluster creates a new ASK on aliyun for given VirtualCluster

func (*MasterProvisionerAliyun) DeleteVirtualCluster

func (mpa *MasterProvisionerAliyun) DeleteVirtualCluster(vc *tenancyv1alpha1.VirtualCluster) error

DeleteVirtualCluster deletes the ASK cluster corresponding to the given VirtualCluster NOTE DeleteVirtualCluster only sends the deletion request to Aliyun and do not promise the ASK will be deleted

func (*MasterProvisionerAliyun) GetMasterProvisioner

func (mpa *MasterProvisionerAliyun) GetMasterProvisioner() string

type MasterProvisionerNative

type MasterProvisionerNative struct {
	client.Client
	// contains filtered or unexported fields
}

func NewMasterProvisionerNative

func NewMasterProvisionerNative(mgr manager.Manager) (*MasterProvisionerNative, error)

func (*MasterProvisionerNative) CreateVirtualCluster

func (mpn *MasterProvisionerNative) CreateVirtualCluster(vc *tenancyv1alpha1.VirtualCluster) error

CreateVirtualCluster sets up the control plane for vc on meta k8s

func (*MasterProvisionerNative) DeleteVirtualCluster

func (mpn *MasterProvisionerNative) DeleteVirtualCluster(vc *tenancyv1alpha1.VirtualCluster) error

func (*MasterProvisionerNative) GetMasterProvisioner

func (mpn *MasterProvisionerNative) GetMasterProvisioner() string

type ReconcileVirtualCluster

type ReconcileVirtualCluster struct {
	client.Client
	// contains filtered or unexported fields
}

ReconcileVirtualCluster reconciles a VirtualCluster object

func (*ReconcileVirtualCluster) Reconcile

func (r *ReconcileVirtualCluster) Reconcile(request reconcile.Request) (rncilRslt reconcile.Result, err error)

Reconcile reads that state of the cluster for a VirtualCluster object and makes changes based on the state read and what is in the VirtualCluster.Spec +kubebuilder:rbac:groups=apps,resources=statefulsets,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=apps,resources=statefulsets/status,verbs=get;update;patch +kubebuilder:rbac:groups=core,resources=services,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=core,resources=services/status,verbs=get;update;patch +kubebuilder:rbac:groups=core,resources=secrets,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=core,resources=secrets/status,verbs=get;update;patch +kubebuilder:rbac:groups=core,resources=configmaps,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=core,resources=configmaps/status,verbs=get;update;patch +kubebuilder:rbac:groups=tenancy.x-k8s.io,resources=virtualclusters,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=tenancy.x-k8s.io,resources=virtualclusters/status,verbs=get;update;patch +kubebuilder:rbac:groups=tenancy.x-k8s.io,resources=clusterversions,verbs=get;list;watch +kubebuilder:rbac:groups=tenancy.x-k8s.io,resources=clusterversions/status,verbs=get