Help us shape the future of Go! Take the 2026 Go Developer Survey

cluster

package
v0.157.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 8, 2023 License: Apache-2.0 Imports: 30 Imported by: 8

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Cluster

type Cluster interface {
	Upgrade(ctx context.Context, dryRun bool) error
	Delete(ctx context.Context, waitInterval, podEvictionWaitPeriod time.Duration, wait, force, disableNodegroupEviction bool, parallel int) error
}

func New

type Description added in v0.84.0

type Description struct {
	Name   string
	Region string
	Owned  api.EKSCTLCreated
}

func GetClusters added in v0.84.0

func GetClusters(ctx context.Context, provider api.ClusterProvider, listAllRegions bool, chunkSize int) ([]Description, error)

type NodeGroupDrainer added in v0.83.0

type NodeGroupDrainer interface {
	Drain(ctx context.Context, input *nodegroup.DrainInput) error
}

type OwnedCluster

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

func NewOwnedCluster

func NewOwnedCluster(ctx context.Context, cfg *api.ClusterConfig, ctl *eks.ClusterProvider, clusterStack *manager.Stack, stackManager manager.StackManager) (*OwnedCluster, error)

func (*OwnedCluster) Delete

func (c *OwnedCluster) Delete(ctx context.Context, _, podEvictionWaitPeriod time.Duration, wait, force, disableNodegroupEviction bool, parallel int) error

func (*OwnedCluster) Upgrade

func (c *OwnedCluster) Upgrade(ctx context.Context, dryRun bool) error

type ProviderConstructor added in v0.84.0

type ProviderConstructor func(ctx context.Context, spec *api.ProviderConfig, clusterSpec *api.ClusterConfig) (*eks.ClusterProvider, error)

type StackManagerConstructor added in v0.84.0

type StackManagerConstructor func(provider api.ClusterProvider, spec *api.ClusterConfig) manager.StackManager

type UnownedCluster

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

func NewUnownedCluster

func NewUnownedCluster(ctx context.Context, cfg *api.ClusterConfig, ctl *eks.ClusterProvider, stackManager manager.StackManager) (*UnownedCluster, error)

func (*UnownedCluster) Delete

func (c *UnownedCluster) Delete(ctx context.Context, waitInterval, podEvictionWaitPeriod time.Duration, wait, force, disableNodegroupEviction bool, parallel int) error

func (*UnownedCluster) Upgrade

func (c *UnownedCluster) Upgrade(ctx context.Context, dryRun bool) error

Directories

Path Synopsis
Code generated by counterfeiter.
Code generated by counterfeiter.

Jump to

Keyboard shortcuts

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