cron

package

v1.0.0-rc.2 Latest Latest Go to latest Published: Sep 7, 2026 License: MIT Imports: 6 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type CronSource struct {
	Schedule string
	Payload  string
	// contains filtered or unexported fields
}

CronSource implements the hermod.Source interface for scheduled triggers.

func NewCronSource(schedule, payload string) *CronSource

NewCronSource creates a new CronSource.

func (s *CronSource) Ack(ctx context.Context, msg hermod.Message) error

Ack is a no-op for cron.

func (s *CronSource) Close() error

Close stops the cron scheduler.

func (s *CronSource) Ping(ctx context.Context) error

Ping checks if the schedule is valid.

func (s *CronSource) Read(ctx context.Context) (hermod.Message, error)

Read blocks until the cron trigger fires.