Documentation
¶
Overview ¶
Package pipeline provides a flexible framework for composing and executing sequences of operations (Steps) for LLM workflows like RAG and data processing.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Hook ¶
type Hook interface {
// OnStepStart is called before a step executes.
OnStepStart(ctx context.Context, step Step, state *State)
// OnStepError is called if a step returns an error.
OnStepError(ctx context.Context, step Step, state *State, err error)
// OnStepComplete is called after a step successfully executes.
OnStepComplete(ctx context.Context, step Step, state *State)
}
Hook allows observing pipeline execution.
type Pipeline ¶
type Pipeline struct {
// contains filtered or unexported fields
}
Pipeline manages a sequence of steps.
type State ¶
type State struct {
// contains filtered or unexported fields
}
State is a thread-safe container for data passed between pipeline steps.
func (*State) Get ¶
Get retrieves a value from the state. Returns nil and false if the key does not exist.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.