eksapi

Documentation

Index

• Constants
• Variables
• func NewDeployer(opts types.Options) (types.Deployer, *pflag.FlagSet)
• func NewJanitor(maxResourceAge time.Duration, emitMetrics bool) *janitor
• func NewLogManager(clients *awsClients, resourceID string) *logManager
• func NewNodeManager(clients *awsClients, resourceID string) *nodeManager
• type AddonManager
  • func NewAddonManager(clients *awsClients) *AddonManager
• type Cluster
• type ClusterManager
  • func NewClusterManager(clients *awsClients, resourceID string) *ClusterManager
• type Infrastructure
• type InfrastructureManager
  • func NewInfrastructureManager(clients *awsClients, resourceID string, metrics metrics.MetricRegistry) *InfrastructureManager
• type KubernetesProviderID
• type NodeCondition
• type StaticClusterManager
  • func NewStaticClusterManager(options *deployerOptions) *StaticClusterManager
  • func (s *StaticClusterManager) CreateNodePool() error
  • func (s *StaticClusterManager) DeployBusyboxAndWaitForNodes() error
  • func (s *StaticClusterManager) EnsureNodeForStaticCluster() error
  • func (s *StaticClusterManager) SetK8sClient(kubeconfig string)
  • func (s *StaticClusterManager) TearDownBusyboxAndNodes() error
  • func (s *StaticClusterManager) TearDownNodeForStaticCluster() error
  • func (s *StaticClusterManager) TearDownNodePool() error

Constants

const DeployerName = "eksapi"

DeployerName is the name of the deployer

const ResourcePrefix = "kubetest2-" + DeployerName

Variables

var DeployerMetricNamespace = path.Join("kubetest2", DeployerName)

var SupportedNodeNameStrategy = []string{"SessionName", "EC2PrivateDNSName"}

Functions

func NewDeployer

func NewDeployer(opts types.Options) (types.Deployer, *pflag.FlagSet)

NewDeployer implements deployer.New for EKS using the EKS (and other AWS) API(s) directly (no cloudformation)

func NewJanitor

func NewJanitor(maxResourceAge time.Duration, emitMetrics bool) *janitor

func NewLogManager

func NewLogManager(clients *awsClients, resourceID string) *logManager

func NewNodeManager

func NewNodeManager(clients *awsClients, resourceID string) *nodeManager

Types

type AddonManager

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

func NewAddonManager

func NewAddonManager(clients *awsClients) *AddonManager

type Cluster

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

type ClusterManager

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

func NewClusterManager

func NewClusterManager(clients *awsClients, resourceID string) *ClusterManager

type Infrastructure

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

type InfrastructureManager

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

func NewInfrastructureManager

func NewInfrastructureManager(clients *awsClients, resourceID string, metrics metrics.MetricRegistry) *InfrastructureManager

type KubernetesProviderID

type KubernetesProviderID struct {
	AvailabilityZone string
	InstanceID       string
}

type NodeCondition

type NodeCondition func(nodes []corev1.Node) bool

type StaticClusterManager

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

func NewStaticClusterManager

func NewStaticClusterManager(options *deployerOptions) *StaticClusterManager

func (*StaticClusterManager) CreateNodePool

func (s *StaticClusterManager) CreateNodePool() error

func (*StaticClusterManager) DeployBusyboxAndWaitForNodes

func (s *StaticClusterManager) DeployBusyboxAndWaitForNodes() error

func (*StaticClusterManager) EnsureNodeForStaticCluster

func (s *StaticClusterManager) EnsureNodeForStaticCluster() error

func (*StaticClusterManager) SetK8sClient

func (s *StaticClusterManager) SetK8sClient(kubeconfig string)

func (*StaticClusterManager) TearDownBusyboxAndNodes

func (s *StaticClusterManager) TearDownBusyboxAndNodes() error

func (*StaticClusterManager) TearDownNodeForStaticCluster

func (s *StaticClusterManager) TearDownNodeForStaticCluster() error

func (*StaticClusterManager) TearDownNodePool

func (s *StaticClusterManager) TearDownNodePool() error