agents

type DeepResearchClarifier ¶ added in v0.0.4

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

func NewDeepResearchClarifier(rail flow.Rail, chatModel model.ToolCallingChatModel, ops *DeepResearchClarifierOps) (*DeepResearchClarifier, error)

func (w *DeepResearchClarifier) Execute(rail flow.Rail, input DeepResearchClarifierInput) (DeepResearchClarifierOutput, error)

type DeepResearchClarifierInput ¶ added in v0.0.4

type DeepResearchClarifierInput struct {
	Now          string `json:"now"`
	Conversation string `json:"conversation"`
	Memory       string `json:"memory"`
}

type DeepResearchClarifierOps ¶ added in v0.0.4

type DeepResearchClarifierOps struct {

	// Injected variables: ${language}
	SystemMessagePrompt string

	// Injected variables: ${now} ${conversation}, ${memory}
	UserMessagePrompt string
	// contains filtered or unexported fields
}

func NewDeepResearchClarifierOps(g *GenericOps) *DeepResearchClarifierOps

type DeepResearchClarifierOutput ¶ added in v0.0.4

type DeepResearchClarifierOutput struct {
	Title       string `json:"title"`
	Description string `json:"description"`
}

type ExecutiveSummaryWriter ¶

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

func NewExecutiveSummaryWriter(rail flow.Rail, chatModel model.ToolCallingChatModel, ops *executiveSummaryWriterOps) (*ExecutiveSummaryWriter, error)

func (w *ExecutiveSummaryWriter) Execute(rail flow.Rail, input ExecutiveSummaryWriterInput) (*ExecutiveSummaryWriterOutput, error)

type ExecutiveSummaryWriterInput ¶

type ExecutiveSummaryWriterInput struct {
	Report  string `json:"report"`
	Context string `json:"context"`
}

type ExecutiveSummaryWriterOutput ¶

type ExecutiveSummaryWriterOutput struct {
	Summary string `json:"summary"`
}

type GenericOps ¶ added in v0.0.4

type GenericOps struct {
	RepeatPrompt bool // Propmt Repeation: https://arxiv.org/html/2512.14982v1
	Now          string
	Language     string
	VisualizeDir string
	LogOnStart   bool
	LogInputs    bool
}

func NewGenericOps() *GenericOps

type MemorySummarizer ¶ added in v0.0.5

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

func NewMemorySummarizer(rail flow.Rail, chatModel model.ToolCallingChatModel, ops *MemorySummarizerOps) (*MemorySummarizer, error)

func (w *MemorySummarizer) Execute(rail flow.Rail, input MemorySummarizerInput) (MemorySummarizerOutput, error)

type MemorySummarizerInput ¶ added in v0.0.5

type MemorySummarizerInput struct {
	LongTermMemory     string `json:"longTermMemory"`
	RecentConversation string `json:"recentConversation"`
}

type MemorySummarizerOps ¶ added in v0.0.5

type MemorySummarizerOps struct {

	// Injected variables: ${language}
	SystemMessagePrompt string

	// Injected variables: ${context}, ${report}
	UserMessagePrompt string
	// contains filtered or unexported fields
}

func NewMemorySummarizerOps(g *GenericOps) *MemorySummarizerOps

type MemorySummarizerOutput ¶ added in v0.0.5

type MemorySummarizerOutput struct {
	Summary string `json:"summary"`
}

type MermaidGenerator ¶

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

Credit: 2026-01-14, Copied from https://github.com/cloudwego/eino-examples/blob/main/devops/visualize/mermaid.go with modification.

MermaidGenerator renders a Mermaid diagram from a compiled Eino graph (Graph/Chain/Workflow).

Core concepts and mapping: - Nodes: labeled with their key and component type. Lambda nodes use rounded shapes. - Special nodes: START/END are rendered with safe IDs (start_node/end_node) to avoid Mermaid keyword conflicts. - SubGraphs: nested Graph/Chain/Workflow are rendered as Mermaid sub-graphs with their component type in the title. - Edges:

• In general graphs/chains: a single solid arrow (-->), representing standard control+data execution.
• In workflows (workflowStyle=true): edges are distinguished by semantics:
• control+data: normal arrow with label "control+data" ("-- control+data -->")
• control-only: bold arrow with label "control-only" ("== control-only ==>")
• data-only: dotted arrow with label "data-only" ("-. data-only .->") Branch decision diamonds and their incoming/outgoing edges are treated as control-only in workflows.

Usage:

buf := &bytes.Buffer{}
gen := visualize.NewMermaidGenerator(buf)                // for Graph/Chain
// or
gen := visualize.NewMermaidGeneratorWorkflow(buf)        // for Workflow with labeled edges
_, _ = g.Compile(ctx, compose.WithGraphCompileCallbacks(gen), compose.WithGraphName("MyGraph"))
// Write to a Markdown file:
md := "```mermaid\n" + buf.String() + "\n```\n"
_ = os.WriteFile("my_graph.md", []byte(md), 0644)

func NewMermaidGenerator(dir string) *MermaidGenerator

func (m *MermaidGenerator) OnFinish(c context.Context, info *compose.GraphInfo)