monitor

package
v5.0.0-alpha.1 Latest Latest
Warning

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

Go to latest
Published: Feb 14, 2026 License: MIT Imports: 11 Imported by: 0

Documentation

Index

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

func (*Service) IsRunning

func (s *Service) IsRunning() bool

IsRunning returns whether the status monitor is running

func (*Service) Start

func (s *Service) Start() error

Start starts the status monitor goroutine

func (*Service) Stop

func (s *Service) Stop()

Stop stops the status monitor

func (*Service) ValidateHypertables

func (s *Service) ValidateHypertables(tables map[string][]string) error

ValidateHypertables validates and creates TimescaleDB hypertables

Jump to

Keyboard shortcuts

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