view

package

Go to main page

Versions in this module

v0

v0.10.11

Dec 10, 2024

v0.10.10

Dec 3, 2024

v0.10.9

Dec 3, 2024

v0.10.8

Nov 21, 2024

v0.10.7

Nov 19, 2024

v0.10.6

Nov 18, 2024

v0.10.5

Nov 18, 2024

v0.10.4

Nov 18, 2024

Changes in this version

+ type Connection struct

+ func (c *Connection) DB() (*sql.DB, error)

+ func (c *Connection) Dialect(ctx context.Context) (*info.Dialect, error)

+ func (c *Connection) Init(ctx context.Context, connectors Connectors) error

+ func (c *Connection) Validate() error

type Connector

+ Connections []*Connection

+ func (c *Connector) GetConnection(ctx context.Context, connectors Connectors) (*Connection, error)

v0.10.3

Nov 14, 2024

Changes in this version

+ type Documentation struct

+ BaseURL string

+ URLs []string

+ func NewDocumentation(URLS ...string) *Documentation

+ func (d *Documentation) Init(ctx context.Context, fs afs.Service, substitutes Substitutes) error

type Resource

+ func (r *Resource) RepositoryURL() string

v0.10.2

Nov 13, 2024

v0.10.1

Nov 13, 2024

Changes in this version

type Option

+ func WithFSEmbedder(embeder *state.FSEmbedder) Option

type Resource

+ FSEmbedder *state.FSEmbedder

v0.10.0

Nov 12, 2024

Changes in this version

type Field

+ Example string

v0.9.15

Nov 7, 2024

v0.9.14

Oct 30, 2024

v0.9.13

Oct 7, 2024

v0.9.12

Oct 3, 2024

Changes in this version

type Resource

+ func (r *Resource) UpdateTime(ctx context.Context, URL string) error

v0.9.11

Oct 2, 2024

v0.9.10

Sep 27, 2024

Changes in this version

type Resource

+ func (r *Resource) ExpandSubstitutes(text string) string

+ func (r *Resource) Lock()

+ func (r *Resource) ReverseSubstitutes(text string) string

+ func (r *Resource) Unlock()

v0.9.9

Sep 27, 2024

Changes in this version

type View

+ func (v *View) DBProvider(name string) (*sql.DB, error)

v0.9.8

Sep 12, 2024

v0.9.7

Sep 5, 2024

Changes in this version

type View

+ TypeName string

v0.9.6

Aug 18, 2024

v0.9.5

Aug 16, 2024

v0.9.4

Aug 16, 2024

v0.9.3

Aug 13, 2024

v0.9.2

Aug 13, 2024

v0.9.1

Aug 8, 2024

Changes in this version

type ColumnConfig

+ func (c *ColumnConfig) IgnoreColumn() bool

type Columns

+ func (c Columns) Dedupe() Columns

type Option

+ func WithViewTag(tag string) Option

type View

+ Tag string

v0.9.0

Jul 25, 2024

Changes in this version

type Resource

+ func (r *Resource) ViewSchemaPointer(ctx context.Context, name string) (*state.Schema, error)

type TypeDefinition

+ func (d TypeDefinition) SimplePackage() string

v0.8.11

Jul 12, 2024

v0.8.10

Jul 11, 2024

Changes in this version

+ const ResourceMBus

type Resource

+ func (r *Resource) MBusResourceByName() MessageBuses

v0.8.9

Jul 10, 2024

v0.8.0

Jul 10, 2024

Changes in this version

+ const AsyncJobsTable

+ const AsyncTagName

+ const ContentFormat

+ const CriteriaQuery

+ const FieldsQuery

+ const LimitQuery

+ const ModeExec

+ const ModeHandler

+ const ModeQuery

+ const ModeUnspecified

+ const OffsetQuery

+ const OrderByQuery

+ const PageQuery

+ const ResourceConnectors

+ const ResourceConstants

+ const SyncFlag

+ var ContextKey = contextKey("view")

+ var QueryStateParameters = &Config

+ func BuildPresenceType(parameters []*state.Parameter) (reflect.Type, error)

+ func ColumnsSchema(caseFormat text.CaseFormat, columns []*Column, relations []*Relation, v *View) func() (reflect.Type, error)

+ func ColumnsSchemaDocumented(caseFormat text.CaseFormat, columns []*Column, relations []*Relation, v *View, ...) func() (reflect.Type, error)

+ func DefaultTypeName(name string) string

+ func Description(paramName, viewName string) string

+ func NewMapBasedDoc(types *TypesDoc) docs.Service

+ func ParamType(name string) reflect.Type

+ func SummaryViewKey(ownerName, name string) string

+ type AerospikeConfig struct

+ FailedRequestLimit int

+ MaxRetries int

+ ResetFailuresInMs int

+ SleepBetweenRetriesInMs int

+ SocketTimeoutInMs int

+ TotalTimeoutInMs int

type Batch

+ Size int

type BatchData

+ ColumnNames []string

+ Size int

+ func (b *BatchData) ColIn() []interface{}

+ func (b *BatchData) ColInBatch() []interface{}

type Cache

+ func NewRefCache(name string) *Cache

+ func (c *Cache) NewInput(selector *Statelet) *CacheInput

+ type Caches []*Cache

+ func (c Caches) Has(name string) bool

+ func (c Caches) Unique() []*Cache

+ func (r *Caches) Append(cache *Cache)

type Collector

+ func (r *Collector) Clone() *Collector

+ func (r *Collector) DestPtr() interface{}

+ func (r *Collector) ReadAll() bool

+ func (r *Collector) SetDest(dest interface{})

type Column

+ FormatTag *format.Tag

