Documentation
¶
Index ¶
- Constants
- type ActionHandler
- type ApproveCSRHandler
- type ChartRollbackHandler
- type ChartUninstallHandler
- type ChartUpsertHandler
- type CheckNodeDeletedHandler
- type CheckNodeStatusHandler
- type CreateEventHandler
- type CreateHandler
- type DeleteHandler
- type DeleteNodeHandler
- type DisconnectClusterHandler
- type DrainNodeHandler
- type PatchHandler
- type PatchNodeHandler
- type SendAKSInitDataHandler
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 ¶
This section is empty.
Types ¶
type ActionHandler ¶
type ActionHandler interface {
Handle(ctx context.Context, action *castai.ClusterAction) error
}
type ApproveCSRHandler ¶
type ApproveCSRHandler struct {
// contains filtered or unexported fields
}
func NewApproveCSRHandler ¶
func NewApproveCSRHandler(log logrus.FieldLogger, clientset kubernetes.Interface) *ApproveCSRHandler
func (*ApproveCSRHandler) Handle ¶
func (h *ApproveCSRHandler) Handle(ctx context.Context, action *castai.ClusterAction) 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 NewCheckNodeStatusHandler ¶
func NewCheckNodeStatusHandler(log logrus.FieldLogger, clientset kubernetes.Interface) *CheckNodeStatusHandler
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
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) *DrainNodeHandler
func (*DrainNodeHandler) Handle ¶
func (h *DrainNodeHandler) 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
type SendAKSInitDataHandler ¶
type SendAKSInitDataHandler struct {
// contains filtered or unexported fields
}
func NewSendAKSInitDataHandler ¶
func NewSendAKSInitDataHandler(log logrus.FieldLogger, client castai.CastAIClient) *SendAKSInitDataHandler
func (*SendAKSInitDataHandler) Handle ¶
func (s *SendAKSInitDataHandler) Handle(ctx context.Context, _ *castai.ClusterAction) error
Source Files
¶
- approve_csr_handler.go
- chart_rollback_handler.go
- chart_uninstall_handler.go
- chart_upsert_handler.go
- check_node_deleted.go
- check_node_status.go
- create_event_handler.go
- create_handler.go
- delete_handler.go
- delete_node_handler.go
- disconnect_cluster_handler.go
- drain_node_handler.go
- kubernetes_helpers.go
- patch_handler.go
- patch_node_handler.go
- send_aks_init_data_handler.go
- types.go
Directories
Click to show internal directories.
Click to hide internal directories.