manager

Documentation

Index

• Variables
• type Handler
  • func NewHandler(svc *Service, configsSvc *configs.Service, connectorsSvc *connectors.Service, ...) *Handler
  • func (h *Handler) Register(mux *http.ServeMux, authMidd *login.Middleware)
  • func (h *Handler) RegisterConfigDecorator(toolKey string, fn func([]entity.Config) []entity.Config)
• type Service
  • func NewService(r *repo) *Service
  • func NewServiceFromDB(db *gorm.DB) *Service
  • func (s *Service) Bootstrap(ctx context.Context, mods []job.Module) error
  • func (s *Service) GetJob(ctx context.Context, key string) (*entity.Job, error)
  • func (s *Service) GetRun(ctx context.Context, runID string) (*entity.JobRun, error)
  • func (s *Service) ListEnabledJobs(ctx context.Context) ([]entity.Job, error)
  • func (s *Service) ListJobs(ctx context.Context) ([]entity.Job, error)
  • func (s *Service) ListRuns(ctx context.Context, key string, limit int) ([]entity.JobRun, error)
  • func (s *Service) RunCron(ctx context.Context, key string) (string, error)
  • func (s *Service) RunManual(ctx context.Context, key string, userID string) (string, error)
  • func (s *Service) SetConfigReader(c cfgReader)
  • func (s *Service) UpdateSchedule(ctx context.Context, key string, schedule string, enabled bool, maxRuns int) error

Variables

var StaticFS embed.FS

Types

type Handler

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

Handler wires the /manager/* routes. Manager owns job scheduling, runtime configs for jobs and tools, and the admin surface for connector rows.

func NewHandler

func NewHandler(svc *Service, configsSvc *configs.Service, connectorsSvc *connectors.Service, tagsSvc *tags.Service, usersSvc *login.Service, tools []tool.Tool) *Handler

func (*Handler) Register

func (h *Handler) Register(mux *http.ServeMux, authMidd *login.Middleware)

Register wires /manager/* to mux. All pages require auth; admin-only actions (edits, regenerate, run) add RequireAdmin on top.

func (*Handler) RegisterConfigDecorator

func (h *Handler) RegisterConfigDecorator(toolKey string, fn func([]entity.Config) []entity.Config)

RegisterConfigDecorator registers a function that is called on the config rows for toolKey just before the manager detail page is rendered. Use it to inject dynamic Options (e.g. workspace names) into specific rows.

type Service

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

Service manages job lifecycle: bootstrap from code-defined jobs, manual/scheduled execution, and result storage.

func NewService

func NewService(r *repo) *Service

func NewServiceFromDB

func NewServiceFromDB(db *gorm.DB) *Service

NewServiceFromDB is a convenience constructor for callers that only have a *gorm.DB (e.g. the worker process and the web server).

func (*Service) Bootstrap

func (s *Service) Bootstrap(ctx context.Context, mods []job.Module) error

Bootstrap syncs code-defined jobs with the jobs table. New jobs get a row with their default cron; existing rows keep admin-managed fields. One module registration = one row.

func (*Service) GetJob

func (s *Service) GetJob(ctx context.Context, key string) (*entity.Job, error)

func (*Service) GetRun

func (s *Service) GetRun(ctx context.Context, runID string) (*entity.JobRun, error)

func (*Service) ListEnabledJobs

func (s *Service) ListEnabledJobs(ctx context.Context) ([]entity.Job, error)

func (*Service) ListJobs

func (s *Service) ListJobs(ctx context.Context) ([]entity.Job, error)

func (*Service) ListRuns

func (s *Service) ListRuns(ctx context.Context, key string, limit int) ([]entity.JobRun, error)

func (*Service) RunCron

func (s *Service) RunCron(ctx context.Context, key string) (string, error)

RunCron triggers a job run initiated by the scheduler.

func (*Service) RunManual

func (s *Service) RunManual(ctx context.Context, key string, userID string) (string, error)

RunManual triggers a job run initiated by a user. Returns the run ID.

func (*Service) SetConfigReader

func (s *Service) SetConfigReader(c cfgReader)

SetConfigReader installs the configs-service view used to build a job.Ctx on every run. Called by wick at boot after both services have been constructed. Safe to skip in tests — Run() then sees a no-op Ctx where every Cfg(...) read returns "".

func (*Service) UpdateSchedule

func (s *Service) UpdateSchedule(ctx context.Context, key string, schedule string, enabled bool, maxRuns int) error