wks

Documentation

Index

• Constants
• type ClusterActuator
  • func NewClusterActuator(params ClusterActuatorParams) (*ClusterActuator, error)
  • func (a *ClusterActuator) Delete(cluster *clusterv1.Cluster) error
  • func (a *ClusterActuator) Reconcile(cluster *clusterv1.Cluster) error
• type ClusterActuatorParams
• type FootlooseMachine
• type MachineActuator
  • func NewMachineActuator(params MachineActuatorParams) (*MachineActuator, error)
  • 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.

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.

func (*ClusterActuator) Delete

func (a *ClusterActuator) Delete(cluster *clusterv1.Cluster) error

Delete the cluster.

func (*ClusterActuator) Reconcile

func (a *ClusterActuator) Reconcile(cluster *clusterv1.Cluster) error

Reconcile creates or updates the cluster.

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.

func (*MachineActuator) Exists

func (a *MachineActuator) Exists(ctx context.Context, cluster *clusterv1.Cluster, machine *clusterv1.Machine) (bool, error)

Exists checks if the machine currently exists.

func (*MachineActuator) Update

func (a *MachineActuator) Update(ctx context.Context, cluster *clusterv1.Cluster, machine *clusterv1.Machine) error

Update the machine to the provided definition.

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.