gptparallel

Jun 24, 2023

Changes in this version

type RequestResult

+ FunctionName string

+ FunctionParams string

+ type ResponseWithFunction struct

+ FunctionName string

+ FunctionParams string

+ Response string

Jun 20, 2023

Changes in this version

type GPTParallel

+ func (g *GPTParallel) RunEmbeddingsChan(requestsChan <-chan VectorRequestWithCallback, concurrency int) <-chan VectorRequestResult

+ type VectorRequestResult struct

+ Err error

+ Identifier string

+ Request openai.EmbeddingRequest

+ Vector []float32

+ type VectorRequestWithCallback struct

+ Callback func(result VectorRequestResult)

+ Identifier string

+ Request openai.EmbeddingRequest

Apr 14, 2023

Changes in this version

type GPTParallel

+ func (g *GPTParallel) RunRequestsChan(requestsChan <-chan RequestWithCallback, concurrency int) <-chan RequestResult

type RequestResult

+ Identifier string

type RequestWithCallback

+ Identifier string

Apr 10, 2023

Changes in this version

+ type GPTParallel struct

+ BackoffSettings *backoff.ExponentialBackOff

+ Client *openai.Client

+ Logger Logger

+ Progress *mpb.Progress

+ func NewGPTParallel(context context.Context, client *openai.Client, progress *mpb.Progress, ...) *GPTParallel

+ func (g *GPTParallel) RunRequests(requests []RequestWithCallback, concurrency int)

+ type Logger interface

+ Debug func(args ...interface{})

+ Debugf func(format string, args ...interface{})

+ Error func(args ...interface{})

+ Errorf func(format string, args ...interface{})

+ Info func(args ...interface{})

+ Infof func(format string, args ...interface{})

+ Warn func(args ...interface{})

+ Warnf func(format string, args ...interface{})

+ type RequestResult struct

+ Err error

+ FinishReason string

+ Request openai.ChatCompletionRequest

+ Response string

+ type RequestWithCallback struct

+ Callback func(result RequestResult)

+ Request openai.ChatCompletionRequest