dependencies

package
v0.16.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 7, 2023 License: Apache-2.0 Imports: 51 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ClusterManagerTimeoutOptions added in v0.14.4 

type ClusterManagerTimeoutOptions struct {
	NoTimeouts bool

	ControlPlaneWait, ExternalEtcdWait, MachineWait, UnhealthyMachineWait, NodeStartupWait time.Duration
}

ClusterManagerTimeoutOptions maintains the timeout options for cluster manager.

type Dependencies 

type Dependencies struct {
	Logger                      logr.Logger
	Provider                    providers.Provider
	ClusterAwsCli               *executables.Clusterawsadm
	DockerClient                *executables.Docker
	Kubectl                     *executables.Kubectl
	Govc                        *executables.Govc
	CloudStackValidatorRegistry cloudstack.ValidatorRegistry
	SnowAwsClientRegistry       *snow.AwsClientRegistry
	SnowConfigManager           *snow.ConfigManager
	Writer                      filewriter.FileWriter
	Kind                        *executables.Kind
	Clusterctl                  *executables.Clusterctl
	Flux                        *executables.Flux
	Troubleshoot                *executables.Troubleshoot
	Helm                        *executables.Helm
	UnAuthKubeClient            *kubernetes.UnAuthClient
	Networking                  clustermanager.Networking
	CNIInstaller                workload.CNIInstaller
	CiliumTemplater             *cilium.Templater
	AwsIamAuth                  *awsiamauth.Installer
	ClusterManager              *clustermanager.ClusterManager
	Bootstrapper                *bootstrapper.Bootstrapper
	GitOpsFlux                  *flux.Flux
	Git                         *gitfactory.GitTools
	EksdInstaller               *eksd.Installer
	EksdUpgrader                *eksd.Upgrader
	KubeProxyCLIUpgrader        clustermanager.KubeProxyCLIUpgrader
	AnalyzerFactory             diagnostics.AnalyzerFactory
	CollectorFactory            diagnostics.CollectorFactory
	DignosticCollectorFactory   diagnostics.DiagnosticBundleFactory
	CAPIManager                 *clusterapi.Manager
	FileReader                  *files.Reader
	ManifestReader              *manifests.Reader

	CliConfig               *cliconfig.CliConfig
	PackageInstaller        interfaces.PackageInstaller
	BundleRegistry          curatedpackages.BundleRegistry
	PackageControllerClient *curatedpackages.PackageControllerClient
	PackageClient           curatedpackages.PackageHandler
	VSphereValidator        *vsphere.Validator
	VSphereDefaulter        *vsphere.Defaulter
	NutanixClientCache      *nutanix.ClientCache
	NutanixDefaulter        *nutanix.Defaulter
	NutanixValidator        *nutanix.Validator
	SnowValidator           *snow.Validator
	IPValidator             *validator.IPValidator
	UnAuthKubectlClient     KubeClients
	// contains filtered or unexported fields
}

func (*Dependencies) Close added in v0.7.0 

func (d *Dependencies) Close(ctx context.Context) error

type Factory 

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

Factory helps initialization.

func ForSpec 

func ForSpec(ctx context.Context, clusterSpec *cluster.Spec) *Factory

func NewFactory 

func NewFactory() *Factory

func (*Factory) Build 

func (f *Factory) Build(ctx context.Context) (*Dependencies, error)

func (*Factory) GetProxyConfiguration added in v0.11.0 

func (f *Factory) GetProxyConfiguration() map[string]string

func (*Factory) UseExecutableImage added in v0.9.0 

func (f *Factory) UseExecutableImage(image string) *Factory

func (*Factory) UseExecutablesDockerClient added in v0.11.0 

func (f *Factory) UseExecutablesDockerClient(client executables.DockerClient) *Factory

UseExecutablesDockerClient forces a specific DockerClient to build Executables as opposed to follow the normal building flow This is only for testing.

func (*Factory) UseProxyConfiguration added in v0.11.0 

func (f *Factory) UseProxyConfiguration(proxyConfig map[string]string) *Factory

func (*Factory) WithAnalyzerFactory 

func (f *Factory) WithAnalyzerFactory() *Factory

func (*Factory) WithAwsIamAuth 

func (f *Factory) WithAwsIamAuth() *Factory

func (*Factory) WithAwsSnow added in v0.9.0 

func (f *Factory) WithAwsSnow() *Factory

