cluster

Documentation

Index

• Constants
• func ApplyExtraObjects(ctx context.Context, clusterClient ClusterClient, cluster *types.Cluster, ...) error
• func GetEksdRelease(cliVersion version.Info, clusterConfig *eksav1alpha1.Cluster) (*v1alpha1.EksDRelease, error)
• type ClusterClient
• type KubeDistro
• type KubeObjects
  • func BuildExtraObjects(clusterSpec *Spec) KubeObjects
  • func (objs KubeObjects) Names() []string
  • func (objs KubeObjects) Values() [][]byte
• type Manifest
• type Spec
  • func BuildSpecFromBundles(cluster *eksav1alpha1.Cluster, bundles *v1alpha1.Bundles, opts ...SpecOpt) (*Spec, error)
  • func NewSpec(clusterConfigPath string, cliVersion version.Info, opts ...SpecOpt) (*Spec, error)
  • func (s *Spec) LoadManifest(manifest v1alpha1.Manifest) (*Manifest, error)
  • func (cs *Spec) SetDefaultGitOps()
• type SpecOpt
  • func WithEmbedFS(embedFS embed.FS) SpecOpt
  • func WithReleasesManifest(manifestURL string) SpecOpt
• type VersionedRepository
• type VersionsBundle

Constants

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

Functions

func ApplyExtraObjects

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

func GetEksdRelease

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

Types

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
}

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
	GitOpsConfig *eksav1alpha1.GitOpsConfig

	VersionsBundle *VersionsBundle

	Bundles *v1alpha1.Bundles
	// contains filtered or unexported fields
}

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) LoadManifest

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

func (*Spec) SetDefaultGitOps

func (cs *Spec) SetDefaultGitOps()

type SpecOpt

type SpecOpt func(*Spec)

func WithEmbedFS

func WithEmbedFS(embedFS embed.FS) 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
}