actions

package
v0.62.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 26, 2026 License: Apache-2.0 Imports: 37 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// ActionIDLogField is the log field name for action ID.
	// This field is used in backend to detect actions ID in logs.
	ActionIDLogField = "id"
)

Variables

This section is empty.

Functions

func ShouldWaitForVolumeDetach added in v0.62.0 

func ShouldWaitForVolumeDetach(req *castai.ActionDrainNode) bool

ShouldWaitForVolumeDetach returns whether to wait for VolumeAttachments based on per-action config. Returns true only if explicitly enabled via action field; defaults to false (disabled).

Types

type ActionHandler 

type ActionHandler interface {
	Handle(ctx context.Context, action *castai.ClusterAction) error
}

func NewCheckNodeStatusHandler 

func NewCheckNodeStatusHandler(log logrus.FieldLogger, clientset kubernetes.Interface) ActionHandler

func NewCheckNodeStatusInformerHandler added in v0.62.0 

func NewCheckNodeStatusInformerHandler(log logrus.FieldLogger, clientset kubernetes.Interface, nodeInformer informer.NodeInformer) ActionHandler

func NewEvictPodHandler added in v0.54.9 

func NewEvictPodHandler(log logrus.FieldLogger, clientset kubernetes.Interface) ActionHandler

type ActionHandlers added in v0.61.0 

type ActionHandlers map[reflect.Type]ActionHandler

func NewDefaultActionHandlers added in v0.61.0 

func NewDefaultActionHandlers(
	k8sVersion string,
	castNamespace string,
	log logrus.FieldLogger,
	clientset *kubernetes.Clientset,
	dynamicClient dynamic.Interface,
	helmClient helm.Client,
	nodeInformer informer.NodeInformer,
	podInformer informer.PodInformer,
	vaWaiter volume.DetachmentWaiter,
) ActionHandlers

func (ActionHandlers) Close added in v0.61.0 

func (h ActionHandlers) Close() error

type ChartRollbackHandler 

type ChartRollbackHandler struct {
	// contains filtered or unexported fields
}

func NewChartRollbackHandler 

func NewChartRollbackHandler(log logrus.FieldLogger, helm helm.Client, version string) *ChartRollbackHandler

func (*ChartRollbackHandler) Handle 

func (c *ChartRollbackHandler) Handle(_ context.Context, action *castai.ClusterAction) error

type ChartUninstallHandler 

type ChartUninstallHandler struct {
	// contains filtered or unexported fields
}

func NewChartUninstallHandler 

func NewChartUninstallHandler(log logrus.FieldLogger, helm helm.Client) *ChartUninstallHandler

func (*ChartUninstallHandler) Handle 

func (c *ChartUninstallHandler) Handle(_ context.Context, action *castai.ClusterAction) error

type ChartUpsertHandler 

type ChartUpsertHandler struct {
	// contains filtered or unexported fields
}

func NewChartUpsertHandler 

func NewChartUpsertHandler(log logrus.FieldLogger, helm helm.Client) *ChartUpsertHandler

func (*ChartUpsertHandler) Handle 

func (c *ChartUpsertHandler) Handle(ctx context.Context, action *castai.ClusterAction) error

type CheckNodeDeletedHandler 

type CheckNodeDeletedHandler struct {
	// contains filtered or unexported fields
}

func NewCheckNodeDeletedHandler 

func NewCheckNodeDeletedHandler(log logrus.FieldLogger, clientset kubernetes.Interface) *CheckNodeDeletedHandler

func (*CheckNodeDeletedHandler) Handle 

func (h *CheckNodeDeletedHandler) Handle(ctx context.Context, action *castai.ClusterAction) error

type CheckNodeStatusHandler 

type CheckNodeStatusHandler struct {
	// contains filtered or unexported fields
}

func (*CheckNodeStatusHandler) Handle 

func (h *CheckNodeStatusHandler) Handle(ctx context.Context, action *castai.ClusterAction) error

type CreateEventHandler 

type CreateEventHandler struct {
	// contains filtered or unexported fields
}

func NewCreateEventHandler 

func NewCreateEventHandler(log logrus.FieldLogger, clientset kubernetes.Interface) *CreateEventHandler

func (*CreateEventHandler) Close 

