servicesInfra

Documentation

Index

• Constants
• type ServicesCmdRepo
  • func NewServicesCmdRepo(persistentDbSvc *internalDbInfra.PersistentDatabaseService) *ServicesCmdRepo
  • func (repo *ServicesCmdRepo) CreateCustom(createDto dto.CreateCustomService) error
  • func (repo *ServicesCmdRepo) CreateInstallable(createDto dto.CreateInstallableService) (installedServiceName valueObject.ServiceName, err error)
  • func (repo *ServicesCmdRepo) Delete(name valueObject.ServiceName) error
  • func (repo *ServicesCmdRepo) Restart(name valueObject.ServiceName) error
  • func (repo *ServicesCmdRepo) Start(name valueObject.ServiceName) error
  • func (repo *ServicesCmdRepo) Stop(name valueObject.ServiceName) error
  • func (repo *ServicesCmdRepo) Update(updateDto dto.UpdateService) error
• type ServicesQueryRepo
  • func NewServicesQueryRepo(persistentDbSvc *internalDbInfra.PersistentDatabaseService) *ServicesQueryRepo
  • func (repo *ServicesQueryRepo) Read() ([]entity.InstalledService, error)
  • func (repo *ServicesQueryRepo) ReadByName(name valueObject.ServiceName) (serviceEntity entity.InstalledService, err error)
  • func (repo *ServicesQueryRepo) ReadInstallableByName(serviceName valueObject.ServiceName) (installableService entity.InstallableService, err error)
  • func (repo *ServicesQueryRepo) ReadInstallables() ([]entity.InstallableService, error)
  • func (repo *ServicesQueryRepo) ReadWithMetrics() ([]dto.InstalledServiceWithMetrics, error)

Constants

const SupervisorCtlBin string = "/usr/bin/supervisorctl -c /infinite/supervisord.conf"

Types

type ServicesCmdRepo

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

func NewServicesCmdRepo

func NewServicesCmdRepo(
	persistentDbSvc *internalDbInfra.PersistentDatabaseService,
) *ServicesCmdRepo

func (*ServicesCmdRepo) CreateCustom

func (repo *ServicesCmdRepo) CreateCustom(createDto dto.CreateCustomService) error

func (*ServicesCmdRepo) CreateInstallable

func (repo *ServicesCmdRepo) CreateInstallable(
	createDto dto.CreateInstallableService,
) (installedServiceName valueObject.ServiceName, err error)

func (*ServicesCmdRepo) Delete

func (repo *ServicesCmdRepo) Delete(name valueObject.ServiceName) error

func (*ServicesCmdRepo) Restart

func (repo *ServicesCmdRepo) Restart(name valueObject.ServiceName) error

func (*ServicesCmdRepo) Start

func (repo *ServicesCmdRepo) Start(name valueObject.ServiceName) error

func (*ServicesCmdRepo) Stop

func (repo *ServicesCmdRepo) Stop(name valueObject.ServiceName) error

func (*ServicesCmdRepo) Update

func (repo *ServicesCmdRepo) Update(updateDto dto.UpdateService) error

type ServicesQueryRepo

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

func NewServicesQueryRepo

func NewServicesQueryRepo(
	persistentDbSvc *internalDbInfra.PersistentDatabaseService,
) *ServicesQueryRepo

func (*ServicesQueryRepo) Read

func (repo *ServicesQueryRepo) Read() ([]entity.InstalledService, error)

func (*ServicesQueryRepo) ReadByName

func (repo *ServicesQueryRepo) ReadByName(
	name valueObject.ServiceName,
) (serviceEntity entity.InstalledService, err error)

func (*ServicesQueryRepo) ReadInstallableByName

func (repo *ServicesQueryRepo) ReadInstallableByName(
	serviceName valueObject.ServiceName,
) (installableService entity.InstallableService, err error)

func (*ServicesQueryRepo) ReadInstallables

func (repo *ServicesQueryRepo) ReadInstallables() ([]entity.InstallableService, error)

func (*ServicesQueryRepo) ReadWithMetrics

func (repo *ServicesQueryRepo) ReadWithMetrics() ([]dto.InstalledServiceWithMetrics, error)