ydb

Documentation

Index

• Variables
• func AddYDB(v *debeziumcommon.Values, colName string, colVal interface{}, colType string, ...) error
• func GetKafkaTypeDescrByYDBType(typeName string) (*debeziumcommon.KafkaTypeDescr, error)
• type Date
  • func (i *Date) Do(in int64, _ *debeziumcommon.OriginalTypeInfo, _ *debeziumcommon.Schema, _ bool) (time.Time, error)
• type Datetime
  • func (i *Datetime) Do(in int64, _ *debeziumcommon.OriginalTypeInfo, _ *debeziumcommon.Schema, _ bool) (time.Time, error)
• type Interval
  • func (i *Interval) Do(in time.Duration, _ *debeziumcommon.OriginalTypeInfo, _ *debeziumcommon.Schema, ...) (int64, error)
• type JSON
  • func (i *JSON) Do(in string, _ *debeziumcommon.OriginalTypeInfo, _ *debeziumcommon.Schema, ...) (interface{}, error)
• type Timestamp
  • func (i *Timestamp) Do(in int64, _ *debeziumcommon.OriginalTypeInfo, _ *debeziumcommon.Schema, _ bool) (time.Time, error)

Variables

var KafkaTypeToOriginalTypeToFieldReceiverFunc = map[debeziumcommon.KafkaType]map[string]debeziumcommon.FieldReceiver{
	debeziumcommon.KafkaTypeInt8: {
		"ydb:Uint8": new(debeziumcommon.Int8ToUint8Default),
	},
	debeziumcommon.KafkaTypeInt16: {
		"ydb:Uint16": new(debeziumcommon.Int16ToUint16Default),
	},
	debeziumcommon.KafkaTypeInt32: {
		"ydb:Uint32": new(debeziumcommon.IntToUint32Default),
		"ydb:Date":   new(Date),
	},
	debeziumcommon.KafkaTypeInt64: {
		"ydb:Uint64":    new(debeziumcommon.Int64ToUint64Default),
		"ydb:Datetime":  new(Datetime),
		"ydb:Timestamp": new(Timestamp),
		"ydb:Interval":  new(Interval),
	},
	debeziumcommon.KafkaTypeFloat32: {
		"ydb:Float": new(debeziumcommon.Float64ToFloat32Default),
	},
	debeziumcommon.KafkaTypeString: {
		"ydb:Json":         new(JSON),
		"ydb:JsonDocument": new(JSON),
	},
}

Functions

func AddYDB

func AddYDB(v *debeziumcommon.Values, colName string, colVal interface{}, colType string, connectorParameters map[string]string) error

func GetKafkaTypeDescrByYDBType

func GetKafkaTypeDescrByYDBType(typeName string) (*debeziumcommon.KafkaTypeDescr, error)

Types

type Date

type Date struct {
	debeziumcommon.Int64ToTime
	debeziumcommon.YTTypeDate
	debeziumcommon.FieldReceiverMarker
}

func (*Date) Do

func (i *Date) Do(in int64, _ *debeziumcommon.OriginalTypeInfo, _ *debeziumcommon.Schema, _ bool) (time.Time, error)

type Datetime

type Datetime struct {
	debeziumcommon.Int64ToTime
	debeziumcommon.YTTypeDateTime
	debeziumcommon.FieldReceiverMarker
}

func (*Datetime) Do

func (i *Datetime) Do(in int64, _ *debeziumcommon.OriginalTypeInfo, _ *debeziumcommon.Schema, _ bool) (time.Time, error)

type Interval

type Interval struct {
	debeziumcommon.DurationToInt64
	debeziumcommon.YTTypeInterval
	debeziumcommon.FieldReceiverMarker
}

func (*Interval) Do

func (i *Interval) Do(in time.Duration, _ *debeziumcommon.OriginalTypeInfo, _ *debeziumcommon.Schema, _ bool) (int64, error)

type JSON

type JSON struct {
	debeziumcommon.StringToAny
	debeziumcommon.YTTypeAny
	debeziumcommon.FieldReceiverMarker
}

func (*JSON) Do

func (i *JSON) Do(in string, _ *debeziumcommon.OriginalTypeInfo, _ *debeziumcommon.Schema, _ bool) (interface{}, error)

type Timestamp

type Timestamp struct {
	debeziumcommon.Int64ToTime
	debeziumcommon.YTTypeTimestamp
	debeziumcommon.FieldReceiverMarker
}

func (*Timestamp) Do

func (i *Timestamp) Do(in int64, _ *debeziumcommon.OriginalTypeInfo, _ *debeziumcommon.Schema, _ bool) (time.Time, error)