agents

Documentation

Index

• Constants
• func MakeChatCompletionRequest(ctx context.Context, l *slog.Logger, client *http.Client, url, apiKey string, ...) (*db.CreateChatCompletionResponse, error)
• func PollForCancellation(ctx context.Context, cancel func(), gdb *gorm.DB, obj Statuser, id string, ...)
• func RunTool(ctx context.Context, l *slog.Logger, ...) (string, error)
• func StreamChatCompletionRequest(ctx context.Context, l *slog.Logger, client *http.Client, url, apiKey string, ...) (<-chan db.ChatCompletionResponseChunk, error)
• type Statuser

Constants

const (
	EventTypeCallConfirm         runner.EventType = "callConfirm"
	EventTypeCallConfirmResponse runner.EventType = "callConfirmResponse"
)

Functions

func MakeChatCompletionRequest

func MakeChatCompletionRequest(ctx context.Context, l *slog.Logger, client *http.Client, url, apiKey string, cc *db.CreateChatCompletionRequest) (*db.CreateChatCompletionResponse, error)

func PollForCancellation

func PollForCancellation(ctx context.Context, cancel func(), gdb *gorm.DB, obj Statuser, id string, pollingInterval time.Duration)

PollForCancellation will poll for the run step with the given id. If the run step has been canceled, then the corresponding context will be canceled.

func RunTool

func RunTool(ctx context.Context, l *slog.Logger, events *broadcaster.Subscription[server.Event], gdb *gorm.DB, opts *gptscript.Options, prg types.Program, envs []string, arguments, runID, runStepID string) (string, error)

func StreamChatCompletionRequest

func StreamChatCompletionRequest(ctx context.Context, l *slog.Logger, client *http.Client, url, apiKey string, cc *db.CreateChatCompletionRequest) (<-chan db.ChatCompletionResponseChunk, error)

Types

type Statuser

type Statuser interface {
	GetStatus() string
}