Documentation ¶
Index ¶
- func FailIfClusterIsNotReachable(kubeContext string) error
- func HasKubernetesFileExtension(n string) bool
- func IsKubernetesManifest(file string) bool
- func ParseImagesFromKubernetesYaml(filepath string) ([]string, error)
- func ParseKubernetesObjects(filepath string) ([]yamlObject, error)
- func TopLevelOwnerKey(ctx context.Context, obj metav1.Object, kubeContext string, kind string) string
- func WaitForDeploymentToStabilize(ctx context.Context, c kubernetes.Interface, ns, name string, ...) error
- func WaitForPodInitialized(ctx context.Context, pods corev1.PodInterface, podName string) error
- func WaitForPodSucceeded(ctx context.Context, pods corev1.PodInterface, podName string, ...) error
- type ImageList
- type ImageListMux
- type PodEvent
- type PodSelector
- type PodWatcher
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func FailIfClusterIsNotReachable ¶
FailIfClusterIsNotReachable checks that Kubernetes is reachable. This gives a clear early error when the cluster can't be reached.
func HasKubernetesFileExtension ¶
HasKubernetesFileExtension is for determining if a file under a glob pattern is deployable file format. It makes no attempt to check whether or not the file is actually deployable or has the correct contents.
func IsKubernetesManifest ¶
IsKubernetesManifest is for determining if a file is a valid Kubernetes manifest
func ParseImagesFromKubernetesYaml ¶
ParseImagesFromKubernetesYaml parses the kubernetes yamls, and if it finds at least one valid Kubernetes object, it will return the images referenced in them.
func ParseKubernetesObjects ¶ added in v2.4.0
ParseKubernetesObjects uses required fields from the k8s spec to determine if a provided yaml file is a valid k8s manifest, as detailed in https://kubernetes.io/docs/concepts/overview/working-with-objects/kubernetes-objects/#required-fields. If so, it will return the parsed objects.
func TopLevelOwnerKey ¶
func TopLevelOwnerKey(ctx context.Context, obj metav1.Object, kubeContext string, kind string) string
TopLevelOwnerKey returns a key associated with the top level owner of a Kubernetes resource in the form Kind-Name
func WaitForDeploymentToStabilize ¶
func WaitForDeploymentToStabilize(ctx context.Context, c kubernetes.Interface, ns, name string, timeout time.Duration) error
WaitForDeploymentToStabilize waits until the Deployment has a matching generation/replica count between spec and status.
func WaitForPodInitialized ¶
WaitForPodInitialized waits until init containers have started running
func WaitForPodSucceeded ¶
func WaitForPodSucceeded(ctx context.Context, pods corev1.PodInterface, podName string, timeout time.Duration) error
WaitForPodSucceeded waits until the Pod status is Succeeded.
Types ¶
type ImageListMux ¶
type ImageListMux []*ImageList
TODO(nkubala): remove this when podSelector is moved entirely into Deployer
type PodSelector ¶
PodSelector is used to choose which pods to log.
type PodWatcher ¶
type PodWatcher interface { Register(receiver chan<- PodEvent) Deregister(receiver chan<- PodEvent) Start(ctx context.Context, kubeContext string, ns []string) (func(), error) }
func NewPodWatcher ¶
func NewPodWatcher(podSelector PodSelector) PodWatcher