pg

package
v0.0.0-rc9 Latest Latest
Warning

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

 Go to latest Published: Nov 12, 2024 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var KafkaTypeToOriginalTypeToFieldReceiverFunc = map[debeziumcommon.KafkaType]map[string]debeziumcommon.FieldReceiver{
	debeziumcommon.KafkaTypeInt32: {
		"pg:date": new(Date),
		debeziumcommon.DTMatchByFunc: &debeziumcommon.FieldReceiverMatchers{
			Matchers: []debeziumcommon.FieldReceiverMatcher{new(TimeWithoutTimeZone)},
		},
	},
	debeziumcommon.KafkaTypeInt64: {
		"pg:interval": new(Interval),
		"pg:oid":      new(Oid),
		debeziumcommon.DTMatchByFunc: &debeziumcommon.FieldReceiverMatchers{
			Matchers: []debeziumcommon.FieldReceiverMatcher{new(TimestampWithoutTimeZone), new(TimeWithoutTimeZone2)},
		},
	},
	debeziumcommon.KafkaTypeBoolean: {
		"pg:bit(1)": new(Bit1),
	},
	debeziumcommon.KafkaTypeBytes: {
		"pg:bit":         new(BitN),
		"pg:bit varying": new(BitVarying),
		"pg:money":       new(debeziumcommon.Decimal),
		debeziumcommon.DTMatchByFunc: &debeziumcommon.FieldReceiverMatchers{
			Matchers: []debeziumcommon.FieldReceiverMatcher{new(Decimal), new(DebeziumBuf)},
		},
	},
	debeziumcommon.KafkaTypeFloat64: {
		"pg:double precision": new(DoublePrecision),
	},
	debeziumcommon.KafkaTypeString: {
		"pg:inet":      new(Inet),
		"pg:int4range": new(debeziumcommon.StringToAnyDefault),
		"pg:int8range": new(debeziumcommon.StringToAnyDefault),
		"pg:json":      new(JSON),
		"pg:jsonb":     new(JSON),
		"pg:numrange":  new(NumRange),
		"pg:tsrange":   new(TSRange),
		"pg:tstzrange": new(TSTZRange),
		"pg:xml":       new(debeziumcommon.StringToAnyDefault),
		"pg:citext":    new(CIText),
		"pg:hstore":    new(HStore),
		"pg:macaddr":   new(StringButYTAny),
		"pg:cidr":      new(StringButYTAny),
		"pg:character": new(StringButYTAny),
		"pg:daterange": new(StringButYTAny),
		debeziumcommon.DTMatchByFunc: &debeziumcommon.FieldReceiverMatchers{
			Matchers: []debeziumcommon.FieldReceiverMatcher{new(TimestampWithTimeZone), new(Enum)},
		},
	},
	debeziumcommon.KafkaTypeStruct: {
		"pg:point": new(Point),
	},
}
View Source 
var OriginalTypePropertyTimeZone = "timezone"

Functions

func AddPg 

func AddPg(v *debeziumcommon.Values, colSchema *abstract.ColSchema, colName string, colVal interface{}, originalType string, intoArr bool, connectorParameters map[string]string) error

func GetKafkaTypeDescrByPgType 

func GetKafkaTypeDescrByPgType(colSchema *abstract.ColSchema) (*debeziumcommon.KafkaTypeDescr, error)

func GetOriginalTypeProperties 

func GetOriginalTypeProperties(in *abstract.ColSchema) map[string]string

Types

type Bit1 

type Bit1 struct {
	debeziumcommon.IntToString
	debeziumcommon.YTTypeAny
	debeziumcommon.FieldReceiverMarker
}

func (*Bit1) Do 

func (b *Bit1) Do(in bool, _ *debeziumcommon.OriginalTypeInfo, _ *debeziumcommon.Schema, _ bool) (string, error)

type BitN 

type BitN struct {
	debeziumcommon.StringToString
	debeziumcommon.YTTypeAny
	debeziumcommon.FieldReceiverMarker
}

func (*BitN) Do 

func (d *BitN) Do(in string, _ *debeziumcommon.OriginalTypeInfo, _ *debeziumcommon.Schema, _ bool) (string, error)

type BitVarying 

type BitVarying struct {
	debeziumcommon.StringToString
	debeziumcommon.YTTypeAny
	debeziumcommon.FieldReceiverMarker
}

func (*BitVarying) Do 

func (d *BitVarying) Do(in string, _ *debeziumcommon.OriginalTypeInfo, _ *debeziumcommon.Schema, _ bool) (string, error)

type CIText 

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

func (*CIText) Do 

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

type Date 

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

func (*Date) Do 

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

type DebeziumBuf 

type DebeziumBuf struct {
	debeziumcommon.StringToString
	debeziumcommon.YTTypeBytes
	debeziumcommon.FieldReceiverMarker
}

func (*DebeziumBuf) Do 

func (b *DebeziumBuf) Do(in string, _ *debeziumcommon.OriginalTypeInfo, schema *debeziumcommon.Schema, _ bool) (string, error)

func (*DebeziumBuf) IsMatched 

func (b *DebeziumBuf) IsMatched(_ *debeziumcommon.OriginalTypeInfo, schema *debeziumcommon.Schema) bool

type Decimal 

type Decimal struct {
	debeziumcommon.StringToAny
	debeziumcommon.YTTypeFloat64
	debeziumcommon.FieldReceiverMarker
	// contains filtered or unexported fields
}

func (*Decimal) Do 

func (d *Decimal) Do(in string, originalType *debeziumcommon.OriginalTypeInfo, schema *debeziumcommon.Schema, intoArr bool) (interface{}, error)

func (*Decimal) IsMatched 

func (d *Decimal) IsMatched(_ *debeziumcommon.OriginalTypeInfo, schema *debeziumcommon.Schema) bool

type DoublePrecision 

type DoublePrecision struct {
	debeziumcommon.AnyToDouble
	debeziumcommon.YTTypeFloat64
	debeziumcommon.FieldReceiverMarker
}

func (*DoublePrecision) Do 

func (p *DoublePrecision) Do(in interface{}, _ *debeziumcommon.OriginalTypeInfo, _ *debeziumcommon.Schema, _ bool) (float64, error)

type Enum 

type Enum struct {
	debeziumcommon.StringToString
	debeziumcommon.YTTypeString
	debeziumcommon.FieldReceiverMarker
}

func (*Enum) AddInfo 

func (t *Enum) AddInfo(schema *debeziumcommon.Schema, outColSchema *abstract.ColSchema)

func (*Enum) Do 

func (t *Enum) Do(in string, _ *debeziumcommon.OriginalTypeInfo, _ *debeziumcommon.Schema, _ bool) (string, error)

func (*Enum) IsMatched 

func (t *Enum) IsMatched(_ *debeziumcommon.OriginalTypeInfo, debeziumSchema *debeziumcommon.Schema) bool

type HStore 

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

func (*HStore) Do 

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

type Inet 

type Inet struct {
	debeziumcommon.StringToString
	debeziumcommon.YTTypeAny
	debeziumcommon.FieldReceiverMarker
}

func (*Inet) Do 

func (i *Inet) Do(in string, _ *debeziumcommon.OriginalTypeInfo, _ *debeziumcommon.Schema, _ bool) (string, error)

type Interval 

type Interval struct {
	debeziumcommon.IntToString
	debeziumcommon.YTTypeString
	debeziumcommon.FieldReceiverMarker
}

func (*Interval) Do 

func (i *Interval) Do(in int64, _ *debeziumcommon.OriginalTypeInfo, _ *debeziumcommon.Schema, _ bool) (string, 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 NumRange 

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

func (*NumRange) Do 

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

type Oid 

type Oid struct {
	debeziumcommon.Int64ToInt64
	debeziumcommon.YTTypeAny
	debeziumcommon.FieldReceiverMarker
}

func (*Oid) Do 

func (d *Oid) Do(in int64, _ *debeziumcommon.OriginalTypeInfo, _ *debeziumcommon.Schema, _ bool) (int64, error)

type Point 

type Point struct {
	debeziumcommon.AnyToAny
	debeziumcommon.YTTypeAny
	debeziumcommon.FieldReceiverMarker
	// contains filtered or unexported fields
}

func (*Point) AddInfo 

func (d *Point) AddInfo(_ *debeziumcommon.Schema, colSchema *abstract.ColSchema)

func (*Point) Do 

func (d *Point) Do(in interface{}, originalTypeInfo *debeziumcommon.OriginalTypeInfo, schema *debeziumcommon.Schema, intoArr bool) (interface{}, error)

type StringButYTAny 

type StringButYTAny struct {
	debeziumcommon.StringToStringDefault
	debeziumcommon.YTTypeAny
	debeziumcommon.FieldReceiverMarker
}

type TSRange 

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

func (*TSRange) Do 

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

type TSTZRange 

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

func (*TSTZRange) Do 

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

type TimeWithoutTimeZone 

type TimeWithoutTimeZone struct {
	debeziumcommon.IntToString
	debeziumcommon.YTTypeString
	debeziumcommon.FieldReceiverMarker
}

func (*TimeWithoutTimeZone) Do 

func (t *TimeWithoutTimeZone) Do(in int64, originalType *debeziumcommon.OriginalTypeInfo, _ *debeziumcommon.Schema, _ bool) (string, error)

func (*TimeWithoutTimeZone) IsMatched 

func (t *TimeWithoutTimeZone) IsMatched(originalType *debeziumcommon.OriginalTypeInfo, _ *debeziumcommon.Schema) bool

type TimeWithoutTimeZone2 

type TimeWithoutTimeZone2 struct {
	debeziumcommon.IntToString
	debeziumcommon.YTTypeString
	debeziumcommon.FieldReceiverMarker
}

func (*TimeWithoutTimeZone2) Do 

func (t *TimeWithoutTimeZone2) Do(in int64, originalType *debeziumcommon.OriginalTypeInfo, _ *debeziumcommon.Schema, intoArr bool) (string, error)

func (*TimeWithoutTimeZone2) IsMatched 

func (t *TimeWithoutTimeZone2) IsMatched(originalType *debeziumcommon.OriginalTypeInfo, _ *debeziumcommon.Schema) bool

type TimestampWithTimeZone 

type TimestampWithTimeZone struct {
	debeziumcommon.StringToString
	debeziumcommon.YTTypeTimestamp
	debeziumcommon.FieldReceiverMarker
}

func (*TimestampWithTimeZone) Do 

func (t *TimestampWithTimeZone) Do(in string, _ *debeziumcommon.OriginalTypeInfo, _ *debeziumcommon.Schema, _ bool) (time.Time, error)

func (*TimestampWithTimeZone) IsMatched 

func (t *TimestampWithTimeZone) IsMatched(originalType *debeziumcommon.OriginalTypeInfo, _ *debeziumcommon.Schema) bool

type TimestampWithoutTimeZone 

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

func (*TimestampWithoutTimeZone) Do 

func (t *TimestampWithoutTimeZone) Do(in int64, originalType *debeziumcommon.OriginalTypeInfo, _ *debeziumcommon.Schema, intoArr bool) (time.Time, error)

func (*TimestampWithoutTimeZone) IsMatched 

func (t *TimestampWithoutTimeZone) IsMatched(originalType *debeziumcommon.OriginalTypeInfo, _ *debeziumcommon.Schema) bool

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.