Documentation
¶
Index ¶
- type Dependencies
- type Service
- func (s *Service) GetProgramStatus(rawBuffers bool, writeQueues bool, lastWrite bool) (output []string, perfModel model.OcapPerformance)
- func (s *Service) IsRunning() bool
- func (s *Service) Start() error
- func (s *Service) Stop()
- func (s *Service) ValidateHypertables(tables map[string][]string) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Dependencies ¶
type Dependencies struct {
DB *gorm.DB
LogManager *logging.SlogManager
HandlerService *handlers.Service
WorkerManager *worker.Manager
Queues *worker.Queues
AddonFolder string
IsDatabaseValid func() bool
}
Dependencies holds all dependencies for the monitor service
type Service ¶
type Service struct {
// contains filtered or unexported fields
}
Service manages status monitoring
func NewService ¶
func NewService(deps Dependencies) *Service
NewService creates a new monitor service
func (*Service) GetProgramStatus ¶
func (s *Service) GetProgramStatus( rawBuffers bool, writeQueues bool, lastWrite bool, ) (output []string, perfModel model.OcapPerformance)
GetProgramStatus returns the current program status
Click to show internal directories.
Click to hide internal directories.