Documentation ¶
Index ¶
- Variables
- type ChannelHub
- type CloudFormationHelper
- func (cf *CloudFormationHelper) GetCloudFormation() *cloudformation.Client
- func (cf *CloudFormationHelper) GetStack(ctx context.Context, instance *v1alpha1.Stack) (*cfTypes.Stack, error)
- func (cf *CloudFormationHelper) GetStackName(ctx context.Context, instance *v1alpha1.Stack, allowID bool) string
- func (cf *CloudFormationHelper) GetStackResources(ctx context.Context, stackId string) ([]v1alpha1.StackResource, error)
- func (cf *CloudFormationHelper) StackInTerminalState(status cfTypes.StackStatus) bool
- type MapWriter
- type StackFollower
- type StackLoop
- type StackReconciler
Constants ¶
This section is empty.
Variables ¶
View Source
var (
ErrMissingTemplateSpec = coreerrors.New("template or templateUrl must be provided")
)
View Source
var (
ErrStackNotFound = coreerrors.New("stack not found")
)
Functions ¶
This section is empty.
Types ¶
type ChannelHub ¶
type CloudFormationHelper ¶
type CloudFormationHelper struct {
*servicesk8saws.ConfigReconciler
}
func (*CloudFormationHelper) GetCloudFormation ¶
func (cf *CloudFormationHelper) GetCloudFormation() *cloudformation.Client
func (*CloudFormationHelper) GetStackName ¶
func (*CloudFormationHelper) GetStackResources ¶
func (cf *CloudFormationHelper) GetStackResources(ctx context.Context, stackId string) ([]v1alpha1.StackResource, error)
func (*CloudFormationHelper) StackInTerminalState ¶
func (cf *CloudFormationHelper) StackInTerminalState(status cfTypes.StackStatus) bool
StackInTerminalState Identify if the follower considers the state identified as terminal.
type StackFollower ¶
type StackFollower struct { client.Client ChannelHub Log logr.Logger CloudFormationHelper *CloudFormationHelper StacksFollowing prometheus.Gauge StacksFollowed prometheus.Counter // contains filtered or unexported fields }
StackFollower ensures a Stack object is monitored until it reaches a terminal state
func (*StackFollower) Receiver ¶
func (f *StackFollower) Receiver()
func (*StackFollower) Worker ¶
func (f *StackFollower) Worker()
type StackReconciler ¶
type StackReconciler struct { client.Client ChannelHub Log logr.Logger Scheme *runtime.Scheme WatchNamespaces []string CloudFormationHelper *CloudFormationHelper DryRun bool }
StackReconciler reconciles a Stack object
func (*StackReconciler) Reconcile ¶
Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.
For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.10.3/pkg/reconcile
func (*StackReconciler) SetupWithManager ¶
func (r *StackReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
Click to show internal directories.
Click to hide internal directories.