platform

package

v0.13.1 Latest Latest Go to latest Published: May 8, 2020 License: Apache-2.0 Imports: 36 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/moshloop/platform-cli

Links

Open Source Insights

Documentation ¶

Index ¶

type Platform

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Platform ¶

type Platform struct {
	Cluster types.Cluster
	types.PlatformConfig
	logger.Logger

	k8s.Client

	// Terminating is true if the cluster is in a terminating state
	Terminating bool
	// contains filtered or unexported fields
}

func (*Platform) ApplyCRD ¶

func (platform *Platform) ApplyCRD(namespace string, specs ...k8s.CRD) error

func (*Platform) ApplySpecs ¶

func (platform *Platform) ApplySpecs(namespace string, specs ...string) error

func (*Platform) ApplyText ¶

func (platform *Platform) ApplyText(namespace string, specs ...string) error

func (*Platform) Clone ¶

func (platform *Platform) Clone(vm types.VM, config *konfigadm.Config) (types.Machine, error)

func (*Platform) CreateIngressCertificate ¶

func (platform *Platform) CreateIngressCertificate(subDomain string) (*certs.Certificate, error)

func (*Platform) CreateInternalCertificate ¶

func (platform *Platform) CreateInternalCertificate(service string, namespace string, clusterDomain string) (*certs.Certificate, error)

func (*Platform) CreateTLSSecret ¶

func (platform *Platform) CreateTLSSecret(namespace, subDomain, secretName string) error

func (*Platform) ExposeIngress ¶

func (platform *Platform) ExposeIngress(namespace, service string, port int, annotations map[string]string) error

func (*Platform) ExposeIngressTLS ¶

func (platform *Platform) ExposeIngressTLS(namespace, service string, port int) error

func (*Platform) GetAWSS3Client ¶

func (platform *Platform) GetAWSS3Client() (*s3.S3, error)

func (*Platform) GetAWSSession ¶

func (platform *Platform) GetAWSSession() (*session.Session, error)

func (*Platform) GetBinary ¶

func (platform *Platform) GetBinary(name string) deps.BinaryFunc

func (*Platform) GetBinaryWithEnv ¶

func (platform *Platform) GetBinaryWithEnv(name string, env map[string]string) deps.BinaryFunc

func (*Platform) GetBinaryWithKubeConfig ¶

func (platform *Platform) GetBinaryWithKubeConfig(binary string) deps.BinaryFunc

func (*Platform) GetCA ¶

func (platform *Platform) GetCA() certs.CertificateAuthority

GetCA retrieves the cert.CertificateAuthority for the given platform, initialising it (platform.ca) if it hasn't been read from the specified config (platform.CA) yet.

func (*Platform) GetConsulClient ¶

func (platform *Platform) GetConsulClient() api.Consul

func (*Platform) GetDNSClient ¶

func (platform *Platform) GetDNSClient() dns.Client

func (*Platform) GetIngressCA ¶

func (platform *Platform) GetIngressCA() certs.CertificateAuthority

func (*Platform) GetKubeConfig ¶

func (platform *Platform) GetKubeConfig() (string, error)

GetKubeConfig gets the path to the admin kubeconfig, creating it if necessary

func (*Platform) GetKubeConfigBytes ¶

func (platform *Platform) GetKubeConfigBytes() ([]byte, error)

func (*Platform) GetKubectl ¶

func (platform *Platform) GetKubectl() deps.BinaryFunc

func (*Platform) GetMasterIPs ¶

func (platform *Platform) GetMasterIPs() []string

GetMasterIPs returns a list of all healthy master IP's

func (*Platform) GetNSXClient ¶

func (platform *Platform) GetNSXClient() (*nsx.NSXClient, error)

func (*Platform) GetOrCreateBucket ¶

func (platform *Platform) GetOrCreateBucket(name string) error

func (*Platform) GetResourceByName ¶

func (platform *Platform) GetResourceByName(file string, pkg string) (string, error)

func (*Platform) GetResourcesByDir ¶

func (platform *Platform) GetResourcesByDir(path string, pkg string) (map[string]http.File, error)

func (*Platform) GetS3Client ¶

func (platform *Platform) GetS3Client() (*minio.Client, error)

func (*Platform) Init ¶

func (platform *Platform) Init()

func (*Platform) OpenDB ¶

func (platform *Platform) OpenDB(namespace, clusterName, databaseName string) (*pg.DB, error)

func (*Platform) ReadIngressCACertString ¶

func (platform *Platform) ReadIngressCACertString() string

func (*Platform) ResetMasterConnection ¶

func (platform *Platform) ResetMasterConnection()

func (*Platform) Template ¶

func (platform *Platform) Template(file string, pkg string) (string, error)

func (*Platform) WaitFor ¶

func (platform *Platform) WaitFor() error

WaitFor at least 1 master IP to be reachable

func (*Platform) WaitForNamespace ¶

func (platform *Platform) WaitForNamespace(ns string, timeout time.Duration)

func (*Platform) WithField ¶

func (platform *Platform) WithField(key string, value interface{}) *Platform

func (*Platform) WithLogOutput ¶

func (platform *Platform) WithLogOutput(output io.Writer) *Platform

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL