providerkcp

Documentation

Index

• func NewController(ctx context.Context, watcher *KcpWatcher, ...) *controller
• type KcpClusterProvider
  • func New(configStrs map[string]string) (*KcpClusterProvider, error)
  • func (k *KcpClusterProvider) Create(name string, opts clusterprovider.Options) error
  • func (k *KcpClusterProvider) Delete(name string, opts clusterprovider.Options) error
  • func (k *KcpClusterProvider) Get(spaceName string) (clusterprovider.SpaceInfo, error)
  • func (k *KcpClusterProvider) GetBasedOnConf(spaceName string, cfgString string) ([]byte, error)
  • func (k *KcpClusterProvider) ListSpaces() ([]clusterprovider.SpaceInfo, error)
  • func (k *KcpClusterProvider) ListSpacesNames() ([]string, error)
  • func (k *KcpClusterProvider) Watch() (clusterprovider.Watcher, error)
• type KcpWatcher
  • func (k *KcpWatcher) ResultChan() <-chan clusterprovider.WatchEvent
  • func (k *KcpWatcher) Stop()

Functions

func NewController

func NewController(
	ctx context.Context,
	watcher *KcpWatcher,
	lcInformer kcpcache.ScopeableSharedIndexInformer,
) *controller

NewController returns new KCP-provider controller

Types

type KcpClusterProvider

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

KcpClusterProvider is a cluster provider for KCP workspaces.

func New

func New(configStrs map[string]string) (*KcpClusterProvider, error)

New returns a new KcpClusterProvider

func (*KcpClusterProvider) Create

func (k *KcpClusterProvider) Create(name string, opts clusterprovider.Options) error

func (*KcpClusterProvider) Delete

func (k *KcpClusterProvider) Delete(name string, opts clusterprovider.Options) error

func (*KcpClusterProvider) Get

func (k *KcpClusterProvider) Get(spaceName string) (clusterprovider.SpaceInfo, error)

func (*KcpClusterProvider) GetBasedOnConf

func (k *KcpClusterProvider) GetBasedOnConf(spaceName string, cfgString string) ([]byte, error)

func (*KcpClusterProvider) ListSpaces

func (k *KcpClusterProvider) ListSpaces() ([]clusterprovider.SpaceInfo, error)

func (*KcpClusterProvider) ListSpacesNames

func (k *KcpClusterProvider) ListSpacesNames() ([]string, error)

ListSpacesNames is N/A for KCP TODO remove it from ProviderClient interface

func (*KcpClusterProvider) Watch

func (k *KcpClusterProvider) Watch() (clusterprovider.Watcher, error)

type KcpWatcher

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

func (*KcpWatcher) ResultChan

func (k *KcpWatcher) ResultChan() <-chan clusterprovider.WatchEvent

func (*KcpWatcher) Stop

func (k *KcpWatcher) Stop()