topodata

package
Version: v0.11.1 Latest Latest
Warning

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

Go to latest
Published: Sep 9, 2021 License: Apache-2.0 Imports: 8 Imported by: 80

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	KeyspaceType_name = map[int32]string{
		0: "NORMAL",
		1: "SNAPSHOT",
	}
	KeyspaceType_value = map[string]int32{
		"NORMAL":   0,
		"SNAPSHOT": 1,
	}
)

Enum value maps for KeyspaceType.

View Source
var (
	KeyspaceIdType_name = map[int32]string{
		0: "UNSET",
		1: "UINT64",
		2: "BYTES",
	}
	KeyspaceIdType_value = map[string]int32{
		"UNSET":  0,
		"UINT64": 1,
		"BYTES":  2,
	}
)

Enum value maps for KeyspaceIdType.

View Source
var (
	TabletType_name = map[int32]string{
		0: "UNKNOWN",
		1: "MASTER",
		2: "REPLICA",
		3: "RDONLY",

		4: "SPARE",
		5: "EXPERIMENTAL",
		6: "BACKUP",
		7: "RESTORE",
		8: "DRAINED",
	}
	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,
	}
)

Enum value maps for TabletType.

View Source
var (
	ErrInvalidLength        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflow          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group")
)
View Source
var File_topodata_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type CellInfo

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"`
	// contains filtered or unexported fields
}

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 deprecated

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

Deprecated: Use CellInfo.ProtoReflect.Descriptor instead.

func (*CellInfo) GetRoot

func (x *CellInfo) GetRoot() string

func (*CellInfo) GetServerAddress

func (x *CellInfo) GetServerAddress() string

func (*CellInfo) MarshalToSizedBufferVT added in v0.11.0

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

func (*CellInfo) MarshalToVT added in v0.11.0

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

func (*CellInfo) MarshalVT added in v0.11.0

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

func (*CellInfo) ProtoMessage

func (*CellInfo) ProtoMessage()

func (*CellInfo) ProtoReflect added in v0.11.0

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

func (*CellInfo) Reset

func (x *CellInfo) Reset()

func (*CellInfo) SizeVT added in v0.11.0

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

func (*CellInfo) String

func (x *CellInfo) String() string

func (*CellInfo) UnmarshalVT added in v0.11.0

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

type CellsAlias

type CellsAlias struct {

	// Cells that map to this alias
	Cells []string `protobuf:"bytes,2,rep,name=cells,proto3" json:"cells,omitempty"`
	// contains filtered or unexported fields
}

CellsAlias

func (*CellsAlias) Descriptor deprecated

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

Deprecated: Use CellsAlias.ProtoReflect.Descriptor instead.

func (*CellsAlias) GetCells

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

func (*CellsAlias) MarshalToSizedBufferVT added in v0.11.0

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

func (*CellsAlias) MarshalToVT added in v0.11.0

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

func (*CellsAlias) MarshalVT added in v0.11.0

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

func (*CellsAlias) ProtoMessage

func (*CellsAlias) ProtoMessage()

func (*CellsAlias) ProtoReflect added in v0.11.0

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

func (*CellsAlias) Reset

func (x *CellsAlias) Reset()

func (*CellsAlias) SizeVT added in v0.11.0

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

func (*CellsAlias) String

func (x *CellsAlias) String() string

func (*CellsAlias) UnmarshalVT added in v0.11.0

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

type ExternalClusters added in v0.10.0

type ExternalClusters struct {
	VitessCluster []*ExternalVitessCluster `protobuf:"bytes,1,rep,name=vitess_cluster,json=vitessCluster,proto3" json:"vitess_cluster,omitempty"`
	// contains filtered or unexported fields
}

ExternalClusters

func (*ExternalClusters) Descriptor deprecated added in v0.10.0

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

Deprecated: Use ExternalClusters.ProtoReflect.Descriptor instead.

func (*ExternalClusters) GetVitessCluster added in v0.10.0

func (x *ExternalClusters) GetVitessCluster() []*ExternalVitessCluster

func (*ExternalClusters) MarshalToSizedBufferVT added in v0.11.0

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

func (*ExternalClusters) MarshalToVT added in v0.11.0

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

