schema

package
v0.97.8 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 20, 2026 License: GPL-3.0 Imports: 11 Imported by: 0

Documentation

Overview

Package schema provides Ent ORM schema definitions.

Package schema provides Ent schema definitions and domain types for the store layer.

Index

Constants

This section is empty.

Variables

View Source 
var PipelineNamePattern = regexp.MustCompile(`^[\p{L}\p{N}][\p{L}\p{N}_-]*$`)

PipelineNamePattern matches valid pipeline names: Unicode letters and digits, with optional underscores and hyphens. Must start with a letter or digit.

Functions

func ValidatePipelineName added in v0.97.8 

func ValidatePipelineName(name string) error

ValidatePipelineName reports whether name is a valid pipeline identifier.

Types

type ActionState 

type ActionState int
const (
	ActionStateUnknown ActionState = iota
	ActionStateLongTerm
	ActionStateSubmitSuccess
	ActionStateSubmitFailed
)

func (ActionState) Value 

func (j ActionState) Value() (driver.Value, error)

type Agent 

type Agent struct {
	ent.Schema
}

func (Agent) Annotations 

func (Agent) Annotations() []schema.Annotation

func (Agent) Fields 

func (Agent) Fields() []ent.Field

type AgentPlan added in v0.94.0 

type AgentPlan struct {
	ent.Schema
}

AgentPlan stores a plan document produced during chat agent plan mode.

func (AgentPlan) Annotations added in v0.94.0 

func (AgentPlan) Annotations() []schema.Annotation

func (AgentPlan) Fields added in v0.94.0 

func (AgentPlan) Fields() []ent.Field

func (AgentPlan) Indexes added in v0.94.0 

func (AgentPlan) Indexes() []ent.Index

type AgentSkill added in v0.93.0 

type AgentSkill struct {
	ent.Schema
}

AgentSkill stores an agent skill definition loaded into chat assistant prompts.

func (AgentSkill) Annotations added in v0.93.0 

func (AgentSkill) Annotations() []schema.Annotation

func (AgentSkill) Fields added in v0.93.0 

func (AgentSkill) Fields() []ent.Field

func (AgentSkill) Indexes added in v0.93.0 

func (AgentSkill) Indexes() []ent.Index

type AgentSkillFile added in v0.94.0 

type AgentSkillFile struct {
	ent.Schema
}

AgentSkillFile stores an auxiliary file belonging to an agent skill directory.

func (AgentSkillFile) Annotations added in v0.94.0 

func (AgentSkillFile) Annotations() []schema.Annotation

Annotations pins the database table name for agent skill files.

func (AgentSkillFile) Fields added in v0.94.0 

func (AgentSkillFile) Fields() []ent.Field

Fields defines the agent skill file columns.

func (AgentSkillFile) Indexes added in v0.94.0 

func (AgentSkillFile) Indexes() []ent.Index

Indexes enforces unique paths per skill and lookup by skill flag.

type AgentSubagent added in v0.93.0 

type AgentSubagent struct {
	ent.Schema
}

AgentSubagent stores a chat assistant subagent definition delegated through the task tool.

func (AgentSubagent) Annotations added in v0.93.0 

func (AgentSubagent) Annotations() []schema.Annotation

Annotations pins the database table name for the subagent definitions.

func (AgentSubagent) Fields added in v0.93.0 

func (AgentSubagent) Fields() []ent.Field

Fields defines the subagent columns mirroring the agent skill schema with delegation-specific attributes.

func (AgentSubagent) Indexes added in v0.93.0 

func (AgentSubagent) Indexes() []ent.Index

Indexes enforces a unique subagent name and an enabled lookup index.

type AgentSubagentTask added in v0.94.0 

type AgentSubagentTask struct {
	ent.Schema
}

AgentSubagentTask records one task delegation through the task tool.

func (AgentSubagentTask) Annotations added in v0.94.0 

func (AgentSubagentTask) Annotations() []schema.Annotation

Annotations pins the database table name for subagent task records.

func (AgentSubagentTask) Fields added in v0.94.0 

func (AgentSubagentTask) Fields() []ent.Field

Fields defines the subagent task columns.

func (AgentSubagentTask) Indexes added in v0.94.0 

func (AgentSubagentTask) Indexes() []ent.Index

Indexes supports session and status lookups for task history.

type AgentSubagentTaskStatus added in v0.94.0 

type AgentSubagentTaskStatus string

AgentSubagentTaskStatus is the lifecycle state of a delegated subagent task. 

const (
	// AgentSubagentTaskStatusRunning indicates the subagent is still executing.
	AgentSubagentTaskStatusRunning AgentSubagentTaskStatus = "running"
	// AgentSubagentTaskStatusCompleted indicates the subagent finished successfully.
	AgentSubagentTaskStatusCompleted AgentSubagentTaskStatus = "completed"
	// AgentSubagentTaskStatusFailed indicates the subagent run failed.
	AgentSubagentTaskStatusFailed AgentSubagentTaskStatus = "failed"
)

type App 

type App struct {
	ent.Schema
}

func (App) Annotations 

func (App) Annotations() []schema.Annotation

func (App) Fields 

func (App) Fields() []ent.Field

type AppStatus 

type AppStatus string
const (
	AppStatusUnknown    AppStatus = "unknown"
	AppStatusRunning    AppStatus = "running"
	AppStatusStopped    AppStatus = "stopped"
	AppStatusPaused     AppStatus = "paused"
	AppStatusRestarting AppStatus = "restarting"
	AppStatusRemoving   AppStatus = "removing"
)

func (AppStatus) Value 

func (j AppStatus) Value() (driver.Value, error)

type AuditLog 

type AuditLog struct {
	ent.Schema
}

func (AuditLog) Annotations 

func (AuditLog) Annotations() []schema.Annotation

func (AuditLog) Fields 

func (AuditLog) Fields() []ent.Field

type Authentication 

type Authentication struct {
	ent.Schema
}

func (Authentication) Annotations 

func (Authentication) Annotations() []schema.Annotation

func (Authentication) Fields 

func (Authentication) Fields() []ent.Field

type Behavior 

type Behavior struct {
	ent.Schema
}

func (Behavior) Annotations 

func (Behavior) Annotations() []schema.Annotation

func (Behavior) Fields 

func (Behavior) Fields() []ent.Field

func (Behavior) Indexes 

func (Behavior) Indexes() []ent.Index

type Bot 

type Bot struct {
	ent.Schema
}

func (Bot) Annotations 

func (Bot) Annotations() []schema.Annotation

func (Bot) Fields 

func (Bot) Fields() []ent.Field

type BotState 

type BotState int
const (
	BotStateUnknown BotState = iota
	BotActive
	BotInactive
)

func (BotState) Value 

func (j BotState) Value() (driver.Value, error)

type CapabilityBinding 

type CapabilityBinding struct {
	ent.Schema
}

func (CapabilityBinding) Annotations 

func (CapabilityBinding) Annotations() []schema.Annotation

func (CapabilityBinding) Fields 

func (CapabilityBinding) Fields() []ent.Field

type Channel 

type Channel struct {
	ent.Schema
}

func (Channel) Annotations 

func (Channel) Annotations() []schema.Annotation

func (Channel) Fields 

func (Channel) Fields() []ent.Field

func (Channel) Indexes 

func (Channel) Indexes() []ent.Index

type ChannelState 

type ChannelState int
const (
	ChannelStateUnknown ChannelState = iota
	ChannelActive
	ChannelInactive
)

func (ChannelState) Value 

func (j ChannelState) Value() (driver.Value, error)

type ChatScheduledTask added in v0.94.0 

type ChatScheduledTask struct {
	ent.Schema
}

ChatScheduledTask stores a user-owned cron or one-shot chat agent job.

func (ChatScheduledTask) Annotations added in v0.94.0 

func (ChatScheduledTask) Annotations() []schema.Annotation

func (ChatScheduledTask) Fields added in v0.94.0 

func (ChatScheduledTask) Fields() []ent.Field

func (ChatScheduledTask) Indexes added in v0.94.0 

func (ChatScheduledTask) Indexes() []ent.Index

type ChatScheduledTaskKind added in v0.94.0 

type ChatScheduledTaskKind string

ChatScheduledTaskKind distinguishes recurring cron jobs from one-shot runs. 

const (
	// ChatScheduledTaskKindCron runs on a cron expression.
	ChatScheduledTaskKindCron ChatScheduledTaskKind = "cron"
	// ChatScheduledTaskKindOnce runs once at run_at.
	ChatScheduledTaskKindOnce ChatScheduledTaskKind = "once"
)

func (ChatScheduledTaskKind) Value added in v0.94.0 

func (j ChatScheduledTaskKind) Value() (driver.Value, error)

type ChatScheduledTaskRun added in v0.94.0 

type ChatScheduledTaskRun struct {
	ent.Schema
}

ChatScheduledTaskRun records one execution of a chat scheduled task.

func (ChatScheduledTaskRun) Annotations added in v0.94.0 

func (ChatScheduledTaskRun) Annotations() []schema.Annotation

func (ChatScheduledTaskRun) Fields added in v0.94.0 

func (ChatScheduledTaskRun) Fields() []ent.Field

func (ChatScheduledTaskRun) Indexes added in v0.94.0 

func (ChatScheduledTaskRun) Indexes() []ent.Index

type ChatScheduledTaskRunState added in v0.94.0 

type ChatScheduledTaskRunState string

ChatScheduledTaskRunState tracks one execution attempt. 

const (
	// ChatScheduledTaskRunStateRunning is in progress.
	ChatScheduledTaskRunStateRunning ChatScheduledTaskRunState = "running"
	// ChatScheduledTaskRunStateCompleted finished successfully.
	ChatScheduledTaskRunStateCompleted ChatScheduledTaskRunState = "completed"
	// ChatScheduledTaskRunStateFailed finished with an error.
	ChatScheduledTaskRunStateFailed ChatScheduledTaskRunState = "failed"
)

func (ChatScheduledTaskRunState) Value added in v0.94.0 

func (j ChatScheduledTaskRunState) Value() (driver.Value, error)

type ChatScheduledTaskState added in v0.94.0 

type ChatScheduledTaskState string

ChatScheduledTaskState tracks lifecycle of a scheduled task definition. 

const (
	// ChatScheduledTaskStateActive is eligible for scheduling.
	ChatScheduledTaskStateActive ChatScheduledTaskState = "active"
	// ChatScheduledTaskStatePaused is retained but not scheduled.
	ChatScheduledTaskStatePaused ChatScheduledTaskState = "paused"
	// ChatScheduledTaskStateCancelled was explicitly cancelled by the user.
	ChatScheduledTaskStateCancelled ChatScheduledTaskState = "cancelled"
	// ChatScheduledTaskStateCompleted finished a one-shot run successfully.
	ChatScheduledTaskStateCompleted ChatScheduledTaskState = "completed"
	// ChatScheduledTaskStateFailed finished a one-shot run with an error.
	ChatScheduledTaskStateFailed ChatScheduledTaskState = "failed"
	// ChatScheduledTaskStateMissed was not executed within the grace window after run_at.
	ChatScheduledTaskStateMissed ChatScheduledTaskState = "missed"
)

func (ChatScheduledTaskState) Value added in v0.94.0 

func (j ChatScheduledTaskState) Value() (driver.Value, error)

type ChatSession added in v0.93.0 

type ChatSession struct {
	ent.Schema
}

ChatSession stores metadata for a direct-message chat assistant session.

func (ChatSession) Annotations added in v0.93.0 

func (ChatSession) Annotations() []schema.Annotation

func (ChatSession) Fields added in v0.93.0 

func (ChatSession) Fields() []ent.Field

func (ChatSession) Indexes added in v0.93.0 

func (ChatSession) Indexes() []ent.Index

type ChatSessionEntry added in v0.93.0 

type ChatSessionEntry struct {
	ent.Schema
}

ChatSessionEntry stores one append-only node in a chat agent session tree.

func (ChatSessionEntry) Annotations added in v0.93.0 

func (ChatSessionEntry) Annotations() []schema.Annotation

func (ChatSessionEntry) Fields added in v0.93.0 

func (ChatSessionEntry) Fields() []ent.Field

func (ChatSessionEntry) Indexes added in v0.93.0 

func (ChatSessionEntry) Indexes() []ent.Index

type ChatSessionMode added in v0.94.0 

type ChatSessionMode string

ChatSessionMode selects whether the chat agent may mutate the workspace. 

const (
	// ChatSessionModeNormal allows full tool access per user permissions.
	ChatSessionModeNormal ChatSessionMode = "normal"
	// ChatSessionModePlan restricts the agent to read-only research tools.
	ChatSessionModePlan ChatSessionMode = "plan"
)

func (ChatSessionMode) Value added in v0.94.0 

func (j ChatSessionMode) Value() (driver.Value, error)

type ChatSessionState added in v0.93.0 

type ChatSessionState int
const (
	ChatSessionStateUnknown ChatSessionState = iota
	ChatSessionActive
	ChatSessionClosed
)

func (ChatSessionState) Value added in v0.93.0 

func (j ChatSessionState) Value() (driver.Value, error)

type Clip added in v0.97.8 

type Clip struct {
	ent.Schema
}

Clip stores a shareable markdown clip addressed by a short slug.

func (Clip) Annotations added in v0.97.8 

func (Clip) Annotations() []schema.Annotation

Annotations of the Clip.

func (Clip) Fields added in v0.97.8 

func (Clip) Fields() []ent.Field

Fields of the Clip.

type ConfigData 

type ConfigData struct {
	ent.Schema
}

func (ConfigData) Annotations 

func (ConfigData) Annotations() []schema.Annotation

func (ConfigData) Fields 

func (ConfigData) Fields() []ent.Field

func (ConfigData) Indexes 

func (ConfigData) Indexes() []ent.Index

type Connection 

type Connection struct {
	ent.Schema
}

func (Connection) Annotations 

func (Connection) Annotations() []schema.Annotation

func (Connection) Fields 

func (Connection) Fields() []ent.Field

type Counter 

type Counter struct {
	ent.Schema
}

func (Counter) Annotations 

func (Counter) Annotations() []schema.Annotation

func (Counter) Fields 

func (Counter) Fields() []ent.Field

func (Counter) Indexes 

func (Counter) Indexes() []ent.Index

type CounterRecord 

type CounterRecord struct {
	ent.Schema
}

func (CounterRecord) Annotations 

func (CounterRecord) Annotations() []schema.Annotation

func (CounterRecord) Fields 

func (CounterRecord) Fields() []ent.Field

type CycleState 

type CycleState int
const (
	CycleStateUnknown CycleState = iota
	CycleStart
	CycleDone
	CycleCancel
)

func (CycleState) Value 

func (j CycleState) Value() (driver.Value, error)

type Data 

type Data struct {
	ent.Schema
}

func (Data) Annotations 

func (Data) Annotations() []schema.Annotation

func (Data) Fields 

func (Data) Fields() []ent.Field

func (Data) Indexes 

func (Data) Indexes() []ent.Index

type DataEvent 

type DataEvent struct {
	ent.Schema
}

func (DataEvent) Annotations 

func (DataEvent) Annotations() []schema.Annotation

func (DataEvent) Fields 

func (DataEvent) Fields() []ent.Field

func (DataEvent) Indexes 

func (DataEvent) Indexes() []ent.Index

type Edge 

type Edge struct {
	Id                string        `json:"id"`
	Source            string        `json:"source"`
	Target            string        `json:"target"`
	SourcePortId      string        `json:"sourcePortId,omitempty"`
	TargetPortId      string        `json:"targetPortId,omitempty"`
	Label             string        `json:"label,omitempty"`
	EdgeContentWidth  int           `json:"edgeContentWidth,omitempty"`
	EdgeContentHeight int           `json:"edgeContentHeight,omitempty"`
	Connector         EdgeConnector `json:"connector"`
	Router            EdgeRouter    `json:"router"`
	SourcePort        string        `json:"sourcePort,omitempty"`
	TargetPort        string        `json:"targetPort,omitempty"`
}

type EdgeConnector 

type EdgeConnector struct {
	Name string `json:"name,omitempty"`
}

EdgeConnector describes the connector for an edge.

type EdgeRouter 

type EdgeRouter struct {
	Name string `json:"name,omitempty"`
}

EdgeRouter describes the router for an edge.

type EventConsumption 

type EventConsumption struct {
	ent.Schema
}

func (EventConsumption) Annotations 

func (EventConsumption) Annotations() []schema.Annotation

func (EventConsumption) Fields 

func (EventConsumption) Fields() []ent.Field

func (EventConsumption) Indexes 

func (EventConsumption) Indexes() []ent.Index

type EventOutbox 

type EventOutbox struct {
	ent.Schema
}

func (EventOutbox) Annotations 

func (EventOutbox) Annotations() []schema.Annotation

func (EventOutbox) Fields 

func (EventOutbox) Fields() []ent.Field

type ExecutionState 

type ExecutionState int
const (
	ExecutionStateUnknown ExecutionState = iota
	ExecutionPending
	ExecutionRunning
	ExecutionSucceeded
	ExecutionFailed
	ExecutionCancelled
)

func (ExecutionState) Value 

func (j ExecutionState) Value() (driver.Value, error)

type FileState 

type FileState int
const (
	FileStateUnknown FileState = iota
	FileStart
	FileFinish
	FileFailed
)

func (FileState) Value 

func (j FileState) Value() (driver.Value, error)

type Fileupload 

type Fileupload struct {
	ent.Schema
}

func (Fileupload) Annotations 

func (Fileupload) Annotations() []schema.Annotation

func (Fileupload) Fields 

func (Fileupload) Fields() []ent.Field

func (Fileupload) Indexes 

func (Fileupload) Indexes() []ent.Index

type FlowState 

type FlowState int
const (
	FlowStateUnknown FlowState = iota
	FlowActive
	FlowInactive
)

func (FlowState) Value 

func (j FlowState) Value() (driver.Value, error)

type Form 

type Form struct {
	ent.Schema
}

func (Form) Annotations 

func (Form) Annotations() []schema.Annotation

func (Form) Fields 

func (Form) Fields() []ent.Field

func (Form) Indexes 

func (Form) Indexes() []ent.Index

type FormState 

type FormState int
const (
	FormStateUnknown FormState = iota
	FormStateCreated
	FormStateSubmitSuccess
	FormStateSubmitFailed
)

func (FormState) Value 

func (j FormState) Value() (driver.Value, error)

type IDList 

