mirror of
https://github.com/kubeshark/kubeshark.git
synced 2025-06-01 20:46:56 +00:00
302333b4ae
* Removed policy rules (validation rules) feature * updated test pcap * Remove rules * fix replay in rules Co-authored-by: Roy Island <roy@up9.com> Co-authored-by: RoyUP9 <87927115+RoyUP9@users.noreply.github.com> Co-authored-by: Roee Gadot <roee.gadot@up9.com>
90 lines
3.2 KiB
Go
90 lines
3.2 KiB
Go
package configStructs
|
|
|
|
import (
|
|
"fmt"
|
|
"io/fs"
|
|
"io/ioutil"
|
|
"os"
|
|
"regexp"
|
|
|
|
"github.com/up9inc/mizu/cli/uiUtils"
|
|
"github.com/up9inc/mizu/shared"
|
|
|
|
"github.com/up9inc/mizu/logger"
|
|
"github.com/up9inc/mizu/shared/units"
|
|
)
|
|
|
|
const (
|
|
GuiPortTapName = "gui-port"
|
|
NamespacesTapName = "namespaces"
|
|
AllNamespacesTapName = "all-namespaces"
|
|
PlainTextFilterRegexesTapName = "regex-masking"
|
|
EnableRedactionTapName = "redact"
|
|
HumanMaxEntriesDBSizeTapName = "max-entries-db-size"
|
|
InsertionFilterName = "insertion-filter"
|
|
DryRunTapName = "dry-run"
|
|
ServiceMeshName = "service-mesh"
|
|
TlsName = "tls"
|
|
ProfilerName = "profiler"
|
|
MaxLiveStreamsName = "max-live-streams"
|
|
)
|
|
|
|
type TapConfig struct {
|
|
PodRegexStr string `yaml:"regex" default:".*"`
|
|
GuiPort uint16 `yaml:"gui-port" default:"8899"`
|
|
ProxyHost string `yaml:"proxy-host" default:"127.0.0.1"`
|
|
Namespaces []string `yaml:"namespaces"`
|
|
AllNamespaces bool `yaml:"all-namespaces" default:"false"`
|
|
PlainTextFilterRegexes []string `yaml:"regex-masking"`
|
|
IgnoredUserAgents []string `yaml:"ignored-user-agents"`
|
|
EnableRedaction bool `yaml:"redact" default:"false"`
|
|
HumanMaxEntriesDBSize string `yaml:"max-entries-db-size" default:"200MB"`
|
|
InsertionFilter string `yaml:"insertion-filter" default:""`
|
|
DryRun bool `yaml:"dry-run" default:"false"`
|
|
ApiServerResources shared.Resources `yaml:"api-server-resources"`
|
|
TapperResources shared.Resources `yaml:"tapper-resources"`
|
|
ServiceMesh bool `yaml:"service-mesh" default:"false"`
|
|
Tls bool `yaml:"tls" default:"false"`
|
|
Profiler bool `yaml:"profiler" default:"false"`
|
|
MaxLiveStreams int `yaml:"max-live-streams" default:"500"`
|
|
}
|
|
|
|
func (config *TapConfig) PodRegex() *regexp.Regexp {
|
|
podRegex, _ := regexp.Compile(config.PodRegexStr)
|
|
return podRegex
|
|
}
|
|
|
|
func (config *TapConfig) MaxEntriesDBSizeBytes() int64 {
|
|
maxEntriesDBSizeBytes, _ := units.HumanReadableToBytes(config.HumanMaxEntriesDBSize)
|
|
return maxEntriesDBSizeBytes
|
|
}
|
|
|
|
func (config *TapConfig) GetInsertionFilter() string {
|
|
insertionFilter := config.InsertionFilter
|
|
if fs.ValidPath(insertionFilter) {
|
|
if _, err := os.Stat(insertionFilter); err == nil {
|
|
b, err := ioutil.ReadFile(insertionFilter)
|
|
if err != nil {
|
|
logger.Log.Warningf(uiUtils.Warning, fmt.Sprintf("Couldn't read the file on path: %s, err: %v", insertionFilter, err))
|
|
} else {
|
|
insertionFilter = string(b)
|
|
}
|
|
}
|
|
}
|
|
return insertionFilter
|
|
}
|
|
|
|
func (config *TapConfig) Validate() error {
|
|
_, compileErr := regexp.Compile(config.PodRegexStr)
|
|
if compileErr != nil {
|
|
return fmt.Errorf("%s is not a valid regex %s", config.PodRegexStr, compileErr)
|
|
}
|
|
|
|
_, parseHumanDataSizeErr := units.HumanReadableToBytes(config.HumanMaxEntriesDBSize)
|
|
if parseHumanDataSizeErr != nil {
|
|
return fmt.Errorf("Could not parse --%s value %s", HumanMaxEntriesDBSizeTapName, config.HumanMaxEntriesDBSize)
|
|
}
|
|
|
|
return nil
|
|
}
|