agentflow

package module

Go to main page

Versions in this module

v0

v0.2.2

May 23, 2026

Changes in this version

type ObservabilityHTTPHandlerConfig

+ TraceExploreURL string

v0.2.1

May 23, 2026

v0.2.0

May 23, 2026

Changes in this version

+ var DeclarativeInterruptWorkflow = scenariobuilder.DeclarativeInterruptWorkflow

+ var MapItemField = scenariobuilder.MapItemField

+ var MapNodeInput = scenariobuilder.MapNodeInput

+ var MapOnError = scenariobuilder.MapOnError

+ var MinimalDeclarativeInterrupt = scenariobuilder.MinimalDeclarativeInterrupt

+ func NewBlobTierColdStore(config BlobTierColdStoreConfig) (tier.Store, error)

+ func NewCheckpointHTTPHandler(config CheckpointHTTPHandlerConfig) (http.Handler, error)

+ func NewInMemoryCheckpointHistory() runstate.CheckpointHistory

+ func NewLLMTierSummarizer(gateway llm.Chatter, profile string) tier.ContentSummarizer

+ func NewPostgresCheckpointHistory(db *sql.DB, tableName ...string) (runstate.CheckpointHistory, error)

+ func NewRetentionHTTPHandler(config RetentionHTTPHandlerConfig) (http.Handler, error)

+ func NewStudioHTTPHandler(config StudioHTTPHandlerConfig) (http.Handler, error)

+ func NewTierColdSummaryIndexer(config TierColdSummaryIndexerConfig) (tier.ColdSummaryIndexer, error)

+ type BlobTierColdStoreConfig struct

+ Blobs runstate.BlobStore

+ IndexDir string

+ type CheckpointHTTPHandlerConfig struct

+ Framework *Framework

+ MaxBodyBytes int64

+ type CodegenResult struct

+ Code string

+ Language string

+ type ForkRunResult struct

+ ForkFromVersion int64

+ ParentRunID string

+ RunID string

+ ThreadID string

type Framework

+ func (f *Framework) CompareRuns(ctx context.Context, runA, runB string) (studio.RunCompareResult, error)

+ func (f *Framework) ExportScenarioGraph() ScenarioGraph

+ func (f *Framework) ForkRun(ctx context.Context, parentRunID string, version int64) (ForkRunResult, error)

+ func (f *Framework) GenerateStudioBuilderCode(_ context.Context, edited graph.ScenarioGraph) (CodegenResult, error)

+ func (f *Framework) GenerateStudioScenarioYAML(_ context.Context, edited graph.ScenarioGraph) (CodegenResult, error)

+ func (f *Framework) GetRunCheckpoint(ctx context.Context, runID string, version int64) (runstate.RunSnapshot, error)

+ func (f *Framework) ImportStudioScenarioYAML(_ context.Context, yamlData []byte, layout graph.ScenarioGraph) (ImportStudioResult, error)

+ func (f *Framework) ListRunCheckpoints(ctx context.Context, runID string, limit int) (ListRunCheckpointsResult, error)

+ func (f *Framework) ListRunSteps(ctx context.Context, runID string) (ListRunStepsResult, error)

+ func (f *Framework) ListRunThread(ctx context.Context, runID string) ([]ThreadRunSummary, error)

+ func (f *Framework) ResumeFromCheckpoint(ctx context.Context, runID string, version int64) (RunResult, error)

+ func (f *Framework) ResumeFromStep(ctx context.Context, runID, nodeID string) (RunResult, error)

+ func (f *Framework) ResumeRunByID(ctx context.Context, runID string, decision core.Decision, ...) (RunResult, error)

+ func (f *Framework) RunStudioGraph(ctx context.Context, edited graph.ScenarioGraph, req RunRequest) (RunResult, error)

+ func (f *Framework) SaveStudioGraph(ctx context.Context, edited graph.ScenarioGraph, path string) (SaveStudioResult, error)

+ func (f *Framework) ValidateStudioGraph(_ context.Context, edited graph.ScenarioGraph) (ValidateStudioResult, error)

+ type GraphEdge = graph.GraphEdge

+ type GraphNode = graph.GraphNode

+ type GraphView = graph.GraphView

+ type ImportStudioResult struct