type IDList []int64

IDList is a []int64 with database Scan/Value support for JSONB array columns.

func (*IDList) Scan 

func (j *IDList) Scan(value any) error

func (*IDList) Value 

func (j *IDList) Value() (driver.Value, error)

type Instruct 

type Instruct struct {
	ent.Schema
}

func (Instruct) Annotations 

func (Instruct) Annotations() []schema.Annotation

func (Instruct) Fields 

func (Instruct) Fields() []ent.Field

func (Instruct) Indexes 

func (Instruct) Indexes() []ent.Index

type InstructObject 

type InstructObject string
const (
	InstructObjectAgent InstructObject = "agent"
)

func (InstructObject) Value 

func (j InstructObject) Value() (driver.Value, error)

type InstructPriority 

type InstructPriority int
const (
	InstructPriorityHigh    InstructPriority = 3
	InstructPriorityDefault InstructPriority = 2
	InstructPriorityLow     InstructPriority = 1
)

func (InstructPriority) Value 

func (j InstructPriority) Value() (driver.Value, error)

type InstructState 

type InstructState int
const (
	InstructStateUnknown InstructState = iota
	InstructCreate
	InstructDone
	InstructCancel
)

func (InstructState) Value 

func (j InstructState) Value() (driver.Value, error)

type JSON 

type JSON map[string]any

JSON is a map[string]any with database Scan/Value support for JSONB columns.

func (*JSON) Scan 

func (j *JSON) Scan(value any) error

func (*JSON) Value 

func (j *JSON) Value() (driver.Value, error)

type JobState 

type JobState int
const (
	JobStateUnknown JobState = iota
	JobReady
	JobStart
	JobRunning
	JobSucceeded
	JobCanceled
	JobFailed
)

func (JobState) Value 

func (j JobState) Value() (driver.Value, error)

type LLMUsageRecord added in v0.95.0 

type LLMUsageRecord struct {
	ent.Schema
}

LLMUsageRecord stores token consumption for one LLM call.

func (LLMUsageRecord) Annotations added in v0.95.0 

func (LLMUsageRecord) Annotations() []schema.Annotation

func (LLMUsageRecord) Fields added in v0.95.0 

func (LLMUsageRecord) Fields() []ent.Field

func (LLMUsageRecord) Indexes added in v0.95.0 

func (LLMUsageRecord) Indexes() []ent.Index

type Message 

type Message struct {
	ent.Schema
}

func (Message) Annotations 

func (Message) Annotations() []schema.Annotation

func (Message) Fields 

func (Message) Fields() []ent.Field

func (Message) Indexes 

func (Message) Indexes() []ent.Index

func (Message) Mixin 

func (Message) Mixin() []ent.Mixin

type MessageState 

type MessageState int
const (
	MessageStateUnknown MessageState = iota
	MessageCreated
)

func (MessageState) Value 

func (j MessageState) Value() (driver.Value, error)

type Node 

type Node struct {
	Id          string         `json:"id"`
	Describe    string         `json:"describe"`
	X           int            `json:"x,omitempty"`
	Y           int            `json:"y,omitempty"`
	Width       int            `json:"width,omitempty"`
	Height      int            `json:"height,omitempty"`
	Label       string         `json:"label,omitempty"`
	RenderKey   string         `json:"renderKey,omitempty"`
	IsGroup     bool           `json:"isGroup,omitempty"`
	Group       string         `json:"group,omitempty"`
	ParentId    string         `json:"parentId,omitempty"`
	Ports       []NodePort     `json:"ports,omitempty"`
	Order       int            `json:"_order,omitempty"`
	Bot         string         `json:"bot"`
	RuleId      string         `json:"rule_id"`
	Parameters  map[string]any `json:"parameters,omitempty"`
	Variables   []string       `json:"variables,omitempty"`
	Connections []string       `json:"connections,omitempty"`
	Status      NodeStatus     `json:"status,omitempty"`
}

type NodePort 

type NodePort struct {
	Id        string `json:"id,omitempty"`
	Group     string `json:"group,omitempty"`
	Type      string `json:"type,omitempty"`
	Tooltip   string `json:"tooltip,omitempty"`
	Connected bool   `json:"connected,omitempty"`
}

NodePort describes a port on a flow node.

type NodeStatus 

type NodeStatus string
const (
	NodeDefault    NodeStatus = "default"
	NodeSuccess    NodeStatus = "success"
	NodeProcessing NodeStatus = "processing"
	NodeError      NodeStatus = "error"
	NodeWarning    NodeStatus = "warning"
)

func (NodeStatus) Value 

func (j NodeStatus) Value() (driver.Value, error)

type NodeType 

