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

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

type FlowLoaderFn func(ctx context.Context, flowSlug string, namespaceUUID string) (Flow, 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 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 Output map[string]any

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

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

type SchedulerDependencies struct {
	OnBeforeAction  HookFn
	OnAfterAction   HookFn
	SecretsProvider SecretsProviderFn
	FlowLoader      FlowLoaderFn
	LogManager      interface{} // streamlogger.LogManager
}

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 TaskScheduler interface {
	QueueTask(ctx context.Context, payload FlowExecutionPayload) (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