run

Documentation

Index

• Variables
• func CleanupBucketSourceAndKS(log logger.Logger, kubeClient client.Client, namespace string) error
• func EnablePortForwardingForDashboard(log logger.Logger, kubeClient client.Client, config *rest.Config, ...) (func(), error)
• func FindConditionMessages(kubeClient client.Client, ks *kustomizev1.Kustomization) ([]string, 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 client.Client) (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 client.Client, ...) (*corev1.Pod, error)
• func GetRelativePathToRootDir(rootDir string, path string) (string, error)
• func InstallDashboard(log logger.Logger, ctx context.Context, kubeClient client.Client, ...) error
• func InstallDevBucketServer(log logger.Logger, kubeClient client.Client, config *rest.Config) (func(), error)
• func InstallFlux(log logger.Logger, ctx context.Context, kubeClient client.Client, ...) error
• func IsDashboardInstalled(log logger.Logger, ctx context.Context, kubeClient client.Client) bool
• func IsLocalCluster(kubeClient *kube.KubeHTTP) bool
• func ReconcileDashboard(kubeClient client.Client, namespace string, timeout time.Duration, ...) error
• func RequestReconciliation(ctx context.Context, kubeClient client.Client, ...) (string, error)
• func SetupBucketSourceAndKS(log logger.Logger, kubeClient client.Client, namespace string, path string, ...) error
• func SyncDir(log logger.Logger, dir string, bucket string, client *minio.Client) error
• func UninstallDevBucketServer(log logger.Logger, kubeClient client.Client) error
• func WaitForDeploymentToBeReady(log logger.Logger, kubeClient client.Client, deploymentName string, ...) error
• func WatchAndSync(log logger.Logger, dir string, bucket string, client *minio.Client) (chan<- bool, error)
• type PortForwardSpec
  • func ParsePortForwardSpec(spec string) (*PortForwardSpec, error)

Variables

var (
	DevBucketContainerImage = "ghcr.io/weaveworks/gitops-bucket-server@sha256:b0446a6c645b5d39cf0db558958bf28363aca3ea80dc9d593983173613a4f290"
)

Functions

func CleanupBucketSourceAndKS

func CleanupBucketSourceAndKS(log logger.Logger, kubeClient client.Client, namespace string) error

CleanupBucketSourceAndKS removes the bucket source and ks

func EnablePortForwardingForDashboard

func EnablePortForwardingForDashboard(log logger.Logger, kubeClient client.Client, config *rest.Config, namespace string, dashboardPort string) (func(), error)

EnablePortForwardingForDashboard enables port forwarding for the GitOps Dashboard.

func FindConditionMessages

func FindConditionMessages(kubeClient client.Client, ks *kustomizev1.Kustomization) ([]string, error)

FindConditionMessages finds the messages in the condition of objects in the inventory.

func FindGitRepoDir

func FindGitRepoDir() (string, error)

FindGitRepoDir finds git repo root directory

func ForwardPort

func ForwardPort(pod *corev1.Pod, cfg *rest.Config, specMap *PortForwardSpec, waitFwd chan struct{}, readyChannel chan struct{}) error

func GetFluxVersion

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

func GetKubeClient

func GetKubeClient(log logger.Logger, contextName string, cfg *rest.Config, kubeClientOpts *runclient.Options) (*kube.KubeHTTP, error)

func GetKubeClientOptions

func GetKubeClientOptions() *runclient.Options

func GetKubeConfigArgs

func GetKubeConfigArgs() *genericclioptions.ConfigFlags

func GetPodFromSpecMap

func GetPodFromSpecMap(specMap *PortForwardSpec, kubeClient client.Client, podStatusPhase corev1.PodPhase) (*corev1.Pod, error)

func GetRelativePathToRootDir

func GetRelativePathToRootDir(rootDir string, path string) (string, error)

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 client.Client, kubeConfigArgs *genericclioptions.ConfigFlags) error

InstallDashboard installs the GitOps Dashboard.

func InstallDevBucketServer

func InstallDevBucketServer(log logger.Logger, kubeClient client.Client, 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 InstallFlux(log logger.Logger, ctx context.Context, kubeClient client.Client, installOptions install.Options, kubeConfigArgs genericclioptions.RESTClientGetter) error

func IsDashboardInstalled

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

IsDashboardInstalled checks if the GitOps Dashboard is installed.

func IsLocalCluster

func IsLocalCluster(kubeClient *kube.KubeHTTP) bool

IsLocalCluster checks if it's a local cluster. See https://skaffold.dev/docs/environment/local-cluster/

func ReconcileDashboard

func ReconcileDashboard(kubeClient client.Client, namespace string, timeout time.Duration, dashboardPort string) error

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 SetupBucketSourceAndKS(log logger.Logger, kubeClient client.Client, namespace string, path string, timeout time.Duration) error

func SyncDir

func SyncDir(log logger.Logger, dir string, bucket string, client *minio.Client) error

SyncDir recursively uploads all files in a directory to an S3 bucket with minio library

func UninstallDevBucketServer

func UninstallDevBucketServer(log logger.Logger, kubeClient client.Client) error

UninstallDevBucketServer deletes the dev-bucket namespace.

func WaitForDeploymentToBeReady

func WaitForDeploymentToBeReady(log logger.Logger, kubeClient client.Client, deploymentName string, namespace string) error

func WatchAndSync

func WatchAndSync(log logger.Logger, dir string, bucket string, client *minio.Client) (chan<- bool, error)

WatchAndSync watches files recursively, and re-sync the whole directory to the bucket using minio library

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"