Documentation
¶
Index ¶
- type EntRepository
- func (r *EntRepository) ApplyWorkflowSkillBindings(ctx context.Context, workflowID uuid.UUID, skillIDs []uuid.UUID, bind bool, ...) (domain.Workflow, error)
- func (r *EntRepository) BuildHarnessTemplateData(ctx context.Context, input domain.BuildHarnessTemplateDataInput) (domain.HarnessTemplateData, error)
- func (r *EntRepository) Create(ctx context.Context, workflow domain.Workflow, harnessContent string, ...) (domain.Workflow, error)
- func (r *EntRepository) CreateSkillBundle(ctx context.Context, input domain.CreateSkillBundleInput, ...) (domain.SkillDetail, error)
- func (r *EntRepository) CurrentSkillVersion(ctx context.Context, skillID uuid.UUID, requiredVersionID *uuid.UUID) (domain.SkillVersionRecord, error)
- func (r *EntRepository) CurrentWorkflowVersion(ctx context.Context, workflowID uuid.UUID) (domain.WorkflowVersionRecord, error)
- func (r *EntRepository) Delete(ctx context.Context, workflowID uuid.UUID) (domain.Workflow, error)
- func (r *EntRepository) DeleteSkill(ctx context.Context, skillID uuid.UUID, deletedAt time.Time) error
- func (r *EntRepository) EnsureAgentBelongsToProject(ctx context.Context, projectID uuid.UUID, agentID uuid.UUID) error
- func (r *EntRepository) EnsureBuiltinSkills(ctx context.Context, projectID uuid.UUID, now time.Time, ...) error
- func (r *EntRepository) EnsureHarnessPathAvailable(ctx context.Context, projectID uuid.UUID, harnessPath string, ...) error
- func (r *EntRepository) EnsurePickupStatusBindingsAvailable(ctx context.Context, projectID uuid.UUID, statusIDs []uuid.UUID, ...) error
- func (r *EntRepository) EnsureProjectExists(ctx context.Context, projectID uuid.UUID) error
- func (r *EntRepository) EnsureStatusBindingsBelongToProject(ctx context.Context, projectID uuid.UUID, statusIDs []uuid.UUID) error
- func (r *EntRepository) EnsureWorkflowNameAvailable(ctx context.Context, projectID uuid.UUID, name string, ...) error
- func (r *EntRepository) Get(ctx context.Context, workflowID uuid.UUID) (domain.Workflow, error)
- func (r *EntRepository) ImpactAnalysis(ctx context.Context, workflowID uuid.UUID) (domain.WorkflowImpactAnalysis, error)
- func (r *EntRepository) List(ctx context.Context, projectID uuid.UUID) ([]domain.Workflow, error)
- func (r *EntRepository) ListSkillVersions(ctx context.Context, skillID uuid.UUID) ([]domain.VersionSummary, error)
- func (r *EntRepository) ListSkills(ctx context.Context, projectID uuid.UUID) ([]domain.Skill, error)
- func (r *EntRepository) ListWorkflowBoundSkillNames(ctx context.Context, workflowID uuid.UUID, enabledOnly bool) ([]string, error)
- func (r *EntRepository) ListWorkflowVersions(ctx context.Context, workflowID uuid.UUID) ([]domain.VersionSummary, error)
- func (r *EntRepository) PublishWorkflowVersion(ctx context.Context, workflowID uuid.UUID, content string, createdBy string) (domain.Workflow, error)
- func (r *EntRepository) RecordedWorkflowVersion(ctx context.Context, workflowID uuid.UUID, workflowVersionID *uuid.UUID) (domain.WorkflowVersionRecord, error)
- func (r *EntRepository) ReplaceReferences(ctx context.Context, input domain.ReplaceWorkflowReferencesInput) (domain.ReplaceWorkflowReferencesResult, error)
- func (r *EntRepository) ResolveInjectedSkillNames(ctx context.Context, projectID uuid.UUID, workflowID *uuid.UUID) ([]string, error)
- func (r *EntRepository) ResolveRecordedRuntimeSnapshot(ctx context.Context, input domain.ResolveRecordedRuntimeSnapshotInput) (domain.RuntimeSnapshot, error)
- func (r *EntRepository) ResolveRuntimeSnapshot(ctx context.Context, workflowID uuid.UUID) (domain.RuntimeSnapshot, error)
- func (r *EntRepository) SetSkillEnabled(ctx context.Context, skillID uuid.UUID, enabled bool, updatedAt time.Time) (domain.SkillDetail, error)
- func (r *EntRepository) Skill(ctx context.Context, skillID uuid.UUID) (domain.SkillRecord, error)
- func (r *EntRepository) SkillByName(ctx context.Context, projectID uuid.UUID, name string) (domain.SkillRecord, error)
- func (r *EntRepository) SkillDetail(ctx context.Context, skillID uuid.UUID) (domain.SkillDetail, error)
- func (r *EntRepository) SkillInProject(ctx context.Context, projectID uuid.UUID, skillID uuid.UUID) (domain.SkillRecord, error)
- func (r *EntRepository) SkillVersionFiles(ctx context.Context, versionID uuid.UUID) ([]domain.SkillBundleFile, error)
- func (r *EntRepository) StatusNames(ctx context.Context, statusIDs []uuid.UUID) ([]string, error)
- func (r *EntRepository) Update(ctx context.Context, workflow domain.Workflow) (domain.Workflow, error)
- func (r *EntRepository) UpdateSkillBundle(ctx context.Context, skillID uuid.UUID, bundle domain.SkillBundle, ...) (domain.SkillDetail, error)
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 (*EntRepository) BuildHarnessTemplateData ¶
func (r *EntRepository) BuildHarnessTemplateData( ctx context.Context, input domain.BuildHarnessTemplateDataInput, ) (domain.HarnessTemplateData, 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) DeleteSkill ¶
func (*EntRepository) EnsureAgentBelongsToProject ¶
func (*EntRepository) EnsureBuiltinSkills ¶
func (r *EntRepository) EnsureBuiltinSkills(ctx context.Context, projectID uuid.UUID, now time.Time, bundles []domain.SkillBundle) error
func (*EntRepository) EnsureHarnessPathAvailable ¶
func (*EntRepository) EnsurePickupStatusBindingsAvailable ¶
func (*EntRepository) EnsureProjectExists ¶
func (*EntRepository) EnsureStatusBindingsBelongToProject ¶
func (*EntRepository) EnsureWorkflowNameAvailable ¶
func (*EntRepository) ImpactAnalysis ¶
func (r *EntRepository) ImpactAnalysis(ctx context.Context, workflowID uuid.UUID) (domain.WorkflowImpactAnalysis, error)
func (*EntRepository) ListSkillVersions ¶
func (r *EntRepository) ListSkillVersions(ctx context.Context, skillID uuid.UUID) ([]domain.VersionSummary, error)
func (*EntRepository) ListSkills ¶
func (*EntRepository) ListWorkflowBoundSkillNames ¶
func (*EntRepository) ListWorkflowVersions ¶
func (r *EntRepository) ListWorkflowVersions(ctx context.Context, workflowID uuid.UUID) ([]domain.VersionSummary, error)
func (*EntRepository) PublishWorkflowVersion ¶
func (*EntRepository) RecordedWorkflowVersion ¶
func (r *EntRepository) RecordedWorkflowVersion( ctx context.Context, workflowID uuid.UUID, workflowVersionID *uuid.UUID, ) (domain.WorkflowVersionRecord, error)
func (*EntRepository) ReplaceReferences ¶
func (r *EntRepository) ReplaceReferences(ctx context.Context, input domain.ReplaceWorkflowReferencesInput) (domain.ReplaceWorkflowReferencesResult, error)
func (*EntRepository) ResolveInjectedSkillNames ¶
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 (*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 (*EntRepository) UpdateSkillBundle ¶
func (r *EntRepository) UpdateSkillBundle( ctx context.Context, skillID uuid.UUID, bundle domain.SkillBundle, updatedAt time.Time, ) (domain.SkillDetail, error)
Click to show internal directories.
Click to hide internal directories.