Versions in this module Expand all Collapse all v0 v0.5.1 Dec 23, 2024 v0.5.0 Nov 8, 2024 v0.4.0 Oct 8, 2024 v0.3.0 Aug 5, 2024 Changes in this version + var ErrInvalidProtoIsNil = errors.New("invalid proto: nil") + var ErrUnsupportedType = errors.New("unsupported type") + var KnownSerdeFactories = map[Type]SerdeFactory + func AttachKeySchemaToRecord(r opencdc.Record, s Schema) + func AttachPayloadSchemaToRecord(r opencdc.Record, s Schema) + type Schema struct + Bytes []byte + ID int + Subject string + Type Type + Version int + func (s *Schema) FromProto(proto *schemav1.Schema) error + func (s *Schema) ToProto(proto *schemav1.Schema) error + func (s Schema) Fingerprint() uint64 + func (s Schema) Marshal(v any) ([]byte, error) + func (s Schema) Serde() (Serde, error) + func (s Schema) Unmarshal(b []byte, v any) error + type Serde interface + Marshal func(v any) ([]byte, error) + String func() string + Unmarshal func(b []byte, v any) error + type SerdeFactory struct + Parse func([]byte) (Serde, error) + SerdeForType func(v any) (Serde, error) + type Type int32 + const TypeAvro + func (i Type) String() string + func (t *Type) UnmarshalText(b []byte) error + func (t Type) MarshalText() ([]byte, error)
Go to main page