Versions in this module Expand all Collapse all v0 v0.1.0 Nov 23, 2019 Changes in this version + const APIServerCertName + const CertificatesDirname + const CredentialsFileName + const DefaultConfigFilename + const DefaultFormat + const GenericKeyPairName + const KubeconfigEKSTmpl + const KubeconfigTmpl + const KubernetesDirname + const RegistryDirname + const StateDirname + const TerraformDirname + var AllStatuses = []Status + var CACertNames = map[string]CACert + var CertNames = map[string]Cert + var MinSemVersion *version.SemVer + var MinVersion = "1.0" + var SemVersion *version.SemVer + var Version = "1.1" + func Ask(title string, sensitive bool) (string, error) + func AskDefault(title, defValue string, sensitive bool) (string, error) + func GetSession(creds map[string]string) (*session.Session, error) + func InvalidFilterParams(params map[string]string) []string + func IsValidFilter(params map[string]string) bool + func ListNames(path string) ([]string, error) + func NewPath(clustersPath string) (string, error) + func Path(clusterName, path string) string + func Unique(clusterName, path string) bool + func ValidClusterName(clusterName string) (string, error) + type AwsCredentials struct + AccessKey string + Platform string + Profile string + Region string + SecretKey string + SessionToken string + func NewAWSCredentials(clustername, path string) *AwsCredentials + func (c *AwsCredentials) Ask() error + func (c *AwsCredentials) AssignFromMap(params map[string]string) error + func (c *AwsCredentials) Complete() bool + func (c *AwsCredentials) Empty() bool + func (c *AwsCredentials) Getenv(force bool) error + func (c *AwsCredentials) List() + func (c *AwsCredentials) LoadSharedCredentialsFromProfile(profile string, force bool) error + func (c *AwsCredentials) LoadSharedRegionFromProfile(profile string, force bool) error + func (c *AwsCredentials) Read() error + func (c *AwsCredentials) Refresh(write, reload bool) error + func (c *AwsCredentials) SetParameters(params ...string) error + func (c *AwsCredentials) SetPath(path string) + func (c *AwsCredentials) Validate() error + func (c *AwsCredentials) Write() error + type AzureCredentials struct + ClientID string + ClientSecret string + Platform string + SubscriptionID string + TenantID string + func NewAzureCredentials(clustername, path string) *AzureCredentials + func (c *AzureCredentials) Ask() error + func (c *AzureCredentials) AssignFromMap(params map[string]string) error + func (c *AzureCredentials) Complete() bool + func (c *AzureCredentials) Empty() bool + func (c *AzureCredentials) Getenv(force bool) error + func (c *AzureCredentials) List() + func (c *AzureCredentials) Read() error + func (c *AzureCredentials) SetParameters(params ...string) error + func (c *AzureCredentials) SetPath(path string) + func (c *AzureCredentials) Write() error + type CACert struct + CN string + Desc string + type Cert struct + CN string + DNSNames []string + ExtKeyUsage []x509.ExtKeyUsage + FromCA string + IPAddresses []string + O string + type ClusterInfo struct + Kubeconfig string + Name string + Nodes int + Path string + Platform string + Status string + URL string + Version string + func (i ClusterInfo) ContainsAll(params map[string]string) bool + type ClustersInfo []ClusterInfo + func GetClustersInfo(baseDir string, params map[string]string, clustersName ...string) (ClustersInfo, error) + func (ci *ClustersInfo) FilterBy(params map[string]string) + func (ci ClustersInfo) JSON(pp bool) (string, error) + func (ci ClustersInfo) Names() []string + func (ci ClustersInfo) Stringf(format string, ppArr ...bool) (result string, err error) + func (ci ClustersInfo) TOML() (string, error) + func (ci ClustersInfo) Table(wide bool) string + func (ci ClustersInfo) Template(format string) (string, error) + func (ci ClustersInfo) YAML() (string, error) + type CredentialHandler interface + Ask func() error + AssignFromMap func(map[string]string) error + Complete func() bool + Empty func() bool + Getenv func(bool) error + List func() + Read func() error + SetParameters func(...string) error + SetPath func(string) + Write func() error + func NewCredentials(clustername, platform, path string) CredentialHandler + type Kluster struct + Config *configurator.Config + Kind string + Name string + Platforms map[string]interface{} + Resources []string + State map[string]*State + Version string + func CreateCluster(clusterName, platform, path, format string, variables map[string]string, ...) (cluster *Kluster, err error) + func List(path string, clustersName ...string) ([]*Kluster, error) + func Load(path string, parentUI *ui.UI) (*Kluster, error) + func LoadCluster(clusterName, clustersPath string, ui *ui.UI) (*Kluster, error) + func LoadSummary(path string) (*Kluster, error) + func New(name, platformName, path, format string, parentUI *ui.UI, ...) (*Kluster, error) + func NewTemplate(name string, platforms []string, path, format string, parentUI *ui.UI, ...) (*Kluster, error) + func (k *Kluster) CertsDir() string + func (k *Kluster) ConfigVariables() (vars map[string]string, err error) + func (k *Kluster) Configure() error + func (k *Kluster) Copy(name, platformName, path, format string, parentUI *ui.UI, ...) (*Kluster, error) + func (k *Kluster) CopyFile(from, to string, nodes []string, pools []string, ...) error + func (k *Kluster) CopyPackage(source, target string, backupPkg bool) error + func (k *Kluster) Create() error + func (k *Kluster) CreateKubeConfigFile() error + func (k *Kluster) Credentials(params ...string) + func (k *Kluster) Dir() string + func (k *Kluster) Exec(command, script string, nodes []string, pools []string, sudoExec bool) (*ssh.CommandResult, error) + func (k *Kluster) ExportK8s() error + func (k *Kluster) ExportTF() error + func (k *Kluster) GenPrivKeyFile(writeFile bool) (string, []byte, error) + func (k *Kluster) GenPubKeyFile(platform provisioner.Provisioner) (string, []byte, error) + func (k *Kluster) GenerateCerts(userCACertsFiles tls.KeyPairs, overwrite bool) error + func (k *Kluster) GenerateKubeConfig() ([]byte, error) + func (k *Kluster) GetCredentials() ([]string, error) + func (k *Kluster) GetCredentialsAsMap() (map[string]string, error) + func (k *Kluster) GetEntrypoint() string + func (k *Kluster) GetKubeconfig() (string, error) + func (k *Kluster) HandleKeys() error + func (k *Kluster) HostsFilterBy(nodes []string, pools []string) configurator.Hosts + func (k *Kluster) InstallPackage(filename string, forcePkg bool) (result *ssh.CommandResult, failedNodes []string, err error) + func (k *Kluster) JSON(pp bool) ([]byte, error) + func (k *Kluster) Load() error + func (k *Kluster) LoadState() error + func (k *Kluster) LoadSummary() error + func (k *Kluster) Lock(name string) (lockfile.Lockfile, error) + func (k *Kluster) MakeCertDir(platfomName ...string) (string, error) + func (k *Kluster) Path() string + func (k *Kluster) Plan(destroy bool) error + func (k *Kluster) Platform() string + func (k *Kluster) ReadJSON(b []byte) error + func (k *Kluster) ReadTOML(b []byte) error + func (k *Kluster) ReadYAML(b []byte) error + func (k *Kluster) Save() error + func (k *Kluster) SaveCredentials(params ...string) error + func (k *Kluster) SaveState() error + func (k *Kluster) StartShellTo(nodeName string, in io.Reader, out, e io.Writer) error + func (k *Kluster) StateDir() string + func (k *Kluster) StateFile() string + func (k *Kluster) String() string + func (k *Kluster) TOML() ([]byte, error) + func (k *Kluster) Terminate() error + func (k *Kluster) Update(envConfig map[string]string) error + func (k *Kluster) UpdateState(platform string) + func (k *Kluster) WriteKubeConfig(kubeconfigContent []byte) (string, error) + func (k *Kluster) YAML() ([]byte, error) + type KubeconfigData struct + CertificateAuthorityData string + ClientCertData string + ClientKeyData string + ClusterName string + Port int + Server string + type PlatformCredentials struct + Password string + Platform string + Server string + Username string + func NewPlatformCredentials(clustername, platform, path string) *PlatformCredentials + func (c *PlatformCredentials) Ask() error + func (c *PlatformCredentials) AssignFromMap(params map[string]string) error + func (c *PlatformCredentials) Complete() bool + func (c *PlatformCredentials) Empty() bool + func (c *PlatformCredentials) Getenv(force bool) error + func (c *PlatformCredentials) List() + func (c *PlatformCredentials) Read() error + func (c *PlatformCredentials) SetParameters(params ...string) error + func (c *PlatformCredentials) SetPath(path string) + func (c *PlatformCredentials) Write() error + type State struct + Address string + Data map[string]interface{} + Nodes configurator.Hosts + Port int + Status string + type Status int + const AbsentStatus + const CreatedStatus + const CreatingStatus + const FailedConfigurationStatus + const FailedCreationStatus + const FailedProvisioningStatus + const FailedTerminationStatus + const ProvisionedStatus + const RunningStatus + const StoppedStatus + const TerminatedStatus + const TerminatingStatus + const UnknownStatus + func ParseStatus(status string) Status + func (status Status) String() string