Documentation
¶
Index ¶
- type FlowRegistry
- type OODAExecutor
- func (e *OODAExecutor) Execute(ctx context.Context, input *OODAFlowInput) (*OODAFlowOutput, error)
- func (e *OODAExecutor) WithMaxRetries(maxRetries int) *OODAExecutor
- func (e *OODAExecutor) WithMiddleware(mw ...ai.Middleware) *OODAExecutor
- func (e *OODAExecutor) WithTimeout(timeout time.Duration) *OODAExecutor
- type OODAExecutorConfig
- type OODAFlow
- type OODAFlowConfig
- type OODAFlowInput
- type OODAFlowOutput
- type OODAFlowWithMiddleware
- type OODAGenkitBridge
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type FlowRegistry ¶
type FlowRegistry struct {
// contains filtered or unexported fields
}
func NewFlowRegistry ¶
func NewFlowRegistry(g *genkit.Genkit) *FlowRegistry
func (*FlowRegistry) Register ¶
func (r *FlowRegistry) Register(name string, flow *OODAFlow)
func (*FlowRegistry) RegisterAndDefine ¶
func (r *FlowRegistry) RegisterAndDefine(name string, flow *OODAFlow)
func (*FlowRegistry) Run ¶
func (r *FlowRegistry) Run(ctx context.Context, name string, input *OODAFlowInput) (*OODAFlowOutput, error)
type OODAExecutor ¶
type OODAExecutor struct {
// contains filtered or unexported fields
}
func NewOODAExecutor ¶
func NewOODAExecutor(cfg *OODAExecutorConfig) *OODAExecutor
func (*OODAExecutor) Execute ¶
func (e *OODAExecutor) Execute(ctx context.Context, input *OODAFlowInput) (*OODAFlowOutput, error)
func (*OODAExecutor) WithMaxRetries ¶
func (e *OODAExecutor) WithMaxRetries(maxRetries int) *OODAExecutor
func (*OODAExecutor) WithMiddleware ¶
func (e *OODAExecutor) WithMiddleware(mw ...ai.Middleware) *OODAExecutor
func (*OODAExecutor) WithTimeout ¶
func (e *OODAExecutor) WithTimeout(timeout time.Duration) *OODAExecutor
type OODAExecutorConfig ¶
type OODAExecutorConfig struct {
MaxRetries int
Timeout time.Duration
Middleware []ai.Middleware
KnowledgeStore ports.KnowledgeStore
TransientStore ports.TransientStore
}
type OODAFlow ¶
type OODAFlow struct {
// contains filtered or unexported fields
}
func NewOODAFlow ¶
func NewOODAFlow(cfg *OODAFlowConfig) *OODAFlow
func (*OODAFlow) DefineStreamingFlow ¶
func (*OODAFlow) Run ¶
func (f *OODAFlow) Run(ctx context.Context, input *OODAFlowInput) (*OODAFlowOutput, error)
type OODAFlowConfig ¶
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
// ParadoxThreshold is the EAST magnitude above which cognitive paradox
// injection is triggered. Defaults to ooda.DefaultParadoxThreshold.
ParadoxThreshold float64
}
type OODAFlowInput ¶
type OODAFlowOutput ¶
type OODAFlowWithMiddleware ¶
type OODAFlowWithMiddleware struct {
*OODAFlow
// contains filtered or unexported fields
}
func NewOODAFlowWithGenkit ¶
func NewOODAFlowWithGenkit(cfg *OODAFlowConfig, g *genkit.Genkit) *OODAFlowWithMiddleware
func (*OODAFlowWithMiddleware) Run ¶
func (f *OODAFlowWithMiddleware) Run(ctx context.Context, input *OODAFlowInput) (*OODAFlowOutput, error)
type OODAGenkitBridge ¶
type OODAGenkitBridge struct {
// contains filtered or unexported fields
}
func NewOODAGenkitBridge ¶
func NewOODAGenkitBridge(g *genkit.Genkit, cfg *OODAFlowConfig) *OODAGenkitBridge
func (*OODAGenkitBridge) DefineOODAFlow ¶
func (b *OODAGenkitBridge) DefineOODAFlow(name string)
func (*OODAGenkitBridge) DefineOODAStreamingFlow ¶
func (b *OODAGenkitBridge) DefineOODAStreamingFlow(name string)
func (*OODAGenkitBridge) RunOODA ¶
func (b *OODAGenkitBridge) RunOODA(ctx context.Context, input *OODAFlowInput) (*OODAFlowOutput, error)
Click to show internal directories.
Click to hide internal directories.