+ IndexedBy string

+ Tag string

+ func NewColumn(name, dataTypeName string, rType reflect.Type, nullable bool, ...) *Column

+ func (c *Column) ApplyConfig(config *ColumnConfig)

+ func (c *Column) CaseFormat() text.CaseFormat

+ func (c *Column) EnsureFormatTag()

+ func (c *Column) EnsureType(lookupType xreflect.LookupType) error

+ func (c *Column) Field() *reflect.StructField

+ func (c *Column) SetColumnType(rType reflect.Type)

+ func (c *Column) SetField(field reflect.StructField)

+ func (c *Column) TimeLayout() string

type ColumnConfig

+ Default *string

+ IgnoreCaseFormatter *bool

+ Required *bool

+ Tag *string

+ type ColumnConfigs []*ColumnConfig

+ func (c ColumnConfigs) Index() NamedColumnConfig

+ type ColumnOption func(c *Column)

+ func WithColumnTag(tag string) ColumnOption

type Columns

+ func NewColumns(columns sqlparser.Columns) Columns

+ func (c Columns) ApplyConfig(configs map[string]*ColumnConfig, lookupType xreflect.LookupType) error

type Config

+ ContentFormatParameter *state.Parameter

+ CriteriaParameter *state.Parameter

+ FieldsParameter *state.Parameter

+ LimitParameter *state.Parameter

+ NoLimit bool

+ OffsetParameter *state.Parameter

+ OrderByParameter *state.Parameter

+ PageParameter *state.Parameter

+ SyncFlagParameter *state.Parameter

+ func (c *Config) Clone() *Config

+ func (c *Config) CloneWithNs(ctx context.Context, resource *Resource, owner *View, ns string) (*Config, error)

+ func (c *Config) GetContentFormatParameter() *state.Parameter

+ func (c *Config) GetSyncFlagParameter() *state.Parameter

type Connector

+ func DecodeConnectors(connectors []string) ([]*Connector, error)

+ func NewConnector(name, driver, dsn string, opts ...ConnectorOption) *Connector

+ func NewRefConnector(name string) *Connector

+ func (c *Connector) Dialect(ctx context.Context) (*info.Dialect, error)

+ type ConnectorOption func(c *Connector)

+ func WithDbConfig(dbConfig *DBConfig) ConnectorOption

+ func WithSecret(secret *scy.Resource) ConnectorOption

type ConnectorSlice

+ func (c ConnectorSlice) IndexInto(result *Connectors)

type Constraints

+ Page *bool

+ func (c *Constraints) IsPageEnabled() bool

type CriteriaParam

+ WhereClauseParameters []interface{}

type DBConfig

+ DSN string

+ Driver string

+ Name string

+ Secret *scy.Resource

+ type Docs struct

+ ConnectorName string

+ DefaultPkg string

+ Name string

+ Types *TypesDoc

+ URL string

+ func (d *Docs) Init(ctx context.Context, registry *docs.Registry, connectors Connectors) error

+ type EncodedConnector string

+ func (c EncodedConnector) Decode() (*Connector, error)

type Field

+ Description string

+ Ptr bool

+ type Link struct

+ Column string

+ Field string

+ IncludeColumn *bool

+ Namespace string

+ func WithLink(field, column string) *Link

+ func (l *Link) EncodeLinkTag() string

+ func (l *Link) Init()

+ func (l *Link) Validate() error

+ type Links []*Link

+ func JoinOn(links ...*Link) Links

+ func (l Links) InColumnExpression() []string

+ func (l Links) Init(name string, v *View) error

+ func (l Links) Namespace() string

+ func (l Links) Validate() error

+ type MapBasedDoc struct

+ func (m *MapBasedDoc) Lookup(ctx context.Context, key string) (string, bool, error)

type MatchStrategy

+ func (s MatchStrategy) ReadAll() bool

+ type MessageBusSlice []*mbus.Resource

+ func (m MessageBusSlice) Index() MessageBuses

+ type MessageBuses map[string]*mbus.Resource

+ func (m MessageBuses) Lookup(name string) (*mbus.Resource, error)

+ type MetaKind string

+ const MetaKindHeader

+ const MetaKindRecord

type Metrics

+ Method string

+ type NamedColumnConfig map[string]*ColumnConfig

+ type NamedColumns map[string]*Column

+ func (c NamedColumns) Column(name string) (codec.Column, bool)

+ func (c NamedColumns) ColumnName(key string) (string, error)

+ func (c NamedColumns) Lookup(name string) (*Column, error)

+ func (c NamedColumns) Register(caseFormat text.CaseFormat, column *Column)

+ func (c NamedColumns) RegisterHolder(columnName, holder string) error

+ func (c NamedColumns) RegisterWithName(name string, column *Column)

+ type NamedResources map[string]*Resource

+ type NamedViews map[string]*View

+ func (v *NamedViews) Register(view *View)

+ func (v NamedViews) Lookup(viewName string) (*View, error)

+ type NamespaceView struct

+ Namespaces []string

+ Path string

+ Root bool

+ View *View

+ func (n *NamespaceView) SelectorParameters(parameter *state.Parameter, rootParameter *state.Parameter) []*state.Parameter

+ type NamespacedView struct

+ Views []*NamespaceView

+ func IndexViews(aView *View) *NamespacedView

+ func (n *NamespacedView) ByName(ns string) *NamespaceView

+ func (n *NamespacedView) ByNamespace(ns string) *NamespaceView

+ func (n *NamespacedView) Parameters() state.NamedParameters

type Option

+ func WithBatchSize(size int) Option

+ func WithColumns(columns Columns) Option

+ func WithConnector(connector *Connector) Option

+ func WithConnectorRef(ref string) Option

+ func WithCriteria(columns ...string) Option

+ func WithDBConfig(dbConfig *DBConfig) Option

+ func WithFS(fs *embed.FS) Option

+ func WithLimit(limit *int) Option

+ func WithMatchStrategy(match string) Option

+ func WithMode(mode Mode) Option

+ func WithOneToMany(holder string, on Links, ref *ReferenceView, opts ...RelationOption) Option

+ func WithOneToOne(holder string, on Links, ref *ReferenceView, opts ...RelationOption) Option

+ func WithPartitioned(partitioned *Partitioned) Option

+ func WithReinitialize() Option

+ func WithResource(resource state.Resource) Option

+ func WithSQL(SQL string, parameters ...*state.Parameter) Option

+ func WithSchema(schema *state.Schema) Option

+ func WithStructTag(tag reflect.StructTag, fs *embed.FS) Option

+ func WithTag(aTag *tags.Tag) Option

+ func WithTemplate(template *Template) Option

+ func WithTransforms(transforms marshal.Transforms) Option

+ func WithViewKind(mode Mode) Option

+ func WithViewType(t reflect.Type, options ...state.SchemaOption) Option

+ type Options []Option

+ func (o Options) Apply(aView *View) error

+ type PackagedType struct

+ Name string

+ Package string

+ func NewPackagedType(pkg string, name string, t reflect.Type) *PackagedType

+ func (p *PackagedType) TypeName() string

+ type Partitioned struct

+ Arguments []string

+ Concurrency int

+ DataType string

+ func NewPartitioned(paritioner Partitioner, concurrency int, args ...string) *Partitioned

+ func (p *Partitioned) Partitioner() Partitioner

+ func (p *Partitioned) SetPartitioner(partitioner Partitioner)

+ type Partitioner interface

+ Partitions func(ctx context.Context, db *sql.DB, aView *View) *Partitions

+ type Partitions struct

+ Expression string

+ Partition []interface{}

+ Partitions [][]interface{}

+ Table string

+ type PredicateEvaluator struct

+ func (e *PredicateEvaluator) Compute(ctx context.Context, value interface{}) (*codec.Criteria, error)

+ func (e *PredicateEvaluator) Evaluate(ctx *expand.Context, state *structology.State, value interface{}) (*expand.State, error)

+ type QuerySelector struct

+ Columns []string

+ Criteria string

+ DatabaseFormat text.CaseFormat

+ Fields []string

+ Ignore bool

+ Limit int

+ Offset int

+ OrderBy string

+ OutputFormat text.CaseFormat

+ Page int

+ Placeholders []interface{}

+ func (s *QuerySelector) Add(fieldName string, isHolder bool)

+ func (s *QuerySelector) CurrentLimit() int

+ func (s *QuerySelector) CurrentOffset() int

+ func (s *QuerySelector) CurrentPage() int

+ func (s *QuerySelector) Has(field string) bool

+ func (s *QuerySelector) SetCriteria(expanded string, placeholders []interface{})

+ type QuerySettings struct

+ ContentFormat string

+ SyncFlag bool

+ type Reducer interface

+ Reduce func(slice interface{}) interface{}

+ type ReducerProvider interface

+ Reducer func(ctx context.Context) Reducer

type ReferenceView

+ On Links

+ func NewReferenceView(links Links, view *View) *ReferenceView

type Relation

+ Caser text.CaseFormat

+ On Links

+ func (r *Relation) TagLink() tags.LinkOn

+ type RelationOption func(r *Relation)

type Resource

+ Docs *Docs

+ MessageBuses []*mbus.Resource

+ Predicates []*predicate.Template

+ Substitutes Substitutes

+ func (r *Resource) AddConnector(name string, driver string, dsn string, opts ...ConnectorOption) *Connector

+ func (r *Resource) AddMessageBus(messageBuses ...*mbus.Resource)

+ func (r *Resource) CodecByName(name string) (*codec.Codec, bool)

+ func (r *Resource) Connector(name string) (*Connector, error)

+ func (r *Resource) Doc() (docs.Service, bool)

+ func (r *Resource) ExistsConnector(name string) bool

+ func (r *Resource) IndexViews()

+ func (r *Resource) LookupParameter(name string) (*state.Parameter, error)

+ func (r *Resource) LookupType() xreflect.LookupType

+ func (r *Resource) MessageBus(name string) (*mbus.Resource, error)

+ func (r *Resource) NamedParameters() state.NamedParameters

+ func (r *Resource) ParamByName(name string) (*state.Parameter, error)

+ func (r *Resource) SetCodecs(codecs *codec.Registry)

+ func (r *Resource) SetFs(fs afs.Service)

+ func (r *Resource) TypeRegistry() *xreflect.Types

+ func (r *Resource) ViewSchema(ctx context.Context, name string) (*state.Schema, error)

+ type ResourceOptions struct

+ Codecs *codec.Registry

+ Columns map[string]Columns

+ Docs *docs.Registry

+ Metrics *Metrics

+ Predicates *extension.PredicateRegistry

+ TransformsIndex marshal.TransformIndex

+ Types *xreflect.Types

+ type Resourcelet struct

+ func NewResources(resource *Resource, view *View) *Resourcelet

+ func (r *Resourcelet) AppendParameter(parameter *state.Parameter)

+ func (r *Resourcelet) CodecOptions() *codec.Options

+ func (r *Resourcelet) Codecs() *codec.Registry

+ func (r *Resourcelet) ExpandSubstitutes(text string) string

+ func (r *Resourcelet) LookupParameter(name string) (*state.Parameter, error)

+ func (r *Resourcelet) ReverseSubstitutes(text string) string

+ func (r Resourcelet) IndexedColumns() NamedColumns

type SelectorParameter

+ SyncFlag string

+ type State struct

+ Views map[string]*Statelet

+ func NewState() *State

+ func (s *State) Init(aView *View)

+ func (s *State) Lookup(view *View) *Statelet

+ func (s *State) QuerySelector(view *View) *QuerySelector

+ func (s *State) QuerySettings(view *View) *QuerySettings

+ type Statelet struct

+ Template *structology.State

+ func NewStatelet() *Statelet

+ func (s *Statelet) IgnoreRead()

+ func (s *Statelet) Init(aView *View)

+ type Substitutes map[string]string

+ func (s Substitutes) Keys() []string

+ func (s Substitutes) Replace(text string) string

+ func (s Substitutes) ReverseReplace(text string) string

type Template

+ Summary *TemplateSummary

+ func NewTemplate(source string, opts ...TemplateOption) *Template

+ func (t *Template) EvaluateState(parameterState *structology.State, parentParam *expand.ViewContext, ...) (*expand.State, error)

+ func (t *Template) EvaluateStateWithSession(parameterState *structology.State, parentParam *expand.ViewContext, ...) (*expand.State, error)

+ func (t *Template) EvaluatorStateType() reflect.Type

+ func (t *Template) Package() string

+ func (t *Template) StateType() *structology.StateType

+ type TemplateOption func(t *Template)

+ func WithTemplateParameters(parameters ...*state.Parameter) TemplateOption

+ func WithTemplateSchema(schema *state.Schema) TemplateOption

+ type TemplateSummary struct

+ Cardinality state.Cardinality

+ Columns Columns

+ Kind MetaKind

+ Name string

+ Schema *state.Schema

+ Source string

+ SourceURL string

+ func (m *TemplateSummary) EnsureSchema()

+ func (m *TemplateSummary) Evaluate(parameterState *structology.State, viewParam *expand.ViewContext) (string, []interface{}, error)

+ func (m *TemplateSummary) Init(ctx context.Context, owner *Template, resource *Resource) error

+ type TypeDefinition struct

+ Alias string

+ Cardinality state.Cardinality

+ CustomType bool

+ DataType string

+ Fields []*Field

+ ModulePath string

+ Name string

+ Package string

+ Ptr bool

+ Schema *state.Schema

+ func (d *TypeDefinition) AddField(field *Field)

+ func (d *TypeDefinition) Init(ctx context.Context, lookupType xreflect.LookupType) error

+ func (d *TypeDefinition) Type() reflect.Type

+ func (d *TypeDefinition) TypeName() string

+ type TypeDefinitions []*TypeDefinition

+ func (d TypeDefinitions) Exclude(candidates ...string) TypeDefinitions

+ type TypeDoc struct

+ Name string

+ Paths map[string]string

+ Pkg *string

+ type TypesDoc struct

+ DefaultPkg *string

+ Doc []*TypeDoc

type View

+ Description string

+ Module string

+ Partitioned *Partitioned

+ TableBatches map[string]bool

+ func Context(ctx context.Context) *View

+ func New(name, table string, opts ...Option) (*View, error)

+ func NewExecView(name, table string, template string, parameters []*state.Parameter, ...) *View

+ func NewRefView(ref string) *View

+ func NewView(name, table string, opts ...Option) *View

+ func (c *View) TypeDefinitions() []*TypeDefinition

+ func (v *View) BuildParametrizedSQL(aState state.Parameters, types *xreflect.Types, SQL string, ...) (*sqlx.SQL, error)

+ func (v *View) ComponentType() reflect.Type

+ func (v *View) Context(ctx context.Context) context.Context

+ func (v *View) EnsureTemplate()

+ func (v *View) GetResource() *Resource

+ func (v *View) GetSchema(ctx context.Context) (*state.Schema, error)

+ func (v *View) InputParameters() state.Parameters

+ func (v *View) LookupRelation(name string) (*Relation, error)

+ func (v *View) OutputType() reflect.Type

+ func (v *View) Resource() state.Resource

+ func (v *View) ResultLimit() int

+ func (v *View) SetNamedType(aType reflect.Type)

+ func (v *View) SetParameter(name string, selectors *State, value interface{}) error

+ func (v *View) SetResource(resource *Resource)

+ func (v *View) TableAlias() string

+ func (v *View) TableName() string

+ func (v *View) ViewName() string

+ func (v *View) Warmup() *Warmup

type Views

+ func (v Views) EnsureResource(r *Resource)

+ func (v Views) Index() NamedViews

+ func (v Views) Init(ctx context.Context, resource *Resource, transforms marshal.TransformIndex) error

+ type VisitorFn func(value interface{}) error

type Warmup

+ Connector *Connector

v0.2.14

Sep 2, 2022

v0.2.11

Sep 1, 2022

Changes in this version

+ const Logger

+ const SQLExecMode

+ const SQLQueryMode

+ var AerospikeConnectionTimeoutInS = 5

+ var PingTimeInS = 15

+ func BuildTree(schemaType reflect.Type, slice *xunsafe.Slice, nodes interface{}, ...) interface

+ func ExpandWithFalseCondition(source string) string

+ func GetOrParseType(types Types, dataType string) (reflect.Type, error)

+ func NotEmptyOf(values ...string) string

+ func NotZeroOf(values ...int) int

+ func ResetConnectionConfig()

type Accessor

+ func (a *Accessor) Values(values interface{}, indexes ...int) ([]interface{}, error)

type Accessors

+ func NewAccessors() *Accessors

+ func (a *Accessors) Init(rType reflect.Type)

type Cache

+ Warmup *Warmup

+ func (c *Cache) GenerateCacheInput(ctx context.Context) ([]*CacheInput, error)

+ type CacheInput struct

+ Column string

+ IndexMeta bool

+ MetaColumn string

+ Selector *Selector

+ type CacheInputFn func() ([]*CacheInput, error)

+ type CacheParameters struct

+ Set []*ParamValue

type Collector

+ func (r *Collector) AddMeta(row interface{}) error

+ func (r *Collector) OnSkip(_ []interface{}) error

+ func (r *Collector) ViewMetaHandler(rel *Relation) (func(viewMeta interface{}) error, error)

type Column

+ DatabaseColumn string

type Config

+ Namespace string

+ PageParam *Parameter

+ Parameters *SelectorParameter

+ func (c *Config) ParameterName(ns, paramName string) string

+ type CriteriaParam struct

+ ColumnsIn string

+ Pagination string

+ WhereClause string

type CriteriaSanitizer

+ Mock bool

+ ParamsGroup []interface{}

+ PlaceholderCounter int

+ TemplateSQL string

+ func Evaluate(evaluator *Evaluator, schemaType reflect.Type, ...) (string, *CriteriaSanitizer, *logger.Printer, error)

+ func NewMockSanitizer() *CriteriaSanitizer

+ func (p *CriteriaSanitizer) Add(_ int, value interface{}) string

+ func (p *CriteriaSanitizer) AppendBinding(value interface{}) string

+ func (p *CriteriaSanitizer) At(_ int) []interface{}

+ func (p *CriteriaSanitizer) Insert() (string, []interface{})

+ func (p *CriteriaSanitizer) Next() (interface{}, error)

type DBConfig

+ TimeoutTime int

+ type ExpanderFn func(placeholders *[]interface{}, SQL string, selector *Selector, ...) (string, error)

type Location

+ func NewQueryLocation(name string) *Location

+ type MetaParam struct

+ Alias string

+ Args []interface{}

+ Limit int

+ Name string

+ NonWindowSQL string

+ Offset int

+ Page int

+ Table string

+ func AsViewParam(aView *View, aSelector *Selector, options ...interface{}) *MetaParam

+ func (m *MetaParam) Expand(sanitizer *CriteriaSanitizer) string

+ type Mode string

+ type NodeIndex map[interface{}]map[interface{}]bool

+ func (i NodeIndex) Get(id interface{}) map[interface{}]bool

+ type ParamValue struct

+ Name string

+ Values []interface{}

type Parameter

+ DataType string

+ MaxAllowedRecords *int

+ func (p *Parameter) ActualParamType() reflect.Type

type Selector

+ Page int

+ type SelectorParameter struct

+ Criteria string

+ Fields string

+ Limit string

+ Offset string

+ OrderBy string

+ Page string

+ type SelfReference struct

+ Child string

+ Holder string

+ Parent string

type Template

+ Meta *TemplateMeta

+ type TemplateEvaluation struct

+ Args []interface{}

+ Evaluated bool

+ Expander ExpanderFn

+ SQL string

+ type TemplateMeta struct

+ Cardinality Cardinality

+ Kind TemplateMetaKind

+ Name string

+ Schema *Schema

+ Source string

+ SourceURL string

+ func (m *TemplateMeta) Evaluate(selectorValues interface{}, selectorPresence interface{}, viewParam *MetaParam) (string, []interface{}, error)

+ func (m *TemplateMeta) Init(ctx context.Context, owner *Template, resource *Resource) error

+ type TemplateMetaKind string

+ const HeaderTemplateMetaKind

+ const RecordTemplateMetaKind

type View

+ Mode Mode

+ SelfReference *SelfReference

+ func (v *View) AreNullValuesAllowed() bool

+ func (v *View) MetaTemplateEnabled() bool

+ func (v *View) ParamByName(name string) (*Parameter, error)

+ type Warmup struct

+ Cases []*CacheParameters

+ IndexColumn string

+ IndexMeta bool

v0.2.7

Jul 27, 2022

Changes in this version

+ func ResetAerospikePool()

+ func ResetDBPool()

type Cache

+ Name string

+ Provider string

+ type CacheType string

type Collector

+ func (r *Collector) Len() int

type Connector

+ func (c *Connector) DB(ctx context.Context) (*sql.DB, error)

+ type DBConfig struct

+ ConnMaxIdleTimeMs int

+ ConnMaxLifetimeMs int

+ MaxIdleConns int

+ MaxOpenConns int

+ func (c *DBConfig) ConnMaxIdleTime() time.Duration

+ func (c *DBConfig) ConnMaxLifetime() time.Duration

type Resource

+ CacheProviders []*Cache

+ func (r *Resource) CacheProvider(ref string) (*Cache, bool)

v0.2.6

Jul 20, 2022

v0.2.5

Jul 19, 2022

Changes in this version

+ type BatchData struct

+ ColumnName string

+ Parent int

+ ParentReadSize int

+ Values []interface{}

+ ValuesBatch []interface{}

type Column

+ func DetectColumns(ctx context.Context, resource *Resource, v *View) ([]*Column, string, error)

type ColumnConfig

+ Format *string

type Parameter

+ DateFormat string

+ ErrorStatusCode int

type Template

+ func (t *Template) Expand(placeholders *[]interface{}, SQL string, selector *Selector, ...) (string, error)

type View

+ func (v *View) Expand(placeholders *[]interface{}, SQL string, selector *Selector, ...) (string, error)

v0.2.4

Jul 14, 2022

v0.2.3

Jul 14, 2022

v0.2.2

Jul 13, 2022

