moduleRepo

Documentation

Index

• type Module
• type ModuleRepository
• type ModuleRepositoryImpl
  • func NewModuleRepositoryImpl(dbConnection *pg.DB) *ModuleRepositoryImpl
  • func (impl ModuleRepositoryImpl) FindAll() ([]Module, error)
  • func (impl ModuleRepositoryImpl) FindAllByStatus(status string) ([]Module, error)
  • func (impl ModuleRepositoryImpl) FindOne(name string) (*Module, error)
  • func (impl ModuleRepositoryImpl) GetInstalledModuleNames() ([]string, error)
  • func (impl ModuleRepositoryImpl) ModuleExists() (bool, error)
  • func (impl ModuleRepositoryImpl) Save(module *Module) error
  • func (impl ModuleRepositoryImpl) Update(module *Module) error
• type ModuleResourceStatus
• type ModuleResourceStatusRepository
• type ModuleResourceStatusRepositoryImpl
  • func NewModuleResourceStatusRepositoryImpl(dbConnection *pg.DB) *ModuleResourceStatusRepositoryImpl
  • func (impl ModuleResourceStatusRepositoryImpl) FindAllActiveByModuleId(moduleId int) ([]*ModuleResourceStatus, error)
  • func (impl ModuleResourceStatusRepositoryImpl) GetConnection() *pg.DB
  • func (impl ModuleResourceStatusRepositoryImpl) Save(statuses []*ModuleResourceStatus, tx *pg.Tx) error
  • func (impl ModuleResourceStatusRepositoryImpl) Update(status *ModuleResourceStatus, tx *pg.Tx) error

Types

type Module

type Module struct {
	Id        int       `sql:"id,pk"`
	Name      string    `sql:"name, notnull"`
	Version   string    `sql:"version, notnull"`
	Status    string    `sql:"status,notnull"`
	UpdatedOn time.Time `sql:"updated_on"`
	// contains filtered or unexported fields
}

type ModuleRepository

type ModuleRepository interface {
	Save(module *Module) error
	FindOne(name string) (*Module, error)
	Update(module *Module) error
	FindAll() ([]Module, error)
	ModuleExists() (bool, error)
	GetInstalledModuleNames() ([]string, error)
}

type ModuleRepositoryImpl

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

func NewModuleRepositoryImpl

func NewModuleRepositoryImpl(dbConnection *pg.DB) *ModuleRepositoryImpl

func (ModuleRepositoryImpl) FindAll

func (impl ModuleRepositoryImpl) FindAll() ([]Module, error)

func (ModuleRepositoryImpl) FindAllByStatus

func (impl ModuleRepositoryImpl) FindAllByStatus(status string) ([]Module, error)

func (ModuleRepositoryImpl) FindOne

func (impl ModuleRepositoryImpl) FindOne(name string) (*Module, error)

func (ModuleRepositoryImpl) GetInstalledModuleNames

func (impl ModuleRepositoryImpl) GetInstalledModuleNames() ([]string, error)

func (ModuleRepositoryImpl) ModuleExists

func (impl ModuleRepositoryImpl) ModuleExists() (bool, error)

func (ModuleRepositoryImpl) Save

func (impl ModuleRepositoryImpl) Save(module *Module) error

func (ModuleRepositoryImpl) Update

func (impl ModuleRepositoryImpl) Update(module *Module) error

type ModuleResourceStatus

type ModuleResourceStatus struct {
	Id            int       `sql:"id,pk"`
	ModuleId      int       `sql:"module_id,notnull"`
	Group         string    `sql:"group, notnull"`
	Version       string    `sql:"version, notnull"`
	Kind          string    `sql:"kind, notnull"`
	Name          string    `sql:"name, notnull"`
	HealthStatus  string    `sql:"health_status"`
	HealthMessage string    `sql:"health_message"`
	Active        bool      `sql:"active"`
	CreatedOn     time.Time `sql:"created_on, notnull"`
	UpdatedOn     time.Time `sql:"updated_on"`
	// contains filtered or unexported fields
}

type ModuleResourceStatusRepository

type ModuleResourceStatusRepository interface {
	GetConnection() *pg.DB
	FindAllActiveByModuleId(moduleId int) ([]*ModuleResourceStatus, error)
	Update(status *ModuleResourceStatus, tx *pg.Tx) error
	Save(statuses []*ModuleResourceStatus, tx *pg.Tx) error
}

type ModuleResourceStatusRepositoryImpl

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

func NewModuleResourceStatusRepositoryImpl

func NewModuleResourceStatusRepositoryImpl(dbConnection *pg.DB) *ModuleResourceStatusRepositoryImpl

func (ModuleResourceStatusRepositoryImpl) FindAllActiveByModuleId

func (impl ModuleResourceStatusRepositoryImpl) FindAllActiveByModuleId(moduleId int) ([]*ModuleResourceStatus, error)

func (ModuleResourceStatusRepositoryImpl) GetConnection

func (impl ModuleResourceStatusRepositoryImpl) GetConnection() *pg.DB

func (ModuleResourceStatusRepositoryImpl) Save

func (impl ModuleResourceStatusRepositoryImpl) Save(statuses []*ModuleResourceStatus, tx *pg.Tx) error

func (ModuleResourceStatusRepositoryImpl) Update

func (impl ModuleResourceStatusRepositoryImpl) Update(status *ModuleResourceStatus, tx *pg.Tx) error