dispatcher

Documentation

Index

• func DeleteCronMonitor(c *temporal.Client, teamID, monitorID string) error
• func DispatchBackgroundTasks(c *temporal.Client) error
• func DispatchCronMonitor(c *temporal.Client, teamID, monitorID, cronSchedule string) error
• func DispatchModuleRunQueueChecker(c *temporal.Client, input *modulequeuechecker.CheckQueueInput) error
• func UpdateCronMonitor(c *temporal.Client, teamID, monitorID, cronSchedule string) error
• type CronMonitorOpts

Functions

func DeleteCronMonitor

func DeleteCronMonitor(c *temporal.Client, teamID, monitorID string) error

func DispatchBackgroundTasks

func DispatchBackgroundTasks(c *temporal.Client) error

func DispatchCronMonitor

func DispatchCronMonitor(c *temporal.Client, teamID, monitorID, cronSchedule string) error

func DispatchModuleRunQueueChecker

func DispatchModuleRunQueueChecker(c *temporal.Client, input *modulequeuechecker.CheckQueueInput) error

func UpdateCronMonitor

func UpdateCronMonitor(c *temporal.Client, teamID, monitorID, cronSchedule string) error

Types

type CronMonitorOpts

type CronMonitorOpts struct {
	Monitor   *models.ModuleMonitor
	Team      *models.Team
	Module    *models.Module
	DB        *database.Config
	TokenOpts token.TokenOpts
	ServerURL string
}