dataprotocol

package
v1.7.11 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 20, 2023 License: Apache-2.0 Imports: 1 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var EnumNamesDataType = map[DataType]string{
	DataTypeNONE:       "NONE",
	DataTypeLONG:       "LONG",
	DataTypeBOOLEAN:    "BOOLEAN",
	DataTypeDOUBLE:     "DOUBLE",
	DataTypeSTRING:     "STRING",
	DataTypeBINARY:     "BINARY",
	DataTypeSTRING_RLE: "STRING_RLE",
	DataTypeCOMPLEX:    "COMPLEX",
}
View Source
var EnumNamesLogicType = map[LogicType]string{
	LogicTypeNONE:     "NONE",
	LogicTypeDATETIME: "DATETIME",
	LogicTypeDATE:     "DATE",
	LogicTypeTIME:     "TIME",
}

Functions

func BytesValueAddValue

func BytesValueAddValue(builder *flatbuffers.Builder, value flatbuffers.UOffsetT)

func BytesValueEnd

func BytesValueEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT

func BytesValueStart

func BytesValueStart(builder *flatbuffers.Builder)

func BytesValueStartValueVector

func BytesValueStartValueVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT

func ColumnValuesAddBinaryValues

func ColumnValuesAddBinaryValues(builder *flatbuffers.Builder, binaryValues flatbuffers.UOffsetT)

func ColumnValuesAddBoolValues

func ColumnValuesAddBoolValues(builder *flatbuffers.Builder, boolValues flatbuffers.UOffsetT)

func ColumnValuesAddDoubleValues

func ColumnValuesAddDoubleValues(builder *flatbuffers.Builder, doubleValues flatbuffers.UOffsetT)

func ColumnValuesAddIsNullvalues

func ColumnValuesAddIsNullvalues(builder *flatbuffers.Builder, isNullvalues flatbuffers.UOffsetT)

func ColumnValuesAddLongValues

func ColumnValuesAddLongValues(builder *flatbuffers.Builder, longValues flatbuffers.UOffsetT)

func ColumnValuesAddRleStringValues

func ColumnValuesAddRleStringValues(builder *flatbuffers.Builder, rleStringValues flatbuffers.UOffsetT)

func ColumnValuesAddStringValues

func ColumnValuesAddStringValues(builder *flatbuffers.Builder, stringValues flatbuffers.UOffsetT)

func ColumnValuesEnd

func ColumnValuesEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT

func ColumnValuesStart

func ColumnValuesStart(builder *flatbuffers.Builder)

func ColumnValuesStartBinaryValuesVector

func ColumnValuesStartBinaryValuesVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT

func ColumnValuesStartBoolValuesVector

func ColumnValuesStartBoolValuesVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT

func ColumnValuesStartDoubleValuesVector

func ColumnValuesStartDoubleValuesVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT

func ColumnValuesStartIsNullvaluesVector

func ColumnValuesStartIsNullvaluesVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT

func ColumnValuesStartLongValuesVector

func ColumnValuesStartLongValuesVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT

func ColumnValuesStartStringValuesVector

func ColumnValuesStartStringValuesVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT

func ComplexColumnTypeInfoAddColumnEncodeType added in v1.7.8

func ComplexColumnTypeInfoAddColumnEncodeType(builder *flatbuffers.Builder, columnEncodeType int8)

func ComplexColumnTypeInfoAddColumnLogicType added in v1.7.8

func ComplexColumnTypeInfoAddColumnLogicType(builder *flatbuffers.Builder, columnLogicType int8)

func ComplexColumnTypeInfoEnd added in v1.7.8

func ComplexColumnTypeInfoEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT

func ComplexColumnTypeInfoStart added in v1.7.8

func ComplexColumnTypeInfoStart(builder *flatbuffers.Builder)

func RLEStringValuesAddArray

func RLEStringValuesAddArray(builder *flatbuffers.Builder, array flatbuffers.UOffsetT)

func RLEStringValuesAddIndexMapping

func RLEStringValuesAddIndexMapping(builder *flatbuffers.Builder, indexMapping flatbuffers.UOffsetT)

func RLEStringValuesEnd

func RLEStringValuesEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT

func RLEStringValuesStart

func RLEStringValuesStart(builder *flatbuffers.Builder)

func RLEStringValuesStartArrayVector

func RLEStringValuesStartArrayVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT

func RLEStringValuesStartIndexMappingVector

func RLEStringValuesStartIndexMappingVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT

func SQLResponseColumnAddColumnComplexTypeInfo added in v1.7.8

func SQLResponseColumnAddColumnComplexTypeInfo(builder *flatbuffers.Builder, columnComplexTypeInfo flatbuffers.UOffsetT)

func SQLResponseColumnAddColumnName

func SQLResponseColumnAddColumnName(builder *flatbuffers.Builder, columnName flatbuffers.UOffsetT)

func SQLResponseColumnAddColumnType

func SQLResponseColumnAddColumnType(builder *flatbuffers.Builder, columnType int8)

func SQLResponseColumnAddColumnValue

func SQLResponseColumnAddColumnValue(builder *flatbuffers.Builder, columnValue flatbuffers.UOffsetT)

func SQLResponseColumnEnd

func SQLResponseColumnEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT

func SQLResponseColumnStart

func SQLResponseColumnStart(builder *flatbuffers.Builder)

func SQLResponseColumnsAddColumns

func SQLResponseColumnsAddColumns(builder *flatbuffers.Builder, columns flatbuffers.UOffsetT)

func SQLResponseColumnsAddRowCount

func SQLResponseColumnsAddRowCount(builder *flatbuffers.Builder, rowCount int64)

func SQLResponseColumnsEnd

func SQLResponseColumnsEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT

func SQLResponseColumnsStart

func SQLResponseColumnsStart(builder *flatbuffers.Builder)

func SQLResponseColumnsStartColumnsVector

func SQLResponseColumnsStartColumnsVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT

func StringValuesAddArray

func StringValuesAddArray(builder *flatbuffers.Builder, array flatbuffers.UOffsetT)

func StringValuesAddIndexMapping

func StringValuesAddIndexMapping(builder *flatbuffers.Builder, indexMapping flatbuffers.UOffsetT)

func StringValuesEnd

func StringValuesEnd(builder *flatbuffers.Builder) flatbuffers.UOffsetT

func StringValuesStart

func StringValuesStart(builder *flatbuffers.Builder)

func StringValuesStartArrayVector

func StringValuesStartArrayVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT

func StringValuesStartIndexMappingVector

func StringValuesStartIndexMappingVector(builder *flatbuffers.Builder, numElems int) flatbuffers.UOffsetT

Types

type BytesValue

type BytesValue struct {
	// contains filtered or unexported fields
}

func GetRootAsBytesValue

func GetRootAsBytesValue(buf []byte, offset flatbuffers.UOffsetT) *BytesValue

func (*BytesValue) Init

func (rcv *BytesValue) Init(buf []byte, i flatbuffers.UOffsetT)

func (*BytesValue) MutateValue

func (rcv *BytesValue) MutateValue(j int, n int8) bool

func (*BytesValue) Table

func (rcv *BytesValue) Table() flatbuffers.Table

func (*BytesValue) Value

func (rcv *BytesValue) Value(j int) int8

func (*BytesValue) ValueLength

func (rcv *BytesValue) ValueLength() int

type ColumnValues

type ColumnValues struct {
	// contains filtered or unexported fields
}

func GetRootAsColumnValues

func GetRootAsColumnValues(buf []byte, offset flatbuffers.UOffsetT) *ColumnValues

func (*ColumnValues) BinaryValues

func (rcv *ColumnValues) BinaryValues(obj *BytesValue, j int) bool

func (*ColumnValues) BinaryValuesLength

func (rcv *ColumnValues) BinaryValuesLength() int

func (*ColumnValues) BoolValues

func (rcv *ColumnValues) BoolValues(j int) bool

func (*ColumnValues) BoolValuesLength

func (rcv *ColumnValues) BoolValuesLength() int

func (*ColumnValues) DoubleValues

func (rcv *ColumnValues) DoubleValues(j int) float64

func (*ColumnValues) DoubleValuesLength

func (rcv *ColumnValues) DoubleValuesLength() int

func (*ColumnValues) Init

func (rcv *ColumnValues) Init(buf []byte, i flatbuffers.UOffsetT)

func (*ColumnValues) IsNullvalues

func (rcv *ColumnValues) IsNullvalues(j int) bool

func (*ColumnValues) IsNullvaluesLength

func (rcv *ColumnValues) IsNullvaluesLength() int

func (*ColumnValues) LongValues

func (rcv *ColumnValues) LongValues(j int) int64

func (*ColumnValues) LongValuesLength

func (rcv *ColumnValues) LongValuesLength() int

func (*ColumnValues) MutateBoolValues

func (rcv *ColumnValues) MutateBoolValues(j int, n bool) bool

func (*ColumnValues) MutateDoubleValues

func (rcv *ColumnValues) MutateDoubleValues(j int, n float64) bool

func (*ColumnValues) MutateIsNullvalues

func (rcv *ColumnValues) MutateIsNullvalues(j int, n bool) bool

func (*ColumnValues) MutateLongValues

func (rcv *ColumnValues) MutateLongValues(j int, n int64) bool

func (*ColumnValues) RleStringValues

func (rcv *ColumnValues) RleStringValues(obj *RLEStringValues) *RLEStringValues

func (*ColumnValues) StringValues

func (rcv *ColumnValues) StringValues(j int) []byte

func (*ColumnValues) StringValuesLength

func (rcv *ColumnValues) StringValuesLength() int

func (*ColumnValues) Table

func (rcv *ColumnValues) Table() flatbuffers.Table

type ComplexColumnTypeInfo added in v1.7.8

type ComplexColumnTypeInfo struct {
	// contains filtered or unexported fields
}

func GetRootAsComplexColumnTypeInfo added in v1.7.8

func GetRootAsComplexColumnTypeInfo(buf []byte, offset flatbuffers.UOffsetT) *ComplexColumnTypeInfo

func (*ComplexColumnTypeInfo) ColumnEncodeType added in v1.7.8

func (rcv *ComplexColumnTypeInfo) ColumnEncodeType() DataType

func (*ComplexColumnTypeInfo) ColumnLogicType added in v1.7.8

func (rcv *ComplexColumnTypeInfo) ColumnLogicType() LogicType

func (*ComplexColumnTypeInfo) Init added in v1.7.8

func (rcv *ComplexColumnTypeInfo) Init(buf []byte, i flatbuffers.UOffsetT)

func (*ComplexColumnTypeInfo) MutateColumnEncodeType added in v1.7.8

func (rcv *ComplexColumnTypeInfo) MutateColumnEncodeType(n DataType) bool

func (*ComplexColumnTypeInfo) MutateColumnLogicType added in v1.7.8

func (rcv *ComplexColumnTypeInfo) MutateColumnLogicType(n LogicType) bool

func (*ComplexColumnTypeInfo) Table added in v1.7.8

type DataType

type DataType = int8
const (
	DataTypeNONE       DataType = 0
	DataTypeLONG       DataType = 1
	DataTypeBOOLEAN    DataType = 2
	DataTypeDOUBLE     DataType = 3
	DataTypeSTRING     DataType = 4
	DataTypeBINARY     DataType = 5
	DataTypeSTRING_RLE DataType = 6
	DataTypeCOMPLEX    DataType = 7
)

type LogicType added in v1.7.8

type LogicType = int8
const (
	LogicTypeNONE     LogicType = 0
	LogicTypeDATETIME LogicType = 1
	LogicTypeDATE     LogicType = 2
	LogicTypeTIME     LogicType = 3
)

type RLEStringValues

type RLEStringValues struct {
	// contains filtered or unexported fields
}

func GetRootAsRLEStringValues

func GetRootAsRLEStringValues(buf []byte, offset flatbuffers.UOffsetT) *RLEStringValues

func (*RLEStringValues) Array

func (rcv *RLEStringValues) Array(j int) []byte

func (*RLEStringValues) ArrayLength

func (rcv *RLEStringValues) ArrayLength() int

func (*RLEStringValues) IndexMapping

func (rcv *RLEStringValues) IndexMapping(j int) int32

func (*RLEStringValues) IndexMappingLength

func (rcv *RLEStringValues) IndexMappingLength() int

func (*RLEStringValues) Init

func (rcv *RLEStringValues) Init(buf []byte, i flatbuffers.UOffsetT)

func (*RLEStringValues) MutateIndexMapping

func (rcv *RLEStringValues) MutateIndexMapping(j int, n int32) bool

func (*RLEStringValues) Table

func (rcv *RLEStringValues) Table() flatbuffers.Table

type SQLResponseColumn

type SQLResponseColumn struct {
	// contains filtered or unexported fields
}

func GetRootAsSQLResponseColumn

func GetRootAsSQLResponseColumn(buf []byte, offset flatbuffers.UOffsetT) *SQLResponseColumn

func (*SQLResponseColumn) ColumnComplexTypeInfo added in v1.7.8

func (rcv *SQLResponseColumn) ColumnComplexTypeInfo(obj *ComplexColumnTypeInfo) *ComplexColumnTypeInfo

func (*SQLResponseColumn) ColumnName

func (rcv *SQLResponseColumn) ColumnName() []byte

func (*SQLResponseColumn) ColumnType

func (rcv *SQLResponseColumn) ColumnType() DataType

func (*SQLResponseColumn) ColumnValue

func (rcv *SQLResponseColumn) ColumnValue(obj *ColumnValues) *ColumnValues

func (*SQLResponseColumn) Init

func (rcv *SQLResponseColumn) Init(buf []byte, i flatbuffers.UOffsetT)

func (*SQLResponseColumn) MutateColumnType

func (rcv *SQLResponseColumn) MutateColumnType(n DataType) bool

func (*SQLResponseColumn) Table

func (rcv *SQLResponseColumn) Table() flatbuffers.Table

type SQLResponseColumns

type SQLResponseColumns struct {
	// contains filtered or unexported fields
}

func GetRootAsSQLResponseColumns

func GetRootAsSQLResponseColumns(buf []byte, offset flatbuffers.UOffsetT) *SQLResponseColumns

func (*SQLResponseColumns) Columns

func (rcv *SQLResponseColumns) Columns(obj *SQLResponseColumn, j int) bool

func (*SQLResponseColumns) ColumnsLength

func (rcv *SQLResponseColumns) ColumnsLength() int

func (*SQLResponseColumns) Init

func (rcv *SQLResponseColumns) Init(buf []byte, i flatbuffers.UOffsetT)

func (*SQLResponseColumns) MutateRowCount

func (rcv *SQLResponseColumns) MutateRowCount(n int64) bool

func (*SQLResponseColumns) RowCount

func (rcv *SQLResponseColumns) RowCount() int64

func (*SQLResponseColumns) Table

func (rcv *SQLResponseColumns) Table() flatbuffers.Table

type StringValues

type StringValues struct {
	// contains filtered or unexported fields
}

func GetRootAsStringValues

func GetRootAsStringValues(buf []byte, offset flatbuffers.UOffsetT) *StringValues

func (*StringValues) Array

func (rcv *StringValues) Array(j int) []byte

func (*StringValues) ArrayLength

func (rcv *StringValues) ArrayLength() int

func (*StringValues) IndexMapping

func (rcv *StringValues) IndexMapping(j int) int32

func (*StringValues) IndexMappingLength

func (rcv *StringValues) IndexMappingLength() int

func (*StringValues) Init

func (rcv *StringValues) Init(buf []byte, i flatbuffers.UOffsetT)

func (*StringValues) MutateIndexMapping

func (rcv *StringValues) MutateIndexMapping(j int, n int32) bool

func (*StringValues) Table

func (rcv *StringValues) Table() flatbuffers.Table

Jump to

Keyboard shortcuts

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