Documentation
¶
Index ¶
- Constants
- func Asset(name string) ([]byte, error)
- func AssetDigest(name string) ([sha256.Size]byte, error)
- func AssetDir(name string) ([]string, error)
- func AssetInfo(name string) (os.FileInfo, error)
- func AssetNames() []string
- func AssetString(name string) (string, error)
- func Digests() (map[string][sha256.Size]byte, error)
- func ImageTag(image string) (string, error)
- func ImageTagsDiffer(image1, image2 string) (bool, error)
- func MustAsset(name string) []byte
- func MustAssetString(name string) string
- func RestoreAsset(dir, name string) error
- func RestoreAssets(dir, name string) 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
- type IRSAHelper
- type MkDevicePlugin
- type NeuronDevicePlugin
- type NvidiaDevicePlugin
- type VPCController
Constants ¶
const AssetDebug = false
AssetDebug is true if the assets were built with the debug flag enabled.
Variables ¶
This section is empty.
Functions ¶
func Asset ¶
func Asset(name string) ([]byte, error)
Asset loads and returns the asset for the given name. It returns an error if the asset could not be found or could not be loaded.
func AssetDigest ¶
func AssetDigest(name string) ([sha256.Size]byte, error)
AssetDigest returns the digest of the file with the given name. It returns an error if the asset could not be found or the digest could not be loaded.
func AssetDir ¶
func AssetDir(name string) ([]string, error)
AssetDir returns the file names below a certain directory embedded in the file by go-bindata. For example if you run go-bindata on data/... and data contains the following hierarchy:
data/
foo.txt
img/
a.png
b.png
then AssetDir("data") would return []string{"foo.txt", "img"}, AssetDir("data/img") would return []string{"a.png", "b.png"}, AssetDir("foo.txt") and AssetDir("notexist") would return an error, and AssetDir("") will return []string{"data"}.
func AssetInfo ¶
func AssetInfo(name string) (os.FileInfo, error)
AssetInfo loads and returns the asset info for the given name. It returns an error if the asset could not be found or could not be loaded.
func AssetString ¶
func AssetString(name string) (string, error)
AssetString returns the asset contents as a string (instead of a []byte).
func Digests ¶
func Digests() (map[string][sha256.Size]byte, error)
Digests returns a map of all known files and their checksums.
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 MustAsset ¶
func MustAsset(name string) []byte
MustAsset is like Asset but panics when Asset would return an error. It simplifies safe initialization of global variables.
func MustAssetString ¶
func MustAssetString(name string) string
MustAssetString is like AssetString but panics when Asset would return an error. It simplifies safe initialization of global variables.
func RestoreAsset ¶
func RestoreAsset(dir, name string) error
RestoreAsset restores an asset under the given directory.
func RestoreAssets ¶
func RestoreAssets(dir, name string) error
RestoreAssets restores an asset under the given directory recursively.
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 *v1.PodTemplateSpec) error
Deploy() error
}
func NewEFADevicePlugin ¶ added in v0.40.0
func NewEFADevicePlugin(rawClient kubernetes.RawClientInterface, region string, planMode bool) DevicePlugin
NewEFADevicePlugin creates a new EFADevicePlugin
func NewNeuronDevicePlugin ¶
func NewNeuronDevicePlugin(rawClient kubernetes.RawClientInterface, region string, planMode bool) DevicePlugin
NewNeuronDevicePlugin creates a new NeuronDevicePlugin
func NewNvidiaDevicePlugin ¶
func NewNvidiaDevicePlugin(rawClient kubernetes.RawClientInterface, region string, planMode bool) 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
type IRSAHelper ¶
type IRSAHelper interface {
IsSupported() (bool, error)
CreateOrUpdate(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) 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
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
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
Source Files
Directories