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

• 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) ClusterName() string
  • func (c *Cluster) Config() *clusterv1alpha1.Cluster
  • func (c *Cluster) ConfigPath() string
  • func (c *Cluster) Environment() interfaces.Environment
  • func (c *Cluster) ImageIDs() (map[string]string, error)
  • func (c *Cluster) Images() []string
  • 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) ReapplyConfiguration() error
  • func (c *Cluster) Region() string
  • func (c *Cluster) RemoteState(stackName string) 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) Stack(name string) interfaces.Stack
  • func (c *Cluster) Stacks() []interfaces.Stack
  • func (c *Cluster) Subnets() (subnets []clusterv1alpha1.Subnet)
  • 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) WaitForConvergance() error

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) 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) 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) 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) 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(stackName string) 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) Stack

func (c *Cluster) Stack(name string) interfaces.Stack

func (*Cluster) Stacks

func (c *Cluster) Stacks() []interfaces.Stack

func (*Cluster) Subnets

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

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

func (c *Cluster) WaitForConvergance() error

This waits until all instances have congverged successfully