schema

Sep 16, 2024

Changes in this version

+ const TypeAvro

+ var ErrUnsupportedType = schema.ErrUnsupportedType

+ var KnownSerdeFactories = schema.KnownSerdeFactories

+ func AttachKeySchemaToRecord(r opencdc.Record, s Schema)

+ func AttachPayloadSchemaToRecord(r opencdc.Record, s Schema)

+ type Schema = schema.Schema

+ type Serde = schema.Serde

+ type Type = schema.Type

Aug 7, 2024

Changes in this version

+ var ErrInvalidSchema = pconnutils.ErrInvalidSchema

+ var ErrSubjectNotFound = pconnutils.ErrSubjectNotFound

+ var ErrVersionNotFound = pconnutils.ErrVersionNotFound

+ var Service pconnutils.SchemaService = newCachedSchemaService(newInMemoryService())

+ func Create(ctx context.Context, typ schema.Type, subject string, bytes []byte) (schema.Schema, error)

+ func Get(ctx context.Context, subject string, version int) (schema.Schema, error)

+ func GetSchemaContextName(ctx context.Context) string

+ func WithSchemaContextName(ctx context.Context, schemaCtxName string) context.Context