addons

package

v0.0.0-...-ee2d30e Latest Latest Go to latest Published: Feb 15, 2023 License: Apache-2.0 Imports: 26 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/yuxiang-zhang/eksct

Documentation ¶

Index ¶

func ImageTag(image string) (string, error)
func ImageTagsDiffer(image1, image2 string) (bool, error)
func UseRegionalImage(spec *corev1.PodTemplateSpec, region string) error
type DevicePlugin
type EFADevicePlugin
type IRSAHelper
- func NewIRSAHelper(oidc *iamoidc.OpenIDConnectManager, stackManager manager.StackManager, ...) IRSAHelper
type MkDevicePlugin
type NeuronDevicePlugin
type NvidiaDevicePlugin
type VPCController
- func NewVPCController(rawClient kubernetes.RawClientInterface, irsa IRSAHelper, ...) *VPCController
- func (v *VPCController) Deploy(ctx context.Context) (err error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func ImageTag ¶

func ImageTag(image string) (string, error)

ImageTag extracts the container image's tag.

func ImageTagsDiffer ¶

func ImageTagsDiffer(image1, image2 string) (bool, error)

ImageTagsDiffer returns true if the image tags are not the same while ignoring the image name.

func UseRegionalImage ¶

func UseRegionalImage(spec *corev1.PodTemplateSpec, region string) error

UseRegionalImage sets the region and AWS DNS suffix for a container image in format '%s.dkr.ecr.%s.%s/image:tag'

Types ¶

type DevicePlugin ¶

type DevicePlugin interface {
	RawClient() kubernetes.RawClientInterface
	PlanMode() bool
	Manifest() []byte
	SetImage(t *corev1.PodTemplateSpec) error
	SetTolerations(t *corev1.PodTemplateSpec) error
	Deploy() error
}

func NewEFADevicePlugin ¶

func NewEFADevicePlugin(rawClient kubernetes.RawClientInterface, region string, planMode bool, spec *api.ClusterConfig) DevicePlugin

NewEFADevicePlugin creates a new EFADevicePlugin

func NewNeuronDevicePlugin ¶

func NewNeuronDevicePlugin(rawClient kubernetes.RawClientInterface, region string, planMode bool, spec *api.ClusterConfig) DevicePlugin

NewNeuronDevicePlugin creates a new NeuronDevicePlugin

func NewNvidiaDevicePlugin ¶

func NewNvidiaDevicePlugin(rawClient kubernetes.RawClientInterface, region string, planMode bool, spec *api.ClusterConfig) DevicePlugin

NewNvidiaDevicePlugin creates a new NvidiaDevicePlugin

type EFADevicePlugin ¶

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

A EFADevicePlugin deploys the EFA Device Plugin to a cluster

func (*EFADevicePlugin) Deploy ¶

func (n *EFADevicePlugin) Deploy() error

Deploy deploys the EFA device plugin to the specified cluster

func (*EFADevicePlugin) Manifest ¶

func (n *EFADevicePlugin) Manifest() []byte

func (*EFADevicePlugin) PlanMode ¶

func (n *EFADevicePlugin) PlanMode() bool

func (*EFADevicePlugin) RawClient ¶

func (n *EFADevicePlugin) RawClient() kubernetes.RawClientInterface

func (*EFADevicePlugin) SetImage ¶

func (n *EFADevicePlugin) SetImage(t *corev1.PodTemplateSpec) error

func (*EFADevicePlugin) SetTolerations ¶

func (n *EFADevicePlugin) SetTolerations(spec *corev1.PodTemplateSpec) error

type IRSAHelper ¶

type IRSAHelper interface {
	IsSupported(ctx context.Context) (bool, error)
	CreateOrUpdate(ctx context.Context, serviceAccounts *api.ClusterIAMServiceAccount) error
}

IRSAHelper provides methods for enabling IRSA

type MkDevicePlugin ¶

type MkDevicePlugin func(rawClient kubernetes.RawClientInterface, region string, planMode bool, spec *api.ClusterConfig) DevicePlugin

type NeuronDevicePlugin ¶

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

A NeuronDevicePlugin deploys the Neuron Device Plugin to a cluster

func (*NeuronDevicePlugin) Deploy ¶

func (n *NeuronDevicePlugin) Deploy() error

Deploy deploys the Neuron device plugin to the specified cluster

func (*NeuronDevicePlugin) Manifest ¶

func (n *NeuronDevicePlugin) Manifest() []byte

func (*NeuronDevicePlugin) PlanMode ¶

func (n *NeuronDevicePlugin) PlanMode() bool

func (*NeuronDevicePlugin) RawClient ¶

func (n *NeuronDevicePlugin) RawClient() kubernetes.RawClientInterface

func (*NeuronDevicePlugin) SetImage ¶

func (n *NeuronDevicePlugin) SetImage(t *corev1.PodTemplateSpec) error

func (*NeuronDevicePlugin) SetTolerations ¶

func (n *NeuronDevicePlugin) SetTolerations(t *corev1.PodTemplateSpec) error

type NvidiaDevicePlugin ¶

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

A NvidiaDevicePlugin deploys the Nvidia Device Plugin to a cluster

func (*NvidiaDevicePlugin) Deploy ¶

func (n *NvidiaDevicePlugin) Deploy() error

Deploy deploys the Nvidia device plugin to the specified cluster

func (*NvidiaDevicePlugin) Manifest ¶

func (n *NvidiaDevicePlugin) Manifest() []byte

func (*NvidiaDevicePlugin) PlanMode ¶

func (n *NvidiaDevicePlugin) PlanMode() bool

func (*NvidiaDevicePlugin) RawClient ¶

func (n *NvidiaDevicePlugin) RawClient() kubernetes.RawClientInterface

func (*NvidiaDevicePlugin) SetImage ¶

func (n *NvidiaDevicePlugin) SetImage(t *corev1.PodTemplateSpec) error

func (*NvidiaDevicePlugin) SetTolerations ¶

func (n *NvidiaDevicePlugin) SetTolerations(spec *corev1.PodTemplateSpec) error

SetTolerations sets given tolerations on the DaemonSet if they don't already exist. We check the taints on each node which is an NVIDIA instance type and apply tolerations for all the taints defined on the node.

type VPCController ¶

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

A VPCController deploys Windows VPC controller to a cluster

func NewVPCController ¶

func NewVPCController(rawClient kubernetes.RawClientInterface, irsa IRSAHelper, clusterStatus *api.ClusterStatus, region string, planMode bool) *VPCController

NewVPCController creates a new VPCController

func (*VPCController) Deploy ¶

func (v *VPCController) Deploy(ctx context.Context) (err error)

Deploy deploys VPC controller to the specified cluster

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
default

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