cluster

package
v0.6.0 Latest Latest
Warning

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

 Go to latest Published: Nov 5, 2021 License: Apache-2.0 Imports: 20 Imported by: 1

Documentation

Index

Constants

View Source 
const (
	FluxDefaultNamespace = "flux-system"
	FluxDefaultBranch    = "main"
)

Variables

This section is empty.

Functions

func ApplyExtraObjects 

func ApplyExtraObjects(ctx context.Context, clusterClient ClusterClient, cluster *types.Cluster, clusterSpec *Spec) error

func GetBundlesForCluster added in v0.6.0 

func GetBundlesForCluster(ctx context.Context, cluster *v1alpha1.Cluster, fetch BundlesFetch) (*v1alpha1release.Bundles, error)

func GetEksdRelease 

func GetEksdRelease(cliVersion version.Info, clusterConfig *eksav1alpha1.Cluster) (*v1alpha1.EksDRelease, error)

func LoadManagement added in v0.6.0 

func LoadManagement(kubeconfig string) (*types.Cluster, error)

func ReadLocalFile added in v0.6.0 

func ReadLocalFile(filename string) ([]byte, error)

Types

type BundlesFetch added in v0.6.0 

type BundlesFetch func(ctx context.Context, name, namespace string) (*v1alpha1release.Bundles, error)

type ClusterClient 

type ClusterClient interface {
	ApplyKubeSpecFromBytes(ctx context.Context, cluster *types.Cluster, data []byte) error
}

type KubeDistro 

type KubeDistro struct {
	Kubernetes          VersionedRepository
	CoreDNS             VersionedRepository
	Etcd                VersionedRepository
	NodeDriverRegistrar v1alpha1.Image
	LivenessProbe       v1alpha1.Image
	ExternalAttacher    v1alpha1.Image
	ExternalProvisioner v1alpha1.Image
	Pause               v1alpha1.Image
	EtcdImage           v1alpha1.Image
	EtcdVersion         string
	AwsIamAuthIamge     v1alpha1.Image
}

type KubeObjects 

type KubeObjects map[string][]byte

func BuildExtraObjects 

func BuildExtraObjects(clusterSpec *Spec) KubeObjects

func (KubeObjects) Names 

func (objs KubeObjects) Names() []string

func (KubeObjects) Values 

func (objs KubeObjects) Values() [][]byte

type Manifest 

type Manifest struct {
	Filename string
	Content  []byte
}

type Spec 

type Spec struct {
	*eksav1alpha1.Cluster
	OIDCConfig       *eksav1alpha1.OIDCConfig
	AWSIamConfig     *eksav1alpha1.AWSIamConfig
	GitOpsConfig     *eksav1alpha1.GitOpsConfig
	DatacenterConfig *metav1.ObjectMeta

	VersionsBundle *VersionsBundle

	Bundles           *v1alpha1.Bundles
	ManagementCluster *types.Cluster
	// contains filtered or unexported fields
}

func BuildSpecForCluster added in v0.6.0 

func BuildSpecForCluster(ctx context.Context, cluster *v1alpha1.Cluster, fetch BundlesFetch) (*Spec, error)

func BuildSpecFromBundles 

func BuildSpecFromBundles(cluster *eksav1alpha1.Cluster, bundles *v1alpha1.Bundles, opts ...SpecOpt) (*Spec, error)

func NewSpec 

func NewSpec(clusterConfigPath string, cliVersion version.Info, opts ...SpecOpt) (*Spec, error)

func (*Spec) DeepCopy added in v0.6.0 

func (s *Spec) DeepCopy() *Spec

func (*Spec) GetBundles added in v0.6.0 

func (s *Spec) GetBundles(cliVersion version.Info) (*v1alpha1.Bundles, error)

func (*Spec) GetRelease added in v0.6.0 

func (s *Spec) GetRelease(cliVersion version.Info) (*v1alpha1.EksARelease, error)

func (*Spec) GetReleaseManifestUrl added in v0.6.0 

func (s *Spec) GetReleaseManifestUrl() string

func (*Spec) KubeDistroImages added in v0.6.0 

func (s *Spec) KubeDistroImages() []v1alpha1.Image

func (*Spec) LoadManifest 

func (s *Spec) LoadManifest(manifest v1alpha1.Manifest) (*Manifest, error)

func (*Spec) ReadEmbedFile added in v0.6.0 

func (s *Spec) ReadEmbedFile(url *url.URL) ([]byte, error)

func (*Spec) ReadFile added in v0.6.0 

func (s *Spec) ReadFile(uri string) ([]byte, error)

func (*Spec) ReadHttpFile added in v0.6.0 

func (s *Spec) ReadHttpFile(uri string) ([]byte, error)

func (*Spec) SetDefaultGitOps 

func (cs *Spec) SetDefaultGitOps()

type SpecOpt 

type SpecOpt func(*Spec)

func WithEmbedFS 

func WithEmbedFS(embedFS embed.FS) SpecOpt

func WithManagementCluster added in v0.6.0 

func WithManagementCluster(cluster *types.Cluster) SpecOpt

func WithOverrideBundlesManifest added in v0.6.0 

func WithOverrideBundlesManifest(fileURL string) SpecOpt

func WithReleasesManifest 

func WithReleasesManifest(manifestURL string) SpecOpt

type VersionedRepository 

type VersionedRepository struct {
	Repository, Tag string
}

type VersionsBundle 

type VersionsBundle struct {
	*v1alpha1.VersionsBundle
	KubeDistro *KubeDistro
}

func (*VersionsBundle) DockerImages added in v0.6.0 

func (vb *VersionsBundle) DockerImages() []v1alpha1.Image

func (*VersionsBundle) Images added in v0.6.0 

func (vb *VersionsBundle) Images() []v1alpha1.Image

func (*VersionsBundle) Manifests added in v0.6.0 

func (vb *VersionsBundle) Manifests() map[string][]v1alpha1.Manifest

func (*VersionsBundle) Ovas added in v0.6.0 

func (vb *VersionsBundle) Ovas() []v1alpha1.Archive

func (*VersionsBundle) SharedImages added in v0.6.0 

func (vb *VersionsBundle) SharedImages() []v1alpha1.Image

func (*VersionsBundle) VsphereImages added in v0.6.0 

func (vb *VersionsBundle) VsphereImages() []v1alpha1.Image

Source Files

View all Source files

Directories

Path Synopsis
Package mocks is a generated GoMock package.
 Package mocks is a generated GoMock package.

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.