deltas

package

v1.0.0 Latest Latest Go to latest Published: Apr 19, 2023 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation ¶

Index ¶

Variables
type DatabaseChanges
type Field
type TableChange
type TableChange_Operation
type TableChanges
- func (x TableChanges) Merge() ([]*TableChange, error)

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	TableChange_Operation_name = map[int32]string{
		0: "UNSET",
		1: "CREATE",
		2: "UPDATE",
		3: "DELETE",
	}
	TableChange_Operation_value = map[string]int32{
		"UNSET":  0,
		"CREATE": 1,
		"UPDATE": 2,
		"DELETE": 3,
	}
)

Enum value maps for TableChange_Operation.

View Source

var File_substreams_databases_deltas_v1_models_proto protoreflect.FileDescriptor

Functions ¶

This section is empty.

Types ¶

type DatabaseChanges ¶

type DatabaseChanges struct {
	TableChanges []*TableChange `protobuf:"bytes,1,rep,name=tableChanges,proto3" json:"tableChanges,omitempty"`
	// contains filtered or unexported fields
}

func (*DatabaseChanges) Descriptor deprecated

func (*DatabaseChanges) Descriptor() ([]byte, []int)

Deprecated: Use DatabaseChanges.ProtoReflect.Descriptor instead.

func (*DatabaseChanges) GetTableChanges ¶

func (x *DatabaseChanges) GetTableChanges() []*TableChange

func (*DatabaseChanges) ProtoMessage ¶

func (*DatabaseChanges) ProtoMessage()

func (*DatabaseChanges) ProtoReflect ¶

func (x *DatabaseChanges) ProtoReflect() protoreflect.Message

func (*DatabaseChanges) Reset ¶

func (x *DatabaseChanges) Reset()

func (*DatabaseChanges) Squash ¶

func (x *DatabaseChanges) Squash() error

func (*DatabaseChanges) String ¶

func (x *DatabaseChanges) String() string

type Field ¶

type Field struct {
	Name     string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	NewValue string `protobuf:"bytes,2,opt,name=new_value,json=newValue,proto3" json:"new_value,omitempty"`
	OldValue string `protobuf:"bytes,3,opt,name=old_value,json=oldValue,proto3" json:"old_value,omitempty"`
	// contains filtered or unexported fields
}

func (*Field) Descriptor deprecated

func (*Field) Descriptor() ([]byte, []int)

Deprecated: Use Field.ProtoReflect.Descriptor instead.

func (*Field) GetName ¶

func (x *Field) GetName() string

func (*Field) GetNewValue ¶

func (x *Field) GetNewValue() string

func (*Field) GetOldValue ¶

func (x *Field) GetOldValue() string

func (*Field) ProtoMessage ¶

func (*Field) ProtoMessage()

func (*Field) ProtoReflect ¶

func (x *Field) ProtoReflect() protoreflect.Message

func (*Field) Reset ¶

func (x *Field) Reset()

func (*Field) String ¶

func (x *Field) String() string

type TableChange ¶

type TableChange struct {
	Table     string                `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
	Pk        string                `protobuf:"bytes,2,opt,name=pk,proto3" json:"pk,omitempty"`
	BlockNum  uint64                `protobuf:"varint,3,opt,name=block_num,json=blockNum,proto3" json:"block_num,omitempty"`
	Ordinal   uint64                `protobuf:"varint,4,opt,name=ordinal,proto3" json:"ordinal,omitempty"`
	Operation TableChange_Operation `` /* 130-byte string literal not displayed */
	Fields    []*Field              `protobuf:"bytes,6,rep,name=fields,proto3" json:"fields,omitempty"`
	// contains filtered or unexported fields
}

func (*TableChange) Descriptor deprecated

func (*TableChange) Descriptor() ([]byte, []int)

Deprecated: Use TableChange.ProtoReflect.Descriptor instead.

func (*TableChange) GetBlockNum ¶

func (x *TableChange) GetBlockNum() uint64

func (*TableChange) GetFields ¶

func (x *TableChange) GetFields() []*Field

func (*TableChange) GetOperation ¶

func (x *TableChange) GetOperation() TableChange_Operation

func (*TableChange) GetOrdinal ¶

func (x *TableChange) GetOrdinal() uint64

func (*TableChange) GetPk ¶

func (x *TableChange) GetPk() string

func (*TableChange) GetTable ¶

func (x *TableChange) GetTable() string

func (*TableChange) Merge ¶

func (x *TableChange) Merge(next *TableChange) error

func (*TableChange) ProtoMessage ¶

func (*TableChange) ProtoMessage()

func (*TableChange) ProtoReflect ¶

func (x *TableChange) ProtoReflect() protoreflect.Message

func (*TableChange) Reset ¶

func (x *TableChange) Reset()

func (*TableChange) String ¶

func (x *TableChange) String() string

type TableChange_Operation ¶

type TableChange_Operation int32

const (
	TableChange_UNSET  TableChange_Operation = 0
	TableChange_CREATE TableChange_Operation = 1
	TableChange_UPDATE TableChange_Operation = 2
	TableChange_DELETE TableChange_Operation = 3
)

func (TableChange_Operation) Descriptor ¶

func (TableChange_Operation) Descriptor() protoreflect.EnumDescriptor

func (TableChange_Operation) Enum ¶

func (x TableChange_Operation) Enum() *TableChange_Operation

func (TableChange_Operation) EnumDescriptor deprecated

func (TableChange_Operation) EnumDescriptor() ([]byte, []int)

Deprecated: Use TableChange_Operation.Descriptor instead.

func (TableChange_Operation) Number ¶

func (x TableChange_Operation) Number() protoreflect.EnumNumber

func (TableChange_Operation) String ¶

func (x TableChange_Operation) String() string

func (TableChange_Operation) Type ¶

func (TableChange_Operation) Type() protoreflect.EnumType

type TableChanges ¶

type TableChanges []*TableChange

func (TableChanges) Merge ¶

func (x TableChanges) Merge() ([]*TableChange, error)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL