Documentation
¶
Index ¶
- Constants
- func Providers() []string
- func Register(name string, provider Provider)
- func RegisterHandler(mux *mux.PathRecorderMux)
- func Setup() error
- func Teardown() error
- type APIProvider
- type ControllerProvider
- type DelegateProvider
- func (p *DelegateProvider) AfterCreate(cluster *types.Cluster) error
- func (p *DelegateProvider) Name() string
- func (p *DelegateProvider) OnCreate(ctx context.Context, cluster *v1.Cluster) error
- func (p *DelegateProvider) OnDelete(ctx context.Context, cluster *v1.Cluster) error
- func (p *DelegateProvider) OnRunning(ctx context.Context, cluster *v1.Cluster) error
- func (p *DelegateProvider) OnUpdate(ctx context.Context, cluster *v1.Cluster) error
- func (p *DelegateProvider) PreCreate(cluster *types.Cluster) error
- func (p *DelegateProvider) RegisterHandler(mux *mux.PathRecorderMux)
- func (p *DelegateProvider) Setup() error
- func (p *DelegateProvider) Teardown() error
- func (p *DelegateProvider) Validate(cluster *types.Cluster) field.ErrorList
- type Handler
- type Provider
Constants ¶
View Source
const ( ReasonWaiting = "Waiting" ReasonSkip = "Skip" ReasonFailedInit = "FailedInit" ReasonFailedUpdate = "FailedUpdate" ReasonFailedDelete = "FailedDelete" ConditionTypeDone = "EnsureDone" )
Variables ¶
This section is empty.
Functions ¶
func Providers ¶
func Providers() []string
Providers returns a sorted list of the names of the registered providers.
func Register ¶
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.
Types ¶
type APIProvider ¶ added in v1.3.1
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 OnCreate(ctx context.Context, cluster *v1.Cluster) error OnUpdate(ctx context.Context, cluster *v1.Cluster) error OnDelete(ctx context.Context, cluster *v1.Cluster) error // 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 PreCreateFunc func(cluster *types.Cluster) error AfterCreateFunc func(cluster *types.Cluster) error CreateHandlers []Handler DeleteHandlers []Handler UpdateHandlers []Handler UpgradeHandlers []Handler ScaleUpHandlers []Handler ScaleDownHandlers []Handler }
func (*DelegateProvider) AfterCreate ¶ added in v1.3.1
func (p *DelegateProvider) AfterCreate(cluster *types.Cluster) error
func (*DelegateProvider) Name ¶ added in v1.3.1
func (p *DelegateProvider) Name() string
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
type Provider ¶
type Provider interface { Name() string APIProvider ControllerProvider }
Provider defines a set of response interfaces for specific cluster types in cluster management.
func GetProvider ¶
GetProvider returns provider by name
Click to show internal directories.
Click to hide internal directories.