module

Documentation

Index

• Constants
• Variables
• type ActionResponse
• type BlobStorageConfig
• type ModuleActionAuditLog
• type ModuleActionAuditLogRepository
• type ModuleActionAuditLogRepositoryImpl
  • func NewModuleActionAuditLogRepositoryImpl(dbConnection *pg.DB) *ModuleActionAuditLogRepositoryImpl
  • func (impl ModuleActionAuditLogRepositoryImpl) Save(moduleActionAuditLog *ModuleActionAuditLog) error
• type ModuleActionRequestDto
• type ModuleCacheService
• type ModuleCacheServiceImpl
  • func NewModuleCacheServiceImpl(logger *zap.SugaredLogger, K8sUtil *util.K8sUtil, ...) *ModuleCacheServiceImpl
• type ModuleConfigDto
• type ModuleCronService
• type ModuleCronServiceImpl
  • func NewModuleCronServiceImpl(logger *zap.SugaredLogger, moduleEnvConfig *ModuleEnvConfig, ...) (*ModuleCronServiceImpl, error)
  • func (impl *ModuleCronServiceImpl) HandleModuleStatus()
• type ModuleEnvConfig
  • func ParseModuleEnvConfig() (*ModuleEnvConfig, error)
• type ModuleInfoDto
• type ModuleName
• type ModuleService
• type ModuleServiceImpl
  • func NewModuleServiceImpl(logger *zap.SugaredLogger, serverEnvConfig *serverEnvConfig.ServerEnvConfig, ...) *ModuleServiceImpl
  • func (impl ModuleServiceImpl) GetModuleConfig(name string) (*ModuleConfigDto, error)
  • func (impl ModuleServiceImpl) GetModuleInfo(name string) (*ModuleInfoDto, error)
  • func (impl ModuleServiceImpl) HandleModuleAction(userId int32, moduleName string, moduleActionRequest *ModuleActionRequestDto) (*ActionResponse, error)
• type ModuleStatus

Constants

const BlobStorage = "blob-storage"

const INSTALLER_MODULES_HELM_KEY = "installer.modules"

Variables

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

Types

type ActionResponse

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

type BlobStorageConfig

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

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"`
}

type ModuleCacheService

type ModuleCacheService interface {
}

type ModuleCacheServiceImpl

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

func NewModuleCacheServiceImpl

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

type ModuleConfigDto

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

type ModuleCronService

type ModuleCronService interface {
}

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) (*ModuleCronServiceImpl, error)

func (*ModuleCronServiceImpl) HandleModuleStatus

func (impl *ModuleCronServiceImpl) HandleModuleStatus()

check modules from DB. if status is installing for 1 hour, mark it as timeout if status is installing and helm release is healthy then mark as installed

type ModuleEnvConfig

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

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"`
}

type ModuleName

type ModuleName = string

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

type ModuleService

type ModuleService interface {
	GetModuleInfo(name string) (*ModuleInfoDto, error)
	GetModuleConfig(name string) (*ModuleConfigDto, error)
	HandleModuleAction(userId int32, moduleName string, moduleActionRequest *ModuleActionRequestDto) (*ActionResponse, 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) *ModuleServiceImpl

func (ModuleServiceImpl) GetModuleConfig

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"
)