+ Graph graph.ScenarioGraph

+ ScenarioName string

+ type ListRunCheckpointsResult struct

+ Checkpoints []runstate.CheckpointSummary

+ RunID string

+ type ListRunStepsResult struct

+ CurrentNodeID string

+ PendingHITL *PendingHITLInfo

+ RunID string

+ Status runstate.RunStatus

+ Steps []RunStep

+ Version int64

+ type MapBranch = scenariobuilder.MapBranch

type ObservabilityHTTPHandlerConfig

+ Framework *Framework

+ StudioSavePath string

type Option

+ func WithCheckpointHistory(history runstate.CheckpointHistory) Option

+ func WithTierColdSummarizer(name string, summarizer tier.ContentSummarizer) Option

+ func WithTierColdSummaryIndexer(name string, indexer tier.ColdSummaryIndexer) Option

+ type PendingHITLInfo struct

+ Interrupt bool

+ NodeID string

type ProductionHTTPHandlerConfig

+ StudioSavePath string

+ type RetentionHTTPHandlerConfig struct

+ Audit audit.Sink

+ Framework *Framework

+ MaxBodyBytes int64

+ Policy security.Policy

+ type RunStep struct

+ NodeID string

+ Output runstate.StepOutputRef

+ type SaveStudioResult struct

+ Graph graph.ScenarioGraph

+ Path string

+ ScenarioName string

+ type ScenarioGraph = graph.ScenarioGraph

+ type StudioHTTPHandlerConfig struct

+ Framework *Framework

+ MaxBodyBytes int64

+ StudioSavePath string

+ type ThreadRunSummary struct

+ ForkFromVersion int64

+ ParentRunID string

+ RunID string

+ ScenarioName string

+ Status runstate.RunStatus

+ ThreadID string

+ type TierColdSummaryIndexerConfig struct

+ Embedder llm.Embedder

+ MemoryName string

+ Profile string

+ Store knowledge.VectorStore

+ type ValidateStudioResult struct

+ Error string

+ ErrorCode string

+ Scenario string

+ Valid bool

v0.1.10

May 22, 2026

Changes in this version

+ var AdaptiveRAG = scenariobuilder.AdaptiveRAG

+ var AdaptiveRAGWorkflow = scenariobuilder.AdaptiveRAGWorkflow

+ var CodeReviewPipeline = scenariobuilder.CodeReviewPipeline

+ var CodeReviewPipelineWorkflow = scenariobuilder.CodeReviewPipelineWorkflow

+ var ContextGovernance = scenariobuilder.ContextGovernance

+ var CorrectiveRAG = scenariobuilder.CorrectiveRAG

+ var CorrectiveRAGWorkflow = scenariobuilder.CorrectiveRAGWorkflow

+ var FixedWorkflowReviewWorkflow = scenariobuilder.FixedWorkflowReviewWorkflow

+ var HybridResearch = scenariobuilder.HybridResearch

+ var HybridResearchWorkflow = scenariobuilder.HybridResearchWorkflow

+ var MinimalAutonomous = scenariobuilder.MinimalAutonomous

+ var MinimalFilesystemTool = scenariobuilder.MinimalFilesystemTool

+ var MinimalFixedWorkflowReview = scenariobuilder.MinimalFixedWorkflowReview

+ var MinimalHTTPTool = scenariobuilder.MinimalHTTPTool

+ var MinimalHumanInLoop = scenariobuilder.MinimalHumanInLoop

+ var MinimalMCPTool = scenariobuilder.MinimalMCPTool

+ var MinimalRAG = scenariobuilder.MinimalRAG

+ var MinimalSQLTool = scenariobuilder.MinimalSQLTool

+ var MinimalTicketHandling = scenariobuilder.MinimalTicketHandling

+ var MultiExpertResearch = scenariobuilder.MultiExpertResearch

+ var MultiExpertResearchWorkflow = scenariobuilder.MultiExpertResearchWorkflow

+ var NewMinimal = scenariobuilder.NewMinimal

+ var NewScenarioBuilder = scenariobuilder.New

+ var NewWorkflowBuilder = scenariobuilder.NewWorkflow

+ var SelfRAG = scenariobuilder.SelfRAG

+ var SelfRAGWorkflow = scenariobuilder.SelfRAGWorkflow

