dev

package
v1.29.1-20231208022702... Latest Latest
Warning

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

Go to latest
Published: unknown License: Apache-2.0 Imports: 14 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	MaterializationIntent_name = map[int32]string{
		0: "CUSTOM",
		1: "MOVETABLES",
		2: "CREATELOOKUPINDEX",
	}
	MaterializationIntent_value = map[string]int32{
		"CUSTOM":            0,
		"MOVETABLES":        1,
		"CREATELOOKUPINDEX": 2,
	}
)

Enum value maps for MaterializationIntent.

View Source
var (
	QueryOrdering_name = map[int32]string{
		0: "NONE",
		1: "ASCENDING",
		2: "DESCENDING",
	}
	QueryOrdering_value = map[string]int32{
		"NONE":       0,
		"ASCENDING":  1,
		"DESCENDING": 2,
	}
)

Enum value maps for QueryOrdering.

View Source
var (
	SchemaMigration_Strategy_name = map[int32]string{
		0: "VITESS",

		1: "GHOST",
		2: "PTOSC",
		3: "DIRECT",
		4: "MYSQL",
	}
	SchemaMigration_Strategy_value = map[string]int32{
		"VITESS": 0,
		"ONLINE": 0,
		"GHOST":  1,
		"PTOSC":  2,
		"DIRECT": 3,
		"MYSQL":  4,
	}
)

Enum value maps for SchemaMigration_Strategy.

View Source
var (
	SchemaMigration_Status_name = map[int32]string{
		0: "UNKNOWN",
		1: "REQUESTED",
		2: "CANCELLED",
		3: "QUEUED",
		4: "READY",
		5: "RUNNING",
		6: "COMPLETE",
		7: "FAILED",
	}
	SchemaMigration_Status_value = map[string]int32{
		"UNKNOWN":   0,
		"REQUESTED": 1,
		"CANCELLED": 2,
		"QUEUED":    3,
		"READY":     4,
		"RUNNING":   5,
		"COMPLETE":  6,
		"FAILED":    7,
	}
)

Enum value maps for SchemaMigration_Status.

View Source
var File_vitess_vtctldata_dev_vtctldata_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type AddCellInfoRequest

type AddCellInfoRequest struct {
	Name     string         `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	CellInfo *dev2.CellInfo `protobuf:"bytes,2,opt,name=cell_info,json=cellInfo,proto3" json:"cell_info,omitempty"`
	// contains filtered or unexported fields
}

func (*AddCellInfoRequest) Descriptor deprecated

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

Deprecated: Use AddCellInfoRequest.ProtoReflect.Descriptor instead.

func (*AddCellInfoRequest) GetCellInfo

func (x *AddCellInfoRequest) GetCellInfo() *dev2.CellInfo

func (*AddCellInfoRequest) GetName

func (x *AddCellInfoRequest) GetName() string

func (*AddCellInfoRequest) ProtoMessage

func (*AddCellInfoRequest) ProtoMessage()

func (*AddCellInfoRequest) ProtoReflect

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

func (*AddCellInfoRequest) Reset

func (x *AddCellInfoRequest) Reset()

func (*AddCellInfoRequest) String

func (x *AddCellInfoRequest) String() string

type AddCellInfoResponse

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

func (*AddCellInfoResponse) Descriptor deprecated

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

Deprecated: Use AddCellInfoResponse.ProtoReflect.Descriptor instead.

func (*AddCellInfoResponse) ProtoMessage

func (*AddCellInfoResponse) ProtoMessage()

func (*AddCellInfoResponse) ProtoReflect

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

func (*AddCellInfoResponse) Reset

func (x *AddCellInfoResponse) Reset()

func (*AddCellInfoResponse) String

func (x *AddCellInfoResponse) String() string

type AddCellsAliasRequest

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

func (*AddCellsAliasRequest) Descriptor deprecated

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

Deprecated: Use AddCellsAliasRequest.ProtoReflect.Descriptor instead.

func (*AddCellsAliasRequest) GetCells

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

func (*AddCellsAliasRequest) GetName

func (x *AddCellsAliasRequest) GetName() string

func (*AddCellsAliasRequest) ProtoMessage

func (*AddCellsAliasRequest) ProtoMessage()

func (*AddCellsAliasRequest) ProtoReflect

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

func (*AddCellsAliasRequest) Reset

func (x *AddCellsAliasRequest) Reset()

func (*AddCellsAliasRequest) String

func (x *AddCellsAliasRequest) String() string

type AddCellsAliasResponse

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

func (*AddCellsAliasResponse) Descriptor deprecated

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

Deprecated: Use AddCellsAliasResponse.ProtoReflect.Descriptor instead.

func (*AddCellsAliasResponse) ProtoMessage

func (*AddCellsAliasResponse) ProtoMessage()

func (*AddCellsAliasResponse) ProtoReflect

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

func (*AddCellsAliasResponse) Reset

func (x *AddCellsAliasResponse) Reset()

func (*AddCellsAliasResponse) String

func (x *AddCellsAliasResponse) String() string

type ApplyRoutingRulesRequest

type ApplyRoutingRulesRequest struct {
	RoutingRules *dev4.RoutingRules `protobuf:"bytes,1,opt,name=routing_rules,json=routingRules,proto3" json:"routing_rules,omitempty"`
	// SkipRebuild, if set, will cause ApplyRoutingRules to skip rebuilding the
	// SrvVSchema objects in each cell in RebuildCells.
	SkipRebuild bool `protobuf:"varint,2,opt,name=skip_rebuild,json=skipRebuild,proto3" json:"skip_rebuild,omitempty"`
	// RebuildCells limits the SrvVSchema rebuild to the specified cells. If not
	// provided the SrvVSchema will be rebuilt in every cell in the topology.
	//
	// Ignored if SkipRebuild is set.
	RebuildCells []string `protobuf:"bytes,3,rep,name=rebuild_cells,json=rebuildCells,proto3" json:"rebuild_cells,omitempty"`
	// contains filtered or unexported fields
}

func (*ApplyRoutingRulesRequest) Descriptor deprecated

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

Deprecated: Use ApplyRoutingRulesRequest.ProtoReflect.Descriptor instead.

func (*ApplyRoutingRulesRequest) GetRebuildCells

func (x *ApplyRoutingRulesRequest) GetRebuildCells() []string

func (*ApplyRoutingRulesRequest) GetRoutingRules

func (x *ApplyRoutingRulesRequest) GetRoutingRules() *dev4.RoutingRules

func (*ApplyRoutingRulesRequest) GetSkipRebuild

func (x *ApplyRoutingRulesRequest) GetSkipRebuild() bool

func (*ApplyRoutingRulesRequest) ProtoMessage

func (*ApplyRoutingRulesRequest) ProtoMessage()

func (*ApplyRoutingRulesRequest) ProtoReflect

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

func (*ApplyRoutingRulesRequest) Reset

func (x *ApplyRoutingRulesRequest) Reset()

func (*ApplyRoutingRulesRequest) String

func (x *ApplyRoutingRulesRequest) String() string

type ApplyRoutingRulesResponse

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

func (*ApplyRoutingRulesResponse) Descriptor deprecated

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

Deprecated: Use ApplyRoutingRulesResponse.ProtoReflect.Descriptor instead.

func (*ApplyRoutingRulesResponse) ProtoMessage

func (*ApplyRoutingRulesResponse) ProtoMessage()

func (*ApplyRoutingRulesResponse) ProtoReflect

func (*ApplyRoutingRulesResponse) Reset

func (x *ApplyRoutingRulesResponse) Reset()

func (*ApplyRoutingRulesResponse) String

func (x *ApplyRoutingRulesResponse) String() string

type ApplySchemaRequest

type ApplySchemaRequest struct {
	Keyspace string `protobuf:"bytes,1,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	// SQL commands to run.
	Sql []string `protobuf:"bytes,3,rep,name=sql,proto3" json:"sql,omitempty"`
	// Online DDL strategy, compatible with @@ddl_strategy session variable (examples: 'gh-ost', 'pt-osc', 'gh-ost --max-load=Threads_running=100'")
	DdlStrategy string `protobuf:"bytes,4,opt,name=ddl_strategy,json=ddlStrategy,proto3" json:"ddl_strategy,omitempty"`
	// Optional: explicit UUIDs for migration.
	// If given, must match number of DDL changes
	UuidList []string `protobuf:"bytes,5,rep,name=uuid_list,json=uuidList,proto3" json:"uuid_list,omitempty"`
	// For Online DDL, optionally supply a custom unique string used as context for the migration(s) in this command.
	// By default a unique context is auto-generated by Vitess
	MigrationContext string `protobuf:"bytes,6,opt,name=migration_context,json=migrationContext,proto3" json:"migration_context,omitempty"`
	// WaitReplicasTimeout is the duration of time to wait for replicas to catch
	// up in reparenting.
	WaitReplicasTimeout *dev3.Duration `protobuf:"bytes,7,opt,name=wait_replicas_timeout,json=waitReplicasTimeout,proto3" json:"wait_replicas_timeout,omitempty"`
	// caller_id identifies the caller. This is the effective caller ID,
	// set by the application to further identify the caller.
	CallerId *dev5.CallerID `protobuf:"bytes,9,opt,name=caller_id,json=callerId,proto3" json:"caller_id,omitempty"`
	// BatchSize indicates how many queries to apply together
	BatchSize int64 `protobuf:"varint,10,opt,name=batch_size,json=batchSize,proto3" json:"batch_size,omitempty"`
	// contains filtered or unexported fields
}

func (*ApplySchemaRequest) Descriptor deprecated

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

Deprecated: Use ApplySchemaRequest.ProtoReflect.Descriptor instead.

func (*ApplySchemaRequest) GetBatchSize

func (x *ApplySchemaRequest) GetBatchSize() int64

func (*ApplySchemaRequest) GetCallerId

func (x *ApplySchemaRequest) GetCallerId() *dev5.CallerID

func (*ApplySchemaRequest) GetDdlStrategy

func (x *ApplySchemaRequest) GetDdlStrategy() string

func (*ApplySchemaRequest) GetKeyspace

func (x *ApplySchemaRequest) GetKeyspace() string

func (*ApplySchemaRequest) GetMigrationContext

func (x *ApplySchemaRequest) GetMigrationContext() string

func (*ApplySchemaRequest) GetSql

func (x *ApplySchemaRequest) GetSql() []string

func (*ApplySchemaRequest) GetUuidList

func (x *ApplySchemaRequest) GetUuidList() []string

func (*ApplySchemaRequest) GetWaitReplicasTimeout

func (x *ApplySchemaRequest) GetWaitReplicasTimeout() *dev3.Duration

func (*ApplySchemaRequest) ProtoMessage

func (*ApplySchemaRequest) ProtoMessage()

func (*ApplySchemaRequest) ProtoReflect

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

func (*ApplySchemaRequest) Reset

func (x *ApplySchemaRequest) Reset()

func (*ApplySchemaRequest) String

func (x *ApplySchemaRequest) String() string

type ApplySchemaResponse

type ApplySchemaResponse struct {
	UuidList            []string          `protobuf:"bytes,1,rep,name=uuid_list,json=uuidList,proto3" json:"uuid_list,omitempty"`
	RowsAffectedByShard map[string]uint64 `` /* 211-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ApplySchemaResponse) Descriptor deprecated

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

Deprecated: Use ApplySchemaResponse.ProtoReflect.Descriptor instead.

func (*ApplySchemaResponse) GetRowsAffectedByShard

func (x *ApplySchemaResponse) GetRowsAffectedByShard() map[string]uint64

func (*ApplySchemaResponse) GetUuidList

func (x *ApplySchemaResponse) GetUuidList() []string

func (*ApplySchemaResponse) ProtoMessage

func (*ApplySchemaResponse) ProtoMessage()

func (*ApplySchemaResponse) ProtoReflect

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

func (*ApplySchemaResponse) Reset

func (x *ApplySchemaResponse) Reset()

func (*ApplySchemaResponse) String

func (x *ApplySchemaResponse) String() string

type ApplyShardRoutingRulesRequest

type ApplyShardRoutingRulesRequest struct {
	ShardRoutingRules *dev4.ShardRoutingRules `protobuf:"bytes,1,opt,name=shard_routing_rules,json=shardRoutingRules,proto3" json:"shard_routing_rules,omitempty"`
	// SkipRebuild, if set, will cause ApplyShardRoutingRules to skip rebuilding the
	// SrvVSchema objects in each cell in RebuildCells.
	SkipRebuild bool `protobuf:"varint,2,opt,name=skip_rebuild,json=skipRebuild,proto3" json:"skip_rebuild,omitempty"`
	// RebuildCells limits the SrvVSchema rebuild to the specified cells. If not
	// provided the SrvVSchema will be rebuilt in every cell in the topology.
	//
	// Ignored if SkipRebuild is set.
	RebuildCells []string `protobuf:"bytes,3,rep,name=rebuild_cells,json=rebuildCells,proto3" json:"rebuild_cells,omitempty"`
	// contains filtered or unexported fields
}

func (*ApplyShardRoutingRulesRequest) Descriptor deprecated

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

Deprecated: Use ApplyShardRoutingRulesRequest.ProtoReflect.Descriptor instead.

func (*ApplyShardRoutingRulesRequest) GetRebuildCells

func (x *ApplyShardRoutingRulesRequest) GetRebuildCells() []string

func (*ApplyShardRoutingRulesRequest) GetShardRoutingRules

func (x *ApplyShardRoutingRulesRequest) GetShardRoutingRules() *dev4.ShardRoutingRules

func (*ApplyShardRoutingRulesRequest) GetSkipRebuild

func (x *ApplyShardRoutingRulesRequest) GetSkipRebuild() bool

func (*ApplyShardRoutingRulesRequest) ProtoMessage

func (*ApplyShardRoutingRulesRequest) ProtoMessage()

func (*ApplyShardRoutingRulesRequest) ProtoReflect

func (*ApplyShardRoutingRulesRequest) Reset

func (x *ApplyShardRoutingRulesRequest) Reset()

func (*ApplyShardRoutingRulesRequest) String

type ApplyShardRoutingRulesResponse

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

func (*ApplyShardRoutingRulesResponse) Descriptor deprecated

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

Deprecated: Use ApplyShardRoutingRulesResponse.ProtoReflect.Descriptor instead.

func (*ApplyShardRoutingRulesResponse) ProtoMessage

func (*ApplyShardRoutingRulesResponse) ProtoMessage()

func (*ApplyShardRoutingRulesResponse) ProtoReflect

func (*ApplyShardRoutingRulesResponse) Reset

func (x *ApplyShardRoutingRulesResponse) Reset()

func (*ApplyShardRoutingRulesResponse) String

type ApplyVSchemaRequest

type ApplyVSchemaRequest struct {
	Keyspace    string         `protobuf:"bytes,1,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	SkipRebuild bool           `protobuf:"varint,2,opt,name=skip_rebuild,json=skipRebuild,proto3" json:"skip_rebuild,omitempty"`
	DryRun      bool           `protobuf:"varint,3,opt,name=dry_run,json=dryRun,proto3" json:"dry_run,omitempty"`
	Cells       []string       `protobuf:"bytes,4,rep,name=cells,proto3" json:"cells,omitempty"`
	VSchema     *dev4.Keyspace `protobuf:"bytes,5,opt,name=v_schema,json=vSchema,proto3" json:"v_schema,omitempty"`
	Sql         string         `protobuf:"bytes,6,opt,name=sql,proto3" json:"sql,omitempty"`
	// contains filtered or unexported fields
}

func (*ApplyVSchemaRequest) Descriptor deprecated

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

Deprecated: Use ApplyVSchemaRequest.ProtoReflect.Descriptor instead.

func (*ApplyVSchemaRequest) GetCells

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

func (*ApplyVSchemaRequest) GetDryRun

func (x *ApplyVSchemaRequest) GetDryRun() bool

func (*ApplyVSchemaRequest) GetKeyspace

func (x *ApplyVSchemaRequest) GetKeyspace() string

func (*ApplyVSchemaRequest) GetSkipRebuild

func (x *ApplyVSchemaRequest) GetSkipRebuild() bool

func (*ApplyVSchemaRequest) GetSql

func (x *ApplyVSchemaRequest) GetSql() string

func (*ApplyVSchemaRequest) GetVSchema

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

func (*ApplyVSchemaRequest) ProtoMessage

func (*ApplyVSchemaRequest) ProtoMessage()

func (*ApplyVSchemaRequest) ProtoReflect

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

func (*ApplyVSchemaRequest) Reset

func (x *ApplyVSchemaRequest) Reset()

func (*ApplyVSchemaRequest) String

func (x *ApplyVSchemaRequest) String() string

type ApplyVSchemaResponse

type ApplyVSchemaResponse struct {
	VSchema *dev4.Keyspace `protobuf:"bytes,1,opt,name=v_schema,json=vSchema,proto3" json:"v_schema,omitempty"`
	// contains filtered or unexported fields
}

func (*ApplyVSchemaResponse) Descriptor deprecated

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

Deprecated: Use ApplyVSchemaResponse.ProtoReflect.Descriptor instead.

func (*ApplyVSchemaResponse) GetVSchema

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

func (*ApplyVSchemaResponse) ProtoMessage

func (*ApplyVSchemaResponse) ProtoMessage()

func (*ApplyVSchemaResponse) ProtoReflect

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

func (*ApplyVSchemaResponse) Reset

func (x *ApplyVSchemaResponse) Reset()

func (*ApplyVSchemaResponse) String

func (x *ApplyVSchemaResponse) String() string

type BackupRequest

type BackupRequest struct {
	TabletAlias *dev2.TabletAlias `protobuf:"bytes,1,opt,name=tablet_alias,json=tabletAlias,proto3" json:"tablet_alias,omitempty"`
	// AllowPrimary allows the backup to proceed if TabletAlias is a PRIMARY.
	//
	// WARNING: If using the builtin backup engine, this will shutdown mysqld on
	// the primary for the duration of the backup, and no writes will be possible.
	AllowPrimary bool `protobuf:"varint,2,opt,name=allow_primary,json=allowPrimary,proto3" json:"allow_primary,omitempty"`
	// Concurrency specifies the number of compression/checksum jobs to run
	// simultaneously.
	Concurrency uint64 `protobuf:"varint,3,opt,name=concurrency,proto3" json:"concurrency,omitempty"`
	// IncrementalFromPos indicates a position of a previous backup. When this value is non-empty
	// then the backup becomes incremental and applies as of given position.
	IncrementalFromPos string `protobuf:"bytes,4,opt,name=incremental_from_pos,json=incrementalFromPos,proto3" json:"incremental_from_pos,omitempty"`
	// UpgradeSafe indicates if the backup should be taken with innodb_fast_shutdown=0
	// so that it's a backup that can be used for an upgrade.
	UpgradeSafe bool `protobuf:"varint,5,opt,name=upgrade_safe,json=upgradeSafe,proto3" json:"upgrade_safe,omitempty"`
	// contains filtered or unexported fields
}

func (*BackupRequest) Descriptor deprecated

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

Deprecated: Use BackupRequest.ProtoReflect.Descriptor instead.

func (*BackupRequest) GetAllowPrimary

func (x *BackupRequest) GetAllowPrimary() bool

func (*BackupRequest) GetConcurrency

func (x *BackupRequest) GetConcurrency() uint64

func (*BackupRequest) GetIncrementalFromPos

func (x *BackupRequest) GetIncrementalFromPos() string

func (*BackupRequest) GetTabletAlias

func (x *BackupRequest) GetTabletAlias() *dev2.TabletAlias

func (*BackupRequest) GetUpgradeSafe

func (x *BackupRequest) GetUpgradeSafe() bool

func (*BackupRequest) ProtoMessage

func (*BackupRequest) ProtoMessage()

func (*BackupRequest) ProtoReflect

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

func (*BackupRequest) Reset

func (x *BackupRequest) Reset()

func (*BackupRequest) String

func (x *BackupRequest) String() string

type BackupResponse

type BackupResponse struct {

	// TabletAlias is the alias being used for the backup.
	TabletAlias *dev2.TabletAlias `protobuf:"bytes,1,opt,name=tablet_alias,json=tabletAlias,proto3" json:"tablet_alias,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"`
	Event       *dev.Event        `protobuf:"bytes,4,opt,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

func (*BackupResponse) Descriptor deprecated

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

Deprecated: Use BackupResponse.ProtoReflect.Descriptor instead.

func (*BackupResponse) GetEvent

func (x *BackupResponse) GetEvent() *dev.Event

func (*BackupResponse) GetKeyspace

func (x *BackupResponse) GetKeyspace() string

func (*BackupResponse) GetShard

func (x *BackupResponse) GetShard() string

func (*BackupResponse) GetTabletAlias

func (x *BackupResponse) GetTabletAlias() *dev2.TabletAlias

func (*BackupResponse) ProtoMessage

func (*BackupResponse) ProtoMessage()

func (*BackupResponse) ProtoReflect

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

func (*BackupResponse) Reset

func (x *BackupResponse) Reset()

func (*BackupResponse) String

func (x *BackupResponse) String() string

type BackupShardRequest

type BackupShardRequest 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"`
	// AllowPrimary allows the backup to occur on a PRIMARY tablet. See
	// BackupRequest.AllowPrimary for warnings and caveats.
	AllowPrimary bool `protobuf:"varint,3,opt,name=allow_primary,json=allowPrimary,proto3" json:"allow_primary,omitempty"`
	// Concurrency specifies the number of compression/checksum jobs to run
	// simultaneously.
	Concurrency uint64 `protobuf:"varint,4,opt,name=concurrency,proto3" json:"concurrency,omitempty"`
	// UpgradeSafe indicates if the backup should be taken with innodb_fast_shutdown=0
	// so that it's a backup that can be used for an upgrade.
	UpgradeSafe bool `protobuf:"varint,5,opt,name=upgrade_safe,json=upgradeSafe,proto3" json:"upgrade_safe,omitempty"`
	// IncrementalFromPos indicates a position of a previous backup. When this value is non-empty
	// then the backup becomes incremental and applies as of given position.
	IncrementalFromPos string `protobuf:"bytes,6,opt,name=incremental_from_pos,json=incrementalFromPos,proto3" json:"incremental_from_pos,omitempty"`
	// contains filtered or unexported fields
}

func (*BackupShardRequest) Descriptor deprecated

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

Deprecated: Use BackupShardRequest.ProtoReflect.Descriptor instead.

func (*BackupShardRequest) GetAllowPrimary

func (x *BackupShardRequest) GetAllowPrimary() bool

func (*BackupShardRequest) GetConcurrency

func (x *BackupShardRequest) GetConcurrency() uint64

func (*BackupShardRequest) GetIncrementalFromPos

func (x *BackupShardRequest) GetIncrementalFromPos() string

func (*BackupShardRequest) GetKeyspace

func (x *BackupShardRequest) GetKeyspace() string

func (*BackupShardRequest) GetShard

func (x *BackupShardRequest) GetShard() string

func (*BackupShardRequest) GetUpgradeSafe

func (x *BackupShardRequest) GetUpgradeSafe() bool

func (*BackupShardRequest) ProtoMessage

func (*BackupShardRequest) ProtoMessage()

func (*BackupShardRequest) ProtoReflect

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

func (*BackupShardRequest) Reset

func (x *BackupShardRequest) Reset()

func (*BackupShardRequest) String

func (x *BackupShardRequest) String() string

type CancelSchemaMigrationRequest

type CancelSchemaMigrationRequest struct {
	Keyspace string `protobuf:"bytes,1,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	Uuid     string `protobuf:"bytes,2,opt,name=uuid,proto3" json:"uuid,omitempty"`
	// contains filtered or unexported fields
}

func (*CancelSchemaMigrationRequest) Descriptor deprecated

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

Deprecated: Use CancelSchemaMigrationRequest.ProtoReflect.Descriptor instead.

func (*CancelSchemaMigrationRequest) GetKeyspace

func (x *CancelSchemaMigrationRequest) GetKeyspace() string

func (*CancelSchemaMigrationRequest) GetUuid

func (x *CancelSchemaMigrationRequest) GetUuid() string

func (*CancelSchemaMigrationRequest) ProtoMessage

func (*CancelSchemaMigrationRequest) ProtoMessage()

func (*CancelSchemaMigrationRequest) ProtoReflect

func (*CancelSchemaMigrationRequest) Reset

func (x *CancelSchemaMigrationRequest) Reset()

func (*CancelSchemaMigrationRequest) String

type CancelSchemaMigrationResponse

type CancelSchemaMigrationResponse struct {
	RowsAffectedByShard map[string]uint64 `` /* 211-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CancelSchemaMigrationResponse) Descriptor deprecated

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

Deprecated: Use CancelSchemaMigrationResponse.ProtoReflect.Descriptor instead.

func (*CancelSchemaMigrationResponse) GetRowsAffectedByShard

func (x *CancelSchemaMigrationResponse) GetRowsAffectedByShard() map[string]uint64

func (*CancelSchemaMigrationResponse) ProtoMessage

func (*CancelSchemaMigrationResponse) ProtoMessage()

func (*CancelSchemaMigrationResponse) ProtoReflect

func (*CancelSchemaMigrationResponse) Reset

func (x *CancelSchemaMigrationResponse) Reset()

func (*CancelSchemaMigrationResponse) String

type ChangeTabletTypeRequest

type ChangeTabletTypeRequest struct {
	TabletAlias *dev2.TabletAlias `protobuf:"bytes,1,opt,name=tablet_alias,json=tabletAlias,proto3" json:"tablet_alias,omitempty"`
	DbType      dev2.TabletType   `protobuf:"varint,2,opt,name=db_type,json=dbType,proto3,enum=vitess.topodata.dev.TabletType" json:"db_type,omitempty"`
	DryRun      bool              `protobuf:"varint,3,opt,name=dry_run,json=dryRun,proto3" json:"dry_run,omitempty"`
	// contains filtered or unexported fields
}

func (*ChangeTabletTypeRequest) Descriptor deprecated

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

Deprecated: Use ChangeTabletTypeRequest.ProtoReflect.Descriptor instead.

func (*ChangeTabletTypeRequest) GetDbType

func (x *ChangeTabletTypeRequest) GetDbType() dev2.TabletType

func (*ChangeTabletTypeRequest) GetDryRun

func (x *ChangeTabletTypeRequest) GetDryRun() bool

func (*ChangeTabletTypeRequest) GetTabletAlias

func (x *ChangeTabletTypeRequest) GetTabletAlias() *dev2.TabletAlias

func (*ChangeTabletTypeRequest) ProtoMessage

func (*ChangeTabletTypeRequest) ProtoMessage()

func (*ChangeTabletTypeRequest) ProtoReflect

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

func (*ChangeTabletTypeRequest) Reset

func (x *ChangeTabletTypeRequest) Reset()

func (*ChangeTabletTypeRequest) String

func (x *ChangeTabletTypeRequest) String() string

type ChangeTabletTypeResponse

type ChangeTabletTypeResponse struct {
	BeforeTablet *dev2.Tablet `protobuf:"bytes,1,opt,name=before_tablet,json=beforeTablet,proto3" json:"before_tablet,omitempty"`
	AfterTablet  *dev2.Tablet `protobuf:"bytes,2,opt,name=after_tablet,json=afterTablet,proto3" json:"after_tablet,omitempty"`
	WasDryRun    bool         `protobuf:"varint,3,opt,name=was_dry_run,json=wasDryRun,proto3" json:"was_dry_run,omitempty"`
	// contains filtered or unexported fields
}

func (*ChangeTabletTypeResponse) Descriptor deprecated

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

Deprecated: Use ChangeTabletTypeResponse.ProtoReflect.Descriptor instead.

func (*ChangeTabletTypeResponse) GetAfterTablet

func (x *ChangeTabletTypeResponse) GetAfterTablet() *dev2.Tablet

func (*ChangeTabletTypeResponse) GetBeforeTablet

func (x *ChangeTabletTypeResponse) GetBeforeTablet() *dev2.Tablet

func (*ChangeTabletTypeResponse) GetWasDryRun

func (x *ChangeTabletTypeResponse) GetWasDryRun() bool

func (*ChangeTabletTypeResponse) ProtoMessage

func (*ChangeTabletTypeResponse) ProtoMessage()

func (*ChangeTabletTypeResponse) ProtoReflect

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

func (*ChangeTabletTypeResponse) Reset

func (x *ChangeTabletTypeResponse) Reset()

func (*ChangeTabletTypeResponse) String

func (x *ChangeTabletTypeResponse) String() string

type CleanupSchemaMigrationRequest

type CleanupSchemaMigrationRequest struct {
	Keyspace string `protobuf:"bytes,1,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	Uuid     string `protobuf:"bytes,2,opt,name=uuid,proto3" json:"uuid,omitempty"`
	// contains filtered or unexported fields
}

func (*CleanupSchemaMigrationRequest) Descriptor deprecated

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

Deprecated: Use CleanupSchemaMigrationRequest.ProtoReflect.Descriptor instead.

func (*CleanupSchemaMigrationRequest) GetKeyspace

func (x *CleanupSchemaMigrationRequest) GetKeyspace() string

func (*CleanupSchemaMigrationRequest) GetUuid

func (*CleanupSchemaMigrationRequest) ProtoMessage

func (*CleanupSchemaMigrationRequest) ProtoMessage()

func (*CleanupSchemaMigrationRequest) ProtoReflect

func (*CleanupSchemaMigrationRequest) Reset

func (x *CleanupSchemaMigrationRequest) Reset()

func (*CleanupSchemaMigrationRequest) String

type CleanupSchemaMigrationResponse

type CleanupSchemaMigrationResponse struct {
	RowsAffectedByShard map[string]uint64 `` /* 211-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CleanupSchemaMigrationResponse) Descriptor deprecated

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

Deprecated: Use CleanupSchemaMigrationResponse.ProtoReflect.Descriptor instead.

func (*CleanupSchemaMigrationResponse) GetRowsAffectedByShard

func (x *CleanupSchemaMigrationResponse) GetRowsAffectedByShard() map[string]uint64

func (*CleanupSchemaMigrationResponse) ProtoMessage

func (*CleanupSchemaMigrationResponse) ProtoMessage()

func (*CleanupSchemaMigrationResponse) ProtoReflect

func (*CleanupSchemaMigrationResponse) Reset

func (x *CleanupSchemaMigrationResponse) Reset()

func (*CleanupSchemaMigrationResponse) String

type CompleteSchemaMigrationRequest

type CompleteSchemaMigrationRequest struct {
	Keyspace string `protobuf:"bytes,1,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	Uuid     string `protobuf:"bytes,2,opt,name=uuid,proto3" json:"uuid,omitempty"`
	// contains filtered or unexported fields
}

func (*CompleteSchemaMigrationRequest) Descriptor deprecated

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

Deprecated: Use CompleteSchemaMigrationRequest.ProtoReflect.Descriptor instead.

func (*CompleteSchemaMigrationRequest) GetKeyspace

func (x *CompleteSchemaMigrationRequest) GetKeyspace() string

func (*CompleteSchemaMigrationRequest) GetUuid

func (*CompleteSchemaMigrationRequest) ProtoMessage

func (*CompleteSchemaMigrationRequest) ProtoMessage()

func (*CompleteSchemaMigrationRequest) ProtoReflect

func (*CompleteSchemaMigrationRequest) Reset

func (x *CompleteSchemaMigrationRequest) Reset()

func (*CompleteSchemaMigrationRequest) String

type CompleteSchemaMigrationResponse

type CompleteSchemaMigrationResponse struct {
	RowsAffectedByShard map[string]uint64 `` /* 211-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CompleteSchemaMigrationResponse) Descriptor deprecated

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

Deprecated: Use CompleteSchemaMigrationResponse.ProtoReflect.Descriptor instead.

func (*CompleteSchemaMigrationResponse) GetRowsAffectedByShard

func (x *CompleteSchemaMigrationResponse) GetRowsAffectedByShard() map[string]uint64

func (*CompleteSchemaMigrationResponse) ProtoMessage

func (*CompleteSchemaMigrationResponse) ProtoMessage()

func (*CompleteSchemaMigrationResponse) ProtoReflect

func (*CompleteSchemaMigrationResponse) Reset

func (*CompleteSchemaMigrationResponse) String

type CreateKeyspaceRequest

type CreateKeyspaceRequest struct {

	// Name is the name of the keyspace.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Force proceeds with the request even if the keyspace already exists.
	Force bool `protobuf:"varint,2,opt,name=force,proto3" json:"force,omitempty"`
	// AllowEmptyVSchema allows a keyspace to be created with no vschema.
	AllowEmptyVSchema bool `protobuf:"varint,3,opt,name=allow_empty_v_schema,json=allowEmptyVSchema,proto3" json:"allow_empty_v_schema,omitempty"`
	// ServedFroms specifies a set of db_type:keyspace pairs used to serve
	// traffic for the keyspace.
	ServedFroms []*dev2.Keyspace_ServedFrom `protobuf:"bytes,6,rep,name=served_froms,json=servedFroms,proto3" json:"served_froms,omitempty"`
	// Type is the type of the keyspace to create.
	Type dev2.KeyspaceType `protobuf:"varint,7,opt,name=type,proto3,enum=vitess.topodata.dev.KeyspaceType" json:"type,omitempty"`
	// BaseKeyspace specifies the base keyspace for SNAPSHOT keyspaces. It is
	// required to create a SNAPSHOT keyspace.
	BaseKeyspace string `protobuf:"bytes,8,opt,name=base_keyspace,json=baseKeyspace,proto3" json:"base_keyspace,omitempty"`
	// SnapshotTime specifies the snapshot time for this keyspace. It is required
	// to create a SNAPSHOT keyspace.
	SnapshotTime *dev3.Time `protobuf:"bytes,9,opt,name=snapshot_time,json=snapshotTime,proto3" json:"snapshot_time,omitempty"`
	// DurabilityPolicy is the durability policy to be
	// used for this keyspace.
	DurabilityPolicy string `protobuf:"bytes,10,opt,name=durability_policy,json=durabilityPolicy,proto3" json:"durability_policy,omitempty"`
	// SidecarDBName is the name of the sidecar database that
	// each vttablet in the keyspace will use.
	SidecarDbName string `protobuf:"bytes,11,opt,name=sidecar_db_name,json=sidecarDbName,proto3" json:"sidecar_db_name,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateKeyspaceRequest) Descriptor deprecated

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

Deprecated: Use CreateKeyspaceRequest.ProtoReflect.Descriptor instead.

func (*CreateKeyspaceRequest) GetAllowEmptyVSchema

func (x *CreateKeyspaceRequest) GetAllowEmptyVSchema() bool

func (*CreateKeyspaceRequest) GetBaseKeyspace

func (x *CreateKeyspaceRequest) GetBaseKeyspace() string

func (*CreateKeyspaceRequest) GetDurabilityPolicy

func (x *CreateKeyspaceRequest) GetDurabilityPolicy() string

func (*CreateKeyspaceRequest) GetForce

func (x *CreateKeyspaceRequest) GetForce() bool

func (*CreateKeyspaceRequest) GetName

func (x *CreateKeyspaceRequest) GetName() string

func (*CreateKeyspaceRequest) GetServedFroms

func (x *CreateKeyspaceRequest) GetServedFroms() []*dev2.Keyspace_ServedFrom

func (*CreateKeyspaceRequest) GetSidecarDbName

func (x *CreateKeyspaceRequest) GetSidecarDbName() string

func (*CreateKeyspaceRequest) GetSnapshotTime

func (x *CreateKeyspaceRequest) GetSnapshotTime() *dev3.Time

func (*CreateKeyspaceRequest) GetType

func (*CreateKeyspaceRequest) ProtoMessage

func (*CreateKeyspaceRequest) ProtoMessage()

func (*CreateKeyspaceRequest) ProtoReflect

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

func (*CreateKeyspaceRequest) Reset

func (x *CreateKeyspaceRequest) Reset()

func (*CreateKeyspaceRequest) String

func (x *CreateKeyspaceRequest) String() string

type CreateKeyspaceResponse

type CreateKeyspaceResponse struct {

	// Keyspace is the newly-created keyspace.
	Keyspace *Keyspace `protobuf:"bytes,1,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateKeyspaceResponse) Descriptor deprecated

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

Deprecated: Use CreateKeyspaceResponse.ProtoReflect.Descriptor instead.

func (*CreateKeyspaceResponse) GetKeyspace

func (x *CreateKeyspaceResponse) GetKeyspace() *Keyspace

func (*CreateKeyspaceResponse) ProtoMessage

func (*CreateKeyspaceResponse) ProtoMessage()

func (*CreateKeyspaceResponse) ProtoReflect

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

func (*CreateKeyspaceResponse) Reset

func (x *CreateKeyspaceResponse) Reset()

func (*CreateKeyspaceResponse) String

func (x *CreateKeyspaceResponse) String() string

type CreateShardRequest

type CreateShardRequest struct {

	// Keyspace is the name of the keyspace to create the shard in.
	Keyspace string `protobuf:"bytes,1,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	// ShardName is the name of the shard to create. E.g. "-" or "-80".
	ShardName string `protobuf:"bytes,2,opt,name=shard_name,json=shardName,proto3" json:"shard_name,omitempty"`
	// Force treats an attempt to create a shard that already exists as a
	// non-error.
	Force bool `protobuf:"varint,3,opt,name=force,proto3" json:"force,omitempty"`
	// IncludeParent creates the parent keyspace as an empty BASE keyspace, if it
	// doesn't already exist.
	IncludeParent bool `protobuf:"varint,4,opt,name=include_parent,json=includeParent,proto3" json:"include_parent,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateShardRequest) Descriptor deprecated

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

Deprecated: Use CreateShardRequest.ProtoReflect.Descriptor instead.

func (*CreateShardRequest) GetForce

func (x *CreateShardRequest) GetForce() bool

func (*CreateShardRequest) GetIncludeParent

func (x *CreateShardRequest) GetIncludeParent() bool

func (*CreateShardRequest) GetKeyspace

func (x *CreateShardRequest) GetKeyspace() string

func (*CreateShardRequest) GetShardName

func (x *CreateShardRequest) GetShardName() string

func (*CreateShardRequest) ProtoMessage

func (*CreateShardRequest) ProtoMessage()

func (*CreateShardRequest) ProtoReflect

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

func (*CreateShardRequest) Reset

func (x *CreateShardRequest) Reset()

func (*CreateShardRequest) String

func (x *CreateShardRequest) String() string

type CreateShardResponse

type CreateShardResponse struct {

	// Keyspace is the created keyspace. It is set only if IncludeParent was
	// specified in the request and the parent keyspace needed to be created.
	Keyspace *Keyspace `protobuf:"bytes,1,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	// Shard is the newly-created shard object.
	Shard *Shard `protobuf:"bytes,2,opt,name=shard,proto3" json:"shard,omitempty"`
	// ShardAlreadyExists is set if Force was specified in the request and the
	// shard already existed.
	ShardAlreadyExists bool `protobuf:"varint,3,opt,name=shard_already_exists,json=shardAlreadyExists,proto3" json:"shard_already_exists,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateShardResponse) Descriptor deprecated

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

Deprecated: Use CreateShardResponse.ProtoReflect.Descriptor instead.

func (*CreateShardResponse) GetKeyspace

func (x *CreateShardResponse) GetKeyspace() *Keyspace

func (*CreateShardResponse) GetShard

func (x *CreateShardResponse) GetShard() *Shard

func (*CreateShardResponse) GetShardAlreadyExists

func (x *CreateShardResponse) GetShardAlreadyExists() bool

func (*CreateShardResponse) ProtoMessage

func (*CreateShardResponse) ProtoMessage()

func (*CreateShardResponse) ProtoReflect

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

func (*CreateShardResponse) Reset

func (x *CreateShardResponse) Reset()

func (*CreateShardResponse) String

func (x *CreateShardResponse) String() string

type DeleteCellInfoRequest

type DeleteCellInfoRequest struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Force bool   `protobuf:"varint,2,opt,name=force,proto3" json:"force,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteCellInfoRequest) Descriptor deprecated

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

Deprecated: Use DeleteCellInfoRequest.ProtoReflect.Descriptor instead.

func (*DeleteCellInfoRequest) GetForce

func (x *DeleteCellInfoRequest) GetForce() bool

func (*DeleteCellInfoRequest) GetName

func (x *DeleteCellInfoRequest) GetName() string

func (*DeleteCellInfoRequest) ProtoMessage

func (*DeleteCellInfoRequest) ProtoMessage()

func (*DeleteCellInfoRequest) ProtoReflect

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

func (*DeleteCellInfoRequest) Reset

func (x *DeleteCellInfoRequest) Reset()

func (*DeleteCellInfoRequest) String

func (x *DeleteCellInfoRequest) String() string

type DeleteCellInfoResponse

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

func (*DeleteCellInfoResponse) Descriptor deprecated

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

Deprecated: Use DeleteCellInfoResponse.ProtoReflect.Descriptor instead.

func (*DeleteCellInfoResponse) ProtoMessage

func (*DeleteCellInfoResponse) ProtoMessage()

func (*DeleteCellInfoResponse) ProtoReflect

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

func (*DeleteCellInfoResponse) Reset

func (x *DeleteCellInfoResponse) Reset()

func (*DeleteCellInfoResponse) String

func (x *DeleteCellInfoResponse) String() string

type DeleteCellsAliasRequest

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

func (*DeleteCellsAliasRequest) Descriptor deprecated

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

Deprecated: Use DeleteCellsAliasRequest.ProtoReflect.Descriptor instead.

func (*DeleteCellsAliasRequest) GetName

func (x *DeleteCellsAliasRequest) GetName() string

func (*DeleteCellsAliasRequest) ProtoMessage

func (*DeleteCellsAliasRequest) ProtoMessage()

func (*DeleteCellsAliasRequest) ProtoReflect

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

func (*DeleteCellsAliasRequest) Reset

func (x *DeleteCellsAliasRequest) Reset()

func (*DeleteCellsAliasRequest) String

func (x *DeleteCellsAliasRequest) String() string

type DeleteCellsAliasResponse

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

func (*DeleteCellsAliasResponse) Descriptor deprecated

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

Deprecated: Use DeleteCellsAliasResponse.ProtoReflect.Descriptor instead.

func (*DeleteCellsAliasResponse) ProtoMessage

func (*DeleteCellsAliasResponse) ProtoMessage()

func (*DeleteCellsAliasResponse) ProtoReflect

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

func (*DeleteCellsAliasResponse) Reset

func (x *DeleteCellsAliasResponse) Reset()

func (*DeleteCellsAliasResponse) String

func (x *DeleteCellsAliasResponse) String() string

type DeleteKeyspaceRequest

type DeleteKeyspaceRequest struct {

	// Keyspace is the name of the keyspace to delete.
	Keyspace string `protobuf:"bytes,1,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	// Recursive causes all shards in the keyspace to be recursively deleted
	// before deleting the keyspace. It is an error to call DeleteKeyspace on a
	// non-empty keyspace without also specifying Recursive.
	Recursive bool `protobuf:"varint,2,opt,name=recursive,proto3" json:"recursive,omitempty"`
	// Force allows a keyspace to be deleted even if the keyspace lock cannot be
	// obtained. This should only be used to force-clean a keyspace.
	Force bool `protobuf:"varint,3,opt,name=force,proto3" json:"force,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteKeyspaceRequest) Descriptor deprecated

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

Deprecated: Use DeleteKeyspaceRequest.ProtoReflect.Descriptor instead.

func (*DeleteKeyspaceRequest) GetForce

func (x *DeleteKeyspaceRequest) GetForce() bool

func (*DeleteKeyspaceRequest) GetKeyspace

func (x *DeleteKeyspaceRequest) GetKeyspace() string

func (*DeleteKeyspaceRequest) GetRecursive

func (x *DeleteKeyspaceRequest) GetRecursive() 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) String

func (x *DeleteKeyspaceRequest) String() string

type DeleteKeyspaceResponse

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

func (*DeleteKeyspaceResponse) Descriptor deprecated

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

Deprecated: Use DeleteKeyspaceResponse.ProtoReflect.Descriptor instead.

func (*DeleteKeyspaceResponse) ProtoMessage

func (*DeleteKeyspaceResponse) ProtoMessage()

func (*DeleteKeyspaceResponse) ProtoReflect

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

func (*DeleteKeyspaceResponse) Reset

func (x *DeleteKeyspaceResponse) Reset()

func (*DeleteKeyspaceResponse) String

func (x *DeleteKeyspaceResponse) String() string

type DeleteShardsRequest

type DeleteShardsRequest struct {

	// Shards is the list of shards to delete. The nested topodatapb.Shard field
	// is not required for DeleteShard, but the Keyspace and Shard fields are.
	Shards []*Shard `protobuf:"bytes,1,rep,name=shards,proto3" json:"shards,omitempty"`
	// Recursive also deletes all tablets belonging to the shard(s). It is an
	// error to call DeleteShard on a non-empty shard without also specificying
	// Recursive.
	Recursive bool `protobuf:"varint,2,opt,name=recursive,proto3" json:"recursive,omitempty"`
	// EvenIfServing allows a shard to be deleted even if it is serving, which is
	// normally an error. Use with caution.
	EvenIfServing bool `protobuf:"varint,4,opt,name=even_if_serving,json=evenIfServing,proto3" json:"even_if_serving,omitempty"`
	// Force allows a shard to be deleted even if the shard lock cannot be
	// obtained. This should only be used to force-clean a shard.
	Force bool `protobuf:"varint,5,opt,name=force,proto3" json:"force,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteShardsRequest) Descriptor deprecated

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

Deprecated: Use DeleteShardsRequest.ProtoReflect.Descriptor instead.

func (*DeleteShardsRequest) GetEvenIfServing

func (x *DeleteShardsRequest) GetEvenIfServing() bool

func (*DeleteShardsRequest) GetForce

func (x *DeleteShardsRequest) GetForce() bool

func (*DeleteShardsRequest) GetRecursive

func (x *DeleteShardsRequest) GetRecursive() bool

func (*DeleteShardsRequest) GetShards

func (x *DeleteShardsRequest) GetShards() []*Shard

func (*DeleteShardsRequest) ProtoMessage

func (*DeleteShardsRequest) ProtoMessage()

func (*DeleteShardsRequest) ProtoReflect

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

func (*DeleteShardsRequest) Reset

func (x *DeleteShardsRequest) Reset()

func (*DeleteShardsRequest) String

func (x *DeleteShardsRequest) String() string

type DeleteShardsResponse

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

func (*DeleteShardsResponse) Descriptor deprecated

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

Deprecated: Use DeleteShardsResponse.ProtoReflect.Descriptor instead.

func (*DeleteShardsResponse) ProtoMessage

func (*DeleteShardsResponse) ProtoMessage()

func (*DeleteShardsResponse) ProtoReflect

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

func (*DeleteShardsResponse) Reset

func (x *DeleteShardsResponse) Reset()

func (*DeleteShardsResponse) String

func (x *DeleteShardsResponse) String() string

type DeleteSrvVSchemaRequest

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

func (*DeleteSrvVSchemaRequest) Descriptor deprecated

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

Deprecated: Use DeleteSrvVSchemaRequest.ProtoReflect.Descriptor instead.

func (*DeleteSrvVSchemaRequest) GetCell

func (x *DeleteSrvVSchemaRequest) GetCell() string

func (*DeleteSrvVSchemaRequest) ProtoMessage

func (*DeleteSrvVSchemaRequest) ProtoMessage()

func (*DeleteSrvVSchemaRequest) ProtoReflect

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

func (*DeleteSrvVSchemaRequest) Reset

func (x *DeleteSrvVSchemaRequest) Reset()

func (*DeleteSrvVSchemaRequest) String

func (x *DeleteSrvVSchemaRequest) String() string

type DeleteSrvVSchemaResponse

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

func (*DeleteSrvVSchemaResponse) Descriptor deprecated

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

Deprecated: Use DeleteSrvVSchemaResponse.ProtoReflect.Descriptor instead.

func (*DeleteSrvVSchemaResponse) ProtoMessage

func (*DeleteSrvVSchemaResponse) ProtoMessage()

func (*DeleteSrvVSchemaResponse) ProtoReflect

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

func (*DeleteSrvVSchemaResponse) Reset

func (x *DeleteSrvVSchemaResponse) Reset()

func (*DeleteSrvVSchemaResponse) String

func (x *DeleteSrvVSchemaResponse) String() string

type DeleteTabletsRequest

type DeleteTabletsRequest struct {

	// TabletAliases is the list of tablets to delete.
	TabletAliases []*dev2.TabletAlias `protobuf:"bytes,1,rep,name=tablet_aliases,json=tabletAliases,proto3" json:"tablet_aliases,omitempty"`
	// AllowPrimary allows for the primary tablet of a shard to be deleted.
	// Use with caution.
	AllowPrimary bool `protobuf:"varint,2,opt,name=allow_primary,json=allowPrimary,proto3" json:"allow_primary,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteTabletsRequest) Descriptor deprecated

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

Deprecated: Use DeleteTabletsRequest.ProtoReflect.Descriptor instead.

func (*DeleteTabletsRequest) GetAllowPrimary

func (x *DeleteTabletsRequest) GetAllowPrimary() bool

func (*DeleteTabletsRequest) GetTabletAliases

func (x *DeleteTabletsRequest) GetTabletAliases() []*dev2.TabletAlias

func (*DeleteTabletsRequest) ProtoMessage

func (*DeleteTabletsRequest) ProtoMessage()

func (*DeleteTabletsRequest) ProtoReflect

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

func (*DeleteTabletsRequest) Reset

func (x *DeleteTabletsRequest) Reset()

func (*DeleteTabletsRequest) String

func (x *DeleteTabletsRequest) String() string

type DeleteTabletsResponse

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

func (*DeleteTabletsResponse) Descriptor deprecated

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

Deprecated: Use DeleteTabletsResponse.ProtoReflect.Descriptor instead.

func (*DeleteTabletsResponse) ProtoMessage

func (*DeleteTabletsResponse) ProtoMessage()

func (*DeleteTabletsResponse) ProtoReflect

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

func (*DeleteTabletsResponse) Reset

func (x *DeleteTabletsResponse) Reset()

func (*DeleteTabletsResponse) String

func (x *DeleteTabletsResponse) String() string

type EmergencyReparentShardRequest

type EmergencyReparentShardRequest struct {

	// Keyspace is the name of the keyspace to perform the Emergency Reparent in.
	Keyspace string `protobuf:"bytes,1,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	// Shard is the name of the shard to perform the Emergency Reparent in.
	Shard string `protobuf:"bytes,2,opt,name=shard,proto3" json:"shard,omitempty"`
	// Optional alias of a tablet that should become the new shard primary. If not
	// not specified, the vtctld will select the most up-to-date canditate to
	// promote.
	NewPrimary *dev2.TabletAlias `protobuf:"bytes,3,opt,name=new_primary,json=newPrimary,proto3" json:"new_primary,omitempty"`
	// List of replica aliases to ignore during the Emergency Reparent. The vtctld
	// will not attempt to stop replication on these tablets, nor attempt to
	// demote any that may think they are the shard primary.
	IgnoreReplicas []*dev2.TabletAlias `protobuf:"bytes,4,rep,name=ignore_replicas,json=ignoreReplicas,proto3" json:"ignore_replicas,omitempty"`
	// WaitReplicasTimeout is the duration of time to wait for replicas to catch
	// up in reparenting.
	WaitReplicasTimeout *dev3.Duration `protobuf:"bytes,5,opt,name=wait_replicas_timeout,json=waitReplicasTimeout,proto3" json:"wait_replicas_timeout,omitempty"`
	// PreventCrossCellPromotion is used to only promote the new primary from the same cell
	// as the failed primary.
	PreventCrossCellPromotion bool `` /* 141-byte string literal not displayed */
	// WaitForAllTablets makes ERS wait for a response from all the tablets before proceeding.
	// Useful when all the tablets are up and reachable.
	WaitForAllTablets bool `protobuf:"varint,7,opt,name=wait_for_all_tablets,json=waitForAllTablets,proto3" json:"wait_for_all_tablets,omitempty"`
	// contains filtered or unexported fields
}

func (*EmergencyReparentShardRequest) Descriptor deprecated

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

Deprecated: Use EmergencyReparentShardRequest.ProtoReflect.Descriptor instead.

func (*EmergencyReparentShardRequest) GetIgnoreReplicas

func (x *EmergencyReparentShardRequest) GetIgnoreReplicas() []*dev2.TabletAlias

func (*EmergencyReparentShardRequest) GetKeyspace

func (x *EmergencyReparentShardRequest) GetKeyspace() string

func (*EmergencyReparentShardRequest) GetNewPrimary

func (x *EmergencyReparentShardRequest) GetNewPrimary() *dev2.TabletAlias

func (*EmergencyReparentShardRequest) GetPreventCrossCellPromotion

func (x *EmergencyReparentShardRequest) GetPreventCrossCellPromotion() bool

func (*EmergencyReparentShardRequest) GetShard

func (x *EmergencyReparentShardRequest) GetShard() string

func (*EmergencyReparentShardRequest) GetWaitForAllTablets

func (x *EmergencyReparentShardRequest) GetWaitForAllTablets() bool

func (*EmergencyReparentShardRequest) GetWaitReplicasTimeout

func (x *EmergencyReparentShardRequest) GetWaitReplicasTimeout() *dev3.Duration

func (*EmergencyReparentShardRequest) ProtoMessage

func (*EmergencyReparentShardRequest) ProtoMessage()

func (*EmergencyReparentShardRequest) ProtoReflect

func (*EmergencyReparentShardRequest) Reset

func (x *EmergencyReparentShardRequest) Reset()

func (*EmergencyReparentShardRequest) String

type EmergencyReparentShardResponse

type EmergencyReparentShardResponse struct {

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

func (*EmergencyReparentShardResponse) Descriptor deprecated

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

Deprecated: Use EmergencyReparentShardResponse.ProtoReflect.Descriptor instead.

func (*EmergencyReparentShardResponse) GetEvents

func (x *EmergencyReparentShardResponse) GetEvents() []*dev.Event

func (*EmergencyReparentShardResponse) GetKeyspace

func (x *EmergencyReparentShardResponse) GetKeyspace() string

func (*EmergencyReparentShardResponse) GetPromotedPrimary

func (x *EmergencyReparentShardResponse) GetPromotedPrimary() *dev2.TabletAlias

func (*EmergencyReparentShardResponse) GetShard

func (x *EmergencyReparentShardResponse) GetShard() string

func (*EmergencyReparentShardResponse) ProtoMessage

func (*EmergencyReparentShardResponse) ProtoMessage()

func (*EmergencyReparentShardResponse) ProtoReflect

func (*EmergencyReparentShardResponse) Reset

func (x *EmergencyReparentShardResponse) Reset()

func (*EmergencyReparentShardResponse) String

type ExecuteFetchAsAppRequest

type ExecuteFetchAsAppRequest struct {
	TabletAlias *dev2.TabletAlias `protobuf:"bytes,1,opt,name=tablet_alias,json=tabletAlias,proto3" json:"tablet_alias,omitempty"`
	Query       string            `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"`
	// MaxRows is an optional parameter to limit the number of rows read into the
	// QueryResult. Note that this does not apply a LIMIT to the query, just how
	// many rows are read from the MySQL server on the tablet side.
	//
	// This field is optional. Specifying a non-positive value will use whatever
	// default is configured in the VtctldService.
	MaxRows int64 `protobuf:"varint,3,opt,name=max_rows,json=maxRows,proto3" json:"max_rows,omitempty"`
	// UsePool causes the query to be run with a pooled connection to the tablet.
	UsePool bool `protobuf:"varint,4,opt,name=use_pool,json=usePool,proto3" json:"use_pool,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteFetchAsAppRequest) Descriptor deprecated

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

Deprecated: Use ExecuteFetchAsAppRequest.ProtoReflect.Descriptor instead.

func (*ExecuteFetchAsAppRequest) GetMaxRows

func (x *ExecuteFetchAsAppRequest) GetMaxRows() int64

func (*ExecuteFetchAsAppRequest) GetQuery

func (x *ExecuteFetchAsAppRequest) GetQuery() string

func (*ExecuteFetchAsAppRequest) GetTabletAlias

func (x *ExecuteFetchAsAppRequest) GetTabletAlias() *dev2.TabletAlias

func (*ExecuteFetchAsAppRequest) GetUsePool

func (x *ExecuteFetchAsAppRequest) GetUsePool() bool

func (*ExecuteFetchAsAppRequest) ProtoMessage

func (*ExecuteFetchAsAppRequest) ProtoMessage()

func (*ExecuteFetchAsAppRequest) ProtoReflect

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

func (*ExecuteFetchAsAppRequest) Reset

func (x *ExecuteFetchAsAppRequest) Reset()

func (*ExecuteFetchAsAppRequest) String

func (x *ExecuteFetchAsAppRequest) String() string

type ExecuteFetchAsAppResponse

type ExecuteFetchAsAppResponse struct {
	Result *dev6.QueryResult `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteFetchAsAppResponse) Descriptor deprecated

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

Deprecated: Use ExecuteFetchAsAppResponse.ProtoReflect.Descriptor instead.

func (*ExecuteFetchAsAppResponse) GetResult

func (x *ExecuteFetchAsAppResponse) GetResult() *dev6.QueryResult

func (*ExecuteFetchAsAppResponse) ProtoMessage

func (*ExecuteFetchAsAppResponse) ProtoMessage()

func (*ExecuteFetchAsAppResponse) ProtoReflect

func (*ExecuteFetchAsAppResponse) Reset

func (x *ExecuteFetchAsAppResponse) Reset()

func (*ExecuteFetchAsAppResponse) String

func (x *ExecuteFetchAsAppResponse) String() string

type ExecuteFetchAsDBARequest

type ExecuteFetchAsDBARequest struct {
	TabletAlias *dev2.TabletAlias `protobuf:"bytes,1,opt,name=tablet_alias,json=tabletAlias,proto3" json:"tablet_alias,omitempty"`
	Query       string            `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"`
	// MaxRows is an optional parameter to limit the number of rows read into the
	// QueryResult. Note that this does not apply a LIMIT to the query, just how
	// many rows are read from the MySQL server on the tablet side.
	//
	// This field is optional. Specifying a non-positive value will use whatever
	// default is configured in the VtctldService.
	MaxRows int64 `protobuf:"varint,3,opt,name=max_rows,json=maxRows,proto3" json:"max_rows,omitempty"`
	// DisableBinlogs instructs the tablet not to use binary logging when
	// executing the query.
	DisableBinlogs bool `protobuf:"varint,4,opt,name=disable_binlogs,json=disableBinlogs,proto3" json:"disable_binlogs,omitempty"`
	// ReloadSchema instructs the tablet to reload its schema after executing the
	// query.
	ReloadSchema bool `protobuf:"varint,5,opt,name=reload_schema,json=reloadSchema,proto3" json:"reload_schema,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteFetchAsDBARequest) Descriptor deprecated

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

Deprecated: Use ExecuteFetchAsDBARequest.ProtoReflect.Descriptor instead.

func (*ExecuteFetchAsDBARequest) GetDisableBinlogs

func (x *ExecuteFetchAsDBARequest) GetDisableBinlogs() bool

func (*ExecuteFetchAsDBARequest) GetMaxRows

func (x *ExecuteFetchAsDBARequest) GetMaxRows() int64

func (*ExecuteFetchAsDBARequest) GetQuery

func (x *ExecuteFetchAsDBARequest) GetQuery() string

func (*ExecuteFetchAsDBARequest) GetReloadSchema

func (x *ExecuteFetchAsDBARequest) GetReloadSchema() bool

func (*ExecuteFetchAsDBARequest) GetTabletAlias

func (x *ExecuteFetchAsDBARequest) GetTabletAlias() *dev2.TabletAlias

func (*ExecuteFetchAsDBARequest) ProtoMessage

func (*ExecuteFetchAsDBARequest) ProtoMessage()

func (*ExecuteFetchAsDBARequest) ProtoReflect

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

func (*ExecuteFetchAsDBARequest) Reset

func (x *ExecuteFetchAsDBARequest) Reset()

func (*ExecuteFetchAsDBARequest) String

func (x *ExecuteFetchAsDBARequest) String() string

type ExecuteFetchAsDBAResponse

type ExecuteFetchAsDBAResponse struct {
	Result *dev6.QueryResult `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteFetchAsDBAResponse) Descriptor deprecated

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

Deprecated: Use ExecuteFetchAsDBAResponse.ProtoReflect.Descriptor instead.

func (*ExecuteFetchAsDBAResponse) GetResult

func (x *ExecuteFetchAsDBAResponse) GetResult() *dev6.QueryResult

func (*ExecuteFetchAsDBAResponse) ProtoMessage

func (*ExecuteFetchAsDBAResponse) ProtoMessage()

func (*ExecuteFetchAsDBAResponse) ProtoReflect

func (*ExecuteFetchAsDBAResponse) Reset

func (x *ExecuteFetchAsDBAResponse) Reset()

func (*ExecuteFetchAsDBAResponse) String

func (x *ExecuteFetchAsDBAResponse) String() string

type ExecuteHookRequest

type ExecuteHookRequest struct {
	TabletAlias       *dev2.TabletAlias        `protobuf:"bytes,1,opt,name=tablet_alias,json=tabletAlias,proto3" json:"tablet_alias,omitempty"`
	TabletHookRequest *dev1.ExecuteHookRequest `protobuf:"bytes,2,opt,name=tablet_hook_request,json=tabletHookRequest,proto3" json:"tablet_hook_request,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteHookRequest) Descriptor deprecated

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

Deprecated: Use ExecuteHookRequest.ProtoReflect.Descriptor instead.

func (*ExecuteHookRequest) GetTabletAlias

func (x *ExecuteHookRequest) GetTabletAlias() *dev2.TabletAlias

func (*ExecuteHookRequest) GetTabletHookRequest

func (x *ExecuteHookRequest) GetTabletHookRequest() *dev1.ExecuteHookRequest

func (*ExecuteHookRequest) ProtoMessage

func (*ExecuteHookRequest) ProtoMessage()

func (*ExecuteHookRequest) ProtoReflect

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

func (*ExecuteHookRequest) Reset

func (x *ExecuteHookRequest) Reset()

func (*ExecuteHookRequest) String

func (x *ExecuteHookRequest) String() string

type ExecuteHookResponse

type ExecuteHookResponse struct {
	HookResult *dev1.ExecuteHookResponse `protobuf:"bytes,1,opt,name=hook_result,json=hookResult,proto3" json:"hook_result,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteHookResponse) Descriptor deprecated

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

Deprecated: Use ExecuteHookResponse.ProtoReflect.Descriptor instead.

func (*ExecuteHookResponse) GetHookResult

func (x *ExecuteHookResponse) GetHookResult() *dev1.ExecuteHookResponse

func (*ExecuteHookResponse) ProtoMessage

func (*ExecuteHookResponse) ProtoMessage()

func (*ExecuteHookResponse) ProtoReflect

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

func (*ExecuteHookResponse) Reset

func (x *ExecuteHookResponse) Reset()

func (*ExecuteHookResponse) String

func (x *ExecuteHookResponse) String() string

type ExecuteVtctlCommandRequest

type ExecuteVtctlCommandRequest struct {
	Args          []string `protobuf:"bytes,1,rep,name=args,proto3" json:"args,omitempty"`
	ActionTimeout int64    `protobuf:"varint,2,opt,name=action_timeout,json=actionTimeout,proto3" json:"action_timeout,omitempty"`
	// contains filtered or unexported fields
}

ExecuteVtctlCommandRequest is the payload for ExecuteVtctlCommand. timeouts are in nanoseconds.

func (*ExecuteVtctlCommandRequest) Descriptor deprecated

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

Deprecated: Use ExecuteVtctlCommandRequest.ProtoReflect.Descriptor instead.

func (*ExecuteVtctlCommandRequest) GetActionTimeout

func (x *ExecuteVtctlCommandRequest) GetActionTimeout() int64

func (*ExecuteVtctlCommandRequest) GetArgs

func (x *ExecuteVtctlCommandRequest) GetArgs() []string

func (*ExecuteVtctlCommandRequest) ProtoMessage

func (*ExecuteVtctlCommandRequest) ProtoMessage()

func (*ExecuteVtctlCommandRequest) ProtoReflect

func (*ExecuteVtctlCommandRequest) Reset

func (x *ExecuteVtctlCommandRequest) Reset()

func (*ExecuteVtctlCommandRequest) String

func (x *ExecuteVtctlCommandRequest) String() string

type ExecuteVtctlCommandResponse

type ExecuteVtctlCommandResponse struct {
	Event *dev.Event `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

ExecuteVtctlCommandResponse is streamed back by ExecuteVtctlCommand.

func (*ExecuteVtctlCommandResponse) Descriptor deprecated

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

Deprecated: Use ExecuteVtctlCommandResponse.ProtoReflect.Descriptor instead.

func (*ExecuteVtctlCommandResponse) GetEvent

func (x *ExecuteVtctlCommandResponse) GetEvent() *dev.Event

func (*ExecuteVtctlCommandResponse) ProtoMessage

func (*ExecuteVtctlCommandResponse) ProtoMessage()

func (*ExecuteVtctlCommandResponse) ProtoReflect

func (*ExecuteVtctlCommandResponse) Reset

func (x *ExecuteVtctlCommandResponse) Reset()

func (*ExecuteVtctlCommandResponse) String

func (x *ExecuteVtctlCommandResponse) String() string

type FindAllShardsInKeyspaceRequest

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

func (*FindAllShardsInKeyspaceRequest) Descriptor deprecated

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

Deprecated: Use FindAllShardsInKeyspaceRequest.ProtoReflect.Descriptor instead.

func (*FindAllShardsInKeyspaceRequest) GetKeyspace

func (x *FindAllShardsInKeyspaceRequest) GetKeyspace() string

func (*FindAllShardsInKeyspaceRequest) ProtoMessage

func (*FindAllShardsInKeyspaceRequest) ProtoMessage()

func (*FindAllShardsInKeyspaceRequest) ProtoReflect

func (*FindAllShardsInKeyspaceRequest) Reset

func (x *FindAllShardsInKeyspaceRequest) Reset()

func (*FindAllShardsInKeyspaceRequest) String

type FindAllShardsInKeyspaceResponse

type FindAllShardsInKeyspaceResponse struct {
	Shards map[string]*Shard `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*FindAllShardsInKeyspaceResponse) Descriptor deprecated

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

Deprecated: Use FindAllShardsInKeyspaceResponse.ProtoReflect.Descriptor instead.

func (*FindAllShardsInKeyspaceResponse) GetShards

func (x *FindAllShardsInKeyspaceResponse) GetShards() map[string]*Shard

func (*FindAllShardsInKeyspaceResponse) ProtoMessage

func (*FindAllShardsInKeyspaceResponse) ProtoMessage()

func (*FindAllShardsInKeyspaceResponse) ProtoReflect

func (*FindAllShardsInKeyspaceResponse) Reset

func (*FindAllShardsInKeyspaceResponse) String

type GetBackupsRequest

type GetBackupsRequest 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"`
	// Limit, if nonzero, will return only the most N recent backups.
	Limit uint32 `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	// Detailed indicates whether to use the backupengine, if supported, to
	// populate additional fields, such as Engine and Status, on BackupInfo
	// objects in the response. If not set, or if the backupengine does not
	// support populating these fields, Engine will always be empty, and Status
	// will always be UNKNOWN.
	Detailed bool `protobuf:"varint,4,opt,name=detailed,proto3" json:"detailed,omitempty"`
	// DetailedLimit, if nonzero, will only populate additional fields (see Detailed)
	// on the N most recent backups. The Limit field still dictates the total
	// number of backup info objects returned, so, in reality, min(Limit, DetailedLimit)
	// backup infos will have additional fields set, and any remaining backups
	// will not.
	DetailedLimit uint32 `protobuf:"varint,5,opt,name=detailed_limit,json=detailedLimit,proto3" json:"detailed_limit,omitempty"`
	// contains filtered or unexported fields
}

func (*GetBackupsRequest) Descriptor deprecated

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

Deprecated: Use GetBackupsRequest.ProtoReflect.Descriptor instead.

func (*GetBackupsRequest) GetDetailed

func (x *GetBackupsRequest) GetDetailed() bool

func (*GetBackupsRequest) GetDetailedLimit

func (x *GetBackupsRequest) GetDetailedLimit() uint32

func (*GetBackupsRequest) GetKeyspace

func (x *GetBackupsRequest) GetKeyspace() string

func (*GetBackupsRequest) GetLimit

func (x *GetBackupsRequest) GetLimit() uint32

func (*GetBackupsRequest) GetShard

func (x *GetBackupsRequest) GetShard() string

func (*GetBackupsRequest) ProtoMessage

func (*GetBackupsRequest) ProtoMessage()

func (*GetBackupsRequest) ProtoReflect

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

func (*GetBackupsRequest) Reset

func (x *GetBackupsRequest) Reset()

func (*GetBackupsRequest) String

func (x *GetBackupsRequest) String() string

type GetBackupsResponse

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

func (*GetBackupsResponse) Descriptor deprecated

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

Deprecated: Use GetBackupsResponse.ProtoReflect.Descriptor instead.

func (*GetBackupsResponse) GetBackups

func (x *GetBackupsResponse) GetBackups() []*dev7.BackupInfo

func (*GetBackupsResponse) ProtoMessage

func (*GetBackupsResponse) ProtoMessage()

func (*GetBackupsResponse) ProtoReflect

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

func (*GetBackupsResponse) Reset

func (x *GetBackupsResponse) Reset()

func (*GetBackupsResponse) String

func (x *GetBackupsResponse) String() string

type GetCellInfoNamesRequest

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

func (*GetCellInfoNamesRequest) Descriptor deprecated

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

Deprecated: Use GetCellInfoNamesRequest.ProtoReflect.Descriptor instead.

func (*GetCellInfoNamesRequest) ProtoMessage

func (*GetCellInfoNamesRequest) ProtoMessage()

func (*GetCellInfoNamesRequest) ProtoReflect

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

func (*GetCellInfoNamesRequest) Reset

func (x *GetCellInfoNamesRequest) Reset()

func (*GetCellInfoNamesRequest) String

func (x *GetCellInfoNamesRequest) String() string

type GetCellInfoNamesResponse

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

func (*GetCellInfoNamesResponse) Descriptor deprecated

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

Deprecated: Use GetCellInfoNamesResponse.ProtoReflect.Descriptor instead.

func (*GetCellInfoNamesResponse) GetNames

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

func (*GetCellInfoNamesResponse) ProtoMessage

func (*GetCellInfoNamesResponse) ProtoMessage()

func (*GetCellInfoNamesResponse) ProtoReflect

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

func (*GetCellInfoNamesResponse) Reset

func (x *GetCellInfoNamesResponse) Reset()

func (*GetCellInfoNamesResponse) String

func (x *GetCellInfoNamesResponse) String() string

type GetCellInfoRequest

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

func (*GetCellInfoRequest) Descriptor deprecated

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

Deprecated: Use GetCellInfoRequest.ProtoReflect.Descriptor instead.

func (*GetCellInfoRequest) GetCell

func (x *GetCellInfoRequest) GetCell() string

func (*GetCellInfoRequest) ProtoMessage

func (*GetCellInfoRequest) ProtoMessage()

func (*GetCellInfoRequest) ProtoReflect

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

func (*GetCellInfoRequest) Reset

func (x *GetCellInfoRequest) Reset()

func (*GetCellInfoRequest) String

func (x *GetCellInfoRequest) String() string

type GetCellInfoResponse

type GetCellInfoResponse struct {
	CellInfo *dev2.CellInfo `protobuf:"bytes,1,opt,name=cell_info,json=cellInfo,proto3" json:"cell_info,omitempty"`
	// contains filtered or unexported fields
}

func (*GetCellInfoResponse) Descriptor deprecated

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

Deprecated: Use GetCellInfoResponse.ProtoReflect.Descriptor instead.

func (*GetCellInfoResponse) GetCellInfo

func (x *GetCellInfoResponse) GetCellInfo() *dev2.CellInfo

func (*GetCellInfoResponse) ProtoMessage

func (*GetCellInfoResponse) ProtoMessage()

func (*GetCellInfoResponse) ProtoReflect

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

func (*GetCellInfoResponse) Reset

func (x *GetCellInfoResponse) Reset()

func (*GetCellInfoResponse) String

func (x *GetCellInfoResponse) String() string

type GetCellsAliasesRequest

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

func (*GetCellsAliasesRequest) Descriptor deprecated

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

Deprecated: Use GetCellsAliasesRequest.ProtoReflect.Descriptor instead.

func (*GetCellsAliasesRequest) ProtoMessage

func (*GetCellsAliasesRequest) ProtoMessage()

func (*GetCellsAliasesRequest) ProtoReflect

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

func (*GetCellsAliasesRequest) Reset

func (x *GetCellsAliasesRequest) Reset()

func (*GetCellsAliasesRequest) String

func (x *GetCellsAliasesRequest) String() string

type GetCellsAliasesResponse

type GetCellsAliasesResponse struct {
	Aliases map[string]*dev2.CellsAlias `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetCellsAliasesResponse) Descriptor deprecated

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

Deprecated: Use GetCellsAliasesResponse.ProtoReflect.Descriptor instead.

func (*GetCellsAliasesResponse) GetAliases

func (x *GetCellsAliasesResponse) GetAliases() map[string]*dev2.CellsAlias

func (*GetCellsAliasesResponse) ProtoMessage

func (*GetCellsAliasesResponse) ProtoMessage()

func (*GetCellsAliasesResponse) ProtoReflect

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

func (*GetCellsAliasesResponse) Reset

func (x *GetCellsAliasesResponse) Reset()

func (*GetCellsAliasesResponse) String

func (x *GetCellsAliasesResponse) String() string

type GetFullStatusRequest

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

func (*GetFullStatusRequest) Descriptor deprecated

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

Deprecated: Use GetFullStatusRequest.ProtoReflect.Descriptor instead.

func (*GetFullStatusRequest) GetTabletAlias

func (x *GetFullStatusRequest) GetTabletAlias() *dev2.TabletAlias

func (*GetFullStatusRequest) ProtoMessage

func (*GetFullStatusRequest) ProtoMessage()

func (*GetFullStatusRequest) ProtoReflect

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

func (*GetFullStatusRequest) Reset

func (x *GetFullStatusRequest) Reset()

func (*GetFullStatusRequest) String

func (x *GetFullStatusRequest) String() string

type GetFullStatusResponse

type GetFullStatusResponse struct {
	Status *dev8.FullStatus `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*GetFullStatusResponse) Descriptor deprecated

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

Deprecated: Use GetFullStatusResponse.ProtoReflect.Descriptor instead.

func (*GetFullStatusResponse) GetStatus

func (x *GetFullStatusResponse) GetStatus() *dev8.FullStatus

func (*GetFullStatusResponse) ProtoMessage

func (*GetFullStatusResponse) ProtoMessage()

func (*GetFullStatusResponse) ProtoReflect

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

func (*GetFullStatusResponse) Reset

func (x *GetFullStatusResponse) Reset()

func (*GetFullStatusResponse) String

func (x *GetFullStatusResponse) String() string

type GetKeyspaceRequest

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

func (*GetKeyspaceRequest) Descriptor deprecated

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

Deprecated: Use GetKeyspaceRequest.ProtoReflect.Descriptor instead.

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

func (x *GetKeyspaceRequest) String() string

type GetKeyspaceResponse

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

func (*GetKeyspaceResponse) Descriptor deprecated

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

Deprecated: Use GetKeyspaceResponse.ProtoReflect.Descriptor instead.

func (*GetKeyspaceResponse) GetKeyspace

func (x *GetKeyspaceResponse) GetKeyspace() *Keyspace

func (*GetKeyspaceResponse) ProtoMessage

func (*GetKeyspaceResponse) ProtoMessage()

func (*GetKeyspaceResponse) ProtoReflect

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

func (*GetKeyspaceResponse) Reset

func (x *GetKeyspaceResponse) Reset()

func (*GetKeyspaceResponse) String

func (x *GetKeyspaceResponse) String() string

type GetKeyspacesRequest

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

func (*GetKeyspacesRequest) Descriptor deprecated

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

Deprecated: Use GetKeyspacesRequest.ProtoReflect.Descriptor instead.

func (*GetKeyspacesRequest) ProtoMessage

func (*GetKeyspacesRequest) ProtoMessage()

func (*GetKeyspacesRequest) ProtoReflect

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

func (*GetKeyspacesRequest) Reset

func (x *GetKeyspacesRequest) Reset()

func (*GetKeyspacesRequest) String

func (x *GetKeyspacesRequest) String() string

type GetKeyspacesResponse

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

func (*GetKeyspacesResponse) Descriptor deprecated

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

Deprecated: Use GetKeyspacesResponse.ProtoReflect.Descriptor instead.

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

func (x *GetKeyspacesResponse) String() string

type GetPermissionsRequest

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

func (*GetPermissionsRequest) Descriptor deprecated

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

Deprecated: Use GetPermissionsRequest.ProtoReflect.Descriptor instead.

func (*GetPermissionsRequest) GetTabletAlias

func (x *GetPermissionsRequest) GetTabletAlias() *dev2.TabletAlias

func (*GetPermissionsRequest) ProtoMessage

func (*GetPermissionsRequest) ProtoMessage()

func (*GetPermissionsRequest) ProtoReflect

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

func (*GetPermissionsRequest) Reset

func (x *GetPermissionsRequest) Reset()

func (*GetPermissionsRequest) String

func (x *GetPermissionsRequest) String() string

type GetPermissionsResponse

type GetPermissionsResponse struct {
	Permissions *dev1.Permissions `protobuf:"bytes,1,opt,name=permissions,proto3" json:"permissions,omitempty"`
	// contains filtered or unexported fields
}

func (*GetPermissionsResponse) Descriptor deprecated

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

Deprecated: Use GetPermissionsResponse.ProtoReflect.Descriptor instead.

func (*GetPermissionsResponse) GetPermissions

func (x *GetPermissionsResponse) GetPermissions() *dev1.Permissions

func (*GetPermissionsResponse) ProtoMessage

func (*GetPermissionsResponse) ProtoMessage()

func (*GetPermissionsResponse) ProtoReflect

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

func (*GetPermissionsResponse) Reset

func (x *GetPermissionsResponse) Reset()

func (*GetPermissionsResponse) String

func (x *GetPermissionsResponse) String() string

type GetRoutingRulesRequest

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

func (*GetRoutingRulesRequest) Descriptor deprecated

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

Deprecated: Use GetRoutingRulesRequest.ProtoReflect.Descriptor instead.

func (*GetRoutingRulesRequest) ProtoMessage

func (*GetRoutingRulesRequest) ProtoMessage()

func (*GetRoutingRulesRequest) ProtoReflect

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

func (*GetRoutingRulesRequest) Reset

func (x *GetRoutingRulesRequest) Reset()

func (*GetRoutingRulesRequest) String

func (x *GetRoutingRulesRequest) String() string

type GetRoutingRulesResponse

type GetRoutingRulesResponse struct {
	RoutingRules *dev4.RoutingRules `protobuf:"bytes,1,opt,name=routing_rules,json=routingRules,proto3" json:"routing_rules,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRoutingRulesResponse) Descriptor deprecated

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

Deprecated: Use GetRoutingRulesResponse.ProtoReflect.Descriptor instead.

func (*GetRoutingRulesResponse) GetRoutingRules

func (x *GetRoutingRulesResponse) GetRoutingRules() *dev4.RoutingRules

func (*GetRoutingRulesResponse) ProtoMessage

func (*GetRoutingRulesResponse) ProtoMessage()

func (*GetRoutingRulesResponse) ProtoReflect

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

func (*GetRoutingRulesResponse) Reset

func (x *GetRoutingRulesResponse) Reset()

func (*GetRoutingRulesResponse) String

func (x *GetRoutingRulesResponse) String() string

type GetSchemaMigrationsRequest

type GetSchemaMigrationsRequest struct {
	Keyspace string `protobuf:"bytes,1,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	// Uuid, if set, will cause GetSchemaMigrations to return exactly 1 migration,
	// namely the one with that UUID. If no migration exists, the response will
	// be an empty slice, not an error.
	//
	// If this field is set, other fields (status filters, limit, skip, order) are
	// ignored.
	Uuid             string                 `protobuf:"bytes,2,opt,name=uuid,proto3" json:"uuid,omitempty"`
	MigrationContext string                 `protobuf:"bytes,3,opt,name=migration_context,json=migrationContext,proto3" json:"migration_context,omitempty"`
	Status           SchemaMigration_Status `protobuf:"varint,4,opt,name=status,proto3,enum=vitess.vtctldata.dev.SchemaMigration_Status" json:"status,omitempty"`
	// Recent, if set, returns migrations requested between now and the provided
	// value.
	Recent *dev3.Duration `protobuf:"bytes,5,opt,name=recent,proto3" json:"recent,omitempty"`
	Order  QueryOrdering  `protobuf:"varint,6,opt,name=order,proto3,enum=vitess.vtctldata.dev.QueryOrdering" json:"order,omitempty"`
	Limit  uint64         `protobuf:"varint,7,opt,name=limit,proto3" json:"limit,omitempty"`
	Skip   uint64         `protobuf:"varint,8,opt,name=skip,proto3" json:"skip,omitempty"`
	// contains filtered or unexported fields
}

GetSchemaMigrationsRequest controls the behavior of the GetSchemaMigrations rpc.

Keyspace is a required field, while all other fields are optional.

If UUID is set, other optional fields will be ignored, since there will be at most one migration with that UUID. Furthermore, if no migration with that UUID exists, an empty response, not an error, is returned.

MigrationContext, Status, and Recent are mutually exclusive.

func (*GetSchemaMigrationsRequest) Descriptor deprecated

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

Deprecated: Use GetSchemaMigrationsRequest.ProtoReflect.Descriptor instead.

func (*GetSchemaMigrationsRequest) GetKeyspace

func (x *GetSchemaMigrationsRequest) GetKeyspace() string

func (*GetSchemaMigrationsRequest) GetLimit

func (x *GetSchemaMigrationsRequest) GetLimit() uint64

func (*GetSchemaMigrationsRequest) GetMigrationContext

func (x *GetSchemaMigrationsRequest) GetMigrationContext() string

func (*GetSchemaMigrationsRequest) GetOrder

func (*GetSchemaMigrationsRequest) GetRecent

func (x *GetSchemaMigrationsRequest) GetRecent() *dev3.Duration

func (*GetSchemaMigrationsRequest) GetSkip

func (x *GetSchemaMigrationsRequest) GetSkip() uint64

func (*GetSchemaMigrationsRequest) GetStatus

func (*GetSchemaMigrationsRequest) GetUuid

func (x *GetSchemaMigrationsRequest) GetUuid() string

func (*GetSchemaMigrationsRequest) ProtoMessage

func (*GetSchemaMigrationsRequest) ProtoMessage()

func (*GetSchemaMigrationsRequest) ProtoReflect

func (*GetSchemaMigrationsRequest) Reset

func (x *GetSchemaMigrationsRequest) Reset()

func (*GetSchemaMigrationsRequest) String

func (x *GetSchemaMigrationsRequest) String() string

type GetSchemaMigrationsResponse

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

func (*GetSchemaMigrationsResponse) Descriptor deprecated

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

Deprecated: Use GetSchemaMigrationsResponse.ProtoReflect.Descriptor instead.

func (*GetSchemaMigrationsResponse) GetMigrations

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

func (*GetSchemaMigrationsResponse) ProtoMessage

func (*GetSchemaMigrationsResponse) ProtoMessage()

func (*GetSchemaMigrationsResponse) ProtoReflect

func (*GetSchemaMigrationsResponse) Reset

func (x *GetSchemaMigrationsResponse) Reset()

func (*GetSchemaMigrationsResponse) String

func (x *GetSchemaMigrationsResponse) String() string

type GetSchemaRequest

type GetSchemaRequest struct {
	TabletAlias *dev2.TabletAlias `protobuf:"bytes,1,opt,name=tablet_alias,json=tabletAlias,proto3" json:"tablet_alias,omitempty"`
	// Tables is a list of tables for which we should gather information. Each is
	// either an exact match, or a regular expression of the form /regexp/.
	Tables []string `protobuf:"bytes,2,rep,name=tables,proto3" json:"tables,omitempty"`
	// ExcludeTables is a list of tables to exclude from the result. Each is
	// either an exact match, or a regular expression of the form /regexp/.
	ExcludeTables []string `protobuf:"bytes,3,rep,name=exclude_tables,json=excludeTables,proto3" json:"exclude_tables,omitempty"`
	// IncludeViews specifies whether to include views in the result.
	IncludeViews bool `protobuf:"varint,4,opt,name=include_views,json=includeViews,proto3" json:"include_views,omitempty"`
	// TableNamesOnly specifies whether to limit the results to just table names,
	// rather than full schema information for each table.
	TableNamesOnly bool `protobuf:"varint,5,opt,name=table_names_only,json=tableNamesOnly,proto3" json:"table_names_only,omitempty"`
	// TableSizesOnly specifies whether to limit the results to just table sizes,
	// rather than full schema information for each table. It is ignored if
	// TableNamesOnly is set to true.
	TableSizesOnly bool `protobuf:"varint,6,opt,name=table_sizes_only,json=tableSizesOnly,proto3" json:"table_sizes_only,omitempty"`
	// TableSchemaOnly specifies whether to limit the results to just table/view
	// schema definition (CREATE TABLE/VIEW statements) and skip column/field information
	TableSchemaOnly bool `protobuf:"varint,7,opt,name=table_schema_only,json=tableSchemaOnly,proto3" json:"table_schema_only,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSchemaRequest) Descriptor deprecated

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

Deprecated: Use GetSchemaRequest.ProtoReflect.Descriptor instead.

func (*GetSchemaRequest) GetExcludeTables

func (x *GetSchemaRequest) GetExcludeTables() []string

func (*GetSchemaRequest) GetIncludeViews

func (x *GetSchemaRequest) GetIncludeViews() bool

func (*GetSchemaRequest) GetTableNamesOnly

func (x *GetSchemaRequest) GetTableNamesOnly() bool

func (*GetSchemaRequest) GetTableSchemaOnly

func (x *GetSchemaRequest) GetTableSchemaOnly() bool

func (*GetSchemaRequest) GetTableSizesOnly

func (x *GetSchemaRequest) GetTableSizesOnly() bool

func (*GetSchemaRequest) GetTables

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

func (*GetSchemaRequest) GetTabletAlias

func (x *GetSchemaRequest) GetTabletAlias() *dev2.TabletAlias

func (*GetSchemaRequest) ProtoMessage

func (*GetSchemaRequest) ProtoMessage()

func (*GetSchemaRequest) ProtoReflect

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

func (*GetSchemaRequest) Reset

func (x *GetSchemaRequest) Reset()

func (*GetSchemaRequest) String

func (x *GetSchemaRequest) String() string

type GetSchemaResponse

type GetSchemaResponse struct {
	Schema *dev1.SchemaDefinition `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSchemaResponse) Descriptor deprecated

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

Deprecated: Use GetSchemaResponse.ProtoReflect.Descriptor instead.

func (*GetSchemaResponse) GetSchema

func (x *GetSchemaResponse) GetSchema() *dev1.SchemaDefinition

func (*GetSchemaResponse) ProtoMessage

func (*GetSchemaResponse) ProtoMessage()

func (*GetSchemaResponse) ProtoReflect

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

func (*GetSchemaResponse) Reset

func (x *GetSchemaResponse) Reset()

func (*GetSchemaResponse) String

func (x *GetSchemaResponse) String() string

type GetShardRequest

type GetShardRequest struct {
	Keyspace  string `protobuf:"bytes,1,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	ShardName string `protobuf:"bytes,2,opt,name=shard_name,json=shardName,proto3" json:"shard_name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetShardRequest) Descriptor deprecated

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

Deprecated: Use GetShardRequest.ProtoReflect.Descriptor instead.

func (*GetShardRequest) GetKeyspace

func (x *GetShardRequest) GetKeyspace() string

func (*GetShardRequest) GetShardName

func (x *GetShardRequest) GetShardName() string

func (*GetShardRequest) ProtoMessage

func (*GetShardRequest) ProtoMessage()

func (*GetShardRequest) ProtoReflect

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

func (*GetShardRequest) Reset

func (x *GetShardRequest) Reset()

func (*GetShardRequest) String

func (x *GetShardRequest) String() string

type GetShardResponse

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

func (*GetShardResponse) Descriptor deprecated

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

Deprecated: Use GetShardResponse.ProtoReflect.Descriptor instead.

func (*GetShardResponse) GetShard

func (x *GetShardResponse) GetShard() *Shard

func (*GetShardResponse) ProtoMessage

func (*GetShardResponse) ProtoMessage()

func (*GetShardResponse) ProtoReflect

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

func (*GetShardResponse) Reset

func (x *GetShardResponse) Reset()

func (*GetShardResponse) String

func (x *GetShardResponse) String() string

type GetShardRoutingRulesRequest

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

func (*GetShardRoutingRulesRequest) Descriptor deprecated

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

Deprecated: Use GetShardRoutingRulesRequest.ProtoReflect.Descriptor instead.

func (*GetShardRoutingRulesRequest) ProtoMessage

func (*GetShardRoutingRulesRequest) ProtoMessage()

func (*GetShardRoutingRulesRequest) ProtoReflect

func (*GetShardRoutingRulesRequest) Reset

func (x *GetShardRoutingRulesRequest) Reset()

func (*GetShardRoutingRulesRequest) String

func (x *GetShardRoutingRulesRequest) String() string

type GetShardRoutingRulesResponse

type GetShardRoutingRulesResponse struct {
	ShardRoutingRules *dev4.ShardRoutingRules `protobuf:"bytes,1,opt,name=shard_routing_rules,json=shardRoutingRules,proto3" json:"shard_routing_rules,omitempty"`
	// contains filtered or unexported fields
}

func (*GetShardRoutingRulesResponse) Descriptor deprecated

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

Deprecated: Use GetShardRoutingRulesResponse.ProtoReflect.Descriptor instead.

func (*GetShardRoutingRulesResponse) GetShardRoutingRules

func (x *GetShardRoutingRulesResponse) GetShardRoutingRules() *dev4.ShardRoutingRules

func (*GetShardRoutingRulesResponse) ProtoMessage

func (*GetShardRoutingRulesResponse) ProtoMessage()

func (*GetShardRoutingRulesResponse) ProtoReflect

func (*GetShardRoutingRulesResponse) Reset

func (x *GetShardRoutingRulesResponse) Reset()

func (*GetShardRoutingRulesResponse) String

type GetSrvKeyspaceNamesRequest

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

func (*GetSrvKeyspaceNamesRequest) Descriptor deprecated

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

Deprecated: Use GetSrvKeyspaceNamesRequest.ProtoReflect.Descriptor instead.

func (*GetSrvKeyspaceNamesRequest) GetCells

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

func (*GetSrvKeyspaceNamesRequest) ProtoMessage

func (*GetSrvKeyspaceNamesRequest) ProtoMessage()

func (*GetSrvKeyspaceNamesRequest) ProtoReflect

func (*GetSrvKeyspaceNamesRequest) Reset

func (x *GetSrvKeyspaceNamesRequest) Reset()

func (*GetSrvKeyspaceNamesRequest) String

func (x *GetSrvKeyspaceNamesRequest) String() string

type GetSrvKeyspaceNamesResponse

type GetSrvKeyspaceNamesResponse struct {

	// Names is a mapping of cell name to a list of SrvKeyspace names.
	Names map[string]*GetSrvKeyspaceNamesResponse_NameList `` /* 151-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetSrvKeyspaceNamesResponse) Descriptor deprecated

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

Deprecated: Use GetSrvKeyspaceNamesResponse.ProtoReflect.Descriptor instead.

func (*GetSrvKeyspaceNamesResponse) GetNames

func (*GetSrvKeyspaceNamesResponse) ProtoMessage

func (*GetSrvKeyspaceNamesResponse) ProtoMessage()

func (*GetSrvKeyspaceNamesResponse) ProtoReflect

func (*GetSrvKeyspaceNamesResponse) Reset

func (x *GetSrvKeyspaceNamesResponse) Reset()

func (*GetSrvKeyspaceNamesResponse) String

func (x *GetSrvKeyspaceNamesResponse) String() string

type GetSrvKeyspaceNamesResponse_NameList

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

func (*GetSrvKeyspaceNamesResponse_NameList) Descriptor deprecated

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

Deprecated: Use GetSrvKeyspaceNamesResponse_NameList.ProtoReflect.Descriptor instead.

func (*GetSrvKeyspaceNamesResponse_NameList) GetNames

func (*GetSrvKeyspaceNamesResponse_NameList) ProtoMessage

func (*GetSrvKeyspaceNamesResponse_NameList) ProtoMessage()

func (*GetSrvKeyspaceNamesResponse_NameList) ProtoReflect

func (*GetSrvKeyspaceNamesResponse_NameList) Reset

func (*GetSrvKeyspaceNamesResponse_NameList) String

type GetSrvKeyspacesRequest

type GetSrvKeyspacesRequest struct {
	Keyspace string `protobuf:"bytes,1,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,2,rep,name=cells,proto3" json:"cells,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSrvKeyspacesRequest) Descriptor deprecated

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

Deprecated: Use GetSrvKeyspacesRequest.ProtoReflect.Descriptor instead.

func (*GetSrvKeyspacesRequest) GetCells

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

func (*GetSrvKeyspacesRequest) GetKeyspace

func (x *GetSrvKeyspacesRequest) GetKeyspace() 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) String

func (x *GetSrvKeyspacesRequest) String() string

type GetSrvKeyspacesResponse

type GetSrvKeyspacesResponse struct {

	// SrvKeyspaces is a mapping of cell name to SrvKeyspace.
	SrvKeyspaces map[string]*dev2.SrvKeyspace `` /* 185-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetSrvKeyspacesResponse) Descriptor deprecated

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

Deprecated: Use GetSrvKeyspacesResponse.ProtoReflect.Descriptor instead.

func (*GetSrvKeyspacesResponse) GetSrvKeyspaces

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

func (*GetSrvKeyspacesResponse) ProtoMessage

func (*GetSrvKeyspacesResponse) ProtoMessage()

func (*GetSrvKeyspacesResponse) ProtoReflect

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

func (*GetSrvKeyspacesResponse) Reset

func (x *GetSrvKeyspacesResponse) Reset()

func (*GetSrvKeyspacesResponse) String

func (x *GetSrvKeyspacesResponse) String() string

type GetSrvVSchemaRequest

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

func (*GetSrvVSchemaRequest) Descriptor deprecated

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

Deprecated: Use GetSrvVSchemaRequest.ProtoReflect.Descriptor instead.

func (*GetSrvVSchemaRequest) GetCell

func (x *GetSrvVSchemaRequest) GetCell() 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) String

func (x *GetSrvVSchemaRequest) String() string

type GetSrvVSchemaResponse

type GetSrvVSchemaResponse struct {
	SrvVSchema *dev4.SrvVSchema `protobuf:"bytes,1,opt,name=srv_v_schema,json=srvVSchema,proto3" json:"srv_v_schema,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSrvVSchemaResponse) Descriptor deprecated

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

Deprecated: Use GetSrvVSchemaResponse.ProtoReflect.Descriptor instead.

func (*GetSrvVSchemaResponse) GetSrvVSchema

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

func (*GetSrvVSchemaResponse) ProtoMessage

func (*GetSrvVSchemaResponse) ProtoMessage()

func (*GetSrvVSchemaResponse) ProtoReflect

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

func (*GetSrvVSchemaResponse) Reset

func (x *GetSrvVSchemaResponse) Reset()

func (*GetSrvVSchemaResponse) String

func (x *GetSrvVSchemaResponse) String() string

type GetSrvVSchemasRequest

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

func (*GetSrvVSchemasRequest) Descriptor deprecated

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

Deprecated: Use GetSrvVSchemasRequest.ProtoReflect.Descriptor instead.

func (*GetSrvVSchemasRequest) GetCells

func (x *GetSrvVSchemasRequest) GetCells() []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) String

func (x *GetSrvVSchemasRequest) String() string

type GetSrvVSchemasResponse

type GetSrvVSchemasResponse struct {

	// SrvVSchemas is a mapping of cell name to SrvVSchema
	SrvVSchemas map[string]*dev4.SrvVSchema `` /* 184-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetSrvVSchemasResponse) Descriptor deprecated

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

Deprecated: Use GetSrvVSchemasResponse.ProtoReflect.Descriptor instead.

func (*GetSrvVSchemasResponse) GetSrvVSchemas

func (x *GetSrvVSchemasResponse) GetSrvVSchemas() map[string]*dev4.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) String

func (x *GetSrvVSchemasResponse) String() string

type GetTabletRequest

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

func (*GetTabletRequest) Descriptor deprecated

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

Deprecated: Use GetTabletRequest.ProtoReflect.Descriptor instead.

func (*GetTabletRequest) GetTabletAlias

func (x *GetTabletRequest) GetTabletAlias() *dev2.TabletAlias

func (*GetTabletRequest) ProtoMessage

func (*GetTabletRequest) ProtoMessage()

func (*GetTabletRequest) ProtoReflect

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

func (*GetTabletRequest) Reset

func (x *GetTabletRequest) Reset()

func (*GetTabletRequest) String

func (x *GetTabletRequest) String() string

type GetTabletResponse

type GetTabletResponse struct {
	Tablet *dev2.Tablet `protobuf:"bytes,1,opt,name=tablet,proto3" json:"tablet,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTabletResponse) Descriptor deprecated

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

Deprecated: Use GetTabletResponse.ProtoReflect.Descriptor instead.

func (*GetTabletResponse) GetTablet

func (x *GetTabletResponse) GetTablet() *dev2.Tablet

func (*GetTabletResponse) ProtoMessage

func (*GetTabletResponse) ProtoMessage()

func (*GetTabletResponse) ProtoReflect

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

func (*GetTabletResponse) Reset

func (x *GetTabletResponse) Reset()

func (*GetTabletResponse) String

func (x *GetTabletResponse) String() string

type GetTabletsRequest

type GetTabletsRequest struct {

	// Keyspace is the name of the keyspace to return tablets for. Omit to return
	// tablets from all keyspaces.
	Keyspace string `protobuf:"bytes,1,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	// Shard is the name of the shard to return tablets for. This field is ignored
	// if Keyspace is not set.
	Shard string `protobuf:"bytes,2,opt,name=shard,proto3" json:"shard,omitempty"`
	// Cells is an optional set of cells to return tablets for.
	Cells []string `protobuf:"bytes,3,rep,name=cells,proto3" json:"cells,omitempty"`
	// Strict specifies how the server should treat failures from individual
	// cells.
	//
	// When false (the default), GetTablets will return data from any cells that
	// return successfully, but will fail the request if all cells fail. When
	// true, any individual cell can fail the full request.
	Strict bool `protobuf:"varint,4,opt,name=strict,proto3" json:"strict,omitempty"`
	// TabletAliases is an optional list of tablet aliases to fetch Tablet objects
	// for. If specified, Keyspace, Shard, and Cells are ignored, and tablets are
	// looked up by their respective aliases' Cells directly.
	TabletAliases []*dev2.TabletAlias `protobuf:"bytes,5,rep,name=tablet_aliases,json=tabletAliases,proto3" json:"tablet_aliases,omitempty"`
	// tablet_type specifies the type of tablets to return. Omit to return all
	// tablet types.
	TabletType dev2.TabletType `` /* 128-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetTabletsRequest) Descriptor deprecated

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

Deprecated: Use GetTabletsRequest.ProtoReflect.Descriptor instead.

func (*GetTabletsRequest) GetCells

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

func (*GetTabletsRequest) GetKeyspace

func (x *GetTabletsRequest) GetKeyspace() string

func (*GetTabletsRequest) GetShard

func (x *GetTabletsRequest) GetShard() string

func (*GetTabletsRequest) GetStrict

func (x *GetTabletsRequest) GetStrict() bool

func (*GetTabletsRequest) GetTabletAliases

func (x *GetTabletsRequest) GetTabletAliases() []*dev2.TabletAlias

func (*GetTabletsRequest) GetTabletType

func (x *GetTabletsRequest) GetTabletType() dev2.TabletType

func (*GetTabletsRequest) ProtoMessage

func (*GetTabletsRequest) ProtoMessage()

func (*GetTabletsRequest) ProtoReflect

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

func (*GetTabletsRequest) Reset

func (x *GetTabletsRequest) Reset()

func (*GetTabletsRequest) String

func (x *GetTabletsRequest) String() string

type GetTabletsResponse

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

func (*GetTabletsResponse) Descriptor deprecated

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

Deprecated: Use GetTabletsResponse.ProtoReflect.Descriptor instead.

func (*GetTabletsResponse) GetTablets

func (x *GetTabletsResponse) GetTablets() []*dev2.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) String

func (x *GetTabletsResponse) String() string

type GetTopologyPathRequest

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

func (*GetTopologyPathRequest) Descriptor deprecated

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

Deprecated: Use GetTopologyPathRequest.ProtoReflect.Descriptor instead.

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

func (x *GetTopologyPathRequest) String() string

type GetTopologyPathResponse

type GetTopologyPathResponse struct {
	Cell *TopologyCell `protobuf:"bytes,1,opt,name=cell,proto3" json:"cell,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTopologyPathResponse) Descriptor deprecated

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

Deprecated: Use GetTopologyPathResponse.ProtoReflect.Descriptor instead.

func (*GetTopologyPathResponse) GetCell

func (x *GetTopologyPathResponse) GetCell() *TopologyCell

func (*GetTopologyPathResponse) ProtoMessage

func (*GetTopologyPathResponse) ProtoMessage()

func (*GetTopologyPathResponse) ProtoReflect

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

func (*GetTopologyPathResponse) Reset

func (x *GetTopologyPathResponse) Reset()

func (*GetTopologyPathResponse) String

func (x *GetTopologyPathResponse) String() string

type GetVSchemaRequest

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

func (*GetVSchemaRequest) Descriptor deprecated

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

Deprecated: Use GetVSchemaRequest.ProtoReflect.Descriptor instead.

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

func (x *GetVSchemaRequest) String() string

type GetVSchemaResponse

type GetVSchemaResponse struct {
	VSchema *dev4.Keyspace `protobuf:"bytes,1,opt,name=v_schema,json=vSchema,proto3" json:"v_schema,omitempty"`
	// contains filtered or unexported fields
}

func (*GetVSchemaResponse) Descriptor deprecated

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

Deprecated: Use GetVSchemaResponse.ProtoReflect.Descriptor instead.

func (*GetVSchemaResponse) GetVSchema

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

func (*GetVSchemaResponse) ProtoMessage

func (*GetVSchemaResponse) ProtoMessage()

func (*GetVSchemaResponse) ProtoReflect

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

func (*GetVSchemaResponse) Reset

func (x *GetVSchemaResponse) Reset()

func (*GetVSchemaResponse) String

func (x *GetVSchemaResponse) String() string

type GetVersionRequest

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

func (*GetVersionRequest) Descriptor deprecated

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

Deprecated: Use GetVersionRequest.ProtoReflect.Descriptor instead.

func (*GetVersionRequest) GetTabletAlias

func (x *GetVersionRequest) GetTabletAlias() *dev2.TabletAlias

func (*GetVersionRequest) ProtoMessage

func (*GetVersionRequest) ProtoMessage()

func (*GetVersionRequest) ProtoReflect

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

func (*GetVersionRequest) Reset

func (x *GetVersionRequest) Reset()

func (*GetVersionRequest) String

func (x *GetVersionRequest) String() string

type GetVersionResponse

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

func (*GetVersionResponse) Descriptor deprecated

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

Deprecated: Use GetVersionResponse.ProtoReflect.Descriptor instead.

func (*GetVersionResponse) GetVersion

func (x *GetVersionResponse) GetVersion() string

func (*GetVersionResponse) ProtoMessage

func (*GetVersionResponse) ProtoMessage()

func (*GetVersionResponse) ProtoReflect

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

func (*GetVersionResponse) Reset

func (x *GetVersionResponse) Reset()

func (*GetVersionResponse) String

func (x *GetVersionResponse) String() string

type GetWorkflowsRequest

type GetWorkflowsRequest struct {
	Keyspace   string `protobuf:"bytes,1,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	ActiveOnly bool   `protobuf:"varint,2,opt,name=active_only,json=activeOnly,proto3" json:"active_only,omitempty"`
	NameOnly   bool   `protobuf:"varint,3,opt,name=name_only,json=nameOnly,proto3" json:"name_only,omitempty"`
	// If you only want a specific workflow then set this field.
	Workflow string `protobuf:"bytes,4,opt,name=workflow,proto3" json:"workflow,omitempty"`
	// contains filtered or unexported fields
}

func (*GetWorkflowsRequest) Descriptor deprecated

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

Deprecated: Use GetWorkflowsRequest.ProtoReflect.Descriptor instead.

func (*GetWorkflowsRequest) GetActiveOnly

func (x *GetWorkflowsRequest) GetActiveOnly() bool

func (*GetWorkflowsRequest) GetKeyspace

func (x *GetWorkflowsRequest) GetKeyspace() string

func (*GetWorkflowsRequest) GetNameOnly

func (x *GetWorkflowsRequest) GetNameOnly() bool

func (*GetWorkflowsRequest) GetWorkflow

func (x *GetWorkflowsRequest) GetWorkflow() 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) String

func (x *GetWorkflowsRequest) String() string

type GetWorkflowsResponse

type GetWorkflowsResponse struct {
	Workflows []*Workflow `protobuf:"bytes,1,rep,name=workflows,proto3" json:"workflows,omitempty"`
	// contains filtered or unexported fields
}

func (*GetWorkflowsResponse) Descriptor deprecated

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

Deprecated: Use GetWorkflowsResponse.ProtoReflect.Descriptor instead.

func (*GetWorkflowsResponse) GetWorkflows

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

func (*GetWorkflowsResponse) ProtoMessage

func (*GetWorkflowsResponse) ProtoMessage()

func (*GetWorkflowsResponse) ProtoReflect

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

func (*GetWorkflowsResponse) Reset

func (x *GetWorkflowsResponse) Reset()

func (*GetWorkflowsResponse) String

func (x *GetWorkflowsResponse) String() string

type InitShardPrimaryRequest

type InitShardPrimaryRequest 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"`
	PrimaryElectTabletAlias *dev2.TabletAlias `` /* 134-byte string literal not displayed */
	Force                   bool              `protobuf:"varint,4,opt,name=force,proto3" json:"force,omitempty"`
	WaitReplicasTimeout     *dev3.Duration    `protobuf:"bytes,5,opt,name=wait_replicas_timeout,json=waitReplicasTimeout,proto3" json:"wait_replicas_timeout,omitempty"`
	// contains filtered or unexported fields
}

func (*InitShardPrimaryRequest) Descriptor deprecated

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

Deprecated: Use InitShardPrimaryRequest.ProtoReflect.Descriptor instead.

func (*InitShardPrimaryRequest) GetForce

func (x *InitShardPrimaryRequest) GetForce() bool

func (*InitShardPrimaryRequest) GetKeyspace

func (x *InitShardPrimaryRequest) GetKeyspace() string

func (*InitShardPrimaryRequest) GetPrimaryElectTabletAlias

func (x *InitShardPrimaryRequest) GetPrimaryElectTabletAlias() *dev2.TabletAlias

func (*InitShardPrimaryRequest) GetShard

func (x *InitShardPrimaryRequest) GetShard() string

func (*InitShardPrimaryRequest) GetWaitReplicasTimeout

func (x *InitShardPrimaryRequest) GetWaitReplicasTimeout() *dev3.Duration

func (*InitShardPrimaryRequest) ProtoMessage

func (*InitShardPrimaryRequest) ProtoMessage()

func (*InitShardPrimaryRequest) ProtoReflect

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

func (*InitShardPrimaryRequest) Reset

func (x *InitShardPrimaryRequest) Reset()

func (*InitShardPrimaryRequest) String

func (x *InitShardPrimaryRequest) String() string

type InitShardPrimaryResponse

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

func (*InitShardPrimaryResponse) Descriptor deprecated

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

Deprecated: Use InitShardPrimaryResponse.ProtoReflect.Descriptor instead.

func (*InitShardPrimaryResponse) GetEvents

func (x *InitShardPrimaryResponse) GetEvents() []*dev.Event

func (*InitShardPrimaryResponse) ProtoMessage

func (*InitShardPrimaryResponse) ProtoMessage()

func (*InitShardPrimaryResponse) ProtoReflect

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

func (*InitShardPrimaryResponse) Reset

func (x *InitShardPrimaryResponse) Reset()

func (*InitShardPrimaryResponse) String

func (x *InitShardPrimaryResponse) String() string

type Keyspace

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

func (*Keyspace) Descriptor deprecated

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

Deprecated: Use Keyspace.ProtoReflect.Descriptor instead.

func (*Keyspace) GetKeyspace

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

func (*Keyspace) GetName

func (x *Keyspace) GetName() string

func (*Keyspace) ProtoMessage

func (*Keyspace) ProtoMessage()

func (*Keyspace) ProtoReflect

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

func (*Keyspace) Reset

func (x *Keyspace) Reset()

func (*Keyspace) String

func (x *Keyspace) String() string

type LaunchSchemaMigrationRequest

type LaunchSchemaMigrationRequest struct {
	Keyspace string `protobuf:"bytes,1,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	Uuid     string `protobuf:"bytes,2,opt,name=uuid,proto3" json:"uuid,omitempty"`
	// contains filtered or unexported fields
}

func (*LaunchSchemaMigrationRequest) Descriptor deprecated

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

Deprecated: Use LaunchSchemaMigrationRequest.ProtoReflect.Descriptor instead.

func (*LaunchSchemaMigrationRequest) GetKeyspace

func (x *LaunchSchemaMigrationRequest) GetKeyspace() string

func (*LaunchSchemaMigrationRequest) GetUuid

func (x *LaunchSchemaMigrationRequest) GetUuid() string

func (*LaunchSchemaMigrationRequest) ProtoMessage

func (*LaunchSchemaMigrationRequest) ProtoMessage()

func (*LaunchSchemaMigrationRequest) ProtoReflect

func (*LaunchSchemaMigrationRequest) Reset

func (x *LaunchSchemaMigrationRequest) Reset()

func (*LaunchSchemaMigrationRequest) String

type LaunchSchemaMigrationResponse

type LaunchSchemaMigrationResponse struct {
	RowsAffectedByShard map[string]uint64 `` /* 211-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*LaunchSchemaMigrationResponse) Descriptor deprecated

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

Deprecated: Use LaunchSchemaMigrationResponse.ProtoReflect.Descriptor instead.

func (*LaunchSchemaMigrationResponse) GetRowsAffectedByShard

func (x *LaunchSchemaMigrationResponse) GetRowsAffectedByShard() map[string]uint64

func (*LaunchSchemaMigrationResponse) ProtoMessage

func (*LaunchSchemaMigrationResponse) ProtoMessage()

func (*LaunchSchemaMigrationResponse) ProtoReflect

func (*LaunchSchemaMigrationResponse) Reset

func (x *LaunchSchemaMigrationResponse) Reset()

func (*LaunchSchemaMigrationResponse) String

type LookupVindexCreateRequest

type LookupVindexCreateRequest struct {
	Keyspace                   string                         `protobuf:"bytes,1,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	Workflow                   string                         `protobuf:"bytes,2,opt,name=workflow,proto3" json:"workflow,omitempty"`
	Cells                      []string                       `protobuf:"bytes,3,rep,name=cells,proto3" json:"cells,omitempty"`
	Vindex                     *dev4.Keyspace                 `protobuf:"bytes,4,opt,name=vindex,proto3" json:"vindex,omitempty"`
	ContinueAfterCopyWithOwner bool                           `` /* 146-byte string literal not displayed */
	TabletTypes                []dev2.TabletType              `` /* 138-byte string literal not displayed */
	TabletSelectionPreference  dev1.TabletSelectionPreference `` /* 199-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*LookupVindexCreateRequest) Descriptor deprecated

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

Deprecated: Use LookupVindexCreateRequest.ProtoReflect.Descriptor instead.

func (*LookupVindexCreateRequest) GetCells

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

func (*LookupVindexCreateRequest) GetContinueAfterCopyWithOwner

func (x *LookupVindexCreateRequest) GetContinueAfterCopyWithOwner() bool

func (*LookupVindexCreateRequest) GetKeyspace

func (x *LookupVindexCreateRequest) GetKeyspace() string

func (*LookupVindexCreateRequest) GetTabletSelectionPreference

func (x *LookupVindexCreateRequest) GetTabletSelectionPreference() dev1.TabletSelectionPreference

func (*LookupVindexCreateRequest) GetTabletTypes

func (x *LookupVindexCreateRequest) GetTabletTypes() []dev2.TabletType

func (*LookupVindexCreateRequest) GetVindex

func (x *LookupVindexCreateRequest) GetVindex() *dev4.Keyspace

func (*LookupVindexCreateRequest) GetWorkflow

func (x *LookupVindexCreateRequest) GetWorkflow() string

func (*LookupVindexCreateRequest) ProtoMessage

func (*LookupVindexCreateRequest) ProtoMessage()

func (*LookupVindexCreateRequest) ProtoReflect

func (*LookupVindexCreateRequest) Reset

func (x *LookupVindexCreateRequest) Reset()

func (*LookupVindexCreateRequest) String

func (x *LookupVindexCreateRequest) String() string

type LookupVindexCreateResponse

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

func (*LookupVindexCreateResponse) Descriptor deprecated

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

Deprecated: Use LookupVindexCreateResponse.ProtoReflect.Descriptor instead.

func (*LookupVindexCreateResponse) ProtoMessage

func (*LookupVindexCreateResponse) ProtoMessage()

func (*LookupVindexCreateResponse) ProtoReflect

func (*LookupVindexCreateResponse) Reset

func (x *LookupVindexCreateResponse) Reset()

func (*LookupVindexCreateResponse) String

func (x *LookupVindexCreateResponse) String() string

type LookupVindexExternalizeRequest

type LookupVindexExternalizeRequest struct {

	// Where the lookup vindex lives.
	Keyspace string `protobuf:"bytes,1,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	// This is the name of the lookup vindex and the vreplication workflow.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Where the vreplication workflow lives.
	TableKeyspace string `protobuf:"bytes,3,opt,name=table_keyspace,json=tableKeyspace,proto3" json:"table_keyspace,omitempty"`
	// contains filtered or unexported fields
}

func (*LookupVindexExternalizeRequest) Descriptor deprecated

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

Deprecated: Use LookupVindexExternalizeRequest.ProtoReflect.Descriptor instead.

func (*LookupVindexExternalizeRequest) GetKeyspace

func (x *LookupVindexExternalizeRequest) GetKeyspace() string

func (*LookupVindexExternalizeRequest) GetName

func (*LookupVindexExternalizeRequest) GetTableKeyspace

func (x *LookupVindexExternalizeRequest) GetTableKeyspace() string

func (*LookupVindexExternalizeRequest) ProtoMessage

func (*LookupVindexExternalizeRequest) ProtoMessage()

func (*LookupVindexExternalizeRequest) ProtoReflect

func (*LookupVindexExternalizeRequest) Reset

func (x *LookupVindexExternalizeRequest) Reset()

func (*LookupVindexExternalizeRequest) String

type LookupVindexExternalizeResponse

type LookupVindexExternalizeResponse struct {

	// Was the workflow also deleted.
	WorkflowDeleted bool `protobuf:"varint,1,opt,name=workflow_deleted,json=workflowDeleted,proto3" json:"workflow_deleted,omitempty"`
	// contains filtered or unexported fields
}

func (*LookupVindexExternalizeResponse) Descriptor deprecated

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

Deprecated: Use LookupVindexExternalizeResponse.ProtoReflect.Descriptor instead.

func (*LookupVindexExternalizeResponse) GetWorkflowDeleted

func (x *LookupVindexExternalizeResponse) GetWorkflowDeleted() bool

func (*LookupVindexExternalizeResponse) ProtoMessage

func (*LookupVindexExternalizeResponse) ProtoMessage()

func (*LookupVindexExternalizeResponse) ProtoReflect

func (*LookupVindexExternalizeResponse) Reset

func (*LookupVindexExternalizeResponse) String

type MaterializationIntent

type MaterializationIntent int32

MaterializationIntent describes the reason for creating the Materialize flow

const (
	// CUSTOM is the default value
	MaterializationIntent_CUSTOM MaterializationIntent = 0
	// MOVETABLES is when we are creating a MoveTables flow
	MaterializationIntent_MOVETABLES MaterializationIntent = 1
	// CREATELOOKUPINDEX is when we are creating a CreateLookupIndex flow
	MaterializationIntent_CREATELOOKUPINDEX MaterializationIntent = 2
)

func (MaterializationIntent) Descriptor

func (MaterializationIntent) Enum

func (MaterializationIntent) EnumDescriptor deprecated

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

Deprecated: Use MaterializationIntent.Descriptor instead.

func (MaterializationIntent) Number

func (MaterializationIntent) String

func (x MaterializationIntent) String() string

func (MaterializationIntent) Type

type MaterializeSettings

type MaterializeSettings struct {

	// workflow is the name of the workflow.
	Workflow       string `protobuf:"bytes,1,opt,name=workflow,proto3" json:"workflow,omitempty"`
	SourceKeyspace string `protobuf:"bytes,2,opt,name=source_keyspace,json=sourceKeyspace,proto3" json:"source_keyspace,omitempty"`
	TargetKeyspace string `protobuf:"bytes,3,opt,name=target_keyspace,json=targetKeyspace,proto3" json:"target_keyspace,omitempty"`
	// stop_after_copy specifies if vreplication should be stopped after copying.
	StopAfterCopy bool                        `protobuf:"varint,4,opt,name=stop_after_copy,json=stopAfterCopy,proto3" json:"stop_after_copy,omitempty"`
	TableSettings []*TableMaterializeSettings `protobuf:"bytes,5,rep,name=table_settings,json=tableSettings,proto3" json:"table_settings,omitempty"`
	// optional parameters.
	Cell        string `protobuf:"bytes,6,opt,name=cell,proto3" json:"cell,omitempty"`
	TabletTypes string `protobuf:"bytes,7,opt,name=tablet_types,json=tabletTypes,proto3" json:"tablet_types,omitempty"`
	// ExternalCluster is the name of the mounted cluster which has the source keyspace/db for this workflow
	// it is of the type <cluster_type.cluster_name>
	ExternalCluster string `protobuf:"bytes,8,opt,name=external_cluster,json=externalCluster,proto3" json:"external_cluster,omitempty"`
	// MaterializationIntent is used to identify the reason behind the materialization workflow: eg. MoveTables, CreateLookupVindex
	MaterializationIntent MaterializationIntent `` /* 173-byte string literal not displayed */
	// SourceTimeZone is the time zone in which datetimes on the source were stored, provided as an option in MoveTable
	SourceTimeZone string `protobuf:"bytes,10,opt,name=source_time_zone,json=sourceTimeZone,proto3" json:"source_time_zone,omitempty"`
	// TargetTimeZone is not currently specifiable by the user, defaults to UTC for the forward workflows
	// and to the SourceTimeZone in reverse workflows
	TargetTimeZone string   `protobuf:"bytes,11,opt,name=target_time_zone,json=targetTimeZone,proto3" json:"target_time_zone,omitempty"`
	SourceShards   []string `protobuf:"bytes,12,rep,name=source_shards,json=sourceShards,proto3" json:"source_shards,omitempty"`
	// OnDdl specifies the action to be taken when a DDL is encountered.
	OnDdl string `protobuf:"bytes,13,opt,name=on_ddl,json=onDdl,proto3" json:"on_ddl,omitempty"`
	// DeferSecondaryKeys specifies if secondary keys should be created in one shot after table copy finishes.
	DeferSecondaryKeys        bool                           `protobuf:"varint,14,opt,name=defer_secondary_keys,json=deferSecondaryKeys,proto3" json:"defer_secondary_keys,omitempty"`
	TabletSelectionPreference dev1.TabletSelectionPreference `` /* 200-byte string literal not displayed */
	AtomicCopy                bool                           `protobuf:"varint,16,opt,name=atomic_copy,json=atomicCopy,proto3" json:"atomic_copy,omitempty"`
	// contains filtered or unexported fields
}

MaterializeSettings contains the settings for the Materialize command.

func (*MaterializeSettings) Descriptor deprecated

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

Deprecated: Use MaterializeSettings.ProtoReflect.Descriptor instead.

func (*MaterializeSettings) GetAtomicCopy

func (x *MaterializeSettings) GetAtomicCopy() bool

func (*MaterializeSettings) GetCell

func (x *MaterializeSettings) GetCell() string

func (*MaterializeSettings) GetDeferSecondaryKeys

func (x *MaterializeSettings) GetDeferSecondaryKeys() bool

func (*MaterializeSettings) GetExternalCluster

func (x *MaterializeSettings) GetExternalCluster() string

func (*MaterializeSettings) GetMaterializationIntent

func (x *MaterializeSettings) GetMaterializationIntent() MaterializationIntent

func (*MaterializeSettings) GetOnDdl

func (x *MaterializeSettings) GetOnDdl() string

func (*MaterializeSettings) GetSourceKeyspace

func (x *MaterializeSettings) GetSourceKeyspace() string

func (*MaterializeSettings) GetSourceShards

func (x *MaterializeSettings) GetSourceShards() []string

func (*MaterializeSettings) GetSourceTimeZone

func (x *MaterializeSettings) GetSourceTimeZone() string

func (*MaterializeSettings) GetStopAfterCopy

func (x *MaterializeSettings) GetStopAfterCopy() bool

func (*MaterializeSettings) GetTableSettings

func (x *MaterializeSettings) GetTableSettings() []*TableMaterializeSettings

func (*MaterializeSettings) GetTabletSelectionPreference

func (x *MaterializeSettings) GetTabletSelectionPreference() dev1.TabletSelectionPreference

func (*MaterializeSettings) GetTabletTypes

func (x *MaterializeSettings) GetTabletTypes() string

func (*MaterializeSettings) GetTargetKeyspace

func (x *MaterializeSettings) GetTargetKeyspace() string

func (*MaterializeSettings) GetTargetTimeZone

func (x *MaterializeSettings) GetTargetTimeZone() string

func (*MaterializeSettings) GetWorkflow

func (x *MaterializeSettings) GetWorkflow() string

func (*MaterializeSettings) ProtoMessage

func (*MaterializeSettings) ProtoMessage()

func (*MaterializeSettings) ProtoReflect

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

func (*MaterializeSettings) Reset

func (x *MaterializeSettings) Reset()

func (*MaterializeSettings) String

func (x *MaterializeSettings) String() string

type MoveTablesCompleteRequest

type MoveTablesCompleteRequest struct {
	Workflow         string `protobuf:"bytes,1,opt,name=workflow,proto3" json:"workflow,omitempty"`
	TargetKeyspace   string `protobuf:"bytes,3,opt,name=target_keyspace,json=targetKeyspace,proto3" json:"target_keyspace,omitempty"`
	KeepData         bool   `protobuf:"varint,4,opt,name=keep_data,json=keepData,proto3" json:"keep_data,omitempty"`
	KeepRoutingRules bool   `protobuf:"varint,5,opt,name=keep_routing_rules,json=keepRoutingRules,proto3" json:"keep_routing_rules,omitempty"`
	RenameTables     bool   `protobuf:"varint,6,opt,name=rename_tables,json=renameTables,proto3" json:"rename_tables,omitempty"`
	DryRun           bool   `protobuf:"varint,7,opt,name=dry_run,json=dryRun,proto3" json:"dry_run,omitempty"`
	// contains filtered or unexported fields
}

func (*MoveTablesCompleteRequest) Descriptor deprecated

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

Deprecated: Use MoveTablesCompleteRequest.ProtoReflect.Descriptor instead.

func (*MoveTablesCompleteRequest) GetDryRun

func (x *MoveTablesCompleteRequest) GetDryRun() bool

func (*MoveTablesCompleteRequest) GetKeepData

func (x *MoveTablesCompleteRequest) GetKeepData() bool

func (*MoveTablesCompleteRequest) GetKeepRoutingRules

func (x *MoveTablesCompleteRequest) GetKeepRoutingRules() bool

func (*MoveTablesCompleteRequest) GetRenameTables

func (x *MoveTablesCompleteRequest) GetRenameTables() bool

func (*MoveTablesCompleteRequest) GetTargetKeyspace

func (x *MoveTablesCompleteRequest) GetTargetKeyspace() string

func (*MoveTablesCompleteRequest) GetWorkflow

func (x *MoveTablesCompleteRequest) GetWorkflow() string

func (*MoveTablesCompleteRequest) ProtoMessage

func (*MoveTablesCompleteRequest) ProtoMessage()

func (*MoveTablesCompleteRequest) ProtoReflect

func (*MoveTablesCompleteRequest) Reset

func (x *MoveTablesCompleteRequest) Reset()

func (*MoveTablesCompleteRequest) String

func (x *MoveTablesCompleteRequest) String() string

type MoveTablesCompleteResponse

type MoveTablesCompleteResponse struct {
	Summary       string   `protobuf:"bytes,1,opt,name=summary,proto3" json:"summary,omitempty"`
	DryRunResults []string `protobuf:"bytes,2,rep,name=dry_run_results,json=dryRunResults,proto3" json:"dry_run_results,omitempty"`
	// contains filtered or unexported fields
}

func (*MoveTablesCompleteResponse) Descriptor deprecated

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

Deprecated: Use MoveTablesCompleteResponse.ProtoReflect.Descriptor instead.

func (*MoveTablesCompleteResponse) GetDryRunResults

func (x *MoveTablesCompleteResponse) GetDryRunResults() []string

func (*MoveTablesCompleteResponse) GetSummary

func (x *MoveTablesCompleteResponse) GetSummary() string

func (*MoveTablesCompleteResponse) ProtoMessage

func (*MoveTablesCompleteResponse) ProtoMessage()

func (*MoveTablesCompleteResponse) ProtoReflect

func (*MoveTablesCompleteResponse) Reset

func (x *MoveTablesCompleteResponse) Reset()

func (*MoveTablesCompleteResponse) String

func (x *MoveTablesCompleteResponse) String() string

type MoveTablesCreateRequest

type MoveTablesCreateRequest struct {

	// The necessary info gets passed on to each primary tablet involved
	// in the workflow via the CreateVReplicationWorkflow tabletmanager RPC.
	Workflow                  string                         `protobuf:"bytes,1,opt,name=workflow,proto3" json:"workflow,omitempty"`
	SourceKeyspace            string                         `protobuf:"bytes,2,opt,name=source_keyspace,json=sourceKeyspace,proto3" json:"source_keyspace,omitempty"`
	TargetKeyspace            string                         `protobuf:"bytes,3,opt,name=target_keyspace,json=targetKeyspace,proto3" json:"target_keyspace,omitempty"`
	Cells                     []string                       `protobuf:"bytes,4,rep,name=cells,proto3" json:"cells,omitempty"`
	TabletTypes               []dev2.TabletType              `` /* 138-byte string literal not displayed */
	TabletSelectionPreference dev1.TabletSelectionPreference `` /* 199-byte string literal not displayed */
	SourceShards              []string                       `protobuf:"bytes,7,rep,name=source_shards,json=sourceShards,proto3" json:"source_shards,omitempty"`
	AllTables                 bool                           `protobuf:"varint,8,opt,name=all_tables,json=allTables,proto3" json:"all_tables,omitempty"`
	IncludeTables             []string                       `protobuf:"bytes,9,rep,name=include_tables,json=includeTables,proto3" json:"include_tables,omitempty"`
	ExcludeTables             []string                       `protobuf:"bytes,10,rep,name=exclude_tables,json=excludeTables,proto3" json:"exclude_tables,omitempty"`
	// The name of the external cluster mounted in topo server.
	ExternalClusterName string `protobuf:"bytes,11,opt,name=external_cluster_name,json=externalClusterName,proto3" json:"external_cluster_name,omitempty"`
	// SourceTimeZone is the time zone in which datetimes on the source were stored, provided as an option in MoveTables
	SourceTimeZone string `protobuf:"bytes,12,opt,name=source_time_zone,json=sourceTimeZone,proto3" json:"source_time_zone,omitempty"`
	// OnDdl specifies the action to be taken when a DDL is encountered.
	OnDdl string `protobuf:"bytes,13,opt,name=on_ddl,json=onDdl,proto3" json:"on_ddl,omitempty"`
	// StopAfterCopy specifies if vreplication should be stopped after copying.
	StopAfterCopy bool `protobuf:"varint,14,opt,name=stop_after_copy,json=stopAfterCopy,proto3" json:"stop_after_copy,omitempty"`
	// DropForeignKeys specifies if foreign key constraints should be elided on the target.
	DropForeignKeys bool `protobuf:"varint,15,opt,name=drop_foreign_keys,json=dropForeignKeys,proto3" json:"drop_foreign_keys,omitempty"`
	// DeferSecondaryKeys specifies if secondary keys should be created in one shot after table copy finishes.
	DeferSecondaryKeys bool `protobuf:"varint,16,opt,name=defer_secondary_keys,json=deferSecondaryKeys,proto3" json:"defer_secondary_keys,omitempty"`
	// Start the workflow after creating it.
	AutoStart bool `protobuf:"varint,17,opt,name=auto_start,json=autoStart,proto3" json:"auto_start,omitempty"`
	// NoRoutingRules is set to true if routing rules should not be created on the target when the workflow is created.
	NoRoutingRules bool `protobuf:"varint,18,opt,name=no_routing_rules,json=noRoutingRules,proto3" json:"no_routing_rules,omitempty"`
	// Run a single copy phase for the entire database.
	AtomicCopy bool `protobuf:"varint,19,opt,name=atomic_copy,json=atomicCopy,proto3" json:"atomic_copy,omitempty"`
	// contains filtered or unexported fields
}

func (*MoveTablesCreateRequest) Descriptor deprecated

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

Deprecated: Use MoveTablesCreateRequest.ProtoReflect.Descriptor instead.

func (*MoveTablesCreateRequest) GetAllTables

func (x *MoveTablesCreateRequest) GetAllTables() bool

func (*MoveTablesCreateRequest) GetAtomicCopy

func (x *MoveTablesCreateRequest) GetAtomicCopy() bool

func (*MoveTablesCreateRequest) GetAutoStart

func (x *MoveTablesCreateRequest) GetAutoStart() bool

func (*MoveTablesCreateRequest) GetCells

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

func (*MoveTablesCreateRequest) GetDeferSecondaryKeys

func (x *MoveTablesCreateRequest) GetDeferSecondaryKeys() bool

func (*MoveTablesCreateRequest) GetDropForeignKeys

func (x *MoveTablesCreateRequest) GetDropForeignKeys() bool

func (*MoveTablesCreateRequest) GetExcludeTables

func (x *MoveTablesCreateRequest) GetExcludeTables() []string

func (*MoveTablesCreateRequest) GetExternalClusterName

func (x *MoveTablesCreateRequest) GetExternalClusterName() string

func (*MoveTablesCreateRequest) GetIncludeTables

func (x *MoveTablesCreateRequest) GetIncludeTables() []string

func (*MoveTablesCreateRequest) GetNoRoutingRules

func (x *MoveTablesCreateRequest) GetNoRoutingRules() bool

func (*MoveTablesCreateRequest) GetOnDdl

func (x *MoveTablesCreateRequest) GetOnDdl() string

func (*MoveTablesCreateRequest) GetSourceKeyspace

func (x *MoveTablesCreateRequest) GetSourceKeyspace() string

func (*MoveTablesCreateRequest) GetSourceShards

func (x *MoveTablesCreateRequest) GetSourceShards() []string

func (*MoveTablesCreateRequest) GetSourceTimeZone

func (x *MoveTablesCreateRequest) GetSourceTimeZone() string

func (*MoveTablesCreateRequest) GetStopAfterCopy

func (x *MoveTablesCreateRequest) GetStopAfterCopy() bool

func (*MoveTablesCreateRequest) GetTabletSelectionPreference

func (x *MoveTablesCreateRequest) GetTabletSelectionPreference() dev1.TabletSelectionPreference

func (*MoveTablesCreateRequest) GetTabletTypes

func (x *MoveTablesCreateRequest) GetTabletTypes() []dev2.TabletType

func (*MoveTablesCreateRequest) GetTargetKeyspace

func (x *MoveTablesCreateRequest) GetTargetKeyspace() string

func (*MoveTablesCreateRequest) GetWorkflow

func (x *MoveTablesCreateRequest) GetWorkflow() string

func (*MoveTablesCreateRequest) ProtoMessage

func (*MoveTablesCreateRequest) ProtoMessage()

func (*MoveTablesCreateRequest) ProtoReflect

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

func (*MoveTablesCreateRequest) Reset

func (x *MoveTablesCreateRequest) Reset()

func (*MoveTablesCreateRequest) String

func (x *MoveTablesCreateRequest) String() string

type MoveTablesCreateResponse

type MoveTablesCreateResponse struct {
	Summary string                                 `protobuf:"bytes,1,opt,name=summary,proto3" json:"summary,omitempty"`
	Details []*MoveTablesCreateResponse_TabletInfo `protobuf:"bytes,2,rep,name=details,proto3" json:"details,omitempty"`
	// contains filtered or unexported fields
}

func (*MoveTablesCreateResponse) Descriptor deprecated

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

Deprecated: Use MoveTablesCreateResponse.ProtoReflect.Descriptor instead.

func (*MoveTablesCreateResponse) GetDetails

func (*MoveTablesCreateResponse) GetSummary

func (x *MoveTablesCreateResponse) GetSummary() string

func (*MoveTablesCreateResponse) ProtoMessage

func (*MoveTablesCreateResponse) ProtoMessage()

func (*MoveTablesCreateResponse) ProtoReflect

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

func (*MoveTablesCreateResponse) Reset

func (x *MoveTablesCreateResponse) Reset()

func (*MoveTablesCreateResponse) String

func (x *MoveTablesCreateResponse) String() string

type MoveTablesCreateResponse_TabletInfo

type MoveTablesCreateResponse_TabletInfo struct {
	Tablet *dev2.TabletAlias `protobuf:"bytes,1,opt,name=tablet,proto3" json:"tablet,omitempty"`
	// Created is set if the workflow was created on this tablet or not.
	Created bool `protobuf:"varint,2,opt,name=created,proto3" json:"created,omitempty"`
	// contains filtered or unexported fields
}

func (*MoveTablesCreateResponse_TabletInfo) Descriptor deprecated

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

Deprecated: Use MoveTablesCreateResponse_TabletInfo.ProtoReflect.Descriptor instead.

func (*MoveTablesCreateResponse_TabletInfo) GetCreated

func (x *MoveTablesCreateResponse_TabletInfo) GetCreated() bool

func (*MoveTablesCreateResponse_TabletInfo) GetTablet

func (*MoveTablesCreateResponse_TabletInfo) ProtoMessage

func (*MoveTablesCreateResponse_TabletInfo) ProtoMessage()

func (*MoveTablesCreateResponse_TabletInfo) ProtoReflect

func (*MoveTablesCreateResponse_TabletInfo) Reset

func (*MoveTablesCreateResponse_TabletInfo) String

type PingTabletRequest

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

func (*PingTabletRequest) Descriptor deprecated

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

Deprecated: Use PingTabletRequest.ProtoReflect.Descriptor instead.

func (*PingTabletRequest) GetTabletAlias

func (x *PingTabletRequest) GetTabletAlias() *dev2.TabletAlias

func (*PingTabletRequest) ProtoMessage

func (*PingTabletRequest) ProtoMessage()

func (*PingTabletRequest) ProtoReflect

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

func (*PingTabletRequest) Reset

func (x *PingTabletRequest) Reset()

func (*PingTabletRequest) String

func (x *PingTabletRequest) String() string

type PingTabletResponse

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

func (*PingTabletResponse) Descriptor deprecated

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

Deprecated: Use PingTabletResponse.ProtoReflect.Descriptor instead.

func (*PingTabletResponse) ProtoMessage

func (*PingTabletResponse) ProtoMessage()

func (*PingTabletResponse) ProtoReflect

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

func (*PingTabletResponse) Reset

func (x *PingTabletResponse) Reset()

func (*PingTabletResponse) String

func (x *PingTabletResponse) String() string

type PlannedReparentShardRequest

type PlannedReparentShardRequest struct {

	// Keyspace is the name of the keyspace to perform the Planned Reparent in.
	Keyspace string `protobuf:"bytes,1,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	// Shard is the name of the shard to perform teh Planned Reparent in.
	Shard string `protobuf:"bytes,2,opt,name=shard,proto3" json:"shard,omitempty"`
	// NewPrimary is the alias of the tablet to promote to shard primary. If not
	// specified, the vtctld will select the most up-to-date candidate to promote.
	//
	// It is an error to set NewPrimary and AvoidPrimary to the same alias.
	NewPrimary *dev2.TabletAlias `protobuf:"bytes,3,opt,name=new_primary,json=newPrimary,proto3" json:"new_primary,omitempty"`
	// AvoidPrimary is the alias of the tablet to demote. In other words,
	// specifying an AvoidPrimary alias tells the vtctld to promote any replica
	// other than this one. A shard whose current primary is not this one is then
	// a no-op.
	//
	// It is an error to set NewPrimary and AvoidPrimary to the same alias.
	AvoidPrimary *dev2.TabletAlias `protobuf:"bytes,4,opt,name=avoid_primary,json=avoidPrimary,proto3" json:"avoid_primary,omitempty"`
	// WaitReplicasTimeout is the duration of time to wait for replicas to catch
	// up in replication both before and after the reparent. The timeout is not
	// cumulative across both wait periods, meaning that the replicas have
	// WaitReplicasTimeout time to catch up before the reparent, and an additional
	// WaitReplicasTimeout time to catch up after the reparent.
	WaitReplicasTimeout *dev3.Duration `protobuf:"bytes,5,opt,name=wait_replicas_timeout,json=waitReplicasTimeout,proto3" json:"wait_replicas_timeout,omitempty"`
	// contains filtered or unexported fields
}

func (*PlannedReparentShardRequest) Descriptor deprecated

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

Deprecated: Use PlannedReparentShardRequest.ProtoReflect.Descriptor instead.

func (*PlannedReparentShardRequest) GetAvoidPrimary

func (x *PlannedReparentShardRequest) GetAvoidPrimary() *dev2.TabletAlias

func (*PlannedReparentShardRequest) GetKeyspace

func (x *PlannedReparentShardRequest) GetKeyspace() string

func (*PlannedReparentShardRequest) GetNewPrimary

func (x *PlannedReparentShardRequest) GetNewPrimary() *dev2.TabletAlias

func (*PlannedReparentShardRequest) GetShard

func (x *PlannedReparentShardRequest) GetShard() string

func (*PlannedReparentShardRequest) GetWaitReplicasTimeout

func (x *PlannedReparentShardRequest) GetWaitReplicasTimeout() *dev3.Duration

func (*PlannedReparentShardRequest) ProtoMessage

func (*PlannedReparentShardRequest) ProtoMessage()

func (*PlannedReparentShardRequest) ProtoReflect

func (*PlannedReparentShardRequest) Reset

func (x *PlannedReparentShardRequest) Reset()

func (*PlannedReparentShardRequest) String

func (x *PlannedReparentShardRequest) String() string

type PlannedReparentShardResponse

type PlannedReparentShardResponse struct {

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

func (*PlannedReparentShardResponse) Descriptor deprecated

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

Deprecated: Use PlannedReparentShardResponse.ProtoReflect.Descriptor instead.

func (*PlannedReparentShardResponse) GetEvents

func (x *PlannedReparentShardResponse) GetEvents() []*dev.Event

func (*PlannedReparentShardResponse) GetKeyspace

func (x *PlannedReparentShardResponse) GetKeyspace() string

func (*PlannedReparentShardResponse) GetPromotedPrimary

func (x *PlannedReparentShardResponse) GetPromotedPrimary() *dev2.TabletAlias

func (*PlannedReparentShardResponse) GetShard

func (x *PlannedReparentShardResponse) GetShard() string

func (*PlannedReparentShardResponse) ProtoMessage

func (*PlannedReparentShardResponse) ProtoMessage()

func (*PlannedReparentShardResponse) ProtoReflect

func (*PlannedReparentShardResponse) Reset

func (x *PlannedReparentShardResponse) Reset()

func (*PlannedReparentShardResponse) String

type QueryOrdering

type QueryOrdering int32
const (
	QueryOrdering_NONE       QueryOrdering = 0
	QueryOrdering_ASCENDING  QueryOrdering = 1
	QueryOrdering_DESCENDING QueryOrdering = 2
)

func (QueryOrdering) Descriptor

func (QueryOrdering) Enum

func (x QueryOrdering) Enum() *QueryOrdering

func (QueryOrdering) EnumDescriptor deprecated

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

Deprecated: Use QueryOrdering.Descriptor instead.

func (QueryOrdering) Number

func (QueryOrdering) String

func (x QueryOrdering) String() string

func (QueryOrdering) Type

type RebuildKeyspaceGraphRequest

type RebuildKeyspaceGraphRequest struct {
	Keyspace string   `protobuf:"bytes,1,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	Cells    []string `protobuf:"bytes,2,rep,name=cells,proto3" json:"cells,omitempty"`
	// AllowPartial, when set, allows a SNAPSHOT keyspace to serve with an
	// incomplete set of shards. It is ignored for all other keyspace types.
	AllowPartial bool `protobuf:"varint,3,opt,name=allow_partial,json=allowPartial,proto3" json:"allow_partial,omitempty"`
	// contains filtered or unexported fields
}

func (*RebuildKeyspaceGraphRequest) Descriptor deprecated

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

Deprecated: Use RebuildKeyspaceGraphRequest.ProtoReflect.Descriptor instead.

func (*RebuildKeyspaceGraphRequest) GetAllowPartial

func (x *RebuildKeyspaceGraphRequest) GetAllowPartial() bool

func (*RebuildKeyspaceGraphRequest) GetCells

func (x *RebuildKeyspaceGraphRequest) GetCells() []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) String

func (x *RebuildKeyspaceGraphRequest) String() string

type RebuildKeyspaceGraphResponse

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

func (*RebuildKeyspaceGraphResponse) Descriptor deprecated

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

Deprecated: Use RebuildKeyspaceGraphResponse.ProtoReflect.Descriptor instead.

func (*RebuildKeyspaceGraphResponse) ProtoMessage

func (*RebuildKeyspaceGraphResponse) ProtoMessage()

func (*RebuildKeyspaceGraphResponse) ProtoReflect

func (*RebuildKeyspaceGraphResponse) Reset

func (x *RebuildKeyspaceGraphResponse) Reset()

func (*RebuildKeyspaceGraphResponse) String

type RebuildVSchemaGraphRequest

type RebuildVSchemaGraphRequest struct {

	// Cells specifies the cells to rebuild the SrvVSchema objects for. If empty,
	// RebuildVSchemaGraph rebuilds the SrvVSchema for every cell in the topo.
	Cells []string `protobuf:"bytes,1,rep,name=cells,proto3" json:"cells,omitempty"`
	// contains filtered or unexported fields
}

func (*RebuildVSchemaGraphRequest) Descriptor deprecated

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

Deprecated: Use RebuildVSchemaGraphRequest.ProtoReflect.Descriptor instead.

func (*RebuildVSchemaGraphRequest) GetCells

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

func (*RebuildVSchemaGraphRequest) ProtoMessage

func (*RebuildVSchemaGraphRequest) ProtoMessage()

func (*RebuildVSchemaGraphRequest) ProtoReflect

func (*RebuildVSchemaGraphRequest) Reset

func (x *RebuildVSchemaGraphRequest) Reset()

func (*RebuildVSchemaGraphRequest) String

func (x *RebuildVSchemaGraphRequest) String() string

type RebuildVSchemaGraphResponse

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

func (*RebuildVSchemaGraphResponse) Descriptor deprecated

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

Deprecated: Use RebuildVSchemaGraphResponse.ProtoReflect.Descriptor instead.

func (*RebuildVSchemaGraphResponse) ProtoMessage

func (*RebuildVSchemaGraphResponse) ProtoMessage()

func (*RebuildVSchemaGraphResponse) ProtoReflect

func (*RebuildVSchemaGraphResponse) Reset

func (x *RebuildVSchemaGraphResponse) Reset()

func (*RebuildVSchemaGraphResponse) String

func (x *RebuildVSchemaGraphResponse) String() string

type RefreshStateByShardRequest

type RefreshStateByShardRequest 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"`
	Cells    []string `protobuf:"bytes,3,rep,name=cells,proto3" json:"cells,omitempty"`
	// contains filtered or unexported fields
}

func (*RefreshStateByShardRequest) Descriptor deprecated

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

Deprecated: Use RefreshStateByShardRequest.ProtoReflect.Descriptor instead.

func (*RefreshStateByShardRequest) GetCells

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

func (*RefreshStateByShardRequest) GetKeyspace

func (x *RefreshStateByShardRequest) GetKeyspace() string

func (*RefreshStateByShardRequest) GetShard

func (x *RefreshStateByShardRequest) GetShard() string

func (*RefreshStateByShardRequest) ProtoMessage

func (*RefreshStateByShardRequest) ProtoMessage()

func (*RefreshStateByShardRequest) ProtoReflect

func (*RefreshStateByShardRequest) Reset

func (x *RefreshStateByShardRequest) Reset()

func (*RefreshStateByShardRequest) String

func (x *RefreshStateByShardRequest) String() string

type RefreshStateByShardResponse

type RefreshStateByShardResponse struct {
	IsPartialRefresh bool `protobuf:"varint,1,opt,name=is_partial_refresh,json=isPartialRefresh,proto3" json:"is_partial_refresh,omitempty"`
	// This explains why we had a partial refresh (if we did)
	PartialRefreshDetails string `` /* 126-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*RefreshStateByShardResponse) Descriptor deprecated

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

Deprecated: Use RefreshStateByShardResponse.ProtoReflect.Descriptor instead.

func (*RefreshStateByShardResponse) GetIsPartialRefresh

func (x *RefreshStateByShardResponse) GetIsPartialRefresh() bool

func (*RefreshStateByShardResponse) GetPartialRefreshDetails

func (x *RefreshStateByShardResponse) GetPartialRefreshDetails() string

func (*RefreshStateByShardResponse) ProtoMessage

func (*RefreshStateByShardResponse) ProtoMessage()

func (*RefreshStateByShardResponse) ProtoReflect

func (*RefreshStateByShardResponse) Reset

func (x *RefreshStateByShardResponse) Reset()

func (*RefreshStateByShardResponse) String

func (x *RefreshStateByShardResponse) String() string

type RefreshStateRequest

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

func (*RefreshStateRequest) Descriptor deprecated

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

Deprecated: Use RefreshStateRequest.ProtoReflect.Descriptor instead.

func (*RefreshStateRequest) GetTabletAlias

func (x *RefreshStateRequest) GetTabletAlias() *dev2.TabletAlias

func (*RefreshStateRequest) ProtoMessage

func (*RefreshStateRequest) ProtoMessage()

func (*RefreshStateRequest) ProtoReflect

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

func (*RefreshStateRequest) Reset

func (x *RefreshStateRequest) Reset()

func (*RefreshStateRequest) String

func (x *RefreshStateRequest) String() string

type RefreshStateResponse

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

func (*RefreshStateResponse) Descriptor deprecated

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

Deprecated: Use RefreshStateResponse.ProtoReflect.Descriptor instead.

func (*RefreshStateResponse) ProtoMessage

func (*RefreshStateResponse) ProtoMessage()

func (*RefreshStateResponse) ProtoReflect

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

func (*RefreshStateResponse) Reset

func (x *RefreshStateResponse) Reset()

func (*RefreshStateResponse) String

func (x *RefreshStateResponse) String() string

type ReloadSchemaKeyspaceRequest

type ReloadSchemaKeyspaceRequest struct {
	Keyspace       string `protobuf:"bytes,1,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	WaitPosition   string `protobuf:"bytes,2,opt,name=wait_position,json=waitPosition,proto3" json:"wait_position,omitempty"`
	IncludePrimary bool   `protobuf:"varint,3,opt,name=include_primary,json=includePrimary,proto3" json:"include_primary,omitempty"`
	// Concurrency is the global concurrency across all shards in the keyspace
	// (so, at most this many tablets will be reloaded across the keyspace at any
	// given point).
	Concurrency uint32 `protobuf:"varint,4,opt,name=concurrency,proto3" json:"concurrency,omitempty"`
	// contains filtered or unexported fields
}

func (*ReloadSchemaKeyspaceRequest) Descriptor deprecated

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

Deprecated: Use ReloadSchemaKeyspaceRequest.ProtoReflect.Descriptor instead.

func (*ReloadSchemaKeyspaceRequest) GetConcurrency

func (x *ReloadSchemaKeyspaceRequest) GetConcurrency() uint32

func (*ReloadSchemaKeyspaceRequest) GetIncludePrimary

func (x *ReloadSchemaKeyspaceRequest) GetIncludePrimary() bool

func (*ReloadSchemaKeyspaceRequest) GetKeyspace

func (x *ReloadSchemaKeyspaceRequest) GetKeyspace() string

func (*ReloadSchemaKeyspaceRequest) GetWaitPosition

func (x *ReloadSchemaKeyspaceRequest) GetWaitPosition() string

func (*ReloadSchemaKeyspaceRequest) ProtoMessage

func (*ReloadSchemaKeyspaceRequest) ProtoMessage()

func (*ReloadSchemaKeyspaceRequest) ProtoReflect

func (*ReloadSchemaKeyspaceRequest) Reset

func (x *ReloadSchemaKeyspaceRequest) Reset()

func (*ReloadSchemaKeyspaceRequest) String

func (x *ReloadSchemaKeyspaceRequest) String() string

type ReloadSchemaKeyspaceResponse

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

func (*ReloadSchemaKeyspaceResponse) Descriptor deprecated

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

Deprecated: Use ReloadSchemaKeyspaceResponse.ProtoReflect.Descriptor instead.

func (*ReloadSchemaKeyspaceResponse) GetEvents

func (x *ReloadSchemaKeyspaceResponse) GetEvents() []*dev.Event

func (*ReloadSchemaKeyspaceResponse) ProtoMessage

func (*ReloadSchemaKeyspaceResponse) ProtoMessage()

func (*ReloadSchemaKeyspaceResponse) ProtoReflect

func (*ReloadSchemaKeyspaceResponse) Reset

func (x *ReloadSchemaKeyspaceResponse) Reset()

func (*ReloadSchemaKeyspaceResponse) String

type ReloadSchemaRequest

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

func (*ReloadSchemaRequest) Descriptor deprecated

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

Deprecated: Use ReloadSchemaRequest.ProtoReflect.Descriptor instead.

func (*ReloadSchemaRequest) GetTabletAlias

func (x *ReloadSchemaRequest) GetTabletAlias() *dev2.TabletAlias

func (*ReloadSchemaRequest) ProtoMessage

func (*ReloadSchemaRequest) ProtoMessage()

func (*ReloadSchemaRequest) ProtoReflect

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

func (*ReloadSchemaRequest) Reset

func (x *ReloadSchemaRequest) Reset()

func (*ReloadSchemaRequest) String

func (x *ReloadSchemaRequest) String() string

type ReloadSchemaResponse

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

func (*ReloadSchemaResponse) Descriptor deprecated

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

Deprecated: Use ReloadSchemaResponse.ProtoReflect.Descriptor instead.

func (*ReloadSchemaResponse) ProtoMessage

func (*ReloadSchemaResponse) ProtoMessage()

func (*ReloadSchemaResponse) ProtoReflect

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

func (*ReloadSchemaResponse) Reset

func (x *ReloadSchemaResponse) Reset()

func (*ReloadSchemaResponse) String

func (x *ReloadSchemaResponse) String() string

type ReloadSchemaShardRequest

type ReloadSchemaShardRequest 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"`
	WaitPosition   string `protobuf:"bytes,3,opt,name=wait_position,json=waitPosition,proto3" json:"wait_position,omitempty"`
	IncludePrimary bool   `protobuf:"varint,4,opt,name=include_primary,json=includePrimary,proto3" json:"include_primary,omitempty"`
	// Concurrency is the maximum number of tablets to reload at one time.
	Concurrency uint32 `protobuf:"varint,5,opt,name=concurrency,proto3" json:"concurrency,omitempty"`
	// contains filtered or unexported fields
}

func (*ReloadSchemaShardRequest) Descriptor deprecated

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

Deprecated: Use ReloadSchemaShardRequest.ProtoReflect.Descriptor instead.

func (*ReloadSchemaShardRequest) GetConcurrency

func (x *ReloadSchemaShardRequest) GetConcurrency() uint32

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

func (x *ReloadSchemaShardRequest) String() string

type ReloadSchemaShardResponse

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

func (*ReloadSchemaShardResponse) Descriptor deprecated

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

Deprecated: Use ReloadSchemaShardResponse.ProtoReflect.Descriptor instead.

func (*ReloadSchemaShardResponse) GetEvents

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

func (*ReloadSchemaShardResponse) ProtoMessage

func (*ReloadSchemaShardResponse) ProtoMessage()

func (*ReloadSchemaShardResponse) ProtoReflect

func (*ReloadSchemaShardResponse) Reset

func (x *ReloadSchemaShardResponse) Reset()

func (*ReloadSchemaShardResponse) String

func (x *ReloadSchemaShardResponse) String() string

type RemoveBackupRequest

type RemoveBackupRequest 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"`
	Name     string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveBackupRequest) Descriptor deprecated

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

Deprecated: Use RemoveBackupRequest.ProtoReflect.Descriptor instead.

func (*RemoveBackupRequest) GetKeyspace

func (x *RemoveBackupRequest) GetKeyspace() string

func (*RemoveBackupRequest) GetName

func (x *RemoveBackupRequest) GetName() string

func (*RemoveBackupRequest) GetShard

func (x *RemoveBackupRequest) GetShard() string

func (*RemoveBackupRequest) ProtoMessage

func (*RemoveBackupRequest) ProtoMessage()

func (*RemoveBackupRequest) ProtoReflect

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

func (*RemoveBackupRequest) Reset

func (x *RemoveBackupRequest) Reset()

func (*RemoveBackupRequest) String

func (x *RemoveBackupRequest) String() string

type RemoveBackupResponse

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

func (*RemoveBackupResponse) Descriptor deprecated

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

Deprecated: Use RemoveBackupResponse.ProtoReflect.Descriptor instead.

func (*RemoveBackupResponse) ProtoMessage

func (*RemoveBackupResponse) ProtoMessage()

func (*RemoveBackupResponse) ProtoReflect

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

func (*RemoveBackupResponse) Reset

func (x *RemoveBackupResponse) Reset()

func (*RemoveBackupResponse) String

func (x *RemoveBackupResponse) String() string

type RemoveKeyspaceCellRequest

type RemoveKeyspaceCellRequest struct {
	Keyspace string `protobuf:"bytes,1,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	Cell     string `protobuf:"bytes,2,opt,name=cell,proto3" json:"cell,omitempty"`
	// Force proceeds even if the cell's topology server cannot be reached. This
	// should only be set if a cell has been shut down entirely, and the global
	// topology data just needs to be updated.
	Force bool `protobuf:"varint,3,opt,name=force,proto3" json:"force,omitempty"`
	// Recursive also deletes all tablets in that cell belonging to the specified
	// keyspace.
	Recursive bool `protobuf:"varint,4,opt,name=recursive,proto3" json:"recursive,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveKeyspaceCellRequest) Descriptor deprecated

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

Deprecated: Use RemoveKeyspaceCellRequest.ProtoReflect.Descriptor instead.

func (*RemoveKeyspaceCellRequest) GetCell

func (x *RemoveKeyspaceCellRequest) GetCell() 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) String

func (x *RemoveKeyspaceCellRequest) String() string

type RemoveKeyspaceCellResponse

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

func (*RemoveKeyspaceCellResponse) Descriptor deprecated

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

Deprecated: Use RemoveKeyspaceCellResponse.ProtoReflect.Descriptor instead.

func (*RemoveKeyspaceCellResponse) ProtoMessage

func (*RemoveKeyspaceCellResponse) ProtoMessage()

func (*RemoveKeyspaceCellResponse) ProtoReflect

func (*RemoveKeyspaceCellResponse) Reset

func (x *RemoveKeyspaceCellResponse) Reset()

func (*RemoveKeyspaceCellResponse) String

func (x *RemoveKeyspaceCellResponse) String() string

type RemoveShardCellRequest

type RemoveShardCellRequest struct {
	Keyspace  string `protobuf:"bytes,1,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	ShardName string `protobuf:"bytes,2,opt,name=shard_name,json=shardName,proto3" json:"shard_name,omitempty"`
	Cell      string `protobuf:"bytes,3,opt,name=cell,proto3" json:"cell,omitempty"`
	// Force proceeds even if the cell's topology server cannot be reached. This
	// should only be set if a cell has been shut down entirely, and the global
	// topology data just needs to be updated.
	Force bool `protobuf:"varint,4,opt,name=force,proto3" json:"force,omitempty"`
	// Recursive also deletes all tablets in that cell belonging to the specified
	// keyspace and shard.
	Recursive bool `protobuf:"varint,5,opt,name=recursive,proto3" json:"recursive,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveShardCellRequest) Descriptor deprecated

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

Deprecated: Use RemoveShardCellRequest.ProtoReflect.Descriptor instead.

func (*RemoveShardCellRequest) GetCell

func (x *RemoveShardCellRequest) GetCell() string

func (*RemoveShardCellRequest) GetForce

func (x *RemoveShardCellRequest) GetForce() bool

func (*RemoveShardCellRequest) GetKeyspace

func (x *RemoveShardCellRequest) GetKeyspace() string

func (*RemoveShardCellRequest) GetRecursive

func (x *RemoveShardCellRequest) GetRecursive() bool

func (*RemoveShardCellRequest) GetShardName

func (x *RemoveShardCellRequest) GetShardName() string

func (*RemoveShardCellRequest) ProtoMessage

func (*RemoveShardCellRequest) ProtoMessage()

func (*RemoveShardCellRequest) ProtoReflect

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

func (*RemoveShardCellRequest) Reset

func (x *RemoveShardCellRequest) Reset()

func (*RemoveShardCellRequest) String

func (x *RemoveShardCellRequest) String() string

type RemoveShardCellResponse

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

func (*RemoveShardCellResponse) Descriptor deprecated

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

Deprecated: Use RemoveShardCellResponse.ProtoReflect.Descriptor instead.

func (*RemoveShardCellResponse) ProtoMessage

func (*RemoveShardCellResponse) ProtoMessage()

func (*RemoveShardCellResponse) ProtoReflect

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

func (*RemoveShardCellResponse) Reset

func (x *RemoveShardCellResponse) Reset()

func (*RemoveShardCellResponse) String

func (x *RemoveShardCellResponse) String() string

type ReparentTabletRequest

type ReparentTabletRequest struct {

	// Tablet is the alias of the tablet that should be reparented under the
	// current shard primary.
	Tablet *dev2.TabletAlias `protobuf:"bytes,1,opt,name=tablet,proto3" json:"tablet,omitempty"`
	// contains filtered or unexported fields
}

func (*ReparentTabletRequest) Descriptor deprecated

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

Deprecated: Use ReparentTabletRequest.ProtoReflect.Descriptor instead.

func (*ReparentTabletRequest) GetTablet

func (x *ReparentTabletRequest) GetTablet() *dev2.TabletAlias

func (*ReparentTabletRequest) ProtoMessage

func (*ReparentTabletRequest) ProtoMessage()

func (*ReparentTabletRequest) ProtoReflect

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

func (*ReparentTabletRequest) Reset

func (x *ReparentTabletRequest) Reset()

func (*ReparentTabletRequest) String

func (x *ReparentTabletRequest) String() string

type ReparentTabletResponse

type ReparentTabletResponse struct {

	// Keyspace is the name of the keyspace the tablet was reparented in.
	Keyspace string `protobuf:"bytes,1,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	// Shard is the name of the shard the tablet was reparented in.
	Shard string `protobuf:"bytes,2,opt,name=shard,proto3" json:"shard,omitempty"`
	// Primary is the alias of the tablet that the tablet was reparented under.
	Primary *dev2.TabletAlias `protobuf:"bytes,3,opt,name=primary,proto3" json:"primary,omitempty"`
	// contains filtered or unexported fields
}

func (*ReparentTabletResponse) Descriptor deprecated

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

Deprecated: Use ReparentTabletResponse.ProtoReflect.Descriptor instead.

func (*ReparentTabletResponse) GetKeyspace

func (x *ReparentTabletResponse) GetKeyspace() string

func (*ReparentTabletResponse) GetPrimary

func (x *ReparentTabletResponse) GetPrimary() *dev2.TabletAlias

func (*ReparentTabletResponse) GetShard

func (x *ReparentTabletResponse) GetShard() string

func (*ReparentTabletResponse) ProtoMessage

func (*ReparentTabletResponse) ProtoMessage()

func (*ReparentTabletResponse) ProtoReflect

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

func (*ReparentTabletResponse) Reset

func (x *ReparentTabletResponse) Reset()

func (*ReparentTabletResponse) String

func (x *ReparentTabletResponse) String() string

type ReshardCreateRequest

type ReshardCreateRequest struct {
	Workflow                  string                         `protobuf:"bytes,1,opt,name=workflow,proto3" json:"workflow,omitempty"`
	Keyspace                  string                         `protobuf:"bytes,2,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	SourceShards              []string                       `protobuf:"bytes,3,rep,name=source_shards,json=sourceShards,proto3" json:"source_shards,omitempty"`
	TargetShards              []string                       `protobuf:"bytes,4,rep,name=target_shards,json=targetShards,proto3" json:"target_shards,omitempty"`
	Cells                     []string                       `protobuf:"bytes,5,rep,name=cells,proto3" json:"cells,omitempty"`
	TabletTypes               []dev2.TabletType              `` /* 138-byte string literal not displayed */
	TabletSelectionPreference dev1.TabletSelectionPreference `` /* 199-byte string literal not displayed */
	// SkipSchemaCopy specifies if the schema should be copied from the source shard, set false if
	// schema is already created on the target shard before Reshard is invoked.
	SkipSchemaCopy bool `protobuf:"varint,8,opt,name=skip_schema_copy,json=skipSchemaCopy,proto3" json:"skip_schema_copy,omitempty"`
	// OnDdl specifies the action to be taken when a DDL is encountered.
	OnDdl string `protobuf:"bytes,9,opt,name=on_ddl,json=onDdl,proto3" json:"on_ddl,omitempty"`
	// StopAfterCopy specifies if vreplication should be stopped after copying.
	StopAfterCopy bool `protobuf:"varint,10,opt,name=stop_after_copy,json=stopAfterCopy,proto3" json:"stop_after_copy,omitempty"`
	// DeferSecondaryKeys specifies if secondary keys should be created in one shot after table copy finishes.
	DeferSecondaryKeys bool `protobuf:"varint,11,opt,name=defer_secondary_keys,json=deferSecondaryKeys,proto3" json:"defer_secondary_keys,omitempty"`
	// Start the workflow after creating it.
	AutoStart bool `protobuf:"varint,12,opt,name=auto_start,json=autoStart,proto3" json:"auto_start,omitempty"`
	// contains filtered or unexported fields
}

func (*ReshardCreateRequest) Descriptor deprecated

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

Deprecated: Use ReshardCreateRequest.ProtoReflect.Descriptor instead.

func (*ReshardCreateRequest) GetAutoStart

func (x *ReshardCreateRequest) GetAutoStart() bool

func (*ReshardCreateRequest) GetCells

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

func (*ReshardCreateRequest) GetDeferSecondaryKeys

func (x *ReshardCreateRequest) GetDeferSecondaryKeys() bool

func (*ReshardCreateRequest) GetKeyspace

func (x *ReshardCreateRequest) GetKeyspace() string

func (*ReshardCreateRequest) GetOnDdl

func (x *ReshardCreateRequest) GetOnDdl() string

func (*ReshardCreateRequest) GetSkipSchemaCopy

func (x *ReshardCreateRequest) GetSkipSchemaCopy() bool

func (*ReshardCreateRequest) GetSourceShards

func (x *ReshardCreateRequest) GetSourceShards() []string

func (*ReshardCreateRequest) GetStopAfterCopy

func (x *ReshardCreateRequest) GetStopAfterCopy() bool

func (*ReshardCreateRequest) GetTabletSelectionPreference

func (x *ReshardCreateRequest) GetTabletSelectionPreference() dev1.TabletSelectionPreference

func (*ReshardCreateRequest) GetTabletTypes

func (x *ReshardCreateRequest) GetTabletTypes() []dev2.TabletType

func (*ReshardCreateRequest) GetTargetShards

func (x *ReshardCreateRequest) GetTargetShards() []string

func (*ReshardCreateRequest) GetWorkflow

func (x *ReshardCreateRequest) GetWorkflow() string

func (*ReshardCreateRequest) ProtoMessage

func (*ReshardCreateRequest) ProtoMessage()

func (*ReshardCreateRequest) ProtoReflect

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

func (*ReshardCreateRequest) Reset

func (x *ReshardCreateRequest) Reset()

func (*ReshardCreateRequest) String

func (x *ReshardCreateRequest) String() string

type RestoreFromBackupRequest

type RestoreFromBackupRequest struct {
	TabletAlias *dev2.TabletAlias `protobuf:"bytes,1,opt,name=tablet_alias,json=tabletAlias,proto3" json:"tablet_alias,omitempty"`
	// BackupTime, if set, will use the backup taken most closely at or before
	// this time. If nil, the latest backup will be restored on the tablet.
	BackupTime *dev3.Time `protobuf:"bytes,2,opt,name=backup_time,json=backupTime,proto3" json:"backup_time,omitempty"`
	// RestoreToPos indicates a position for a point-in-time recovery. The recovery
	// is expected to utilize one full backup, followed by zero or more incremental backups,
	// that reach the precise desired position
	RestoreToPos string `protobuf:"bytes,3,opt,name=restore_to_pos,json=restoreToPos,proto3" json:"restore_to_pos,omitempty"`
	// Dry run does not actually performs the restore, but validates the steps and availability of backups
	DryRun bool `protobuf:"varint,4,opt,name=dry_run,json=dryRun,proto3" json:"dry_run,omitempty"`
	// RestoreToTimestamp, if given, requested an inremental restore up to (and excluding) the given timestamp.
	// RestoreToTimestamp and RestoreToPos are mutually exclusive.
	RestoreToTimestamp *dev3.Time `protobuf:"bytes,5,opt,name=restore_to_timestamp,json=restoreToTimestamp,proto3" json:"restore_to_timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*RestoreFromBackupRequest) Descriptor deprecated

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

Deprecated: Use RestoreFromBackupRequest.ProtoReflect.Descriptor instead.

func (*RestoreFromBackupRequest) GetBackupTime

func (x *RestoreFromBackupRequest) GetBackupTime() *dev3.Time

func (*RestoreFromBackupRequest) GetDryRun

func (x *RestoreFromBackupRequest) GetDryRun() bool

func (*RestoreFromBackupRequest) GetRestoreToPos

func (x *RestoreFromBackupRequest) GetRestoreToPos() string

func (*RestoreFromBackupRequest) GetRestoreToTimestamp

func (x *RestoreFromBackupRequest) GetRestoreToTimestamp() *dev3.Time

func (*RestoreFromBackupRequest) GetTabletAlias

func (x *RestoreFromBackupRequest) GetTabletAlias() *dev2.TabletAlias

func (*RestoreFromBackupRequest) ProtoMessage

func (*RestoreFromBackupRequest) ProtoMessage()

func (*RestoreFromBackupRequest) ProtoReflect

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

func (*RestoreFromBackupRequest) Reset

func (x *RestoreFromBackupRequest) Reset()

func (*RestoreFromBackupRequest) String

func (x *RestoreFromBackupRequest) String() string

type RestoreFromBackupResponse

type RestoreFromBackupResponse struct {

	// TabletAlias is the alias of the tablet doing the restore.
	TabletAlias *dev2.TabletAlias `protobuf:"bytes,1,opt,name=tablet_alias,json=tabletAlias,proto3" json:"tablet_alias,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"`
	Event       *dev.Event        `protobuf:"bytes,4,opt,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

func (*RestoreFromBackupResponse) Descriptor deprecated

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

Deprecated: Use RestoreFromBackupResponse.ProtoReflect.Descriptor instead.

func (*RestoreFromBackupResponse) GetEvent

func (x *RestoreFromBackupResponse) GetEvent() *dev.Event

func (*RestoreFromBackupResponse) GetKeyspace

func (x *RestoreFromBackupResponse) GetKeyspace() string

func (*RestoreFromBackupResponse) GetShard

func (x *RestoreFromBackupResponse) GetShard() string

func (*RestoreFromBackupResponse) GetTabletAlias

func (x *RestoreFromBackupResponse) GetTabletAlias() *dev2.TabletAlias

func (*RestoreFromBackupResponse) ProtoMessage

func (*RestoreFromBackupResponse) ProtoMessage()

func (*RestoreFromBackupResponse) ProtoReflect

func (*RestoreFromBackupResponse) Reset

func (x *RestoreFromBackupResponse) Reset()

func (*RestoreFromBackupResponse) String

func (x *RestoreFromBackupResponse) String() string

type RetrySchemaMigrationRequest

type RetrySchemaMigrationRequest struct {
	Keyspace string `protobuf:"bytes,1,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	Uuid     string `protobuf:"bytes,2,opt,name=uuid,proto3" json:"uuid,omitempty"`
	// contains filtered or unexported fields
}

func (*RetrySchemaMigrationRequest) Descriptor deprecated

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

Deprecated: Use RetrySchemaMigrationRequest.ProtoReflect.Descriptor instead.

func (*RetrySchemaMigrationRequest) GetKeyspace

func (x *RetrySchemaMigrationRequest) GetKeyspace() string

func (*RetrySchemaMigrationRequest) GetUuid

func (x *RetrySchemaMigrationRequest) GetUuid() string

func (*RetrySchemaMigrationRequest) ProtoMessage

func (*RetrySchemaMigrationRequest) ProtoMessage()

func (*RetrySchemaMigrationRequest) ProtoReflect

func (*RetrySchemaMigrationRequest) Reset

func (x *RetrySchemaMigrationRequest) Reset()

func (*RetrySchemaMigrationRequest) String

func (x *RetrySchemaMigrationRequest) String() string

type RetrySchemaMigrationResponse

type RetrySchemaMigrationResponse struct {
	RowsAffectedByShard map[string]uint64 `` /* 211-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*RetrySchemaMigrationResponse) Descriptor deprecated

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

Deprecated: Use RetrySchemaMigrationResponse.ProtoReflect.Descriptor instead.

func (*RetrySchemaMigrationResponse) GetRowsAffectedByShard

func (x *RetrySchemaMigrationResponse) GetRowsAffectedByShard() map[string]uint64

func (*RetrySchemaMigrationResponse) ProtoMessage

func (*RetrySchemaMigrationResponse) ProtoMessage()

func (*RetrySchemaMigrationResponse) ProtoReflect

func (*RetrySchemaMigrationResponse) Reset

func (x *RetrySchemaMigrationResponse) Reset()

func (*RetrySchemaMigrationResponse) String

type RunHealthCheckRequest

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

func (*RunHealthCheckRequest) Descriptor deprecated

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

Deprecated: Use RunHealthCheckRequest.ProtoReflect.Descriptor instead.

func (*RunHealthCheckRequest) GetTabletAlias

func (x *RunHealthCheckRequest) GetTabletAlias() *dev2.TabletAlias

func (*RunHealthCheckRequest) ProtoMessage

func (*RunHealthCheckRequest) ProtoMessage()

func (*RunHealthCheckRequest) ProtoReflect

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

func (*RunHealthCheckRequest) Reset

func (x *RunHealthCheckRequest) Reset()

func (*RunHealthCheckRequest) String

func (x *RunHealthCheckRequest) String() string

type RunHealthCheckResponse

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

func (*RunHealthCheckResponse) Descriptor deprecated

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

Deprecated: Use RunHealthCheckResponse.ProtoReflect.Descriptor instead.

func (*RunHealthCheckResponse) ProtoMessage

func (*RunHealthCheckResponse) ProtoMessage()

func (*RunHealthCheckResponse) ProtoReflect

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

func (*RunHealthCheckResponse) Reset

func (x *RunHealthCheckResponse) Reset()

func (*RunHealthCheckResponse) String

func (x *RunHealthCheckResponse) String() string

type SchemaMigration

type SchemaMigration struct {
	Uuid                        string                   `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,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"`
	Schema                      string                   `protobuf:"bytes,4,opt,name=schema,proto3" json:"schema,omitempty"`
	Table                       string                   `protobuf:"bytes,5,opt,name=table,proto3" json:"table,omitempty"`
	MigrationStatement          string                   `protobuf:"bytes,6,opt,name=migration_statement,json=migrationStatement,proto3" json:"migration_statement,omitempty"`
	Strategy                    SchemaMigration_Strategy `protobuf:"varint,7,opt,name=strategy,proto3,enum=vitess.vtctldata.dev.SchemaMigration_Strategy" json:"strategy,omitempty"`
	Options                     string                   `protobuf:"bytes,8,opt,name=options,proto3" json:"options,omitempty"`
	AddedAt                     *dev3.Time               `protobuf:"bytes,9,opt,name=added_at,json=addedAt,proto3" json:"added_at,omitempty"`
	RequestedAt                 *dev3.Time               `protobuf:"bytes,10,opt,name=requested_at,json=requestedAt,proto3" json:"requested_at,omitempty"`
	ReadyAt                     *dev3.Time               `protobuf:"bytes,11,opt,name=ready_at,json=readyAt,proto3" json:"ready_at,omitempty"`
	StartedAt                   *dev3.Time               `protobuf:"bytes,12,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
	LivenessTimestamp           *dev3.Time               `protobuf:"bytes,13,opt,name=liveness_timestamp,json=livenessTimestamp,proto3" json:"liveness_timestamp,omitempty"`
	CompletedAt                 *dev3.Time               `protobuf:"bytes,14,opt,name=completed_at,json=completedAt,proto3" json:"completed_at,omitempty"`
	CleanedUpAt                 *dev3.Time               `protobuf:"bytes,15,opt,name=cleaned_up_at,json=cleanedUpAt,proto3" json:"cleaned_up_at,omitempty"`
	Status                      SchemaMigration_Status   `protobuf:"varint,16,opt,name=status,proto3,enum=vitess.vtctldata.dev.SchemaMigration_Status" json:"status,omitempty"`
	LogPath                     string                   `protobuf:"bytes,17,opt,name=log_path,json=logPath,proto3" json:"log_path,omitempty"`
	Artifacts                   string                   `protobuf:"bytes,18,opt,name=artifacts,proto3" json:"artifacts,omitempty"`
	Retries                     uint64                   `protobuf:"varint,19,opt,name=retries,proto3" json:"retries,omitempty"`
	Tablet                      *dev2.TabletAlias        `protobuf:"bytes,20,opt,name=tablet,proto3" json:"tablet,omitempty"`
	TabletFailure               bool                     `protobuf:"varint,21,opt,name=tablet_failure,json=tabletFailure,proto3" json:"tablet_failure,omitempty"`
	Progress                    float32                  `protobuf:"fixed32,22,opt,name=progress,proto3" json:"progress,omitempty"`
	MigrationContext            string                   `protobuf:"bytes,23,opt,name=migration_context,json=migrationContext,proto3" json:"migration_context,omitempty"`
	DdlAction                   string                   `protobuf:"bytes,24,opt,name=ddl_action,json=ddlAction,proto3" json:"ddl_action,omitempty"`
	Message                     string                   `protobuf:"bytes,25,opt,name=message,proto3" json:"message,omitempty"`
	EtaSeconds                  int64                    `protobuf:"varint,26,opt,name=eta_seconds,json=etaSeconds,proto3" json:"eta_seconds,omitempty"`
	RowsCopied                  uint64                   `protobuf:"varint,27,opt,name=rows_copied,json=rowsCopied,proto3" json:"rows_copied,omitempty"`
	TableRows                   int64                    `protobuf:"varint,28,opt,name=table_rows,json=tableRows,proto3" json:"table_rows,omitempty"`
	AddedUniqueKeys             uint32                   `protobuf:"varint,29,opt,name=added_unique_keys,json=addedUniqueKeys,proto3" json:"added_unique_keys,omitempty"`
	RemovedUniqueKeys           uint32                   `protobuf:"varint,30,opt,name=removed_unique_keys,json=removedUniqueKeys,proto3" json:"removed_unique_keys,omitempty"`
	LogFile                     string                   `protobuf:"bytes,31,opt,name=log_file,json=logFile,proto3" json:"log_file,omitempty"`
	ArtifactRetention           *dev3.Duration           `protobuf:"bytes,32,opt,name=artifact_retention,json=artifactRetention,proto3" json:"artifact_retention,omitempty"`
	PostponeCompletion          bool                     `protobuf:"varint,33,opt,name=postpone_completion,json=postponeCompletion,proto3" json:"postpone_completion,omitempty"`
	RemovedUniqueKeyNames       string                   `` /* 129-byte string literal not displayed */
	DroppedNoDefaultColumnNames string                   `` /* 149-byte string literal not displayed */
	ExpandedColumnNames         string                   `protobuf:"bytes,36,opt,name=expanded_column_names,json=expandedColumnNames,proto3" json:"expanded_column_names,omitempty"`
	RevertibleNotes             string                   `protobuf:"bytes,37,opt,name=revertible_notes,json=revertibleNotes,proto3" json:"revertible_notes,omitempty"`
	AllowConcurrent             bool                     `protobuf:"varint,38,opt,name=allow_concurrent,json=allowConcurrent,proto3" json:"allow_concurrent,omitempty"`
	RevertedUuid                string                   `protobuf:"bytes,39,opt,name=reverted_uuid,json=revertedUuid,proto3" json:"reverted_uuid,omitempty"`
	IsView                      bool                     `protobuf:"varint,40,opt,name=is_view,json=isView,proto3" json:"is_view,omitempty"`
	ReadyToComplete             bool                     `protobuf:"varint,41,opt,name=ready_to_complete,json=readyToComplete,proto3" json:"ready_to_complete,omitempty"`
	VitessLivenessIndicator     int64                    `` /* 134-byte string literal not displayed */
	UserThrottleRatio           float32                  `protobuf:"fixed32,43,opt,name=user_throttle_ratio,json=userThrottleRatio,proto3" json:"user_throttle_ratio,omitempty"`
	SpecialPlan                 string                   `protobuf:"bytes,44,opt,name=special_plan,json=specialPlan,proto3" json:"special_plan,omitempty"`
	LastThrottledAt             *dev3.Time               `protobuf:"bytes,45,opt,name=last_throttled_at,json=lastThrottledAt,proto3" json:"last_throttled_at,omitempty"`
	ComponentThrottled          string                   `protobuf:"bytes,46,opt,name=component_throttled,json=componentThrottled,proto3" json:"component_throttled,omitempty"`
	CancelledAt                 *dev3.Time               `protobuf:"bytes,47,opt,name=cancelled_at,json=cancelledAt,proto3" json:"cancelled_at,omitempty"`
	PostponeLaunch              bool                     `protobuf:"varint,48,opt,name=postpone_launch,json=postponeLaunch,proto3" json:"postpone_launch,omitempty"`
	Stage                       string                   `protobuf:"bytes,49,opt,name=stage,proto3" json:"stage,omitempty"` // enum?
	CutoverAttempts             uint32                   `protobuf:"varint,50,opt,name=cutover_attempts,json=cutoverAttempts,proto3" json:"cutover_attempts,omitempty"`
	IsImmediateOperation        bool                     `protobuf:"varint,51,opt,name=is_immediate_operation,json=isImmediateOperation,proto3" json:"is_immediate_operation,omitempty"`
	ReviewedAt                  *dev3.Time               `protobuf:"bytes,52,opt,name=reviewed_at,json=reviewedAt,proto3" json:"reviewed_at,omitempty"`
	ReadyToCompleteAt           *dev3.Time               `protobuf:"bytes,53,opt,name=ready_to_complete_at,json=readyToCompleteAt,proto3" json:"ready_to_complete_at,omitempty"`
	// contains filtered or unexported fields
}

SchemaMigration represents a row in the schema_migrations sidecar table.

func (*SchemaMigration) Descriptor deprecated

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

Deprecated: Use SchemaMigration.ProtoReflect.Descriptor instead.

func (*SchemaMigration) GetAddedAt

func (x *SchemaMigration) GetAddedAt() *dev3.Time

func (*SchemaMigration) GetAddedUniqueKeys

func (x *SchemaMigration) GetAddedUniqueKeys() uint32

func (*SchemaMigration) GetAllowConcurrent

func (x *SchemaMigration) GetAllowConcurrent() bool

func (*SchemaMigration) GetArtifactRetention

func (x *SchemaMigration) GetArtifactRetention() *dev3.Duration

func (*SchemaMigration) GetArtifacts

func (x *SchemaMigration) GetArtifacts() string

func (*SchemaMigration) GetCancelledAt

func (x *SchemaMigration) GetCancelledAt() *dev3.Time

func (*SchemaMigration) GetCleanedUpAt

func (x *SchemaMigration) GetCleanedUpAt() *dev3.Time

func (*SchemaMigration) GetCompletedAt

func (x *SchemaMigration) GetCompletedAt() *dev3.Time

func (*SchemaMigration) GetComponentThrottled

func (x *SchemaMigration) GetComponentThrottled() string

func (*SchemaMigration) GetCutoverAttempts

func (x *SchemaMigration) GetCutoverAttempts() uint32

func (*SchemaMigration) GetDdlAction

func (x *SchemaMigration) GetDdlAction() string

func (*SchemaMigration) GetDroppedNoDefaultColumnNames

func (x *SchemaMigration) GetDroppedNoDefaultColumnNames() string

func (*SchemaMigration) GetEtaSeconds

func (x *SchemaMigration) GetEtaSeconds() int64

func (*SchemaMigration) GetExpandedColumnNames

func (x *SchemaMigration) GetExpandedColumnNames() string

func (*SchemaMigration) GetIsImmediateOperation

func (x *SchemaMigration) GetIsImmediateOperation() bool

func (*SchemaMigration) GetIsView

func (x *SchemaMigration) GetIsView() bool

func (*SchemaMigration) GetKeyspace

func (x *SchemaMigration) GetKeyspace() string

func (*SchemaMigration) GetLastThrottledAt

func (x *SchemaMigration) GetLastThrottledAt() *dev3.Time

func (*SchemaMigration) GetLivenessTimestamp

func (x *SchemaMigration) GetLivenessTimestamp() *dev3.Time

func (*SchemaMigration) GetLogFile

func (x *SchemaMigration) GetLogFile() string

func (*SchemaMigration) GetLogPath

func (x *SchemaMigration) GetLogPath() string

func (*SchemaMigration) GetMessage

func (x *SchemaMigration) GetMessage() string

func (*SchemaMigration) GetMigrationContext

func (x *SchemaMigration) GetMigrationContext() string

func (*SchemaMigration) GetMigrationStatement

func (x *SchemaMigration) GetMigrationStatement() string

func (*SchemaMigration) GetOptions

func (x *SchemaMigration) GetOptions() string

func (*SchemaMigration) GetPostponeCompletion

func (x *SchemaMigration) GetPostponeCompletion() bool

func (*SchemaMigration) GetPostponeLaunch

func (x *SchemaMigration) GetPostponeLaunch() bool

func (*SchemaMigration) GetProgress

func (x *SchemaMigration) GetProgress() float32

func (*SchemaMigration) GetReadyAt

func (x *SchemaMigration) GetReadyAt() *dev3.Time

func (*SchemaMigration) GetReadyToComplete

func (x *SchemaMigration) GetReadyToComplete() bool

func (*SchemaMigration) GetReadyToCompleteAt

func (x *SchemaMigration) GetReadyToCompleteAt() *dev3.Time

func (*SchemaMigration) GetRemovedUniqueKeyNames

func (x *SchemaMigration) GetRemovedUniqueKeyNames() string

func (*SchemaMigration) GetRemovedUniqueKeys

func (x *SchemaMigration) GetRemovedUniqueKeys() uint32

func (*SchemaMigration) GetRequestedAt

func (x *SchemaMigration) GetRequestedAt() *dev3.Time

func (*SchemaMigration) GetRetries

func (x *SchemaMigration) GetRetries() uint64

func (*SchemaMigration) GetRevertedUuid

func (x *SchemaMigration) GetRevertedUuid() string

func (*SchemaMigration) GetRevertibleNotes

func (x *SchemaMigration) GetRevertibleNotes() string

func (*SchemaMigration) GetReviewedAt

func (x *SchemaMigration) GetReviewedAt() *dev3.Time

func (*SchemaMigration) GetRowsCopied

func (x *SchemaMigration) GetRowsCopied() uint64

func (*SchemaMigration) GetSchema

func (x *SchemaMigration) GetSchema() string

func (*SchemaMigration) GetShard

func (x *SchemaMigration) GetShard() string

func (*SchemaMigration) GetSpecialPlan

func (x *SchemaMigration) GetSpecialPlan() string

func (*SchemaMigration) GetStage

func (x *SchemaMigration) GetStage() string

func (*SchemaMigration) GetStartedAt

func (x *SchemaMigration) GetStartedAt() *dev3.Time

func (*SchemaMigration) GetStatus

func (x *SchemaMigration) GetStatus() SchemaMigration_Status

func (*SchemaMigration) GetStrategy

func (x *SchemaMigration) GetStrategy() SchemaMigration_Strategy

func (*SchemaMigration) GetTable

func (x *SchemaMigration) GetTable() string

func (*SchemaMigration) GetTableRows

func (x *SchemaMigration) GetTableRows() int64

func (*SchemaMigration) GetTablet

func (x *SchemaMigration) GetTablet() *dev2.TabletAlias

func (*SchemaMigration) GetTabletFailure

func (x *SchemaMigration) GetTabletFailure() bool

func (*SchemaMigration) GetUserThrottleRatio

func (x *SchemaMigration) GetUserThrottleRatio() float32

func (*SchemaMigration) GetUuid

func (x *SchemaMigration) GetUuid() string

func (*SchemaMigration) GetVitessLivenessIndicator

func (x *SchemaMigration) GetVitessLivenessIndicator() int64

func (*SchemaMigration) ProtoMessage

func (*SchemaMigration) ProtoMessage()

func (*SchemaMigration) ProtoReflect

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

func (*SchemaMigration) Reset

func (x *SchemaMigration) Reset()

func (*SchemaMigration) String

func (x *SchemaMigration) String() string

type SchemaMigration_Status

type SchemaMigration_Status int32
const (
	SchemaMigration_UNKNOWN   SchemaMigration_Status = 0
	SchemaMigration_REQUESTED SchemaMigration_Status = 1
	SchemaMigration_CANCELLED SchemaMigration_Status = 2
	SchemaMigration_QUEUED    SchemaMigration_Status = 3
	SchemaMigration_READY     SchemaMigration_Status = 4
	SchemaMigration_RUNNING   SchemaMigration_Status = 5
	SchemaMigration_COMPLETE  SchemaMigration_Status = 6
	SchemaMigration_FAILED    SchemaMigration_Status = 7
)

func (SchemaMigration_Status) Descriptor

func (SchemaMigration_Status) Enum

func (SchemaMigration_Status) EnumDescriptor deprecated

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

Deprecated: Use SchemaMigration_Status.Descriptor instead.

func (SchemaMigration_Status) Number

func (SchemaMigration_Status) String

func (x SchemaMigration_Status) String() string

func (SchemaMigration_Status) Type

type SchemaMigration_Strategy

type SchemaMigration_Strategy int32
const (
	// SchemaMigration_VITESS uses vreplication to run the schema migration. It is
	// the default strategy for OnlineDDL requests.
	//
	// SchemaMigration_VITESS was also formerly called "ONLINE".
	SchemaMigration_VITESS SchemaMigration_Strategy = 0
	SchemaMigration_ONLINE SchemaMigration_Strategy = 0
	SchemaMigration_GHOST  SchemaMigration_Strategy = 1
	SchemaMigration_PTOSC  SchemaMigration_Strategy = 2
	// SchemaMigration_DIRECT runs the migration directly against MySQL (e.g. `ALTER TABLE ...`),
	// meaning it is not actually an "online" DDL migration.
	SchemaMigration_DIRECT SchemaMigration_Strategy = 3
	// SchemaMigration_MYSQL is a managed migration (queued and executed by the
	// scheduler) but runs through a MySQL `ALTER TABLE`.
	SchemaMigration_MYSQL SchemaMigration_Strategy = 4
)

func (SchemaMigration_Strategy) Descriptor

func (SchemaMigration_Strategy) Enum

func (SchemaMigration_Strategy) EnumDescriptor deprecated

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

Deprecated: Use SchemaMigration_Strategy.Descriptor instead.

func (SchemaMigration_Strategy) Number

func (SchemaMigration_Strategy) String

func (x SchemaMigration_Strategy) String() string

func (SchemaMigration_Strategy) Type

type SetKeyspaceDurabilityPolicyRequest

type SetKeyspaceDurabilityPolicyRequest struct {
	Keyspace         string `protobuf:"bytes,1,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	DurabilityPolicy string `protobuf:"bytes,2,opt,name=durability_policy,json=durabilityPolicy,proto3" json:"durability_policy,omitempty"`
	// contains filtered or unexported fields
}

func (*SetKeyspaceDurabilityPolicyRequest) Descriptor deprecated

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

Deprecated: Use SetKeyspaceDurabilityPolicyRequest.ProtoReflect.Descriptor instead.

func (*SetKeyspaceDurabilityPolicyRequest) GetDurabilityPolicy

func (x *SetKeyspaceDurabilityPolicyRequest) GetDurabilityPolicy() string

func (*SetKeyspaceDurabilityPolicyRequest) GetKeyspace

func (x *SetKeyspaceDurabilityPolicyRequest) GetKeyspace() string

func (*SetKeyspaceDurabilityPolicyRequest) ProtoMessage

func (*SetKeyspaceDurabilityPolicyRequest) ProtoMessage()

func (*SetKeyspaceDurabilityPolicyRequest) ProtoReflect

func (*SetKeyspaceDurabilityPolicyRequest) Reset

func (*SetKeyspaceDurabilityPolicyRequest) String

type SetKeyspaceDurabilityPolicyResponse

type SetKeyspaceDurabilityPolicyResponse struct {

	// Keyspace is the updated keyspace record.
	Keyspace *dev2.Keyspace `protobuf:"bytes,1,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	// contains filtered or unexported fields
}

func (*SetKeyspaceDurabilityPolicyResponse) Descriptor deprecated

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

Deprecated: Use SetKeyspaceDurabilityPolicyResponse.ProtoReflect.Descriptor instead.

func (*SetKeyspaceDurabilityPolicyResponse) GetKeyspace

func (*SetKeyspaceDurabilityPolicyResponse) ProtoMessage

func (*SetKeyspaceDurabilityPolicyResponse) ProtoMessage()

func (*SetKeyspaceDurabilityPolicyResponse) ProtoReflect

func (*SetKeyspaceDurabilityPolicyResponse) Reset

func (*SetKeyspaceDurabilityPolicyResponse) String

type SetKeyspaceServedFromRequest

type SetKeyspaceServedFromRequest struct {
	Keyspace       string          `protobuf:"bytes,1,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	TabletType     dev2.TabletType `` /* 128-byte string literal not displayed */
	Cells          []string        `protobuf:"bytes,3,rep,name=cells,proto3" json:"cells,omitempty"`
	Remove         bool            `protobuf:"varint,4,opt,name=remove,proto3" json:"remove,omitempty"`
	SourceKeyspace string          `protobuf:"bytes,5,opt,name=source_keyspace,json=sourceKeyspace,proto3" json:"source_keyspace,omitempty"`
	// contains filtered or unexported fields
}

func (*SetKeyspaceServedFromRequest) Descriptor deprecated

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

Deprecated: Use SetKeyspaceServedFromRequest.ProtoReflect.Descriptor instead.

func (*SetKeyspaceServedFromRequest) GetCells

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

func (*SetKeyspaceServedFromRequest) GetKeyspace

func (x *SetKeyspaceServedFromRequest) GetKeyspace() string

func (*SetKeyspaceServedFromRequest) GetRemove

func (x *SetKeyspaceServedFromRequest) GetRemove() bool

func (*SetKeyspaceServedFromRequest) GetSourceKeyspace

func (x *SetKeyspaceServedFromRequest) GetSourceKeyspace() string

func (*SetKeyspaceServedFromRequest) GetTabletType

func (x *SetKeyspaceServedFromRequest) GetTabletType() dev2.TabletType

func (*SetKeyspaceServedFromRequest) ProtoMessage

func (*SetKeyspaceServedFromRequest) ProtoMessage()

func (*SetKeyspaceServedFromRequest) ProtoReflect

func (*SetKeyspaceServedFromRequest) Reset

func (x *SetKeyspaceServedFromRequest) Reset()

func (*SetKeyspaceServedFromRequest) String

type SetKeyspaceServedFromResponse

type SetKeyspaceServedFromResponse struct {

	// Keyspace is the updated keyspace record.
	Keyspace *dev2.Keyspace `protobuf:"bytes,1,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	// contains filtered or unexported fields
}

func (*SetKeyspaceServedFromResponse) Descriptor deprecated

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

Deprecated: Use SetKeyspaceServedFromResponse.ProtoReflect.Descriptor instead.

func (*SetKeyspaceServedFromResponse) GetKeyspace

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

func (*SetKeyspaceServedFromResponse) ProtoMessage

func (*SetKeyspaceServedFromResponse) ProtoMessage()

func (*SetKeyspaceServedFromResponse) ProtoReflect

func (*SetKeyspaceServedFromResponse) Reset

func (x *SetKeyspaceServedFromResponse) Reset()

func (*SetKeyspaceServedFromResponse) String

type SetKeyspaceShardingInfoRequest

type SetKeyspaceShardingInfoRequest struct {
	Keyspace string `protobuf:"bytes,1,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	Force    bool   `protobuf:"varint,4,opt,name=force,proto3" json:"force,omitempty"`
	// contains filtered or unexported fields
}

func (*SetKeyspaceShardingInfoRequest) Descriptor deprecated

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

Deprecated: Use SetKeyspaceShardingInfoRequest.ProtoReflect.Descriptor instead.

func (*SetKeyspaceShardingInfoRequest) GetForce

func (x *SetKeyspaceShardingInfoRequest) GetForce() bool

func (*SetKeyspaceShardingInfoRequest) GetKeyspace

func (x *SetKeyspaceShardingInfoRequest) GetKeyspace() string

func (*SetKeyspaceShardingInfoRequest) ProtoMessage

func (*SetKeyspaceShardingInfoRequest) ProtoMessage()

func (*SetKeyspaceShardingInfoRequest) ProtoReflect

func (*SetKeyspaceShardingInfoRequest) Reset

func (x *SetKeyspaceShardingInfoRequest) Reset()

func (*SetKeyspaceShardingInfoRequest) String

type SetKeyspaceShardingInfoResponse

type SetKeyspaceShardingInfoResponse struct {

	// Keyspace is the updated keyspace record.
	Keyspace *dev2.Keyspace `protobuf:"bytes,1,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	// contains filtered or unexported fields
}

func (*SetKeyspaceShardingInfoResponse) Descriptor deprecated

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

Deprecated: Use SetKeyspaceShardingInfoResponse.ProtoReflect.Descriptor instead.

func (*SetKeyspaceShardingInfoResponse) GetKeyspace

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

func (*SetKeyspaceShardingInfoResponse) ProtoMessage

func (*SetKeyspaceShardingInfoResponse) ProtoMessage()

func (*SetKeyspaceShardingInfoResponse) ProtoReflect

func (*SetKeyspaceShardingInfoResponse) Reset

func (*SetKeyspaceShardingInfoResponse) String

type SetShardIsPrimaryServingRequest

type SetShardIsPrimaryServingRequest 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"`
	IsServing bool   `protobuf:"varint,3,opt,name=is_serving,json=isServing,proto3" json:"is_serving,omitempty"`
	// contains filtered or unexported fields
}

func (*SetShardIsPrimaryServingRequest) Descriptor deprecated

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

Deprecated: Use SetShardIsPrimaryServingRequest.ProtoReflect.Descriptor instead.

func (*SetShardIsPrimaryServingRequest) GetIsServing

func (x *SetShardIsPrimaryServingRequest) GetIsServing() bool

func (*SetShardIsPrimaryServingRequest) GetKeyspace

func (x *SetShardIsPrimaryServingRequest) GetKeyspace() string

func (*SetShardIsPrimaryServingRequest) GetShard

func (*SetShardIsPrimaryServingRequest) ProtoMessage

func (*SetShardIsPrimaryServingRequest) ProtoMessage()

func (*SetShardIsPrimaryServingRequest) ProtoReflect

func (*SetShardIsPrimaryServingRequest) Reset

func (*SetShardIsPrimaryServingRequest) String

type SetShardIsPrimaryServingResponse

type SetShardIsPrimaryServingResponse struct {

	// Shard is the updated shard record.
	Shard *dev2.Shard `protobuf:"bytes,1,opt,name=shard,proto3" json:"shard,omitempty"`
	// contains filtered or unexported fields
}

func (*SetShardIsPrimaryServingResponse) Descriptor deprecated

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

Deprecated: Use SetShardIsPrimaryServingResponse.ProtoReflect.Descriptor instead.

func (*SetShardIsPrimaryServingResponse) GetShard

func (*SetShardIsPrimaryServingResponse) ProtoMessage

func (*SetShardIsPrimaryServingResponse) ProtoMessage()

func (*SetShardIsPrimaryServingResponse) ProtoReflect

func (*SetShardIsPrimaryServingResponse) Reset

func (*SetShardIsPrimaryServingResponse) String

type SetShardTabletControlRequest

type SetShardTabletControlRequest 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"`
	TabletType dev2.TabletType `` /* 128-byte string literal not displayed */
	Cells      []string        `protobuf:"bytes,4,rep,name=cells,proto3" json:"cells,omitempty"`
	// DeniedTables updates the list of denied tables the shard will serve for
	// the given tablet type. This is useful to fix tables that are being blocked
	// after a MoveTables operation.
	//
	// NOTE: Setting this field will cause DisableQueryService to be ignored.
	DeniedTables []string `protobuf:"bytes,5,rep,name=denied_tables,json=deniedTables,proto3" json:"denied_tables,omitempty"`
	// DisableQueryService instructs whether to enable the query service on
	// tablets of the given type in the shard. This is useful to fix Reshard
	// operations gone awry.
	//
	// NOTE: this is ignored if DeniedTables is not empty.
	DisableQueryService bool `protobuf:"varint,6,opt,name=disable_query_service,json=disableQueryService,proto3" json:"disable_query_service,omitempty"`
	// Remove removes the ShardTabletControl record entirely. If set, this takes
	// precedence over DeniedTables and DisableQueryService fields, and is useful
	// to manually remove serving restrictions after a completed MoveTables
	// operation.
	Remove bool `protobuf:"varint,7,opt,name=remove,proto3" json:"remove,omitempty"`
	// contains filtered or unexported fields
}

func (*SetShardTabletControlRequest) Descriptor deprecated

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

Deprecated: Use SetShardTabletControlRequest.ProtoReflect.Descriptor instead.

func (*SetShardTabletControlRequest) GetCells

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

func (*SetShardTabletControlRequest) GetDeniedTables

func (x *SetShardTabletControlRequest) GetDeniedTables() []string

func (*SetShardTabletControlRequest) GetDisableQueryService

func (x *SetShardTabletControlRequest) GetDisableQueryService() bool

func (*SetShardTabletControlRequest) GetKeyspace

func (x *SetShardTabletControlRequest) GetKeyspace() string

func (*SetShardTabletControlRequest) GetRemove

func (x *SetShardTabletControlRequest) GetRemove() bool

func (*SetShardTabletControlRequest) GetShard

func (x *SetShardTabletControlRequest) GetShard() string

func (*SetShardTabletControlRequest) GetTabletType

func (x *SetShardTabletControlRequest) GetTabletType() dev2.TabletType

func (*SetShardTabletControlRequest) ProtoMessage

func (*SetShardTabletControlRequest) ProtoMessage()

func (*SetShardTabletControlRequest) ProtoReflect

func (*SetShardTabletControlRequest) Reset

func (x *SetShardTabletControlRequest) Reset()

func (*SetShardTabletControlRequest) String

type SetShardTabletControlResponse

type SetShardTabletControlResponse struct {

	// Shard is the updated shard record.
	Shard *dev2.Shard `protobuf:"bytes,1,opt,name=shard,proto3" json:"shard,omitempty"`
	// contains filtered or unexported fields
}

func (*SetShardTabletControlResponse) Descriptor deprecated

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

Deprecated: Use SetShardTabletControlResponse.ProtoReflect.Descriptor instead.

func (*SetShardTabletControlResponse) GetShard

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

func (*SetShardTabletControlResponse) ProtoMessage

func (*SetShardTabletControlResponse) ProtoMessage()

func (*SetShardTabletControlResponse) ProtoReflect

func (*SetShardTabletControlResponse) Reset

func (x *SetShardTabletControlResponse) Reset()

func (*SetShardTabletControlResponse) String

type SetWritableRequest

type SetWritableRequest struct {
	TabletAlias *dev2.TabletAlias `protobuf:"bytes,1,opt,name=tablet_alias,json=tabletAlias,proto3" json:"tablet_alias,omitempty"`
	Writable    bool              `protobuf:"varint,2,opt,name=writable,proto3" json:"writable,omitempty"`
	// contains filtered or unexported fields
}

func (*SetWritableRequest) Descriptor deprecated

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

Deprecated: Use SetWritableRequest.ProtoReflect.Descriptor instead.

func (*SetWritableRequest) GetTabletAlias

func (x *SetWritableRequest) GetTabletAlias() *dev2.TabletAlias

func (*SetWritableRequest) GetWritable

func (x *SetWritableRequest) GetWritable() bool

func (*SetWritableRequest) ProtoMessage

func (*SetWritableRequest) ProtoMessage()

func (*SetWritableRequest) ProtoReflect

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

func (*SetWritableRequest) Reset

func (x *SetWritableRequest) Reset()

func (*SetWritableRequest) String

func (x *SetWritableRequest) String() string

type SetWritableResponse

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

func (*SetWritableResponse) Descriptor deprecated

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

Deprecated: Use SetWritableResponse.ProtoReflect.Descriptor instead.

func (*SetWritableResponse) ProtoMessage

func (*SetWritableResponse) ProtoMessage()

func (*SetWritableResponse) ProtoReflect

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

func (*SetWritableResponse) Reset

func (x *SetWritableResponse) Reset()

func (*SetWritableResponse) String

func (x *SetWritableResponse) String() string

type Shard

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

func (*Shard) Descriptor deprecated

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

Deprecated: Use Shard.ProtoReflect.Descriptor instead.

func (*Shard) GetKeyspace

func (x *Shard) GetKeyspace() string

func (*Shard) GetName

func (x *Shard) GetName() string

func (*Shard) GetShard

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

func (*Shard) ProtoMessage

func (*Shard) ProtoMessage()

func (*Shard) ProtoReflect

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

func (*Shard) Reset

func (x *Shard) Reset()

func (*Shard) String

func (x *Shard) String() string

type ShardReplicationAddRequest

type ShardReplicationAddRequest 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"`
	TabletAlias *dev2.TabletAlias `protobuf:"bytes,3,opt,name=tablet_alias,json=tabletAlias,proto3" json:"tablet_alias,omitempty"`
	// contains filtered or unexported fields
}

func (*ShardReplicationAddRequest) Descriptor deprecated

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

Deprecated: Use ShardReplicationAddRequest.ProtoReflect.Descriptor instead.

func (*ShardReplicationAddRequest) GetKeyspace

func (x *ShardReplicationAddRequest) GetKeyspace() string

func (*ShardReplicationAddRequest) GetShard

func (x *ShardReplicationAddRequest) GetShard() string

func (*ShardReplicationAddRequest) GetTabletAlias

func (x *ShardReplicationAddRequest) GetTabletAlias() *dev2.TabletAlias

func (*ShardReplicationAddRequest) ProtoMessage

func (*ShardReplicationAddRequest) ProtoMessage()

func (*ShardReplicationAddRequest) ProtoReflect

func (*ShardReplicationAddRequest) Reset

func (x *ShardReplicationAddRequest) Reset()

func (*ShardReplicationAddRequest) String

func (x *ShardReplicationAddRequest) String() string

type ShardReplicationAddResponse

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

func (*ShardReplicationAddResponse) Descriptor deprecated

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

Deprecated: Use ShardReplicationAddResponse.ProtoReflect.Descriptor instead.

func (*ShardReplicationAddResponse) ProtoMessage

func (*ShardReplicationAddResponse) ProtoMessage()

func (*ShardReplicationAddResponse) ProtoReflect

func (*ShardReplicationAddResponse) Reset

func (x *ShardReplicationAddResponse) Reset()

func (*ShardReplicationAddResponse) String

func (x *ShardReplicationAddResponse) String() string

type ShardReplicationFixRequest

type ShardReplicationFixRequest 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"`
	Cell     string `protobuf:"bytes,3,opt,name=cell,proto3" json:"cell,omitempty"`
	// contains filtered or unexported fields
}

func (*ShardReplicationFixRequest) Descriptor deprecated

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

Deprecated: Use ShardReplicationFixRequest.ProtoReflect.Descriptor instead.

func (*ShardReplicationFixRequest) GetCell

func (x *ShardReplicationFixRequest) GetCell() string

func (*ShardReplicationFixRequest) GetKeyspace

func (x *ShardReplicationFixRequest) GetKeyspace() string

func (*ShardReplicationFixRequest) GetShard

func (x *ShardReplicationFixRequest) GetShard() string

func (*ShardReplicationFixRequest) ProtoMessage

func (*ShardReplicationFixRequest) ProtoMessage()

func (*ShardReplicationFixRequest) ProtoReflect

func (*ShardReplicationFixRequest) Reset

func (x *ShardReplicationFixRequest) Reset()

func (*ShardReplicationFixRequest) String

func (x *ShardReplicationFixRequest) String() string

type ShardReplicationFixResponse

type ShardReplicationFixResponse struct {

	// Error contains information about the error fixed by a
	// ShardReplicationFix RPC. If there were no errors to fix (i.e. all nodes
	// in the replication graph are valid), this field is nil.
	Error *dev2.ShardReplicationError `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*ShardReplicationFixResponse) Descriptor deprecated

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

Deprecated: Use ShardReplicationFixResponse.ProtoReflect.Descriptor instead.

func (*ShardReplicationFixResponse) GetError

func (*ShardReplicationFixResponse) ProtoMessage

func (*ShardReplicationFixResponse) ProtoMessage()

func (*ShardReplicationFixResponse) ProtoReflect

func (*ShardReplicationFixResponse) Reset

func (x *ShardReplicationFixResponse) Reset()

func (*ShardReplicationFixResponse) String

func (x *ShardReplicationFixResponse) String() string

type ShardReplicationPositionsRequest

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

func (*ShardReplicationPositionsRequest) Descriptor deprecated

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

Deprecated: Use ShardReplicationPositionsRequest.ProtoReflect.Descriptor instead.

func (*ShardReplicationPositionsRequest) GetKeyspace

func (x *ShardReplicationPositionsRequest) GetKeyspace() string

func (*ShardReplicationPositionsRequest) GetShard

func (*ShardReplicationPositionsRequest) ProtoMessage

func (*ShardReplicationPositionsRequest) ProtoMessage()

func (*ShardReplicationPositionsRequest) ProtoReflect

func (*ShardReplicationPositionsRequest) Reset

func (*ShardReplicationPositionsRequest) String

type ShardReplicationPositionsResponse

type ShardReplicationPositionsResponse struct {

	// ReplicationStatuses is a mapping of tablet alias string to replication
	// status for that tablet.
	ReplicationStatuses map[string]*dev8.Status `` /* 206-byte string literal not displayed */
	// TabletMap is the set of tablets whose replication statuses were queried,
	// keyed by tablet alias.
	TabletMap map[string]*dev2.Tablet `` /* 176-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ShardReplicationPositionsResponse) Descriptor deprecated

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

Deprecated: Use ShardReplicationPositionsResponse.ProtoReflect.Descriptor instead.

func (*ShardReplicationPositionsResponse) GetReplicationStatuses

func (x *ShardReplicationPositionsResponse) GetReplicationStatuses() map[string]*dev8.Status

func (*ShardReplicationPositionsResponse) GetTabletMap

func (x *ShardReplicationPositionsResponse) GetTabletMap() map[string]*dev2.Tablet

func (*ShardReplicationPositionsResponse) ProtoMessage

func (*ShardReplicationPositionsResponse) ProtoMessage()

func (*ShardReplicationPositionsResponse) ProtoReflect

func (*ShardReplicationPositionsResponse) Reset

func (*ShardReplicationPositionsResponse) String

type ShardReplicationRemoveRequest

type ShardReplicationRemoveRequest 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"`
	TabletAlias *dev2.TabletAlias `protobuf:"bytes,3,opt,name=tablet_alias,json=tabletAlias,proto3" json:"tablet_alias,omitempty"`
	// contains filtered or unexported fields
}

func (*ShardReplicationRemoveRequest) Descriptor deprecated

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

Deprecated: Use ShardReplicationRemoveRequest.ProtoReflect.Descriptor instead.

func (*ShardReplicationRemoveRequest) GetKeyspace

func (x *ShardReplicationRemoveRequest) GetKeyspace() string

func (*ShardReplicationRemoveRequest) GetShard

func (x *ShardReplicationRemoveRequest) GetShard() string

func (*ShardReplicationRemoveRequest) GetTabletAlias

func (x *ShardReplicationRemoveRequest) GetTabletAlias() *dev2.TabletAlias

func (*ShardReplicationRemoveRequest) ProtoMessage

func (*ShardReplicationRemoveRequest) ProtoMessage()

func (*ShardReplicationRemoveRequest) ProtoReflect

func (*ShardReplicationRemoveRequest) Reset

func (x *ShardReplicationRemoveRequest) Reset()

func (*ShardReplicationRemoveRequest) String

type ShardReplicationRemoveResponse

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

func (*ShardReplicationRemoveResponse) Descriptor deprecated

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

Deprecated: Use ShardReplicationRemoveResponse.ProtoReflect.Descriptor instead.

func (*ShardReplicationRemoveResponse) ProtoMessage

func (*ShardReplicationRemoveResponse) ProtoMessage()

func (*ShardReplicationRemoveResponse) ProtoReflect

func (*ShardReplicationRemoveResponse) Reset

func (x *ShardReplicationRemoveResponse) Reset()

func (*ShardReplicationRemoveResponse) String

type SleepTabletRequest

type SleepTabletRequest struct {
	TabletAlias *dev2.TabletAlias `protobuf:"bytes,1,opt,name=tablet_alias,json=tabletAlias,proto3" json:"tablet_alias,omitempty"`
	Duration    *dev3.Duration    `protobuf:"bytes,2,opt,name=duration,proto3" json:"duration,omitempty"`
	// contains filtered or unexported fields
}

func (*SleepTabletRequest) Descriptor deprecated

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

Deprecated: Use SleepTabletRequest.ProtoReflect.Descriptor instead.

func (*SleepTabletRequest) GetDuration

func (x *SleepTabletRequest) GetDuration() *dev3.Duration

func (*SleepTabletRequest) GetTabletAlias

func (x *SleepTabletRequest) GetTabletAlias() *dev2.TabletAlias

func (*SleepTabletRequest) ProtoMessage

func (*SleepTabletRequest) ProtoMessage()

func (*SleepTabletRequest) ProtoReflect

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

func (*SleepTabletRequest) Reset

func (x *SleepTabletRequest) Reset()

func (*SleepTabletRequest) String

func (x *SleepTabletRequest) String() string

type SleepTabletResponse

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

func (*SleepTabletResponse) Descriptor deprecated

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

Deprecated: Use SleepTabletResponse.ProtoReflect.Descriptor instead.

func (*SleepTabletResponse) ProtoMessage

func (*SleepTabletResponse) ProtoMessage()

func (*SleepTabletResponse) ProtoReflect

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

func (*SleepTabletResponse) Reset

func (x *SleepTabletResponse) Reset()

func (*SleepTabletResponse) String

func (x *SleepTabletResponse) String() string

type SourceShardAddRequest

type SourceShardAddRequest 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"`
	Uid            int32  `protobuf:"varint,3,opt,name=uid,proto3" json:"uid,omitempty"`
	SourceKeyspace string `protobuf:"bytes,4,opt,name=source_keyspace,json=sourceKeyspace,proto3" json:"source_keyspace,omitempty"`
	SourceShard    string `protobuf:"bytes,5,opt,name=source_shard,json=sourceShard,proto3" json:"source_shard,omitempty"`
	// KeyRange identifies the key range to use for the SourceShard. This field is
	// optional.
	KeyRange *dev2.KeyRange `protobuf:"bytes,6,opt,name=key_range,json=keyRange,proto3" json:"key_range,omitempty"`
	// Tables is a list of tables replicate (for MoveTables). Each "table" can be
	// either an exact match or a regular expression of the form "/regexp/".
	Tables []string `protobuf:"bytes,7,rep,name=tables,proto3" json:"tables,omitempty"`
	// contains filtered or unexported fields
}

func (*SourceShardAddRequest) Descriptor deprecated

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

Deprecated: Use SourceShardAddRequest.ProtoReflect.Descriptor instead.

func (*SourceShardAddRequest) GetKeyRange

func (x *SourceShardAddRequest) GetKeyRange() *dev2.KeyRange

func (*SourceShardAddRequest) GetKeyspace

func (x *SourceShardAddRequest) GetKeyspace() string

func (*SourceShardAddRequest) GetShard

func (x *SourceShardAddRequest) GetShard() string

func (*SourceShardAddRequest) GetSourceKeyspace

func (x *SourceShardAddRequest) GetSourceKeyspace() string

func (*SourceShardAddRequest) GetSourceShard

func (x *SourceShardAddRequest) GetSourceShard() string

func (*SourceShardAddRequest) GetTables

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

func (*SourceShardAddRequest) GetUid

func (x *SourceShardAddRequest) GetUid() int32

func (*SourceShardAddRequest) ProtoMessage

func (*SourceShardAddRequest) ProtoMessage()

func (*SourceShardAddRequest) ProtoReflect

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

func (*SourceShardAddRequest) Reset

func (x *SourceShardAddRequest) Reset()

func (*SourceShardAddRequest) String

func (x *SourceShardAddRequest) String() string

type SourceShardAddResponse

type SourceShardAddResponse struct {

	// Shard is the updated shard record.
	Shard *dev2.Shard `protobuf:"bytes,1,opt,name=shard,proto3" json:"shard,omitempty"`
	// contains filtered or unexported fields
}

func (*SourceShardAddResponse) Descriptor deprecated

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

Deprecated: Use SourceShardAddResponse.ProtoReflect.Descriptor instead.

func (*SourceShardAddResponse) GetShard

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

func (*SourceShardAddResponse) ProtoMessage

func (*SourceShardAddResponse) ProtoMessage()

func (*SourceShardAddResponse) ProtoReflect

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

func (*SourceShardAddResponse) Reset

func (x *SourceShardAddResponse) Reset()

func (*SourceShardAddResponse) String

func (x *SourceShardAddResponse) String() string

type SourceShardDeleteRequest

type SourceShardDeleteRequest 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"`
	Uid      int32  `protobuf:"varint,3,opt,name=uid,proto3" json:"uid,omitempty"`
	// contains filtered or unexported fields
}

func (*SourceShardDeleteRequest) Descriptor deprecated

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

Deprecated: Use SourceShardDeleteRequest.ProtoReflect.Descriptor instead.

func (*SourceShardDeleteRequest) GetKeyspace

func (x *SourceShardDeleteRequest) GetKeyspace() string

func (*SourceShardDeleteRequest) GetShard

func (x *SourceShardDeleteRequest) GetShard() string

func (*SourceShardDeleteRequest) GetUid

func (x *SourceShardDeleteRequest) GetUid() int32

func (*SourceShardDeleteRequest) ProtoMessage

func (*SourceShardDeleteRequest) ProtoMessage()

func (*SourceShardDeleteRequest) ProtoReflect

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

func (*SourceShardDeleteRequest) Reset

func (x *SourceShardDeleteRequest) Reset()

func (*SourceShardDeleteRequest) String

func (x *SourceShardDeleteRequest) String() string

type SourceShardDeleteResponse

type SourceShardDeleteResponse struct {

	// Shard is the updated shard record.
	Shard *dev2.Shard `protobuf:"bytes,1,opt,name=shard,proto3" json:"shard,omitempty"`
	// contains filtered or unexported fields
}

func (*SourceShardDeleteResponse) Descriptor deprecated

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

Deprecated: Use SourceShardDeleteResponse.ProtoReflect.Descriptor instead.

func (*SourceShardDeleteResponse) GetShard

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

func (*SourceShardDeleteResponse) ProtoMessage

func (*SourceShardDeleteResponse) ProtoMessage()

func (*SourceShardDeleteResponse) ProtoReflect

func (*SourceShardDeleteResponse) Reset

func (x *SourceShardDeleteResponse) Reset()

func (*SourceShardDeleteResponse) String

func (x *SourceShardDeleteResponse) String() string

type StartReplicationRequest

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

func (*StartReplicationRequest) Descriptor deprecated

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

Deprecated: Use StartReplicationRequest.ProtoReflect.Descriptor instead.

func (*StartReplicationRequest) GetTabletAlias

func (x *StartReplicationRequest) GetTabletAlias() *dev2.TabletAlias

func (*StartReplicationRequest) ProtoMessage

func (*StartReplicationRequest) ProtoMessage()

func (*StartReplicationRequest) ProtoReflect

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

func (*StartReplicationRequest) Reset

func (x *StartReplicationRequest) Reset()

func (*StartReplicationRequest) String

func (x *StartReplicationRequest) String() string

type StartReplicationResponse

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

func (*StartReplicationResponse) Descriptor deprecated

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

Deprecated: Use StartReplicationResponse.ProtoReflect.Descriptor instead.

func (*StartReplicationResponse) ProtoMessage

func (*StartReplicationResponse) ProtoMessage()

func (*StartReplicationResponse) ProtoReflect

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

func (*StartReplicationResponse) Reset

func (x *StartReplicationResponse) Reset()

func (*StartReplicationResponse) String

func (x *StartReplicationResponse) String() string

type StopReplicationRequest

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

func (*StopReplicationRequest) Descriptor deprecated

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

Deprecated: Use StopReplicationRequest.ProtoReflect.Descriptor instead.

func (*StopReplicationRequest) GetTabletAlias

func (x *StopReplicationRequest) GetTabletAlias() *dev2.TabletAlias

func (*StopReplicationRequest) ProtoMessage

func (*StopReplicationRequest) ProtoMessage()

func (*StopReplicationRequest) ProtoReflect

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

func (*StopReplicationRequest) Reset

func (x *StopReplicationRequest) Reset()

func (*StopReplicationRequest) String

func (x *StopReplicationRequest) String() string

type StopReplicationResponse

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

func (*StopReplicationResponse) Descriptor deprecated

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

Deprecated: Use StopReplicationResponse.ProtoReflect.Descriptor instead.

func (*StopReplicationResponse) ProtoMessage

func (*StopReplicationResponse) ProtoMessage()

func (*StopReplicationResponse) ProtoReflect

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

func (*StopReplicationResponse) Reset

func (x *StopReplicationResponse) Reset()

func (*StopReplicationResponse) String

func (x *StopReplicationResponse) String() string

type TableMaterializeSettings

type TableMaterializeSettings struct {
	TargetTable string `protobuf:"bytes,1,opt,name=target_table,json=targetTable,proto3" json:"target_table,omitempty"`
	// source_expression is a select statement.
	SourceExpression string `protobuf:"bytes,2,opt,name=source_expression,json=sourceExpression,proto3" json:"source_expression,omitempty"`
	// create_ddl contains the DDL to create the target table.
	// If empty, the target table must already exist.
	// if "copy", the target table DDL is the same as the source table.
	CreateDdl string `protobuf:"bytes,3,opt,name=create_ddl,json=createDdl,proto3" json:"create_ddl,omitempty"`
	// contains filtered or unexported fields
}

TableMaterializeSttings contains the settings for one table.

func (*TableMaterializeSettings) Descriptor deprecated

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

Deprecated: Use TableMaterializeSettings.ProtoReflect.Descriptor instead.

func (*TableMaterializeSettings) GetCreateDdl

func (x *TableMaterializeSettings) GetCreateDdl() string

func (*TableMaterializeSettings) GetSourceExpression

func (x *TableMaterializeSettings) GetSourceExpression() string

func (*TableMaterializeSettings) GetTargetTable

func (x *TableMaterializeSettings) GetTargetTable() string

func (*TableMaterializeSettings) ProtoMessage

func (*TableMaterializeSettings) ProtoMessage()

func (*TableMaterializeSettings) ProtoReflect

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

func (*TableMaterializeSettings) Reset

func (x *TableMaterializeSettings) Reset()

func (*TableMaterializeSettings) String

func (x *TableMaterializeSettings) String() string

type TabletExternallyReparentedRequest

type TabletExternallyReparentedRequest struct {

	// Tablet is the alias of the tablet that was promoted externally and should
	// be updated to the shard primary in the topo.
	Tablet *dev2.TabletAlias `protobuf:"bytes,1,opt,name=tablet,proto3" json:"tablet,omitempty"`
	// contains filtered or unexported fields
}

func (*TabletExternallyReparentedRequest) Descriptor deprecated

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

Deprecated: Use TabletExternallyReparentedRequest.ProtoReflect.Descriptor instead.

func (*TabletExternallyReparentedRequest) GetTablet

func (*TabletExternallyReparentedRequest) ProtoMessage

func (*TabletExternallyReparentedRequest) ProtoMessage()

func (*TabletExternallyReparentedRequest) ProtoReflect

func (*TabletExternallyReparentedRequest) Reset

func (*TabletExternallyReparentedRequest) String

type TabletExternallyReparentedResponse

type TabletExternallyReparentedResponse 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"`
	NewPrimary *dev2.TabletAlias `protobuf:"bytes,3,opt,name=new_primary,json=newPrimary,proto3" json:"new_primary,omitempty"`
	OldPrimary *dev2.TabletAlias `protobuf:"bytes,4,opt,name=old_primary,json=oldPrimary,proto3" json:"old_primary,omitempty"`
	// contains filtered or unexported fields
}

func (*TabletExternallyReparentedResponse) Descriptor deprecated

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

Deprecated: Use TabletExternallyReparentedResponse.ProtoReflect.Descriptor instead.

func (*TabletExternallyReparentedResponse) GetKeyspace

func (x *TabletExternallyReparentedResponse) GetKeyspace() string

func (*TabletExternallyReparentedResponse) GetNewPrimary

func (*TabletExternallyReparentedResponse) GetOldPrimary

func (*TabletExternallyReparentedResponse) GetShard

func (*TabletExternallyReparentedResponse) ProtoMessage

func (*TabletExternallyReparentedResponse) ProtoMessage()

func (*TabletExternallyReparentedResponse) ProtoReflect

func (*TabletExternallyReparentedResponse) Reset

func (*TabletExternallyReparentedResponse) String

type TopologyCell

type TopologyCell struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// Data is the file contents of the cell located at path.
	// It is only populated if the cell is a terminal node.
	Data     string   `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	Children []string `protobuf:"bytes,4,rep,name=children,proto3" json:"children,omitempty"`
	// contains filtered or unexported fields
}

func (*TopologyCell) Descriptor deprecated

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

Deprecated: Use TopologyCell.ProtoReflect.Descriptor instead.

func (*TopologyCell) GetChildren

func (x *TopologyCell) GetChildren() []string

func (*TopologyCell) GetData

func (x *TopologyCell) GetData() string

func (*TopologyCell) GetName

func (x *TopologyCell) GetName() string

func (*TopologyCell) GetPath

func (x *TopologyCell) GetPath() string

func (*TopologyCell) ProtoMessage

func (*TopologyCell) ProtoMessage()

func (*TopologyCell) ProtoReflect

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

func (*TopologyCell) Reset

func (x *TopologyCell) Reset()

func (*TopologyCell) String

func (x *TopologyCell) String() string

type UpdateCellInfoRequest

type UpdateCellInfoRequest struct {
	Name     string         `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	CellInfo *dev2.CellInfo `protobuf:"bytes,2,opt,name=cell_info,json=cellInfo,proto3" json:"cell_info,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateCellInfoRequest) Descriptor deprecated

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

Deprecated: Use UpdateCellInfoRequest.ProtoReflect.Descriptor instead.

func (*UpdateCellInfoRequest) GetCellInfo

func (x *UpdateCellInfoRequest) GetCellInfo() *dev2.CellInfo

func (*UpdateCellInfoRequest) GetName

func (x *UpdateCellInfoRequest) GetName() string

func (*UpdateCellInfoRequest) ProtoMessage

func (*UpdateCellInfoRequest) ProtoMessage()

func (*UpdateCellInfoRequest) ProtoReflect

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

func (*UpdateCellInfoRequest) Reset

func (x *UpdateCellInfoRequest) Reset()

func (*UpdateCellInfoRequest) String

func (x *UpdateCellInfoRequest) String() string

type UpdateCellInfoResponse

type UpdateCellInfoResponse struct {
	Name     string         `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	CellInfo *dev2.CellInfo `protobuf:"bytes,2,opt,name=cell_info,json=cellInfo,proto3" json:"cell_info,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateCellInfoResponse) Descriptor deprecated

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

Deprecated: Use UpdateCellInfoResponse.ProtoReflect.Descriptor instead.

func (*UpdateCellInfoResponse) GetCellInfo

func (x *UpdateCellInfoResponse) GetCellInfo() *dev2.CellInfo

func (*UpdateCellInfoResponse) GetName

func (x *UpdateCellInfoResponse) GetName() string

func (*UpdateCellInfoResponse) ProtoMessage

func (*UpdateCellInfoResponse) ProtoMessage()

func (*UpdateCellInfoResponse) ProtoReflect

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

func (*UpdateCellInfoResponse) Reset

func (x *UpdateCellInfoResponse) Reset()

func (*UpdateCellInfoResponse) String

func (x *UpdateCellInfoResponse) String() string

type UpdateCellsAliasRequest

type UpdateCellsAliasRequest struct {
	Name       string           `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	CellsAlias *dev2.CellsAlias `protobuf:"bytes,2,opt,name=cells_alias,json=cellsAlias,proto3" json:"cells_alias,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateCellsAliasRequest) Descriptor deprecated

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

Deprecated: Use UpdateCellsAliasRequest.ProtoReflect.Descriptor instead.

func (*UpdateCellsAliasRequest) GetCellsAlias

func (x *UpdateCellsAliasRequest) GetCellsAlias() *dev2.CellsAlias

func (*UpdateCellsAliasRequest) GetName

func (x *UpdateCellsAliasRequest) GetName() string

func (*UpdateCellsAliasRequest) ProtoMessage

func (*UpdateCellsAliasRequest) ProtoMessage()

func (*UpdateCellsAliasRequest) ProtoReflect

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

func (*UpdateCellsAliasRequest) Reset

func (x *UpdateCellsAliasRequest) Reset()

func (*UpdateCellsAliasRequest) String

func (x *UpdateCellsAliasRequest) String() string

type UpdateCellsAliasResponse

type UpdateCellsAliasResponse struct {
	Name       string           `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	CellsAlias *dev2.CellsAlias `protobuf:"bytes,2,opt,name=cells_alias,json=cellsAlias,proto3" json:"cells_alias,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateCellsAliasResponse) Descriptor deprecated

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

Deprecated: Use UpdateCellsAliasResponse.ProtoReflect.Descriptor instead.

func (*UpdateCellsAliasResponse) GetCellsAlias

func (x *UpdateCellsAliasResponse) GetCellsAlias() *dev2.CellsAlias

func (*UpdateCellsAliasResponse) GetName

func (x *UpdateCellsAliasResponse) GetName() string

func (*UpdateCellsAliasResponse) ProtoMessage

func (*UpdateCellsAliasResponse) ProtoMessage()

func (*UpdateCellsAliasResponse) ProtoReflect

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

func (*UpdateCellsAliasResponse) Reset

func (x *UpdateCellsAliasResponse) Reset()

func (*UpdateCellsAliasResponse) String

func (x *UpdateCellsAliasResponse) String() string

type UpdateThrottlerConfigRequest

type UpdateThrottlerConfigRequest struct {
	Keyspace string `protobuf:"bytes,1,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	// Enable instructs to enable the throttler
	Enable bool `protobuf:"varint,2,opt,name=enable,proto3" json:"enable,omitempty"`
	// Disable instructs to disable the throttler
	Disable bool `protobuf:"varint,3,opt,name=disable,proto3" json:"disable,omitempty"`
	// Threshold for throttler (with no custom query, ie using default query, only positive values are considered)
	Threshold float64 `protobuf:"fixed64,4,opt,name=threshold,proto3" json:"threshold,omitempty"`
	// CustomQuery replaces the default replication lag query
	CustomQuery string `protobuf:"bytes,5,opt,name=custom_query,json=customQuery,proto3" json:"custom_query,omitempty"`
	// CustomQuerySet indicates that the value of CustomQuery has changed
	CustomQuerySet bool `protobuf:"varint,6,opt,name=custom_query_set,json=customQuerySet,proto3" json:"custom_query_set,omitempty"`
	// CheckAsCheckSelf instructs the throttler to respond to /check requests by checking the tablet's own health
	CheckAsCheckSelf bool `protobuf:"varint,7,opt,name=check_as_check_self,json=checkAsCheckSelf,proto3" json:"check_as_check_self,omitempty"`
	// CheckAsCheckShard instructs the throttler to respond to /check requests by checking the shard's health (this is the default behavior)
	CheckAsCheckShard bool `protobuf:"varint,8,opt,name=check_as_check_shard,json=checkAsCheckShard,proto3" json:"check_as_check_shard,omitempty"`
	// ThrottledApp indicates a single throttled app rule (ignored if name is empty)
	ThrottledApp *dev2.ThrottledAppRule `protobuf:"bytes,9,opt,name=throttled_app,json=throttledApp,proto3" json:"throttled_app,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateThrottlerConfigRequest) Descriptor deprecated

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

Deprecated: Use UpdateThrottlerConfigRequest.ProtoReflect.Descriptor instead.

func (*UpdateThrottlerConfigRequest) GetCheckAsCheckSelf

func (x *UpdateThrottlerConfigRequest) GetCheckAsCheckSelf() bool

func (*UpdateThrottlerConfigRequest) GetCheckAsCheckShard

func (x *UpdateThrottlerConfigRequest) GetCheckAsCheckShard() bool

func (*UpdateThrottlerConfigRequest) GetCustomQuery

func (x *UpdateThrottlerConfigRequest) GetCustomQuery() string

func (*UpdateThrottlerConfigRequest) GetCustomQuerySet

func (x *UpdateThrottlerConfigRequest) GetCustomQuerySet() bool

func (*UpdateThrottlerConfigRequest) GetDisable

func (x *UpdateThrottlerConfigRequest) GetDisable() bool

func (*UpdateThrottlerConfigRequest) GetEnable

func (x *UpdateThrottlerConfigRequest) GetEnable() bool

func (*UpdateThrottlerConfigRequest) GetKeyspace

func (x *UpdateThrottlerConfigRequest) GetKeyspace() string

func (*UpdateThrottlerConfigRequest) GetThreshold

func (x *UpdateThrottlerConfigRequest) GetThreshold() float64

func (*UpdateThrottlerConfigRequest) GetThrottledApp

func (x *UpdateThrottlerConfigRequest) GetThrottledApp() *dev2.ThrottledAppRule

func (*UpdateThrottlerConfigRequest) ProtoMessage

func (*UpdateThrottlerConfigRequest) ProtoMessage()

func (*UpdateThrottlerConfigRequest) ProtoReflect

func (*UpdateThrottlerConfigRequest) Reset

func (x *UpdateThrottlerConfigRequest) Reset()

func (*UpdateThrottlerConfigRequest) String

type UpdateThrottlerConfigResponse

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

func (*UpdateThrottlerConfigResponse) Descriptor deprecated

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

Deprecated: Use UpdateThrottlerConfigResponse.ProtoReflect.Descriptor instead.

func (*UpdateThrottlerConfigResponse) ProtoMessage

func (*UpdateThrottlerConfigResponse) ProtoMessage()

func (*UpdateThrottlerConfigResponse) ProtoReflect

func (*UpdateThrottlerConfigResponse) Reset

func (x *UpdateThrottlerConfigResponse) Reset()

func (*UpdateThrottlerConfigResponse) String

type VDiffCreateRequest

type VDiffCreateRequest struct {
	Workflow                    string                         `protobuf:"bytes,1,opt,name=workflow,proto3" json:"workflow,omitempty"`
	TargetKeyspace              string                         `protobuf:"bytes,2,opt,name=target_keyspace,json=targetKeyspace,proto3" json:"target_keyspace,omitempty"`
	Uuid                        string                         `protobuf:"bytes,3,opt,name=uuid,proto3" json:"uuid,omitempty"`
	SourceCells                 []string                       `protobuf:"bytes,4,rep,name=source_cells,json=sourceCells,proto3" json:"source_cells,omitempty"`
	TargetCells                 []string                       `protobuf:"bytes,5,rep,name=target_cells,json=targetCells,proto3" json:"target_cells,omitempty"`
	TabletTypes                 []dev2.TabletType              `` /* 138-byte string literal not displayed */
	TabletSelectionPreference   dev1.TabletSelectionPreference `` /* 199-byte string literal not displayed */
	Tables                      []string                       `protobuf:"bytes,8,rep,name=tables,proto3" json:"tables,omitempty"`
	Limit                       int64                          `protobuf:"varint,9,opt,name=limit,proto3" json:"limit,omitempty"`
	FilteredReplicationWaitTime *dev3.Duration                 `` /* 147-byte string literal not displayed */
	DebugQuery                  bool                           `protobuf:"varint,11,opt,name=debug_query,json=debugQuery,proto3" json:"debug_query,omitempty"`
	OnlyPKs                     bool                           `protobuf:"varint,12,opt,name=only_p_ks,json=onlyPKs,proto3" json:"only_p_ks,omitempty"`
	UpdateTableStats            bool                           `protobuf:"varint,13,opt,name=update_table_stats,json=updateTableStats,proto3" json:"update_table_stats,omitempty"`
	MaxExtraRowsToCompare       int64                          `` /* 132-byte string literal not displayed */
	Wait                        bool                           `protobuf:"varint,15,opt,name=wait,proto3" json:"wait,omitempty"`
	WaitUpdateInterval          *dev3.Duration                 `protobuf:"bytes,16,opt,name=wait_update_interval,json=waitUpdateInterval,proto3" json:"wait_update_interval,omitempty"`
	AutoRetry                   bool                           `protobuf:"varint,17,opt,name=auto_retry,json=autoRetry,proto3" json:"auto_retry,omitempty"`
	Verbose                     bool                           `protobuf:"varint,18,opt,name=verbose,proto3" json:"verbose,omitempty"`
	// contains filtered or unexported fields
}

func (*VDiffCreateRequest) Descriptor deprecated

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

Deprecated: Use VDiffCreateRequest.ProtoReflect.Descriptor instead.

func (*VDiffCreateRequest) GetAutoRetry

func (x *VDiffCreateRequest) GetAutoRetry() bool

func (*VDiffCreateRequest) GetDebugQuery

func (x *VDiffCreateRequest) GetDebugQuery() bool

func (*VDiffCreateRequest) GetFilteredReplicationWaitTime

func (x *VDiffCreateRequest) GetFilteredReplicationWaitTime() *dev3.Duration

func (*VDiffCreateRequest) GetLimit

func (x *VDiffCreateRequest) GetLimit() int64

func (*VDiffCreateRequest) GetMaxExtraRowsToCompare

func (x *VDiffCreateRequest) GetMaxExtraRowsToCompare() int64

func (*VDiffCreateRequest) GetOnlyPKs

func (x *VDiffCreateRequest) GetOnlyPKs() bool

func (*VDiffCreateRequest) GetSourceCells

func (x *VDiffCreateRequest) GetSourceCells() []string

func (*VDiffCreateRequest) GetTables

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

func (*VDiffCreateRequest) GetTabletSelectionPreference

func (x *VDiffCreateRequest) GetTabletSelectionPreference() dev1.TabletSelectionPreference

func (*VDiffCreateRequest) GetTabletTypes

func (x *VDiffCreateRequest) GetTabletTypes() []dev2.TabletType

func (*VDiffCreateRequest) GetTargetCells

func (x *VDiffCreateRequest) GetTargetCells() []string

func (*VDiffCreateRequest) GetTargetKeyspace

func (x *VDiffCreateRequest) GetTargetKeyspace() string

func (*VDiffCreateRequest) GetUpdateTableStats

func (x *VDiffCreateRequest) GetUpdateTableStats() bool

func (*VDiffCreateRequest) GetUuid

func (x *VDiffCreateRequest) GetUuid() string

func (*VDiffCreateRequest) GetVerbose

func (x *VDiffCreateRequest) GetVerbose() bool

func (*VDiffCreateRequest) GetWait

func (x *VDiffCreateRequest) GetWait() bool

func (*VDiffCreateRequest) GetWaitUpdateInterval

func (x *VDiffCreateRequest) GetWaitUpdateInterval() *dev3.Duration

func (*VDiffCreateRequest) GetWorkflow

func (x *VDiffCreateRequest) GetWorkflow() string

func (*VDiffCreateRequest) ProtoMessage

func (*VDiffCreateRequest) ProtoMessage()

func (*VDiffCreateRequest) ProtoReflect

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

func (*VDiffCreateRequest) Reset

func (x *VDiffCreateRequest) Reset()

func (*VDiffCreateRequest) String

func (x *VDiffCreateRequest) String() string

type VDiffCreateResponse

type VDiffCreateResponse struct {

	// Intentionally upper case to maintain compatibility with
	// vtctlclient and other VDiff client command output.
	UUID string `protobuf:"bytes,1,opt,name=UUID,proto3" json:"UUID,omitempty"`
	// contains filtered or unexported fields
}

func (*VDiffCreateResponse) Descriptor deprecated

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

Deprecated: Use VDiffCreateResponse.ProtoReflect.Descriptor instead.

func (*VDiffCreateResponse) GetUUID

func (x *VDiffCreateResponse) GetUUID() string

func (*VDiffCreateResponse) ProtoMessage

func (*VDiffCreateResponse) ProtoMessage()

func (*VDiffCreateResponse) ProtoReflect

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

func (*VDiffCreateResponse) Reset

func (x *VDiffCreateResponse) Reset()

func (*VDiffCreateResponse) String

func (x *VDiffCreateResponse) String() string

type VDiffDeleteRequest

type VDiffDeleteRequest struct {
	Workflow       string `protobuf:"bytes,1,opt,name=workflow,proto3" json:"workflow,omitempty"`
	TargetKeyspace string `protobuf:"bytes,2,opt,name=target_keyspace,json=targetKeyspace,proto3" json:"target_keyspace,omitempty"`
	// This will be 'all' or a UUID.
	Arg string `protobuf:"bytes,3,opt,name=arg,proto3" json:"arg,omitempty"`
	// contains filtered or unexported fields
}

func (*VDiffDeleteRequest) Descriptor deprecated

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

Deprecated: Use VDiffDeleteRequest.ProtoReflect.Descriptor instead.

func (*VDiffDeleteRequest) GetArg

func (x *VDiffDeleteRequest) GetArg() string

func (*VDiffDeleteRequest) GetTargetKeyspace

func (x *VDiffDeleteRequest) GetTargetKeyspace() string

func (*VDiffDeleteRequest) GetWorkflow

func (x *VDiffDeleteRequest) GetWorkflow() string

func (*VDiffDeleteRequest) ProtoMessage

func (*VDiffDeleteRequest) ProtoMessage()

func (*VDiffDeleteRequest) ProtoReflect

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

func (*VDiffDeleteRequest) Reset

func (x *VDiffDeleteRequest) Reset()

func (*VDiffDeleteRequest) String

func (x *VDiffDeleteRequest) String() string

type VDiffDeleteResponse

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

func (*VDiffDeleteResponse) Descriptor deprecated

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

Deprecated: Use VDiffDeleteResponse.ProtoReflect.Descriptor instead.

func (*VDiffDeleteResponse) ProtoMessage

func (*VDiffDeleteResponse) ProtoMessage()

func (*VDiffDeleteResponse) ProtoReflect

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

func (*VDiffDeleteResponse) Reset

func (x *VDiffDeleteResponse) Reset()

func (*VDiffDeleteResponse) String

func (x *VDiffDeleteResponse) String() string

type VDiffResumeRequest

type VDiffResumeRequest struct {
	Workflow       string `protobuf:"bytes,1,opt,name=workflow,proto3" json:"workflow,omitempty"`
	TargetKeyspace string `protobuf:"bytes,2,opt,name=target_keyspace,json=targetKeyspace,proto3" json:"target_keyspace,omitempty"`
	Uuid           string `protobuf:"bytes,3,opt,name=uuid,proto3" json:"uuid,omitempty"`
	// contains filtered or unexported fields
}

func (*VDiffResumeRequest) Descriptor deprecated

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

Deprecated: Use VDiffResumeRequest.ProtoReflect.Descriptor instead.

func (*VDiffResumeRequest) GetTargetKeyspace

func (x *VDiffResumeRequest) GetTargetKeyspace() string

func (*VDiffResumeRequest) GetUuid

func (x *VDiffResumeRequest) GetUuid() string

func (*VDiffResumeRequest) GetWorkflow

func (x *VDiffResumeRequest) GetWorkflow() string

func (*VDiffResumeRequest) ProtoMessage

func (*VDiffResumeRequest) ProtoMessage()

func (*VDiffResumeRequest) ProtoReflect

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

func (*VDiffResumeRequest) Reset

func (x *VDiffResumeRequest) Reset()

func (*VDiffResumeRequest) String

func (x *VDiffResumeRequest) String() string

type VDiffResumeResponse

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

func (*VDiffResumeResponse) Descriptor deprecated

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

Deprecated: Use VDiffResumeResponse.ProtoReflect.Descriptor instead.

func (*VDiffResumeResponse) ProtoMessage

func (*VDiffResumeResponse) ProtoMessage()

func (*VDiffResumeResponse) ProtoReflect

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

func (*VDiffResumeResponse) Reset

func (x *VDiffResumeResponse) Reset()

func (*VDiffResumeResponse) String

func (x *VDiffResumeResponse) String() string

type VDiffShowRequest

type VDiffShowRequest struct {
	Workflow       string `protobuf:"bytes,1,opt,name=workflow,proto3" json:"workflow,omitempty"`
	TargetKeyspace string `protobuf:"bytes,2,opt,name=target_keyspace,json=targetKeyspace,proto3" json:"target_keyspace,omitempty"`
	// This will be 'all', 'last', or a UUID.
	Arg string `protobuf:"bytes,3,opt,name=arg,proto3" json:"arg,omitempty"`
	// contains filtered or unexported fields
}

func (*VDiffShowRequest) Descriptor deprecated

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

Deprecated: Use VDiffShowRequest.ProtoReflect.Descriptor instead.

func (*VDiffShowRequest) GetArg

func (x *VDiffShowRequest) GetArg() string

func (*VDiffShowRequest) GetTargetKeyspace

func (x *VDiffShowRequest) GetTargetKeyspace() string

func (*VDiffShowRequest) GetWorkflow

func (x *VDiffShowRequest) GetWorkflow() string

func (*VDiffShowRequest) ProtoMessage

func (*VDiffShowRequest) ProtoMessage()

func (*VDiffShowRequest) ProtoReflect

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

func (*VDiffShowRequest) Reset

func (x *VDiffShowRequest) Reset()

func (*VDiffShowRequest) String

func (x *VDiffShowRequest) String() string

type VDiffShowResponse

type VDiffShowResponse struct {

	// The key is keyspace/shard.
	TabletResponses map[string]*dev1.VDiffResponse `` /* 194-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*VDiffShowResponse) Descriptor deprecated

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

Deprecated: Use VDiffShowResponse.ProtoReflect.Descriptor instead.

func (*VDiffShowResponse) GetTabletResponses

func (x *VDiffShowResponse) GetTabletResponses() map[string]*dev1.VDiffResponse

func (*VDiffShowResponse) ProtoMessage

func (*VDiffShowResponse) ProtoMessage()

func (*VDiffShowResponse) ProtoReflect

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

func (*VDiffShowResponse) Reset

func (x *VDiffShowResponse) Reset()

func (*VDiffShowResponse) String

func (x *VDiffShowResponse) String() string

type VDiffStopRequest

type VDiffStopRequest struct {
	Workflow       string `protobuf:"bytes,1,opt,name=workflow,proto3" json:"workflow,omitempty"`
	TargetKeyspace string `protobuf:"bytes,2,opt,name=target_keyspace,json=targetKeyspace,proto3" json:"target_keyspace,omitempty"`
	Uuid           string `protobuf:"bytes,3,opt,name=uuid,proto3" json:"uuid,omitempty"`
	// contains filtered or unexported fields
}

func (*VDiffStopRequest) Descriptor deprecated

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

Deprecated: Use VDiffStopRequest.ProtoReflect.Descriptor instead.

func (*VDiffStopRequest) GetTargetKeyspace

func (x *VDiffStopRequest) GetTargetKeyspace() string

func (*VDiffStopRequest) GetUuid

func (x *VDiffStopRequest) GetUuid() string

func (*VDiffStopRequest) GetWorkflow

func (x *VDiffStopRequest) GetWorkflow() string

func (*VDiffStopRequest) ProtoMessage

func (*VDiffStopRequest) ProtoMessage()

func (*VDiffStopRequest) ProtoReflect

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

func (*VDiffStopRequest) Reset

func (x *VDiffStopRequest) Reset()

func (*VDiffStopRequest) String

func (x *VDiffStopRequest) String() string

type VDiffStopResponse

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

func (*VDiffStopResponse) Descriptor deprecated

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

Deprecated: Use VDiffStopResponse.ProtoReflect.Descriptor instead.

func (*VDiffStopResponse) ProtoMessage

func (*VDiffStopResponse) ProtoMessage()

func (*VDiffStopResponse) ProtoReflect

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

func (*VDiffStopResponse) Reset

func (x *VDiffStopResponse) Reset()

func (*VDiffStopResponse) String

func (x *VDiffStopResponse) String() string

type ValidateKeyspaceRequest

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

func (*ValidateKeyspaceRequest) Descriptor deprecated

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

Deprecated: Use ValidateKeyspaceRequest.ProtoReflect.Descriptor instead.

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

func (x *ValidateKeyspaceRequest) String() string

type ValidateKeyspaceResponse

type ValidateKeyspaceResponse struct {
	Results        []string                          `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	ResultsByShard map[string]*ValidateShardResponse `` /* 193-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ValidateKeyspaceResponse) Descriptor deprecated

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

Deprecated: Use ValidateKeyspaceResponse.ProtoReflect.Descriptor instead.

func (*ValidateKeyspaceResponse) GetResults

func (x *ValidateKeyspaceResponse) GetResults() []string

func (*ValidateKeyspaceResponse) GetResultsByShard

func (x *ValidateKeyspaceResponse) GetResultsByShard() map[string]*ValidateShardResponse

func (*ValidateKeyspaceResponse) ProtoMessage

func (*ValidateKeyspaceResponse) ProtoMessage()

func (*ValidateKeyspaceResponse) ProtoReflect

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

func (*ValidateKeyspaceResponse) Reset

func (x *ValidateKeyspaceResponse) Reset()

func (*ValidateKeyspaceResponse) String

func (x *ValidateKeyspaceResponse) String() string

type ValidateRequest

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

func (*ValidateRequest) Descriptor deprecated

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

Deprecated: Use ValidateRequest.ProtoReflect.Descriptor instead.

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

func (x *ValidateRequest) String() string

type ValidateResponse

type ValidateResponse struct {
	Results           []string                             `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	ResultsByKeyspace map[string]*ValidateKeyspaceResponse `` /* 202-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ValidateResponse) Descriptor deprecated

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

Deprecated: Use ValidateResponse.ProtoReflect.Descriptor instead.

func (*ValidateResponse) GetResults

func (x *ValidateResponse) GetResults() []string

func (*ValidateResponse) GetResultsByKeyspace

func (x *ValidateResponse) GetResultsByKeyspace() map[string]*ValidateKeyspaceResponse

func (*ValidateResponse) ProtoMessage

func (*ValidateResponse) ProtoMessage()

func (*ValidateResponse) ProtoReflect

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

func (*ValidateResponse) Reset

func (x *ValidateResponse) Reset()

func (*ValidateResponse) String

func (x *ValidateResponse) String() string

type ValidateSchemaKeyspaceRequest

type ValidateSchemaKeyspaceRequest struct {
	Keyspace       string   `protobuf:"bytes,1,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	ExcludeTables  []string `protobuf:"bytes,2,rep,name=exclude_tables,json=excludeTables,proto3" json:"exclude_tables,omitempty"`
	IncludeViews   bool     `protobuf:"varint,3,opt,name=include_views,json=includeViews,proto3" json:"include_views,omitempty"`
	SkipNoPrimary  bool     `protobuf:"varint,4,opt,name=skip_no_primary,json=skipNoPrimary,proto3" json:"skip_no_primary,omitempty"`
	IncludeVschema bool     `protobuf:"varint,5,opt,name=include_vschema,json=includeVschema,proto3" json:"include_vschema,omitempty"`
	// contains filtered or unexported fields
}

func (*ValidateSchemaKeyspaceRequest) Descriptor deprecated

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

Deprecated: Use ValidateSchemaKeyspaceRequest.ProtoReflect.Descriptor instead.

func (*ValidateSchemaKeyspaceRequest) GetExcludeTables

func (x *ValidateSchemaKeyspaceRequest) GetExcludeTables() []string

func (*ValidateSchemaKeyspaceRequest) GetIncludeViews

func (x *ValidateSchemaKeyspaceRequest) GetIncludeViews() bool

func (*ValidateSchemaKeyspaceRequest) GetIncludeVschema

func (x *ValidateSchemaKeyspaceRequest) GetIncludeVschema() bool

func (*ValidateSchemaKeyspaceRequest) GetKeyspace

func (x *ValidateSchemaKeyspaceRequest) GetKeyspace() string

func (*ValidateSchemaKeyspaceRequest) GetSkipNoPrimary

func (x *ValidateSchemaKeyspaceRequest) GetSkipNoPrimary() bool

func (*ValidateSchemaKeyspaceRequest) ProtoMessage

func (*ValidateSchemaKeyspaceRequest) ProtoMessage()

func (*ValidateSchemaKeyspaceRequest) ProtoReflect

func (*ValidateSchemaKeyspaceRequest) Reset

func (x *ValidateSchemaKeyspaceRequest) Reset()

func (*ValidateSchemaKeyspaceRequest) String

type ValidateSchemaKeyspaceResponse

type ValidateSchemaKeyspaceResponse struct {
	Results        []string                          `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	ResultsByShard map[string]*ValidateShardResponse `` /* 193-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ValidateSchemaKeyspaceResponse) Descriptor deprecated

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

Deprecated: Use ValidateSchemaKeyspaceResponse.ProtoReflect.Descriptor instead.

func (*ValidateSchemaKeyspaceResponse) GetResults

func (x *ValidateSchemaKeyspaceResponse) GetResults() []string

func (*ValidateSchemaKeyspaceResponse) GetResultsByShard

func (x *ValidateSchemaKeyspaceResponse) GetResultsByShard() map[string]*ValidateShardResponse

func (*ValidateSchemaKeyspaceResponse) ProtoMessage

func (*ValidateSchemaKeyspaceResponse) ProtoMessage()

func (*ValidateSchemaKeyspaceResponse) ProtoReflect

func (*ValidateSchemaKeyspaceResponse) Reset

func (x *ValidateSchemaKeyspaceResponse) Reset()

func (*ValidateSchemaKeyspaceResponse) String

type ValidateShardRequest

type ValidateShardRequest 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"`
	PingTablets bool   `protobuf:"varint,3,opt,name=ping_tablets,json=pingTablets,proto3" json:"ping_tablets,omitempty"`
	// contains filtered or unexported fields
}

func (*ValidateShardRequest) Descriptor deprecated

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

Deprecated: Use ValidateShardRequest.ProtoReflect.Descriptor instead.

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

func (x *ValidateShardRequest) String() string

type ValidateShardResponse

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

func (*ValidateShardResponse) Descriptor deprecated

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

Deprecated: Use ValidateShardResponse.ProtoReflect.Descriptor instead.

func (*ValidateShardResponse) GetResults

func (x *ValidateShardResponse) GetResults() []string

func (*ValidateShardResponse) ProtoMessage

func (*ValidateShardResponse) ProtoMessage()

func (*ValidateShardResponse) ProtoReflect

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

func (*ValidateShardResponse) Reset

func (x *ValidateShardResponse) Reset()

func (*ValidateShardResponse) String

func (x *ValidateShardResponse) String() string

type ValidateVSchemaRequest

type ValidateVSchemaRequest struct {
	Keyspace      string   `protobuf:"bytes,1,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	Shards        []string `protobuf:"bytes,2,rep,name=shards,proto3" json:"shards,omitempty"`
	ExcludeTables []string `protobuf:"bytes,3,rep,name=exclude_tables,json=excludeTables,proto3" json:"exclude_tables,omitempty"`
	IncludeViews  bool     `protobuf:"varint,4,opt,name=include_views,json=includeViews,proto3" json:"include_views,omitempty"`
	// contains filtered or unexported fields
}

func (*ValidateVSchemaRequest) Descriptor deprecated

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

Deprecated: Use ValidateVSchemaRequest.ProtoReflect.Descriptor instead.

func (*ValidateVSchemaRequest) GetExcludeTables

func (x *ValidateVSchemaRequest) GetExcludeTables() []string

func (*ValidateVSchemaRequest) GetIncludeViews

func (x *ValidateVSchemaRequest) GetIncludeViews() bool

func (*ValidateVSchemaRequest) GetKeyspace

func (x *ValidateVSchemaRequest) GetKeyspace() string

func (*ValidateVSchemaRequest) GetShards

func (x *ValidateVSchemaRequest) GetShards() []string

func (*ValidateVSchemaRequest) ProtoMessage

func (*ValidateVSchemaRequest) ProtoMessage()

func (*ValidateVSchemaRequest) ProtoReflect

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

func (*ValidateVSchemaRequest) Reset

func (x *ValidateVSchemaRequest) Reset()

func (*ValidateVSchemaRequest) String

func (x *ValidateVSchemaRequest) String() string

type ValidateVSchemaResponse

type ValidateVSchemaResponse struct {
	Results        []string                          `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	ResultsByShard map[string]*ValidateShardResponse `` /* 193-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ValidateVSchemaResponse) Descriptor deprecated

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

Deprecated: Use ValidateVSchemaResponse.ProtoReflect.Descriptor instead.

func (*ValidateVSchemaResponse) GetResults

func (x *ValidateVSchemaResponse) GetResults() []string

func (*ValidateVSchemaResponse) GetResultsByShard

func (x *ValidateVSchemaResponse) GetResultsByShard() map[string]*ValidateShardResponse

func (*ValidateVSchemaResponse) ProtoMessage

func (*ValidateVSchemaResponse) ProtoMessage()

func (*ValidateVSchemaResponse) ProtoReflect

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

func (*ValidateVSchemaResponse) Reset

func (x *ValidateVSchemaResponse) Reset()

func (*ValidateVSchemaResponse) String

func (x *ValidateVSchemaResponse) String() string

type ValidateVersionKeyspaceRequest

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

func (*ValidateVersionKeyspaceRequest) Descriptor deprecated

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

Deprecated: Use ValidateVersionKeyspaceRequest.ProtoReflect.Descriptor instead.

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

type ValidateVersionKeyspaceResponse

type ValidateVersionKeyspaceResponse struct {
	Results        []string                          `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	ResultsByShard map[string]*ValidateShardResponse `` /* 193-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ValidateVersionKeyspaceResponse) Descriptor deprecated

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

Deprecated: Use ValidateVersionKeyspaceResponse.ProtoReflect.Descriptor instead.

func (*ValidateVersionKeyspaceResponse) GetResults

func (x *ValidateVersionKeyspaceResponse) GetResults() []string

func (*ValidateVersionKeyspaceResponse) GetResultsByShard

func (x *ValidateVersionKeyspaceResponse) GetResultsByShard() map[string]*ValidateShardResponse

func (*ValidateVersionKeyspaceResponse) ProtoMessage

func (*ValidateVersionKeyspaceResponse) ProtoMessage()

func (*ValidateVersionKeyspaceResponse) ProtoReflect

func (*ValidateVersionKeyspaceResponse) Reset

func (*ValidateVersionKeyspaceResponse) String

type ValidateVersionShardRequest

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

func (*ValidateVersionShardRequest) Descriptor deprecated

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

Deprecated: Use ValidateVersionShardRequest.ProtoReflect.Descriptor instead.

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

func (x *ValidateVersionShardRequest) String() string

type ValidateVersionShardResponse

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

func (*ValidateVersionShardResponse) Descriptor deprecated

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

Deprecated: Use ValidateVersionShardResponse.ProtoReflect.Descriptor instead.

func (*ValidateVersionShardResponse) GetResults

func (x *ValidateVersionShardResponse) GetResults() []string

func (*ValidateVersionShardResponse) ProtoMessage

func (*ValidateVersionShardResponse) ProtoMessage()

func (*ValidateVersionShardResponse) ProtoReflect

func (*ValidateVersionShardResponse) Reset

func (x *ValidateVersionShardResponse) Reset()

func (*ValidateVersionShardResponse) String

type Workflow

type Workflow struct {
	Name               string                           `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Source             *Workflow_ReplicationLocation    `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"`
	Target             *Workflow_ReplicationLocation    `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
	MaxVReplicationLag int64                            `protobuf:"varint,4,opt,name=max_v_replication_lag,json=maxVReplicationLag,proto3" json:"max_v_replication_lag,omitempty"`
	ShardStreams       map[string]*Workflow_ShardStream `` /* 185-byte string literal not displayed */
	WorkflowType       string                           `protobuf:"bytes,6,opt,name=workflow_type,json=workflowType,proto3" json:"workflow_type,omitempty"`
	WorkflowSubType    string                           `protobuf:"bytes,7,opt,name=workflow_sub_type,json=workflowSubType,proto3" json:"workflow_sub_type,omitempty"`
	// contains filtered or unexported fields
}

TODO: comment the hell out of this.

func (*Workflow) Descriptor deprecated

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

Deprecated: Use Workflow.ProtoReflect.Descriptor instead.

func (*Workflow) GetMaxVReplicationLag

func (x *Workflow) GetMaxVReplicationLag() int64

func (*Workflow) GetName

func (x *Workflow) GetName() string

func (*Workflow) GetShardStreams

func (x *Workflow) GetShardStreams() map[string]*Workflow_ShardStream

func (*Workflow) GetSource

func (x *Workflow) GetSource() *Workflow_ReplicationLocation

func (*Workflow) GetTarget

func (x *Workflow) GetTarget() *Workflow_ReplicationLocation

func (*Workflow) GetWorkflowSubType

func (x *Workflow) GetWorkflowSubType() string

func (*Workflow) GetWorkflowType

func (x *Workflow) GetWorkflowType() string

func (*Workflow) ProtoMessage

func (*Workflow) ProtoMessage()

func (*Workflow) ProtoReflect

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

func (*Workflow) Reset

func (x *Workflow) Reset()

func (*Workflow) String

func (x *Workflow) String() string

type WorkflowDeleteRequest

type WorkflowDeleteRequest struct {
	Keyspace         string `protobuf:"bytes,1,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	Workflow         string `protobuf:"bytes,2,opt,name=workflow,proto3" json:"workflow,omitempty"`
	KeepData         bool   `protobuf:"varint,3,opt,name=keep_data,json=keepData,proto3" json:"keep_data,omitempty"`
	KeepRoutingRules bool   `protobuf:"varint,4,opt,name=keep_routing_rules,json=keepRoutingRules,proto3" json:"keep_routing_rules,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkflowDeleteRequest) Descriptor deprecated

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

Deprecated: Use WorkflowDeleteRequest.ProtoReflect.Descriptor instead.

func (*WorkflowDeleteRequest) GetKeepData

func (x *WorkflowDeleteRequest) GetKeepData() bool

func (*WorkflowDeleteRequest) GetKeepRoutingRules

func (x *WorkflowDeleteRequest) GetKeepRoutingRules() bool

func (*WorkflowDeleteRequest) GetKeyspace

func (x *WorkflowDeleteRequest) GetKeyspace() string

func (*WorkflowDeleteRequest) GetWorkflow

func (x *WorkflowDeleteRequest) GetWorkflow() string

func (*WorkflowDeleteRequest) ProtoMessage

func (*WorkflowDeleteRequest) ProtoMessage()

func (*WorkflowDeleteRequest) ProtoReflect

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

func (*WorkflowDeleteRequest) Reset

func (x *WorkflowDeleteRequest) Reset()

func (*WorkflowDeleteRequest) String

func (x *WorkflowDeleteRequest) String() string

type WorkflowDeleteResponse

type WorkflowDeleteResponse struct {
	Summary string                               `protobuf:"bytes,1,opt,name=summary,proto3" json:"summary,omitempty"`
	Details []*WorkflowDeleteResponse_TabletInfo `protobuf:"bytes,2,rep,name=details,proto3" json:"details,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkflowDeleteResponse) Descriptor deprecated

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

Deprecated: Use WorkflowDeleteResponse.ProtoReflect.Descriptor instead.

func (*WorkflowDeleteResponse) GetDetails

func (*WorkflowDeleteResponse) GetSummary

func (x *WorkflowDeleteResponse) GetSummary() string

func (*WorkflowDeleteResponse) ProtoMessage

func (*WorkflowDeleteResponse) ProtoMessage()

func (*WorkflowDeleteResponse) ProtoReflect

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

func (*WorkflowDeleteResponse) Reset

func (x *WorkflowDeleteResponse) Reset()

func (*WorkflowDeleteResponse) String

func (x *WorkflowDeleteResponse) String() string

type WorkflowDeleteResponse_TabletInfo

type WorkflowDeleteResponse_TabletInfo struct {
	Tablet *dev2.TabletAlias `protobuf:"bytes,1,opt,name=tablet,proto3" json:"tablet,omitempty"`
	// Delete is set if the workflow was deleted on this tablet.
	Deleted bool `protobuf:"varint,2,opt,name=deleted,proto3" json:"deleted,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkflowDeleteResponse_TabletInfo) Descriptor deprecated

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

Deprecated: Use WorkflowDeleteResponse_TabletInfo.ProtoReflect.Descriptor instead.

func (*WorkflowDeleteResponse_TabletInfo) GetDeleted

func (x *WorkflowDeleteResponse_TabletInfo) GetDeleted() bool

func (*WorkflowDeleteResponse_TabletInfo) GetTablet

func (*WorkflowDeleteResponse_TabletInfo) ProtoMessage

func (*WorkflowDeleteResponse_TabletInfo) ProtoMessage()

func (*WorkflowDeleteResponse_TabletInfo) ProtoReflect

func (*WorkflowDeleteResponse_TabletInfo) Reset

func (*WorkflowDeleteResponse_TabletInfo) String

type WorkflowStatusRequest

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

func (*WorkflowStatusRequest) Descriptor deprecated

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

Deprecated: Use WorkflowStatusRequest.ProtoReflect.Descriptor instead.

func (*WorkflowStatusRequest) GetKeyspace

func (x *WorkflowStatusRequest) GetKeyspace() string

func (*WorkflowStatusRequest) GetWorkflow

func (x *WorkflowStatusRequest) GetWorkflow() string

func (*WorkflowStatusRequest) ProtoMessage

func (*WorkflowStatusRequest) ProtoMessage()

func (*WorkflowStatusRequest) ProtoReflect

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

func (*WorkflowStatusRequest) Reset

func (x *WorkflowStatusRequest) Reset()

func (*WorkflowStatusRequest) String

func (x *WorkflowStatusRequest) String() string

type WorkflowStatusResponse

type WorkflowStatusResponse struct {

	// The key is keyspace/shard.
	TableCopyState map[string]*WorkflowStatusResponse_TableCopyState `` /* 193-byte string literal not displayed */
	ShardStreams   map[string]*WorkflowStatusResponse_ShardStreams   `` /* 185-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*WorkflowStatusResponse) Descriptor deprecated

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

Deprecated: Use WorkflowStatusResponse.ProtoReflect.Descriptor instead.

func (*WorkflowStatusResponse) GetShardStreams

func (*WorkflowStatusResponse) GetTableCopyState

func (*WorkflowStatusResponse) ProtoMessage

func (*WorkflowStatusResponse) ProtoMessage()

func (*WorkflowStatusResponse) ProtoReflect

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

func (*WorkflowStatusResponse) Reset

func (x *WorkflowStatusResponse) Reset()

func (*WorkflowStatusResponse) String

func (x *WorkflowStatusResponse) String() string

type WorkflowStatusResponse_ShardStreamState

type WorkflowStatusResponse_ShardStreamState struct {
	Id          int32             `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Tablet      *dev2.TabletAlias `protobuf:"bytes,2,opt,name=tablet,proto3" json:"tablet,omitempty"`
	SourceShard string            `protobuf:"bytes,3,opt,name=source_shard,json=sourceShard,proto3" json:"source_shard,omitempty"`
	Position    string            `protobuf:"bytes,4,opt,name=position,proto3" json:"position,omitempty"`
	Status      string            `protobuf:"bytes,5,opt,name=status,proto3" json:"status,omitempty"`
	Info        string            `protobuf:"bytes,6,opt,name=info,proto3" json:"info,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkflowStatusResponse_ShardStreamState) Descriptor deprecated

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

Deprecated: Use WorkflowStatusResponse_ShardStreamState.ProtoReflect.Descriptor instead.

func (*WorkflowStatusResponse_ShardStreamState) GetId

func (*WorkflowStatusResponse_ShardStreamState) GetInfo

func (*WorkflowStatusResponse_ShardStreamState) GetPosition

func (*WorkflowStatusResponse_ShardStreamState) GetSourceShard

func (x *WorkflowStatusResponse_ShardStreamState) GetSourceShard() string

func (*WorkflowStatusResponse_ShardStreamState) GetStatus

func (*WorkflowStatusResponse_ShardStreamState) GetTablet

func (*WorkflowStatusResponse_ShardStreamState) ProtoMessage

func (*WorkflowStatusResponse_ShardStreamState) ProtoReflect

func (*WorkflowStatusResponse_ShardStreamState) Reset

func (*WorkflowStatusResponse_ShardStreamState) String

type WorkflowStatusResponse_ShardStreams

type WorkflowStatusResponse_ShardStreams struct {
	Streams []*WorkflowStatusResponse_ShardStreamState `protobuf:"bytes,2,rep,name=streams,proto3" json:"streams,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkflowStatusResponse_ShardStreams) Descriptor deprecated

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

Deprecated: Use WorkflowStatusResponse_ShardStreams.ProtoReflect.Descriptor instead.

func (*WorkflowStatusResponse_ShardStreams) GetStreams

func (*WorkflowStatusResponse_ShardStreams) ProtoMessage

func (*WorkflowStatusResponse_ShardStreams) ProtoMessage()

func (*WorkflowStatusResponse_ShardStreams) ProtoReflect

func (*WorkflowStatusResponse_ShardStreams) Reset

func (*WorkflowStatusResponse_ShardStreams) String

type WorkflowStatusResponse_TableCopyState

type WorkflowStatusResponse_TableCopyState struct {
	RowsCopied      int64   `protobuf:"varint,1,opt,name=rows_copied,json=rowsCopied,proto3" json:"rows_copied,omitempty"`
	RowsTotal       int64   `protobuf:"varint,2,opt,name=rows_total,json=rowsTotal,proto3" json:"rows_total,omitempty"`
	RowsPercentage  float32 `protobuf:"fixed32,3,opt,name=rows_percentage,json=rowsPercentage,proto3" json:"rows_percentage,omitempty"`
	BytesCopied     int64   `protobuf:"varint,4,opt,name=bytes_copied,json=bytesCopied,proto3" json:"bytes_copied,omitempty"`
	BytesTotal      int64   `protobuf:"varint,5,opt,name=bytes_total,json=bytesTotal,proto3" json:"bytes_total,omitempty"`
	BytesPercentage float32 `protobuf:"fixed32,6,opt,name=bytes_percentage,json=bytesPercentage,proto3" json:"bytes_percentage,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkflowStatusResponse_TableCopyState) Descriptor deprecated

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

Deprecated: Use WorkflowStatusResponse_TableCopyState.ProtoReflect.Descriptor instead.

func (*WorkflowStatusResponse_TableCopyState) GetBytesCopied

func (x *WorkflowStatusResponse_TableCopyState) GetBytesCopied() int64

func (*WorkflowStatusResponse_TableCopyState) GetBytesPercentage

func (x *WorkflowStatusResponse_TableCopyState) GetBytesPercentage() float32

func (*WorkflowStatusResponse_TableCopyState) GetBytesTotal

func (x *WorkflowStatusResponse_TableCopyState) GetBytesTotal() int64

func (*WorkflowStatusResponse_TableCopyState) GetRowsCopied

func (x *WorkflowStatusResponse_TableCopyState) GetRowsCopied() int64

func (*WorkflowStatusResponse_TableCopyState) GetRowsPercentage

func (x *WorkflowStatusResponse_TableCopyState) GetRowsPercentage() float32

func (*WorkflowStatusResponse_TableCopyState) GetRowsTotal

func (x *WorkflowStatusResponse_TableCopyState) GetRowsTotal() int64

func (*WorkflowStatusResponse_TableCopyState) ProtoMessage

func (*WorkflowStatusResponse_TableCopyState) ProtoMessage()

func (*WorkflowStatusResponse_TableCopyState) ProtoReflect

func (*WorkflowStatusResponse_TableCopyState) Reset

func (*WorkflowStatusResponse_TableCopyState) String

type WorkflowSwitchTrafficRequest

type WorkflowSwitchTrafficRequest struct {
	Keyspace                  string            `protobuf:"bytes,1,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	Workflow                  string            `protobuf:"bytes,2,opt,name=workflow,proto3" json:"workflow,omitempty"`
	Cells                     []string          `protobuf:"bytes,3,rep,name=cells,proto3" json:"cells,omitempty"`
	TabletTypes               []dev2.TabletType `` /* 138-byte string literal not displayed */
	MaxReplicationLagAllowed  *dev3.Duration    `` /* 137-byte string literal not displayed */
	EnableReverseReplication  bool              `` /* 136-byte string literal not displayed */
	Direction                 int32             `protobuf:"varint,7,opt,name=direction,proto3" json:"direction,omitempty"`
	Timeout                   *dev3.Duration    `protobuf:"bytes,8,opt,name=timeout,proto3" json:"timeout,omitempty"`
	DryRun                    bool              `protobuf:"varint,9,opt,name=dry_run,json=dryRun,proto3" json:"dry_run,omitempty"`
	InitializeTargetSequences bool              `` /* 140-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*WorkflowSwitchTrafficRequest) Descriptor deprecated

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

Deprecated: Use WorkflowSwitchTrafficRequest.ProtoReflect.Descriptor instead.

func (*WorkflowSwitchTrafficRequest) GetCells

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

func (*WorkflowSwitchTrafficRequest) GetDirection

func (x *WorkflowSwitchTrafficRequest) GetDirection() int32

func (*WorkflowSwitchTrafficRequest) GetDryRun

func (x *WorkflowSwitchTrafficRequest) GetDryRun() bool

func (*WorkflowSwitchTrafficRequest) GetEnableReverseReplication

func (x *WorkflowSwitchTrafficRequest) GetEnableReverseReplication() bool

func (*WorkflowSwitchTrafficRequest) GetInitializeTargetSequences

func (x *WorkflowSwitchTrafficRequest) GetInitializeTargetSequences() bool

func (*WorkflowSwitchTrafficRequest) GetKeyspace

func (x *WorkflowSwitchTrafficRequest) GetKeyspace() string

func (*WorkflowSwitchTrafficRequest) GetMaxReplicationLagAllowed

func (x *WorkflowSwitchTrafficRequest) GetMaxReplicationLagAllowed() *dev3.Duration

func (*WorkflowSwitchTrafficRequest) GetTabletTypes

func (x *WorkflowSwitchTrafficRequest) GetTabletTypes() []dev2.TabletType

func (*WorkflowSwitchTrafficRequest) GetTimeout

func (x *WorkflowSwitchTrafficRequest) GetTimeout() *dev3.Duration

func (*WorkflowSwitchTrafficRequest) GetWorkflow

func (x *WorkflowSwitchTrafficRequest) GetWorkflow() string

func (*WorkflowSwitchTrafficRequest) ProtoMessage

func (*WorkflowSwitchTrafficRequest) ProtoMessage()

func (*WorkflowSwitchTrafficRequest) ProtoReflect

func (*WorkflowSwitchTrafficRequest) Reset

func (x *WorkflowSwitchTrafficRequest) Reset()

func (*WorkflowSwitchTrafficRequest) String

type WorkflowSwitchTrafficResponse

type WorkflowSwitchTrafficResponse struct {
	Summary       string   `protobuf:"bytes,1,opt,name=summary,proto3" json:"summary,omitempty"`
	StartState    string   `protobuf:"bytes,2,opt,name=start_state,json=startState,proto3" json:"start_state,omitempty"`
	CurrentState  string   `protobuf:"bytes,3,opt,name=current_state,json=currentState,proto3" json:"current_state,omitempty"`
	DryRunResults []string `protobuf:"bytes,4,rep,name=dry_run_results,json=dryRunResults,proto3" json:"dry_run_results,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkflowSwitchTrafficResponse) Descriptor deprecated

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

Deprecated: Use WorkflowSwitchTrafficResponse.ProtoReflect.Descriptor instead.

func (*WorkflowSwitchTrafficResponse) GetCurrentState

func (x *WorkflowSwitchTrafficResponse) GetCurrentState() string

func (*WorkflowSwitchTrafficResponse) GetDryRunResults

func (x *WorkflowSwitchTrafficResponse) GetDryRunResults() []string

func (*WorkflowSwitchTrafficResponse) GetStartState

func (x *WorkflowSwitchTrafficResponse) GetStartState() string

func (*WorkflowSwitchTrafficResponse) GetSummary

func (x *WorkflowSwitchTrafficResponse) GetSummary() string

func (*WorkflowSwitchTrafficResponse) ProtoMessage

func (*WorkflowSwitchTrafficResponse) ProtoMessage()

func (*WorkflowSwitchTrafficResponse) ProtoReflect

func (*WorkflowSwitchTrafficResponse) Reset

func (x *WorkflowSwitchTrafficResponse) Reset()

func (*WorkflowSwitchTrafficResponse) String

type WorkflowUpdateRequest

type WorkflowUpdateRequest struct {
	Keyspace string `protobuf:"bytes,1,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	// TabletRequest gets passed on to each primary tablet involved
	// in the workflow via the UpdateVReplicationWorkflow tabletmanager RPC.
	TabletRequest *dev1.UpdateVReplicationWorkflowRequest `protobuf:"bytes,2,opt,name=tablet_request,json=tabletRequest,proto3" json:"tablet_request,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkflowUpdateRequest) Descriptor deprecated

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

Deprecated: Use WorkflowUpdateRequest.ProtoReflect.Descriptor instead.

func (*WorkflowUpdateRequest) GetKeyspace

func (x *WorkflowUpdateRequest) GetKeyspace() string

func (*WorkflowUpdateRequest) GetTabletRequest

func (*WorkflowUpdateRequest) ProtoMessage

func (*WorkflowUpdateRequest) ProtoMessage()

func (*WorkflowUpdateRequest) ProtoReflect

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

func (*WorkflowUpdateRequest) Reset

func (x *WorkflowUpdateRequest) Reset()

func (*WorkflowUpdateRequest) String

func (x *WorkflowUpdateRequest) String() string

type WorkflowUpdateResponse

type WorkflowUpdateResponse struct {
	Summary string                               `protobuf:"bytes,1,opt,name=summary,proto3" json:"summary,omitempty"`
	Details []*WorkflowUpdateResponse_TabletInfo `protobuf:"bytes,2,rep,name=details,proto3" json:"details,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkflowUpdateResponse) Descriptor deprecated

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

Deprecated: Use WorkflowUpdateResponse.ProtoReflect.Descriptor instead.

func (*WorkflowUpdateResponse) GetDetails

func (*WorkflowUpdateResponse) GetSummary

func (x *WorkflowUpdateResponse) GetSummary() string

func (*WorkflowUpdateResponse) ProtoMessage

func (*WorkflowUpdateResponse) ProtoMessage()

func (*WorkflowUpdateResponse) ProtoReflect

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

func (*WorkflowUpdateResponse) Reset

func (x *WorkflowUpdateResponse) Reset()

func (*WorkflowUpdateResponse) String

func (x *WorkflowUpdateResponse) String() string

type WorkflowUpdateResponse_TabletInfo

type WorkflowUpdateResponse_TabletInfo struct {
	Tablet *dev2.TabletAlias `protobuf:"bytes,1,opt,name=tablet,proto3" json:"tablet,omitempty"`
	// Changed is true if any of the provided values were different
	// than what was already stored on this tablet.
	Changed bool `protobuf:"varint,2,opt,name=changed,proto3" json:"changed,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkflowUpdateResponse_TabletInfo) Descriptor deprecated

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

Deprecated: Use WorkflowUpdateResponse_TabletInfo.ProtoReflect.Descriptor instead.

func (*WorkflowUpdateResponse_TabletInfo) GetChanged

func (x *WorkflowUpdateResponse_TabletInfo) GetChanged() bool

func (*WorkflowUpdateResponse_TabletInfo) GetTablet

func (*WorkflowUpdateResponse_TabletInfo) ProtoMessage

func (*WorkflowUpdateResponse_TabletInfo) ProtoMessage()

func (*WorkflowUpdateResponse_TabletInfo) ProtoReflect

func (*WorkflowUpdateResponse_TabletInfo) Reset

func (*WorkflowUpdateResponse_TabletInfo) String

type Workflow_ReplicationLocation

type Workflow_ReplicationLocation struct {
	Keyspace string   `protobuf:"bytes,1,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	Shards   []string `protobuf:"bytes,2,rep,name=shards,proto3" json:"shards,omitempty"`
	// contains filtered or unexported fields
}

func (*Workflow_ReplicationLocation) Descriptor deprecated

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

Deprecated: Use Workflow_ReplicationLocation.ProtoReflect.Descriptor instead.

func (*Workflow_ReplicationLocation) GetKeyspace

func (x *Workflow_ReplicationLocation) GetKeyspace() string

func (*Workflow_ReplicationLocation) GetShards

func (x *Workflow_ReplicationLocation) GetShards() []string

func (*Workflow_ReplicationLocation) ProtoMessage

func (*Workflow_ReplicationLocation) ProtoMessage()

func (*Workflow_ReplicationLocation) ProtoReflect

func (*Workflow_ReplicationLocation) Reset

func (x *Workflow_ReplicationLocation) Reset()

func (*Workflow_ReplicationLocation) String

type Workflow_ShardStream

type Workflow_ShardStream struct {
	Streams          []*Workflow_Stream          `protobuf:"bytes,1,rep,name=streams,proto3" json:"streams,omitempty"`
	TabletControls   []*dev2.Shard_TabletControl `protobuf:"bytes,2,rep,name=tablet_controls,json=tabletControls,proto3" json:"tablet_controls,omitempty"`
	IsPrimaryServing bool                        `protobuf:"varint,3,opt,name=is_primary_serving,json=isPrimaryServing,proto3" json:"is_primary_serving,omitempty"`
	// contains filtered or unexported fields
}

func (*Workflow_ShardStream) Descriptor deprecated

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

Deprecated: Use Workflow_ShardStream.ProtoReflect.Descriptor instead.

func (*Workflow_ShardStream) GetIsPrimaryServing

func (x *Workflow_ShardStream) GetIsPrimaryServing() bool

func (*Workflow_ShardStream) GetStreams

func (x *Workflow_ShardStream) GetStreams() []*Workflow_Stream

func (*Workflow_ShardStream) GetTabletControls

func (x *Workflow_ShardStream) GetTabletControls() []*dev2.Shard_TabletControl

func (*Workflow_ShardStream) ProtoMessage

func (*Workflow_ShardStream) ProtoMessage()

func (*Workflow_ShardStream) ProtoReflect

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

func (*Workflow_ShardStream) Reset

func (x *Workflow_ShardStream) Reset()

func (*Workflow_ShardStream) String

func (x *Workflow_ShardStream) String() string

type Workflow_Stream

type Workflow_Stream struct {
	Id                   int64                        `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Shard                string                       `protobuf:"bytes,2,opt,name=shard,proto3" json:"shard,omitempty"`
	Tablet               *dev2.TabletAlias            `protobuf:"bytes,3,opt,name=tablet,proto3" json:"tablet,omitempty"`
	BinlogSource         *dev9.BinlogSource           `protobuf:"bytes,4,opt,name=binlog_source,json=binlogSource,proto3" json:"binlog_source,omitempty"`
	Position             string                       `protobuf:"bytes,5,opt,name=position,proto3" json:"position,omitempty"`
	StopPosition         string                       `protobuf:"bytes,6,opt,name=stop_position,json=stopPosition,proto3" json:"stop_position,omitempty"`
	State                string                       `protobuf:"bytes,7,opt,name=state,proto3" json:"state,omitempty"`
	DbName               string                       `protobuf:"bytes,8,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	TransactionTimestamp *dev3.Time                   `protobuf:"bytes,9,opt,name=transaction_timestamp,json=transactionTimestamp,proto3" json:"transaction_timestamp,omitempty"`
	TimeUpdated          *dev3.Time                   `protobuf:"bytes,10,opt,name=time_updated,json=timeUpdated,proto3" json:"time_updated,omitempty"`
	Message              string                       `protobuf:"bytes,11,opt,name=message,proto3" json:"message,omitempty"`
	CopyStates           []*Workflow_Stream_CopyState `protobuf:"bytes,12,rep,name=copy_states,json=copyStates,proto3" json:"copy_states,omitempty"`
	Logs                 []*Workflow_Stream_Log       `protobuf:"bytes,13,rep,name=logs,proto3" json:"logs,omitempty"`
	// LogFetchError is set if we fail to fetch some logs for this stream. We
	// will never fail to fetch workflows because we cannot fetch the logs, but
	// we will still forward log-fetch errors to the caller, should that be
	// relevant to the context in which they are fetching workflows.
	//
	// Note that this field being set does not necessarily mean that Logs is nil;
	// if there are N logs that exist for the stream, and we fail to fetch the
	// ith log, we will still return logs in [0, i) + (i, N].
	LogFetchError string   `protobuf:"bytes,14,opt,name=log_fetch_error,json=logFetchError,proto3" json:"log_fetch_error,omitempty"`
	Tags          []string `protobuf:"bytes,15,rep,name=tags,proto3" json:"tags,omitempty"`
	// contains filtered or unexported fields
}

func (*Workflow_Stream) Descriptor deprecated

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

Deprecated: Use Workflow_Stream.ProtoReflect.Descriptor instead.

func (*Workflow_Stream) GetBinlogSource

func (x *Workflow_Stream) GetBinlogSource() *dev9.BinlogSource

func (*Workflow_Stream) GetCopyStates

func (x *Workflow_Stream) GetCopyStates() []*Workflow_Stream_CopyState

func (*Workflow_Stream) GetDbName

func (x *Workflow_Stream) GetDbName() string

func (*Workflow_Stream) GetId

func (x *Workflow_Stream) GetId() int64

func (*Workflow_Stream) GetLogFetchError

func (x *Workflow_Stream) GetLogFetchError() string

func (*Workflow_Stream) GetLogs

func (x *Workflow_Stream) GetLogs() []*Workflow_Stream_Log

func (*Workflow_Stream) GetMessage

func (x *Workflow_Stream) GetMessage() string

func (*Workflow_Stream) GetPosition

func (x *Workflow_Stream) GetPosition() string

func (*Workflow_Stream) GetShard

func (x *Workflow_Stream) GetShard() string

func (*Workflow_Stream) GetState

func (x *Workflow_Stream) GetState() string

func (*Workflow_Stream) GetStopPosition

func (x *Workflow_Stream) GetStopPosition() string

func (*Workflow_Stream) GetTablet

func (x *Workflow_Stream) GetTablet() *dev2.TabletAlias

func (*Workflow_Stream) GetTags

func (x *Workflow_Stream) GetTags() []string

func (*Workflow_Stream) GetTimeUpdated

func (x *Workflow_Stream) GetTimeUpdated() *dev3.Time

func (*Workflow_Stream) GetTransactionTimestamp

func (x *Workflow_Stream) GetTransactionTimestamp() *dev3.Time

func (*Workflow_Stream) ProtoMessage

func (*Workflow_Stream) ProtoMessage()

func (*Workflow_Stream) ProtoReflect

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

func (*Workflow_Stream) Reset

func (x *Workflow_Stream) Reset()

func (*Workflow_Stream) String

func (x *Workflow_Stream) String() string

type Workflow_Stream_CopyState

type Workflow_Stream_CopyState struct {
	Table  string `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
	LastPk string `protobuf:"bytes,2,opt,name=last_pk,json=lastPk,proto3" json:"last_pk,omitempty"`
	// contains filtered or unexported fields
}

func (*Workflow_Stream_CopyState) Descriptor deprecated

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

Deprecated: Use Workflow_Stream_CopyState.ProtoReflect.Descriptor instead.

func (*Workflow_Stream_CopyState) GetLastPk

func (x *Workflow_Stream_CopyState) GetLastPk() string

func (*Workflow_Stream_CopyState) GetTable

func (x *Workflow_Stream_CopyState) GetTable() string

func (*Workflow_Stream_CopyState) ProtoMessage

func (*Workflow_Stream_CopyState) ProtoMessage()

func (*Workflow_Stream_CopyState) ProtoReflect

func (*Workflow_Stream_CopyState) Reset

func (x *Workflow_Stream_CopyState) Reset()

func (*Workflow_Stream_CopyState) String

func (x *Workflow_Stream_CopyState) String() string

type Workflow_Stream_Log

type Workflow_Stream_Log struct {
	Id        int64      `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	StreamId  int64      `protobuf:"varint,2,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	Type      string     `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	State     string     `protobuf:"bytes,4,opt,name=state,proto3" json:"state,omitempty"`
	CreatedAt *dev3.Time `protobuf:"bytes,5,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt *dev3.Time `protobuf:"bytes,6,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	Message   string     `protobuf:"bytes,7,opt,name=message,proto3" json:"message,omitempty"`
	Count     int64      `protobuf:"varint,8,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*Workflow_Stream_Log) Descriptor deprecated

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

Deprecated: Use Workflow_Stream_Log.ProtoReflect.Descriptor instead.

func (*Workflow_Stream_Log) GetCount

func (x *Workflow_Stream_Log) GetCount() int64

func (*Workflow_Stream_Log) GetCreatedAt

func (x *Workflow_Stream_Log) GetCreatedAt() *dev3.Time

func (*Workflow_Stream_Log) GetId

func (x *Workflow_Stream_Log) GetId() int64

func (*Workflow_Stream_Log) GetMessage

func (x *Workflow_Stream_Log) GetMessage() string

func (*Workflow_Stream_Log) GetState

func (x *Workflow_Stream_Log) GetState() string

func (*Workflow_Stream_Log) GetStreamId

func (x *Workflow_Stream_Log) GetStreamId() int64

func (*Workflow_Stream_Log) GetType

func (x *Workflow_Stream_Log) GetType() string

func (*Workflow_Stream_Log) GetUpdatedAt

func (x *Workflow_Stream_Log) GetUpdatedAt() *dev3.Time

func (*Workflow_Stream_Log) ProtoMessage

func (*Workflow_Stream_Log) ProtoMessage()

func (*Workflow_Stream_Log) ProtoReflect

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

func (*Workflow_Stream_Log) Reset

func (x *Workflow_Stream_Log) Reset()

func (*Workflow_Stream_Log) String

func (x *Workflow_Stream_Log) String() string

Jump to

Keyboard shortcuts

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