Documentation ¶
Index ¶
- Constants
- type ClusterActuator
- type ClusterActuatorParams
- type FootlooseMachine
- type MachineActuator
- func (a *MachineActuator) Create(ctx context.Context, cluster *clusterv1.Cluster, machine *clusterv1.Machine) error
- func (a *MachineActuator) Delete(ctx context.Context, cluster *clusterv1.Cluster, machine *clusterv1.Machine) error
- func (a *MachineActuator) Exists(ctx context.Context, cluster *clusterv1.Cluster, machine *clusterv1.Machine) (bool, error)
- func (a *MachineActuator) Update(ctx context.Context, cluster *clusterv1.Cluster, machine *clusterv1.Machine) error
- type MachineActuatorParams
Constants ¶
const ProviderName = "wks"
ProviderName is the name of this cluster API provider.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ClusterActuator ¶
type ClusterActuator struct {
// contains filtered or unexported fields
}
ClusterActuator is responsible for managing this cluster, and ensuring its state converges towards its definition.
func NewClusterActuator ¶
func NewClusterActuator(params ClusterActuatorParams) (*ClusterActuator, error)
NewClusterActuator creates a new cluster actuator.
type ClusterActuatorParams ¶
type ClusterActuatorParams struct { Client client.Client ClientSet *kubernetes.Clientset EventRecorder record.EventRecorder Scheme *runtime.Scheme }
ClusterActuatorParams groups required inputs to create a cluster actuator.
type FootlooseMachine ¶
type FootlooseMachine struct { Spec *fconfig.Machine `json:"spec"` // container name. Name string `json:"name"` // container hostname. Hostname string `json:"hostname"` // container ip. IP string `json:"ip,omitempty"` RuntimeNetworks []*cluster.RuntimeNetwork `json:"runtimeNetworks,omitempty"` Ports map[int]int `json:"ports,omitempty"` }
STOPGAP: copy of machine def from footloose; the footloose version has private fields
type MachineActuator ¶
type MachineActuator struct {
// contains filtered or unexported fields
}
MachineActuator is responsible for managing this cluster's machines, and ensuring their state converge towards their definitions.
func NewMachineActuator ¶
func NewMachineActuator(params MachineActuatorParams) (*MachineActuator, error)
NewMachineActuator creates a new Machine actuator.
func (*MachineActuator) Create ¶
func (a *MachineActuator) Create(ctx context.Context, cluster *clusterv1.Cluster, machine *clusterv1.Machine) error
Create the machine.
func (*MachineActuator) Delete ¶
func (a *MachineActuator) Delete(ctx context.Context, cluster *clusterv1.Cluster, machine *clusterv1.Machine) error
Delete the machine. If no error is returned, it is assumed that all dependent resources have been cleaned up.
type MachineActuatorParams ¶
type MachineActuatorParams struct { Client client.Client ClientSet *kubernetes.Clientset ControllerNamespace string EventRecorder record.EventRecorder Scheme *runtime.Scheme Verbose bool }
MachineActuatorParams groups required inputs to create a machine actuator.