pipeline

Documentation

Overview

Package pipeline provides a thread-safe runtime registry for pipeline prompts. Both the tools package (which writes entries) and the actors package (which reads them) import this package, avoiding an import cycle.

Index

• func ClearPrompts()
• func LookupPrompt(key string) (string, bool)
• func PersistToKV(kv nats.KeyValue) error
• func RegisterPrompt(key, prompt string)
• func RestoreFromKV(kv nats.KeyValue) error

Functions

func ClearPrompts

func ClearPrompts()

ClearPrompts removes all entries from the pipeline overlay.

func LookupPrompt

func LookupPrompt(key string) (string, bool)

LookupPrompt returns the prompt for the given key, if one has been registered. Thread-safe for concurrent reads.

func PersistToKV

func PersistToKV(kv nats.KeyValue) error

PersistToKV writes all pipeline prompts to the given KV bucket.

func RegisterPrompt

func RegisterPrompt(key, prompt string)

RegisterPrompt adds or overwrites a prompt in the pipeline overlay. The key format is "language:phase" and the prompt must contain two %s placeholders (source pane alias, accumulated context) matching the convention of softdevPrompts in the actors package.

func RestoreFromKV

func RestoreFromKV(kv nats.KeyValue) error

RestoreFromKV loads pipeline prompts from the given KV bucket.