module

Documentation

Index

• type ModuleActionAuditLog
• type ModuleActionAuditLogRepository
• type ModuleActionAuditLogRepositoryImpl
  • func NewModuleActionAuditLogRepositoryImpl(dbConnection *pg.DB) *ModuleActionAuditLogRepositoryImpl
  • func (impl ModuleActionAuditLogRepositoryImpl) Save(moduleActionAuditLog *ModuleActionAuditLog) error
• type ModuleCacheService
• type ModuleCacheServiceImpl
  • func NewModuleCacheServiceImpl(logger *zap.SugaredLogger, K8sUtil *k8s.K8sServiceImpl, ...) (*ModuleCacheServiceImpl, error)
• type ModuleCronService
• type ModuleCronServiceImpl
  • func NewModuleCronServiceImpl(logger *zap.SugaredLogger, moduleEnvConfig *bean2.ModuleEnvConfig, ...) (*ModuleCronServiceImpl, error)
  • func (impl *ModuleCronServiceImpl) HandleModuleStatusIfNotInProgress(moduleName string)
• type ModuleService
• type ModuleServiceHelper
• type ModuleServiceHelperImpl
  • func NewModuleServiceHelperImpl(serverEnvConfig *serverEnvConfig.ServerEnvConfig) *ModuleServiceHelperImpl
  • func (impl ModuleServiceHelperImpl) GetModuleMetadata(moduleName string) ([]byte, error)
• type ModuleServiceImpl
  • func NewModuleServiceImpl(logger *zap.SugaredLogger, serverEnvConfig *serverEnvConfig.ServerEnvConfig, ...) *ModuleServiceImpl
  • func (impl ModuleServiceImpl) EnableModule(moduleName, version string) (*bean.ActionResponse, error)
  • func (impl ModuleServiceImpl) GetAllModuleInfo() ([]bean.ModuleInfoDto, error)
  • func (impl ModuleServiceImpl) GetModuleConfig(name string) (*bean.ModuleConfigDto, error)
  • func (impl ModuleServiceImpl) GetModuleInfo(name string) (*bean.ModuleInfoDto, error)
  • func (impl ModuleServiceImpl) HandleModuleAction(userId int32, moduleName string, ...) (*bean.ActionResponse, error)

Types

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 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 *bean.ModuleEnvConfig, serverEnvConfig *serverEnvConfig.ServerEnvConfig,
	serverDataStore *serverDataStore.ServerDataStore, moduleRepository moduleRepo.ModuleRepository, teamService team.TeamService) (*ModuleCacheServiceImpl, error)

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 *bean2.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

func (impl *ModuleCronServiceImpl) HandleModuleStatusIfNotInProgress(moduleName string)

type ModuleService

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

type ModuleServiceHelper

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

type ModuleServiceHelperImpl

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

func NewModuleServiceHelperImpl

func NewModuleServiceHelperImpl(serverEnvConfig *serverEnvConfig.ServerEnvConfig) *ModuleServiceHelperImpl

func (ModuleServiceHelperImpl) GetModuleMetadata

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 scanTool.ScanToolMetadataService) *ModuleServiceImpl

func (ModuleServiceImpl) EnableModule

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

func (ModuleServiceImpl) GetAllModuleInfo

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

func (ModuleServiceImpl) GetModuleConfig

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

func (ModuleServiceImpl) GetModuleInfo

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

func (ModuleServiceImpl) HandleModuleAction

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