github/kubeshark
1
0
Fork 0
mirror of https://github.com/kubeshark/kubeshark.git synced 2025-09-25 12:41:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add GetDeployment

Browse Source
This commit is contained in:
Nimrod Gilboa Markevich
2022-02-16 12:43:47 +02:00
parent 6bc1bcd254
commit 7dc39c7416
1 changed files with 20 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

28
shared/kubernetes/provider.go
View File

@@ -949,20 +949,28 @@ func (provider *Provider) ApplyMizuTapperDaemonSet(ctx context.Context, namespac
})
podTemplate.WithSpec(podSpec)
ownerReferences := applyconfmeta.OwnerReference()
// ownerReferences.WithAPIVersion()
ownerReferences.WithKind("DaemonSet")
ownerReferences.WithName(daemonSetName)
// ownerReferences.WithUID()
// ownerReferences.WithController()
// ownerReferences.WithBlockOwnerDeletion()
ownerReferences := make([]*applyconfmeta.OwnerReferenceApplyConfiguration, 0)
deployment, err := provider.GetDeployment(ctx, namespace, "mizu-api-server")
if err == nil {
logger.Log.Info("DEBUG adding owner %+v", deployment)
ownerReference := applyconfmeta.OwnerReference()
ownerReference.WithAPIVersion("apps/v1") // get from deployment obj. deployment.APIVersion is empty. ¯\_(ツ)_/¯
ownerReference.WithKind("Deployment") // get from deployment obj. deployment.Kind is empty. ¯\_(ツ)_/¯
ownerReference.WithName(deployment.Name)
ownerReference.WithUID(deployment.UID)
ownerReferences = append(ownerReferences, ownerReference)
// ownerReferences.WithController() // not sure whether or not to use this
// ownerReferences.WithBlockOwnerDeletion() // not sure whether or not to use this
} else {
logger.Log.Infof("DEBUG error getting deployment %+v", err)
}
labelSelector := applyconfmeta.LabelSelector()
labelSelector.WithMatchLabels(map[string]string{"app": tapperPodName})
daemonSet := applyconfapp.DaemonSet(daemonSetName, namespace)
daemonSet.
WithOwnerReferences(ownerReferences).
WithOwnerReferences(ownerReferences...).
WithLabels(map[string]string{
LabelManagedBy: provider.managedBy,
LabelCreatedBy: provider.createdBy,
@@ -1001,6 +1009,10 @@ func (provider *Provider) GetPod(ctx context.Context, namespaces string, podName
return provider.clientSet.CoreV1().Pods(namespaces).Get(ctx, podName, metav1.GetOptions{})
}
func (provider *Provider) GetDeployment(ctx context.Context, namespace string, deploymentName string) (*v1.Deployment, error) {
return provider.clientSet.AppsV1().Deployments(namespace).Get(ctx, deploymentName, metav1.GetOptions{})
}
func (provider *Provider) ListAllRunningPodsMatchingRegex(ctx context.Context, regex *regexp.Regexp, namespaces []string) ([]core.Pod, error) {
pods, err := provider.ListAllPodsMatchingRegex(ctx, regex, namespaces)
if err != nil {