Documentation ¶
Index ¶
- Constants
- type KflexClusterProvider
- func (k KflexClusterProvider) Create(name string, opts clusterprovider.Options) error
- func (k KflexClusterProvider) Delete(name string, opts clusterprovider.Options) error
- func (k KflexClusterProvider) Get(lcName string) (clusterprovider.SpaceInfo, error)
- func (k KflexClusterProvider) ListSpaces() ([]clusterprovider.SpaceInfo, error)
- func (k KflexClusterProvider) ListSpacesNames() ([]string, error)
- func (k KflexClusterProvider) Watch() (clusterprovider.Watcher, error)
- type KflexWatcher
Constants ¶
View Source
const ( CPGroup = "tenancy.kflex.kubestellar.org" CPVersion = "v1alpha1" CPKind = "ControlPlane" CPResource = "controlplanes" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type KflexClusterProvider ¶
type KflexClusterProvider struct {
// contains filtered or unexported fields
}
KflexClusterProvider is a kubeflex cluster provider
func New ¶
func New(configStrs map[string]string) (KflexClusterProvider, error)
New creates a new KflexClusterProvider
func (KflexClusterProvider) Create ¶
func (k KflexClusterProvider) Create(name string, opts clusterprovider.Options) error
func (KflexClusterProvider) Delete ¶
func (k KflexClusterProvider) Delete(name string, opts clusterprovider.Options) error
func (KflexClusterProvider) Get ¶
func (k KflexClusterProvider) Get(lcName string) (clusterprovider.SpaceInfo, error)
Get: obtains the kubeconfig for the given lcName cluster. TODO: switch from cli to kube directives
func (KflexClusterProvider) ListSpaces ¶
func (k KflexClusterProvider) ListSpaces() ([]clusterprovider.SpaceInfo, error)
func (KflexClusterProvider) ListSpacesNames ¶
func (k KflexClusterProvider) ListSpacesNames() ([]string, error)
ListSpacesNames: returns a list of clusters in KubeFlex that are in the Ready condition.
func (KflexClusterProvider) Watch ¶
func (k KflexClusterProvider) Watch() (clusterprovider.Watcher, error)
type KflexWatcher ¶
type KflexWatcher struct {
// contains filtered or unexported fields
}
func (*KflexWatcher) ResultChan ¶
func (k *KflexWatcher) ResultChan() <-chan clusterprovider.WatchEvent
func (*KflexWatcher) Stop ¶
func (k *KflexWatcher) Stop()
Click to show internal directories.
Click to hide internal directories.