schema

Aug 26, 2023

Changes in this version

type Builder

+ func Geography() Builder

+ func Geometry() Builder

Aug 14, 2023

Changes in this version

type Builder

+ func HStore() Builder

+ func Map() Builder

Jul 30, 2023

Changes in this version

+ type Builder interface

+ Build func() Struct

+ Clone func() Builder

+ DefaultValue func(defaultValue *string) Builder

+ Documentation func(documentation *string) Builder

+ Field func(name FieldName, index int, schemaBuilder Builder) Builder

+ FieldName func(fieldName string) Builder

+ Fields func() map[string]Field

+ GetDefaultValue func() *string

+ GetDocumentation func() *string

+ GetFieldName func() string

+ GetIndex func() int

+ GetKeySchema func() Builder

+ GetSchemaName func() string

+ GetValueSchema func() Builder

+ GetVersion func() int

+ Index func(index int) Builder

+ IsOptional func() bool

+ KeySchema func(builder Builder) Builder

+ Optional func() Builder

+ Parameter func(key string, value any) Builder

+ Parameters func() map[string]any

+ Required func() Builder

+ SchemaName func(schemaName string) Builder

+ SchemaType func() Type

+ SetOptional func(optional bool) Builder

+ ValueSchema func(builder Builder) Builder

+ Version func(version int) Builder

type ColumnAlike

+ DataType func() uint32

type Identifiable

+ CanonicalName func() string

type NameGenerator

+ func NewNameGenerator(topicPrefix string, namingStrategy namingstrategy.NamingStrategy) NameGenerator

+ func NewNameGeneratorFromConfig(c *config.Config, namingStrategy namingstrategy.NamingStrategy) NameGenerator

type TableAlike

+ KeyIndexColumns func() []ColumnAlike

Jul 22, 2023

Changes in this version

+ const BitsSchemaName

+ const EnumSchemaName

+ const GeographySchemaName

+ const GeometrySchemaName

+ const JsonSchemaName

+ const LtreeSchemaName

+ const PointSchemaName

+ const UuidSchemaName

+ const XmlSchemaName

+ type Buildable interface

+ SchemaBuilder func() SchemaBuilder

+ type ColumnAlike interface

+ IsPrimaryKey func() bool

+ Name func() string

+ SchemaType func() Type

+ type Field interface

+ Index func() int

+ SchemaBuilder func() SchemaBuilder

+ SchemaStruct func() Struct

+ type FieldName = string

+ const FieldNameAfter

+ const FieldNameAllowed

+ const FieldNameBefore

+ const FieldNameConnector

+ const FieldNameContent

+ const FieldNameDatabase

+ const FieldNameDefault

+ const FieldNameField

+ const FieldNameFields

+ const FieldNameIndex

+ const FieldNameKeySchema

+ const FieldNameLSN

+ const FieldNameLength

+ const FieldNameMessage

+ const FieldNameName

+ const FieldNameOperation

+ const FieldNameOptional

+ const FieldNamePayload

+ const FieldNamePrefix

+ const FieldNameSchema

+ const FieldNameSequence

+ const FieldNameSnapshot

+ const FieldNameSource

+ const FieldNameTable

+ const FieldNameTimescaleOp

+ const FieldNameTimestamp

+ const FieldNameTransaction

+ const FieldNameTxId

+ const FieldNameType

+ const FieldNameValueSchema

+ const FieldNameVersion

+ const FieldNameXmin

+ type Identifiable interface

+ SchemaName func() string

+ TableName func() string

+ type NameGenerator interface

+ EventTopicName func(hypertable TableAlike) string

+ MessageTopicName func() string

+ SchemaTopicName func(hypertable TableAlike) string

type Registry

+ func NewRegistry(topicNameGenerator NameGenerator) Registry

+ type SchemaBuilder interface

+ Build func() Struct

+ Clone func() SchemaBuilder

+ DefaultValue func(defaultValue *string) SchemaBuilder

+ Documentation func(documentation *string) SchemaBuilder

+ Field func(name FieldName, index int, schemaBuilder SchemaBuilder) SchemaBuilder

+ FieldName func(fieldName string) SchemaBuilder

+ Fields func() map[string]Field

+ GetDefaultValue func() *string

+ GetDocumentation func() *string

+ GetFieldName func() string

+ GetIndex func() int

+ GetKeySchema func() SchemaBuilder

+ GetSchemaName func() string

+ GetValueSchema func() SchemaBuilder

+ GetVersion func() int

+ Index func(index int) SchemaBuilder

+ IsOptional func() bool

+ KeySchema func(builder SchemaBuilder) SchemaBuilder

+ Optional func() SchemaBuilder

+ Parameter func(key string, value any) SchemaBuilder

+ Parameters func() map[string]any

+ Required func() SchemaBuilder

+ SchemaName func(schemaName string) SchemaBuilder

+ SchemaType func() Type

+ SetOptional func(optional bool) SchemaBuilder

+ ValueSchema func(builder SchemaBuilder) SchemaBuilder

+ Version func(version int) SchemaBuilder

+ func Bits(length int) SchemaBuilder

+ func Boolean() SchemaBuilder

+ func Bytes() SchemaBuilder

+ func Enum(enumValues []string) SchemaBuilder

+ func Float32() SchemaBuilder

+ func Float64() SchemaBuilder

+ func Int16() SchemaBuilder

+ func Int32() SchemaBuilder

+ func Int64() SchemaBuilder

+ func Int8() SchemaBuilder

+ func Json() SchemaBuilder

+ func Ltree() SchemaBuilder

+ func NewSchemaBuilder(schemaType Type) SchemaBuilder

+ func String() SchemaBuilder

+ func Uuid() SchemaBuilder

+ func Xml() SchemaBuilder

+ type TableAlike interface

+ TableColumns func() []ColumnAlike

+ type Type string

+ const ARRAY

+ const BOOLEAN

+ const BYTES

+ const FLOAT32

+ const FLOAT64

+ const INT16

+ const INT32

+ const INT64

+ const INT8

+ const MAP

+ const STRING

+ const STRUCT

+ func (st Type) IsPrimitive() bool

Jun 30, 2023

Changes in this version

+ const MessageBlockSchemaName

+ const MessageKeySchemaName

+ const MessageValueSchemaName

+ const SourceSchemaName

+ const TimescaleEventSchemaName

+ type Operation string

+ const OP_CREATE

+ const OP_DELETE

+ const OP_MESSAGE

+ const OP_READ

+ const OP_TIMESCALE

+ const OP_TRUNCATE

+ const OP_UPDATE

+ type Registry interface

+ GetSchema func(schemaName string) Struct

+ GetSchemaOrCreate func(schemaName string, creator func() Struct) Struct

+ HypertableEnvelopeSchemaName func(hypertable *systemcatalog.Hypertable) string

+ HypertableKeySchemaName func(hypertable *systemcatalog.Hypertable) string

+ MessageEnvelopeSchemaName func() string

+ RegisterSchema func(schemaName string, schema Struct)

+ type Struct = map[schemaField]any

+ 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 string

+ const OP_COMPRESSION

+ const OP_DECOMPRESSION