install

Documentation

Index

• Constants
• func CreateDashboardObjects(log logger.Logger, name string, namespace string, username string, ...) ([]byte, error)
• func GeneratePasswordHash(log logger.Logger, password string) (string, error)
• func InstallDashboard(ctx context.Context, log logger.Logger, manager ResourceManagerForApply, ...) error
• func InstallFluentBit(ctx context.Context, log logger.Logger, kubeClient client.Client, ...) error
• func IsDashboardInstalled(ctx context.Context, log logger.Logger, kubeClient client.Client, name string, ...) bool
• 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, name string, namespace string, ...) error
• func SanitizeResourceData(log logger.Logger, resourceData []byte) ([]byte, 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"

Functions

func CreateDashboardObjects

func CreateDashboardObjects(log logger.Logger, name string, namespace string, username string, passwordHash string, chartVersion string, dashboardImage string) ([]byte, error)

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

func GeneratePasswordHash

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

func InstallDashboard

func InstallDashboard(ctx context.Context, log logger.Logger, manager ResourceManagerForApply, manifests []byte) error

InstallDashboard installs the GitOps Dashboard.

func InstallFluentBit

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

func IsDashboardInstalled

func IsDashboardInstalled(ctx context.Context, log logger.Logger, kubeClient client.Client, name string, namespace string) bool

IsDashboardInstalled checks if the GitOps Dashboard is installed.

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, name string, namespace string, podName string, timeout time.Duration) error

ReconcileDashboard reconciles the dashboard.

func SanitizeResourceData

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

Types

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, 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