steps

package
v0.1.4 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 14, 2026 License: MIT Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ChatStep

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

func NewChatStep

func NewChatStep(client core.Client, inputKey, outputKey string, opts ...core.Option) *ChatStep

func (*ChatStep) Execute

func (s *ChatStep) Execute(ctx context.Context, state *pipeline.State) error

func (*ChatStep) Name

func (s *ChatStep) Name() string

type ChatStreamStep

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

func NewChatStreamStep

func NewChatStreamStep(client core.Client, inputKey, outputKey string, opts ...core.Option) *ChatStreamStep

func (*ChatStreamStep) Execute

func (s *ChatStreamStep) Execute(ctx context.Context, state *pipeline.State) error

func (*ChatStreamStep) Name

func (s *ChatStreamStep) Name() string

type EmbedSingleStep

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

func NewEmbedSingleStep

func NewEmbedSingleStep(provider embedding.Provider, inputKey, outputKey string) *EmbedSingleStep

func (*EmbedSingleStep) Execute

func (s *EmbedSingleStep) Execute(ctx context.Context, state *pipeline.State) error

func (*EmbedSingleStep) Name

func (s *EmbedSingleStep) Name() string

type EmbedStep

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

func NewEmbedStep

func NewEmbedStep(provider embedding.Provider, inputKey, outputKey string, batchSize int) *EmbedStep

func (*EmbedStep) Execute

func (s *EmbedStep) Execute(ctx context.Context, state *pipeline.State) error

func (*EmbedStep) Name

func (s *EmbedStep) Name() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL