vtctldata

package
v0.11.0 Latest Latest
Warning

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

 Go to latest Published: Jul 27, 2021 License: Apache-2.0 Imports: 15 Imported by: 7

Documentation

Index

Constants

This section is empty.

Variables

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

Functions

This section is empty.

Types

type AddCellInfoRequest added in v0.11.0 

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

func (*AddCellInfoRequest) Descriptor deprecated added in v0.11.0 

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

Deprecated: Use AddCellInfoRequest.ProtoReflect.Descriptor instead.

func (*AddCellInfoRequest) GetCellInfo added in v0.11.0 

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

func (*AddCellInfoRequest) GetName added in v0.11.0 

func (x *AddCellInfoRequest) GetName() string

func (*AddCellInfoRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*AddCellInfoRequest) MarshalToVT added in v0.11.0 

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

func (*AddCellInfoRequest) MarshalVT added in v0.11.0 

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

func (*AddCellInfoRequest) ProtoMessage added in v0.11.0 

func (*AddCellInfoRequest) ProtoMessage()

func (*AddCellInfoRequest) ProtoReflect added in v0.11.0 

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

func (*AddCellInfoRequest) Reset added in v0.11.0 

func (x *AddCellInfoRequest) Reset()

func (*AddCellInfoRequest) SizeVT added in v0.11.0 

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

func (*AddCellInfoRequest) String added in v0.11.0 

func (x *AddCellInfoRequest) String() string

func (*AddCellInfoRequest) UnmarshalVT added in v0.11.0 

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

type AddCellInfoResponse added in v0.11.0 

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

func (*AddCellInfoResponse) Descriptor deprecated added in v0.11.0 

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

Deprecated: Use AddCellInfoResponse.ProtoReflect.Descriptor instead.

func (*AddCellInfoResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*AddCellInfoResponse) MarshalToVT added in v0.11.0 

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

func (*AddCellInfoResponse) MarshalVT added in v0.11.0 

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

func (*AddCellInfoResponse) ProtoMessage added in v0.11.0 

func (*AddCellInfoResponse) ProtoMessage()

func (*AddCellInfoResponse) ProtoReflect added in v0.11.0 

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

func (*AddCellInfoResponse) Reset added in v0.11.0 

func (x *AddCellInfoResponse) Reset()

func (*AddCellInfoResponse) SizeVT added in v0.11.0 

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

func (*AddCellInfoResponse) String added in v0.11.0 

func (x *AddCellInfoResponse) String() string

func (*AddCellInfoResponse) UnmarshalVT added in v0.11.0 

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

type AddCellsAliasRequest added in v0.11.0 

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

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

Deprecated: Use AddCellsAliasRequest.ProtoReflect.Descriptor instead.

func (*AddCellsAliasRequest) GetCells added in v0.11.0 

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

func (*AddCellsAliasRequest) GetName added in v0.11.0 

func (x *AddCellsAliasRequest) GetName() string

func (*AddCellsAliasRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*AddCellsAliasRequest) MarshalToVT added in v0.11.0 

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

func (*AddCellsAliasRequest) MarshalVT added in v0.11.0 

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

func (*AddCellsAliasRequest) ProtoMessage added in v0.11.0 

func (*AddCellsAliasRequest) ProtoMessage()

func (*AddCellsAliasRequest) ProtoReflect added in v0.11.0 

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

func (*AddCellsAliasRequest) Reset added in v0.11.0 

func (x *AddCellsAliasRequest) Reset()

func (*AddCellsAliasRequest) SizeVT added in v0.11.0 

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

func (*AddCellsAliasRequest) String added in v0.11.0 

func (x *AddCellsAliasRequest) String() string

func (*AddCellsAliasRequest) UnmarshalVT added in v0.11.0 

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

type AddCellsAliasResponse added in v0.11.0 

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

func (*AddCellsAliasResponse) Descriptor deprecated added in v0.11.0 

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

Deprecated: Use AddCellsAliasResponse.ProtoReflect.Descriptor instead.

func (*AddCellsAliasResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*AddCellsAliasResponse) MarshalToVT added in v0.11.0 

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

func (*AddCellsAliasResponse) MarshalVT added in v0.11.0 

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

func (*AddCellsAliasResponse) ProtoMessage added in v0.11.0 

func (*AddCellsAliasResponse) ProtoMessage()

func (*AddCellsAliasResponse) ProtoReflect added in v0.11.0 

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

func (*AddCellsAliasResponse) Reset added in v0.11.0 

func (x *AddCellsAliasResponse) Reset()

func (*AddCellsAliasResponse) SizeVT added in v0.11.0 

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

func (*AddCellsAliasResponse) String added in v0.11.0 

func (x *AddCellsAliasResponse) String() string

func (*AddCellsAliasResponse) UnmarshalVT added in v0.11.0 

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

type ApplyRoutingRulesRequest added in v0.11.0 