+ var TierMemoryAutonomous = scenariobuilder.TierMemoryAutonomous

+ var WorkflowEnhancements = scenariobuilder.WorkflowEnhancements

+ var WorkflowEnhancementsWorkflow = scenariobuilder.WorkflowEnhancementsWorkflow

+ type ScenarioBuilder = scenariobuilder.ScenarioBuilder

+ type WorkflowBuilder = scenariobuilder.WorkflowBuilder

v0.1.9

May 22, 2026

Changes in this version

+ func NewCognitiveTierMemory(manager tier.Manager, weights tier.RecallWeights) memory.CognitiveMemory

+ func NewCompositeTierStore(config CompositeTierStoreConfig) tier.Store

+ func NewFileTierColdStore(dir string) (tier.Store, error)

+ func NewInMemoryTierHotStore() tier.Store

+ func NewPostgresTierWarmStore(config PostgresTierWarmStoreConfig) (tier.Store, error)

+ type CompositeTierStoreConfig struct

+ Cold tier.Store

+ Hot tier.Store

+ Warm tier.Store

type Option

+ func WithCognitiveMemory(name string, repo memory.CognitiveMemory) Option

+ func WithJobQueue(queue async.Queue) Option

+ func WithTierMemory(name string, manager tier.Manager) Option

+ func WithTierStore(name string, store tier.Store, policy tier.Policy) Option

+ type PostgresTierWarmStoreConfig struct

+ DB *sql.DB

+ TableName string

v0.1.8

May 21, 2026

Changes in this version

+ func LoadSkillManifest(data []byte) (core.Skill, error)

+ func LoadSkillManifestFile(path string) (core.Skill, error)

+ func LoadToolManifest(data []byte) (core.Tool, error)

+ func LoadToolManifestFile(path string) (core.Tool, error)

+ func NewOpenTelemetryStdoutTracerProvider(ctx context.Context, config OpenTelemetryTracerProviderConfig) (*sdktrace.TracerProvider, error)

+ func NewOpenTelemetryTracer(tracer oteltrace.Tracer) observability.Tracer

+ func OpenTelemetryTracerFromProvider(provider *sdktrace.TracerProvider, instrumentationName string) observability.Tracer

+ func ValidateSkillManifest(skill core.Skill) error

+ func ValidateToolManifest(tool core.Tool) error

+ type OpenTelemetryTracer = oteladapter.Tracer

+ type OpenTelemetryTracerProviderConfig = oteladapter.TracerProviderConfig

type ProductionHTTPHandlerConfig

+ MetricsHandler http.Handler

v0.1.7

May 21, 2026

v0.1.6

May 21, 2026

Changes in this version

+ func NewVerboseSlogEventSink(logger *stdslog.Logger) core.EventSink

v0.1.5

May 21, 2026

Changes in this version

+ func NewLLMReranker(gateway llm.Gateway, profile string) knowledge.Reranker

+ func NewScoreReranker() knowledge.Reranker

+ type KnowledgeRegistry struct

+ Embedder llm.Embedder

+ Reranker knowledge.Reranker

+ Store knowledge.VectorStore

+ type MCPRegistry struct

+ Clients map[string]mcp.Client

+ HTTPClient *http.Client

type Option

+ func KnowledgeWiringOptions(scenario core.Scenario, registry KnowledgeRegistry) ([]Option, error)

+ func MCPWiringOptions(ctx context.Context, scenario core.Scenario, registry MCPRegistry) ([]Option, error)

+ func WireMCPTools(ctx context.Context, scenario core.Scenario, registry MCPRegistry) ([]Option, error)

v0.1.4

May 21, 2026

Changes in this version

+ const SchemaVersion

+ const Version

+ func BuildProductionHTTPHandler(cfg ProductionConfig, fw *Framework, queue asyncpkg.Queue) (http.Handler, error)

+ func IsLoopbackAddr(addr string) bool

+ func NewMockLLMGateway(scenario core.Scenario) llm.Gateway

+ func NewProductionQueue(cfg ProductionConfig, db **sql.DB) (asyncpkg.Queue, error)

+ func NewProductionWorker(cfg ProductionConfig, queue asyncpkg.Queue, fw *Framework) (*asyncpkg.Worker, error)

