scheduler

type Action struct {
	ID        string         `yaml:"id" validate:"required,alphanum_underscore"`
	Name      string         `yaml:"name" validate:"required"`
	Executor  string         `yaml:"executor"`
	With      map[string]any `yaml:"with" validate:"required"`
	Approval  bool           `yaml:"approval"`
	Variables []Variable     `yaml:"variables"`
	On        []Node         `yaml:"on"`
}

type AuthMethod string

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

type Flow struct {
	Meta      Metadata     `yaml:"metadata" validate:"required"`
	Inputs    []Input      `yaml:"inputs" validate:"required"`
	Actions   []Action     `yaml:"actions" validate:"required"`
	Outputs   []Output     `yaml:"outputs"`
	Schedules []Scheduling `yaml:"scheduling"`
	Notify    []Notify     `yaml:"notify"`
}

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

type FlowExecutionPayload struct {
	Workflow          Flow
	Input             map[string]any
	StartingActionIdx int
	NamespaceID       string
	TriggerType       TriggerType
	UserUUID          string
	FlowDirectory     string

	// Resumed should be set to true if resuming an existing execution (after approval or retry)
	Resumed bool
}

type FlowHandlerConfig struct {
	Store                repo.Store
	SecretsProvider      SecretsProviderFn
	LogManager           streamlogger.LogManager
	Logger               *slog.Logger
	Metrics              *metrics.Manager
	FlowExecutionTimeout time.Duration
	ExecutorKeys         map[string]string // executor_name → API token
	APIBaseURL           string
}

type FlowLoaderFn func(ctx context.Context, flowSlug string, namespaceUUID string) (Flow, error)

type Handler interface {
	// Type returns the payload type this handler processes
	Type() PayloadType
	// Handle processes a job
	Handle(ctx context.Context, job Job) error
}

type HookFn func(ctx context.Context, execID string, action Action, namespaceID string) error

type Input struct {
	Name        string    `yaml:"name" json:"name" validate:"required,alphanum_underscore"`
	Type        InputType `yaml:"type" json:"type" validate:"required,oneof=string int float bool slice_string slice_int slice_uint slice_float"`
	Label       string    `yaml:"label" json:"label"`
	Description string    `yaml:"description" json:"description"`
	Validation  string    `yaml:"validation" json:"validation"`
	Required    bool      `yaml:"required" json:"required"`
	Default     string    `yaml:"default" json:"default"`
	MaxFileSize int64     `yaml:"max_file_size" json:"max_file_size"`
}

type InputType string

type Job struct {
	ID          int64
	ExecID      string
	PayloadType PayloadType
	Payload     []byte
	CreatedAt   time.Time
	ScheduledAt time.Time
	MaxRetries  int
	Attempt     int
}

type JobSyncerFn func(ctx context.Context) ([]ScheduledJob, error)

type Metadata struct {
	ID          string `yaml:"id" validate:"required,alphanum_underscore"`
	DBID        int32  `yaml:"-"`
	Name        string `yaml:"name" validate:"required"`
	Description string `yaml:"description"`
	SrcDir      string `yaml:"-"`
	Namespace   string `yaml:"namespace"`
}

type Node struct {
	ID             string
	Name           string
	Hostname       string
	Port           int
	Username       string
	OSFamily       string
	ConnectionType string
	Tags           []string
	Auth           NodeAuth
}

type NodeAuth struct {
	CredentialID string
	Method       AuthMethod
	Key          string
}

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

type NotificationPayload struct {
	FlowID      string         `json:"flow_id"`
	FlowName    string         `json:"flow_name"`
	ExecID      string         `json:"exec_id"`
	Status      string         `json:"status"`
	Error       string         `json:"error,omitempty"`
	Config      map[string]any `json:"config"`
	NamespaceID string         `json:"namespace_id"`
	Channel     string         `json:"channel"`
}

type Notify struct {
	Channel string         `yaml:"channel" json:"channel"`
	Config  map[string]any `yaml:"config" json:"config"`
	Events  []NotifyEvent  `yaml:"events" json:"events"`
}

type NotifyEvent string

type Output map[string]any

type PayloadType string

type QueueConfig struct {
	Queues []QueueWeight
}

type QueueWeight struct {
	PayloadType PayloadType
	Weight      int // 1-100, all weights must sum to 100
}

type RetryOptions struct {
	InitialDelay  time.Duration
	MaxDelay      time.Duration
	BackoffFactor float64
}

type ScheduledJob struct {
	ID          string
	Name        string
	Cron        string
	Timezone    string
	PayloadType PayloadType
	Payload     any
}

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

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

type Scheduling struct {
	Cron     string `yaml:"cron" json:"cron"`
	Timezone string `yaml:"timezone" json:"timezone"`
}

type SecretsProviderFn func(ctx context.Context, flowID string, namespaceID string) (map[string]string, error)

type Task struct {
	UUID      string
	ExecID    string
	Payload   []byte
	Status    string
	CreatedAt time.Time
}

type TaskQueuer interface {
	QueueTask(ctx context.Context, payloadType PayloadType, execID string, payload any) (string, error)
	QueueTaskWithRetries(ctx context.Context, payloadType PayloadType, execID string, payload any, maxRetries int) (string, error)
}

type TaskScheduler interface {
	QueueTask(ctx context.Context, payloadType PayloadType, execID string, payload any) (string, error)
	QueueTaskWithRetries(ctx context.Context, payloadType PayloadType, execID string, payload any, maxRetries int) (string, error)
	QueueScheduledTask(ctx context.Context, payloadType PayloadType, execID string, payload any, scheduledAt time.Time) (string, error)
	QueueScheduledTaskWithRetries(ctx context.Context, payloadType PayloadType, execID string, payload any, scheduledAt time.Time, maxRetries int) (string, error)
	CancelTask(ctx context.Context, execID string) error
	Start(ctx context.Context) error
	Stop(ctx context.Context) error
}

type TriggerType string

type Variable map[string]any