Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ExecService ¶
type ExecService interface {
Execute(ctx context.Context, request *TaskRequest) (*TaskResponse, error)
}
func WithActivityTracker ¶
func WithActivityTracker(service ExecService, tracker activitytracker.ActivityTracker) ExecService
type TaskRequest ¶
type TaskRequest struct {
Prompt string `json:"prompt" example:"Hello, how are you?"`
}
type TaskResponse ¶
type TasksEnvService ¶
type TasksEnvService interface {
Execute(ctx context.Context, chain *taskengine.ChainDefinition, input any, inputType taskengine.DataType) (any, taskengine.DataType, []taskengine.CapturedStateUnit, error)
taskengine.HookRegistry
}
func EnvWithActivityTracker ¶
func EnvWithActivityTracker(service TasksEnvService, tracker activitytracker.ActivityTracker) TasksEnvService
func NewTasksEnv ¶
func NewTasksEnv(ctx context.Context, environmentExec taskengine.EnvExecutor, dbInstance libdb.DBManager, hookRegistry taskengine.HookRegistry) TasksEnvService
Click to show internal directories.
Click to hide internal directories.