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
- type DashboardType
- type FluxVersionInfo
- type ResourceManagerForApply
- type Session
Constants ¶
View Source
const FluentBitHRName = "fluent-bit"
Variables ¶
View Source
var ErrDashboardInstalled = fmt.Errorf("dashboard already installed")
Functions ¶
func GeneratePasswordHash ¶ added in v0.10.0
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 ¶ added in v0.16.0
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 ¶ added in v0.10.0
func SanitizeResourceData(log logger.Logger, resourceData []byte) ([]byte, error)
func UninstallFluentBit ¶ added in v0.19.0
func UninstallFluentBit(ctx context.Context, log logger.Logger, kubeClient client.Client, hrNamespace, hrName string) error
Types ¶
type DashboardObjects ¶ added in v0.21.0
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 ¶ added in v0.17.0
type DashboardType int32
const (
DashboardTypeNone DashboardType = 0
DashboardTypeOSS DashboardType = 1
DashboardTypeEnterprise DashboardType = 2
)
func GetInstalledDashboard ¶ added in v0.17.0
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 ¶ added in v0.16.0
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 ¶ added in v0.10.0
type Session struct {
// contains filtered or unexported fields
}
func NewSession ¶ added in v0.10.0
func NewSession(log logger.Logger,
kubeClient client.Client,
name string, namespace string,
fluxNamespace string, portForwards []string,
skipDashboardInstall bool, dashboardHashedPassword string,
automationKind string) (*Session, error)
Source Files
Click to show internal directories.
Click to hide internal directories.