handlers

Jan 31, 2025

Changes in this version

+ type ConditionFunc func(tc minds.ThreadContext) (bool, error)

+ func (f ConditionFunc) Evaluate(tc minds.ThreadContext) (bool, error)

Jan 31, 2025

Changes in this version

+ func Noop() *noop

+ type BoolResp struct

+ Bool bool

type First

+ func NewFirst(name string, handlers ...minds.ThreadHandler) *First

+ func (f *First) HandleThread(tc minds.ThreadContext, next minds.ThreadHandler) (minds.ThreadContext, error)

+ func (f *First) String() string

+ func (f *First) Use(middleware ...minds.Middleware)

+ func (f *First) With(middleware ...minds.Middleware) minds.ThreadHandler

type For

+ func NewFor(name string, iterations int, handler minds.ThreadHandler, fn ForConditionFn) *For

+ func (f *For) HandleThread(tc minds.ThreadContext, next minds.ThreadHandler) (minds.ThreadContext, error)

+ func (f *For) String() string

+ func (f *For) Use(middleware ...minds.Middleware)

+ func (f *For) With(middleware ...minds.Middleware) minds.ThreadHandler

+ type If struct

+ func NewIf(name string, condition SwitchCondition, trueHandler minds.ThreadHandler, ...) *If

+ func (h *If) HandleThread(tc minds.ThreadContext, next minds.ThreadHandler) (minds.ThreadContext, error)

+ func (h *If) String() string

+ func (h *If) Use(middleware ...minds.Middleware)

+ func (h *If) With(middleware ...minds.Middleware) minds.ThreadHandler

type Must

+ func NewMust(name string, agg ResultAggregator, handlers ...minds.ThreadHandler) *Must

+ func (m *Must) HandleThread(tc minds.ThreadContext, next minds.ThreadHandler) (minds.ThreadContext, error)

+ func (m *Must) String() string

+ func (m *Must) Use(middleware ...minds.Middleware)

+ func (m *Must) With(middleware ...minds.Middleware) *Must

type Policy

+ func NewPolicy(llm minds.ContentGenerator, name, systemPrompt string, ...) *Policy

+ func (h *Policy) HandleThread(tc minds.ThreadContext, next minds.ThreadHandler) (minds.ThreadContext, error)

+ func (h *Policy) String() string

type Range

+ func NewRange(name string, handler minds.ThreadHandler, values ...any) *Range

+ func (r *Range) HandleThread(tc minds.ThreadContext, next minds.ThreadHandler) (minds.ThreadContext, error)

+ func (r *Range) String() string

+ func (r *Range) Use(middleware ...minds.Middleware)

+ func (r *Range) With(middleware ...minds.Middleware) minds.ThreadHandler

+ type Sequence struct

+ func NewSequence(name string, handlers ...minds.ThreadHandler) *Sequence

+ func (s *Sequence) HandleThread(tc minds.ThreadContext, next minds.ThreadHandler) (minds.ThreadContext, error)

+ func (s *Sequence) String() string

+ func (s *Sequence) Use(middleware ...minds.Middleware)

type Switch

+ func NewSwitch(name string, defaultHandler minds.ThreadHandler, cases ...SwitchCase) *Switch

+ func (s *Switch) HandleThread(tc minds.ThreadContext, next minds.ThreadHandler) (minds.ThreadContext, error)

+ func (s *Switch) String() string

+ func (s *Switch) Use(middleware ...minds.Middleware)

+ func (s *Switch) With(middleware ...minds.Middleware) *Switch

Jan 18, 2025

Changes in this version

+ func DefaultAggregator(results []HandlerResult) (minds.ThreadContext, error)

+ type HandlerResult struct

+ Context minds.ThreadContext

+ Error error

+ Handler minds.ThreadHandler

+ type Middleware interface

+ Wrap func(minds.ThreadHandler) minds.ThreadHandler

+ type MiddlewareFunc func(minds.ThreadHandler) minds.ThreadHandler

+ func (f MiddlewareFunc) Wrap(next minds.ThreadHandler) minds.ThreadHandler

+ type ResultAggregator func([]HandlerResult) (minds.ThreadContext, error)

+ type ThreadFlow struct

+ func NewThreadFlow(name string) *ThreadFlow

+ func (f *ThreadFlow) Group(fn func(*ThreadFlow))

+ func (f *ThreadFlow) Handle(handler minds.ThreadHandler)

+ func (f *ThreadFlow) HandleThread(tc minds.ThreadContext, _ minds.ThreadHandler) (minds.ThreadContext, error)

+ func (f *ThreadFlow) String() string

+ func (f *ThreadFlow) Use(middleware ...Middleware)

Jan 11, 2025

Changes in this version

+ func Summarize(provider minds.ContentGenerator, systemMsg string) *summarize

+ func Switch(name string, defaultHandler minds.ThreadHandler, cases ...SwitchCase) *switcher

+ type LLMCondition struct

+ Generator minds.ContentGenerator

+ Prompt string

+ func (l LLMCondition) Evaluate(tc minds.ThreadContext) (bool, error)

+ type MetadataEquals struct

+ Key string

+ Value interface{}

+ func (m MetadataEquals) Evaluate(tc minds.ThreadContext) (bool, error)

+ type SwitchCase struct

+ Condition SwitchCondition

+ Handler minds.ThreadHandler

+ type SwitchCondition interface

+ Evaluate func(tc minds.ThreadContext) (bool, error)

Jan 3, 2025

Changes in this version

+ func First(name string, handlers ...minds.ThreadHandler) *anyHandler

+ func For(name string, iterations int, handler minds.ThreadHandler, fn ForConditionFn) *looper

+ func Policy(llm minds.ContentGenerator, name, systemPrompt string, ...) *policyValidator

+ type ForConditionFn func(tc minds.ThreadContext, iteration int) bool

+ type PolicyResult struct

+ Reason string

+ Valid bool

+ Violation string

Jan 2, 2025

Changes in this version

+ func Cycle(name string, iterations int, handlers ...minds.ThreadHandler) *cycler

+ func Range(name string, handler minds.ThreadHandler, values ...interface{}) *ranger

Dec 30, 2024

Changes in this version

+ func Must(name string, handlers ...minds.ThreadHandler) *mustHandler

+ func PolicyValidator(llm minds.ContentGenerator, name, systemPrompt string, ...) *policyValidator

+ func Sequential(name string, handlers ...minds.ThreadHandler) *sequential

+ func Summerize(provider minds.ContentGenerator, systemMsg string) *summarize

+ func WithDescription(description string) func(*HandlerOption)

+ func WithName(name string) func(*HandlerOption)

+ func WithPrompt(prompt minds.Prompt) func(*HandlerOption)

+ type HandlerOption struct

+ type PolicyResultFunc func(ctx context.Context, tc minds.ThreadContext, res ValidationResult) error

+ type ValidationResult struct

+ Reason string

+ Valid bool

+ Violation string