github/kubeshark
1
0
Fork 0
mirror of https://github.com/kubeshark/kubeshark.git synced 2025-06-23 23:08:35 +00:00
Code Issues Packages Projects Releases Wiki Activity

⏪ Revert "Create Worker(s) before Hub"

Browse Source
This commit is contained in:
M. Mert Yildiran 2023-02-15 22:33:59 +03:00
parent dcd42798c7
commit f0b68cb44b
No known key found for this signature in database
GPG Key ID: DA5D6DCBB758A461
2 changed files with 17 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
cmd/tapRunner.go
View File

@ -409,6 +409,23 @@ func postHubStarted(ctx context.Context, kubernetesProvider *kubernetes.Provider
"/echo", "/echo",
) )
// Create workers
err := kubernetes.CreateWorkers(
kubernetesProvider,
state.selfServiceAccountExists,
ctx,
config.Config.SelfNamespace,
config.Config.Tap.Resources.Worker,
config.Config.ImagePullPolicy(),
config.Config.ImagePullSecrets(),
config.Config.Tap.ServiceMesh,
config.Config.Tap.Tls,
config.Config.Tap.Debug,
)
if err != nil {
log.Error().Err(err).Send()
}
// Storage limit // Storage limit
connector.PostStorageLimitToHub(config.Config.Tap.StorageLimitBytes()) connector.PostStorageLimitToHub(config.Config.Tap.StorageLimitBytes())

17
resources/createResources.go
View File

@ -32,23 +32,6 @@ func CreateHubResources(ctx context.Context, kubernetesProvider *kubernetes.Prov
serviceAccountName = "" serviceAccountName = ""
} }
// Create workers
err = kubernetes.CreateWorkers(
kubernetesProvider,
selfServiceAccountExists,
ctx,
config.Config.SelfNamespace,
config.Config.Tap.Resources.Worker,
config.Config.ImagePullPolicy(),
config.Config.ImagePullSecrets(),
config.Config.Tap.ServiceMesh,
config.Config.Tap.Tls,
config.Config.Tap.Debug,
)
if err != nil {
log.Error().Err(err).Send()
}
opts := &kubernetes.PodOptions{ opts := &kubernetes.PodOptions{
Namespace: selfNamespace, Namespace: selfNamespace,
PodName: kubernetes.HubPodName, PodName: kubernetes.HubPodName,