type NodeType string
const (
	NodeTypeTrigger   NodeType = "trigger"
	NodeTypeAction    NodeType = "action"
	NodeTypeFilter    NodeType = "filter"
	NodeTypeCondition NodeType = "condition"
)

func (NodeType) Value 

func (j NodeType) Value() (driver.Value, error)

type NotificationRecord 

type NotificationRecord struct {
	ent.Schema
}

func (NotificationRecord) Annotations 

func (NotificationRecord) Annotations() []schema.Annotation

func (NotificationRecord) Fields 

func (NotificationRecord) Fields() []ent.Field

func (NotificationRecord) Indexes 

func (NotificationRecord) Indexes() []ent.Index

type NotifyChannel 

type NotifyChannel struct {
	ent.Schema
}

func (NotifyChannel) Annotations 

func (NotifyChannel) Annotations() []schema.Annotation

func (NotifyChannel) Fields 

func (NotifyChannel) Fields() []ent.Field

func (NotifyChannel) Indexes 

func (NotifyChannel) Indexes() []ent.Index

type NotifyRule 

type NotifyRule struct {
	ent.Schema
}

func (NotifyRule) Annotations 

func (NotifyRule) Annotations() []schema.Annotation

func (NotifyRule) Fields 

func (NotifyRule) Fields() []ent.Field

func (NotifyRule) Indexes 

func (NotifyRule) Indexes() []ent.Index

type NotifyTemplate added in v0.97.8 

type NotifyTemplate struct {
	ent.Schema
}

NotifyTemplate holds a notification message template persisted in the database.

func (NotifyTemplate) Annotations added in v0.97.8 

func (NotifyTemplate) Annotations() []schema.Annotation

Annotations of the NotifyTemplate.

func (NotifyTemplate) Fields added in v0.97.8 

func (NotifyTemplate) Fields() []ent.Field

Fields of the NotifyTemplate.

func (NotifyTemplate) Indexes added in v0.97.8 

func (NotifyTemplate) Indexes() []ent.Index

Indexes of the NotifyTemplate.

type NotifyTemplateOverride added in v0.97.8 

type NotifyTemplateOverride struct {
	Channel  string `json:"channel"`
	Format   string `json:"format"`
	Template string `json:"template"`
}

NotifyTemplateOverride is a channel-specific template body stored as JSON.

type OAuth 

type OAuth struct {
	ent.Schema
}

func (OAuth) Annotations 

func (OAuth) Annotations() []schema.Annotation

func (OAuth) Fields 

func (OAuth) Fields() []ent.Field

func (OAuth) Indexes 

func (OAuth) Indexes() []ent.Index

type Page 

type Page struct {
	ent.Schema
}

func (Page) Annotations 

func (Page) Annotations() []schema.Annotation

func (Page) Fields 

func (Page) Fields() []ent.Field

func (Page) Indexes 

func (Page) Indexes() []ent.Index

type PageData 

type PageData struct {
	ent.Schema
}

PageData represents a shared page with token-based access.

func (PageData) Annotations 

func (PageData) Annotations() []schema.Annotation

Annotations of the PageData.

func (PageData) Fields 

func (PageData) Fields() []ent.Field

Fields of the PageData.

func (PageData) Indexes 

func (PageData) Indexes() []ent.Index

Indexes of the PageData.

type PageState 

type PageState int
const (
	PageStateUnknown PageState = iota
	PageStateCreated
	PageStateProcessedSuccess
	PageStateProcessedFailed
)

func (PageState) Value 

func (j PageState) Value() (driver.Value, error)

type PageType 

type PageType string
const (
	PageForm  PageType = "form"
	PageTable PageType = "table"
	PageHtml  PageType = "html"
)

func (PageType) Value 

func (j PageType) Value() (driver.Value, error)

type Parameter 

type Parameter struct {
	ent.Schema
}

func (Parameter) Annotations 

func (Parameter) Annotations() []schema.Annotation

func (Parameter) Fields 

func (Parameter) Fields() []ent.Field

type PipelineDefinition 

type PipelineDefinition struct {
	ent.Schema
}

func (PipelineDefinition) Annotations 

func (PipelineDefinition) Annotations() []schema.Annotation

func (PipelineDefinition) Fields 

func (PipelineDefinition) Fields() []ent.Field

type PipelineDefinitionVersion 

type PipelineDefinitionVersion struct {
	ent.Schema
}

PipelineDefinitionVersion stores YAML snapshots of pipeline definitions each time a pipeline is published. It enforces a composite unique constraint on (pipeline_name, version) so that each name+version pair is immutable.

func (PipelineDefinitionVersion) Annotations 

func (PipelineDefinitionVersion) Annotations() []schema.Annotation

func (PipelineDefinitionVersion) Fields 

func (PipelineDefinitionVersion) Fields() []ent.Field

