vschema

package
v0.21.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 29, 2024 License: Apache-2.0 Imports: 11 Imported by: 12

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	Keyspace_ForeignKeyMode_name = map[int32]string{
		0: "unspecified",
		1: "disallow",
		2: "unmanaged",
		3: "managed",
	}
	Keyspace_ForeignKeyMode_value = map[string]int32{
		"unspecified": 0,
		"disallow":    1,
		"unmanaged":   2,
		"managed":     3,
	}
)

Enum value maps for Keyspace_ForeignKeyMode.

View Source 
var File_vschema_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type AutoIncrement 

type AutoIncrement struct {
	Column string `protobuf:"bytes,1,opt,name=column,proto3" json:"column,omitempty"`
	// The sequence must match a table of type SEQUENCE.
	Sequence string `protobuf:"bytes,2,opt,name=sequence,proto3" json:"sequence,omitempty"`
	// contains filtered or unexported fields
}

Autoincrement is used to designate a column as auto-inc.

func (*AutoIncrement) CloneMessageVT added in v0.18.0 

func (m *AutoIncrement) CloneMessageVT() proto.Message

func (*AutoIncrement) CloneVT added in v0.18.0 

func (m *AutoIncrement) CloneVT() *AutoIncrement

func (*AutoIncrement) Descriptor deprecated 

func (*AutoIncrement) Descriptor() ([]byte, []int)

Deprecated: Use AutoIncrement.ProtoReflect.Descriptor instead.

func (*AutoIncrement) GetColumn 

func (x *AutoIncrement) GetColumn() string

func (*AutoIncrement) GetSequence 

func (x *AutoIncrement) GetSequence() string

func (*AutoIncrement) MarshalToSizedBufferVT added in v0.11.0 

func (m *AutoIncrement) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*AutoIncrement) MarshalToVT added in v0.11.0 

func (m *AutoIncrement) MarshalToVT(dAtA []byte) (int, error)

func (*AutoIncrement) MarshalVT added in v0.11.0 

func (m *AutoIncrement) MarshalVT() (dAtA []byte, err error)

func (*AutoIncrement) ProtoMessage 

func (*AutoIncrement) ProtoMessage()

func (*AutoIncrement) ProtoReflect added in v0.11.0 

func (x *AutoIncrement) ProtoReflect() protoreflect.Message

func (*AutoIncrement) Reset 

func (x *AutoIncrement) Reset()

func (*AutoIncrement) SizeVT added in v0.11.0 

func (m *AutoIncrement) SizeVT() (n int)

func (*AutoIncrement) String 

func (x *AutoIncrement) String() string

func (*AutoIncrement) UnmarshalVT added in v0.11.0 

func (m *AutoIncrement) UnmarshalVT(dAtA []byte) error

type Column 

type Column struct {
	Name          string     `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type          query.Type `protobuf:"varint,2,opt,name=type,proto3,enum=query.Type" json:"type,omitempty"`
	Invisible     bool       `protobuf:"varint,3,opt,name=invisible,proto3" json:"invisible,omitempty"`
	Default       string     `protobuf:"bytes,4,opt,name=default,proto3" json:"default,omitempty"`
	CollationName string     `protobuf:"bytes,5,opt,name=collation_name,json=collationName,proto3" json:"collation_name,omitempty"`
	Size          int32      `protobuf:"varint,6,opt,name=size,proto3" json:"size,omitempty"`
	Scale         int32      `protobuf:"varint,7,opt,name=scale,proto3" json:"scale,omitempty"`
	Nullable      *bool      `protobuf:"varint,8,opt,name=nullable,proto3,oneof" json:"nullable,omitempty"`
	// values contains the list of values for an enum or set column.
	Values []string `protobuf:"bytes,9,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

Column describes a column.

func (*Column) CloneMessageVT added in v0.18.0 

func (m *Column) CloneMessageVT() proto.Message

func (*Column) CloneVT added in v0.18.0 

func (m *Column) CloneVT() *Column

func (*Column) Descriptor deprecated 

func (*Column) Descriptor() ([]byte, []int)

Deprecated: Use Column.ProtoReflect.Descriptor instead.

func (*Column) GetCollationName added in v0.19.0 

func (x *Column) GetCollationName() string

func (*Column) GetDefault added in v0.19.0 

func (x *Column) GetDefault() string

func (*Column) GetInvisible added in v0.19.0 

func (x *Column) GetInvisible() bool

func (*Column) GetName 

func (x *Column) GetName() string

func (*Column) GetNullable added in v0.19.0 

func (x *Column) GetNullable() bool

func (*Column) GetScale added in v0.19.0 

func (x *Column) GetScale() int32

func (*Column) GetSize added in v0.19.0 

func (x *Column) GetSize() int32

func (*Column) GetType 

func (x *Column) GetType() query.Type

func (*Column) GetValues added in v0.19.0 

func (x *Column) GetValues() []string

func (*Column) MarshalToSizedBufferVT added in v0.11.0 

func (m *Column) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Column) MarshalToVT added in v0.11.0 

func (m *Column) MarshalToVT(dAtA []byte) (int, error)

func (*Column) MarshalVT added in v0.11.0 

func (m *Column) MarshalVT() (dAtA []byte, err error)

func (*Column) ProtoMessage 

func (*Column) ProtoMessage()

func (*Column) ProtoReflect added in v0.11.0 

func (x *Column) ProtoReflect() protoreflect.Message

func (*Column) Reset 

func (x *Column) Reset()

func (*Column) SizeVT added in v0.11.0 

func (m *Column) SizeVT() (n int)

func (*Column) String 

func (x *Column) String() string

func (*Column) UnmarshalVT added in v0.11.0 

func (m *Column) UnmarshalVT(dAtA []byte) error

type ColumnVindex 

type ColumnVindex struct {

	// Legacy implementation, moving forward all vindexes should define a list of columns.
	Column string `protobuf:"bytes,1,opt,name=column,proto3" json:"column,omitempty"`
	// The name must match a vindex defined in Keyspace.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// List of columns that define this Vindex
	Columns []string `protobuf:"bytes,3,rep,name=columns,proto3" json:"columns,omitempty"`
	// contains filtered or unexported fields
}

ColumnVindex is used to associate a column to a vindex.

func (*ColumnVindex) CloneMessageVT added in v0.18.0 

func (m *ColumnVindex) CloneMessageVT() proto.Message

func (*ColumnVindex) CloneVT added in v0.18.0 

func (m *ColumnVindex) CloneVT() *ColumnVindex

func (*ColumnVindex) Descriptor deprecated 

func (*ColumnVindex) Descriptor() ([]byte, []int)

Deprecated: Use ColumnVindex.ProtoReflect.Descriptor instead.

func (*ColumnVindex) GetColumn 

func (x *ColumnVindex) GetColumn() string

func (*ColumnVindex) GetColumns 

func (x *ColumnVindex) GetColumns() []string

func (*ColumnVindex) GetName 

func (x *ColumnVindex) GetName() string

func (*ColumnVindex) MarshalToSizedBufferVT added in v0.11.0 

func (m *ColumnVindex) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ColumnVindex) MarshalToVT added in v0.11.0 

func (m *ColumnVindex) MarshalToVT(dAtA []byte) (int, error)

func (*ColumnVindex) MarshalVT added in v0.11.0 

func (m *ColumnVindex) MarshalVT() (dAtA []byte, err error)

func (*ColumnVindex) ProtoMessage 

func (*ColumnVindex) ProtoMessage()

func (*ColumnVindex) ProtoReflect added in v0.11.0 

func (x *ColumnVindex) ProtoReflect() protoreflect.Message

func (*ColumnVindex) Reset 

func (x *ColumnVindex) Reset()

func (*ColumnVindex) SizeVT added in v0.11.0 

func (m *ColumnVindex) SizeVT() (n int)

func (*ColumnVindex) String 

func (x *ColumnVindex) String() string

func (*ColumnVindex) UnmarshalVT added in v0.11.0 

func (m *ColumnVindex) UnmarshalVT(dAtA []byte) error

type Keyspace 

type Keyspace struct {

	// If sharded is false, vindexes and tables are ignored.
	Sharded  bool               `protobuf:"varint,1,opt,name=sharded,proto3" json:"sharded,omitempty"`
	Vindexes map[string]*Vindex `` /* 157-byte string literal not displayed */
	Tables   map[string]*Table  `` /* 153-byte string literal not displayed */
	// If require_explicit_routing is true, vindexes and tables are not added to global routing
	RequireExplicitRouting bool `` /* 130-byte string literal not displayed */
	// foreign_key_mode dictates how Vitess should handle foreign keys for this keyspace.
	ForeignKeyMode Keyspace_ForeignKeyMode `` /* 143-byte string literal not displayed */
	// multi_tenant_mode specifies that the keyspace is multi-tenant. Currently used during migrations with MoveTables.
	MultiTenantSpec *MultiTenantSpec `protobuf:"bytes,6,opt,name=multi_tenant_spec,json=multiTenantSpec,proto3" json:"multi_tenant_spec,omitempty"`
	// contains filtered or unexported fields
}

Keyspace is the vschema for a keyspace.

func (*Keyspace) CloneMessageVT added in v0.18.0 

func (m *Keyspace) CloneMessageVT() proto.Message

func (*Keyspace) CloneVT added in v0.18.0 

func (m *Keyspace) CloneVT() *Keyspace

func (*Keyspace) Descriptor deprecated 

func (*Keyspace) Descriptor() ([]byte, []int)

Deprecated: Use Keyspace.ProtoReflect.Descriptor instead.

func (*Keyspace) GetForeignKeyMode added in v0.18.0 

func (x *Keyspace) GetForeignKeyMode() Keyspace_ForeignKeyMode

func (*Keyspace) GetMultiTenantSpec added in v0.20.0 

func (x *Keyspace) GetMultiTenantSpec() *MultiTenantSpec

func (*Keyspace) GetRequireExplicitRouting 

func (x *Keyspace) GetRequireExplicitRouting() bool

func (*Keyspace) GetSharded 

func (x *Keyspace) GetSharded() bool

func (*Keyspace) GetTables 

func (x *Keyspace) GetTables() map[string]*Table

func (*Keyspace) GetVindexes 

func (x *Keyspace) GetVindexes() map[string]*Vindex

func (*Keyspace) MarshalToSizedBufferVT added in v0.11.0 

func (m *Keyspace) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Keyspace) MarshalToVT added in v0.11.0 

func (m *Keyspace) MarshalToVT(dAtA []byte) (int, error)

func (*Keyspace) MarshalVT added in v0.11.0 

func (m *Keyspace) MarshalVT() (dAtA []byte, err error)

func (*Keyspace) ProtoMessage 

func (*Keyspace) ProtoMessage()

