Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

opencdc

package

Go to main page

Versions in this module

v0

v0.5.0

Nov 8, 2024

v0.4.0

Oct 8, 2024

v0.3.0

Aug 5, 2024

Changes in this version

+ const MetadataKeySchemaSubject

+ const MetadataKeySchemaVersion

+ const MetadataPayloadSchemaSubject

+ const MetadataPayloadSchemaVersion

type Metadata

+ func (m Metadata) GetKeySchemaSubject() (string, error)

+ func (m Metadata) GetKeySchemaVersion() (int, error)

+ func (m Metadata) GetPayloadSchemaSubject() (string, error)

+ func (m Metadata) GetPayloadSchemaVersion() (int, error)

+ func (m Metadata) SetKeySchemaSubject(subject string)

+ func (m Metadata) SetKeySchemaVersion(version int)

+ func (m Metadata) SetPayloadSchemaSubject(subject string)

+ func (m Metadata) SetPayloadSchemaVersion(version int)

v0.2.0

Apr 23, 2024

Changes in this version

+ const MetadataCollection

type Metadata

+ func (m Metadata) GetCollection() (string, error)

+ func (m Metadata) SetCollection(collection string)

v0.1.1

Mar 8, 2024

v0.1.0

Mar 6, 2024

v0.0.1

Mar 5, 2024

Changes in this version

+ const MetadataConduitDLQNackError

+ const MetadataConduitDLQNackNodeID

+ const MetadataConduitDestinationPluginName

+ const MetadataConduitDestinationPluginVersion

+ const MetadataConduitSourceConnectorID

+ const MetadataConduitSourcePluginName

+ const MetadataConduitSourcePluginVersion

+ const MetadataCreatedAt

+ const MetadataOpenCDCVersion

+ const MetadataReadAt

+ const OpenCDCVersion

+ var ErrInvalidProtoDataType = errors.New("invalid proto data type")

+ var ErrMetadataFieldNotFound = errors.New("metadata field not found")

+ var ErrUnknownOperation = errors.New("unknown operation")

+ func WithJSONMarshalOptions(ctx context.Context, options *JSONMarshalOptions) context.Context

+ type Change struct

+ After Data

+ Before Data

+ func (c *Change) FromProto(proto *opencdcv1.Change) error

+ func (c Change) ToProto(proto *opencdcv1.Change) error

+ type Data interface

+ Bytes func() []byte

+ Clone func() Data

+ ToProto func(*opencdcv1.Data) error

+ type JSONMarshalOptions struct

+ RawDataAsString bool

+ type JSONSerializer JSONMarshalOptions

+ func (s JSONSerializer) Serialize(r Record) ([]byte, error)

+ type Metadata map[string]string

+ func (m Metadata) GetConduitDLQNackError() (string, error)

+ func (m Metadata) GetConduitDLQNackNodeID() (string, error)

+ func (m Metadata) GetConduitDestinationPluginName() (string, error)

+ func (m Metadata) GetConduitDestinationPluginVersion() (string, error)

+ func (m Metadata) GetConduitSourceConnectorID() (string, error)

+ func (m Metadata) GetConduitSourcePluginName() (string, error)

+ func (m Metadata) GetConduitSourcePluginVersion() (string, error)

+ func (m Metadata) GetCreatedAt() (time.Time, error)

+ func (m Metadata) GetOpenCDCVersion() (string, error)

+ func (m Metadata) GetReadAt() (time.Time, error)

+ func (m Metadata) SetConduitDLQNackError(err string)

+ func (m Metadata) SetConduitDLQNackNodeID(id string)

+ func (m Metadata) SetConduitDestinationPluginName(name string)

+ func (m Metadata) SetConduitDestinationPluginVersion(version string)

+ func (m Metadata) SetConduitSourceConnectorID(id string)

+ func (m Metadata) SetConduitSourcePluginName(name string)

+ func (m Metadata) SetConduitSourcePluginVersion(version string)

+ func (m Metadata) SetCreatedAt(createdAt time.Time)

+ func (m Metadata) SetOpenCDCVersion()

+ func (m Metadata) SetReadAt(createdAt time.Time)

+ type Operation int

+ const OperationCreate

+ const OperationDelete

+ const OperationSnapshot

+ const OperationUpdate

+ func (i *Operation) UnmarshalText(b []byte) error

+ func (i Operation) MarshalText() ([]byte, error)

+ func (i Operation) String() string

+ type Position []byte

+ func (p Position) String() string

+ type RawData []byte

+ func (d RawData) Bytes() []byte

+ func (d RawData) Clone() Data

+ func (d RawData) MarshalJSON(ctx context.Context) ([]byte, error)

+ func (d RawData) ToProto(proto *opencdcv1.Data) error

+ type Record struct

+ Key Data

+ Metadata Metadata

+ Operation Operation

+ Payload Change

+ Position Position

+ func (r *Record) FromProto(proto *opencdcv1.Record) error

+ func (r *Record) SetSerializer(serializer RecordSerializer)

+ func (r *Record) UnmarshalJSON(b []byte) error

+ func (r Record) Bytes() []byte

+ func (r Record) Clone() Record

+ func (r Record) Map() map[string]interface{}

+ func (r Record) ToProto(proto *opencdcv1.Record) error

+ type RecordSerializer interface

+ Serialize func(Record) ([]byte, error)

+ type StructuredData map[string]interface

+ func (d StructuredData) Bytes() []byte

+ func (d StructuredData) Clone() Data

+ func (d StructuredData) ToProto(proto *opencdcv1.Data) error