schema

Mar 14, 2023

Changes in this version

type Table

+ Title string

Mar 2, 2023

Changes in this version

type Resource

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

Feb 16, 2023

Changes in this version

type Table

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

+ 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

Feb 12, 2023

Changes in this version

type Column

+ func (c *Column) String() string

type ColumnList

+ func (c ColumnList) String() string

Feb 8, 2023

Changes in this version

type Table

+ PkConstraintName string

+ func (t *Table) GetAddedColumns(other *Table) []Column

+ func (t *Table) GetChangedColumns(other *Table) []Column

+ func (t *Table) IsPrimaryKeyEqual(other *Table) bool

Jan 11, 2023

Changes in this version

type Tables

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

Jan 10, 2023

Changes in this version

+ type ValidationError struct

+ Err error

+ Msg string

+ Type ValueType

+ Value any

+ func (e *ValidationError) Error() string

+ func (e *ValidationError) MaskedError() string

+ func (e *ValidationError) Unwrap() error

Jan 9, 2023

Changes in this version

type ColumnCreationOptions

+ IncrementalKey bool

type Table

+ IsIncremental bool

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

Jan 9, 2023

Changes in this version

type Bool

+ func (*Bool) Size() int

type Bytea

+ func (dst *Bytea) Size() int

type CIDR

+ func (dst *CIDR) Size() int

type CIDRArray

+ func (dst *CIDRArray) Size() int

type CQType

+ Size func() int

type CQTypes

+ func (c CQTypes) Size() int

type Float8

+ func (dst *Float8) Size() int

type Inet

+ func (dst *Inet) Size() int

type InetArray

+ func (dst *InetArray) Size() int

type Int8

+ func (*Int8) Size() int

type Int8Array

+ func (dst *Int8Array) Size() int

type JSON

+ func (dst *JSON) Size() int

type Macaddr

+ func (dst *Macaddr) Size() int

type MacaddrArray

+ func (dst *MacaddrArray) Size() int

type Text

+ func (dst *Text) Size() int

type TextArray

+ func (dst *TextArray) Size() int

type Timestamptz

+ func (dst *Timestamptz) Size() int

type UUID

+ func (dst *UUID) Size() int

type UUIDArray

+ func (dst *UUIDArray) Size() int

Jan 4, 2023

Changes in this version

type Table

+ Transform Transform

+ type Transform func(table *Table) error

Jan 3, 2023

Changes in this version

type Bool

+ func (dst *Bool) GetStatus() Status

type Bytea

+ func (dst *Bytea) GetStatus() Status

type CIDR

+ func (dst *CIDR) GetStatus() Status

type CIDRArray

+ func (dst *CIDRArray) GetStatus() Status

type CQType

+ GetStatus func() Status

type Float8

+ func (dst *Float8) GetStatus() Status

type Inet

+ func (dst *Inet) GetStatus() Status

type InetArray

+ func (dst *InetArray) GetStatus() Status

type Int8

+ func (dst *Int8) GetStatus() Status

type Int8Array

+ func (dst *Int8Array) GetStatus() Status

type JSON

+ func (dst *JSON) GetStatus() Status

type Macaddr

+ func (dst *Macaddr) GetStatus() Status

type MacaddrArray

+ func (dst *MacaddrArray) GetStatus() Status

type Resource

+ func (r *Resource) Validate() error

type Text

+ func (dst *Text) GetStatus() Status

type TextArray

+ func (dst *TextArray) GetStatus() Status

type Timestamptz

+ func (dst *Timestamptz) GetStatus() Status

type UUID

+ func (dst *UUID) GetStatus() Status

type UUIDArray

+ func (dst *UUIDArray) GetStatus() Status

Dec 21, 2022

Changes in this version

type CQTypes

+ func (c CQTypes) Diff(other CQTypes) string

Dec 13, 2022

Changes in this version

type Table

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

type Tables

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

Nov 24, 2022

Changes in this version

type Tables

+ func (tt Tables) FlattenTables() Tables

Nov 15, 2022

Changes in this version

type CIDR

+ func (dst *CIDR) UnmarshalJSON(b []byte) error

type Inet

+ func (dst *Inet) UnmarshalJSON(b []byte) error

Nov 14, 2022

Changes in this version

type Tables

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

Nov 11, 2022

Changes in this version

