schema

Documentation

Index

• Constants
• Variables
• func AttachKeySchemaToRecord(r opencdc.Record, s Schema)
• func AttachPayloadSchemaToRecord(r opencdc.Record, s Schema)
• func GetSchemaContextName(ctx context.Context) string
• func WithSchemaContextName(ctx context.Context, schemaCtxName string) context.Context
• type Schema
  • func Create(ctx context.Context, typ Type, subject string, bytes []byte) (Schema, error)
  • func Get(ctx context.Context, subject string, version int) (Schema, error)
• type Serde
• type Type

Constants

const (
	TypeAvro = schema.TypeAvro
)

Variables

var (
	ErrSubjectNotFound = pconnutils.ErrSubjectNotFound
	ErrVersionNotFound = pconnutils.ErrVersionNotFound
	ErrInvalidSchema   = pconnutils.ErrInvalidSchema

	ErrUnsupportedType = schema.ErrUnsupportedType
)

var KnownSerdeFactories = schema.KnownSerdeFactories

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

Service is the schema service client that can be used to interact with the schema service. It is initialized with an in-memory service by default.

Functions

func AttachKeySchemaToRecord

func AttachKeySchemaToRecord(r opencdc.Record, s Schema)

func AttachPayloadSchemaToRecord

func AttachPayloadSchemaToRecord(r opencdc.Record, s Schema)

func GetSchemaContextName

func GetSchemaContextName(ctx context.Context) string

GetSchemaContextName fetches the schema context name from the context. If the context does not contain a schema context name it returns an empty string.

func WithSchemaContextName

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

WithSchemaContextName wraps ctx and returns a context that contains the provided schema context name.

Types

type Schema

type Schema = schema.Schema

Schema represents a schema object.

func Create

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

Create creates a new schema with the given name and bytes. The schema type must be Avro.

func Get

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

Get retrieves the schema with the given name and version. If the schema does not exist, an error is returned.

type Serde

type Serde = schema.Serde

Serde represents a serializer/deserializer.

type Type

type Type = schema.Type

Type represents the type of a schema (avro, protobuf, etc).