cluster

package

v0.3.0 Latest Latest Go to latest Published: Jan 19, 2021 License: LGPL-3.0 Imports: 14 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/wtxue/kok-operator

Links

Open Source Insights

Documentation ¶

Constants ¶

View Source

const (
	ReasonFailedProcess     = "FailedProcess"
	ReasonWaitingProcess    = "WaitingProcess"
	ReasonSuccessfulProcess = "SuccessfulProcess"
	ReasonSkipProcess       = "SkipProcess"

	ConditionTypeDone = "EnsureDone"
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type CpManager ¶

type CpManager struct {
	sync.RWMutex
	Cp map[string]Provider
}

func New ¶

func New() *CpManager

func (*CpManager) GetProvider ¶

func (p *CpManager) GetProvider(name string) (Provider, error)

GetProvider returns provider by name

func (*CpManager) Providers ¶

func (p *CpManager) Providers() []string

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

func (*CpManager) Register ¶

func (p *CpManager) 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 (*CpManager) RegisterHandler ¶

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

RegisterHandler register all provider's hanlder.

type DelegateProvider ¶

type DelegateProvider struct {
	ProviderName string

	ValidateFunc    func(ctx *common.ClusterContext) field.ErrorList
	PreCreateFunc   func(ctx *common.ClusterContext) error
	AfterCreateFunc func(ctx *common.ClusterContext) error

	CreateHandlers []Handler
	DeleteHandlers []Handler
	UpdateHandlers []Handler
}

func (*DelegateProvider) AfterCreate ¶

func (p *DelegateProvider) AfterCreate(ctx *common.ClusterContext) error

func (*DelegateProvider) Name ¶

func (p *DelegateProvider) Name() string

func (*DelegateProvider) OnCreate ¶

func (p *DelegateProvider) OnCreate(ctx *common.ClusterContext) error

func (*DelegateProvider) OnDelete ¶

func (p *DelegateProvider) OnDelete(ctx *common.ClusterContext) error

func (*DelegateProvider) OnUpdate ¶

func (p *DelegateProvider) OnUpdate(ctx *common.ClusterContext) error

func (*DelegateProvider) PreCreate ¶

func (p *DelegateProvider) PreCreate(ctx *common.ClusterContext) error

func (*DelegateProvider) RegisterHandler ¶

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

func (*DelegateProvider) Validate ¶

func (p *DelegateProvider) Validate(ctx *common.ClusterContext) field.ErrorList

type Handler ¶

type Handler func(ctx *common.ClusterContext) error

func (Handler) Name ¶

func (h Handler) Name() string

type Provider ¶

type Provider interface {
	Name() string

	RegisterHandler(mux *mux.PathRecorderMux)

	Validate(ctx *common.ClusterContext) field.ErrorList

	PreCreate(ctx *common.ClusterContext) error
	AfterCreate(ctx *common.ClusterContext) error

	OnCreate(ctx *common.ClusterContext) error
	OnUpdate(ctx *common.ClusterContext) error
	OnDelete(ctx *common.ClusterContext) error
}

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL