sdk

Jun 12, 2025

Changes in this version

+ type MultiRecord []opencdc.Record

Aug 7, 2024

Changes in this version

type ErrorRecord

+ func (e ErrorRecord) MarshalJSON() ([]byte, error)

type Processor

+ func ProcessorWithMiddleware(p Processor, middleware ...ProcessorMiddleware) Processor

+ MiddlewareOptions func() []ProcessorMiddlewareOption

+ type ProcessorMiddleware interface

+ Wrap func(Processor) Processor

+ func DefaultProcessorMiddleware(opts ...ProcessorMiddlewareOption) []ProcessorMiddleware

+ type ProcessorMiddlewareOption interface

+ Apply func(ProcessorMiddleware)

+ type ProcessorWithSchemaDecode struct

+ Config ProcessorWithSchemaDecodeConfig

+ func (s *ProcessorWithSchemaDecode) Wrap(impl Processor) Processor

+ type ProcessorWithSchemaDecodeConfig struct

+ KeyEnabled *bool

+ PayloadEnabled *bool

+ func (c ProcessorWithSchemaDecodeConfig) Apply(m ProcessorMiddleware)

+ func (c ProcessorWithSchemaDecodeConfig) SchemaKeyEnabledParameterName() string

+ func (c ProcessorWithSchemaDecodeConfig) SchemaPayloadEnabledParameterName() string

+ type ProcessorWithSchemaEncode struct

+ Config ProcessorWithSchemaEncodeConfig

+ func (p *ProcessorWithSchemaEncode) Wrap(impl Processor) Processor

+ type ProcessorWithSchemaEncodeConfig struct

+ KeyEnabled *bool

+ PayloadEnabled *bool

+ func (c ProcessorWithSchemaEncodeConfig) Apply(m ProcessorMiddleware)

+ func (c ProcessorWithSchemaEncodeConfig) SchemaKeyEnabledParameterName() string

+ func (c ProcessorWithSchemaEncodeConfig) SchemaPayloadEnabledParameterName() string

type UnimplementedProcessor

+ func (UnimplementedProcessor) MiddlewareOptions() []ProcessorMiddlewareOption

Mar 7, 2024

Changes in this version

+ var ErrFilterRecord = errors.New("filter out this record")

+ var ErrUnimplemented = errors.New(...)

+ func Logger(ctx context.Context) *zerolog.Logger

+ func ParseConfig(ctx context.Context, cfg map[string]string, target any, ...) error

+ func Run(p Processor) — js/wasm

+ type ErrorRecord struct

+ Error error

+ type FilterRecord struct

+ type ProcessedRecord interface

+ type Processor interface

+ Configure func(context.Context, map[string]string) error

+ Open func(context.Context) error

+ Process func(context.Context, []opencdc.Record) []ProcessedRecord

+ Specification func() (Specification, error)

+ Teardown func(context.Context) error

+ type ProcessorFunc struct

+ func NewProcessorFunc(specs Specification, ...) ProcessorFunc

+ func (f ProcessorFunc) Process(ctx context.Context, records []opencdc.Record) []ProcessedRecord

+ func (f ProcessorFunc) Specification() (Specification, error)

+ type Reference reference.Reference

+ type ReferenceResolver reference.Resolver

+ func NewReferenceResolver(input string) (ReferenceResolver, error)

+ func (r ReferenceResolver) Resolve(rec *opencdc.Record) (Reference, error)

+ type SingleRecord opencdc.Record

+ type Specification struct

+ Author string

+ Description string

+ Name string

+ Parameters config.Parameters

+ Summary string

+ Version string

+ type UnimplementedProcessor struct

+ func (UnimplementedProcessor) Configure(context.Context, map[string]string) error

+ func (UnimplementedProcessor) Open(context.Context) error

+ func (UnimplementedProcessor) Process(context.Context, []opencdc.Record) []ProcessedRecord

+ func (UnimplementedProcessor) Specification() (Specification, error)

+ func (UnimplementedProcessor) Teardown(context.Context) error