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 GenerateSecret(log logger.Logger) (string, 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, manager ResourceManagerForApply, ...) error
• func InstallDevBucketServer(log logger.Logger, kubeClient client.Client, config *rest.Config) (func(), error)
• func InstallFlux(log logger.Logger, ctx context.Context, installOptions install.Options, ...) error
• func IsDashboardInstalled(log logger.Logger, ctx context.Context, kubeClient client.Client, ...) bool
• func IsLocalCluster(kubeClient *kube.KubeHTTP) bool
• func NewManager(log logger.Logger, ctx context.Context, kubeClient ctrlclient.Client, ...) (*ssa.ResourceManager, error)
• 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)
• type ResourceManagerForApply

Variables

var (
	ErrNoPodsForService           = errors.New("no pods found for service")
	ErrNoPodsForDeployment        = errors.New("no pods found for deployment")
	ErrNoRunningPodsForService    = errors.New("no running pods found for service")
	ErrNoRunningPodsForDeployment = errors.New("no running pods found for deployment")
	ErrDashboardPodNotFound       = errors.New("dashboard pod not found")
)

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 GenerateSecret

func GenerateSecret(log logger.Logger) (string, 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) (*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, manager ResourceManagerForApply, namespace string, secret string) 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, installOptions install.Options, manager ResourceManagerForApply) error

func IsDashboardInstalled

func IsDashboardInstalled(log logger.Logger, ctx context.Context, kubeClient client.Client, namespace string) 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 NewManager

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

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"

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
}