Documentation ¶
Index ¶
- Constants
- type Installer
- func (i *Installer) Cleanup(wc *v1.WorkloadCluster)
- func (i *Installer) Install(wc *v1.WorkloadCluster) (jobPath string, err error)
- func (i *Installer) Reduce(wc *v1.WorkloadCluster) (jobPath string, err error)
- func (i *Installer) Remove(wc *v1.WorkloadCluster) (jobPath string, err error)
- func (i *Installer) Scale(wc *v1.WorkloadCluster) (jobPath string, err error)
- type JobType
- type PreChecker
- type PrecheckResult
- type XwcAgentProvider
- func (a *XwcAgentProvider) Cleanup(wc *v1.WorkloadCluster)
- func (a *XwcAgentProvider) Install(wc *v1.WorkloadCluster) (jobPath string)
- func (a *XwcAgentProvider) Precheck(nodes []v1.Node, resultCh chan<- provider.PrecheckResultInterface, ...)
- func (a *XwcAgentProvider) Reduce(wc *v1.WorkloadCluster) (jobPath string)
- func (a *XwcAgentProvider) Remove(wc *v1.WorkloadCluster) (jobPath string)
- func (a *XwcAgentProvider) Scale(wc *v1.WorkloadCluster) (jobPath string)
Constants ¶
View Source
const ( PrecheckCommand = "time /usr/sbin/ip addr |grep " PrecheckTimeout = 60 * time.Second )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Installer ¶
type Installer struct {
// contains filtered or unexported fields
}
func NewInstaller ¶
func NewInstaller(name string, clientSet kubernetes.Interface, timeout int64) *Installer
func (*Installer) Cleanup ¶
func (i *Installer) Cleanup(wc *v1.WorkloadCluster)
func (*Installer) Install ¶
func (i *Installer) Install(wc *v1.WorkloadCluster) (jobPath string, err error)
func (*Installer) Reduce ¶
func (i *Installer) Reduce(wc *v1.WorkloadCluster) (jobPath string, err error)
type PreChecker ¶
type PreChecker struct {
// contains filtered or unexported fields
}
func NewAgentPreChecker ¶
func NewAgentPreChecker() *PreChecker
type PrecheckResult ¶
type PrecheckResult struct { Host string NodeID string CmdList []string Success bool Result string }
func (*PrecheckResult) HostInfo ¶
func (r *PrecheckResult) HostInfo() string
func (*PrecheckResult) IsSuccess ¶
func (r *PrecheckResult) IsSuccess() bool
func (*PrecheckResult) ResultMessage ¶
func (r *PrecheckResult) ResultMessage() string
type XwcAgentProvider ¶
type XwcAgentProvider struct {
// contains filtered or unexported fields
}
func NewXwcAgentProvider ¶
func NewXwcAgentProvider(name string, kubeClient kubernetes.Interface, timeout int64) *XwcAgentProvider
func (*XwcAgentProvider) Cleanup ¶
func (a *XwcAgentProvider) Cleanup(wc *v1.WorkloadCluster)
func (*XwcAgentProvider) Install ¶
func (a *XwcAgentProvider) Install(wc *v1.WorkloadCluster) (jobPath string)
func (*XwcAgentProvider) Precheck ¶
func (a *XwcAgentProvider) Precheck(nodes []v1.Node, resultCh chan<- provider.PrecheckResultInterface, finished chan<- interface{})
func (*XwcAgentProvider) Reduce ¶
func (a *XwcAgentProvider) Reduce(wc *v1.WorkloadCluster) (jobPath string)
func (*XwcAgentProvider) Remove ¶
func (a *XwcAgentProvider) Remove(wc *v1.WorkloadCluster) (jobPath string)
func (*XwcAgentProvider) Scale ¶
func (a *XwcAgentProvider) Scale(wc *v1.WorkloadCluster) (jobPath string)
Click to show internal directories.
Click to hide internal directories.