schema

Jul 30, 2024

Changes in this version

+ const MetadataTablePermissionsNeeded

type Table

+ PermissionsNeeded []string

Jul 24, 2024

Changes in this version

+ const MetadataTypeSchema

type Column

+ TypeSchema string

Feb 27, 2024

Changes in this version

type GenTestDataOptions

+ UseHomogeneousType bool

Jan 31, 2024

Changes in this version

+ const MetadataPrimaryKeyComponent

type Column

+ PrimaryKeyComponent bool

type Table

+ func (t *Table) PrimaryKeyComponents() []string

Jan 29, 2024

Changes in this version

+ func CqIDAsPK(t *Table)

Jan 23, 2024

Changes in this version

type TableColumnChangeType

+ const TableColumnChangeTypeMoveToCQOnly

+ const TableColumnChangeTypeRemoveUniqueConstraint

Dec 7, 2023

Changes in this version

type Tables

+ func (tt Tables) GetPaidTables() Tables

+ func (tt Tables) HasPaidTables() bool

Oct 30, 2023

Changes in this version

+ const MetadataTableIsPaid

type Table

+ IsPaid bool

Aug 22, 2023

Changes in this version

type TestDataGenerator

+ func (tg *TestDataGenerator) Reset()

Aug 15, 2023

Changes in this version

type Column

+ func (c Column) MarshalJSON() ([]byte, error)

Aug 8, 2023

Changes in this version

type Tables

+ func (tt Tables) UnflattenTables() (Tables, error)

Aug 8, 2023

Changes in this version

+ const MetadataTableDependsOn

+ const MetadataTableTitle

Jul 12, 2023

Changes in this version

+ const MetadataConstraintName

+ const MetadataFalse

+ const MetadataIncremental

+ const MetadataPrimaryKey

+ const MetadataTableDescription

+ const MetadataTableName

+ const MetadataTrue

+ const MetadataUnique

+ var CqIDColumn = Column

+ var CqParentIDColumn = Column

+ var CqSourceNameColumn = Column

+ var CqSyncTimeColumn = Column

+ func AddCqIDs(table *Table)

+ func FindEmptyColumns(table *Table, records []arrow.Record) []string

+ func ValidColumnName(name string) bool

+ func ValidateTable(t *Table) error

+ type ClientMeta interface

+ ID func() string

+ type Column struct

+ Description string

+ IgnoreInTests bool

+ IncrementalKey bool

+ Name string

+ NotNull bool

+ PrimaryKey bool

+ Resolver ColumnResolver

+ Type arrow.DataType

+ Unique bool

+ func NewColumnFromArrowField(f arrow.Field) Column

+ func (c Column) String() string

+ func (c Column) ToArrowField() arrow.Field

+ type ColumnList []Column

+ func (c ColumnList) Get(name string) *Column

+ func (c ColumnList) Index(col string) int

+ func (c ColumnList) Names() []string

+ func (c ColumnList) String() string

+ type ColumnResolver func(ctx context.Context, meta ClientMeta, resource *Resource, c Column) error

+ func ParentColumnResolver(name string) ColumnResolver

+ func PathResolver(path string) ColumnResolver

+ type GenTestDataOptions struct

+ MaxRows int

+ NullRows bool

+ Seed int64

+ SourceName string

+ StableTime time.Time

+ StableUUID uuid.UUID

+ SyncTime time.Time

+ TimePrecision time.Duration

+ type LengthTableValidator struct

+ func (LengthTableValidator) Validate(t *Table) error

+ type Multiplexer func(meta ClientMeta) []ClientMeta

+ type Resource struct

+ Item any

+ Parent *Resource

+ Table *Table

+ func NewResourceData(t *Table, parent *Resource, item any) *Resource

+ func (r *Resource) CalculateCQID(deterministicCQID bool) error

+ func (r *Resource) Get(columnName string) scalar.Scalar

+ func (r *Resource) GetItem() any

+ func (r *Resource) GetValues() scalar.Vector

+ func (r *Resource) Set(columnName string, value any) error

+ func (r *Resource) SetItem(item any)

+ func (r *Resource) Validate() error

+ type Resources []*Resource

+ func (rr Resources) ColumnNames() []string

+ func (rr Resources) TableName() string

+ type RowResolver func(ctx context.Context, meta ClientMeta, resource *Resource) error

+ type Schemas []*arrow.Schema

+ func (s Schemas) Len() int

+ func (s Schemas) SchemaByName(name string) *arrow.Schema

+ type SyncSummary struct

+ Errors uint64

+ Panics uint64

+ Resources uint64

+ type Table struct

+ Columns ColumnList

+ Description string

+ IgnoreInTests bool

+ IsIncremental bool

+ Multiplex Multiplexer

+ Name string

+ Parent *Table

+ PkConstraintName string

+ PostResourceResolver RowResolver

+ PreResourceResolver RowResolver

+ Relations Tables

+ Resolver TableResolver

+ Title string

+ Transform Transform

+ func NewTableFromArrowSchema(sc *arrow.Schema) (*Table, error)

+ func TestTable(name string, opts TestSourceOptions) *Table

+ func (t *Table) Column(name string) *Column

+ func (t *Table) Copy(parent *Table) *Table

+ func (t *Table) GetChanges(old *Table) []TableColumnChange

+ func (t *Table) IncrementalKeys() []string

+ func (t *Table) OverwriteOrAddColumn(column *Column)

+ func (t *Table) PrimaryKeys() []string

+ func (t *Table) PrimaryKeysIndexes() []int

+ func (t *Table) TableNames() []string

+ func (t *Table) ToArrowSchema() *arrow.Schema

+ func (t *Table) ValidateColumnNames() error

+ func (t *Table) ValidateDuplicateColumns() error

+ func (t *Table) ValidateName() error

+ type TableColumnChange struct

+ ColumnName string

+ Current Column

+ Previous Column

+ Type TableColumnChangeType

+ func (t TableColumnChange) String() string

+ type TableColumnChangeType int

+ const TableColumnChangeTypeAdd

+ const TableColumnChangeTypeRemove

+ const TableColumnChangeTypeUnknown

+ const TableColumnChangeTypeUpdate

+ func (t TableColumnChangeType) String() string

+ type TableResolver func(ctx context.Context, meta ClientMeta, parent *Resource, res chan<- any) error

+ type TableValidator interface

+ Validate func(t *Table) error

+ type Tables []*Table

+ func NewTablesFromArrowSchemas(schemas []*arrow.Schema) (Tables, error)

+ func (tt Tables) FilterDfs(tables, skipTables []string, skipDependentTables bool) (Tables, error)

+ func (tt Tables) FilterDfsFunc(include, exclude func(*Table) bool, skipDependentTables bool) Tables

+ func (tt Tables) FlattenTables() Tables

+ func (tt Tables) Get(name string) *Table

+ func (tt Tables) GetTopLevel(name string) *Table

+ func (tt Tables) TableNames() []string

+ func (tt Tables) ToArrowSchemas() Schemas

+ func (tt Tables) ValidateColumnNames() error

+ func (tt Tables) ValidateDuplicateColumns() error

+ func (tt Tables) ValidateDuplicateTables() error

+ func (tt Tables) ValidateTableNames() error

+ type TestDataGenerator struct

+ func NewTestDataGenerator() *TestDataGenerator

+ func (tg *TestDataGenerator) Generate(table *Table, opts GenTestDataOptions) []arrow.Record

+ type TestSourceOptions struct

+ SkipDates bool

+ SkipDecimals bool

+ SkipDurations bool

+ SkipIntervals bool

+ SkipLargeTypes bool

+ SkipLists bool

+ SkipMaps bool

+ SkipStructs bool

+ SkipTimes bool

+ SkipTimestamps bool

+ TimePrecision time.Duration

+ type Transform func(table *Table) error

+ type ValidationError struct

+ Err error

+ Msg string

+ Type arrow.DataType

+ Value any

+ func (e *ValidationError) Error() string

+ func (e *ValidationError) MaskedError() string

+ func (e *ValidationError) Unwrap() error