func (*ExternalClusters) MarshalVT added in v0.11.0

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

func (*ExternalClusters) ProtoMessage added in v0.10.0

func (*ExternalClusters) ProtoMessage()

func (*ExternalClusters) ProtoReflect added in v0.11.0

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

func (*ExternalClusters) Reset added in v0.10.0

func (x *ExternalClusters) Reset()

func (*ExternalClusters) SizeVT added in v0.11.0

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

func (*ExternalClusters) String added in v0.10.0

func (x *ExternalClusters) String() string

func (*ExternalClusters) UnmarshalVT added in v0.11.0

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

type ExternalVitessCluster added in v0.10.0

type ExternalVitessCluster struct {
	TopoConfig *TopoConfig `protobuf:"bytes,1,opt,name=topo_config,json=topoConfig,proto3" json:"topo_config,omitempty"`
	// contains filtered or unexported fields
}

func (*ExternalVitessCluster) Descriptor deprecated added in v0.10.0

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

Deprecated: Use ExternalVitessCluster.ProtoReflect.Descriptor instead.

func (*ExternalVitessCluster) GetTopoConfig added in v0.10.0

func (x *ExternalVitessCluster) GetTopoConfig() *TopoConfig

func (*ExternalVitessCluster) MarshalToSizedBufferVT added in v0.11.0

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

func (*ExternalVitessCluster) MarshalToVT added in v0.11.0

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

func (*ExternalVitessCluster) MarshalVT added in v0.11.0

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

func (*ExternalVitessCluster) ProtoMessage added in v0.10.0

func (*ExternalVitessCluster) ProtoMessage()

func (*ExternalVitessCluster) ProtoReflect added in v0.11.0

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

func (*ExternalVitessCluster) Reset added in v0.10.0

func (x *ExternalVitessCluster) Reset()

func (*ExternalVitessCluster) SizeVT added in v0.11.0

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

func (*ExternalVitessCluster) String added in v0.10.0

func (x *ExternalVitessCluster) String() string

func (*ExternalVitessCluster) UnmarshalVT added in v0.11.0

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

type KeyRange

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"`
	// contains filtered or unexported fields
}

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

func (*KeyRange) CachedSize added in v0.10.0

func (cached *KeyRange) CachedSize(alloc bool) int64

func (*KeyRange) Descriptor deprecated

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

Deprecated: Use KeyRange.ProtoReflect.Descriptor instead.

func (*KeyRange) GetEnd

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

func (*KeyRange) GetStart

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

func (*KeyRange) MarshalToSizedBufferVT added in v0.11.0

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

func (*KeyRange) MarshalToVT added in v0.11.0

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

func (*KeyRange) MarshalVT added in v0.11.0

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

func (*KeyRange) ProtoMessage

func (*KeyRange) ProtoMessage()

func (*KeyRange) ProtoReflect added in v0.11.0

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

func (*KeyRange) Reset

func (x *KeyRange) Reset()

func (*KeyRange) SizeVT added in v0.11.0

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

func (*KeyRange) String

func (x *KeyRange) String() string

func (*KeyRange) UnmarshalVT added in v0.11.0

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

type Keyspace

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 `` /* 147-byte string literal not displayed */
	// 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"`
	// keyspace_type will determine how this keyspace is treated by
	// vtgate / vschema. Normal keyspaces are routable by
	// any query. Snapshot keyspaces are only accessible
	// by explicit addresssing or by calling "use keyspace" first
	KeyspaceType KeyspaceType `protobuf:"varint,5,opt,name=keyspace_type,json=keyspaceType,proto3,enum=topodata.KeyspaceType" json:"keyspace_type,omitempty"`
	// base_keyspace is the base keyspace from which a snapshot
	// keyspace is created. empty for normal keyspaces
	BaseKeyspace string `protobuf:"bytes,6,opt,name=base_keyspace,json=baseKeyspace,proto3" json:"base_keyspace,omitempty"`
	// snapshot_time (in UTC) is a property of snapshot
	// keyspaces which tells us what point in time
	// the snapshot is of
	SnapshotTime *vttime.Time `protobuf:"bytes,7,opt,name=snapshot_time,json=snapshotTime,proto3" json:"snapshot_time,omitempty"`
	// contains filtered or unexported fields
}

A Keyspace contains data about a keyspace.

func (*Keyspace) Descriptor deprecated

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

Deprecated: Use Keyspace.ProtoReflect.Descriptor instead.

func (*Keyspace) GetBaseKeyspace

func (x *Keyspace) GetBaseKeyspace() string

func (*Keyspace) GetKeyspaceType

func (x *Keyspace) GetKeyspaceType() KeyspaceType

func (*Keyspace) GetServedFroms

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

func (*Keyspace) GetShardingColumnName

func (x *Keyspace) GetShardingColumnName() string

func (*Keyspace) GetShardingColumnType

func (x *Keyspace) GetShardingColumnType() KeyspaceIdType

func (*Keyspace) GetSnapshotTime

func (x *Keyspace) GetSnapshotTime() *vttime.Time

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 KeyspaceIdType

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) Descriptor added in v0.11.0

func (KeyspaceIdType) Enum added in v0.11.0

func (x KeyspaceIdType) Enum() *KeyspaceIdType

func (KeyspaceIdType) EnumDescriptor deprecated

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

Deprecated: Use KeyspaceIdType.Descriptor instead.

func (KeyspaceIdType) Number added in v0.11.0

func (KeyspaceIdType) String

func (x KeyspaceIdType) String() string

func (KeyspaceIdType) Type added in v0.11.0

type KeyspaceType

type KeyspaceType int32

KeyspaceType describes the type of the keyspace

const (
	// NORMAL is the default value
	KeyspaceType_NORMAL KeyspaceType = 0
	// SNAPSHOT is when we are creating a snapshot keyspace
	KeyspaceType_SNAPSHOT KeyspaceType = 1
)

func (KeyspaceType) Descriptor added in v0.11.0

func (KeyspaceType) Enum added in v0.11.0

func (x KeyspaceType) Enum() *KeyspaceType

func (KeyspaceType) EnumDescriptor deprecated

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

Deprecated: Use KeyspaceType.Descriptor instead.

func (KeyspaceType) Number added in v0.11.0

func (KeyspaceType) String

func (x KeyspaceType) String() string

func (KeyspaceType) Type added in v0.11.0

type Keyspace_ServedFrom

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"`
	// contains filtered or unexported fields
}

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

func (*Keyspace_ServedFrom) Descriptor deprecated

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

Deprecated: Use Keyspace_ServedFrom.ProtoReflect.Descriptor instead.

func (*Keyspace_ServedFrom) GetCells

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

func (*Keyspace_ServedFrom) GetKeyspace

func (x *Keyspace_ServedFrom) GetKeyspace() string

func (*Keyspace_ServedFrom) GetTabletType

func (x *Keyspace_ServedFrom) GetTabletType() TabletType

func (*Keyspace_ServedFrom) MarshalToSizedBufferVT added in v0.11.0

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

func (*Keyspace_ServedFrom) MarshalToVT added in v0.11.0

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

func (*Keyspace_ServedFrom) MarshalVT added in v0.11.0

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

func (*Keyspace_ServedFrom) ProtoMessage

func (*Keyspace_ServedFrom) ProtoMessage()

func (*Keyspace_ServedFrom) ProtoReflect added in v0.11.0

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

func (*Keyspace_ServedFrom) Reset

func (x *Keyspace_ServedFrom) Reset()

func (*Keyspace_ServedFrom) SizeVT added in v0.11.0

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

func (*Keyspace_ServedFrom) String

func (x *Keyspace_ServedFrom) String() string

func (*Keyspace_ServedFrom) UnmarshalVT added in v0.11.0

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

type Shard

type Shard struct {

	// master_alias is the tablet alias of the master for the shard.
	// If it is unset, then there is no master in this shard yet.
	// 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"`
	// master_term_start_time is the time (in UTC) at which the current term of
	// the master specified in master_alias began.
	//
	// A new master term begins any time an authoritative decision is communicated
	// about which tablet should be the master, such as via Vitess
	// replication-management commands like PlannedReparentShard,
	// EmergencyReparentShard, and TabletExternallyReparented.
	//
	// The master_alias should only ever be changed if the new master's term began
	// at a later time than this. Note that a new term can start for the tablet
	// that is already the master. In that case, the master_term_start_time would
	// be increased without changing the master_alias.
	MasterTermStartTime *vttime.Time `protobuf:"bytes,8,opt,name=master_term_start_time,json=masterTermStartTime,proto3" json:"master_term_start_time,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"`
	// contains filtered or unexported fields
}

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

func (*Shard) Descriptor deprecated

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

Deprecated: Use Shard.ProtoReflect.Descriptor instead.

func (*Shard) GetIsMasterServing

func (x *Shard) GetIsMasterServing() bool

func (*Shard) GetKeyRange

func (x *Shard) GetKeyRange() *KeyRange

func (*Shard) GetMasterAlias

func (x *Shard) GetMasterAlias() *TabletAlias

func (*Shard) GetMasterTermStartTime

func (x *Shard) GetMasterTermStartTime() *vttime.Time

func (*Shard) GetServedTypes

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

func (*Shard) GetSourceShards

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

func (*Shard) GetTabletControls

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

func (*Shard) MarshalToSizedBufferVT added in v0.11.0

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

func (*Shard) MarshalToVT added in v0.11.0

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

func (*Shard) MarshalVT added in v0.11.0

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

func (*Shard) ProtoMessage

func (*Shard) ProtoMessage()

func (*Shard) ProtoReflect added in v0.11.0

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

func (*Shard) Reset

func (x *Shard) Reset()

func (*Shard) SizeVT added in v0.11.0

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

func (*Shard) String

func (x *Shard) String() string

func (*Shard) UnmarshalVT added in v0.11.0

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

type ShardReference

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"` // Disable query serving in this shard
	// contains filtered or unexported fields
}

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

func (*ShardReference) Descriptor deprecated

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

Deprecated: Use ShardReference.ProtoReflect.Descriptor instead.

func (*ShardReference) GetKeyRange

func (x *ShardReference) GetKeyRange() *KeyRange

func (*ShardReference) GetName

func (x *ShardReference) GetName() string

func (*ShardReference) MarshalToSizedBufferVT added in v0.11.0

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

func (*ShardReference) MarshalToVT added in v0.11.0

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

func (*ShardReference) MarshalVT added in v0.11.0

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

func (*ShardReference) ProtoMessage

func (*ShardReference) ProtoMessage()

func (*ShardReference) ProtoReflect added in v0.11.0

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

func (*ShardReference) Reset

func (x *ShardReference) Reset()

func (*ShardReference) SizeVT added in v0.11.0

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

func (*ShardReference) String

func (x *ShardReference) String() string

func (*ShardReference) UnmarshalVT added in v0.11.0

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

type ShardReplication

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"`
	// contains filtered or unexported fields
}

ShardReplication describes the MySQL replication relationships whithin a cell.

func (*ShardReplication) Descriptor deprecated

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

Deprecated: Use ShardReplication.ProtoReflect.Descriptor instead.

func (*ShardReplication) GetNodes

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

func (*ShardReplication) MarshalToSizedBufferVT added in v0.11.0

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

func (*ShardReplication) MarshalToVT added in v0.11.0

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

func (*ShardReplication) MarshalVT added in v0.11.0

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

func (*ShardReplication) ProtoMessage

func (*ShardReplication) ProtoMessage()

func (*ShardReplication) ProtoReflect added in v0.11.0

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

func (*ShardReplication) Reset

func (x *ShardReplication) Reset()

func (*ShardReplication) SizeVT added in v0.11.0

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

func (*ShardReplication) String

func (x *ShardReplication) String() string

func (*ShardReplication) UnmarshalVT added in v0.11.0

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

type ShardReplication_Node

type ShardReplication_Node struct {
	TabletAlias *TabletAlias `protobuf:"bytes,1,opt,name=tablet_alias,json=tabletAlias,proto3" json:"tablet_alias,omitempty"`
	// contains filtered or unexported fields
}

Node describes a tablet instance within the cell

func (*ShardReplication_Node) Descriptor deprecated

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

Deprecated: Use ShardReplication_Node.ProtoReflect.Descriptor instead.

