events

Documentation

Index

• func GenerateEvents(seed int64, prompt string) []types.AgentEvent
• type EventStream
  • func NewEventStream(seed int64, prompt string) *EventStream
  • func NewMockEventStream(seed int64, prompt string) *EventStream
  • func (es *EventStream) IsMockFast() bool
  • func (es *EventStream) Next() (types.AgentEvent, bool)
  • func (es *EventStream) PeekNext() (types.AgentEvent, bool)
• type Generator
  • func NewGenerator(seed int64) *Generator

Functions

func GenerateEvents

func GenerateEvents(seed int64, prompt string) []types.AgentEvent

Types

type EventStream

type EventStream struct {
	// contains filtered or unexported fields
}

EventStream yields AgentEvents one at a time using the same logic and RNG sequence as GenerateEvents, without running the full probe loop upfront.

func NewEventStream

func NewEventStream(seed int64, prompt string) *EventStream

NewEventStream creates a lazy generator for the given seed and prompt.

func NewMockEventStream

func NewMockEventStream(seed int64, prompt string) *EventStream

NewMockEventStream creates a fast lazy generator for llm-mock: think on the first Next(), message on the second, with no synchronous probe execution.

func (*EventStream) IsMockFast

func (es *EventStream) IsMockFast() bool

IsMockFast reports whether this stream uses the llm-mock fast path (think then message).

func (*EventStream) Next

func (es *EventStream) Next() (types.AgentEvent, bool)

Next returns the next generated event, or false when the session is exhausted.

func (*EventStream) PeekNext

func (es *EventStream) PeekNext() (types.AgentEvent, bool)

PeekNext returns the next event without advancing stream state.

type Generator

type Generator struct {
	// contains filtered or unexported fields
}

func NewGenerator

func NewGenerator(seed int64) *Generator