ai

type DatalogValidator struct {
	// Validator is called before and after generation to enforce Datalog rules.
	Validator func(ctx context.Context, phase string, req *ai.ModelRequest, resp *ai.ModelResponse) error
}

type Example struct{}

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

type GenerationOption func(*GenerationSettings)

type GenerationSettings struct {
	Config     *core.GenerationConfig
	Middleware *MiddlewareConfig
}

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

type LoggingMiddleware struct {
	Logger core.Logger
}

type MiddlewareConfig struct {
	// Retry configures automatic retry with exponential backoff.
	Retry *middleware.Retry

	// Fallback configures alternative model fallback on failure.
	Fallback *middleware.Fallback

	// ToolApproval requires explicit approval for tool execution.
	ToolApproval *middleware.ToolApproval

	// Filesystem enables scoped file system access for the model.
	Filesystem *middleware.Filesystem

	// CustomMiddlewares allows injecting arbitrary middleware.
	CustomMiddlewares []ai.Middleware
}

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

type OODAExecutorConfig struct {
	MaxRetries     int
	Timeout        time.Duration
	Middleware     []ai.Middleware
	KnowledgeStore ports.KnowledgeStore
	TransientStore ports.TransientStore
}

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

type OODAFlowConfig struct {
	Memory          ooda.Memory
	Brain           ooda.Brain
	Executor        ooda.Executor
	Dispatcher      *ooda.Dispatcher
	KnowledgeStore  ports.KnowledgeStore
	TransientStore  ports.TransientStore
	MaxRetries      int
	Timeout         time.Duration
	GenerateOptions []core.GenerateOption
}

type OODAFlowInput struct {
	Input    string        `json:"input"`
	Intent   string        `json:"intent,omitempty"`
	TaskType ooda.TaskType `json:"task_type,omitempty"`
}

type OODAFlowOutput struct {
	Output         string                       `json:"output"`
	Status         ooda.VerifyStatus            `json:"status"`
	PhaseDurations map[ooda.Phase]time.Duration `json:"phase_durations"`
	RetryCount     int                          `json:"retry_count"`
	AuditTrail     string                       `json:"audit_trail,omitempty"`
	Error          string                       `json:"error,omitempty"`
}

type OODAFlowWithMiddleware struct {
	*OODAFlow
	// contains filtered or unexported fields
}

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

type TelemetryMiddleware struct {
	OnGenerate func(ctx context.Context, duration time.Duration, model string, inputTokens, outputTokens int)
}