Versions in this module Expand all Collapse all v1 v1.1.0 Sep 28, 2026 Changes in this version type Execution + func (e *Execution) CacheViews() []string + func (e *Execution) InvalidateCache(ctx context.Context, view, scope string) ([]dexec.CacheInvalidation, error) v1.0.0 Sep 22, 2026 Changes in this version + const ViewDependencyKind + type Config struct + Component *spec.Component + InputType reflect.Type + OutputType reflect.Type + Plan *Plan + ReadCaches map[*data.View]cache.Cache + SQL *dsql.SQLComponent + type Execution struct + func NewExecution(config Config, options ...Option) (*Execution, error) + func (e *Execution) PlanRead(ctx context.Context, input any, binder xhandler.Binder, ...) (*dexec.ReadPlan, error) + func (e *Execution) PrepareQuery(ctx context.Context, input any, binder xhandler.Binder, ...) (*dexec.PreparedQuery, error) + func (e *Execution) Read(ctx context.Context, input any, binder xhandler.Binder, ...) (any, error) + func (e *Execution) ReadResult(ctx context.Context, input any, binder xhandler.Binder, ...) (*ReadResult, error) + func (e *Execution) Warmup(ctx context.Context, invocation dexec.ReaderWarmupInvocation) (int, error) + func (e *Execution) WarmupTargets() []dexec.ReaderWarmupTarget + func (e *Execution) WithRecorder(recorder *observability.Recorder) dexec.Reader + type Option func(*Service) + func WithRelationFetchConcurrency(concurrency int) Option + type Output struct + Data any + DataPtr any + DataType reflect.Type + Metrics response.Metrics + Projection *readmeta.Result + type Plan struct + DirectOutput bool + OutputMetricsField string + OutputStatusField string + OutputViewField string + Root *ViewPlan + SelectorBindings []SelectorBindingPlan + ViewIndex *ViewIndex + func NewPlan(config PlanConfig) (*Plan, error) + func (p *Plan) Validate(outputType reflect.Type) error + func (p *Plan) ViewPlanFor(view *data.View) *ViewPlan + type PlanConfig struct + Codecs map[*data.View]*rowcodec.Plan + Collection *collector.Graph + Criteria map[*data.View]*criteria.Compiler + DirectOutput bool + OutputMetricsField string + OutputStatusField string + OutputViewField string + Partitioners map[*data.View]xreader.Partitioner + RootView *data.View + SelectorBindings []SelectorBindingPlan + Templates map[*data.View]sqltemplate.Evaluator + ViewIndex *ViewIndex + type ReadResult struct + Data any + Projection *readmeta.Result + type RelationPlan struct + Relation *data.Relation + Target *ViewPlan + type SelectorBindingPlan struct + FieldIndex []int + Property spec.SelectorProperty + View *data.View + type Service struct + func NewService(options ...Option) *Service + func (s *Service) Read(ctx context.Context, session *Session, input any, binder xhandler.Binder) (_ any, err error) + type Session struct + Artifact *Plan + CacheOnly bool + CollectProjection bool + Component *spec.Component + DryRun bool + InputType reflect.Type + OutputType reflect.Type + Parameters sqlx.ParameterResolver + QueryScope *sqlxread.QueryScope + ReadCaches map[*data.View]cache.Cache + RefreshCache bool + SQL *dsql.SQLComponent + func (s *Session) Init() error + type ViewDependency struct + Component *spec.Component + InputType reflect.Type + Name string + Plan *Plan + TargetType reflect.Type + type ViewIndex struct + func NewViewIndex(component *spec.Component, root *data.View) *ViewIndex + func (i *ViewIndex) Resolve(alias string) (*data.View, error) + type ViewPlan struct + Codec *rowcodec.Plan + Collector *collector.View + Connector string + Criteria *criteria.Compiler + Partitioner xreader.Partitioner + Relations []*RelationPlan + Template sqltemplate.Evaluator + View *data.View
Go to main page