Documentation
¶
Index ¶
- Constants
- func AddWithActuator(mgr manager.Manager, actuator Actuator) error
- type Actuator
- type ReconcileMachine
- type TestActuator
- func (a *TestActuator) Create(context.Context, *v1alpha1.Cluster, *v1alpha1.Machine) error
- func (a *TestActuator) Delete(context.Context, *v1alpha1.Cluster, *v1alpha1.Machine) error
- func (a *TestActuator) Exists(context.Context, *v1alpha1.Cluster, *v1alpha1.Machine) (bool, error)
- func (a *TestActuator) Unblock()
- func (a *TestActuator) Update(ctx context.Context, c *v1alpha1.Cluster, machine *v1alpha1.Machine) error
Constants ¶
View Source
const (
NodeNameEnvVar = "NODE_NAME"
)
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Actuator ¶
type Actuator interface {
// Create the machine.
Create(context.Context, *clusterv1.Cluster, *clusterv1.Machine) error
// Delete the machine. If no error is returned, it is assumed that all dependent resources have been cleaned up.
Delete(context.Context, *clusterv1.Cluster, *clusterv1.Machine) error
// Update the machine to the provided definition.
Update(context.Context, *clusterv1.Cluster, *clusterv1.Machine) error
// Checks if the machine currently exists.
Exists(context.Context, *clusterv1.Cluster, *clusterv1.Machine) (bool, error)
}
/ Actuator Actuator controls machines on a specific infrastructure. All methods should be idempotent unless otherwise specified.
var DefaultActuator Actuator
type ReconcileMachine ¶
ReconcileMachine reconciles a Machine object
type TestActuator ¶
type TestActuator struct {
BlockOnCreate bool
BlockOnDelete bool
BlockOnUpdate bool
BlockOnExists bool
CreateCallCount int64
DeleteCallCount int64
UpdateCallCount int64
ExistsCallCount int64
ExistsValue bool
Lock sync.Mutex
// contains filtered or unexported fields
}
func (*TestActuator) Unblock ¶
func (a *TestActuator) Unblock()
Click to show internal directories.
Click to hide internal directories.