schema

type ClientMeta interface {
	Logger() *zerolog.Logger
}

type Column struct {
	// Name of column
	Name string
	// Value Type of column i.e String, UUID etc'
	Type ValueType
	// Description about column, this description is added as a comment in the database
	Description string
	// Column Resolver allows to set you own data based on resolving this can be an API call or setting multiple embedded values etc'
	Resolver ColumnResolver `msgpack:"-"`
	// Creation options allow modifying how column is defined when table is created
	CreationOptions ColumnCreationOptions
	// IgnoreInTests is used to skip verifying the column is non-nil in integration tests.
	// By default, integration tests perform a fetch for all resources in cloudquery's test account, and
	// verify all columns are non-nil.
	// If IgnoreInTests is true, verification is skipped for this column.
	// Used when it is hard to create a reproducible environment with this column being non-nil (e.g. various error columns).
	IgnoreInTests bool
	// contains filtered or unexported fields
}

type ColumnCreationOptions struct {
	Unique  bool
	NotNull bool
}

type ColumnList []Column

type ColumnMeta struct {
	Resolver     *ResolverMeta
	IgnoreExists bool
}

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

type IgnoreErrorFunc func(err error) bool

type LengthTableValidator struct{}

type Meta struct {
	LastUpdate time.Time `json:"last_updated"`
	FetchId    string    `json:"fetch_id,omitempty"`
}

type ResolverMeta struct {
	Name    string
	Builtin bool
}

type Resource struct {
	// Original resource item that wa from prior resolve
	Item interface{}
	// Set if this is an embedded table
	Parent *Resource `msgpack:"parent"`
	// internal fields
	Table *Table                 `msgpack:"table"`
	Data  map[string]interface{} `msgpack:"data"`

	CColumns []string `msgpack:"columns"`
	// contains filtered or unexported fields
}

type Resources []*Resource

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

type Table struct {
	// Name of table
	Name string
	// table description
	Description string
	// Columns are the set of fields that are part of this table
	Columns ColumnList
	// Relations are a set of related tables defines
	Relations []*Table
	// Resolver is the main entry point to fetching table data and
	Resolver TableResolver `msgpack:"-"`
	// Ignore errors checks if returned error from table resolver should be ignored.
	IgnoreError IgnoreErrorFunc `msgpack:"-"`
	// Multiplex returns re-purposed meta clients. The sdk will execute the table with each of them
	Multiplex func(meta ClientMeta) []ClientMeta `msgpack:"-"`
	// Post resource resolver is called after all columns have been resolved, and before resource is inserted to database.
	PostResourceResolver RowResolver `msgpack:"-"`
	// Options allow modification of how the table is defined when created
	Options TableCreationOptions

	// IgnoreInTests is used to exclude a table from integration tests.
	// By default, integration tests fetch all resources from cloudquery's test account, and verify all tables
	// have at least one row.
	// When IgnoreInTests is true, integration tests won't fetch from this table.
	// Used when it is hard to create a reproducible environment with a row in this table.
	IgnoreInTests bool

	// Parent is the parent table in case this table is called via parent table (i.e. relation)
	Parent *Table

	// Serial is used to force a signature change, which forces new table creation and cascading removal of old table and relations
	Serial string
}

type TableCreationOptions struct {
	// List of columns to set as primary keys. If this is empty, a random unique ID is generated.
	PrimaryKeys []string
}

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

type TableValidator interface {
	Validate(t *Table) error
}

type ValueType int