scheduler

type AutomationFrequency string

type AutomationSchedule struct {
	Key          string                   `json:"key"`
	WorkflowID   string                   `json:"workflow_id"`
	WorkflowName string                   `json:"workflow_name"`
	VersionID    string                   `json:"version_id"`
	TriggerID    string                   `json:"trigger_id"`
	Fingerprint  string                   `json:"-"`
	Config       AutomationScheduleConfig `json:"schedule"`
	Enabled      bool                     `json:"enabled"`
	NextRunAt    time.Time                `json:"next_run_at"`
	LastRunAt    time.Time                `json:"last_run_at,omitempty"`
	LastRunID    string                   `json:"last_run_id,omitempty"`
	LastError    string                   `json:"last_error,omitempty"`
	ClaimToken   string                   `json:"-"`
	ClaimUntil   time.Time                `json:"-"`
}

type AutomationScheduleConfig struct {
	Frequency       AutomationFrequency `json:"frequency"`
	Time            string              `json:"time,omitempty"`
	Weekdays        []int               `json:"weekdays,omitempty"`
	IntervalMinutes int                 `json:"interval_minutes,omitempty"`
	Timezone        string              `json:"timezone"`
}

type AutomationStatus struct {
	AutomationSchedule
	LastRunStatus wfruntime.Status `json:"last_run_status,omitempty"`
}

type AutomationStore interface {
	ReconcileSchedules(ctx context.Context, desired []AutomationSchedule) error
	ClaimDueSchedules(ctx context.Context, now time.Time, limit int, lease time.Duration) ([]AutomationSchedule, error)
	CompleteSchedule(ctx context.Context, key, claimToken, runID string, scheduledAt, nextRunAt time.Time) error
	FailSchedule(ctx context.Context, key, claimToken, message string, retryAt time.Time) error
	ListSchedules(ctx context.Context) ([]AutomationSchedule, error)
}

type DispatchMode string

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

type HTTPHandler struct {
	Service *Service
}

type HybridDispatcher struct {
	LocalRegistry *executor.Registry
	Workers       WorkerRegistry
	HTTPClient    *RemoteHTTPClient
	Mode          DispatchMode
}

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

type MemoryWorkerRegistry struct {
	HeartbeatTTL time.Duration
	Now          func() time.Time
	// contains filtered or unexported fields
}

type Options struct {
	Compiler               planning.Compiler
	Store                  wfruntime.Store
	Definitions            definition.Repository
	Workspace              definition.WorkspaceRepository
	RunController          runner.RunController
	EnableEmbeddedWorker   bool
	EmbeddedWorker         *worker.Service
	WorkerRegistry         WorkerRegistry
	DispatchMode           DispatchMode
	ResultReporter         runner.ResultReporter
	HeartbeatReporter      runner.HeartbeatReporter
	Credentials            credential.Store
	DefaultCredentialScope string
	Automations            AutomationStore
}

type PublishedAPIContract struct {
	WorkflowID   string                   `json:"workflow_id"`
	VersionID    string                   `json:"version_id"`
	Version      int                      `json:"version"`
	Name         string                   `json:"name"`
	Description  string                   `json:"description,omitempty"`
	Route        string                   `json:"route"`
	URL          string                   `json:"url,omitempty"`
	InvokeURL    string                   `json:"invoke_url,omitempty"`
	AsyncURL     string                   `json:"async_url,omitempty"`
	StreamURL    string                   `json:"stream_url_template,omitempty"`
	Method       string                   `json:"method"`
	InputMode    string                   `json:"input_mode"`
	ResponseMode string                   `json:"response_mode"`
	TimeoutMS    int64                    `json:"timeout"`
	Inputs       []PublishedAPIInputField `json:"inputs,omitempty"`
	Example      map[string]any           `json:"request_example,omitempty"`
}

type PublishedAPIInputField struct {
	Key         string                       `json:"key"`
	Label       map[string]string            `json:"label"`
	Description map[string]string            `json:"description,omitempty"`
	Kind        string                       `json:"kind"`
	Required    bool                         `json:"required,omitempty"`
	Default     any                          `json:"default,omitempty"`
	Options     []PublishedAPIInputOption    `json:"options,omitempty"`
	VisibleWhen *PublishedAPIInputVisibility `json:"visible_when,omitempty"`
	// contains filtered or unexported fields
}

type PublishedAPIInputOption struct {
	Value string            `json:"value"`
	Label map[string]string `json:"label"`
}

type PublishedAPIInputVisibility struct {
	Key       string `json:"key"`
	Equals    any    `json:"equals,omitempty"`
	NotEquals any    `json:"not_equals,omitempty"`
	// contains filtered or unexported fields
}

type RegistryHTTPHandler struct {
	Workers WorkerRegistry
}

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

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

type RunRequest struct {
	Definition *definition.WorkflowDefinition `json:"definition,omitempty"`
	Version    *definition.WorkflowVersion    `json:"version,omitempty"`
	VersionID  string                         `json:"version_id,omitempty"`
	Run        *wfruntime.WorkflowRun         `json:"run,omitempty"`
}

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

type ValidateResponse struct {
	OK   bool                    `json:"ok"`
	Plan *planning.ExecutionPlan `json:"plan,omitempty"`
}

type WorkerAllocator interface {
	AcquireForTask(ctx context.Context, task executor.ExecuteTask) (*WorkerLease, error)
}

type WorkerLease struct {
	Worker  *workerproto.WorkerDescriptor
	Release func()
}

type WorkerRegistry interface {
	Register(ctx context.Context, worker workerproto.WorkerDescriptor) error
	Heartbeat(ctx context.Context, workerID string) error
	FindForTask(ctx context.Context, task executor.ExecuteTask) (*workerproto.WorkerDescriptor, error)
	List(ctx context.Context) ([]workerproto.WorkerDescriptor, error)
}