orchestration

Documentation

Index

• type EinoOrchestrationAgent
  • func NewEinoOrchestrationAgent(cfg *config.Config) *EinoOrchestrationAgent
  • func (oa *EinoOrchestrationAgent) HandleOrchestrationRequest(w http.ResponseWriter, r *http.Request)
  • func (oa *EinoOrchestrationAgent) Orchestrate(ctx context.Context, req *models.OrchestrationRequest) (*models.OrchestrationResponse, error)
• type QualityDecision
• type ResearchState
• type SynthesisState
• type VerificationState

Types

type EinoOrchestrationAgent

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

EinoOrchestrationAgent uses Eino framework for deterministic orchestration

func NewEinoOrchestrationAgent

func NewEinoOrchestrationAgent(cfg *config.Config) *EinoOrchestrationAgent

NewEinoOrchestrationAgent creates a new Eino-based orchestration agent

func (*EinoOrchestrationAgent) HandleOrchestrationRequest

func (oa *EinoOrchestrationAgent) HandleOrchestrationRequest(w http.ResponseWriter, r *http.Request)

HTTP Handler

func (*EinoOrchestrationAgent) Orchestrate

func (oa *EinoOrchestrationAgent) Orchestrate(ctx context.Context, req *models.OrchestrationRequest) (*models.OrchestrationResponse, error)

Orchestrate executes the deterministic Eino workflow

type QualityDecision

type QualityDecision struct {
	State     *VerificationState
	NeedMore  bool
	Shortfall int
}

type ResearchState

type ResearchState struct {
	Request       *models.OrchestrationRequest
	SearchResults []models.SearchResult
}

State types for the workflow

type SynthesisState

type SynthesisState struct {
	Request       *models.OrchestrationRequest
	SearchResults []models.SearchResult
	Candidates    []models.CandidateStatistic
}

type VerificationState

type VerificationState struct {
	Request       *models.OrchestrationRequest
	AllCandidates []models.CandidateStatistic
	Verified      []models.Statistic
	Failed        int
}