Documentation
¶
Index ¶
- Variables
- type Column
- func (*Column) Descriptor() ([]byte, []int)
- func (m *Column) GetFlag() uint32
- func (m *Column) GetName() string
- func (m *Column) GetType() uint32
- func (m *Column) GetValue() []byte
- func (m *Column) Marshal() (dAtA []byte, err error)
- func (m *Column) MarshalTo(dAtA []byte) (int, error)
- func (m *Column) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Column) ProtoMessage()
- func (m *Column) Reset()
- func (m *Column) Size() (n int)
- func (m *Column) String() string
- func (m *Column) Unmarshal(dAtA []byte) error
- func (m *Column) XXX_DiscardUnknown()
- func (m *Column) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Column) XXX_Merge(src proto.Message)
- func (m *Column) XXX_Size() int
- func (m *Column) XXX_Unmarshal(b []byte) error
- type ColumnsColumnar
- func (*ColumnsColumnar) Descriptor() ([]byte, []int)
- func (m *ColumnsColumnar) GetFlag() []uint32
- func (m *ColumnsColumnar) GetName() []string
- func (m *ColumnsColumnar) GetType() []uint32
- func (m *ColumnsColumnar) GetValue() [][]byte
- func (m *ColumnsColumnar) GetWhereHandle() []bool
- func (m *ColumnsColumnar) Marshal() (dAtA []byte, err error)
- func (m *ColumnsColumnar) MarshalTo(dAtA []byte) (int, error)
- func (m *ColumnsColumnar) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ColumnsColumnar) ProtoMessage()
- func (m *ColumnsColumnar) Reset()
- func (m *ColumnsColumnar) Size() (n int)
- func (m *ColumnsColumnar) String() string
- func (m *ColumnsColumnar) Unmarshal(dAtA []byte) error
- func (m *ColumnsColumnar) XXX_DiscardUnknown()
- func (m *ColumnsColumnar) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ColumnsColumnar) XXX_Merge(src proto.Message)
- func (m *ColumnsColumnar) XXX_Size() int
- func (m *ColumnsColumnar) XXX_Unmarshal(b []byte) error
- type Key
- func (*Key) Descriptor() ([]byte, []int)
- func (m *Key) GetPartition() int64
- func (m *Key) GetRowId() int64
- func (m *Key) GetSchema() string
- func (m *Key) GetTable() string
- func (m *Key) GetTs() uint64
- func (m *Key) GetType() uint32
- func (m *Key) Marshal() (dAtA []byte, err error)
- func (m *Key) MarshalTo(dAtA []byte) (int, error)
- func (m *Key) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Key) ProtoMessage()
- func (m *Key) Reset()
- func (m *Key) Size() (n int)
- func (m *Key) String() string
- func (m *Key) Unmarshal(dAtA []byte) error
- func (m *Key) XXX_DiscardUnknown()
- func (m *Key) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Key) XXX_Merge(src proto.Message)
- func (m *Key) XXX_Size() int
- func (m *Key) XXX_Unmarshal(b []byte) error
- type KeysColumnar
- func (*KeysColumnar) Descriptor() ([]byte, []int)
- func (m *KeysColumnar) GetPartition() []int64
- func (m *KeysColumnar) GetRowId() []int64
- func (m *KeysColumnar) GetSchema() []string
- func (m *KeysColumnar) GetTable() []string
- func (m *KeysColumnar) GetTs() []uint64
- func (m *KeysColumnar) GetType() []uint32
- func (m *KeysColumnar) Marshal() (dAtA []byte, err error)
- func (m *KeysColumnar) MarshalTo(dAtA []byte) (int, error)
- func (m *KeysColumnar) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*KeysColumnar) ProtoMessage()
- func (m *KeysColumnar) Reset()
- func (m *KeysColumnar) Size() (n int)
- func (m *KeysColumnar) String() string
- func (m *KeysColumnar) Unmarshal(dAtA []byte) error
- func (m *KeysColumnar) XXX_DiscardUnknown()
- func (m *KeysColumnar) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *KeysColumnar) XXX_Merge(src proto.Message)
- func (m *KeysColumnar) XXX_Size() int
- func (m *KeysColumnar) XXX_Unmarshal(b []byte) error
- type RowChanged
- func (*RowChanged) Descriptor() ([]byte, []int)
- func (m *RowChanged) GetNewValue() []*Column
- func (m *RowChanged) GetOldValue() []*Column
- func (m *RowChanged) Marshal() (dAtA []byte, err error)
- func (m *RowChanged) MarshalTo(dAtA []byte) (int, error)
- func (m *RowChanged) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*RowChanged) ProtoMessage()
- func (m *RowChanged) Reset()
- func (m *RowChanged) Size() (n int)
- func (m *RowChanged) String() string
- func (m *RowChanged) Unmarshal(dAtA []byte) error
- func (m *RowChanged) XXX_DiscardUnknown()
- func (m *RowChanged) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RowChanged) XXX_Merge(src proto.Message)
- func (m *RowChanged) XXX_Size() int
- func (m *RowChanged) XXX_Unmarshal(b []byte) error
- type RowChangedColumnar
- func (*RowChangedColumnar) Descriptor() ([]byte, []int)
- func (m *RowChangedColumnar) GetNewValue() []*ColumnsColumnar
- func (m *RowChangedColumnar) GetOldValue() []*ColumnsColumnar
- func (m *RowChangedColumnar) Marshal() (dAtA []byte, err error)
- func (m *RowChangedColumnar) MarshalTo(dAtA []byte) (int, error)
- func (m *RowChangedColumnar) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*RowChangedColumnar) ProtoMessage()
- func (m *RowChangedColumnar) Reset()
- func (m *RowChangedColumnar) Size() (n int)
- func (m *RowChangedColumnar) String() string
- func (m *RowChangedColumnar) Unmarshal(dAtA []byte) error
- func (m *RowChangedColumnar) XXX_DiscardUnknown()
- func (m *RowChangedColumnar) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RowChangedColumnar) XXX_Merge(src proto.Message)
- func (m *RowChangedColumnar) XXX_Size() int
- func (m *RowChangedColumnar) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
Functions ¶
This section is empty.
Types ¶
type Column ¶
type Column struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Type uint32 `protobuf:"varint,2,opt,name=type,proto3" json:"type,omitempty"` Flag uint32 `protobuf:"varint,3,opt,name=flag,proto3" json:"flag,omitempty"` Value []byte `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"` }
func (*Column) Descriptor ¶
func (*Column) MarshalToSizedBuffer ¶
func (*Column) ProtoMessage ¶
func (*Column) ProtoMessage()
func (*Column) XXX_DiscardUnknown ¶
func (m *Column) XXX_DiscardUnknown()
func (*Column) XXX_Marshal ¶
func (*Column) XXX_Unmarshal ¶
type ColumnsColumnar ¶
type ColumnsColumnar struct { Name []string `protobuf:"bytes,1,rep,name=name,proto3" json:"name,omitempty"` Type []uint32 `protobuf:"varint,2,rep,packed,name=type,proto3" json:"type,omitempty"` WhereHandle []bool `protobuf:"varint,3,rep,packed,name=where_handle,json=whereHandle,proto3" json:"where_handle,omitempty"` Flag []uint32 `protobuf:"varint,4,rep,packed,name=flag,proto3" json:"flag,omitempty"` Value [][]byte `protobuf:"bytes,5,rep,name=value,proto3" json:"value,omitempty"` }
func (*ColumnsColumnar) Descriptor ¶
func (*ColumnsColumnar) Descriptor() ([]byte, []int)
func (*ColumnsColumnar) GetFlag ¶
func (m *ColumnsColumnar) GetFlag() []uint32
func (*ColumnsColumnar) GetName ¶
func (m *ColumnsColumnar) GetName() []string
func (*ColumnsColumnar) GetType ¶
func (m *ColumnsColumnar) GetType() []uint32
func (*ColumnsColumnar) GetValue ¶
func (m *ColumnsColumnar) GetValue() [][]byte
func (*ColumnsColumnar) GetWhereHandle ¶
func (m *ColumnsColumnar) GetWhereHandle() []bool
func (*ColumnsColumnar) Marshal ¶
func (m *ColumnsColumnar) Marshal() (dAtA []byte, err error)
func (*ColumnsColumnar) MarshalToSizedBuffer ¶
func (m *ColumnsColumnar) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ColumnsColumnar) ProtoMessage ¶
func (*ColumnsColumnar) ProtoMessage()
func (*ColumnsColumnar) Reset ¶
func (m *ColumnsColumnar) Reset()
func (*ColumnsColumnar) Size ¶
func (m *ColumnsColumnar) Size() (n int)
func (*ColumnsColumnar) String ¶
func (m *ColumnsColumnar) String() string
func (*ColumnsColumnar) Unmarshal ¶
func (m *ColumnsColumnar) Unmarshal(dAtA []byte) error
func (*ColumnsColumnar) XXX_DiscardUnknown ¶
func (m *ColumnsColumnar) XXX_DiscardUnknown()
func (*ColumnsColumnar) XXX_Marshal ¶
func (m *ColumnsColumnar) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ColumnsColumnar) XXX_Merge ¶
func (m *ColumnsColumnar) XXX_Merge(src proto.Message)
func (*ColumnsColumnar) XXX_Size ¶
func (m *ColumnsColumnar) XXX_Size() int
func (*ColumnsColumnar) XXX_Unmarshal ¶
func (m *ColumnsColumnar) XXX_Unmarshal(b []byte) error
type Key ¶
type Key struct { Ts uint64 `protobuf:"varint,1,opt,name=ts,proto3" json:"ts,omitempty"` Schema string `protobuf:"bytes,2,opt,name=schema,proto3" json:"schema,omitempty"` Table string `protobuf:"bytes,3,opt,name=table,proto3" json:"table,omitempty"` RowId int64 `protobuf:"varint,4,opt,name=row_id,json=rowId,proto3" json:"row_id,omitempty"` Type uint32 `protobuf:"varint,5,opt,name=type,proto3" json:"type,omitempty"` Partition int64 `protobuf:"varint,6,opt,name=partition,proto3" json:"partition,omitempty"` }
func (*Key) Descriptor ¶
func (*Key) GetPartition ¶
func (*Key) ProtoMessage ¶
func (*Key) ProtoMessage()
func (*Key) XXX_DiscardUnknown ¶
func (m *Key) XXX_DiscardUnknown()
func (*Key) XXX_Unmarshal ¶
type KeysColumnar ¶
type KeysColumnar struct { Ts []uint64 `protobuf:"varint,1,rep,packed,name=ts,proto3" json:"ts,omitempty"` Schema []string `protobuf:"bytes,2,rep,name=schema,proto3" json:"schema,omitempty"` Table []string `protobuf:"bytes,3,rep,name=table,proto3" json:"table,omitempty"` RowId []int64 `protobuf:"varint,4,rep,packed,name=row_id,json=rowId,proto3" json:"row_id,omitempty"` Type []uint32 `protobuf:"varint,5,rep,packed,name=type,proto3" json:"type,omitempty"` Partition []int64 `protobuf:"varint,6,rep,packed,name=partition,proto3" json:"partition,omitempty"` }
func (*KeysColumnar) Descriptor ¶
func (*KeysColumnar) Descriptor() ([]byte, []int)
func (*KeysColumnar) GetPartition ¶
func (m *KeysColumnar) GetPartition() []int64
func (*KeysColumnar) GetRowId ¶
func (m *KeysColumnar) GetRowId() []int64
func (*KeysColumnar) GetSchema ¶
func (m *KeysColumnar) GetSchema() []string
func (*KeysColumnar) GetTable ¶
func (m *KeysColumnar) GetTable() []string
func (*KeysColumnar) GetTs ¶
func (m *KeysColumnar) GetTs() []uint64
func (*KeysColumnar) GetType ¶
func (m *KeysColumnar) GetType() []uint32
func (*KeysColumnar) Marshal ¶
func (m *KeysColumnar) Marshal() (dAtA []byte, err error)
func (*KeysColumnar) MarshalToSizedBuffer ¶
func (m *KeysColumnar) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*KeysColumnar) ProtoMessage ¶
func (*KeysColumnar) ProtoMessage()
func (*KeysColumnar) Reset ¶
func (m *KeysColumnar) Reset()
func (*KeysColumnar) Size ¶
func (m *KeysColumnar) Size() (n int)
func (*KeysColumnar) String ¶
func (m *KeysColumnar) String() string
func (*KeysColumnar) Unmarshal ¶
func (m *KeysColumnar) Unmarshal(dAtA []byte) error
func (*KeysColumnar) XXX_DiscardUnknown ¶
func (m *KeysColumnar) XXX_DiscardUnknown()
func (*KeysColumnar) XXX_Marshal ¶
func (m *KeysColumnar) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*KeysColumnar) XXX_Merge ¶
func (m *KeysColumnar) XXX_Merge(src proto.Message)
func (*KeysColumnar) XXX_Size ¶
func (m *KeysColumnar) XXX_Size() int
func (*KeysColumnar) XXX_Unmarshal ¶
func (m *KeysColumnar) XXX_Unmarshal(b []byte) error
type RowChanged ¶
type RowChanged struct { OldValue []*Column `protobuf:"bytes,1,rep,name=old_value,json=oldValue,proto3" json:"old_value,omitempty"` NewValue []*Column `protobuf:"bytes,2,rep,name=new_value,json=newValue,proto3" json:"new_value,omitempty"` }
func (*RowChanged) Descriptor ¶
func (*RowChanged) Descriptor() ([]byte, []int)
func (*RowChanged) GetNewValue ¶
func (m *RowChanged) GetNewValue() []*Column
func (*RowChanged) GetOldValue ¶
func (m *RowChanged) GetOldValue() []*Column
func (*RowChanged) Marshal ¶
func (m *RowChanged) Marshal() (dAtA []byte, err error)
func (*RowChanged) MarshalToSizedBuffer ¶
func (m *RowChanged) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*RowChanged) ProtoMessage ¶
func (*RowChanged) ProtoMessage()
func (*RowChanged) Reset ¶
func (m *RowChanged) Reset()
func (*RowChanged) Size ¶
func (m *RowChanged) Size() (n int)
func (*RowChanged) String ¶
func (m *RowChanged) String() string
func (*RowChanged) Unmarshal ¶
func (m *RowChanged) Unmarshal(dAtA []byte) error
func (*RowChanged) XXX_DiscardUnknown ¶
func (m *RowChanged) XXX_DiscardUnknown()
func (*RowChanged) XXX_Marshal ¶
func (m *RowChanged) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RowChanged) XXX_Merge ¶
func (m *RowChanged) XXX_Merge(src proto.Message)
func (*RowChanged) XXX_Size ¶
func (m *RowChanged) XXX_Size() int
func (*RowChanged) XXX_Unmarshal ¶
func (m *RowChanged) XXX_Unmarshal(b []byte) error
type RowChangedColumnar ¶
type RowChangedColumnar struct { OldValue []*ColumnsColumnar `protobuf:"bytes,1,rep,name=old_value,json=oldValue,proto3" json:"old_value,omitempty"` NewValue []*ColumnsColumnar `protobuf:"bytes,2,rep,name=new_value,json=newValue,proto3" json:"new_value,omitempty"` }
func (*RowChangedColumnar) Descriptor ¶
func (*RowChangedColumnar) Descriptor() ([]byte, []int)
func (*RowChangedColumnar) GetNewValue ¶
func (m *RowChangedColumnar) GetNewValue() []*ColumnsColumnar
func (*RowChangedColumnar) GetOldValue ¶
func (m *RowChangedColumnar) GetOldValue() []*ColumnsColumnar
func (*RowChangedColumnar) Marshal ¶
func (m *RowChangedColumnar) Marshal() (dAtA []byte, err error)
func (*RowChangedColumnar) MarshalTo ¶
func (m *RowChangedColumnar) MarshalTo(dAtA []byte) (int, error)
func (*RowChangedColumnar) MarshalToSizedBuffer ¶
func (m *RowChangedColumnar) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*RowChangedColumnar) ProtoMessage ¶
func (*RowChangedColumnar) ProtoMessage()
func (*RowChangedColumnar) Reset ¶
func (m *RowChangedColumnar) Reset()
func (*RowChangedColumnar) Size ¶
func (m *RowChangedColumnar) Size() (n int)
func (*RowChangedColumnar) String ¶
func (m *RowChangedColumnar) String() string
func (*RowChangedColumnar) Unmarshal ¶
func (m *RowChangedColumnar) Unmarshal(dAtA []byte) error
func (*RowChangedColumnar) XXX_DiscardUnknown ¶
func (m *RowChangedColumnar) XXX_DiscardUnknown()
func (*RowChangedColumnar) XXX_Marshal ¶
func (m *RowChangedColumnar) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RowChangedColumnar) XXX_Merge ¶
func (m *RowChangedColumnar) XXX_Merge(src proto.Message)
func (*RowChangedColumnar) XXX_Size ¶
func (m *RowChangedColumnar) XXX_Size() int
func (*RowChangedColumnar) XXX_Unmarshal ¶
func (m *RowChangedColumnar) XXX_Unmarshal(b []byte) error
Click to show internal directories.
Click to hide internal directories.