type Tables

+ func (tt Tables) GlobMatch(pattern string) Tables

Nov 7, 2022

Changes in this version

+ func TransformWithTransformer(transformer CQTypeTransformer, values CQTypes) []interface

+ type ArrayDimension struct

+ Length int32

+ LowerBound int32

+ type Bool struct

+ Bool bool

+ Status Status

+ func (*Bool) Type() ValueType

+ func (dst *Bool) Equal(src CQType) bool

+ func (dst *Bool) Set(src interface{}) error

+ func (dst *Bool) String() string

+ func (dst Bool) Get() interface{}

+ type BoolTransformer interface

+ TransformBool func(*Bool) interface{}

+ type Bytea struct

+ Bytes []byte

+ Status Status

+ func (*Bytea) Type() ValueType

+ func (dst *Bytea) Equal(src CQType) bool

+ func (dst *Bytea) Set(src interface{}) error

+ func (dst *Bytea) String() string

+ func (dst Bytea) Get() interface{}

+ type ByteaTransformer interface

+ TransformBytea func(*Bytea) interface{}

+ type CIDR Inet

+ func (*CIDR) Type() ValueType

+ func (dst *CIDR) Equal(src CQType) bool

+ func (dst *CIDR) Set(src interface{}) error

+ func (dst *CIDR) String() string

+ func (dst CIDR) Get() interface{}

+ type CIDRArray struct

+ Dimensions []ArrayDimension

+ Elements []CIDR

+ Status Status

+ func (*CIDRArray) Type() ValueType

+ func (dst *CIDRArray) Equal(src CQType) bool

+ func (dst *CIDRArray) Set(src interface{}) error

+ func (dst *CIDRArray) String() string

+ func (dst CIDRArray) Get() interface{}

+ type CIDRArrayTransformer interface

+ TransformCIDRArray func(*CIDRArray) interface{}

+ type CIDRTransformer interface

+ TransformCIDR func(*CIDR) interface{}

+ type CQType interface

+ Equal func(CQType) bool

+ Get func() interface{}

+ Set func(v interface{}) error

+ String func() string

+ Type func() ValueType

+ func NewCqTypeFromValueType(typ ValueType) CQType

+ type CQTypeTransformer interface

+ type CQTypes []CQType

+ func (c *CQTypes) UnmarshalJSON(b []byte) error

+ func (c CQTypes) Equal(other CQTypes) bool

+ func (c CQTypes) Len() int

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

+ func (c CQTypes) String() string

type ColumnList

+ func (c *ColumnList) UnmarshalJSON(data []byte) (err error)

+ type DefaultTransformer struct

+ func (*DefaultTransformer) TransformBool(v *Bool) interface{}

+ func (*DefaultTransformer) TransformBytea(v *Bytea) interface{}

+ func (*DefaultTransformer) TransformCIDR(v *CIDR) interface{}

+ func (*DefaultTransformer) TransformCIDRArray(v *CIDRArray) interface{}

+ func (*DefaultTransformer) TransformFloat8(v *Float8) interface{}

+ func (*DefaultTransformer) TransformInet(v *Inet) interface{}

+ func (*DefaultTransformer) TransformInetArray(v *InetArray) interface{}

+ func (*DefaultTransformer) TransformInt8(v *Int8) interface{}

+ func (*DefaultTransformer) TransformInt8Array(v *Int8Array) interface{}

+ func (*DefaultTransformer) TransformJSON(v *JSON) interface{}

+ func (*DefaultTransformer) TransformMacaddr(v *Macaddr) interface{}

+ func (*DefaultTransformer) TransformMacaddrArray(v *MacaddrArray) interface{}

+ func (*DefaultTransformer) TransformText(v *Text) interface{}

+ func (*DefaultTransformer) TransformTextArray(v *TextArray) interface{}

+ func (*DefaultTransformer) TransformTimestamptz(v *Timestamptz) interface{}

+ func (*DefaultTransformer) TransformUUID(v *UUID) interface{}

+ func (*DefaultTransformer) TransformUUIDArray(v *UUIDArray) interface{}

+ type Float8 struct

+ Float float64

+ Status Status

+ func (*Float8) Type() ValueType

+ func (dst *Float8) Equal(src CQType) bool

+ func (dst *Float8) Set(src interface{}) error

+ func (dst *Float8) String() string

+ func (dst Float8) Get() interface{}

+ type Float8Transformer interface

+ TransformFloat8 func(*Float8) interface{}

+ type Inet struct

+ IPNet *net.IPNet

+ Status Status

+ func (*Inet) Type() ValueType

+ func (dst *Inet) Equal(src CQType) bool

+ func (dst *Inet) Set(src interface{}) error

+ func (dst *Inet) String() string

+ func (dst Inet) Get() interface{}

+ type InetArray struct

+ Dimensions []ArrayDimension

+ Elements []Inet

+ Status Status

+ func (*InetArray) Type() ValueType

+ func (dst *InetArray) Equal(src CQType) bool

+ func (dst *InetArray) Set(src interface{}) error

+ func (dst *InetArray) String() string

+ func (dst InetArray) Get() interface{}

+ type InetArrayTransformer interface

+ TransformInetArray func(*InetArray) interface{}

+ type InetTransformer interface

+ TransformInet func(*Inet) interface{}

+ type InfinityModifier int8

+ const Infinity

+ const NegativeInfinity

+ const None

+ type Int8 struct

+ Int int64

+ Status Status

+ func (*Int8) Type() ValueType

+ func (dst *Int8) Equal(src CQType) bool

+ func (dst *Int8) Set(src interface{}) error

+ func (dst *Int8) String() string

+ func (dst Int8) Get() interface{}

+ type Int8Array struct

+ Dimensions []ArrayDimension

+ Elements []Int8

+ Status Status

+ func (*Int8Array) Type() ValueType

+ func (dst *Int8Array) Equal(src CQType) bool

+ func (dst *Int8Array) Set(src interface{}) error

+ func (dst *Int8Array) String() string

+ func (dst Int8Array) Get() interface{}

+ type Int8ArrayTransformer interface

+ TransformInt8Array func(*Int8Array) interface{}

+ type Int8Transformer interface

+ TransformInt8 func(*Int8) interface{}

+ type JSON struct

+ Bytes []byte

+ Status Status

+ func (*JSON) Type() ValueType

+ func (dst *JSON) Equal(src CQType) bool

+ func (dst *JSON) Set(src interface{}) error

+ func (dst *JSON) String() string

+ func (dst JSON) Get() interface{}

+ type JSONTransformer interface

+ TransformJSON func(*JSON) interface{}

+ type Macaddr struct

+ Addr net.HardwareAddr

+ Status Status

+ func (*Macaddr) Type() ValueType

+ func (dst *Macaddr) Equal(src CQType) bool

+ func (dst *Macaddr) Set(src interface{}) error

+ func (dst *Macaddr) String() string

+ func (dst Macaddr) Get() interface{}

+ type MacaddrArray struct

+ Dimensions []ArrayDimension

+ Elements []Macaddr

+ Status Status

+ func (*MacaddrArray) Type() ValueType

+ func (dst *MacaddrArray) Equal(src CQType) bool

+ func (dst *MacaddrArray) Set(src interface{}) error

+ func (dst *MacaddrArray) String() string

+ func (dst MacaddrArray) Get() interface{}

+ type MacaddrArrayTransformer interface

+ TransformMacaddrArray func(*MacaddrArray) interface{}

+ type MacaddrTransformer interface

+ TransformMacaddr func(*Macaddr) interface{}

+ type Text struct

+ Status Status

+ Str string

+ func (*Text) Type() ValueType

+ func (dst *Text) Equal(src CQType) bool

+ func (dst *Text) Set(src interface{}) error

+ func (dst *Text) String() string

+ func (dst Text) Get() interface{}

+ type TextArray struct

+ Dimensions []ArrayDimension

+ Elements []Text

+ Status Status

+ func (*TextArray) Type() ValueType

+ func (dst *TextArray) Equal(src CQType) bool

+ func (dst *TextArray) Set(src interface{}) error

+ func (dst *TextArray) String() string

+ func (dst TextArray) Get() interface{}

+ type TextArrayTransformer interface

+ TransformTextArray func(*TextArray) interface{}

+ type TextTransformer interface

+ TransformText func(*Text) interface{}

+ type Timestamptz struct

+ InfinityModifier InfinityModifier

+ Status Status

+ Time time.Time

+ func (*Timestamptz) Type() ValueType

