systemcatalog

Dec 8, 2023

Changes in this version

type SystemCatalog

+ GetAllHypertables func() []SystemEntity

Oct 1, 2023

Changes in this version

type BaseTable

+ KeyIndexColumns func() []schema.ColumnAlike

type PgTable

+ func (bt PgTable) ApplyTableSchema(newColumns []Column) (changes map[string]string)

+ func (bt PgTable) Columns() Columns

+ func (bt PgTable) ReplicaIdentity() pgtypes.ReplicaIdentity

+ func (bt PgTable) SchemaBuilder() schema.Builder

+ func (bt PgTable) TableColumns() []schema.ColumnAlike

Sep 18, 2023

Changes in this version

+ func IsVanillaTable(relation *pgtypes.RelationMessage) bool

+ type BaseTable struct

+ func (bse BaseTable) CanonicalName() string

+ func (bse BaseTable) SchemaName() string

+ func (bse BaseTable) TableName() string

+ func (bt *BaseTable) ApplyChanges(schemaName, tableName string, replicaIdentity pgtypes.ReplicaIdentity) *BaseTable

+ func (bt *BaseTable) ApplyTableSchema(newColumns []Column) (changes map[string]string)

+ func (bt *BaseTable) Columns() Columns

+ func (bt *BaseTable) ReplicaIdentity() pgtypes.ReplicaIdentity

+ func (bt *BaseTable) SchemaBuilder() schema.Builder

+ func (bt *BaseTable) TableColumns() []schema.ColumnAlike

+ type PgTable struct

+ func NewPgTable(relId uint32, schemaName, tableName string, ...) *PgTable

+ func (bse PgTable) CanonicalName() string

+ func (bse PgTable) SchemaName() string

+ func (bse PgTable) TableName() string

+ func (t *PgTable) ApplyChanges(schemaName, tableName string, replicaIdentity pgtypes.ReplicaIdentity) (applied *PgTable, changes map[string]string)

+ func (t *PgTable) KeyIndexColumns() []schema.ColumnAlike

+ func (t *PgTable) RelId() uint32

+ func (t *PgTable) String() string

type SystemCatalog

+ FindVanillaTableById func(relId uint32) (table *PgTable, present bool)

+ FindVanillaTableByName func(schemaName, tableName string) (table *PgTable, present bool)

+ GetAllVanillaTables func() []SystemEntity

Jul 30, 2023

Changes in this version

type Hypertable

+ func (h *Hypertable) KeyIndexColumns() []schema.ColumnAlike

+ type SystemCatalog interface

+ ApplySchemaUpdate func(hypertable *Hypertable, columns []Column) bool

+ FindChunkById func(id int32) (chunk *Chunk, present bool)

+ FindChunkByName func(schemaName, tableName string) (chunk *Chunk, present bool)

+ FindCompressedHypertableByHypertableId func(hypertableId int32) (hypertable *Hypertable, present bool)

+ FindHypertableByChunkId func(chunkId int32) (hypertable *Hypertable, present bool)

+ FindHypertableByCompressedHypertableId func(compressedHypertableId int32) (hypertable *Hypertable, present bool)

+ FindHypertableById func(hypertableId int32) (hypertable *Hypertable, present bool)

+ FindHypertableByName func(schema, name string) (hypertable *Hypertable, present bool)

+ GetAllChunks func() []SystemEntity

+ IsHypertableSelectedForReplication func(hypertableId int32) bool

+ RegisterChunk func(chunk *Chunk) error

+ RegisterHypertable func(hypertable *Hypertable) error

+ ResolveOriginHypertable func(chunk *Chunk) (hypertable *Hypertable, present bool)

+ ResolveUncompressedHypertable func(hypertableId int32) (uncompressedHypertable, compressedHypertable *Hypertable, present bool)

+ UnregisterChunk func(chunk *Chunk) error

+ UnregisterHypertable func(hypertable *Hypertable) error

Jul 22, 2023

Changes in this version

type Column

+ func (c Column) Format() string

+ func (c Column) MaxCharLength() *int

+ func (c Column) Modifiers() int

+ func (c Column) SchemaType() schema.Type

type Hypertable

+ func (h *Hypertable) TableColumns() []schema.ColumnAlike

Jul 20, 2023

Changes in this version

type Column

+ func (c Column) SchemaBuilder() schemamodel.SchemaBuilder

type Hypertable

+ func (h *Hypertable) SchemaBuilder() schemamodel.SchemaBuilder

type PgType

+ Namespace func() string

Jul 12, 2023

Changes in this version

type Column

+ func (c Column) PgType() PgType

+ type PgCategory string

+ const Array

+ const BitString

+ const Boolean

+ const Composite

+ const DateTime

+ const Enum

+ const Geometric

+ const InternalUse

+ const Network

+ const Numeric

+ const Pseudo

+ const Range

+ const String

+ const Timespan

+ const Unknown

+ const UserDefined

+ type PgKind string

+ const BaseKind

+ const CompositeKind

+ const DomainKind

+ const EnumKind

+ const MultiRangeKind

+ const PseudoKind

+ const RangeKind

+ type PgType interface

+ ArrayType func() PgType

+ Category func() PgCategory

+ Delimiter func() string

+ ElementType func() PgType

+ EnumValues func() []string

+ Equal func(other PgType) bool

+ IsArray func() bool

+ IsRecord func() bool

+ Kind func() PgKind

+ Modifiers func() int

+ Name func() string

+ Oid func() uint32

+ OidArray func() uint32

+ OidElement func() uint32

+ OidParent func() uint32

+ ParentType func() PgType