func (*Factory) WithBootstrapper 

func (f *Factory) WithBootstrapper() *Factory

func (*Factory) WithCAPIManager 

func (f *Factory) WithCAPIManager() *Factory

func (*Factory) WithCNIInstaller added in v0.13.0 

func (f *Factory) WithCNIInstaller(spec *cluster.Spec, provider providers.Provider) *Factory

WithCNIInstaller builds a CNI installer for the given cluster.

func (*Factory) WithCiliumTemplater added in v0.12.0 

func (f *Factory) WithCiliumTemplater() *Factory

func (*Factory) WithCliConfig added in v0.9.2 

func (f *Factory) WithCliConfig(cliConfig *cliconfig.CliConfig) *Factory

WithCliConfig builds a cli config.

func (*Factory) WithCloudStackValidatorRegistry added in v0.13.0 

func (f *Factory) WithCloudStackValidatorRegistry(skipIPCheck bool) *Factory

WithCloudStackValidatorRegistry initializes the CloudStack validator for the object being constructed to make it available in the constructor.

func (*Factory) WithClusterManager 

func (f *Factory) WithClusterManager(clusterConfig *v1alpha1.Cluster, timeoutOpts *ClusterManagerTimeoutOptions) *Factory

WithClusterManager builds a cluster manager based on the cluster config and timeout options.

func (*Factory) WithClusterctl 

func (f *Factory) WithClusterctl() *Factory

func (*Factory) WithCollectorFactory 

func (f *Factory) WithCollectorFactory() *Factory

func (*Factory) WithCuratedPackagesRegistry added in v0.9.2 

func (f *Factory) WithCuratedPackagesRegistry(registryName, kubeVersion string, version version.Info) *Factory

func (*Factory) WithCustomBundles added in v0.15.3 

func (f *Factory) WithCustomBundles(bundlesOverride string) *Factory

WithCustomBundles allows configuring a bundle override.

func (*Factory) WithDiagnosticBundleFactory 

func (f *Factory) WithDiagnosticBundleFactory() *Factory

func (*Factory) WithDiagnosticCollectorImage 

func (f *Factory) WithDiagnosticCollectorImage(diagnosticCollectorImage string) *Factory

func (*Factory) WithDocker 

func (f *Factory) WithDocker() *Factory

func (*Factory) WithDockerLogin added in v0.12.0 

func (f *Factory) WithDockerLogin() *Factory

WithDockerLogin adds a docker login to the build steps.

func (*Factory) WithEksdInstaller added in v0.9.0 

func (f *Factory) WithEksdInstaller() *Factory

func (*Factory) WithEksdUpgrader added in v0.9.0 

func (f *Factory) WithEksdUpgrader() *Factory

func (*Factory) WithExecutableBuilder 

func (f *Factory) WithExecutableBuilder() *Factory

func (*Factory) WithExecutableImage added in v0.7.0 

func (f *Factory) WithExecutableImage() *Factory

WithExecutableImage sets the right cli tools image for the executable builder, reading from the Bundle and using the first VersionsBundle This is just the default for when there is not an specific kubernetes version available For commands that receive a cluster config file or a kubernetes version directly as input, use UseExecutableImage to specify the image directly.

func (*Factory) WithExecutableMountDirs added in v0.7.0 

func (f *Factory) WithExecutableMountDirs(mountDirs ...string) *Factory

func (*Factory) WithFileReader added in v0.9.0 

func (f *Factory) WithFileReader() *Factory

func (*Factory) WithFlux 

func (f *Factory) WithFlux() *Factory

func (*Factory) WithGit added in v0.9.0 

func (f *Factory) WithGit(clusterConfig *v1alpha1.Cluster, fluxConfig *v1alpha1.FluxConfig) *Factory

func (*Factory) WithGitOpsFlux added in v0.11.0 

func (f *Factory) WithGitOpsFlux(clusterConfig *v1alpha1.Cluster, fluxConfig *v1alpha1.FluxConfig, cliConfig *cliconfig.CliConfig) *Factory

WithGitOpsFlux builds a gitops flux.

func (*Factory) WithGovc 

func (f *Factory) WithGovc() *Factory

func (*Factory) WithHelm added in v0.7.0 

func (f *Factory) WithHelm(opts ...executables.HelmOpt) *Factory

func (*Factory) WithIPValidator added in v0.13.0 

func (f *Factory) WithIPValidator() *Factory

