google

Documentation

Index

• Constants
• func CreateMachineControllerPod(token string) error
• func PreloadMasterScript(version string, dockerImages []string) (string, error)
• func PreloadNodeScript(version string, dockerImages []string) (string, error)
• type GCEClient
  • func NewMachineActuator(kubeadmToken string, machineClient client.MachinesInterface) (*GCEClient, error)
  • func (gce *GCEClient) Create(cluster *clusterv1.Cluster, machine *clusterv1.Machine) error
  • func (gce *GCEClient) CreateMachineController(cluster *clusterv1.Cluster, initialMachines []*clusterv1.Machine) error
  • func (gce *GCEClient) CreateMachineControllerServiceAccount(cluster *clusterv1.Cluster, initialMachines []*clusterv1.Machine) error
  • func (gce *GCEClient) Delete(machine *clusterv1.Machine) error
  • func (gce *GCEClient) DeleteMachineControllerServiceAccount(cluster *clusterv1.Cluster, machines []*clusterv1.Machine) error
  • func (gce *GCEClient) Exists(machine *clusterv1.Machine) (bool, error)
  • func (gce *GCEClient) GetIP(machine *clusterv1.Machine) (string, error)
  • func (gce *GCEClient) GetKubeConfig(master *clusterv1.Machine) (string, error)
  • func (gce *GCEClient) PostDelete(cluster *clusterv1.Cluster, machines []*clusterv1.Machine) error
  • func (gce *GCEClient) Update(cluster *clusterv1.Cluster, goalMachine *clusterv1.Machine) error
• type SshCreds

Constants

const (
	ProjectAnnotationKey = "gcp-project"
	ZoneAnnotationKey    = "gcp-zone"
	NameAnnotationKey    = "gcp-name"

	UIDLabelKey       = "machine-crd-uid"
	BootstrapLabelKey = "boostrap"
)

const (
	ServiceAccountPrefix    = "k8s-machine-controller-"
	ServiceAccount          = "service-account"
	MachineControllerSecret = "machine-controller-credential"
	ServiceAccountNs        = "kube-system"
)

const (
	MachineControllerSshKeySecret = "machine-controller-sshkeys"
	// Arbitrary name used for SSH.
	SshUser                = "clusterapi"
	SshKeyFile             = "clusterapi-key"
	SshKeyFilePublic       = SshKeyFile + ".pub"
	SshKeyFilePublicGcloud = SshKeyFilePublic + ".gcloud"
)

const InstanceStatusAnnotationKey = "instance-status"

Functions

func CreateMachineControllerPod

func CreateMachineControllerPod(token string) error

func PreloadMasterScript

func PreloadMasterScript(version string, dockerImages []string) (string, error)

PreloadMasterScript returns a script that can be used to preload a master.

func PreloadNodeScript

func PreloadNodeScript(version string, dockerImages []string) (string, error)

PreloadNodeScript returns a script that can be used to preload a master.

Types

type GCEClient

type GCEClient struct {
	// contains filtered or unexported fields
}

func NewMachineActuator

func NewMachineActuator(kubeadmToken string, machineClient client.MachinesInterface) (*GCEClient, error)

func (*GCEClient) Create

func (gce *GCEClient) Create(cluster *clusterv1.Cluster, machine *clusterv1.Machine) error

func (*GCEClient) CreateMachineController

func (gce *GCEClient) CreateMachineController(cluster *clusterv1.Cluster, initialMachines []*clusterv1.Machine) error

func (*GCEClient) CreateMachineControllerServiceAccount

func (gce *GCEClient) CreateMachineControllerServiceAccount(cluster *clusterv1.Cluster, initialMachines []*clusterv1.Machine) error

Creates a GCP service account for the machine controller, granted the permissions to manage compute instances, and stores its credentials as a Kubernetes secret.

func (*GCEClient) Delete

func (gce *GCEClient) Delete(machine *clusterv1.Machine) error

func (*GCEClient) DeleteMachineControllerServiceAccount

func (gce *GCEClient) DeleteMachineControllerServiceAccount(cluster *clusterv1.Cluster, machines []*clusterv1.Machine) error

func (*GCEClient) Exists

func (gce *GCEClient) Exists(machine *clusterv1.Machine) (bool, error)

func (*GCEClient) GetIP

func (gce *GCEClient) GetIP(machine *clusterv1.Machine) (string, error)

func (*GCEClient) GetKubeConfig

func (gce *GCEClient) GetKubeConfig(master *clusterv1.Machine) (string, error)

func (*GCEClient) PostDelete

func (gce *GCEClient) PostDelete(cluster *clusterv1.Cluster, machines []*clusterv1.Machine) error

func (*GCEClient) Update

func (gce *GCEClient) Update(cluster *clusterv1.Cluster, goalMachine *clusterv1.Machine) error

type SshCreds

type SshCreds struct {
	// contains filtered or unexported fields
}