turbine

type App = *pocketbase.PocketBase

type ApprovalOption func(*approvalOptions)

type ApprovalResult struct {
	Approved bool   `json:"approved"`
	Comment  string `json:"comment,omitempty"`
}

type AsyncResult[R any] struct {
	Result R
	Err    error
}

type Config struct {
	ApplicationVersion string        // Optional: defaults to binary hash
	ExecutorID         string        // Optional: defaults to "local"
	GCRetention        time.Duration // How long to keep completed workflows. 0 = use default (72h). Negative = disabled.
	GCSchedule         string        // Cron expression for GC. Default: "0 0 * * *" (daily midnight)
	ProductSender      ProductSender // Optional: sender for dispatching products to external systems
	WebhookMaxRetries  int           // Max webhook delivery attempts. 0 = use default (3).
	WebhookTimeout     time.Duration // Timeout per webhook delivery attempt. 0 = use default (10s).
	ShutdownTimeout    time.Duration // Max drain duration on Shutdown. 0 = use default (30s).
	Logger             *slog.Logger  // Optional: overrides the default logger used by LoggerFrom and ctx.Logger().
}

type Context interface {
	context.Context
	App() core.App
	Logger() *slog.Logger
	WorkflowID() (string, error)
	SetAppStatus(label, color string)
}

type Error struct {
	Message         string
	Code            ErrorCode
	WorkflowID      string
	StepName        string
	QueueName       string
	DeduplicationID string
	MaxRetries      int
	// contains filtered or unexported fields
}

type ErrorCode int

type GetResultOption func(*getResultOptions)

type Handle[R any] interface {
	GetResult(opts ...GetResultOption) (R, error)
	GetStatus() (Status, error)
	GetWorkflowID() string
}

type ProductRecord struct {
	ID       string         `json:"id"`
	FileName string         `json:"file_name"`
	Size     int            `json:"size"`
	Metadata map[string]any `json:"metadata"`
}

type ProductSender interface {
	Send(ctx context.Context, product ProductRecord, data io.Reader) error
}

type QueueOption func(*WorkflowQueue)

type RateLimiter struct {
	Limit  int
	Period time.Duration
}

type RegisteredWorkflow struct {
	Name         string         `json:"name"`
	FQN          string         `json:"fqn"`
	Triggerable  bool           `json:"triggerable"`
	CronSchedule string         `json:"cronSchedule"`
	InputSchema  map[string]any `json:"inputSchema,omitempty"`
	Tags         []string       `json:"tags,omitempty"`
}

type RequestEvent = core.RequestEvent

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

type Schedule struct {
	core.BaseRecordProxy
}

type SendInput struct {
	DestinationUUID string
	Topic           string
	Message         *string
}

type ServeEvent = core.ServeEvent

type SetValueInput struct {
	WorkflowUUID string
	Key          string
	Value        *string
}

type Status struct {
	ID                 string        `json:"workflow_id"`
	Status             StatusType    `json:"status"`
	Name               string        `json:"name"`
	Output             any           `json:"output,omitempty"`
	Error              error         `json:"error,omitempty"`
	ExecutorID         string        `json:"executor_id"`
	CreatedAt          time.Time     `json:"created_at"`
	UpdatedAt          time.Time     `json:"updated_at"`
	ApplicationVersion string        `json:"application_version"`
	ApplicationID      string        `json:"application_id,omitempty"`
	Attempts           int           `json:"attempts"`
	QueueName          string        `json:"queue_name,omitempty"`
	Timeout            time.Duration `json:"timeout,omitempty"`
	Deadline           time.Time     `json:"deadline"`
	StartedAt          time.Time     `json:"started_at"`
	DeduplicationID    string        `json:"deduplication_id,omitempty"`
	Input              any           `json:"input,omitempty"`
	Priority           int           `json:"priority,omitempty"`
	QueuePartitionKey  string        `json:"queue_partition_key,omitempty"`
	ForkedFrom         string        `json:"forked_from,omitempty"`
	ParentWorkflowID   string        `json:"parent_workflow_id,omitempty"`
	AppStatus          string        `json:"app_status,omitempty"`
	AppStatusColor     string        `json:"app_status_color,omitempty"`
	Summary            string        `json:"summary,omitempty"`
	Tags               []string      `json:"tags,omitempty"`
}

type StatusType string

type Step[R any] func(ctx context.Context) (R, error)

type StepFunc func(ctx context.Context) (any, error)

type StepInfo struct {
	WorkflowID   string `json:"workflow_id"`
	FunctionID   int    `json:"function_id"`
	FunctionName string `json:"function_name"`
	Output       string `json:"output,omitempty"`
	Error        string `json:"error,omitempty"`
	StartedAt    int64  `json:"started_at_epoch_ms,omitempty"`
	EndedAt      int64  `json:"ended_at_epoch_ms,omitempty"`
}

type StepOption func(*stepOptions)

type Workflow[P any, R any] func(ctx Context, input P) (R, error)

type WorkflowFunc func(ctx Context, input any) (any, error)

type WorkflowOption func(*workflowOptions)

type WorkflowQueue struct {
	Name                 string
	WorkerConcurrency    *int
	GlobalConcurrency    *int
	PriorityEnabled      bool
	RateLimit            *RateLimiter
	MaxTasksPerIteration int
	PartitionQueue       bool
	// contains filtered or unexported fields
}

type WorkflowRegistrationOption func(*workflowRegistrationOptions)

type WorkflowSender[R any] struct {
	// contains filtered or unexported fields
}