platform

package
v0.18.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 6, 2020 License: Apache-2.0 Imports: 37 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CompositeHook 

type CompositeHook struct {
	Hooks []ProvisionHook
}

func (CompositeHook) AfterProvision 

func (c CompositeHook) AfterProvision(platform *Platform, machine types.Machine) error

func (CompositeHook) AfterTerminate 

func (c CompositeHook) AfterTerminate(platform *Platform, machine types.Machine) error

func (CompositeHook) BeforeProvision 

func (c CompositeHook) BeforeProvision(platform *Platform, machine *types.VM) error

func (CompositeHook) BeforeTerminate 

func (c CompositeHook) BeforeTerminate(platform *Platform, machine types.Machine) error

func (CompositeHook) String 

func (c CompositeHook) String() string

type ConsulProvider 

type ConsulProvider struct {
	api.Consul
}

func NewConsulProvider 

func NewConsulProvider(platform *Platform) ConsulProvider

func (ConsulProvider) AfterProvision 

func (consul ConsulProvider) AfterProvision(platform *Platform, machine types.Machine) error

func (ConsulProvider) AfterTerminate 

func (consul ConsulProvider) AfterTerminate(platform *Platform, machine types.Machine) error

func (ConsulProvider) BeforeProvision 

func (consul ConsulProvider) BeforeProvision(platform *Platform, machine *types.VM) error

func (ConsulProvider) BeforeTerminate 

func (consul ConsulProvider) BeforeTerminate(platform *Platform, machine types.Machine) error

func (ConsulProvider) GetControlPlaneEndpoint 

func (consul ConsulProvider) GetControlPlaneEndpoint(platform *Platform) (string, error)

func (ConsulProvider) GetExternalEndpoints 

func (consul ConsulProvider) GetExternalEndpoints(platform *Platform) ([]string, error)

func (ConsulProvider) String 

func (consul ConsulProvider) String() string

type DNSProvider 

type DNSProvider struct {
	dns.Client
}

func NewDNSProvider 

func NewDNSProvider(client dns.Client) DNSProvider

func (DNSProvider) AfterProvision 

func (dns DNSProvider) AfterProvision(platform *Platform, machine types.Machine) error

func (DNSProvider) AfterTerminate 

func (dns DNSProvider) AfterTerminate(platform *Platform, machine types.Machine) error

func (DNSProvider) BeforeProvision 

func (dns DNSProvider) BeforeProvision(platform *Platform, machine *types.VM) error

func (DNSProvider) BeforeTerminate 

func (dns DNSProvider) BeforeTerminate(platform *Platform, machine types.Machine) error

func (DNSProvider) GetControlPlaneEndpoint 

func (dns DNSProvider) GetControlPlaneEndpoint(platform *Platform) (string, error)

func (DNSProvider) GetExternalEndpoints 

func (dns DNSProvider) GetExternalEndpoints(platform *Platform) ([]string, error)

func (DNSProvider) String 

func (dns DNSProvider) String() string

type KindProvider 

type KindProvider struct {
}

func (KindProvider) AfterProvision 

func (kind KindProvider) AfterProvision(platform *Platform, machine types.Machine) error

func (KindProvider) AfterTerminate 

func (kind KindProvider) AfterTerminate(platform *Platform, machine types.Machine) error

func (KindProvider) BeforeProvision 

func (kind KindProvider) BeforeProvision(platform *Platform, machine *types.VM) error

func (KindProvider) BeforeTerminate 

func (kind KindProvider) BeforeTerminate(platform *Platform, machine types.Machine) error

func (KindProvider) GetControlPlaneEndpoint 

func (kind KindProvider) GetControlPlaneEndpoint(platform *Platform) (string, error)

func (KindProvider) GetExternalEndpoints 

func (kind KindProvider) GetExternalEndpoints(platform *Platform) ([]string, error)

func (KindProvider) String 

func (kind KindProvider) String() string

type MasterDiscovery 

type MasterDiscovery interface {
	fmt.Stringer
	GetControlPlaneEndpoint(platform *Platform) (string, error)
	GetExternalEndpoints(platform *Platform) ([]string, error)
}

type NSXProvider 

type NSXProvider struct {
	nsxapi.NSXClient
}

func NewNSXProvider 

func NewNSXProvider(platform *Platform) (*NSXProvider, error)

func (*NSXProvider) AfterProvision 

func (nsx *NSXProvider) AfterProvision(platform *Platform, vm types.Machine) error

func (NSXProvider) AfterTerminate 

func (nsx NSXProvider) AfterTerminate(platform *Platform, machine types.Machine) error

func (*NSXProvider) BeforeProvision 

func (nsx *NSXProvider) BeforeProvision(platform *Platform, machine *types.VM) error

func (*NSXProvider) BeforeTerminate 

func (nsx *NSXProvider) BeforeTerminate(platform *Platform, machine types.Machine) error

func (*NSXProvider) GetControlPlaneEndpoint 

func (nsx *NSXProvider) GetControlPlaneEndpoint(platform *Platform) (string, error)

func (*NSXProvider) GetExternalEndpoints 

func (nsx *NSXProvider) GetExternalEndpoints(platform *Platform) ([]string, error)

func (*NSXProvider) String 

func (nsx *NSXProvider) String() string

type Platform 

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

	k8s.Client

	KubeConfigPath string

	// 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) CreateOrUpdateNamespace 

func (platform *Platform) CreateOrUpdateNamespace(name string, labels map[string]string, annotations map[string]string) error

func (*Platform) CreateOrUpdateWorkloadNamespace 

func (platform *Platform) CreateOrUpdateWorkloadNamespace(name string, labels map[string]string, annotations map[string]string) error

func (*Platform) CreateTLSSecret 

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

func (*Platform) DefaultNamespaceAnnotations 

func (platform *Platform) DefaultNamespaceAnnotations() map[string]string

func (*Platform) DefaultNamespaceLabels 

func (platform *Platform) DefaultNamespaceLabels() map[string]string

func (*Platform) DeleteNode added in v0.17.14 

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

func (*Platform) DeleteSpecs 

func (platform *Platform) DeleteSpecs(namespace string, specs ...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) GetAPIEndpoint 

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

GetAPIEndpoint returns an endpoint for reaching a master node that is reachable on 6443 or an error otherwise

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) GetNodeNames 

func (platform *Platform) GetNodeNames() map[string]bool

func (*Platform) GetOrCreateBucket 

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

func (*Platform) GetOrCreateBucketFor added in v0.17.15 

func (platform *Platform) GetOrCreateBucketFor(conn types.S3Connection, name string) error

func (*Platform) GetProxyTransport added in v0.17.15 

func (platform *Platform) GetProxyTransport(endpoint string) (*http.Transport, 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) GetS3ClientFor added in v0.17.15 

func (platform *Platform) GetS3ClientFor(conn types.S3Connection) (*minio.Client, error)

func (*Platform) Init 

func (platform *Platform) Init() error

func (*Platform) IsMaster 

func (platform *Platform) IsMaster(machine types.TagInterface) bool

func (*Platform) NewSelfSigned added in v0.16.3 

func (platform *Platform) NewSelfSigned(domain string) *certs.Certificate

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

type ProvisionHook 

type ProvisionHook interface {
	fmt.Stringer
	BeforeProvision(platform *Platform, machine *types.VM) error
	AfterProvision(platform *Platform, machine types.Machine) error
	BeforeTerminate(platform *Platform, machine types.Machine) error
	AfterTerminate(platform *Platform, machine types.Machine) error
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.