requester

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

type FormBuilder interface {
	CreateFormFile(fieldname string, fileHeader *multipart.FileHeader) error
	CreateFormFileReader(fieldname string, r io.Reader, filename string) error
	WriteField(fieldname, value string) error
	Close() error
	FormDataContentType() string
}

type HTTPRequester struct {
	// requestBuilder    utils.RequestBuilder
	CreateFormBuilder func(io.Writer) FormBuilder
	ErrorHandler      HttpErrorHandler

	Context  context.Context
	IsOpenAI bool
	// contains filtered or unexported fields
}

type HandlerPrefix[T streamable] func(rawLine *[]byte, dataChan chan T, errChan chan error)

type HttpErrorHandler func(*http.Response) *types.OpenAIError

type MessageHandler func(source MessageSource, messageType int, message []byte) (bool, *types.UsageEvent, []byte, error)

type MessageSource int

type StreamReaderInterface[T streamable] interface {
	Recv() (<-chan T, <-chan error)
	Close()
}

type Stringer interface {
	GetString() *string
}

type UsageHandler func(usage *types.UsageEvent) error

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

type WSRequester struct {
	WSClient *websocket.Dialer
}