opencdcv1

type Change struct {

	// Before contains the data before the operation occurred. This field is
	// optional and should only be populated for operations "update" and "delete"
	// (if the system supports fetching the data before the operation).
	Before *Data `protobuf:"bytes,1,opt,name=before,proto3" json:"before,omitempty"`
	// After contains the data after the operation occurred. This field should be
	// populated for all operations except "delete".
	After *Data `protobuf:"bytes,2,opt,name=after,proto3" json:"after,omitempty"`
	// contains filtered or unexported fields
}

type Data struct {

	// Types that are assignable to Data:
	//
	//	*Data_RawData
	//	*Data_StructuredData
	Data isData_Data `protobuf_oneof:"data"`
	// contains filtered or unexported fields
}

type Data_RawData struct {
	// Raw data contains unstructured data in form of a byte array.
	RawData []byte `protobuf:"bytes,1,opt,name=raw_data,json=rawData,proto3,oneof"`
}

type Data_StructuredData struct {
	// Structured data contains data in form of a struct with fields.
	StructuredData *structpb.Struct `protobuf:"bytes,2,opt,name=structured_data,json=structuredData,proto3,oneof"`
}

type Operation int32

type Record struct {

	// Position uniquely identifies the record.
	Position []byte `protobuf:"bytes,1,opt,name=position,proto3" json:"position,omitempty"`
	// Operation defines what triggered the creation of a record. There are four
	// possibilities: create, update, delete or snapshot. The first three
	// operations are encountered during normal CDC operation, while "snapshot" is
	// meant to represent records during an initial load. Depending on the
	// operation, the record will contain either the payload before the change,
	// after the change, or both (see field payload).
	Operation Operation `protobuf:"varint,2,opt,name=operation,proto3,enum=opencdc.v1.Operation" json:"operation,omitempty"`
	// Metadata contains optional information related to the record. Although the
	// map can contain arbitrary keys, the standard provides a set of standard
	// metadata fields (see options prefixed with metadata_*).
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// Key represents a value that should identify the entity (e.g. database row).
	Key *Data `protobuf:"bytes,4,opt,name=key,proto3" json:"key,omitempty"`
	// Payload holds the payload change (data before and after the operation
	// occurred).
	Payload *Change `protobuf:"bytes,5,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}