cluster

package
v1.9.0-industry.2 Latest Latest
Warning

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

 Go to latest Published: Dec 1, 2022 License: Apache-2.0, BSD-2-Clause, BSD-3-Clause, + 8 more Imports: 23 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ReasonWaiting      = "Waiting"
	ReasonSkip         = "Skip"
	ReasonFailedInit   = "FailedInit"
	ReasonFailedUpdate = "FailedUpdate"
	ReasonFailedDelete = "FailedDelete"
	ConditionTypeDone  = "EnsureDone"
)
View Source 
const AdminUsername = "admin"

Variables

This section is empty.

Functions

func GetCluster added in v1.8.0 

func GetCluster(ctx context.Context, platformClient internalversion.PlatformInterface, cluster *platform.Cluster, username string) (*types.Cluster, error)

func GetClusterByName added in v1.8.0 

func GetClusterByName(ctx context.Context, platformClient internalversion.PlatformInterface, clsname, username string) (*types.Cluster, error)

func GetV1Cluster added in v1.8.0 

func GetV1Cluster(ctx context.Context, platformClient platformversionedclient.PlatformV1Interface, cluster *platformv1.Cluster, username string) (*v1.Cluster, error)

func GetV1ClusterByName added in v1.8.0 

func GetV1ClusterByName(ctx context.Context, platformClient platformversionedclient.PlatformV1Interface, clsname, username string) (*v1.Cluster, error)

func Providers 

func Providers() []string

Providers returns a sorted list of the names of the registered providers.

func ReRegister added in v1.9.0 

func ReRegister(name string, provider Provider) error

re register provider, if provider's name exists, new provider will replace old provider

func Register 

func Register(name string, provider Provider)

Register makes a provider available by the provided name. If Register is called twice with the same name or if provider is nil, it panics.

func RegisterHandler added in v1.3.1 

func RegisterHandler(mux *mux.PathRecorderMux)

RegisterHandler register all provider's hanlder.

func Setup added in v1.3.1 

func Setup() error

Setup call all provider's setup method.

func Teardown added in v1.3.1 

func Teardown() error

Teardown call all provider's teardown method.

Types

type APIProvider added in v1.3.1 

type APIProvider interface {
	RegisterHandler(mux *mux.PathRecorderMux)
	Validate(cluster *types.Cluster) field.ErrorList
	ValidateUpdate(cluster *types.Cluster, oldCluster *types.Cluster) field.ErrorList
	PreCreate(cluster *types.Cluster) error
	AfterCreate(cluster *types.Cluster) error
}

type ControllerProvider added in v1.3.1 

type ControllerProvider interface {
	// Setup called by controller to give an chance for plugin do some init work.
	Setup() error
	// Teardown called by controller for plugin do some clean job.
	Teardown() error
	// NeedUpdate could be implemented by user to judge whether cluster need update or not.
	NeedUpdate(old, new *platformv1.Cluster) bool

	OnCreate(ctx context.Context, cluster *v1.Cluster) error
	OnUpdate(ctx context.Context, cluster *v1.Cluster) error
	OnDelete(ctx context.Context, cluster *v1.Cluster) error
	// OnFilter called by cluster controller informer for plugin
	// do the filter on the cluster obj for specific case:
	// return bool:
	//  false: drop the object to the queue
	//  true: add the object to queue, AddFunc and UpdateFunc will
	//  go through later
	OnFilter(ctx context.Context, cluster *platformv1.Cluster) bool
	// OnRunning call on first running.
	OnRunning(ctx context.Context, cluster *v1.Cluster) error
}

type DelegateProvider added in v1.3.1 

type DelegateProvider struct {
	ProviderName string

	ValidateFunc       func(cluster *types.Cluster) field.ErrorList
	ValidateUpdateFunc func(cluster *types.Cluster, oldCluster *types.Cluster) field.ErrorList
	PreCreateFunc      func(cluster *types.Cluster) error
	AfterCreateFunc    func(cluster *types.Cluster) error

	CreateHandlers    []Handler
	DeleteHandlers    []Handler
	UpdateHandlers    []Handler
	UpgradeHandlers   []Handler
	ScaleUpHandlers   []Handler
	ScaleDownHandlers []Handler
	PlatformClient    platformv1client.PlatformV1Interface
}

func (*DelegateProvider) AfterCreate added in v1.3.1 

func (p *DelegateProvider) AfterCreate(cluster *types.Cluster) error

func (*DelegateProvider) GetRestConfig added in v1.9.0 

func (p *DelegateProvider) GetRestConfig(ctx context.Context, cluster *platformv1.Cluster, username string) (*rest.Config, error)

GetRestConfig returns the cluster's rest config

func (*DelegateProvider) Name added in v1.3.1 

func (p *DelegateProvider) Name() string

func (*DelegateProvider) NeedUpdate added in v1.8.0 

func (p *DelegateProvider) NeedUpdate(old, new *platformv1.Cluster) bool

func (*DelegateProvider) OnCreate added in v1.3.1 

func (p *DelegateProvider) OnCreate(ctx context.Context, cluster *v1.Cluster) error

func (*DelegateProvider) OnDelete added in v1.3.1 

func (p *DelegateProvider) OnDelete(ctx context.Context, cluster *v1.Cluster) error

func (*DelegateProvider) OnFilter added in v1.8.0 

func (p *DelegateProvider) OnFilter(ctx context.Context, cluster *platformv1.Cluster) (pass bool)

func (*DelegateProvider) OnRunning added in v1.3.1 

func (p *DelegateProvider) OnRunning(ctx context.Context, cluster *v1.Cluster) error

func (*DelegateProvider) OnUpdate added in v1.3.1 

func (p *DelegateProvider) OnUpdate(ctx context.Context, cluster *v1.Cluster) error

func (*DelegateProvider) PreCreate added in v1.3.1 

func (p *DelegateProvider) PreCreate(cluster *types.Cluster) error

func (*DelegateProvider) RegisterHandler added in v1.3.1 

func (p *DelegateProvider) RegisterHandler(mux *mux.PathRecorderMux)

func (*DelegateProvider) Setup added in v1.3.1 

func (p *DelegateProvider) Setup() error

func (*DelegateProvider) Teardown added in v1.3.1 

func (p *DelegateProvider) Teardown() error

func (*DelegateProvider) Validate added in v1.3.1 

func (p *DelegateProvider) Validate(cluster *types.Cluster) field.ErrorList

func (*DelegateProvider) ValidateUpdate added in v1.9.0 

func (p *DelegateProvider) ValidateUpdate(cluster *types.Cluster, oldCluster *types.Cluster) field.ErrorList

type Handler added in v1.3.1 

type Handler func(context.Context, *v1.Cluster) error

func (Handler) Name added in v1.3.1 

func (h Handler) Name() string

type Provider 

type Provider interface {
	Name() string

	APIProvider
	ControllerProvider
	RestConfigProvider
}

Provider defines a set of response interfaces for specific cluster types in cluster management.

func GetProvider 

func GetProvider(name string) (Provider, error)

GetProvider returns provider by name

type RestConfigProvider added in v1.9.0 

type RestConfigProvider interface {
	GetRestConfig(ctx context.Context, cluster *platformv1.Cluster, username string) (*rest.Config, error)
}

Source Files

View all Source files

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.