clustermanager

Documentation

Index

• type Manager
  • func NewManager(httpsPort int, context *config.ScaledContext) *Manager
  • func (m *Manager) APIExtClient(apiContext *types.APIContext, storageContext types.StorageContext) (clientset.Interface, error)
  • func (m *Manager) AccessControl(apiContext *types.APIContext, storageContext types.StorageContext) (types.AccessControl, error)
  • func (m *Manager) CanCreate(apiContext *types.APIContext, schema *types.Schema) bool
  • func (m *Manager) CanDelete(apiContext *types.APIContext, obj map[string]interface{}, schema *types.Schema) bool
  • func (m *Manager) CanGet(apiContext *types.APIContext, schema *types.Schema) bool
  • func (m *Manager) CanList(apiContext *types.APIContext, schema *types.Schema) bool
  • func (m *Manager) CanUpdate(apiContext *types.APIContext, obj map[string]interface{}, schema *types.Schema) bool
  • func (m *Manager) Config(apiContext *types.APIContext, storageContext types.StorageContext) (rest.Config, error)
  • func (m *Manager) Filter(apiContext *types.APIContext, schema *types.Schema, obj map[string]interface{}, ...) map[string]interface{}
  • func (m *Manager) FilterList(apiContext *types.APIContext, schema *types.Schema, ...) []map[string]interface{}
  • func (m *Manager) KubeConfig(clusterName, token string) *clientcmdapi.Config
  • func (m *Manager) RESTConfig(cluster *v3.Cluster) (rest.Config, error)
  • func (m *Manager) Start(ctx context.Context, cluster *v3.Cluster) error
  • func (m *Manager) Stop(cluster *v3.Cluster)
  • func (m *Manager) UnversionedClient(apiContext *types.APIContext, storageContext types.StorageContext) (rest.Interface, error)

Types

type Manager

type Manager struct {
	ScaledContext *config.ScaledContext
	// contains filtered or unexported fields
}

func NewManager

func NewManager(httpsPort int, context *config.ScaledContext) *Manager

func (*Manager) APIExtClient

func (m *Manager) APIExtClient(apiContext *types.APIContext, storageContext types.StorageContext) (clientset.Interface, error)

func (*Manager) AccessControl

func (m *Manager) AccessControl(apiContext *types.APIContext, storageContext types.StorageContext) (types.AccessControl, error)

func (*Manager) CanCreate

func (m *Manager) CanCreate(apiContext *types.APIContext, schema *types.Schema) bool

func (*Manager) CanDelete

func (m *Manager) CanDelete(apiContext *types.APIContext, obj map[string]interface{}, schema *types.Schema) bool

func (*Manager) CanGet

func (m *Manager) CanGet(apiContext *types.APIContext, schema *types.Schema) bool

func (*Manager) CanList

func (m *Manager) CanList(apiContext *types.APIContext, schema *types.Schema) bool

func (*Manager) CanUpdate

func (m *Manager) CanUpdate(apiContext *types.APIContext, obj map[string]interface{}, schema *types.Schema) bool

func (*Manager) Config

func (m *Manager) Config(apiContext *types.APIContext, storageContext types.StorageContext) (rest.Config, error)

func (*Manager) Filter

func (m *Manager) Filter(apiContext *types.APIContext, schema *types.Schema, obj map[string]interface{}, context map[string]string) map[string]interface{}

func (*Manager) FilterList

func (m *Manager) FilterList(apiContext *types.APIContext, schema *types.Schema, obj []map[string]interface{}, context map[string]string) []map[string]interface{}

func (*Manager) KubeConfig

func (m *Manager) KubeConfig(clusterName, token string) *clientcmdapi.Config

func (*Manager) RESTConfig

func (m *Manager) RESTConfig(cluster *v3.Cluster) (rest.Config, error)

func (*Manager) Start

func (m *Manager) Start(ctx context.Context, cluster *v3.Cluster) error

func (*Manager) Stop

func (m *Manager) Stop(cluster *v3.Cluster)

func (*Manager) UnversionedClient

func (m *Manager) UnversionedClient(apiContext *types.APIContext, storageContext types.StorageContext) (rest.Interface, error)