record

type Data interface {
	Bytes() []byte
}

type Position []byte

type RawData struct {
	Raw    []byte
	Schema schema.Schema
}

type Record struct {
	Position Position
	Metadata map[string]string

	// SourceID contains the source connector ID.
	SourceID string

	// CreatedAt represents the time when the change occurred in the source system.
	// If that's impossible to find out, then it should be the time the change was detected by Conduit.
	CreatedAt time.Time
	// ReadAt represents the time at which Conduit read the record.
	ReadAt time.Time

	// Key and payload are guaranteed to be non-nil, always.
	// However, they may be 'empty', i.e. not contain any real data.
	Key     Data
	Payload Data
}

type StructuredData map[string]interface{}