eks

Documentation

Overview

Copyright The Pharmer Authors.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright The Pharmer Authors.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright The Pharmer Authors.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright The Pharmer Authors.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright The Pharmer Authors.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright The Pharmer Authors.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Index

• Constants
• func New(s *cloud.Scope) cloud.Interface
• type ClusterManager
  • func (cm *ClusterManager) AddToManager(m manager.Manager) error
  • func (cm *ClusterManager) ApplyDelete() error
  • func (cm *ClusterManager) ApplyScale() error
  • func (cm *ClusterManager) CreateCredentials(kc kubernetes.Interface) error
  • func (cm *ClusterManager) EnsureMaster(_ *v1alpha1.Machine) error
  • func (cm *ClusterManager) GetAdminClient() (kubernetes.Interface, error)
  • func (cm *ClusterManager) GetClusterAPIComponents() (string, error)
  • func (cm *ClusterManager) GetDefaultMachineProviderSpec(sku string, role api.MachineRole) (clusterapi.ProviderSpec, error)
  • func (cm *ClusterManager) GetEKSAdminClient() (kubernetes.Interface, error)
  • func (cm *ClusterManager) GetKubeConfig() (*api.KubeConfig, error)
  • func (cm *ClusterManager) GetMasterSKU(totalNodes int32) string
  • func (cm *ClusterManager) IsValid(cluster *api.Cluster) (bool, error)
  • func (cm *ClusterManager) NewMasterTemplateData(machine *v1alpha1.Machine, token string, td cloud.TemplateData) cloud.TemplateData
  • func (cm *ClusterManager) NewNodeTemplateData(machine *v1alpha1.Machine, token string, td cloud.TemplateData) cloud.TemplateData
  • func (cm *ClusterManager) PrepareCloud() error
  • func (cm *ClusterManager) SetCloudConnector() error
  • func (cm *ClusterManager) SetDefaultCluster() error
• type EKSNodeGroupManager
  • func NewEKSNodeGroupManager(scope *cloud.Scope, conn *cloudConnector, ng *clusterapi.MachineSet, ...) *EKSNodeGroupManager
  • func (igm *EKSNodeGroupManager) Apply() error

Constants

const (
	UID = "eks"

	EKSNodeConfigMap  = "aws-auth"
	EKSConfigMapRoles = "mapRoles"
	EKSVPCUrl         = "https://amazon-eks.s3-us-west-2.amazonaws.com/cloudformation/2019-01-09/amazon-eks-vpc-sample.yaml"
	ServiceRoleURL    = "https://amazon-eks.s3-us-west-2.amazonaws.com/cloudformation/2019-01-09/amazon-eks-service-role.yaml"
	NodeGroupURL      = "https://amazon-eks.s3-us-west-2.amazonaws.com/cloudformation/2019-01-09/amazon-eks-nodegroup.yaml"
)

Functions

func New

func New(s *cloud.Scope) cloud.Interface

Types

type ClusterManager

type ClusterManager struct {
	*cloud.Scope
	// contains filtered or unexported fields
}

func (*ClusterManager) AddToManager

func (cm *ClusterManager) AddToManager(m manager.Manager) error

AddToManager adds all Controllers to the Manager

func (*ClusterManager) ApplyDelete

func (cm *ClusterManager) ApplyDelete() error

func (*ClusterManager) ApplyScale

func (cm *ClusterManager) ApplyScale() error

func (*ClusterManager) CreateCredentials

func (cm *ClusterManager) CreateCredentials(kc kubernetes.Interface) error

func (*ClusterManager) EnsureMaster

func (cm *ClusterManager) EnsureMaster(_ *v1alpha1.Machine) error

func (*ClusterManager) GetAdminClient

func (cm *ClusterManager) GetAdminClient() (kubernetes.Interface, error)

func (*ClusterManager) GetClusterAPIComponents

func (cm *ClusterManager) GetClusterAPIComponents() (string, error)

func (*ClusterManager) GetDefaultMachineProviderSpec

func (cm *ClusterManager) GetDefaultMachineProviderSpec(sku string, role api.MachineRole) (clusterapi.ProviderSpec, error)

func (*ClusterManager) GetEKSAdminClient

func (cm *ClusterManager) GetEKSAdminClient() (kubernetes.Interface, error)

func (*ClusterManager) GetKubeConfig

func (cm *ClusterManager) GetKubeConfig() (*api.KubeConfig, error)

func (*ClusterManager) GetMasterSKU

func (cm *ClusterManager) GetMasterSKU(totalNodes int32) string

func (*ClusterManager) IsValid

func (cm *ClusterManager) IsValid(cluster *api.Cluster) (bool, error)

func (*ClusterManager) NewMasterTemplateData

func (cm *ClusterManager) NewMasterTemplateData(machine *v1alpha1.Machine, token string, td cloud.TemplateData) cloud.TemplateData

func (*ClusterManager) NewNodeTemplateData

func (cm *ClusterManager) NewNodeTemplateData(machine *v1alpha1.Machine, token string, td cloud.TemplateData) cloud.TemplateData

func (*ClusterManager) PrepareCloud

func (cm *ClusterManager) PrepareCloud() error

func (*ClusterManager) SetCloudConnector

func (cm *ClusterManager) SetCloudConnector() error

func (*ClusterManager) SetDefaultCluster

func (cm *ClusterManager) SetDefaultCluster() error

type EKSNodeGroupManager

type EKSNodeGroupManager struct {
	*cloud.Scope
	// contains filtered or unexported fields
}

func NewEKSNodeGroupManager

func NewEKSNodeGroupManager(scope *cloud.Scope, conn *cloudConnector, ng *clusterapi.MachineSet, kc kubernetes.Interface) *EKSNodeGroupManager

func (*EKSNodeGroupManager) Apply

func (igm *EKSNodeGroupManager) Apply() error