module

package
v1.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 20, 2024 License: Apache-2.0 Imports: 37 Imported by: 4

Documentation

Index

Constants

View Source 
const (
	CLAIR_V4 = "V4"
	CLAIR_V2 = "V2"
	TRIVY_V1 = "V1"
)
View Source 
const BlobStorage = "blob-storage"
View Source 
const INSTALLER_MODULES_HELM_KEY = "installer.modules"
View Source 
const (
	MODULE_TYPE_SECURITY string = "security"
)

Variables

View Source 
var SupportedModuleNamesListFirstReleaseExcludingCicd = []string{ModuleNameArgoCd, ModuleNameSecurityClair, ModuleNameNotification, ModuleNameMonitoringGrafana}

Functions

This section is empty.

Types

type ActionResponse 

type ActionResponse struct {
	Success bool `json:"success"`
}

type BlobStorageConfig added in v0.6.0 

type BlobStorageConfig struct {
	Enabled bool `env:"BLOB_STORAGE_ENABLED" envDefault:"false"`
}

type GvkLevelFilter added in v0.6.10 

type GvkLevelFilter struct {
	Gvk                *schema.GroupVersionKind `json:"gvk"`
	ResourceIdentifier *ResourceIdentifier      `json:"filter"`
}

type ModuleActionAuditLog 

type ModuleActionAuditLog struct {
	Id         int       `sql:"id,pk"`
	ModuleName string    `sql:"module_name, notnull"`
	Action     string    `sql:"action,notnull"`
	Version    string    `sql:"version,notnull"`
	CreatedOn  time.Time `sql:"created_on,notnull"`
	CreatedBy  int32     `sql:"created_by,notnull"`
	// contains filtered or unexported fields
}

type ModuleActionAuditLogRepository 

type ModuleActionAuditLogRepository interface {
	Save(moduleActionAuditLog *ModuleActionAuditLog) error
}

type ModuleActionAuditLogRepositoryImpl 

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

func NewModuleActionAuditLogRepositoryImpl 

func NewModuleActionAuditLogRepositoryImpl(dbConnection *pg.DB) *ModuleActionAuditLogRepositoryImpl

func (ModuleActionAuditLogRepositoryImpl) Save 

func (impl ModuleActionAuditLogRepositoryImpl) Save(moduleActionAuditLog *ModuleActionAuditLog) error

type ModuleActionRequestDto 

type ModuleActionRequestDto struct {
	Action     string `json:"action,notnull" validate:"oneof=install"`
	Version    string `json:"version,notnull"`
	ModuleType string `json:"moduleType"`
}

type ModuleCacheService 

type ModuleCacheService interface {
}

type ModuleCacheServiceImpl 

type ModuleCacheServiceImpl struct {
	K8sUtil *k8s.K8sServiceImpl
	// contains filtered or unexported fields
}

func NewModuleCacheServiceImpl 

func NewModuleCacheServiceImpl(logger *zap.SugaredLogger, K8sUtil *k8s.K8sServiceImpl, moduleEnvConfig *ModuleEnvConfig, serverEnvConfig *serverEnvConfig.ServerEnvConfig,
	serverDataStore *serverDataStore.ServerDataStore, moduleRepository moduleRepo.ModuleRepository, teamService team.TeamService) (*ModuleCacheServiceImpl, error)

type ModuleConfigDto added in v0.6.0 

type ModuleConfigDto struct {
	Enabled bool `json:"enabled"`
}

type ModuleCronService 

type ModuleCronService interface {
	HandleModuleStatusIfNotInProgress(moduleName string)
}

type ModuleCronServiceImpl 

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

func NewModuleCronServiceImpl 

func NewModuleCronServiceImpl(logger *zap.SugaredLogger, moduleEnvConfig *ModuleEnvConfig, moduleRepository moduleRepo.ModuleRepository,
	serverEnvConfig *serverEnvConfig.ServerEnvConfig, helmAppService client.HelmAppService, moduleServiceHelper ModuleServiceHelper, moduleResourceStatusRepository moduleRepo.ModuleResourceStatusRepository,
	moduleDataStore *moduleDataStore.ModuleDataStore, cronLogger *cron2.CronLoggerImpl) (*ModuleCronServiceImpl, error)

func (*ModuleCronServiceImpl) HandleModuleStatusIfNotInProgress added in v0.6.10 

func (impl *ModuleCronServiceImpl) HandleModuleStatusIfNotInProgress(moduleName string)

type ModuleEnableRequestDto added in v0.6.18 

type ModuleEnableRequestDto struct {
	Version string `json:"version,notnull"`
}

type ModuleEnvConfig 

type ModuleEnvConfig struct {
	ModuleStatusHandlingCronDurationInMin int `env:"MODULE_STATUS_HANDLING_CRON_DURATION_MIN" envDefault:"3"` // default 3 minutes
}

func ParseModuleEnvConfig 

func ParseModuleEnvConfig() (*ModuleEnvConfig, error)

