vschemawrapper

Documentation

Index

• type VSchemaWrapper
  • func (vw *VSchemaWrapper) AllKeyspace() ([]*vindexes.Keyspace, error)
  • func (vw *VSchemaWrapper) AnyKeyspace() (*vindexes.Keyspace, error)
  • func (vw *VSchemaWrapper) ClearPrepareData(string)
  • func (vw *VSchemaWrapper) ConnCollation() collations.ID
  • func (vw *VSchemaWrapper) CurrentDb() string
  • func (vw *VSchemaWrapper) DefaultKeyspace() (*vindexes.Keyspace, error)
  • func (vw *VSchemaWrapper) Destination() key.Destination
  • func (vw *VSchemaWrapper) Environment() *vtenv.Environment
  • func (vw *VSchemaWrapper) ErrorIfShardedF(keyspace *vindexes.Keyspace, _, errFmt string, params ...any) error
  • func (vw *VSchemaWrapper) FindKeyspace(keyspace string) (*vindexes.Keyspace, error)
  • func (vw *VSchemaWrapper) FindRoutedShard(keyspace, shard string) (string, error)
  • func (vw *VSchemaWrapper) FindTable(tab sqlparser.TableName) (*vindexes.Table, string, topodatapb.TabletType, key.Destination, error)
  • func (vw *VSchemaWrapper) FindTableOrVindex(tab sqlparser.TableName) (*vindexes.Table, vindexes.Vindex, string, topodatapb.TabletType, ...)
  • func (vw *VSchemaWrapper) FindView(tab sqlparser.TableName) sqlparser.SelectStatement
  • func (vw *VSchemaWrapper) FirstSortedKeyspace() (*vindexes.Keyspace, error)
  • func (vw *VSchemaWrapper) ForeignKeyMode(keyspace string) (vschemapb.Keyspace_ForeignKeyMode, error)
  • func (vw *VSchemaWrapper) GetForeignKeyChecksState() *bool
  • func (vw *VSchemaWrapper) GetPrepareData(stmtName string) *vtgatepb.PrepareData
  • func (vw *VSchemaWrapper) GetSemTable() *semantics.SemTable
  • func (vw *VSchemaWrapper) GetSrvVschema() *vschemapb.SrvVSchema
  • func (vw *VSchemaWrapper) GetUDV(name string) *querypb.BindVariable
  • func (vw *VSchemaWrapper) GetVSchema() *vindexes.VSchema
  • func (vw *VSchemaWrapper) IsShardRoutingEnabled() bool
  • func (vw *VSchemaWrapper) IsViewsEnabled() bool
  • func (vw *VSchemaWrapper) KeyspaceError(keyspace string) error
  • func (vw *VSchemaWrapper) KeyspaceExists(keyspace string) bool
  • func (vw *VSchemaWrapper) PlanPrepareStatement(ctx context.Context, query string) (*engine.Plan, sqlparser.Statement, error)
  • func (vw *VSchemaWrapper) Planner() plancontext.PlannerVersion
  • func (vw *VSchemaWrapper) PlannerWarning(_ string)
  • func (vw *VSchemaWrapper) SetPlannerVersion(v plancontext.PlannerVersion)
  • func (vw *VSchemaWrapper) StorePrepareData(string, *vtgatepb.PrepareData)
  • func (vw *VSchemaWrapper) SysVarSetEnabled() bool
  • func (vw *VSchemaWrapper) TabletType() topodatapb.TabletType
  • func (vw *VSchemaWrapper) TargetDestination(qualifier string) (key.Destination, *vindexes.Keyspace, topodatapb.TabletType, error)
  • func (vw *VSchemaWrapper) TargetString() string
  • func (vw *VSchemaWrapper) WarnUnshardedOnly(_ string, _ ...any)

Types

type VSchemaWrapper

type VSchemaWrapper struct {
	V                     *vindexes.VSchema
	Keyspace              *vindexes.Keyspace
	TabletType_           topodatapb.TabletType
	Dest                  key.Destination
	SysVarEnabled         bool
	ForeignKeyChecksState *bool
	Version               plancontext.PlannerVersion
	EnableViews           bool
	TestBuilder           func(query string, vschema plancontext.VSchema, keyspace string) (*engine.Plan, error)
	Env                   *vtenv.Environment
}

func (*VSchemaWrapper) AllKeyspace

func (vw *VSchemaWrapper) AllKeyspace() ([]*vindexes.Keyspace, error)

func (*VSchemaWrapper) AnyKeyspace

func (vw *VSchemaWrapper) AnyKeyspace() (*vindexes.Keyspace, error)

func (*VSchemaWrapper) ClearPrepareData

func (vw *VSchemaWrapper) ClearPrepareData(string)

func (*VSchemaWrapper) ConnCollation

func (vw *VSchemaWrapper) ConnCollation() collations.ID

func (*VSchemaWrapper) CurrentDb

func (vw *VSchemaWrapper) CurrentDb() string

func (*VSchemaWrapper) DefaultKeyspace

func (vw *VSchemaWrapper) DefaultKeyspace() (*vindexes.Keyspace, error)

func (*VSchemaWrapper) Destination

func (vw *VSchemaWrapper) Destination() key.Destination

func (*VSchemaWrapper) Environment

func (vw *VSchemaWrapper) Environment() *vtenv.Environment

func (*VSchemaWrapper) ErrorIfShardedF

func (vw *VSchemaWrapper) ErrorIfShardedF(keyspace *vindexes.Keyspace, _, errFmt string, params ...any) error

func (*VSchemaWrapper) FindKeyspace

func (vw *VSchemaWrapper) FindKeyspace(keyspace string) (*vindexes.Keyspace, error)

FindKeyspace implements the VSchema interface

func (*VSchemaWrapper) FindRoutedShard

func (vw *VSchemaWrapper) FindRoutedShard(keyspace, shard string) (string, error)

func (*VSchemaWrapper) FindTable

func (vw *VSchemaWrapper) FindTable(tab sqlparser.TableName) (*vindexes.Table, string, topodatapb.TabletType, key.Destination, error)

func (*VSchemaWrapper) FindTableOrVindex

func (vw *VSchemaWrapper) FindTableOrVindex(tab sqlparser.TableName) (*vindexes.Table, vindexes.Vindex, string, topodatapb.TabletType, key.Destination, error)

func (*VSchemaWrapper) FindView

func (vw *VSchemaWrapper) FindView(tab sqlparser.TableName) sqlparser.SelectStatement

func (*VSchemaWrapper) FirstSortedKeyspace

func (vw *VSchemaWrapper) FirstSortedKeyspace() (*vindexes.Keyspace, error)

func (*VSchemaWrapper) ForeignKeyMode

func (vw *VSchemaWrapper) ForeignKeyMode(keyspace string) (vschemapb.Keyspace_ForeignKeyMode, error)

func (*VSchemaWrapper) GetForeignKeyChecksState

func (vw *VSchemaWrapper) GetForeignKeyChecksState() *bool

func (*VSchemaWrapper) GetPrepareData

func (vw *VSchemaWrapper) GetPrepareData(stmtName string) *vtgatepb.PrepareData

func (*VSchemaWrapper) GetSemTable

func (vw *VSchemaWrapper) GetSemTable() *semantics.SemTable

func (*VSchemaWrapper) GetSrvVschema

func (vw *VSchemaWrapper) GetSrvVschema() *vschemapb.SrvVSchema

func (*VSchemaWrapper) GetUDV

func (vw *VSchemaWrapper) GetUDV(name string) *querypb.BindVariable

func (*VSchemaWrapper) GetVSchema

func (vw *VSchemaWrapper) GetVSchema() *vindexes.VSchema

func (*VSchemaWrapper) IsShardRoutingEnabled

func (vw *VSchemaWrapper) IsShardRoutingEnabled() bool

func (*VSchemaWrapper) IsViewsEnabled

func (vw *VSchemaWrapper) IsViewsEnabled() bool

func (*VSchemaWrapper) KeyspaceError

func (vw *VSchemaWrapper) KeyspaceError(keyspace string) error

func (*VSchemaWrapper) KeyspaceExists

func (vw *VSchemaWrapper) KeyspaceExists(keyspace string) bool

func (*VSchemaWrapper) PlanPrepareStatement

func (vw *VSchemaWrapper) PlanPrepareStatement(ctx context.Context, query string) (*engine.Plan, sqlparser.Statement, error)

func (*VSchemaWrapper) Planner

func (vw *VSchemaWrapper) Planner() plancontext.PlannerVersion

func (*VSchemaWrapper) PlannerWarning

func (vw *VSchemaWrapper) PlannerWarning(_ string)

func (*VSchemaWrapper) SetPlannerVersion

func (vw *VSchemaWrapper) SetPlannerVersion(v plancontext.PlannerVersion)

SetPlannerVersion implements the ContextVSchema interface

func (*VSchemaWrapper) StorePrepareData

func (vw *VSchemaWrapper) StorePrepareData(string, *vtgatepb.PrepareData)

func (*VSchemaWrapper) SysVarSetEnabled

func (vw *VSchemaWrapper) SysVarSetEnabled() bool

func (*VSchemaWrapper) TabletType

func (vw *VSchemaWrapper) TabletType() topodatapb.TabletType

func (*VSchemaWrapper) TargetDestination

func (vw *VSchemaWrapper) TargetDestination(qualifier string) (key.Destination, *vindexes.Keyspace, topodatapb.TabletType, error)

func (*VSchemaWrapper) TargetString

func (vw *VSchemaWrapper) TargetString() string

func (*VSchemaWrapper) WarnUnshardedOnly

func (vw *VSchemaWrapper) WarnUnshardedOnly(_ string, _ ...any)