+ func PrometheusMetricsHandler(recorder *PrometheusRecorder) http.Handler

+ func ScenarioJSONSchema() []byte

+ func ValidateWiring(scenario core.Scenario, opts ...Option) error

+ func ValidateWiringWithOptions(scenario core.Scenario, wiring WiringOptions, opts ...Option) error

+ type DevelopmentConfig = DemoConfig

type Framework

+ func NewProduction(cfg ProductionConfig, tokenWriter io.Writer) (*Framework, error)

+ func (f *Framework) Catalog() catalog.Catalog

+ func (f *Framework) Close(ctx context.Context) error

+ func (f *Framework) PurgeExpired(ctx context.Context, maxAge time.Duration) (int, error)

+ func (f *Framework) PurgeOrphanBlobs(ctx context.Context) (int, error)

+ func (f *Framework) PurgeRuns(ctx context.Context, filter runstate.ListFilter) (int, error)

+ func (f *Framework) PurgeWithPolicy(ctx context.Context, policy RetentionPolicy) (int, error)

type Option

+ func DevelopmentOptions(scenario core.Scenario, config DevelopmentConfig) ([]Option, error)

+ func ProductionOptions(cfg ProductionConfig, scenario core.Scenario, workDir string) ([]Option, error)

+ func WithCloser(fn func(context.Context) error) Option

+ func WithDatabase(db *sql.DB) Option

+ func WithRequireLLM() Option

+ type ProductionConfig struct

+ APIKey string

+ AuditFile string

+ Concurrency int

+ HTTPAddr string

+ JobTimeout time.Duration

+ LeaseTTL time.Duration

+ PollInterval time.Duration

+ PostgresDSN string

+ PrincipalID string

+ QueueKind string

+ RenewInterval time.Duration

+ ScenarioFile string

+ StateDir string

+ TenantID string

+ TokenSecret string

+ TokenTTL time.Duration

+ Version string

+ WorkerID string

+ func LoadProductionConfigFromEnv() (ProductionConfig, error)

+ type PrometheusRecorder = promrecorder.Recorder

+ func NewPrometheusRecorder() *PrometheusRecorder

+ type RetentionPolicy struct

+ Limit int

+ MaxAge time.Duration

+ ScenarioName string

+ Status runstate.RunStatus

+ type WiringOptions struct

+ AllowMockProviderWithoutGW bool

+ RequireLLM bool

v0.1.3

May 20, 2026

Changes in this version

+ func DemoWorkDir(scenarioFile string) (string, error)

+ type DemoConfig struct

+ GitRoots []string

+ WorkDir string

type Option

+ func DemoOptions(scenario core.Scenario, config DemoConfig) ([]Option, error)

v0.1.2

May 20, 2026

Changes in this version

+ func NewFrameworkJobHandler(config FrameworkRunJobHandlerConfig) (asyncpkg.Handler, error)

+ func NewGitToolExecutor(config GitToolConfig) (core.ToolExecutor, error)

+ func NewHumanHTTPHandler(config HumanHTTPHandlerConfig) http.Handler

+ func NewTicketToolExecutor(config TicketToolConfig) (core.ToolExecutor, error)

+ func NewWebhookHTTPHandler(config WebhookHTTPHandlerConfig) (http.Handler, error)

+ type EventRouter = eventrouter.Router

+ func NewEventRouter(scenario core.Scenario) *EventRouter

type Framework

+ func (f *Framework) HandleEvent(ctx context.Context, event IncomingEvent) (RunResult, error)

+ func (f *Framework) ResolveEvent(event IncomingEvent) (RunRequest, error)

+ func (f *Framework) ResumeAndContinue(ctx context.Context, token string, decision core.Decision, ...) (RunResult, error)

+ type GitToolConfig struct

+ AllowedRoots []string

+ type HumanHTTPHandlerConfig struct

+ Framework *Framework

+ MaxBodyBytes int64

+ type IncomingEvent = eventrouter.Event

type ProductionHTTPHandlerConfig

+ Framework *Framework

+ type Ticket = toolticket.Ticket

+ type TicketStore = toolticket.Store

+ func NewMemoryTicketStore(seed map[string]Ticket) TicketStore

+ type TicketToolConfig struct

+ Store toolticket.Store

+ type WebhookHTTPHandlerConfig struct

+ Framework *Framework

+ MaxBodyBytes int64

v0.1.1

May 17, 2026

Changes in this version

type Option

+ func WithLogger(logger appexec.Logger) Option

+ func WithRecorder(recorder observability.Recorder) Option

+ func WithTracer(tracer observability.Tracer) Option

v0.1.0

May 17, 2026

Changes in this version

+ func LoadScenario(data []byte) (core.Scenario, error)

+ func LoadScenarioFile(path string) (core.Scenario, error)

+ func NewAPIKeyMiddleware(config APIKeyMiddlewareConfig) (func(http.Handler) http.Handler, error)

+ func NewAnthropicGateway(profiles []llm.Profile, client *http.Client) llm.Gateway

+ func NewAsyncRunHTTPHandler(config AsyncRunHTTPHandlerConfig) (http.Handler, error)

+ func NewAuthorizationMiddleware(config AuthorizationMiddlewareConfig) (func(http.Handler) http.Handler, error)

+ func NewEventFanoutSink(sinks ...core.EventSink) core.EventSink

+ func NewEventHub() *observability.EventHub

+ func NewEventStoreSink(store observability.EventStore, publishers ...observability.EventPublisher) core.EventSink

+ func NewFileAuditSink(path string) (audit.Sink, error)

+ func NewFileBlobStore(dir string) (runstate.BlobStore, error)

+ func NewFileKnowledgeLoader(config FileKnowledgeLoaderConfig) (knowledge.Loader, error)

+ func NewFileMemoryRepository(dir string) (memory.Repository, error)

+ func NewFileRunStateRepository(dir string) (runstate.Repository, error)

+ func NewFilesystemToolExecutor(config FilesystemToolConfig) (core.ToolExecutor, error)

+ func NewFrameworkRunJobHandler(config FrameworkRunJobHandlerConfig) (asyncpkg.Handler, error)

+ func NewHTTPKnowledgeLoader(config HTTPKnowledgeLoaderConfig) (knowledge.Loader, error)

+ func NewHTTPToolExecutor(config HTTPToolConfig) (core.ToolExecutor, error)

+ func NewInMemoryAuditSink(limit int) audit.Sink

+ func NewInMemoryBlobStore() runstate.BlobStore

+ func NewInMemoryEventStore() observability.EventStore

+ func NewInMemoryJobQueue() asyncpkg.Queue

+ func NewInMemoryRunStateRepository() runstate.Repository

+ func NewJWTAuthenticator(config JWTAuthenticatorConfig) (security.BearerAuthenticator, error)

+ func NewJWTMiddleware(config JWTMiddlewareConfig) (func(http.Handler) http.Handler, error)

+ func NewKnowledgeIndexer(config KnowledgeIndexerConfig) (*knowledge.Indexer, error)

+ func NewLLMRouter(routes map[string]llm.Gateway) llm.Gateway

+ func NewLocalGateway(profiles []llm.Profile, client *http.Client) llm.Gateway

+ func NewMCPHTTPClient(endpoint string, client *http.Client) (mcp.Client, error)

+ func NewMCPToolExecutor(client mcp.Client, tool string) (core.ToolExecutor, error)

+ func NewNoopAuditSink() audit.Sink

+ func NewOIDCJWTAuthenticator(config OIDCJWTAuthenticatorConfig) (security.BearerAuthenticator, error)

+ func NewObservabilityEventSink(recorder observability.Recorder, tracer observability.Tracer, ...) core.EventSink

+ func NewObservabilityHTTPHandler(config ObservabilityHTTPHandlerConfig) (http.Handler, error)

+ func NewOpenAICompatibleEmbedder(profiles []llm.Profile, client *http.Client) llm.Embedder

+ func NewOpenAICompatibleGateway(profiles []llm.Profile, client *http.Client) llm.Gateway

+ func NewPostgresEventStore(ctx context.Context, config PostgresEventStoreConfig) (observability.EventStore, error)

+ func NewPostgresJobQueue(db *sql.DB, tableName ...string) (asyncpkg.Queue, error)

+ func NewPostgresRunStateRepository(db *sql.DB, tableName ...string) (runstate.Repository, error)

