Help us shape the future of Go! Take the 2026 Go Developer Survey

mainhandler

package
v0.1.14 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 23, 2023 License: Apache-2.0 Imports: 40 Imported by: 0

Documentation

Index

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() []apis.Command

func HandleKubescapeResponse

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

func NewRegistryScan

func NewRegistryScan(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(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 ContainerData

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

ContainerData specific container data

type HandleCommandResponseCallBack

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

type MainHandler

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

func NewMainHandler

func NewMainHandler(sessionObj *chan utils.SessionObj, k8sAPI *k8sinterface.KubernetesApi) *MainHandler

CreateWebSocketHandler Create ws-handler obj

func (*MainHandler) HandleRequest

func (mainHandler *MainHandler) HandleRequest(ctx context.Context) []error

HandlePostmanRequest Parse received commands and run the command

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)

func (*MainHandler) StartupTriggerActions

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

HandlePostmanRequest Parse received commands and run the command

type RepositoriesAndTagsParams added in v0.0.66

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

Jump to

Keyboard shortcuts

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