schema

Jul 28, 2022

Changes in this version

type TableResolver

+ func PathTableResolver(path string) TableResolver

May 24, 2022

Changes in this version

type Table

+ Serial string

+ func (t Table) Signature(d Dialect) string

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

May 23, 2022

Changes in this version

+ const FetchIdMetaKey

May 2, 2022

Changes in this version

+ type ClientIdentifier interface

+ Identify func() string

Mar 10, 2022

Changes in this version

type Resource

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

Feb 2, 2022

Changes in this version

type ColumnList

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

Jan 25, 2022

Changes in this version

+ const Postgres

+ const TSDB

type Column

+ func (c Column) Internal() bool

type ColumnCreationOptions

+ NotNull bool

+ type ColumnList []Column

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

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

+ type Dialect interface

+ Columns func(t *Table) ColumnList

+ Constraints func(t, parent *Table) []string

+ DBTypeFromType func(v ValueType) string

+ Extra func(t, parent *Table) []string

+ GetResourceValues func(r *Resource) ([]interface{}, error)

+ PrimaryKeys func(t *Table) []string

+ func GetDialect(t DialectType) (Dialect, error)

+ type DialectType string

+ func (t DialectType) MigrationDirectory() string

+ type Meta struct

+ FetchId string

+ LastUpdate time.Time

+ type PostgresDialect struct

+ func (d PostgresDialect) Columns(t *Table) ColumnList

+ func (d PostgresDialect) Constraints(t, parent *Table) []string

+ func (d PostgresDialect) DBTypeFromType(v ValueType) string

+ func (d PostgresDialect) Extra(_, _ *Table) []string

+ func (d PostgresDialect) GetResourceValues(r *Resource) ([]interface{}, error)

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

+ type QueryExecer interface

+ Exec func(ctx context.Context, query string, args ...interface{}) error

type Resource

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

+ func (r *Resource) TableName() string

+ type Storage interface

+ Close func()

+ CopyFrom func(ctx context.Context, resources Resources, shouldCascade bool, ...) error

+ Delete func(ctx context.Context, t *Table, kvFilters []interface{}) error

+ Dialect func() Dialect

+ Insert func(ctx context.Context, t *Table, instance Resources) error

+ RemoveStaleData func(ctx context.Context, t *Table, executionStart time.Time, ...) error

+ type TSDBDialect struct

+ func (d TSDBDialect) Columns(t *Table) ColumnList

+ func (d TSDBDialect) Constraints(t, _ *Table) []string

+ func (d TSDBDialect) DBTypeFromType(v ValueType) string

+ func (d TSDBDialect) Extra(t, parent *Table) []string

+ func (d TSDBDialect) GetResourceValues(r *Resource) ([]interface{}, error)

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

type Table

+ Global bool

Dec 31, 2021

Changes in this version

type Column

+ IgnoreInTests bool

type Table

+ IgnoreInTests bool

Nov 23, 2021

Changes in this version

type ColumnResolver

+ func IPAddressesResolver(path string) ColumnResolver

Nov 4, 2021

Changes in this version

type Column

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

+ func (c Column) Meta() *ColumnMeta

+ type ColumnMeta struct

+ IgnoreExists bool

+ Resolver *ResolverMeta

+ type ResolverMeta struct

+ Builtin bool

+ Name string

Oct 21, 2021

Changes in this version

type ExecutionData

+ ResourceName string

+ type ResourceFetchError struct

+ Err error

+ RootPrimaryKeyValues []string

+ RootTableName string

+ TableName string

+ func (p ResourceFetchError) Error() string

Sep 23, 2021

Changes in this version

type Column

+ IgnoreError IgnoreErrorFunc

type Database

+ RemoveStaleData func(ctx context.Context, t *Table, executionStart time.Time, ...) error

type PgDatabase

+ func (p PgDatabase) RemoveStaleData(ctx context.Context, t *Table, executionStart time.Time, ...) error

type Resource

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

Sep 13, 2021

Changes in this version

type Resource

+ func (r *Resource) String() string

Sep 2, 2021

Changes in this version

type Database

+ Close func()

type ExecutionData

+ PartialFetchFailureResult []PartialFetchFailedResource

+ type PartialFetchFailedResource struct

+ Error string

+ RootPrimaryKeyValues []string

+ RootTableName string

+ TableName string

type PgDatabase

+ func (p PgDatabase) Close()

Aug 10, 2021

Changes in this version

type ColumnResolver

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

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

+ func IPAddressResolver(path string) ColumnResolver

+ func IPNetResolver(path string) ColumnResolver

+ func IntResolver(path string) ColumnResolver

+ func MACAddressResolver(path string) ColumnResolver

+ func StringResolver(path string) ColumnResolver

+ func UUIDResolver(path string) ColumnResolver

Jul 26, 2021

Changes in this version

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

+ func TruncateTableConstraint(name string) string

type Column

+ func GetDefaultSDKColumns() []Column

type ColumnResolver

+ func ParentPathResolver(path string) ColumnResolver

+ func ParentResourceFieldResolver(name string) ColumnResolver

type Database

+ CopyFrom func(ctx context.Context, resources Resources, shouldCascade bool, ...) error

type PgDatabase

+ func (p PgDatabase) CopyFrom(ctx context.Context, resources Resources, shouldCascade bool, ...) error

type Resource

+ func (r *Resource) GenerateCQId() error

+ type Resources []*Resource

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

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

+ func (rr Resources) TableName() string

type Table

+ AlwaysDelete bool

+ Options TableCreationOptions

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

+ type TableCreationOptions struct

+ PrimaryKeys []string

Jul 4, 2021

Changes in this version

type ValueType

+ const TypeCIDR

+ const TypeCIDRArray

+ const TypeInet

+ const TypeInetArray

+ const TypeMacAddr

+ const TypeMacAddrArray

May 15, 2021

Changes in this version

+ func ValidateTable(t *Table) error

+ type LengthTableValidator struct

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

+ type TableValidator interface

+ Validate func(t *Table) error

Apr 18, 2021

Changes in this version

type ValueType

+ const TypeUUIDArray

Apr 8, 2021

Changes in this version

+ func GetPgTypeFromType(v ValueType) string

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

+ type ClientMeta interface

+ Logger func() hclog.Logger

+ type Column struct

+ CreationOptions ColumnCreationOptions

+ Default interface{}

+ Description string

+ Name string

+ Resolver ColumnResolver

+ Type ValueType

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

+ type ColumnCreationOptions struct

+ Nullable bool

+ Unique bool

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

+ func PathResolver(path string) ColumnResolver

+ type Database interface

+ Delete func(ctx context.Context, t *Table, args []interface{}) error

+ Exec func(ctx context.Context, query string, args ...interface{}) error

+ Insert func(ctx context.Context, t *Table, instance []*Resource) error

+ Query func(ctx context.Context, query string, args ...interface{}) (pgx.Rows, error)

+ type ExecutionData struct

+ Column *Column

+ Db Database

+ Logger hclog.Logger

+ Table *Table

+ func NewExecutionData(db Database, logger hclog.Logger, table *Table) ExecutionData

+ func (e ExecutionData) ResolveTable(ctx context.Context, meta ClientMeta, parent *Resource) error

+ func (e ExecutionData) WithTable(t *Table) ExecutionData

+ type IgnoreErrorFunc func(err error) bool

+ type PgDatabase struct

+ func NewPgDatabase(dsn string) (*PgDatabase, error)

+ func (p PgDatabase) Delete(ctx context.Context, t *Table, args []interface{}) error

+ func (p PgDatabase) Exec(ctx context.Context, query string, args ...interface{}) error

+ func (p PgDatabase) Insert(ctx context.Context, t *Table, resources []*Resource) error

+ func (p PgDatabase) Query(ctx context.Context, query string, args ...interface{}) (pgx.Rows, error)

+ func (p PgDatabase) QueryOne(ctx context.Context, query string, args ...interface{}) pgx.Row

+ type Resource struct

+ Item interface{}

+ Parent *Resource

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

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

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

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

+ func (r Resource) Values() ([]interface{}, error)

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

+ type Table struct

+ Columns []Column

+ DeleteFilter func(meta ClientMeta) []interface{}

+ Description string

+ IgnoreError IgnoreErrorFunc

+ Multiplex func(meta ClientMeta) []ClientMeta

+ Name string

+ PostResourceResolver RowResolver

+ Relations []*Table

+ Resolver TableResolver

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

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

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

+ type ValueType int

+ const TypeBigInt

+ const TypeBool

+ const TypeByteArray

+ const TypeFloat

+ const TypeInt

+ const TypeIntArray

+ const TypeInvalid

+ const TypeJSON

+ const TypeSmallInt

+ const TypeString

+ const TypeStringArray

+ const TypeTimestamp

+ const TypeUUID

+ func ValueTypeFromString(s string) ValueType

+ func (v ValueType) String() string