ConnectStreams will continue to reboot and restart the main operations within the operator if any disconnects or errors occur.

GetClusterID returns the uid of the k8s cluster's kube-system namespace, which is used as the cluster's globally unique ID.

GetTLSConfig returns a TLS configuration.

GetTokenSource returns an OAuth2 token source.

IsRunningInCluster helps determine if the application is running inside a Kubernetes cluster.

NewAuthenticatedConnection gets a valid token and creats a connection to CloudSecure.

NewBufferedGrpcWriteSyncer returns a new BufferedGrpcWriteSyncer.

NewClientSet returns a new Kubernetes clientset based on the execution environment.

NewFalcoEventHandler creates a new HTTP handler function for processing Falco events.

NewGRPClogger will define a new zap logger with multiple writesyncs one to stdout and one for GRPC writestream.

Onboard onboards this cluster with CloudSecure using the onboarding credentials and obtains OAuth 2 credentials for this cluster.

ParseToken parses the JWT token and returns the claims.

ServerIsHealthy checks if a deadlock has occured within the threaded resource listing process.

SetUpOAuthConnection establishes a gRPC connection using OAuth credentials and logging the process.

Authenticator keeps a logger for its own methods.

BufferedGrpcWriteSyncer is a custom zap writesync that writes to a grpc stream In case stream is not connected it will buffer to memory.

CiliumFlowCollector collects flows from Cilium Hubble Relay running in this cluster.

Credentials contains attributes that are needed for onboarding.

FalcoEvent represents the network information extracted from a Falco event.

ResourceManager encapsulates components for listing and managing Kubernetes resources.