Changes in this version

+ var Now = time.Now

+ type Cache struct

+ Location string

+ PartSize int

+ Size int

+ TimeToLiveMs int

+ func (c *Cache) Service() *cache.Service

type Column

+ Codec *Codec

+ type ColumnConfig struct

+ Codec *Codec

+ DataType *string

+ Expression *string

+ Name string

type Constraints

+ Projection bool

+ SQLMethods []*Method

+ type Namer interface

+ Names func(rField reflect.StructField) []string

type Resource

+ func (r *Resource) VisitorByName(name string) (codec.LifecycleVisitor, bool)

type Schema

+ Cardinality Cardinality

+ type SqlxNamer struct

+ func (s *SqlxNamer) Names(rField reflect.StructField) []string

+ type VeltyNamer struct

+ func (v *VeltyNamer) Names(rField reflect.StructField) []string

type View

+ Cache *Cache

+ ColumnsConfig map[string]*ColumnConfig

+ func (v *View) CanUseSelectorProjection() bool

+ func (v *View) DatabaseType() reflect.Type

+ func (v *View) UnwrapDatabaseType(ctx context.Context, value interface{}) (interface{}, error)

v0.2.1

Jul 2, 2022

Changes in this version

+ const SafeBool

+ const SafeColumn

+ const SafeFloat

+ const SafeInt

+ const SafeString

+ const SafeValue

+ const VeltyCriteriaCodec

+ func DetectCase(data ...string) string

+ func ParseType(dataType string) (reflect.Type, error)

type Accessors

+ func (a *Accessors) AccessorByName(name string) (*Accessor, error)

type Codec

+ Schema *Schema

+ Source string

+ SourceURL string

+ func (v *Codec) Transform(ctx context.Context, raw string, options ...interface{}) (interface{}, error)

type Column

+ func (c *Column) ColumnType() reflect.Type

+ type ColumnIndex map[string]*Column

+ func (c ColumnIndex) Lookup(name string) (*Column, error)

+ func (c ColumnIndex) Register(caser format.Case, column *Column)

+ func (c ColumnIndex) RegisterHolder(relation *Relation) error

+ func (c ColumnIndex) RegisterWithName(name string, column *Column)

type Columns

+ func (c Columns) Index(caser format.Case) ColumnIndex

+ func (c Columns) Init(caser format.Case, allowNulls bool) error

type Config

+ CriteriaParam *Parameter

+ FieldsParam *Parameter

+ LimitParam *Parameter

+ OffsetParam *Parameter

+ OrderByParam *Parameter

+ func (c *Config) Init(ctx context.Context, resource *Resource, parent *View) error

type Constraints

+ SqlMethods []*Method

+ func (c *Constraints) SqlMethodsIndexed() map[string]*Method

+ type CriteriaSanitizer struct

+ Columns ColumnIndex

+ Placeholders []interface{}

+ func NewCriteria(columns ColumnIndex) *CriteriaSanitizer

+ func (c *CriteriaSanitizer) AsBinding(value interface{}) string

+ func (c *CriteriaSanitizer) AsColumn(columnName string) (string, error)

type Evaluator

+ func NewEvaluator(paramSchema, presenceSchema reflect.Type, template string, ...) (*Evaluator, error)

+ func (e *Evaluator) Evaluate(schemaType reflect.Type, externalParams, presenceMap interface{}, ...) (string, error)

type Field

+ Cardinality Cardinality

+ FromName string

+ Tag string

type Kind

+ const EnvironmentKind

+ type Method struct

+ Args []*Schema

+ Name string

type Parameter

+ Positions []int

type ReferenceView

+ Field string

type Resource

+ ModTime time.Time

+ func (r *Resource) LoadObject(ctx context.Context, URL string) (storage.Object, error)

+ func (r *Resource) TypeName(p reflect.Type) (string, bool)

+ type Sanitizer struct

type Selector

+ DatabaseFormat format.Case

+ OutputFormat format.Case

+ Placeholders []interface{}

+ func NewSelector() *Selector

+ func (s *Selector) Add(fieldName string, isHolder bool)

type Selectors

+ Index map[string]*Selector

type Template

+ func (t *Template) IsActualTemplate() bool

+ type VeltyCodec struct

+ func NewVeltyCodec(template string, paramType reflect.Type, view *View) (*VeltyCodec, error)

+ func (v *VeltyCodec) Value(ctx context.Context, raw string, options ...interface{}) (interface{}, error)

type View

+ AllowNulls *bool

+ DiscoverCriteria *bool

+ UseBindingPositions *bool

+ func (v *View) ShouldTryDiscover() bool

+ func (v *View) UseParamBindingPositions() bool

v0.2.0

May 25, 2022

Changes in this version

+ const AndPrefix

+ const ColumnsIn

+ const Criteria

+ const OrPrefix

+ const Pagination

+ const WhereCriteria

+ const WherePrefix

+ func TemplateField(name string, rType reflect.Type) (reflect.StructField, error)

+ type Accessor struct

+ func (a *Accessor) Value(values interface{}) (interface{}, error)

+ type Accessors struct

+ type Batch struct

+ Parent int

+ type Cardinality string

+ const Many

+ const One

+ type CaseFormat string

+ const Lower

+ const LowerCamel

+ const LowerCamelShort

+ const LowerShort

+ const LowerUnderscore

+ const LowerUnderscoreShort

+ const Upper

+ const UpperCamel

+ const UpperCamelShort

+ const UpperShort

+ const UpperUnderscore

+ const UpperUnderscoreShort

+ func (f *CaseFormat) Init() error

+ func (f CaseFormat) Caser() (format.Case, error)

+ type Codec struct

+ Name string

+ func (v *Codec) Init(resource *Resource, paramType reflect.Type) error

+ type CodecFn func(context context.Context, rawValue string) (interface{}, error)

+ type Collector struct

+ func NewCollector(slice *xunsafe.Slice, view *View, dest interface{}, supportParallel bool) *Collector

+ func (r *Collector) Dest() interface{}

+ func (r *Collector) Fetched()

+ func (r *Collector) Lock() *sync.Mutex

+ func (r *Collector) MergeData()

+ func (r *Collector) NewItem() func() interface{}

+ func (r *Collector) ParentPlaceholders() ([]interface{}, string)

+ func (r *Collector) Relation() *Relation

+ func (r *Collector) Relations(selector *Selector) []*Collector

+ func (r *Collector) Resolve(column io.Column) func(ptr unsafe.Pointer) interface{}

+ func (r *Collector) Slice() (unsafe.Pointer, *xunsafe.Slice)

+ func (r *Collector) SupportsParallel() bool

+ func (r *Collector) View() *View

+ func (r *Collector) Visitor() Visitor

+ func (r *Collector) WaitIfNeeded()

+ type Column struct

+ DataType string

+ Default string

+ Expression string

+ Filterable bool

+ Format string

+ Name string

+ Nullable bool

+ func (c *Column) ColumnName() string

+ func (c *Column) FieldName() string

+ func (c *Column) Init(caser format.Case) error

+ func (c *Column) Kind() sql.Kind

+ func (c *Column) SqlExpression() string

+ type ColumnSlice []*Column

+ func (c ColumnSlice) Index(caser format.Case) Columns

+ func (c ColumnSlice) Init(caser format.Case) error

+ type Columns map[string]*Column

+ func (c Columns) Lookup(name string) (*Column, error)

+ func (c Columns) Register(caser format.Case, column *Column)

+ func (c Columns) RegisterHolder(relation *Relation) error

+ func (c Columns) RegisterWithName(name string, column *Column)

+ type CommonParams struct

+ ColumnsIn string

+ Pagination string

+ WhereClause string

+ type Config struct

+ Constraints *Constraints

+ Limit int

+ OrderBy string

+ type Connector struct

+ DSN string

+ Driver string

+ Name string

+ Secret *scy.Resource

+ func (c *Connector) Close() error

+ func (c *Connector) Db() (*sql.DB, error)

+ func (c *Connector) Init(ctx context.Context, connectors Connectors) error

+ func (c *Connector) Reset()

+ func (c *Connector) Validate() error

+ type ConnectorSlice []*Connector

+ func (c ConnectorSlice) Index() Connectors

+ func (c ConnectorSlice) Init(ctx context.Context, connectors Connectors) error

+ type Connectors map[string]*Connector

+ func (v *Connectors) Register(connector *Connector)

+ func (v Connectors) Lookup(name string) (*Connector, error)

+ type Constraints struct

+ Criteria bool

+ Filterable []string

+ Limit bool

+ Offset bool

+ OrderBy bool

+ type Definition struct

+ Fields []*Field

+ Name string

+ func (d *Definition) Init(ctx context.Context, types Types) error

+ type Evaluator struct

+ type Field struct

+ Column string

+ Embed bool

+ Fields []*Field

+ Name string

+ Schema *Schema

+ func (f *Field) Init(ctx context.Context, types Types) error

+ type Kind string

+ const CookieKind

+ const DataViewKind

+ const HeaderKind

+ const PathKind

+ const QueryKind

+ const RequestBodyKind

+ func (k Kind) Validate() error

+ type Location struct

+ Kind Kind

+ Name string

+ func (l *Location) Validate() error

+ type MatchStrategy string

+ const ReadAll

+ const ReadDerived

+ const ReadMatched

+ func (s MatchStrategy) SupportsParallel() bool

+ func (s MatchStrategy) Validate() error

+ type Metrics struct

+ URIPart string

+ type Names []string

+ func (c Names) Index() map[string]bool

+ type Option interface

+ type Param struct

+ Alias string

+ Name string

+ Table string

+ type ParamName string

+ func (p ParamName) Validate(kind Kind) error

+ type ParamState struct

+ Has interface{}

+ Values interface{}

+ func (s *ParamState) Init(view *View)

+ type Parameter struct

+ Codec *Codec

+ Description string

+ In *Location

+ Name string

+ PresenceName string

+ Required *bool

+ Schema *Schema

+ Style string

+ func (p *Parameter) ConvertAndSet(ctx context.Context, paramPtr unsafe.Pointer, value string) error

+ func (p *Parameter) Init(ctx context.Context, resource *Resource, structType reflect.Type) error

+ func (p *Parameter) IsRequired() bool

+ func (p *Parameter) Set(ptr unsafe.Pointer, value interface{}) error

+ func (p *Parameter) SetAccessor(accessor *Accessor)

+ func (p *Parameter) SetPresenceField(structType reflect.Type) error

+ func (p *Parameter) UpdatePresence(presencePtr unsafe.Pointer)

+ func (p *Parameter) Validate() error

+ func (p *Parameter) Value(values interface{}) (interface{}, error)

+ func (p *Parameter) View() *View

+ type ParametersIndex map[string]*Parameter

+ func (p ParametersIndex) Lookup(paramName string) (*Parameter, error)

+ func (p ParametersIndex) Register(parameter *Parameter)

+ type ParametersSlice []*Parameter

+ func (p ParametersSlice) Filter(kind Kind) ParametersIndex

+ func (p ParametersSlice) Index() ParametersIndex

+ type ReferenceView struct

+ Column string

+ func (r *ReferenceView) Init(_ context.Context, _ *Resource) error

+ func (r *ReferenceView) Validate() error

+ type Relation struct

+ Cardinality Cardinality

+ Column string

+ ColumnAlias string

+ Holder string

+ IncludeColumn bool

+ Name string

+ Of *ReferenceView

+ func (r *Relation) BeforeViewInit(ctx context.Context) error

+ func (r *Relation) Init(ctx context.Context, resource *Resource, parent *View) error

+ func (r *Relation) Validate() error

+ type RelationsSlice []*Relation

+ func (r RelationsSlice) Columns() []string

+ func (r RelationsSlice) Index() map[string]*Relation

+ func (r RelationsSlice) PopulateWithResolve() []*Relation

+ func (r RelationsSlice) PopulateWithVisitor() []*Relation

+ type Resource struct

+ Connectors []*Connector

+ Loggers logger.Adapters

+ Metrics *Metrics

+ Parameters []*Parameter

+ SourceURL string

+ Types []*Definition

+ Views []*View

+ func EmptyResource() *Resource

+ func LoadResourceFromURL(ctx context.Context, URL string, fs afs.Service) (*Resource, error)

+ func NewResource(types Types) *Resource

+ func NewResourceFromURL(ctx context.Context, url string, types Types, visitors visitor.Visitors) (*Resource, error)

+ func (r *Resource) AddConnectors(connectors ...*Connector)

+ func (r *Resource) AddLoggers(loggers ...*logger.Adapter)

+ func (r *Resource) AddParameters(parameters ...*Parameter)

+ func (r *Resource) AddViews(views ...*View)

+ func (r *Resource) ConnectorByName() map[string]*Connector

+ func (r *Resource) FindConnector(view *View) (*Connector, error)

+ func (r *Resource) GetConnectors() Connectors

+ func (r *Resource) GetTypes() Types

+ func (r *Resource) GetViews() Views

+ func (r *Resource) Init(ctx context.Context, types Types, visitors visitor.Visitors) error

+ func (r *Resource) LoadText(ctx context.Context, URL string) (string, error)

+ func (r *Resource) MergeFrom(resource *Resource, types Types)

+ func (r *Resource) SetTypes(types Types)

+ func (r *Resource) View(name string) (*View, error)

+ type Schema struct

+ DataType string

+ Name string

+ func NewSchema(compType reflect.Type) *Schema

+ func (c *Schema) AutoGen() bool

+ func (c *Schema) Init(columns []*Column, relations []*Relation, viewCaseFormat format.Case, ...) error

+ func (c *Schema) Slice() *xunsafe.Slice

+ func (c *Schema) SliceType() reflect.Type

+ func (c *Schema) Type() reflect.Type

+ func (c *Schema) XType() *xunsafe.Type

+ type Selector struct

+ Columns []string

+ Criteria string

+ Fields []string

+ Limit int

+ Offset int

+ OrderBy string

+ Parameters ParamState

+ func (s *Selector) Has(field string) bool

+ func (s *Selector) Init()

+ type Selectors map[string]*Selector

+ func (s Selectors) Init()

+ func (s Selectors) Lookup(view *View) *Selector

+ type Template struct

+ Parameters []*Parameter

+ PresenceSchema *Schema

+ Schema *Schema

+ Source string

+ SourceURL string

+ func (t *Template) AccessorByName(name string) (*Accessor, error)

+ func (t *Template) EvaluateCriteria(externalParams, presenceMap interface{}, parent *View) (string, error)

+ func (t *Template) EvaluateSource(externalParams, presenceMap interface{}, parent *View) (string, error)

+ func (t *Template) Init(ctx context.Context, resource *Resource, view *View) error

+ type Types map[string]reflect.Type

+ func (r Types) Lookup(name string) (reflect.Type, error)

+ func (r Types) Register(name string, rType reflect.Type)

+ type View struct

+ Alias string

+ Batch *Batch

+ CaseFormat CaseFormat

+ Caser format.Case

+ Columns []*Column

+ Connector *Connector

+ Counter logger.Counter

+ Criteria string

+ Exclude []string

+ From string

+ FromURL string

+ InheritSchemaColumns bool

+ Logger *logger.Adapter

+ MatchStrategy MatchStrategy

+ Name string

+ Schema *Schema

+ Selector *Config

+ Standalone bool

+ Table string

+ Template *Template

+ With []*Relation

+ func ViewReference(name, ref string, options ...Option) *View

+ func (v *View) CanUseSelectorColumns() bool

+ func (v *View) CanUseSelectorCriteria() bool

+ func (v *View) CanUseSelectorLimit() bool

+ func (v *View) CanUseSelectorOffset() bool

+ func (v *View) CanUseSelectorOrderBy() bool

+ func (v *View) Collector(dest interface{}, supportParallel bool) *Collector

+ func (v *View) ColumnByName(name string) (*Column, bool)

+ func (v *View) DataType() reflect.Type

+ func (v *View) Db() (*sql.DB, error)

+ func (v *View) IndexedColumns() Columns

+ func (v *View) Init(ctx context.Context, resource *Resource) error

+ func (v *View) IsHolder(value string) bool

+ func (v *View) LimitWithSelector(selector *Selector) int

+ func (v *View) SelectedColumns(selector *Selector) ([]*Column, error)

+ func (v *View) Source() string

+ type ViewSlice []*View

+ func (v ViewSlice) Index() Views

+ func (v ViewSlice) Init(ctx context.Context, resource *Resource) error

+ type Views map[string]*View

+ func (v *Views) Register(view *View)

+ func (v Views) Lookup(viewName string) (*View, error)

+ type Visitor func(value interface{}) error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL