streaming

package

v0.1.1 Latest Latest Go to latest Published: Sep 2, 2025 License: MIT Imports: 8 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 ProactiveSuggestionEngine

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

NewStreamConsumer creates a new stream consumer that delegates to ProactiveSuggestionEngine

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