util

Documentation

Index

• Constants
• func AddTagsToPodSelector(runnerBuilds []graph.Artifact, deployerArtifacts []graph.Artifact, ...)
• func ApplyDefaultRepo(globalConfig string, defaultRepo *string, tag string) (string, error)
• func ConsolidateNamespaces(original, new []string) []string
• func GetAllPodNamespaces(configNamespace string, pipelines []latest.Pipeline) ([]string, error)
• func GetHydrationDir(opts config.SkaffoldOptions, workingDir string, promptIfNeeded bool, ...) (string, error)
• func GetManifestsFromHydratedManifests(ctx context.Context, hydratedManifests []string) (manifest.ManifestList, error)
• func GroupVersionResource(disco discovery.DiscoveryInterface, gvk schema.GroupVersionKind) (bool, schema.GroupVersionResource, error)
• func MockK8sClient(string) (k8s.Interface, error)
• func WithLogFile(filename string, out io.Writer, muted Muted) (io.Writer, func(), error)
• func WithStatusCheckLogFile(filename string, out io.Writer, muted Muted) (io.Writer, func(), error)
• type Muted

Constants

const TimeFormat = "2006-01-02_15-04-05"

TimeFormat is used to name log files generated by deploy step

Functions

func AddTagsToPodSelector

func AddTagsToPodSelector(runnerBuilds []graph.Artifact, deployerArtifacts []graph.Artifact, podSelector *kubernetes.ImageList)

Update which images are logged, if the image is present in the provided deployer's artifacts.

func ApplyDefaultRepo

func ApplyDefaultRepo(globalConfig string, defaultRepo *string, tag string) (string, error)

ApplyDefaultRepo applies the default repo to a given image tag.

func ConsolidateNamespaces

func ConsolidateNamespaces(original, new []string) []string

func GetAllPodNamespaces

func GetAllPodNamespaces(configNamespace string, pipelines []latest.Pipeline) ([]string, error)

GetAllPodNamespaces lists the namespaces that should be watched. + The namespace passed on the command line + Current kube context's namespace + Namespaces referenced in Helm releases

func GetHydrationDir

func GetHydrationDir(opts config.SkaffoldOptions, workingDir string, promptIfNeeded bool, isKptRendererOrDeployerUsed bool) (string, error)

GetHydrationDir points to the directory where the manifest rendering happens. By default, it is set to "<WORKDIR>/.kpt-pipeline".

func GetManifestsFromHydratedManifests

func GetManifestsFromHydratedManifests(ctx context.Context, hydratedManifests []string) (manifest.ManifestList, error)

func GroupVersionResource

func GroupVersionResource(disco discovery.DiscoveryInterface, gvk schema.GroupVersionKind) (bool, schema.GroupVersionResource, error)

GroupVersionResource returns the first `GroupVersionResource` for the given `GroupVersionKind`.

func MockK8sClient

func MockK8sClient(string) (k8s.Interface, error)

func WithLogFile

func WithLogFile(filename string, out io.Writer, muted Muted) (io.Writer, func(), error)

WithLogFile returns a file to write the deploy output to, and a function to be executed after the deploy step is complete.

func WithStatusCheckLogFile

func WithStatusCheckLogFile(filename string, out io.Writer, muted Muted) (io.Writer, func(), error)

WithStatusCheckLogFile returns a file to write the status-check output to, and a function to be executed after the status-check step is complete.

Types

type Muted

type Muted interface {
	MuteStatusCheck() bool
	MuteDeploy() bool
}