func (h *CreateEventHandler) Close() error

func (*CreateEventHandler) Handle 

func (h *CreateEventHandler) Handle(ctx context.Context, action *castai.ClusterAction) error

type CreateHandler 

type CreateHandler struct {
	// contains filtered or unexported fields
}

func NewCreateHandler 

func NewCreateHandler(log logrus.FieldLogger, client dynamic.Interface) *CreateHandler

func (*CreateHandler) Handle 

func (h *CreateHandler) Handle(ctx context.Context, action *castai.ClusterAction) error

type DeleteHandler 

type DeleteHandler struct {
	// contains filtered or unexported fields
}

func NewDeleteHandler 

func NewDeleteHandler(log logrus.FieldLogger, client dynamic.Interface) *DeleteHandler

func (*DeleteHandler) Handle 

func (h *DeleteHandler) Handle(ctx context.Context, action *castai.ClusterAction) error

type DeleteNodeHandler 

type DeleteNodeHandler struct {
	DrainNodeHandler
	// contains filtered or unexported fields
}

func NewDeleteNodeHandler 

func NewDeleteNodeHandler(log logrus.FieldLogger, clientset kubernetes.Interface) *DeleteNodeHandler

func (*DeleteNodeHandler) Handle 

func (h *DeleteNodeHandler) Handle(ctx context.Context, action *castai.ClusterAction) error

nolint: gocognit

type DisconnectClusterHandler 

type DisconnectClusterHandler struct {
	// contains filtered or unexported fields
}

func NewDisconnectClusterHandler 

func NewDisconnectClusterHandler(log logrus.FieldLogger, client kubernetes.Interface) *DisconnectClusterHandler

func (*DisconnectClusterHandler) Handle 

func (c *DisconnectClusterHandler) Handle(ctx context.Context, action *castai.ClusterAction) error

type DrainNodeHandler 

type DrainNodeHandler struct {
	// contains filtered or unexported fields
}

func NewDrainNodeHandler 

func NewDrainNodeHandler(
	log logrus.FieldLogger,
	clientset kubernetes.Interface,
	castNamespace string,
	vaWaiter volume.DetachmentWaiter,
) *DrainNodeHandler

func (*DrainNodeHandler) Handle 

func (h *DrainNodeHandler) Handle(ctx context.Context, action *castai.ClusterAction) error

type DrainNodeInfomerHandler added in v0.62.0 

type DrainNodeInfomerHandler struct {
	// contains filtered or unexported fields
}

func NewDrainNodeInformerHandler added in v0.62.0 

func NewDrainNodeInformerHandler(
	log logrus.FieldLogger,
	clientset kubernetes.Interface,
	castNamespace string,
	vaWaiter volume.DetachmentWaiter,
	podInformer informer.PodInformer,
	nodeInformer informer.NodeInformer,
) *DrainNodeInfomerHandler

func (*DrainNodeInfomerHandler) Handle added in v0.62.0 

func (h *DrainNodeInfomerHandler) Handle(ctx context.Context, action *castai.ClusterAction) error

type EvictPodHandler added in v0.54.9 

type EvictPodHandler struct {
	// contains filtered or unexported fields
}

func (*EvictPodHandler) Handle added in v0.54.9 

func (h *EvictPodHandler) Handle(ctx context.Context, action *castai.ClusterAction) error

type PatchHandler 

type PatchHandler struct {
	// contains filtered or unexported fields
}

func NewPatchHandler 

func NewPatchHandler(log logrus.FieldLogger, client dynamic.Interface) *PatchHandler

func (*PatchHandler) Handle 

func (h *PatchHandler) Handle(ctx context.Context, action *castai.ClusterAction) error

type PatchNodeHandler 

type PatchNodeHandler struct {
	// contains filtered or unexported fields
}

func NewPatchNodeHandler 

func NewPatchNodeHandler(log logrus.FieldLogger, clientset kubernetes.Interface) *PatchNodeHandler

func (*PatchNodeHandler) Handle 

func (h *PatchNodeHandler) Handle(ctx context.Context, action *castai.ClusterAction) error

Source Files

View all Source files

Directories

Path Synopsis
csr
test
wrapper
Package mock_actions is a generated GoMock package.
 Package mock_actions is a generated GoMock package.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.