watch

May 28, 2023

Changes in this version

+ type InstallationData struct

+ ClusterName string

+ ImageVulnerabilitiesScanningEnabled bool

+ Namespace string

+ OtelCollectorEnabled bool

+ PostureScanEnabled bool

+ RelevantImageVulnerabilitiesEnabled bool

+ StorageEnabled bool

Feb 27, 2023

Changes in this version

+ var FirstReportEmptyBytes = []byte("{\"firstReport\":true}")

+ var FirstReportEmptyLength = len(FirstReportEmptyBytes)

Jan 4, 2023

Changes in this version

+ const WaitBeforeReportEnv

Aug 11, 2022

Changes in this version

+ const EventReceiverWebsocketPath

Aug 10, 2022

Changes in this version

+ func Clone(src, dst interface{}) error

+ func CreateID() int

+ func DeepCopy(src, dst interface{}) error

+ func DeepCopyObj(src, dst interface{}) error

+ func DeleteID(id int)

+ func GetOwnerData(name string, kind string, apiVersion string, namespace string, ...) interface

+ func HashByteArray(text []byte) []byte

+ func IDCreator() int

+ func IsPodExist(pod *core.Pod, pdm map[int]*list.List) bool

+ func IsPodSpecAlreadyExist(podOwner *OwnerDet, namespace, armoStatus, newArmoAttached string, ...) (int, int)

+ func RemoveNode(node *core.Node, ndm map[int]*list.List) string

+ func WaitTillNewDataArrived(wh *WatchHandler) bool

+ type CRDOwnerData struct

+ type DataSocket struct

+ RType ReqType

+ type IDDataBase struct

+ Ids *list.List

+ Mutex sync.RWMutex

+ type JsonType int

+ const MICROSERVICES

+ const NAMESPACES

+ const NODE

+ const PODS

+ const SECRETS

+ const SERVICES

+ type MicroServiceData struct

+ Owner OwnerDet

+ PodSpecId int

+ type NodeData struct

+ Name string

+ func UpdateNode(node *core.Node, ndm map[int]*list.List) *NodeData

+ func (updateNode *NodeData) UpdateNodeData(node *core.Node)

+ type ObjectData struct

+ Created []interface{}

+ Deleted []interface{}

+ Updated []interface{}

+ func (obj *ObjectData) AddToJsonFormatByState(NewData interface{}, stype StateType)

+ func (obj *ObjectData) Len() int

+ type OwnerDet struct

+ Kind string

+ Name string

+ OwnerData interface{}

+ func GetAncestorFromLocalPodsList(pod *core.Pod, wh *WatchHandler) (*OwnerDet, error)

+ func GetAncestorOfPod(pod *core.Pod, wh *WatchHandler) (OwnerDet, error)

+ type OwnerDetNameAndKindOnly struct

+ Kind string

+ Name string

+ type PodDataForExistMicroService struct

+ CreationTimestamp string

+ DeletionTimestamp string

+ Namespace string

+ NodeName string

+ Owner OwnerDetNameAndKindOnly

+ PodIP string

+ PodName string

+ PodStatus string

+ type ReqType int

+ const EXIT

+ const MESSAGE

+ const PING

+ type ScanNewImageData struct

+ Owner *OwnerDet

+ Pod *core.Pod

+ PodsNumber int

+ type StateType int

+ const CREATED

+ const DELETED

+ const UPDATED

+ type WatchHandler struct

+ K8sApi *k8sinterface.KubernetesApi

+ RestAPIClient kubernetes.Interface

+ WebSocketHandle *WebSocketHandler

+ func CreateWatchHandler() (*WatchHandler, error)

+ func (wh *WatchHandler) CronJobWatch()

+ func (wh *WatchHandler) DeletePod(pod *core.Pod, podName string)

+ func (wh *WatchHandler) ListenerAndSender()

+ func (wh *WatchHandler) NamespaceEventHandler(event *watch.Event, lastWatchEventCreationTime time.Time) error

+ func (wh *WatchHandler) NamespaceWatch()

+ func (wh *WatchHandler) NodeWatch()

+ func (wh *WatchHandler) PodWatch()

+ func (wh *WatchHandler) RemoveNamespace(namespace *corev1.Namespace) string

+ func (wh *WatchHandler) RemovePod(pod *core.Pod, pdm map[int]*list.List) (int, bool, OwnerDet)

+ func (wh *WatchHandler) SecretWatch()

+ func (wh *WatchHandler) SendMessageToWebSocket(jsonData []byte)

+ func (wh *WatchHandler) ServiceWatch()

+ func (wh *WatchHandler) SetFirstReportFlag(first bool)

+ func (wh *WatchHandler) UpdateNamespace(namespace *corev1.Namespace)

+ type WebSocketHandler struct

+ SignalChan chan os.Signal

+ func (wsh *WebSocketHandler) SendReportRoutine(isServerReady *bool, reconnectCallback func(bool)) error