mirror of
https://github.com/kubeshark/kubeshark.git
synced 2025-06-21 22:08:59 +00:00
✨ Pull the images from public ECR repositories in case of the edition is not community
This commit is contained in:
parent
4b2c678fa3
commit
964d30bf80
@ -5,6 +5,7 @@ import (
|
|||||||
"errors"
|
"errors"
|
||||||
"fmt"
|
"fmt"
|
||||||
"regexp"
|
"regexp"
|
||||||
|
"strings"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
"github.com/kubeshark/kubeshark/docker"
|
"github.com/kubeshark/kubeshark/docker"
|
||||||
@ -41,6 +42,9 @@ var proxyDone bool
|
|||||||
func tap() {
|
func tap() {
|
||||||
state.startTime = time.Now()
|
state.startTime = time.Now()
|
||||||
docker.SetRegistry(config.Config.Tap.Docker.Registry)
|
docker.SetRegistry(config.Config.Tap.Docker.Registry)
|
||||||
|
if config.Config.Edition != "community" && strings.HasPrefix(config.Config.Tap.Docker.Registry, "docker.io/kubeshark") {
|
||||||
|
docker.SetRegistry(docker.NonCommunityRegistry)
|
||||||
|
}
|
||||||
docker.SetTag(config.Config.Tap.Docker.Tag)
|
docker.SetTag(config.Config.Tap.Docker.Tag)
|
||||||
log.Info().Str("registry", docker.GetRegistry()).Str("tag", docker.GetTag()).Msg("Using Docker:")
|
log.Info().Str("registry", docker.GetRegistry()).Str("tag", docker.GetTag()).Msg("Using Docker:")
|
||||||
if config.Config.Tap.Pcap != "" {
|
if config.Config.Tap.Pcap != "" {
|
||||||
|
@ -14,6 +14,7 @@ const (
|
|||||||
var (
|
var (
|
||||||
registry = "docker.io/kubeshark/"
|
registry = "docker.io/kubeshark/"
|
||||||
tag = "latest"
|
tag = "latest"
|
||||||
|
NonCommunityRegistry = "public.ecr.aws/g4h6q0l5/kubeshark-"
|
||||||
)
|
)
|
||||||
|
|
||||||
func GetRegistry() string {
|
func GetRegistry() string {
|
||||||
|
Loading…
Reference in New Issue
Block a user