internal

Documentation

Index

• type Decoder
  • func NewDecoder(registry schemaregistry.Registry, logger log.CtxLogger) *Decoder
  • func (d *Decoder) Decode(ctx context.Context, b opencdc.RawData) (opencdc.StructuredData, error)
• type DownloadSchemaStrategy
  • func (str DownloadSchemaStrategy) GetSchema(ctx context.Context, registry schemaregistry.Registry, _ log.CtxLogger, ...) (schema.Schema, error)
• type Encoder
  • func NewEncoder(registry schemaregistry.Registry, logger log.CtxLogger, ...) *Encoder
  • func (e *Encoder) Encode(ctx context.Context, sd opencdc.StructuredData) (opencdc.RawData, error)
• type ExtractAndUploadSchemaStrategy
  • func (str ExtractAndUploadSchemaStrategy) GetSchema(ctx context.Context, registry schemaregistry.Registry, _ log.CtxLogger, ...) (schema.Schema, error)
• type SchemaStrategy

Types

type Decoder

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

func NewDecoder

func NewDecoder(registry schemaregistry.Registry, logger log.CtxLogger) *Decoder

func (*Decoder) Decode

func (d *Decoder) Decode(ctx context.Context, b opencdc.RawData) (opencdc.StructuredData, error)

type DownloadSchemaStrategy

type DownloadSchemaStrategy struct {
	Subject string
	// TODO add support for specifying "latest" - https://github.com/ConduitIO/conduit/issues/1095
	Version int
}

func (DownloadSchemaStrategy) GetSchema

func (str DownloadSchemaStrategy) GetSchema(ctx context.Context, registry schemaregistry.Registry, _ log.CtxLogger, _ opencdc.StructuredData) (schema.Schema, error)

type Encoder

type Encoder struct {
	SchemaStrategy
	// contains filtered or unexported fields
}

func NewEncoder

func NewEncoder(registry schemaregistry.Registry, logger log.CtxLogger, strategy SchemaStrategy) *Encoder

func (*Encoder) Encode

func (e *Encoder) Encode(ctx context.Context, sd opencdc.StructuredData) (opencdc.RawData, error)

type ExtractAndUploadSchemaStrategy

type ExtractAndUploadSchemaStrategy struct {
	Subject string
}

func (ExtractAndUploadSchemaStrategy) GetSchema

func (str ExtractAndUploadSchemaStrategy) GetSchema(ctx context.Context, registry schemaregistry.Registry, _ log.CtxLogger, sd opencdc.StructuredData) (schema.Schema, error)

type SchemaStrategy

type SchemaStrategy interface {
	GetSchema(context.Context, schemaregistry.Registry, log.CtxLogger, opencdc.StructuredData) (schema.Schema, error)
}