cronjob

Documentation

Index

• type CronJobFiredPayload
• type JobStatus
• type OrchestratorClient
• type Service
  • func NewService(orchestrator OrchestratorClient, workDir string, logger *slog.Logger) *Service
  • func (s *Service) ListJobs() []JobStatus
  • func (s *Service) Reload(cfg config.CronJobsConfig) error
  • func (s *Service) RunNow(ctx context.Context, name string) (*mesnadamodels.Task, error)
  • func (s *Service) Start(ctx context.Context, cfg config.CronJobsConfig) error
  • func (s *Service) Stop()
  • func (s *Service) Subscribe(ctx context.Context) <-chan pubsub.Event[CronJobFiredPayload]

Types

type CronJobFiredPayload

type CronJobFiredPayload struct {
	JobName string
	TaskID  string
}

CronJobFiredPayload is published via pubsub whenever a scheduled or manual cronjob dispatch succeeds and a Mesnada task has been created.

type JobStatus

type JobStatus struct {
	config.CronJob
	NextRun time.Time `json:"nextRun,omitempty"`
}

type OrchestratorClient

type OrchestratorClient interface {
	Spawn(ctx context.Context, req mesnadamodels.SpawnRequest) (*mesnadamodels.Task, error)
	ListTasks(req mesnadamodels.ListRequest) ([]*mesnadamodels.Task, error)
}

type Service

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

func NewService

func NewService(orchestrator OrchestratorClient, workDir string, logger *slog.Logger) *Service

func (*Service) ListJobs

func (s *Service) ListJobs() []JobStatus

func (*Service) Reload

func (s *Service) Reload(cfg config.CronJobsConfig) error

func (*Service) RunNow

func (s *Service) RunNow(ctx context.Context, name string) (*mesnadamodels.Task, error)

func (*Service) Start

func (s *Service) Start(ctx context.Context, cfg config.CronJobsConfig) error

func (*Service) Stop

func (s *Service) Stop()

func (*Service) Subscribe

func (s *Service) Subscribe(ctx context.Context) <-chan pubsub.Event[CronJobFiredPayload]

Subscribe returns a channel that emits CronJobFiredPayload events whenever a cronjob dispatch succeeds. The channel is closed when ctx is cancelled.