+ SchemaBuilder func() schemamodel.SchemaBuilder

+ SchemaType func() schemamodel.SchemaType

Jul 5, 2023

Changes in this version

type Chunk

+ func (c *Chunk) String() string

type Column

+ func (c Column) String() string

type Hypertable

+ func (h *Hypertable) String() string

type Index

+ func (i *Index) String() string

Jun 30, 2023

Changes in this version

+ var ErrIllegalValue = fmt.Errorf("illegal value for data type conversion")

+ func BinaryMarshall(buffer encoding.WriteBuffer, oid uint32, value any) error

+ func BinaryUnmarshall(buffer encoding.ReadBuffer, oid uint32) (value any, err error)

+ func IsChunkEvent(relation *pgtypes.RelationMessage) bool

+ func IsContinuousAggregateHypertable(hypertableName string) bool

+ func IsHypertableEvent(relation *pgtypes.RelationMessage) bool

+ func MakeRelationKey(schemaName, tableName string) string

+ type BinaryMarshaller func(buffer encoding.WriteBuffer, oid uint32, value any) error

+ type BinaryUnmarshaller func(buffer encoding.ReadBuffer, oid uint32) (value any, err error)

+ type Chunk struct

+ func NewChunk(id, hypertableId int32, schemaName, tableName string, dropped bool, ...) *Chunk

+ func (bse Chunk) CanonicalName() string

+ func (bse Chunk) SchemaName() string

+ func (bse Chunk) TableName() string

+ func (c *Chunk) ApplyChanges(schemaName, tableName string, dropped bool, status int32, ...) (*Chunk, map[string]string)

+ func (c *Chunk) CompressedChunkId() *int32

+ func (c *Chunk) Dropped() bool

+ func (c *Chunk) HypertableId() int32

+ func (c *Chunk) Id() int32

+ func (c *Chunk) IsCompressed() bool

+ func (c *Chunk) IsPartiallyCompressed() bool

+ func (c *Chunk) Status() int32

+ type Column struct

+ func NewColumn(name string, dataType uint32, typeName string, nullable bool, ...) Column

+ func NewIndexColumn(name string, dataType uint32, typeName string, nullable, primaryKey bool, ...) Column

+ func (c Column) DataType() uint32

+ func (c Column) DefaultValue() *string

+ func (c Column) DimensionType() *string

+ func (c Column) IsDimension() bool

+ func (c Column) IsDimensionAligned() bool

+ func (c Column) IsNullable() bool

+ func (c Column) IsPrimaryKey() bool

+ func (c Column) IsReplicaIdent() bool

+ func (c Column) Name() string

+ func (c Column) TypeName() string

+ type Columns []Column

+ func (c Columns) HasPrimaryKey() bool

+ func (c Columns) HasReplicaIdentity() bool

+ func (c Columns) PrimaryKeyIndex() (index *Index, present bool)

+ func (c Columns) ReplicaIdentityIndex() (index *Index, present bool)

+ func (c Columns) SnapshotIndex() (index *Index, present bool)

+ type Converter func(oid uint32, value any) (any, error)

+ func ConverterByOID(oid uint32) (Converter, error)

+ type DataType 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 DataTypeByOID(oid uint32) (DataType, error)

+ type Hypertable struct

+ func NewHypertable(id int32, ...) *Hypertable

+ func (bse Hypertable) CanonicalName() string

+ func (bse Hypertable) SchemaName() string

+ func (bse Hypertable) TableName() string

+ func (h *Hypertable) ApplyChanges(schemaName, tableName, associatedSchemaName, associatedTablePrefix string, ...) (applied *Hypertable, changes map[string]string)

+ func (h *Hypertable) ApplyTableSchema(newColumns []Column) (changes map[string]string)

+ func (h *Hypertable) CanonicalContinuousAggregateName() string

+ func (h *Hypertable) Columns() Columns

+ func (h *Hypertable) CompressedHypertableId() (compressedHypertableId int32, present bool)

+ func (h *Hypertable) DatabaseName() string

+ func (h *Hypertable) Id() int32

+ func (h *Hypertable) IsCompressedTable() bool

+ func (h *Hypertable) IsCompressionEnabled() bool

+ func (h *Hypertable) IsContinuousAggregate() bool

+ func (h *Hypertable) IsDistributed() bool

+ func (h *Hypertable) ReplicaIdentity() pgtypes.ReplicaIdentity

+ func (h *Hypertable) ViewName() (viewName string, present bool)

+ func (h *Hypertable) ViewSchema() (viewSchemaName string, present bool)

+ type Index struct

+ func (i *Index) AsSqlOrderBy(desc bool) string

+ func (i *Index) AsSqlTuple() string

+ func (i *Index) Columns() []Column

+ func (i *Index) Name() string

+ func (i *Index) PrimaryKey() bool

+ func (i *Index) ReplicaIdentity() bool

+ func (i *Index) WhereTupleEQ(params map[string]any) (string, bool)

+ func (i *Index) WhereTupleGE(params map[string]any) (string, bool)

+ func (i *Index) WhereTupleGT(params map[string]any) (string, bool)

+ func (i *Index) WhereTupleLE(params map[string]any) (string, bool)

+ func (i *Index) WhereTupleLT(params map[string]any) (string, bool)

+ type IndexNullsOrder string

+ const NULLS_FIRST

+ const NULLS_LAST

+ type IndexSortOrder string

+ const ASC

+ const DESC

+ type SystemEntity interface

+ CanonicalName func() string

+ SchemaName func() string

+ TableName func() string

+ func NewSystemEntity(schemaName, tableName string) SystemEntity