scheduler

type Action struct {
	ID        string         `yaml:"id" validate:"required,alphanum_underscore"`
	Name      string         `yaml:"name" validate:"required"`
	Executor  string         `yaml:"executor" validate:"required,oneof=script docker"`
	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
}

type FlowHandlerConfig struct {
	Store                repo.Store
	SecretsProvider      SecretsProviderFn
	LogManager           streamlogger.LogManager
	Logger               *slog.Logger
	Metrics              *metrics.Manager
	FlowExecutionTimeout time.Duration
}

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"`
}

type InputType string

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

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"`
	Receivers   []string `json:"receivers"`
	NamespaceID string   `json:"namespace_id"`
	Channel     string   `json:"channel"`
}

type Notify struct {
	Channel   string        `yaml:"channel" json:"channel"`
	Receivers []string      `yaml:"receivers" json:"receivers"`
	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 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)
}

type TaskScheduler interface {
	QueueTask(ctx context.Context, payloadType PayloadType, execID string, payload any) (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