func (*Keyspace) ProtoReflect added in v0.11.0 

func (x *Keyspace) ProtoReflect() protoreflect.Message

func (*Keyspace) Reset 

func (x *Keyspace) Reset()

func (*Keyspace) SizeVT added in v0.11.0 

func (m *Keyspace) SizeVT() (n int)

func (*Keyspace) String 

func (x *Keyspace) String() string

func (*Keyspace) UnmarshalVT added in v0.11.0 

func (m *Keyspace) UnmarshalVT(dAtA []byte) error

type KeyspaceRoutingRule added in v0.20.0 

type KeyspaceRoutingRule struct {
	FromKeyspace string `protobuf:"bytes,1,opt,name=from_keyspace,json=fromKeyspace,proto3" json:"from_keyspace,omitempty"`
	ToKeyspace   string `protobuf:"bytes,2,opt,name=to_keyspace,json=toKeyspace,proto3" json:"to_keyspace,omitempty"`
	// contains filtered or unexported fields
}

func (*KeyspaceRoutingRule) CloneMessageVT added in v0.20.0 

func (m *KeyspaceRoutingRule) CloneMessageVT() proto.Message

func (*KeyspaceRoutingRule) CloneVT added in v0.20.0 

func (m *KeyspaceRoutingRule) CloneVT() *KeyspaceRoutingRule

func (*KeyspaceRoutingRule) Descriptor deprecated added in v0.20.0 

func (*KeyspaceRoutingRule) Descriptor() ([]byte, []int)

Deprecated: Use KeyspaceRoutingRule.ProtoReflect.Descriptor instead.

func (*KeyspaceRoutingRule) GetFromKeyspace added in v0.20.0 

func (x *KeyspaceRoutingRule) GetFromKeyspace() string

func (*KeyspaceRoutingRule) GetToKeyspace added in v0.20.0 

func (x *KeyspaceRoutingRule) GetToKeyspace() string

func (*KeyspaceRoutingRule) MarshalToSizedBufferVT added in v0.20.0 

func (m *KeyspaceRoutingRule) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*KeyspaceRoutingRule) MarshalToVT added in v0.20.0 

func (m *KeyspaceRoutingRule) MarshalToVT(dAtA []byte) (int, error)

func (*KeyspaceRoutingRule) MarshalVT added in v0.20.0 

func (m *KeyspaceRoutingRule) MarshalVT() (dAtA []byte, err error)

func (*KeyspaceRoutingRule) ProtoMessage added in v0.20.0 

func (*KeyspaceRoutingRule) ProtoMessage()

func (*KeyspaceRoutingRule) ProtoReflect added in v0.20.0 

func (x *KeyspaceRoutingRule) ProtoReflect() protoreflect.Message

func (*KeyspaceRoutingRule) Reset added in v0.20.0 

func (x *KeyspaceRoutingRule) Reset()

func (*KeyspaceRoutingRule) SizeVT added in v0.20.0 

func (m *KeyspaceRoutingRule) SizeVT() (n int)

func (*KeyspaceRoutingRule) String added in v0.20.0 

func (x *KeyspaceRoutingRule) String() string

func (*KeyspaceRoutingRule) UnmarshalVT added in v0.20.0 

func (m *KeyspaceRoutingRule) UnmarshalVT(dAtA []byte) error

type KeyspaceRoutingRules added in v0.20.0 

type KeyspaceRoutingRules struct {
	Rules []*KeyspaceRoutingRule `protobuf:"bytes,1,rep,name=rules,proto3" json:"rules,omitempty"`
	// contains filtered or unexported fields
}

func (*KeyspaceRoutingRules) CloneMessageVT added in v0.20.0 

func (m *KeyspaceRoutingRules) CloneMessageVT() proto.Message

func (*KeyspaceRoutingRules) CloneVT added in v0.20.0 

func (m *KeyspaceRoutingRules) CloneVT() *KeyspaceRoutingRules

func (*KeyspaceRoutingRules) Descriptor deprecated added in v0.20.0 

func (*KeyspaceRoutingRules) Descriptor() ([]byte, []int)

Deprecated: Use KeyspaceRoutingRules.ProtoReflect.Descriptor instead.

func (*KeyspaceRoutingRules) GetRules added in v0.20.0 

func (x *KeyspaceRoutingRules) GetRules() []*KeyspaceRoutingRule

func (*KeyspaceRoutingRules) MarshalToSizedBufferVT added in v0.20.0 

func (m *KeyspaceRoutingRules) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*KeyspaceRoutingRules) MarshalToVT added in v0.20.0 

func (m *KeyspaceRoutingRules) MarshalToVT(dAtA []byte) (int, error)

func (*KeyspaceRoutingRules) MarshalVT added in v0.20.0 

func (m *KeyspaceRoutingRules) MarshalVT() (dAtA []byte, err error)

func (*KeyspaceRoutingRules) ProtoMessage added in v0.20.0 

func (*KeyspaceRoutingRules) ProtoMessage()

func (*KeyspaceRoutingRules) ProtoReflect added in v0.20.0 

func (x *KeyspaceRoutingRules) ProtoReflect() protoreflect.Message

func (*KeyspaceRoutingRules) Reset added in v0.20.0 

func (x *KeyspaceRoutingRules) Reset()

func (*KeyspaceRoutingRules) SizeVT added in v0.20.0 

func (m *KeyspaceRoutingRules) SizeVT() (n int)

func (*KeyspaceRoutingRules) String added in v0.20.0 

func (x *KeyspaceRoutingRules) String() string

func (*KeyspaceRoutingRules) UnmarshalVT added in v0.20.0 

func (m *KeyspaceRoutingRules) UnmarshalVT(dAtA []byte) error

type Keyspace_ForeignKeyMode added in v0.18.0 

type Keyspace_ForeignKeyMode int32
const (
	Keyspace_unspecified Keyspace_ForeignKeyMode = 0
	Keyspace_disallow    Keyspace_ForeignKeyMode = 1
	Keyspace_unmanaged   Keyspace_ForeignKeyMode = 2
	Keyspace_managed     Keyspace_ForeignKeyMode = 3
)

func (Keyspace_ForeignKeyMode) Descriptor added in v0.18.0 

func (Keyspace_ForeignKeyMode) Descriptor() protoreflect.EnumDescriptor

func (Keyspace_ForeignKeyMode) Enum added in v0.18.0 

func (x Keyspace_ForeignKeyMode) Enum() *Keyspace_ForeignKeyMode

func (Keyspace_ForeignKeyMode) EnumDescriptor deprecated added in v0.18.0 

func (Keyspace_ForeignKeyMode) EnumDescriptor() ([]byte, []int)

Deprecated: Use Keyspace_ForeignKeyMode.Descriptor instead.

func (Keyspace_ForeignKeyMode) Number added in v0.18.0 

func (x Keyspace_ForeignKeyMode) Number() protoreflect.EnumNumber

func (Keyspace_ForeignKeyMode) String added in v0.18.0 

func (x Keyspace_ForeignKeyMode) String() string

func (Keyspace_ForeignKeyMode) Type added in v0.18.0 

func (Keyspace_ForeignKeyMode) Type() protoreflect.EnumType

type MirrorRule added in v0.21.0 

type MirrorRule struct {
	FromTable string  `protobuf:"bytes,1,opt,name=from_table,json=fromTable,proto3" json:"from_table,omitempty"`
	ToTable   string  `protobuf:"bytes,2,opt,name=to_table,json=toTable,proto3" json:"to_table,omitempty"`
	Percent   float32 `protobuf:"fixed32,3,opt,name=percent,proto3" json:"percent,omitempty"`
	// contains filtered or unexported fields
}

MirrorRule specifies a mirror rule.

func (*MirrorRule) CloneMessageVT added in v0.21.0 

func (m *MirrorRule) CloneMessageVT() proto.Message

func (*MirrorRule) CloneVT added in v0.21.0 

func (m *MirrorRule) CloneVT() *MirrorRule

func (*MirrorRule) Descriptor deprecated added in v0.21.0 

func (*MirrorRule) Descriptor() ([]byte, []int)

Deprecated: Use MirrorRule.ProtoReflect.Descriptor instead.

func (*MirrorRule) GetFromTable added in v0.21.0 

func (x *MirrorRule) GetFromTable() string

func (*MirrorRule) GetPercent added in v0.21.0 

func (x *MirrorRule) GetPercent() float32

func (*MirrorRule) GetToTable added in v0.21.0 

func (x *MirrorRule) GetToTable() string

func (*MirrorRule) MarshalToSizedBufferVT added in v0.21.0 

func (m *MirrorRule) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*MirrorRule) MarshalToVT added in v0.21.0 

func (m *MirrorRule) MarshalToVT(dAtA []byte) (int, error)

func (*MirrorRule) MarshalVT added in v0.21.0 

func (m *MirrorRule) MarshalVT() (dAtA []byte, err error)

func (*MirrorRule) ProtoMessage added in v0.21.0 

func (*MirrorRule) ProtoMessage()

func (*MirrorRule) ProtoReflect added in v0.21.0 

func (x *MirrorRule) ProtoReflect() protoreflect.Message

func (*MirrorRule) Reset added in v0.21.0 

func (x *MirrorRule) Reset()

func (*MirrorRule) SizeVT added in v0.21.0 

func (m *MirrorRule) SizeVT() (n int)

func (*MirrorRule) String added in v0.21.0 

func (x *MirrorRule) String() string

func (*MirrorRule) UnmarshalVT added in v0.21.0 

func (m *MirrorRule) UnmarshalVT(dAtA []byte) error

type MirrorRules added in v0.21.0 

type MirrorRules struct {

	// rules should ideally be a map. However protos dont't allow
	// repeated fields as elements of a map. So, we use a list
	// instead.
	Rules []*MirrorRule `protobuf:"bytes,1,rep,name=rules,proto3" json:"rules,omitempty"`
	// contains filtered or unexported fields
}

MirrorRules specify the high level mirror rules for the VSchema.

func (*MirrorRules) CloneMessageVT added in v0.21.0 

func (m *MirrorRules) CloneMessageVT() proto.Message

func (*MirrorRules) CloneVT added in v0.21.0 

func (m *MirrorRules) CloneVT() *MirrorRules

func (*MirrorRules) Descriptor deprecated added in v0.21.0 

func (*MirrorRules) Descriptor() ([]byte, []int)

Deprecated: Use MirrorRules.ProtoReflect.Descriptor instead.

func (*MirrorRules) GetRules added in v0.21.0 

func (x *MirrorRules) GetRules() []*MirrorRule

func (*MirrorRules) MarshalToSizedBufferVT added in v0.21.0 

func (m *MirrorRules) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*MirrorRules) MarshalToVT added in v0.21.0 

func (m *MirrorRules) MarshalToVT(dAtA []byte) (int, error)

func (*MirrorRules) MarshalVT added in v0.21.0 

func (m *MirrorRules) MarshalVT() (dAtA []byte, err error)

func (*MirrorRules) ProtoMessage added in v0.21.0 

func (*MirrorRules) ProtoMessage()

func (*MirrorRules) ProtoReflect added in v0.21.0 

func (x *MirrorRules) ProtoReflect() protoreflect.Message

func (*MirrorRules) Reset added in v0.21.0 

func (x *MirrorRules) Reset()

func (*MirrorRules) SizeVT added in v0.21.0 

func (m *MirrorRules) SizeVT() (n int)

func (*MirrorRules) String added in v0.21.0 

func (x *MirrorRules) String() string

func (*MirrorRules) UnmarshalVT added in v0.21.0 

func (m *MirrorRules) UnmarshalVT(dAtA []byte) error

type MultiTenantSpec added in v0.20.0 

type MultiTenantSpec struct {

	// tenant_column is the name of the column that specifies the tenant id.
	TenantIdColumnName string `protobuf:"bytes,1,opt,name=tenant_id_column_name,json=tenantIdColumnName,proto3" json:"tenant_id_column_name,omitempty"`
	// tenant_column_type is the type of the column that specifies the tenant id.
	TenantIdColumnType query.Type `` /* 136-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*MultiTenantSpec) CloneMessageVT added in v0.20.0 

func (m *MultiTenantSpec) CloneMessageVT() proto.Message

func (*MultiTenantSpec) CloneVT added in v0.20.0 

func (m *MultiTenantSpec) CloneVT() *MultiTenantSpec

func (*MultiTenantSpec) Descriptor deprecated added in v0.20.0 

func (*MultiTenantSpec) Descriptor() ([]byte, []int)

Deprecated: Use MultiTenantSpec.ProtoReflect.Descriptor instead.

func (*MultiTenantSpec) GetTenantIdColumnName added in v0.20.0 

func (x *MultiTenantSpec) GetTenantIdColumnName() string

func (*MultiTenantSpec) GetTenantIdColumnType added in v0.20.0 

func (x *MultiTenantSpec) GetTenantIdColumnType() query.Type

func (*MultiTenantSpec) MarshalToSizedBufferVT added in v0.20.0 

func (m *MultiTenantSpec) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*MultiTenantSpec) MarshalToVT added in v0.20.0 

func (m *MultiTenantSpec) MarshalToVT(dAtA []byte) (int, error)

func (*MultiTenantSpec) MarshalVT added in v0.20.0 

func (m *MultiTenantSpec) MarshalVT() (dAtA []byte, err error)

func (*MultiTenantSpec) ProtoMessage added in v0.20.0 

func (*MultiTenantSpec) ProtoMessage()

func (*MultiTenantSpec) ProtoReflect added in v0.20.0 

func (x *MultiTenantSpec) ProtoReflect() protoreflect.Message

func (*MultiTenantSpec) Reset added in v0.20.0 

func (x *MultiTenantSpec) Reset()

func (*MultiTenantSpec) SizeVT added in v0.20.0 

func (m *MultiTenantSpec) SizeVT() (n int)

func (*MultiTenantSpec) String added in v0.20.0 

func (x *MultiTenantSpec) String() string

func (*MultiTenantSpec) UnmarshalVT added in v0.20.0 

func (m *MultiTenantSpec) UnmarshalVT(dAtA []byte) error

type RoutingRule 

type RoutingRule struct {
	FromTable string   `protobuf:"bytes,1,opt,name=from_table,json=fromTable,proto3" json:"from_table,omitempty"`
	ToTables  []string `protobuf:"bytes,2,rep,name=to_tables,json=toTables,proto3" json:"to_tables,omitempty"`
	// contains filtered or unexported fields
}

RoutingRule specifies a routing rule.

func (*RoutingRule) CloneMessageVT added in v0.18.0 

func (m *RoutingRule) CloneMessageVT() proto.Message

func (*RoutingRule) CloneVT added in v0.18.0 

func (m *RoutingRule) CloneVT() *RoutingRule

func (*RoutingRule) Descriptor deprecated 

func (*RoutingRule) Descriptor() ([]byte, []int)

Deprecated: Use RoutingRule.ProtoReflect.Descriptor instead.

func (*RoutingRule) GetFromTable 

func (x *RoutingRule) GetFromTable() string

func (*RoutingRule) GetToTables 

func (x *RoutingRule) GetToTables() []string

func (*RoutingRule) MarshalToSizedBufferVT added in v0.11.0 

func (m *RoutingRule) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RoutingRule) MarshalToVT added in v0.11.0 

func (m *RoutingRule) MarshalToVT(dAtA []byte) (int, error)

func (*RoutingRule) MarshalVT added in v0.11.0 

func (m *RoutingRule) MarshalVT() (dAtA []byte, err error)

func (*RoutingRule) ProtoMessage 

func (*RoutingRule) ProtoMessage()

func (*RoutingRule) ProtoReflect added in v0.11.0 

func (x *RoutingRule) ProtoReflect() protoreflect.Message

func (*RoutingRule) Reset 

func (x *RoutingRule) Reset()

func (*RoutingRule) SizeVT added in v0.11.0 

func (m *RoutingRule) SizeVT() (n int)

func (*RoutingRule) String 

func (x *RoutingRule) String() string

func (*RoutingRule) UnmarshalVT added in v0.11.0 

func (m *RoutingRule) UnmarshalVT(dAtA []byte) error

type RoutingRules 

type RoutingRules struct {

	// rules should ideally be a map. However protos dont't allow
	// repeated fields as elements of a map. So, we use a list
	// instead.
	Rules []*RoutingRule `protobuf:"bytes,1,rep,name=rules,proto3" json:"rules,omitempty"`
	// contains filtered or unexported fields
}

RoutingRules specify the high level routing rules for the VSchema.

func (*RoutingRules) CloneMessageVT added in v0.18.0 

func (m *RoutingRules) CloneMessageVT() proto.Message

func (*RoutingRules) CloneVT added in v0.18.0 

func (m *RoutingRules) CloneVT() *RoutingRules

func (*RoutingRules) Descriptor deprecated 

func (*RoutingRules) Descriptor() ([]byte, []int)

Deprecated: Use RoutingRules.ProtoReflect.Descriptor instead.

func (*RoutingRules) GetRules 

func (x *RoutingRules) GetRules() []*RoutingRule

func (*RoutingRules) MarshalToSizedBufferVT added in v0.11.0 

func (m *RoutingRules) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RoutingRules) MarshalToVT added in v0.11.0 

func (m *RoutingRules) MarshalToVT(dAtA []byte) (int, error)

func (*RoutingRules) MarshalVT added in v0.11.0 

func (m *RoutingRules) MarshalVT() (dAtA []byte, err error)

func (*RoutingRules) ProtoMessage 

func (*RoutingRules) ProtoMessage()

func (*RoutingRules) ProtoReflect added in v0.11.0 

func (x *RoutingRules) ProtoReflect() protoreflect.Message

func (*RoutingRules) Reset 

func (x *RoutingRules) Reset()

func (*RoutingRules) SizeVT added in v0.11.0 

func (m *RoutingRules) SizeVT() (n int)

func (*RoutingRules) String 

func (x *RoutingRules) String() string

func (*RoutingRules) UnmarshalVT added in v0.11.0 

func (m *RoutingRules) UnmarshalVT(dAtA []byte) error

type ShardRoutingRule added in v0.15.0 

type ShardRoutingRule struct {
	FromKeyspace string `protobuf:"bytes,1,opt,name=from_keyspace,json=fromKeyspace,proto3" json:"from_keyspace,omitempty"`
	ToKeyspace   string `protobuf:"bytes,2,opt,name=to_keyspace,json=toKeyspace,proto3" json:"to_keyspace,omitempty"`
	Shard        string `protobuf:"bytes,3,opt,name=shard,proto3" json:"shard,omitempty"`
	// contains filtered or unexported fields
}

ShardRoutingRule specifies a routing rule.

func (*ShardRoutingRule) CloneMessageVT added in v0.18.0 

func (m *ShardRoutingRule) CloneMessageVT() proto.Message

func (*ShardRoutingRule) CloneVT added in v0.18.0 

func (m *ShardRoutingRule) CloneVT() *ShardRoutingRule

func (*ShardRoutingRule) Descriptor deprecated added in v0.15.0 

func (*ShardRoutingRule) Descriptor() ([]byte, []int)

Deprecated: Use ShardRoutingRule.ProtoReflect.Descriptor instead.

func (*ShardRoutingRule) GetFromKeyspace added in v0.15.0 

func (x *ShardRoutingRule) GetFromKeyspace() string

func (*ShardRoutingRule) GetShard added in v0.15.0 

func (x *ShardRoutingRule) GetShard() string

func (*ShardRoutingRule) GetToKeyspace added in v0.15.0 

func (x *ShardRoutingRule) GetToKeyspace() string

func (*ShardRoutingRule) MarshalToSizedBufferVT added in v0.15.0 

func (m *ShardRoutingRule) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ShardRoutingRule) MarshalToVT added in v0.15.0 

func (m *ShardRoutingRule) MarshalToVT(dAtA []byte) (int, error)

func (*ShardRoutingRule) MarshalVT added in v0.15.0 

func (m *ShardRoutingRule) MarshalVT() (dAtA []byte, err error)

func (*ShardRoutingRule) ProtoMessage added in v0.15.0 

func (*ShardRoutingRule) ProtoMessage()

func (*ShardRoutingRule) ProtoReflect added in v0.15.0 

func (x *ShardRoutingRule) ProtoReflect() protoreflect.Message

func (*ShardRoutingRule) Reset added in v0.15.0 

func (x *ShardRoutingRule) Reset()

func (*ShardRoutingRule) SizeVT added in v0.15.0 

func (m *ShardRoutingRule) SizeVT() (n int)

func (*ShardRoutingRule) String added in v0.15.0 

func (x *ShardRoutingRule) String() string

func (*ShardRoutingRule) UnmarshalVT added in v0.15.0 

func (m *ShardRoutingRule) UnmarshalVT(dAtA []byte) error

type ShardRoutingRules added in v0.15.0 

type ShardRoutingRules struct {
	Rules []*ShardRoutingRule `protobuf:"bytes,1,rep,name=rules,proto3" json:"rules,omitempty"`
	// contains filtered or unexported fields
}

ShardRoutingRules specify the shard routing rules for the VSchema.

func (*ShardRoutingRules) CloneMessageVT added in v0.18.0 

func (m *ShardRoutingRules) CloneMessageVT() proto.Message

func (*ShardRoutingRules) CloneVT added in v0.18.0 

func (m *ShardRoutingRules) CloneVT() *ShardRoutingRules

func (*ShardRoutingRules) Descriptor deprecated added in v0.15.0 

func (*ShardRoutingRules) Descriptor() ([]byte, []int)

Deprecated: Use ShardRoutingRules.ProtoReflect.Descriptor instead.

func (*ShardRoutingRules) GetRules added in v0.15.0 

func (x *ShardRoutingRules) GetRules() []*ShardRoutingRule

func (*ShardRoutingRules) MarshalToSizedBufferVT added in v0.15.0 

func (m *ShardRoutingRules) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ShardRoutingRules) MarshalToVT added in v0.15.0 

func (m *ShardRoutingRules) MarshalToVT(dAtA []byte) (int, error)

func (*ShardRoutingRules) MarshalVT added in v0.15.0 

func (m *ShardRoutingRules) MarshalVT() (dAtA []byte, err error)

func (*ShardRoutingRules) ProtoMessage added in v0.15.0 

func (*ShardRoutingRules) ProtoMessage()

func (*ShardRoutingRules) ProtoReflect added in v0.15.0 

func (x *ShardRoutingRules) ProtoReflect() protoreflect.Message

func (*ShardRoutingRules) Reset added in v0.15.0 

func (x *ShardRoutingRules) Reset()

func (*ShardRoutingRules) SizeVT added in v0.15.0 

func (m *ShardRoutingRules) SizeVT() (n int)

func (*ShardRoutingRules) String added in v0.15.0 

func (x *ShardRoutingRules) String() string

func (*ShardRoutingRules) UnmarshalVT added in v0.15.0 

func (m *ShardRoutingRules) UnmarshalVT(dAtA []byte) error

type SrvVSchema 

type SrvVSchema struct {

	// keyspaces is a map of keyspace name -> Keyspace object.
	Keyspaces            map[string]*Keyspace  ``                                                                                                  /* 159-byte string literal not displayed */
	RoutingRules         *RoutingRules         `protobuf:"bytes,2,opt,name=routing_rules,json=routingRules,proto3" json:"routing_rules,omitempty"` // table routing rules
	ShardRoutingRules    *ShardRoutingRules    `protobuf:"bytes,3,opt,name=shard_routing_rules,json=shardRoutingRules,proto3" json:"shard_routing_rules,omitempty"`
	KeyspaceRoutingRules *KeyspaceRoutingRules `protobuf:"bytes,4,opt,name=keyspace_routing_rules,json=keyspaceRoutingRules,proto3" json:"keyspace_routing_rules,omitempty"`
	MirrorRules          *MirrorRules          `protobuf:"bytes,5,opt,name=mirror_rules,json=mirrorRules,proto3" json:"mirror_rules,omitempty"` // mirror rules
	// contains filtered or unexported fields
}

SrvVSchema is the roll-up of all the Keyspace schema for a cell.

func (*SrvVSchema) CloneMessageVT added in v0.18.0 

func (m *SrvVSchema) CloneMessageVT() proto.Message

func (*SrvVSchema) CloneVT added in v0.18.0 

func (m *SrvVSchema) CloneVT() *SrvVSchema

func (*SrvVSchema) Descriptor deprecated 

func (*SrvVSchema) Descriptor() ([]byte, []int)

Deprecated: Use SrvVSchema.ProtoReflect.Descriptor instead.

func (*SrvVSchema) GetKeyspaceRoutingRules added in v0.20.0 

func (x *SrvVSchema) GetKeyspaceRoutingRules() *KeyspaceRoutingRules

func (*SrvVSchema) GetKeyspaces 

func (x *SrvVSchema) GetKeyspaces() map[string]*Keyspace

func (*SrvVSchema) GetMirrorRules added in v0.21.0 

func (x *SrvVSchema) GetMirrorRules() *MirrorRules

func (*SrvVSchema) GetRoutingRules 

func (x *SrvVSchema) GetRoutingRules() *RoutingRules

func (*SrvVSchema) GetShardRoutingRules added in v0.15.0 

func (x *SrvVSchema) GetShardRoutingRules() *ShardRoutingRules

func (*SrvVSchema) MarshalToSizedBufferVT added in v0.11.0 

func (m *SrvVSchema) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SrvVSchema) MarshalToVT added in v0.11.0 

func (m *SrvVSchema) MarshalToVT(dAtA []byte) (int, error)

func (*SrvVSchema) MarshalVT added in v0.11.0 

func (m *SrvVSchema) MarshalVT() (dAtA []byte, err error)

func (*SrvVSchema) ProtoMessage 

func (*SrvVSchema) ProtoMessage()

func (*SrvVSchema) ProtoReflect added in v0.11.0 

func (x *SrvVSchema) ProtoReflect() protoreflect.Message

func (*SrvVSchema) Reset 

func (x *SrvVSchema) Reset()

func (*SrvVSchema) SizeVT added in v0.11.0 

func (m *SrvVSchema) SizeVT() (n int)

func (*SrvVSchema) String 

func (x *SrvVSchema) String() string

func (*SrvVSchema) UnmarshalVT added in v0.11.0 

func (m *SrvVSchema) UnmarshalVT(dAtA []byte) error

type Table 

type Table struct {

	// If the table is a sequence, type must be
	// "sequence".
	//
	// If the table is a reference, type must be
	// "reference".
	// See https://vitess.io/docs/reference/features/vschema/#reference-tables.
	//
	// Otherwise, it should be empty.
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	// column_vindexes associates columns to vindexes.
	ColumnVindexes []*ColumnVindex `protobuf:"bytes,2,rep,name=column_vindexes,json=columnVindexes,proto3" json:"column_vindexes,omitempty"`
	// auto_increment is specified if a column needs
	// to be associated with a sequence.
	AutoIncrement *AutoIncrement `protobuf:"bytes,3,opt,name=auto_increment,json=autoIncrement,proto3" json:"auto_increment,omitempty"`
	// columns lists the columns for the table.
	Columns []*Column `protobuf:"bytes,4,rep,name=columns,proto3" json:"columns,omitempty"`
	// pinned pins an unsharded table to a specific
	// shard, as dictated by the keyspace id.
	// The keyspace id is represented in hex form
	// like in keyranges.
	Pinned string `protobuf:"bytes,5,opt,name=pinned,proto3" json:"pinned,omitempty"`
	// column_list_authoritative is set to true if columns is
	// an authoritative list for the table. This allows
	// us to expand 'select *' expressions.
	ColumnListAuthoritative bool `` /* 133-byte string literal not displayed */
	// reference tables may optionally indicate their source table.
	Source string `protobuf:"bytes,7,opt,name=source,proto3" json:"source,omitempty"`
	// contains filtered or unexported fields
}

Table is the table info for a Keyspace.

func (*Table) CloneMessageVT added in v0.18.0 

func (m *Table) CloneMessageVT() proto.Message

func (*Table) CloneVT added in v0.18.0 

func (m *Table) CloneVT() *Table

func (*Table) Descriptor deprecated 

func (*Table) Descriptor() ([]byte, []int)

Deprecated: Use Table.ProtoReflect.Descriptor instead.

func (*Table) GetAutoIncrement 

func (x *Table) GetAutoIncrement() *AutoIncrement

func (*Table) GetColumnListAuthoritative 

func (x *Table) GetColumnListAuthoritative() bool

func (*Table) GetColumnVindexes 

func (x *Table) GetColumnVindexes() []*ColumnVindex

func (*Table) GetColumns 

func (x *Table) GetColumns() []*Column

func (*Table) GetPinned 

func (x *Table) GetPinned() string

func (*Table) GetSource added in v0.16.0 

func (x *Table) GetSource() string

func (*Table) GetType 

func (x *Table) GetType() string

func (*Table) MarshalToSizedBufferVT added in v0.11.0 

func (m *Table) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Table) MarshalToVT added in v0.11.0 

func (m *Table) MarshalToVT(dAtA []byte) (int, error)

func (*Table) MarshalVT added in v0.11.0 

func (m *Table) MarshalVT() (dAtA []byte, err error)

func (*Table) ProtoMessage 

func (*Table) ProtoMessage()

func (*Table) ProtoReflect added in v0.11.0 

func (x *Table) ProtoReflect() protoreflect.Message

func (*Table) Reset 

func (x *Table) Reset()

func (*Table) SizeVT added in v0.11.0 

func (m *Table) SizeVT() (n int)

func (*Table) String 

func (x *Table) String() string

func (*Table) UnmarshalVT added in v0.11.0 

func (m *Table) UnmarshalVT(dAtA []byte) error

type Vindex 

type Vindex struct {

	// The type must match one of the predefined
	// (or plugged in) vindex names.
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	// params is a map of attribute value pairs
	// that must be defined as required by the
	// vindex constructors. The values can only
	// be strings.
	Params map[string]string `` /* 153-byte string literal not displayed */
	// A lookup vindex can have an owner table defined.
	// If so, rows in the lookup table are created or
	// deleted in sync with corresponding rows in the
	// owner table.
	Owner string `protobuf:"bytes,3,opt,name=owner,proto3" json:"owner,omitempty"`
	// contains filtered or unexported fields
}

Vindex is the vindex info for a Keyspace.

func (*Vindex) CloneMessageVT added in v0.18.0 

func (m *Vindex) CloneMessageVT() proto.Message

func (*Vindex) CloneVT added in v0.18.0 

func (m *Vindex) CloneVT() *Vindex

func (*Vindex) Descriptor deprecated 

func (*Vindex) Descriptor() ([]byte, []int)

Deprecated: Use Vindex.ProtoReflect.Descriptor instead.

func (*Vindex) GetOwner 

func (x *Vindex) GetOwner() string

func (*Vindex) GetParams 

func (x *Vindex) GetParams() map[string]string

func (*Vindex) GetType 

func (x *Vindex) GetType() string

func (*Vindex) MarshalToSizedBufferVT added in v0.11.0 

func (m *Vindex) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Vindex) MarshalToVT added in v0.11.0 

func (m *Vindex) MarshalToVT(dAtA []byte) (int, error)

func (*Vindex) MarshalVT added in v0.11.0 

func (m *Vindex) MarshalVT() (dAtA []byte, err error)

func (*Vindex) ProtoMessage 

func (*Vindex) ProtoMessage()

func (*Vindex) ProtoReflect added in v0.11.0 

func (x *Vindex) ProtoReflect() protoreflect.Message

func (*Vindex) Reset 

func (x *Vindex) Reset()

func (*Vindex) SizeVT added in v0.11.0 

func (m *Vindex) SizeVT() (n int)

func (*Vindex) String 

func (x *Vindex) String() string

func (*Vindex) UnmarshalVT added in v0.11.0 

func (m *Vindex) UnmarshalVT(dAtA []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.