schedule

Documentation

Overview

Package schedule provides cron-based scheduling for sync operations

Index

• func ValidateSpec(spec string) error
• type Scheduler
  • func New(spec string, syncFn SyncFunc) (*Scheduler, error)
  • func (s *Scheduler) Run(ctx context.Context) error
• type SyncFunc

Functions

func ValidateSpec

func ValidateSpec(spec string) error

ValidateSpec validates a cron expression

Types

type Scheduler

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

Scheduler manages cron-based sync execution

func New

func New(spec string, syncFn SyncFunc) (*Scheduler, error)

New creates a new Scheduler. Returns an error if the cron spec is invalid.

func (*Scheduler) Run

func (s *Scheduler) Run(ctx context.Context) error

Run executes an immediate sync, then starts the cron loop. It blocks until the context is cancelled. Sync errors are logged but do not stop the scheduler. Overlapping runs are skipped via cron.SkipIfStillRunning.

type SyncFunc

type SyncFunc func(ctx context.Context) error

SyncFunc is the function signature for sync callbacks