type ApplyRoutingRulesRequest struct {
	RoutingRules *vschema.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 added in v0.11.0 

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

Deprecated: Use ApplyRoutingRulesRequest.ProtoReflect.Descriptor instead.

func (*ApplyRoutingRulesRequest) GetRebuildCells added in v0.11.0 

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

func (*ApplyRoutingRulesRequest) GetRoutingRules added in v0.11.0 

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

func (*ApplyRoutingRulesRequest) GetSkipRebuild added in v0.11.0 

func (x *ApplyRoutingRulesRequest) GetSkipRebuild() bool

func (*ApplyRoutingRulesRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*ApplyRoutingRulesRequest) MarshalToVT added in v0.11.0 

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

func (*ApplyRoutingRulesRequest) MarshalVT added in v0.11.0 

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

func (*ApplyRoutingRulesRequest) ProtoMessage added in v0.11.0 

func (*ApplyRoutingRulesRequest) ProtoMessage()

func (*ApplyRoutingRulesRequest) ProtoReflect added in v0.11.0 

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

func (*ApplyRoutingRulesRequest) Reset added in v0.11.0 

func (x *ApplyRoutingRulesRequest) Reset()

func (*ApplyRoutingRulesRequest) SizeVT added in v0.11.0 

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

func (*ApplyRoutingRulesRequest) String added in v0.11.0 

func (x *ApplyRoutingRulesRequest) String() string

func (*ApplyRoutingRulesRequest) UnmarshalVT added in v0.11.0 

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

type ApplyRoutingRulesResponse added in v0.11.0 

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

func (*ApplyRoutingRulesResponse) Descriptor deprecated added in v0.11.0 

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

Deprecated: Use ApplyRoutingRulesResponse.ProtoReflect.Descriptor instead.

func (*ApplyRoutingRulesResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*ApplyRoutingRulesResponse) MarshalToVT added in v0.11.0 

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

func (*ApplyRoutingRulesResponse) MarshalVT added in v0.11.0 

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

func (*ApplyRoutingRulesResponse) ProtoMessage added in v0.11.0 

func (*ApplyRoutingRulesResponse) ProtoMessage()

func (*ApplyRoutingRulesResponse) ProtoReflect added in v0.11.0 

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

func (*ApplyRoutingRulesResponse) Reset added in v0.11.0 

func (x *ApplyRoutingRulesResponse) Reset()

func (*ApplyRoutingRulesResponse) SizeVT added in v0.11.0 

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

func (*ApplyRoutingRulesResponse) String added in v0.11.0 

func (x *ApplyRoutingRulesResponse) String() string

func (*ApplyRoutingRulesResponse) UnmarshalVT added in v0.11.0 

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

type ApplyVSchemaRequest added in v0.11.0 

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     *vschema.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 added in v0.11.0 

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

Deprecated: Use ApplyVSchemaRequest.ProtoReflect.Descriptor instead.

func (*ApplyVSchemaRequest) GetCells added in v0.11.0 

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

func (*ApplyVSchemaRequest) GetDryRun added in v0.11.0 

func (x *ApplyVSchemaRequest) GetDryRun() bool

func (*ApplyVSchemaRequest) GetKeyspace added in v0.11.0 

func (x *ApplyVSchemaRequest) GetKeyspace() string

func (*ApplyVSchemaRequest) GetSkipRebuild added in v0.11.0 

func (x *ApplyVSchemaRequest) GetSkipRebuild() bool

func (*ApplyVSchemaRequest) GetSql added in v0.11.0 

func (x *ApplyVSchemaRequest) GetSql() string

func (*ApplyVSchemaRequest) GetVSchema added in v0.11.0 

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

func (*ApplyVSchemaRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*ApplyVSchemaRequest) MarshalToVT added in v0.11.0 

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

func (*ApplyVSchemaRequest) MarshalVT added in v0.11.0 

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

func (*ApplyVSchemaRequest) ProtoMessage added in v0.11.0 

func (*ApplyVSchemaRequest) ProtoMessage()

func (*ApplyVSchemaRequest) ProtoReflect added in v0.11.0 

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

func (*ApplyVSchemaRequest) Reset added in v0.11.0 

func (x *ApplyVSchemaRequest) Reset()

func (*ApplyVSchemaRequest) SizeVT added in v0.11.0 

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

func (*ApplyVSchemaRequest) String added in v0.11.0 

func (x *ApplyVSchemaRequest) String() string

func (*ApplyVSchemaRequest) UnmarshalVT added in v0.11.0 

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

type ApplyVSchemaResponse added in v0.11.0 

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

func (*ApplyVSchemaResponse) Descriptor deprecated added in v0.11.0 

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

Deprecated: Use ApplyVSchemaResponse.ProtoReflect.Descriptor instead.

func (*ApplyVSchemaResponse) GetVSchema added in v0.11.0 

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

func (*ApplyVSchemaResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*ApplyVSchemaResponse) MarshalToVT added in v0.11.0 

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

func (*ApplyVSchemaResponse) MarshalVT added in v0.11.0 

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

func (*ApplyVSchemaResponse) ProtoMessage added in v0.11.0 

func (*ApplyVSchemaResponse) ProtoMessage()

func (*ApplyVSchemaResponse) ProtoReflect added in v0.11.0 

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

func (*ApplyVSchemaResponse) Reset added in v0.11.0 

func (x *ApplyVSchemaResponse) Reset()

func (*ApplyVSchemaResponse) SizeVT added in v0.11.0 

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

func (*ApplyVSchemaResponse) String added in v0.11.0 

func (x *ApplyVSchemaResponse) String() string

func (*ApplyVSchemaResponse) UnmarshalVT added in v0.11.0 

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

type ChangeTabletTypeRequest added in v0.10.0 

type ChangeTabletTypeRequest struct {
	TabletAlias *topodata.TabletAlias `protobuf:"bytes,1,opt,name=tablet_alias,json=tabletAlias,proto3" json:"tablet_alias,omitempty"`
	DbType      topodata.TabletType   `protobuf:"varint,2,opt,name=db_type,json=dbType,proto3,enum=topodata.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 added in v0.10.0 

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

Deprecated: Use ChangeTabletTypeRequest.ProtoReflect.Descriptor instead.

func (*ChangeTabletTypeRequest) GetDbType added in v0.10.0 

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

func (*ChangeTabletTypeRequest) GetDryRun added in v0.10.0 

func (x *ChangeTabletTypeRequest) GetDryRun() bool

func (*ChangeTabletTypeRequest) GetTabletAlias added in v0.10.0 

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

func (*ChangeTabletTypeRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*ChangeTabletTypeRequest) MarshalToVT added in v0.11.0 

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

func (*ChangeTabletTypeRequest) MarshalVT added in v0.11.0 

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

func (*ChangeTabletTypeRequest) ProtoMessage added in v0.10.0 

func (*ChangeTabletTypeRequest) ProtoMessage()

func (*ChangeTabletTypeRequest) ProtoReflect added in v0.11.0 

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

func (*ChangeTabletTypeRequest) Reset added in v0.10.0 

func (x *ChangeTabletTypeRequest) Reset()

func (*ChangeTabletTypeRequest) SizeVT added in v0.11.0 

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

func (*ChangeTabletTypeRequest) String added in v0.10.0 

func (x *ChangeTabletTypeRequest) String() string

func (*ChangeTabletTypeRequest) UnmarshalVT added in v0.11.0 

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

type ChangeTabletTypeResponse added in v0.10.0 

type ChangeTabletTypeResponse struct {
	BeforeTablet *topodata.Tablet `protobuf:"bytes,1,opt,name=before_tablet,json=beforeTablet,proto3" json:"before_tablet,omitempty"`
	AfterTablet  *topodata.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 added in v0.10.0 

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

Deprecated: Use ChangeTabletTypeResponse.ProtoReflect.Descriptor instead.

func (*ChangeTabletTypeResponse) GetAfterTablet added in v0.10.0 

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

func (*ChangeTabletTypeResponse) GetBeforeTablet added in v0.10.0 

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

func (*ChangeTabletTypeResponse) GetWasDryRun added in v0.10.0 

func (x *ChangeTabletTypeResponse) GetWasDryRun() bool

func (*ChangeTabletTypeResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*ChangeTabletTypeResponse) MarshalToVT added in v0.11.0 

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

func (*ChangeTabletTypeResponse) MarshalVT added in v0.11.0 

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

func (*ChangeTabletTypeResponse) ProtoMessage added in v0.10.0 

func (*ChangeTabletTypeResponse) ProtoMessage()

func (*ChangeTabletTypeResponse) ProtoReflect added in v0.11.0 

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

func (*ChangeTabletTypeResponse) Reset added in v0.10.0 

func (x *ChangeTabletTypeResponse) Reset()

func (*ChangeTabletTypeResponse) SizeVT added in v0.11.0 

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

func (*ChangeTabletTypeResponse) String added in v0.10.0 

func (x *ChangeTabletTypeResponse) String() string

func (*ChangeTabletTypeResponse) UnmarshalVT added in v0.11.0 

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

type CreateKeyspaceRequest added in v0.10.0 

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"`
	// ShardingColumnName specifies the column to use for sharding operations.
	ShardingColumnName string `protobuf:"bytes,4,opt,name=sharding_column_name,json=shardingColumnName,proto3" json:"sharding_column_name,omitempty"`
	// ShardingColumnType specifies the type of the column to use for sharding
	// operations.
	ShardingColumnType topodata.KeyspaceIdType `` /* 147-byte string literal not displayed */
	// ServedFroms specifies a set of db_type:keyspace pairs used to serve
	// traffic for the keyspace.
	ServedFroms []*topodata.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 topodata.KeyspaceType `protobuf:"varint,7,opt,name=type,proto3,enum=topodata.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 *vttime.Time `protobuf:"bytes,9,opt,name=snapshot_time,json=snapshotTime,proto3" json:"snapshot_time,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use CreateKeyspaceRequest.ProtoReflect.Descriptor instead.

func (*CreateKeyspaceRequest) GetAllowEmptyVSchema added in v0.10.0 

func (x *CreateKeyspaceRequest) GetAllowEmptyVSchema() bool

func (*CreateKeyspaceRequest) GetBaseKeyspace added in v0.10.0 

func (x *CreateKeyspaceRequest) GetBaseKeyspace() string

func (*CreateKeyspaceRequest) GetForce added in v0.10.0 

func (x *CreateKeyspaceRequest) GetForce() bool

func (*CreateKeyspaceRequest) GetName added in v0.10.0 

func (x *CreateKeyspaceRequest) GetName() string

func (*CreateKeyspaceRequest) GetServedFroms added in v0.10.0 

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

func (*CreateKeyspaceRequest) GetShardingColumnName added in v0.10.0 

func (x *CreateKeyspaceRequest) GetShardingColumnName() string

func (*CreateKeyspaceRequest) GetShardingColumnType added in v0.10.0 

func (x *CreateKeyspaceRequest) GetShardingColumnType() topodata.KeyspaceIdType

func (*CreateKeyspaceRequest) GetSnapshotTime added in v0.10.0 

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

func (*CreateKeyspaceRequest) GetType added in v0.10.0 

func (x *CreateKeyspaceRequest) GetType() topodata.KeyspaceType

func (*CreateKeyspaceRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*CreateKeyspaceRequest) MarshalToVT added in v0.11.0 

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

func (*CreateKeyspaceRequest) MarshalVT added in v0.11.0 

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

func (*CreateKeyspaceRequest) ProtoMessage added in v0.10.0 

func (*CreateKeyspaceRequest) ProtoMessage()

func (*CreateKeyspaceRequest) ProtoReflect added in v0.11.0 

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

func (*CreateKeyspaceRequest) Reset added in v0.10.0 

func (x *CreateKeyspaceRequest) Reset()

func (*CreateKeyspaceRequest) SizeVT added in v0.11.0 

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

func (*CreateKeyspaceRequest) String added in v0.10.0 

func (x *CreateKeyspaceRequest) String() string

func (*CreateKeyspaceRequest) UnmarshalVT added in v0.11.0 

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

type CreateKeyspaceResponse added in v0.10.0 

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

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

Deprecated: Use CreateKeyspaceResponse.ProtoReflect.Descriptor instead.

func (*CreateKeyspaceResponse) GetKeyspace added in v0.10.0 

func (x *CreateKeyspaceResponse) GetKeyspace() *Keyspace

func (*CreateKeyspaceResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*CreateKeyspaceResponse) MarshalToVT added in v0.11.0 

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

func (*CreateKeyspaceResponse) MarshalVT added in v0.11.0 

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

func (*CreateKeyspaceResponse) ProtoMessage added in v0.10.0 

func (*CreateKeyspaceResponse) ProtoMessage()

func (*CreateKeyspaceResponse) ProtoReflect added in v0.11.0 

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

func (*CreateKeyspaceResponse) Reset added in v0.10.0 

func (x *CreateKeyspaceResponse) Reset()

func (*CreateKeyspaceResponse) SizeVT added in v0.11.0 

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

func (*CreateKeyspaceResponse) String added in v0.10.0 

func (x *CreateKeyspaceResponse) String() string

func (*CreateKeyspaceResponse) UnmarshalVT added in v0.11.0 

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

type CreateShardRequest added in v0.10.0 

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

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

Deprecated: Use CreateShardRequest.ProtoReflect.Descriptor instead.

func (*CreateShardRequest) GetForce added in v0.10.0 

func (x *CreateShardRequest) GetForce() bool

func (*CreateShardRequest) GetIncludeParent added in v0.10.0 

func (x *CreateShardRequest) GetIncludeParent() bool

func (*CreateShardRequest) GetKeyspace added in v0.10.0 

func (x *CreateShardRequest) GetKeyspace() string

func (*CreateShardRequest) GetShardName added in v0.10.0 

func (x *CreateShardRequest) GetShardName() string

func (*CreateShardRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*CreateShardRequest) MarshalToVT added in v0.11.0 

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

func (*CreateShardRequest) MarshalVT added in v0.11.0 

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

func (*CreateShardRequest) ProtoMessage added in v0.10.0 

func (*CreateShardRequest) ProtoMessage()

func (*CreateShardRequest) ProtoReflect added in v0.11.0 

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

func (*CreateShardRequest) Reset added in v0.10.0 

func (x *CreateShardRequest) Reset()

func (*CreateShardRequest) SizeVT added in v0.11.0 

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

func (*CreateShardRequest) String added in v0.10.0 

func (x *CreateShardRequest) String() string

func (*CreateShardRequest) UnmarshalVT added in v0.11.0 

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

type CreateShardResponse added in v0.10.0 

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

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

Deprecated: Use CreateShardResponse.ProtoReflect.Descriptor instead.

func (*CreateShardResponse) GetKeyspace added in v0.10.0 

func (x *CreateShardResponse) GetKeyspace() *Keyspace

func (*CreateShardResponse) GetShard added in v0.10.0 

func (x *CreateShardResponse) GetShard() *Shard

func (*CreateShardResponse) GetShardAlreadyExists added in v0.10.0 

func (x *CreateShardResponse) GetShardAlreadyExists() bool

func (*CreateShardResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*CreateShardResponse) MarshalToVT added in v0.11.0 

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

func (*CreateShardResponse) MarshalVT added in v0.11.0 

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

func (*CreateShardResponse) ProtoMessage added in v0.10.0 

func (*CreateShardResponse) ProtoMessage()

func (*CreateShardResponse) ProtoReflect added in v0.11.0 

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

func (*CreateShardResponse) Reset added in v0.10.0 

func (x *CreateShardResponse) Reset()

func (*CreateShardResponse) SizeVT added in v0.11.0 

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

func (*CreateShardResponse) String added in v0.10.0 

func (x *CreateShardResponse) String() string

func (*CreateShardResponse) UnmarshalVT added in v0.11.0 

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

type DeleteCellInfoRequest added in v0.11.0 

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

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

Deprecated: Use DeleteCellInfoRequest.ProtoReflect.Descriptor instead.

func (*DeleteCellInfoRequest) GetForce added in v0.11.0 

func (x *DeleteCellInfoRequest) GetForce() bool

func (*DeleteCellInfoRequest) GetName added in v0.11.0 

func (x *DeleteCellInfoRequest) GetName() string

func (*DeleteCellInfoRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*DeleteCellInfoRequest) MarshalToVT added in v0.11.0 

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

func (*DeleteCellInfoRequest) MarshalVT added in v0.11.0 

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

func (*DeleteCellInfoRequest) ProtoMessage added in v0.11.0 

func (*DeleteCellInfoRequest) ProtoMessage()

func (*DeleteCellInfoRequest) ProtoReflect added in v0.11.0 

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

func (*DeleteCellInfoRequest) Reset added in v0.11.0 

func (x *DeleteCellInfoRequest) Reset()

func (*DeleteCellInfoRequest) SizeVT added in v0.11.0 

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

func (*DeleteCellInfoRequest) String added in v0.11.0 

func (x *DeleteCellInfoRequest) String() string

func (*DeleteCellInfoRequest) UnmarshalVT added in v0.11.0 

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

type DeleteCellInfoResponse added in v0.11.0 

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

func (*DeleteCellInfoResponse) Descriptor deprecated added in v0.11.0 

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

Deprecated: Use DeleteCellInfoResponse.ProtoReflect.Descriptor instead.

func (*DeleteCellInfoResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*DeleteCellInfoResponse) MarshalToVT added in v0.11.0 

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

func (*DeleteCellInfoResponse) MarshalVT added in v0.11.0 

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

func (*DeleteCellInfoResponse) ProtoMessage added in v0.11.0 

func (*DeleteCellInfoResponse) ProtoMessage()

func (*DeleteCellInfoResponse) ProtoReflect added in v0.11.0 

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

func (*DeleteCellInfoResponse) Reset added in v0.11.0 

func (x *DeleteCellInfoResponse) Reset()

func (*DeleteCellInfoResponse) SizeVT added in v0.11.0 

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

func (*DeleteCellInfoResponse) String added in v0.11.0 

func (x *DeleteCellInfoResponse) String() string

func (*DeleteCellInfoResponse) UnmarshalVT added in v0.11.0 

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

type DeleteCellsAliasRequest added in v0.11.0 

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

func (*DeleteCellsAliasRequest) Descriptor deprecated added in v0.11.0 

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

Deprecated: Use DeleteCellsAliasRequest.ProtoReflect.Descriptor instead.

func (*DeleteCellsAliasRequest) GetName added in v0.11.0 

func (x *DeleteCellsAliasRequest) GetName() string

func (*DeleteCellsAliasRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*DeleteCellsAliasRequest) MarshalToVT added in v0.11.0 

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

func (*DeleteCellsAliasRequest) MarshalVT added in v0.11.0 

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

func (*DeleteCellsAliasRequest) ProtoMessage added in v0.11.0 

func (*DeleteCellsAliasRequest) ProtoMessage()

func (*DeleteCellsAliasRequest) ProtoReflect added in v0.11.0 

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

func (*DeleteCellsAliasRequest) Reset added in v0.11.0 

func (x *DeleteCellsAliasRequest) Reset()

func (*DeleteCellsAliasRequest) SizeVT added in v0.11.0 

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

func (*DeleteCellsAliasRequest) String added in v0.11.0 

func (x *DeleteCellsAliasRequest) String() string

func (*DeleteCellsAliasRequest) UnmarshalVT added in v0.11.0 

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

type DeleteCellsAliasResponse added in v0.11.0 

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

func (*DeleteCellsAliasResponse) Descriptor deprecated added in v0.11.0 

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

Deprecated: Use DeleteCellsAliasResponse.ProtoReflect.Descriptor instead.

func (*DeleteCellsAliasResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*DeleteCellsAliasResponse) MarshalToVT added in v0.11.0 

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

func (*DeleteCellsAliasResponse) MarshalVT added in v0.11.0 

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

func (*DeleteCellsAliasResponse) ProtoMessage added in v0.11.0 

func (*DeleteCellsAliasResponse) ProtoMessage()

func (*DeleteCellsAliasResponse) ProtoReflect added in v0.11.0 

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

func (*DeleteCellsAliasResponse) Reset added in v0.11.0 

func (x *DeleteCellsAliasResponse) Reset()

func (*DeleteCellsAliasResponse) SizeVT added in v0.11.0 

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

func (*DeleteCellsAliasResponse) String added in v0.11.0 

func (x *DeleteCellsAliasResponse) String() string

func (*DeleteCellsAliasResponse) UnmarshalVT added in v0.11.0 

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

type DeleteKeyspaceRequest added in v0.10.0 

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

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

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

Deprecated: Use DeleteKeyspaceRequest.ProtoReflect.Descriptor instead.

func (*DeleteKeyspaceRequest) GetKeyspace added in v0.10.0 

func (x *DeleteKeyspaceRequest) GetKeyspace() string

func (*DeleteKeyspaceRequest) GetRecursive added in v0.10.0 

func (x *DeleteKeyspaceRequest) GetRecursive() bool

func (*DeleteKeyspaceRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*DeleteKeyspaceRequest) MarshalToVT added in v0.11.0 

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

func (*DeleteKeyspaceRequest) MarshalVT added in v0.11.0 

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

func (*DeleteKeyspaceRequest) ProtoMessage added in v0.10.0 

func (*DeleteKeyspaceRequest) ProtoMessage()

func (*DeleteKeyspaceRequest) ProtoReflect added in v0.11.0 

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

func (*DeleteKeyspaceRequest) Reset added in v0.10.0 

func (x *DeleteKeyspaceRequest) Reset()

func (*DeleteKeyspaceRequest) SizeVT added in v0.11.0 

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

func (*DeleteKeyspaceRequest) String added in v0.10.0 

func (x *DeleteKeyspaceRequest) String() string

func (*DeleteKeyspaceRequest) UnmarshalVT added in v0.11.0 

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

type DeleteKeyspaceResponse added in v0.10.0 

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

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

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

Deprecated: Use DeleteKeyspaceResponse.ProtoReflect.Descriptor instead.

func (*DeleteKeyspaceResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*DeleteKeyspaceResponse) MarshalToVT added in v0.11.0 

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

func (*DeleteKeyspaceResponse) MarshalVT added in v0.11.0 

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

func (*DeleteKeyspaceResponse) ProtoMessage added in v0.10.0 

func (*DeleteKeyspaceResponse) ProtoMessage()

func (*DeleteKeyspaceResponse) ProtoReflect added in v0.11.0 

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

func (*DeleteKeyspaceResponse) Reset added in v0.10.0 

func (x *DeleteKeyspaceResponse) Reset()

func (*DeleteKeyspaceResponse) SizeVT added in v0.11.0 

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

func (*DeleteKeyspaceResponse) String added in v0.10.0 

func (x *DeleteKeyspaceResponse) String() string

func (*DeleteKeyspaceResponse) UnmarshalVT added in v0.11.0 

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

type DeleteShardsRequest added in v0.10.0 

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

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

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

Deprecated: Use DeleteShardsRequest.ProtoReflect.Descriptor instead.

func (*DeleteShardsRequest) GetEvenIfServing added in v0.10.0 

func (x *DeleteShardsRequest) GetEvenIfServing() bool

func (*DeleteShardsRequest) GetRecursive added in v0.10.0 

func (x *DeleteShardsRequest) GetRecursive() bool

func (*DeleteShardsRequest) GetShards added in v0.10.0 

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

func (*DeleteShardsRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*DeleteShardsRequest) MarshalToVT added in v0.11.0 

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

func (*DeleteShardsRequest) MarshalVT added in v0.11.0 

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

func (*DeleteShardsRequest) ProtoMessage added in v0.10.0 

func (*DeleteShardsRequest) ProtoMessage()

func (*DeleteShardsRequest) ProtoReflect added in v0.11.0 

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

func (*DeleteShardsRequest) Reset added in v0.10.0 

func (x *DeleteShardsRequest) Reset()

func (*DeleteShardsRequest) SizeVT added in v0.11.0 

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

func (*DeleteShardsRequest) String added in v0.10.0 

func (x *DeleteShardsRequest) String() string

func (*DeleteShardsRequest) UnmarshalVT added in v0.11.0 

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

type DeleteShardsResponse added in v0.10.0 

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

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

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

Deprecated: Use DeleteShardsResponse.ProtoReflect.Descriptor instead.

func (*DeleteShardsResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*DeleteShardsResponse) MarshalToVT added in v0.11.0 

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

func (*DeleteShardsResponse) MarshalVT added in v0.11.0 

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

func (*DeleteShardsResponse) ProtoMessage added in v0.10.0 

func (*DeleteShardsResponse) ProtoMessage()

func (*DeleteShardsResponse) ProtoReflect added in v0.11.0 

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

func (*DeleteShardsResponse) Reset added in v0.10.0 

func (x *DeleteShardsResponse) Reset()

func (*DeleteShardsResponse) SizeVT added in v0.11.0 

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

func (*DeleteShardsResponse) String added in v0.10.0 

func (x *DeleteShardsResponse) String() string

func (*DeleteShardsResponse) UnmarshalVT added in v0.11.0 

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

type DeleteTabletsRequest added in v0.10.0 

type DeleteTabletsRequest struct {

	// TabletAliases is the list of tablets to delete.
	TabletAliases []*topodata.TabletAlias `protobuf:"bytes,1,rep,name=tablet_aliases,json=tabletAliases,proto3" json:"tablet_aliases,omitempty"`
	// AllowPrimary allows for the master/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 added in v0.10.0 

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

Deprecated: Use DeleteTabletsRequest.ProtoReflect.Descriptor instead.

func (*DeleteTabletsRequest) GetAllowPrimary added in v0.10.0 

func (x *DeleteTabletsRequest) GetAllowPrimary() bool

func (*DeleteTabletsRequest) GetTabletAliases added in v0.10.0 

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

func (*DeleteTabletsRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*DeleteTabletsRequest) MarshalToVT added in v0.11.0 

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

func (*DeleteTabletsRequest) MarshalVT added in v0.11.0 

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

func (*DeleteTabletsRequest) ProtoMessage added in v0.10.0 

func (*DeleteTabletsRequest) ProtoMessage()

func (*DeleteTabletsRequest) ProtoReflect added in v0.11.0 

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

func (*DeleteTabletsRequest) Reset added in v0.10.0 

func (x *DeleteTabletsRequest) Reset()

func (*DeleteTabletsRequest) SizeVT added in v0.11.0 

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

func (*DeleteTabletsRequest) String added in v0.10.0 

func (x *DeleteTabletsRequest) String() string

func (*DeleteTabletsRequest) UnmarshalVT added in v0.11.0 

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

type DeleteTabletsResponse added in v0.10.0 

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

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

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

Deprecated: Use DeleteTabletsResponse.ProtoReflect.Descriptor instead.

func (*DeleteTabletsResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*DeleteTabletsResponse) MarshalToVT added in v0.11.0 

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

func (*DeleteTabletsResponse) MarshalVT added in v0.11.0 

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

func (*DeleteTabletsResponse) ProtoMessage added in v0.10.0 

func (*DeleteTabletsResponse) ProtoMessage()

func (*DeleteTabletsResponse) ProtoReflect added in v0.11.0 

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

func (*DeleteTabletsResponse) Reset added in v0.10.0 

func (x *DeleteTabletsResponse) Reset()

func (*DeleteTabletsResponse) SizeVT added in v0.11.0 

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

func (*DeleteTabletsResponse) String added in v0.10.0 

func (x *DeleteTabletsResponse) String() string

func (*DeleteTabletsResponse) UnmarshalVT added in v0.11.0 

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

type EmergencyReparentShardRequest added in v0.10.0 

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 *topodata.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 []*topodata.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 *vttime.Duration `protobuf:"bytes,5,opt,name=wait_replicas_timeout,json=waitReplicasTimeout,proto3" json:"wait_replicas_timeout,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use EmergencyReparentShardRequest.ProtoReflect.Descriptor instead.

func (*EmergencyReparentShardRequest) GetIgnoreReplicas added in v0.10.0 

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

func (*EmergencyReparentShardRequest) GetKeyspace added in v0.10.0 

func (x *EmergencyReparentShardRequest) GetKeyspace() string

func (*EmergencyReparentShardRequest) GetNewPrimary added in v0.10.0 

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

func (*EmergencyReparentShardRequest) GetShard added in v0.10.0 

func (x *EmergencyReparentShardRequest) GetShard() string

func (*EmergencyReparentShardRequest) GetWaitReplicasTimeout added in v0.10.0 

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

func (*EmergencyReparentShardRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*EmergencyReparentShardRequest) MarshalToVT added in v0.11.0 

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

func (*EmergencyReparentShardRequest) MarshalVT added in v0.11.0 

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

func (*EmergencyReparentShardRequest) ProtoMessage added in v0.10.0 

func (*EmergencyReparentShardRequest) ProtoMessage()

func (*EmergencyReparentShardRequest) ProtoReflect added in v0.11.0 

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

func (*EmergencyReparentShardRequest) Reset added in v0.10.0 

func (x *EmergencyReparentShardRequest) Reset()

func (*EmergencyReparentShardRequest) SizeVT added in v0.11.0 

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

func (*EmergencyReparentShardRequest) String added in v0.10.0 

func (x *EmergencyReparentShardRequest) String() string

func (*EmergencyReparentShardRequest) UnmarshalVT added in v0.11.0 

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

type EmergencyReparentShardResponse added in v0.10.0 

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 *topodata.TabletAlias `protobuf:"bytes,3,opt,name=promoted_primary,json=promotedPrimary,proto3" json:"promoted_primary,omitempty"`
	Events          []*logutil.Event      `protobuf:"bytes,4,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use EmergencyReparentShardResponse.ProtoReflect.Descriptor instead.

func (*EmergencyReparentShardResponse) GetEvents added in v0.10.0 

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

func (*EmergencyReparentShardResponse) GetKeyspace added in v0.10.0 

func (x *EmergencyReparentShardResponse) GetKeyspace() string

func (*EmergencyReparentShardResponse) GetPromotedPrimary added in v0.10.0 

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

func (*EmergencyReparentShardResponse) GetShard added in v0.10.0 

func (x *EmergencyReparentShardResponse) GetShard() string

func (*EmergencyReparentShardResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*EmergencyReparentShardResponse) MarshalToVT added in v0.11.0 

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

func (*EmergencyReparentShardResponse) MarshalVT added in v0.11.0 

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

func (*EmergencyReparentShardResponse) ProtoMessage added in v0.10.0 

func (*EmergencyReparentShardResponse) ProtoMessage()

func (*EmergencyReparentShardResponse) ProtoReflect added in v0.11.0 

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

func (*EmergencyReparentShardResponse) Reset added in v0.10.0 

func (x *EmergencyReparentShardResponse) Reset()

func (*EmergencyReparentShardResponse) SizeVT added in v0.11.0 

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

func (*EmergencyReparentShardResponse) String added in v0.10.0 

func (x *EmergencyReparentShardResponse) String() string

func (*EmergencyReparentShardResponse) UnmarshalVT added in v0.11.0 

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

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

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

func (*ExecuteVtctlCommandRequest) MarshalToVT added in v0.11.0 

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

func (*ExecuteVtctlCommandRequest) MarshalVT added in v0.11.0 

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

func (*ExecuteVtctlCommandRequest) ProtoMessage 

func (*ExecuteVtctlCommandRequest) ProtoMessage()

func (*ExecuteVtctlCommandRequest) ProtoReflect added in v0.11.0 

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

func (*ExecuteVtctlCommandRequest) Reset 

func (x *ExecuteVtctlCommandRequest) Reset()

func (*ExecuteVtctlCommandRequest) SizeVT added in v0.11.0 

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

func (*ExecuteVtctlCommandRequest) String 

func (x *ExecuteVtctlCommandRequest) String() string

func (*ExecuteVtctlCommandRequest) UnmarshalVT added in v0.11.0 

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

type ExecuteVtctlCommandResponse 

type ExecuteVtctlCommandResponse struct {
	Event *logutil.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() *logutil.Event

func (*ExecuteVtctlCommandResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*ExecuteVtctlCommandResponse) MarshalToVT added in v0.11.0 

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

func (*ExecuteVtctlCommandResponse) MarshalVT added in v0.11.0 

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

func (*ExecuteVtctlCommandResponse) ProtoMessage 

func (*ExecuteVtctlCommandResponse) ProtoMessage()

func (*ExecuteVtctlCommandResponse) ProtoReflect added in v0.11.0 

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

func (*ExecuteVtctlCommandResponse) Reset 

func (x *ExecuteVtctlCommandResponse) Reset()

func (*ExecuteVtctlCommandResponse) SizeVT added in v0.11.0 

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

func (*ExecuteVtctlCommandResponse) String 

func (x *ExecuteVtctlCommandResponse) String() string

func (*ExecuteVtctlCommandResponse) UnmarshalVT added in v0.11.0 

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

type FindAllShardsInKeyspaceRequest added in v0.9.0 

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

func (*FindAllShardsInKeyspaceRequest) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use FindAllShardsInKeyspaceRequest.ProtoReflect.Descriptor instead.

func (*FindAllShardsInKeyspaceRequest) GetKeyspace added in v0.9.0 

func (x *FindAllShardsInKeyspaceRequest) GetKeyspace() string

func (*FindAllShardsInKeyspaceRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*FindAllShardsInKeyspaceRequest) MarshalToVT added in v0.11.0 

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

func (*FindAllShardsInKeyspaceRequest) MarshalVT added in v0.11.0 

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

func (*FindAllShardsInKeyspaceRequest) ProtoMessage added in v0.9.0 

func (*FindAllShardsInKeyspaceRequest) ProtoMessage()

func (*FindAllShardsInKeyspaceRequest) ProtoReflect added in v0.11.0 

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

func (*FindAllShardsInKeyspaceRequest) Reset added in v0.9.0 

func (x *FindAllShardsInKeyspaceRequest) Reset()

func (*FindAllShardsInKeyspaceRequest) SizeVT added in v0.11.0 

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

func (*FindAllShardsInKeyspaceRequest) String added in v0.9.0 

func (x *FindAllShardsInKeyspaceRequest) String() string

func (*FindAllShardsInKeyspaceRequest) UnmarshalVT added in v0.11.0 

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

type FindAllShardsInKeyspaceResponse added in v0.9.0 

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

func (*FindAllShardsInKeyspaceResponse) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use FindAllShardsInKeyspaceResponse.ProtoReflect.Descriptor instead.

func (*FindAllShardsInKeyspaceResponse) GetShards added in v0.9.0 

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

func (*FindAllShardsInKeyspaceResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*FindAllShardsInKeyspaceResponse) MarshalToVT added in v0.11.0 

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

func (*FindAllShardsInKeyspaceResponse) MarshalVT added in v0.11.0 

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

func (*FindAllShardsInKeyspaceResponse) ProtoMessage added in v0.9.0 

func (*FindAllShardsInKeyspaceResponse) ProtoMessage()

func (*FindAllShardsInKeyspaceResponse) ProtoReflect added in v0.11.0 

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

func (*FindAllShardsInKeyspaceResponse) Reset added in v0.9.0 

func (x *FindAllShardsInKeyspaceResponse) Reset()

func (*FindAllShardsInKeyspaceResponse) SizeVT added in v0.11.0 

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

func (*FindAllShardsInKeyspaceResponse) String added in v0.9.0 

func (x *FindAllShardsInKeyspaceResponse) String() string

func (*FindAllShardsInKeyspaceResponse) UnmarshalVT added in v0.11.0 

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

type GetBackupsRequest added in v0.10.0 

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

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

Deprecated: Use GetBackupsRequest.ProtoReflect.Descriptor instead.

func (*GetBackupsRequest) GetDetailed added in v0.11.0 

func (x *GetBackupsRequest) GetDetailed() bool

func (*GetBackupsRequest) GetDetailedLimit added in v0.11.0 

func (x *GetBackupsRequest) GetDetailedLimit() uint32

func (*GetBackupsRequest) GetKeyspace added in v0.10.0 

func (x *GetBackupsRequest) GetKeyspace() string

func (*GetBackupsRequest) GetLimit added in v0.11.0 

func (x *GetBackupsRequest) GetLimit() uint32

func (*GetBackupsRequest) GetShard added in v0.10.0 

func (x *GetBackupsRequest) GetShard() string

func (*GetBackupsRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*GetBackupsRequest) MarshalToVT added in v0.11.0 

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

func (*GetBackupsRequest) MarshalVT added in v0.11.0 

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

func (*GetBackupsRequest) ProtoMessage added in v0.10.0 

func (*GetBackupsRequest) ProtoMessage()

func (*GetBackupsRequest) ProtoReflect added in v0.11.0 

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

func (*GetBackupsRequest) Reset added in v0.10.0 

func (x *GetBackupsRequest) Reset()

func (*GetBackupsRequest) SizeVT added in v0.11.0 

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

func (*GetBackupsRequest) String added in v0.10.0 

func (x *GetBackupsRequest) String() string

func (*GetBackupsRequest) UnmarshalVT added in v0.11.0 

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

type GetBackupsResponse added in v0.10.0 

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

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

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

Deprecated: Use GetBackupsResponse.ProtoReflect.Descriptor instead.

func (*GetBackupsResponse) GetBackups added in v0.10.0 

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

func (*GetBackupsResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*GetBackupsResponse) MarshalToVT added in v0.11.0 

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

func (*GetBackupsResponse) MarshalVT added in v0.11.0 

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

func (*GetBackupsResponse) ProtoMessage added in v0.10.0 

func (*GetBackupsResponse) ProtoMessage()

func (*GetBackupsResponse) ProtoReflect added in v0.11.0 

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

func (*GetBackupsResponse) Reset added in v0.10.0 

func (x *GetBackupsResponse) Reset()

func (*GetBackupsResponse) SizeVT added in v0.11.0 

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

func (*GetBackupsResponse) String added in v0.10.0 

func (x *GetBackupsResponse) String() string

func (*GetBackupsResponse) UnmarshalVT added in v0.11.0 

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

type GetCellInfoNamesRequest added in v0.10.0 

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

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

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

Deprecated: Use GetCellInfoNamesRequest.ProtoReflect.Descriptor instead.

func (*GetCellInfoNamesRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*GetCellInfoNamesRequest) MarshalToVT added in v0.11.0 

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

func (*GetCellInfoNamesRequest) MarshalVT added in v0.11.0 

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

func (*GetCellInfoNamesRequest) ProtoMessage added in v0.10.0 

func (*GetCellInfoNamesRequest) ProtoMessage()

func (*GetCellInfoNamesRequest) ProtoReflect added in v0.11.0 

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

func (*GetCellInfoNamesRequest) Reset added in v0.10.0 

func (x *GetCellInfoNamesRequest) Reset()

func (*GetCellInfoNamesRequest) SizeVT added in v0.11.0 

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

func (*GetCellInfoNamesRequest) String added in v0.10.0 

func (x *GetCellInfoNamesRequest) String() string

func (*GetCellInfoNamesRequest) UnmarshalVT added in v0.11.0 

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

type GetCellInfoNamesResponse added in v0.10.0 

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

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

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

Deprecated: Use GetCellInfoNamesResponse.ProtoReflect.Descriptor instead.

func (*GetCellInfoNamesResponse) GetNames added in v0.10.0 

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

func (*GetCellInfoNamesResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*GetCellInfoNamesResponse) MarshalToVT added in v0.11.0 

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

func (*GetCellInfoNamesResponse) MarshalVT added in v0.11.0 

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

func (*GetCellInfoNamesResponse) ProtoMessage added in v0.10.0 

func (*GetCellInfoNamesResponse) ProtoMessage()

func (*GetCellInfoNamesResponse) ProtoReflect added in v0.11.0 

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

func (*GetCellInfoNamesResponse) Reset added in v0.10.0 

func (x *GetCellInfoNamesResponse) Reset()

func (*GetCellInfoNamesResponse) SizeVT added in v0.11.0 

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

func (*GetCellInfoNamesResponse) String added in v0.10.0 

func (x *GetCellInfoNamesResponse) String() string

func (*GetCellInfoNamesResponse) UnmarshalVT added in v0.11.0 

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

type GetCellInfoRequest added in v0.10.0 

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

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

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

Deprecated: Use GetCellInfoRequest.ProtoReflect.Descriptor instead.

func (*GetCellInfoRequest) GetCell added in v0.10.0 

func (x *GetCellInfoRequest) GetCell() string

func (*GetCellInfoRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*GetCellInfoRequest) MarshalToVT added in v0.11.0 

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

func (*GetCellInfoRequest) MarshalVT added in v0.11.0 

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

func (*GetCellInfoRequest) ProtoMessage added in v0.10.0 

func (*GetCellInfoRequest) ProtoMessage()

func (*GetCellInfoRequest) ProtoReflect added in v0.11.0 

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

func (*GetCellInfoRequest) Reset added in v0.10.0 

func (x *GetCellInfoRequest) Reset()

func (*GetCellInfoRequest) SizeVT added in v0.11.0 

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

func (*GetCellInfoRequest) String added in v0.10.0 

func (x *GetCellInfoRequest) String() string

func (*GetCellInfoRequest) UnmarshalVT added in v0.11.0 

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

type GetCellInfoResponse added in v0.10.0 

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

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

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

Deprecated: Use GetCellInfoResponse.ProtoReflect.Descriptor instead.

func (*GetCellInfoResponse) GetCellInfo added in v0.10.0 

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

func (*GetCellInfoResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*GetCellInfoResponse) MarshalToVT added in v0.11.0 

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

func (*GetCellInfoResponse) MarshalVT added in v0.11.0 

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

func (*GetCellInfoResponse) ProtoMessage added in v0.10.0 

func (*GetCellInfoResponse) ProtoMessage()

func (*GetCellInfoResponse) ProtoReflect added in v0.11.0 

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

func (*GetCellInfoResponse) Reset added in v0.10.0 

func (x *GetCellInfoResponse) Reset()

func (*GetCellInfoResponse) SizeVT added in v0.11.0 

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

func (*GetCellInfoResponse) String added in v0.10.0 

func (x *GetCellInfoResponse) String() string

func (*GetCellInfoResponse) UnmarshalVT added in v0.11.0 

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

type GetCellsAliasesRequest added in v0.10.0 

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

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

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

Deprecated: Use GetCellsAliasesRequest.ProtoReflect.Descriptor instead.

func (*GetCellsAliasesRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*GetCellsAliasesRequest) MarshalToVT added in v0.11.0 

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

func (*GetCellsAliasesRequest) MarshalVT added in v0.11.0 

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

func (*GetCellsAliasesRequest) ProtoMessage added in v0.10.0 

func (*GetCellsAliasesRequest) ProtoMessage()

func (*GetCellsAliasesRequest) ProtoReflect added in v0.11.0 

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

func (*GetCellsAliasesRequest) Reset added in v0.10.0 

func (x *GetCellsAliasesRequest) Reset()

func (*GetCellsAliasesRequest) SizeVT added in v0.11.0 

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

func (*GetCellsAliasesRequest) String added in v0.10.0 

func (x *GetCellsAliasesRequest) String() string

func (*GetCellsAliasesRequest) UnmarshalVT added in v0.11.0 

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

type GetCellsAliasesResponse added in v0.10.0 

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

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

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

Deprecated: Use GetCellsAliasesResponse.ProtoReflect.Descriptor instead.

func (*GetCellsAliasesResponse) GetAliases added in v0.10.0 

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

func (*GetCellsAliasesResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*GetCellsAliasesResponse) MarshalToVT added in v0.11.0 

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

func (*GetCellsAliasesResponse) MarshalVT added in v0.11.0 

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

func (*GetCellsAliasesResponse) ProtoMessage added in v0.10.0 

func (*GetCellsAliasesResponse) ProtoMessage()

func (*GetCellsAliasesResponse) ProtoReflect added in v0.11.0 

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

func (*GetCellsAliasesResponse) Reset added in v0.10.0 

func (x *GetCellsAliasesResponse) Reset()

func (*GetCellsAliasesResponse) SizeVT added in v0.11.0 

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

func (*GetCellsAliasesResponse) String added in v0.10.0 

func (x *GetCellsAliasesResponse) String() string

func (*GetCellsAliasesResponse) UnmarshalVT added in v0.11.0 

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

type GetKeyspaceRequest added in v0.9.0 

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

func (*GetKeyspaceRequest) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use GetKeyspaceRequest.ProtoReflect.Descriptor instead.

func (*GetKeyspaceRequest) GetKeyspace added in v0.9.0 

func (x *GetKeyspaceRequest) GetKeyspace() string

func (*GetKeyspaceRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*GetKeyspaceRequest) MarshalToVT added in v0.11.0 

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

func (*GetKeyspaceRequest) MarshalVT added in v0.11.0 

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

func (*GetKeyspaceRequest) ProtoMessage added in v0.9.0 

func (*GetKeyspaceRequest) ProtoMessage()

func (*GetKeyspaceRequest) ProtoReflect added in v0.11.0 

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

func (*GetKeyspaceRequest) Reset added in v0.9.0 

func (x *GetKeyspaceRequest) Reset()

func (*GetKeyspaceRequest) SizeVT added in v0.11.0 

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

func (*GetKeyspaceRequest) String added in v0.9.0 

func (x *GetKeyspaceRequest) String() string

func (*GetKeyspaceRequest) UnmarshalVT added in v0.11.0 

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

type GetKeyspaceResponse added in v0.9.0 

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

func (*GetKeyspaceResponse) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use GetKeyspaceResponse.ProtoReflect.Descriptor instead.

func (*GetKeyspaceResponse) GetKeyspace added in v0.9.0 

func (x *GetKeyspaceResponse) GetKeyspace() *Keyspace

func (*GetKeyspaceResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*GetKeyspaceResponse) MarshalToVT added in v0.11.0 

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

func (*GetKeyspaceResponse) MarshalVT added in v0.11.0 

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

func (*GetKeyspaceResponse) ProtoMessage added in v0.9.0 

func (*GetKeyspaceResponse) ProtoMessage()

func (*GetKeyspaceResponse) ProtoReflect added in v0.11.0 

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

func (*GetKeyspaceResponse) Reset added in v0.9.0 

func (x *GetKeyspaceResponse) Reset()

func (*GetKeyspaceResponse) SizeVT added in v0.11.0 

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

func (*GetKeyspaceResponse) String added in v0.9.0 

func (x *GetKeyspaceResponse) String() string

func (*GetKeyspaceResponse) UnmarshalVT added in v0.11.0 

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

type GetKeyspacesRequest added in v0.9.0 

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

func (*GetKeyspacesRequest) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use GetKeyspacesRequest.ProtoReflect.Descriptor instead.

func (*GetKeyspacesRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*GetKeyspacesRequest) MarshalToVT added in v0.11.0 

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

func (*GetKeyspacesRequest) MarshalVT added in v0.11.0 

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

func (*GetKeyspacesRequest) ProtoMessage added in v0.9.0 

func (*GetKeyspacesRequest) ProtoMessage()

func (*GetKeyspacesRequest) ProtoReflect added in v0.11.0 

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

func (*GetKeyspacesRequest) Reset added in v0.9.0 

func (x *GetKeyspacesRequest) Reset()

func (*GetKeyspacesRequest) SizeVT added in v0.11.0 

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

func (*GetKeyspacesRequest) String added in v0.9.0 

func (x *GetKeyspacesRequest) String() string

func (*GetKeyspacesRequest) UnmarshalVT added in v0.11.0 

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

type GetKeyspacesResponse added in v0.9.0 

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

func (*GetKeyspacesResponse) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use GetKeyspacesResponse.ProtoReflect.Descriptor instead.

func (*GetKeyspacesResponse) GetKeyspaces added in v0.9.0 

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

func (*GetKeyspacesResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*GetKeyspacesResponse) MarshalToVT added in v0.11.0 

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

func (*GetKeyspacesResponse) MarshalVT added in v0.11.0 

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

func (*GetKeyspacesResponse) ProtoMessage added in v0.9.0 

func (*GetKeyspacesResponse) ProtoMessage()

func (*GetKeyspacesResponse) ProtoReflect added in v0.11.0 

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

func (*GetKeyspacesResponse) Reset added in v0.9.0 

func (x *GetKeyspacesResponse) Reset()

func (*GetKeyspacesResponse) SizeVT added in v0.11.0 

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

func (*GetKeyspacesResponse) String added in v0.9.0 

func (x *GetKeyspacesResponse) String() string

func (*GetKeyspacesResponse) UnmarshalVT added in v0.11.0 

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

type GetRoutingRulesRequest added in v0.11.0 

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

func (*GetRoutingRulesRequest) Descriptor deprecated added in v0.11.0 

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

Deprecated: Use GetRoutingRulesRequest.ProtoReflect.Descriptor instead.

func (*GetRoutingRulesRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*GetRoutingRulesRequest) MarshalToVT added in v0.11.0 

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

func (*GetRoutingRulesRequest) MarshalVT added in v0.11.0 

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

func (*GetRoutingRulesRequest) ProtoMessage added in v0.11.0 

func (*GetRoutingRulesRequest) ProtoMessage()

func (*GetRoutingRulesRequest) ProtoReflect added in v0.11.0 

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

func (*GetRoutingRulesRequest) Reset added in v0.11.0 

func (x *GetRoutingRulesRequest) Reset()

func (*GetRoutingRulesRequest) SizeVT added in v0.11.0 

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

func (*GetRoutingRulesRequest) String added in v0.11.0 

func (x *GetRoutingRulesRequest) String() string

func (*GetRoutingRulesRequest) UnmarshalVT added in v0.11.0 

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

type GetRoutingRulesResponse added in v0.11.0 

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

func (*GetRoutingRulesResponse) Descriptor deprecated added in v0.11.0 

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

Deprecated: Use GetRoutingRulesResponse.ProtoReflect.Descriptor instead.

func (*GetRoutingRulesResponse) GetRoutingRules added in v0.11.0 

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

func (*GetRoutingRulesResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*GetRoutingRulesResponse) MarshalToVT added in v0.11.0 

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

func (*GetRoutingRulesResponse) MarshalVT added in v0.11.0 

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

func (*GetRoutingRulesResponse) ProtoMessage added in v0.11.0 

func (*GetRoutingRulesResponse) ProtoMessage()

func (*GetRoutingRulesResponse) ProtoReflect added in v0.11.0 

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

func (*GetRoutingRulesResponse) Reset added in v0.11.0 

func (x *GetRoutingRulesResponse) Reset()

func (*GetRoutingRulesResponse) SizeVT added in v0.11.0 

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

func (*GetRoutingRulesResponse) String added in v0.11.0 

func (x *GetRoutingRulesResponse) String() string

func (*GetRoutingRulesResponse) UnmarshalVT added in v0.11.0 

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

type GetSchemaRequest added in v0.10.0 

type GetSchemaRequest struct {
	TabletAlias *topodata.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"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use GetSchemaRequest.ProtoReflect.Descriptor instead.

func (*GetSchemaRequest) GetExcludeTables added in v0.10.0 

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

func (*GetSchemaRequest) GetIncludeViews added in v0.10.0 

func (x *GetSchemaRequest) GetIncludeViews() bool

func (*GetSchemaRequest) GetTableNamesOnly added in v0.10.0 

func (x *GetSchemaRequest) GetTableNamesOnly() bool

func (*GetSchemaRequest) GetTableSizesOnly added in v0.10.0 

func (x *GetSchemaRequest) GetTableSizesOnly() bool

func (*GetSchemaRequest) GetTables added in v0.10.0 

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

func (*GetSchemaRequest) GetTabletAlias added in v0.10.0 

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

func (*GetSchemaRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*GetSchemaRequest) MarshalToVT added in v0.11.0 

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

func (*GetSchemaRequest) MarshalVT added in v0.11.0 

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

func (*GetSchemaRequest) ProtoMessage added in v0.10.0 

func (*GetSchemaRequest) ProtoMessage()

func (*GetSchemaRequest) ProtoReflect added in v0.11.0 

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

func (*GetSchemaRequest) Reset added in v0.10.0 

func (x *GetSchemaRequest) Reset()

func (*GetSchemaRequest) SizeVT added in v0.11.0 

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

func (*GetSchemaRequest) String added in v0.10.0 

func (x *GetSchemaRequest) String() string

func (*GetSchemaRequest) UnmarshalVT added in v0.11.0 

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

type GetSchemaResponse added in v0.10.0 

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

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

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

Deprecated: Use GetSchemaResponse.ProtoReflect.Descriptor instead.

func (*GetSchemaResponse) GetSchema added in v0.10.0 

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

func (*GetSchemaResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*GetSchemaResponse) MarshalToVT added in v0.11.0 

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

func (*GetSchemaResponse) MarshalVT added in v0.11.0 

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

func (*GetSchemaResponse) ProtoMessage added in v0.10.0 

func (*GetSchemaResponse) ProtoMessage()

func (*GetSchemaResponse) ProtoReflect added in v0.11.0 

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

func (*GetSchemaResponse) Reset added in v0.10.0 

func (x *GetSchemaResponse) Reset()

func (*GetSchemaResponse) SizeVT added in v0.11.0 

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

func (*GetSchemaResponse) String added in v0.10.0 

func (x *GetSchemaResponse) String() string

func (*GetSchemaResponse) UnmarshalVT added in v0.11.0 

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

type GetShardRequest added in v0.10.0 

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

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

Deprecated: Use GetShardRequest.ProtoReflect.Descriptor instead.

func (*GetShardRequest) GetKeyspace added in v0.10.0 

func (x *GetShardRequest) GetKeyspace() string

func (*GetShardRequest) GetShardName added in v0.10.0 

func (x *GetShardRequest) GetShardName() string

func (*GetShardRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*GetShardRequest) MarshalToVT added in v0.11.0 

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

func (*GetShardRequest) MarshalVT added in v0.11.0 

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

func (*GetShardRequest) ProtoMessage added in v0.10.0 

func (*GetShardRequest) ProtoMessage()

func (*GetShardRequest) ProtoReflect added in v0.11.0 

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

func (*GetShardRequest) Reset added in v0.10.0 

func (x *GetShardRequest) Reset()

func (*GetShardRequest) SizeVT added in v0.11.0 

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

func (*GetShardRequest) String added in v0.10.0 

func (x *GetShardRequest) String() string

func (*GetShardRequest) UnmarshalVT added in v0.11.0 

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

type GetShardResponse added in v0.10.0 

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

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

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

Deprecated: Use GetShardResponse.ProtoReflect.Descriptor instead.

func (*GetShardResponse) GetShard added in v0.10.0 

func (x *GetShardResponse) GetShard() *Shard

func (*GetShardResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*GetShardResponse) MarshalToVT added in v0.11.0 

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

func (*GetShardResponse) MarshalVT added in v0.11.0 

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

func (*GetShardResponse) ProtoMessage added in v0.10.0 

func (*GetShardResponse) ProtoMessage()

func (*GetShardResponse) ProtoReflect added in v0.11.0 

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

func (*GetShardResponse) Reset added in v0.10.0 

func (x *GetShardResponse) Reset()

func (*GetShardResponse) SizeVT added in v0.11.0 

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

func (*GetShardResponse) String added in v0.10.0 

func (x *GetShardResponse) String() string

func (*GetShardResponse) UnmarshalVT added in v0.11.0 

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

type GetSrvKeyspacesRequest added in v0.10.0 

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

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

Deprecated: Use GetSrvKeyspacesRequest.ProtoReflect.Descriptor instead.

func (*GetSrvKeyspacesRequest) GetCells added in v0.10.0 

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

func (*GetSrvKeyspacesRequest) GetKeyspace added in v0.10.0 

func (x *GetSrvKeyspacesRequest) GetKeyspace() string

func (*GetSrvKeyspacesRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*GetSrvKeyspacesRequest) MarshalToVT added in v0.11.0 

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

func (*GetSrvKeyspacesRequest) MarshalVT added in v0.11.0 

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

func (*GetSrvKeyspacesRequest) ProtoMessage added in v0.10.0 

func (*GetSrvKeyspacesRequest) ProtoMessage()

func (*GetSrvKeyspacesRequest) ProtoReflect added in v0.11.0 

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

func (*GetSrvKeyspacesRequest) Reset added in v0.10.0 

func (x *GetSrvKeyspacesRequest) Reset()

func (*GetSrvKeyspacesRequest) SizeVT added in v0.11.0 

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

func (*GetSrvKeyspacesRequest) String added in v0.10.0 

func (x *GetSrvKeyspacesRequest) String() string

func (*GetSrvKeyspacesRequest) UnmarshalVT added in v0.11.0 

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

type GetSrvKeyspacesResponse added in v0.10.0 

type GetSrvKeyspacesResponse struct {

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

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

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

Deprecated: Use GetSrvKeyspacesResponse.ProtoReflect.Descriptor instead.

func (*GetSrvKeyspacesResponse) GetSrvKeyspaces added in v0.10.0 

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

func (*GetSrvKeyspacesResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*GetSrvKeyspacesResponse) MarshalToVT added in v0.11.0 

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

func (*GetSrvKeyspacesResponse) MarshalVT added in v0.11.0 

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

func (*GetSrvKeyspacesResponse) ProtoMessage added in v0.10.0 

func (*GetSrvKeyspacesResponse) ProtoMessage()

func (*GetSrvKeyspacesResponse) ProtoReflect added in v0.11.0 

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

func (*GetSrvKeyspacesResponse) Reset added in v0.10.0 

func (x *GetSrvKeyspacesResponse) Reset()

func (*GetSrvKeyspacesResponse) SizeVT added in v0.11.0 

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

func (*GetSrvKeyspacesResponse) String added in v0.10.0 

func (x *GetSrvKeyspacesResponse) String() string

func (*GetSrvKeyspacesResponse) UnmarshalVT added in v0.11.0 

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

type GetSrvVSchemaRequest added in v0.10.0 

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

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

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

Deprecated: Use GetSrvVSchemaRequest.ProtoReflect.Descriptor instead.

func (*GetSrvVSchemaRequest) GetCell added in v0.10.0 

func (x *GetSrvVSchemaRequest) GetCell() string

func (*GetSrvVSchemaRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*GetSrvVSchemaRequest) MarshalToVT added in v0.11.0 

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

func (*GetSrvVSchemaRequest) MarshalVT added in v0.11.0 

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

func (*GetSrvVSchemaRequest) ProtoMessage added in v0.10.0 

func (*GetSrvVSchemaRequest) ProtoMessage()

func (*GetSrvVSchemaRequest) ProtoReflect added in v0.11.0 

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

func (*GetSrvVSchemaRequest) Reset added in v0.10.0 

func (x *GetSrvVSchemaRequest) Reset()

func (*GetSrvVSchemaRequest) SizeVT added in v0.11.0 

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

func (*GetSrvVSchemaRequest) String added in v0.10.0 

func (x *GetSrvVSchemaRequest) String() string

func (*GetSrvVSchemaRequest) UnmarshalVT added in v0.11.0 

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

type GetSrvVSchemaResponse added in v0.10.0 

type GetSrvVSchemaResponse struct {
	SrvVSchema *vschema.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 added in v0.10.0 

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

Deprecated: Use GetSrvVSchemaResponse.ProtoReflect.Descriptor instead.

func (*GetSrvVSchemaResponse) GetSrvVSchema added in v0.10.0 

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

func (*GetSrvVSchemaResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*GetSrvVSchemaResponse) MarshalToVT added in v0.11.0 

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

func (*GetSrvVSchemaResponse) MarshalVT added in v0.11.0 

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

func (*GetSrvVSchemaResponse) ProtoMessage added in v0.10.0 

func (*GetSrvVSchemaResponse) ProtoMessage()

func (*GetSrvVSchemaResponse) ProtoReflect added in v0.11.0 

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

func (*GetSrvVSchemaResponse) Reset added in v0.10.0 

func (x *GetSrvVSchemaResponse) Reset()

func (*GetSrvVSchemaResponse) SizeVT added in v0.11.0 

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

func (*GetSrvVSchemaResponse) String added in v0.10.0 

func (x *GetSrvVSchemaResponse) String() string

func (*GetSrvVSchemaResponse) UnmarshalVT added in v0.11.0 

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

type GetSrvVSchemasRequest added in v0.11.0 

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

func (*GetSrvVSchemasRequest) Descriptor deprecated added in v0.11.0 

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

Deprecated: Use GetSrvVSchemasRequest.ProtoReflect.Descriptor instead.

func (*GetSrvVSchemasRequest) GetCells added in v0.11.0 

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

func (*GetSrvVSchemasRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*GetSrvVSchemasRequest) MarshalToVT added in v0.11.0 

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

func (*GetSrvVSchemasRequest) MarshalVT added in v0.11.0 

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

func (*GetSrvVSchemasRequest) ProtoMessage added in v0.11.0 

func (*GetSrvVSchemasRequest) ProtoMessage()

func (*GetSrvVSchemasRequest) ProtoReflect added in v0.11.0 

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

func (*GetSrvVSchemasRequest) Reset added in v0.11.0 

func (x *GetSrvVSchemasRequest) Reset()

func (*GetSrvVSchemasRequest) SizeVT added in v0.11.0 

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

func (*GetSrvVSchemasRequest) String added in v0.11.0 

func (x *GetSrvVSchemasRequest) String() string

func (*GetSrvVSchemasRequest) UnmarshalVT added in v0.11.0 

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

type GetSrvVSchemasResponse added in v0.11.0 

type GetSrvVSchemasResponse struct {

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

func (*GetSrvVSchemasResponse) Descriptor deprecated added in v0.11.0 

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

Deprecated: Use GetSrvVSchemasResponse.ProtoReflect.Descriptor instead.

func (*GetSrvVSchemasResponse) GetSrvVSchemas added in v0.11.0 

func (x *GetSrvVSchemasResponse) GetSrvVSchemas() map[string]*vschema.SrvVSchema

func (*GetSrvVSchemasResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*GetSrvVSchemasResponse) MarshalToVT added in v0.11.0 

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

func (*GetSrvVSchemasResponse) MarshalVT added in v0.11.0 

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

func (*GetSrvVSchemasResponse) ProtoMessage added in v0.11.0 

func (*GetSrvVSchemasResponse) ProtoMessage()

func (*GetSrvVSchemasResponse) ProtoReflect added in v0.11.0 

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

func (*GetSrvVSchemasResponse) Reset added in v0.11.0 

func (x *GetSrvVSchemasResponse) Reset()

func (*GetSrvVSchemasResponse) SizeVT added in v0.11.0 

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

func (*GetSrvVSchemasResponse) String added in v0.11.0 

func (x *GetSrvVSchemasResponse) String() string

func (*GetSrvVSchemasResponse) UnmarshalVT added in v0.11.0 

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

type GetTabletRequest added in v0.10.0 

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

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

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

Deprecated: Use GetTabletRequest.ProtoReflect.Descriptor instead.

func (*GetTabletRequest) GetTabletAlias added in v0.10.0 

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

func (*GetTabletRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*GetTabletRequest) MarshalToVT added in v0.11.0 

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

func (*GetTabletRequest) MarshalVT added in v0.11.0 

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

func (*GetTabletRequest) ProtoMessage added in v0.10.0 

func (*GetTabletRequest) ProtoMessage()

func (*GetTabletRequest) ProtoReflect added in v0.11.0 

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

func (*GetTabletRequest) Reset added in v0.10.0 

func (x *GetTabletRequest) Reset()

func (*GetTabletRequest) SizeVT added in v0.11.0 

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

func (*GetTabletRequest) String added in v0.10.0 

func (x *GetTabletRequest) String() string

func (*GetTabletRequest) UnmarshalVT added in v0.11.0 

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

type GetTabletResponse added in v0.10.0 

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

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

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

Deprecated: Use GetTabletResponse.ProtoReflect.Descriptor instead.

func (*GetTabletResponse) GetTablet added in v0.10.0 

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

func (*GetTabletResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*GetTabletResponse) MarshalToVT added in v0.11.0 

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

func (*GetTabletResponse) MarshalVT added in v0.11.0 

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

func (*GetTabletResponse) ProtoMessage added in v0.10.0 

func (*GetTabletResponse) ProtoMessage()

func (*GetTabletResponse) ProtoReflect added in v0.11.0 

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

func (*GetTabletResponse) Reset added in v0.10.0 

func (x *GetTabletResponse) Reset()

func (*GetTabletResponse) SizeVT added in v0.11.0 

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

func (*GetTabletResponse) String added in v0.10.0 

func (x *GetTabletResponse) String() string

func (*GetTabletResponse) UnmarshalVT added in v0.11.0 

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

type GetTabletsRequest added in v0.10.0 

type GetTabletsRequest struct {

	// Keyspace is the name of the keyspace to return tablets for. Omit to return
	// all tablets.
	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 []*topodata.TabletAlias `protobuf:"bytes,5,rep,name=tablet_aliases,json=tabletAliases,proto3" json:"tablet_aliases,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use GetTabletsRequest.ProtoReflect.Descriptor instead.

func (*GetTabletsRequest) GetCells added in v0.10.0 

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

func (*GetTabletsRequest) GetKeyspace added in v0.10.0 

func (x *GetTabletsRequest) GetKeyspace() string

func (*GetTabletsRequest) GetShard added in v0.10.0 

func (x *GetTabletsRequest) GetShard() string

func (*GetTabletsRequest) GetStrict added in v0.10.0 

func (x *GetTabletsRequest) GetStrict() bool

func (*GetTabletsRequest) GetTabletAliases added in v0.10.0 

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

func (*GetTabletsRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*GetTabletsRequest) MarshalToVT added in v0.11.0 

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

func (*GetTabletsRequest) MarshalVT added in v0.11.0 

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

func (*GetTabletsRequest) ProtoMessage added in v0.10.0 

func (*GetTabletsRequest) ProtoMessage()

func (*GetTabletsRequest) ProtoReflect added in v0.11.0 

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

func (*GetTabletsRequest) Reset added in v0.10.0 

func (x *GetTabletsRequest) Reset()

func (*GetTabletsRequest) SizeVT added in v0.11.0 

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

func (*GetTabletsRequest) String added in v0.10.0 

func (x *GetTabletsRequest) String() string

func (*GetTabletsRequest) UnmarshalVT added in v0.11.0 

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

type GetTabletsResponse added in v0.10.0 

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

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

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

Deprecated: Use GetTabletsResponse.ProtoReflect.Descriptor instead.

func (*GetTabletsResponse) GetTablets added in v0.10.0 

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

func (*GetTabletsResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*GetTabletsResponse) MarshalToVT added in v0.11.0 

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

func (*GetTabletsResponse) MarshalVT added in v0.11.0 

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

func (*GetTabletsResponse) ProtoMessage added in v0.10.0 

func (*GetTabletsResponse) ProtoMessage()

func (*GetTabletsResponse) ProtoReflect added in v0.11.0 

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

func (*GetTabletsResponse) Reset added in v0.10.0 

func (x *GetTabletsResponse) Reset()

func (*GetTabletsResponse) SizeVT added in v0.11.0 

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

func (*GetTabletsResponse) String added in v0.10.0 

func (x *GetTabletsResponse) String() string

func (*GetTabletsResponse) UnmarshalVT added in v0.11.0 

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

type GetVSchemaRequest added in v0.10.0 

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

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

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

Deprecated: Use GetVSchemaRequest.ProtoReflect.Descriptor instead.

func (*GetVSchemaRequest) GetKeyspace added in v0.10.0 

func (x *GetVSchemaRequest) GetKeyspace() string

func (*GetVSchemaRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*GetVSchemaRequest) MarshalToVT added in v0.11.0 

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

func (*GetVSchemaRequest) MarshalVT added in v0.11.0 

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

func (*GetVSchemaRequest) ProtoMessage added in v0.10.0 

func (*GetVSchemaRequest) ProtoMessage()

func (*GetVSchemaRequest) ProtoReflect added in v0.11.0 

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

func (*GetVSchemaRequest) Reset added in v0.10.0 

func (x *GetVSchemaRequest) Reset()

func (*GetVSchemaRequest) SizeVT added in v0.11.0 

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

func (*GetVSchemaRequest) String added in v0.10.0 

func (x *GetVSchemaRequest) String() string

func (*GetVSchemaRequest) UnmarshalVT added in v0.11.0 

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

type GetVSchemaResponse added in v0.10.0 

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

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

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

Deprecated: Use GetVSchemaResponse.ProtoReflect.Descriptor instead.

func (*GetVSchemaResponse) GetVSchema added in v0.10.0 

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

func (*GetVSchemaResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*GetVSchemaResponse) MarshalToVT added in v0.11.0 

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

func (*GetVSchemaResponse) MarshalVT added in v0.11.0 

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

func (*GetVSchemaResponse) ProtoMessage added in v0.10.0 

func (*GetVSchemaResponse) ProtoMessage()

func (*GetVSchemaResponse) ProtoReflect added in v0.11.0 

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

func (*GetVSchemaResponse) Reset added in v0.10.0 

func (x *GetVSchemaResponse) Reset()

func (*GetVSchemaResponse) SizeVT added in v0.11.0 

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

func (*GetVSchemaResponse) String added in v0.10.0 

func (x *GetVSchemaResponse) String() string

func (*GetVSchemaResponse) UnmarshalVT added in v0.11.0 

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

type GetWorkflowsRequest added in v0.10.0 

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

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

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

Deprecated: Use GetWorkflowsRequest.ProtoReflect.Descriptor instead.

func (*GetWorkflowsRequest) GetActiveOnly added in v0.10.0 

func (x *GetWorkflowsRequest) GetActiveOnly() bool

func (*GetWorkflowsRequest) GetKeyspace added in v0.10.0 

func (x *GetWorkflowsRequest) GetKeyspace() string

func (*GetWorkflowsRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*GetWorkflowsRequest) MarshalToVT added in v0.11.0 

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

func (*GetWorkflowsRequest) MarshalVT added in v0.11.0 

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

func (*GetWorkflowsRequest) ProtoMessage added in v0.10.0 

func (*GetWorkflowsRequest) ProtoMessage()

func (*GetWorkflowsRequest) ProtoReflect added in v0.11.0 

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

func (*GetWorkflowsRequest) Reset added in v0.10.0 

func (x *GetWorkflowsRequest) Reset()

func (*GetWorkflowsRequest) SizeVT added in v0.11.0 

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

func (*GetWorkflowsRequest) String added in v0.10.0 

func (x *GetWorkflowsRequest) String() string

func (*GetWorkflowsRequest) UnmarshalVT added in v0.11.0 

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

type GetWorkflowsResponse added in v0.10.0 

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

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

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

Deprecated: Use GetWorkflowsResponse.ProtoReflect.Descriptor instead.

func (*GetWorkflowsResponse) GetWorkflows added in v0.10.0 

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

func (*GetWorkflowsResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*GetWorkflowsResponse) MarshalToVT added in v0.11.0 

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

func (*GetWorkflowsResponse) MarshalVT added in v0.11.0 

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

func (*GetWorkflowsResponse) ProtoMessage added in v0.10.0 

func (*GetWorkflowsResponse) ProtoMessage()

func (*GetWorkflowsResponse) ProtoReflect added in v0.11.0 

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

func (*GetWorkflowsResponse) Reset added in v0.10.0 

func (x *GetWorkflowsResponse) Reset()

func (*GetWorkflowsResponse) SizeVT added in v0.11.0 

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

func (*GetWorkflowsResponse) String added in v0.10.0 

func (x *GetWorkflowsResponse) String() string

func (*GetWorkflowsResponse) UnmarshalVT added in v0.11.0 

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

type InitShardPrimaryRequest added in v0.10.0 

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 *topodata.TabletAlias `` /* 134-byte string literal not displayed */
	Force                   bool                  `protobuf:"varint,4,opt,name=force,proto3" json:"force,omitempty"`
	WaitReplicasTimeout     *vttime.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 added in v0.10.0 

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

Deprecated: Use InitShardPrimaryRequest.ProtoReflect.Descriptor instead.

func (*InitShardPrimaryRequest) GetForce added in v0.10.0 

func (x *InitShardPrimaryRequest) GetForce() bool

func (*InitShardPrimaryRequest) GetKeyspace added in v0.10.0 

func (x *InitShardPrimaryRequest) GetKeyspace() string

func (*InitShardPrimaryRequest) GetPrimaryElectTabletAlias added in v0.10.0 

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

func (*InitShardPrimaryRequest) GetShard added in v0.10.0 

func (x *InitShardPrimaryRequest) GetShard() string

func (*InitShardPrimaryRequest) GetWaitReplicasTimeout added in v0.10.0 

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

func (*InitShardPrimaryRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*InitShardPrimaryRequest) MarshalToVT added in v0.11.0 

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

func (*InitShardPrimaryRequest) MarshalVT added in v0.11.0 

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

func (*InitShardPrimaryRequest) ProtoMessage added in v0.10.0 

func (*InitShardPrimaryRequest) ProtoMessage()

func (*InitShardPrimaryRequest) ProtoReflect added in v0.11.0 

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

func (*InitShardPrimaryRequest) Reset added in v0.10.0 

func (x *InitShardPrimaryRequest) Reset()

func (*InitShardPrimaryRequest) SizeVT added in v0.11.0 

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

func (*InitShardPrimaryRequest) String added in v0.10.0 

func (x *InitShardPrimaryRequest) String() string

func (*InitShardPrimaryRequest) UnmarshalVT added in v0.11.0 

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

type InitShardPrimaryResponse added in v0.10.0 

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

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

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

Deprecated: Use InitShardPrimaryResponse.ProtoReflect.Descriptor instead.

func (*InitShardPrimaryResponse) GetEvents added in v0.10.0 

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

func (*InitShardPrimaryResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*InitShardPrimaryResponse) MarshalToVT added in v0.11.0 

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

func (*InitShardPrimaryResponse) MarshalVT added in v0.11.0 

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

func (*InitShardPrimaryResponse) ProtoMessage added in v0.10.0 

func (*InitShardPrimaryResponse) ProtoMessage()

func (*InitShardPrimaryResponse) ProtoReflect added in v0.11.0 

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

func (*InitShardPrimaryResponse) Reset added in v0.10.0 

func (x *InitShardPrimaryResponse) Reset()

func (*InitShardPrimaryResponse) SizeVT added in v0.11.0 

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

func (*InitShardPrimaryResponse) String added in v0.10.0 

func (x *InitShardPrimaryResponse) String() string

func (*InitShardPrimaryResponse) UnmarshalVT added in v0.11.0 

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

type Keyspace added in v0.9.0 

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

func (*Keyspace) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use Keyspace.ProtoReflect.Descriptor instead.

func (*Keyspace) GetKeyspace added in v0.9.0 

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

func (*Keyspace) GetName added in v0.9.0 

func (x *Keyspace) GetName() string

func (*Keyspace) MarshalToSizedBufferVT added in v0.11.0 

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

func (*Keyspace) MarshalToVT added in v0.11.0 

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

func (*Keyspace) MarshalVT added in v0.11.0 

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

func (*Keyspace) ProtoMessage added in v0.9.0 

func (*Keyspace) ProtoMessage()

func (*Keyspace) ProtoReflect added in v0.11.0 

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

func (*Keyspace) Reset added in v0.9.0 

func (x *Keyspace) Reset()

func (*Keyspace) SizeVT added in v0.11.0 

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

func (*Keyspace) String added in v0.9.0 

func (x *Keyspace) String() string

func (*Keyspace) UnmarshalVT added in v0.11.0 

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

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"`
	// 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) GetCell 

func (x *MaterializeSettings) GetCell() string

func (*MaterializeSettings) GetExternalCluster added in v0.10.0 

func (x *MaterializeSettings) GetExternalCluster() string

func (*MaterializeSettings) GetSourceKeyspace 

func (x *MaterializeSettings) GetSourceKeyspace() string

func (*MaterializeSettings) GetStopAfterCopy 

func (x *MaterializeSettings) GetStopAfterCopy() bool

func (*MaterializeSettings) GetTableSettings 

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

func (*MaterializeSettings) GetTabletTypes 

func (x *MaterializeSettings) GetTabletTypes() string

func (*MaterializeSettings) GetTargetKeyspace 

func (x *MaterializeSettings) GetTargetKeyspace() string

func (*MaterializeSettings) GetWorkflow 

func (x *MaterializeSettings) GetWorkflow() string

func (*MaterializeSettings) MarshalToSizedBufferVT added in v0.11.0 

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

func (*MaterializeSettings) MarshalToVT added in v0.11.0 

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

func (*MaterializeSettings) MarshalVT added in v0.11.0 

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

func (*MaterializeSettings) ProtoMessage 

func (*MaterializeSettings) ProtoMessage()

func (*MaterializeSettings) ProtoReflect added in v0.11.0 

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

func (*MaterializeSettings) Reset 

func (x *MaterializeSettings) Reset()

func (*MaterializeSettings) SizeVT added in v0.11.0 

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

func (*MaterializeSettings) String 

func (x *MaterializeSettings) String() string

func (*MaterializeSettings) UnmarshalVT added in v0.11.0 

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

type PlannedReparentShardRequest added in v0.10.0 

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 *topodata.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 *topodata.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 *vttime.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 added in v0.10.0 

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

Deprecated: Use PlannedReparentShardRequest.ProtoReflect.Descriptor instead.

func (*PlannedReparentShardRequest) GetAvoidPrimary added in v0.10.0 

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

func (*PlannedReparentShardRequest) GetKeyspace added in v0.10.0 

func (x *PlannedReparentShardRequest) GetKeyspace() string

func (*PlannedReparentShardRequest) GetNewPrimary added in v0.10.0 

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

func (*PlannedReparentShardRequest) GetShard added in v0.10.0 

func (x *PlannedReparentShardRequest) GetShard() string

func (*PlannedReparentShardRequest) GetWaitReplicasTimeout added in v0.10.0 

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

func (*PlannedReparentShardRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*PlannedReparentShardRequest) MarshalToVT added in v0.11.0 

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

func (*PlannedReparentShardRequest) MarshalVT added in v0.11.0 

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

func (*PlannedReparentShardRequest) ProtoMessage added in v0.10.0 

func (*PlannedReparentShardRequest) ProtoMessage()

func (*PlannedReparentShardRequest) ProtoReflect added in v0.11.0 

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

func (*PlannedReparentShardRequest) Reset added in v0.10.0 

func (x *PlannedReparentShardRequest) Reset()

func (*PlannedReparentShardRequest) SizeVT added in v0.11.0 

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

func (*PlannedReparentShardRequest) String added in v0.10.0 

func (x *PlannedReparentShardRequest) String() string

func (*PlannedReparentShardRequest) UnmarshalVT added in v0.11.0 

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

type PlannedReparentShardResponse added in v0.10.0 

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 *topodata.TabletAlias `protobuf:"bytes,3,opt,name=promoted_primary,json=promotedPrimary,proto3" json:"promoted_primary,omitempty"`
	Events          []*logutil.Event      `protobuf:"bytes,4,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use PlannedReparentShardResponse.ProtoReflect.Descriptor instead.

func (*PlannedReparentShardResponse) GetEvents added in v0.10.0 

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

func (*PlannedReparentShardResponse) GetKeyspace added in v0.10.0 

func (x *PlannedReparentShardResponse) GetKeyspace() string

func (*PlannedReparentShardResponse) GetPromotedPrimary added in v0.10.0 

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

func (*PlannedReparentShardResponse) GetShard added in v0.10.0 

func (x *PlannedReparentShardResponse) GetShard() string

func (*PlannedReparentShardResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*PlannedReparentShardResponse) MarshalToVT added in v0.11.0 

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

func (*PlannedReparentShardResponse) MarshalVT added in v0.11.0 

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

func (*PlannedReparentShardResponse) ProtoMessage added in v0.10.0 

func (*PlannedReparentShardResponse) ProtoMessage()

func (*PlannedReparentShardResponse) ProtoReflect added in v0.11.0 

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

func (*PlannedReparentShardResponse) Reset added in v0.10.0 

func (x *PlannedReparentShardResponse) Reset()

func (*PlannedReparentShardResponse) SizeVT added in v0.11.0 

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

func (*PlannedReparentShardResponse) String added in v0.10.0 

func (x *PlannedReparentShardResponse) String() string

func (*PlannedReparentShardResponse) UnmarshalVT added in v0.11.0 

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

type RebuildVSchemaGraphRequest added in v0.11.0 

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

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

Deprecated: Use RebuildVSchemaGraphRequest.ProtoReflect.Descriptor instead.

func (*RebuildVSchemaGraphRequest) GetCells added in v0.11.0 

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

func (*RebuildVSchemaGraphRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*RebuildVSchemaGraphRequest) MarshalToVT added in v0.11.0 

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

func (*RebuildVSchemaGraphRequest) MarshalVT added in v0.11.0 

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

func (*RebuildVSchemaGraphRequest) ProtoMessage added in v0.11.0 

func (*RebuildVSchemaGraphRequest) ProtoMessage()

func (*RebuildVSchemaGraphRequest) ProtoReflect added in v0.11.0 

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

func (*RebuildVSchemaGraphRequest) Reset added in v0.11.0 

func (x *RebuildVSchemaGraphRequest) Reset()

func (*RebuildVSchemaGraphRequest) SizeVT added in v0.11.0 

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

func (*RebuildVSchemaGraphRequest) String added in v0.11.0 

func (x *RebuildVSchemaGraphRequest) String() string

func (*RebuildVSchemaGraphRequest) UnmarshalVT added in v0.11.0 

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

type RebuildVSchemaGraphResponse added in v0.11.0 

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

func (*RebuildVSchemaGraphResponse) Descriptor deprecated added in v0.11.0 

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

Deprecated: Use RebuildVSchemaGraphResponse.ProtoReflect.Descriptor instead.

func (*RebuildVSchemaGraphResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*RebuildVSchemaGraphResponse) MarshalToVT added in v0.11.0 

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

func (*RebuildVSchemaGraphResponse) MarshalVT added in v0.11.0 

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

func (*RebuildVSchemaGraphResponse) ProtoMessage added in v0.11.0 

func (*RebuildVSchemaGraphResponse) ProtoMessage()

func (*RebuildVSchemaGraphResponse) ProtoReflect added in v0.11.0 

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

func (*RebuildVSchemaGraphResponse) Reset added in v0.11.0 

func (x *RebuildVSchemaGraphResponse) Reset()

func (*RebuildVSchemaGraphResponse) SizeVT added in v0.11.0 

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

func (*RebuildVSchemaGraphResponse) String added in v0.11.0 

func (x *RebuildVSchemaGraphResponse) String() string

func (*RebuildVSchemaGraphResponse) UnmarshalVT added in v0.11.0 

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

type RefreshStateByShardRequest added in v0.11.0 

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

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

Deprecated: Use RefreshStateByShardRequest.ProtoReflect.Descriptor instead.

func (*RefreshStateByShardRequest) GetCells added in v0.11.0 

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

func (*RefreshStateByShardRequest) GetKeyspace added in v0.11.0 

func (x *RefreshStateByShardRequest) GetKeyspace() string

func (*RefreshStateByShardRequest) GetShard added in v0.11.0 

func (x *RefreshStateByShardRequest) GetShard() string

func (*RefreshStateByShardRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*RefreshStateByShardRequest) MarshalToVT added in v0.11.0 

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

func (*RefreshStateByShardRequest) MarshalVT added in v0.11.0 

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

func (*RefreshStateByShardRequest) ProtoMessage added in v0.11.0 

func (*RefreshStateByShardRequest) ProtoMessage()

func (*RefreshStateByShardRequest) ProtoReflect added in v0.11.0 

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

func (*RefreshStateByShardRequest) Reset added in v0.11.0 

func (x *RefreshStateByShardRequest) Reset()

func (*RefreshStateByShardRequest) SizeVT added in v0.11.0 

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

func (*RefreshStateByShardRequest) String added in v0.11.0 

func (x *RefreshStateByShardRequest) String() string

func (*RefreshStateByShardRequest) UnmarshalVT added in v0.11.0 

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

type RefreshStateByShardResponse added in v0.11.0 

type RefreshStateByShardResponse struct {
	IsPartialRefresh bool `protobuf:"varint,1,opt,name=is_partial_refresh,json=isPartialRefresh,proto3" json:"is_partial_refresh,omitempty"`
	// contains filtered or unexported fields
}

func (*RefreshStateByShardResponse) Descriptor deprecated added in v0.11.0 

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

Deprecated: Use RefreshStateByShardResponse.ProtoReflect.Descriptor instead.

func (*RefreshStateByShardResponse) GetIsPartialRefresh added in v0.11.0 

func (x *RefreshStateByShardResponse) GetIsPartialRefresh() bool

func (*RefreshStateByShardResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*RefreshStateByShardResponse) MarshalToVT added in v0.11.0 

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

func (*RefreshStateByShardResponse) MarshalVT added in v0.11.0 

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

func (*RefreshStateByShardResponse) ProtoMessage added in v0.11.0 

func (*RefreshStateByShardResponse) ProtoMessage()

func (*RefreshStateByShardResponse) ProtoReflect added in v0.11.0 

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

func (*RefreshStateByShardResponse) Reset added in v0.11.0 

func (x *RefreshStateByShardResponse) Reset()

func (*RefreshStateByShardResponse) SizeVT added in v0.11.0 

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

func (*RefreshStateByShardResponse) String added in v0.11.0 

func (x *RefreshStateByShardResponse) String() string

func (*RefreshStateByShardResponse) UnmarshalVT added in v0.11.0 

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

type RefreshStateRequest added in v0.11.0 

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

func (*RefreshStateRequest) Descriptor deprecated added in v0.11.0 

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

Deprecated: Use RefreshStateRequest.ProtoReflect.Descriptor instead.

func (*RefreshStateRequest) GetTabletAlias added in v0.11.0 

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

func (*RefreshStateRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*RefreshStateRequest) MarshalToVT added in v0.11.0 

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

func (*RefreshStateRequest) MarshalVT added in v0.11.0 

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

func (*RefreshStateRequest) ProtoMessage added in v0.11.0 

func (*RefreshStateRequest) ProtoMessage()

func (*RefreshStateRequest) ProtoReflect added in v0.11.0 

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

func (*RefreshStateRequest) Reset added in v0.11.0 

func (x *RefreshStateRequest) Reset()

func (*RefreshStateRequest) SizeVT added in v0.11.0 

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

func (*RefreshStateRequest) String added in v0.11.0 

func (x *RefreshStateRequest) String() string

func (*RefreshStateRequest) UnmarshalVT added in v0.11.0 

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

type RefreshStateResponse added in v0.11.0 

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

func (*RefreshStateResponse) Descriptor deprecated added in v0.11.0 

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

Deprecated: Use RefreshStateResponse.ProtoReflect.Descriptor instead.

func (*RefreshStateResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*RefreshStateResponse) MarshalToVT added in v0.11.0 

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

func (*RefreshStateResponse) MarshalVT added in v0.11.0 

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

func (*RefreshStateResponse) ProtoMessage added in v0.11.0 

func (*RefreshStateResponse) ProtoMessage()

func (*RefreshStateResponse) ProtoReflect added in v0.11.0 

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

func (*RefreshStateResponse) Reset added in v0.11.0 

func (x *RefreshStateResponse) Reset()

func (*RefreshStateResponse) SizeVT added in v0.11.0 

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

func (*RefreshStateResponse) String added in v0.11.0 

func (x *RefreshStateResponse) String() string

func (*RefreshStateResponse) UnmarshalVT added in v0.11.0 

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

type RemoveKeyspaceCellRequest added in v0.10.0 

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

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

Deprecated: Use RemoveKeyspaceCellRequest.ProtoReflect.Descriptor instead.

func (*RemoveKeyspaceCellRequest) GetCell added in v0.10.0 

func (x *RemoveKeyspaceCellRequest) GetCell() string

func (*RemoveKeyspaceCellRequest) GetForce added in v0.10.0 

func (x *RemoveKeyspaceCellRequest) GetForce() bool

func (*RemoveKeyspaceCellRequest) GetKeyspace added in v0.10.0 

func (x *RemoveKeyspaceCellRequest) GetKeyspace() string

func (*RemoveKeyspaceCellRequest) GetRecursive added in v0.10.0 

func (x *RemoveKeyspaceCellRequest) GetRecursive() bool

func (*RemoveKeyspaceCellRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*RemoveKeyspaceCellRequest) MarshalToVT added in v0.11.0 

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

func (*RemoveKeyspaceCellRequest) MarshalVT added in v0.11.0 

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

func (*RemoveKeyspaceCellRequest) ProtoMessage added in v0.10.0 

func (*RemoveKeyspaceCellRequest) ProtoMessage()

func (*RemoveKeyspaceCellRequest) ProtoReflect added in v0.11.0 

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

func (*RemoveKeyspaceCellRequest) Reset added in v0.10.0 

func (x *RemoveKeyspaceCellRequest) Reset()

func (*RemoveKeyspaceCellRequest) SizeVT added in v0.11.0 

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

func (*RemoveKeyspaceCellRequest) String added in v0.10.0 

func (x *RemoveKeyspaceCellRequest) String() string

func (*RemoveKeyspaceCellRequest) UnmarshalVT added in v0.11.0 

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

type RemoveKeyspaceCellResponse added in v0.10.0 

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

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

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

Deprecated: Use RemoveKeyspaceCellResponse.ProtoReflect.Descriptor instead.

func (*RemoveKeyspaceCellResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*RemoveKeyspaceCellResponse) MarshalToVT added in v0.11.0 

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

func (*RemoveKeyspaceCellResponse) MarshalVT added in v0.11.0 

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

func (*RemoveKeyspaceCellResponse) ProtoMessage added in v0.10.0 

func (*RemoveKeyspaceCellResponse) ProtoMessage()

func (*RemoveKeyspaceCellResponse) ProtoReflect added in v0.11.0 

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

func (*RemoveKeyspaceCellResponse) Reset added in v0.10.0 

func (x *RemoveKeyspaceCellResponse) Reset()

func (*RemoveKeyspaceCellResponse) SizeVT added in v0.11.0 

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

func (*RemoveKeyspaceCellResponse) String added in v0.10.0 

func (x *RemoveKeyspaceCellResponse) String() string

func (*RemoveKeyspaceCellResponse) UnmarshalVT added in v0.11.0 

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

type RemoveShardCellRequest added in v0.10.0 

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

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

Deprecated: Use RemoveShardCellRequest.ProtoReflect.Descriptor instead.

func (*RemoveShardCellRequest) GetCell added in v0.10.0 

func (x *RemoveShardCellRequest) GetCell() string

func (*RemoveShardCellRequest) GetForce added in v0.10.0 

func (x *RemoveShardCellRequest) GetForce() bool

func (*RemoveShardCellRequest) GetKeyspace added in v0.10.0 

func (x *RemoveShardCellRequest) GetKeyspace() string

func (*RemoveShardCellRequest) GetRecursive added in v0.10.0 

func (x *RemoveShardCellRequest) GetRecursive() bool

func (*RemoveShardCellRequest) GetShardName added in v0.10.0 

func (x *RemoveShardCellRequest) GetShardName() string

func (*RemoveShardCellRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*RemoveShardCellRequest) MarshalToVT added in v0.11.0 

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

func (*RemoveShardCellRequest) MarshalVT added in v0.11.0 

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

func (*RemoveShardCellRequest) ProtoMessage added in v0.10.0 

func (*RemoveShardCellRequest) ProtoMessage()

func (*RemoveShardCellRequest) ProtoReflect added in v0.11.0 

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

func (*RemoveShardCellRequest) Reset added in v0.10.0 

func (x *RemoveShardCellRequest) Reset()

func (*RemoveShardCellRequest) SizeVT added in v0.11.0 

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

func (*RemoveShardCellRequest) String added in v0.10.0 

func (x *RemoveShardCellRequest) String() string

func (*RemoveShardCellRequest) UnmarshalVT added in v0.11.0 

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

type RemoveShardCellResponse added in v0.10.0 

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

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

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

Deprecated: Use RemoveShardCellResponse.ProtoReflect.Descriptor instead.

func (*RemoveShardCellResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*RemoveShardCellResponse) MarshalToVT added in v0.11.0 

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

func (*RemoveShardCellResponse) MarshalVT added in v0.11.0 

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

func (*RemoveShardCellResponse) ProtoMessage added in v0.10.0 

func (*RemoveShardCellResponse) ProtoMessage()

func (*RemoveShardCellResponse) ProtoReflect added in v0.11.0 

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

func (*RemoveShardCellResponse) Reset added in v0.10.0 

func (x *RemoveShardCellResponse) Reset()

func (*RemoveShardCellResponse) SizeVT added in v0.11.0 

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

func (*RemoveShardCellResponse) String added in v0.10.0 

func (x *RemoveShardCellResponse) String() string

func (*RemoveShardCellResponse) UnmarshalVT added in v0.11.0 

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

type ReparentTabletRequest added in v0.10.0 

type ReparentTabletRequest struct {

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

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

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

Deprecated: Use ReparentTabletRequest.ProtoReflect.Descriptor instead.

func (*ReparentTabletRequest) GetTablet added in v0.10.0 

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

func (*ReparentTabletRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*ReparentTabletRequest) MarshalToVT added in v0.11.0 

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

func (*ReparentTabletRequest) MarshalVT added in v0.11.0 

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

func (*ReparentTabletRequest) ProtoMessage added in v0.10.0 

func (*ReparentTabletRequest) ProtoMessage()

func (*ReparentTabletRequest) ProtoReflect added in v0.11.0 

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

func (*ReparentTabletRequest) Reset added in v0.10.0 

func (x *ReparentTabletRequest) Reset()

func (*ReparentTabletRequest) SizeVT added in v0.11.0 

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

func (*ReparentTabletRequest) String added in v0.10.0 

func (x *ReparentTabletRequest) String() string

func (*ReparentTabletRequest) UnmarshalVT added in v0.11.0 

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

type ReparentTabletResponse added in v0.10.0 

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

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

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

Deprecated: Use ReparentTabletResponse.ProtoReflect.Descriptor instead.

func (*ReparentTabletResponse) GetKeyspace added in v0.10.0 

func (x *ReparentTabletResponse) GetKeyspace() string

func (*ReparentTabletResponse) GetPrimary added in v0.10.0 

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

func (*ReparentTabletResponse) GetShard added in v0.10.0 

func (x *ReparentTabletResponse) GetShard() string

func (*ReparentTabletResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*ReparentTabletResponse) MarshalToVT added in v0.11.0 

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

func (*ReparentTabletResponse) MarshalVT added in v0.11.0 

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

func (*ReparentTabletResponse) ProtoMessage added in v0.10.0 

func (*ReparentTabletResponse) ProtoMessage()

func (*ReparentTabletResponse) ProtoReflect added in v0.11.0 

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

func (*ReparentTabletResponse) Reset added in v0.10.0 

func (x *ReparentTabletResponse) Reset()

func (*ReparentTabletResponse) SizeVT added in v0.11.0 

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

func (*ReparentTabletResponse) String added in v0.10.0 

func (x *ReparentTabletResponse) String() string

func (*ReparentTabletResponse) UnmarshalVT added in v0.11.0 

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

type Shard added in v0.9.0 

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    *topodata.Shard `protobuf:"bytes,3,opt,name=shard,proto3" json:"shard,omitempty"`
	// contains filtered or unexported fields
}

func (*Shard) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use Shard.ProtoReflect.Descriptor instead.

func (*Shard) GetKeyspace added in v0.9.0 

func (x *Shard) GetKeyspace() string

func (*Shard) GetName added in v0.9.0 

func (x *Shard) GetName() string

func (*Shard) GetShard added in v0.9.0 

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

func (*Shard) MarshalToSizedBufferVT added in v0.11.0 

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

func (*Shard) MarshalToVT added in v0.11.0 

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

func (*Shard) MarshalVT added in v0.11.0 

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

func (*Shard) ProtoMessage added in v0.9.0 

func (*Shard) ProtoMessage()

func (*Shard) ProtoReflect added in v0.11.0 

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

func (*Shard) Reset added in v0.9.0 

func (x *Shard) Reset()

func (*Shard) SizeVT added in v0.11.0 

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

func (*Shard) String added in v0.9.0 

func (x *Shard) String() string

func (*Shard) UnmarshalVT added in v0.11.0 

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

type ShardReplicationPositionsRequest added in v0.10.0 

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

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

Deprecated: Use ShardReplicationPositionsRequest.ProtoReflect.Descriptor instead.

func (*ShardReplicationPositionsRequest) GetKeyspace added in v0.10.0 

func (x *ShardReplicationPositionsRequest) GetKeyspace() string

func (*ShardReplicationPositionsRequest) GetShard added in v0.10.0 

func (x *ShardReplicationPositionsRequest) GetShard() string

func (*ShardReplicationPositionsRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*ShardReplicationPositionsRequest) MarshalToVT added in v0.11.0 

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

func (*ShardReplicationPositionsRequest) MarshalVT added in v0.11.0 

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

func (*ShardReplicationPositionsRequest) ProtoMessage added in v0.10.0 

func (*ShardReplicationPositionsRequest) ProtoMessage()

func (*ShardReplicationPositionsRequest) ProtoReflect added in v0.11.0 

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

func (*ShardReplicationPositionsRequest) Reset added in v0.10.0 

func (x *ShardReplicationPositionsRequest) Reset()

func (*ShardReplicationPositionsRequest) SizeVT added in v0.11.0 

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

func (*ShardReplicationPositionsRequest) String added in v0.10.0 

func (x *ShardReplicationPositionsRequest) String() string

func (*ShardReplicationPositionsRequest) UnmarshalVT added in v0.11.0 

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

type ShardReplicationPositionsResponse added in v0.10.0 

type ShardReplicationPositionsResponse struct {

	// ReplicationStatuses is a mapping of tablet alias string to replication
	// status for that tablet.
	ReplicationStatuses map[string]*replicationdata.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]*topodata.Tablet `` /* 176-byte string literal not displayed */
	// contains filtered or unexported fields
}

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

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

Deprecated: Use ShardReplicationPositionsResponse.ProtoReflect.Descriptor instead.

func (*ShardReplicationPositionsResponse) GetReplicationStatuses added in v0.10.0 

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

func (*ShardReplicationPositionsResponse) GetTabletMap added in v0.10.0 

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

func (*ShardReplicationPositionsResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*ShardReplicationPositionsResponse) MarshalToVT added in v0.11.0 

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

func (*ShardReplicationPositionsResponse) MarshalVT added in v0.11.0 

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

func (*ShardReplicationPositionsResponse) ProtoMessage added in v0.10.0 

func (*ShardReplicationPositionsResponse) ProtoMessage()

func (*ShardReplicationPositionsResponse) ProtoReflect added in v0.11.0 

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

func (*ShardReplicationPositionsResponse) Reset added in v0.10.0 

func (x *ShardReplicationPositionsResponse) Reset()

func (*ShardReplicationPositionsResponse) SizeVT added in v0.11.0 

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

func (*ShardReplicationPositionsResponse) String added in v0.10.0 

func (x *ShardReplicationPositionsResponse) String() string

func (*ShardReplicationPositionsResponse) UnmarshalVT added in v0.11.0 

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

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

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

func (*TableMaterializeSettings) MarshalToVT added in v0.11.0 

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

func (*TableMaterializeSettings) MarshalVT added in v0.11.0 

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

func (*TableMaterializeSettings) ProtoMessage 

func (*TableMaterializeSettings) ProtoMessage()

func (*TableMaterializeSettings) ProtoReflect added in v0.11.0 

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

func (*TableMaterializeSettings) Reset 

func (x *TableMaterializeSettings) Reset()

func (*TableMaterializeSettings) SizeVT added in v0.11.0 

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

func (*TableMaterializeSettings) String 

func (x *TableMaterializeSettings) String() string

func (*TableMaterializeSettings) UnmarshalVT added in v0.11.0 

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

type TabletExternallyReparentedRequest added in v0.10.0 

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 *topodata.TabletAlias `protobuf:"bytes,1,opt,name=tablet,proto3" json:"tablet,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use TabletExternallyReparentedRequest.ProtoReflect.Descriptor instead.

func (*TabletExternallyReparentedRequest) GetTablet added in v0.10.0 

func (x *TabletExternallyReparentedRequest) GetTablet() *topodata.TabletAlias

func (*TabletExternallyReparentedRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*TabletExternallyReparentedRequest) MarshalToVT added in v0.11.0 

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

func (*TabletExternallyReparentedRequest) MarshalVT added in v0.11.0 

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

func (*TabletExternallyReparentedRequest) ProtoMessage added in v0.10.0 

func (*TabletExternallyReparentedRequest) ProtoMessage()

func (*TabletExternallyReparentedRequest) ProtoReflect added in v0.11.0 

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

func (*TabletExternallyReparentedRequest) Reset added in v0.10.0 

func (x *TabletExternallyReparentedRequest) Reset()

func (*TabletExternallyReparentedRequest) SizeVT added in v0.11.0 

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

func (*TabletExternallyReparentedRequest) String added in v0.10.0 

func (x *TabletExternallyReparentedRequest) String() string

func (*TabletExternallyReparentedRequest) UnmarshalVT added in v0.11.0 

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

type TabletExternallyReparentedResponse added in v0.10.0 

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

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

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

Deprecated: Use TabletExternallyReparentedResponse.ProtoReflect.Descriptor instead.

func (*TabletExternallyReparentedResponse) GetKeyspace added in v0.10.0 

func (x *TabletExternallyReparentedResponse) GetKeyspace() string

func (*TabletExternallyReparentedResponse) GetNewPrimary added in v0.10.0 

func (x *TabletExternallyReparentedResponse) GetNewPrimary() *topodata.TabletAlias

func (*TabletExternallyReparentedResponse) GetOldPrimary added in v0.10.0 

func (x *TabletExternallyReparentedResponse) GetOldPrimary() *topodata.TabletAlias

func (*TabletExternallyReparentedResponse) GetShard added in v0.10.0 

func (x *TabletExternallyReparentedResponse) GetShard() string

func (*TabletExternallyReparentedResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*TabletExternallyReparentedResponse) MarshalToVT added in v0.11.0 

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

func (*TabletExternallyReparentedResponse) MarshalVT added in v0.11.0 

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

func (*TabletExternallyReparentedResponse) ProtoMessage added in v0.10.0 

func (*TabletExternallyReparentedResponse) ProtoMessage()

func (*TabletExternallyReparentedResponse) ProtoReflect added in v0.11.0 

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

func (*TabletExternallyReparentedResponse) Reset added in v0.10.0 

func (x *TabletExternallyReparentedResponse) Reset()

func (*TabletExternallyReparentedResponse) SizeVT added in v0.11.0 

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

func (*TabletExternallyReparentedResponse) String added in v0.10.0 

func (x *TabletExternallyReparentedResponse) String() string

func (*TabletExternallyReparentedResponse) UnmarshalVT added in v0.11.0 

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

type UpdateCellInfoRequest added in v0.11.0 

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

func (*UpdateCellInfoRequest) Descriptor deprecated added in v0.11.0 

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

Deprecated: Use UpdateCellInfoRequest.ProtoReflect.Descriptor instead.

func (*UpdateCellInfoRequest) GetCellInfo added in v0.11.0 

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

func (*UpdateCellInfoRequest) GetName added in v0.11.0 

func (x *UpdateCellInfoRequest) GetName() string

func (*UpdateCellInfoRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*UpdateCellInfoRequest) MarshalToVT added in v0.11.0 

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

func (*UpdateCellInfoRequest) MarshalVT added in v0.11.0 

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

func (*UpdateCellInfoRequest) ProtoMessage added in v0.11.0 

func (*UpdateCellInfoRequest) ProtoMessage()

func (*UpdateCellInfoRequest) ProtoReflect added in v0.11.0 

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

func (*UpdateCellInfoRequest) Reset added in v0.11.0 

func (x *UpdateCellInfoRequest) Reset()

func (*UpdateCellInfoRequest) SizeVT added in v0.11.0 

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

func (*UpdateCellInfoRequest) String added in v0.11.0 

func (x *UpdateCellInfoRequest) String() string

func (*UpdateCellInfoRequest) UnmarshalVT added in v0.11.0 

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

type UpdateCellInfoResponse added in v0.11.0 

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

func (*UpdateCellInfoResponse) Descriptor deprecated added in v0.11.0 

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

Deprecated: Use UpdateCellInfoResponse.ProtoReflect.Descriptor instead.

func (*UpdateCellInfoResponse) GetCellInfo added in v0.11.0 

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

func (*UpdateCellInfoResponse) GetName added in v0.11.0 

func (x *UpdateCellInfoResponse) GetName() string

func (*UpdateCellInfoResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*UpdateCellInfoResponse) MarshalToVT added in v0.11.0 

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

func (*UpdateCellInfoResponse) MarshalVT added in v0.11.0 

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

func (*UpdateCellInfoResponse) ProtoMessage added in v0.11.0 

func (*UpdateCellInfoResponse) ProtoMessage()

func (*UpdateCellInfoResponse) ProtoReflect added in v0.11.0 

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

func (*UpdateCellInfoResponse) Reset added in v0.11.0 

func (x *UpdateCellInfoResponse) Reset()

func (*UpdateCellInfoResponse) SizeVT added in v0.11.0 

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

func (*UpdateCellInfoResponse) String added in v0.11.0 

func (x *UpdateCellInfoResponse) String() string

func (*UpdateCellInfoResponse) UnmarshalVT added in v0.11.0 

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

type UpdateCellsAliasRequest added in v0.11.0 

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

func (*UpdateCellsAliasRequest) Descriptor deprecated added in v0.11.0 

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

Deprecated: Use UpdateCellsAliasRequest.ProtoReflect.Descriptor instead.

func (*UpdateCellsAliasRequest) GetCellsAlias added in v0.11.0 

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

func (*UpdateCellsAliasRequest) GetName added in v0.11.0 

func (x *UpdateCellsAliasRequest) GetName() string

func (*UpdateCellsAliasRequest) MarshalToSizedBufferVT added in v0.11.0 

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

func (*UpdateCellsAliasRequest) MarshalToVT added in v0.11.0 

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

func (*UpdateCellsAliasRequest) MarshalVT added in v0.11.0 

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

func (*UpdateCellsAliasRequest) ProtoMessage added in v0.11.0 

func (*UpdateCellsAliasRequest) ProtoMessage()

func (*UpdateCellsAliasRequest) ProtoReflect added in v0.11.0 

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

func (*UpdateCellsAliasRequest) Reset added in v0.11.0 

func (x *UpdateCellsAliasRequest) Reset()

func (*UpdateCellsAliasRequest) SizeVT added in v0.11.0 

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

func (*UpdateCellsAliasRequest) String added in v0.11.0 

func (x *UpdateCellsAliasRequest) String() string

func (*UpdateCellsAliasRequest) UnmarshalVT added in v0.11.0 

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

type UpdateCellsAliasResponse added in v0.11.0 

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

func (*UpdateCellsAliasResponse) Descriptor deprecated added in v0.11.0 

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

Deprecated: Use UpdateCellsAliasResponse.ProtoReflect.Descriptor instead.

func (*UpdateCellsAliasResponse) GetCellsAlias added in v0.11.0 

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

func (*UpdateCellsAliasResponse) GetName added in v0.11.0 

func (x *UpdateCellsAliasResponse) GetName() string

func (*UpdateCellsAliasResponse) MarshalToSizedBufferVT added in v0.11.0 

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

func (*UpdateCellsAliasResponse) MarshalToVT added in v0.11.0 

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

func (*UpdateCellsAliasResponse) MarshalVT added in v0.11.0 

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

func (*UpdateCellsAliasResponse) ProtoMessage added in v0.11.0 

func (*UpdateCellsAliasResponse) ProtoMessage()

func (*UpdateCellsAliasResponse) ProtoReflect added in v0.11.0 

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

func (*UpdateCellsAliasResponse) Reset added in v0.11.0 

func (x *UpdateCellsAliasResponse) Reset()

func (*UpdateCellsAliasResponse) SizeVT added in v0.11.0 

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

func (*UpdateCellsAliasResponse) String added in v0.11.0 

func (x *UpdateCellsAliasResponse) String() string

func (*UpdateCellsAliasResponse) UnmarshalVT added in v0.11.0 

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

type Workflow added in v0.10.0 

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

TODO: comment the hell out of this.

func (*Workflow) Descriptor deprecated added in v0.10.0 

func (*Workflow) Descriptor() ([]byte, []int)

Deprecated: Use Workflow.ProtoReflect.Descriptor instead.

func (*Workflow) GetMaxVReplicationLag added in v0.10.0 

func (x *Workflow) GetMaxVReplicationLag() int64

func (*Workflow) GetName added in v0.10.0 

func (x *Workflow) GetName() string

func (*Workflow) GetShardStreams added in v0.10.0 

func (x *Workflow) GetShardStreams() map[string]*Workflow_ShardStream

func (*Workflow) GetSource added in v0.10.0 

func (x *Workflow) GetSource() *Workflow_ReplicationLocation

func (*Workflow) GetTarget added in v0.10.0 

func (x *Workflow) GetTarget() *Workflow_ReplicationLocation

func (*Workflow) MarshalToSizedBufferVT added in v0.11.0 

func (m *Workflow) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Workflow) MarshalToVT added in v0.11.0 

func (m *Workflow) MarshalToVT(dAtA []byte) (int, error)

func (*Workflow) MarshalVT added in v0.11.0 

func (m *Workflow) MarshalVT() (dAtA []byte, err error)

func (*Workflow) ProtoMessage added in v0.10.0 

func (*Workflow) ProtoMessage()

func (*Workflow) ProtoReflect added in v0.11.0 

func (x *Workflow) ProtoReflect() protoreflect.Message

func (*Workflow) Reset added in v0.10.0 

func (x *Workflow) Reset()

func (*Workflow) SizeVT added in v0.11.0 

func (m *Workflow) SizeVT() (n int)

func (*Workflow) String added in v0.10.0 

func (x *Workflow) String() string

func (*Workflow) UnmarshalVT added in v0.11.0 

func (m *Workflow) UnmarshalVT(dAtA []byte) error

type Workflow_ReplicationLocation added in v0.10.0 

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 added in v0.10.0 

func (*Workflow_ReplicationLocation) Descriptor() ([]byte, []int)

Deprecated: Use Workflow_ReplicationLocation.ProtoReflect.Descriptor instead.

func (*Workflow_ReplicationLocation) GetKeyspace added in v0.10.0 

func (x *Workflow_ReplicationLocation) GetKeyspace() string

func (*Workflow_ReplicationLocation) GetShards added in v0.10.0 

func (x *Workflow_ReplicationLocation) GetShards() []string

func (*Workflow_ReplicationLocation) MarshalToSizedBufferVT added in v0.11.0 

func (m *Workflow_ReplicationLocation) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Workflow_ReplicationLocation) MarshalToVT added in v0.11.0 

func (m *Workflow_ReplicationLocation) MarshalToVT(dAtA []byte) (int, error)

func (*Workflow_ReplicationLocation) MarshalVT added in v0.11.0 

func (m *Workflow_ReplicationLocation) MarshalVT() (dAtA []byte, err error)

func (*Workflow_ReplicationLocation) ProtoMessage added in v0.10.0 

func (*Workflow_ReplicationLocation) ProtoMessage()

func (*Workflow_ReplicationLocation) ProtoReflect added in v0.11.0 

func (x *Workflow_ReplicationLocation) ProtoReflect() protoreflect.Message

func (*Workflow_ReplicationLocation) Reset added in v0.10.0 

func (x *Workflow_ReplicationLocation) Reset()

func (*Workflow_ReplicationLocation) SizeVT added in v0.11.0 

func (m *Workflow_ReplicationLocation) SizeVT() (n int)

func (*Workflow_ReplicationLocation) String added in v0.10.0 

func (x *Workflow_ReplicationLocation) String() string

func (*Workflow_ReplicationLocation) UnmarshalVT added in v0.11.0 

func (m *Workflow_ReplicationLocation) UnmarshalVT(dAtA []byte) error

type Workflow_ShardStream added in v0.10.0 

type Workflow_ShardStream struct {
	Streams          []*Workflow_Stream              `protobuf:"bytes,1,rep,name=streams,proto3" json:"streams,omitempty"`
	TabletControls   []*topodata.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 added in v0.10.0 

func (*Workflow_ShardStream) Descriptor() ([]byte, []int)

Deprecated: Use Workflow_ShardStream.ProtoReflect.Descriptor instead.

func (*Workflow_ShardStream) GetIsPrimaryServing added in v0.10.0 

func (x *Workflow_ShardStream) GetIsPrimaryServing() bool

func (*Workflow_ShardStream) GetStreams added in v0.10.0 

func (x *Workflow_ShardStream) GetStreams() []*Workflow_Stream

func (*Workflow_ShardStream) GetTabletControls added in v0.10.0 

func (x *Workflow_ShardStream) GetTabletControls() []*topodata.Shard_TabletControl

func (*Workflow_ShardStream) MarshalToSizedBufferVT added in v0.11.0 

func (m *Workflow_ShardStream) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Workflow_ShardStream) MarshalToVT added in v0.11.0 

func (m *Workflow_ShardStream) MarshalToVT(dAtA []byte) (int, error)

func (*Workflow_ShardStream) MarshalVT added in v0.11.0 

func (m *Workflow_ShardStream) MarshalVT() (dAtA []byte, err error)

func (*Workflow_ShardStream) ProtoMessage added in v0.10.0 

func (*Workflow_ShardStream) ProtoMessage()

func (*Workflow_ShardStream) ProtoReflect added in v0.11.0 

func (x *Workflow_ShardStream) ProtoReflect() protoreflect.Message

func (*Workflow_ShardStream) Reset added in v0.10.0 

func (x *Workflow_ShardStream) Reset()

func (*Workflow_ShardStream) SizeVT added in v0.11.0 

func (m *Workflow_ShardStream) SizeVT() (n int)

func (*Workflow_ShardStream) String added in v0.10.0 

func (x *Workflow_ShardStream) String() string

func (*Workflow_ShardStream) UnmarshalVT added in v0.11.0 

func (m *Workflow_ShardStream) UnmarshalVT(dAtA []byte) error

type Workflow_Stream added in v0.10.0 

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               *topodata.TabletAlias        `protobuf:"bytes,3,opt,name=tablet,proto3" json:"tablet,omitempty"`
	BinlogSource         *binlogdata.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 *vttime.Time                 `protobuf:"bytes,9,opt,name=transaction_timestamp,json=transactionTimestamp,proto3" json:"transaction_timestamp,omitempty"`
	TimeUpdated          *vttime.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"`
	// contains filtered or unexported fields
}

func (*Workflow_Stream) Descriptor deprecated added in v0.10.0 

func (*Workflow_Stream) Descriptor() ([]byte, []int)

Deprecated: Use Workflow_Stream.ProtoReflect.Descriptor instead.

func (*Workflow_Stream) GetBinlogSource added in v0.10.0 

func (x *Workflow_Stream) GetBinlogSource() *binlogdata.BinlogSource

func (*Workflow_Stream) GetCopyStates added in v0.10.0 

func (x *Workflow_Stream) GetCopyStates() []*Workflow_Stream_CopyState

func (*Workflow_Stream) GetDbName added in v0.10.0 

func (x *Workflow_Stream) GetDbName() string

func (*Workflow_Stream) GetId added in v0.10.0 

func (x *Workflow_Stream) GetId() int64

func (*Workflow_Stream) GetLogFetchError added in v0.11.0 

func (x *Workflow_Stream) GetLogFetchError() string

func (*Workflow_Stream) GetLogs added in v0.11.0 

func (x *Workflow_Stream) GetLogs() []*Workflow_Stream_Log

func (*Workflow_Stream) GetMessage added in v0.10.0 

func (x *Workflow_Stream) GetMessage() string

func (*Workflow_Stream) GetPosition added in v0.10.0 

func (x *Workflow_Stream) GetPosition() string

func (*Workflow_Stream) GetShard added in v0.10.0 

func (x *Workflow_Stream) GetShard() string

func (*Workflow_Stream) GetState added in v0.10.0 

func (x *Workflow_Stream) GetState() string

func (*Workflow_Stream) GetStopPosition added in v0.10.0 

func (x *Workflow_Stream) GetStopPosition() string

func (*Workflow_Stream) GetTablet added in v0.10.0 

func (x *Workflow_Stream) GetTablet() *topodata.TabletAlias

func (*Workflow_Stream) GetTimeUpdated added in v0.10.0 

func (x *Workflow_Stream) GetTimeUpdated() *vttime.Time

func (*Workflow_Stream) GetTransactionTimestamp added in v0.10.0 

func (x *Workflow_Stream) GetTransactionTimestamp() *vttime.Time

func (*Workflow_Stream) MarshalToSizedBufferVT added in v0.11.0 

func (m *Workflow_Stream) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Workflow_Stream) MarshalToVT added in v0.11.0 

func (m *Workflow_Stream) MarshalToVT(dAtA []byte) (int, error)

func (*Workflow_Stream) MarshalVT added in v0.11.0 

func (m *Workflow_Stream) MarshalVT() (dAtA []byte, err error)

func (*Workflow_Stream) ProtoMessage added in v0.10.0 

func (*Workflow_Stream) ProtoMessage()

func (*Workflow_Stream) ProtoReflect added in v0.11.0 

func (x *Workflow_Stream) ProtoReflect() protoreflect.Message

func (*Workflow_Stream) Reset added in v0.10.0 

func (x *Workflow_Stream) Reset()

func (*Workflow_Stream) SizeVT added in v0.11.0 

func (m *Workflow_Stream) SizeVT() (n int)

func (*Workflow_Stream) String added in v0.10.0 

func (x *Workflow_Stream) String() string

func (*Workflow_Stream) UnmarshalVT added in v0.11.0 

func (m *Workflow_Stream) UnmarshalVT(dAtA []byte) error

type Workflow_Stream_CopyState added in v0.10.0 

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 added in v0.10.0 

func (*Workflow_Stream_CopyState) Descriptor() ([]byte, []int)

Deprecated: Use Workflow_Stream_CopyState.ProtoReflect.Descriptor instead.

func (*Workflow_Stream_CopyState) GetLastPk added in v0.10.0 

func (x *Workflow_Stream_CopyState) GetLastPk() string

func (*Workflow_Stream_CopyState) GetTable added in v0.10.0 

func (x *Workflow_Stream_CopyState) GetTable() string

func (*Workflow_Stream_CopyState) MarshalToSizedBufferVT added in v0.11.0 

func (m *Workflow_Stream_CopyState) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Workflow_Stream_CopyState) MarshalToVT added in v0.11.0 

func (m *Workflow_Stream_CopyState) MarshalToVT(dAtA []byte) (int, error)

func (*Workflow_Stream_CopyState) MarshalVT added in v0.11.0 

func (m *Workflow_Stream_CopyState) MarshalVT() (dAtA []byte, err error)

func (*Workflow_Stream_CopyState) ProtoMessage added in v0.10.0 

func (*Workflow_Stream_CopyState) ProtoMessage()

func (*Workflow_Stream_CopyState) ProtoReflect added in v0.11.0 

func (x *Workflow_Stream_CopyState) ProtoReflect() protoreflect.Message

func (*Workflow_Stream_CopyState) Reset added in v0.10.0 

func (x *Workflow_Stream_CopyState) Reset()

func (*Workflow_Stream_CopyState) SizeVT added in v0.11.0 

func (m *Workflow_Stream_CopyState) SizeVT() (n int)

func (*Workflow_Stream_CopyState) String added in v0.10.0 

func (x *Workflow_Stream_CopyState) String() string

func (*Workflow_Stream_CopyState) UnmarshalVT added in v0.11.0 

func (m *Workflow_Stream_CopyState) UnmarshalVT(dAtA []byte) error

type Workflow_Stream_Log added in v0.11.0 

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 *vttime.Time `protobuf:"bytes,5,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt *vttime.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 added in v0.11.0 

func (*Workflow_Stream_Log) Descriptor() ([]byte, []int)

Deprecated: Use Workflow_Stream_Log.ProtoReflect.Descriptor instead.

func (*Workflow_Stream_Log) GetCount added in v0.11.0 

func (x *Workflow_Stream_Log) GetCount() int64

func (*Workflow_Stream_Log) GetCreatedAt added in v0.11.0 

func (x *Workflow_Stream_Log) GetCreatedAt() *vttime.Time

func (*Workflow_Stream_Log) GetId added in v0.11.0 

func (x *Workflow_Stream_Log) GetId() int64

func (*Workflow_Stream_Log) GetMessage added in v0.11.0 

func (x *Workflow_Stream_Log) GetMessage() string

func (*Workflow_Stream_Log) GetState added in v0.11.0 

func (x *Workflow_Stream_Log) GetState() string

func (*Workflow_Stream_Log) GetStreamId added in v0.11.0 

func (x *Workflow_Stream_Log) GetStreamId() int64

func (*Workflow_Stream_Log) GetType added in v0.11.0 

func (x *Workflow_Stream_Log) GetType() string

func (*Workflow_Stream_Log) GetUpdatedAt added in v0.11.0 

func (x *Workflow_Stream_Log) GetUpdatedAt() *vttime.Time

func (*Workflow_Stream_Log) MarshalToSizedBufferVT added in v0.11.0 

func (m *Workflow_Stream_Log) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Workflow_Stream_Log) MarshalToVT added in v0.11.0 

func (m *Workflow_Stream_Log) MarshalToVT(dAtA []byte) (int, error)

func (*Workflow_Stream_Log) MarshalVT added in v0.11.0 

func (m *Workflow_Stream_Log) MarshalVT() (dAtA []byte, err error)

func (*Workflow_Stream_Log) ProtoMessage added in v0.11.0 

func (*Workflow_Stream_Log) ProtoMessage()

func (*Workflow_Stream_Log) ProtoReflect added in v0.11.0 

func (x *Workflow_Stream_Log) ProtoReflect() protoreflect.Message

func (*Workflow_Stream_Log) Reset added in v0.11.0 

func (x *Workflow_Stream_Log) Reset()

func (*Workflow_Stream_Log) SizeVT added in v0.11.0 

func (m *Workflow_Stream_Log) SizeVT() (n int)

func (*Workflow_Stream_Log) String added in v0.11.0 

func (x *Workflow_Stream_Log) String() string

func (*Workflow_Stream_Log) UnmarshalVT added in v0.11.0 

func (m *Workflow_Stream_Log) UnmarshalVT(dAtA []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.