resourcehandler

Documentation

Index

• Variables
• func ConvertMapListToMeta(resourceMap []map[string]interface{}) []workloadinterface.IMetadata
• func ScanRepository(command string, branchOptional string) ([]string, error)
• type EKSProviderContext
  • func NewEKSProviderContext() *EKSProviderContext
• type EKSProviderEnvVar
  • func NewEKSProviderEnvVar() *EKSProviderEnvVar
• type EmptyCloudProvider
  • func NewEmptyCloudProvider() *EmptyCloudProvider
• type EmptySelector
  • func (es *EmptySelector) GetNamespacesSelectors(resource *schema.GroupVersionResource) []string
• type ExcludeSelector
  • func NewExcludeSelector(ns string) *ExcludeSelector
  • func (es *ExcludeSelector) GetNamespacesSelectors(resource *schema.GroupVersionResource) []string
• type FileFormat
• type FileResourceHandler
  • func NewFileResourceHandler(inputPatterns []string) *FileResourceHandler
  • func (fileHandler *FileResourceHandler) GetClusterAPIServerInfo() *version.Info
  • func (fileHandler *FileResourceHandler) GetResources(frameworks []reporthandling.Framework, designator *armotypes.PortalDesignator) (*cautils.K8SResources, map[string]workloadinterface.IMetadata, error)
• type GKEProviderContext
  • func NewGKEProviderContext() *GKEProviderContext
• type GKEProviderEnvVar
  • func NewGKEProviderEnvVar() *GKEProviderEnvVar
• type GitHubRepository
  • func NewGitHubRepository(rep string) *GitHubRepository
• type ICloudProvider
• type IFieldSelector
• type IRepository
• type IResourceHandler
• type IncludeSelector
  • func NewIncludeSelector(ns string) *IncludeSelector
  • func (is *IncludeSelector) GetNamespacesSelectors(resource *schema.GroupVersionResource) []string
• type K8sResourceHandler
  • func NewK8sResourceHandler(k8s *k8sinterface.KubernetesApi, fieldSelector IFieldSelector, ...) *K8sResourceHandler
  • func (k8sHandler *K8sResourceHandler) GetClusterAPIServerInfo() *version.Info
  • func (k8sHandler *K8sResourceHandler) GetResources(frameworks []reporthandling.Framework, designator *armotypes.PortalDesignator) (*cautils.K8SResources, map[string]workloadinterface.IMetadata, error)

Variables

var (
	KS_KUBE_CLUSTER_ENV_VAR   = "KS_KUBE_CLUSTER"
	KS_CLOUD_PROVIDER_ENV_VAR = "KS_CLOUD_PROVIDER"
	KS_CLOUD_REGION_ENV_VAR   = "KS_CLOUD_REGION"
	KS_GKE_PROJECT_ENV_VAR    = "KS_GKE_PROJECT"
)

var (
	YAML_PREFIX = []string{".yaml", ".yml"}
	JSON_PREFIX = []string{".json"}
)

Functions

func ConvertMapListToMeta

func ConvertMapListToMeta(resourceMap []map[string]interface{}) []workloadinterface.IMetadata

func ScanRepository

func ScanRepository(command string, branchOptional string) ([]string, error)

Types

type EKSProviderContext

type EKSProviderContext struct {
}

func NewEKSProviderContext

func NewEKSProviderContext() *EKSProviderContext

type EKSProviderEnvVar

type EKSProviderEnvVar struct {
}

func NewEKSProviderEnvVar

func NewEKSProviderEnvVar() *EKSProviderEnvVar

type EmptyCloudProvider

type EmptyCloudProvider struct {
}

func NewEmptyCloudProvider

func NewEmptyCloudProvider() *EmptyCloudProvider

type EmptySelector

type EmptySelector struct {
}

func (*EmptySelector) GetNamespacesSelectors

func (es *EmptySelector) GetNamespacesSelectors(resource *schema.GroupVersionResource) []string

type ExcludeSelector

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

func NewExcludeSelector

func NewExcludeSelector(ns string) *ExcludeSelector

func (*ExcludeSelector) GetNamespacesSelectors

func (es *ExcludeSelector) GetNamespacesSelectors(resource *schema.GroupVersionResource) []string

type FileFormat

type FileFormat string

const (
	YAML_FILE_FORMAT FileFormat = "yaml"
	JSON_FILE_FORMAT FileFormat = "json"
)

type FileResourceHandler

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

FileResourceHandler handle resources from files and URLs

func NewFileResourceHandler

func NewFileResourceHandler(inputPatterns []string) *FileResourceHandler

func (*FileResourceHandler) GetClusterAPIServerInfo

func (fileHandler *FileResourceHandler) GetClusterAPIServerInfo() *version.Info

func (*FileResourceHandler) GetResources

func (fileHandler *FileResourceHandler) GetResources(frameworks []reporthandling.Framework, designator *armotypes.PortalDesignator) (*cautils.K8SResources, map[string]workloadinterface.IMetadata, error)

type GKEProviderContext

type GKEProviderContext struct {
}

func NewGKEProviderContext

func NewGKEProviderContext() *GKEProviderContext

type GKEProviderEnvVar

type GKEProviderEnvVar struct {
}

func NewGKEProviderEnvVar

func NewGKEProviderEnvVar() *GKEProviderEnvVar

type GitHubRepository

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

func NewGitHubRepository

func NewGitHubRepository(rep string) *GitHubRepository

type ICloudProvider

type ICloudProvider interface {
	// contains filtered or unexported methods
}

type IFieldSelector

type IFieldSelector interface {
	GetNamespacesSelectors(*schema.GroupVersionResource) []string
}

type IRepository

type IRepository interface {
	// contains filtered or unexported methods
}

type IResourceHandler

type IResourceHandler interface {
	GetResources([]reporthandling.Framework, *armotypes.PortalDesignator) (*cautils.K8SResources, map[string]workloadinterface.IMetadata, error)
	GetClusterAPIServerInfo() *version.Info
}

type IncludeSelector

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

func NewIncludeSelector

func NewIncludeSelector(ns string) *IncludeSelector

func (*IncludeSelector) GetNamespacesSelectors

func (is *IncludeSelector) GetNamespacesSelectors(resource *schema.GroupVersionResource) []string

type K8sResourceHandler

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

func NewK8sResourceHandler

func NewK8sResourceHandler(k8s *k8sinterface.KubernetesApi, fieldSelector IFieldSelector, hostSensorHandler hostsensorutils.IHostSensor, rbacObjects *cautils.RBACObjects) *K8sResourceHandler

func (*K8sResourceHandler) GetClusterAPIServerInfo

func (k8sHandler *K8sResourceHandler) GetClusterAPIServerInfo() *version.Info

func (*K8sResourceHandler) GetResources

func (k8sHandler *K8sResourceHandler) GetResources(frameworks []reporthandling.Framework, designator *armotypes.PortalDesignator) (*cautils.K8SResources, map[string]workloadinterface.IMetadata, error)