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
- 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ImageTagsDiffer ¶
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 ¶ added in v0.40.0
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 ¶ added in v0.40.0
type EFADevicePlugin struct {
// contains filtered or unexported fields
}
A EFADevicePlugin deploys the EFA Device Plugin to a cluster
func (*EFADevicePlugin) Deploy ¶ added in v0.40.0
func (n *EFADevicePlugin) Deploy() error
Deploy deploys the EFA device plugin to the specified cluster
func (*EFADevicePlugin) Manifest ¶ added in v0.40.0
func (n *EFADevicePlugin) Manifest() []byte
func (*EFADevicePlugin) PlanMode ¶ added in v0.40.0
func (n *EFADevicePlugin) PlanMode() bool
func (*EFADevicePlugin) RawClient ¶ added in v0.40.0
func (n *EFADevicePlugin) RawClient() kubernetes.RawClientInterface
func (*EFADevicePlugin) SetImage ¶ added in v0.40.0
func (n *EFADevicePlugin) SetImage(t *corev1.PodTemplateSpec) error
func (*EFADevicePlugin) SetTolerations ¶ added in v0.101.0
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 ¶ added in v0.101.0
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 ¶ added in v0.101.0
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