Directories
¶
| Path | Synopsis |
|---|---|
|
connectors
|
|
|
cron
Package cron provides a connector whose sources emit a message on a cron schedule.
|
Package cron provides a connector whose sources emit a message on a cron schedule. |
|
database
Package database provides a connector that owns a database/sql connection pool.
|
Package database provides a connector that owns a database/sql connection pool. |
|
events
Package events exposes the platform's broadcast pub/sub (core.Topics) to flows as first-class DSL constructs: an "event" message source that runs every message published to a subject through a flow, and the "publish-event" block that broadcasts the current message to a subject.
|
Package events exposes the platform's broadcast pub/sub (core.Topics) to flows as first-class DSL constructs: an "event" message source that runs every message published to a subject through a flow, and the "publish-event" block that broadcasts the current message to a subject. |
|
http
Package http provides a connector that turns synchronous HTTP requests into flow executions and returns the result to the caller.
|
Package http provides a connector that turns synchronous HTTP requests into flow executions and returns the result to the caller. |
|
httpclient
Package httpclient provides a connector that owns a configured net/http client for calling external HTTP APIs, plus the "rest" block that runs a single request through it and folds the response into the message body.
|
Package httpclient provides a connector that owns a configured net/http client for calling external HTTP APIs, plus the "rest" block that runs a single request through it and folds the response into the message body. |
|
llm/aiblocks
Package aiblocks provides leaf processor blocks powered by an LLM connector.
|
Package aiblocks provides leaf processor blocks powered by an LLM connector. |
|
llm/anthropic
Package anthropic provides the "llm-anthropic" connector: a configured Anthropic Messages client that satisfies core.LLMClient so the AI flow elements (ai-router, ai-agent, ai-mapping, ai-retry) can drive it without knowing which provider is behind the name they reference.
|
Package anthropic provides the "llm-anthropic" connector: a configured Anthropic Messages client that satisfies core.LLMClient so the AI flow elements (ai-router, ai-agent, ai-mapping, ai-retry) can drive it without knowing which provider is behind the name they reference. |
|
llm/gemini
Package gemini provides the "llm-gemini" connector: a configured Google Gemini client that satisfies core.LLMClient so the AI flow elements can drive it interchangeably with the other providers.
|
Package gemini provides the "llm-gemini" connector: a configured Google Gemini client that satisfies core.LLMClient so the AI flow elements can drive it interchangeably with the other providers. |
|
llm/openai
Package openai provides the "llm-openai" connector: a configured OpenAI Chat Completions client that satisfies core.LLMClient so the AI flow elements can drive it interchangeably with the other providers.
|
Package openai provides the "llm-openai" connector: a configured OpenAI Chat Completions client that satisfies core.LLMClient so the AI flow elements can drive it interchangeably with the other providers. |
|
logger
This file provides the "log" leaf block: a pass-through wire tap that logs a line for each message and forwards the message unchanged.
|
This file provides the "log" leaf block: a pass-through wire tap that logs a line for each message and forwards the message unchanged. |
|
notion
This file provides the "notion-retrieve-blocks" block: it retrieves a page's (or any block's) child blocks (GET /blocks/{id}/children), following pagination, and stores them as a {results: [...]} object.
|
This file provides the "notion-retrieve-blocks" block: it retrieves a page's (or any block's) child blocks (GET /blocks/{id}/children), following pagination, and stores them as a {results: [...]} object. |
|
queue
This file provides the "queue-dispatch" block: it sends the current message to a queue subject to load balance work across replicas.
|
This file provides the "queue-dispatch" block: it sends the current message to a queue subject to load balance work across replicas. |
|
slack
This file provides the "slack-event" block: it unwraps a verified Slack event_callback into a friendly, flat shape and filters it.
|
This file provides the "slack-event" block: it unwraps a verified Slack event_callback into a friendly, flat shape and filters it. |
|
Schema metadata registry.
|
Schema metadata registry. |
|
expr
Package expr is the runtime's expression engine.
|
Package expr is the runtime's expression engine. |
|
internal/engine
Agent memory: per-thread conversation transcripts for the ai-agent block, persisted in the runtime KV store.
|
Agent memory: per-thread conversation transcripts for the ai-agent block, persisted in the runtime KV store. |
|
internal/pool
Package pool provides the shared worker pool a flow owns and hands to any block that needs parallelism (e.g.
|
Package pool provides the shared worker pool a flow owns and hands to any block that needs parallelism (e.g. |
|
runtime
Package runtime is the application layer that wires configured connectors and flows into a running service.
|
Package runtime is the application layer that wires configured connectors and flows into a running service. |
|
schema
Package schema generates the editor capability catalogue (packages/editor/src/app/schema/capabilities.json) from the block and connector metadata registered in package core.
|
Package schema generates the editor capability catalogue (packages/editor/src/app/schema/capabilities.json) from the block and connector metadata registered in package core. |
|
dolphin is octo's companion test runner: it drives the real octo CLI against an integration and checks what comes back, so a flow can have a test suite the way any other unit of code does.
|
dolphin is octo's companion test runner: it drives the real octo CLI against an integration and checks what comes back, so a flow can have a test suite the way any other unit of code does. |
|
internal/assert
Package assert decides whether a flow did what a case said it would, and says what was wrong when it did not.
|
Package assert decides whether a flow did what a case said it would, and says what was wrong when it did not. |
|
internal/report
Package report renders what a run did — to a terminal, and to the JUnit XML a CI job reads.
|
Package report renders what a run did — to a terminal, and to the JUnit XML a CI job reads. |
|
internal/runner
Package runner runs a case against octo and says what came back.
|
Package runner runs a case against octo and says what came back. |
|
internal/suite
Package suite is what a _test.yaml is: the format, its validation, and the rules for pairing a suite with the flows it exercises.
|
Package suite is what a _test.yaml is: the format, its validation, and the rules for pairing a suite with the flows it exercises. |
|
internal
|
|
|
schemafmt
Package schemafmt renders a JSON Schema document the way both CLIs print one.
|
Package schemafmt renders a JSON Schema document the way both CLIs print one. |
|
Package services selects and constructs the runtime services provider chosen at startup by the RUNTIME_SERVICES_MODULE environment variable.
|
Package services selects and constructs the runtime services provider chosen at startup by the RUNTIME_SERVICES_MODULE environment variable. |
|
k8s
Package k8s implements the runtime services provider for a Kubernetes cluster: leader election backed by coordination/v1 Leases (so work runs on one replica) and a KV store backed by the orchestrator API (deployment-scoped, with encrypted secrets).
|
Package k8s implements the runtime services provider for a Kubernetes cluster: leader election backed by coordination/v1 Leases (so work runs on one replica) and a KV store backed by the orchestrator API (deployment-scoped, with encrypted secrets). |
|
standalone
Package standalone implements the single-process runtime services module: leader election always grants leadership (there is nothing to elect) and the KV store lives in process memory.
|
Package standalone implements the single-process runtime services module: leader election always grants leadership (there is nothing to elect) and the KV store lives in process memory. |
Click to show internal directories.
Click to hide internal directories.