monitor

package

Go to main page

Versions in this module

v1

v1.0.1

Apr 12, 2026

v0

v0.1.8

Apr 22, 2026

v0.1.7

Apr 22, 2026

v0.1.6

Apr 22, 2026

v0.1.5

Apr 19, 2026

v0.1.4

Apr 19, 2026

v0.1.3

Apr 19, 2026

v0.1.2

Apr 19, 2026

Changes in this version

type Handler

+ func (h *Handler) DeleteMonitor(w http.ResponseWriter, r *http.Request)

type Repository

+ func (r *Repository) Delete(ctx context.Context, userID, monitorID uuid.UUID) error

type Service

+ func (s *Service) DeleteMonitor(ctx context.Context, userID, monitorID uuid.UUID) error

type UserService

+ DecrementMonitorCount func(ctx context.Context, userID uuid.UUID) error

v0.1.1

Apr 18, 2026

v0.1.0

Apr 18, 2026

Changes in this version

+ func Routes(h *Handler) chi.Router

+ type Cache interface

+ ClearIncident func(ctx context.Context, monitorID uuid.UUID) error

+ DelMonitor func(ctx context.Context, id uuid.UUID) error

+ DelSchedule func(ctx context.Context, monitorID string) error

+ DelStatus func(ctx context.Context, monitorID uuid.UUID) error

+ GetMonitor func(ctx context.Context, id uuid.UUID) (Monitor, bool)

+ Schedule func(ctx context.Context, monitorID string, runAt time.Time) error

+ SetMonitor func(ctx context.Context, m Monitor) error

+ type CreateMonitor struct

+ AlertEmail string

+ ExpectedStatus *int32

+ IntervalSec int32

+ LatencyThresholdMs *int32

+ TimeoutSec int32

+ Url string

+ UserID uuid.UUID

+ type CreateMonitorRequest struct

+ AlertEmail string

+ ExpectedStatus *int32

+ IntervalSec int32

+ LatencyThresholdMs *int32

+ TimeoutSec int32

+ Url string

+ type CreateMonitorResponse struct

+ MonitorID string

+ type GetAllMonitorsResponse struct

+ Limit int32

+ Monitors []GetMonitorResponse

+ Offset int32

+ UserID string

+ type GetMonitorResponse struct

+ AlertEmail string

+ Enabled bool

+ ExpectedStatus *int32

+ ID string

+ IntervalSec int32

+ LatencyThresholdMs *int32

+ TimeoutSec int32

+ Url string

+ type Handler struct

+ func NewHandler(service *Service, validator *validator.Validate, logger *zerolog.Logger) *Handler

+ func (h *Handler) CreateMonitor(w http.ResponseWriter, r *http.Request)

+ func (h *Handler) GetAllMonitors(w http.ResponseWriter, r *http.Request)

+ func (h *Handler) GetMonitor(w http.ResponseWriter, r *http.Request)

+ func (h *Handler) UpdateMonitorStatus(w http.ResponseWriter, r *http.Request)

+ type Monitor struct

+ AlertEmail string

+ Enabled bool

+ ExpectedStatus *int32

+ ID uuid.UUID

+ IntervalSec int32

+ LatencyThresholdMs *int32

+ TimeoutSec int32

+ Url string

+ UserID uuid.UUID

+ type MonitorRecord struct

+ Disabled bool

+ Enabled bool

+ ExpectedStatus int

+ ID uuid.UUID

+ IntervalSec time.Duration

+ LatencyThresholdMS time.Duration

+ TimeoutSec time.Duration

+ Url string

+ UserID uuid.UUID

+ type Repository struct

+ func NewRepository(dbExecutor db.DBTX, logger *zerolog.Logger) *Repository

+ func (r *Repository) Create(ctx context.Context, monitor CreateMonitor) (uuid.UUID, error)

+ func (r *Repository) Get(ctx context.Context, userID, monitorID uuid.UUID) (Monitor, error)

+ func (r *Repository) GetAll(ctx context.Context, userID uuid.UUID, limit int32, offset int32) ([]Monitor, error)

+ func (r *Repository) GetByID(ctx context.Context, monitorID uuid.UUID) (Monitor, error)

+ func (r *Repository) SetEnabled(ctx context.Context, userID, monitorID uuid.UUID, enabled bool) error

+ type Service struct

+ func NewService(monitorRepo *Repository, cache Cache, userSvc UserService, ...) *Service

+ func (s *Service) CreateMonitor(ctx context.Context, data CreateMonitor) (uuid.UUID, error)

+ func (s *Service) GetAllMonitors(ctx context.Context, userID uuid.UUID, limit int32, offset int32) ([]Monitor, error)

+ func (s *Service) GetMonitor(ctx context.Context, userID uuid.UUID, monitorID uuid.UUID) (Monitor, error)

+ func (s *Service) LoadMonitor(ctx context.Context, monitorID uuid.UUID) (Monitor, error)

+ func (s *Service) ScheduleMonitor(ctx context.Context, mID uuid.UUID, intervalSec int32, op string)

+ func (s *Service) UpdateMonitorStatus(ctx context.Context, userID, monitorID uuid.UUID, enable bool) (bool, error)

+ type UpdateMonitorStatusRequest struct

+ Enable *bool

+ type UserService interface

+ IncrementMonitorCount func(ctx context.Context, userID uuid.UUID) error

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