Help us shape the future of Go! Take the 2026 Go Developer Survey

module

package
v0.6.9 Latest Latest
Warning

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

Go to latest
Published: Dec 14, 2022 License: Apache-2.0 Imports: 30 Imported by: 4

Documentation

Index

Constants

View Source
const BlobStorage = "blob-storage"
View Source
const INSTALLER_MODULES_HELM_KEY = "installer.modules"

Variables

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 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 added in v0.6.0

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 added in v0.5.3

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

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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL