streaming

package

v0.2.0 Latest Latest Go to latest Published: Sep 3, 2025 License: MIT Imports: 9 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

StreamConsumer listens to Redis streams and forwards events to the learning Engine

func NewStreamConsumer(redisAddr string, server *mcp.Server, engine *learning.Engine) (*StreamConsumer, error)

NewStreamConsumer creates a new stream consumer that delegates to learning Engine

func (sc *StreamConsumer) PublishEvent(ctx context.Context, eventType string, data map[string]interface{}) error

PublishEvent publishes a tool event to the stream (for other components to use)

func (sc *StreamConsumer) Start(ctx context.Context) error

Start begins consuming the stream

func (sc *StreamConsumer) Stop()

Stop gracefully stops the consumer