inspect

Documentation

Index

• Variables
• func CalculateScore(fmResultss []kubeeyev1alpha2.ResourceResult, k8sResources kube.K8SResource) (scoreInfo kubeeyev1alpha2.ScoreInfo)
• func GetCpu(fs procfs.FS) map[string]interface{}
• func GetFileSystem(p string) map[string]interface{}
• func GetInodes(p string) map[string]interface{}
• func GetInspectComponent(ctx context.Context, clients *kube.KubernetesClient, ...) (map[string]kubeeyev1alpha2.ServiceConnectRule, error)
• func GetLoadAvg(fs procfs.FS) map[string]interface{}
• func GetMemory(fs procfs.FS) map[string]interface{}
• func GetNameSpacesForWorkSpace(ctx context.Context, clients *kube.KubernetesClient, workspace string) []corev1.Namespace
• func GetServices(services []corev1.Service, name string) (corev1.Service, bool)
• func GetServicesForNameSpace(services []corev1.Service, namespace string) []corev1.Service
• func MergeRegoRulesValidate(ctx context.Context, regoRulesChan []string, vfuncs ...validateFunc) <-chan []v1alpha2.ResourceResult
• func RegoRulesValidate(queryRule string, Resources kube.K8SResource, auditPercent *PercentOutput) validateFunc
• func VailOpaRulesResult(ctx context.Context, k8sResources kube.K8SResource, RegoRules []string) v1alpha2.KubeeyeOpaResult
• type OpaInspect
  • func (o *OpaInspect) GetResult(runNodeName string, resultCm *corev1.ConfigMap, ...) (*kubeeyev1alpha2.InspectResult, error)
  • func (o *OpaInspect) RunInspect(ctx context.Context, rules []kubeeyev1alpha2.JobRule, ...) ([]byte, error)
• type OutputType
• type PercentOutput

Variables

var RuleOperatorMap = make(map[string]options.InspectInterface)

Functions

func CalculateScore

func CalculateScore(fmResultss []kubeeyev1alpha2.ResourceResult, k8sResources kube.K8SResource) (scoreInfo kubeeyev1alpha2.ScoreInfo)

func GetCpu

func GetCpu(fs procfs.FS) map[string]interface{}

func GetFileSystem

func GetFileSystem(p string) map[string]interface{}

func GetInodes

func GetInodes(p string) map[string]interface{}

func GetInspectComponent

func GetInspectComponent(ctx context.Context, clients *kube.KubernetesClient, serviceConnectRule []kubeeyev1alpha2.ServiceConnectRule) (map[string]kubeeyev1alpha2.ServiceConnectRule, error)

func GetLoadAvg

func GetLoadAvg(fs procfs.FS) map[string]interface{}

func GetMemory

func GetMemory(fs procfs.FS) map[string]interface{}

func GetNameSpacesForWorkSpace

func GetNameSpacesForWorkSpace(ctx context.Context, clients *kube.KubernetesClient, workspace string) []corev1.Namespace

func GetServices

func GetServices(services []corev1.Service, name string) (corev1.Service, bool)

func GetServicesForNameSpace

func GetServicesForNameSpace(services []corev1.Service, namespace string) []corev1.Service

func MergeRegoRulesValidate

func MergeRegoRulesValidate(ctx context.Context, regoRulesChan []string, vfuncs ...validateFunc) <-chan []v1alpha2.ResourceResult

MergeRegoRulesValidate Validate kubernetes cluster Resources, put the results into channels.

func RegoRulesValidate

func RegoRulesValidate(queryRule string, Resources kube.K8SResource, auditPercent *PercentOutput) validateFunc

func VailOpaRulesResult

func VailOpaRulesResult(ctx context.Context, k8sResources kube.K8SResource, RegoRules []string) v1alpha2.KubeeyeOpaResult

Types

type OpaInspect

type OpaInspect struct {
}

func (*OpaInspect) GetResult

func (o *OpaInspect) GetResult(runNodeName string, resultCm *corev1.ConfigMap, resultCr *kubeeyev1alpha2.InspectResult) (*kubeeyev1alpha2.InspectResult, error)

func (*OpaInspect) RunInspect

func (o *OpaInspect) RunInspect(ctx context.Context, rules []kubeeyev1alpha2.JobRule, clients *kube.KubernetesClient, currentJobName string, informers informers.SharedInformerFactory, ownerRef ...metav1.OwnerReference) ([]byte, error)

type OutputType

type OutputType string

type PercentOutput

type PercentOutput struct {
	TotalAuditCount   int
	CurrentAuditCount int
	AuditPercent      int
}