+ func (dst *Timestamptz) DecodeText(src []byte) error

+ func (dst *Timestamptz) Equal(src CQType) bool

+ func (dst *Timestamptz) Set(src interface{}) error

+ func (dst *Timestamptz) String() string

+ func (dst Timestamptz) Get() interface{}

+ type TimestamptzTransformer interface

+ TransformTimestamptz func(*Timestamptz) interface{}

+ type UUID struct

+ Bytes [16]byte

+ Status Status

+ func (*UUID) Type() ValueType

+ func (dst *UUID) Equal(src CQType) bool

+ func (dst *UUID) Set(src interface{}) error

+ func (dst *UUID) String() string

+ func (dst UUID) Get() interface{}

+ type UUIDArray struct

+ Dimensions []ArrayDimension

+ Elements []UUID

+ Status Status

+ func (*UUIDArray) Type() ValueType

+ func (dst *UUIDArray) Equal(src CQType) bool

+ func (dst *UUIDArray) Set(src interface{}) error

+ func (dst *UUIDArray) String() string

+ func (dst UUIDArray) Get() interface{}

+ type UUIDArrayTransformer interface

+ TransformUUIDArray func(*UUIDArray) interface{}

+ type UUIDTransformer interface

+ TransformUUID func(*UUID) interface{}

type ValueType

+ const TypeEnd

+ const TypeTimeIntervalDeprecated

+ func (r *ValueType) UnmarshalJSON(data []byte) (err error)

Oct 31, 2022

Changes in this version

+ func CQTypesFromValues(table *Table, values interface{}) (cqtypes.CQTypes, error)

type ColumnList

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

+ type DestinationResource struct

+ Data cqtypes.CQTypes

+ TableName string

type Resource

+ func (r *Resource) GetValues() cqtypes.CQTypes

+ func (r *Resource) ToDestinationResource() DestinationResource

+ type Status byte

+ const Null

+ const Present

+ const Undefined

Oct 30, 2022

Changes in this version

type ClientMeta

+ ID func() string

type Resource

+ func (r *Resource) GetItem() interface{}

type Tables

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

Oct 19, 2022

Changes in this version

type Table

+ func (t *Table) ValidateColumnNames() error

+ func (t *Table) ValidateName() error

type Tables

+ func (tt Tables) ValidateColumnNames() error

+ func (tt Tables) ValidateTableNames() error

Oct 10, 2022

Changes in this version

+ var CqSourceNameColumn = Column

+ var CqSyncTimeColumn = Column

type Table

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

Oct 7, 2022

Changes in this version

type SyncSummary

+ func (s *SyncSummary) Merge(other SyncSummary)

Oct 3, 2022

Changes in this version

+ var CqParentIDColumn = Column

+ var CqSourceName = Column

+ var CqSyncTime = Column

+ type SyncSummary struct

+ Errors uint64

+ Panics uint64

+ Resources uint64

Sep 30, 2022

Changes in this version

type ValueType

+ const TypeTimeInterval

Sep 29, 2022

Changes in this version

type ColumnResolver

+ func ParentColumnResolver(name string) ColumnResolver

Sep 19, 2022

Changes in this version

+ type Multiplexer func(meta ClientMeta) []ClientMeta

Sep 13, 2022

Changes in this version

+ const FetchIDMetaKey

+ var CqIDColumn = Column

+ func DeleteParentIDFilter(id string) func(meta ClientMeta, parent *Resource) []interface

+ func ParentIDResolver(_ context.Context, _ ClientMeta, r *Resource, c Column) error

type Meta

+ FetchID string

type Resource

+ func (r *Resource) ID() uuid.UUID

Sep 3, 2022

Changes in this version

type Resource

+ func (r *Resource) SetItem(item interface{})

type Table

+ PreResourceResolver RowResolver

Aug 31, 2022

Changes in this version

type Tables

+ func (tt Tables) ValidateDuplicateTables() error

Aug 30, 2022

Changes in this version

+ var CqColumns = []Column

+ var CqFetchTime = Column

+ var CqIdColumn = Column

type ColumnCreationOptions

+ PrimaryKey bool

type ColumnResolver

+ func CQUUIDResolver() ColumnResolver

type Resource

+ func (r *Resource) PrimaryKeyValue() string

type Table

+ func (t Table) ColumnIndex(name string) int

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

+ func (t Table) ValidateDuplicateColumns() error

+ type Tables []*Table

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

+ func (tt Tables) ValidateDuplicateColumns() error

Aug 9, 2022

Changes in this version

+ const FetchIdMetaKey

+ func DeleteParentIdFilter(id string) func(meta ClientMeta, parent *Resource) []interface

+ func GenerateMarkdownTree(tables []*Table, dir string) error

+ func ParentIdResolver(_ context.Context, _ ClientMeta, r *Resource, c Column) error

+ func ValidateTable(t *Table) error

+ type ClientMeta interface

+ Logger func() *zerolog.Logger

+ type Column struct

+ CreationOptions ColumnCreationOptions

+ Description string

+ IgnoreInTests bool

+ Name string

+ Resolver ColumnResolver

+ Type ValueType

+ func SetColumnMeta(c Column, m *ColumnMeta) Column

+ func (c Column) Internal() bool

+ func (c Column) Meta() *ColumnMeta

+ func (c Column) ValidateType(v interface{}) error

+ type ColumnCreationOptions struct

+ NotNull bool

+ Unique bool

+ type ColumnList []Column

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

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

+ func (c ColumnList) Sift() (providerCols ColumnList, internalCols ColumnList)

+ type ColumnMeta struct

+ IgnoreExists bool

+ Resolver *ResolverMeta

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

+ func DateResolver(path string, rfcs ...string) ColumnResolver

+ func DateUTCResolver(path string, rfcs ...string) ColumnResolver

+ func IPAddressResolver(path string) ColumnResolver

+ func IPAddressesResolver(path string) ColumnResolver

+ func IPNetResolver(path string) ColumnResolver

+ func IntResolver(path string) ColumnResolver

+ func MACAddressResolver(path string) ColumnResolver

+ func ParentPathResolver(path string) ColumnResolver

+ func ParentResourceFieldResolver(name string) ColumnResolver

+ func PathResolver(path string) ColumnResolver

+ func StringResolver(path string) ColumnResolver

+ func UUIDResolver(path string) ColumnResolver

+ type IgnoreErrorFunc func(err error) bool

+ type LengthTableValidator struct

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

+ type Meta struct

+ FetchId string

+ LastUpdate time.Time

+ type ResolverMeta struct

+ Builtin bool

+ Name string

+ type Resource struct

+ CColumns []string

+ Data map[string]interface{}

+ Item interface{}

+ Parent *Resource

+ Table *Table

+ func NewResourceData(t *Table, parent *Resource, item interface{}) *Resource

+ func (r *Resource) Columns() []string

+ func (r *Resource) Get(key string) interface{}

+ func (r *Resource) Id() uuid.UUID

+ func (r *Resource) Set(key string, value interface{}) error

+ func (r *Resource) TableName() string

+ func (r Resource) GetMeta(key string) (interface{}, bool)

+ type Resources []*Resource

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

+ func (rr Resources) GetIds() []uuid.UUID

+ func (rr Resources) TableName() string

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

+ type Table struct

+ Columns ColumnList

+ Description string

+ IgnoreError IgnoreErrorFunc

+ IgnoreInTests bool

+ Multiplex func(meta ClientMeta) []ClientMeta

+ Name string

+ Options TableCreationOptions

+ Parent *Table

+ PostResourceResolver RowResolver

+ Relations []*Table

+ Resolver TableResolver

+ Serial string

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

+ func (t Table) Resolve(ctx context.Context, meta ClientMeta, parent *Resource, ...)

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

+ type TableCreationOptions struct

+ PrimaryKeys []string

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

+ type TableValidator interface

+ Validate func(t *Table) error

+ type ValueType int

+ const TypeBigInt

+ const TypeBool

+ const TypeByteArray

+ const TypeCIDR

+ const TypeCIDRArray

+ const TypeFloat

+ const TypeInet

+ const TypeInetArray

+ const TypeInt

+ const TypeIntArray

+ const TypeInvalid

+ const TypeJSON

+ const TypeMacAddr

+ const TypeMacAddrArray

+ const TypeSmallInt

+ const TypeString

+ const TypeStringArray

+ const TypeTimestamp

+ const TypeUUID

+ const TypeUUIDArray

+ func ValueTypeFromString(s string) ValueType

+ func (v ValueType) String() string