pbdatabase

Documentation

Index

• Variables
• type DatabaseChanges
  • func (*DatabaseChanges) Descriptor() ([]byte, []int)
  • func (x *DatabaseChanges) GetTableChanges() []*TableChange
  • func (*DatabaseChanges) ProtoMessage()
  • func (x *DatabaseChanges) ProtoReflect() protoreflect.Message
  • func (x *DatabaseChanges) Reset()
  • func (x *DatabaseChanges) String() string
• type Field
  • func (*Field) Descriptor() ([]byte, []int)
  • func (x *Field) GetName() string
  • func (x *Field) GetNewValue() string
  • func (x *Field) GetOldValue() string
  • func (*Field) ProtoMessage()
  • func (x *Field) ProtoReflect() protoreflect.Message
  • func (x *Field) Reset()
  • func (x *Field) String() string
• type TableChange
  • func (*TableChange) Descriptor() ([]byte, []int)
  • 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 (*TableChange) ProtoMessage()
  • func (x *TableChange) ProtoReflect() protoreflect.Message
  • func (x *TableChange) Reset()
  • func (x *TableChange) String() string
• type TableChange_Operation
  • func (TableChange_Operation) Descriptor() protoreflect.EnumDescriptor
  • func (x TableChange_Operation) Enum() *TableChange_Operation
  • func (TableChange_Operation) EnumDescriptor() ([]byte, []int)
  • func (x TableChange_Operation) Number() protoreflect.EnumNumber
  • func (x TableChange_Operation) String() string
  • func (TableChange_Operation) Type() protoreflect.EnumType

Variables

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.

var File_substreams_sink_database_v1_database_proto protoreflect.FileDescriptor

Types

type DatabaseChanges

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

func (*DatabaseChanges) Descriptor

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) 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

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"`
	Ordinal   uint64                `protobuf:"varint,3,opt,name=ordinal,proto3" json:"ordinal,omitempty"`
	Operation TableChange_Operation `` /* 130-byte string literal not displayed */
	Fields    []*Field              `protobuf:"bytes,5,rep,name=fields,proto3" json:"fields,omitempty"`
	// contains filtered or unexported fields
}

func (*TableChange) Descriptor

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

Deprecated: Use TableChange.ProtoReflect.Descriptor instead.

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) 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 // Protobuf default should not be used, this is used so that the consume can ensure that the value was actually specified
	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

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