openai

Apr 10, 2025

Changes in this version

+ type EmbeddingsProcessor struct

+ func NewEmbeddingsProcessor(log.CtxLogger) *EmbeddingsProcessor

+ func (p *EmbeddingsProcessor) Configure(ctx context.Context, cfg config.Config) error

+ func (p *EmbeddingsProcessor) Process(ctx context.Context, recs []opencdc.Record) []sdk.ProcessedRecord

+ func (p *EmbeddingsProcessor) Specification() (sdk.Specification, error)

+ type TextgenProcessor struct

+ func NewTextgenProcessor(log.CtxLogger) *TextgenProcessor

+ func (p *TextgenProcessor) Configure(ctx context.Context, cfg config.Config) error

+ func (p *TextgenProcessor) Process(ctx context.Context, recs []opencdc.Record) []sdk.ProcessedRecord

+ func (p *TextgenProcessor) Specification() (sdk.Specification, error)

Mar 20, 2025

Changes in this version

+ func CallWithRetry[T any](ctx context.Context, config Config, caller OpenaiCaller[T], payload string) (T, error)

+ func ProcessRecordField[T any](ctx context.Context, rec opencdc.Record, resolver sdk.ReferenceResolver, ...) (opencdc.Record, error)

+ func TestRecords() []opencdc.Record

+ type Config struct

+ BackoffFactor float64

+ InitialBackoff int

+ MaxBackoff int

+ MaxRetries int

+ type FlakyEmbeddingsCaller struct

+ CallCount int

+ Embeddings []float32

+ func (f *FlakyEmbeddingsCaller) Call(ctx context.Context, input string) ([]float32, error)

+ type FlakyOpenAICaller struct

+ CallCount int

+ func (f *FlakyOpenAICaller) Call(ctx context.Context, input string) (string, error)

+ type MockEmbeddingsCaller struct

+ Embeddings []float32

+ func (m *MockEmbeddingsCaller) Call(ctx context.Context, input string) ([]float32, error)

+ type OpenaiCaller interface

+ Call func(ctx context.Context, input string) (T, error)