taskengine

package

Go to main page

Versions in this module

v0

v0.6.1

Mar 18, 2026

v0.6.0

Mar 17, 2026

v0.5.1

Mar 15, 2026

v0.5.0

Mar 15, 2026

Changes in this version

+ func ExportedResolveHookNames(ctx context.Context, allowlist []string, provider HookProvider) ([]string, error)

+ func ExtractJSONArray(s string) string

+ func HookArgsFromContext(ctx context.Context, hookName string) map[string]string

+ func StripCodeFences(s string) string

+ func WithHookArgs(ctx context.Context, hookName string, args map[string]string) context.Context

type LLMExecutionConfig

+ HookPolicies map[string]map[string]string

v0.4.0

Mar 9, 2026

v0.2.4

Mar 7, 2026

v0.2.3

Mar 7, 2026

v0.2.2

Mar 6, 2026

v0.2.1

Mar 6, 2026

v0.2.0

Mar 6, 2026

Changes in this version

type LLMExecutionConfig

+ Shift bool

+ Think string

type Message

+ Thinking string

type OpenAIChatRequestMessage

+ Thinking string

+ ToolCallID string

+ ToolCalls []ToolCall

type OpenAIChatResponseMessage

+ Thinking string

type ToolCall

+ ProviderMeta map[string]string

v0.1.7

Mar 4, 2026

v0.1.6

Mar 3, 2026

v0.1.5

Mar 3, 2026

v0.1.4

Mar 3, 2026

Changes in this version

+ const TermEnd

+ var ErrHookNotFound = errors.New("hook not found")

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

+ func ConvertOpenAIToChatHistory(request OpenAIChatRequest) (ChatHistory, int, []Tool, LLMExecutionConfig)

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

+ func SupportedOperators() []string

+ func TemplateVarsFromContext(ctx context.Context) map[string]string

+ func WithTemplateVars(ctx context.Context, vars map[string]string) context.Context

+ type BranchCompose struct

+ Strategy string

+ WithVar string

+ type CapturedStateUnit struct

+ Duration time.Duration

+ Error ErrorResponse

+ Input string

+ InputType DataType

+ InputVar string

+ Output string

+ OutputType DataType

+ TaskHandler string

+ TaskID string

+ Transition string

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

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

+ type ChainContext struct

+ ClientTools []Tool

+ Debug bool

+ Tools map[string]ToolWithResolution

+ type ChainTerms string

+ type ChatHistory struct

+ InputTokens int

+ Messages []Message

+ Model string

+ OutputTokens int

+ type DataType int

+ const DataTypeAny

+ const DataTypeBool

+ const DataTypeChatHistory

+ const DataTypeFloat

+ const DataTypeInt

+ const DataTypeJSON

+ const DataTypeNil

+ 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)

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

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

+ type EnvExecutor interface

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

+ func NewEnv(_ context.Context, tracker libtracker.ActivityTracker, exec TaskExecutor, ...) (EnvExecutor, error)

+ func NewMacroEnv(inner EnvExecutor, hookProvider HookRepo) (EnvExecutor, error)

+ type ErrorResponse struct

+ Error string

+ ErrorInternal error

+ type ExecutionState struct

+ CurrentTask *TaskDefinition

+ DataTypes map[string]DataType

+ Variables map[string]any

+ type FunctionCall struct

+ Arguments string

+ Name string

+ type FunctionCallObject struct

+ Arguments any

+ Name string

+ type FunctionTool struct

+ Description string

+ Name string

+ Parameters interface{}

+ type HookCall struct

+ Args map[string]string

+ Name string

+ ToolName string

+ type HookProvider interface

+ type HookRegistry interface

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

+ type HookRepo interface

+ Exec func(ctx context.Context, startingTime time.Time, input any, debug bool, ...) (any, DataType, error)

+ type HooksWithSchema interface

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

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

+ type Inspector interface

+ Start func(ctx context.Context) StackTrace

+ func NewSimpleInspector() Inspector

+ 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

+ HideTools []string