func (*ShardReplication_Node) GetTabletAlias

func (x *ShardReplication_Node) GetTabletAlias() *TabletAlias

func (*ShardReplication_Node) MarshalToSizedBufferVT added in v0.11.0

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

func (*ShardReplication_Node) MarshalToVT added in v0.11.0

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

func (*ShardReplication_Node) MarshalVT added in v0.11.0

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

func (*ShardReplication_Node) ProtoMessage

func (*ShardReplication_Node) ProtoMessage()

func (*ShardReplication_Node) ProtoReflect added in v0.11.0

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

func (*ShardReplication_Node) Reset

func (x *ShardReplication_Node) Reset()

func (*ShardReplication_Node) SizeVT added in v0.11.0

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

func (*ShardReplication_Node) String

func (x *ShardReplication_Node) String() string

func (*ShardReplication_Node) UnmarshalVT added in v0.11.0

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

type ShardTabletControl

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"`
	// contains filtered or unexported fields
}

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

func (*ShardTabletControl) Descriptor deprecated

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

Deprecated: Use ShardTabletControl.ProtoReflect.Descriptor instead.

func (*ShardTabletControl) GetKeyRange

func (x *ShardTabletControl) GetKeyRange() *KeyRange

func (*ShardTabletControl) GetName

func (x *ShardTabletControl) GetName() string

func (*ShardTabletControl) GetQueryServiceDisabled

func (x *ShardTabletControl) GetQueryServiceDisabled() bool

func (*ShardTabletControl) MarshalToSizedBufferVT added in v0.11.0

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

func (*ShardTabletControl) MarshalToVT added in v0.11.0

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

func (*ShardTabletControl) MarshalVT added in v0.11.0

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

func (*ShardTabletControl) ProtoMessage

func (*ShardTabletControl) ProtoMessage()

func (*ShardTabletControl) ProtoReflect added in v0.11.0

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

func (*ShardTabletControl) Reset

func (x *ShardTabletControl) Reset()

func (*ShardTabletControl) SizeVT added in v0.11.0

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

func (*ShardTabletControl) String

func (x *ShardTabletControl) String() string

func (*ShardTabletControl) UnmarshalVT added in v0.11.0

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

type Shard_ServedType

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"`
	// contains filtered or unexported fields
}

ServedType is an entry in the served_types

func (*Shard_ServedType) Descriptor deprecated

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

Deprecated: Use Shard_ServedType.ProtoReflect.Descriptor instead.

func (*Shard_ServedType) GetCells

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

func (*Shard_ServedType) GetTabletType

func (x *Shard_ServedType) GetTabletType() TabletType

func (*Shard_ServedType) MarshalToSizedBufferVT added in v0.11.0

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

func (*Shard_ServedType) MarshalToVT added in v0.11.0

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

func (*Shard_ServedType) MarshalVT added in v0.11.0

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

func (*Shard_ServedType) ProtoMessage

func (*Shard_ServedType) ProtoMessage()

func (*Shard_ServedType) ProtoReflect added in v0.11.0

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

func (*Shard_ServedType) Reset

func (x *Shard_ServedType) Reset()

func (*Shard_ServedType) SizeVT added in v0.11.0

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

func (*Shard_ServedType) String

func (x *Shard_ServedType) String() string

func (*Shard_ServedType) UnmarshalVT added in v0.11.0

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

type Shard_SourceShard

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"`
	// contains filtered or unexported fields
}

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

func (*Shard_SourceShard) Descriptor deprecated

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

Deprecated: Use Shard_SourceShard.ProtoReflect.Descriptor instead.

func (*Shard_SourceShard) GetKeyRange

func (x *Shard_SourceShard) GetKeyRange() *KeyRange

func (*Shard_SourceShard) GetKeyspace

func (x *Shard_SourceShard) GetKeyspace() string

func (*Shard_SourceShard) GetShard

func (x *Shard_SourceShard) GetShard() string

func (*Shard_SourceShard) GetTables

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

func (*Shard_SourceShard) GetUid

func (x *Shard_SourceShard) GetUid() uint32

func (*Shard_SourceShard) MarshalToSizedBufferVT added in v0.11.0

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

