decoderbufs

Documentation

Overview

Package decoderbufs is a generated protocol buffer package.

It is generated from these files:

pg_logicaldec.proto

It has these top-level messages:

Point
DatumMessage
RowMessage

Index

• Variables
• type DatumMessage
  • func (*DatumMessage) Descriptor() ([]byte, []int)
  • func (m *DatumMessage) GetColumnName() string
  • func (m *DatumMessage) GetColumnType() int64
  • func (m *DatumMessage) GetDatumBool() bool
  • func (m *DatumMessage) GetDatumBytes() []byte
  • func (m *DatumMessage) GetDatumDouble() float64
  • func (m *DatumMessage) GetDatumFloat() float32
  • func (m *DatumMessage) GetDatumInt32() int32
  • func (m *DatumMessage) GetDatumInt64() int64
  • func (m *DatumMessage) GetDatumPoint() *Point
  • func (m *DatumMessage) GetDatumString() string
  • func (m *DatumMessage) GetUnchangedNoValue() bool
  • func (*DatumMessage) ProtoMessage()
  • func (m *DatumMessage) Reset()
  • func (m *DatumMessage) String() string
• type Op
  • func (x Op) Enum() *Op
  • func (Op) EnumDescriptor() ([]byte, []int)
  • func (x Op) String() string
  • func (x *Op) UnmarshalJSON(data []byte) error
• type Point
  • func (*Point) Descriptor() ([]byte, []int)
  • func (m *Point) GetX() float64
  • func (m *Point) GetY() float64
  • func (*Point) ProtoMessage()
  • func (m *Point) Reset()
  • func (m *Point) String() string
• type RowMessage
  • func (*RowMessage) Descriptor() ([]byte, []int)
  • func (m *RowMessage) GetCommitTime() uint64
  • func (m *RowMessage) GetLogPosition() uint64
  • func (m *RowMessage) GetNewTuple() []*DatumMessage
  • func (m *RowMessage) GetOldTuple() []*DatumMessage
  • func (m *RowMessage) GetOp() Op
  • func (m *RowMessage) GetTable() string
  • func (*RowMessage) ProtoMessage()
  • func (m *RowMessage) Reset()
  • func (m *RowMessage) String() string

Variables

var Op_name = map[int32]string{
	0: "INSERT",
	1: "UPDATE",
	2: "DELETE",
}

var Op_value = map[string]int32{
	"INSERT": 0,
	"UPDATE": 1,
	"DELETE": 2,
}

Types

type DatumMessage

type DatumMessage struct {
	ColumnName       *string  `protobuf:"bytes,1,opt,name=column_name" json:"column_name,omitempty"`
	ColumnType       *int64   `protobuf:"varint,2,opt,name=column_type" json:"column_type,omitempty"`
	DatumInt32       *int32   `protobuf:"varint,3,opt,name=datum_int32" json:"datum_int32,omitempty"`
	DatumInt64       *int64   `protobuf:"varint,4,opt,name=datum_int64" json:"datum_int64,omitempty"`
	DatumFloat       *float32 `protobuf:"fixed32,5,opt,name=datum_float" json:"datum_float,omitempty"`
	DatumDouble      *float64 `protobuf:"fixed64,6,opt,name=datum_double" json:"datum_double,omitempty"`
	DatumBool        *bool    `protobuf:"varint,7,opt,name=datum_bool" json:"datum_bool,omitempty"`
	DatumString      *string  `protobuf:"bytes,8,opt,name=datum_string" json:"datum_string,omitempty"`
	DatumBytes       []byte   `protobuf:"bytes,9,opt,name=datum_bytes" json:"datum_bytes,omitempty"`
	DatumPoint       *Point   `protobuf:"bytes,10,opt,name=datum_point" json:"datum_point,omitempty"`
	UnchangedNoValue *bool    `protobuf:"varint,11,opt,name=unchanged_no_value" json:"unchanged_no_value,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*DatumMessage) Descriptor

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

func (*DatumMessage) GetColumnName

func (m *DatumMessage) GetColumnName() string

func (*DatumMessage) GetColumnType

func (m *DatumMessage) GetColumnType() int64

func (*DatumMessage) GetDatumBool

func (m *DatumMessage) GetDatumBool() bool

func (*DatumMessage) GetDatumBytes

func (m *DatumMessage) GetDatumBytes() []byte

func (*DatumMessage) GetDatumDouble

func (m *DatumMessage) GetDatumDouble() float64

func (*DatumMessage) GetDatumFloat

func (m *DatumMessage) GetDatumFloat() float32

func (*DatumMessage) GetDatumInt32

func (m *DatumMessage) GetDatumInt32() int32

func (*DatumMessage) GetDatumInt64

func (m *DatumMessage) GetDatumInt64() int64

func (*DatumMessage) GetDatumPoint

func (m *DatumMessage) GetDatumPoint() *Point

func (*DatumMessage) GetDatumString

func (m *DatumMessage) GetDatumString() string

func (*DatumMessage) GetUnchangedNoValue

func (m *DatumMessage) GetUnchangedNoValue() bool

func (*DatumMessage) ProtoMessage

func (*DatumMessage) ProtoMessage()

func (*DatumMessage) Reset

func (m *DatumMessage) Reset()

func (*DatumMessage) String

func (m *DatumMessage) String() string

type Op

type Op int32

const (
	Op_INSERT Op = 0
	Op_UPDATE Op = 1
	Op_DELETE Op = 2
)

func (Op) Enum

func (x Op) Enum() *Op

func (Op) EnumDescriptor

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

func (Op) String

func (x Op) String() string

func (*Op) UnmarshalJSON

func (x *Op) UnmarshalJSON(data []byte) error

type Point

type Point struct {
	X                *float64 `protobuf:"fixed64,1,req,name=x" json:"x,omitempty"`
	Y                *float64 `protobuf:"fixed64,2,req,name=y" json:"y,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*Point) Descriptor

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

func (*Point) GetX

func (m *Point) GetX() float64

func (*Point) GetY

func (m *Point) GetY() float64

func (*Point) ProtoMessage

func (*Point) ProtoMessage()

func (*Point) Reset

func (m *Point) Reset()

func (*Point) String

func (m *Point) String() string

type RowMessage

type RowMessage struct {
	CommitTime       *uint64         `protobuf:"varint,1,opt,name=commit_time" json:"commit_time,omitempty"`
	LogPosition      *uint64         `protobuf:"varint,2,opt,name=log_position" json:"log_position,omitempty"`
	Table            *string         `protobuf:"bytes,3,opt,name=table" json:"table,omitempty"`
	Op               *Op             `protobuf:"varint,4,opt,name=op,enum=decoderbufs.Op" json:"op,omitempty"`
	NewTuple         []*DatumMessage `protobuf:"bytes,5,rep,name=new_tuple" json:"new_tuple,omitempty"`
	OldTuple         []*DatumMessage `protobuf:"bytes,6,rep,name=old_tuple" json:"old_tuple,omitempty"`
	XXX_unrecognized []byte          `json:"-"`
}

func (*RowMessage) Descriptor

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

func (*RowMessage) GetCommitTime

func (m *RowMessage) GetCommitTime() uint64

func (*RowMessage) GetLogPosition

func (m *RowMessage) GetLogPosition() uint64

func (*RowMessage) GetNewTuple

func (m *RowMessage) GetNewTuple() []*DatumMessage

func (*RowMessage) GetOldTuple

func (m *RowMessage) GetOldTuple() []*DatumMessage

func (*RowMessage) GetOp

func (m *RowMessage) GetOp() Op

func (*RowMessage) GetTable

func (m *RowMessage) GetTable() string

func (*RowMessage) ProtoMessage

func (*RowMessage) ProtoMessage()

func (*RowMessage) Reset

func (m *RowMessage) Reset()

func (*RowMessage) String

func (m *RowMessage) String() string