record

Nov 8, 2021

Changes in this version

type Value

+ func CreateValue(t DataType, data interface{}) (*Value, error)

Oct 27, 2021

Changes in this version

+ func ConvertFieldsToMap(fields []*Field) map[string]interface

Oct 27, 2021

Changes in this version

+ func FieldsToMap(fields []*Field) map[string]interface

Oct 19, 2021

Changes in this version

+ var File_types_record_record_proto protoreflect.FileDescriptor

+ var NotFoundPrimaryKey = errors.New("Not found primary key")

+ var UnsupportedOperationErr = errors.New("Unsupported operation")

+ func Marshal(record *Record) ([]byte, error)

+ func Unmarshal(data []byte, record *Record) error

type Field

+ func GetField(fields []*Field, fieldName string) *Field

type Record

+ func (record *Record) GetPayload() *Value

+ func (record *Record) GetPrimaryKeyValue() (*Value, error)

type Value

+ func GetValueByPath(value *Value, key string) (*Value, error)

+ func (v *Value) GetBytes() ([]byte, error)

Aug 11, 2021

Changes in this version

type DataType

+ const DataType_TIME

type Value

+ Timestamp *timestamppb.Timestamp

+ func (x *Value) GetTimestamp() *timestamppb.Timestamp

Jul 29, 2021

Changes in this version

+ var File_record_proto protoreflect.FileDescriptor

type ArrayValue

+ func (x *ArrayValue) ProtoReflect() protoreflect.Message

type DataType

+ const DataType_NULL

+ func (DataType) Descriptor() protoreflect.EnumDescriptor

+ func (DataType) Type() protoreflect.EnumType

+ func (x DataType) Enum() *DataType

+ func (x DataType) Number() protoreflect.EnumNumber

type Field

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

type MapValue

+ func (x *MapValue) ProtoReflect() protoreflect.Message

type Method

+ func (Method) Descriptor() protoreflect.EnumDescriptor

+ func (Method) Type() protoreflect.EnumType

+ func (x Method) Enum() *Method

+ func (x Method) Number() protoreflect.EnumNumber

type Record

+ func (x *Record) ProtoReflect() protoreflect.Message

type SendReply

+ func (x *SendReply) ProtoReflect() protoreflect.Message

type TruncateReply

+ func (x *TruncateReply) ProtoReflect() protoreflect.Message

type TruncateRequest

+ func (x *TruncateRequest) ProtoReflect() protoreflect.Message

type Value

+ func (x *Value) ProtoReflect() protoreflect.Message

Jun 5, 2021

Changes in this version

+ var NotFloatErr = errors.New("Not float")

+ var NotIntegerErr = errors.New("Not integer")

+ var NotUnsignedIntegerErr = errors.New("Not unisgned integer")

+ func StrToBytes(s string) []byte

+ func UnmarshalJSON(data []byte, record *Record) error

+ func UnmarshalMapData(obj map[string]interface{}, record *Record) error

type Value

+ func GetValueFromInterface(data interface{}) (*Value, error)

May 17, 2021

Changes in this version

+ var DataType_name = map[int32]string

+ var DataType_value = map[string]int32

+ var Method_name = map[int32]string

+ var Method_value = map[string]int32

+ func GetValue(value *Value) interface

+ type ArrayValue struct

+ Elements []*Value

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ArrayValue) Descriptor() ([]byte, []int)

+ func (*ArrayValue) ProtoMessage()

+ func (m *ArrayValue) GetElements() []*Value

+ func (m *ArrayValue) Reset()

+ func (m *ArrayValue) String() string

+ func (m *ArrayValue) XXX_DiscardUnknown()

+ func (m *ArrayValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ArrayValue) XXX_Merge(src proto.Message)

+ func (m *ArrayValue) XXX_Size() int

+ func (m *ArrayValue) XXX_Unmarshal(b []byte) error

+ type ColumnDef struct

+ BindingName string

+ ColumnName string

+ Value interface{}

+ type DataType int32

+ const DataType_ARRAY

+ const DataType_BINARY

+ const DataType_BOOLEAN

+ const DataType_FLOAT64

+ const DataType_INT64

+ const DataType_MAP

+ const DataType_STRING

+ const DataType_UINT64

+ func (DataType) EnumDescriptor() ([]byte, []int)

+ func (x DataType) String() string

+ type Field struct

+ Name string

+ Value *Value

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Field) ProtoMessage()

+ func (m *Field) GetName() string

+ func (m *Field) GetValue() *Value

+ func (m *Field) Reset()

+ func (m *Field) String() string

+ func (m *Field) XXX_DiscardUnknown()

+ func (m *Field) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Field) XXX_Merge(src proto.Message)

+ func (m *Field) XXX_Size() int

+ func (m *Field) XXX_Unmarshal(b []byte) error

+ type MapValue struct

+ Fields []*Field

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*MapValue) Descriptor() ([]byte, []int)

+ func (*MapValue) ProtoMessage()

+ func (m *MapValue) GetFields() []*Field

+ func (m *MapValue) Reset()

+ func (m *MapValue) String() string

+ func (m *MapValue) XXX_DiscardUnknown()

+ func (m *MapValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *MapValue) XXX_Merge(src proto.Message)

+ func (m *MapValue) XXX_Size() int

+ func (m *MapValue) XXX_Unmarshal(b []byte) error

+ type Method int32

+ const Method_DELETE

+ const Method_INSERT

+ const Method_TRUNCATE

+ const Method_UPDATE

+ func (Method) EnumDescriptor() ([]byte, []int)

+ func (x Method) String() string

+ type Record struct

+ EventName string

+ Fields []*Field

+ Method Method

+ PrimaryKey string

+ Table string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Record) Descriptor() ([]byte, []int)

+ func (*Record) ProtoMessage()

+ func (m *Record) GetEventName() string

+ func (m *Record) GetFields() []*Field

+ func (m *Record) GetMethod() Method

+ func (m *Record) GetPrimaryKey() string

+ func (m *Record) GetTable() string

+ func (m *Record) Reset()

+ func (m *Record) String() string

+ func (m *Record) XXX_DiscardUnknown()

+ func (m *Record) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Record) XXX_Merge(src proto.Message)

+ func (m *Record) XXX_Size() int

+ func (m *Record) XXX_Unmarshal(b []byte) error

+ type RecordDef struct

+ ColumnDefs []*ColumnDef

+ HasPrimary bool

+ PrimaryColumn string

+ Values map[string]interface{}

+ func GetDefinition(record *Record) (*RecordDef, error)

+ type SendReply struct

+ Reason string

+ Success bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SendReply) Descriptor() ([]byte, []int)

+ func (*SendReply) ProtoMessage()

+ func (m *SendReply) GetReason() string

+ func (m *SendReply) GetSuccess() bool

+ func (m *SendReply) Reset()

+ func (m *SendReply) String() string

+ func (m *SendReply) XXX_DiscardUnknown()

+ func (m *SendReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SendReply) XXX_Merge(src proto.Message)

+ func (m *SendReply) XXX_Size() int

+ func (m *SendReply) XXX_Unmarshal(b []byte) error

+ type TruncateReply struct

+ Reason string

+ Success bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TruncateReply) Descriptor() ([]byte, []int)

+ func (*TruncateReply) ProtoMessage()

+ func (m *TruncateReply) GetReason() string

+ func (m *TruncateReply) GetSuccess() bool

+ func (m *TruncateReply) Reset()

+ func (m *TruncateReply) String() string

+ func (m *TruncateReply) XXX_DiscardUnknown()

+ func (m *TruncateReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TruncateReply) XXX_Merge(src proto.Message)

+ func (m *TruncateReply) XXX_Size() int

+ func (m *TruncateReply) XXX_Unmarshal(b []byte) error

+ type TruncateRequest struct

+ Table string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TruncateRequest) Descriptor() ([]byte, []int)

+ func (*TruncateRequest) ProtoMessage()

+ func (m *TruncateRequest) GetTable() string

+ func (m *TruncateRequest) Reset()

+ func (m *TruncateRequest) String() string

+ func (m *TruncateRequest) XXX_DiscardUnknown()

+ func (m *TruncateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TruncateRequest) XXX_Merge(src proto.Message)

+ func (m *TruncateRequest) XXX_Size() int

+ func (m *TruncateRequest) XXX_Unmarshal(b []byte) error

+ type Value struct

+ Array *ArrayValue

+ Map *MapValue

+ Type DataType

+ Value []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Value) Descriptor() ([]byte, []int)

+ func (*Value) ProtoMessage()

+ func (m *Value) GetArray() *ArrayValue

+ func (m *Value) GetMap() *MapValue

+ func (m *Value) GetType() DataType

+ func (m *Value) GetValue() []byte

+ func (m *Value) Reset()

+ func (m *Value) String() string

+ func (m *Value) XXX_DiscardUnknown()

+ func (m *Value) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Value) XXX_Merge(src proto.Message)

+ func (m *Value) XXX_Size() int

+ func (m *Value) XXX_Unmarshal(b []byte) error