invoke

Documentation

Index

• func CreateThreadForAgent(ctx context.Context, c kclient.WithWatch, agent *v1.Agent, ...) (*v1.Thread, error)
• type ErrToolResult
  • func (e ErrToolResult) Error() string
• type Invoker
  • func NewInvoker(c kclient.WithWatch, gptClient *gptscript.GPTScript, ...) *Invoker
  • func (i *Invoker) Agent(ctx context.Context, c kclient.WithWatch, agent *v1.Agent, input string, ...) (_ *Response, err error)
  • func (i *Invoker) Resume(ctx context.Context, c kclient.WithWatch, thread *v1.Thread, run *v1.Run) error
  • func (i *Invoker) Step(ctx context.Context, c kclient.WithWatch, step *v1.WorkflowStep, ...) (*Response, error)
  • func (i *Invoker) SystemTask(ctx context.Context, thread *v1.Thread, tool, input any, ...) (*Response, error)
  • func (i *Invoker) Workflow(ctx context.Context, c kclient.WithWatch, wf *v1.Workflow, input string, ...) (*Response, error)
• type Options
• type Response
  • func (r *Response) Close()
  • func (r *Response) Result(ctx context.Context) (TaskResult, error)
• type StepOptions
• type SystemTaskOptions
• type TaskResult
• type WorkflowOptions

Functions

func CreateThreadForAgent

func CreateThreadForAgent(ctx context.Context, c kclient.WithWatch, agent *v1.Agent, threadName, userUID, agentAlias string) (*v1.Thread, error)

Types

type ErrToolResult

type ErrToolResult struct {
	Message string
}

func (ErrToolResult) Error

func (e ErrToolResult) Error() string

type Invoker

type Invoker struct {
	// contains filtered or unexported fields
}

func NewInvoker

func NewInvoker(c kclient.WithWatch, gptClient *gptscript.GPTScript, gatewayClient *client.Client, serverURL string, tokenService *jwt.TokenService, events *events.Emitter) *Invoker

func (*Invoker) Agent

func (i *Invoker) Agent(ctx context.Context, c kclient.WithWatch, agent *v1.Agent, input string, opt Options) (_ *Response, err error)

func (*Invoker) Resume

func (i *Invoker) Resume(ctx context.Context, c kclient.WithWatch, thread *v1.Thread, run *v1.Run) error

func (*Invoker) Step

func (i *Invoker) Step(ctx context.Context, c kclient.WithWatch, step *v1.WorkflowStep, opt StepOptions) (*Response, error)

func (*Invoker) SystemTask

func (i *Invoker) SystemTask(ctx context.Context, thread *v1.Thread, tool, input any, opts ...SystemTaskOptions) (*Response, error)

func (*Invoker) Workflow

func (i *Invoker) Workflow(ctx context.Context, c kclient.WithWatch, wf *v1.Workflow, input string, opt WorkflowOptions) (*Response, error)

type Options

type Options struct {
	Synchronous           bool
	ThreadName            string
	WorkflowStepName      string
	WorkflowStepID        string
	WorkflowExecutionName string
	PreviousRunName       string
	ForceNoResume         bool
	CreateThread          bool
	ThreadCredentialScope *bool
	UserUID               string
	AgentAlias            string
}

type Response

type Response struct {
	Run               *v1.Run
	Thread            *v1.Thread
	WorkflowExecution *v1.WorkflowExecution
	Events            <-chan types.Progress
	// contains filtered or unexported fields
}

func (*Response) Close

func (r *Response) Close()

func (*Response) Result

func (r *Response) Result(ctx context.Context) (TaskResult, error)

type StepOptions

type StepOptions struct {
	PreviousRunName string
	Continue        *string
}

type SystemTaskOptions

type SystemTaskOptions struct {
	CredentialContextIDs []string
	Env                  []string
	Timeout              time.Duration
}

type TaskResult

type TaskResult struct {
	// Task output
	Output string
}

type WorkflowOptions

type WorkflowOptions struct {
	ThreadName            string
	StepID                string
	OwningThreadName      string
	WorkflowExecutionName string
	Events                bool
}