func (PipelineDefinitionVersion) Indexes 

func (PipelineDefinitionVersion) Indexes() []ent.Index

type PipelineRun 

type PipelineRun struct {
	ent.Schema
}

func (PipelineRun) Annotations 

func (PipelineRun) Annotations() []schema.Annotation

func (PipelineRun) Fields 

func (PipelineRun) Fields() []ent.Field

func (PipelineRun) Indexes 

func (PipelineRun) Indexes() []ent.Index

type PipelineState 

type PipelineState int
const (
	PipelineStateUnknown PipelineState = iota
	PipelineStart
	PipelineDone
	PipelineCancel
	PipelineFailed
)

func (PipelineState) Value 

func (j PipelineState) Value() (driver.Value, error)

type PipelineStepRun 

type PipelineStepRun struct {
	ent.Schema
}

func (PipelineStepRun) Annotations 

func (PipelineStepRun) Annotations() []schema.Annotation

func (PipelineStepRun) Fields 

func (PipelineStepRun) Fields() []ent.Field

func (PipelineStepRun) Indexes 

func (PipelineStepRun) Indexes() []ent.Index

type Platform 

type Platform struct {
	ent.Schema
}

func (Platform) Annotations 

func (Platform) Annotations() []schema.Annotation

func (Platform) Fields 

func (Platform) Fields() []ent.Field

type PlatformBot 

type PlatformBot struct {
	ent.Schema
}

func (PlatformBot) Annotations 

func (PlatformBot) Annotations() []schema.Annotation

func (PlatformBot) Fields 

func (PlatformBot) Fields() []ent.Field

func (PlatformBot) Indexes 

func (PlatformBot) Indexes() []ent.Index

type PlatformChannel 

type PlatformChannel struct {
	ent.Schema
}

func (PlatformChannel) Annotations 

func (PlatformChannel) Annotations() []schema.Annotation

func (PlatformChannel) Fields 

func (PlatformChannel) Fields() []ent.Field

func (PlatformChannel) Indexes 

func (PlatformChannel) Indexes() []ent.Index

type PlatformChannelUser 

type PlatformChannelUser struct {
	ent.Schema
}

func (PlatformChannelUser) Annotations 

func (PlatformChannelUser) Annotations() []schema.Annotation

func (PlatformChannelUser) Fields 

func (PlatformChannelUser) Fields() []ent.Field

func (PlatformChannelUser) Indexes 

func (PlatformChannelUser) Indexes() []ent.Index

type PlatformUser 

type PlatformUser struct {
	ent.Schema
}

func (PlatformUser) Annotations 

func (PlatformUser) Annotations() []schema.Annotation

func (PlatformUser) Fields 

func (PlatformUser) Fields() []ent.Field

func (PlatformUser) Indexes 

func (PlatformUser) Indexes() []ent.Index

type PollingState 

type PollingState struct {
	ent.Schema
}

func (PollingState) Annotations 

func (PollingState) Annotations() []schema.Annotation

func (PollingState) Fields 

func (PollingState) Fields() []ent.Field

type RateLimitType 

type RateLimitType string
const (
	RateLimitTypeFlow RateLimitType = "flow"
	RateLimitTypeNode RateLimitType = "node"
)

func (RateLimitType) Value 

func (j RateLimitType) Value() (driver.Value, error)

type ResourceEdge 

type ResourceEdge struct {
	SourceApp        string    `json:"source_app"`
	SourceCapability string    `json:"source_capability"`
	SourceEntityID   string    `json:"source_entity_id"`
	TargetApp        string    `json:"target_app"`
	TargetCapability string    `json:"target_capability"`
	TargetEntityID   string    `json:"target_entity_id"`
	PipelineName     string    `json:"pipeline_name"`
	CreatedAt        time.Time `json:"created_at"`
}

ResourceEdge represents a directed resource link with full source and target details plus pipeline metadata and creation time. 

type ResourceLink struct {
	ent.Schema
}

func (ResourceLink) Annotations 

func (ResourceLink) Annotations() []schema.Annotation

func (ResourceLink) Fields 

func (ResourceLink) Fields() []ent.Field

func (ResourceLink) Indexes 

func (ResourceLink) Indexes() []ent.Index

type ResourceRef 

type ResourceRef struct {
	App          string `json:"app"`
	EntityID     string `json:"entity_id"`
	Capability   string `json:"capability,omitempty"`
	PipelineName string `json:"pipeline_name,omitempty"`
}

ResourceRef identifies a resource by app, entity_id, and optional metadata.

type ResourceRelations 

type ResourceRelations struct {
	App        string        `json:"app"`
	EntityID   string        `json:"entity_id"`
	Upstream   []ResourceRef `json:"upstream"`
	Downstream []ResourceRef `json:"downstream"`
}

