actions

Documentation

Index

• Constants
• type Action
• type ClusterVersionUpgrade
  • func NewClusterVersionUpgradeAction(c *scyllav1alpha1.Cluster, l log.Logger) *ClusterVersionUpgrade
  • func (a *ClusterVersionUpgrade) Execute(ctx context.Context, s *State) error
  • func (a *ClusterVersionUpgrade) Name() string
• type RackCreate
  • func NewRackCreateAction(r scyllav1alpha1.RackSpec, c *scyllav1alpha1.Cluster, image string) *RackCreate
  • func (a *RackCreate) Execute(ctx context.Context, s *State) error
  • func (a *RackCreate) Name() string
• type RackScaleDown
  • func NewRackScaleDownAction(r scyllav1alpha1.RackSpec, c *scyllav1alpha1.Cluster) *RackScaleDown
  • func (a *RackScaleDown) Execute(ctx context.Context, s *State) error
  • func (a *RackScaleDown) Name() string
• type RackScaleUp
  • func NewRackScaleUpAction(r scyllav1alpha1.RackSpec, c *scyllav1alpha1.Cluster) *RackScaleUp
  • func (a *RackScaleUp) Execute(ctx context.Context, s *State) error
  • func (a *RackScaleUp) Name() string
• type State
  • func NewState(client client.Client, kubeclient kubernetes.Interface, ...) *State

Constants

const (
	ClusterVersionUpgradeAction = "rack-version-upgrade"
)

const RackCreateAction = "rack-create"

const RackScaleDownAction = "rack-scale-down"

const RackScaleUpAction = "rack-scale-up"

Types

type Action

type Action interface {
	// Name returns the action's name.
	// Useful for unit-testing.
	Name() string

	// Execute will execute the action using the
	// ClusterController to read and write the
	// state of the system.
	Execute(ctx context.Context, s *State) error
}

Action represents a discrete action that a scylla rack can take. This can be a rack creation,

type ClusterVersionUpgrade

type ClusterVersionUpgrade struct {
	Cluster *scyllav1alpha1.Cluster
	// contains filtered or unexported fields
}

func NewClusterVersionUpgradeAction

func NewClusterVersionUpgradeAction(c *scyllav1alpha1.Cluster, l log.Logger) *ClusterVersionUpgrade

func (*ClusterVersionUpgrade) Execute

func (a *ClusterVersionUpgrade) Execute(ctx context.Context, s *State) error

func (*ClusterVersionUpgrade) Name

func (a *ClusterVersionUpgrade) Name() string

type RackCreate

type RackCreate struct {
	Rack          scyllav1alpha1.RackSpec
	Cluster       *scyllav1alpha1.Cluster
	OperatorImage string
}

func NewRackCreateAction

func NewRackCreateAction(r scyllav1alpha1.RackSpec, c *scyllav1alpha1.Cluster, image string) *RackCreate

func (*RackCreate) Execute

func (a *RackCreate) Execute(ctx context.Context, s *State) error

func (*RackCreate) Name

func (a *RackCreate) Name() string

type RackScaleDown

type RackScaleDown struct {
	Rack    scyllav1alpha1.RackSpec
	Cluster *scyllav1alpha1.Cluster
}

func NewRackScaleDownAction

func NewRackScaleDownAction(r scyllav1alpha1.RackSpec, c *scyllav1alpha1.Cluster) *RackScaleDown

func (*RackScaleDown) Execute

func (a *RackScaleDown) Execute(ctx context.Context, s *State) error

func (*RackScaleDown) Name

func (a *RackScaleDown) Name() string

type RackScaleUp

type RackScaleUp struct {
	Rack    scyllav1alpha1.RackSpec
	Cluster *scyllav1alpha1.Cluster
}

func NewRackScaleUpAction

func NewRackScaleUpAction(r scyllav1alpha1.RackSpec, c *scyllav1alpha1.Cluster) *RackScaleUp

func (*RackScaleUp) Execute

func (a *RackScaleUp) Execute(ctx context.Context, s *State) error

func (*RackScaleUp) Name

func (a *RackScaleUp) Name() string

type State

type State struct {
	// Dynamic client - uses caching for lookups
	client.Client
	// contains filtered or unexported fields
}

State contains tools to discover and modify the state of the world.

func NewState

func NewState(client client.Client, kubeclient kubernetes.Interface, recorder record.EventRecorder) *State