go-vitess.v1: gopkg.in/src-d/go-vitess.v1/vt/proto/topodata Index | Files

package topodata

import "gopkg.in/src-d/go-vitess.v1/vt/proto/topodata"

Index

Package Files

topodata.pb.go

Variables

var KeyspaceIdType_name = map[int32]string{
    0:  "UNSET",
    1:  "UINT64",
    2:  "BYTES",
}
var KeyspaceIdType_value = map[string]int32{
    "UNSET":  0,
    "UINT64": 1,
    "BYTES":  2,
}
var TabletType_name = map[int32]string{
    0:  "UNKNOWN",
    1:  "MASTER",
    2:  "REPLICA",
    3:  "RDONLY",

    4:  "SPARE",
    5:  "EXPERIMENTAL",
    6:  "BACKUP",
    7:  "RESTORE",
    8:  "DRAINED",
}
var TabletType_value = map[string]int32{
    "UNKNOWN":      0,
    "MASTER":       1,
    "REPLICA":      2,
    "RDONLY":       3,
    "BATCH":        3,
    "SPARE":        4,
    "EXPERIMENTAL": 5,
    "BACKUP":       6,
    "RESTORE":      7,
    "DRAINED":      8,
}

type CellInfo Uses

type CellInfo struct {
    // ServerAddress contains the address of the server for the cell.
    // The syntax of this field is topology implementation specific.
    // For instance, for Zookeeper, it is a comma-separated list of
    // server addresses.
    ServerAddress string `protobuf:"bytes,1,opt,name=server_address,json=serverAddress,proto3" json:"server_address,omitempty"`
    // Root is the path to store data in. It is only used when talking
    // to server_address.
    Root                 string   `protobuf:"bytes,2,opt,name=root,proto3" json:"root,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

CellInfo contains information about a cell. CellInfo objects are stored in the global topology server, and describe how to reach local topology servers.

func (*CellInfo) Descriptor Uses

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

func (*CellInfo) GetRoot Uses

func (m *CellInfo) GetRoot() string

func (*CellInfo) GetServerAddress Uses

func (m *CellInfo) GetServerAddress() string

func (*CellInfo) ProtoMessage Uses

func (*CellInfo) ProtoMessage()

func (*CellInfo) Reset Uses

func (m *CellInfo) Reset()

func (*CellInfo) String Uses

func (m *CellInfo) String() string

func (*CellInfo) XXX_DiscardUnknown Uses

func (m *CellInfo) XXX_DiscardUnknown()

func (*CellInfo) XXX_Marshal Uses

func (m *CellInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CellInfo) XXX_Merge Uses

func (dst *CellInfo) XXX_Merge(src proto.Message)

func (*CellInfo) XXX_Size Uses

func (m *CellInfo) XXX_Size() int

func (*CellInfo) XXX_Unmarshal Uses

func (m *CellInfo) XXX_Unmarshal(b []byte) error

type CellsAlias Uses

type CellsAlias struct {
    // Cells that map to this alias
    Cells                []string `protobuf:"bytes,2,rep,name=cells,proto3" json:"cells,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

CellsAlias

func (*CellsAlias) Descriptor Uses

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

func (*CellsAlias) GetCells Uses

func (m *CellsAlias) GetCells() []string

func (*CellsAlias) ProtoMessage Uses

func (*CellsAlias) ProtoMessage()

func (*CellsAlias) Reset Uses

func (m *CellsAlias) Reset()

func (*CellsAlias) String Uses

func (m *CellsAlias) String() string

func (*CellsAlias) XXX_DiscardUnknown Uses

func (m *CellsAlias) XXX_DiscardUnknown()

func (*CellsAlias) XXX_Marshal Uses

func (m *CellsAlias) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CellsAlias) XXX_Merge Uses

func (dst *CellsAlias) XXX_Merge(src proto.Message)

func (*CellsAlias) XXX_Size Uses

func (m *CellsAlias) XXX_Size() int

func (*CellsAlias) XXX_Unmarshal Uses

func (m *CellsAlias) XXX_Unmarshal(b []byte) error

type KeyRange Uses

type KeyRange struct {
    Start                []byte   `protobuf:"bytes,1,opt,name=start,proto3" json:"start,omitempty"`
    End                  []byte   `protobuf:"bytes,2,opt,name=end,proto3" json:"end,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

KeyRange describes a range of sharding keys, when range-based sharding is used.

func (*KeyRange) Descriptor Uses

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

func (*KeyRange) GetEnd Uses

func (m *KeyRange) GetEnd() []byte

func (*KeyRange) GetStart Uses

func (m *KeyRange) GetStart() []byte

func (*KeyRange) ProtoMessage Uses

func (*KeyRange) ProtoMessage()

func (*KeyRange) Reset Uses

func (m *KeyRange) Reset()

func (*KeyRange) String Uses

func (m *KeyRange) String() string

func (*KeyRange) XXX_DiscardUnknown Uses

func (m *KeyRange) XXX_DiscardUnknown()

func (*KeyRange) XXX_Marshal Uses

func (m *KeyRange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KeyRange) XXX_Merge Uses

func (dst *KeyRange) XXX_Merge(src proto.Message)

func (*KeyRange) XXX_Size Uses

func (m *KeyRange) XXX_Size() int

func (*KeyRange) XXX_Unmarshal Uses

func (m *KeyRange) XXX_Unmarshal(b []byte) error

type Keyspace Uses

type Keyspace struct {
    // name of the column used for sharding
    // empty if the keyspace is not sharded
    ShardingColumnName string `protobuf:"bytes,1,opt,name=sharding_column_name,json=shardingColumnName,proto3" json:"sharding_column_name,omitempty"`
    // type of the column used for sharding
    // UNSET if the keyspace is not sharded
    ShardingColumnType KeyspaceIdType `protobuf:"varint,2,opt,name=sharding_column_type,json=shardingColumnType,proto3,enum=topodata.KeyspaceIdType" json:"sharding_column_type,omitempty"`
    // ServedFrom will redirect the appropriate traffic to
    // another keyspace.
    ServedFroms          []*Keyspace_ServedFrom `protobuf:"bytes,4,rep,name=served_froms,json=servedFroms,proto3" json:"served_froms,omitempty"`
    XXX_NoUnkeyedLiteral struct{}               `json:"-"`
    XXX_unrecognized     []byte                 `json:"-"`
    XXX_sizecache        int32                  `json:"-"`
}

A Keyspace contains data about a keyspace.

func (*Keyspace) Descriptor Uses

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

func (*Keyspace) GetServedFroms Uses

func (m *Keyspace) GetServedFroms() []*Keyspace_ServedFrom

func (*Keyspace) GetShardingColumnName Uses

func (m *Keyspace) GetShardingColumnName() string

func (*Keyspace) GetShardingColumnType Uses

func (m *Keyspace) GetShardingColumnType() KeyspaceIdType

func (*Keyspace) ProtoMessage Uses

func (*Keyspace) ProtoMessage()

func (*Keyspace) Reset Uses

func (m *Keyspace) Reset()

func (*Keyspace) String Uses

func (m *Keyspace) String() string

func (*Keyspace) XXX_DiscardUnknown Uses

func (m *Keyspace) XXX_DiscardUnknown()

func (*Keyspace) XXX_Marshal Uses

func (m *Keyspace) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Keyspace) XXX_Merge Uses

func (dst *Keyspace) XXX_Merge(src proto.Message)

func (*Keyspace) XXX_Size Uses

func (m *Keyspace) XXX_Size() int

func (*Keyspace) XXX_Unmarshal Uses

func (m *Keyspace) XXX_Unmarshal(b []byte) error

type KeyspaceIdType Uses

type KeyspaceIdType int32

KeyspaceIdType describes the type of the sharding key for a range-based sharded keyspace.

const (
    // UNSET is the default value, when range-based sharding is not used.
    KeyspaceIdType_UNSET KeyspaceIdType = 0
    // UINT64 is when uint64 value is used.
    // This is represented as 'unsigned bigint' in mysql
    KeyspaceIdType_UINT64 KeyspaceIdType = 1
    // BYTES is when an array of bytes is used.
    // This is represented as 'varbinary' in mysql
    KeyspaceIdType_BYTES KeyspaceIdType = 2
)

func (KeyspaceIdType) EnumDescriptor Uses

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

func (KeyspaceIdType) String Uses

func (x KeyspaceIdType) String() string

type Keyspace_ServedFrom Uses

type Keyspace_ServedFrom struct {
    // the tablet type (key for the map)
    TabletType TabletType `protobuf:"varint,1,opt,name=tablet_type,json=tabletType,proto3,enum=topodata.TabletType" json:"tablet_type,omitempty"`
    // the cells to limit this to
    Cells []string `protobuf:"bytes,2,rep,name=cells,proto3" json:"cells,omitempty"`
    // the keyspace name that's serving it
    Keyspace             string   `protobuf:"bytes,3,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

ServedFrom indicates a relationship between a TabletType and the keyspace name that's serving it.

func (*Keyspace_ServedFrom) Descriptor Uses

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

func (*Keyspace_ServedFrom) GetCells Uses

func (m *Keyspace_ServedFrom) GetCells() []string

func (*Keyspace_ServedFrom) GetKeyspace Uses

func (m *Keyspace_ServedFrom) GetKeyspace() string

func (*Keyspace_ServedFrom) GetTabletType Uses

func (m *Keyspace_ServedFrom) GetTabletType() TabletType

func (*Keyspace_ServedFrom) ProtoMessage Uses

func (*Keyspace_ServedFrom) ProtoMessage()

func (*Keyspace_ServedFrom) Reset Uses

func (m *Keyspace_ServedFrom) Reset()

func (*Keyspace_ServedFrom) String Uses

func (m *Keyspace_ServedFrom) String() string

func (*Keyspace_ServedFrom) XXX_DiscardUnknown Uses

func (m *Keyspace_ServedFrom) XXX_DiscardUnknown()

func (*Keyspace_ServedFrom) XXX_Marshal Uses

func (m *Keyspace_ServedFrom) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Keyspace_ServedFrom) XXX_Merge Uses

func (dst *Keyspace_ServedFrom) XXX_Merge(src proto.Message)

func (*Keyspace_ServedFrom) XXX_Size Uses

func (m *Keyspace_ServedFrom) XXX_Size() int

func (*Keyspace_ServedFrom) XXX_Unmarshal Uses

func (m *Keyspace_ServedFrom) XXX_Unmarshal(b []byte) error

type Shard Uses

type Shard struct {
    // No lock is necessary to update this field, when for instance
    // TabletExternallyReparented updates this. However, we lock the
    // shard for reparenting operations (InitShardMaster,
    // PlannedReparentShard,EmergencyReparentShard), to guarantee
    // exclusive operation.
    MasterAlias *TabletAlias `protobuf:"bytes,1,opt,name=master_alias,json=masterAlias,proto3" json:"master_alias,omitempty"`
    // key_range is the KeyRange for this shard. It can be unset if:
    // - we are not using range-based sharding in this shard.
    // - the shard covers the entire keyrange.
    // This must match the shard name based on our other conventions, but
    // helpful to have it decomposed here.
    // Once set at creation time, it is never changed.
    KeyRange *KeyRange `protobuf:"bytes,2,opt,name=key_range,json=keyRange,proto3" json:"key_range,omitempty"`
    // served_types has at most one entry per TabletType
    // This field is in the process of being deprecated in favor of
    // is_master_serving. Keeping for backwards compatibility purposes.
    ServedTypes []*Shard_ServedType `protobuf:"bytes,3,rep,name=served_types,json=servedTypes,proto3" json:"served_types,omitempty"`
    // SourceShards is the list of shards we're replicating from,
    // using filtered replication.
    // The keyspace lock is always taken when changing this.
    SourceShards []*Shard_SourceShard `protobuf:"bytes,4,rep,name=source_shards,json=sourceShards,proto3" json:"source_shards,omitempty"`
    // tablet_controls has at most one entry per TabletType.
    // The keyspace lock is always taken when changing this.
    TabletControls []*Shard_TabletControl `protobuf:"bytes,6,rep,name=tablet_controls,json=tabletControls,proto3" json:"tablet_controls,omitempty"`
    // is_master_serving sets whether this shard master is serving traffic or not.
    // The keyspace lock is always taken when changing this.
    IsMasterServing      bool     `protobuf:"varint,7,opt,name=is_master_serving,json=isMasterServing,proto3" json:"is_master_serving,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

A Shard contains data about a subset of the data whithin a keyspace.

func (*Shard) Descriptor Uses

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

func (*Shard) GetIsMasterServing Uses

func (m *Shard) GetIsMasterServing() bool

func (*Shard) GetKeyRange Uses

func (m *Shard) GetKeyRange() *KeyRange

func (*Shard) GetMasterAlias Uses

func (m *Shard) GetMasterAlias() *TabletAlias

func (*Shard) GetServedTypes Uses

func (m *Shard) GetServedTypes() []*Shard_ServedType

func (*Shard) GetSourceShards Uses

func (m *Shard) GetSourceShards() []*Shard_SourceShard

func (*Shard) GetTabletControls Uses

func (m *Shard) GetTabletControls() []*Shard_TabletControl

func (*Shard) ProtoMessage Uses

func (*Shard) ProtoMessage()

func (*Shard) Reset Uses

func (m *Shard) Reset()

func (*Shard) String Uses

func (m *Shard) String() string

func (*Shard) XXX_DiscardUnknown Uses

func (m *Shard) XXX_DiscardUnknown()

func (*Shard) XXX_Marshal Uses

func (m *Shard) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Shard) XXX_Merge Uses

func (dst *Shard) XXX_Merge(src proto.Message)

func (*Shard) XXX_Size Uses

func (m *Shard) XXX_Size() int

func (*Shard) XXX_Unmarshal Uses

func (m *Shard) XXX_Unmarshal(b []byte) error

type ShardReference Uses

type ShardReference struct {
    // Copied from Shard.
    Name                 string    `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
    KeyRange             *KeyRange `protobuf:"bytes,2,opt,name=key_range,json=keyRange,proto3" json:"key_range,omitempty"`
    XXX_NoUnkeyedLiteral struct{}  `json:"-"`
    XXX_unrecognized     []byte    `json:"-"`
    XXX_sizecache        int32     `json:"-"`
}

ShardReference is used as a pointer from a SrvKeyspace to a Shard

func (*ShardReference) Descriptor Uses

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

func (*ShardReference) GetKeyRange Uses

func (m *ShardReference) GetKeyRange() *KeyRange

func (*ShardReference) GetName Uses

func (m *ShardReference) GetName() string

func (*ShardReference) ProtoMessage Uses

func (*ShardReference) ProtoMessage()

func (*ShardReference) Reset Uses

func (m *ShardReference) Reset()

func (*ShardReference) String Uses

func (m *ShardReference) String() string

func (*ShardReference) XXX_DiscardUnknown Uses

func (m *ShardReference) XXX_DiscardUnknown()

func (*ShardReference) XXX_Marshal Uses

func (m *ShardReference) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ShardReference) XXX_Merge Uses

func (dst *ShardReference) XXX_Merge(src proto.Message)

func (*ShardReference) XXX_Size Uses

func (m *ShardReference) XXX_Size() int

func (*ShardReference) XXX_Unmarshal Uses

func (m *ShardReference) XXX_Unmarshal(b []byte) error

type ShardReplication Uses

type ShardReplication struct {
    // Note there can be only one Node in this array
    // for a given tablet.
    Nodes                []*ShardReplication_Node `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"`
    XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
    XXX_unrecognized     []byte                   `json:"-"`
    XXX_sizecache        int32                    `json:"-"`
}

ShardReplication describes the MySQL replication relationships whithin a cell.

func (*ShardReplication) Descriptor Uses

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

func (*ShardReplication) GetNodes Uses

func (m *ShardReplication) GetNodes() []*ShardReplication_Node

func (*ShardReplication) ProtoMessage Uses

func (*ShardReplication) ProtoMessage()

func (*ShardReplication) Reset Uses

func (m *ShardReplication) Reset()

func (*ShardReplication) String Uses

func (m *ShardReplication) String() string

func (*ShardReplication) XXX_DiscardUnknown Uses

func (m *ShardReplication) XXX_DiscardUnknown()

func (*ShardReplication) XXX_Marshal Uses

func (m *ShardReplication) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ShardReplication) XXX_Merge Uses

func (dst *ShardReplication) XXX_Merge(src proto.Message)

func (*ShardReplication) XXX_Size Uses

func (m *ShardReplication) XXX_Size() int

func (*ShardReplication) XXX_Unmarshal Uses

func (m *ShardReplication) XXX_Unmarshal(b []byte) error

type ShardReplication_Node Uses

type ShardReplication_Node struct {
    TabletAlias          *TabletAlias `protobuf:"bytes,1,opt,name=tablet_alias,json=tabletAlias,proto3" json:"tablet_alias,omitempty"`
    XXX_NoUnkeyedLiteral struct{}     `json:"-"`
    XXX_unrecognized     []byte       `json:"-"`
    XXX_sizecache        int32        `json:"-"`
}

Node describes a tablet instance within the cell

func (*ShardReplication_Node) Descriptor Uses

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

func (*ShardReplication_Node) GetTabletAlias Uses

func (m *ShardReplication_Node) GetTabletAlias() *TabletAlias

func (*ShardReplication_Node) ProtoMessage Uses

func (*ShardReplication_Node) ProtoMessage()

func (*ShardReplication_Node) Reset Uses

func (m *ShardReplication_Node) Reset()

func (*ShardReplication_Node) String Uses

func (m *ShardReplication_Node) String() string

func (*ShardReplication_Node) XXX_DiscardUnknown Uses

func (m *ShardReplication_Node) XXX_DiscardUnknown()

func (*ShardReplication_Node) XXX_Marshal Uses

func (m *ShardReplication_Node) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ShardReplication_Node) XXX_Merge Uses

func (dst *ShardReplication_Node) XXX_Merge(src proto.Message)

func (*ShardReplication_Node) XXX_Size Uses

func (m *ShardReplication_Node) XXX_Size() int

func (*ShardReplication_Node) XXX_Unmarshal Uses

func (m *ShardReplication_Node) XXX_Unmarshal(b []byte) error

type ShardTabletControl Uses

type ShardTabletControl struct {
    // Copied from Shard.
    Name     string    `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
    KeyRange *KeyRange `protobuf:"bytes,2,opt,name=key_range,json=keyRange,proto3" json:"key_range,omitempty"`
    // Disable query serving in this shard
    QueryServiceDisabled bool     `protobuf:"varint,3,opt,name=query_service_disabled,json=queryServiceDisabled,proto3" json:"query_service_disabled,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

ShardTabletControl is used as a pointer from a SrvKeyspace to a Shard

func (*ShardTabletControl) Descriptor Uses

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

func (*ShardTabletControl) GetKeyRange Uses

func (m *ShardTabletControl) GetKeyRange() *KeyRange

func (*ShardTabletControl) GetName Uses

func (m *ShardTabletControl) GetName() string

func (*ShardTabletControl) GetQueryServiceDisabled Uses

func (m *ShardTabletControl) GetQueryServiceDisabled() bool

func (*ShardTabletControl) ProtoMessage Uses

func (*ShardTabletControl) ProtoMessage()

func (*ShardTabletControl) Reset Uses

func (m *ShardTabletControl) Reset()

func (*ShardTabletControl) String Uses

func (m *ShardTabletControl) String() string

func (*ShardTabletControl) XXX_DiscardUnknown Uses

func (m *ShardTabletControl) XXX_DiscardUnknown()

func (*ShardTabletControl) XXX_Marshal Uses

func (m *ShardTabletControl) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ShardTabletControl) XXX_Merge Uses

func (dst *ShardTabletControl) XXX_Merge(src proto.Message)

func (*ShardTabletControl) XXX_Size Uses

func (m *ShardTabletControl) XXX_Size() int

func (*ShardTabletControl) XXX_Unmarshal Uses

func (m *ShardTabletControl) XXX_Unmarshal(b []byte) error

type Shard_ServedType Uses

type Shard_ServedType struct {
    TabletType           TabletType `protobuf:"varint,1,opt,name=tablet_type,json=tabletType,proto3,enum=topodata.TabletType" json:"tablet_type,omitempty"`
    Cells                []string   `protobuf:"bytes,2,rep,name=cells,proto3" json:"cells,omitempty"`
    XXX_NoUnkeyedLiteral struct{}   `json:"-"`
    XXX_unrecognized     []byte     `json:"-"`
    XXX_sizecache        int32      `json:"-"`
}

ServedType is an entry in the served_types

func (*Shard_ServedType) Descriptor Uses

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

func (*Shard_ServedType) GetCells Uses

func (m *Shard_ServedType) GetCells() []string

func (*Shard_ServedType) GetTabletType Uses

func (m *Shard_ServedType) GetTabletType() TabletType

func (*Shard_ServedType) ProtoMessage Uses

func (*Shard_ServedType) ProtoMessage()

func (*Shard_ServedType) Reset Uses

func (m *Shard_ServedType) Reset()

func (*Shard_ServedType) String Uses

func (m *Shard_ServedType) String() string

func (*Shard_ServedType) XXX_DiscardUnknown Uses

func (m *Shard_ServedType) XXX_DiscardUnknown()

func (*Shard_ServedType) XXX_Marshal Uses

func (m *Shard_ServedType) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Shard_ServedType) XXX_Merge Uses

func (dst *Shard_ServedType) XXX_Merge(src proto.Message)

func (*Shard_ServedType) XXX_Size Uses

func (m *Shard_ServedType) XXX_Size() int

func (*Shard_ServedType) XXX_Unmarshal Uses

func (m *Shard_ServedType) XXX_Unmarshal(b []byte) error

type Shard_SourceShard Uses

type Shard_SourceShard struct {
    // Uid is the unique ID for this SourceShard object.
    Uid uint32 `protobuf:"varint,1,opt,name=uid,proto3" json:"uid,omitempty"`
    // the source keyspace
    Keyspace string `protobuf:"bytes,2,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
    // the source shard
    Shard string `protobuf:"bytes,3,opt,name=shard,proto3" json:"shard,omitempty"`
    // the source shard keyrange
    KeyRange *KeyRange `protobuf:"bytes,4,opt,name=key_range,json=keyRange,proto3" json:"key_range,omitempty"`
    // the source table list to replicate
    Tables               []string `protobuf:"bytes,5,rep,name=tables,proto3" json:"tables,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

SourceShard represents a data source for filtered replication accross shards. When this is used in a destination shard, the master of that shard will run filtered replication.

func (*Shard_SourceShard) Descriptor Uses

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

func (*Shard_SourceShard) GetKeyRange Uses

func (m *Shard_SourceShard) GetKeyRange() *KeyRange

func (*Shard_SourceShard) GetKeyspace Uses

func (m *Shard_SourceShard) GetKeyspace() string

func (*Shard_SourceShard) GetShard Uses

func (m *Shard_SourceShard) GetShard() string

func (*Shard_SourceShard) GetTables Uses

func (m *Shard_SourceShard) GetTables() []string

func (*Shard_SourceShard) GetUid Uses

func (m *Shard_SourceShard) GetUid() uint32

func (*Shard_SourceShard) ProtoMessage Uses

func (*Shard_SourceShard) ProtoMessage()

func (*Shard_SourceShard) Reset Uses

func (m *Shard_SourceShard) Reset()

func (*Shard_SourceShard) String Uses

func (m *Shard_SourceShard) String() string

func (*Shard_SourceShard) XXX_DiscardUnknown Uses

func (m *Shard_SourceShard) XXX_DiscardUnknown()

func (*Shard_SourceShard) XXX_Marshal Uses

func (m *Shard_SourceShard) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Shard_SourceShard) XXX_Merge Uses

func (dst *Shard_SourceShard) XXX_Merge(src proto.Message)

func (*Shard_SourceShard) XXX_Size Uses

func (m *Shard_SourceShard) XXX_Size() int

func (*Shard_SourceShard) XXX_Unmarshal Uses

func (m *Shard_SourceShard) XXX_Unmarshal(b []byte) error

type Shard_TabletControl Uses

type Shard_TabletControl struct {
    // which tablet type is affected
    TabletType        TabletType `protobuf:"varint,1,opt,name=tablet_type,json=tabletType,proto3,enum=topodata.TabletType" json:"tablet_type,omitempty"`
    Cells             []string   `protobuf:"bytes,2,rep,name=cells,proto3" json:"cells,omitempty"`
    BlacklistedTables []string   `protobuf:"bytes,4,rep,name=blacklisted_tables,json=blacklistedTables,proto3" json:"blacklisted_tables,omitempty"`
    // frozen is set if we've started failing over traffic for
    // the master. If set, this record should not be removed.
    Frozen               bool     `protobuf:"varint,5,opt,name=frozen,proto3" json:"frozen,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

TabletControl controls tablet's behavior

func (*Shard_TabletControl) Descriptor Uses

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

func (*Shard_TabletControl) GetBlacklistedTables Uses

func (m *Shard_TabletControl) GetBlacklistedTables() []string

func (*Shard_TabletControl) GetCells Uses

func (m *Shard_TabletControl) GetCells() []string

func (*Shard_TabletControl) GetFrozen Uses

func (m *Shard_TabletControl) GetFrozen() bool

func (*Shard_TabletControl) GetTabletType Uses

func (m *Shard_TabletControl) GetTabletType() TabletType

func (*Shard_TabletControl) ProtoMessage Uses

func (*Shard_TabletControl) ProtoMessage()

func (*Shard_TabletControl) Reset Uses

func (m *Shard_TabletControl) Reset()

func (*Shard_TabletControl) String Uses

func (m *Shard_TabletControl) String() string

func (*Shard_TabletControl) XXX_DiscardUnknown Uses

func (m *Shard_TabletControl) XXX_DiscardUnknown()

func (*Shard_TabletControl) XXX_Marshal Uses

func (m *Shard_TabletControl) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Shard_TabletControl) XXX_Merge Uses

func (dst *Shard_TabletControl) XXX_Merge(src proto.Message)

func (*Shard_TabletControl) XXX_Size Uses

func (m *Shard_TabletControl) XXX_Size() int

func (*Shard_TabletControl) XXX_Unmarshal Uses

func (m *Shard_TabletControl) XXX_Unmarshal(b []byte) error

type SrvKeyspace Uses

type SrvKeyspace struct {
    // The partitions this keyspace is serving, per tablet type.
    Partitions []*SrvKeyspace_KeyspacePartition `protobuf:"bytes,1,rep,name=partitions,proto3" json:"partitions,omitempty"`
    // copied from Keyspace
    ShardingColumnName   string                    `protobuf:"bytes,2,opt,name=sharding_column_name,json=shardingColumnName,proto3" json:"sharding_column_name,omitempty"`
    ShardingColumnType   KeyspaceIdType            `protobuf:"varint,3,opt,name=sharding_column_type,json=shardingColumnType,proto3,enum=topodata.KeyspaceIdType" json:"sharding_column_type,omitempty"`
    ServedFrom           []*SrvKeyspace_ServedFrom `protobuf:"bytes,4,rep,name=served_from,json=servedFrom,proto3" json:"served_from,omitempty"`
    XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
    XXX_unrecognized     []byte                    `json:"-"`
    XXX_sizecache        int32                     `json:"-"`
}

SrvKeyspace is a rollup node for the keyspace itself.

func (*SrvKeyspace) Descriptor Uses

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

func (*SrvKeyspace) GetPartitions Uses

func (m *SrvKeyspace) GetPartitions() []*SrvKeyspace_KeyspacePartition

func (*SrvKeyspace) GetServedFrom Uses

func (m *SrvKeyspace) GetServedFrom() []*SrvKeyspace_ServedFrom

func (*SrvKeyspace) GetShardingColumnName Uses

func (m *SrvKeyspace) GetShardingColumnName() string

func (*SrvKeyspace) GetShardingColumnType Uses

func (m *SrvKeyspace) GetShardingColumnType() KeyspaceIdType

func (*SrvKeyspace) ProtoMessage Uses

func (*SrvKeyspace) ProtoMessage()

func (*SrvKeyspace) Reset Uses

func (m *SrvKeyspace) Reset()

func (*SrvKeyspace) String Uses

func (m *SrvKeyspace) String() string

func (*SrvKeyspace) XXX_DiscardUnknown Uses

func (m *SrvKeyspace) XXX_DiscardUnknown()

func (*SrvKeyspace) XXX_Marshal Uses

func (m *SrvKeyspace) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SrvKeyspace) XXX_Merge Uses

func (dst *SrvKeyspace) XXX_Merge(src proto.Message)

func (*SrvKeyspace) XXX_Size Uses

func (m *SrvKeyspace) XXX_Size() int

func (*SrvKeyspace) XXX_Unmarshal Uses

func (m *SrvKeyspace) XXX_Unmarshal(b []byte) error

type SrvKeyspace_KeyspacePartition Uses

type SrvKeyspace_KeyspacePartition struct {
    // The type this partition applies to.
    ServedType TabletType `protobuf:"varint,1,opt,name=served_type,json=servedType,proto3,enum=topodata.TabletType" json:"served_type,omitempty"`
    // List of non-overlapping continuous shards sorted by range.
    ShardReferences []*ShardReference `protobuf:"bytes,2,rep,name=shard_references,json=shardReferences,proto3" json:"shard_references,omitempty"`
    // List of shard tablet controls
    ShardTabletControls  []*ShardTabletControl `protobuf:"bytes,3,rep,name=shard_tablet_controls,json=shardTabletControls,proto3" json:"shard_tablet_controls,omitempty"`
    XXX_NoUnkeyedLiteral struct{}              `json:"-"`
    XXX_unrecognized     []byte                `json:"-"`
    XXX_sizecache        int32                 `json:"-"`
}

func (*SrvKeyspace_KeyspacePartition) Descriptor Uses

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

func (*SrvKeyspace_KeyspacePartition) GetServedType Uses

func (m *SrvKeyspace_KeyspacePartition) GetServedType() TabletType

func (*SrvKeyspace_KeyspacePartition) GetShardReferences Uses

func (m *SrvKeyspace_KeyspacePartition) GetShardReferences() []*ShardReference

func (*SrvKeyspace_KeyspacePartition) GetShardTabletControls Uses

func (m *SrvKeyspace_KeyspacePartition) GetShardTabletControls() []*ShardTabletControl

func (*SrvKeyspace_KeyspacePartition) ProtoMessage Uses

func (*SrvKeyspace_KeyspacePartition) ProtoMessage()

func (*SrvKeyspace_KeyspacePartition) Reset Uses

func (m *SrvKeyspace_KeyspacePartition) Reset()

func (*SrvKeyspace_KeyspacePartition) String Uses

func (m *SrvKeyspace_KeyspacePartition) String() string

func (*SrvKeyspace_KeyspacePartition) XXX_DiscardUnknown Uses

func (m *SrvKeyspace_KeyspacePartition) XXX_DiscardUnknown()

func (*SrvKeyspace_KeyspacePartition) XXX_Marshal Uses

func (m *SrvKeyspace_KeyspacePartition) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SrvKeyspace_KeyspacePartition) XXX_Merge Uses

func (dst *SrvKeyspace_KeyspacePartition) XXX_Merge(src proto.Message)

func (*SrvKeyspace_KeyspacePartition) XXX_Size Uses

func (m *SrvKeyspace_KeyspacePartition) XXX_Size() int

func (*SrvKeyspace_KeyspacePartition) XXX_Unmarshal Uses

func (m *SrvKeyspace_KeyspacePartition) XXX_Unmarshal(b []byte) error

type SrvKeyspace_ServedFrom Uses

type SrvKeyspace_ServedFrom struct {
    // the tablet type
    TabletType TabletType `protobuf:"varint,1,opt,name=tablet_type,json=tabletType,proto3,enum=topodata.TabletType" json:"tablet_type,omitempty"`
    // the keyspace name that's serving it
    Keyspace             string   `protobuf:"bytes,2,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

ServedFrom indicates a relationship between a TabletType and the keyspace name that's serving it.

func (*SrvKeyspace_ServedFrom) Descriptor Uses

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

func (*SrvKeyspace_ServedFrom) GetKeyspace Uses

func (m *SrvKeyspace_ServedFrom) GetKeyspace() string

func (*SrvKeyspace_ServedFrom) GetTabletType Uses

func (m *SrvKeyspace_ServedFrom) GetTabletType() TabletType

func (*SrvKeyspace_ServedFrom) ProtoMessage Uses

func (*SrvKeyspace_ServedFrom) ProtoMessage()

func (*SrvKeyspace_ServedFrom) Reset Uses

func (m *SrvKeyspace_ServedFrom) Reset()

func (*SrvKeyspace_ServedFrom) String Uses

func (m *SrvKeyspace_ServedFrom) String() string

func (*SrvKeyspace_ServedFrom) XXX_DiscardUnknown Uses

func (m *SrvKeyspace_ServedFrom) XXX_DiscardUnknown()

func (*SrvKeyspace_ServedFrom) XXX_Marshal Uses

func (m *SrvKeyspace_ServedFrom) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SrvKeyspace_ServedFrom) XXX_Merge Uses

func (dst *SrvKeyspace_ServedFrom) XXX_Merge(src proto.Message)

func (*SrvKeyspace_ServedFrom) XXX_Size Uses

func (m *SrvKeyspace_ServedFrom) XXX_Size() int

func (*SrvKeyspace_ServedFrom) XXX_Unmarshal Uses

func (m *SrvKeyspace_ServedFrom) XXX_Unmarshal(b []byte) error

type Tablet Uses

type Tablet struct {
    // alias is the unique name of the tablet.
    Alias *TabletAlias `protobuf:"bytes,1,opt,name=alias,proto3" json:"alias,omitempty"`
    // Fully qualified domain name of the host.
    Hostname string `protobuf:"bytes,2,opt,name=hostname,proto3" json:"hostname,omitempty"`
    // Map of named ports. Normally this should include vt and grpc.
    // Going forward, the mysql port will be stored in mysql_port
    // instead of here.
    // For accessing mysql port, use topoproto.MysqlPort to fetch, and
    // topoproto.SetMysqlPort to set. These wrappers will ensure
    // legacy behavior is supported.
    PortMap map[string]int32 `protobuf:"bytes,4,rep,name=port_map,json=portMap,proto3" json:"port_map,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"varint,2,opt,name=value,proto3"`
    // Keyspace name.
    Keyspace string `protobuf:"bytes,5,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
    // Shard name. If range based sharding is used, it should match
    // key_range.
    Shard string `protobuf:"bytes,6,opt,name=shard,proto3" json:"shard,omitempty"`
    // If range based sharding is used, range for the tablet's shard.
    KeyRange *KeyRange `protobuf:"bytes,7,opt,name=key_range,json=keyRange,proto3" json:"key_range,omitempty"`
    // type is the current type of the tablet.
    Type TabletType `protobuf:"varint,8,opt,name=type,proto3,enum=topodata.TabletType" json:"type,omitempty"`
    // It this is set, it is used as the database name instead of the
    // normal "vt_" + keyspace.
    DbNameOverride string `protobuf:"bytes,9,opt,name=db_name_override,json=dbNameOverride,proto3" json:"db_name_override,omitempty"`
    // tablet tags
    Tags map[string]string `protobuf:"bytes,10,rep,name=tags,proto3" json:"tags,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    // MySQL hostname.
    MysqlHostname string `protobuf:"bytes,12,opt,name=mysql_hostname,json=mysqlHostname,proto3" json:"mysql_hostname,omitempty"`
    // MySQL port. Use topoproto.MysqlPort and topoproto.SetMysqlPort
    // to access this variable. The functions provide support
    // for legacy behavior.
    MysqlPort            int32    `protobuf:"varint,13,opt,name=mysql_port,json=mysqlPort,proto3" json:"mysql_port,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Tablet represents information about a running instance of vttablet.

func (*Tablet) Descriptor Uses

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

func (*Tablet) GetAlias Uses

func (m *Tablet) GetAlias() *TabletAlias

func (*Tablet) GetDbNameOverride Uses

func (m *Tablet) GetDbNameOverride() string

func (*Tablet) GetHostname Uses

func (m *Tablet) GetHostname() string

func (*Tablet) GetKeyRange Uses

func (m *Tablet) GetKeyRange() *KeyRange

func (*Tablet) GetKeyspace Uses

func (m *Tablet) GetKeyspace() string

func (*Tablet) GetMysqlHostname Uses

func (m *Tablet) GetMysqlHostname() string

func (*Tablet) GetMysqlPort Uses

func (m *Tablet) GetMysqlPort() int32

func (*Tablet) GetPortMap Uses

func (m *Tablet) GetPortMap() map[string]int32

func (*Tablet) GetShard Uses

func (m *Tablet) GetShard() string

func (*Tablet) GetTags Uses

func (m *Tablet) GetTags() map[string]string

func (*Tablet) GetType Uses

func (m *Tablet) GetType() TabletType

func (*Tablet) ProtoMessage Uses

func (*Tablet) ProtoMessage()

func (*Tablet) Reset Uses

func (m *Tablet) Reset()

func (*Tablet) String Uses

func (m *Tablet) String() string

func (*Tablet) XXX_DiscardUnknown Uses

func (m *Tablet) XXX_DiscardUnknown()

func (*Tablet) XXX_Marshal Uses

func (m *Tablet) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Tablet) XXX_Merge Uses

func (dst *Tablet) XXX_Merge(src proto.Message)

func (*Tablet) XXX_Size Uses

func (m *Tablet) XXX_Size() int

func (*Tablet) XXX_Unmarshal Uses

func (m *Tablet) XXX_Unmarshal(b []byte) error

type TabletAlias Uses

type TabletAlias struct {
    // cell is the cell (or datacenter) the tablet is in
    Cell string `protobuf:"bytes,1,opt,name=cell,proto3" json:"cell,omitempty"`
    // uid is a unique id for this tablet within the shard
    // (this is the MySQL server id as well).
    Uid                  uint32   `protobuf:"varint,2,opt,name=uid,proto3" json:"uid,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

TabletAlias is a globally unique tablet identifier.

func (*TabletAlias) Descriptor Uses

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

func (*TabletAlias) GetCell Uses

func (m *TabletAlias) GetCell() string

func (*TabletAlias) GetUid Uses

func (m *TabletAlias) GetUid() uint32

func (*TabletAlias) ProtoMessage Uses

func (*TabletAlias) ProtoMessage()

func (*TabletAlias) Reset Uses

func (m *TabletAlias) Reset()

func (*TabletAlias) String Uses

func (m *TabletAlias) String() string

func (*TabletAlias) XXX_DiscardUnknown Uses

func (m *TabletAlias) XXX_DiscardUnknown()

func (*TabletAlias) XXX_Marshal Uses

func (m *TabletAlias) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TabletAlias) XXX_Merge Uses

func (dst *TabletAlias) XXX_Merge(src proto.Message)

func (*TabletAlias) XXX_Size Uses

func (m *TabletAlias) XXX_Size() int

func (*TabletAlias) XXX_Unmarshal Uses

func (m *TabletAlias) XXX_Unmarshal(b []byte) error

type TabletType Uses

type TabletType int32

TabletType represents the type of a given tablet.

const (
    // UNKNOWN is not a valid value.
    TabletType_UNKNOWN TabletType = 0
    // MASTER is the master server for the shard. Only MASTER allows DMLs.
    TabletType_MASTER TabletType = 1
    // REPLICA is a slave type. It is used to serve live traffic.
    // A REPLICA can be promoted to MASTER. A demoted MASTER will go to REPLICA.
    TabletType_REPLICA TabletType = 2
    // RDONLY (old name) / BATCH (new name) is used to serve traffic for
    // long-running jobs. It is a separate type from REPLICA so
    // long-running queries don't affect web-like traffic.
    TabletType_RDONLY TabletType = 3
    TabletType_BATCH  TabletType = 3
    // SPARE is a type of servers that cannot serve queries, but is available
    // in case an extra server is needed.
    TabletType_SPARE TabletType = 4
    // EXPERIMENTAL is like SPARE, except it can serve queries. This
    // type can be used for usages not planned by Vitess, like online
    // export to another storage engine.
    TabletType_EXPERIMENTAL TabletType = 5
    // BACKUP is the type a server goes to when taking a backup. No queries
    // can be served in BACKUP mode.
    TabletType_BACKUP TabletType = 6
    // RESTORE is the type a server uses when restoring a backup, at
    // startup time.  No queries can be served in RESTORE mode.
    TabletType_RESTORE TabletType = 7
    // DRAINED is the type a server goes into when used by Vitess tools
    // to perform an offline action. It is a serving type (as
    // the tools processes may need to run queries), but it's not used
    // to route queries from Vitess users. In this state,
    // this tablet is dedicated to the process that uses it.
    TabletType_DRAINED TabletType = 8
)

func (TabletType) EnumDescriptor Uses

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

func (TabletType) String Uses

func (x TabletType) String() string

Package topodata imports 3 packages (graph) and is imported by 114 packages. Updated 2019-07-09. Refresh now. Tools for package owners.