mainhandler

package

v0.2.92 Latest Latest Go to latest Published: Jun 30, 2025 License: Apache-2.0 Imports: 56 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/kubescape/operator

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func GetStartupActions(config config.IConfig) []apis.Command
func HandleKubescapeResponse(ctx context.Context, config config.IConfig, payload interface{}) (bool, *time.Duration)
type ActionHandler
- func NewActionHandler(config config.IConfig, k8sAPI *k8sinterface.KubernetesApi, ...) *ActionHandler
type AuthMethods
type CommandResponseData
type HandleCommandResponseCallBack
type ImageScanConfig
type MainHandler
- func NewMainHandler(config config.IConfig, k8sAPI *k8sinterface.KubernetesApi, ...) *MainHandler

Constants ¶

View Source

const (
	WaitTimeForKubescapeScanResponse = 40
	KubescapeCronJobTemplateName     = "kubescape-cronjob-template"
)

View Source

const (
	KubescapeResponse string = "KubescapeResponse"
)

View Source

const (
	MaxLimitationInsertToCommandResponseChannelGoRoutine = 10
)

View Source

const VulnScanCronjobTemplateName = "kubevuln-cronjob-template"

Variables ¶

View Source

var KubescapeHttpClient httputils.IHttpClient

View Source

var VulnScanHttpClient httputils.IHttpClient

Functions ¶

func GetStartupActions ¶

func GetStartupActions(config config.IConfig) []apis.Command

func HandleKubescapeResponse ¶

func HandleKubescapeResponse(ctx context.Context, config config.IConfig, payload interface{}) (bool, *time.Duration)

Types ¶

type ActionHandler ¶

type ActionHandler struct {
	// contains filtered or unexported fields
}

func NewActionHandler ¶

func NewActionHandler(config config.IConfig, k8sAPI *k8sinterface.KubernetesApi, sessionObj *utils.SessionObj, commandResponseChannel *commandResponseChannelData, exporter *exporters.HTTPExporter) *ActionHandler

CreateWebSocketHandler Create ws-handler obj

type AuthMethods ¶

type AuthMethods string

type CommandResponseData ¶

type CommandResponseData struct {
	// contains filtered or unexported fields
}

type HandleCommandResponseCallBack ¶

type HandleCommandResponseCallBack func(ctx context.Context, config config.IConfig, payload interface{}) (bool, *time.Duration)

type ImageScanConfig ¶ added in v0.2.6

type ImageScanConfig struct {
	// contains filtered or unexported fields
}

type MainHandler ¶

type MainHandler struct {
	// contains filtered or unexported fields
}

func NewMainHandler ¶

func NewMainHandler(config config.IConfig, k8sAPI *k8sinterface.KubernetesApi, exporter *exporters.HTTPExporter, ksStorageClient kssc.Interface) *MainHandler

CreateWebSocketHandler Create ws-handler obj

func (*MainHandler) EventWorkerPool ¶ added in v0.1.39

func (mainHandler *MainHandler) EventWorkerPool() *ants.PoolWithFunc

func (*MainHandler) HandleCommandResponse ¶ added in v0.1.39

func (mainHandler *MainHandler) HandleCommandResponse(ctx context.Context)

func (*MainHandler) HandleImageScanningScopedRequest ¶ added in v0.2.4

func (mainHandler *MainHandler) HandleImageScanningScopedRequest(ctx context.Context, sessionObj *utils.SessionObj)

HandleScopedRequest handle a request of a scope e.g. all workloads in a namespace

func (*MainHandler) HandleScopedRequest ¶

func (mainHandler *MainHandler) HandleScopedRequest(ctx context.Context, sessionObj *utils.SessionObj)

HandleScopedRequest handle a request of a scope e.g. all workloads in a namespace

func (*MainHandler) HandleSingleRequest ¶

func (mainHandler *MainHandler) HandleSingleRequest(ctx context.Context, sessionObj *utils.SessionObj) error

func (*MainHandler) HandleWatchers ¶ added in v0.1.21

func (mainHandler *MainHandler) HandleWatchers(ctx context.Context)

func (*MainHandler) SendReports ¶ added in v0.2.31

func (mainHandler *MainHandler) SendReports(ctx context.Context, period time.Duration)

func (*MainHandler) SetupContinuousScanning ¶ added in v0.1.70

func (mainHandler *MainHandler) SetupContinuousScanning(ctx context.Context) error

SetupContinuousScanning sets up the continuous cluster scanning function

func (*MainHandler) StartContinuousScanning ¶ added in v0.1.70

func (h *MainHandler) StartContinuousScanning(_ context.Context) error

func (*MainHandler) StartupTriggerActions ¶

func (mainHandler *MainHandler) StartupTriggerActions(ctx context.Context, actions []apis.Command)

HandlePostmanRequest Parse received commands and run the command

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL