run

Documentation

Index

• Constants
• Variables
• func GetKubeClient(log logger.Logger, contextName string, cfg *rest.Config, ...) (*kube.KubeHTTP, error)
• func GetKubeClientOptions() *runclient.Options
• func GetKubeConfigArgs() *genericclioptions.ConfigFlags
• func GetPodFromResourceDescription(ctx context.Context, kubeClient client.Client, ...) (*corev1.Pod, error)
• func GetRelativePathToRootDir(rootDir, path string) (string, error)
• func GetUnusedPorts(count int) (ports []int32, retErr error)
• func IsLocalCluster(kubeClient *kube.KubeHTTP) bool
• func RequestReconciliation(ctx context.Context, kubeClient client.Client, ...) (string, error)
• type Paths
  • func NewPaths(specifiedTargetDir, specifiedRootDir string) (*Paths, error)
  • func (p *Paths) GetAbsoluteTargetDir() string

Constants

const (
	NotInGitRepoError = "not in a git repo, last checked directory: %s"
	StatError         = "unexpected error while checking for .git directory: %v"
	AbsError          = "unexpected error while getting the absolute filepath: %v"
	PermissionError   = "permission denied while checking for parent directory of: %s"
)

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")
)

Functions

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 GetPodFromResourceDescription

func GetPodFromResourceDescription(ctx context.Context, kubeClient client.Client, namespacedName types.NamespacedName, kind string, podLabels map[string]string) (*corev1.Pod, error)

func GetRelativePathToRootDir

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

func GetUnusedPorts

func GetUnusedPorts(count int) (ports []int32, retErr error)

GetUnusedPorts returns a slice of unused ports.

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 RequestReconciliation

func RequestReconciliation(ctx context.Context, kubeClient client.Client, namespacedName types.NamespacedName, gvk schema.GroupVersionKind) (string, error)

Types

type Paths

type Paths struct {
	RootDir    string // Absolute path to the git repository
	CurrentDir string // Path to the current working directory, relative to rootDir
	ClusterDir string // Path to the cluster dir, relative to rootDir - currentDir / "clusters" / "my-cluster"
	TargetDir  string // Path to the target workload dir, relative to rootDir. Must not contain clusterDir, may or may not be inside currentDir
}

func NewPaths

func NewPaths(specifiedTargetDir, specifiedRootDir string) (*Paths, error)

func (*Paths) GetAbsoluteTargetDir

func (p *Paths) GetAbsoluteTargetDir() string