install

Documentation

Index

• Constants
• Variables
• func GeneratePasswordHash(log logger.Logger, password string) (string, error)
• func InstallDashboard(ctx context.Context, log logger.Logger, kubeClient client.Client, ...) error
• func InstallFluentBit(ctx context.Context, log logger.Logger, kubeClient client.Client, ...) error
• func NewManager(ctx context.Context, log logger.Logger, kubeClient ctrlclient.Client, ...) (*ssa.ResourceManager, error)
• func ReadPassword(log logger.Logger) (string, error)
• func ReconcileDashboard(ctx context.Context, kubeClient client.Client, ...) error
• func SanitizeResourceData(log logger.Logger, resourceData []byte) ([]byte, error)
• func UninstallFluentBit(ctx context.Context, log logger.Logger, kubeClient client.Client, ...) error
• type DashboardObjects
  • func CreateDashboardObjects(log logger.Logger, ...) (*DashboardObjects, error)
• type DashboardType
  • func GetInstalledDashboard(ctx context.Context, kubeClient client.Client, namespace string, ...) (DashboardType, string, error)
• type FluxVersionInfo
  • func GetFluxVersion(ctx context.Context, log logger.Logger, kubeClient client.Client) (fluxVersionInfo *FluxVersionInfo, guessed bool, err error)
• type ResourceManagerForApply
• type Session
  • func NewSession(log logger.Logger, kubeClient client.Client, name string, namespace string, ...) (*Session, error)
  • func (s *Session) Close() error
  • func (s *Session) Connect() error
  • func (s *Session) Start() error

Constants

const FluentBitHRName = "fluent-bit"

Variables

var ErrDashboardInstalled = fmt.Errorf("dashboard already installed")

Functions

func GeneratePasswordHash

func GeneratePasswordHash(log logger.Logger, password string) (string, error)

func InstallDashboard

func InstallDashboard(ctx context.Context, log logger.Logger, kubeClient client.Client, dashboardObjects *DashboardObjects) error

InstallDashboard installs the GitOps Dashboard.

func InstallFluentBit

func InstallFluentBit(ctx context.Context, log logger.Logger, kubeClient client.Client, fluxNamespace, targetNamespace, name, bucketName string, bucketServerPort int32) error

func NewManager

func NewManager(ctx context.Context, log logger.Logger, kubeClient ctrlclient.Client, kubeConfigArgs genericclioptions.RESTClientGetter) (*ssa.ResourceManager, error)

func ReadPassword

func ReadPassword(log logger.Logger) (string, error)

func ReconcileDashboard

func ReconcileDashboard(ctx context.Context, kubeClient client.Client, dashboardName, namespace, podName string, timeout time.Duration) error

ReconcileDashboard reconciles the dashboard. If podName is an empty string, it will get the dashboard pod by labels instead of pod name.

func SanitizeResourceData

func SanitizeResourceData(log logger.Logger, resourceData []byte) ([]byte, error)

func UninstallFluentBit

func UninstallFluentBit(ctx context.Context, log logger.Logger, kubeClient client.Client, hrNamespace, hrName string) error

Types

type DashboardObjects

type DashboardObjects struct {
	Manifests      []byte
	HelmRepository *sourcev1.HelmRepository
	HelmRelease    *helmv2.HelmRelease
}

func CreateDashboardObjects

func CreateDashboardObjects(log logger.Logger, name, namespace, username, passwordHash, chartVersion, dashboardImage string) (*DashboardObjects, error)

CreateDashboardObjects creates HelmRepository and HelmRelease objects for the GitOps Dashboard installation.

type DashboardType

type DashboardType int32

const (
	DashboardTypeNone       DashboardType = 0
	DashboardTypeOSS        DashboardType = 1
	DashboardTypeEnterprise DashboardType = 2
)

func GetInstalledDashboard

func GetInstalledDashboard(ctx context.Context, kubeClient client.Client, namespace string, dashboards map[DashboardType]bool) (DashboardType, string, error)

GetInstalledDashboard checks if the GitOps Dashboard is installed.

type FluxVersionInfo

type FluxVersionInfo struct {
	FluxVersion             string
	SourceControllerVersion string
	FluxNamespace           string
}

func GetFluxVersion

func GetFluxVersion(ctx context.Context, log logger.Logger, kubeClient client.Client) (fluxVersionInfo *FluxVersionInfo, guessed bool, err error)

GetFluxVersion returns the Flux version that is used in the cluster.

type ResourceManagerForApply

type ResourceManagerForApply interface {
	ApplyAll(ctx context.Context, objects []*unstructured.Unstructured, opts ssa.ApplyOptions) (*ssa.ChangeSet, error)
	WaitForSet(set object.ObjMetadataSet, opts ssa.WaitOptions) error
}

type Session

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

func NewSession

func NewSession(log logger.Logger,
	kubeClient client.Client,
	name string, namespace string,
	fluxNamespace string, portForwards []string,
	skipDashboardInstall bool, dashboardHashedPassword string,
	automationKind string) (*Session, error)

func (*Session) Close

func (s *Session) Close() error

func (*Session) Connect

func (s *Session) Connect() error

func (*Session) Start

func (s *Session) Start() error