Versions in this module Expand all Collapse all v1 v1.0.0 Apr 19, 2023 Changes in this version + var File_substreams_databases_deltas_v1_models_proto protoreflect.FileDescriptor + var TableChange_Operation_name = map[int32]string + var TableChange_Operation_value = map[string]int32 + type DatabaseChanges struct + TableChanges []*TableChange + func (*DatabaseChanges) Descriptor() ([]byte, []int) + func (*DatabaseChanges) ProtoMessage() + func (x *DatabaseChanges) GetTableChanges() []*TableChange + func (x *DatabaseChanges) ProtoReflect() protoreflect.Message + func (x *DatabaseChanges) Reset() + func (x *DatabaseChanges) Squash() error + func (x *DatabaseChanges) String() string + type Field struct + Name string + NewValue string + OldValue string + func (*Field) Descriptor() ([]byte, []int) + func (*Field) ProtoMessage() + func (x *Field) GetName() string + func (x *Field) GetNewValue() string + func (x *Field) GetOldValue() string + func (x *Field) ProtoReflect() protoreflect.Message + func (x *Field) Reset() + func (x *Field) String() string + type TableChange struct + BlockNum uint64 + Fields []*Field + Operation TableChange_Operation + Ordinal uint64 + Pk string + Table string + func (*TableChange) Descriptor() ([]byte, []int) + func (*TableChange) ProtoMessage() + func (x *TableChange) GetBlockNum() uint64 + func (x *TableChange) GetFields() []*Field + func (x *TableChange) GetOperation() TableChange_Operation + func (x *TableChange) GetOrdinal() uint64 + func (x *TableChange) GetPk() string + func (x *TableChange) GetTable() string + func (x *TableChange) Merge(next *TableChange) error + func (x *TableChange) ProtoReflect() protoreflect.Message + func (x *TableChange) Reset() + func (x *TableChange) String() string + type TableChange_Operation int32 + const TableChange_CREATE + const TableChange_DELETE + const TableChange_UNSET + const TableChange_UPDATE + func (TableChange_Operation) Descriptor() protoreflect.EnumDescriptor + func (TableChange_Operation) EnumDescriptor() ([]byte, []int) + func (TableChange_Operation) Type() protoreflect.EnumType + func (x TableChange_Operation) Enum() *TableChange_Operation + func (x TableChange_Operation) Number() protoreflect.EnumNumber + func (x TableChange_Operation) String() string + type TableChanges []*TableChange + func (x TableChanges) Merge() ([]*TableChange, error)
Go to main page