processor

Documentation

Index

• type CreateProcessor
  • func (c *CreateProcessor) Execute(cluster *v2.Cluster) error
  • func (c *CreateProcessor) GetPhasePluginFunc(phase plugin.Phase) func(cluster *v2.Cluster) error
  • func (c *CreateProcessor) GetPipeLine() ([]func(cluster *v2.Cluster) error, error)
  • func (c *CreateProcessor) Init(cluster *v2.Cluster) error
  • func (c *CreateProcessor) Join(cluster *v2.Cluster) error
  • func (c *CreateProcessor) MountImage(cluster *v2.Cluster) error
  • func (c *CreateProcessor) MountRootfs(cluster *v2.Cluster) error
  • func (c *CreateProcessor) RunConfig(cluster *v2.Cluster) error
  • func (c *CreateProcessor) RunGuest(cluster *v2.Cluster) error
  • func (c *CreateProcessor) UnMountImage(cluster *v2.Cluster) error
• type DeleteProcessor
  • func (d DeleteProcessor) CleanFS(cluster *v2.Cluster) error
  • func (d DeleteProcessor) Execute(cluster *v2.Cluster) (err error)
  • func (d DeleteProcessor) GetPipeLine() ([]func(cluster *v2.Cluster) error, error)
  • func (d DeleteProcessor) UnMountImage(cluster *v2.Cluster) error
  • func (d DeleteProcessor) UnMountRootfs(cluster *v2.Cluster) error
• type InstallProcessor
  • func (i InstallProcessor) Execute(cluster *v2.Cluster) error
  • func (i InstallProcessor) Install(cluster *v2.Cluster) error
  • func (i InstallProcessor) MountRootfs(cluster *v2.Cluster) error
• type Interface
  • func NewCreateProcessor() (Interface, error)
  • func NewDeleteProcessor() (Interface, error)
  • func NewInstallProcessor(fs filesystem.Interface) (Interface, error)
  • func NewScaleProcessor(fs filesystem.Interface, ...) (Interface, error)
  • func NewUpgradeProcessor(fs filesystem.Interface, rt runtime.Interface, ...) (Interface, error)
• type ScaleProcessor
  • func (s ScaleProcessor) Execute(cluster *v2.Cluster) error
  • func (s ScaleProcessor) ScaleDown() error
  • func (s ScaleProcessor) ScaleUp(cluster *v2.Cluster) error
• type UpgradeProcessor
  • func (u UpgradeProcessor) Execute(cluster *v2.Cluster) error
  • func (u UpgradeProcessor) MountRootfs(cluster *v2.Cluster) error
  • func (u UpgradeProcessor) Upgrade() error

Types

type CreateProcessor

type CreateProcessor struct {
	ImageManager image.Service
	FileSystem   filesystem.Interface
	Runtime      runtime.Interface
	Guest        guest.Interface
	Config       config.Interface
	Plugins      plugin.Plugins
}

func (*CreateProcessor) Execute

func (c *CreateProcessor) Execute(cluster *v2.Cluster) error

func (*CreateProcessor) GetPhasePluginFunc

func (c *CreateProcessor) GetPhasePluginFunc(phase plugin.Phase) func(cluster *v2.Cluster) error

func (*CreateProcessor) GetPipeLine

func (c *CreateProcessor) GetPipeLine() ([]func(cluster *v2.Cluster) error, error)

func (*CreateProcessor) Init

func (c *CreateProcessor) Init(cluster *v2.Cluster) error

func (*CreateProcessor) Join

func (c *CreateProcessor) Join(cluster *v2.Cluster) error

func (*CreateProcessor) MountImage

func (c *CreateProcessor) MountImage(cluster *v2.Cluster) error

func (*CreateProcessor) MountRootfs

func (c *CreateProcessor) MountRootfs(cluster *v2.Cluster) error

func (*CreateProcessor) RunConfig

func (c *CreateProcessor) RunConfig(cluster *v2.Cluster) error

func (*CreateProcessor) RunGuest

func (c *CreateProcessor) RunGuest(cluster *v2.Cluster) error

func (*CreateProcessor) UnMountImage

func (c *CreateProcessor) UnMountImage(cluster *v2.Cluster) error

type DeleteProcessor

type DeleteProcessor struct {
	FileSystem filesystem.Interface
}

func (DeleteProcessor) CleanFS

func (d DeleteProcessor) CleanFS(cluster *v2.Cluster) error

func (DeleteProcessor) Execute

func (d DeleteProcessor) Execute(cluster *v2.Cluster) (err error)

Execute :according to the different of desired cluster to delete cluster.

func (DeleteProcessor) GetPipeLine

func (d DeleteProcessor) GetPipeLine() ([]func(cluster *v2.Cluster) error, error)

func (DeleteProcessor) UnMountImage

func (d DeleteProcessor) UnMountImage(cluster *v2.Cluster) error

func (DeleteProcessor) UnMountRootfs

func (d DeleteProcessor) UnMountRootfs(cluster *v2.Cluster) error

type InstallProcessor

type InstallProcessor struct {
	FileSystem filesystem.Interface
	Guest      guest.Interface
}

func (InstallProcessor) Execute

func (i InstallProcessor) Execute(cluster *v2.Cluster) error

Execute :according to the different of desired cluster to install app on cluster.

func (InstallProcessor) Install

func (i InstallProcessor) Install(cluster *v2.Cluster) error

func (InstallProcessor) MountRootfs

func (i InstallProcessor) MountRootfs(cluster *v2.Cluster) error

type Interface

type Interface interface {
	// Execute :according to the different of desired cluster to do cluster apply.
	Execute(cluster *v2.Cluster) error
}

func NewCreateProcessor

func NewCreateProcessor() (Interface, error)

func NewDeleteProcessor

func NewDeleteProcessor() (Interface, error)

func NewInstallProcessor

func NewInstallProcessor(fs filesystem.Interface) (Interface, error)

func NewScaleProcessor

func NewScaleProcessor(fs filesystem.Interface, masterToJoin, masterToDelete, nodeToJoin, nodeToDelete []string) (Interface, error)

func NewUpgradeProcessor

func NewUpgradeProcessor(fs filesystem.Interface, rt runtime.Interface, masterToJoin, nodeToJoin []string) (Interface, error)

type ScaleProcessor

type ScaleProcessor struct {
	FileSystem      filesystem.Interface
	Runtime         runtime.Interface
	MastersToJoin   []string
	MastersToDelete []string
	NodesToJoin     []string
	NodesToDelete   []string
	IsScaleUp       bool
}

func (ScaleProcessor) Execute

func (s ScaleProcessor) Execute(cluster *v2.Cluster) error

Execute :according to the different of desired cluster to scale cluster.

func (ScaleProcessor) ScaleDown

func (s ScaleProcessor) ScaleDown() error

func (ScaleProcessor) ScaleUp

func (s ScaleProcessor) ScaleUp(cluster *v2.Cluster) error

type UpgradeProcessor

type UpgradeProcessor struct {
	FileSystem    filesystem.Interface
	Runtime       runtime.Interface
	MastersToJoin []string
	NodesToJoin   []string
}

func (UpgradeProcessor) Execute

func (u UpgradeProcessor) Execute(cluster *v2.Cluster) error

Execute :according to the different of desired cluster to upgrade cluster.

func (UpgradeProcessor) MountRootfs

func (u UpgradeProcessor) MountRootfs(cluster *v2.Cluster) error

func (UpgradeProcessor) Upgrade

func (u UpgradeProcessor) Upgrade() error