gatedcontext

package

v0.2.0 Latest Latest Go to latest Published: May 16, 2026 License: Apache-2.0 Imports: 5 Imported by: 0

Details

Package gatedcontext provides a processor that holds LLMContextFrame until a notifier signals release.

This section is empty.

This section is empty.

This section is empty.

type Processor struct {
	*processors.BaseProcessor
	Notifier  *notifier.Notifier
	StartOpen bool
	// contains filtered or unexported fields
}

Processor holds the latest LLMContextFrame until Notify() is called on the notifier, then pushes it.

func New(name string, n *notifier.Notifier, startOpen bool) *Processor

New returns a gated LLM context processor. When Notifier.Notify() is called, the last stored LLMContextFrame is pushed downstream.

func (p *Processor) ProcessFrame(ctx context.Context, f frames.Frame, dir processors.Direction) error

ProcessFrame holds LLMContextFrame until notifier signals; other frames pass through.

func (p *Processor) Setup(ctx context.Context) error

Setup starts the goroutine that waits on the notifier and pushes the stored frame.