Documentation ¶
Index ¶
- type AutoIncrement
- func (*AutoIncrement) Descriptor() ([]byte, []int)
- func (m *AutoIncrement) GetColumn() string
- func (m *AutoIncrement) GetSequence() string
- func (*AutoIncrement) ProtoMessage()
- func (m *AutoIncrement) Reset()
- func (m *AutoIncrement) String() string
- func (m *AutoIncrement) XXX_DiscardUnknown()
- func (m *AutoIncrement) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AutoIncrement) XXX_Merge(src proto.Message)
- func (m *AutoIncrement) XXX_Size() int
- func (m *AutoIncrement) XXX_Unmarshal(b []byte) error
- type Column
- func (*Column) Descriptor() ([]byte, []int)
- func (m *Column) GetName() string
- func (m *Column) GetType() query.Type
- func (*Column) ProtoMessage()
- func (m *Column) Reset()
- func (m *Column) String() string
- func (m *Column) XXX_DiscardUnknown()
- func (m *Column) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Column) XXX_Merge(src proto.Message)
- func (m *Column) XXX_Size() int
- func (m *Column) XXX_Unmarshal(b []byte) error
- type ColumnVindex
- func (*ColumnVindex) Descriptor() ([]byte, []int)
- func (m *ColumnVindex) GetColumn() string
- func (m *ColumnVindex) GetColumns() []string
- func (m *ColumnVindex) GetName() string
- func (*ColumnVindex) ProtoMessage()
- func (m *ColumnVindex) Reset()
- func (m *ColumnVindex) String() string
- func (m *ColumnVindex) XXX_DiscardUnknown()
- func (m *ColumnVindex) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ColumnVindex) XXX_Merge(src proto.Message)
- func (m *ColumnVindex) XXX_Size() int
- func (m *ColumnVindex) XXX_Unmarshal(b []byte) error
- type Keyspace
- func (*Keyspace) Descriptor() ([]byte, []int)
- func (m *Keyspace) GetRequireExplicitRouting() bool
- func (m *Keyspace) GetSharded() bool
- func (m *Keyspace) GetTables() map[string]*Table
- func (m *Keyspace) GetVindexes() map[string]*Vindex
- func (*Keyspace) ProtoMessage()
- func (m *Keyspace) Reset()
- func (m *Keyspace) String() string
- func (m *Keyspace) XXX_DiscardUnknown()
- func (m *Keyspace) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Keyspace) XXX_Merge(src proto.Message)
- func (m *Keyspace) XXX_Size() int
- func (m *Keyspace) XXX_Unmarshal(b []byte) error
- type RoutingRule
- func (*RoutingRule) Descriptor() ([]byte, []int)
- func (m *RoutingRule) GetFromTable() string
- func (m *RoutingRule) GetToTables() []string
- func (*RoutingRule) ProtoMessage()
- func (m *RoutingRule) Reset()
- func (m *RoutingRule) String() string
- func (m *RoutingRule) XXX_DiscardUnknown()
- func (m *RoutingRule) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RoutingRule) XXX_Merge(src proto.Message)
- func (m *RoutingRule) XXX_Size() int
- func (m *RoutingRule) XXX_Unmarshal(b []byte) error
- type RoutingRules
- func (*RoutingRules) Descriptor() ([]byte, []int)
- func (m *RoutingRules) GetRules() []*RoutingRule
- func (*RoutingRules) ProtoMessage()
- func (m *RoutingRules) Reset()
- func (m *RoutingRules) String() string
- func (m *RoutingRules) XXX_DiscardUnknown()
- func (m *RoutingRules) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RoutingRules) XXX_Merge(src proto.Message)
- func (m *RoutingRules) XXX_Size() int
- func (m *RoutingRules) XXX_Unmarshal(b []byte) error
- type SrvVSchema
- func (*SrvVSchema) Descriptor() ([]byte, []int)
- func (m *SrvVSchema) GetKeyspaces() map[string]*Keyspace
- func (m *SrvVSchema) GetRoutingRules() *RoutingRules
- func (*SrvVSchema) ProtoMessage()
- func (m *SrvVSchema) Reset()
- func (m *SrvVSchema) String() string
- func (m *SrvVSchema) XXX_DiscardUnknown()
- func (m *SrvVSchema) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SrvVSchema) XXX_Merge(src proto.Message)
- func (m *SrvVSchema) XXX_Size() int
- func (m *SrvVSchema) XXX_Unmarshal(b []byte) error
- type Table
- func (*Table) Descriptor() ([]byte, []int)
- func (m *Table) GetAutoIncrement() *AutoIncrement
- func (m *Table) GetColumnListAuthoritative() bool
- func (m *Table) GetColumnVindexes() []*ColumnVindex
- func (m *Table) GetColumns() []*Column
- func (m *Table) GetPinned() string
- func (m *Table) GetType() string
- func (*Table) ProtoMessage()
- func (m *Table) Reset()
- func (m *Table) String() string
- func (m *Table) XXX_DiscardUnknown()
- func (m *Table) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Table) XXX_Merge(src proto.Message)
- func (m *Table) XXX_Size() int
- func (m *Table) XXX_Unmarshal(b []byte) error
- type Vindex
- func (*Vindex) Descriptor() ([]byte, []int)
- func (m *Vindex) GetOwner() string
- func (m *Vindex) GetParams() map[string]string
- func (m *Vindex) GetType() string
- func (*Vindex) ProtoMessage()
- func (m *Vindex) Reset()
- func (m *Vindex) String() string
- func (m *Vindex) XXX_DiscardUnknown()
- func (m *Vindex) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Vindex) XXX_Merge(src proto.Message)
- func (m *Vindex) XXX_Size() int
- func (m *Vindex) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Autoincrement is used to designate a column as auto-inc.
func (*AutoIncrement) Descriptor ¶
func (*AutoIncrement) Descriptor() ([]byte, []int)
func (*AutoIncrement) GetColumn ¶
func (m *AutoIncrement) GetColumn() string
func (*AutoIncrement) GetSequence ¶
func (m *AutoIncrement) GetSequence() string
func (*AutoIncrement) ProtoMessage ¶
func (*AutoIncrement) ProtoMessage()
func (*AutoIncrement) Reset ¶
func (m *AutoIncrement) Reset()
func (*AutoIncrement) String ¶
func (m *AutoIncrement) String() string
func (*AutoIncrement) XXX_DiscardUnknown ¶
func (m *AutoIncrement) XXX_DiscardUnknown()
func (*AutoIncrement) XXX_Marshal ¶
func (m *AutoIncrement) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AutoIncrement) XXX_Merge ¶
func (m *AutoIncrement) XXX_Merge(src proto.Message)
func (*AutoIncrement) XXX_Size ¶
func (m *AutoIncrement) XXX_Size() int
func (*AutoIncrement) XXX_Unmarshal ¶
func (m *AutoIncrement) XXX_Unmarshal(b []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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Column describes a column.
func (*Column) Descriptor ¶
func (*Column) ProtoMessage ¶
func (*Column) ProtoMessage()
func (*Column) XXX_DiscardUnknown ¶
func (m *Column) XXX_DiscardUnknown()
func (*Column) XXX_Marshal ¶
func (*Column) XXX_Unmarshal ¶
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
ColumnVindex is used to associate a column to a vindex.
func (*ColumnVindex) Descriptor ¶
func (*ColumnVindex) Descriptor() ([]byte, []int)
func (*ColumnVindex) GetColumn ¶
func (m *ColumnVindex) GetColumn() string
func (*ColumnVindex) GetColumns ¶
func (m *ColumnVindex) GetColumns() []string
func (*ColumnVindex) GetName ¶
func (m *ColumnVindex) GetName() string
func (*ColumnVindex) ProtoMessage ¶
func (*ColumnVindex) ProtoMessage()
func (*ColumnVindex) Reset ¶
func (m *ColumnVindex) Reset()
func (*ColumnVindex) String ¶
func (m *ColumnVindex) String() string
func (*ColumnVindex) XXX_DiscardUnknown ¶
func (m *ColumnVindex) XXX_DiscardUnknown()
func (*ColumnVindex) XXX_Marshal ¶
func (m *ColumnVindex) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ColumnVindex) XXX_Merge ¶
func (m *ColumnVindex) XXX_Merge(src proto.Message)
func (*ColumnVindex) XXX_Size ¶
func (m *ColumnVindex) XXX_Size() int
func (*ColumnVindex) XXX_Unmarshal ¶
func (m *ColumnVindex) XXX_Unmarshal(b []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 */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Keyspace is the vschema for a keyspace.
func (*Keyspace) Descriptor ¶
func (*Keyspace) GetRequireExplicitRouting ¶
func (*Keyspace) GetSharded ¶
func (*Keyspace) GetVindexes ¶
func (*Keyspace) ProtoMessage ¶
func (*Keyspace) ProtoMessage()
func (*Keyspace) XXX_DiscardUnknown ¶
func (m *Keyspace) XXX_DiscardUnknown()
func (*Keyspace) XXX_Marshal ¶
func (*Keyspace) XXX_Unmarshal ¶
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
RoutingRule specifies a routing rule.
func (*RoutingRule) Descriptor ¶
func (*RoutingRule) Descriptor() ([]byte, []int)
func (*RoutingRule) GetFromTable ¶
func (m *RoutingRule) GetFromTable() string
func (*RoutingRule) GetToTables ¶
func (m *RoutingRule) GetToTables() []string
func (*RoutingRule) ProtoMessage ¶
func (*RoutingRule) ProtoMessage()
func (*RoutingRule) Reset ¶
func (m *RoutingRule) Reset()
func (*RoutingRule) String ¶
func (m *RoutingRule) String() string
func (*RoutingRule) XXX_DiscardUnknown ¶
func (m *RoutingRule) XXX_DiscardUnknown()
func (*RoutingRule) XXX_Marshal ¶
func (m *RoutingRule) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RoutingRule) XXX_Merge ¶
func (m *RoutingRule) XXX_Merge(src proto.Message)
func (*RoutingRule) XXX_Size ¶
func (m *RoutingRule) XXX_Size() int
func (*RoutingRule) XXX_Unmarshal ¶
func (m *RoutingRule) XXX_Unmarshal(b []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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
RoutingRules specify the high level routing rules for the VSchema.
func (*RoutingRules) Descriptor ¶
func (*RoutingRules) Descriptor() ([]byte, []int)
func (*RoutingRules) GetRules ¶
func (m *RoutingRules) GetRules() []*RoutingRule
func (*RoutingRules) ProtoMessage ¶
func (*RoutingRules) ProtoMessage()
func (*RoutingRules) Reset ¶
func (m *RoutingRules) Reset()
func (*RoutingRules) String ¶
func (m *RoutingRules) String() string
func (*RoutingRules) XXX_DiscardUnknown ¶
func (m *RoutingRules) XXX_DiscardUnknown()
func (*RoutingRules) XXX_Marshal ¶
func (m *RoutingRules) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RoutingRules) XXX_Merge ¶
func (m *RoutingRules) XXX_Merge(src proto.Message)
func (*RoutingRules) XXX_Size ¶
func (m *RoutingRules) XXX_Size() int
func (*RoutingRules) XXX_Unmarshal ¶
func (m *RoutingRules) XXX_Unmarshal(b []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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
SrvVSchema is the roll-up of all the Keyspace schema for a cell.
func (*SrvVSchema) Descriptor ¶
func (*SrvVSchema) Descriptor() ([]byte, []int)
func (*SrvVSchema) GetKeyspaces ¶
func (m *SrvVSchema) GetKeyspaces() map[string]*Keyspace
func (*SrvVSchema) GetRoutingRules ¶
func (m *SrvVSchema) GetRoutingRules() *RoutingRules
func (*SrvVSchema) ProtoMessage ¶
func (*SrvVSchema) ProtoMessage()
func (*SrvVSchema) Reset ¶
func (m *SrvVSchema) Reset()
func (*SrvVSchema) String ¶
func (m *SrvVSchema) String() string
func (*SrvVSchema) XXX_DiscardUnknown ¶
func (m *SrvVSchema) XXX_DiscardUnknown()
func (*SrvVSchema) XXX_Marshal ¶
func (m *SrvVSchema) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SrvVSchema) XXX_Merge ¶
func (m *SrvVSchema) XXX_Merge(src proto.Message)
func (*SrvVSchema) XXX_Size ¶
func (m *SrvVSchema) XXX_Size() int
func (*SrvVSchema) XXX_Unmarshal ¶
func (m *SrvVSchema) XXX_Unmarshal(b []byte) error
type Table ¶
type Table struct { // If the table is a sequence, type must be // "sequence". 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 */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Table is the table info for a Keyspace.
func (*Table) Descriptor ¶
func (*Table) GetAutoIncrement ¶
func (m *Table) GetAutoIncrement() *AutoIncrement
func (*Table) GetColumnListAuthoritative ¶
func (*Table) GetColumnVindexes ¶
func (m *Table) GetColumnVindexes() []*ColumnVindex
func (*Table) GetColumns ¶
func (*Table) ProtoMessage ¶
func (*Table) ProtoMessage()
func (*Table) XXX_DiscardUnknown ¶
func (m *Table) XXX_DiscardUnknown()
func (*Table) XXX_Marshal ¶
func (*Table) XXX_Unmarshal ¶
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Vindex is the vindex info for a Keyspace.
func (*Vindex) Descriptor ¶
func (*Vindex) ProtoMessage ¶
func (*Vindex) ProtoMessage()
func (*Vindex) XXX_DiscardUnknown ¶
func (m *Vindex) XXX_DiscardUnknown()
func (*Vindex) XXX_Marshal ¶
func (*Vindex) XXX_Unmarshal ¶
Click to show internal directories.
Click to hide internal directories.