taskengine

Sep 23, 2025

Changes in this version

+ type ChainContext struct

+ ClientTools []Tool

+ Tools map[string]ToolWithResolution

type DataType

+ const DataTypeNil

+ type FunctionTool struct

+ Description string

+ Name string

+ Parameters interface{}

type HookCall

+ ToolName string

+ type HookProvider interface

+ type HooksWithSchema interface

+ GetSchemasForSupportedHooks func(ctx context.Context) (map[string]*openapi3.T, error)

+ GetToolsForHookByName func(ctx context.Context, name string) ([]Tool, error)

type LLMExecutionConfig

+ HideTools []string

+ Hooks []string

+ PassClientsTools bool

type Message

+ ToolCallID string

type OpenAIChatRequest

+ ToolChoice interface{}

+ Tools []Tool

type TaskHandler

+ const HandleExecuteToolCalls

+ type Tool struct

+ Function FunctionTool

+ Type string

+ type ToolWithResolution struct

+ HookName string

Sep 4, 2025

Changes in this version

+ type FunctionCallObject struct

+ Arguments any

+ Name string

Sep 1, 2025

Changes in this version

type TaskDefinition

+ OutputTemplate string

Sep 1, 2025

Changes in this version

type TaskHandler

+ const HandleParseKeyValue

Aug 30, 2025

Changes in this version

+ type FunctionCall struct

+ Arguments string

+ Name string

type Message

+ CallTools []ToolCall

+ type OpenAIChatResponseMessage struct

+ Content *string

+ Role string

+ ToolCalls []ToolCall

+ type ToolCall struct

+ Function FunctionCall

+ ID string

+ Type string

Aug 26, 2025

Changes in this version

type CapturedStateUnit

+ InputVar string

Aug 25, 2025

Changes in this version

+ func ConvertOpenAIToChatHistory(request OpenAIChatRequest) (ChatHistory, int, LLMExecutionConfig)

type MockTaskExecutor

+ MockTaskTypeSequence []DataType

+ MockTransitionValue string

+ MockTransitionValueSequence []string

type OpenAIChatRequest

+ func ConvertChatHistoryToOpenAIRequest(chatHistory ChatHistory) (OpenAIChatRequest, int, int)

type OpenAIChatResponse

+ func ConvertChatHistoryToOpenAI(id string, chatHistory ChatHistory, config *LLMExecutionConfig) OpenAIChatResponse

type TaskHandler

+ const HandleConvertToOpenAIChatResponse

Aug 22, 2025

Changes in this version

+ type TaskChainDefinition struct

+ Debug bool

+ Description string

+ ID string

+ Tasks []TaskDefinition

+ TokenLimit int64

+ type TaskDefinition struct

+ Compose *ComposeTask

+ Description string

+ ExecuteConfig *LLMExecutionConfig

+ Handler TaskHandler

+ Hook *HookCall

+ ID string

+ InputVar string

+ Print string

+ PromptTemplate string

+ RetryOnFailure int

+ SystemInstruction string

+ Timeout string

+ Transition TaskTransition

+ ValidConditions map[string]bool

Aug 9, 2025

Changes in this version

type LLMExecutionConfig

+ Temperature float32

Aug 6, 2025

Changes in this version

+ func ConvertToType(value interface{}, dataType DataType) (interface{}, error)

Aug 6, 2025

Changes in this version

type DataType

+ func (dt DataType) UnmarshalJSON(data []byte) error

+ func (dt DataType) UnmarshalYAML(data []byte) error

Aug 6, 2025

Changes in this version

type CapturedStateUnit

+ func (c *CapturedStateUnit) UnmarshalJSON(data []byte) error

Aug 5, 2025

Changes in this version

+ const StatusError

+ const StatusSuccess

+ const StatusUnknownHookProvider

+ const TermEnd

+ var ErrUnsupportedTaskType = errors.New("executor does not support the task type")

+ func SupportedOperators() []string

+ type Alert struct

+ ID string

+ Message string

+ Metadata map[string]string

+ RequestID string

+ Timestamp time.Time

+ type AlertSink interface

+ FetchAlerts func(ctx context.Context, limit int) ([]*Alert, error)

+ SendAlert func(ctx context.Context, message string, kvPairMetadata ...string) error

+ func NewAlertSink(kvManager libkv.KVManager) AlertSink

+ type CapturedStateUnit struct

+ Duration time.Duration

+ Error ErrorResponse

+ Input string

+ InputType DataType

+ Output string

+ OutputType DataType

+ TaskHandler string

+ TaskID string

+ Transition string

+ func (c *CapturedStateUnit) MarshalJSON() ([]byte, error)

+ type ChainDefinition struct

+ Debug bool

+ Description string

+ ID string

+ RoutingStrategy string

+ Tasks []ChainTask

+ TokenLimit int64

+ type ChainTask struct

+ Compose *ComposeTask

+ Description string

+ ExecuteConfig *LLMExecutionConfig

+ Handler TaskHandler

+ Hook *HookCall

+ ID string

+ InputVar string

+ Print string

+ PromptTemplate string

+ RetryOnFailure int

+ SystemInstruction string

+ Timeout string

+ Transition TaskTransition

+ ValidConditions map[string]bool

+ type ChainTerms string

+ type ChainWithTrigger struct

+ Triggers []Trigger

+ type ChatHistory struct

+ InputTokens int

+ Messages []Message

+ Model string

+ OutputTokens int

+ type ComposeTask struct

+ Strategy string

+ WithVar string

+ type DataType int

+ const DataTypeAny

+ const DataTypeBool

+ const DataTypeChatHistory

+ const DataTypeFloat

+ const DataTypeInt

+ const DataTypeJSON

+ const DataTypeOpenAIChat

+ const DataTypeOpenAIChatResponse

+ const DataTypeSearchResults

+ const DataTypeString

+ const DataTypeVector

+ func DataTypeFromString(s string) (DataType, error)

+ func (d *DataType) String() string

+ func (d DataType) MarshalJSON() ([]byte, error)

+ func (d DataType) MarshalYAML() ([]byte, error)

+ type EnvExecutor interface

+ ExecEnv func(ctx context.Context, chain *ChainDefinition, input any, dataType DataType) (any, []CapturedStateUnit, error)

+ func NewEnv(_ context.Context, tracker activitytracker.ActivityTracker, ...) (EnvExecutor, error)

+ type ErrorResponse struct

+ Error string

+ ErrorInternal error

+ type ExecutionState struct

+ CurrentTask *ChainTask

+ DataTypes map[string]DataType

+ Variables map[string]any

+ type HookCall struct

+ Args map[string]string

+ Name string

+ type HookRegistry interface

+ Supports func(ctx context.Context) ([]string, error)

+ type HookRepo interface

+ Exec func(ctx context.Context, startingTime time.Time, input any, dataType DataType, ...) (int, any, DataType, string, error)

+ type Inspector interface

+ Start func(ctx context.Context) StackTrace

+ type KVActivitySink struct

+ func NewKVActivityTracker(kvManager libkv.KVManager) *KVActivitySink

+ func (t *KVActivitySink) GetActivityLogs(ctx context.Context, limit int) ([]TrackedEvent, error)

+ func (t *KVActivitySink) GetActivityLogsByRequestID(ctx context.Context, requestID string) ([]TrackedEvent, error)

+ func (t *KVActivitySink) GetExecutionStateByRequestID(ctx context.Context, requestID string) ([]CapturedStateUnit, error)

+ func (t *KVActivitySink) GetKnownOperations(ctx context.Context) ([]Operation, error)

+ func (t *KVActivitySink) GetRecentRequestIDs(ctx context.Context, limit int) ([]TrackedRequest, error)

+ func (t *KVActivitySink) GetRequestIDByOperation(ctx context.Context, operation Operation) ([]TrackedRequest, error)

+ func (t *KVActivitySink) GetStatefulRequests(ctx context.Context) ([]string, error)

+ func (t *KVActivitySink) Start(ctx context.Context, operation string, subject string, kvArgs ...any) (func(error), func(string, any), func())

+ type LLMExecutionConfig struct

+ Model string

+ Models []string

+ Provider string

+ Providers []string

+ type Message struct

+ Content string

+ ID string

+ Role string

+ Timestamp time.Time

+ type MessageConfig struct

+ Content string

+ Role string

+ type MockTaskExecutor struct

+ CalledWithInput any

+ CalledWithPrompt string

+ CalledWithTask *ChainTask

+ ErrorSequence []error

+ MockError error

+ MockOutput any

+ MockOutputSequence []any

+ MockRawResponse string

+ MockRawResponseSequence []string

+ func (m *MockTaskExecutor) CallCount() int

+ func (m *MockTaskExecutor) Reset()

+ func (m *MockTaskExecutor) TaskExec(ctx context.Context, startingTime time.Time, resolver llmresolver.Policy, ...) (any, DataType, string, error)

+ type NoopAlertSink struct

+ func (a *NoopAlertSink) SendAlert(ctx context.Context, msg string, kvs ...string) error

+ func (s *NoopAlertSink) FetchAlerts(ctx context.Context, limit int) ([]*Alert, error)

+ type NoopExecutionStack struct

+ func (s *NoopExecutionStack) ClearBreakpoints()

+ func (s *NoopExecutionStack) GetCurrentState() ExecutionState

+ func (s *NoopExecutionStack) GetExecutionHistory() []CapturedStateUnit

+ func (s *NoopExecutionStack) HasBreakpoint(taskID string) bool

+ func (s *NoopExecutionStack) RecordStep(step CapturedStateUnit)

+ func (s *NoopExecutionStack) SetBreakpoint(taskID string)

+ type NoopInspector struct

+ func (i *NoopInspector) Start(ctx context.Context) StackTrace

