Documentation
¶
Index ¶
- func Base64ToNumeric(based64buf string, scale int) (string, error)
- func BitParametersExtractor(colSchema *abstract.ColSchema, _, _ bool, _ map[string]string) (string, string, map[string]interface{})
- func BufToChangeItemsBits(in []byte) string
- func ChangeItemsBitsToDebeziumHonest(bits string) string
- func DateToInt32(v time.Time) int32
- func DatetimeToMicrosecs(vv time.Time) int64
- func DatetimeToSecs(vv time.Time) int64
- func DecimalGetPrecisionAndScale(dataTypeVerbose string) (bool, int, int, error)
- func DecimalToDebezium(decimal, decimalWithoutProvider string, connectorParameters map[string]string) (interface{}, error)
- func DecimalToDebeziumHandlingModePrecise(decimal, decimalWithoutProvider string) (interface{}, error)
- func DecimalToDebeziumPrimitives(decimal string, connectorParameters map[string]string) (interface{}, error)
- func DecimalToDebeziumPrimitivesImpl(decimal string) (string, int, error)
- func EmitPostgresInterval(val int64) string
- func ExponentialFloatFormToNumeric(in string) (string, error)
- func ExtractParameter(originalType string) (int, error)
- func ExtractPostgresIntervalArray(interval string) ([]string, error)
- func FieldDescrDecimal(precision, scale int) (string, string, map[string]interface{})
- func FormatTime(inputTime time.Time, precision int) string
- func GetBitLength(pgType string) (string, error)
- func GetTimeDivider(originalTypeWithoutProvider string) (int, error)
- func GetTimePrecision(colTypeStr string) int
- func IsPgNumeric(originalType string) bool
- func LSNToFileAndPos(lsn uint64) (string, uint64)
- func MakeFractionSecondSuffix(fraction int64, precision int) string
- func MysqlDecimalFieldDescr(colSchema *abstract.ColSchema, _, _ bool, ...) (string, string, map[string]interface{})
- func MysqlDecimalFloatToValue(val float64, colType string) (string, error)
- func MysqlFitBinaryLength(colType string, colVal interface{}) (interface{}, error)
- func NumRangeFromDebezium(in string) (string, error)
- func NumRangeToDebezium(in string) (string, error)
- func NumericToExponentialFloatForm(in string) (string, error)
- func OriginalTypeWithoutProvider(originalType string) string
- func ParseBytea(colVal interface{}, binaryHandlingMode string) (interface{}, error)
- func ParseMysqlBit(colVal interface{}, _ string) (interface{}, error)
- func ParsePgDateTimeWithTimezone(in string) (time.Time, error)
- func ParsePgDateTimeWithTimezone2(l, r string) (time.Time, time.Time, error)
- func ParsePostgresInterval(interval, intervalHandlingMode string) (interface{}, error)
- func ParseTimeWithoutTZ(timeStr string) (time.Time, error)
- func ParseTimestamp(timeStr string) (time.Time, error)
- func PgTimeWithoutTimeZonePrecision(originalType string) int
- func PointToDebezium(in string) (map[string]interface{}, error)
- func ReverseBytesArr(buf []byte) []byte
- func ShrinkMysqlBit(colVal interface{}, colType string) ([]uint8, error)
- func SprintfDebeziumTime(in time.Time) string
- func TSRangeUnquote(colStr string) (string, error)
- func TimeFromDate(in int64) time.Time
- func TimeFromDatetime(in int64) time.Time
- func TimeFromTimestamp(in int64) time.Time
- func TimePgWithoutTZParamsToKafkaType(colSchema *abstract.ColSchema, intoArr, _ bool, _ map[string]string) (string, string, map[string]interface{})
- func TimestampMysqlParamsTypeToKafkaType(colSchema *abstract.ColSchema, intoArr, _ bool, _ map[string]string) (string, string, map[string]interface{})
- func TimestampPgParamsTypeToKafkaType(colSchema *abstract.ColSchema, intoArr, _ bool, _ map[string]string) (string, string, map[string]interface{})
- func TstZRangeQuote(colStr string) (string, error)
- func TstZRangeUnquote(colStr string) (string, error)
- func UnescapeUnicode(in string) string
- func UnknownTypeToString(in interface{}) (string, error)
- func UnquoteIfQuoted(in string) string
- func UnwrapMysqlEnumsAndSets(in string) (string, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func BitParametersExtractor ¶
func BufToChangeItemsBits ¶
func DateToInt32 ¶
func DatetimeToMicrosecs ¶
func DatetimeToSecs ¶
func DecimalToDebezium ¶
func EmitPostgresInterval ¶
func ExtractParameter ¶
func FieldDescrDecimal ¶
func GetBitLength ¶
func GetTimeDivider ¶
func GetTimePrecision ¶
func IsPgNumeric ¶
func LSNToFileAndPos ¶
func MysqlDecimalFieldDescr ¶
func MysqlFitBinaryLength ¶
MysqlFitBinaryLength - used for types: "mysql:binary", "mysql:varbinary", "mysql:longblob", "mysql:mediumblob", "mysql:blob", "mysql:tinyblob"
func NumRangeFromDebezium ¶
func NumRangeToDebezium ¶
func ParseBytea ¶
func ParseMysqlBit ¶
func ParsePostgresInterval ¶
func PointToDebezium ¶
func ReverseBytesArr ¶
func ShrinkMysqlBit ¶
func SprintfDebeziumTime ¶
func TSRangeUnquote ¶
func TimeFromDate ¶
func TimeFromDatetime ¶
func TimeFromTimestamp ¶
func TstZRangeQuote ¶
func TstZRangeUnquote ¶
func UnescapeUnicode ¶
func UnknownTypeToString ¶
func UnquoteIfQuoted ¶
func UnwrapMysqlEnumsAndSets ¶
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.