chatcompletion

Documentation

Index

• func HandleBufferResponse(ctx context.Context, client *openai.Client, req openai.ChatCompletionRequest, ...) error
• func HandleStreamResponse(ctx context.Context, client *openai.Client, req openai.ChatCompletionRequest, ...) error
• func Send(ctx context.Context, client *openai.Client, req openai.ChatCompletionRequest, ...) error
• func SendReply(ctx context.Context, client *openai.Client, conversation Conversation, ...) error
• type ContentResponseWriter
  • func (b *ContentResponseWriter) Write(res openai.ChatCompletionResponse) error
  • func (b *ContentResponseWriter) WriteRequest(_ openai.ChatCompletionRequest) error
  • func (b *ContentResponseWriter) WriteStream(res openai.ChatCompletionStreamResponse) error
• type Conversation
• type PersistentConversation
  • func LoadPersistentConversation(name string, defaults openai.ChatCompletionRequest) (PersistentConversation, error)
  • func (c *PersistentConversation) Continue(reply openai.ChatCompletionRequest) (openai.ChatCompletionRequest, error)
  • func (c PersistentConversation) UpdateResponse(response string) error
• type RawResponseWriter
  • func (b *RawResponseWriter) Write(res openai.ChatCompletionResponse) error
  • func (b *RawResponseWriter) WriteRequest(_ openai.ChatCompletionRequest) error
  • func (b *RawResponseWriter) WriteStream(res openai.ChatCompletionStreamResponse) error
• type RecapResponseWriter
  • func (b *RecapResponseWriter) Write(res openai.ChatCompletionResponse) error
  • func (b *RecapResponseWriter) WriteRequest(req openai.ChatCompletionRequest) error
  • func (b *RecapResponseWriter) WriteStream(res openai.ChatCompletionStreamResponse) error
• type ResponseWriter
• type ResponseWriterContentBuffer
  • func NewResponseWriterContentBuffer(w ResponseWriter) *ResponseWriterContentBuffer
  • func (b *ResponseWriterContentBuffer) String() string
  • func (b *ResponseWriterContentBuffer) Write(res openai.ChatCompletionResponse) error
  • func (b *ResponseWriterContentBuffer) WriteRequest(req openai.ChatCompletionRequest) error
  • func (b *ResponseWriterContentBuffer) WriteStream(res openai.ChatCompletionStreamResponse) error

Functions

func HandleBufferResponse

func HandleBufferResponse(
	ctx context.Context,
	client *openai.Client,
	req openai.ChatCompletionRequest,
	writer ResponseWriter,
) error

func HandleStreamResponse

func HandleStreamResponse(
	ctx context.Context,
	client *openai.Client,
	req openai.ChatCompletionRequest,
	writer ResponseWriter,
) error

func Send

func Send(
	ctx context.Context,
	client *openai.Client,
	req openai.ChatCompletionRequest,
	writer ResponseWriter,
) error

func SendReply

func SendReply(
	ctx context.Context,
	client *openai.Client,
	conversation Conversation,
	reply openai.ChatCompletionRequest,
	writer ResponseWriter,
) error

Types

type ContentResponseWriter

type ContentResponseWriter struct {
	W io.Writer
}

func (*ContentResponseWriter) Write

func (b *ContentResponseWriter) Write(res openai.ChatCompletionResponse) error

func (*ContentResponseWriter) WriteRequest

func (b *ContentResponseWriter) WriteRequest(_ openai.ChatCompletionRequest) error

func (*ContentResponseWriter) WriteStream

func (b *ContentResponseWriter) WriteStream(res openai.ChatCompletionStreamResponse) error

type Conversation

type Conversation interface {
	Continue(openai.ChatCompletionRequest) (openai.ChatCompletionRequest, error)
	UpdateResponse(string) error
}

type PersistentConversation

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

func LoadPersistentConversation

func LoadPersistentConversation(
	name string,
	defaults openai.ChatCompletionRequest,
) (PersistentConversation, error)

LoadPersistentConversation will load an existing conversation by the supplied name or create it if it does not exist.

func (*PersistentConversation) Continue

func (c *PersistentConversation) Continue(
	reply openai.ChatCompletionRequest,
) (openai.ChatCompletionRequest, error)

func (PersistentConversation) UpdateResponse

func (c PersistentConversation) UpdateResponse(response string) error

type RawResponseWriter

type RawResponseWriter struct {
	W io.Writer
}

func (*RawResponseWriter) Write

func (b *RawResponseWriter) Write(res openai.ChatCompletionResponse) error

func (*RawResponseWriter) WriteRequest

func (b *RawResponseWriter) WriteRequest(_ openai.ChatCompletionRequest) error

func (*RawResponseWriter) WriteStream

func (b *RawResponseWriter) WriteStream(res openai.ChatCompletionStreamResponse) error

type RecapResponseWriter

type RecapResponseWriter struct {
	W io.Writer
	// contains filtered or unexported fields
}

func (*RecapResponseWriter) Write

func (b *RecapResponseWriter) Write(res openai.ChatCompletionResponse) error

func (*RecapResponseWriter) WriteRequest

func (b *RecapResponseWriter) WriteRequest(req openai.ChatCompletionRequest) error

func (*RecapResponseWriter) WriteStream

func (b *RecapResponseWriter) WriteStream(res openai.ChatCompletionStreamResponse) error

type ResponseWriter

type ResponseWriter interface {
	Write(openai.ChatCompletionResponse) error
	WriteRequest(openai.ChatCompletionRequest) error
	WriteStream(openai.ChatCompletionStreamResponse) error
}

type ResponseWriterContentBuffer

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

func NewResponseWriterContentBuffer

func NewResponseWriterContentBuffer(w ResponseWriter) *ResponseWriterContentBuffer

func (*ResponseWriterContentBuffer) String

func (b *ResponseWriterContentBuffer) String() string

func (*ResponseWriterContentBuffer) Write

func (b *ResponseWriterContentBuffer) Write(res openai.ChatCompletionResponse) error

func (*ResponseWriterContentBuffer) WriteRequest

func (b *ResponseWriterContentBuffer) WriteRequest(req openai.ChatCompletionRequest) error

func (*ResponseWriterContentBuffer) WriteStream

func (b *ResponseWriterContentBuffer) WriteStream(res openai.ChatCompletionStreamResponse) error