addons

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
  • func NewEFADevicePlugin(rawClient kubernetes.RawClientInterface, region string, planMode bool, ...) DevicePlugin
  • func NewNeuronDevicePlugin(rawClient kubernetes.RawClientInterface, region string, planMode bool, ...) DevicePlugin
  • func NewNvidiaDevicePlugin(rawClient kubernetes.RawClientInterface, region string, planMode bool, ...) DevicePlugin
• type EFADevicePlugin
  • func (n *EFADevicePlugin) Deploy() error
  • func (n *EFADevicePlugin) Manifest() []byte
  • func (n *EFADevicePlugin) PlanMode() bool
  • func (n *EFADevicePlugin) RawClient() kubernetes.RawClientInterface
  • func (n *EFADevicePlugin) SetImage(t *corev1.PodTemplateSpec) error
  • func (n *EFADevicePlugin) SetTolerations(spec *corev1.PodTemplateSpec) error
• type IRSAHelper
  • func NewIRSAHelper(oidc *iamoidc.OpenIDConnectManager, stackManager manager.StackManager, ...) IRSAHelper
• type MkDevicePlugin
• type NeuronDevicePlugin
  • func (n *NeuronDevicePlugin) Deploy() error
  • func (n *NeuronDevicePlugin) Manifest() []byte
  • func (n *NeuronDevicePlugin) PlanMode() bool
  • func (n *NeuronDevicePlugin) RawClient() kubernetes.RawClientInterface
  • func (n *NeuronDevicePlugin) SetImage(t *corev1.PodTemplateSpec) error
  • func (n *NeuronDevicePlugin) SetTolerations(t *corev1.PodTemplateSpec) error
• type NvidiaDevicePlugin
  • func (n *NvidiaDevicePlugin) Deploy() error
  • func (n *NvidiaDevicePlugin) Manifest() []byte
  • func (n *NvidiaDevicePlugin) PlanMode() bool
  • func (n *NvidiaDevicePlugin) RawClient() kubernetes.RawClientInterface
  • func (n *NvidiaDevicePlugin) SetImage(t *corev1.PodTemplateSpec) error
  • func (n *NvidiaDevicePlugin) SetTolerations(spec *corev1.PodTemplateSpec) error
• type VPCController
  • func NewVPCController(rawClient kubernetes.RawClientInterface, irsa IRSAHelper, ...) *VPCController
  • func (v *VPCController) Deploy(ctx context.Context) (err error)

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

func NewIRSAHelper

func NewIRSAHelper(oidc *iamoidc.OpenIDConnectManager, stackManager manager.StackManager, irsaManager *irsa.Manager, clusterName string) IRSAHelper

NewIRSAHelper creates a new IRSAHelper

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