schema

Documentation

Index

• Constants
• type Operation
• type Registry
• type Struct
  • func CompressionEvent(source Struct) Struct
  • func CreateEvent(record Struct, source Struct) Struct
  • func DecompressionEvent(source Struct) Struct
  • func DeleteEvent(before, source Struct, tombstone bool) Struct
  • func Envelope(schema, payload Struct) Struct
  • func EnvelopeMessageSchema(schemaRegistry Registry, topicSchemaGenerator namegenerator.NameGenerator) Struct
  • func EnvelopeSchema(schemaRegistry Registry, hypertable *systemcatalog.Hypertable, ...) Struct
  • func HypertableSchema(hypertableSchemaName string, columns []systemcatalog.Column) Struct
  • func KeySchema(hypertable *systemcatalog.Hypertable, ...) Struct
  • func MessageEvent(prefix, content string, source Struct) Struct
  • func MessageKey(prefix string) Struct
  • func MessageKeySchema() Struct
  • func MessageValueSchema(schemaRegistry Registry) Struct
  • func ReadEvent(record Struct, source Struct) Struct
  • func Source(lsn pglogrepl.LSN, timestamp time.Time, snapshot bool, ...) Struct
  • func SourceSchema() Struct
  • func TimescaleEventKeySchema() Struct
  • func TimescaleKey(schemaName, tableName string) Struct
  • func TruncateEvent(source Struct) Struct
  • func UpdateEvent(before, after, source Struct) Struct
• type TimescaleOperation

Constants

const MessageBlockSchemaName = "io.debezium.connector.postgresql.Message"

const MessageKeySchemaName = "io.debezium.connector.postgresql.MessageKey"

const MessageValueSchemaName = "io.debezium.connector.postgresql.MessageValue"

const SourceSchemaName = "io.debezium.connector.postgresql.Source"

const TimescaleEventSchemaName = "com.timescale.Event"

Types

type Operation

type Operation string

const (
	OP_READ      Operation = "r"
	OP_CREATE    Operation = "c"
	OP_UPDATE    Operation = "u"
	OP_DELETE    Operation = "d"
	OP_TRUNCATE  Operation = "t"
	OP_MESSAGE   Operation = "m"
	OP_TIMESCALE Operation = "$"
)

type Registry

type Registry interface {
	RegisterSchema(schemaName string, schema Struct)
	GetSchema(schemaName string) Struct
	GetSchemaOrCreate(schemaName string, creator func() Struct) Struct
	HypertableEnvelopeSchemaName(hypertable *systemcatalog.Hypertable) string
	HypertableKeySchemaName(hypertable *systemcatalog.Hypertable) string
	MessageEnvelopeSchemaName() string
}

type Struct

type Struct = map[schemaField]any

func CompressionEvent

func CompressionEvent(source Struct) Struct

func CreateEvent

func CreateEvent(record Struct, source Struct) Struct

func DecompressionEvent

func DecompressionEvent(source Struct) Struct

func DeleteEvent

func DeleteEvent(before, source Struct, tombstone bool) Struct

func Envelope

func Envelope(schema, payload Struct) Struct

func EnvelopeMessageSchema

func EnvelopeMessageSchema(schemaRegistry Registry, topicSchemaGenerator namegenerator.NameGenerator) Struct

func EnvelopeSchema

func EnvelopeSchema(schemaRegistry Registry, hypertable *systemcatalog.Hypertable,
	topicSchemaGenerator namegenerator.NameGenerator) Struct

func HypertableSchema

func HypertableSchema(hypertableSchemaName string, columns []systemcatalog.Column) Struct

func KeySchema

func KeySchema(hypertable *systemcatalog.Hypertable, topicSchemaGenerator namegenerator.NameGenerator) Struct

func MessageEvent

func MessageEvent(prefix, content string, source Struct) Struct

func MessageKey

func MessageKey(prefix string) Struct

func MessageKeySchema

func MessageKeySchema() Struct

func MessageValueSchema

func MessageValueSchema(schemaRegistry Registry) Struct

func ReadEvent

func ReadEvent(record Struct, source Struct) Struct

func Source

func Source(lsn pglogrepl.LSN, timestamp time.Time, snapshot bool,
	databaseName, schemaName, hypertableName string, transactionId *uint32) Struct

func SourceSchema

func SourceSchema() Struct

func TimescaleEventKeySchema

func TimescaleEventKeySchema() Struct

func TimescaleKey

func TimescaleKey(schemaName, tableName string) Struct

func TruncateEvent

func TruncateEvent(source Struct) Struct

func UpdateEvent

func UpdateEvent(before, after, source Struct) Struct

type TimescaleOperation

type TimescaleOperation string

const (
	OP_COMPRESSION   TimescaleOperation = "c"
	OP_DECOMPRESSION TimescaleOperation = "d"
)