The highest tagged major version is v2.

provider

package

v1.3.0 Latest Latest Go to latest Published: Feb 16, 2022 License: Apache-2.0 Imports: 14 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/kubecost/cluster-turndown

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func Validate(provider TurndownProvider, maxRetries int) error
type AWSProvider
type EKSProvider
type GKEProvider
type TurndownProvider

Constants ¶

View Source

const (
	AWSClusterIDTagKey      = "KubernetesCluster"
	AWSGroupNameTagKey      = "aws:autoscaling:groupName"
	AWSRoleMasterTagKey     = "k8s.io/role/master"
	AWSRoleNodeTagKey       = "k8s.io/role/node"
	AWSNodeGroupPreviousKey = "cluster.turndown.previous"
	AWSTurndownPoolName     = "cluster-turndown"
)

View Source

const (
	EKSNodeGroupPreviousKey = "cluster.turndown.previous"
	EKSTurndownPoolName     = "cluster-turndown"
)

View Source

const (
	TurndownNodeLabel         = "cluster-turndown-node"
	TurndownNodeLabelSelector = "cluster-turndown-node=true"
)

View Source

const (
	GKETurndownPoolName = "cluster-turndown"
)

Variables ¶

This section is empty.

Functions ¶

func Validate ¶

func Validate(provider TurndownProvider, maxRetries int) error

Validate will return an error if the validation on a ComputeProvider fails

Types ¶

type AWSProvider ¶

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

ComputeProvider for AWS

func (*AWSProvider) CreateSingletonNodePool ¶

func (p *AWSProvider) CreateSingletonNodePool(labels map[string]string) error

func (*AWSProvider) GetNodePools ¶

func (p *AWSProvider) GetNodePools() ([]cp.NodePool, error)

func (*AWSProvider) GetPoolID ¶

func (p *AWSProvider) GetPoolID(node *v1.Node) string

func (*AWSProvider) IsTurndownNodePool ¶

func (p *AWSProvider) IsTurndownNodePool() bool

func (*AWSProvider) ResetNodePoolSizes ¶

func (p *AWSProvider) ResetNodePoolSizes(nodePools []cp.NodePool) error

func (*AWSProvider) SetNodePoolSizes ¶

func (p *AWSProvider) SetNodePoolSizes(nodePools []cp.NodePool, size int32) error

type EKSProvider ¶

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

ComputeProvider for AWS EKS

func (*EKSProvider) CreateSingletonNodePool ¶

func (p *EKSProvider) CreateSingletonNodePool(labels map[string]string) error

func (*EKSProvider) GetNodePools ¶

func (p *EKSProvider) GetNodePools() ([]cp.NodePool, error)

func (*EKSProvider) GetPoolID ¶

func (p *EKSProvider) GetPoolID(node *v1.Node) string

func (*EKSProvider) IsTurndownNodePool ¶

func (p *EKSProvider) IsTurndownNodePool() bool

func (*EKSProvider) ResetNodePoolSizes ¶

func (p *EKSProvider) ResetNodePoolSizes(nodePools []cp.NodePool) error

func (*EKSProvider) SetNodePoolSizes ¶

func (p *EKSProvider) SetNodePoolSizes(nodePools []cp.NodePool, size int32) error

type GKEProvider ¶

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

ComputeProvider for GKE

func (*GKEProvider) CreateSingletonNodePool ¶

func (p *GKEProvider) CreateSingletonNodePool(labels map[string]string) error

func (*GKEProvider) GetNodePools ¶

func (p *GKEProvider) GetNodePools() ([]cp.NodePool, error)

func (*GKEProvider) GetPoolID ¶

func (p *GKEProvider) GetPoolID(node *v1.Node) string

func (*GKEProvider) IsTurndownNodePool ¶

func (p *GKEProvider) IsTurndownNodePool() bool

func (*GKEProvider) ResetNodePoolSizes ¶

func (p *GKEProvider) ResetNodePoolSizes(nodePools []cp.NodePool) error

func (*GKEProvider) SetNodePoolSizes ¶

func (p *GKEProvider) SetNodePoolSizes(nodePools []cp.NodePool, size int32) error

type TurndownProvider ¶

type TurndownProvider interface {
	IsTurndownNodePool() bool
	CreateSingletonNodePool(labels map[string]string) error
	GetNodePools() ([]cp.NodePool, error)
	GetPoolID(node *v1.Node) string
	SetNodePoolSizes(nodePools []cp.NodePool, size int32) error
	ResetNodePoolSizes(nodePools []cp.NodePool) error
}

TurndownProvider contains methods used to manage turndown

func NewAWSProvider ¶

func NewAWSProvider(kubernetes kubernetes.Interface, clusterProvider cp.ClusterProvider) TurndownProvider

func NewEKSProvider ¶

func NewEKSProvider(kubernetes kubernetes.Interface, clusterProvider cp.ClusterProvider) TurndownProvider

func NewGKEProvider ¶

func NewGKEProvider(kubernetes kubernetes.Interface, clusterProvider cp.ClusterProvider) TurndownProvider

func NewTurndownProvider ¶

func NewTurndownProvider(client kubernetes.Interface, clusterProvider cp.ClusterProvider) (TurndownProvider, error)

Creates a new TurndownProvider implementation using the kubernetes client instance a ClusterProvider

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL