common

package

Go to main page

Versions in this module

v0

v0.1.6

Aug 16, 2022

Changes in this version

+ const DummyTableID

+ const ShardLeaderTableID

+ func GetOrDefaultIntProperty(propName string, props map[string]string, def int) (int, error)

+ func NanoTime() uint64

type IndexInfo

+ func NewIndexInfo(schemaName string, id uint64, tableName string, name string, indexCols []int) *IndexInfo

+ func (i *IndexInfo) CalcColsSet()

type SourceOriginInfo

+ ConsumerGroupID string

+ Transient bool

+ type SpinLock struct

+ func (l *SpinLock) Lock()

+ func (l *SpinLock) Unlock()

type TableInfo

+ func NewTableInfo(id uint64, schemaName string, name string, pkCols []int, colNames []string, ...) *TableInfo

+ func (t *TableInfo) CalcPKColsSet()

v0.1.5-beta.1

Jul 18, 2022

v0.1.4-beta.1

Jul 6, 2022

v0.1.3-beta.1

Jul 6, 2022

v0.1.2

Jul 6, 2022

v0.1.2-beta.1

Jul 6, 2022

v0.1.1

Jul 6, 2022

Changes in this version

+ func KeyDecodeInt64(buffer []byte, offset int) (int64, int)

+ func LogInternalError(err error) errors.PranaError

type Decimal

+ func KeyDecodeDecimal(buffer []byte, offset int, precision int, scale int) (Decimal, int, error)

type MaterializedViewInfo

+ OriginInfo *MaterializedViewOriginInfo

+ type MaterializedViewOriginInfo struct

+ InitialState string

type SourceInfo

+ OriginInfo *SourceOriginInfo

+ type SourceOriginInfo struct

+ BrokerName string

+ ColSelectors []selector.ColumnSelector

+ HeaderEncoding KafkaEncoding

+ IngestFilter string

+ InitialState string

+ KeyEncoding KafkaEncoding

+ Properties map[string]string

+ TopicName string

+ ValueEncoding KafkaEncoding

type Timestamp

+ func KeyDecodeTimestamp(buffer []byte, offset int, fsp int8) (Timestamp, int, error)

v0.1.1-beta.1

Jun 30, 2022

v0.1.0

Jun 23, 2022

Changes in this version

+ const ForwardDedupTableID

+ const IndexTableID

+ const LastLogIndexReceivedTableID

+ const LocalConfigTableID

+ const LocksTableID

+ const ProtobufTableID

+ const ReceiverTableID

+ const SchemaTableID

+ const SequenceGeneratorTableID

+ const SignBitMask

+ const SyncTableID

+ const ToDeleteTableID

+ const UserTableIDBase

+ var BigIntColumnType = ColumnType

+ var ColumnTypesByType = map[Type]ColumnType

+ var DoubleColumnType = ColumnType

+ var IntColumnType = ColumnType

+ var IsLittleEndian = isLittleEndian()

+ var KafkaEncodingCSV = KafkaEncoding

+ var KafkaEncodingFloat32BE = KafkaEncoding

+ var KafkaEncodingFloat64BE = KafkaEncoding

+ var KafkaEncodingInt16BE = KafkaEncoding

+ var KafkaEncodingInt32BE = KafkaEncoding

+ var KafkaEncodingInt64BE = KafkaEncoding

+ var KafkaEncodingJSON = KafkaEncoding

+ var KafkaEncodingRaw = KafkaEncoding

+ var KafkaEncodingStringBytes = KafkaEncoding

+ var KafkaEncodingUnknown = KafkaEncoding

+ var TimestampColumnType = ColumnType

+ var TinyIntColumnType = ColumnType

+ var UnknownColumnType = ColumnType

+ var VarcharColumnType = ColumnType

+ func AppendFloat32ToBufferBE(buffer []byte, value float32) []byte

+ func AppendFloat64ToBufferBE(buffer []byte, value float64) []byte

+ func AppendFloat64ToBufferLE(buffer []byte, value float64) []byte

+ func AppendStringToBufferLE(buffer []byte, value string) []byte

+ func AppendTimestampToBuffer(buffer []byte, ts Timestamp) ([]byte, error)

+ func AppendUint16ToBufferBE(buffer []byte, v uint16) []byte

+ func AppendUint32ToBufferBE(buffer []byte, v uint32) []byte

+ func AppendUint32ToBufferLE(buffer []byte, v uint32) []byte

+ func AppendUint64ToBufferBE(buffer []byte, v uint64) []byte

+ func AppendUint64ToBufferLE(buffer []byte, v uint64) []byte

+ func ByteSliceToStringZeroCopy(buffer []byte) string

+ func ConvertPranaTypeToTiDBType(columnType ColumnType) *types.FieldType

+ func CopyByteSlice(buff []byte) []byte

+ func DecodeIndexOrPKCol(buffer []byte, offset int, colType ColumnType, outputColIndex int, pkCol bool, ...) (int, error)

+ func DecodeIndexOrPKCols(buffer []byte, offset int, pk bool, indexOrPKColTypes []ColumnType, ...) (int, error)

+ func DecodeRow(buffer []byte, colTypes []ColumnType, rows *Rows) error

+ func DecodeRowWithIgnoredCols(buffer []byte, colTypes []ColumnType, includeCol []bool, rows *Rows) error

+ func DoDumpStacks(filterSpam bool)

+ func DumpDataKey(bytes []byte) string

+ func DumpStacks()

+ func EncodeIndexKeyCols(row *Row, colIndexes []int, colTypes []ColumnType, buffer []byte) ([]byte, error)

+ func EncodeKey(key Key, colTypes []ColumnType, keyColIndexes []int, buffer []byte) ([]byte, error)

+ func EncodeKeyCol(row *Row, colIndex int, colType ColumnType, buffer []byte) ([]byte, error)

+ func EncodeKeyCols(row *Row, colIndexes []int, colTypes []ColumnType, buffer []byte) ([]byte, error)

+ func EncodeKeyElement(value interface{}, colType ColumnType, buffer []byte) ([]byte, error)

+ func EncodeRow(row *Row, colTypes []ColumnType, buffer []byte) ([]byte, error)

+ func IncrementBytesBigEndian(bytes []byte) []byte

+ func InvokeCloser(closer io.Closer)

+ func KeyDecodeFloat64(buffer []byte, offset int) (float64, int)

+ func KeyDecodeString(buffer []byte, offset int) (string, int)

+ func KeyEncodeDecimal(buffer []byte, val Decimal, precision int, scale int) ([]byte, error)

+ func KeyEncodeFloat64(buffer []byte, val float64) []byte

+ func KeyEncodeInt64(buffer []byte, val int64) []byte

+ func KeyEncodeString(buffer []byte, val string) []byte

+ func KeyEncodeTimestamp(buffer []byte, val Timestamp) ([]byte, error)

+ func PanicHandler()

+ func ReadFloat32FromBufferBE(buffer []byte, offset int) (val float32, off int)

+ func ReadFloat64FromBufferBE(buffer []byte, offset int) (val float64, off int)

+ func ReadFloat64FromBufferLE(buffer []byte, offset int) (val float64, off int)

+ func ReadInt64FromBufferLE(buffer []byte, offset int) (int64, int)

+ func ReadStringFromBufferLE(buffer []byte, offset int) (val string, off int)

+ func ReadUint16FromBufferBE(buffer []byte, offset int) (uint16, int)

+ func ReadUint32FromBufferBE(buffer []byte, offset int) (uint32, int)

+ func ReadUint32FromBufferLE(buffer []byte, offset int) (uint32, int)

+ func ReadUint64FromBufferBE(buffer []byte, offset int) (uint64, int)

+ func ReadUint64FromBufferLE(buffer []byte, offset int) (uint64, int)

+ func RoundTimestampToFSP(ts *Timestamp, fsp int8) error

+ func StringToByteSliceZeroCopy(str string) []byte

+ func TiDBValueToPranaValue(tidbValue interface{}) interface

+ type AtomicBool struct

+ func (a *AtomicBool) CompareAndSet(expected bool, val bool) bool

+ func (a *AtomicBool) Get() bool

+ func (a *AtomicBool) Set(val bool)

+ type ByteSliceMap struct

+ TheMap map[string][]byte

+ func NewByteSliceMap() *ByteSliceMap

+ func (b *ByteSliceMap) Get(key []byte) (v []byte, ok bool)

+ func (b *ByteSliceMap) Put(key []byte, value []byte)

+ type ColumnInfo struct

+ Name string

+ type ColumnType struct

+ DecPrecision int

+ DecScale int

+ FSP int8

+ Type Type

+ func ConvertTiDBTypeToPranaType(columnType *types.FieldType) ColumnType

+ func InferColumnType(value interface{}) ColumnType

+ func NewDecimalColumnType(precision int, scale int) ColumnType

+ func NewTimestampColumnType(fsp int8) ColumnType

+ func (t *ColumnType) String() string

+ type Decimal struct

+ func NewDecFromFloat64(f float64) (*Decimal, error)

+ func NewDecFromInt64(i int64) *Decimal

+ func NewDecFromString(s string) (*Decimal, error)

+ func NewDecFromUint64(i uint64) *Decimal

+ func NewDecimal(dec *types.MyDecimal) *Decimal

+ func ReadDecimalFromBuffer(buffer []byte, offset int, precision int, scale int) (val Decimal, off int, err error)

+ func ZeroDecimal() *Decimal

+ func (d *Decimal) Add(other *Decimal) (*Decimal, error)

+ func (d *Decimal) CompareTo(dec *Decimal) int

+ func (d *Decimal) Decode(buffer []byte, offset int, precision int, scale int) (int, error)

+ func (d *Decimal) Encode(buffer []byte, precision int, scale int) ([]byte, error)

+ func (d *Decimal) String() string

+ func (d *Decimal) Subtract(other *Decimal) (*Decimal, error)

+ type Encoding int

+ const EncodingCSV

+ const EncodingFloat32BE

+ const EncodingFloat64BE

+ const EncodingInt16BE

+ const EncodingInt32BE

+ const EncodingInt64BE

+ const EncodingJSON

+ const EncodingProtobuf

+ const EncodingRaw

+ const EncodingStringBytes

+ const EncodingUnknown

+ func EncodingFormatFromString(str string) Encoding

+ type Expression struct

+ func NewColumnExpression(colIndex int, colType ColumnType) *Expression

+ func NewConstantDouble(colType ColumnType, val float64) *Expression

+ func NewConstantInt(colType ColumnType, val int64) *Expression

+ func NewConstantVarchar(colType ColumnType, val string) *Expression

+ func NewExpression(exp expression.Expression, ctx sessionctx.Context) *Expression

+ func NewScalarFunctionExpression(colType ColumnType, funcName string, args ...*Expression) (*Expression, error)

+ func (e *Expression) EvalBoolean(row *Row) (bool, bool, error)

+ func (e *Expression) EvalDecimal(row *Row) (Decimal, bool, error)

+ func (e *Expression) EvalFloat64(row *Row) (val float64, null bool, err error)

+ func (e *Expression) EvalInt64(row *Row) (val int64, null bool, err error)

+ func (e *Expression) EvalString(row *Row) (val string, null bool, err error)

+ func (e *Expression) EvalTimestamp(row *Row) (Timestamp, bool, error)

+ func (e *Expression) GetColumnIndex() (int, bool)

+ func (e *Expression) ReturnType(colTypes []ColumnType) (ColumnType, error)

+ type IndexInfo struct

+ ID uint64

+ IndexCols []int

+ Name string

+ SchemaName string

+ TableName string

+ func (i *IndexInfo) ContainsColIndex(colIndex int) bool

+ type InternalTableInfo struct

+ MaterializedViewName string

+ type KafkaEncoding struct

+ Encoding Encoding

+ SchemaName string

+ func KafkaEncodingFromString(str string) KafkaEncoding

+ type Key []interface

+ type MaterializedViewInfo struct

+ Query string

+ func (i *MaterializedViewInfo) String() string

+ type MetaTableInfo struct

+ func (i *MetaTableInfo) String() string

+ type PreAllocatedSeqGenerator struct

+ func NewPreallocSeqGen(seq []uint64) *PreAllocatedSeqGenerator

+ func (p *PreAllocatedSeqGenerator) GenerateSequence() uint64

+ type Row struct

+ func (r *Row) ColCount() int

+ func (r *Row) ColumnTypes() []ColumnType

+ func (r *Row) GetByte(colIndex int) byte

+ func (r *Row) GetDecimal(colIndex int) Decimal

+ func (r *Row) GetFloat64(colIndex int) float64

+ func (r *Row) GetInt64(colIndex int) int64

+ func (r *Row) GetString(colIndex int) string

+ func (r *Row) GetTimestamp(colIndex int) Timestamp

+ func (r *Row) IsNull(colIndex int) bool

+ func (r *Row) String() string

+ type Rows struct

+ func NewRows(columnTypes []ColumnType, capacity int) *Rows

+ func (r *Rows) AppendAll(other *Rows)

+ func (r *Rows) AppendDecimalToColumn(colIndex int, val Decimal)

+ func (r *Rows) AppendFloat64ToColumn(colIndex int, val float64)

+ func (r *Rows) AppendInt64ToColumn(colIndex int, val int64)

+ func (r *Rows) AppendNullToColumn(colIndex int)

+ func (r *Rows) AppendRow(row Row)

+ func (r *Rows) AppendStringToColumn(colIndex int, val string)

+ func (r *Rows) AppendTimestampToColumn(colIndex int, val Timestamp)

+ func (r *Rows) ColumnTypes() []ColumnType

+ func (r *Rows) Deserialize(buff []byte)

+ func (r *Rows) GetRow(rowIndex int) Row

+ func (r *Rows) RowCount() int

+ func (r *Rows) Serialize() []byte

+ func (r *Rows) String() string

+ type RowsFactory struct

+ ColumnTypes []ColumnType

+ func NewRowsFactory(columnTypes []ColumnType) *RowsFactory

+ func (rf *RowsFactory) NewRows(capacity int) *Rows

+ type Schema struct

+ Name string

+ func NewSchema(name string) *Schema

+ func (s *Schema) DeleteIndex(tableName string, indexName string) error

+ func (s *Schema) DeleteTable(name string)

+ func (s *Schema) Equal(other *Schema) bool

+ func (s *Schema) GetAllTableInfos() map[string]*TableInfo

+ func (s *Schema) GetTable(name string) (Table, bool)

+ func (s *Schema) IsDeleted() bool

+ func (s *Schema) LenTables() int

+ func (s *Schema) PutIndex(indexInfo *IndexInfo) error

+ func (s *Schema) PutTable(name string, table Table)

+ func (s *Schema) SetDeleted()

+ type SeqGenerator interface

+ GenerateSequence func() uint64

+ type SimpleQueryExec interface

+ ExecuteQuery func(schemaName string, query string) (rows *Rows, err error)

+ type SinkInfo struct

+ Name string

+ Query string

+ TopicInfo *TopicInfo

+ type SourceInfo struct

+ TopicInfo *TopicInfo

+ func (i *SourceInfo) String() string

+ type Table interface

+ GetTableInfo func() *TableInfo

+ type TableInfo struct

+ ColsVisible []bool

+ ColumnNames []string

+ ColumnTypes []ColumnType

+ ID uint64

+ IndexInfos map[string]*IndexInfo

+ Internal bool

+ Name string

+ PrimaryKeyCols []int

+ SchemaName string

+ func (t *TableInfo) GetTableInfo() *TableInfo

+ func (t *TableInfo) IsPrimaryKeyCol(colIndex int) bool

+ func (t *TableInfo) String() string

+ type Timestamp = types.Time

+ func NewTimestampFromGoTime(t time.Time) Timestamp

+ func NewTimestampFromString(str string) Timestamp

+ func NewTimestampFromUnixEpochMillis(v int64) Timestamp

+ func ReadTimestampFromBuffer(buffer []byte, offset int, fsp int8) (val Timestamp, off int, err error)

+ func ReadTimestampFromBufferBE(buffer []byte, offset int, fsp int8) (val Timestamp, off int, err error)

+ type TopicInfo struct

+ BrokerName string

+ ColSelectors []selector.ColumnSelector

+ HeaderEncoding KafkaEncoding

+ KeyEncoding KafkaEncoding

+ Properties map[string]string

+ TopicName string

+ ValueEncoding KafkaEncoding

+ type Type int

+ const TypeBigInt

+ const TypeDecimal

+ const TypeDouble

+ const TypeInt

+ const TypeTimestamp

+ const TypeTinyInt

+ const TypeUnknown

+ const TypeVarchar

+ func (t *Type) Capture(tokens []string) error

+ func (t Type) String() string

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