platform

Documentation

Index

• type Platform
  • func (platform *Platform) ApplyCRD(namespace string, specs ...k8s.CRD) error
  • func (platform *Platform) ApplySpecs(namespace string, specs ...string) error
  • func (platform *Platform) ApplyText(namespace string, specs ...string) error
  • func (platform *Platform) Clone(vm types.VM, config *konfigadm.Config) (types.Machine, error)
  • func (platform *Platform) CreateIngressCertificate(subDomain string) (*certs.Certificate, error)
  • func (platform *Platform) CreateInternalCertificate(service string, namespace string, clusterDomain string) (*certs.Certificate, error)
  • func (platform *Platform) CreateTLSSecret(namespace, subDomain, secretName string) error
  • func (platform *Platform) ExposeIngress(namespace, service string, port int, annotations map[string]string) error
  • func (platform *Platform) ExposeIngressTLS(namespace, service string, port int) error
  • func (platform *Platform) GetAWSS3Client() (*s3.S3, error)
  • func (platform *Platform) GetAWSSession() (*session.Session, error)
  • func (platform *Platform) GetBinary(name string) deps.BinaryFunc
  • func (platform *Platform) GetBinaryWithEnv(name string, env map[string]string) deps.BinaryFunc
  • func (platform *Platform) GetBinaryWithKubeConfig(binary string) deps.BinaryFunc
  • func (platform *Platform) GetCA() certs.CertificateAuthority
  • func (platform *Platform) GetConsulClient() api.Consul
  • func (platform *Platform) GetDNSClient() dns.Client
  • func (platform *Platform) GetIngressCA() certs.CertificateAuthority
  • func (platform *Platform) GetKubeConfig() (string, error)
  • func (platform *Platform) GetKubeConfigBytes() ([]byte, error)
  • func (platform *Platform) GetKubectl() deps.BinaryFunc
  • func (platform *Platform) GetMasterIPs() []string
  • func (platform *Platform) GetNSXClient() (*nsx.NSXClient, error)
  • func (platform *Platform) GetOrCreateBucket(name string) error
  • func (platform *Platform) GetResourceByName(file string, pkg string) (string, error)
  • func (platform *Platform) GetResourcesByDir(path string, pkg string) (map[string]http.File, error)
  • func (platform *Platform) GetS3Client() (*minio.Client, error)
  • func (platform *Platform) Init()
  • func (platform *Platform) OpenDB(namespace, clusterName, databaseName string) (*pg.DB, error)
  • func (platform *Platform) ReadIngressCACertString() string
  • func (platform *Platform) ResetMasterConnection()
  • func (platform *Platform) Template(file string, pkg string) (string, error)
  • func (platform *Platform) WaitFor() error
  • func (platform *Platform) WaitForNamespace(ns string, timeout time.Duration)
  • func (platform *Platform) WithField(key string, value interface{}) *Platform
  • func (platform *Platform) WithLogOutput(output io.Writer) *Platform

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