func (*Shard_SourceShard) MarshalToVT added in v0.11.0

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

func (*Shard_SourceShard) MarshalVT added in v0.11.0

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

func (*Shard_SourceShard) ProtoMessage

func (*Shard_SourceShard) ProtoMessage()

func (*Shard_SourceShard) ProtoReflect added in v0.11.0

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

func (*Shard_SourceShard) Reset

func (x *Shard_SourceShard) Reset()

func (*Shard_SourceShard) SizeVT added in v0.11.0

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

func (*Shard_SourceShard) String

func (x *Shard_SourceShard) String() string

func (*Shard_SourceShard) UnmarshalVT added in v0.11.0

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

type Shard_TabletControl

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"`
	// contains filtered or unexported fields
}

TabletControl controls tablet's behavior

func (*Shard_TabletControl) Descriptor deprecated

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

Deprecated: Use Shard_TabletControl.ProtoReflect.Descriptor instead.

func (*Shard_TabletControl) GetBlacklistedTables

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

func (*Shard_TabletControl) GetCells

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

func (*Shard_TabletControl) GetFrozen

func (x *Shard_TabletControl) GetFrozen() bool

func (*Shard_TabletControl) GetTabletType

func (x *Shard_TabletControl) GetTabletType() TabletType

func (*Shard_TabletControl) MarshalToSizedBufferVT added in v0.11.0

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

func (*Shard_TabletControl) MarshalToVT added in v0.11.0

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

func (*Shard_TabletControl) MarshalVT added in v0.11.0

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

func (*Shard_TabletControl) ProtoMessage

func (*Shard_TabletControl) ProtoMessage()

func (*Shard_TabletControl) ProtoReflect added in v0.11.0

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

func (*Shard_TabletControl) Reset

func (x *Shard_TabletControl) Reset()

func (*Shard_TabletControl) SizeVT added in v0.11.0

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

func (*Shard_TabletControl) String

func (x *Shard_TabletControl) String() string

func (*Shard_TabletControl) UnmarshalVT added in v0.11.0

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

type SrvKeyspace

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            `` /* 147-byte string literal not displayed */
	ServedFrom         []*SrvKeyspace_ServedFrom `protobuf:"bytes,4,rep,name=served_from,json=servedFrom,proto3" json:"served_from,omitempty"`
	// contains filtered or unexported fields
}

SrvKeyspace is a rollup node for the keyspace itself.

func (*SrvKeyspace) Descriptor deprecated

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

Deprecated: Use SrvKeyspace.ProtoReflect.Descriptor instead.

func (*SrvKeyspace) GetPartitions

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

func (*SrvKeyspace) GetServedFrom

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

func (*SrvKeyspace) GetShardingColumnName

func (x *SrvKeyspace) GetShardingColumnName() string

func (*SrvKeyspace) GetShardingColumnType

func (x *SrvKeyspace) GetShardingColumnType() KeyspaceIdType

func (*SrvKeyspace) MarshalToSizedBufferVT added in v0.11.0

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

func (*SrvKeyspace) MarshalToVT added in v0.11.0

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

func (*SrvKeyspace) MarshalVT added in v0.11.0

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

func (*SrvKeyspace) ProtoMessage

func (*SrvKeyspace) ProtoMessage()

func (*SrvKeyspace) ProtoReflect added in v0.11.0

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

func (*SrvKeyspace) Reset

func (x *SrvKeyspace) Reset()

func (*SrvKeyspace) SizeVT added in v0.11.0

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

func (*SrvKeyspace) String

func (x *SrvKeyspace) String() string

func (*SrvKeyspace) UnmarshalVT added in v0.11.0

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

type SrvKeyspace_KeyspacePartition

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"`
	// contains filtered or unexported fields
}

func (*SrvKeyspace_KeyspacePartition) Descriptor deprecated

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

Deprecated: Use SrvKeyspace_KeyspacePartition.ProtoReflect.Descriptor instead.

func (*SrvKeyspace_KeyspacePartition) GetServedType

func (x *SrvKeyspace_KeyspacePartition) GetServedType() TabletType

func (*SrvKeyspace_KeyspacePartition) GetShardReferences

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

func (*SrvKeyspace_KeyspacePartition) GetShardTabletControls

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

func (*SrvKeyspace_KeyspacePartition) MarshalToSizedBufferVT added in v0.11.0

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

func (*SrvKeyspace_KeyspacePartition) MarshalToVT added in v0.11.0

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

func (*SrvKeyspace_KeyspacePartition) MarshalVT added in v0.11.0

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

func (*SrvKeyspace_KeyspacePartition) ProtoMessage

func (*SrvKeyspace_KeyspacePartition) ProtoMessage()

func (*SrvKeyspace_KeyspacePartition) ProtoReflect added in v0.11.0

func (*SrvKeyspace_KeyspacePartition) Reset

func (x *SrvKeyspace_KeyspacePartition) Reset()

func (*SrvKeyspace_KeyspacePartition) SizeVT added in v0.11.0

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

func (*SrvKeyspace_KeyspacePartition) String

func (*SrvKeyspace_KeyspacePartition) UnmarshalVT added in v0.11.0

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

type SrvKeyspace_ServedFrom

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"`
	// contains filtered or unexported fields
}

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

func (*SrvKeyspace_ServedFrom) Descriptor deprecated

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

Deprecated: Use SrvKeyspace_ServedFrom.ProtoReflect.Descriptor instead.

func (*SrvKeyspace_ServedFrom) GetKeyspace

func (x *SrvKeyspace_ServedFrom) GetKeyspace() string

func (*SrvKeyspace_ServedFrom) GetTabletType

func (x *SrvKeyspace_ServedFrom) GetTabletType() TabletType

func (*SrvKeyspace_ServedFrom) MarshalToSizedBufferVT added in v0.11.0

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

func (*SrvKeyspace_ServedFrom) MarshalToVT added in v0.11.0

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

func (*SrvKeyspace_ServedFrom) MarshalVT added in v0.11.0

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

func (*SrvKeyspace_ServedFrom) ProtoMessage

func (*SrvKeyspace_ServedFrom) ProtoMessage()

func (*SrvKeyspace_ServedFrom) ProtoReflect added in v0.11.0

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

func (*SrvKeyspace_ServedFrom) Reset

func (x *SrvKeyspace_ServedFrom) Reset()

func (*SrvKeyspace_ServedFrom) SizeVT added in v0.11.0

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

func (*SrvKeyspace_ServedFrom) String

func (x *SrvKeyspace_ServedFrom) String() string

func (*SrvKeyspace_ServedFrom) UnmarshalVT added in v0.11.0

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

type Tablet

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 `` /* 171-byte string literal not displayed */
	// 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 `` /* 150-byte string literal not displayed */
	// 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"`
	// master_term_start_time is the time (in UTC) at which the current term of
	// the current tablet began as master. If this tablet is not currently the
	// master, this value is ignored.
	//
	// A new master term begins any time an authoritative decision is communicated
	// about which tablet should be the master, such as via Vitess
	// replication-management commands like PlannedReparentShard,
	// EmergencyReparentShard, and TabletExternallyReparented.
	//
	MasterTermStartTime *vttime.Time `protobuf:"bytes,14,opt,name=master_term_start_time,json=masterTermStartTime,proto3" json:"master_term_start_time,omitempty"`
	// contains filtered or unexported fields
}

Tablet represents information about a running instance of vttablet.

func (*Tablet) Descriptor deprecated

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

Deprecated: Use Tablet.ProtoReflect.Descriptor instead.

func (*Tablet) GetAlias

func (x *Tablet) GetAlias() *TabletAlias

func (*Tablet) GetDbNameOverride

func (x *Tablet) GetDbNameOverride() string

func (*Tablet) GetHostname

func (x *Tablet) GetHostname() string

func (*Tablet) GetKeyRange

func (x *Tablet) GetKeyRange() *KeyRange

func (*Tablet) GetKeyspace

func (x *Tablet) GetKeyspace() string

func (*Tablet) GetMasterTermStartTime

func (x *Tablet) GetMasterTermStartTime() *vttime.Time

func (*Tablet) GetMysqlHostname

func (x *Tablet) GetMysqlHostname() string

func (*Tablet) GetMysqlPort

func (x *Tablet) GetMysqlPort() int32

func (*Tablet) GetPortMap

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

func (*Tablet) GetShard

func (x *Tablet) GetShard() string

func (*Tablet) GetTags

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

func (*Tablet) GetType

func (x *Tablet) GetType() TabletType

func (*Tablet) MarshalToSizedBufferVT added in v0.11.0

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

func (*Tablet) MarshalToVT added in v0.11.0

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

func (*Tablet) MarshalVT added in v0.11.0

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

func (*Tablet) ProtoMessage

func (*Tablet) ProtoMessage()

func (*Tablet) ProtoReflect added in v0.11.0

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

func (*Tablet) Reset

func (x *Tablet) Reset()

func (*Tablet) SizeVT added in v0.11.0

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

func (*Tablet) String

func (x *Tablet) String() string

func (*Tablet) UnmarshalVT added in v0.11.0

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

type TabletAlias

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"`
	// contains filtered or unexported fields
}

TabletAlias is a globally unique tablet identifier.

func (*TabletAlias) Descriptor deprecated

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

Deprecated: Use TabletAlias.ProtoReflect.Descriptor instead.

func (*TabletAlias) GetCell

func (x *TabletAlias) GetCell() string

func (*TabletAlias) GetUid

func (x *TabletAlias) GetUid() uint32

func (*TabletAlias) MarshalToSizedBufferVT added in v0.11.0

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

func (*TabletAlias) MarshalToVT added in v0.11.0

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

func (*TabletAlias) MarshalVT added in v0.11.0

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

func (*TabletAlias) ProtoMessage

func (*TabletAlias) ProtoMessage()

func (*TabletAlias) ProtoReflect added in v0.11.0

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

func (*TabletAlias) Reset

func (x *TabletAlias) Reset()

func (*TabletAlias) SizeVT added in v0.11.0

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

func (*TabletAlias) String

func (x *TabletAlias) String() string

func (*TabletAlias) UnmarshalVT added in v0.11.0

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

type TabletType

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 replicates from master. 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) Descriptor added in v0.11.0

func (TabletType) Descriptor() protoreflect.EnumDescriptor

func (TabletType) Enum added in v0.11.0

func (x TabletType) Enum() *TabletType

func (TabletType) EnumDescriptor deprecated

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

Deprecated: Use TabletType.Descriptor instead.

func (TabletType) Number added in v0.11.0

func (x TabletType) Number() protoreflect.EnumNumber

func (TabletType) String

func (x TabletType) String() string

func (TabletType) Type added in v0.11.0

type TopoConfig added in v0.10.0

type TopoConfig struct {
	TopoType string `protobuf:"bytes,1,opt,name=topo_type,json=topoType,proto3" json:"topo_type,omitempty"`
	Server   string `protobuf:"bytes,2,opt,name=server,proto3" json:"server,omitempty"`
	Root     string `protobuf:"bytes,3,opt,name=root,proto3" json:"root,omitempty"`
	// contains filtered or unexported fields
}

func (*TopoConfig) Descriptor deprecated added in v0.10.0

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

Deprecated: Use TopoConfig.ProtoReflect.Descriptor instead.

func (*TopoConfig) GetRoot added in v0.10.0

func (x *TopoConfig) GetRoot() string

func (*TopoConfig) GetServer added in v0.10.0

func (x *TopoConfig) GetServer() string

func (*TopoConfig) GetTopoType added in v0.10.0

func (x *TopoConfig) GetTopoType() string

func (*TopoConfig) MarshalToSizedBufferVT added in v0.11.0

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

func (*TopoConfig) MarshalToVT added in v0.11.0

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

func (*TopoConfig) MarshalVT added in v0.11.0

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

func (*TopoConfig) ProtoMessage added in v0.10.0

func (*TopoConfig) ProtoMessage()

func (*TopoConfig) ProtoReflect added in v0.11.0

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

func (*TopoConfig) Reset added in v0.10.0

func (x *TopoConfig) Reset()

func (*TopoConfig) SizeVT added in v0.11.0

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

func (*TopoConfig) String added in v0.10.0

func (x *TopoConfig) String() string

func (*TopoConfig) UnmarshalVT added in v0.11.0

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL