Affected by 
Documentation
¶
Index ¶
- Variables
- func CleanupBucketSourceAndKS(log logger.Logger, kubeClient *kube.KubeHTTP, namespace string) error
- func EnablePortForwardingForDashboard(log logger.Logger, kubeClient *kube.KubeHTTP, config *rest.Config, ...) (func(), error)
- func FindGitRepoDir() (string, error)
- func ForwardPort(pod *corev1.Pod, cfg *rest.Config, specMap *PortForwardSpec, ...) error
- func GetFluxVersion(log logger.Logger, ctx context.Context, kubeClient *kube.KubeHTTP) (string, error)
- func GetKubeClient(log logger.Logger, contextName string, cfg *rest.Config, ...) (*kube.KubeHTTP, error)
- func GetKubeClientOptions() *runclient.Options
- func GetKubeConfigArgs() *genericclioptions.ConfigFlags
- func GetPodFromSpecMap(specMap *PortForwardSpec, kubeClient *kube.KubeHTTP) (*corev1.Pod, error)
- func GetRelativePathToRootDir(rootDir string, path string) (string, error)
- func InstallDashboard(log logger.Logger, ctx context.Context, kubeClient *kube.KubeHTTP, ...) error
- func InstallDevBucketServer(log logger.Logger, kubeClient *kube.KubeHTTP, config *rest.Config) (func(), error)
- func InstallFlux(log logger.Logger, ctx context.Context, kubeClient *kube.KubeHTTP, ...) error
- func IsDashboardInstalled(log logger.Logger, ctx context.Context, kubeClient *kube.KubeHTTP) bool
- func IsLocalCluster(kubeClient *kube.KubeHTTP) bool
- func ReconcileDashboard(kubeClient *kube.KubeHTTP, namespace string, timeout time.Duration) error
- func RequestReconciliation(ctx context.Context, kubeClient client.Client, ...) (string, error)
- func SetupBucketSourceAndKS(log logger.Logger, kubeClient *kube.KubeHTTP, namespace string, path string) error
- func SyncDir(log logger.Logger, dir string, bucket string, client *minio.Client) error
- func UninstallDevBucketServer(log logger.Logger, kubeClient *kube.KubeHTTP) error
- func WaitForDeploymentToBeReady(log logger.Logger, kubeClient *kube.KubeHTTP, deploymentName string, ...) error
- func WatchAndSync(log logger.Logger, dir string, bucket string, client *minio.Client) (chan<- bool, error)
- type PortForwardSpec
Constants ¶
This section is empty.
Variables ¶
var (
DevBucketContainerImage = "ghcr.io/weaveworks/gitops-bucket-server@sha256:b0446a6c645b5d39cf0db558958bf28363aca3ea80dc9d593983173613a4f290"
)
Functions ¶
func CleanupBucketSourceAndKS ¶
CleanupBucketSourceAndKS removes the bucket source and ks
func EnablePortForwardingForDashboard ¶
func EnablePortForwardingForDashboard(log logger.Logger, kubeClient *kube.KubeHTTP, config *rest.Config, dashboardPort string) (func(), error)
EnablePortForwardingForDashboard enables port forwarding for the GitOps Dashboard.
func FindGitRepoDir ¶
FindGitRepoDir finds git repo root directory
func ForwardPort ¶
func GetFluxVersion ¶
func GetKubeClient ¶
func GetKubeClientOptions ¶
func GetKubeConfigArgs ¶
func GetKubeConfigArgs() *genericclioptions.ConfigFlags
func GetPodFromSpecMap ¶
func GetRelativePathToRootDir ¶
GetRelativePathToRootDir gets relative path to a directory from the git root. It returns an error if there's no git repo.
func InstallDashboard ¶
func InstallDashboard(log logger.Logger, ctx context.Context, kubeClient *kube.KubeHTTP, kubeConfigArgs *genericclioptions.ConfigFlags) error
InstallDashboard installs the GitOps Dashboard.
func InstallDevBucketServer ¶
func InstallDevBucketServer(log logger.Logger, kubeClient *kube.KubeHTTP, config *rest.Config) (func(), error)
InstallDevBucketServer installs the dev bucket server, open port forwarding, and returns a function that can be used to the port forwarding.
func InstallFlux ¶
func IsDashboardInstalled ¶
IsDashboardInstalled checks if the GitOps Dashboard is installed.
func IsLocalCluster ¶
IsLocalCluster checks if it's a local cluster. See https://skaffold.dev/docs/environment/local-cluster/
func ReconcileDashboard ¶
ReconcileDashboard reconciles the dashboard.
func RequestReconciliation ¶
func RequestReconciliation(ctx context.Context, kubeClient client.Client, namespacedName types.NamespacedName, gvk schema.GroupVersionKind) (string, error)
func SetupBucketSourceAndKS ¶
func SyncDir ¶
SyncDir recursively uploads all files in a directory to an S3 bucket with minio library
func UninstallDevBucketServer ¶
UninstallDevBucketServer deletes the dev-bucket namespace.
Types ¶
type PortForwardSpec ¶
type PortForwardSpec struct {
Namespace string
Name string
Kind string
HostPort string
ContainerPort string
Map map[string]string
}
func ParsePortForwardSpec ¶
func ParsePortForwardSpec(spec string) (*PortForwardSpec, error)
parse port forward specin the key-value format of "port=8000:8080,resource=svc/app,namespace=default"
Source Files