actions

Documentation

Index

• type CreateNodePool
  • func (c *CreateNodePool) Execute(state *controllers.State) error
  • func (c *CreateNodePool) Name() string
• type CreatePilot
  • func (c *CreatePilot) Execute(state *controllers.State) error
  • func (c *CreatePilot) Name() string
• type Scale
  • func (s *Scale) Execute(state *controllers.State) error
  • func (c *Scale) Name() string
• type UpdateVersion
  • func (c *UpdateVersion) Execute(state *controllers.State) error
  • func (c *UpdateVersion) Name() string

Types

type CreateNodePool

type CreateNodePool struct {
	Cluster  *v1alpha1.ElasticsearchCluster
	NodePool *v1alpha1.ElasticsearchClusterNodePool
}

func (*CreateNodePool) Execute

func (c *CreateNodePool) Execute(state *controllers.State) error

func (*CreateNodePool) Name

func (c *CreateNodePool) Name() string

type CreatePilot

type CreatePilot struct {
	Cluster  *v1alpha1.ElasticsearchCluster
	NodePool *v1alpha1.ElasticsearchClusterNodePool
}

func (*CreatePilot) Execute

func (c *CreatePilot) Execute(state *controllers.State) error

func (*CreatePilot) Name

func (c *CreatePilot) Name() string

type Scale

type Scale struct {
	// The Elasticsearch cluster resource being operated on
	Cluster *v1alpha1.ElasticsearchCluster
	// The node pool being scaled
	NodePool *v1alpha1.ElasticsearchClusterNodePool
	// Number of replicas to scale to
	Replicas int32
}

func (*Scale) Execute

func (s *Scale) Execute(state *controllers.State) error

Execute will scale the s.NodePool statefulset to the desired number of replicas. It will refuse to scale if the cluster is not in a 'state to scale' as defined by s.canScaleNodePool.

func (*Scale) Name

func (c *Scale) Name() string

type UpdateVersion

type UpdateVersion struct {
	// The Elasticsearch cluster resource being operated on
	Cluster *v1alpha1.ElasticsearchCluster
	// The node pool being scaled
	NodePool *v1alpha1.ElasticsearchClusterNodePool
	// contains filtered or unexported fields
}

func (*UpdateVersion) Execute

func (c *UpdateVersion) Execute(state *controllers.State) error

func (*UpdateVersion) Name

func (c *UpdateVersion) Name() string