mainhandler

Documentation

Index

• Constants
• Variables
• func GetStartupActions(config config.IConfig) []apis.Command
• func HandleKubescapeResponse(ctx context.Context, config config.IConfig, sendReport bool, ...) (bool, *time.Duration)
• func NewRegistryScan(config config.IConfig, k8sAPI *k8sinterface.KubernetesApi) registryScan
• func NewRegistryScanConfig(registryName string) *registryScanConfig
• type ActionHandler
  • func NewActionHandler(config config.IConfig, k8sAPI *k8sinterface.KubernetesApi, ...) *ActionHandler
• type AuthMethods
• type CommandResponseData
• type HandleCommandResponseCallBack
• type IWorkloadsGetter
• type ImageScanConfig
• type MainHandler
  • func NewMainHandler(config config.IConfig, k8sAPI *k8sinterface.KubernetesApi) *MainHandler
  • func (mainHandler *MainHandler) EventWorkerPool() *ants.PoolWithFunc
  • func (mainHandler *MainHandler) HandleCommandResponse(ctx context.Context)
  • func (mainHandler *MainHandler) HandleImageScanningScopedRequest(ctx context.Context, sessionObj *utils.SessionObj)
  • func (mainHandler *MainHandler) HandleScopedRequest(ctx context.Context, sessionObj *utils.SessionObj)
  • func (mainHandler *MainHandler) HandleSingleRequest(ctx context.Context, sessionObj *utils.SessionObj) error
  • func (mainHandler *MainHandler) HandleWatchers(ctx context.Context)
  • func (mainHandler *MainHandler) SetupContinuousScanning(ctx context.Context, queueSize int, eventCooldown time.Duration) error
  • func (h *MainHandler) StartContinuousScanning(ctx context.Context) error
  • func (mainHandler *MainHandler) StartupTriggerActions(ctx context.Context, actions []apis.Command)
• type RepositoriesAndTagsParams

Constants

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

const (
	KubescapeResponse string = "KubescapeResponse"
)

const (
	MaxLimitationInsertToCommandResponseChannelGoRoutine = 10
)

const VulnScanCronjobTemplateName = "kubevuln-cronjob-template"

Variables

var KubescapeHttpClient httputils.IHttpClient

var VulnScanHttpClient httputils.IHttpClient

Functions

func GetStartupActions

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

func HandleKubescapeResponse

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

func NewRegistryScan

func NewRegistryScan(config config.IConfig, k8sAPI *k8sinterface.KubernetesApi) registryScan

func NewRegistryScanConfig

func NewRegistryScanConfig(registryName string) *registryScanConfig

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) *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, sendReport bool, payload interface{}) (bool, *time.Duration)

type IWorkloadsGetter

type IWorkloadsGetter interface {
	GetWorkload(namespace, kind, name string) (k8sinterface.IWorkload, error)
	ListWorkloads2(namespace, kind string) ([]k8sinterface.IWorkload, error)
}

KubernetesApiSecrets is an interface for getting workloads from k8s api

type ImageScanConfig

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) *MainHandler

CreateWebSocketHandler Create ws-handler obj

func (*MainHandler) EventWorkerPool

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

func (*MainHandler) HandleCommandResponse

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

func (*MainHandler) HandleImageScanningScopedRequest

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

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

func (*MainHandler) SetupContinuousScanning

func (mainHandler *MainHandler) SetupContinuousScanning(ctx context.Context, queueSize int, eventCooldown time.Duration) error

SetupContinuousScanning sets up the continuous cluster scanning function

func (*MainHandler) StartContinuousScanning

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

func (*MainHandler) StartupTriggerActions

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

HandlePostmanRequest Parse received commands and run the command

type RepositoriesAndTagsParams

type RepositoriesAndTagsParams struct {
	CustomerGUID string                 `json:"customerGUID"`
	RegistryName string                 `json:"registryName"`
	JobID        string                 `json:"jobID"`
	Repositories []armotypes.Repository `json:"repositories"`
}