watch

Documentation

Index

• Constants
• Variables
• func CleanupBucketSourceAndHelm(ctx context.Context, log logger.Logger, kubeClient client.Client, ...) error
• func CleanupBucketSourceAndKS(ctx context.Context, log logger.Logger, kubeClient client.Client, ...) error
• func CreateIgnorer(gitRootDir string) *ignore.GitIgnore
• func EnablePortForwardingForDashboard(ctx context.Context, log logger.Logger, kubeClient client.Client, ...) (func(), error)
• func ForwardPort(log logr.Logger, pod *corev1.Pod, cfg *rest.Config, specMap *PortForwardSpec, ...) error
• func GetNextPortForwardKey(portForwards map[rune]PortForwardShortcut) (rune, error)
• func InitializeTargetDir(targetPath string) error
• func InstallDevBucketServer(ctx context.Context, log logger.Logger, kubeClient client.Client, ...) (func(), []byte, error)
• func ReconcileDevBucketSourceAndHelm(ctx context.Context, log logger.Logger, kubeClient client.Client, ...) error
• func ReconcileDevBucketSourceAndKS(ctx context.Context, log logger.Logger, kubeClient client.Client, ...) error
• func SetupBucketSourceAndHelm(ctx context.Context, log logger.Logger, kubeClient client.Client, ...) error
• func SetupBucketSourceAndKS(ctx context.Context, log logger.Logger, kubeClient client.Client, ...) error
• func ShowPortForwards(ctx context.Context, log clilogger.Logger, ...)
• func SyncDir(ctx context.Context, log logger.Logger, dir string, bucket string, ...) error
• func UninstallDevBucketServer(ctx context.Context, log logger.Logger, kubeClient client.Client) error
• func WatchDirsForFileWalker(watcher *fsnotify.Watcher, ignorer *ignore.GitIgnore) func(path string, info os.FileInfo, err error) error
• type PortForwardShortcut
• type PortForwardSpec
  • func ParsePortForwardSpec(spec string) (*PortForwardSpec, error)
• type SetupRunObjectParams

Constants

const (
	RunDevBucketName   = "run-dev-bucket"
	RunDevKsName       = "run-dev-ks"
	RunDevHelmName     = "run-dev-helm"
	GitOpsRunNamespace = "gitops-run"
)

Variables

var (
	DevBucketContainerImage string
)

var PortForwardShortcutRunes = []rune{'0', '1', '2', '3', '4', '5', '6', '7', '8', '9'}

Functions

func CleanupBucketSourceAndHelm

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

CleanupBucketSourceAndHelm removes the bucket source and ks

func CleanupBucketSourceAndKS

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

CleanupBucketSourceAndKS removes the bucket source and ks

func CreateIgnorer

func CreateIgnorer(gitRootDir string) *ignore.GitIgnore

func EnablePortForwardingForDashboard

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

EnablePortForwardingForDashboard enables port forwarding for the GitOps Dashboard.

func ForwardPort

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

func GetNextPortForwardKey

func GetNextPortForwardKey(portForwards map[rune]PortForwardShortcut) (rune, error)

func InitializeTargetDir

func InitializeTargetDir(targetPath string) error

func InstallDevBucketServer

func InstallDevBucketServer(
	ctx context.Context,
	log logger.Logger,
	kubeClient client.Client,
	config *rest.Config,
	httpPort,
	httpsPort int32,
	accessKey,
	secretKey []byte) (func(), []byte, error)

InstallDevBucketServer installs the dev bucket server, open port forwarding, and returns a function that can be used to the port forwarding.

func ReconcileDevBucketSourceAndHelm

func ReconcileDevBucketSourceAndHelm(ctx context.Context, log logger.Logger, kubeClient client.Client, namespace string, timeout time.Duration) error

ReconcileDevBucketSourceAndHelm reconciles the dev-bucket and dev-helm asynchronously.

func ReconcileDevBucketSourceAndKS

func ReconcileDevBucketSourceAndKS(ctx context.Context, log logger.Logger, kubeClient client.Client, namespace string, timeout time.Duration) error

ReconcileDevBucketSourceAndKS reconciles the dev-bucket and dev-ks asynchronously.

func SetupBucketSourceAndHelm

func SetupBucketSourceAndHelm(ctx context.Context, log logger.Logger, kubeClient client.Client, params SetupRunObjectParams) error

func SetupBucketSourceAndKS

func SetupBucketSourceAndKS(ctx context.Context, log logger.Logger, kubeClient client.Client, params SetupRunObjectParams) error

func ShowPortForwards

func ShowPortForwards(ctx context.Context, log clilogger.Logger, portForwards map[rune]PortForwardShortcut)

func SyncDir

func SyncDir(ctx context.Context, log logger.Logger, dir string, bucket string, client *minio.Client, ignorer *ignore.GitIgnore) error

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

func UninstallDevBucketServer

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

UninstallDevBucketServer deletes the dev-bucket namespace.

func WatchDirsForFileWalker

func WatchDirsForFileWalker(watcher *fsnotify.Watcher, ignorer *ignore.GitIgnore) func(path string, info os.FileInfo, err error) error

Types

type PortForwardShortcut

type PortForwardShortcut struct {
	Name     string
	HostPort string
}

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 SetupRunObjectParams

type SetupRunObjectParams struct {
	Namespace         string
	Path              string
	Timeout           time.Duration
	DevBucketPort     int32
	SessionName       string
	Username          string
	AccessKey         []byte
	SecretKey         []byte
	DecryptionKeyFile string
}