util

Documentation

Index

• Constants
• func AddTagsToPodSelector(artifacts []graph.Artifact, deployerArtifacts []graph.Artifact, ...)
• func ApplyDefaultRepo(globalConfig string, defaultRepo *string, tag string) (string, error)
• func ConsolidateNamespaces(original, new []string) []string
• func ConsolidateTransformConfiguration(cfg types.Config) (map[schema.GroupKind]latest.ResourceFilter, ...)
• func ConvertJSONPathIndex(rf latest.ResourceFilter) latest.ResourceFilter
• func GetAllPodNamespaces(configNamespace string, pipelines []latest.Pipeline) ([]string, 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(artifacts []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 ConsolidateTransformConfiguration

func ConsolidateTransformConfiguration(cfg types.Config) (map[schema.GroupKind]latest.ResourceFilter, map[schema.GroupKind]latest.ResourceFilter, error)

func ConvertJSONPathIndex

func ConvertJSONPathIndex(rf latest.ResourceFilter) latest.ResourceFilter

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 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
}