baiducloud

Documentation

Index

• Constants
• type CCEClient
  • func NewMachineActuator(params MachineActuatorParams) (*CCEClient, error)
  • func (cce *CCEClient) Create(ctx context.Context, cluster *clusterv1.Cluster, machine *clusterv1.Machine) error
  • func (cce *CCEClient) Delete(ctx context.Context, cluster *clusterv1.Cluster, machine *clusterv1.Machine) error
  • func (cce *CCEClient) Exists(ctx context.Context, cluster *clusterv1.Cluster, machine *clusterv1.Machine) (bool, error)
  • func (cce *CCEClient) GetIP(cluster *clusterv1.Cluster, machine *clusterv1.Machine) (string, error)
  • func (cce *CCEClient) GetKubeConfig(cluster *clusterv1.Cluster, master *clusterv1.Machine) (string, error)
  • func (cce *CCEClient) Update(ctx context.Context, cluster *clusterv1.Cluster, machine *clusterv1.Machine) error
• type CCEClientComputeService
• type CCEClientKubeadm
• type CCEClusterClient
  • func NewClusterActuator(m manager.Manager, params ClusterActuatorParams) (*CCEClusterClient, error)
  • func (cce *CCEClusterClient) Delete(cluster *clusterv1.Cluster) error
  • func (cce *CCEClusterClient) Reconcile(cluster *clusterv1.Cluster) error
• type ClusterActuatorParams
• type MachineActuatorParams
• type SSHCreds

Constants

const (
	ProviderName = "baidu"

	TagInstanceRole      = "instanceRole"
	TagInstanceID        = "instanceID"
	TagInstanceStatus    = "instanceStatus"
	TagInstanceAdminPass = "instanceAdminPass"
	TagKubeletVersion    = "kubelet-version"

	TagClusterToken     = "clusterToken"
	TagMasterInstanceID = "masterInstanceID"
	TagMasterIP         = "masterIP"
)

Types

type CCEClient

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

var MachineActuator *CCEClient

MachineActuator is the client of cloud provider baidu

func NewMachineActuator

func NewMachineActuator(params MachineActuatorParams) (*CCEClient, error)

NewMachineActuator creates a new machine actuator

func (*CCEClient) Create

func (cce *CCEClient) Create(ctx context.Context, cluster *clusterv1.Cluster, machine *clusterv1.Machine) error

Create creates a new instance machine in the cluster

func (*CCEClient) Delete

func (cce *CCEClient) Delete(ctx context.Context, cluster *clusterv1.Cluster, machine *clusterv1.Machine) error

Delete cleans a node

func (*CCEClient) Exists

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

Exists checks the existances of some instance

func (*CCEClient) GetIP

func (cce *CCEClient) GetIP(cluster *clusterv1.Cluster, machine *clusterv1.Machine) (string, error)

GetIP returns ip of some machine

func (*CCEClient) GetKubeConfig

func (cce *CCEClient) GetKubeConfig(cluster *clusterv1.Cluster, master *clusterv1.Machine) (string, error)

GetKubeConfig returns config of some mahine

func (*CCEClient) Update

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

Update updates the some machine

type CCEClientComputeService

type CCEClientComputeService interface {
	Bcc() *bcc.Client
	Blb() *blb.Client
	Eip() *eip.Client
}

type CCEClientKubeadm

type CCEClientKubeadm interface {
	TokenCreate(params kubeadm.TokenCreateParams) (string, error)
}

type CCEClusterClient

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

func NewClusterActuator

func NewClusterActuator(m manager.Manager, params ClusterActuatorParams) (*CCEClusterClient, error)

func (*CCEClusterClient) Delete

func (cce *CCEClusterClient) Delete(cluster *clusterv1.Cluster) error

func (*CCEClusterClient) Reconcile

func (cce *CCEClusterClient) Reconcile(cluster *clusterv1.Cluster) error

type ClusterActuatorParams

type ClusterActuatorParams struct {
	ComputeService CCEClientComputeService
}

type MachineActuatorParams

type MachineActuatorParams struct {
	CertificateAuthority *cert.CertificateAuthority
	ComputeService       CCEClientComputeService
	Kubeadm              CCEClientKubeadm
	Client               client.Client
	// configgetter
	EventRecorder record.EventRecorder
	Scheme        *runtime.Scheme
}

type SSHCreds

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

SSHCreds ssh credentials TODO