workflow

package
v0.2.2 Latest Latest
Warning

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

Go to latest
Published: Apr 5, 2026 License: Apache-2.0 Imports: 35 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type EntRepository

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

func NewEntRepository

func NewEntRepository(client *ent.Client) *EntRepository

func (*EntRepository) ApplyWorkflowSkillBindings

func (r *EntRepository) ApplyWorkflowSkillBindings(
	ctx context.Context,
	workflowID uuid.UUID,
	skillIDs []uuid.UUID,
	bind bool,
	content string,
	createdBy string,
) (domain.Workflow, error)

func (*EntRepository) BuildHarnessTemplateData

func (r *EntRepository) BuildHarnessTemplateData(
	ctx context.Context,
	input domain.BuildHarnessTemplateDataInput,
) (domain.HarnessTemplateData, error)

func (*EntRepository) Create

func (r *EntRepository) Create(ctx context.Context, workflow domain.Workflow, harnessContent string, createdBy string) (domain.Workflow, error)

func (*EntRepository) CreateSkillBundle

func (r *EntRepository) CreateSkillBundle(
	ctx context.Context,
	input domain.CreateSkillBundleInput,
	bundle domain.SkillBundle,
	enabled bool,
	createdBy string,
	now time.Time,
) (domain.SkillDetail, error)

func (*EntRepository) CurrentSkillVersion

func (r *EntRepository) CurrentSkillVersion(ctx context.Context, skillID uuid.UUID, requiredVersionID *uuid.UUID) (domain.SkillVersionRecord, error)

func (*EntRepository) CurrentWorkflowVersion

func (r *EntRepository) CurrentWorkflowVersion(ctx context.Context, workflowID uuid.UUID) (domain.WorkflowVersionRecord, error)

func (*EntRepository) Delete

func (r *EntRepository) Delete(ctx context.Context, workflowID uuid.UUID) (domain.Workflow, error)

func (*EntRepository) DeleteSkill

func (r *EntRepository) DeleteSkill(ctx context.Context, skillID uuid.UUID, deletedAt time.Time) error

func (*EntRepository) EnsureAgentBelongsToProject

func (r *EntRepository) EnsureAgentBelongsToProject(ctx context.Context, projectID uuid.UUID, agentID uuid.UUID) error

func (*EntRepository) EnsureBuiltinSkills

func (r *EntRepository) EnsureBuiltinSkills(ctx context.Context, projectID uuid.UUID, now time.Time, bundles []domain.SkillBundle) error

func (*EntRepository) EnsureHarnessPathAvailable

func (r *EntRepository) EnsureHarnessPathAvailable(
	ctx context.Context,
	projectID uuid.UUID,
	harnessPath string,
	excludeWorkflowID uuid.UUID,
) error

func (*EntRepository) EnsurePickupStatusBindingsAvailable

func (r *EntRepository) EnsurePickupStatusBindingsAvailable(
	ctx context.Context,
	projectID uuid.UUID,
	statusIDs []uuid.UUID,
	excludeWorkflowID uuid.UUID,
) error

func (*EntRepository) EnsureProjectExists

func (r *EntRepository) EnsureProjectExists(ctx context.Context, projectID uuid.UUID) error

func (*EntRepository) EnsureStatusBindingsBelongToProject

func (r *EntRepository) EnsureStatusBindingsBelongToProject(ctx context.Context, projectID uuid.UUID, statusIDs []uuid.UUID) error

func (*EntRepository) EnsureWorkflowNameAvailable

func (r *EntRepository) EnsureWorkflowNameAvailable(
	ctx context.Context,
	projectID uuid.UUID,
	name string,
	excludeWorkflowID uuid.UUID,
) error

func (*EntRepository) Get

func (r *EntRepository) Get(ctx context.Context, workflowID uuid.UUID) (domain.Workflow, error)

func (*EntRepository) ImpactAnalysis

func (r *EntRepository) ImpactAnalysis(ctx context.Context, workflowID uuid.UUID) (domain.WorkflowImpactAnalysis, error)

func (*EntRepository) List

func (r *EntRepository) List(ctx context.Context, projectID uuid.UUID) ([]domain.Workflow, error)

func (*EntRepository) ListSkillVersions

func (r *EntRepository) ListSkillVersions(ctx context.Context, skillID uuid.UUID) ([]domain.VersionSummary, error)

func (*EntRepository) ListSkills

func (r *EntRepository) ListSkills(ctx context.Context, projectID uuid.UUID) ([]domain.Skill, error)

func (*EntRepository) ListWorkflowBoundSkillNames

func (r *EntRepository) ListWorkflowBoundSkillNames(ctx context.Context, workflowID uuid.UUID, enabledOnly bool) ([]string, error)

func (*EntRepository) ListWorkflowVersions

func (r *EntRepository) ListWorkflowVersions(ctx context.Context, workflowID uuid.UUID) ([]domain.VersionSummary, error)

func (*EntRepository) PublishWorkflowVersion

func (r *EntRepository) PublishWorkflowVersion(ctx context.Context, workflowID uuid.UUID, content string, createdBy string) (domain.Workflow, error)

func (*EntRepository) RecordedWorkflowVersion

func (r *EntRepository) RecordedWorkflowVersion(
	ctx context.Context,
	workflowID uuid.UUID,
	workflowVersionID *uuid.UUID,
) (domain.WorkflowVersionRecord, error)

func (*EntRepository) ResolveInjectedSkillNames

func (r *EntRepository) ResolveInjectedSkillNames(ctx context.Context, projectID uuid.UUID, workflowID *uuid.UUID) ([]string, error)

func (*EntRepository) ResolveRecordedRuntimeSnapshot

func (r *EntRepository) ResolveRecordedRuntimeSnapshot(
	ctx context.Context,
	input domain.ResolveRecordedRuntimeSnapshotInput,
) (domain.RuntimeSnapshot, error)

func (*EntRepository) ResolveRuntimeSnapshot

func (r *EntRepository) ResolveRuntimeSnapshot(ctx context.Context, workflowID uuid.UUID) (domain.RuntimeSnapshot, error)

func (*EntRepository) SetSkillEnabled

func (r *EntRepository) SetSkillEnabled(ctx context.Context, skillID uuid.UUID, enabled bool, updatedAt time.Time) (domain.SkillDetail, error)

func (*EntRepository) Skill

func (r *EntRepository) Skill(ctx context.Context, skillID uuid.UUID) (domain.SkillRecord, error)

func (*EntRepository) SkillByName

func (r *EntRepository) SkillByName(ctx context.Context, projectID uuid.UUID, name string) (domain.SkillRecord, error)

func (*EntRepository) SkillDetail

func (r *EntRepository) SkillDetail(ctx context.Context, skillID uuid.UUID) (domain.SkillDetail, error)

func (*EntRepository) SkillInProject

func (r *EntRepository) SkillInProject(ctx context.Context, projectID uuid.UUID, skillID uuid.UUID) (domain.SkillRecord, error)

func (*EntRepository) SkillVersionFiles

func (r *EntRepository) SkillVersionFiles(ctx context.Context, versionID uuid.UUID) ([]domain.SkillBundleFile, error)

func (*EntRepository) StatusNames

func (r *EntRepository) StatusNames(ctx context.Context, statusIDs []uuid.UUID) ([]string, error)

func (*EntRepository) Update

func (r *EntRepository) Update(ctx context.Context, workflow domain.Workflow) (domain.Workflow, error)

func (*EntRepository) UpdateSkillBundle

func (r *EntRepository) UpdateSkillBundle(
	ctx context.Context,
	skillID uuid.UUID,
	bundle domain.SkillBundle,
	updatedAt time.Time,
) (domain.SkillDetail, error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL