Documentation
¶
Index ¶
- type Config
- type Option
- func WithAgents(agents ...*agent.Agent) Option
- func WithConfig(config *Config) Option
- func WithFluxorActivityLogger(w io.Writer) Option
- func WithHistory(store memory.History) Option
- func WithLLMLogger(w io.Writer) Option
- func WithMetaService(metaService *meta.Service) Option
- func WithModelConfig(providers ...*modelprovider.Config) Option
- func WithNewElicitationAwaiter(newAwaiter func() elicitation.Awaiter) Option
- func WithToolDebugLogger(w io.Writer) Option
- func WithToolRetries(maxRetries int) Option
- func WithTools(tools tool.Registry) Option
- func WithWorkflowOptions(option ...fluxor.Option) Option
- func WithoutHotSwap() Option
- type Service
- func (e *Service) AgentService() *llmagent.Service
- func (e *Service) ApprovalService() approval.Service
- func (e *Service) Config() *Config
- func (e *Service) Conversation() *conversation.Manager
- func (e *Service) EventService() *event.Service
- func (e *Service) ExecuteTool(ctx context.Context, name string, args map[string]interface{}, ...) (interface{}, error)
- func (e *Service) ExecutionStore() *memory.ExecutionStore
- func (e *Service) IsStarted() bool
- func (e *Service) LLMCore() *core.Service
- func (e *Service) NewContext(ctx context.Context) context.Context
- func (e *Service) OAuthFinder() *oauthfinder.Finder
- func (e *Service) Orchestration() *mcp.Service
- func (e *Service) Runtime() *fluxor.Runtime
- func (e *Service) Shutdown(ctx context.Context)
- func (e *Service) Start(ctx context.Context)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct {
BaseURL string `yaml:"baseUrl" json:"baseUrl" `
Agent *mcpcfg.Group[*agent.Agent] `yaml:"agents" json:"agents"`
Model *mcpcfg.Group[*llmprovider.Config] `yaml:"models" json:"models"`
Embedder *mcpcfg.Group[*embedderprovider.Config] `yaml:"embedders" json:"embedders" `
MCP *mcpcfg.Group[*mcp.ClientOptions] `yaml:"mcp" json:"mcp"`
DAOConnector *view.DBConfig `yaml:"daoConfig" json:"daoConfig" `
Default config.Defaults `yaml:"default" json:"default"`
ToolRetries int
Services []string `yaml:"services" json:"services"`
// contains filtered or unexported fields
}
func (*Config) DefaultAgentFinder ¶
func (c *Config) DefaultAgentFinder(options ...agentloader.Option) *agentfinder.Finder
func (*Config) DefaultEmbedderFinder ¶
func (c *Config) DefaultEmbedderFinder() *embedderfinder.Finder
func (*Config) DefaultModelFinder ¶
func (c *Config) DefaultModelFinder() *modelfinder.Finder
type Option ¶
type Option func(config *Service)
func WithAgents ¶
WithAgents sets a custom agent registry.
func WithConfig ¶
func WithFluxorActivityLogger ¶
WithFluxorActivityLogger writes every executed Fluxor task (as seen by the executor listener) to the supplied writer in JSON. Passing nil disables logging.
func WithHistory ¶
WithHistory injects a custom conversation history implementation.
func WithLLMLogger ¶
WithLLMLogger redirects all LLM prompt/response traffic captured by the core LLM service to the supplied writer. Passing nil disables logging.
func WithMetaService ¶
WithMetaService sets metaService service
func WithModelConfig ¶
func WithModelConfig(providers ...*modelprovider.Config) Option
func WithNewElicitationAwaiter ¶
func WithNewElicitationAwaiter(newAwaiter func() elicitation.Awaiter) Option
WithNewElicitationAwaiter registers an interactive Awaiter responsible for resolving schema-driven user prompts ("elicitation"). When set, the awaiter is attached to the internally managed MCP client so that interactive CLI sessions can synchronously obtain the required payload.
The last non-nil value wins when the option is applied multiple times. WithNewElicitationAwaiter registers (or overrides) the Awaiter that will be used to resolve schema-based elicitation requests originating from the runtime.
Passing a non-nil Awaiter enables interactive (or otherwise custom) behaviour. Passing nil explicitly disables any previously registered Awaiter – this is useful for headless deployments such as the embedded HTTP server where blocking on stdin must be avoided.
The *last* call wins, therefore a later invocation can override an earlier one (including the implicit registration performed by the CLI helpers).
func WithToolDebugLogger ¶
WithToolDebugLogger enables debug logging for every atool call executed via the executor's atool registry. Each invocation is written to the supplied writer. Passing nil disables logging.
func WithToolRetries ¶
WithToolRetries sets the default retry count for atool execution steps.
func WithWorkflowOptions ¶
WithWorkflowOptions sets fluxor options
func WithoutHotSwap ¶
func WithoutHotSwap() Option
WithoutHotSwap disables automatic workspace hot-reload. Use this option for deterministic production runs where configuration should not change while the process is running.
type Service ¶
type Service struct {
// contains filtered or unexported fields
}
func (*Service) AgentService ¶
AgentService returns the registered llmagent service
func (*Service) ApprovalService ¶
ApprovalService exposes the Fluxor approval service from the orchestration engine. It returns nil when orchestration is not yet initialised.
func (*Service) Config ¶
Config returns the underlying configuration struct (read-only). Callers must treat the returned pointer as immutable once the executor has been initialised.
func (*Service) Conversation ¶
func (e *Service) Conversation() *conversation.Manager
Conversation returns the shared conversation manager initialised by the service.
func (*Service) EventService ¶
func (*Service) ExecuteTool ¶
func (e *Service) ExecuteTool(ctx context.Context, name string, args map[string]interface{}, timeout time.Duration) (interface{}, error)
ExecuteTool invokes a registered tool through the configured tool registry. It provides a lightweight way to run an individual tool without crafting a full workflow. When `timeout` is positive a child context with that deadline is used.
func (*Service) ExecutionStore ¶
func (e *Service) ExecutionStore() *memory.ExecutionStore
ExecutionStore returns the shared executoin store
func (*Service) LLMCore ¶
LLMCore returns the underlying llm/core service instance (mainly for introspection or test hooks).
func (*Service) OAuthFinder ¶
func (e *Service) OAuthFinder() *oauthfinder.Finder
OAuthFinder exposes decrypted OAuth2 configurations loaded from workspace.
Source Files
Directories