steps

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