WithIPValidator builds the IPValidator for the given cluster.

func (*Factory) WithKind 

func (f *Factory) WithKind() *Factory

func (*Factory) WithKubeProxyCLIUpgrader added in v0.15.0 

func (f *Factory) WithKubeProxyCLIUpgrader() *Factory

WithKubeProxyCLIUpgrader builds a KubeProxyCLIUpgrader.

func (*Factory) WithKubectl 

func (f *Factory) WithKubectl() *Factory

func (*Factory) WithLocalExecutables added in v0.11.0 

func (f *Factory) WithLocalExecutables() *Factory

func (*Factory) WithLogger added in v0.15.0 

func (f *Factory) WithLogger() *Factory

WithLogger setups a logger to be injected in constructors. It uses the logger package level logger.

func (*Factory) WithManifestReader added in v0.9.0 

func (f *Factory) WithManifestReader() *Factory

func (*Factory) WithNetworking 

func (f *Factory) WithNetworking(clusterConfig *v1alpha1.Cluster) *Factory

WithNetworking builds a Networking.

func (*Factory) WithNoTimeouts added in v0.15.2 

func (f *Factory) WithNoTimeouts() *Factory

WithNoTimeouts injects no timeouts to all the dependencies with configurable timeout. Calling this method sets no timeout for the waits and retries in all the cluster operations, i.e. cluster manager, eksa installer, networking installer. Instead of passing the option to each dependency's constructor, use this method to pass no timeouts to new dependency.

func (*Factory) WithNutanixClientCache added in v0.15.0 

func (f *Factory) WithNutanixClientCache() *Factory

WithNutanixClientCache adds a new NutanixClientCache to the factory.

func (*Factory) WithNutanixDefaulter added in v0.15.0 

func (f *Factory) WithNutanixDefaulter() *Factory

WithNutanixDefaulter adds a new NutanixDefaulter to the factory.

func (*Factory) WithNutanixValidator added in v0.15.0 

func (f *Factory) WithNutanixValidator() *Factory

WithNutanixValidator adds a new NutanixValidator to the factory.

func (*Factory) WithPackageClient added in v0.11.0 

func (f *Factory) WithPackageClient() *Factory

func (*Factory) WithPackageControllerClient added in v0.11.0 

func (f *Factory) WithPackageControllerClient(spec *cluster.Spec, kubeConfig string) *Factory

func (*Factory) WithPackageInstaller added in v0.9.2 

func (f *Factory) WithPackageInstaller(spec *cluster.Spec, packagesLocation, kubeConfig string) *Factory

func (*Factory) WithProvider 

func (f *Factory) WithProvider(clusterConfigFile string, clusterConfig *v1alpha1.Cluster, skipIpCheck bool, hardwareCSVPath string, force bool, tinkerbellBootstrapIp string) *Factory

func (*Factory) WithProxyConfiguration added in v0.9.0 

func (f *Factory) WithProxyConfiguration() *Factory

func (*Factory) WithRegistryMirror added in v0.9.0 

func (f *Factory) WithRegistryMirror(registryMirror *registrymirror.RegistryMirror) *Factory

WithRegistryMirror configures the factory to use registry mirror wherever applicable.

func (*Factory) WithSnowConfigManager added in v0.9.0 

func (f *Factory) WithSnowConfigManager() *Factory

func (*Factory) WithTroubleshoot 

func (f *Factory) WithTroubleshoot() *Factory

func (*Factory) WithUnAuthKubeClient added in v0.9.0 

func (f *Factory) WithUnAuthKubeClient() *Factory

func (*Factory) WithVSphereDefaulter added in v0.11.0 

func (f *Factory) WithVSphereDefaulter() *Factory

func (*Factory) WithVSphereValidator added in v0.11.0 

func (f *Factory) WithVSphereValidator() *Factory

func (*Factory) WithValidatorClients added in v0.16.0 

func (f *Factory) WithValidatorClients() *Factory

WithValidatorClients builds KubeClients.

func (*Factory) WithWriter 

func (f *Factory) WithWriter() *Factory

func (*Factory) WithWriterFolder 

func (f *Factory) WithWriterFolder(folder string) *Factory

type KubeClients added in v0.16.0 

type KubeClients struct {
	*executables.Kubectl
	*kubernetes.UnAuthClient
}

KubeClients defines super struct that exposes all behavior.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.