Versions in this module Expand all Collapse all v0 v0.1.3 Mar 13, 2026 Changes in this version + type ChatStep struct + func NewChatStep(client core.Client, inputKey, outputKey string, opts ...core.Option) *ChatStep + func (s *ChatStep) Execute(ctx context.Context, state *pipeline.State) error + func (s *ChatStep) Name() string + type ChatStreamStep struct + func NewChatStreamStep(client core.Client, inputKey, outputKey string, opts ...core.Option) *ChatStreamStep + func (s *ChatStreamStep) Execute(ctx context.Context, state *pipeline.State) error + func (s *ChatStreamStep) Name() string + type EmbedSingleStep struct + func NewEmbedSingleStep(provider embedding.Provider, inputKey, outputKey string) *EmbedSingleStep + func (s *EmbedSingleStep) Execute(ctx context.Context, state *pipeline.State) error + func (s *EmbedSingleStep) Name() string + type EmbedStep struct + func NewEmbedStep(provider embedding.Provider, inputKey, outputKey string, batchSize int) *EmbedStep + func (s *EmbedStep) Execute(ctx context.Context, state *pipeline.State) error + func (s *EmbedStep) Name() string