query

Documentation

Index

• Variables
• func GenerateK8sAuditQuery(clusterName string, auditKindFilter *queryutil.SetFilterParseResult, ...) string

Variables

var Task = query.NewQueryGeneratorTask(k8saudittask.K8sAuditQueryTaskID, "K8s audit logs", enum.LogTypeAudit, []string{
	gcp_task.InputClusterNameTaskID,
	gcp_task.InputKindFilterTaskID,
	gcp_task.InputNamespaceFilterTaskID,
}, func(ctx context.Context, i int, vs *task.VariableSet) ([]string, error) {
	clusterName, err := gcp_task.GetInputClusterNameFromTaskVariable(vs)
	if err != nil {
		return []string{}, err
	}
	kindFilter, err := gcp_task.GetInputKindNameFromTaskVariable(vs)
	if err != nil {
		return []string{}, err
	}
	namespaceFilter, err := gcp_task.GetInputNamespaceFilterFromTaskVariable(vs)
	if err != nil {
		return []string{}, err
	}
	return []string{GenerateK8sAuditQuery(clusterName, kindFilter, namespaceFilter)}, nil
})

Functions

func GenerateK8sAuditQuery

func GenerateK8sAuditQuery(clusterName string, auditKindFilter *queryutil.SetFilterParseResult, namespaceFilter *queryutil.SetFilterParseResult) string