cluster

Documentation

Overview

Copyright Jetstack Ltd. See LICENSE for details.

Copyright Jetstack Ltd. See LICENSE for details.

Copyright Jetstack Ltd. See LICENSE for details.

Copyright Jetstack Ltd. See LICENSE for details.

Copyright Jetstack Ltd. See LICENSE for details.

Index

• Constants
• func Init(init interfaces.Initialize) (cluster *clusterv1alpha1.Cluster, err error)
• type Cluster
  • func NewFromConfig(environment interfaces.Environment, conf *clusterv1alpha1.Cluster) (*Cluster, error)
  • func (c *Cluster) APITunnel() interfaces.Tunnel
  • func (c *Cluster) AmazonEBSEncrypted() bool
  • func (c *Cluster) ClusterName() string
  • func (c *Cluster) Config() *clusterv1alpha1.Cluster
  • func (c *Cluster) ConfigPath() string
  • func (c *Cluster) Environment() interfaces.Environment
  • func (c *Cluster) GetState() string
  • func (c *Cluster) ImageIDs() (map[string]string, error)
  • func (c *Cluster) Images() []string
  • func (c *Cluster) InstancePool(roleName string) interfaces.InstancePool
  • func (c *Cluster) InstancePools() []interfaces.InstancePool
  • func (c *Cluster) InstancePoolsMap() (instancePoolsMap map[string][]*clusterv1alpha1.InstancePool)
  • func (c *Cluster) ListHosts() ([]interfaces.Host, error)
  • func (c *Cluster) Log() *logrus.Entry
  • func (c *Cluster) Name() string
  • func (c *Cluster) NetworkCIDR() *net.IPNet
  • func (c *Cluster) Parameters() map[string]string
  • func (c *Cluster) PrivateAPIHostname() string
  • func (c *Cluster) PublicAPIHostname() string
  • func (c *Cluster) ReapplyConfiguration() error
  • func (c *Cluster) Region() string
  • func (c *Cluster) RemoteState() string
  • func (c *Cluster) Role(roleName string) *role.Role
  • func (c *Cluster) Roles() (roles []*role.Role)
  • func (c *Cluster) SSHConfigPath() string
  • func (c *Cluster) SSHHostKeysPath() string
  • func (c *Cluster) SetState(state string)
  • func (c *Cluster) Subnets() (subnets []clusterv1alpha1.Subnet)
  • func (c *Cluster) TerraformOutput() (map[string]interface{}, error)
  • func (c *Cluster) Type() string
  • func (c *Cluster) UploadConfiguration() error
  • func (c *Cluster) Validate() error
  • func (c *Cluster) Variables() map[string]interface{}
  • func (c *Cluster) Verify() error
  • func (c *Cluster) VerifyInstancePools() error
  • func (c *Cluster) WaitForConvergance() error

Constants

const (
	// represents Terraform in a destroy state
	StateDestroy                          = "destroy"
	ExistingVPCAnnotationKey              = "tarmak.io/existing-vpc-id"
	ExistingPublicSubnetIDsAnnotationKey  = "tarmak.io/existing-public-subnet-ids"
	ExistingPrivateSubnetIDsAnnotationKey = "tarmak.io/existing-private-subnet-ids"
	JenkinsCertificateARNAnnotationKey    = "tarmak.io/jenkins-certificate-arn"
)

Functions

func Init

func Init(init interfaces.Initialize) (cluster *clusterv1alpha1.Cluster, err error)

Types

type Cluster

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

returns a server

func NewFromConfig

func NewFromConfig(environment interfaces.Environment, conf *clusterv1alpha1.Cluster) (*Cluster, error)

func (*Cluster) APITunnel

func (c *Cluster) APITunnel() interfaces.Tunnel

func (*Cluster) AmazonEBSEncrypted

func (c *Cluster) AmazonEBSEncrypted() bool

retrieve Amazons EBS encryption status

func (*Cluster) ClusterName

func (c *Cluster) ClusterName() string

func (*Cluster) Config

func (c *Cluster) Config() *clusterv1alpha1.Cluster

func (*Cluster) ConfigPath

func (c *Cluster) ConfigPath() string

func (*Cluster) Environment

func (c *Cluster) Environment() interfaces.Environment

func (*Cluster) GetState

func (c *Cluster) GetState() string

GetState retreives the state of Terraform

func (*Cluster) ImageIDs

func (c *Cluster) ImageIDs() (map[string]string, error)

func (*Cluster) Images

func (c *Cluster) Images() []string

This methods aggregates all images of the pools

func (*Cluster) InstancePool

func (c *Cluster) InstancePool(roleName string) interfaces.InstancePool

func (*Cluster) InstancePools

func (c *Cluster) InstancePools() []interfaces.InstancePool

func (*Cluster) InstancePoolsMap

func (c *Cluster) InstancePoolsMap() (instancePoolsMap map[string][]*clusterv1alpha1.InstancePool)

func (*Cluster) ListHosts

func (c *Cluster) ListHosts() ([]interfaces.Host, error)

func (*Cluster) Log

func (c *Cluster) Log() *logrus.Entry

func (*Cluster) Name

func (c *Cluster) Name() string

func (*Cluster) NetworkCIDR

func (c *Cluster) NetworkCIDR() *net.IPNet

func (*Cluster) Parameters

func (c *Cluster) Parameters() map[string]string

func (*Cluster) PrivateAPIHostname

func (c *Cluster) PrivateAPIHostname() string

get API server private hostname

func (*Cluster) PublicAPIHostname

func (c *Cluster) PublicAPIHostname() string

get API server public hostname

func (*Cluster) ReapplyConfiguration

func (c *Cluster) ReapplyConfiguration() error

This enforces a reapply of the puppet.tar.gz on every instance in the cluster

func (*Cluster) Region

func (c *Cluster) Region() string

func (*Cluster) RemoteState

func (c *Cluster) RemoteState() string

func (*Cluster) Role

func (c *Cluster) Role(roleName string) *role.Role

func (*Cluster) Roles

func (c *Cluster) Roles() (roles []*role.Role)

func (*Cluster) SSHConfigPath

func (c *Cluster) SSHConfigPath() string

func (*Cluster) SSHHostKeysPath

func (c *Cluster) SSHHostKeysPath() string

func (*Cluster) SetState

func (c *Cluster) SetState(state string)

SetState records the state of Terraform

func (*Cluster) Subnets

func (c *Cluster) Subnets() (subnets []clusterv1alpha1.Subnet)

func (*Cluster) TerraformOutput

func (c *Cluster) TerraformOutput() (map[string]interface{}, error)

get the terrform output from this cluster

func (*Cluster) Type

func (c *Cluster) Type() string

Determine if this Cluster is a cluster or hub, single or multi environment

func (*Cluster) UploadConfiguration

func (c *Cluster) UploadConfiguration() error

This upload the puppet.tar.gz to the cluster, warning there is some duplication as terraform is also uploading this puppet.tar.gz

func (*Cluster) Validate

func (c *Cluster) Validate() error

func (*Cluster) Variables

func (c *Cluster) Variables() map[string]interface{}

func (*Cluster) Verify

func (c *Cluster) Verify() error

Verify cluster

func (*Cluster) VerifyInstancePools

func (c *Cluster) VerifyInstancePools() error

Verify instance pools

func (*Cluster) WaitForConvergance

func (c *Cluster) WaitForConvergance() error

This waits until all instances have congverged successfully