Documentation
¶
Index ¶
- Constants
- func CreateBundleManager(kubeVersion string) bundle.Manager
- func GetPackageBundleRef(vb releasev1.VersionsBundle) (string, error)
- func GetVersionBundle(reader Reader, eksaVersion, kubeVersion string) (*releasev1.VersionsBundle, error)
- func NewDependenciesForPackages(ctx context.Context, paths ...string) (*dependencies.Dependencies, error)
- func PrintLicense()
- func Pull(ctx context.Context, art string) ([]byte, error)
- func Push(ctx context.Context, ref, fileName string, fileContent []byte) error
- func ValidateKubeVersion(kubeVersion string, source BundleSource) error
- type BundleReader
- func (b *BundleReader) GetActiveController(ctx context.Context) (*packagesv1.PackageBundleController, error)
- func (b *BundleReader) GetLatestBundle(ctx context.Context) (*packagesv1.PackageBundle, error)
- func (b *BundleReader) UpgradeBundle(ctx context.Context, controller *packagesv1.PackageBundleController, ...) error
- type BundleRegistry
- type BundleSource
- type ChartInstaller
- type CustomRegistry
- type DefaultRegistry
- type Discovery
- type DisplayablePackage
- type KubeVersion
- type KubectlRunner
- type Manager
- type PackageClient
- func (pc *PackageClient) ApplyPackages(ctx context.Context, fileName string, kubeConfig string) error
- func (pc *PackageClient) CreatePackages(ctx context.Context, fileName string, kubeConfig string) error
- func (pc *PackageClient) DeletePackages(ctx context.Context, packages []string, kubeConfig string) error
- func (pc *PackageClient) DescribePackages(ctx context.Context, packages []string, kubeConfig string) error
- func (pc *PackageClient) DisplayPackages()
- func (pc *PackageClient) GeneratePackages() ([]packagesv1.Package, error)
- func (pc *PackageClient) GetPackageFromBundle(packageName string) (*packagesv1.BundlePackage, error)
- func (pc *PackageClient) InstallPackage(ctx context.Context, bp *packagesv1.BundlePackage, customName string, ...) error
- func (pc *PackageClient) WritePackagesToStdOut(packages []packagesv1.Package) error
- type PackageControllerClient
- type PackageReader
- type Reader
Constants ¶
View Source
const ( Cluster = "cluster" Registry = "registry" )
View Source
const (
CustomName = "my-"
)
View Source
const (
ImageRepositoryName = "eks-anywhere-packages-bundles"
)
Variables ¶
This section is empty.
Functions ¶
func CreateBundleManager ¶
func GetPackageBundleRef ¶
func GetPackageBundleRef(vb releasev1.VersionsBundle) (string, error)
func GetVersionBundle ¶
func GetVersionBundle(reader Reader, eksaVersion, kubeVersion string) (*releasev1.VersionsBundle, error)
func NewDependenciesForPackages ¶
func NewDependenciesForPackages(ctx context.Context, paths ...string) (*dependencies.Dependencies, error)
func PrintLicense ¶
func PrintLicense()
func ValidateKubeVersion ¶
func ValidateKubeVersion(kubeVersion string, source BundleSource) error
Types ¶
type BundleReader ¶
type BundleReader struct {
// contains filtered or unexported fields
}
func NewBundleReader ¶
func NewBundleReader(kubeConfig, kubeVersion string, source BundleSource, k KubectlRunner, bm Manager, cli version.Info, reg BundleRegistry) *BundleReader
func (*BundleReader) GetActiveController ¶
func (b *BundleReader) GetActiveController(ctx context.Context) (*packagesv1.PackageBundleController, error)
func (*BundleReader) GetLatestBundle ¶
func (b *BundleReader) GetLatestBundle(ctx context.Context) (*packagesv1.PackageBundle, error)
func (*BundleReader) UpgradeBundle ¶
func (b *BundleReader) UpgradeBundle(ctx context.Context, controller *packagesv1.PackageBundleController, newBundle string) error
type BundleRegistry ¶
func NewRegistry ¶
func NewRegistry(deps *dependencies.Dependencies, registryName, kubeVersion, username, password string) (BundleRegistry, error)
type BundleSource ¶
type BundleSource string
func (*BundleSource) Set ¶
func (b *BundleSource) Set(s string) error
func (BundleSource) String ¶
func (b BundleSource) String() string
func (BundleSource) Type ¶
func (b BundleSource) Type() string
type ChartInstaller ¶
type CustomRegistry ¶
type CustomRegistry struct {
*executables.Helm
// contains filtered or unexported fields
}
func NewCustomRegistry ¶
func NewCustomRegistry(helm *executables.Helm, registry, username, password string) *CustomRegistry
func (*CustomRegistry) GetRegistryBaseRef ¶
func (cm *CustomRegistry) GetRegistryBaseRef(ctx context.Context) (string, error)
type DefaultRegistry ¶
type DefaultRegistry struct {
// contains filtered or unexported fields
}
func NewDefaultRegistry ¶
func NewDefaultRegistry(rmr Reader, kv string, cv version.Info) *DefaultRegistry
func (*DefaultRegistry) GetRegistryBaseRef ¶
func (dr *DefaultRegistry) GetRegistryBaseRef(ctx context.Context) (string, error)
type Discovery ¶
type Discovery struct {
// contains filtered or unexported fields
}
Discovery * Implements ServerVersionInterface to provide the Kubernetes client version to be used.
func NewDiscovery ¶
func NewDiscovery(kubeVersion *KubeVersion) *Discovery
type DisplayablePackage ¶
DisplayablePackage wraps Package to omit undesired members (like Status).
This is necessary in part because of https://github.com/golang/go/issues/11939 but also because we just don't want to generate a Status section when we're emitting templates for a user to modify.
func NewDisplayablePackage ¶
func NewDisplayablePackage(p *api.Package) *DisplayablePackage
type KubeVersion ¶
type KubeVersion struct {
// contains filtered or unexported fields
}
func NewKubeVersion ¶
func NewKubeVersion(major string, minor string) *KubeVersion
type KubectlRunner ¶
type KubectlRunner interface {
ExecuteCommand(ctx context.Context, opts ...string) (bytes.Buffer, error)
CreateFromYaml(ctx context.Context, yaml []byte, opts ...string) (bytes.Buffer, error)
GetResource(ctx context.Context, resourceType string, name string, kubeconfig string, namespace string) (bool, error)
}
type Manager ¶
type Manager interface {
LatestBundle(ctx context.Context, baseRef string) (
*packagesv1.PackageBundle, error)
}
type PackageClient ¶
type PackageClient struct {
// contains filtered or unexported fields
}
func NewPackageClient ¶
func NewPackageClient(bundle *packagesv1.PackageBundle, kubectl KubectlRunner, packages ...string) *PackageClient
func (*PackageClient) ApplyPackages ¶
func (*PackageClient) CreatePackages ¶
func (*PackageClient) DeletePackages ¶
func (*PackageClient) DescribePackages ¶
func (*PackageClient) DisplayPackages ¶
func (pc *PackageClient) DisplayPackages()
func (*PackageClient) GeneratePackages ¶
func (pc *PackageClient) GeneratePackages() ([]packagesv1.Package, error)
func (*PackageClient) GetPackageFromBundle ¶
func (pc *PackageClient) GetPackageFromBundle(packageName string) (*packagesv1.BundlePackage, error)
func (*PackageClient) InstallPackage ¶
func (pc *PackageClient) InstallPackage(ctx context.Context, bp *packagesv1.BundlePackage, customName string, kubeConfig string) error
func (*PackageClient) WritePackagesToStdOut ¶
func (pc *PackageClient) WritePackagesToStdOut(packages []packagesv1.Package) error
type PackageControllerClient ¶
type PackageControllerClient struct {
// contains filtered or unexported fields
}
func NewPackageControllerClient ¶
func NewPackageControllerClient(chartInstaller ChartInstaller, kubectl KubectlRunner, kubeConfig, uri, chartName, chartVersion string) *PackageControllerClient
func (*PackageControllerClient) InstallController ¶
func (pc *PackageControllerClient) InstallController(ctx context.Context) error
func (*PackageControllerClient) ValidateControllerDoesNotExist ¶
func (pc *PackageControllerClient) ValidateControllerDoesNotExist(ctx context.Context) error
type PackageReader ¶
func NewPackageReader ¶
func NewPackageReader(mr *manifests.Reader) *PackageReader
func (*PackageReader) ReadChartsFromBundles ¶
func (*PackageReader) ReadImagesFromBundles ¶
Source Files
¶
Click to show internal directories.
Click to hide internal directories.