thread

Documentation

Index

• type History
  • func Clone(h *History) *History
  • func Reset(h *History) *History
• type Thread
  • func NewThread(history *History, client *bootstrap.ClientRef, host *host.Host) (*Thread, error)
  • func (t *Thread) Post(ctx context.Context, message string) (*History, error)
• type ToolRunner
  • func NewToolRunner(host *host.Host) *ToolRunner
  • func (c *ToolRunner) Add(toolCall *openai.ChatCompletionMessageToolCall) error
  • func (c *ToolRunner) Complete(ctx context.Context) ([]openai.ChatCompletionMessageParamUnion, error)
• type ToolRunnerHandler

Types

type History

type History struct {
	Messages []openai.ChatCompletionMessageParamUnion

	// Total number of tokens in the history. Doesn't include the
	// pending messages.
	Toks int

	// A collection of pending messages to be delivered with the next
	// user message.
	Pending []string
}

func Clone

func Clone(h *History) *History

func Reset

func Reset(h *History) *History

Reset returns only the part of the history that contains the system message, if any.

type Thread

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

func NewThread

func NewThread(
	history *History,
	client *bootstrap.ClientRef,
	host *host.Host,
) (*Thread, error)

func (*Thread) Post

func (t *Thread) Post(ctx context.Context, message string) (*History, error)

type ToolRunner

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

func NewToolRunner

func NewToolRunner(host *host.Host) *ToolRunner

func (*ToolRunner) Add

func (c *ToolRunner) Add(toolCall *openai.ChatCompletionMessageToolCall) error

func (*ToolRunner) Complete

func (c *ToolRunner) Complete(ctx context.Context) ([]openai.ChatCompletionMessageParamUnion, error)

type ToolRunnerHandler

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