type ModuleInfoDto 

type ModuleInfoDto struct {
	Name                  string                     `json:"name,notnull"`
	Status                string                     `json:"status,notnull" validate:"oneof=notInstalled installed installing installFailed timeout"`
	ModuleResourcesStatus []*ModuleResourceStatusDto `json:"moduleResourcesStatus"`
	Enabled               bool                       `json:"enabled"`
	Moduletype            string                     `json:"moduleType,omitempty"`
}

type ModuleName added in v0.5.3 

type ModuleName = string
const (
	ModuleNameCicd              ModuleName = "cicd"
	ModuleNameArgoCd            ModuleName = "argo-cd"
	ModuleNameSecurityClair     ModuleName = "security.clair"
	ModuleNameNotification      ModuleName = "notifier"
	ModuleNameMonitoringGrafana ModuleName = "monitoring.grafana"
	ModuleNameSecurityTrivy     ModuleName = "security.trivy"
)

type ModuleResourceStatusDto added in v0.6.10 

type ModuleResourceStatusDto struct {
	Group         string `json:"group"`
	Version       string `json:"version"`
	Kind          string `json:"kind"`
	Name          string `json:"name"`
	HealthStatus  string `json:"healthStatus"`
	HealthMessage string `json:"healthMessage"`
}

type ModuleService 

type ModuleService interface {
	GetModuleInfo(name string) (*ModuleInfoDto, error)
	GetModuleConfig(name string) (*ModuleConfigDto, error)
	HandleModuleAction(userId int32, moduleName string, moduleActionRequest *ModuleActionRequestDto) (*ActionResponse, error)
	GetAllModuleInfo() ([]ModuleInfoDto, error)
	EnableModule(moduleName, version string) (*ActionResponse, error)
}

type ModuleServiceHelper added in v0.6.10 

type ModuleServiceHelper interface {
	GetModuleMetadata(moduleName string) ([]byte, error)
}

type ModuleServiceHelperImpl added in v0.6.10 

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

func NewModuleServiceHelperImpl added in v0.6.10 

func NewModuleServiceHelperImpl(serverEnvConfig *serverEnvConfig.ServerEnvConfig) *ModuleServiceHelperImpl

func (ModuleServiceHelperImpl) GetModuleMetadata added in v0.6.10 

func (impl ModuleServiceHelperImpl) GetModuleMetadata(moduleName string) ([]byte, error)

type ModuleServiceImpl 

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

func NewModuleServiceImpl 

func NewModuleServiceImpl(logger *zap.SugaredLogger, serverEnvConfig *serverEnvConfig.ServerEnvConfig, moduleRepository moduleRepo.ModuleRepository,
	moduleActionAuditLogRepository ModuleActionAuditLogRepository, helmAppService client.HelmAppService, serverDataStore *serverDataStore.ServerDataStore, serverCacheService server.ServerCacheService, moduleCacheService ModuleCacheService, moduleCronService ModuleCronService,
	moduleServiceHelper ModuleServiceHelper, moduleResourceStatusRepository moduleRepo.ModuleResourceStatusRepository,
	scanToolMetadataService imageScanning.ScanToolMetadataService) *ModuleServiceImpl

func (ModuleServiceImpl) EnableModule added in v0.6.18 

func (impl ModuleServiceImpl) EnableModule(moduleName, version string) (*ActionResponse, error)

func (ModuleServiceImpl) GetAllModuleInfo added in v0.6.17 

func (impl ModuleServiceImpl) GetAllModuleInfo() ([]ModuleInfoDto, error)

func (ModuleServiceImpl) GetModuleConfig added in v0.6.0 

func (impl ModuleServiceImpl) GetModuleConfig(name string) (*ModuleConfigDto, error)

func (ModuleServiceImpl) GetModuleInfo 

func (impl ModuleServiceImpl) GetModuleInfo(name string) (*ModuleInfoDto, error)

func (ModuleServiceImpl) HandleModuleAction 

func (impl ModuleServiceImpl) HandleModuleAction(userId int32, moduleName string, moduleActionRequest *ModuleActionRequestDto) (*ActionResponse, error)

type ModuleStatus 

type ModuleStatus = string
const (
	ModuleStatusNotInstalled  ModuleStatus = "notInstalled"
	ModuleStatusInstalled     ModuleStatus = "installed"
	ModuleStatusInstalling    ModuleStatus = "installing"
	ModuleStatusInstallFailed ModuleStatus = "installFailed"
	ModuleStatusTimeout       ModuleStatus = "timeout"
)

type ResourceFilter added in v0.6.10 

type ResourceFilter struct {
	GlobalFilter    *ResourceIdentifier `json:"globalFilter,omitempty"`
	GvkLevelFilters []*GvkLevelFilter   `json:"gvkLevelFilters,omitempty"`
}

type ResourceIdentifier added in v0.6.10 

type ResourceIdentifier struct {
	Labels map[string]string `json:"labels"`
}

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.