ResourceRelations holds upstream and downstream resource references for a specific resource identified by app and entity_id.

type ReviewType 

type ReviewType int
const (
	ReviewTypeUnknown ReviewType = iota
	ReviewMid
	ReviewEnd
)

func (ReviewType) Value 

func (j ReviewType) Value() (driver.Value, error)

type SessionState 

type SessionState int
const (
	SessionStateUnknown SessionState = iota
	SessionStart
	SessionDone
	SessionCancel
)

func (SessionState) Value 

func (j SessionState) Value() (driver.Value, error)

type StepState 

type StepState int
const (
	StepStateUnknown StepState = iota
	StepCreated
	StepReady
	StepStart
	StepRunning
	StepSucceeded
	StepFailed
	StepCanceled
	StepSkipped
)

func (StepState) Value 

func (j StepState) Value() (driver.Value, error)

type Topic 

type Topic struct {
	ent.Schema
}

func (Topic) Annotations 

func (Topic) Annotations() []schema.Annotation

func (Topic) Fields 

func (Topic) Fields() []ent.Field

type TopicState 

type TopicState int

func (TopicState) Value 

func (j TopicState) Value() (driver.Value, error)

type TriggerCronRule 

type TriggerCronRule struct {
	Spec string `json:"spec"`
}

type TriggerType 

type TriggerType string
const (
	TriggerCron   TriggerType = "cron"
	TriggerManual TriggerType = "manual"
)

func (TriggerType) Value 

func (j TriggerType) Value() (driver.Value, error)

type Url 

type Url struct {
	ent.Schema
}

func (Url) Annotations 

func (Url) Annotations() []schema.Annotation

func (Url) Fields 

func (Url) Fields() []ent.Field

type UrlState 

type UrlState int
const (
	UrlStateUnknown UrlState = iota
	UrlStateEnable
	UrlStateDisable
)

func (UrlState) Value 

func (j UrlState) Value() (driver.Value, error)

type User 

type User struct {
	ent.Schema
}

func (User) Annotations 

func (User) Annotations() []schema.Annotation

func (User) Fields 

func (User) Fields() []ent.Field

type UserState 

type UserState int
const (
	UserStateUnknown UserState = iota
	UserActive
	UserInactive
)

func (UserState) Value 

func (j UserState) Value() (driver.Value, error)

type ValueModeType 

type ValueModeType string
const (
	ValueSumMode  ValueModeType = "sum"
	ValueLastMode ValueModeType = "last"
	ValueAvgMode  ValueModeType = "avg"
	ValueMaxMode  ValueModeType = "max"
)

func (ValueModeType) Value 

func (j ValueModeType) Value() (driver.Value, error)

type WorkflowRun 

type WorkflowRun struct {
	ent.Schema
}

func (WorkflowRun) Annotations 

func (WorkflowRun) Annotations() []schema.Annotation

func (WorkflowRun) Fields 

func (WorkflowRun) Fields() []ent.Field

func (WorkflowRun) Indexes 

func (WorkflowRun) Indexes() []ent.Index

type WorkflowRunState 

type WorkflowRunState int

WorkflowRunState represents the execution state of a local workflow engine run. 

const (
	WorkflowRunStateUnknown WorkflowRunState = iota
	WorkflowRunRunning
	WorkflowRunDone
	WorkflowRunFailed
)

func (WorkflowRunState) Value 

func (j WorkflowRunState) Value() (driver.Value, error)

type WorkflowScriptLang 

type WorkflowScriptLang string
const (
	WorkflowScriptYaml WorkflowScriptLang = "yaml"
)

func (WorkflowScriptLang) Value 

func (j WorkflowScriptLang) Value() (driver.Value, error)

type WorkflowState 

type WorkflowState int
const (
	WorkflowStateUnknown WorkflowState = iota
	WorkflowEnable
	WorkflowDisable
)

func (WorkflowState) Value 

func (j WorkflowState) Value() (driver.Value, error)

type WorkflowStepRun 

type WorkflowStepRun struct {
	ent.Schema
}

func (WorkflowStepRun) Annotations 

func (WorkflowStepRun) Annotations() []schema.Annotation

func (WorkflowStepRun) Fields 

func (WorkflowStepRun) Fields() []ent.Field

func (WorkflowStepRun) Indexes 

func (WorkflowStepRun) Indexes() []ent.Index

type WorkflowTriggerState 

type WorkflowTriggerState int
const (
	WorkflowTriggerStateUnknown WorkflowTriggerState = iota
	WorkflowTriggerEnable
	WorkflowTriggerDisable
)

func (WorkflowTriggerState) Value 

func (j WorkflowTriggerState) Value() (driver.Value, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.