+ Hooks []string

+ Model string

+ Models []string

+ PassClientsTools bool

+ Provider string

+ Providers []string

+ Temperature float32

+ type MacroEnv struct

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

+ type Message struct

+ CallTools []ToolCall

+ Content string

+ ID string

+ Role string

+ Timestamp time.Time

+ ToolCallID string

+ type MockTaskExecutor struct

+ CalledWithInput any

+ CalledWithPrompt string

+ CalledWithTask *TaskDefinition

+ ErrorSequence []error

+ MockError error

+ MockOutput any

+ MockOutputSequence []any

+ MockTaskTypeSequence []DataType

+ MockTransitionValue string

+ MockTransitionValueSequence []string

+ func (m *MockTaskExecutor) CallCount() int

+ func (m *MockTaskExecutor) Reset()

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

+ type OpenAIChatRequest struct

+ FrequencyPenalty float64

+ MaxTokens int

+ Messages []OpenAIChatRequestMessage

+ Model string

+ N int

+ PresencePenalty float64

+ Stop []string

+ Stream bool

+ Temperature float64

+ ToolChoice interface{}

+ Tools []Tool

+ TopP float64

+ User string

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

+ type OpenAIChatRequestMessage struct

+ Content string

+ Role string

+ type OpenAIChatResponse struct

+ Choices []OpenAIChatResponseChoice

+ Created int64

+ ID string

+ Model string

+ Object string

+ SystemFingerprint string

+ Usage OpenAITokenUsage

+ func ConvertChatHistoryToOpenAI(id string, chatHistory ChatHistory) OpenAIChatResponse

+ type OpenAIChatResponseChoice struct

+ FinishReason string

+ Index int

+ Message OpenAIChatResponseMessage

+ type OpenAIChatResponseMessage struct

+ Content *string

+ Role string

+ ToolCalls []ToolCall

+ 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 SimpleEnv struct

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

+ type SimpleExec struct

+ func (exe *SimpleExec) Embed(ctx context.Context, llmCall LLMExecutionConfig, prompt string, ctxLength int) ([]float64, error)

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

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

+ 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()

+ GetExecutionHistory func() []CapturedStateUnit

+ HasBreakpoint func(taskID string) bool

+ RecordStep func(step CapturedStateUnit)

+ SetBreakpoint func(taskID string)

+ type TaskChainDefinition struct

+ Debug bool

+ Description string

+ ID string

+ Tasks []TaskDefinition

+ TokenLimit int64

+ type TaskDefinition struct

+ Description string

+ ExecuteConfig *LLMExecutionConfig

+ Handler TaskHandler

+ Hook *HookCall

+ ID string

+ InputVar string

+ OutputTemplate string

+ Print string

+ PromptTemplate string

+ RetryOnFailure int

+ SystemInstruction string

+ Timeout string

+ Transition TaskTransition

+ ValidConditions map[string]bool

+ type TaskExecutor interface

+ TaskExec func(ctx context.Context, startingTime time.Time, ctxLength int, ...) (any, DataType, string, error)

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

+ type TaskHandler string

+ const HandleChatCompletion

+ const HandleConvertToOpenAIChatResponse

+ const HandleExecuteToolCalls

+ const HandleHook

+ const HandleNoop

+ const HandleParseKeyValue

+ const HandleParseTransition

+ const HandlePromptToCondition

+ const HandlePromptToFloat

+ const HandlePromptToInt

+ const HandlePromptToJS

+ const HandlePromptToRange

+ const HandlePromptToString

+ const HandleRaiseError

+ const HandleTextToEmbedding

+ func (t TaskHandler) String() string

+ type TaskTransition struct

+ Branches []TransitionBranch

+ OnFailure string

+ type Tool struct

+ Function FunctionTool

+ Type string

+ type ToolCall struct

+ Function FunctionCall

+ ID string

+ Type string

+ type ToolWithResolution struct

+ HookName 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

+ Compose *BranchCompose

+ Goto string

+ Operator OperatorTerm

+ When string

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