+ func NewPostgresVectorStore(config PostgresVectorStoreConfig) (knowledge.VectorStore, error)

+ func NewProductionHTTPHandler(config ProductionHTTPHandlerConfig) (http.Handler, error)

+ func NewRedisLocker(config RedisLockerConfig) (coordination.Locker, error)

+ func NewRedisRunStateRepository(config RedisRunStateRepositoryConfig) (runstate.Repository, error)

+ func NewRetrieverTool(config RetrieverToolConfig) (core.ToolExecutor, error)

+ func NewS3BlobStore(config S3BlobStoreConfig) (runstate.BlobStore, error)

+ func NewSQLToolExecutor(config SQLToolConfig) (core.ToolExecutor, error)

+ func NewSlogAuditSink(logger *stdslog.Logger) audit.Sink

+ func NewSlogEventSink(logger *stdslog.Logger) core.EventSink

+ func NewStaticAPIKeyAuthenticator(keys map[string]identity.Principal) (security.APIKeyAuthenticator, error)

+ func ValidateScenario(scenario core.Scenario) error

+ type APIKeyMiddlewareConfig struct

+ Authenticator security.APIKeyAuthenticator

+ HeaderName string

+ type AsyncRunHTTPHandlerConfig struct

+ Audit audit.Sink

+ IDGenerator func() string

+ MaxBodyBytes int64

+ Now func() time.Time

+ Policy security.Policy

+ Queue asyncpkg.Queue

+ type AuthorizationMiddlewareConfig struct

+ Action security.Action

+ Audit audit.Sink

+ Policy security.Policy

+ Resource security.Resource

+ ResourceFunc func(*http.Request) security.Resource

+ type FileKnowledgeLoaderConfig struct

+ MaxBytes int64

+ Metadata map[string]string

+ Namespace string

+ Paths []string

+ type FilesystemToolConfig struct

+ AllowedRoots []string

+ MaxBytes int64

+ type Framework struct

+ func New(scenario core.Scenario, opts ...Option) (*Framework, error)

+ func NewFromFile(path string, opts ...Option) (*Framework, error)

+ func (f *Framework) BlobStore() runstate.BlobStore

+ func (f *Framework) Resume(ctx context.Context, token string, decision core.Decision, ...) error

+ func (f *Framework) Run(ctx context.Context, req RunRequest) (RunResult, error)

+ func (f *Framework) RunStateRepository() runstate.Repository

+ func (f *Framework) RunStructured(ctx context.Context, req RunRequest) (RunResult, error)

+ func (f *Framework) Scenario() core.Scenario

+ func (f *Framework) Stream(ctx context.Context, req RunRequest) (<-chan llm.ChatChunk, error)

+ type FrameworkRunJobHandlerConfig struct

+ Framework *Framework

+ type HTTPKnowledgeLoaderConfig struct

+ Client *http.Client

+ MaxBytes int64

+ Metadata map[string]string

+ Namespace string

+ URLs []string

+ type HTTPToolConfig struct

+ AllowedHosts []string

+ AllowedMethods []string

+ Client *http.Client

+ DefaultHeaders map[string]string

+ MaxResponseBytes int64

+ type JWTAlgorithm string

+ const JWTAlgorithmHS256

+ const JWTAlgorithmRS256

+ type JWTAuthenticatorConfig struct

+ Audience string

+ Issuer string

+ Keys []JWTKey

+ Leeway time.Duration

+ Now func() time.Time

+ PrincipalType identity.PrincipalType

+ ProjectClaim string

+ RolesClaim string

+ TenantClaim string

+ WorkspaceClaim string

+ type JWTKey struct

+ Algorithm JWTAlgorithm

+ HMACSecret []byte

+ ID string

+ RSAPublicKeyPEM []byte

+ type JWTMiddlewareConfig struct

+ Authenticator security.BearerAuthenticator

+ type KnowledgeIndexerConfig struct

+ BatchSize int

+ Chunker knowledge.Chunker

+ Embedder llm.Embedder

+ Namespace string

+ Profile string

+ Store knowledge.VectorStore

+ type LLMProviderRouter interface

+ func NewLLMProviderRouter(routes map[string]llm.Gateway) LLMProviderRouter

+ type MCPStdioClient interface

+ Close func() error

+ func NewMCPStdioClient(ctx context.Context, config MCPStdioClientConfig) (MCPStdioClient, error)

+ type MCPStdioClientConfig struct

+ Args []string

+ Command string

+ Dir string

+ Env []string

+ type OIDCJWTAuthenticatorConfig struct

+ Audience string

+ DiscoveryURL string

+ HTTPClient *http.Client

+ Issuer string

+ JWKSURL string

+ Leeway time.Duration

+ Now func() time.Time

+ PrincipalType identity.PrincipalType

+ ProjectClaim string

+ RefreshInterval time.Duration

+ RolesClaim string

+ TenantClaim string

+ WorkspaceClaim string

+ type ObservabilityHTTPHandlerConfig struct

+ AuthMiddleware func(http.Handler) http.Handler

+ Hub *observability.EventHub

+ Store observability.EventStore

+ type OpenAICompatibleProvider interface

+ func NewOpenAICompatibleProvider(profiles []llm.Profile, client *http.Client) OpenAICompatibleProvider

+ type Option func(*options) error

+ func WithAuditSink(sink audit.Sink) Option

+ func WithBlobStore(store runstate.BlobStore) Option

+ func WithEventSink(sink core.EventSink) Option

+ func WithHITLTokenSecret(secret []byte, tokenWriter io.Writer) Option

+ func WithHITLTokenTTL(ttl time.Duration) Option

+ func WithHumanGate(gate core.HumanGate) Option

+ func WithLLMGateway(gateway llm.Gateway) Option

+ func WithMemoryRepository(name string, repo memory.Repository) Option

+ func WithOutputRedactor(redactor governance.OutputRedactor) Option

+ func WithRunStateRepository(repo runstate.Repository) Option

+ func WithSecurityPolicy(policy security.Policy) Option

+ func WithToolExecutor(name string, executor core.ToolExecutor) Option

+ func WithToolGovernancePolicy(policy governance.ToolPolicy) Option

+ func WithToolResolver(resolver core.ToolResolver) Option

+ type Plan struct

+ LLMs map[string]llm.Profile

+ Memory map[string]memory.Namespace

+ Scenario core.Scenario

+ func BuildPlan(scenario core.Scenario) (Plan, error)

+ type PostgresEventStoreConfig struct

+ DB *sql.DB

+ SkipSchemaSetup bool

+ TableName string

+ type PostgresVectorStoreConfig struct

+ DB *sql.DB

+ TableName string

+ type ProductionHTTPHandlerConfig struct

+ Audit audit.Sink

+ AuthMiddleware func(http.Handler) http.Handler

+ IDGenerator func() string

+ MaxBodyBytes int64

+ Now func() time.Time

+ Policy security.Policy

+ Queue asyncpkg.Queue

+ Version string

+ type RedisLockerConfig struct

+ Addr string

+ DB int

+ DialTimeout time.Duration

+ KeyPrefix string

+ Password string

+ ReadTimeout time.Duration

+ WriteTimeout time.Duration

+ type RedisRunStateRepositoryConfig struct

+ Addr string

+ DB int

+ DialTimeout time.Duration

+ KeyPrefix string

+ Password string

+ ReadTimeout time.Duration

+ WriteTimeout time.Duration

+ type RetrieverToolConfig struct

+ CandidateMultiplier int

+ DefaultLimit int

+ Embedder llm.Embedder

+ Namespace string

+ Profile string

+ Reranker knowledge.Reranker

+ SearchMode knowledge.SearchMode

+ Store knowledge.VectorStore

+ TextWeight float64

+ VectorWeight float64

+ type RunRequest = appexec.RunRequest

+ type RunResult = appexec.RunResult

+ type S3BlobStoreConfig struct

+ AccessKeyID string

+ Bucket string

+ Endpoint string

+ HTTPClient *http.Client

+ Prefix string

+ Region string

+ SecretAccessKey string

+ SessionToken string

+ type SQLToolConfig struct

+ AllowAdHocQuery bool

+ AllowedQueries map[string]string

+ DB *sql.DB

+ MaxRows int

+ Timeout time.Duration

+ type ToolResolver = core.ToolResolver

+ type ToolResolverFunc = core.ToolResolverFunc

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL