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: 10 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	Tablet_ServingState_name = map[int32]string{
		0: "UNKNOWN",
		1: "SERVING",
		2: "NOT_SERVING",
	}
	Tablet_ServingState_value = map[string]int32{
		"UNKNOWN":     0,
		"SERVING":     1,
		"NOT_SERVING": 2,
	}
)

Enum value maps for Tablet_ServingState.

View Source
var File_vitess_vtadmin_dev_vtadmin_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type ApplySchemaRequest

type ApplySchemaRequest struct {
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// Request.Sql will be overriden by this Sql field.
	Sql string `protobuf:"bytes,2,opt,name=sql,proto3" json:"sql,omitempty"`
	// Request.CallerId will be overriden by this CallerId field.
	CallerId string                   `protobuf:"bytes,3,opt,name=caller_id,json=callerId,proto3" json:"caller_id,omitempty"`
	Request  *dev2.ApplySchemaRequest `protobuf:"bytes,4,opt,name=request,proto3" json:"request,omitempty"`
	// contains filtered or unexported fields
}

func (*ApplySchemaRequest) ClearRequest

func (x *ApplySchemaRequest) ClearRequest()

func (*ApplySchemaRequest) GetCallerId

func (x *ApplySchemaRequest) GetCallerId() string

func (*ApplySchemaRequest) GetClusterId

func (x *ApplySchemaRequest) GetClusterId() string

func (*ApplySchemaRequest) GetRequest

func (x *ApplySchemaRequest) GetRequest() *dev2.ApplySchemaRequest

func (*ApplySchemaRequest) GetSql

func (x *ApplySchemaRequest) GetSql() string

func (*ApplySchemaRequest) HasRequest

func (x *ApplySchemaRequest) HasRequest() bool

func (*ApplySchemaRequest) ProtoMessage

func (*ApplySchemaRequest) ProtoMessage()

func (*ApplySchemaRequest) ProtoReflect

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

func (*ApplySchemaRequest) Reset

func (x *ApplySchemaRequest) Reset()

func (*ApplySchemaRequest) SetCallerId

func (x *ApplySchemaRequest) SetCallerId(v string)

func (*ApplySchemaRequest) SetClusterId

func (x *ApplySchemaRequest) SetClusterId(v string)

func (*ApplySchemaRequest) SetRequest

func (x *ApplySchemaRequest) SetRequest(v *dev2.ApplySchemaRequest)

func (*ApplySchemaRequest) SetSql

func (x *ApplySchemaRequest) SetSql(v string)

func (*ApplySchemaRequest) String

func (x *ApplySchemaRequest) String() string

type ApplySchemaRequest_builder

type ApplySchemaRequest_builder struct {
	ClusterId string
	// Request.Sql will be overriden by this Sql field.
	Sql string
	// Request.CallerId will be overriden by this CallerId field.
	CallerId string
	Request  *dev2.ApplySchemaRequest
	// contains filtered or unexported fields
}

func (ApplySchemaRequest_builder) Build

type CancelSchemaMigrationRequest

type CancelSchemaMigrationRequest struct {
	ClusterId string                             `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Request   *dev2.CancelSchemaMigrationRequest `protobuf:"bytes,2,opt,name=request,proto3" json:"request,omitempty"`
	// contains filtered or unexported fields
}

func (*CancelSchemaMigrationRequest) ClearRequest

func (x *CancelSchemaMigrationRequest) ClearRequest()

func (*CancelSchemaMigrationRequest) GetClusterId

func (x *CancelSchemaMigrationRequest) GetClusterId() string

func (*CancelSchemaMigrationRequest) GetRequest

func (*CancelSchemaMigrationRequest) HasRequest

func (x *CancelSchemaMigrationRequest) HasRequest() bool

func (*CancelSchemaMigrationRequest) ProtoMessage

func (*CancelSchemaMigrationRequest) ProtoMessage()

func (*CancelSchemaMigrationRequest) ProtoReflect

func (*CancelSchemaMigrationRequest) Reset

func (x *CancelSchemaMigrationRequest) Reset()

func (*CancelSchemaMigrationRequest) SetClusterId

func (x *CancelSchemaMigrationRequest) SetClusterId(v string)

func (*CancelSchemaMigrationRequest) SetRequest

func (*CancelSchemaMigrationRequest) String

type CancelSchemaMigrationRequest_builder

type CancelSchemaMigrationRequest_builder struct {
	ClusterId string
	Request   *dev2.CancelSchemaMigrationRequest
	// contains filtered or unexported fields
}

func (CancelSchemaMigrationRequest_builder) Build

type CleanupSchemaMigrationRequest

type CleanupSchemaMigrationRequest struct {
	ClusterId string                              `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Request   *dev2.CleanupSchemaMigrationRequest `protobuf:"bytes,2,opt,name=request,proto3" json:"request,omitempty"`
	// contains filtered or unexported fields
}

func (*CleanupSchemaMigrationRequest) ClearRequest

func (x *CleanupSchemaMigrationRequest) ClearRequest()

func (*CleanupSchemaMigrationRequest) GetClusterId

func (x *CleanupSchemaMigrationRequest) GetClusterId() string

func (*CleanupSchemaMigrationRequest) GetRequest

func (*CleanupSchemaMigrationRequest) HasRequest

func (x *CleanupSchemaMigrationRequest) HasRequest() bool

func (*CleanupSchemaMigrationRequest) ProtoMessage

func (*CleanupSchemaMigrationRequest) ProtoMessage()

func (*CleanupSchemaMigrationRequest) ProtoReflect

func (*CleanupSchemaMigrationRequest) Reset

func (x *CleanupSchemaMigrationRequest) Reset()

func (*CleanupSchemaMigrationRequest) SetClusterId

func (x *CleanupSchemaMigrationRequest) SetClusterId(v string)

func (*CleanupSchemaMigrationRequest) SetRequest

func (*CleanupSchemaMigrationRequest) String

type CleanupSchemaMigrationRequest_builder

type CleanupSchemaMigrationRequest_builder struct {
	ClusterId string
	Request   *dev2.CleanupSchemaMigrationRequest
	// contains filtered or unexported fields
}

func (CleanupSchemaMigrationRequest_builder) Build

type Cluster

type Cluster struct {
	Id   string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Cluster represents information about a Vitess cluster.

func (*Cluster) GetId

func (x *Cluster) GetId() string

func (*Cluster) GetName

func (x *Cluster) GetName() string

func (*Cluster) ProtoMessage

func (*Cluster) ProtoMessage()

func (*Cluster) ProtoReflect

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

func (*Cluster) Reset

func (x *Cluster) Reset()

func (*Cluster) SetId

func (x *Cluster) SetId(v string)

func (*Cluster) SetName

func (x *Cluster) SetName(v string)

func (*Cluster) String

func (x *Cluster) String() string

type ClusterBackup

type ClusterBackup struct {
	Cluster *Cluster        `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	Backup  *dev.BackupInfo `protobuf:"bytes,2,opt,name=backup,proto3" json:"backup,omitempty"`
	// contains filtered or unexported fields
}

func (*ClusterBackup) ClearBackup

func (x *ClusterBackup) ClearBackup()

func (*ClusterBackup) ClearCluster

func (x *ClusterBackup) ClearCluster()

func (*ClusterBackup) GetBackup

func (x *ClusterBackup) GetBackup() *dev.BackupInfo

func (*ClusterBackup) GetCluster

func (x *ClusterBackup) GetCluster() *Cluster

func (*ClusterBackup) HasBackup

func (x *ClusterBackup) HasBackup() bool

func (*ClusterBackup) HasCluster

func (x *ClusterBackup) HasCluster() bool

func (*ClusterBackup) ProtoMessage

func (*ClusterBackup) ProtoMessage()

func (*ClusterBackup) ProtoReflect

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

func (*ClusterBackup) Reset

func (x *ClusterBackup) Reset()

func (*ClusterBackup) SetBackup

func (x *ClusterBackup) SetBackup(v *dev.BackupInfo)

func (*ClusterBackup) SetCluster

func (x *ClusterBackup) SetCluster(v *Cluster)

func (*ClusterBackup) String

func (x *ClusterBackup) String() string

type ClusterBackup_builder

type ClusterBackup_builder struct {
	Cluster *Cluster
	Backup  *dev.BackupInfo
	// contains filtered or unexported fields
}

func (ClusterBackup_builder) Build

type ClusterCellInfo

type ClusterCellInfo struct {
	Cluster *Cluster `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	Name    string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// CellInfo contains the data for the cell.
	//
	// It may be nil if the GetCellsInfosRequest specified NamesOnly.
	CellInfo *dev1.CellInfo `protobuf:"bytes,3,opt,name=cell_info,json=cellInfo,proto3" json:"cell_info,omitempty"`
	// contains filtered or unexported fields
}

func (*ClusterCellInfo) ClearCellInfo

func (x *ClusterCellInfo) ClearCellInfo()

func (*ClusterCellInfo) ClearCluster

func (x *ClusterCellInfo) ClearCluster()

func (*ClusterCellInfo) GetCellInfo

func (x *ClusterCellInfo) GetCellInfo() *dev1.CellInfo

func (*ClusterCellInfo) GetCluster

func (x *ClusterCellInfo) GetCluster() *Cluster

func (*ClusterCellInfo) GetName

func (x *ClusterCellInfo) GetName() string

func (*ClusterCellInfo) HasCellInfo

func (x *ClusterCellInfo) HasCellInfo() bool

func (*ClusterCellInfo) HasCluster

func (x *ClusterCellInfo) HasCluster() bool

func (*ClusterCellInfo) ProtoMessage

func (*ClusterCellInfo) ProtoMessage()

func (*ClusterCellInfo) ProtoReflect

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

func (*ClusterCellInfo) Reset

func (x *ClusterCellInfo) Reset()

func (*ClusterCellInfo) SetCellInfo

func (x *ClusterCellInfo) SetCellInfo(v *dev1.CellInfo)

func (*ClusterCellInfo) SetCluster

func (x *ClusterCellInfo) SetCluster(v *Cluster)

func (*ClusterCellInfo) SetName

func (x *ClusterCellInfo) SetName(v string)

func (*ClusterCellInfo) String

func (x *ClusterCellInfo) String() string

type ClusterCellInfo_builder

type ClusterCellInfo_builder struct {
	Cluster *Cluster
	Name    string
	// CellInfo contains the data for the cell.
	//
	// It may be nil if the GetCellsInfosRequest specified NamesOnly.
	CellInfo *dev1.CellInfo
	// contains filtered or unexported fields
}

func (ClusterCellInfo_builder) Build

type ClusterCellsAliases

type ClusterCellsAliases struct {
	Cluster *Cluster                    `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	Aliases map[string]*dev1.CellsAlias `` /* 141-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ClusterCellsAliases) ClearCluster

func (x *ClusterCellsAliases) ClearCluster()

func (*ClusterCellsAliases) GetAliases

func (x *ClusterCellsAliases) GetAliases() map[string]*dev1.CellsAlias

func (*ClusterCellsAliases) GetCluster

func (x *ClusterCellsAliases) GetCluster() *Cluster

func (*ClusterCellsAliases) HasCluster

func (x *ClusterCellsAliases) HasCluster() bool

func (*ClusterCellsAliases) ProtoMessage

func (*ClusterCellsAliases) ProtoMessage()

func (*ClusterCellsAliases) ProtoReflect

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

func (*ClusterCellsAliases) Reset

func (x *ClusterCellsAliases) Reset()

func (*ClusterCellsAliases) SetAliases

func (x *ClusterCellsAliases) SetAliases(v map[string]*dev1.CellsAlias)

func (*ClusterCellsAliases) SetCluster

func (x *ClusterCellsAliases) SetCluster(v *Cluster)

func (*ClusterCellsAliases) String

func (x *ClusterCellsAliases) String() string

type ClusterCellsAliases_builder

type ClusterCellsAliases_builder struct {
	Cluster *Cluster
	Aliases map[string]*dev1.CellsAlias
	// contains filtered or unexported fields
}

func (ClusterCellsAliases_builder) Build

type ClusterShardReplicationPosition

type ClusterShardReplicationPosition struct {
	Cluster      *Cluster                                `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	Keyspace     string                                  `protobuf:"bytes,2,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	Shard        string                                  `protobuf:"bytes,3,opt,name=shard,proto3" json:"shard,omitempty"`
	PositionInfo *dev2.ShardReplicationPositionsResponse `protobuf:"bytes,4,opt,name=position_info,json=positionInfo,proto3" json:"position_info,omitempty"`
	// contains filtered or unexported fields
}

func (*ClusterShardReplicationPosition) ClearCluster

func (x *ClusterShardReplicationPosition) ClearCluster()

func (*ClusterShardReplicationPosition) ClearPositionInfo

func (x *ClusterShardReplicationPosition) ClearPositionInfo()

func (*ClusterShardReplicationPosition) GetCluster

func (x *ClusterShardReplicationPosition) GetCluster() *Cluster

func (*ClusterShardReplicationPosition) GetKeyspace

func (x *ClusterShardReplicationPosition) GetKeyspace() string

func (*ClusterShardReplicationPosition) GetPositionInfo

func (*ClusterShardReplicationPosition) GetShard

func (*ClusterShardReplicationPosition) HasCluster

func (x *ClusterShardReplicationPosition) HasCluster() bool

func (*ClusterShardReplicationPosition) HasPositionInfo

func (x *ClusterShardReplicationPosition) HasPositionInfo() bool

func (*ClusterShardReplicationPosition) ProtoMessage

func (*ClusterShardReplicationPosition) ProtoMessage()

func (*ClusterShardReplicationPosition) ProtoReflect

func (*ClusterShardReplicationPosition) Reset

func (*ClusterShardReplicationPosition) SetCluster

func (x *ClusterShardReplicationPosition) SetCluster(v *Cluster)

func (*ClusterShardReplicationPosition) SetKeyspace

func (x *ClusterShardReplicationPosition) SetKeyspace(v string)

func (*ClusterShardReplicationPosition) SetPositionInfo

func (*ClusterShardReplicationPosition) SetShard

func (x *ClusterShardReplicationPosition) SetShard(v string)

func (*ClusterShardReplicationPosition) String

type ClusterShardReplicationPosition_builder

type ClusterShardReplicationPosition_builder struct {
	Cluster      *Cluster
	Keyspace     string
	Shard        string
	PositionInfo *dev2.ShardReplicationPositionsResponse
	// contains filtered or unexported fields
}

func (ClusterShardReplicationPosition_builder) Build

type ClusterWorkflows

type ClusterWorkflows struct {
	Workflows []*Workflow `protobuf:"bytes,1,rep,name=workflows,proto3" json:"workflows,omitempty"`
	// Warnings is a list of non-fatal errors encountered when fetching
	// workflows for a particular cluster.
	Warnings []string `protobuf:"bytes,2,rep,name=warnings,proto3" json:"warnings,omitempty"`
	// contains filtered or unexported fields
}

func (*ClusterWorkflows) GetWarnings

func (x *ClusterWorkflows) GetWarnings() []string

func (*ClusterWorkflows) GetWorkflows

func (x *ClusterWorkflows) GetWorkflows() []*Workflow

func (*ClusterWorkflows) ProtoMessage

func (*ClusterWorkflows) ProtoMessage()

func (*ClusterWorkflows) ProtoReflect

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

func (*ClusterWorkflows) Reset

func (x *ClusterWorkflows) Reset()

func (*ClusterWorkflows) SetWarnings

func (x *ClusterWorkflows) SetWarnings(v []string)

func (*ClusterWorkflows) SetWorkflows

func (x *ClusterWorkflows) SetWorkflows(v []*Workflow)

func (*ClusterWorkflows) String

func (x *ClusterWorkflows) String() string

type ClusterWorkflows_builder

type ClusterWorkflows_builder struct {
	Workflows []*Workflow
	// Warnings is a list of non-fatal errors encountered when fetching
	// workflows for a particular cluster.
	Warnings []string
	// contains filtered or unexported fields
}

func (ClusterWorkflows_builder) Build

type Cluster_builder

type Cluster_builder struct {
	Id   string
	Name string
	// contains filtered or unexported fields
}

func (Cluster_builder) Build

func (b0 Cluster_builder) Build() *Cluster

type CompleteSchemaMigrationRequest

type CompleteSchemaMigrationRequest struct {
	ClusterId string                               `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Request   *dev2.CompleteSchemaMigrationRequest `protobuf:"bytes,2,opt,name=request,proto3" json:"request,omitempty"`
	// contains filtered or unexported fields
}

func (*CompleteSchemaMigrationRequest) ClearRequest

func (x *CompleteSchemaMigrationRequest) ClearRequest()

func (*CompleteSchemaMigrationRequest) GetClusterId

func (x *CompleteSchemaMigrationRequest) GetClusterId() string

func (*CompleteSchemaMigrationRequest) GetRequest

func (*CompleteSchemaMigrationRequest) HasRequest

func (x *CompleteSchemaMigrationRequest) HasRequest() bool

func (*CompleteSchemaMigrationRequest) ProtoMessage

func (*CompleteSchemaMigrationRequest) ProtoMessage()

func (*CompleteSchemaMigrationRequest) ProtoReflect

func (*CompleteSchemaMigrationRequest) Reset

func (x *CompleteSchemaMigrationRequest) Reset()

func (*CompleteSchemaMigrationRequest) SetClusterId

func (x *CompleteSchemaMigrationRequest) SetClusterId(v string)

func (*CompleteSchemaMigrationRequest) SetRequest

func (*CompleteSchemaMigrationRequest) String

type CompleteSchemaMigrationRequest_builder

type CompleteSchemaMigrationRequest_builder struct {
	ClusterId string
	Request   *dev2.CompleteSchemaMigrationRequest
	// contains filtered or unexported fields
}

func (CompleteSchemaMigrationRequest_builder) Build

type ConcludeTransactionRequest

type ConcludeTransactionRequest struct {
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Dtid      string `protobuf:"bytes,2,opt,name=dtid,proto3" json:"dtid,omitempty"`
	// contains filtered or unexported fields
}

func (*ConcludeTransactionRequest) GetClusterId

func (x *ConcludeTransactionRequest) GetClusterId() string

func (*ConcludeTransactionRequest) GetDtid

func (x *ConcludeTransactionRequest) GetDtid() string

func (*ConcludeTransactionRequest) ProtoMessage

func (*ConcludeTransactionRequest) ProtoMessage()

func (*ConcludeTransactionRequest) ProtoReflect

func (*ConcludeTransactionRequest) Reset

func (x *ConcludeTransactionRequest) Reset()

func (*ConcludeTransactionRequest) SetClusterId

func (x *ConcludeTransactionRequest) SetClusterId(v string)

func (*ConcludeTransactionRequest) SetDtid

func (x *ConcludeTransactionRequest) SetDtid(v string)

func (*ConcludeTransactionRequest) String

func (x *ConcludeTransactionRequest) String() string

type ConcludeTransactionRequest_builder

type ConcludeTransactionRequest_builder struct {
	ClusterId string
	Dtid      string
	// contains filtered or unexported fields
}

func (ConcludeTransactionRequest_builder) Build

type CreateKeyspaceRequest

type CreateKeyspaceRequest struct {
	ClusterId string                      `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Options   *dev2.CreateKeyspaceRequest `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateKeyspaceRequest) ClearOptions

func (x *CreateKeyspaceRequest) ClearOptions()

func (*CreateKeyspaceRequest) GetClusterId

func (x *CreateKeyspaceRequest) GetClusterId() string

func (*CreateKeyspaceRequest) GetOptions

func (*CreateKeyspaceRequest) HasOptions

func (x *CreateKeyspaceRequest) HasOptions() bool

func (*CreateKeyspaceRequest) ProtoMessage

func (*CreateKeyspaceRequest) ProtoMessage()

func (*CreateKeyspaceRequest) ProtoReflect

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

func (*CreateKeyspaceRequest) Reset

func (x *CreateKeyspaceRequest) Reset()

func (*CreateKeyspaceRequest) SetClusterId

func (x *CreateKeyspaceRequest) SetClusterId(v string)

func (*CreateKeyspaceRequest) SetOptions

func (*CreateKeyspaceRequest) String

func (x *CreateKeyspaceRequest) String() string

type CreateKeyspaceRequest_builder

type CreateKeyspaceRequest_builder struct {
	ClusterId string
	Options   *dev2.CreateKeyspaceRequest
	// contains filtered or unexported fields
}

func (CreateKeyspaceRequest_builder) Build

type CreateKeyspaceResponse

type CreateKeyspaceResponse struct {
	Keyspace *Keyspace `protobuf:"bytes,1,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateKeyspaceResponse) ClearKeyspace

func (x *CreateKeyspaceResponse) ClearKeyspace()

func (*CreateKeyspaceResponse) GetKeyspace

func (x *CreateKeyspaceResponse) GetKeyspace() *Keyspace

func (*CreateKeyspaceResponse) HasKeyspace

func (x *CreateKeyspaceResponse) HasKeyspace() bool

func (*CreateKeyspaceResponse) ProtoMessage

func (*CreateKeyspaceResponse) ProtoMessage()

func (*CreateKeyspaceResponse) ProtoReflect

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

func (*CreateKeyspaceResponse) Reset

func (x *CreateKeyspaceResponse) Reset()

func (*CreateKeyspaceResponse) SetKeyspace

func (x *CreateKeyspaceResponse) SetKeyspace(v *Keyspace)

func (*CreateKeyspaceResponse) String

func (x *CreateKeyspaceResponse) String() string

type CreateKeyspaceResponse_builder

type CreateKeyspaceResponse_builder struct {
	Keyspace *Keyspace
	// contains filtered or unexported fields
}

func (CreateKeyspaceResponse_builder) Build

type CreateShardRequest

type CreateShardRequest struct {
	ClusterId string                   `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Options   *dev2.CreateShardRequest `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateShardRequest) ClearOptions

func (x *CreateShardRequest) ClearOptions()

func (*CreateShardRequest) GetClusterId

func (x *CreateShardRequest) GetClusterId() string

func (*CreateShardRequest) GetOptions

func (x *CreateShardRequest) GetOptions() *dev2.CreateShardRequest

func (*CreateShardRequest) HasOptions

func (x *CreateShardRequest) HasOptions() bool

func (*CreateShardRequest) ProtoMessage

func (*CreateShardRequest) ProtoMessage()

func (*CreateShardRequest) ProtoReflect

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

func (*CreateShardRequest) Reset

func (x *CreateShardRequest) Reset()

func (*CreateShardRequest) SetClusterId

func (x *CreateShardRequest) SetClusterId(v string)

func (*CreateShardRequest) SetOptions

func (x *CreateShardRequest) SetOptions(v *dev2.CreateShardRequest)

func (*CreateShardRequest) String

func (x *CreateShardRequest) String() string

type CreateShardRequest_builder

type CreateShardRequest_builder struct {
	ClusterId string
	Options   *dev2.CreateShardRequest
	// contains filtered or unexported fields
}

func (CreateShardRequest_builder) Build

type DeleteKeyspaceRequest

type DeleteKeyspaceRequest struct {
	ClusterId string                      `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Options   *dev2.DeleteKeyspaceRequest `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteKeyspaceRequest) ClearOptions

func (x *DeleteKeyspaceRequest) ClearOptions()

func (*DeleteKeyspaceRequest) GetClusterId

func (x *DeleteKeyspaceRequest) GetClusterId() string

func (*DeleteKeyspaceRequest) GetOptions

func (*DeleteKeyspaceRequest) HasOptions

func (x *DeleteKeyspaceRequest) HasOptions() bool

func (*DeleteKeyspaceRequest) ProtoMessage

func (*DeleteKeyspaceRequest) ProtoMessage()

func (*DeleteKeyspaceRequest) ProtoReflect

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

func (*DeleteKeyspaceRequest) Reset

func (x *DeleteKeyspaceRequest) Reset()

func (*DeleteKeyspaceRequest) SetClusterId

func (x *DeleteKeyspaceRequest) SetClusterId(v string)

func (*DeleteKeyspaceRequest) SetOptions

func (*DeleteKeyspaceRequest) String

func (x *DeleteKeyspaceRequest) String() string

type DeleteKeyspaceRequest_builder

type DeleteKeyspaceRequest_builder struct {
	ClusterId string
	Options   *dev2.DeleteKeyspaceRequest
	// contains filtered or unexported fields
}

func (DeleteKeyspaceRequest_builder) Build

type DeleteShardsRequest

type DeleteShardsRequest struct {
	ClusterId string                    `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Options   *dev2.DeleteShardsRequest `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteShardsRequest) ClearOptions

func (x *DeleteShardsRequest) ClearOptions()

func (*DeleteShardsRequest) GetClusterId

func (x *DeleteShardsRequest) GetClusterId() string

func (*DeleteShardsRequest) GetOptions

func (x *DeleteShardsRequest) GetOptions() *dev2.DeleteShardsRequest

func (*DeleteShardsRequest) HasOptions

func (x *DeleteShardsRequest) HasOptions() bool

func (*DeleteShardsRequest) ProtoMessage

func (*DeleteShardsRequest) ProtoMessage()

func (*DeleteShardsRequest) ProtoReflect

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

func (*DeleteShardsRequest) Reset

func (x *DeleteShardsRequest) Reset()

func (*DeleteShardsRequest) SetClusterId

func (x *DeleteShardsRequest) SetClusterId(v string)

func (*DeleteShardsRequest) SetOptions

func (x *DeleteShardsRequest) SetOptions(v *dev2.DeleteShardsRequest)

func (*DeleteShardsRequest) String

func (x *DeleteShardsRequest) String() string

type DeleteShardsRequest_builder

type DeleteShardsRequest_builder struct {
	ClusterId string
	Options   *dev2.DeleteShardsRequest
	// contains filtered or unexported fields
}

func (DeleteShardsRequest_builder) Build

type DeleteTabletRequest

type DeleteTabletRequest struct {
	Alias        *dev1.TabletAlias `protobuf:"bytes,1,opt,name=alias,proto3" json:"alias,omitempty"`
	ClusterIds   []string          `protobuf:"bytes,2,rep,name=cluster_ids,json=clusterIds,proto3" json:"cluster_ids,omitempty"`
	AllowPrimary bool              `protobuf:"varint,3,opt,name=allow_primary,json=allowPrimary,proto3" json:"allow_primary,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteTabletRequest) ClearAlias

func (x *DeleteTabletRequest) ClearAlias()

func (*DeleteTabletRequest) GetAlias

func (x *DeleteTabletRequest) GetAlias() *dev1.TabletAlias

func (*DeleteTabletRequest) GetAllowPrimary

func (x *DeleteTabletRequest) GetAllowPrimary() bool

func (*DeleteTabletRequest) GetClusterIds

func (x *DeleteTabletRequest) GetClusterIds() []string

func (*DeleteTabletRequest) HasAlias

func (x *DeleteTabletRequest) HasAlias() bool

func (*DeleteTabletRequest) ProtoMessage

func (*DeleteTabletRequest) ProtoMessage()

func (*DeleteTabletRequest) ProtoReflect

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

func (*DeleteTabletRequest) Reset

func (x *DeleteTabletRequest) Reset()

func (*DeleteTabletRequest) SetAlias

func (x *DeleteTabletRequest) SetAlias(v *dev1.TabletAlias)

func (*DeleteTabletRequest) SetAllowPrimary

func (x *DeleteTabletRequest) SetAllowPrimary(v bool)

func (*DeleteTabletRequest) SetClusterIds

func (x *DeleteTabletRequest) SetClusterIds(v []string)

func (*DeleteTabletRequest) String

func (x *DeleteTabletRequest) String() string

type DeleteTabletRequest_builder

type DeleteTabletRequest_builder struct {
	Alias        *dev1.TabletAlias
	ClusterIds   []string
	AllowPrimary bool
	// contains filtered or unexported fields
}

func (DeleteTabletRequest_builder) Build

type DeleteTabletResponse

type DeleteTabletResponse struct {
	Status  string   `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Cluster *Cluster `protobuf:"bytes,2,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteTabletResponse) ClearCluster

func (x *DeleteTabletResponse) ClearCluster()

func (*DeleteTabletResponse) GetCluster

func (x *DeleteTabletResponse) GetCluster() *Cluster

func (*DeleteTabletResponse) GetStatus

func (x *DeleteTabletResponse) GetStatus() string

func (*DeleteTabletResponse) HasCluster

func (x *DeleteTabletResponse) HasCluster() bool

func (*DeleteTabletResponse) ProtoMessage

func (*DeleteTabletResponse) ProtoMessage()

func (*DeleteTabletResponse) ProtoReflect

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

func (*DeleteTabletResponse) Reset

func (x *DeleteTabletResponse) Reset()

func (*DeleteTabletResponse) SetCluster

func (x *DeleteTabletResponse) SetCluster(v *Cluster)

func (*DeleteTabletResponse) SetStatus

func (x *DeleteTabletResponse) SetStatus(v string)

func (*DeleteTabletResponse) String

func (x *DeleteTabletResponse) String() string

type DeleteTabletResponse_builder

type DeleteTabletResponse_builder struct {
	Status  string
	Cluster *Cluster
	// contains filtered or unexported fields
}

func (DeleteTabletResponse_builder) Build

type EmergencyFailoverShardRequest

type EmergencyFailoverShardRequest struct {
	ClusterId string                              `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Options   *dev2.EmergencyReparentShardRequest `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*EmergencyFailoverShardRequest) ClearOptions

func (x *EmergencyFailoverShardRequest) ClearOptions()

func (*EmergencyFailoverShardRequest) GetClusterId

func (x *EmergencyFailoverShardRequest) GetClusterId() string

func (*EmergencyFailoverShardRequest) GetOptions

func (*EmergencyFailoverShardRequest) HasOptions

func (x *EmergencyFailoverShardRequest) HasOptions() bool

func (*EmergencyFailoverShardRequest) ProtoMessage

func (*EmergencyFailoverShardRequest) ProtoMessage()

func (*EmergencyFailoverShardRequest) ProtoReflect

func (*EmergencyFailoverShardRequest) Reset

func (x *EmergencyFailoverShardRequest) Reset()

func (*EmergencyFailoverShardRequest) SetClusterId

func (x *EmergencyFailoverShardRequest) SetClusterId(v string)

func (*EmergencyFailoverShardRequest) SetOptions

func (*EmergencyFailoverShardRequest) String

type EmergencyFailoverShardRequest_builder

type EmergencyFailoverShardRequest_builder struct {
	ClusterId string
	Options   *dev2.EmergencyReparentShardRequest
	// contains filtered or unexported fields
}

func (EmergencyFailoverShardRequest_builder) Build

type EmergencyFailoverShardResponse

type EmergencyFailoverShardResponse struct {
	Cluster  *Cluster `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	Keyspace string   `protobuf:"bytes,2,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	Shard    string   `protobuf:"bytes,3,opt,name=shard,proto3" json:"shard,omitempty"`
	// PromotedPrimary is the tablet alias that was promoted to shard primary.
	// If NewPrimary was set in the request options, then this will be the
	// same tablet alias. Otherwise, it will be the alias of the tablet found
	// to be most up-to-date in the shard.
	PromotedPrimary *dev1.TabletAlias `protobuf:"bytes,4,opt,name=promoted_primary,json=promotedPrimary,proto3" json:"promoted_primary,omitempty"`
	Events          []*dev5.Event     `protobuf:"bytes,5,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

func (*EmergencyFailoverShardResponse) ClearCluster

func (x *EmergencyFailoverShardResponse) ClearCluster()

func (*EmergencyFailoverShardResponse) ClearPromotedPrimary

func (x *EmergencyFailoverShardResponse) ClearPromotedPrimary()

func (*EmergencyFailoverShardResponse) GetCluster

func (x *EmergencyFailoverShardResponse) GetCluster() *Cluster

func (*EmergencyFailoverShardResponse) GetEvents

func (x *EmergencyFailoverShardResponse) GetEvents() []*dev5.Event

func (*EmergencyFailoverShardResponse) GetKeyspace

func (x *EmergencyFailoverShardResponse) GetKeyspace() string

func (*EmergencyFailoverShardResponse) GetPromotedPrimary

func (x *EmergencyFailoverShardResponse) GetPromotedPrimary() *dev1.TabletAlias

func (*EmergencyFailoverShardResponse) GetShard

func (x *EmergencyFailoverShardResponse) GetShard() string

func (*EmergencyFailoverShardResponse) HasCluster

func (x *EmergencyFailoverShardResponse) HasCluster() bool

func (*EmergencyFailoverShardResponse) HasPromotedPrimary

func (x *EmergencyFailoverShardResponse) HasPromotedPrimary() bool

func (*EmergencyFailoverShardResponse) ProtoMessage

func (*EmergencyFailoverShardResponse) ProtoMessage()

func (*EmergencyFailoverShardResponse) ProtoReflect

func (*EmergencyFailoverShardResponse) Reset

func (x *EmergencyFailoverShardResponse) Reset()

func (*EmergencyFailoverShardResponse) SetCluster

func (x *EmergencyFailoverShardResponse) SetCluster(v *Cluster)

func (*EmergencyFailoverShardResponse) SetEvents

func (x *EmergencyFailoverShardResponse) SetEvents(v []*dev5.Event)

func (*EmergencyFailoverShardResponse) SetKeyspace

func (x *EmergencyFailoverShardResponse) SetKeyspace(v string)

func (*EmergencyFailoverShardResponse) SetPromotedPrimary

func (x *EmergencyFailoverShardResponse) SetPromotedPrimary(v *dev1.TabletAlias)

func (*EmergencyFailoverShardResponse) SetShard

func (x *EmergencyFailoverShardResponse) SetShard(v string)

func (*EmergencyFailoverShardResponse) String

type EmergencyFailoverShardResponse_builder

type EmergencyFailoverShardResponse_builder struct {
	Cluster  *Cluster
	Keyspace string
	Shard    string
	// PromotedPrimary is the tablet alias that was promoted to shard primary.
	// If NewPrimary was set in the request options, then this will be the
	// same tablet alias. Otherwise, it will be the alias of the tablet found
	// to be most up-to-date in the shard.
	PromotedPrimary *dev1.TabletAlias
	Events          []*dev5.Event
	// contains filtered or unexported fields
}

func (EmergencyFailoverShardResponse_builder) Build

type FindSchemaRequest

type FindSchemaRequest struct {
	Table            string                     `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
	ClusterIds       []string                   `protobuf:"bytes,2,rep,name=cluster_ids,json=clusterIds,proto3" json:"cluster_ids,omitempty"`
	TableSizeOptions *GetSchemaTableSizeOptions `protobuf:"bytes,3,opt,name=table_size_options,json=tableSizeOptions,proto3" json:"table_size_options,omitempty"`
	// contains filtered or unexported fields
}

func (*FindSchemaRequest) ClearTableSizeOptions

func (x *FindSchemaRequest) ClearTableSizeOptions()

func (*FindSchemaRequest) GetClusterIds

func (x *FindSchemaRequest) GetClusterIds() []string

func (*FindSchemaRequest) GetTable

func (x *FindSchemaRequest) GetTable() string

func (*FindSchemaRequest) GetTableSizeOptions

func (x *FindSchemaRequest) GetTableSizeOptions() *GetSchemaTableSizeOptions

func (*FindSchemaRequest) HasTableSizeOptions

func (x *FindSchemaRequest) HasTableSizeOptions() bool

func (*FindSchemaRequest) ProtoMessage

func (*FindSchemaRequest) ProtoMessage()

func (*FindSchemaRequest) ProtoReflect

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

func (*FindSchemaRequest) Reset

func (x *FindSchemaRequest) Reset()

func (*FindSchemaRequest) SetClusterIds

func (x *FindSchemaRequest) SetClusterIds(v []string)

func (*FindSchemaRequest) SetTable

func (x *FindSchemaRequest) SetTable(v string)

func (*FindSchemaRequest) SetTableSizeOptions

func (x *FindSchemaRequest) SetTableSizeOptions(v *GetSchemaTableSizeOptions)

func (*FindSchemaRequest) String

func (x *FindSchemaRequest) String() string

type FindSchemaRequest_builder

type FindSchemaRequest_builder struct {
	Table            string
	ClusterIds       []string
	TableSizeOptions *GetSchemaTableSizeOptions
	// contains filtered or unexported fields
}

func (FindSchemaRequest_builder) Build

type GetBackupsRequest

type GetBackupsRequest struct {
	ClusterIds []string `protobuf:"bytes,1,rep,name=cluster_ids,json=clusterIds,proto3" json:"cluster_ids,omitempty"`
	// Keyspaces, if set, limits backups to just the specified keyspaces.
	// Applies to all clusters in the request.
	Keyspaces []string `protobuf:"bytes,2,rep,name=keyspaces,proto3" json:"keyspaces,omitempty"`
	// KeyspaceShards, if set, limits backups to just the specified
	// keyspace/shards. Applies to all clusters in the request.
	//
	// This field takes precedence over Keyspaces. If KeyspaceShards is set,
	// Keyspaces is ignored.
	KeyspaceShards []string `protobuf:"bytes,3,rep,name=keyspace_shards,json=keyspaceShards,proto3" json:"keyspace_shards,omitempty"`
	// RequestOptions controls the per-shard request options when making
	// GetBackups requests to vtctlds. Note that the Keyspace and Shard fields
	// of this field are ignored; it is used only to specify Limit and Detailed
	// fields.
	RequestOptions *dev2.GetBackupsRequest `protobuf:"bytes,4,opt,name=request_options,json=requestOptions,proto3" json:"request_options,omitempty"`
	// contains filtered or unexported fields
}

func (*GetBackupsRequest) ClearRequestOptions

func (x *GetBackupsRequest) ClearRequestOptions()

func (*GetBackupsRequest) GetClusterIds

func (x *GetBackupsRequest) GetClusterIds() []string

func (*GetBackupsRequest) GetKeyspaceShards

func (x *GetBackupsRequest) GetKeyspaceShards() []string

func (*GetBackupsRequest) GetKeyspaces

func (x *GetBackupsRequest) GetKeyspaces() []string

func (*GetBackupsRequest) GetRequestOptions

func (x *GetBackupsRequest) GetRequestOptions() *dev2.GetBackupsRequest

func (*GetBackupsRequest) HasRequestOptions

func (x *GetBackupsRequest) HasRequestOptions() bool

func (*GetBackupsRequest) ProtoMessage

func (*GetBackupsRequest) ProtoMessage()

func (*GetBackupsRequest) ProtoReflect

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

func (*GetBackupsRequest) Reset

func (x *GetBackupsRequest) Reset()

func (*GetBackupsRequest) SetClusterIds

func (x *GetBackupsRequest) SetClusterIds(v []string)

func (*GetBackupsRequest) SetKeyspaceShards

func (x *GetBackupsRequest) SetKeyspaceShards(v []string)

func (*GetBackupsRequest) SetKeyspaces

func (x *GetBackupsRequest) SetKeyspaces(v []string)

func (*GetBackupsRequest) SetRequestOptions

func (x *GetBackupsRequest) SetRequestOptions(v *dev2.GetBackupsRequest)

func (*GetBackupsRequest) String

func (x *GetBackupsRequest) String() string

type GetBackupsRequest_builder

type GetBackupsRequest_builder struct {
	ClusterIds []string
	// Keyspaces, if set, limits backups to just the specified keyspaces.
	// Applies to all clusters in the request.
	Keyspaces []string
	// KeyspaceShards, if set, limits backups to just the specified
	// keyspace/shards. Applies to all clusters in the request.
	//
	// This field takes precedence over Keyspaces. If KeyspaceShards is set,
	// Keyspaces is ignored.
	KeyspaceShards []string
	// RequestOptions controls the per-shard request options when making
	// GetBackups requests to vtctlds. Note that the Keyspace and Shard fields
	// of this field are ignored; it is used only to specify Limit and Detailed
	// fields.
	RequestOptions *dev2.GetBackupsRequest
	// contains filtered or unexported fields
}

func (GetBackupsRequest_builder) Build

type GetBackupsResponse

type GetBackupsResponse struct {
	Backups []*ClusterBackup `protobuf:"bytes,1,rep,name=backups,proto3" json:"backups,omitempty"`
	// contains filtered or unexported fields
}

func (*GetBackupsResponse) GetBackups

func (x *GetBackupsResponse) GetBackups() []*ClusterBackup

func (*GetBackupsResponse) ProtoMessage

func (*GetBackupsResponse) ProtoMessage()

func (*GetBackupsResponse) ProtoReflect

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

func (*GetBackupsResponse) Reset

func (x *GetBackupsResponse) Reset()

func (*GetBackupsResponse) SetBackups

func (x *GetBackupsResponse) SetBackups(v []*ClusterBackup)

func (*GetBackupsResponse) String

func (x *GetBackupsResponse) String() string

type GetBackupsResponse_builder

type GetBackupsResponse_builder struct {
	Backups []*ClusterBackup
	// contains filtered or unexported fields
}

func (GetBackupsResponse_builder) Build

type GetCellInfosRequest

type GetCellInfosRequest struct {
	ClusterIds []string `protobuf:"bytes,1,rep,name=cluster_ids,json=clusterIds,proto3" json:"cluster_ids,omitempty"`
	// Cells, if specified, limits the response to include only CellInfo objects
	// with those names. If omitted, all CellInfo objects in each cluster are
	// returned.
	//
	// Mutually-exclusive with NamesOnly. If both are set, this field takes
	// precedence.
	Cells []string `protobuf:"bytes,2,rep,name=cells,proto3" json:"cells,omitempty"`
	// Return only the cell names in each cluster; the actual CellInfo objects
	// will be empty.
	NamesOnly bool `protobuf:"varint,3,opt,name=names_only,json=namesOnly,proto3" json:"names_only,omitempty"`
	// contains filtered or unexported fields
}

func (*GetCellInfosRequest) GetCells

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

func (*GetCellInfosRequest) GetClusterIds

func (x *GetCellInfosRequest) GetClusterIds() []string

func (*GetCellInfosRequest) GetNamesOnly

func (x *GetCellInfosRequest) GetNamesOnly() bool

func (*GetCellInfosRequest) ProtoMessage

func (*GetCellInfosRequest) ProtoMessage()

func (*GetCellInfosRequest) ProtoReflect

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

func (*GetCellInfosRequest) Reset

func (x *GetCellInfosRequest) Reset()

func (*GetCellInfosRequest) SetCells

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

func (*GetCellInfosRequest) SetClusterIds

func (x *GetCellInfosRequest) SetClusterIds(v []string)

func (*GetCellInfosRequest) SetNamesOnly

func (x *GetCellInfosRequest) SetNamesOnly(v bool)

func (*GetCellInfosRequest) String

func (x *GetCellInfosRequest) String() string

type GetCellInfosRequest_builder

type GetCellInfosRequest_builder struct {
	ClusterIds []string
	// Cells, if specified, limits the response to include only CellInfo objects
	// with those names. If omitted, all CellInfo objects in each cluster are
	// returned.
	//
	// Mutually-exclusive with NamesOnly. If both are set, this field takes
	// precedence.
	Cells []string
	// Return only the cell names in each cluster; the actual CellInfo objects
	// will be empty.
	NamesOnly bool
	// contains filtered or unexported fields
}

func (GetCellInfosRequest_builder) Build

type GetCellInfosResponse

type GetCellInfosResponse struct {
	CellInfos []*ClusterCellInfo `protobuf:"bytes,1,rep,name=cell_infos,json=cellInfos,proto3" json:"cell_infos,omitempty"`
	// contains filtered or unexported fields
}

func (*GetCellInfosResponse) GetCellInfos

func (x *GetCellInfosResponse) GetCellInfos() []*ClusterCellInfo

func (*GetCellInfosResponse) ProtoMessage

func (*GetCellInfosResponse) ProtoMessage()

func (*GetCellInfosResponse) ProtoReflect

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

func (*GetCellInfosResponse) Reset

func (x *GetCellInfosResponse) Reset()

func (*GetCellInfosResponse) SetCellInfos

func (x *GetCellInfosResponse) SetCellInfos(v []*ClusterCellInfo)

func (*GetCellInfosResponse) String

func (x *GetCellInfosResponse) String() string

type GetCellInfosResponse_builder

type GetCellInfosResponse_builder struct {
	CellInfos []*ClusterCellInfo
	// contains filtered or unexported fields
}

func (GetCellInfosResponse_builder) Build

type GetCellsAliasesRequest

type GetCellsAliasesRequest struct {
	ClusterIds []string `protobuf:"bytes,1,rep,name=cluster_ids,json=clusterIds,proto3" json:"cluster_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*GetCellsAliasesRequest) GetClusterIds

func (x *GetCellsAliasesRequest) GetClusterIds() []string

func (*GetCellsAliasesRequest) ProtoMessage

func (*GetCellsAliasesRequest) ProtoMessage()

func (*GetCellsAliasesRequest) ProtoReflect

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

func (*GetCellsAliasesRequest) Reset

func (x *GetCellsAliasesRequest) Reset()

func (*GetCellsAliasesRequest) SetClusterIds

func (x *GetCellsAliasesRequest) SetClusterIds(v []string)

func (*GetCellsAliasesRequest) String

func (x *GetCellsAliasesRequest) String() string

type GetCellsAliasesRequest_builder

type GetCellsAliasesRequest_builder struct {
	ClusterIds []string
	// contains filtered or unexported fields
}

func (GetCellsAliasesRequest_builder) Build

type GetCellsAliasesResponse

type GetCellsAliasesResponse struct {
	Aliases []*ClusterCellsAliases `protobuf:"bytes,1,rep,name=aliases,proto3" json:"aliases,omitempty"`
	// contains filtered or unexported fields
}

func (*GetCellsAliasesResponse) GetAliases

func (x *GetCellsAliasesResponse) GetAliases() []*ClusterCellsAliases

func (*GetCellsAliasesResponse) ProtoMessage

func (*GetCellsAliasesResponse) ProtoMessage()

func (*GetCellsAliasesResponse) ProtoReflect

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

func (*GetCellsAliasesResponse) Reset

func (x *GetCellsAliasesResponse) Reset()

func (*GetCellsAliasesResponse) SetAliases

func (x *GetCellsAliasesResponse) SetAliases(v []*ClusterCellsAliases)

func (*GetCellsAliasesResponse) String

func (x *GetCellsAliasesResponse) String() string

type GetCellsAliasesResponse_builder

type GetCellsAliasesResponse_builder struct {
	Aliases []*ClusterCellsAliases
	// contains filtered or unexported fields
}

func (GetCellsAliasesResponse_builder) Build

type GetClustersRequest

type GetClustersRequest struct {
	// contains filtered or unexported fields
}

func (*GetClustersRequest) ProtoMessage

func (*GetClustersRequest) ProtoMessage()

func (*GetClustersRequest) ProtoReflect

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

func (*GetClustersRequest) Reset

func (x *GetClustersRequest) Reset()

func (*GetClustersRequest) String

func (x *GetClustersRequest) String() string

type GetClustersRequest_builder

type GetClustersRequest_builder struct {
	// contains filtered or unexported fields
}

func (GetClustersRequest_builder) Build

type GetClustersResponse

type GetClustersResponse struct {
	Clusters []*Cluster `protobuf:"bytes,1,rep,name=clusters,proto3" json:"clusters,omitempty"`
	// contains filtered or unexported fields
}

func (*GetClustersResponse) GetClusters

func (x *GetClustersResponse) GetClusters() []*Cluster

func (*GetClustersResponse) ProtoMessage

func (*GetClustersResponse) ProtoMessage()

func (*GetClustersResponse) ProtoReflect

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

func (*GetClustersResponse) Reset

func (x *GetClustersResponse) Reset()

func (*GetClustersResponse) SetClusters

func (x *GetClustersResponse) SetClusters(v []*Cluster)

func (*GetClustersResponse) String

func (x *GetClustersResponse) String() string

type GetClustersResponse_builder

type GetClustersResponse_builder struct {
	Clusters []*Cluster
	// contains filtered or unexported fields
}

func (GetClustersResponse_builder) Build

type GetFullStatusRequest

type GetFullStatusRequest struct {
	ClusterId string            `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Alias     *dev1.TabletAlias `protobuf:"bytes,2,opt,name=alias,proto3" json:"alias,omitempty"`
	// contains filtered or unexported fields
}

func (*GetFullStatusRequest) ClearAlias

func (x *GetFullStatusRequest) ClearAlias()

func (*GetFullStatusRequest) GetAlias

func (x *GetFullStatusRequest) GetAlias() *dev1.TabletAlias

func (*GetFullStatusRequest) GetClusterId

func (x *GetFullStatusRequest) GetClusterId() string

func (*GetFullStatusRequest) HasAlias

func (x *GetFullStatusRequest) HasAlias() bool

func (*GetFullStatusRequest) ProtoMessage

func (*GetFullStatusRequest) ProtoMessage()

func (*GetFullStatusRequest) ProtoReflect

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

func (*GetFullStatusRequest) Reset

func (x *GetFullStatusRequest) Reset()

func (*GetFullStatusRequest) SetAlias

func (x *GetFullStatusRequest) SetAlias(v *dev1.TabletAlias)

func (*GetFullStatusRequest) SetClusterId

func (x *GetFullStatusRequest) SetClusterId(v string)

func (*GetFullStatusRequest) String

func (x *GetFullStatusRequest) String() string

type GetFullStatusRequest_builder

type GetFullStatusRequest_builder struct {
	ClusterId string
	Alias     *dev1.TabletAlias
	// contains filtered or unexported fields
}

func (GetFullStatusRequest_builder) Build

type GetGatesRequest

type GetGatesRequest struct {
	ClusterIds []string `protobuf:"bytes,1,rep,name=cluster_ids,json=clusterIds,proto3" json:"cluster_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*GetGatesRequest) GetClusterIds

func (x *GetGatesRequest) GetClusterIds() []string

func (*GetGatesRequest) ProtoMessage

func (*GetGatesRequest) ProtoMessage()

func (*GetGatesRequest) ProtoReflect

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

func (*GetGatesRequest) Reset

func (x *GetGatesRequest) Reset()

func (*GetGatesRequest) SetClusterIds

func (x *GetGatesRequest) SetClusterIds(v []string)

func (*GetGatesRequest) String

func (x *GetGatesRequest) String() string

type GetGatesRequest_builder

type GetGatesRequest_builder struct {
	ClusterIds []string
	// contains filtered or unexported fields
}

func (GetGatesRequest_builder) Build

type GetGatesResponse

type GetGatesResponse struct {
	Gates []*VTGate `protobuf:"bytes,1,rep,name=gates,proto3" json:"gates,omitempty"`
	// contains filtered or unexported fields
}

func (*GetGatesResponse) GetGates

func (x *GetGatesResponse) GetGates() []*VTGate

func (*GetGatesResponse) ProtoMessage

func (*GetGatesResponse) ProtoMessage()

func (*GetGatesResponse) ProtoReflect

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

func (*GetGatesResponse) Reset

func (x *GetGatesResponse) Reset()

func (*GetGatesResponse) SetGates

func (x *GetGatesResponse) SetGates(v []*VTGate)

func (*GetGatesResponse) String

func (x *GetGatesResponse) String() string

type GetGatesResponse_builder

type GetGatesResponse_builder struct {
	Gates []*VTGate
	// contains filtered or unexported fields
}

func (GetGatesResponse_builder) Build

type GetKeyspaceRequest

type GetKeyspaceRequest struct {
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Keyspace  string `protobuf:"bytes,2,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	// contains filtered or unexported fields
}

func (*GetKeyspaceRequest) GetClusterId

func (x *GetKeyspaceRequest) GetClusterId() string

func (*GetKeyspaceRequest) GetKeyspace

func (x *GetKeyspaceRequest) GetKeyspace() string

func (*GetKeyspaceRequest) ProtoMessage

func (*GetKeyspaceRequest) ProtoMessage()

func (*GetKeyspaceRequest) ProtoReflect

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

func (*GetKeyspaceRequest) Reset

func (x *GetKeyspaceRequest) Reset()

func (*GetKeyspaceRequest) SetClusterId

func (x *GetKeyspaceRequest) SetClusterId(v string)

func (*GetKeyspaceRequest) SetKeyspace

func (x *GetKeyspaceRequest) SetKeyspace(v string)

func (*GetKeyspaceRequest) String

func (x *GetKeyspaceRequest) String() string

type GetKeyspaceRequest_builder

type GetKeyspaceRequest_builder struct {
	ClusterId string
	Keyspace  string
	// contains filtered or unexported fields
}

func (GetKeyspaceRequest_builder) Build

type GetKeyspacesRequest

type GetKeyspacesRequest struct {
	ClusterIds []string `protobuf:"bytes,1,rep,name=cluster_ids,json=clusterIds,proto3" json:"cluster_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*GetKeyspacesRequest) GetClusterIds

func (x *GetKeyspacesRequest) GetClusterIds() []string

func (*GetKeyspacesRequest) ProtoMessage

func (*GetKeyspacesRequest) ProtoMessage()

func (*GetKeyspacesRequest) ProtoReflect

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

func (*GetKeyspacesRequest) Reset

func (x *GetKeyspacesRequest) Reset()

func (*GetKeyspacesRequest) SetClusterIds

func (x *GetKeyspacesRequest) SetClusterIds(v []string)

func (*GetKeyspacesRequest) String

func (x *GetKeyspacesRequest) String() string

type GetKeyspacesRequest_builder

type GetKeyspacesRequest_builder struct {
	ClusterIds []string
	// contains filtered or unexported fields
}

func (GetKeyspacesRequest_builder) Build

type GetKeyspacesResponse

type GetKeyspacesResponse struct {
	Keyspaces []*Keyspace `protobuf:"bytes,1,rep,name=keyspaces,proto3" json:"keyspaces,omitempty"`
	// contains filtered or unexported fields
}

func (*GetKeyspacesResponse) GetKeyspaces

func (x *GetKeyspacesResponse) GetKeyspaces() []*Keyspace

func (*GetKeyspacesResponse) ProtoMessage

func (*GetKeyspacesResponse) ProtoMessage()

func (*GetKeyspacesResponse) ProtoReflect

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

func (*GetKeyspacesResponse) Reset

func (x *GetKeyspacesResponse) Reset()

func (*GetKeyspacesResponse) SetKeyspaces

func (x *GetKeyspacesResponse) SetKeyspaces(v []*Keyspace)

func (*GetKeyspacesResponse) String

func (x *GetKeyspacesResponse) String() string

type GetKeyspacesResponse_builder

type GetKeyspacesResponse_builder struct {
	Keyspaces []*Keyspace
	// contains filtered or unexported fields
}

func (GetKeyspacesResponse_builder) Build

type GetSchemaMigrationsRequest

type GetSchemaMigrationsRequest struct {
	ClusterRequests []*GetSchemaMigrationsRequest_ClusterRequest `protobuf:"bytes,1,rep,name=cluster_requests,json=clusterRequests,proto3" json:"cluster_requests,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSchemaMigrationsRequest) GetClusterRequests

func (*GetSchemaMigrationsRequest) ProtoMessage

func (*GetSchemaMigrationsRequest) ProtoMessage()

func (*GetSchemaMigrationsRequest) ProtoReflect

func (*GetSchemaMigrationsRequest) Reset

func (x *GetSchemaMigrationsRequest) Reset()

func (*GetSchemaMigrationsRequest) SetClusterRequests

func (*GetSchemaMigrationsRequest) String

func (x *GetSchemaMigrationsRequest) String() string

type GetSchemaMigrationsRequest_ClusterRequest

type GetSchemaMigrationsRequest_ClusterRequest struct {
	ClusterId string                           `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Request   *dev2.GetSchemaMigrationsRequest `protobuf:"bytes,2,opt,name=request,proto3" json:"request,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSchemaMigrationsRequest_ClusterRequest) ClearRequest

func (*GetSchemaMigrationsRequest_ClusterRequest) GetClusterId

func (*GetSchemaMigrationsRequest_ClusterRequest) GetRequest

func (*GetSchemaMigrationsRequest_ClusterRequest) HasRequest

func (*GetSchemaMigrationsRequest_ClusterRequest) ProtoMessage

func (*GetSchemaMigrationsRequest_ClusterRequest) ProtoReflect

func (*GetSchemaMigrationsRequest_ClusterRequest) Reset

func (*GetSchemaMigrationsRequest_ClusterRequest) SetClusterId

func (*GetSchemaMigrationsRequest_ClusterRequest) SetRequest

func (*GetSchemaMigrationsRequest_ClusterRequest) String

type GetSchemaMigrationsRequest_ClusterRequest_builder

type GetSchemaMigrationsRequest_ClusterRequest_builder struct {
	ClusterId string
	Request   *dev2.GetSchemaMigrationsRequest
	// contains filtered or unexported fields
}

func (GetSchemaMigrationsRequest_ClusterRequest_builder) Build

type GetSchemaMigrationsRequest_builder

type GetSchemaMigrationsRequest_builder struct {
	ClusterRequests []*GetSchemaMigrationsRequest_ClusterRequest
	// contains filtered or unexported fields
}

func (GetSchemaMigrationsRequest_builder) Build

type GetSchemaMigrationsResponse

type GetSchemaMigrationsResponse struct {
	SchemaMigrations []*SchemaMigration `protobuf:"bytes,1,rep,name=schema_migrations,json=schemaMigrations,proto3" json:"schema_migrations,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSchemaMigrationsResponse) GetSchemaMigrations

func (x *GetSchemaMigrationsResponse) GetSchemaMigrations() []*SchemaMigration

func (*GetSchemaMigrationsResponse) ProtoMessage

func (*GetSchemaMigrationsResponse) ProtoMessage()

func (*GetSchemaMigrationsResponse) ProtoReflect

func (*GetSchemaMigrationsResponse) Reset

func (x *GetSchemaMigrationsResponse) Reset()

func (*GetSchemaMigrationsResponse) SetSchemaMigrations

func (x *GetSchemaMigrationsResponse) SetSchemaMigrations(v []*SchemaMigration)

func (*GetSchemaMigrationsResponse) String

func (x *GetSchemaMigrationsResponse) String() string

type GetSchemaMigrationsResponse_builder

type GetSchemaMigrationsResponse_builder struct {
	SchemaMigrations []*SchemaMigration
	// contains filtered or unexported fields
}

func (GetSchemaMigrationsResponse_builder) Build

type GetSchemaRequest

type GetSchemaRequest struct {
	ClusterId        string                     `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Keyspace         string                     `protobuf:"bytes,2,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	Table            string                     `protobuf:"bytes,3,opt,name=table,proto3" json:"table,omitempty"`
	TableSizeOptions *GetSchemaTableSizeOptions `protobuf:"bytes,4,opt,name=table_size_options,json=tableSizeOptions,proto3" json:"table_size_options,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSchemaRequest) ClearTableSizeOptions

func (x *GetSchemaRequest) ClearTableSizeOptions()

func (*GetSchemaRequest) GetClusterId

func (x *GetSchemaRequest) GetClusterId() string

func (*GetSchemaRequest) GetKeyspace

func (x *GetSchemaRequest) GetKeyspace() string

func (*GetSchemaRequest) GetTable

func (x *GetSchemaRequest) GetTable() string

func (*GetSchemaRequest) GetTableSizeOptions

func (x *GetSchemaRequest) GetTableSizeOptions() *GetSchemaTableSizeOptions

func (*GetSchemaRequest) HasTableSizeOptions

func (x *GetSchemaRequest) HasTableSizeOptions() bool

func (*GetSchemaRequest) ProtoMessage

func (*GetSchemaRequest) ProtoMessage()

func (*GetSchemaRequest) ProtoReflect

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

func (*GetSchemaRequest) Reset

func (x *GetSchemaRequest) Reset()

func (*GetSchemaRequest) SetClusterId

func (x *GetSchemaRequest) SetClusterId(v string)

func (*GetSchemaRequest) SetKeyspace

func (x *GetSchemaRequest) SetKeyspace(v string)

func (*GetSchemaRequest) SetTable

func (x *GetSchemaRequest) SetTable(v string)

func (*GetSchemaRequest) SetTableSizeOptions

func (x *GetSchemaRequest) SetTableSizeOptions(v *GetSchemaTableSizeOptions)

func (*GetSchemaRequest) String

func (x *GetSchemaRequest) String() string

type GetSchemaRequest_builder

type GetSchemaRequest_builder struct {
	ClusterId        string
	Keyspace         string
	Table            string
	TableSizeOptions *GetSchemaTableSizeOptions
	// contains filtered or unexported fields
}

func (GetSchemaRequest_builder) Build

type GetSchemaTableSizeOptions

type GetSchemaTableSizeOptions struct {
	AggregateSizes          bool `protobuf:"varint,1,opt,name=aggregate_sizes,json=aggregateSizes,proto3" json:"aggregate_sizes,omitempty"`
	IncludeNonServingShards bool `` /* 135-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetSchemaTableSizeOptions) GetAggregateSizes

func (x *GetSchemaTableSizeOptions) GetAggregateSizes() bool

func (*GetSchemaTableSizeOptions) GetIncludeNonServingShards

func (x *GetSchemaTableSizeOptions) GetIncludeNonServingShards() bool

func (*GetSchemaTableSizeOptions) ProtoMessage

func (*GetSchemaTableSizeOptions) ProtoMessage()

func (*GetSchemaTableSizeOptions) ProtoReflect

func (*GetSchemaTableSizeOptions) Reset

func (x *GetSchemaTableSizeOptions) Reset()

func (*GetSchemaTableSizeOptions) SetAggregateSizes

func (x *GetSchemaTableSizeOptions) SetAggregateSizes(v bool)

func (*GetSchemaTableSizeOptions) SetIncludeNonServingShards

func (x *GetSchemaTableSizeOptions) SetIncludeNonServingShards(v bool)

func (*GetSchemaTableSizeOptions) String

func (x *GetSchemaTableSizeOptions) String() string

type GetSchemaTableSizeOptions_builder

type GetSchemaTableSizeOptions_builder struct {
	AggregateSizes          bool
	IncludeNonServingShards bool
	// contains filtered or unexported fields
}

func (GetSchemaTableSizeOptions_builder) Build

type GetSchemasRequest

type GetSchemasRequest struct {
	ClusterIds       []string                   `protobuf:"bytes,1,rep,name=cluster_ids,json=clusterIds,proto3" json:"cluster_ids,omitempty"`
	TableSizeOptions *GetSchemaTableSizeOptions `protobuf:"bytes,2,opt,name=table_size_options,json=tableSizeOptions,proto3" json:"table_size_options,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSchemasRequest) ClearTableSizeOptions

func (x *GetSchemasRequest) ClearTableSizeOptions()

func (*GetSchemasRequest) GetClusterIds

func (x *GetSchemasRequest) GetClusterIds() []string

func (*GetSchemasRequest) GetTableSizeOptions

func (x *GetSchemasRequest) GetTableSizeOptions() *GetSchemaTableSizeOptions

func (*GetSchemasRequest) HasTableSizeOptions

func (x *GetSchemasRequest) HasTableSizeOptions() bool

func (*GetSchemasRequest) ProtoMessage

func (*GetSchemasRequest) ProtoMessage()

func (*GetSchemasRequest) ProtoReflect

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

func (*GetSchemasRequest) Reset

func (x *GetSchemasRequest) Reset()

func (*GetSchemasRequest) SetClusterIds

func (x *GetSchemasRequest) SetClusterIds(v []string)

func (*GetSchemasRequest) SetTableSizeOptions

func (x *GetSchemasRequest) SetTableSizeOptions(v *GetSchemaTableSizeOptions)

func (*GetSchemasRequest) String

func (x *GetSchemasRequest) String() string

type GetSchemasRequest_builder

type GetSchemasRequest_builder struct {
	ClusterIds       []string
	TableSizeOptions *GetSchemaTableSizeOptions
	// contains filtered or unexported fields
}

func (GetSchemasRequest_builder) Build

type GetSchemasResponse

type GetSchemasResponse struct {
	Schemas []*Schema `protobuf:"bytes,1,rep,name=schemas,proto3" json:"schemas,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSchemasResponse) GetSchemas

func (x *GetSchemasResponse) GetSchemas() []*Schema

func (*GetSchemasResponse) ProtoMessage

func (*GetSchemasResponse) ProtoMessage()

func (*GetSchemasResponse) ProtoReflect

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

func (*GetSchemasResponse) Reset

func (x *GetSchemasResponse) Reset()

func (*GetSchemasResponse) SetSchemas

func (x *GetSchemasResponse) SetSchemas(v []*Schema)

func (*GetSchemasResponse) String

func (x *GetSchemasResponse) String() string

type GetSchemasResponse_builder

type GetSchemasResponse_builder struct {
	Schemas []*Schema
	// contains filtered or unexported fields
}

func (GetSchemasResponse_builder) Build

type GetShardReplicationPositionsRequest

type GetShardReplicationPositionsRequest struct {
	ClusterIds []string `protobuf:"bytes,1,rep,name=cluster_ids,json=clusterIds,proto3" json:"cluster_ids,omitempty"`
	// Keyspaces, if set, limits replication positions to just the specified
	// keyspaces. Applies to all clusters in the request.
	Keyspaces []string `protobuf:"bytes,2,rep,name=keyspaces,proto3" json:"keyspaces,omitempty"`
	// KeyspaceShards, if set, limits replicatin positions to just the specified
	// keyspace/shards. Applies to all clusters in the request.
	//
	// This field takes precedence over Keyspaces. If KeyspaceShards is set,
	// Keyspaces is ignored.
	KeyspaceShards []string `protobuf:"bytes,3,rep,name=keyspace_shards,json=keyspaceShards,proto3" json:"keyspace_shards,omitempty"`
	// contains filtered or unexported fields
}

func (*GetShardReplicationPositionsRequest) GetClusterIds

func (x *GetShardReplicationPositionsRequest) GetClusterIds() []string

func (*GetShardReplicationPositionsRequest) GetKeyspaceShards

func (x *GetShardReplicationPositionsRequest) GetKeyspaceShards() []string

func (*GetShardReplicationPositionsRequest) GetKeyspaces

func (x *GetShardReplicationPositionsRequest) GetKeyspaces() []string

func (*GetShardReplicationPositionsRequest) ProtoMessage

func (*GetShardReplicationPositionsRequest) ProtoMessage()

func (*GetShardReplicationPositionsRequest) ProtoReflect

func (*GetShardReplicationPositionsRequest) Reset

func (*GetShardReplicationPositionsRequest) SetClusterIds

func (x *GetShardReplicationPositionsRequest) SetClusterIds(v []string)

func (*GetShardReplicationPositionsRequest) SetKeyspaceShards

func (x *GetShardReplicationPositionsRequest) SetKeyspaceShards(v []string)

func (*GetShardReplicationPositionsRequest) SetKeyspaces

func (x *GetShardReplicationPositionsRequest) SetKeyspaces(v []string)

func (*GetShardReplicationPositionsRequest) String

type GetShardReplicationPositionsRequest_builder

type GetShardReplicationPositionsRequest_builder struct {
	ClusterIds []string
	// Keyspaces, if set, limits replication positions to just the specified
	// keyspaces. Applies to all clusters in the request.
	Keyspaces []string
	// KeyspaceShards, if set, limits replicatin positions to just the specified
	// keyspace/shards. Applies to all clusters in the request.
	//
	// This field takes precedence over Keyspaces. If KeyspaceShards is set,
	// Keyspaces is ignored.
	KeyspaceShards []string
	// contains filtered or unexported fields
}

func (GetShardReplicationPositionsRequest_builder) Build

type GetShardReplicationPositionsResponse

type GetShardReplicationPositionsResponse struct {
	ReplicationPositions []*ClusterShardReplicationPosition `protobuf:"bytes,1,rep,name=replication_positions,json=replicationPositions,proto3" json:"replication_positions,omitempty"`
	// contains filtered or unexported fields
}

func (*GetShardReplicationPositionsResponse) GetReplicationPositions

func (*GetShardReplicationPositionsResponse) ProtoMessage

func (*GetShardReplicationPositionsResponse) ProtoMessage()

func (*GetShardReplicationPositionsResponse) ProtoReflect

func (*GetShardReplicationPositionsResponse) Reset

func (*GetShardReplicationPositionsResponse) SetReplicationPositions

func (*GetShardReplicationPositionsResponse) String

type GetShardReplicationPositionsResponse_builder

type GetShardReplicationPositionsResponse_builder struct {
	ReplicationPositions []*ClusterShardReplicationPosition
	// contains filtered or unexported fields
}

func (GetShardReplicationPositionsResponse_builder) Build

type GetSrvKeyspaceRequest

type GetSrvKeyspaceRequest struct {
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Keyspace  string `protobuf:"bytes,2,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	// Cells is a list of cells to lookup a SrvKeyspace for. Leaving this empty is
	// equivalent to specifying all cells in the topo.
	Cells []string `protobuf:"bytes,3,rep,name=cells,proto3" json:"cells,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSrvKeyspaceRequest) GetCells

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

func (*GetSrvKeyspaceRequest) GetClusterId

func (x *GetSrvKeyspaceRequest) GetClusterId() string

func (*GetSrvKeyspaceRequest) GetKeyspace

func (x *GetSrvKeyspaceRequest) GetKeyspace() string

func (*GetSrvKeyspaceRequest) ProtoMessage

func (*GetSrvKeyspaceRequest) ProtoMessage()

func (*GetSrvKeyspaceRequest) ProtoReflect

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

func (*GetSrvKeyspaceRequest) Reset

func (x *GetSrvKeyspaceRequest) Reset()

func (*GetSrvKeyspaceRequest) SetCells

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

func (*GetSrvKeyspaceRequest) SetClusterId

func (x *GetSrvKeyspaceRequest) SetClusterId(v string)

func (*GetSrvKeyspaceRequest) SetKeyspace

func (x *GetSrvKeyspaceRequest) SetKeyspace(v string)

func (*GetSrvKeyspaceRequest) String

func (x *GetSrvKeyspaceRequest) String() string

type GetSrvKeyspaceRequest_builder

type GetSrvKeyspaceRequest_builder struct {
	ClusterId string
	Keyspace  string
	// Cells is a list of cells to lookup a SrvKeyspace for. Leaving this empty is
	// equivalent to specifying all cells in the topo.
	Cells []string
	// contains filtered or unexported fields
}

func (GetSrvKeyspaceRequest_builder) Build

type GetSrvKeyspacesRequest

type GetSrvKeyspacesRequest struct {

	// An optional list of cluster IDs to filter specific clusters
	ClusterIds []string `protobuf:"bytes,1,rep,name=cluster_ids,json=clusterIds,proto3" json:"cluster_ids,omitempty"`
	// Cells is a list of cells to lookup a SrvKeyspace for. Leaving this empty is
	// equivalent to specifying all cells in the topo.
	Cells []string `protobuf:"bytes,2,rep,name=cells,proto3" json:"cells,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSrvKeyspacesRequest) GetCells

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

func (*GetSrvKeyspacesRequest) GetClusterIds

func (x *GetSrvKeyspacesRequest) GetClusterIds() []string

func (*GetSrvKeyspacesRequest) ProtoMessage

func (*GetSrvKeyspacesRequest) ProtoMessage()

func (*GetSrvKeyspacesRequest) ProtoReflect

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

func (*GetSrvKeyspacesRequest) Reset

func (x *GetSrvKeyspacesRequest) Reset()

func (*GetSrvKeyspacesRequest) SetCells

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

func (*GetSrvKeyspacesRequest) SetClusterIds

func (x *GetSrvKeyspacesRequest) SetClusterIds(v []string)

func (*GetSrvKeyspacesRequest) String

func (x *GetSrvKeyspacesRequest) String() string

type GetSrvKeyspacesRequest_builder

type GetSrvKeyspacesRequest_builder struct {

	// An optional list of cluster IDs to filter specific clusters
	ClusterIds []string
	// Cells is a list of cells to lookup a SrvKeyspace for. Leaving this empty is
	// equivalent to specifying all cells in the topo.
	Cells []string
	// contains filtered or unexported fields
}

func (GetSrvKeyspacesRequest_builder) Build

type GetSrvKeyspacesResponse

type GetSrvKeyspacesResponse struct {

	// GetSrvKeyspaces responses for each keyspace
	SrvKeyspaces map[string]*dev2.GetSrvKeyspacesResponse `` /* 171-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetSrvKeyspacesResponse) GetSrvKeyspaces

func (x *GetSrvKeyspacesResponse) GetSrvKeyspaces() map[string]*dev2.GetSrvKeyspacesResponse

func (*GetSrvKeyspacesResponse) ProtoMessage

func (*GetSrvKeyspacesResponse) ProtoMessage()

func (*GetSrvKeyspacesResponse) ProtoReflect

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

func (*GetSrvKeyspacesResponse) Reset

func (x *GetSrvKeyspacesResponse) Reset()

func (*GetSrvKeyspacesResponse) SetSrvKeyspaces

func (x *GetSrvKeyspacesResponse) SetSrvKeyspaces(v map[string]*dev2.GetSrvKeyspacesResponse)

func (*GetSrvKeyspacesResponse) String

func (x *GetSrvKeyspacesResponse) String() string

type GetSrvKeyspacesResponse_builder

type GetSrvKeyspacesResponse_builder struct {

	// GetSrvKeyspaces responses for each keyspace
	SrvKeyspaces map[string]*dev2.GetSrvKeyspacesResponse
	// contains filtered or unexported fields
}

func (GetSrvKeyspacesResponse_builder) Build

type GetSrvVSchemaRequest

type GetSrvVSchemaRequest struct {
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Cell      string `protobuf:"bytes,2,opt,name=cell,proto3" json:"cell,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSrvVSchemaRequest) GetCell

func (x *GetSrvVSchemaRequest) GetCell() string

func (*GetSrvVSchemaRequest) GetClusterId

func (x *GetSrvVSchemaRequest) GetClusterId() string

func (*GetSrvVSchemaRequest) ProtoMessage

func (*GetSrvVSchemaRequest) ProtoMessage()

func (*GetSrvVSchemaRequest) ProtoReflect

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

func (*GetSrvVSchemaRequest) Reset

func (x *GetSrvVSchemaRequest) Reset()

func (*GetSrvVSchemaRequest) SetCell

func (x *GetSrvVSchemaRequest) SetCell(v string)

func (*GetSrvVSchemaRequest) SetClusterId

func (x *GetSrvVSchemaRequest) SetClusterId(v string)

func (*GetSrvVSchemaRequest) String

func (x *GetSrvVSchemaRequest) String() string

type GetSrvVSchemaRequest_builder

type GetSrvVSchemaRequest_builder struct {
	ClusterId string
	Cell      string
	// contains filtered or unexported fields
}

func (GetSrvVSchemaRequest_builder) Build

type GetSrvVSchemasRequest

type GetSrvVSchemasRequest struct {
	ClusterIds []string `protobuf:"bytes,1,rep,name=cluster_ids,json=clusterIds,proto3" json:"cluster_ids,omitempty"`
	Cells      []string `protobuf:"bytes,2,rep,name=cells,proto3" json:"cells,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSrvVSchemasRequest) GetCells

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

func (*GetSrvVSchemasRequest) GetClusterIds

func (x *GetSrvVSchemasRequest) GetClusterIds() []string

func (*GetSrvVSchemasRequest) ProtoMessage

func (*GetSrvVSchemasRequest) ProtoMessage()

func (*GetSrvVSchemasRequest) ProtoReflect

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

func (*GetSrvVSchemasRequest) Reset

func (x *GetSrvVSchemasRequest) Reset()

func (*GetSrvVSchemasRequest) SetCells

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

func (*GetSrvVSchemasRequest) SetClusterIds

func (x *GetSrvVSchemasRequest) SetClusterIds(v []string)

func (*GetSrvVSchemasRequest) String

func (x *GetSrvVSchemasRequest) String() string

type GetSrvVSchemasRequest_builder

type GetSrvVSchemasRequest_builder struct {
	ClusterIds []string
	Cells      []string
	// contains filtered or unexported fields
}

func (GetSrvVSchemasRequest_builder) Build

type GetSrvVSchemasResponse

type GetSrvVSchemasResponse struct {
	SrvVSchemas []*SrvVSchema `protobuf:"bytes,1,rep,name=srv_v_schemas,json=srvVSchemas,proto3" json:"srv_v_schemas,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSrvVSchemasResponse) GetSrvVSchemas

func (x *GetSrvVSchemasResponse) GetSrvVSchemas() []*SrvVSchema

func (*GetSrvVSchemasResponse) ProtoMessage

func (*GetSrvVSchemasResponse) ProtoMessage()

func (*GetSrvVSchemasResponse) ProtoReflect

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

func (*GetSrvVSchemasResponse) Reset

func (x *GetSrvVSchemasResponse) Reset()

func (*GetSrvVSchemasResponse) SetSrvVSchemas

func (x *GetSrvVSchemasResponse) SetSrvVSchemas(v []*SrvVSchema)

func (*GetSrvVSchemasResponse) String

func (x *GetSrvVSchemasResponse) String() string

type GetSrvVSchemasResponse_builder

type GetSrvVSchemasResponse_builder struct {
	SrvVSchemas []*SrvVSchema
	// contains filtered or unexported fields
}

func (GetSrvVSchemasResponse_builder) Build

type GetTabletRequest

type GetTabletRequest struct {

	// Unique (per cluster) tablet alias.
	Alias *dev1.TabletAlias `protobuf:"bytes,1,opt,name=alias,proto3" json:"alias,omitempty"`
	// ClusterIDs is an optional parameter to narrow the scope of the search, if
	// the caller knows which cluster the tablet may be in, or, to disambiguate
	// if multiple clusters have a tablet with the same hostname.
	ClusterIds []string `protobuf:"bytes,2,rep,name=cluster_ids,json=clusterIds,proto3" json:"cluster_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTabletRequest) ClearAlias

func (x *GetTabletRequest) ClearAlias()

func (*GetTabletRequest) GetAlias

func (x *GetTabletRequest) GetAlias() *dev1.TabletAlias

func (*GetTabletRequest) GetClusterIds

func (x *GetTabletRequest) GetClusterIds() []string

func (*GetTabletRequest) HasAlias

func (x *GetTabletRequest) HasAlias() bool

func (*GetTabletRequest) ProtoMessage

func (*GetTabletRequest) ProtoMessage()

func (*GetTabletRequest) ProtoReflect

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

func (*GetTabletRequest) Reset

func (x *GetTabletRequest) Reset()

func (*GetTabletRequest) SetAlias

func (x *GetTabletRequest) SetAlias(v *dev1.TabletAlias)

func (*GetTabletRequest) SetClusterIds

func (x *GetTabletRequest) SetClusterIds(v []string)

func (*GetTabletRequest) String

func (x *GetTabletRequest) String() string

type GetTabletRequest_builder

type GetTabletRequest_builder struct {

	// Unique (per cluster) tablet alias.
	Alias *dev1.TabletAlias
	// ClusterIDs is an optional parameter to narrow the scope of the search, if
	// the caller knows which cluster the tablet may be in, or, to disambiguate
	// if multiple clusters have a tablet with the same hostname.
	ClusterIds []string
	// contains filtered or unexported fields
}

func (GetTabletRequest_builder) Build

type GetTabletsRequest

type GetTabletsRequest struct {
	ClusterIds []string `protobuf:"bytes,1,rep,name=cluster_ids,json=clusterIds,proto3" json:"cluster_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTabletsRequest) GetClusterIds

func (x *GetTabletsRequest) GetClusterIds() []string

func (*GetTabletsRequest) ProtoMessage

func (*GetTabletsRequest) ProtoMessage()

func (*GetTabletsRequest) ProtoReflect

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

func (*GetTabletsRequest) Reset

func (x *GetTabletsRequest) Reset()

func (*GetTabletsRequest) SetClusterIds

func (x *GetTabletsRequest) SetClusterIds(v []string)

func (*GetTabletsRequest) String

func (x *GetTabletsRequest) String() string

type GetTabletsRequest_builder

type GetTabletsRequest_builder struct {
	ClusterIds []string
	// contains filtered or unexported fields
}

func (GetTabletsRequest_builder) Build

type GetTabletsResponse

type GetTabletsResponse struct {
	Tablets []*Tablet `protobuf:"bytes,1,rep,name=tablets,proto3" json:"tablets,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTabletsResponse) GetTablets

func (x *GetTabletsResponse) GetTablets() []*Tablet

func (*GetTabletsResponse) ProtoMessage

func (*GetTabletsResponse) ProtoMessage()

func (*GetTabletsResponse) ProtoReflect

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

func (*GetTabletsResponse) Reset

func (x *GetTabletsResponse) Reset()

func (*GetTabletsResponse) SetTablets

func (x *GetTabletsResponse) SetTablets(v []*Tablet)

func (*GetTabletsResponse) String

func (x *GetTabletsResponse) String() string

type GetTabletsResponse_builder

type GetTabletsResponse_builder struct {
	Tablets []*Tablet
	// contains filtered or unexported fields
}

func (GetTabletsResponse_builder) Build

type GetTopologyPathRequest

type GetTopologyPathRequest struct {
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Path      string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTopologyPathRequest) GetClusterId

func (x *GetTopologyPathRequest) GetClusterId() string

func (*GetTopologyPathRequest) GetPath

func (x *GetTopologyPathRequest) GetPath() string

func (*GetTopologyPathRequest) ProtoMessage

func (*GetTopologyPathRequest) ProtoMessage()

func (*GetTopologyPathRequest) ProtoReflect

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

func (*GetTopologyPathRequest) Reset

func (x *GetTopologyPathRequest) Reset()

func (*GetTopologyPathRequest) SetClusterId

func (x *GetTopologyPathRequest) SetClusterId(v string)

func (*GetTopologyPathRequest) SetPath

func (x *GetTopologyPathRequest) SetPath(v string)

func (*GetTopologyPathRequest) String

func (x *GetTopologyPathRequest) String() string

type GetTopologyPathRequest_builder

type GetTopologyPathRequest_builder struct {
	ClusterId string
	Path      string
	// contains filtered or unexported fields
}

func (GetTopologyPathRequest_builder) Build

type GetTransactionInfoRequest

type GetTransactionInfoRequest struct {
	ClusterId string                          `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Request   *dev2.GetTransactionInfoRequest `protobuf:"bytes,2,opt,name=request,proto3" json:"request,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTransactionInfoRequest) ClearRequest

func (x *GetTransactionInfoRequest) ClearRequest()

func (*GetTransactionInfoRequest) GetClusterId

func (x *GetTransactionInfoRequest) GetClusterId() string

func (*GetTransactionInfoRequest) GetRequest

func (*GetTransactionInfoRequest) HasRequest

func (x *GetTransactionInfoRequest) HasRequest() bool

func (*GetTransactionInfoRequest) ProtoMessage

func (*GetTransactionInfoRequest) ProtoMessage()

func (*GetTransactionInfoRequest) ProtoReflect

func (*GetTransactionInfoRequest) Reset

func (x *GetTransactionInfoRequest) Reset()

func (*GetTransactionInfoRequest) SetClusterId

func (x *GetTransactionInfoRequest) SetClusterId(v string)

func (*GetTransactionInfoRequest) SetRequest

func (*GetTransactionInfoRequest) String

func (x *GetTransactionInfoRequest) String() string

type GetTransactionInfoRequest_builder

type GetTransactionInfoRequest_builder struct {
	ClusterId string
	Request   *dev2.GetTransactionInfoRequest
	// contains filtered or unexported fields
}

func (GetTransactionInfoRequest_builder) Build

type GetUnresolvedTransactionsRequest

type GetUnresolvedTransactionsRequest struct {
	ClusterId  string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Keyspace   string `protobuf:"bytes,2,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	AbandonAge int64  `protobuf:"varint,3,opt,name=abandon_age,json=abandonAge,proto3" json:"abandon_age,omitempty"`
	// contains filtered or unexported fields
}

func (*GetUnresolvedTransactionsRequest) GetAbandonAge

func (x *GetUnresolvedTransactionsRequest) GetAbandonAge() int64

func (*GetUnresolvedTransactionsRequest) GetClusterId

func (x *GetUnresolvedTransactionsRequest) GetClusterId() string

func (*GetUnresolvedTransactionsRequest) GetKeyspace

func (x *GetUnresolvedTransactionsRequest) GetKeyspace() string

func (*GetUnresolvedTransactionsRequest) ProtoMessage

func (*GetUnresolvedTransactionsRequest) ProtoMessage()

func (*GetUnresolvedTransactionsRequest) ProtoReflect

func (*GetUnresolvedTransactionsRequest) Reset

func (*GetUnresolvedTransactionsRequest) SetAbandonAge

func (x *GetUnresolvedTransactionsRequest) SetAbandonAge(v int64)

func (*GetUnresolvedTransactionsRequest) SetClusterId

func (x *GetUnresolvedTransactionsRequest) SetClusterId(v string)

func (*GetUnresolvedTransactionsRequest) SetKeyspace

func (x *GetUnresolvedTransactionsRequest) SetKeyspace(v string)

func (*GetUnresolvedTransactionsRequest) String

type GetUnresolvedTransactionsRequest_builder

type GetUnresolvedTransactionsRequest_builder struct {
	ClusterId  string
	Keyspace   string
	AbandonAge int64
	// contains filtered or unexported fields
}

func (GetUnresolvedTransactionsRequest_builder) Build

type GetVSchemaRequest

type GetVSchemaRequest struct {
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Keyspace  string `protobuf:"bytes,2,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	// contains filtered or unexported fields
}

func (*GetVSchemaRequest) GetClusterId

func (x *GetVSchemaRequest) GetClusterId() string

func (*GetVSchemaRequest) GetKeyspace

func (x *GetVSchemaRequest) GetKeyspace() string

func (*GetVSchemaRequest) ProtoMessage

func (*GetVSchemaRequest) ProtoMessage()

func (*GetVSchemaRequest) ProtoReflect

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

func (*GetVSchemaRequest) Reset

func (x *GetVSchemaRequest) Reset()

func (*GetVSchemaRequest) SetClusterId

func (x *GetVSchemaRequest) SetClusterId(v string)

func (*GetVSchemaRequest) SetKeyspace

func (x *GetVSchemaRequest) SetKeyspace(v string)

func (*GetVSchemaRequest) String

func (x *GetVSchemaRequest) String() string

type GetVSchemaRequest_builder

type GetVSchemaRequest_builder struct {
	ClusterId string
	Keyspace  string
	// contains filtered or unexported fields
}

func (GetVSchemaRequest_builder) Build

type GetVSchemasRequest

type GetVSchemasRequest struct {
	ClusterIds []string `protobuf:"bytes,1,rep,name=cluster_ids,json=clusterIds,proto3" json:"cluster_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*GetVSchemasRequest) GetClusterIds

func (x *GetVSchemasRequest) GetClusterIds() []string

func (*GetVSchemasRequest) ProtoMessage

func (*GetVSchemasRequest) ProtoMessage()

func (*GetVSchemasRequest) ProtoReflect

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

func (*GetVSchemasRequest) Reset

func (x *GetVSchemasRequest) Reset()

func (*GetVSchemasRequest) SetClusterIds

func (x *GetVSchemasRequest) SetClusterIds(v []string)

func (*GetVSchemasRequest) String

func (x *GetVSchemasRequest) String() string

type GetVSchemasRequest_builder

type GetVSchemasRequest_builder struct {
	ClusterIds []string
	// contains filtered or unexported fields
}

func (GetVSchemasRequest_builder) Build

type GetVSchemasResponse

type GetVSchemasResponse struct {
	VSchemas []*VSchema `protobuf:"bytes,1,rep,name=v_schemas,json=vSchemas,proto3" json:"v_schemas,omitempty"`
	// contains filtered or unexported fields
}

func (*GetVSchemasResponse) GetVSchemas

func (x *GetVSchemasResponse) GetVSchemas() []*VSchema

func (*GetVSchemasResponse) ProtoMessage

func (*GetVSchemasResponse) ProtoMessage()

func (*GetVSchemasResponse) ProtoReflect

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

func (*GetVSchemasResponse) Reset

func (x *GetVSchemasResponse) Reset()

func (*GetVSchemasResponse) SetVSchemas

func (x *GetVSchemasResponse) SetVSchemas(v []*VSchema)

func (*GetVSchemasResponse) String

func (x *GetVSchemasResponse) String() string

type GetVSchemasResponse_builder

type GetVSchemasResponse_builder struct {
	VSchemas []*VSchema
	// contains filtered or unexported fields
}

func (GetVSchemasResponse_builder) Build

type GetVtctldsRequest

type GetVtctldsRequest struct {
	ClusterIds []string `protobuf:"bytes,1,rep,name=cluster_ids,json=clusterIds,proto3" json:"cluster_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*GetVtctldsRequest) GetClusterIds

func (x *GetVtctldsRequest) GetClusterIds() []string

func (*GetVtctldsRequest) ProtoMessage

func (*GetVtctldsRequest) ProtoMessage()

func (*GetVtctldsRequest) ProtoReflect

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

func (*GetVtctldsRequest) Reset

func (x *GetVtctldsRequest) Reset()

func (*GetVtctldsRequest) SetClusterIds

func (x *GetVtctldsRequest) SetClusterIds(v []string)

func (*GetVtctldsRequest) String

func (x *GetVtctldsRequest) String() string

type GetVtctldsRequest_builder

type GetVtctldsRequest_builder struct {
	ClusterIds []string
	// contains filtered or unexported fields
}

func (GetVtctldsRequest_builder) Build

type GetVtctldsResponse

type GetVtctldsResponse struct {
	Vtctlds []*Vtctld `protobuf:"bytes,1,rep,name=vtctlds,proto3" json:"vtctlds,omitempty"`
	// contains filtered or unexported fields
}

func (*GetVtctldsResponse) GetVtctlds

func (x *GetVtctldsResponse) GetVtctlds() []*Vtctld

func (*GetVtctldsResponse) ProtoMessage

func (*GetVtctldsResponse) ProtoMessage()

func (*GetVtctldsResponse) ProtoReflect

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

func (*GetVtctldsResponse) Reset

func (x *GetVtctldsResponse) Reset()

func (*GetVtctldsResponse) SetVtctlds

func (x *GetVtctldsResponse) SetVtctlds(v []*Vtctld)

func (*GetVtctldsResponse) String

func (x *GetVtctldsResponse) String() string

type GetVtctldsResponse_builder

type GetVtctldsResponse_builder struct {
	Vtctlds []*Vtctld
	// contains filtered or unexported fields
}

func (GetVtctldsResponse_builder) Build

type GetWorkflowRequest

type GetWorkflowRequest struct {
	ClusterId  string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Keyspace   string `protobuf:"bytes,2,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	Name       string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	ActiveOnly bool   `protobuf:"varint,4,opt,name=active_only,json=activeOnly,proto3" json:"active_only,omitempty"`
	// contains filtered or unexported fields
}

func (*GetWorkflowRequest) GetActiveOnly

func (x *GetWorkflowRequest) GetActiveOnly() bool

func (*GetWorkflowRequest) GetClusterId

func (x *GetWorkflowRequest) GetClusterId() string

func (*GetWorkflowRequest) GetKeyspace

func (x *GetWorkflowRequest) GetKeyspace() string

func (*GetWorkflowRequest) GetName

func (x *GetWorkflowRequest) GetName() string

func (*GetWorkflowRequest) ProtoMessage

func (*GetWorkflowRequest) ProtoMessage()

func (*GetWorkflowRequest) ProtoReflect

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

func (*GetWorkflowRequest) Reset

func (x *GetWorkflowRequest) Reset()

func (*GetWorkflowRequest) SetActiveOnly

func (x *GetWorkflowRequest) SetActiveOnly(v bool)

func (*GetWorkflowRequest) SetClusterId

func (x *GetWorkflowRequest) SetClusterId(v string)

func (*GetWorkflowRequest) SetKeyspace

func (x *GetWorkflowRequest) SetKeyspace(v string)

func (*GetWorkflowRequest) SetName

func (x *GetWorkflowRequest) SetName(v string)

func (*GetWorkflowRequest) String

func (x *GetWorkflowRequest) String() string

type GetWorkflowRequest_builder

type GetWorkflowRequest_builder struct {
	ClusterId  string
	Keyspace   string
	Name       string
	ActiveOnly bool
	// contains filtered or unexported fields
}

func (GetWorkflowRequest_builder) Build

type GetWorkflowStatusRequest

type GetWorkflowStatusRequest struct {
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Keyspace  string `protobuf:"bytes,2,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	Name      string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetWorkflowStatusRequest) GetClusterId

func (x *GetWorkflowStatusRequest) GetClusterId() string

func (*GetWorkflowStatusRequest) GetKeyspace

func (x *GetWorkflowStatusRequest) GetKeyspace() string

func (*GetWorkflowStatusRequest) GetName

func (x *GetWorkflowStatusRequest) GetName() string

func (*GetWorkflowStatusRequest) ProtoMessage

func (*GetWorkflowStatusRequest) ProtoMessage()

func (*GetWorkflowStatusRequest) ProtoReflect

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

func (*GetWorkflowStatusRequest) Reset

func (x *GetWorkflowStatusRequest) Reset()

func (*GetWorkflowStatusRequest) SetClusterId

func (x *GetWorkflowStatusRequest) SetClusterId(v string)

func (*GetWorkflowStatusRequest) SetKeyspace

func (x *GetWorkflowStatusRequest) SetKeyspace(v string)

func (*GetWorkflowStatusRequest) SetName

func (x *GetWorkflowStatusRequest) SetName(v string)

func (*GetWorkflowStatusRequest) String

func (x *GetWorkflowStatusRequest) String() string

type GetWorkflowStatusRequest_builder

type GetWorkflowStatusRequest_builder struct {
	ClusterId string
	Keyspace  string
	Name      string
	// contains filtered or unexported fields
}

func (GetWorkflowStatusRequest_builder) Build

type GetWorkflowsRequest

type GetWorkflowsRequest struct {
	ClusterIds []string `protobuf:"bytes,1,rep,name=cluster_ids,json=clusterIds,proto3" json:"cluster_ids,omitempty"`
	// ActiveOnly specifies whether to return workflows that are currently
	// active (running or paused) instead of all workflows.
	ActiveOnly bool `protobuf:"varint,2,opt,name=active_only,json=activeOnly,proto3" json:"active_only,omitempty"`
	// Keyspaces is a list of keyspaces to restrict the workflow search to. Note
	// that the keyspaces list applies across all cluster IDs in the request.
	//
	// If, for example, you have two clusters, each with a keyspace called "foo"
	// and want the workflows from "foo" in cluster1 but not from cluster2, you
	// must make two requests.
	//
	// Keyspaces and IgnoreKeyspaces are mutually-exclusive, and Keyspaces takes
	// precedence; if Keyspaces is a non-empty list, then IgnoreKeyspaces is
	// ignored completely.
	Keyspaces []string `protobuf:"bytes,3,rep,name=keyspaces,proto3" json:"keyspaces,omitempty"`
	// IgnoreKeyspaces is a list of keyspaces to skip during the workflow
	// search. It has the same semantics as the Keyspaces parameter, so refer to
	// that documentation for more details.
	IgnoreKeyspaces []string `protobuf:"bytes,4,rep,name=ignore_keyspaces,json=ignoreKeyspaces,proto3" json:"ignore_keyspaces,omitempty"`
	// contains filtered or unexported fields
}

func (*GetWorkflowsRequest) GetActiveOnly

func (x *GetWorkflowsRequest) GetActiveOnly() bool

func (*GetWorkflowsRequest) GetClusterIds

func (x *GetWorkflowsRequest) GetClusterIds() []string

func (*GetWorkflowsRequest) GetIgnoreKeyspaces

func (x *GetWorkflowsRequest) GetIgnoreKeyspaces() []string

func (*GetWorkflowsRequest) GetKeyspaces

func (x *GetWorkflowsRequest) GetKeyspaces() []string

func (*GetWorkflowsRequest) ProtoMessage

func (*GetWorkflowsRequest) ProtoMessage()

func (*GetWorkflowsRequest) ProtoReflect

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

func (*GetWorkflowsRequest) Reset

func (x *GetWorkflowsRequest) Reset()

func (*GetWorkflowsRequest) SetActiveOnly

func (x *GetWorkflowsRequest) SetActiveOnly(v bool)

func (*GetWorkflowsRequest) SetClusterIds

func (x *GetWorkflowsRequest) SetClusterIds(v []string)

func (*GetWorkflowsRequest) SetIgnoreKeyspaces

func (x *GetWorkflowsRequest) SetIgnoreKeyspaces(v []string)

func (*GetWorkflowsRequest) SetKeyspaces

func (x *GetWorkflowsRequest) SetKeyspaces(v []string)

func (*GetWorkflowsRequest) String

func (x *GetWorkflowsRequest) String() string

type GetWorkflowsRequest_builder

type GetWorkflowsRequest_builder struct {
	ClusterIds []string
	// ActiveOnly specifies whether to return workflows that are currently
	// active (running or paused) instead of all workflows.
	ActiveOnly bool
	// Keyspaces is a list of keyspaces to restrict the workflow search to. Note
	// that the keyspaces list applies across all cluster IDs in the request.
	//
	// If, for example, you have two clusters, each with a keyspace called "foo"
	// and want the workflows from "foo" in cluster1 but not from cluster2, you
	// must make two requests.
	//
	// Keyspaces and IgnoreKeyspaces are mutually-exclusive, and Keyspaces takes
	// precedence; if Keyspaces is a non-empty list, then IgnoreKeyspaces is
	// ignored completely.
	Keyspaces []string
	// IgnoreKeyspaces is a list of keyspaces to skip during the workflow
	// search. It has the same semantics as the Keyspaces parameter, so refer to
	// that documentation for more details.
	IgnoreKeyspaces []string
	// contains filtered or unexported fields
}

func (GetWorkflowsRequest_builder) Build

type GetWorkflowsResponse

type GetWorkflowsResponse struct {
	WorkflowsByCluster map[string]*ClusterWorkflows `` /* 191-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetWorkflowsResponse) GetWorkflowsByCluster

func (x *GetWorkflowsResponse) GetWorkflowsByCluster() map[string]*ClusterWorkflows

func (*GetWorkflowsResponse) ProtoMessage

func (*GetWorkflowsResponse) ProtoMessage()

func (*GetWorkflowsResponse) ProtoReflect

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

func (*GetWorkflowsResponse) Reset

func (x *GetWorkflowsResponse) Reset()

func (*GetWorkflowsResponse) SetWorkflowsByCluster

func (x *GetWorkflowsResponse) SetWorkflowsByCluster(v map[string]*ClusterWorkflows)

func (*GetWorkflowsResponse) String

func (x *GetWorkflowsResponse) String() string

type GetWorkflowsResponse_builder

type GetWorkflowsResponse_builder struct {
	WorkflowsByCluster map[string]*ClusterWorkflows
	// contains filtered or unexported fields
}

func (GetWorkflowsResponse_builder) Build

type Keyspace

type Keyspace struct {
	Cluster  *Cluster               `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	Keyspace *dev2.Keyspace         `protobuf:"bytes,2,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	Shards   map[string]*dev2.Shard `` /* 139-byte string literal not displayed */
	// contains filtered or unexported fields
}

Keyspace represents information about a keyspace in a particular Vitess cluster.

func (*Keyspace) ClearCluster

func (x *Keyspace) ClearCluster()

func (*Keyspace) ClearKeyspace

func (x *Keyspace) ClearKeyspace()

func (*Keyspace) GetCluster

func (x *Keyspace) GetCluster() *Cluster

func (*Keyspace) GetKeyspace

func (x *Keyspace) GetKeyspace() *dev2.Keyspace

func (*Keyspace) GetShards

func (x *Keyspace) GetShards() map[string]*dev2.Shard

func (*Keyspace) HasCluster

func (x *Keyspace) HasCluster() bool

func (*Keyspace) HasKeyspace

func (x *Keyspace) HasKeyspace() 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) SetCluster

func (x *Keyspace) SetCluster(v *Cluster)

func (*Keyspace) SetKeyspace

func (x *Keyspace) SetKeyspace(v *dev2.Keyspace)

func (*Keyspace) SetShards

func (x *Keyspace) SetShards(v map[string]*dev2.Shard)

func (*Keyspace) String

func (x *Keyspace) String() string

type Keyspace_builder

type Keyspace_builder struct {
	Cluster  *Cluster
	Keyspace *dev2.Keyspace
	Shards   map[string]*dev2.Shard
	// contains filtered or unexported fields
}

func (Keyspace_builder) Build

func (b0 Keyspace_builder) Build() *Keyspace

type LaunchSchemaMigrationRequest

type LaunchSchemaMigrationRequest struct {
	ClusterId string                             `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Request   *dev2.LaunchSchemaMigrationRequest `protobuf:"bytes,2,opt,name=request,proto3" json:"request,omitempty"`
	// contains filtered or unexported fields
}

func (*LaunchSchemaMigrationRequest) ClearRequest

func (x *LaunchSchemaMigrationRequest) ClearRequest()

func (*LaunchSchemaMigrationRequest) GetClusterId

func (x *LaunchSchemaMigrationRequest) GetClusterId() string

func (*LaunchSchemaMigrationRequest) GetRequest

func (*LaunchSchemaMigrationRequest) HasRequest

func (x *LaunchSchemaMigrationRequest) HasRequest() bool

func (*LaunchSchemaMigrationRequest) ProtoMessage

func (*LaunchSchemaMigrationRequest) ProtoMessage()

func (*LaunchSchemaMigrationRequest) ProtoReflect

func (*LaunchSchemaMigrationRequest) Reset

func (x *LaunchSchemaMigrationRequest) Reset()

func (*LaunchSchemaMigrationRequest) SetClusterId

func (x *LaunchSchemaMigrationRequest) SetClusterId(v string)

func (*LaunchSchemaMigrationRequest) SetRequest

func (*LaunchSchemaMigrationRequest) String

type LaunchSchemaMigrationRequest_builder

type LaunchSchemaMigrationRequest_builder struct {
	ClusterId string
	Request   *dev2.LaunchSchemaMigrationRequest
	// contains filtered or unexported fields
}

func (LaunchSchemaMigrationRequest_builder) Build

type MaterializeCreateRequest

type MaterializeCreateRequest struct {
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// TableSettings is a JSON string defining what tables to materialize using
	// what select statements.
	TableSettings string                         `protobuf:"bytes,2,opt,name=table_settings,json=tableSettings,proto3" json:"table_settings,omitempty"`
	Request       *dev2.MaterializeCreateRequest `protobuf:"bytes,3,opt,name=request,proto3" json:"request,omitempty"`
	// contains filtered or unexported fields
}

func (*MaterializeCreateRequest) ClearRequest

func (x *MaterializeCreateRequest) ClearRequest()

func (*MaterializeCreateRequest) GetClusterId

func (x *MaterializeCreateRequest) GetClusterId() string

func (*MaterializeCreateRequest) GetRequest

func (*MaterializeCreateRequest) GetTableSettings

func (x *MaterializeCreateRequest) GetTableSettings() string

func (*MaterializeCreateRequest) HasRequest

func (x *MaterializeCreateRequest) HasRequest() bool

func (*MaterializeCreateRequest) ProtoMessage

func (*MaterializeCreateRequest) ProtoMessage()

func (*MaterializeCreateRequest) ProtoReflect

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

func (*MaterializeCreateRequest) Reset

func (x *MaterializeCreateRequest) Reset()

func (*MaterializeCreateRequest) SetClusterId

func (x *MaterializeCreateRequest) SetClusterId(v string)

func (*MaterializeCreateRequest) SetRequest

func (*MaterializeCreateRequest) SetTableSettings

func (x *MaterializeCreateRequest) SetTableSettings(v string)

func (*MaterializeCreateRequest) String

func (x *MaterializeCreateRequest) String() string

type MaterializeCreateRequest_builder

type MaterializeCreateRequest_builder struct {
	ClusterId string
	// TableSettings is a JSON string defining what tables to materialize using
	// what select statements.
	TableSettings string
	Request       *dev2.MaterializeCreateRequest
	// contains filtered or unexported fields
}

func (MaterializeCreateRequest_builder) Build

type MoveTablesCompleteRequest

type MoveTablesCompleteRequest struct {
	ClusterId string                          `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Request   *dev2.MoveTablesCompleteRequest `protobuf:"bytes,2,opt,name=request,proto3" json:"request,omitempty"`
	// contains filtered or unexported fields
}

func (*MoveTablesCompleteRequest) ClearRequest

func (x *MoveTablesCompleteRequest) ClearRequest()

func (*MoveTablesCompleteRequest) GetClusterId

func (x *MoveTablesCompleteRequest) GetClusterId() string

func (*MoveTablesCompleteRequest) GetRequest

func (*MoveTablesCompleteRequest) HasRequest

func (x *MoveTablesCompleteRequest) HasRequest() bool

func (*MoveTablesCompleteRequest) ProtoMessage

func (*MoveTablesCompleteRequest) ProtoMessage()

func (*MoveTablesCompleteRequest) ProtoReflect

func (*MoveTablesCompleteRequest) Reset

func (x *MoveTablesCompleteRequest) Reset()

func (*MoveTablesCompleteRequest) SetClusterId

func (x *MoveTablesCompleteRequest) SetClusterId(v string)

func (*MoveTablesCompleteRequest) SetRequest

func (*MoveTablesCompleteRequest) String

func (x *MoveTablesCompleteRequest) String() string

type MoveTablesCompleteRequest_builder

type MoveTablesCompleteRequest_builder struct {
	ClusterId string
	Request   *dev2.MoveTablesCompleteRequest
	// contains filtered or unexported fields
}

func (MoveTablesCompleteRequest_builder) Build

type MoveTablesCreateRequest

type MoveTablesCreateRequest struct {
	ClusterId string                        `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Request   *dev2.MoveTablesCreateRequest `protobuf:"bytes,2,opt,name=request,proto3" json:"request,omitempty"`
	// contains filtered or unexported fields
}

func (*MoveTablesCreateRequest) ClearRequest

func (x *MoveTablesCreateRequest) ClearRequest()

func (*MoveTablesCreateRequest) GetClusterId

func (x *MoveTablesCreateRequest) GetClusterId() string

func (*MoveTablesCreateRequest) GetRequest

func (*MoveTablesCreateRequest) HasRequest

func (x *MoveTablesCreateRequest) HasRequest() bool

func (*MoveTablesCreateRequest) ProtoMessage

func (*MoveTablesCreateRequest) ProtoMessage()

func (*MoveTablesCreateRequest) ProtoReflect

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

func (*MoveTablesCreateRequest) Reset

func (x *MoveTablesCreateRequest) Reset()

func (*MoveTablesCreateRequest) SetClusterId

func (x *MoveTablesCreateRequest) SetClusterId(v string)

func (*MoveTablesCreateRequest) SetRequest

func (*MoveTablesCreateRequest) String

func (x *MoveTablesCreateRequest) String() string

type MoveTablesCreateRequest_builder

type MoveTablesCreateRequest_builder struct {
	ClusterId string
	Request   *dev2.MoveTablesCreateRequest
	// contains filtered or unexported fields
}

func (MoveTablesCreateRequest_builder) Build

type PingTabletRequest

type PingTabletRequest struct {

	// Unique (per cluster) tablet alias of the standard form: "$cell-$uid"
	Alias *dev1.TabletAlias `protobuf:"bytes,1,opt,name=alias,proto3" json:"alias,omitempty"`
	// ClusterIDs is an optional parameter to narrow the scope of the search, if
	// the caller knows which cluster the tablet may be in, or, to disambiguate
	// if multiple clusters have a tablet with the same hostname.
	ClusterIds []string `protobuf:"bytes,2,rep,name=cluster_ids,json=clusterIds,proto3" json:"cluster_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*PingTabletRequest) ClearAlias

func (x *PingTabletRequest) ClearAlias()

func (*PingTabletRequest) GetAlias

func (x *PingTabletRequest) GetAlias() *dev1.TabletAlias

func (*PingTabletRequest) GetClusterIds

func (x *PingTabletRequest) GetClusterIds() []string

func (*PingTabletRequest) HasAlias

func (x *PingTabletRequest) HasAlias() bool

func (*PingTabletRequest) ProtoMessage

func (*PingTabletRequest) ProtoMessage()

func (*PingTabletRequest) ProtoReflect

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

func (*PingTabletRequest) Reset

func (x *PingTabletRequest) Reset()

func (*PingTabletRequest) SetAlias

func (x *PingTabletRequest) SetAlias(v *dev1.TabletAlias)

func (*PingTabletRequest) SetClusterIds

func (x *PingTabletRequest) SetClusterIds(v []string)

func (*PingTabletRequest) String

func (x *PingTabletRequest) String() string

type PingTabletRequest_builder

type PingTabletRequest_builder struct {

	// Unique (per cluster) tablet alias of the standard form: "$cell-$uid"
	Alias *dev1.TabletAlias
	// ClusterIDs is an optional parameter to narrow the scope of the search, if
	// the caller knows which cluster the tablet may be in, or, to disambiguate
	// if multiple clusters have a tablet with the same hostname.
	ClusterIds []string
	// contains filtered or unexported fields
}

func (PingTabletRequest_builder) Build

type PingTabletResponse

type PingTabletResponse struct {
	Status  string   `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Cluster *Cluster `protobuf:"bytes,2,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// contains filtered or unexported fields
}

func (*PingTabletResponse) ClearCluster

func (x *PingTabletResponse) ClearCluster()

func (*PingTabletResponse) GetCluster

func (x *PingTabletResponse) GetCluster() *Cluster

func (*PingTabletResponse) GetStatus

func (x *PingTabletResponse) GetStatus() string

func (*PingTabletResponse) HasCluster

func (x *PingTabletResponse) HasCluster() bool

func (*PingTabletResponse) ProtoMessage

func (*PingTabletResponse) ProtoMessage()

func (*PingTabletResponse) ProtoReflect

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

func (*PingTabletResponse) Reset

func (x *PingTabletResponse) Reset()

func (*PingTabletResponse) SetCluster

func (x *PingTabletResponse) SetCluster(v *Cluster)

func (*PingTabletResponse) SetStatus

func (x *PingTabletResponse) SetStatus(v string)

func (*PingTabletResponse) String

func (x *PingTabletResponse) String() string

type PingTabletResponse_builder

type PingTabletResponse_builder struct {
	Status  string
	Cluster *Cluster
	// contains filtered or unexported fields
}

func (PingTabletResponse_builder) Build

type PlannedFailoverShardRequest

type PlannedFailoverShardRequest struct {
	ClusterId string                            `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Options   *dev2.PlannedReparentShardRequest `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*PlannedFailoverShardRequest) ClearOptions

func (x *PlannedFailoverShardRequest) ClearOptions()

func (*PlannedFailoverShardRequest) GetClusterId

func (x *PlannedFailoverShardRequest) GetClusterId() string

func (*PlannedFailoverShardRequest) GetOptions

func (*PlannedFailoverShardRequest) HasOptions

func (x *PlannedFailoverShardRequest) HasOptions() bool

func (*PlannedFailoverShardRequest) ProtoMessage

func (*PlannedFailoverShardRequest) ProtoMessage()

func (*PlannedFailoverShardRequest) ProtoReflect

func (*PlannedFailoverShardRequest) Reset

func (x *PlannedFailoverShardRequest) Reset()

func (*PlannedFailoverShardRequest) SetClusterId

func (x *PlannedFailoverShardRequest) SetClusterId(v string)

func (*PlannedFailoverShardRequest) SetOptions

func (*PlannedFailoverShardRequest) String

func (x *PlannedFailoverShardRequest) String() string

type PlannedFailoverShardRequest_builder

type PlannedFailoverShardRequest_builder struct {
	ClusterId string
	Options   *dev2.PlannedReparentShardRequest
	// contains filtered or unexported fields
}

func (PlannedFailoverShardRequest_builder) Build

type PlannedFailoverShardResponse

type PlannedFailoverShardResponse struct {
	Cluster  *Cluster `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	Keyspace string   `protobuf:"bytes,2,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	Shard    string   `protobuf:"bytes,3,opt,name=shard,proto3" json:"shard,omitempty"`
	// PromotedPrimary is the tablet alias that was promoted to shard primary.
	// If NewPrimary was set in the request options, then this will be the
	// same tablet alias. Otherwise, it will be the alias of the tablet found
	// to be most up-to-date in the shard.
	PromotedPrimary *dev1.TabletAlias `protobuf:"bytes,4,opt,name=promoted_primary,json=promotedPrimary,proto3" json:"promoted_primary,omitempty"`
	Events          []*dev5.Event     `protobuf:"bytes,5,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

func (*PlannedFailoverShardResponse) ClearCluster

func (x *PlannedFailoverShardResponse) ClearCluster()

func (*PlannedFailoverShardResponse) ClearPromotedPrimary

func (x *PlannedFailoverShardResponse) ClearPromotedPrimary()

func (*PlannedFailoverShardResponse) GetCluster

func (x *PlannedFailoverShardResponse) GetCluster() *Cluster

func (*PlannedFailoverShardResponse) GetEvents

func (x *PlannedFailoverShardResponse) GetEvents() []*dev5.Event

func (*PlannedFailoverShardResponse) GetKeyspace

func (x *PlannedFailoverShardResponse) GetKeyspace() string

func (*PlannedFailoverShardResponse) GetPromotedPrimary

func (x *PlannedFailoverShardResponse) GetPromotedPrimary() *dev1.TabletAlias

func (*PlannedFailoverShardResponse) GetShard

func (x *PlannedFailoverShardResponse) GetShard() string

func (*PlannedFailoverShardResponse) HasCluster

func (x *PlannedFailoverShardResponse) HasCluster() bool

func (*PlannedFailoverShardResponse) HasPromotedPrimary

func (x *PlannedFailoverShardResponse) HasPromotedPrimary() bool

func (*PlannedFailoverShardResponse) ProtoMessage

func (*PlannedFailoverShardResponse) ProtoMessage()

func (*PlannedFailoverShardResponse) ProtoReflect

func (*PlannedFailoverShardResponse) Reset

func (x *PlannedFailoverShardResponse) Reset()

func (*PlannedFailoverShardResponse) SetCluster

func (x *PlannedFailoverShardResponse) SetCluster(v *Cluster)

func (*PlannedFailoverShardResponse) SetEvents

func (x *PlannedFailoverShardResponse) SetEvents(v []*dev5.Event)

func (*PlannedFailoverShardResponse) SetKeyspace

func (x *PlannedFailoverShardResponse) SetKeyspace(v string)

func (*PlannedFailoverShardResponse) SetPromotedPrimary

func (x *PlannedFailoverShardResponse) SetPromotedPrimary(v *dev1.TabletAlias)

func (*PlannedFailoverShardResponse) SetShard

func (x *PlannedFailoverShardResponse) SetShard(v string)

func (*PlannedFailoverShardResponse) String

type PlannedFailoverShardResponse_builder

type PlannedFailoverShardResponse_builder struct {
	Cluster  *Cluster
	Keyspace string
	Shard    string
	// PromotedPrimary is the tablet alias that was promoted to shard primary.
	// If NewPrimary was set in the request options, then this will be the
	// same tablet alias. Otherwise, it will be the alias of the tablet found
	// to be most up-to-date in the shard.
	PromotedPrimary *dev1.TabletAlias
	Events          []*dev5.Event
	// contains filtered or unexported fields
}

func (PlannedFailoverShardResponse_builder) Build

type RebuildKeyspaceGraphRequest

type RebuildKeyspaceGraphRequest struct {
	ClusterId    string   `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Keyspace     string   `protobuf:"bytes,2,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	Cells        []string `protobuf:"bytes,3,rep,name=cells,proto3" json:"cells,omitempty"`
	AllowPartial bool     `protobuf:"varint,4,opt,name=allow_partial,json=allowPartial,proto3" json:"allow_partial,omitempty"`
	// contains filtered or unexported fields
}

func (*RebuildKeyspaceGraphRequest) GetAllowPartial

func (x *RebuildKeyspaceGraphRequest) GetAllowPartial() bool

func (*RebuildKeyspaceGraphRequest) GetCells

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

func (*RebuildKeyspaceGraphRequest) GetClusterId

func (x *RebuildKeyspaceGraphRequest) GetClusterId() string

func (*RebuildKeyspaceGraphRequest) GetKeyspace

func (x *RebuildKeyspaceGraphRequest) GetKeyspace() string

func (*RebuildKeyspaceGraphRequest) ProtoMessage

func (*RebuildKeyspaceGraphRequest) ProtoMessage()

func (*RebuildKeyspaceGraphRequest) ProtoReflect

func (*RebuildKeyspaceGraphRequest) Reset

func (x *RebuildKeyspaceGraphRequest) Reset()

func (*RebuildKeyspaceGraphRequest) SetAllowPartial

func (x *RebuildKeyspaceGraphRequest) SetAllowPartial(v bool)

func (*RebuildKeyspaceGraphRequest) SetCells

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

func (*RebuildKeyspaceGraphRequest) SetClusterId

func (x *RebuildKeyspaceGraphRequest) SetClusterId(v string)

func (*RebuildKeyspaceGraphRequest) SetKeyspace

func (x *RebuildKeyspaceGraphRequest) SetKeyspace(v string)

func (*RebuildKeyspaceGraphRequest) String

func (x *RebuildKeyspaceGraphRequest) String() string

type RebuildKeyspaceGraphRequest_builder

type RebuildKeyspaceGraphRequest_builder struct {
	ClusterId    string
	Keyspace     string
	Cells        []string
	AllowPartial bool
	// contains filtered or unexported fields
}

func (RebuildKeyspaceGraphRequest_builder) Build

type RebuildKeyspaceGraphResponse

type RebuildKeyspaceGraphResponse struct {
	Status string `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*RebuildKeyspaceGraphResponse) GetStatus

func (x *RebuildKeyspaceGraphResponse) GetStatus() string

func (*RebuildKeyspaceGraphResponse) ProtoMessage

func (*RebuildKeyspaceGraphResponse) ProtoMessage()

func (*RebuildKeyspaceGraphResponse) ProtoReflect

func (*RebuildKeyspaceGraphResponse) Reset

func (x *RebuildKeyspaceGraphResponse) Reset()

func (*RebuildKeyspaceGraphResponse) SetStatus

func (x *RebuildKeyspaceGraphResponse) SetStatus(v string)

func (*RebuildKeyspaceGraphResponse) String

type RebuildKeyspaceGraphResponse_builder

type RebuildKeyspaceGraphResponse_builder struct {
	Status string
	// contains filtered or unexported fields
}

func (RebuildKeyspaceGraphResponse_builder) Build

type RefreshStateRequest

type RefreshStateRequest struct {
	Alias      *dev1.TabletAlias `protobuf:"bytes,1,opt,name=alias,proto3" json:"alias,omitempty"`
	ClusterIds []string          `protobuf:"bytes,2,rep,name=cluster_ids,json=clusterIds,proto3" json:"cluster_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*RefreshStateRequest) ClearAlias

func (x *RefreshStateRequest) ClearAlias()

func (*RefreshStateRequest) GetAlias

func (x *RefreshStateRequest) GetAlias() *dev1.TabletAlias

func (*RefreshStateRequest) GetClusterIds

func (x *RefreshStateRequest) GetClusterIds() []string

func (*RefreshStateRequest) HasAlias

func (x *RefreshStateRequest) HasAlias() bool

func (*RefreshStateRequest) ProtoMessage

func (*RefreshStateRequest) ProtoMessage()

func (*RefreshStateRequest) ProtoReflect

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

func (*RefreshStateRequest) Reset

func (x *RefreshStateRequest) Reset()

func (*RefreshStateRequest) SetAlias

func (x *RefreshStateRequest) SetAlias(v *dev1.TabletAlias)

func (*RefreshStateRequest) SetClusterIds

func (x *RefreshStateRequest) SetClusterIds(v []string)

func (*RefreshStateRequest) String

func (x *RefreshStateRequest) String() string

type RefreshStateRequest_builder

type RefreshStateRequest_builder struct {
	Alias      *dev1.TabletAlias
	ClusterIds []string
	// contains filtered or unexported fields
}

func (RefreshStateRequest_builder) Build

type RefreshStateResponse

type RefreshStateResponse struct {
	Status  string   `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Cluster *Cluster `protobuf:"bytes,2,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// contains filtered or unexported fields
}

func (*RefreshStateResponse) ClearCluster

func (x *RefreshStateResponse) ClearCluster()

func (*RefreshStateResponse) GetCluster

func (x *RefreshStateResponse) GetCluster() *Cluster

func (*RefreshStateResponse) GetStatus

func (x *RefreshStateResponse) GetStatus() string

func (*RefreshStateResponse) HasCluster

func (x *RefreshStateResponse) HasCluster() bool

func (*RefreshStateResponse) ProtoMessage

func (*RefreshStateResponse) ProtoMessage()

func (*RefreshStateResponse) ProtoReflect

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

func (*RefreshStateResponse) Reset

func (x *RefreshStateResponse) Reset()

func (*RefreshStateResponse) SetCluster

func (x *RefreshStateResponse) SetCluster(v *Cluster)

func (*RefreshStateResponse) SetStatus

func (x *RefreshStateResponse) SetStatus(v string)

func (*RefreshStateResponse) String

func (x *RefreshStateResponse) String() string

type RefreshStateResponse_builder

type RefreshStateResponse_builder struct {
	Status  string
	Cluster *Cluster
	// contains filtered or unexported fields
}

func (RefreshStateResponse_builder) Build

type RefreshTabletReplicationSourceRequest

type RefreshTabletReplicationSourceRequest struct {
	Alias      *dev1.TabletAlias `protobuf:"bytes,1,opt,name=alias,proto3" json:"alias,omitempty"`
	ClusterIds []string          `protobuf:"bytes,2,rep,name=cluster_ids,json=clusterIds,proto3" json:"cluster_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*RefreshTabletReplicationSourceRequest) ClearAlias

func (x *RefreshTabletReplicationSourceRequest) ClearAlias()

func (*RefreshTabletReplicationSourceRequest) GetAlias

func (*RefreshTabletReplicationSourceRequest) GetClusterIds

func (x *RefreshTabletReplicationSourceRequest) GetClusterIds() []string

func (*RefreshTabletReplicationSourceRequest) HasAlias

func (*RefreshTabletReplicationSourceRequest) ProtoMessage

func (*RefreshTabletReplicationSourceRequest) ProtoMessage()

func (*RefreshTabletReplicationSourceRequest) ProtoReflect

func (*RefreshTabletReplicationSourceRequest) Reset

func (*RefreshTabletReplicationSourceRequest) SetAlias

func (*RefreshTabletReplicationSourceRequest) SetClusterIds

func (x *RefreshTabletReplicationSourceRequest) SetClusterIds(v []string)

func (*RefreshTabletReplicationSourceRequest) String

type RefreshTabletReplicationSourceRequest_builder

type RefreshTabletReplicationSourceRequest_builder struct {
	Alias      *dev1.TabletAlias
	ClusterIds []string
	// contains filtered or unexported fields
}

func (RefreshTabletReplicationSourceRequest_builder) Build

type RefreshTabletReplicationSourceResponse

type RefreshTabletReplicationSourceResponse struct {
	Keyspace string            `protobuf:"bytes,1,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	Shard    string            `protobuf:"bytes,2,opt,name=shard,proto3" json:"shard,omitempty"`
	Primary  *dev1.TabletAlias `protobuf:"bytes,3,opt,name=primary,proto3" json:"primary,omitempty"`
	Cluster  *Cluster          `protobuf:"bytes,4,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// contains filtered or unexported fields
}

func (*RefreshTabletReplicationSourceResponse) ClearCluster

func (x *RefreshTabletReplicationSourceResponse) ClearCluster()

func (*RefreshTabletReplicationSourceResponse) ClearPrimary

func (x *RefreshTabletReplicationSourceResponse) ClearPrimary()

func (*RefreshTabletReplicationSourceResponse) GetCluster

func (*RefreshTabletReplicationSourceResponse) GetKeyspace

func (*RefreshTabletReplicationSourceResponse) GetPrimary

func (*RefreshTabletReplicationSourceResponse) GetShard

func (*RefreshTabletReplicationSourceResponse) HasCluster

func (*RefreshTabletReplicationSourceResponse) HasPrimary

func (*RefreshTabletReplicationSourceResponse) ProtoMessage

func (*RefreshTabletReplicationSourceResponse) ProtoReflect

func (*RefreshTabletReplicationSourceResponse) Reset

func (*RefreshTabletReplicationSourceResponse) SetCluster

func (*RefreshTabletReplicationSourceResponse) SetKeyspace

func (*RefreshTabletReplicationSourceResponse) SetPrimary

func (*RefreshTabletReplicationSourceResponse) SetShard

func (*RefreshTabletReplicationSourceResponse) String

type RefreshTabletReplicationSourceResponse_builder

type RefreshTabletReplicationSourceResponse_builder struct {
	Keyspace string
	Shard    string
	Primary  *dev1.TabletAlias
	Cluster  *Cluster
	// contains filtered or unexported fields
}

func (RefreshTabletReplicationSourceResponse_builder) Build

type ReloadSchemaShardRequest

type ReloadSchemaShardRequest struct {
	ClusterId      string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Keyspace       string `protobuf:"bytes,2,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	Shard          string `protobuf:"bytes,3,opt,name=shard,proto3" json:"shard,omitempty"`
	WaitPosition   string `protobuf:"bytes,4,opt,name=wait_position,json=waitPosition,proto3" json:"wait_position,omitempty"`
	IncludePrimary bool   `protobuf:"varint,5,opt,name=include_primary,json=includePrimary,proto3" json:"include_primary,omitempty"`
	Concurrency    int32  `protobuf:"varint,6,opt,name=concurrency,proto3" json:"concurrency,omitempty"`
	// contains filtered or unexported fields
}

func (*ReloadSchemaShardRequest) GetClusterId

func (x *ReloadSchemaShardRequest) GetClusterId() string

func (*ReloadSchemaShardRequest) GetConcurrency

func (x *ReloadSchemaShardRequest) GetConcurrency() int32

func (*ReloadSchemaShardRequest) GetIncludePrimary

func (x *ReloadSchemaShardRequest) GetIncludePrimary() bool

func (*ReloadSchemaShardRequest) GetKeyspace

func (x *ReloadSchemaShardRequest) GetKeyspace() string

func (*ReloadSchemaShardRequest) GetShard

func (x *ReloadSchemaShardRequest) GetShard() string

func (*ReloadSchemaShardRequest) GetWaitPosition

func (x *ReloadSchemaShardRequest) GetWaitPosition() string

func (*ReloadSchemaShardRequest) ProtoMessage

func (*ReloadSchemaShardRequest) ProtoMessage()

func (*ReloadSchemaShardRequest) ProtoReflect

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

func (*ReloadSchemaShardRequest) Reset

func (x *ReloadSchemaShardRequest) Reset()

func (*ReloadSchemaShardRequest) SetClusterId

func (x *ReloadSchemaShardRequest) SetClusterId(v string)

func (*ReloadSchemaShardRequest) SetConcurrency

func (x *ReloadSchemaShardRequest) SetConcurrency(v int32)

func (*ReloadSchemaShardRequest) SetIncludePrimary

func (x *ReloadSchemaShardRequest) SetIncludePrimary(v bool)

func (*ReloadSchemaShardRequest) SetKeyspace

func (x *ReloadSchemaShardRequest) SetKeyspace(v string)

func (*ReloadSchemaShardRequest) SetShard

func (x *ReloadSchemaShardRequest) SetShard(v string)

func (*ReloadSchemaShardRequest) SetWaitPosition

func (x *ReloadSchemaShardRequest) SetWaitPosition(v string)

func (*ReloadSchemaShardRequest) String

func (x *ReloadSchemaShardRequest) String() string

type ReloadSchemaShardRequest_builder

type ReloadSchemaShardRequest_builder struct {
	ClusterId      string
	Keyspace       string
	Shard          string
	WaitPosition   string
	IncludePrimary bool
	Concurrency    int32
	// contains filtered or unexported fields
}

func (ReloadSchemaShardRequest_builder) Build

type ReloadSchemaShardResponse

type ReloadSchemaShardResponse struct {
	Events []*dev5.Event `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

func (*ReloadSchemaShardResponse) GetEvents

func (x *ReloadSchemaShardResponse) GetEvents() []*dev5.Event

func (*ReloadSchemaShardResponse) ProtoMessage

func (*ReloadSchemaShardResponse) ProtoMessage()

func (*ReloadSchemaShardResponse) ProtoReflect

func (*ReloadSchemaShardResponse) Reset

func (x *ReloadSchemaShardResponse) Reset()

func (*ReloadSchemaShardResponse) SetEvents

func (x *ReloadSchemaShardResponse) SetEvents(v []*dev5.Event)

func (*ReloadSchemaShardResponse) String

func (x *ReloadSchemaShardResponse) String() string

type ReloadSchemaShardResponse_builder

type ReloadSchemaShardResponse_builder struct {
	Events []*dev5.Event
	// contains filtered or unexported fields
}

func (ReloadSchemaShardResponse_builder) Build

type ReloadSchemasRequest

type ReloadSchemasRequest struct {

	// Keyspaces, if set, will reload schemas across one or more keyspaces. A
	// keyspace not existing in a cluster will not fail the overall request.
	//
	// Superceded by KeyspaceShards and Tablets, in that order.
	Keyspaces []string `protobuf:"bytes,1,rep,name=keyspaces,proto3" json:"keyspaces,omitempty"`
	// KeyspaceShards, if set, will reload schemas across one or more shards.
	// Each element must be a valid keyspace/shard according to
	// topoproto.ParseKeyspaceShard. A shard not existing in a cluster will not
	// fail the overall request.
	//
	// Supercedes Keyspaces, and is superceded by Tablets.
	KeyspaceShards []string `protobuf:"bytes,2,rep,name=keyspace_shards,json=keyspaceShards,proto3" json:"keyspace_shards,omitempty"`
	// Tablets, if set will reload schemas across one or more tablets.
	// Supercedes both Keyspaces and KeyspaceShards.
	Tablets []*dev1.TabletAlias `protobuf:"bytes,3,rep,name=tablets,proto3" json:"tablets,omitempty"`
	// ClusterIds optionally restricts the reload operation to clusters with
	// the specified IDs. An empty list of ClusterIds will operate on all
	// clusters.
	ClusterIds []string `protobuf:"bytes,4,rep,name=cluster_ids,json=clusterIds,proto3" json:"cluster_ids,omitempty"`
	// Concurrency controls the number of tablets to reload at any given time.
	// Its semantics depend on whether the request is for keyspace, shard, or
	// tablet mode.
	//
	// In Keyspaces mode, Concurrency is the number of tablets to reload at once
	// *per keyspace*.
	//
	// In KeyspaceShards mode, Concurrency is the number of tablets to reload at
	// once *per shard*.
	//
	// In Tablets mode, Concurrency is the number of tablets to reload at once
	// *per cluster*.
	Concurrency int32 `protobuf:"varint,5,opt,name=concurrency,proto3" json:"concurrency,omitempty"`
	// WaitPosition is the replication position that replicating tablets should
	// reach prior to reloading their schemas.
	//
	// Does not apply in Tablets mode.
	WaitPosition string `protobuf:"bytes,6,opt,name=wait_position,json=waitPosition,proto3" json:"wait_position,omitempty"`
	// IncludePrimary, if set, will reload the schemas on PRIMARY tablets as
	// well as REPLICA and RDONLY.
	//
	// Does not apply in Tablets mode.
	IncludePrimary bool `protobuf:"varint,7,opt,name=include_primary,json=includePrimary,proto3" json:"include_primary,omitempty"`
	// contains filtered or unexported fields
}

func (*ReloadSchemasRequest) GetClusterIds

func (x *ReloadSchemasRequest) GetClusterIds() []string

func (*ReloadSchemasRequest) GetConcurrency

func (x *ReloadSchemasRequest) GetConcurrency() int32

func (*ReloadSchemasRequest) GetIncludePrimary

func (x *ReloadSchemasRequest) GetIncludePrimary() bool

func (*ReloadSchemasRequest) GetKeyspaceShards

func (x *ReloadSchemasRequest) GetKeyspaceShards() []string

func (*ReloadSchemasRequest) GetKeyspaces

func (x *ReloadSchemasRequest) GetKeyspaces() []string

func (*ReloadSchemasRequest) GetTablets

func (x *ReloadSchemasRequest) GetTablets() []*dev1.TabletAlias

func (*ReloadSchemasRequest) GetWaitPosition

func (x *ReloadSchemasRequest) GetWaitPosition() string

func (*ReloadSchemasRequest) ProtoMessage

func (*ReloadSchemasRequest) ProtoMessage()

func (*ReloadSchemasRequest) ProtoReflect

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

func (*ReloadSchemasRequest) Reset

func (x *ReloadSchemasRequest) Reset()

func (*ReloadSchemasRequest) SetClusterIds

func (x *ReloadSchemasRequest) SetClusterIds(v []string)

func (*ReloadSchemasRequest) SetConcurrency

func (x *ReloadSchemasRequest) SetConcurrency(v int32)

func (*ReloadSchemasRequest) SetIncludePrimary

func (x *ReloadSchemasRequest) SetIncludePrimary(v bool)

func (*ReloadSchemasRequest) SetKeyspaceShards

func (x *ReloadSchemasRequest) SetKeyspaceShards(v []string)

func (*ReloadSchemasRequest) SetKeyspaces

func (x *ReloadSchemasRequest) SetKeyspaces(v []string)

func (*ReloadSchemasRequest) SetTablets

func (x *ReloadSchemasRequest) SetTablets(v []*dev1.TabletAlias)

func (*ReloadSchemasRequest) SetWaitPosition

func (x *ReloadSchemasRequest) SetWaitPosition(v string)

func (*ReloadSchemasRequest) String

func (x *ReloadSchemasRequest) String() string

type ReloadSchemasRequest_builder

type ReloadSchemasRequest_builder struct {

	// Keyspaces, if set, will reload schemas across one or more keyspaces. A
	// keyspace not existing in a cluster will not fail the overall request.
	//
	// Superceded by KeyspaceShards and Tablets, in that order.
	Keyspaces []string
	// KeyspaceShards, if set, will reload schemas across one or more shards.
	// Each element must be a valid keyspace/shard according to
	// topoproto.ParseKeyspaceShard. A shard not existing in a cluster will not
	// fail the overall request.
	//
	// Supercedes Keyspaces, and is superceded by Tablets.
	KeyspaceShards []string
	// Tablets, if set will reload schemas across one or more tablets.
	// Supercedes both Keyspaces and KeyspaceShards.
	Tablets []*dev1.TabletAlias
	// ClusterIds optionally restricts the reload operation to clusters with
	// the specified IDs. An empty list of ClusterIds will operate on all
	// clusters.
	ClusterIds []string
	// Concurrency controls the number of tablets to reload at any given time.
	// Its semantics depend on whether the request is for keyspace, shard, or
	// tablet mode.
	//
	// In Keyspaces mode, Concurrency is the number of tablets to reload at once
	// *per keyspace*.
	//
	// In KeyspaceShards mode, Concurrency is the number of tablets to reload at
	// once *per shard*.
	//
	// In Tablets mode, Concurrency is the number of tablets to reload at once
	// *per cluster*.
	Concurrency int32
	// WaitPosition is the replication position that replicating tablets should
	// reach prior to reloading their schemas.
	//
	// Does not apply in Tablets mode.
	WaitPosition string
	// IncludePrimary, if set, will reload the schemas on PRIMARY tablets as
	// well as REPLICA and RDONLY.
	//
	// Does not apply in Tablets mode.
	IncludePrimary bool
	// contains filtered or unexported fields
}

func (ReloadSchemasRequest_builder) Build

type ReloadSchemasResponse

type ReloadSchemasResponse struct {

	// KeyspaceResults is the list of KeyspaceResult objects for a ReloadSchemas
	// operation. It is only set when the request mandates Keyspaces mode (see
	// ReloadSchemasRequest).
	KeyspaceResults []*ReloadSchemasResponse_KeyspaceResult `protobuf:"bytes,1,rep,name=keyspace_results,json=keyspaceResults,proto3" json:"keyspace_results,omitempty"`
	// ShardResults is the list of ShardResult objects for a ReloadSchemas
	// operation. It is only set when the request mandates KeyspaceShards mode
	// (see ReloadSchemasRequest).
	ShardResults []*ReloadSchemasResponse_ShardResult `protobuf:"bytes,2,rep,name=shard_results,json=shardResults,proto3" json:"shard_results,omitempty"`
	// TabletResults is the list of TabletResult objects for a ReloadSchemas
	// operation. It is only set when the request mandates Tablets mode (see
	// ReloadSchemasRequest).
	TabletResults []*ReloadSchemasResponse_TabletResult `protobuf:"bytes,3,rep,name=tablet_results,json=tabletResults,proto3" json:"tablet_results,omitempty"`
	// contains filtered or unexported fields
}

func (*ReloadSchemasResponse) GetKeyspaceResults

func (*ReloadSchemasResponse) GetShardResults

func (*ReloadSchemasResponse) GetTabletResults

func (*ReloadSchemasResponse) ProtoMessage

func (*ReloadSchemasResponse) ProtoMessage()

func (*ReloadSchemasResponse) ProtoReflect

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

func (*ReloadSchemasResponse) Reset

func (x *ReloadSchemasResponse) Reset()

func (*ReloadSchemasResponse) SetKeyspaceResults

func (x *ReloadSchemasResponse) SetKeyspaceResults(v []*ReloadSchemasResponse_KeyspaceResult)

func (*ReloadSchemasResponse) SetShardResults

func (*ReloadSchemasResponse) SetTabletResults

func (*ReloadSchemasResponse) String

func (x *ReloadSchemasResponse) String() string

type ReloadSchemasResponse_KeyspaceResult

type ReloadSchemasResponse_KeyspaceResult struct {
	Keyspace *Keyspace     `protobuf:"bytes,1,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	Events   []*dev5.Event `protobuf:"bytes,2,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

KeyspaceResult is a grouping of a Keyspace and any log events that occurred in that keyspace during a schema reload (usually associated with partial errors - ReloadSchemas requests are best-effort).

It is only set when a ReloadSchemas request mandates Keyspaces mode (see ReloadSchemasRequest).

func (*ReloadSchemasResponse_KeyspaceResult) ClearKeyspace

func (x *ReloadSchemasResponse_KeyspaceResult) ClearKeyspace()

func (*ReloadSchemasResponse_KeyspaceResult) GetEvents

func (*ReloadSchemasResponse_KeyspaceResult) GetKeyspace

func (*ReloadSchemasResponse_KeyspaceResult) HasKeyspace

func (x *ReloadSchemasResponse_KeyspaceResult) HasKeyspace() bool

func (*ReloadSchemasResponse_KeyspaceResult) ProtoMessage

func (*ReloadSchemasResponse_KeyspaceResult) ProtoMessage()

func (*ReloadSchemasResponse_KeyspaceResult) ProtoReflect

func (*ReloadSchemasResponse_KeyspaceResult) Reset

func (*ReloadSchemasResponse_KeyspaceResult) SetEvents

func (x *ReloadSchemasResponse_KeyspaceResult) SetEvents(v []*dev5.Event)

func (*ReloadSchemasResponse_KeyspaceResult) SetKeyspace

func (*ReloadSchemasResponse_KeyspaceResult) String

type ReloadSchemasResponse_KeyspaceResult_builder

type ReloadSchemasResponse_KeyspaceResult_builder struct {
	Keyspace *Keyspace
	Events   []*dev5.Event
	// contains filtered or unexported fields
}

func (ReloadSchemasResponse_KeyspaceResult_builder) Build

type ReloadSchemasResponse_ShardResult

type ReloadSchemasResponse_ShardResult struct {
	Shard  *Shard        `protobuf:"bytes,1,opt,name=shard,proto3" json:"shard,omitempty"`
	Events []*dev5.Event `protobuf:"bytes,2,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

ShardResult is a grouping of a Shard and any log events that occurred in that shard during a schema reload (usually associated with partial errors - ReloadSchemas requests are best-effort).

It is only set when a ReloadSchemas request mandates KeyspaceShards mode (see ReloadSchemasRequest).

func (*ReloadSchemasResponse_ShardResult) ClearShard

func (x *ReloadSchemasResponse_ShardResult) ClearShard()

func (*ReloadSchemasResponse_ShardResult) GetEvents

func (x *ReloadSchemasResponse_ShardResult) GetEvents() []*dev5.Event

func (*ReloadSchemasResponse_ShardResult) GetShard

func (*ReloadSchemasResponse_ShardResult) HasShard

func (*ReloadSchemasResponse_ShardResult) ProtoMessage

func (*ReloadSchemasResponse_ShardResult) ProtoMessage()

func (*ReloadSchemasResponse_ShardResult) ProtoReflect

func (*ReloadSchemasResponse_ShardResult) Reset

func (*ReloadSchemasResponse_ShardResult) SetEvents

func (x *ReloadSchemasResponse_ShardResult) SetEvents(v []*dev5.Event)

func (*ReloadSchemasResponse_ShardResult) SetShard

func (x *ReloadSchemasResponse_ShardResult) SetShard(v *Shard)

func (*ReloadSchemasResponse_ShardResult) String

type ReloadSchemasResponse_ShardResult_builder

type ReloadSchemasResponse_ShardResult_builder struct {
	Shard  *Shard
	Events []*dev5.Event
	// contains filtered or unexported fields
}

func (ReloadSchemasResponse_ShardResult_builder) Build

type ReloadSchemasResponse_TabletResult

type ReloadSchemasResponse_TabletResult struct {
	Tablet *Tablet `protobuf:"bytes,1,opt,name=tablet,proto3" json:"tablet,omitempty"`
	Result string  `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

TabletResult is a grouping of a Tablet and the result of reloading that Tablet's schema. Result will either be the string "ok", or the error message from that tablet. Note ReloadSchemas is best-effort, so tablet's failing to reload is not treated as an overall failure.

It is only set when a ReloadSchemas request mandates Tablets mode (see ReloadSchemasRequest).

func (*ReloadSchemasResponse_TabletResult) ClearTablet

func (x *ReloadSchemasResponse_TabletResult) ClearTablet()

func (*ReloadSchemasResponse_TabletResult) GetResult

func (*ReloadSchemasResponse_TabletResult) GetTablet

func (*ReloadSchemasResponse_TabletResult) HasTablet

func (*ReloadSchemasResponse_TabletResult) ProtoMessage

func (*ReloadSchemasResponse_TabletResult) ProtoMessage()

func (*ReloadSchemasResponse_TabletResult) ProtoReflect

func (*ReloadSchemasResponse_TabletResult) Reset

func (*ReloadSchemasResponse_TabletResult) SetResult

func (*ReloadSchemasResponse_TabletResult) SetTablet

func (x *ReloadSchemasResponse_TabletResult) SetTablet(v *Tablet)

func (*ReloadSchemasResponse_TabletResult) String

type ReloadSchemasResponse_TabletResult_builder

type ReloadSchemasResponse_TabletResult_builder struct {
	Tablet *Tablet
	Result string
	// contains filtered or unexported fields
}

func (ReloadSchemasResponse_TabletResult_builder) Build

type ReloadSchemasResponse_builder

type ReloadSchemasResponse_builder struct {

	// KeyspaceResults is the list of KeyspaceResult objects for a ReloadSchemas
	// operation. It is only set when the request mandates Keyspaces mode (see
	// ReloadSchemasRequest).
	KeyspaceResults []*ReloadSchemasResponse_KeyspaceResult
	// ShardResults is the list of ShardResult objects for a ReloadSchemas
	// operation. It is only set when the request mandates KeyspaceShards mode
	// (see ReloadSchemasRequest).
	ShardResults []*ReloadSchemasResponse_ShardResult
	// TabletResults is the list of TabletResult objects for a ReloadSchemas
	// operation. It is only set when the request mandates Tablets mode (see
	// ReloadSchemasRequest).
	TabletResults []*ReloadSchemasResponse_TabletResult
	// contains filtered or unexported fields
}

func (ReloadSchemasResponse_builder) Build

type RemoveKeyspaceCellRequest

type RemoveKeyspaceCellRequest struct {
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Keyspace  string `protobuf:"bytes,2,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	Cell      string `protobuf:"bytes,3,opt,name=cell,proto3" json:"cell,omitempty"`
	Force     bool   `protobuf:"varint,4,opt,name=force,proto3" json:"force,omitempty"`
	Recursive bool   `protobuf:"varint,5,opt,name=recursive,proto3" json:"recursive,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveKeyspaceCellRequest) GetCell

func (x *RemoveKeyspaceCellRequest) GetCell() string

func (*RemoveKeyspaceCellRequest) GetClusterId

func (x *RemoveKeyspaceCellRequest) GetClusterId() string

func (*RemoveKeyspaceCellRequest) GetForce

func (x *RemoveKeyspaceCellRequest) GetForce() bool

func (*RemoveKeyspaceCellRequest) GetKeyspace

func (x *RemoveKeyspaceCellRequest) GetKeyspace() string

func (*RemoveKeyspaceCellRequest) GetRecursive

func (x *RemoveKeyspaceCellRequest) GetRecursive() bool

func (*RemoveKeyspaceCellRequest) ProtoMessage

func (*RemoveKeyspaceCellRequest) ProtoMessage()

func (*RemoveKeyspaceCellRequest) ProtoReflect

func (*RemoveKeyspaceCellRequest) Reset

func (x *RemoveKeyspaceCellRequest) Reset()

func (*RemoveKeyspaceCellRequest) SetCell

func (x *RemoveKeyspaceCellRequest) SetCell(v string)

func (*RemoveKeyspaceCellRequest) SetClusterId

func (x *RemoveKeyspaceCellRequest) SetClusterId(v string)

func (*RemoveKeyspaceCellRequest) SetForce

func (x *RemoveKeyspaceCellRequest) SetForce(v bool)

func (*RemoveKeyspaceCellRequest) SetKeyspace

func (x *RemoveKeyspaceCellRequest) SetKeyspace(v string)

func (*RemoveKeyspaceCellRequest) SetRecursive

func (x *RemoveKeyspaceCellRequest) SetRecursive(v bool)

func (*RemoveKeyspaceCellRequest) String

func (x *RemoveKeyspaceCellRequest) String() string

type RemoveKeyspaceCellRequest_builder

type RemoveKeyspaceCellRequest_builder struct {
	ClusterId string
	Keyspace  string
	Cell      string
	Force     bool
	Recursive bool
	// contains filtered or unexported fields
}

func (RemoveKeyspaceCellRequest_builder) Build

type RemoveKeyspaceCellResponse

type RemoveKeyspaceCellResponse struct {
	Status string `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveKeyspaceCellResponse) GetStatus

func (x *RemoveKeyspaceCellResponse) GetStatus() string

func (*RemoveKeyspaceCellResponse) ProtoMessage

func (*RemoveKeyspaceCellResponse) ProtoMessage()

func (*RemoveKeyspaceCellResponse) ProtoReflect

func (*RemoveKeyspaceCellResponse) Reset

func (x *RemoveKeyspaceCellResponse) Reset()

func (*RemoveKeyspaceCellResponse) SetStatus

func (x *RemoveKeyspaceCellResponse) SetStatus(v string)

func (*RemoveKeyspaceCellResponse) String

func (x *RemoveKeyspaceCellResponse) String() string

type RemoveKeyspaceCellResponse_builder

type RemoveKeyspaceCellResponse_builder struct {
	Status string
	// contains filtered or unexported fields
}

func (RemoveKeyspaceCellResponse_builder) Build

type ReshardCreateRequest

type ReshardCreateRequest struct {
	ClusterId string                     `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Request   *dev2.ReshardCreateRequest `protobuf:"bytes,2,opt,name=request,proto3" json:"request,omitempty"`
	// contains filtered or unexported fields
}

func (*ReshardCreateRequest) ClearRequest

func (x *ReshardCreateRequest) ClearRequest()

func (*ReshardCreateRequest) GetClusterId

func (x *ReshardCreateRequest) GetClusterId() string

func (*ReshardCreateRequest) GetRequest

func (*ReshardCreateRequest) HasRequest

func (x *ReshardCreateRequest) HasRequest() bool

func (*ReshardCreateRequest) ProtoMessage

func (*ReshardCreateRequest) ProtoMessage()

func (*ReshardCreateRequest) ProtoReflect

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

func (*ReshardCreateRequest) Reset

func (x *ReshardCreateRequest) Reset()

func (*ReshardCreateRequest) SetClusterId

func (x *ReshardCreateRequest) SetClusterId(v string)

func (*ReshardCreateRequest) SetRequest

func (*ReshardCreateRequest) String

func (x *ReshardCreateRequest) String() string

type ReshardCreateRequest_builder

type ReshardCreateRequest_builder struct {
	ClusterId string
	Request   *dev2.ReshardCreateRequest
	// contains filtered or unexported fields
}

func (ReshardCreateRequest_builder) Build

type RetrySchemaMigrationRequest

type RetrySchemaMigrationRequest struct {
	ClusterId string                            `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Request   *dev2.RetrySchemaMigrationRequest `protobuf:"bytes,2,opt,name=request,proto3" json:"request,omitempty"`
	// contains filtered or unexported fields
}

func (*RetrySchemaMigrationRequest) ClearRequest

func (x *RetrySchemaMigrationRequest) ClearRequest()

func (*RetrySchemaMigrationRequest) GetClusterId

func (x *RetrySchemaMigrationRequest) GetClusterId() string

func (*RetrySchemaMigrationRequest) GetRequest

func (*RetrySchemaMigrationRequest) HasRequest

func (x *RetrySchemaMigrationRequest) HasRequest() bool

func (*RetrySchemaMigrationRequest) ProtoMessage

func (*RetrySchemaMigrationRequest) ProtoMessage()

func (*RetrySchemaMigrationRequest) ProtoReflect

func (*RetrySchemaMigrationRequest) Reset

func (x *RetrySchemaMigrationRequest) Reset()

func (*RetrySchemaMigrationRequest) SetClusterId

func (x *RetrySchemaMigrationRequest) SetClusterId(v string)

func (*RetrySchemaMigrationRequest) SetRequest

func (*RetrySchemaMigrationRequest) String

func (x *RetrySchemaMigrationRequest) String() string

type RetrySchemaMigrationRequest_builder

type RetrySchemaMigrationRequest_builder struct {
	ClusterId string
	Request   *dev2.RetrySchemaMigrationRequest
	// contains filtered or unexported fields
}

func (RetrySchemaMigrationRequest_builder) Build

type RunHealthCheckRequest

type RunHealthCheckRequest struct {
	Alias      *dev1.TabletAlias `protobuf:"bytes,1,opt,name=alias,proto3" json:"alias,omitempty"`
	ClusterIds []string          `protobuf:"bytes,2,rep,name=cluster_ids,json=clusterIds,proto3" json:"cluster_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*RunHealthCheckRequest) ClearAlias

func (x *RunHealthCheckRequest) ClearAlias()

func (*RunHealthCheckRequest) GetAlias

func (x *RunHealthCheckRequest) GetAlias() *dev1.TabletAlias

func (*RunHealthCheckRequest) GetClusterIds

func (x *RunHealthCheckRequest) GetClusterIds() []string

func (*RunHealthCheckRequest) HasAlias

func (x *RunHealthCheckRequest) HasAlias() bool

func (*RunHealthCheckRequest) ProtoMessage

func (*RunHealthCheckRequest) ProtoMessage()

func (*RunHealthCheckRequest) ProtoReflect

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

func (*RunHealthCheckRequest) Reset

func (x *RunHealthCheckRequest) Reset()

func (*RunHealthCheckRequest) SetAlias

func (x *RunHealthCheckRequest) SetAlias(v *dev1.TabletAlias)

func (*RunHealthCheckRequest) SetClusterIds

func (x *RunHealthCheckRequest) SetClusterIds(v []string)

func (*RunHealthCheckRequest) String

func (x *RunHealthCheckRequest) String() string

type RunHealthCheckRequest_builder

type RunHealthCheckRequest_builder struct {
	Alias      *dev1.TabletAlias
	ClusterIds []string
	// contains filtered or unexported fields
}

func (RunHealthCheckRequest_builder) Build

type RunHealthCheckResponse

type RunHealthCheckResponse struct {
	Status  string   `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Cluster *Cluster `protobuf:"bytes,2,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// contains filtered or unexported fields
}

func (*RunHealthCheckResponse) ClearCluster

func (x *RunHealthCheckResponse) ClearCluster()

func (*RunHealthCheckResponse) GetCluster

func (x *RunHealthCheckResponse) GetCluster() *Cluster

func (*RunHealthCheckResponse) GetStatus

func (x *RunHealthCheckResponse) GetStatus() string

func (*RunHealthCheckResponse) HasCluster

func (x *RunHealthCheckResponse) HasCluster() bool

func (*RunHealthCheckResponse) ProtoMessage

func (*RunHealthCheckResponse) ProtoMessage()

func (*RunHealthCheckResponse) ProtoReflect

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

func (*RunHealthCheckResponse) Reset

func (x *RunHealthCheckResponse) Reset()

func (*RunHealthCheckResponse) SetCluster

func (x *RunHealthCheckResponse) SetCluster(v *Cluster)

func (*RunHealthCheckResponse) SetStatus

func (x *RunHealthCheckResponse) SetStatus(v string)

func (*RunHealthCheckResponse) String

func (x *RunHealthCheckResponse) String() string

type RunHealthCheckResponse_builder

type RunHealthCheckResponse_builder struct {
	Status  string
	Cluster *Cluster
	// contains filtered or unexported fields
}

func (RunHealthCheckResponse_builder) Build

type Schema

type Schema struct {
	Cluster          *Cluster                `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	Keyspace         string                  `protobuf:"bytes,2,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	TableDefinitions []*dev3.TableDefinition `protobuf:"bytes,3,rep,name=table_definitions,json=tableDefinitions,proto3" json:"table_definitions,omitempty"`
	// TableSizes is a mapping of table name to TableSize information.
	TableSizes map[string]*Schema_TableSize `` /* 165-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Schema) ClearCluster

func (x *Schema) ClearCluster()

func (*Schema) GetCluster

func (x *Schema) GetCluster() *Cluster

func (*Schema) GetKeyspace

func (x *Schema) GetKeyspace() string

func (*Schema) GetTableDefinitions

func (x *Schema) GetTableDefinitions() []*dev3.TableDefinition

func (*Schema) GetTableSizes

func (x *Schema) GetTableSizes() map[string]*Schema_TableSize

func (*Schema) HasCluster

func (x *Schema) HasCluster() bool

func (*Schema) ProtoMessage

func (*Schema) ProtoMessage()

func (*Schema) ProtoReflect

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

func (*Schema) Reset

func (x *Schema) Reset()

func (*Schema) SetCluster

func (x *Schema) SetCluster(v *Cluster)

func (*Schema) SetKeyspace

func (x *Schema) SetKeyspace(v string)

func (*Schema) SetTableDefinitions

func (x *Schema) SetTableDefinitions(v []*dev3.TableDefinition)

func (*Schema) SetTableSizes

func (x *Schema) SetTableSizes(v map[string]*Schema_TableSize)

func (*Schema) String

func (x *Schema) String() string

type SchemaMigration

type SchemaMigration struct {
	Cluster         *Cluster              `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	SchemaMigration *dev2.SchemaMigration `protobuf:"bytes,2,opt,name=schema_migration,json=schemaMigration,proto3" json:"schema_migration,omitempty"`
	// contains filtered or unexported fields
}

func (*SchemaMigration) ClearCluster

func (x *SchemaMigration) ClearCluster()

func (*SchemaMigration) ClearSchemaMigration

func (x *SchemaMigration) ClearSchemaMigration()

func (*SchemaMigration) GetCluster

func (x *SchemaMigration) GetCluster() *Cluster

func (*SchemaMigration) GetSchemaMigration

func (x *SchemaMigration) GetSchemaMigration() *dev2.SchemaMigration

func (*SchemaMigration) HasCluster

func (x *SchemaMigration) HasCluster() bool

func (*SchemaMigration) HasSchemaMigration

func (x *SchemaMigration) HasSchemaMigration() bool

func (*SchemaMigration) ProtoMessage

func (*SchemaMigration) ProtoMessage()

func (*SchemaMigration) ProtoReflect

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

func (*SchemaMigration) Reset

func (x *SchemaMigration) Reset()

func (*SchemaMigration) SetCluster

func (x *SchemaMigration) SetCluster(v *Cluster)

func (*SchemaMigration) SetSchemaMigration

func (x *SchemaMigration) SetSchemaMigration(v *dev2.SchemaMigration)

func (*SchemaMigration) String

func (x *SchemaMigration) String() string

type SchemaMigration_builder

type SchemaMigration_builder struct {
	Cluster         *Cluster
	SchemaMigration *dev2.SchemaMigration
	// contains filtered or unexported fields
}

func (SchemaMigration_builder) Build

type Schema_ShardTableSize

type Schema_ShardTableSize struct {
	RowCount   uint64 `protobuf:"varint,1,opt,name=row_count,json=rowCount,proto3" json:"row_count,omitempty"`
	DataLength uint64 `protobuf:"varint,2,opt,name=data_length,json=dataLength,proto3" json:"data_length,omitempty"`
	// contains filtered or unexported fields
}

func (*Schema_ShardTableSize) GetDataLength

func (x *Schema_ShardTableSize) GetDataLength() uint64

func (*Schema_ShardTableSize) GetRowCount

func (x *Schema_ShardTableSize) GetRowCount() uint64

func (*Schema_ShardTableSize) ProtoMessage

func (*Schema_ShardTableSize) ProtoMessage()

func (*Schema_ShardTableSize) ProtoReflect

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

func (*Schema_ShardTableSize) Reset

func (x *Schema_ShardTableSize) Reset()

func (*Schema_ShardTableSize) SetDataLength

func (x *Schema_ShardTableSize) SetDataLength(v uint64)

func (*Schema_ShardTableSize) SetRowCount

func (x *Schema_ShardTableSize) SetRowCount(v uint64)

func (*Schema_ShardTableSize) String

func (x *Schema_ShardTableSize) String() string

type Schema_ShardTableSize_builder

type Schema_ShardTableSize_builder struct {
	RowCount   uint64
	DataLength uint64
	// contains filtered or unexported fields
}

func (Schema_ShardTableSize_builder) Build

type Schema_TableSize

type Schema_TableSize struct {
	RowCount   uint64                            `protobuf:"varint,1,opt,name=row_count,json=rowCount,proto3" json:"row_count,omitempty"`
	DataLength uint64                            `protobuf:"varint,2,opt,name=data_length,json=dataLength,proto3" json:"data_length,omitempty"`
	ByShard    map[string]*Schema_ShardTableSize `` /* 156-byte string literal not displayed */
	// contains filtered or unexported fields
}

TableSize aggregates table size information across all shards containing in the given keyspace and cluster, as well as per-shard size information.

func (*Schema_TableSize) GetByShard

func (x *Schema_TableSize) GetByShard() map[string]*Schema_ShardTableSize

func (*Schema_TableSize) GetDataLength

func (x *Schema_TableSize) GetDataLength() uint64

func (*Schema_TableSize) GetRowCount

func (x *Schema_TableSize) GetRowCount() uint64

func (*Schema_TableSize) ProtoMessage

func (*Schema_TableSize) ProtoMessage()

func (*Schema_TableSize) ProtoReflect

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

func (*Schema_TableSize) Reset

func (x *Schema_TableSize) Reset()

func (*Schema_TableSize) SetByShard

func (x *Schema_TableSize) SetByShard(v map[string]*Schema_ShardTableSize)

func (*Schema_TableSize) SetDataLength

func (x *Schema_TableSize) SetDataLength(v uint64)

func (*Schema_TableSize) SetRowCount

func (x *Schema_TableSize) SetRowCount(v uint64)

func (*Schema_TableSize) String

func (x *Schema_TableSize) String() string

type Schema_TableSize_builder

type Schema_TableSize_builder struct {
	RowCount   uint64
	DataLength uint64
	ByShard    map[string]*Schema_ShardTableSize
	// contains filtered or unexported fields
}

func (Schema_TableSize_builder) Build

type Schema_builder

type Schema_builder struct {
	Cluster          *Cluster
	Keyspace         string
	TableDefinitions []*dev3.TableDefinition
	// TableSizes is a mapping of table name to TableSize information.
	TableSizes map[string]*Schema_TableSize
	// contains filtered or unexported fields
}

func (Schema_builder) Build

func (b0 Schema_builder) Build() *Schema

type SetReadOnlyRequest

type SetReadOnlyRequest struct {
	Alias      *dev1.TabletAlias `protobuf:"bytes,1,opt,name=alias,proto3" json:"alias,omitempty"`
	ClusterIds []string          `protobuf:"bytes,2,rep,name=cluster_ids,json=clusterIds,proto3" json:"cluster_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*SetReadOnlyRequest) ClearAlias

func (x *SetReadOnlyRequest) ClearAlias()

func (*SetReadOnlyRequest) GetAlias

func (x *SetReadOnlyRequest) GetAlias() *dev1.TabletAlias

func (*SetReadOnlyRequest) GetClusterIds

func (x *SetReadOnlyRequest) GetClusterIds() []string

func (*SetReadOnlyRequest) HasAlias

func (x *SetReadOnlyRequest) HasAlias() bool

func (*SetReadOnlyRequest) ProtoMessage

func (*SetReadOnlyRequest) ProtoMessage()

func (*SetReadOnlyRequest) ProtoReflect

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

func (*SetReadOnlyRequest) Reset

func (x *SetReadOnlyRequest) Reset()

func (*SetReadOnlyRequest) SetAlias

func (x *SetReadOnlyRequest) SetAlias(v *dev1.TabletAlias)

func (*SetReadOnlyRequest) SetClusterIds

func (x *SetReadOnlyRequest) SetClusterIds(v []string)

func (*SetReadOnlyRequest) String

func (x *SetReadOnlyRequest) String() string

type SetReadOnlyRequest_builder

type SetReadOnlyRequest_builder struct {
	Alias      *dev1.TabletAlias
	ClusterIds []string
	// contains filtered or unexported fields
}

func (SetReadOnlyRequest_builder) Build

type SetReadOnlyResponse

type SetReadOnlyResponse struct {
	// contains filtered or unexported fields
}

func (*SetReadOnlyResponse) ProtoMessage

func (*SetReadOnlyResponse) ProtoMessage()

func (*SetReadOnlyResponse) ProtoReflect

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

func (*SetReadOnlyResponse) Reset

func (x *SetReadOnlyResponse) Reset()

func (*SetReadOnlyResponse) String

func (x *SetReadOnlyResponse) String() string

type SetReadOnlyResponse_builder

type SetReadOnlyResponse_builder struct {
	// contains filtered or unexported fields
}

func (SetReadOnlyResponse_builder) Build

type SetReadWriteRequest

type SetReadWriteRequest struct {
	Alias      *dev1.TabletAlias `protobuf:"bytes,1,opt,name=alias,proto3" json:"alias,omitempty"`
	ClusterIds []string          `protobuf:"bytes,2,rep,name=cluster_ids,json=clusterIds,proto3" json:"cluster_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*SetReadWriteRequest) ClearAlias

func (x *SetReadWriteRequest) ClearAlias()

func (*SetReadWriteRequest) GetAlias

func (x *SetReadWriteRequest) GetAlias() *dev1.TabletAlias

func (*SetReadWriteRequest) GetClusterIds

func (x *SetReadWriteRequest) GetClusterIds() []string

func (*SetReadWriteRequest) HasAlias

func (x *SetReadWriteRequest) HasAlias() bool

func (*SetReadWriteRequest) ProtoMessage

func (*SetReadWriteRequest) ProtoMessage()

func (*SetReadWriteRequest) ProtoReflect

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

func (*SetReadWriteRequest) Reset

func (x *SetReadWriteRequest) Reset()

func (*SetReadWriteRequest) SetAlias

func (x *SetReadWriteRequest) SetAlias(v *dev1.TabletAlias)

func (*SetReadWriteRequest) SetClusterIds

func (x *SetReadWriteRequest) SetClusterIds(v []string)

func (*SetReadWriteRequest) String

func (x *SetReadWriteRequest) String() string

type SetReadWriteRequest_builder

type SetReadWriteRequest_builder struct {
	Alias      *dev1.TabletAlias
	ClusterIds []string
	// contains filtered or unexported fields
}

func (SetReadWriteRequest_builder) Build

type SetReadWriteResponse

type SetReadWriteResponse struct {
	// contains filtered or unexported fields
}

func (*SetReadWriteResponse) ProtoMessage

func (*SetReadWriteResponse) ProtoMessage()

func (*SetReadWriteResponse) ProtoReflect

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

func (*SetReadWriteResponse) Reset

func (x *SetReadWriteResponse) Reset()

func (*SetReadWriteResponse) String

func (x *SetReadWriteResponse) String() string

type SetReadWriteResponse_builder

type SetReadWriteResponse_builder struct {
	// contains filtered or unexported fields
}

func (SetReadWriteResponse_builder) Build

type Shard

type Shard struct {
	Cluster *Cluster    `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	Shard   *dev2.Shard `protobuf:"bytes,2,opt,name=shard,proto3" json:"shard,omitempty"`
	// contains filtered or unexported fields
}

Shard groups the vtctldata information about a shard record together with the Vitess cluster it belongs to.

func (*Shard) ClearCluster

func (x *Shard) ClearCluster()

func (*Shard) ClearShard

func (x *Shard) ClearShard()

func (*Shard) GetCluster

func (x *Shard) GetCluster() *Cluster

func (*Shard) GetShard

func (x *Shard) GetShard() *dev2.Shard

func (*Shard) HasCluster

func (x *Shard) HasCluster() bool

func (*Shard) HasShard

func (x *Shard) HasShard() 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) SetCluster

func (x *Shard) SetCluster(v *Cluster)

func (*Shard) SetShard

func (x *Shard) SetShard(v *dev2.Shard)

func (*Shard) String

func (x *Shard) String() string

type Shard_builder

type Shard_builder struct {
	Cluster *Cluster
	Shard   *dev2.Shard
	// contains filtered or unexported fields
}

func (Shard_builder) Build

func (b0 Shard_builder) Build() *Shard

type SrvVSchema

type SrvVSchema struct {
	Cell       string           `protobuf:"bytes,1,opt,name=cell,proto3" json:"cell,omitempty"`
	Cluster    *Cluster         `protobuf:"bytes,2,opt,name=cluster,proto3" json:"cluster,omitempty"`
	SrvVSchema *dev4.SrvVSchema `protobuf:"bytes,3,opt,name=srv_v_schema,json=srvVSchema,proto3" json:"srv_v_schema,omitempty"`
	// contains filtered or unexported fields
}

func (*SrvVSchema) ClearCluster

func (x *SrvVSchema) ClearCluster()

func (*SrvVSchema) ClearSrvVSchema

func (x *SrvVSchema) ClearSrvVSchema()

func (*SrvVSchema) GetCell

func (x *SrvVSchema) GetCell() string

func (*SrvVSchema) GetCluster

func (x *SrvVSchema) GetCluster() *Cluster

func (*SrvVSchema) GetSrvVSchema

func (x *SrvVSchema) GetSrvVSchema() *dev4.SrvVSchema

func (*SrvVSchema) HasCluster

func (x *SrvVSchema) HasCluster() bool

func (*SrvVSchema) HasSrvVSchema

func (x *SrvVSchema) HasSrvVSchema() bool

func (*SrvVSchema) ProtoMessage

func (*SrvVSchema) ProtoMessage()

func (*SrvVSchema) ProtoReflect

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

func (*SrvVSchema) Reset

func (x *SrvVSchema) Reset()

func (*SrvVSchema) SetCell

func (x *SrvVSchema) SetCell(v string)

func (*SrvVSchema) SetCluster

func (x *SrvVSchema) SetCluster(v *Cluster)

func (*SrvVSchema) SetSrvVSchema

func (x *SrvVSchema) SetSrvVSchema(v *dev4.SrvVSchema)

func (*SrvVSchema) String

func (x *SrvVSchema) String() string

type SrvVSchema_builder

type SrvVSchema_builder struct {
	Cell       string
	Cluster    *Cluster
	SrvVSchema *dev4.SrvVSchema
	// contains filtered or unexported fields
}

func (SrvVSchema_builder) Build

func (b0 SrvVSchema_builder) Build() *SrvVSchema

type StartReplicationRequest

type StartReplicationRequest struct {
	Alias      *dev1.TabletAlias `protobuf:"bytes,1,opt,name=alias,proto3" json:"alias,omitempty"`
	ClusterIds []string          `protobuf:"bytes,2,rep,name=cluster_ids,json=clusterIds,proto3" json:"cluster_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*StartReplicationRequest) ClearAlias

func (x *StartReplicationRequest) ClearAlias()

func (*StartReplicationRequest) GetAlias

func (x *StartReplicationRequest) GetAlias() *dev1.TabletAlias

func (*StartReplicationRequest) GetClusterIds

func (x *StartReplicationRequest) GetClusterIds() []string

func (*StartReplicationRequest) HasAlias

func (x *StartReplicationRequest) HasAlias() bool

func (*StartReplicationRequest) ProtoMessage

func (*StartReplicationRequest) ProtoMessage()

func (*StartReplicationRequest) ProtoReflect

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

func (*StartReplicationRequest) Reset

func (x *StartReplicationRequest) Reset()

func (*StartReplicationRequest) SetAlias

func (x *StartReplicationRequest) SetAlias(v *dev1.TabletAlias)

func (*StartReplicationRequest) SetClusterIds

func (x *StartReplicationRequest) SetClusterIds(v []string)

func (*StartReplicationRequest) String

func (x *StartReplicationRequest) String() string

type StartReplicationRequest_builder

type StartReplicationRequest_builder struct {
	Alias      *dev1.TabletAlias
	ClusterIds []string
	// contains filtered or unexported fields
}

func (StartReplicationRequest_builder) Build

type StartReplicationResponse

type StartReplicationResponse struct {
	Status  string   `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Cluster *Cluster `protobuf:"bytes,2,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// contains filtered or unexported fields
}

func (*StartReplicationResponse) ClearCluster

func (x *StartReplicationResponse) ClearCluster()

func (*StartReplicationResponse) GetCluster

func (x *StartReplicationResponse) GetCluster() *Cluster

func (*StartReplicationResponse) GetStatus

func (x *StartReplicationResponse) GetStatus() string

func (*StartReplicationResponse) HasCluster

func (x *StartReplicationResponse) HasCluster() bool

func (*StartReplicationResponse) ProtoMessage

func (*StartReplicationResponse) ProtoMessage()

func (*StartReplicationResponse) ProtoReflect

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

func (*StartReplicationResponse) Reset

func (x *StartReplicationResponse) Reset()

func (*StartReplicationResponse) SetCluster

func (x *StartReplicationResponse) SetCluster(v *Cluster)

func (*StartReplicationResponse) SetStatus

func (x *StartReplicationResponse) SetStatus(v string)

func (*StartReplicationResponse) String

func (x *StartReplicationResponse) String() string

type StartReplicationResponse_builder

type StartReplicationResponse_builder struct {
	Status  string
	Cluster *Cluster
	// contains filtered or unexported fields
}

func (StartReplicationResponse_builder) Build

type StartWorkflowRequest

type StartWorkflowRequest struct {
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Keyspace  string `protobuf:"bytes,2,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	Workflow  string `protobuf:"bytes,3,opt,name=workflow,proto3" json:"workflow,omitempty"`
	// contains filtered or unexported fields
}

func (*StartWorkflowRequest) GetClusterId

func (x *StartWorkflowRequest) GetClusterId() string

func (*StartWorkflowRequest) GetKeyspace

func (x *StartWorkflowRequest) GetKeyspace() string

func (*StartWorkflowRequest) GetWorkflow

func (x *StartWorkflowRequest) GetWorkflow() string

func (*StartWorkflowRequest) ProtoMessage

func (*StartWorkflowRequest) ProtoMessage()

func (*StartWorkflowRequest) ProtoReflect

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

func (*StartWorkflowRequest) Reset

func (x *StartWorkflowRequest) Reset()

func (*StartWorkflowRequest) SetClusterId

func (x *StartWorkflowRequest) SetClusterId(v string)

func (*StartWorkflowRequest) SetKeyspace

func (x *StartWorkflowRequest) SetKeyspace(v string)

func (*StartWorkflowRequest) SetWorkflow

func (x *StartWorkflowRequest) SetWorkflow(v string)

func (*StartWorkflowRequest) String

func (x *StartWorkflowRequest) String() string

type StartWorkflowRequest_builder

type StartWorkflowRequest_builder struct {
	ClusterId string
	Keyspace  string
	Workflow  string
	// contains filtered or unexported fields
}

func (StartWorkflowRequest_builder) Build

type StopReplicationRequest

type StopReplicationRequest struct {
	Alias      *dev1.TabletAlias `protobuf:"bytes,1,opt,name=alias,proto3" json:"alias,omitempty"`
	ClusterIds []string          `protobuf:"bytes,2,rep,name=cluster_ids,json=clusterIds,proto3" json:"cluster_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*StopReplicationRequest) ClearAlias

func (x *StopReplicationRequest) ClearAlias()

func (*StopReplicationRequest) GetAlias

func (x *StopReplicationRequest) GetAlias() *dev1.TabletAlias

func (*StopReplicationRequest) GetClusterIds

func (x *StopReplicationRequest) GetClusterIds() []string

func (*StopReplicationRequest) HasAlias

func (x *StopReplicationRequest) HasAlias() bool

func (*StopReplicationRequest) ProtoMessage

func (*StopReplicationRequest) ProtoMessage()

func (*StopReplicationRequest) ProtoReflect

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

func (*StopReplicationRequest) Reset

func (x *StopReplicationRequest) Reset()

func (*StopReplicationRequest) SetAlias

func (x *StopReplicationRequest) SetAlias(v *dev1.TabletAlias)

func (*StopReplicationRequest) SetClusterIds

func (x *StopReplicationRequest) SetClusterIds(v []string)

func (*StopReplicationRequest) String

func (x *StopReplicationRequest) String() string

type StopReplicationRequest_builder

type StopReplicationRequest_builder struct {
	Alias      *dev1.TabletAlias
	ClusterIds []string
	// contains filtered or unexported fields
}

func (StopReplicationRequest_builder) Build

type StopReplicationResponse

type StopReplicationResponse struct {
	Status  string   `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Cluster *Cluster `protobuf:"bytes,2,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// contains filtered or unexported fields
}

func (*StopReplicationResponse) ClearCluster

func (x *StopReplicationResponse) ClearCluster()

func (*StopReplicationResponse) GetCluster

func (x *StopReplicationResponse) GetCluster() *Cluster

func (*StopReplicationResponse) GetStatus

func (x *StopReplicationResponse) GetStatus() string

func (*StopReplicationResponse) HasCluster

func (x *StopReplicationResponse) HasCluster() bool

func (*StopReplicationResponse) ProtoMessage

func (*StopReplicationResponse) ProtoMessage()

func (*StopReplicationResponse) ProtoReflect

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

func (*StopReplicationResponse) Reset

func (x *StopReplicationResponse) Reset()

func (*StopReplicationResponse) SetCluster

func (x *StopReplicationResponse) SetCluster(v *Cluster)

func (*StopReplicationResponse) SetStatus

func (x *StopReplicationResponse) SetStatus(v string)

func (*StopReplicationResponse) String

func (x *StopReplicationResponse) String() string

type StopReplicationResponse_builder

type StopReplicationResponse_builder struct {
	Status  string
	Cluster *Cluster
	// contains filtered or unexported fields
}

func (StopReplicationResponse_builder) Build

type StopWorkflowRequest

type StopWorkflowRequest struct {
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Keyspace  string `protobuf:"bytes,2,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	Workflow  string `protobuf:"bytes,3,opt,name=workflow,proto3" json:"workflow,omitempty"`
	// contains filtered or unexported fields
}

func (*StopWorkflowRequest) GetClusterId

func (x *StopWorkflowRequest) GetClusterId() string

func (*StopWorkflowRequest) GetKeyspace

func (x *StopWorkflowRequest) GetKeyspace() string

func (*StopWorkflowRequest) GetWorkflow

func (x *StopWorkflowRequest) GetWorkflow() string

func (*StopWorkflowRequest) ProtoMessage

func (*StopWorkflowRequest) ProtoMessage()

func (*StopWorkflowRequest) ProtoReflect

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

func (*StopWorkflowRequest) Reset

func (x *StopWorkflowRequest) Reset()

func (*StopWorkflowRequest) SetClusterId

func (x *StopWorkflowRequest) SetClusterId(v string)

func (*StopWorkflowRequest) SetKeyspace

func (x *StopWorkflowRequest) SetKeyspace(v string)

func (*StopWorkflowRequest) SetWorkflow

func (x *StopWorkflowRequest) SetWorkflow(v string)

func (*StopWorkflowRequest) String

func (x *StopWorkflowRequest) String() string

type StopWorkflowRequest_builder

type StopWorkflowRequest_builder struct {
	ClusterId string
	Keyspace  string
	Workflow  string
	// contains filtered or unexported fields
}

func (StopWorkflowRequest_builder) Build

type Tablet

type Tablet struct {
	Cluster *Cluster            `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	Tablet  *dev1.Tablet        `protobuf:"bytes,2,opt,name=tablet,proto3" json:"tablet,omitempty"`
	State   Tablet_ServingState `protobuf:"varint,3,opt,name=state,proto3,enum=vitess.vtadmin.dev.Tablet_ServingState" json:"state,omitempty"`
	FQDN    string              `protobuf:"bytes,4,opt,name=FQDN,proto3" json:"FQDN,omitempty"`
	// contains filtered or unexported fields
}

Tablet groups the topo information of a tablet together with the Vitess cluster it belongs to.

func (*Tablet) ClearCluster

func (x *Tablet) ClearCluster()

func (*Tablet) ClearTablet

func (x *Tablet) ClearTablet()

func (*Tablet) GetCluster

func (x *Tablet) GetCluster() *Cluster

func (*Tablet) GetFQDN

func (x *Tablet) GetFQDN() string

func (*Tablet) GetState

func (x *Tablet) GetState() Tablet_ServingState

func (*Tablet) GetTablet

func (x *Tablet) GetTablet() *dev1.Tablet

func (*Tablet) HasCluster

func (x *Tablet) HasCluster() bool

func (*Tablet) HasTablet

func (x *Tablet) HasTablet() 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) SetCluster

func (x *Tablet) SetCluster(v *Cluster)

func (*Tablet) SetFQDN

func (x *Tablet) SetFQDN(v string)

func (*Tablet) SetState

func (x *Tablet) SetState(v Tablet_ServingState)

func (*Tablet) SetTablet

func (x *Tablet) SetTablet(v *dev1.Tablet)

func (*Tablet) String

func (x *Tablet) String() string

type TabletExternallyPromotedRequest

type TabletExternallyPromotedRequest struct {

	// Tablet is the alias of the tablet that was promoted externally and should
	// be updated to the shard primary in the topo.
	Alias      *dev1.TabletAlias `protobuf:"bytes,1,opt,name=alias,proto3" json:"alias,omitempty"`
	ClusterIds []string          `protobuf:"bytes,2,rep,name=cluster_ids,json=clusterIds,proto3" json:"cluster_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*TabletExternallyPromotedRequest) ClearAlias

func (x *TabletExternallyPromotedRequest) ClearAlias()

func (*TabletExternallyPromotedRequest) GetAlias

func (*TabletExternallyPromotedRequest) GetClusterIds

func (x *TabletExternallyPromotedRequest) GetClusterIds() []string

func (*TabletExternallyPromotedRequest) HasAlias

func (x *TabletExternallyPromotedRequest) HasAlias() bool

func (*TabletExternallyPromotedRequest) ProtoMessage

func (*TabletExternallyPromotedRequest) ProtoMessage()

func (*TabletExternallyPromotedRequest) ProtoReflect

func (*TabletExternallyPromotedRequest) Reset

func (*TabletExternallyPromotedRequest) SetAlias

func (*TabletExternallyPromotedRequest) SetClusterIds

func (x *TabletExternallyPromotedRequest) SetClusterIds(v []string)

func (*TabletExternallyPromotedRequest) String

type TabletExternallyPromotedRequest_builder

type TabletExternallyPromotedRequest_builder struct {

	// Tablet is the alias of the tablet that was promoted externally and should
	// be updated to the shard primary in the topo.
	Alias      *dev1.TabletAlias
	ClusterIds []string
	// contains filtered or unexported fields
}

func (TabletExternallyPromotedRequest_builder) Build

type TabletExternallyPromotedResponse

type TabletExternallyPromotedResponse struct {
	Cluster    *Cluster          `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	Keyspace   string            `protobuf:"bytes,2,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	Shard      string            `protobuf:"bytes,3,opt,name=shard,proto3" json:"shard,omitempty"`
	NewPrimary *dev1.TabletAlias `protobuf:"bytes,4,opt,name=new_primary,json=newPrimary,proto3" json:"new_primary,omitempty"`
	OldPrimary *dev1.TabletAlias `protobuf:"bytes,5,opt,name=old_primary,json=oldPrimary,proto3" json:"old_primary,omitempty"`
	// contains filtered or unexported fields
}

func (*TabletExternallyPromotedResponse) ClearCluster

func (x *TabletExternallyPromotedResponse) ClearCluster()

func (*TabletExternallyPromotedResponse) ClearNewPrimary

func (x *TabletExternallyPromotedResponse) ClearNewPrimary()

func (*TabletExternallyPromotedResponse) ClearOldPrimary

func (x *TabletExternallyPromotedResponse) ClearOldPrimary()

func (*TabletExternallyPromotedResponse) GetCluster

func (x *TabletExternallyPromotedResponse) GetCluster() *Cluster

func (*TabletExternallyPromotedResponse) GetKeyspace

func (x *TabletExternallyPromotedResponse) GetKeyspace() string

func (*TabletExternallyPromotedResponse) GetNewPrimary

func (*TabletExternallyPromotedResponse) GetOldPrimary

func (*TabletExternallyPromotedResponse) GetShard

func (*TabletExternallyPromotedResponse) HasCluster

func (x *TabletExternallyPromotedResponse) HasCluster() bool

func (*TabletExternallyPromotedResponse) HasNewPrimary

func (x *TabletExternallyPromotedResponse) HasNewPrimary() bool

func (*TabletExternallyPromotedResponse) HasOldPrimary

func (x *TabletExternallyPromotedResponse) HasOldPrimary() bool

func (*TabletExternallyPromotedResponse) ProtoMessage

func (*TabletExternallyPromotedResponse) ProtoMessage()

func (*TabletExternallyPromotedResponse) ProtoReflect

func (*TabletExternallyPromotedResponse) Reset

func (*TabletExternallyPromotedResponse) SetCluster

func (x *TabletExternallyPromotedResponse) SetCluster(v *Cluster)

func (*TabletExternallyPromotedResponse) SetKeyspace

func (x *TabletExternallyPromotedResponse) SetKeyspace(v string)

func (*TabletExternallyPromotedResponse) SetNewPrimary

func (x *TabletExternallyPromotedResponse) SetNewPrimary(v *dev1.TabletAlias)

func (*TabletExternallyPromotedResponse) SetOldPrimary

func (x *TabletExternallyPromotedResponse) SetOldPrimary(v *dev1.TabletAlias)

func (*TabletExternallyPromotedResponse) SetShard

func (*TabletExternallyPromotedResponse) String

type TabletExternallyPromotedResponse_builder

type TabletExternallyPromotedResponse_builder struct {
	Cluster    *Cluster
	Keyspace   string
	Shard      string
	NewPrimary *dev1.TabletAlias
	OldPrimary *dev1.TabletAlias
	// contains filtered or unexported fields
}

func (TabletExternallyPromotedResponse_builder) Build

type TabletExternallyReparentedRequest

type TabletExternallyReparentedRequest struct {
	Alias      *dev1.TabletAlias `protobuf:"bytes,1,opt,name=alias,proto3" json:"alias,omitempty"`
	ClusterIds []string          `protobuf:"bytes,2,rep,name=cluster_ids,json=clusterIds,proto3" json:"cluster_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*TabletExternallyReparentedRequest) ClearAlias

func (x *TabletExternallyReparentedRequest) ClearAlias()

func (*TabletExternallyReparentedRequest) GetAlias

func (*TabletExternallyReparentedRequest) GetClusterIds

func (x *TabletExternallyReparentedRequest) GetClusterIds() []string

func (*TabletExternallyReparentedRequest) HasAlias

func (*TabletExternallyReparentedRequest) ProtoMessage

func (*TabletExternallyReparentedRequest) ProtoMessage()

func (*TabletExternallyReparentedRequest) ProtoReflect

func (*TabletExternallyReparentedRequest) Reset

func (*TabletExternallyReparentedRequest) SetAlias

func (*TabletExternallyReparentedRequest) SetClusterIds

func (x *TabletExternallyReparentedRequest) SetClusterIds(v []string)

func (*TabletExternallyReparentedRequest) String

type TabletExternallyReparentedRequest_builder

type TabletExternallyReparentedRequest_builder struct {
	Alias      *dev1.TabletAlias
	ClusterIds []string
	// contains filtered or unexported fields
}

func (TabletExternallyReparentedRequest_builder) Build

type Tablet_ServingState

type Tablet_ServingState int32
const (
	Tablet_UNKNOWN     Tablet_ServingState = 0
	Tablet_SERVING     Tablet_ServingState = 1
	Tablet_NOT_SERVING Tablet_ServingState = 2
)

func (Tablet_ServingState) Descriptor

func (Tablet_ServingState) Enum

func (Tablet_ServingState) Number

func (Tablet_ServingState) String

func (x Tablet_ServingState) String() string

func (Tablet_ServingState) Type

type Tablet_builder

type Tablet_builder struct {
	Cluster *Cluster
	Tablet  *dev1.Tablet
	State   Tablet_ServingState
	FQDN    string
	// contains filtered or unexported fields
}

func (Tablet_builder) Build

func (b0 Tablet_builder) Build() *Tablet

type VDiffCreateRequest

type VDiffCreateRequest struct {
	ClusterId string                   `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Request   *dev2.VDiffCreateRequest `protobuf:"bytes,2,opt,name=request,proto3" json:"request,omitempty"`
	// contains filtered or unexported fields
}

func (*VDiffCreateRequest) ClearRequest

func (x *VDiffCreateRequest) ClearRequest()

func (*VDiffCreateRequest) GetClusterId

func (x *VDiffCreateRequest) GetClusterId() string

func (*VDiffCreateRequest) GetRequest

func (x *VDiffCreateRequest) GetRequest() *dev2.VDiffCreateRequest

func (*VDiffCreateRequest) HasRequest

func (x *VDiffCreateRequest) HasRequest() bool

func (*VDiffCreateRequest) ProtoMessage

func (*VDiffCreateRequest) ProtoMessage()

func (*VDiffCreateRequest) ProtoReflect

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

func (*VDiffCreateRequest) Reset

func (x *VDiffCreateRequest) Reset()

func (*VDiffCreateRequest) SetClusterId

func (x *VDiffCreateRequest) SetClusterId(v string)

func (*VDiffCreateRequest) SetRequest

func (x *VDiffCreateRequest) SetRequest(v *dev2.VDiffCreateRequest)

func (*VDiffCreateRequest) String

func (x *VDiffCreateRequest) String() string

type VDiffCreateRequest_builder

type VDiffCreateRequest_builder struct {
	ClusterId string
	Request   *dev2.VDiffCreateRequest
	// contains filtered or unexported fields
}

func (VDiffCreateRequest_builder) Build

type VDiffProgress

type VDiffProgress struct {
	Percentage float64 `protobuf:"fixed64,1,opt,name=percentage,proto3" json:"percentage,omitempty"`
	Eta        string  `protobuf:"bytes,2,opt,name=eta,proto3" json:"eta,omitempty"`
	// contains filtered or unexported fields
}

func (*VDiffProgress) GetEta

func (x *VDiffProgress) GetEta() string

func (*VDiffProgress) GetPercentage

func (x *VDiffProgress) GetPercentage() float64

func (*VDiffProgress) ProtoMessage

func (*VDiffProgress) ProtoMessage()

func (*VDiffProgress) ProtoReflect

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

func (*VDiffProgress) Reset

func (x *VDiffProgress) Reset()

func (*VDiffProgress) SetEta

func (x *VDiffProgress) SetEta(v string)

func (*VDiffProgress) SetPercentage

func (x *VDiffProgress) SetPercentage(v float64)

func (*VDiffProgress) String

func (x *VDiffProgress) String() string

type VDiffProgress_builder

type VDiffProgress_builder struct {
	Percentage float64
	Eta        string
	// contains filtered or unexported fields
}

func (VDiffProgress_builder) Build

type VDiffShardReport

type VDiffShardReport struct {
	State        string         `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
	RowsCompared int64          `protobuf:"varint,2,opt,name=rows_compared,json=rowsCompared,proto3" json:"rows_compared,omitempty"`
	HasMismatch  bool           `protobuf:"varint,3,opt,name=has_mismatch,json=hasMismatch,proto3" json:"has_mismatch,omitempty"`
	StartedAt    string         `protobuf:"bytes,4,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
	CompletedAt  string         `protobuf:"bytes,5,opt,name=completed_at,json=completedAt,proto3" json:"completed_at,omitempty"`
	Progress     *VDiffProgress `protobuf:"bytes,6,opt,name=progress,proto3" json:"progress,omitempty"`
	// contains filtered or unexported fields
}

func (*VDiffShardReport) ClearProgress

func (x *VDiffShardReport) ClearProgress()

func (*VDiffShardReport) GetCompletedAt

func (x *VDiffShardReport) GetCompletedAt() string

func (*VDiffShardReport) GetHasMismatch

func (x *VDiffShardReport) GetHasMismatch() bool

func (*VDiffShardReport) GetProgress

func (x *VDiffShardReport) GetProgress() *VDiffProgress

func (*VDiffShardReport) GetRowsCompared

func (x *VDiffShardReport) GetRowsCompared() int64

func (*VDiffShardReport) GetStartedAt

func (x *VDiffShardReport) GetStartedAt() string

func (*VDiffShardReport) GetState

func (x *VDiffShardReport) GetState() string

func (*VDiffShardReport) HasProgress

func (x *VDiffShardReport) HasProgress() bool

func (*VDiffShardReport) ProtoMessage

func (*VDiffShardReport) ProtoMessage()

func (*VDiffShardReport) ProtoReflect

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

func (*VDiffShardReport) Reset

func (x *VDiffShardReport) Reset()

func (*VDiffShardReport) SetCompletedAt

func (x *VDiffShardReport) SetCompletedAt(v string)

func (*VDiffShardReport) SetHasMismatch

func (x *VDiffShardReport) SetHasMismatch(v bool)

func (*VDiffShardReport) SetProgress

func (x *VDiffShardReport) SetProgress(v *VDiffProgress)

func (*VDiffShardReport) SetRowsCompared

func (x *VDiffShardReport) SetRowsCompared(v int64)

func (*VDiffShardReport) SetStartedAt

func (x *VDiffShardReport) SetStartedAt(v string)

func (*VDiffShardReport) SetState

func (x *VDiffShardReport) SetState(v string)

func (*VDiffShardReport) String

func (x *VDiffShardReport) String() string

type VDiffShardReport_builder

type VDiffShardReport_builder struct {
	State        string
	RowsCompared int64
	HasMismatch  bool
	StartedAt    string
	CompletedAt  string
	Progress     *VDiffProgress
	// contains filtered or unexported fields
}

func (VDiffShardReport_builder) Build

type VDiffShowRequest

type VDiffShowRequest struct {
	ClusterId string                 `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Request   *dev2.VDiffShowRequest `protobuf:"bytes,2,opt,name=request,proto3" json:"request,omitempty"`
	// contains filtered or unexported fields
}

func (*VDiffShowRequest) ClearRequest

func (x *VDiffShowRequest) ClearRequest()

func (*VDiffShowRequest) GetClusterId

func (x *VDiffShowRequest) GetClusterId() string

func (*VDiffShowRequest) GetRequest

func (x *VDiffShowRequest) GetRequest() *dev2.VDiffShowRequest

func (*VDiffShowRequest) HasRequest

func (x *VDiffShowRequest) HasRequest() bool

func (*VDiffShowRequest) ProtoMessage

func (*VDiffShowRequest) ProtoMessage()

func (*VDiffShowRequest) ProtoReflect

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

func (*VDiffShowRequest) Reset

func (x *VDiffShowRequest) Reset()

func (*VDiffShowRequest) SetClusterId

func (x *VDiffShowRequest) SetClusterId(v string)

func (*VDiffShowRequest) SetRequest

func (x *VDiffShowRequest) SetRequest(v *dev2.VDiffShowRequest)

func (*VDiffShowRequest) String

func (x *VDiffShowRequest) String() string

type VDiffShowRequest_builder

type VDiffShowRequest_builder struct {
	ClusterId string
	Request   *dev2.VDiffShowRequest
	// contains filtered or unexported fields
}

func (VDiffShowRequest_builder) Build

type VDiffShowResponse

type VDiffShowResponse struct {
	ShardReport map[string]*VDiffShardReport `` /* 168-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*VDiffShowResponse) GetShardReport

func (x *VDiffShowResponse) GetShardReport() map[string]*VDiffShardReport

func (*VDiffShowResponse) ProtoMessage

func (*VDiffShowResponse) ProtoMessage()

func (*VDiffShowResponse) ProtoReflect

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

func (*VDiffShowResponse) Reset

func (x *VDiffShowResponse) Reset()

func (*VDiffShowResponse) SetShardReport

func (x *VDiffShowResponse) SetShardReport(v map[string]*VDiffShardReport)

func (*VDiffShowResponse) String

func (x *VDiffShowResponse) String() string

type VDiffShowResponse_builder

type VDiffShowResponse_builder struct {
	ShardReport map[string]*VDiffShardReport
	// contains filtered or unexported fields
}

func (VDiffShowResponse_builder) Build

type VExplainRequest

type VExplainRequest struct {
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Keyspace  string `protobuf:"bytes,2,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	Sql       string `protobuf:"bytes,3,opt,name=sql,proto3" json:"sql,omitempty"`
	// contains filtered or unexported fields
}

func (*VExplainRequest) GetClusterId

func (x *VExplainRequest) GetClusterId() string

func (*VExplainRequest) GetKeyspace

func (x *VExplainRequest) GetKeyspace() string

func (*VExplainRequest) GetSql

func (x *VExplainRequest) GetSql() string

func (*VExplainRequest) ProtoMessage

func (*VExplainRequest) ProtoMessage()

func (*VExplainRequest) ProtoReflect

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

func (*VExplainRequest) Reset

func (x *VExplainRequest) Reset()

func (*VExplainRequest) SetClusterId

func (x *VExplainRequest) SetClusterId(v string)

func (*VExplainRequest) SetKeyspace

func (x *VExplainRequest) SetKeyspace(v string)

func (*VExplainRequest) SetSql

func (x *VExplainRequest) SetSql(v string)

func (*VExplainRequest) String

func (x *VExplainRequest) String() string

type VExplainRequest_builder

type VExplainRequest_builder struct {
	ClusterId string
	Keyspace  string
	Sql       string
	// contains filtered or unexported fields
}

func (VExplainRequest_builder) Build

type VExplainResponse

type VExplainResponse struct {
	Response string `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*VExplainResponse) GetResponse

func (x *VExplainResponse) GetResponse() string

func (*VExplainResponse) ProtoMessage

func (*VExplainResponse) ProtoMessage()

func (*VExplainResponse) ProtoReflect

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

func (*VExplainResponse) Reset

func (x *VExplainResponse) Reset()

func (*VExplainResponse) SetResponse

func (x *VExplainResponse) SetResponse(v string)

func (*VExplainResponse) String

func (x *VExplainResponse) String() string

type VExplainResponse_builder

type VExplainResponse_builder struct {
	Response string
	// contains filtered or unexported fields
}

func (VExplainResponse_builder) Build

type VSchema

type VSchema struct {
	Cluster *Cluster `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// Name is the name of the keyspace this VSchema is for.
	Name    string         `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	VSchema *dev4.Keyspace `protobuf:"bytes,3,opt,name=v_schema,json=vSchema,proto3" json:"v_schema,omitempty"`
	// contains filtered or unexported fields
}

VSchema represents the vschema for a keyspace in the cluster it belongs to.

func (*VSchema) ClearCluster

func (x *VSchema) ClearCluster()

func (*VSchema) ClearVSchema

func (x *VSchema) ClearVSchema()

func (*VSchema) GetCluster

func (x *VSchema) GetCluster() *Cluster

func (*VSchema) GetName

func (x *VSchema) GetName() string

func (*VSchema) GetVSchema

func (x *VSchema) GetVSchema() *dev4.Keyspace

func (*VSchema) HasCluster

func (x *VSchema) HasCluster() bool

func (*VSchema) HasVSchema

func (x *VSchema) HasVSchema() bool

func (*VSchema) ProtoMessage

func (*VSchema) ProtoMessage()

func (*VSchema) ProtoReflect

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

func (*VSchema) Reset

func (x *VSchema) Reset()

func (*VSchema) SetCluster

func (x *VSchema) SetCluster(v *Cluster)

func (*VSchema) SetName

func (x *VSchema) SetName(v string)

func (*VSchema) SetVSchema

func (x *VSchema) SetVSchema(v *dev4.Keyspace)

func (*VSchema) String

func (x *VSchema) String() string

type VSchema_builder

type VSchema_builder struct {
	Cluster *Cluster
	// Name is the name of the keyspace this VSchema is for.
	Name    string
	VSchema *dev4.Keyspace
	// contains filtered or unexported fields
}

func (VSchema_builder) Build

func (b0 VSchema_builder) Build() *VSchema

type VTExplainRequest

type VTExplainRequest struct {
	Cluster  string `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	Keyspace string `protobuf:"bytes,2,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	Sql      string `protobuf:"bytes,3,opt,name=sql,proto3" json:"sql,omitempty"`
	// contains filtered or unexported fields
}

func (*VTExplainRequest) GetCluster

func (x *VTExplainRequest) GetCluster() string

func (*VTExplainRequest) GetKeyspace

func (x *VTExplainRequest) GetKeyspace() string

func (*VTExplainRequest) GetSql

func (x *VTExplainRequest) GetSql() string

func (*VTExplainRequest) ProtoMessage

func (*VTExplainRequest) ProtoMessage()

func (*VTExplainRequest) ProtoReflect

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

func (*VTExplainRequest) Reset

func (x *VTExplainRequest) Reset()

func (*VTExplainRequest) SetCluster

func (x *VTExplainRequest) SetCluster(v string)

func (*VTExplainRequest) SetKeyspace

func (x *VTExplainRequest) SetKeyspace(v string)

func (*VTExplainRequest) SetSql

func (x *VTExplainRequest) SetSql(v string)

func (*VTExplainRequest) String

func (x *VTExplainRequest) String() string

type VTExplainRequest_builder

type VTExplainRequest_builder struct {
	Cluster  string
	Keyspace string
	Sql      string
	// contains filtered or unexported fields
}

func (VTExplainRequest_builder) Build

type VTExplainResponse

type VTExplainResponse struct {
	Response string `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*VTExplainResponse) GetResponse

func (x *VTExplainResponse) GetResponse() string

func (*VTExplainResponse) ProtoMessage

func (*VTExplainResponse) ProtoMessage()

func (*VTExplainResponse) ProtoReflect

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

func (*VTExplainResponse) Reset

func (x *VTExplainResponse) Reset()

func (*VTExplainResponse) SetResponse

func (x *VTExplainResponse) SetResponse(v string)

func (*VTExplainResponse) String

func (x *VTExplainResponse) String() string

type VTExplainResponse_builder

type VTExplainResponse_builder struct {
	Response string
	// contains filtered or unexported fields
}

func (VTExplainResponse_builder) Build

type VTGate

type VTGate struct {

	// Hostname is the shortname of the VTGate.
	Hostname string `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"`
	// Pool is group the VTGate serves queries for. Some deployments segment
	// VTGates into groups or pools, based on the workloads they serve queries
	// for. Use of this field is optional.
	Pool string `protobuf:"bytes,2,opt,name=pool,proto3" json:"pool,omitempty"`
	// Cell is the topology cell the VTGate is in.
	Cell string `protobuf:"bytes,3,opt,name=cell,proto3" json:"cell,omitempty"`
	// Cluster is the cluster the VTGate serves.
	Cluster *Cluster `protobuf:"bytes,4,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// Keyspaces is the list of keyspaces-to-watch for the VTGate.
	Keyspaces []string `protobuf:"bytes,5,rep,name=keyspaces,proto3" json:"keyspaces,omitempty"`
	FQDN      string   `protobuf:"bytes,6,opt,name=FQDN,proto3" json:"FQDN,omitempty"`
	// contains filtered or unexported fields
}

VTGate represents information about a single VTGate host.

func (*VTGate) ClearCluster

func (x *VTGate) ClearCluster()

func (*VTGate) GetCell

func (x *VTGate) GetCell() string

func (*VTGate) GetCluster

func (x *VTGate) GetCluster() *Cluster

func (*VTGate) GetFQDN

func (x *VTGate) GetFQDN() string

func (*VTGate) GetHostname

func (x *VTGate) GetHostname() string

func (*VTGate) GetKeyspaces

func (x *VTGate) GetKeyspaces() []string

func (*VTGate) GetPool

func (x *VTGate) GetPool() string

func (*VTGate) HasCluster

func (x *VTGate) HasCluster() bool

func (*VTGate) ProtoMessage

func (*VTGate) ProtoMessage()

func (*VTGate) ProtoReflect

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

func (*VTGate) Reset

func (x *VTGate) Reset()

func (*VTGate) SetCell

func (x *VTGate) SetCell(v string)

func (*VTGate) SetCluster

func (x *VTGate) SetCluster(v *Cluster)

func (*VTGate) SetFQDN

func (x *VTGate) SetFQDN(v string)

func (*VTGate) SetHostname

func (x *VTGate) SetHostname(v string)

func (*VTGate) SetKeyspaces

func (x *VTGate) SetKeyspaces(v []string)

func (*VTGate) SetPool

func (x *VTGate) SetPool(v string)

func (*VTGate) String

func (x *VTGate) String() string

type VTGate_builder

type VTGate_builder struct {

	// Hostname is the shortname of the VTGate.
	Hostname string
	// Pool is group the VTGate serves queries for. Some deployments segment
	// VTGates into groups or pools, based on the workloads they serve queries
	// for. Use of this field is optional.
	Pool string
	// Cell is the topology cell the VTGate is in.
	Cell string
	// Cluster is the cluster the VTGate serves.
	Cluster *Cluster
	// Keyspaces is the list of keyspaces-to-watch for the VTGate.
	Keyspaces []string
	FQDN      string
	// contains filtered or unexported fields
}

func (VTGate_builder) Build

func (b0 VTGate_builder) Build() *VTGate

type ValidateKeyspaceRequest

type ValidateKeyspaceRequest struct {
	ClusterId   string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Keyspace    string `protobuf:"bytes,2,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	PingTablets bool   `protobuf:"varint,3,opt,name=ping_tablets,json=pingTablets,proto3" json:"ping_tablets,omitempty"`
	// contains filtered or unexported fields
}

func (*ValidateKeyspaceRequest) GetClusterId

func (x *ValidateKeyspaceRequest) GetClusterId() string

func (*ValidateKeyspaceRequest) GetKeyspace

func (x *ValidateKeyspaceRequest) GetKeyspace() string

func (*ValidateKeyspaceRequest) GetPingTablets

func (x *ValidateKeyspaceRequest) GetPingTablets() bool

func (*ValidateKeyspaceRequest) ProtoMessage

func (*ValidateKeyspaceRequest) ProtoMessage()

func (*ValidateKeyspaceRequest) ProtoReflect

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

func (*ValidateKeyspaceRequest) Reset

func (x *ValidateKeyspaceRequest) Reset()

func (*ValidateKeyspaceRequest) SetClusterId

func (x *ValidateKeyspaceRequest) SetClusterId(v string)

func (*ValidateKeyspaceRequest) SetKeyspace

func (x *ValidateKeyspaceRequest) SetKeyspace(v string)

func (*ValidateKeyspaceRequest) SetPingTablets

func (x *ValidateKeyspaceRequest) SetPingTablets(v bool)

func (*ValidateKeyspaceRequest) String

func (x *ValidateKeyspaceRequest) String() string

type ValidateKeyspaceRequest_builder

type ValidateKeyspaceRequest_builder struct {
	ClusterId   string
	Keyspace    string
	PingTablets bool
	// contains filtered or unexported fields
}

func (ValidateKeyspaceRequest_builder) Build

type ValidateRequest

type ValidateRequest struct {
	ClusterId   string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	PingTablets bool   `protobuf:"varint,2,opt,name=ping_tablets,json=pingTablets,proto3" json:"ping_tablets,omitempty"`
	// contains filtered or unexported fields
}

func (*ValidateRequest) GetClusterId

func (x *ValidateRequest) GetClusterId() string

func (*ValidateRequest) GetPingTablets

func (x *ValidateRequest) GetPingTablets() bool

func (*ValidateRequest) ProtoMessage

func (*ValidateRequest) ProtoMessage()

func (*ValidateRequest) ProtoReflect

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

func (*ValidateRequest) Reset

func (x *ValidateRequest) Reset()

func (*ValidateRequest) SetClusterId

func (x *ValidateRequest) SetClusterId(v string)

func (*ValidateRequest) SetPingTablets

func (x *ValidateRequest) SetPingTablets(v bool)

func (*ValidateRequest) String

func (x *ValidateRequest) String() string

type ValidateRequest_builder

type ValidateRequest_builder struct {
	ClusterId   string
	PingTablets bool
	// contains filtered or unexported fields
}

func (ValidateRequest_builder) Build

type ValidateSchemaKeyspaceRequest

type ValidateSchemaKeyspaceRequest struct {
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Keyspace  string `protobuf:"bytes,2,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	// contains filtered or unexported fields
}

func (*ValidateSchemaKeyspaceRequest) GetClusterId

func (x *ValidateSchemaKeyspaceRequest) GetClusterId() string

func (*ValidateSchemaKeyspaceRequest) GetKeyspace

func (x *ValidateSchemaKeyspaceRequest) GetKeyspace() string

func (*ValidateSchemaKeyspaceRequest) ProtoMessage

func (*ValidateSchemaKeyspaceRequest) ProtoMessage()

func (*ValidateSchemaKeyspaceRequest) ProtoReflect

func (*ValidateSchemaKeyspaceRequest) Reset

func (x *ValidateSchemaKeyspaceRequest) Reset()

func (*ValidateSchemaKeyspaceRequest) SetClusterId

func (x *ValidateSchemaKeyspaceRequest) SetClusterId(v string)

func (*ValidateSchemaKeyspaceRequest) SetKeyspace

func (x *ValidateSchemaKeyspaceRequest) SetKeyspace(v string)

func (*ValidateSchemaKeyspaceRequest) String

type ValidateSchemaKeyspaceRequest_builder

type ValidateSchemaKeyspaceRequest_builder struct {
	ClusterId string
	Keyspace  string
	// contains filtered or unexported fields
}

func (ValidateSchemaKeyspaceRequest_builder) Build

type ValidateShardRequest

type ValidateShardRequest struct {
	ClusterId   string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Keyspace    string `protobuf:"bytes,2,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	Shard       string `protobuf:"bytes,3,opt,name=shard,proto3" json:"shard,omitempty"`
	PingTablets bool   `protobuf:"varint,4,opt,name=ping_tablets,json=pingTablets,proto3" json:"ping_tablets,omitempty"`
	// contains filtered or unexported fields
}

func (*ValidateShardRequest) GetClusterId

func (x *ValidateShardRequest) GetClusterId() string

func (*ValidateShardRequest) GetKeyspace

func (x *ValidateShardRequest) GetKeyspace() string

func (*ValidateShardRequest) GetPingTablets

func (x *ValidateShardRequest) GetPingTablets() bool

func (*ValidateShardRequest) GetShard

func (x *ValidateShardRequest) GetShard() string

func (*ValidateShardRequest) ProtoMessage

func (*ValidateShardRequest) ProtoMessage()

func (*ValidateShardRequest) ProtoReflect

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

func (*ValidateShardRequest) Reset

func (x *ValidateShardRequest) Reset()

func (*ValidateShardRequest) SetClusterId

func (x *ValidateShardRequest) SetClusterId(v string)

func (*ValidateShardRequest) SetKeyspace

func (x *ValidateShardRequest) SetKeyspace(v string)

func (*ValidateShardRequest) SetPingTablets

func (x *ValidateShardRequest) SetPingTablets(v bool)

func (*ValidateShardRequest) SetShard

func (x *ValidateShardRequest) SetShard(v string)

func (*ValidateShardRequest) String

func (x *ValidateShardRequest) String() string

type ValidateShardRequest_builder

type ValidateShardRequest_builder struct {
	ClusterId   string
	Keyspace    string
	Shard       string
	PingTablets bool
	// contains filtered or unexported fields
}

func (ValidateShardRequest_builder) Build

type ValidateVersionKeyspaceRequest

type ValidateVersionKeyspaceRequest struct {
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Keyspace  string `protobuf:"bytes,2,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	// contains filtered or unexported fields
}

func (*ValidateVersionKeyspaceRequest) GetClusterId

func (x *ValidateVersionKeyspaceRequest) GetClusterId() string

func (*ValidateVersionKeyspaceRequest) GetKeyspace

func (x *ValidateVersionKeyspaceRequest) GetKeyspace() string

func (*ValidateVersionKeyspaceRequest) ProtoMessage

func (*ValidateVersionKeyspaceRequest) ProtoMessage()

func (*ValidateVersionKeyspaceRequest) ProtoReflect

func (*ValidateVersionKeyspaceRequest) Reset

func (x *ValidateVersionKeyspaceRequest) Reset()

func (*ValidateVersionKeyspaceRequest) SetClusterId

func (x *ValidateVersionKeyspaceRequest) SetClusterId(v string)

func (*ValidateVersionKeyspaceRequest) SetKeyspace

func (x *ValidateVersionKeyspaceRequest) SetKeyspace(v string)

func (*ValidateVersionKeyspaceRequest) String

type ValidateVersionKeyspaceRequest_builder

type ValidateVersionKeyspaceRequest_builder struct {
	ClusterId string
	Keyspace  string
	// contains filtered or unexported fields
}

func (ValidateVersionKeyspaceRequest_builder) Build

type ValidateVersionShardRequest

type ValidateVersionShardRequest struct {
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Keyspace  string `protobuf:"bytes,2,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	Shard     string `protobuf:"bytes,3,opt,name=shard,proto3" json:"shard,omitempty"`
	// contains filtered or unexported fields
}

func (*ValidateVersionShardRequest) GetClusterId

func (x *ValidateVersionShardRequest) GetClusterId() string

func (*ValidateVersionShardRequest) GetKeyspace

func (x *ValidateVersionShardRequest) GetKeyspace() string

func (*ValidateVersionShardRequest) GetShard

func (x *ValidateVersionShardRequest) GetShard() string

func (*ValidateVersionShardRequest) ProtoMessage

func (*ValidateVersionShardRequest) ProtoMessage()

func (*ValidateVersionShardRequest) ProtoReflect

func (*ValidateVersionShardRequest) Reset

func (x *ValidateVersionShardRequest) Reset()

func (*ValidateVersionShardRequest) SetClusterId

func (x *ValidateVersionShardRequest) SetClusterId(v string)

func (*ValidateVersionShardRequest) SetKeyspace

func (x *ValidateVersionShardRequest) SetKeyspace(v string)

func (*ValidateVersionShardRequest) SetShard

func (x *ValidateVersionShardRequest) SetShard(v string)

func (*ValidateVersionShardRequest) String

func (x *ValidateVersionShardRequest) String() string

type ValidateVersionShardRequest_builder

type ValidateVersionShardRequest_builder struct {
	ClusterId string
	Keyspace  string
	Shard     string
	// contains filtered or unexported fields
}

func (ValidateVersionShardRequest_builder) Build

type Vtctld

type Vtctld struct {
	Hostname string   `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"`
	Cluster  *Cluster `protobuf:"bytes,2,opt,name=cluster,proto3" json:"cluster,omitempty"`
	FQDN     string   `protobuf:"bytes,3,opt,name=FQDN,proto3" json:"FQDN,omitempty"`
	// contains filtered or unexported fields
}

Vtctld represents information about a single Vtctld host.

func (*Vtctld) ClearCluster

func (x *Vtctld) ClearCluster()

func (*Vtctld) GetCluster

func (x *Vtctld) GetCluster() *Cluster

func (*Vtctld) GetFQDN

func (x *Vtctld) GetFQDN() string

func (*Vtctld) GetHostname

func (x *Vtctld) GetHostname() string

func (*Vtctld) HasCluster

func (x *Vtctld) HasCluster() bool

func (*Vtctld) ProtoMessage

func (*Vtctld) ProtoMessage()

func (*Vtctld) ProtoReflect

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

func (*Vtctld) Reset

func (x *Vtctld) Reset()

func (*Vtctld) SetCluster

func (x *Vtctld) SetCluster(v *Cluster)

func (*Vtctld) SetFQDN

func (x *Vtctld) SetFQDN(v string)

func (*Vtctld) SetHostname

func (x *Vtctld) SetHostname(v string)

func (*Vtctld) String

func (x *Vtctld) String() string

type Vtctld_builder

type Vtctld_builder struct {
	Hostname string
	Cluster  *Cluster
	FQDN     string
	// contains filtered or unexported fields
}

func (Vtctld_builder) Build

func (b0 Vtctld_builder) Build() *Vtctld

type Workflow

type Workflow struct {
	Cluster  *Cluster       `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	Keyspace string         `protobuf:"bytes,2,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	Workflow *dev2.Workflow `protobuf:"bytes,3,opt,name=workflow,proto3" json:"workflow,omitempty"`
	// contains filtered or unexported fields
}

func (*Workflow) ClearCluster

func (x *Workflow) ClearCluster()

func (*Workflow) ClearWorkflow

func (x *Workflow) ClearWorkflow()

func (*Workflow) GetCluster

func (x *Workflow) GetCluster() *Cluster

func (*Workflow) GetKeyspace

func (x *Workflow) GetKeyspace() string

func (*Workflow) GetWorkflow

func (x *Workflow) GetWorkflow() *dev2.Workflow

func (*Workflow) HasCluster

func (x *Workflow) HasCluster() bool

func (*Workflow) HasWorkflow

func (x *Workflow) HasWorkflow() bool

func (*Workflow) ProtoMessage

func (*Workflow) ProtoMessage()

func (*Workflow) ProtoReflect

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

func (*Workflow) Reset

func (x *Workflow) Reset()

func (*Workflow) SetCluster

func (x *Workflow) SetCluster(v *Cluster)

func (*Workflow) SetKeyspace

func (x *Workflow) SetKeyspace(v string)

func (*Workflow) SetWorkflow

func (x *Workflow) SetWorkflow(v *dev2.Workflow)

func (*Workflow) String

func (x *Workflow) String() string

type WorkflowDeleteRequest

type WorkflowDeleteRequest struct {
	ClusterId string                      `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Request   *dev2.WorkflowDeleteRequest `protobuf:"bytes,2,opt,name=request,proto3" json:"request,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkflowDeleteRequest) ClearRequest

func (x *WorkflowDeleteRequest) ClearRequest()

func (*WorkflowDeleteRequest) GetClusterId

func (x *WorkflowDeleteRequest) GetClusterId() string

func (*WorkflowDeleteRequest) GetRequest

func (*WorkflowDeleteRequest) HasRequest

func (x *WorkflowDeleteRequest) HasRequest() bool

func (*WorkflowDeleteRequest) ProtoMessage

func (*WorkflowDeleteRequest) ProtoMessage()

func (*WorkflowDeleteRequest) ProtoReflect

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

func (*WorkflowDeleteRequest) Reset

func (x *WorkflowDeleteRequest) Reset()

func (*WorkflowDeleteRequest) SetClusterId

func (x *WorkflowDeleteRequest) SetClusterId(v string)

func (*WorkflowDeleteRequest) SetRequest

func (*WorkflowDeleteRequest) String

func (x *WorkflowDeleteRequest) String() string

type WorkflowDeleteRequest_builder

type WorkflowDeleteRequest_builder struct {
	ClusterId string
	Request   *dev2.WorkflowDeleteRequest
	// contains filtered or unexported fields
}

func (WorkflowDeleteRequest_builder) Build

type WorkflowSwitchTrafficRequest

type WorkflowSwitchTrafficRequest struct {
	ClusterId string                             `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Request   *dev2.WorkflowSwitchTrafficRequest `protobuf:"bytes,2,opt,name=request,proto3" json:"request,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkflowSwitchTrafficRequest) ClearRequest

func (x *WorkflowSwitchTrafficRequest) ClearRequest()

func (*WorkflowSwitchTrafficRequest) GetClusterId

func (x *WorkflowSwitchTrafficRequest) GetClusterId() string

func (*WorkflowSwitchTrafficRequest) GetRequest

func (*WorkflowSwitchTrafficRequest) HasRequest

func (x *WorkflowSwitchTrafficRequest) HasRequest() bool

func (*WorkflowSwitchTrafficRequest) ProtoMessage

func (*WorkflowSwitchTrafficRequest) ProtoMessage()

func (*WorkflowSwitchTrafficRequest) ProtoReflect

func (*WorkflowSwitchTrafficRequest) Reset

func (x *WorkflowSwitchTrafficRequest) Reset()

func (*WorkflowSwitchTrafficRequest) SetClusterId

func (x *WorkflowSwitchTrafficRequest) SetClusterId(v string)

func (*WorkflowSwitchTrafficRequest) SetRequest

func (*WorkflowSwitchTrafficRequest) String

type WorkflowSwitchTrafficRequest_builder

type WorkflowSwitchTrafficRequest_builder struct {
	ClusterId string
	Request   *dev2.WorkflowSwitchTrafficRequest
	// contains filtered or unexported fields
}

func (WorkflowSwitchTrafficRequest_builder) Build

type Workflow_builder

type Workflow_builder struct {
	Cluster  *Cluster
	Keyspace string
	Workflow *dev2.Workflow
	// contains filtered or unexported fields
}

func (Workflow_builder) Build

func (b0 Workflow_builder) Build() *Workflow

Source Files

  • vtadmin.pb.go

Jump to

Keyboard shortcuts

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