topodata

package
v0.21.0-rc2 Latest Latest
Warning

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

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

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 (
	TabletType_name = map[int32]string{
		0: "UNKNOWN",
		1: "PRIMARY",

		2: "REPLICA",
		3: "RDONLY",

		4: "SPARE",
		5: "EXPERIMENTAL",
		6: "BACKUP",
		7: "RESTORE",
		8: "DRAINED",
	}
	TabletType_value = map[string]int32{
		"UNKNOWN":      0,
		"PRIMARY":      1,
		"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 (
	ShardReplicationError_Type_name = map[int32]string{
		0: "UNKNOWN",
		1: "NOT_FOUND",
		2: "TOPOLOGY_MISMATCH",
	}
	ShardReplicationError_Type_value = map[string]int32{
		"UNKNOWN":           0,
		"NOT_FOUND":         1,
		"TOPOLOGY_MISMATCH": 2,
	}
)

Enum value maps for ShardReplicationError_Type.

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) CloneMessageVT added in v0.18.0 

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

func (*CellInfo) CloneVT added in v0.18.0 

func (m *CellInfo) CloneVT() *CellInfo

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) CloneMessageVT added in v0.18.0 

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

func (*CellsAlias) CloneVT added in v0.18.0 

func (m *CellsAlias) CloneVT() *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) CloneMessageVT added in v0.18.0 

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

func (*ExternalClusters) CloneVT added in v0.18.0 

func (m *ExternalClusters) CloneVT() *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) CloneMessageVT added in v0.18.0 

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

func (*ExternalVitessCluster) CloneVT added in v0.18.0 

func (m *ExternalVitessCluster) CloneVT() *ExternalVitessCluster

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) CloneMessageVT added in v0.18.0 

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

func (*KeyRange) CloneVT added in v0.18.0 

func (m *KeyRange) CloneVT() *KeyRange

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 {

	// 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"`
	// DurabilityPolicy is the durability policy to be
	// used for the keyspace.
	DurabilityPolicy string `protobuf:"bytes,8,opt,name=durability_policy,json=durabilityPolicy,proto3" json:"durability_policy,omitempty"`
	// ThrottlerConfig has the configuration for the tablet
	// server's lag throttler, and applies to the entire
	// keyspace, across all shards and tablets.
	ThrottlerConfig *ThrottlerConfig `protobuf:"bytes,9,opt,name=throttler_config,json=throttlerConfig,proto3" json:"throttler_config,omitempty"`
	// SidecarDBName is the name of the Vitess sidecar database
	// used for various system metadata that is stored in each
	// tablet's mysqld instance.
	SidecarDbName string `protobuf:"bytes,10,opt,name=sidecar_db_name,json=sidecarDbName,proto3" json:"sidecar_db_name,omitempty"`
	// contains filtered or unexported fields
}

A Keyspace contains data about a keyspace.

func (*Keyspace) CloneMessageVT added in v0.18.0 

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

func (*Keyspace) CloneVT added in v0.18.0 

func (m *Keyspace) CloneVT() *Keyspace

func (*Keyspace) Descriptor deprecated 

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

Deprecated: Use Keyspace.ProtoReflect.Descriptor instead.

func (*Keyspace) GetBaseKeyspace 

func (x *Keyspace) GetBaseKeyspace() string

func (*Keyspace) GetDurabilityPolicy added in v0.14.0 

func (x *Keyspace) GetDurabilityPolicy() string

func (*Keyspace) GetKeyspaceType 

func (x *Keyspace) GetKeyspaceType() KeyspaceType

func (*Keyspace) GetSidecarDbName added in v0.17.0 

func (x *Keyspace) GetSidecarDbName() string

func (*Keyspace) GetSnapshotTime 

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

func (*Keyspace) GetThrottlerConfig added in v0.16.1 

func (x *Keyspace) GetThrottlerConfig() *ThrottlerConfig

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 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) Descriptor() protoreflect.EnumDescriptor

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 (x KeyspaceType) Number() protoreflect.EnumNumber

func (KeyspaceType) String 

func (x KeyspaceType) String() string

func (KeyspaceType) Type added in v0.11.0 

func (KeyspaceType) Type() protoreflect.EnumType

type Shard 

type Shard struct {

	// primary_alias is the tablet alias of the primary for the shard.
	// If it is unset, then there is no primary 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 (InitShardPrimary,
	// PlannedReparentShard,EmergencyReparentShard), to guarantee
	// exclusive operation.
	PrimaryAlias *TabletAlias `protobuf:"bytes,1,opt,name=primary_alias,json=primaryAlias,proto3" json:"primary_alias,omitempty"`
	// primary_term_start_time is the time (in UTC) at which the current term of
	// the primary specified in primary_alias began.
	//
	// A new primary term begins any time an authoritative decision is communicated
	// about which tablet should be the primary, such as via Vitess
	// replication-management commands like PlannedReparentShard,
	// EmergencyReparentShard, and TabletExternallyReparented.
	//
	// The primary_alias should only ever be changed if the new primary's term began
	// at a later time than this. Note that a new term can start for the tablet
	// that is already the primary. In that case, the primary_term_start_time would
	// be increased without changing the primary_alias.
	PrimaryTermStartTime *vttime.Time `protobuf:"bytes,8,opt,name=primary_term_start_time,json=primaryTermStartTime,proto3" json:"primary_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"`
	// 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_primary_serving sets whether this shard primary is serving traffic or not.
	// The keyspace lock is always taken when changing this.
	IsPrimaryServing bool `protobuf:"varint,7,opt,name=is_primary_serving,json=isPrimaryServing,proto3" json:"is_primary_serving,omitempty"`
	// contains filtered or unexported fields
}

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

func (*Shard) CloneMessageVT added in v0.18.0 

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

func (*Shard) CloneVT added in v0.18.0 

func (m *Shard) CloneVT() *Shard

func (*Shard) Descriptor deprecated 

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

Deprecated: Use Shard.ProtoReflect.Descriptor instead.

func (*Shard) GetIsPrimaryServing added in v0.12.0 

func (x *Shard) GetIsPrimaryServing() bool

func (*Shard) GetKeyRange 

func (x *Shard) GetKeyRange() *KeyRange

func (*Shard) GetPrimaryAlias added in v0.12.0 

func (x *Shard) GetPrimaryAlias() *TabletAlias

func (*Shard) GetPrimaryTermStartTime added in v0.12.0 

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

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) CloneMessageVT added in v0.18.0 

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

func (*ShardReference) CloneVT added in v0.18.0 

func (m *ShardReference) CloneVT() *ShardReference

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) CloneMessageVT added in v0.18.0 

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

func (*ShardReplication) CloneVT added in v0.18.0 

func (m *ShardReplication) CloneVT() *ShardReplication

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 ShardReplicationError added in v0.14.0 

type ShardReplicationError struct {

	// Type is the category of problem being fixed.
	Type ShardReplicationError_Type `protobuf:"varint,1,opt,name=type,proto3,enum=topodata.ShardReplicationError_Type" json:"type,omitempty"`
	// TabletAlias is the tablet record that has the problem.
	TabletAlias *TabletAlias `protobuf:"bytes,2,opt,name=tablet_alias,json=tabletAlias,proto3" json:"tablet_alias,omitempty"`
	// contains filtered or unexported fields
}

ShardReplicationError describes the error being fixed by ShardReplicationFix.

func (*ShardReplicationError) CloneMessageVT added in v0.18.0 

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

func (*ShardReplicationError) CloneVT added in v0.18.0 

func (m *ShardReplicationError) CloneVT() *ShardReplicationError

func (*ShardReplicationError) Descriptor deprecated added in v0.14.0 

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

Deprecated: Use ShardReplicationError.ProtoReflect.Descriptor instead.

func (*ShardReplicationError) GetTabletAlias added in v0.14.0 

func (x *ShardReplicationError) GetTabletAlias() *TabletAlias

func (*ShardReplicationError) GetType added in v0.14.0 

func (x *ShardReplicationError) GetType() ShardReplicationError_Type

func (*ShardReplicationError) MarshalToSizedBufferVT added in v0.14.0 

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

func (*ShardReplicationError) MarshalToVT added in v0.14.0 

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

func (*ShardReplicationError) MarshalVT added in v0.14.0 

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

func (*ShardReplicationError) ProtoMessage added in v0.14.0 

func (*ShardReplicationError) ProtoMessage()

func (*ShardReplicationError) ProtoReflect added in v0.14.0 

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

func (*ShardReplicationError) Reset added in v0.14.0 

func (x *ShardReplicationError) Reset()

func (*ShardReplicationError) SizeVT added in v0.14.0 

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

func (*ShardReplicationError) String added in v0.14.0 

func (x *ShardReplicationError) String() string

func (*ShardReplicationError) UnmarshalVT added in v0.14.0 

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

type ShardReplicationError_Type added in v0.14.0 

type ShardReplicationError_Type int32
const (
	// UNKNOWN is not a valid value.
	ShardReplicationError_UNKNOWN ShardReplicationError_Type = 0
	// NOT_FOUND occurs when a tablet is in the ShardReplication record
	// but does not exist in the topology.
	ShardReplicationError_NOT_FOUND ShardReplicationError_Type = 1
	// TOPOLOGY_MISMATCH occurs when a tablet is in the replication graph and
	// exists in the topology, but at least one of the Keyspace, Shard, or Cell
	// fields for that tablet does not match the ShardReplication record.
	ShardReplicationError_TOPOLOGY_MISMATCH ShardReplicationError_Type = 2
)

func (ShardReplicationError_Type) Descriptor added in v0.14.0 

func (ShardReplicationError_Type) Descriptor() protoreflect.EnumDescriptor

func (ShardReplicationError_Type) Enum added in v0.14.0 

func (x ShardReplicationError_Type) Enum() *ShardReplicationError_Type

func (ShardReplicationError_Type) EnumDescriptor deprecated added in v0.14.0 

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

Deprecated: Use ShardReplicationError_Type.Descriptor instead.

func (ShardReplicationError_Type) Number added in v0.14.0 

func (x ShardReplicationError_Type) Number() protoreflect.EnumNumber

func (ShardReplicationError_Type) String added in v0.14.0 

func (x ShardReplicationError_Type) String() string

func (ShardReplicationError_Type) Type added in v0.14.0 

func (ShardReplicationError_Type) Type() protoreflect.EnumType

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) CloneMessageVT added in v0.18.0 

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

func (*ShardReplication_Node) CloneVT added in v0.18.0 

func (m *ShardReplication_Node) CloneVT() *ShardReplication_Node

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) CloneMessageVT added in v0.18.0 

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

func (*ShardTabletControl) CloneVT added in v0.18.0 

func (m *ShardTabletControl) CloneVT() *ShardTabletControl

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_SourceShard 

type Shard_SourceShard struct {

	// Uid is the unique ID for this SourceShard object.
	Uid int32 `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 primary of that shard will run filtered replication.

func (*Shard_SourceShard) CloneMessageVT added in v0.18.0 

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

func (*Shard_SourceShard) CloneVT added in v0.18.0 

func (m *Shard_SourceShard) CloneVT() *Shard_SourceShard

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() int32

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"`
	DeniedTables []string   `protobuf:"bytes,4,rep,name=denied_tables,json=deniedTables,proto3" json:"denied_tables,omitempty"`
	// frozen is set if we've started failing over traffic for
	// the primary. 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) CloneMessageVT added in v0.18.0 

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

func (*Shard_TabletControl) CloneVT added in v0.18.0 

func (m *Shard_TabletControl) CloneVT() *Shard_TabletControl

func (*Shard_TabletControl) Descriptor deprecated 

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

Deprecated: Use Shard_TabletControl.ProtoReflect.Descriptor instead.

func (*Shard_TabletControl) GetCells 

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

func (*Shard_TabletControl) GetDeniedTables added in v0.12.0 

func (x *Shard_TabletControl) GetDeniedTables() []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"`
	// ThrottlerConfig has the configuration for the tablet server's
	// lag throttler, and applies to the entire keyspace, across all
	// shards and tablets. This is copied from the global keyspace
	// object.
	ThrottlerConfig *ThrottlerConfig `protobuf:"bytes,6,opt,name=throttler_config,json=throttlerConfig,proto3" json:"throttler_config,omitempty"`
	// contains filtered or unexported fields
}

SrvKeyspace is a rollup node for the keyspace itself.

func (*SrvKeyspace) CloneMessageVT added in v0.18.0 

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

func (*SrvKeyspace) CloneVT added in v0.18.0 

func (m *SrvKeyspace) CloneVT() *SrvKeyspace

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) GetThrottlerConfig added in v0.16.0 

func (x *SrvKeyspace) GetThrottlerConfig() *ThrottlerConfig

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) CloneMessageVT added in v0.18.0 

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

func (*SrvKeyspace_KeyspacePartition) CloneVT added in v0.18.0 

func (m *SrvKeyspace_KeyspacePartition) CloneVT() *SrvKeyspace_KeyspacePartition

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 (x *SrvKeyspace_KeyspacePartition) ProtoReflect() protoreflect.Message

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 (x *SrvKeyspace_KeyspacePartition) String() string

func (*SrvKeyspace_KeyspacePartition) UnmarshalVT added in v0.11.0 

func (m *SrvKeyspace_KeyspacePartition) 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"`
	// primary_term_start_time is the time (in UTC) at which the current term of
	// the current tablet began as primary. If this tablet is not currently the
	// primary, this value is ignored.
	//
	// A new primary term begins any time an authoritative decision is communicated
	// about which tablet should be the primary, such as via Vitess
	// replication-management commands like PlannedReparentShard,
	// EmergencyReparentShard, and TabletExternallyReparented.
	PrimaryTermStartTime *vttime.Time `` /* 126-byte string literal not displayed */
	// default_conn_collation is the default connection collation used by this tablet.
	DefaultConnCollation uint32 `protobuf:"varint,16,opt,name=default_conn_collation,json=defaultConnCollation,proto3" json:"default_conn_collation,omitempty"`
	// contains filtered or unexported fields
}

Tablet represents information about a running instance of vttablet.

func (*Tablet) CloneMessageVT added in v0.18.0 

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

func (*Tablet) CloneVT added in v0.18.0 

func (m *Tablet) CloneVT() *Tablet

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) GetDefaultConnCollation added in v0.13.0 

func (x *Tablet) GetDefaultConnCollation() uint32

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) 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) GetPrimaryTermStartTime added in v0.12.0 

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

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) CloneMessageVT added in v0.18.0 

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

func (*TabletAlias) CloneVT added in v0.18.0 

func (m *TabletAlias) CloneVT() *TabletAlias

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
	// PRIMARY is the primary server for the shard. Only PRIMARY allows DMLs.
	TabletType_PRIMARY TabletType = 1
	// DEPRECATED
	TabletType_MASTER TabletType = 1
	// REPLICA replicates from primary. It is used to serve live traffic.
	// A REPLICA can be promoted to PRIMARY. A demoted PRIMARY 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 

func (TabletType) Type() protoreflect.EnumType

type ThrottledAppRule added in v0.18.0 

type ThrottledAppRule struct {

	// Name of the app to be throttled, e.g. "vreplication" or "online-ddl"
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Ratio defines how much the app should be throttled, range [0.0...1.0]. 1.0 means fully throttled. 0.0 means not throttled at all.
	// Negative values are reserved for a future implementation.
	Ratio float64 `protobuf:"fixed64,2,opt,name=ratio,proto3" json:"ratio,omitempty"`
	// ExpiresAt is the time at which the rule expires.
	ExpiresAt *vttime.Time `protobuf:"bytes,3,opt,name=expires_at,json=expiresAt,proto3" json:"expires_at,omitempty"`
	// Exempt indicates the app should never be throttled, even if the throttler is, in general, throttling other apps.
	Exempt bool `protobuf:"varint,4,opt,name=exempt,proto3" json:"exempt,omitempty"`
	// contains filtered or unexported fields
}

ThrottledAppRule defines an app-specific throttling rule, with expiration.

func (*ThrottledAppRule) CachedSize added in v0.18.0 

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

func (*ThrottledAppRule) CloneMessageVT added in v0.18.0 

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

func (*ThrottledAppRule) CloneVT added in v0.18.0 

func (m *ThrottledAppRule) CloneVT() *ThrottledAppRule

func (*ThrottledAppRule) Descriptor deprecated added in v0.18.0 

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

Deprecated: Use ThrottledAppRule.ProtoReflect.Descriptor instead.

func (*ThrottledAppRule) GetExempt added in v0.18.0 

func (x *ThrottledAppRule) GetExempt() bool

func (*ThrottledAppRule) GetExpiresAt added in v0.18.0 

func (x *ThrottledAppRule) GetExpiresAt() *vttime.Time

func (*ThrottledAppRule) GetName added in v0.18.0 

func (x *ThrottledAppRule) GetName() string

func (*ThrottledAppRule) GetRatio added in v0.18.0 

func (x *ThrottledAppRule) GetRatio() float64

func (*ThrottledAppRule) MarshalToSizedBufferVT added in v0.18.0 

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

func (*ThrottledAppRule) MarshalToVT added in v0.18.0 

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

func (*ThrottledAppRule) MarshalVT added in v0.18.0 

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

func (*ThrottledAppRule) ProtoMessage added in v0.18.0 

func (*ThrottledAppRule) ProtoMessage()

func (*ThrottledAppRule) ProtoReflect added in v0.18.0 

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

func (*ThrottledAppRule) Reset added in v0.18.0 

func (x *ThrottledAppRule) Reset()

func (*ThrottledAppRule) SizeVT added in v0.18.0 

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

func (*ThrottledAppRule) String added in v0.18.0 

func (x *ThrottledAppRule) String() string

func (*ThrottledAppRule) UnmarshalVT added in v0.18.0 

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

type ThrottlerConfig added in v0.16.1 

type ThrottlerConfig struct {

	// Enabled indicates that the throttler is actually checking state for
	// requests. When disabled, it automatically returns 200 OK for all
	// checks.
	Enabled bool `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"`
	// Threshold is the threshold for either the default check (heartbeat
	// lag) or custom check.
	Threshold float64 `protobuf:"fixed64,2,opt,name=threshold,proto3" json:"threshold,omitempty"`
	// CustomQuery is an optional query that overrides the default check
	// query.
	CustomQuery string `protobuf:"bytes,3,opt,name=custom_query,json=customQuery,proto3" json:"custom_query,omitempty"`
	// CheckAsCheckSelf indicates whether a throttler /check request
	// should behave like a /check-self.
	CheckAsCheckSelf bool `protobuf:"varint,4,opt,name=check_as_check_self,json=checkAsCheckSelf,proto3" json:"check_as_check_self,omitempty"`
	// ThrottledApps is a map of rules for app-specific throttling
	ThrottledApps map[string]*ThrottledAppRule `` /* 188-byte string literal not displayed */
	// AppCheckedMetrics maps app names to the list of metrics that should be checked for that app
	AppCheckedMetrics map[string]*ThrottlerConfig_MetricNames `` /* 202-byte string literal not displayed */
	// MetricThresholds maps metric names to the threshold values that should be used for that metric
	MetricThresholds map[string]float64 `` /* 199-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ThrottlerConfig) CloneMessageVT added in v0.18.0 

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

func (*ThrottlerConfig) CloneVT added in v0.18.0 

func (m *ThrottlerConfig) CloneVT() *ThrottlerConfig

func (*ThrottlerConfig) Descriptor deprecated added in v0.16.1 

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

Deprecated: Use ThrottlerConfig.ProtoReflect.Descriptor instead.

func (*ThrottlerConfig) GetAppCheckedMetrics added in v0.21.0 

func (x *ThrottlerConfig) GetAppCheckedMetrics() map[string]*ThrottlerConfig_MetricNames

func (*ThrottlerConfig) GetCheckAsCheckSelf added in v0.16.1 

func (x *ThrottlerConfig) GetCheckAsCheckSelf() bool

func (*ThrottlerConfig) GetCustomQuery added in v0.16.1 

func (x *ThrottlerConfig) GetCustomQuery() string

func (*ThrottlerConfig) GetEnabled added in v0.16.1 

func (x *ThrottlerConfig) GetEnabled() bool

func (*ThrottlerConfig) GetMetricThresholds added in v0.21.0 

func (x *ThrottlerConfig) GetMetricThresholds() map[string]float64

func (*ThrottlerConfig) GetThreshold added in v0.16.1 

func (x *ThrottlerConfig) GetThreshold() float64

func (*ThrottlerConfig) GetThrottledApps added in v0.18.0 

func (x *ThrottlerConfig) GetThrottledApps() map[string]*ThrottledAppRule

func (*ThrottlerConfig) MarshalToSizedBufferVT added in v0.16.1 

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

func (*ThrottlerConfig) MarshalToVT added in v0.16.1 

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

func (*ThrottlerConfig) MarshalVT added in v0.16.1 

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

func (*ThrottlerConfig) ProtoMessage added in v0.16.1 

func (*ThrottlerConfig) ProtoMessage()

func (*ThrottlerConfig) ProtoReflect added in v0.16.1 

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

func (*ThrottlerConfig) Reset added in v0.16.1 

func (x *ThrottlerConfig) Reset()

func (*ThrottlerConfig) SizeVT added in v0.16.1 

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

func (*ThrottlerConfig) String added in v0.16.1 

func (x *ThrottlerConfig) String() string

func (*ThrottlerConfig) UnmarshalVT added in v0.16.1 

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

type ThrottlerConfig_MetricNames added in v0.21.0 

type ThrottlerConfig_MetricNames struct {
	Names []string `protobuf:"bytes,1,rep,name=names,proto3" json:"names,omitempty"`
	// contains filtered or unexported fields
}

func (*ThrottlerConfig_MetricNames) CloneMessageVT added in v0.21.0 

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

func (*ThrottlerConfig_MetricNames) CloneVT added in v0.21.0 

func (m *ThrottlerConfig_MetricNames) CloneVT() *ThrottlerConfig_MetricNames

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

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

Deprecated: Use ThrottlerConfig_MetricNames.ProtoReflect.Descriptor instead.

func (*ThrottlerConfig_MetricNames) GetNames added in v0.21.0 

func (x *ThrottlerConfig_MetricNames) GetNames() []string

func (*ThrottlerConfig_MetricNames) MarshalToSizedBufferVT added in v0.21.0 

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

func (*ThrottlerConfig_MetricNames) MarshalToVT added in v0.21.0 

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

func (*ThrottlerConfig_MetricNames) MarshalVT added in v0.21.0 

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

func (*ThrottlerConfig_MetricNames) ProtoMessage added in v0.21.0 

func (*ThrottlerConfig_MetricNames) ProtoMessage()

func (*ThrottlerConfig_MetricNames) ProtoReflect added in v0.21.0 

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

func (*ThrottlerConfig_MetricNames) Reset added in v0.21.0 

func (x *ThrottlerConfig_MetricNames) Reset()

func (*ThrottlerConfig_MetricNames) SizeVT added in v0.21.0 

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

func (*ThrottlerConfig_MetricNames) String added in v0.21.0 

func (x *ThrottlerConfig_MetricNames) String() string

func (*ThrottlerConfig_MetricNames) UnmarshalVT added in v0.21.0 

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

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) CloneMessageVT added in v0.18.0 

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

func (*TopoConfig) CloneVT added in v0.18.0 

func (m *TopoConfig) CloneVT() *TopoConfig

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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