dev

package
v1.36.11-2025072813344... Latest Latest
Warning

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

 Go to latest Published: unknown License: Apache-2.0 Imports: 5 Imported by: 0

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_vitess_topodata_dev_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) GetRoot 

func (x *CellInfo) GetRoot() string

func (*CellInfo) GetServerAddress 

func (x *CellInfo) GetServerAddress() string

func (*CellInfo) ProtoMessage 

func (*CellInfo) ProtoMessage()

func (*CellInfo) ProtoReflect 

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

func (*CellInfo) Reset 

func (x *CellInfo) Reset()

func (*CellInfo) SetRoot 

func (x *CellInfo) SetRoot(v string)

func (*CellInfo) SetServerAddress 

func (x *CellInfo) SetServerAddress(v string)

func (*CellInfo) String 

func (x *CellInfo) String() string

type CellInfo_builder 

type CellInfo_builder 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
	// Root is the path to store data in. It is only used when talking
	// to server_address.
	Root string
	// contains filtered or unexported fields
}

func (CellInfo_builder) Build 

func (b0 CellInfo_builder) Build() *CellInfo

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) GetCells 

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

func (*CellsAlias) ProtoMessage 

func (*CellsAlias) ProtoMessage()

func (*CellsAlias) ProtoReflect 

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

func (*CellsAlias) Reset 

func (x *CellsAlias) Reset()

func (*CellsAlias) SetCells 

func (x *CellsAlias) SetCells(v []string)

func (*CellsAlias) String 

func (x *CellsAlias) String() string

type CellsAlias_builder 

type CellsAlias_builder struct {

	// Cells that map to this alias
	Cells []string
	// contains filtered or unexported fields
}

func (CellsAlias_builder) Build 

func (b0 CellsAlias_builder) Build() *CellsAlias

type ExternalClusters 

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) GetVitessCluster 

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

func (*ExternalClusters) ProtoMessage 

func (*ExternalClusters) ProtoMessage()

func (*ExternalClusters) ProtoReflect 

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

func (*ExternalClusters) Reset 

func (x *ExternalClusters) Reset()

func (*ExternalClusters) SetVitessCluster 

func (x *ExternalClusters) SetVitessCluster(v []*ExternalVitessCluster)

func (*ExternalClusters) String 

func (x *ExternalClusters) String() string

type ExternalClusters_builder 

type ExternalClusters_builder struct {
	VitessCluster []*ExternalVitessCluster
	// contains filtered or unexported fields
}

func (ExternalClusters_builder) Build 

func (b0 ExternalClusters_builder) Build() *ExternalClusters

type ExternalVitessCluster 

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) ClearTopoConfig 

func (x *ExternalVitessCluster) ClearTopoConfig()

func (*ExternalVitessCluster) GetTopoConfig 

func (x *ExternalVitessCluster) GetTopoConfig() *TopoConfig

func (*ExternalVitessCluster) HasTopoConfig 

func (x *ExternalVitessCluster) HasTopoConfig() bool

func (*ExternalVitessCluster) ProtoMessage 

func (*ExternalVitessCluster) ProtoMessage()

func (*ExternalVitessCluster) ProtoReflect 

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

func (*ExternalVitessCluster) Reset 

func (x *ExternalVitessCluster) Reset()

func (*ExternalVitessCluster) SetTopoConfig 

func (x *ExternalVitessCluster) SetTopoConfig(v *TopoConfig)

func (*ExternalVitessCluster) String 

func (x *ExternalVitessCluster) String() string

type ExternalVitessCluster_builder 

type ExternalVitessCluster_builder struct {
	TopoConfig *TopoConfig
	// contains filtered or unexported fields
}

func (ExternalVitessCluster_builder) Build 

func (b0 ExternalVitessCluster_builder) Build() *ExternalVitessCluster

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) GetEnd 

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

func (*KeyRange) GetStart 

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

func (*KeyRange) ProtoMessage 

func (*KeyRange) ProtoMessage()

func (*KeyRange) ProtoReflect 

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

func (*KeyRange) Reset 

func (x *KeyRange) Reset()

func (*KeyRange) SetEnd 

func (x *KeyRange) SetEnd(v []byte)

func (*KeyRange) SetStart 

func (x *KeyRange) SetStart(v []byte)

func (*KeyRange) String 

func (x *KeyRange) String() string

type KeyRange_builder 

type KeyRange_builder struct {
	Start []byte
	End   []byte
	// contains filtered or unexported fields
}

func (KeyRange_builder) Build 

func (b0 KeyRange_builder) Build() *KeyRange

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 `` /* 136-byte string literal not displayed */
	// 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 *dev.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) ClearSnapshotTime 

func (x *Keyspace) ClearSnapshotTime()

func (*Keyspace) ClearThrottlerConfig 

func (x *Keyspace) ClearThrottlerConfig()

func (*Keyspace) GetBaseKeyspace 

func (x *Keyspace) GetBaseKeyspace() string

func (*Keyspace) GetDurabilityPolicy 

func (x *Keyspace) GetDurabilityPolicy() string

func (*Keyspace) GetKeyspaceType 

func (x *Keyspace) GetKeyspaceType() KeyspaceType

func (*Keyspace) GetSidecarDbName 

func (x *Keyspace) GetSidecarDbName() string

func (*Keyspace) GetSnapshotTime 

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

func (*Keyspace) GetThrottlerConfig 

func (x *Keyspace) GetThrottlerConfig() *ThrottlerConfig

func (*Keyspace) HasSnapshotTime 

func (x *Keyspace) HasSnapshotTime() bool

func (*Keyspace) HasThrottlerConfig 

func (x *Keyspace) HasThrottlerConfig() bool

func (*Keyspace) ProtoMessage 

func (*Keyspace) ProtoMessage()

func (*Keyspace) ProtoReflect 

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

func (*Keyspace) Reset 

func (x *Keyspace) Reset()

func (*Keyspace) SetBaseKeyspace 

func (x *Keyspace) SetBaseKeyspace(v string)

func (*Keyspace) SetDurabilityPolicy 

func (x *Keyspace) SetDurabilityPolicy(v string)

func (*Keyspace) SetKeyspaceType 

func (x *Keyspace) SetKeyspaceType(v KeyspaceType)

func (*Keyspace) SetSidecarDbName 

func (x *Keyspace) SetSidecarDbName(v string)

func (*Keyspace) SetSnapshotTime 

func (x *Keyspace) SetSnapshotTime(v *dev.Time)

func (*Keyspace) SetThrottlerConfig 

func (x *Keyspace) SetThrottlerConfig(v *ThrottlerConfig)

func (*Keyspace) String 

func (x *Keyspace) String() string

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 

func (KeyspaceType) Descriptor() protoreflect.EnumDescriptor

func (KeyspaceType) Enum 

func (x KeyspaceType) Enum() *KeyspaceType

func (KeyspaceType) Number 

func (x KeyspaceType) Number() protoreflect.EnumNumber

func (KeyspaceType) String 

func (x KeyspaceType) String() string

func (KeyspaceType) Type 

func (KeyspaceType) Type() protoreflect.EnumType

type Keyspace_builder 

type Keyspace_builder 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
	// base_keyspace is the base keyspace from which a snapshot
	// keyspace is created. empty for normal keyspaces
	BaseKeyspace string
	// snapshot_time (in UTC) is a property of snapshot
	// keyspaces which tells us what point in time
	// the snapshot is of
	SnapshotTime *dev.Time
	// DurabilityPolicy is the durability policy to be
	// used for the keyspace.
	DurabilityPolicy string
	// ThrottlerConfig has the configuration for the tablet
	// server's lag throttler, and applies to the entire
	// keyspace, across all shards and tablets.
	ThrottlerConfig *ThrottlerConfig
	// 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
	// contains filtered or unexported fields
}

func (Keyspace_builder) Build 

func (b0 Keyspace_builder) Build() *Keyspace

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 *dev.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) ClearKeyRange 

func (x *Shard) ClearKeyRange()

func (*Shard) ClearPrimaryAlias 

func (x *Shard) ClearPrimaryAlias()

func (*Shard) ClearPrimaryTermStartTime 

func (x *Shard) ClearPrimaryTermStartTime()

func (*Shard) GetIsPrimaryServing 

func (x *Shard) GetIsPrimaryServing() bool

func (*Shard) GetKeyRange 

func (x *Shard) GetKeyRange() *KeyRange

func (*Shard) GetPrimaryAlias 

func (x *Shard) GetPrimaryAlias() *TabletAlias

func (*Shard) GetPrimaryTermStartTime 

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

func (*Shard) GetSourceShards 

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

func (*Shard) GetTabletControls 

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

func (*Shard) HasKeyRange 

func (x *Shard) HasKeyRange() bool

func (*Shard) HasPrimaryAlias 

func (x *Shard) HasPrimaryAlias() bool

func (*Shard) HasPrimaryTermStartTime 

func (x *Shard) HasPrimaryTermStartTime() bool

func (*Shard) ProtoMessage 

func (*Shard) ProtoMessage()

func (*Shard) ProtoReflect 

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

func (*Shard) Reset 

func (x *Shard) Reset()

func (*Shard) SetIsPrimaryServing 

func (x *Shard) SetIsPrimaryServing(v bool)

func (*Shard) SetKeyRange 

func (x *Shard) SetKeyRange(v *KeyRange)

func (*Shard) SetPrimaryAlias 

func (x *Shard) SetPrimaryAlias(v *TabletAlias)

func (*Shard) SetPrimaryTermStartTime 

func (x *Shard) SetPrimaryTermStartTime(v *dev.Time)

func (*Shard) SetSourceShards 

func (x *Shard) SetSourceShards(v []*Shard_SourceShard)

func (*Shard) SetTabletControls 

func (x *Shard) SetTabletControls(v []*Shard_TabletControl)

func (*Shard) String 

func (x *Shard) String() string

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) ClearKeyRange 

func (x *ShardReference) ClearKeyRange()

func (*ShardReference) GetKeyRange 

func (x *ShardReference) GetKeyRange() *KeyRange

func (*ShardReference) GetName 

func (x *ShardReference) GetName() string

func (*ShardReference) HasKeyRange 

func (x *ShardReference) HasKeyRange() bool

func (*ShardReference) ProtoMessage 

func (*ShardReference) ProtoMessage()

func (*ShardReference) ProtoReflect 

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

func (*ShardReference) Reset 

func (x *ShardReference) Reset()

func (*ShardReference) SetKeyRange 

func (x *ShardReference) SetKeyRange(v *KeyRange)

func (*ShardReference) SetName 

func (x *ShardReference) SetName(v string)

func (*ShardReference) String 

func (x *ShardReference) String() string

type ShardReference_builder 

type ShardReference_builder struct {

	// Copied from Shard.
	Name     string
	KeyRange *KeyRange
	// contains filtered or unexported fields
}

func (ShardReference_builder) Build 

func (b0 ShardReference_builder) Build() *ShardReference

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) GetNodes 

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

func (*ShardReplication) ProtoMessage 

func (*ShardReplication) ProtoMessage()

func (*ShardReplication) ProtoReflect 

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

func (*ShardReplication) Reset 

func (x *ShardReplication) Reset()

func (*ShardReplication) SetNodes 

func (x *ShardReplication) SetNodes(v []*ShardReplication_Node)

func (*ShardReplication) String 

func (x *ShardReplication) String() string

type ShardReplicationError 

type ShardReplicationError struct {

	// Type is the category of problem being fixed.
	Type ShardReplicationError_Type `protobuf:"varint,1,opt,name=type,proto3,enum=vitess.topodata.dev.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) ClearTabletAlias 

func (x *ShardReplicationError) ClearTabletAlias()

func (*ShardReplicationError) GetTabletAlias 

func (x *ShardReplicationError) GetTabletAlias() *TabletAlias

func (*ShardReplicationError) GetType 

func (x *ShardReplicationError) GetType() ShardReplicationError_Type

func (*ShardReplicationError) HasTabletAlias 

func (x *ShardReplicationError) HasTabletAlias() bool

func (*ShardReplicationError) ProtoMessage 

func (*ShardReplicationError) ProtoMessage()

func (*ShardReplicationError) ProtoReflect 

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

func (*ShardReplicationError) Reset 

func (x *ShardReplicationError) Reset()

func (*ShardReplicationError) SetTabletAlias 

func (x *ShardReplicationError) SetTabletAlias(v *TabletAlias)

func (*ShardReplicationError) SetType 

func (x *ShardReplicationError) SetType(v ShardReplicationError_Type)

func (*ShardReplicationError) String 

func (x *ShardReplicationError) String() string

type ShardReplicationError_Type 

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 

func (ShardReplicationError_Type) Descriptor() protoreflect.EnumDescriptor

func (ShardReplicationError_Type) Enum 

func (x ShardReplicationError_Type) Enum() *ShardReplicationError_Type

func (ShardReplicationError_Type) Number 

func (x ShardReplicationError_Type) Number() protoreflect.EnumNumber

func (ShardReplicationError_Type) String 

func (x ShardReplicationError_Type) String() string

func (ShardReplicationError_Type) Type 

func (ShardReplicationError_Type) Type() protoreflect.EnumType

type ShardReplicationError_builder 

type ShardReplicationError_builder struct {

	// Type is the category of problem being fixed.
	Type ShardReplicationError_Type
	// TabletAlias is the tablet record that has the problem.
	TabletAlias *TabletAlias
	// contains filtered or unexported fields
}

func (ShardReplicationError_builder) Build 

func (b0 ShardReplicationError_builder) Build() *ShardReplicationError

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) ClearTabletAlias 

func (x *ShardReplication_Node) ClearTabletAlias()

func (*ShardReplication_Node) GetTabletAlias 

func (x *ShardReplication_Node) GetTabletAlias() *TabletAlias

func (*ShardReplication_Node) HasTabletAlias 

func (x *ShardReplication_Node) HasTabletAlias() bool

func (*ShardReplication_Node) ProtoMessage 

func (*ShardReplication_Node) ProtoMessage()

func (*ShardReplication_Node) ProtoReflect 

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

func (*ShardReplication_Node) Reset 

func (x *ShardReplication_Node) Reset()

func (*ShardReplication_Node) SetTabletAlias 

func (x *ShardReplication_Node) SetTabletAlias(v *TabletAlias)

func (*ShardReplication_Node) String 

func (x *ShardReplication_Node) String() string

type ShardReplication_Node_builder 

type ShardReplication_Node_builder struct {
	TabletAlias *TabletAlias
	// contains filtered or unexported fields
}

func (ShardReplication_Node_builder) Build 

func (b0 ShardReplication_Node_builder) Build() *ShardReplication_Node

type ShardReplication_builder 

type ShardReplication_builder struct {

	// Note there can be only one Node in this array
	// for a given tablet.
	Nodes []*ShardReplication_Node
	// contains filtered or unexported fields
}

func (ShardReplication_builder) Build 

func (b0 ShardReplication_builder) Build() *ShardReplication

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) ClearKeyRange 

func (x *ShardTabletControl) ClearKeyRange()

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) HasKeyRange 

func (x *ShardTabletControl) HasKeyRange() bool

func (*ShardTabletControl) ProtoMessage 

func (*ShardTabletControl) ProtoMessage()

func (*ShardTabletControl) ProtoReflect 

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

func (*ShardTabletControl) Reset 

func (x *ShardTabletControl) Reset()

func (*ShardTabletControl) SetKeyRange 

func (x *ShardTabletControl) SetKeyRange(v *KeyRange)

func (*ShardTabletControl) SetName 

func (x *ShardTabletControl) SetName(v string)

func (*ShardTabletControl) SetQueryServiceDisabled 

func (x *ShardTabletControl) SetQueryServiceDisabled(v bool)

func (*ShardTabletControl) String 

func (x *ShardTabletControl) String() string

type ShardTabletControl_builder 

type ShardTabletControl_builder struct {

	// Copied from Shard.
	Name     string
	KeyRange *KeyRange
	// Disable query serving in this shard
	QueryServiceDisabled bool
	// contains filtered or unexported fields
}

func (ShardTabletControl_builder) Build 

func (b0 ShardTabletControl_builder) Build() *ShardTabletControl

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) ClearKeyRange 

func (x *Shard_SourceShard) ClearKeyRange()

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) HasKeyRange 

func (x *Shard_SourceShard) HasKeyRange() bool

func (*Shard_SourceShard) ProtoMessage 

func (*Shard_SourceShard) ProtoMessage()

func (*Shard_SourceShard) ProtoReflect 

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

func (*Shard_SourceShard) Reset 

func (x *Shard_SourceShard) Reset()

func (*Shard_SourceShard) SetKeyRange 

func (x *Shard_SourceShard) SetKeyRange(v *KeyRange)

func (*Shard_SourceShard) SetKeyspace 

func (x *Shard_SourceShard) SetKeyspace(v string)

func (*Shard_SourceShard) SetShard 

func (x *Shard_SourceShard) SetShard(v string)

func (*Shard_SourceShard) SetTables 

func (x *Shard_SourceShard) SetTables(v []string)

func (*Shard_SourceShard) SetUid 

func (x *Shard_SourceShard) SetUid(v int32)

func (*Shard_SourceShard) String 

func (x *Shard_SourceShard) String() string

type Shard_SourceShard_builder 

type Shard_SourceShard_builder struct {

	// Uid is the unique ID for this SourceShard object.
	Uid int32
	// the source keyspace
	Keyspace string
	// the source shard
	Shard string
	// the source shard keyrange
	KeyRange *KeyRange
	// the source table list to replicate
	Tables []string
	// contains filtered or unexported fields
}

func (Shard_SourceShard_builder) Build 

func (b0 Shard_SourceShard_builder) Build() *Shard_SourceShard

type Shard_TabletControl 

type Shard_TabletControl struct {

	// which tablet type is affected
	TabletType   TabletType `` /* 128-byte string literal not displayed */
	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) GetCells 

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

func (*Shard_TabletControl) GetDeniedTables 

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) ProtoMessage 

func (*Shard_TabletControl) ProtoMessage()

func (*Shard_TabletControl) ProtoReflect 

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

func (*Shard_TabletControl) Reset 

func (x *Shard_TabletControl) Reset()

func (*Shard_TabletControl) SetCells 

func (x *Shard_TabletControl) SetCells(v []string)

func (*Shard_TabletControl) SetDeniedTables 

func (x *Shard_TabletControl) SetDeniedTables(v []string)

func (*Shard_TabletControl) SetFrozen 

func (x *Shard_TabletControl) SetFrozen(v bool)

func (*Shard_TabletControl) SetTabletType 

func (x *Shard_TabletControl) SetTabletType(v TabletType)

func (*Shard_TabletControl) String 

func (x *Shard_TabletControl) String() string

type Shard_TabletControl_builder 

type Shard_TabletControl_builder struct {

	// which tablet type is affected
	TabletType   TabletType
	Cells        []string
	DeniedTables []string
	// frozen is set if we've started failing over traffic for
	// the primary. If set, this record should not be removed.
	Frozen bool
	// contains filtered or unexported fields
}

func (Shard_TabletControl_builder) Build 

func (b0 Shard_TabletControl_builder) Build() *Shard_TabletControl

type Shard_builder 

type Shard_builder 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
	// 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 *dev.Time
	// 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
	// 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
	// tablet_controls has at most one entry per TabletType.
	// The keyspace lock is always taken when changing this.
	TabletControls []*Shard_TabletControl
	// is_primary_serving sets whether this shard primary is serving traffic or not.
	// The keyspace lock is always taken when changing this.
	IsPrimaryServing bool
	// contains filtered or unexported fields
}

func (Shard_builder) Build 

func (b0 Shard_builder) Build() *Shard

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) ClearThrottlerConfig 

func (x *SrvKeyspace) ClearThrottlerConfig()

func (*SrvKeyspace) GetPartitions 

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

func (*SrvKeyspace) GetThrottlerConfig 

func (x *SrvKeyspace) GetThrottlerConfig() *ThrottlerConfig

func (*SrvKeyspace) HasThrottlerConfig 

func (x *SrvKeyspace) HasThrottlerConfig() bool

func (*SrvKeyspace) ProtoMessage 

func (*SrvKeyspace) ProtoMessage()

func (*SrvKeyspace) ProtoReflect 

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

func (*SrvKeyspace) Reset 

func (x *SrvKeyspace) Reset()

func (*SrvKeyspace) SetPartitions 

func (x *SrvKeyspace) SetPartitions(v []*SrvKeyspace_KeyspacePartition)

func (*SrvKeyspace) SetThrottlerConfig 

func (x *SrvKeyspace) SetThrottlerConfig(v *ThrottlerConfig)

func (*SrvKeyspace) String 

func (x *SrvKeyspace) String() string

type SrvKeyspace_KeyspacePartition 

type SrvKeyspace_KeyspacePartition struct {

	// The type this partition applies to.
	ServedType TabletType `` /* 128-byte string literal not displayed */
	// 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) 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) ProtoMessage 

func (*SrvKeyspace_KeyspacePartition) ProtoMessage()

func (*SrvKeyspace_KeyspacePartition) ProtoReflect 

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

func (*SrvKeyspace_KeyspacePartition) Reset 

func (x *SrvKeyspace_KeyspacePartition) Reset()

func (*SrvKeyspace_KeyspacePartition) SetServedType 

func (x *SrvKeyspace_KeyspacePartition) SetServedType(v TabletType)

func (*SrvKeyspace_KeyspacePartition) SetShardReferences 

func (x *SrvKeyspace_KeyspacePartition) SetShardReferences(v []*ShardReference)

func (*SrvKeyspace_KeyspacePartition) SetShardTabletControls 

func (x *SrvKeyspace_KeyspacePartition) SetShardTabletControls(v []*ShardTabletControl)

func (*SrvKeyspace_KeyspacePartition) String 

func (x *SrvKeyspace_KeyspacePartition) String() string

type SrvKeyspace_KeyspacePartition_builder 

type SrvKeyspace_KeyspacePartition_builder struct {

	// The type this partition applies to.
	ServedType TabletType
	// List of non-overlapping continuous shards sorted by range.
	ShardReferences []*ShardReference
	// List of shard tablet controls
	ShardTabletControls []*ShardTabletControl
	// contains filtered or unexported fields
}

func (SrvKeyspace_KeyspacePartition_builder) Build 

func (b0 SrvKeyspace_KeyspacePartition_builder) Build() *SrvKeyspace_KeyspacePartition

type SrvKeyspace_builder 

type SrvKeyspace_builder struct {

	// The partitions this keyspace is serving, per tablet type.
	Partitions []*SrvKeyspace_KeyspacePartition
	// 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
	// contains filtered or unexported fields
}

func (SrvKeyspace_builder) Build 

func (b0 SrvKeyspace_builder) Build() *SrvKeyspace

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 `` /* 157-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=vitess.topodata.dev.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 `` /* 136-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 *dev.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) ClearAlias 

func (x *Tablet) ClearAlias()

func (*Tablet) ClearKeyRange 

func (x *Tablet) ClearKeyRange()

func (*Tablet) ClearPrimaryTermStartTime 

func (x *Tablet) ClearPrimaryTermStartTime()

func (*Tablet) GetAlias 

func (x *Tablet) GetAlias() *TabletAlias

func (*Tablet) GetDbNameOverride 

func (x *Tablet) GetDbNameOverride() string

func (*Tablet) GetDefaultConnCollation 

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 

func (x *Tablet) GetPrimaryTermStartTime() *dev.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) HasAlias 

func (x *Tablet) HasAlias() bool

func (*Tablet) HasKeyRange 

func (x *Tablet) HasKeyRange() bool

func (*Tablet) HasPrimaryTermStartTime 

func (x *Tablet) HasPrimaryTermStartTime() bool

func (*Tablet) ProtoMessage 

func (*Tablet) ProtoMessage()

func (*Tablet) ProtoReflect 

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

func (*Tablet) Reset 

func (x *Tablet) Reset()

func (*Tablet) SetAlias 

func (x *Tablet) SetAlias(v *TabletAlias)

func (*Tablet) SetDbNameOverride 

func (x *Tablet) SetDbNameOverride(v string)

func (*Tablet) SetDefaultConnCollation 

func (x *Tablet) SetDefaultConnCollation(v uint32)

func (*Tablet) SetHostname 

func (x *Tablet) SetHostname(v string)

func (*Tablet) SetKeyRange 

func (x *Tablet) SetKeyRange(v *KeyRange)

func (*Tablet) SetKeyspace 

func (x *Tablet) SetKeyspace(v string)

func (*Tablet) SetMysqlHostname 

func (x *Tablet) SetMysqlHostname(v string)

func (*Tablet) SetMysqlPort 

func (x *Tablet) SetMysqlPort(v int32)

func (*Tablet) SetPortMap 

func (x *Tablet) SetPortMap(v map[string]int32)

func (*Tablet) SetPrimaryTermStartTime 

func (x *Tablet) SetPrimaryTermStartTime(v *dev.Time)

func (*Tablet) SetShard 

func (x *Tablet) SetShard(v string)

func (*Tablet) SetTags 

func (x *Tablet) SetTags(v map[string]string)

func (*Tablet) SetType 

func (x *Tablet) SetType(v TabletType)

func (*Tablet) String 

func (x *Tablet) String() string

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) GetCell 

func (x *TabletAlias) GetCell() string

func (*TabletAlias) GetUid 

func (x *TabletAlias) GetUid() uint32

func (*TabletAlias) ProtoMessage 

func (*TabletAlias) ProtoMessage()

func (*TabletAlias) ProtoReflect 

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

func (*TabletAlias) Reset 

func (x *TabletAlias) Reset()

func (*TabletAlias) SetCell 

func (x *TabletAlias) SetCell(v string)

func (*TabletAlias) SetUid 

func (x *TabletAlias) SetUid(v uint32)

func (*TabletAlias) String 

func (x *TabletAlias) String() string

type TabletAlias_builder 

type TabletAlias_builder struct {

	// cell is the cell (or datacenter) the tablet is in
	Cell string
	// uid is a unique id for this tablet within the shard
	// (this is the MySQL server id as well).
	Uid uint32
	// contains filtered or unexported fields
}

func (TabletAlias_builder) Build 

func (b0 TabletAlias_builder) Build() *TabletAlias

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 

func (TabletType) Descriptor() protoreflect.EnumDescriptor

func (TabletType) Enum 

func (x TabletType) Enum() *TabletType

func (TabletType) Number 

func (x TabletType) Number() protoreflect.EnumNumber

func (TabletType) String 

func (x TabletType) String() string

func (TabletType) Type 

func (TabletType) Type() protoreflect.EnumType

type Tablet_builder 

type Tablet_builder struct {

	// alias is the unique name of the tablet.
	Alias *TabletAlias
	// Fully qualified domain name of the host.
	Hostname string
	// 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
	// Keyspace name.
	Keyspace string
	// Shard name. If range based sharding is used, it should match
	// key_range.
	Shard string
	// If range based sharding is used, range for the tablet's shard.
	KeyRange *KeyRange
	// type is the current type of the tablet.
	Type TabletType
	// It this is set, it is used as the database name instead of the
	// normal "vt_" + keyspace.
	DbNameOverride string
	// tablet tags
	Tags map[string]string
	// MySQL hostname.
	MysqlHostname string
	// MySQL port. Use topoproto.MysqlPort and topoproto.SetMysqlPort
	// to access this variable. The functions provide support
	// for legacy behavior.
	MysqlPort int32
	// 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 *dev.Time
	// default_conn_collation is the default connection collation used by this tablet.
	DefaultConnCollation uint32
	// contains filtered or unexported fields
}

func (Tablet_builder) Build 

func (b0 Tablet_builder) Build() *Tablet

type ThrottledAppRule 

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 *dev.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) ClearExpiresAt 

func (x *ThrottledAppRule) ClearExpiresAt()

func (*ThrottledAppRule) GetExempt 

func (x *ThrottledAppRule) GetExempt() bool

func (*ThrottledAppRule) GetExpiresAt 

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

func (*ThrottledAppRule) GetName 

func (x *ThrottledAppRule) GetName() string

func (*ThrottledAppRule) GetRatio 

func (x *ThrottledAppRule) GetRatio() float64

func (*ThrottledAppRule) HasExpiresAt 

func (x *ThrottledAppRule) HasExpiresAt() bool

func (*ThrottledAppRule) ProtoMessage 

func (*ThrottledAppRule) ProtoMessage()

func (*ThrottledAppRule) ProtoReflect 

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

func (*ThrottledAppRule) Reset 

func (x *ThrottledAppRule) Reset()

func (*ThrottledAppRule) SetExempt 

func (x *ThrottledAppRule) SetExempt(v bool)

func (*ThrottledAppRule) SetExpiresAt 

func (x *ThrottledAppRule) SetExpiresAt(v *dev.Time)

func (*ThrottledAppRule) SetName 

func (x *ThrottledAppRule) SetName(v string)

func (*ThrottledAppRule) SetRatio 

func (x *ThrottledAppRule) SetRatio(v float64)

func (*ThrottledAppRule) String 

func (x *ThrottledAppRule) String() string

type ThrottledAppRule_builder 

type ThrottledAppRule_builder struct {

	// Name of the app to be throttled, e.g. "vreplication" or "online-ddl"
	Name string
	// 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
	// ExpiresAt is the time at which the rule expires.
	ExpiresAt *dev.Time
	// Exempt indicates the app should never be throttled, even if the throttler is, in general, throttling other apps.
	Exempt bool
	// contains filtered or unexported fields
}

func (ThrottledAppRule_builder) Build 

func (b0 ThrottledAppRule_builder) Build() *ThrottledAppRule

type ThrottlerConfig 

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 `` /* 174-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 `` /* 188-byte string literal not displayed */
	// MetricThresholds maps metric names to the threshold values that should be used for that metric
	MetricThresholds map[string]float64 `` /* 185-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ThrottlerConfig) GetAppCheckedMetrics 

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

func (*ThrottlerConfig) GetCheckAsCheckSelf 

func (x *ThrottlerConfig) GetCheckAsCheckSelf() bool

func (*ThrottlerConfig) GetCustomQuery 

func (x *ThrottlerConfig) GetCustomQuery() string

func (*ThrottlerConfig) GetEnabled 

func (x *ThrottlerConfig) GetEnabled() bool

func (*ThrottlerConfig) GetMetricThresholds 

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

func (*ThrottlerConfig) GetThreshold 

func (x *ThrottlerConfig) GetThreshold() float64

func (*ThrottlerConfig) GetThrottledApps 

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

func (*ThrottlerConfig) ProtoMessage 

func (*ThrottlerConfig) ProtoMessage()

func (*ThrottlerConfig) ProtoReflect 

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

func (*ThrottlerConfig) Reset 

func (x *ThrottlerConfig) Reset()

func (*ThrottlerConfig) SetAppCheckedMetrics 

func (x *ThrottlerConfig) SetAppCheckedMetrics(v map[string]*ThrottlerConfig_MetricNames)

func (*ThrottlerConfig) SetCheckAsCheckSelf 

func (x *ThrottlerConfig) SetCheckAsCheckSelf(v bool)

func (*ThrottlerConfig) SetCustomQuery 

func (x *ThrottlerConfig) SetCustomQuery(v string)

func (*ThrottlerConfig) SetEnabled 

func (x *ThrottlerConfig) SetEnabled(v bool)

func (*ThrottlerConfig) SetMetricThresholds 

func (x *ThrottlerConfig) SetMetricThresholds(v map[string]float64)

func (*ThrottlerConfig) SetThreshold 

func (x *ThrottlerConfig) SetThreshold(v float64)

func (*ThrottlerConfig) SetThrottledApps 

func (x *ThrottlerConfig) SetThrottledApps(v map[string]*ThrottledAppRule)

func (*ThrottlerConfig) String 

func (x *ThrottlerConfig) String() string

type ThrottlerConfig_MetricNames 

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

func (*ThrottlerConfig_MetricNames) GetNames 

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

func (*ThrottlerConfig_MetricNames) ProtoMessage 

func (*ThrottlerConfig_MetricNames) ProtoMessage()

func (*ThrottlerConfig_MetricNames) ProtoReflect 

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

func (*ThrottlerConfig_MetricNames) Reset 

func (x *ThrottlerConfig_MetricNames) Reset()

func (*ThrottlerConfig_MetricNames) SetNames 

func (x *ThrottlerConfig_MetricNames) SetNames(v []string)

func (*ThrottlerConfig_MetricNames) String 

func (x *ThrottlerConfig_MetricNames) String() string

type ThrottlerConfig_MetricNames_builder 

type ThrottlerConfig_MetricNames_builder struct {
	Names []string
	// contains filtered or unexported fields
}

func (ThrottlerConfig_MetricNames_builder) Build 

func (b0 ThrottlerConfig_MetricNames_builder) Build() *ThrottlerConfig_MetricNames

type ThrottlerConfig_builder 

type ThrottlerConfig_builder struct {

	// Enabled indicates that the throttler is actually checking state for
	// requests. When disabled, it automatically returns 200 OK for all
	// checks.
	Enabled bool
	// Threshold is the threshold for either the default check (heartbeat
	// lag) or custom check.
	Threshold float64
	// CustomQuery is an optional query that overrides the default check
	// query.
	CustomQuery string
	// CheckAsCheckSelf indicates whether a throttler /check request
	// should behave like a /check-self.
	CheckAsCheckSelf bool
	// ThrottledApps is a map of rules for app-specific throttling
	ThrottledApps map[string]*ThrottledAppRule
	// AppCheckedMetrics maps app names to the list of metrics that should be checked for that app
	AppCheckedMetrics map[string]*ThrottlerConfig_MetricNames
	// MetricThresholds maps metric names to the threshold values that should be used for that metric
	MetricThresholds map[string]float64
	// contains filtered or unexported fields
}

func (ThrottlerConfig_builder) Build 

func (b0 ThrottlerConfig_builder) Build() *ThrottlerConfig

type TopoConfig 

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) GetRoot 

func (x *TopoConfig) GetRoot() string

func (*TopoConfig) GetServer 

func (x *TopoConfig) GetServer() string

func (*TopoConfig) GetTopoType 

func (x *TopoConfig) GetTopoType() string

func (*TopoConfig) ProtoMessage 

func (*TopoConfig) ProtoMessage()

func (*TopoConfig) ProtoReflect 

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

func (*TopoConfig) Reset 

func (x *TopoConfig) Reset()

func (*TopoConfig) SetRoot 

func (x *TopoConfig) SetRoot(v string)

func (*TopoConfig) SetServer 

func (x *TopoConfig) SetServer(v string)

func (*TopoConfig) SetTopoType 

func (x *TopoConfig) SetTopoType(v string)

func (*TopoConfig) String 

func (x *TopoConfig) String() string

type TopoConfig_builder 

type TopoConfig_builder struct {
	TopoType string
	Server   string
	Root     string
	// contains filtered or unexported fields
}

func (TopoConfig_builder) Build 

func (b0 TopoConfig_builder) Build() *TopoConfig

Source Files

  • topodata.pb.go

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.