Documentation
¶
Index ¶
- Variables
- 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 InitializeTargetDir(targetPath string) error
- func InstallDevBucketServer(ctx context.Context, log logger.Logger, kubeClient client.Client, ...) (func(), error)
- func ReconcileDevBucketSourceAndKS(ctx context.Context, log logger.Logger, kubeClient client.Client, ...) error
- func SetupBucketSourceAndKS(ctx context.Context, log logger.Logger, kubeClient client.Client, ...) error
- 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 PortForwardSpec
Constants ¶
This section is empty.
Variables ¶
View Source
var (
DevBucketContainerImage = "ghcr.io/weaveworks/gitops-bucket-server@sha256:8fbb7534e772e14ea598d287a4b54a3f556416cac6621095ce45f78346fda78a"
)
Functions ¶
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 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 InitializeTargetDir ¶
func InstallDevBucketServer ¶
func InstallDevBucketServer(ctx context.Context, log logger.Logger, kubeClient client.Client, config *rest.Config, devBucketPort int32) (func(), error)
InstallDevBucketServer installs the dev bucket server, open port forwarding, and returns a function that can be used to the port forwarding.
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 SetupBucketSourceAndKS ¶
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
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"
Click to show internal directories.
Click to hide internal directories.