+ type OpenAIChatRequest struct

+ FrequencyPenalty float64

+ MaxTokens int

+ Messages []OpenAIChatRequestMessage

+ Model string

+ N int

+ PresencePenalty float64

+ Stop []string

+ Stream bool

+ Temperature float64

+ TopP float64

+ User string

+ type OpenAIChatRequestMessage struct

+ Content string

+ Role string

+ type OpenAIChatResponse struct

+ Choices []OpenAIChatResponseChoice

+ Created int64

+ ID string

+ Model string

+ Object string

+ SystemFingerprint string

+ Usage OpenAITokenUsage

+ type OpenAIChatResponseChoice struct

+ FinishReason string

+ Index int

+ Message OpenAIChatRequestMessage

+ type OpenAITokenUsage struct

+ CompletionTokens int

+ PromptTokens int

+ TotalTokens int

+ type Operation struct

+ Operation string

+ Subject string

+ type OperatorTerm string

+ const OpContains

+ const OpDefault

+ const OpEndsWith

+ const OpEquals

+ const OpGreaterThan

+ const OpGt

+ const OpInRange

+ const OpLessThan

+ const OpLt

+ const OpStartsWith

+ func ToOperatorTerm(s string) (OperatorTerm, error)

+ func (t OperatorTerm) String() string

+ type SearchResult struct

+ Distance float32

+ ID string

+ ResourceType string

+ type SimpleAlertSink struct

+ func (as *SimpleAlertSink) FetchAlerts(ctx context.Context, limit int) ([]*Alert, error)

+ func (as *SimpleAlertSink) SendAlert(ctx context.Context, message string, kvPairMetadata ...string) error

+ type SimpleEnv struct

+ func (exe SimpleEnv) ExecEnv(ctx context.Context, chain *ChainDefinition, input any, dataType DataType) (any, []CapturedStateUnit, error)

+ type SimpleExec struct

+ func (exe *SimpleExec) Embed(ctx context.Context, resolver llmresolver.Policy, llmCall LLMExecutionConfig, ...) ([]float64, error)

+ func (exe *SimpleExec) Prompt(ctx context.Context, resolver llmresolver.Policy, llmCall LLMExecutionConfig, ...) (string, error)

+ func (exe *SimpleExec) TaskExec(taskCtx context.Context, startingTime time.Time, resolver llmresolver.Policy, ...) (any, DataType, string, error)

+ type SimpleInspector struct

+ func NewSimpleInspector(kvManager libkv.KVManager) *SimpleInspector

+ func (m SimpleInspector) Start(ctx context.Context) StackTrace

+ type SimpleStackTrace struct

+ func (s *SimpleStackTrace) ClearBreakpoints()

+ func (s *SimpleStackTrace) GetCurrentState() ExecutionState

+ func (s *SimpleStackTrace) GetExecutionHistory() []CapturedStateUnit

+ func (s *SimpleStackTrace) HasBreakpoint(taskID string) bool

+ func (s *SimpleStackTrace) RecordStep(step CapturedStateUnit)

+ func (s *SimpleStackTrace) SetBreakpoint(taskID string)

+ type StackTrace interface

+ ClearBreakpoints func()

+ GetCurrentState func() ExecutionState

+ GetExecutionHistory func() []CapturedStateUnit

+ HasBreakpoint func(taskID string) bool

+ RecordStep func(step CapturedStateUnit)

+ SetBreakpoint func(taskID string)

+ type TaskExecutor interface

+ TaskExec func(ctx context.Context, startingTime time.Time, resolver llmresolver.Policy, ...) (any, DataType, string, error)

+ func NewExec(_ context.Context, repo llmrepo.ModelRepo, embedRepo llmrepo.ModelRepo, ...) (TaskExecutor, error)

+ type TaskHandler string

+ const HandleConditionKey

+ const HandleEmbedding

+ const HandleHook

+ const HandleModelExecution

+ const HandleNoop

+ const HandleParseNumber

+ const HandleParseRange

+ const HandleParseScore

+ const HandleParseTransition

+ const HandleRaiseError

+ const HandleRawString

+ func (t TaskHandler) String() string

+ type TaskTransition struct

+ Branches []TransitionBranch

+ OnFailure string

+ OnFailureAlert string

+ type TrackedEvent struct

+ Duration float64

+ End *time.Time

+ EntityData any

+ EntityID *string

+ Error *string

+ ID string

+ Metadata map[string]string

+ Operation string

+ RequestID string

+ Start time.Time

+ Subject string

+ type TrackedRequest struct

+ ID string

+ type TransitionBranch struct

+ AlertOnMatch string

+ Goto string

+ Operator OperatorTerm

+ When string

+ type Trigger struct

+ Description string

+ Pattern string

+ Type TriggerType

+ type TriggerType string

+ const TriggerEvent

+ const TriggerKeyword

+ const TriggerManual

+ const TriggerSemantic

+ func (t TriggerType) String() string