cloud

Documentation

Index

• Constants
• type K8sClusterAdapter
  • func NewK8sClusterAdapter(spec *models.K8sProvisionerSpec, ks KopsSupporter, workdir string) *K8sClusterAdapter
  • func (k *K8sClusterAdapter) GetCluster(ctx context.Context) (*models.K8sCluster, errors.Error)
  • func (k *K8sClusterAdapter) GetKubeconfig(ctx context.Context) (io.Reader, errors.Error)
  • func (k *K8sClusterAdapter) ProvisionCluster(ctx context.Context) errors.Error
• type KopsSupporter

Constants

const (
	DefaultNodeCount   = 2
	DefaultMasterCount = 1
)

Types

type K8sClusterAdapter

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

K8sClusterAdapter creates, updates or deletes clusters running inside cloud providers

func NewK8sClusterAdapter

func NewK8sClusterAdapter(spec *models.K8sProvisionerSpec, ks KopsSupporter, workdir string) *K8sClusterAdapter

NewK8sClusterAdapter returns a new K8sClusterAdapter.

func (*K8sClusterAdapter) GetCluster

func (k *K8sClusterAdapter) GetCluster(ctx context.Context) (*models.K8sCluster, errors.Error)

func (*K8sClusterAdapter) GetKubeconfig

func (k *K8sClusterAdapter) GetKubeconfig(ctx context.Context) (io.Reader, errors.Error)

func (*K8sClusterAdapter) ProvisionCluster

func (k *K8sClusterAdapter) ProvisionCluster(ctx context.Context) errors.Error

ClusterCreate uses kops to create a kubernetes cluster

type KopsSupporter

type KopsSupporter interface {
	StateStoreURL(context.Context) (*url.URL, errors.Error)
	CredentialsFile(context.Context) (string, errors.Error)
	SSHPublicKey(context.Context) (string, errors.Error)
	EnvironmentVariables(context.Context) ([]string, errors.Error)
	PlatformID() string
}