vtctldata

package
v0.10.4 Latest Latest
Warning

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

 Go to latest Published: Dec 17, 2021 License: Apache-2.0 Imports: 13 Imported by: 7

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthVtctldata        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowVtctldata          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupVtctldata = fmt.Errorf("proto: unexpected end of group")
)

Functions

This section is empty.

Types

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"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*ChangeTabletTypeRequest) Descriptor added in v0.10.0 

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

func (*ChangeTabletTypeRequest) GetDbType added in v0.10.0 

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

func (*ChangeTabletTypeRequest) GetDryRun added in v0.10.0 

func (m *ChangeTabletTypeRequest) GetDryRun() bool

func (*ChangeTabletTypeRequest) GetTabletAlias added in v0.10.0 

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

func (*ChangeTabletTypeRequest) Marshal added in v0.10.0 

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

func (*ChangeTabletTypeRequest) MarshalTo added in v0.10.0 

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

func (*ChangeTabletTypeRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*ChangeTabletTypeRequest) ProtoMessage added in v0.10.0 

func (*ChangeTabletTypeRequest) ProtoMessage()

func (*ChangeTabletTypeRequest) Reset added in v0.10.0 

func (m *ChangeTabletTypeRequest) Reset()

func (*ChangeTabletTypeRequest) Size added in v0.10.0 

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

func (*ChangeTabletTypeRequest) String added in v0.10.0 

func (m *ChangeTabletTypeRequest) String() string

func (*ChangeTabletTypeRequest) Unmarshal added in v0.10.0 

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

func (*ChangeTabletTypeRequest) XXX_DiscardUnknown added in v0.10.0 

func (m *ChangeTabletTypeRequest) XXX_DiscardUnknown()

func (*ChangeTabletTypeRequest) XXX_Marshal added in v0.10.0 

func (m *ChangeTabletTypeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ChangeTabletTypeRequest) XXX_Merge added in v0.10.0 

func (m *ChangeTabletTypeRequest) XXX_Merge(src proto.Message)

func (*ChangeTabletTypeRequest) XXX_Size added in v0.10.0 

func (m *ChangeTabletTypeRequest) XXX_Size() int

func (*ChangeTabletTypeRequest) XXX_Unmarshal added in v0.10.0 

func (m *ChangeTabletTypeRequest) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*ChangeTabletTypeResponse) Descriptor added in v0.10.0 

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

func (*ChangeTabletTypeResponse) GetAfterTablet added in v0.10.0 

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

func (*ChangeTabletTypeResponse) GetBeforeTablet added in v0.10.0 

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

func (*ChangeTabletTypeResponse) GetWasDryRun added in v0.10.0 

func (m *ChangeTabletTypeResponse) GetWasDryRun() bool

func (*ChangeTabletTypeResponse) Marshal added in v0.10.0 

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

func (*ChangeTabletTypeResponse) MarshalTo added in v0.10.0 

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

func (*ChangeTabletTypeResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*ChangeTabletTypeResponse) ProtoMessage added in v0.10.0 

func (*ChangeTabletTypeResponse) ProtoMessage()

func (*ChangeTabletTypeResponse) Reset added in v0.10.0 

func (m *ChangeTabletTypeResponse) Reset()

func (*ChangeTabletTypeResponse) Size added in v0.10.0 

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

func (*ChangeTabletTypeResponse) String added in v0.10.0 

func (m *ChangeTabletTypeResponse) String() string

func (*ChangeTabletTypeResponse) Unmarshal added in v0.10.0 

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

func (*ChangeTabletTypeResponse) XXX_DiscardUnknown added in v0.10.0 

func (m *ChangeTabletTypeResponse) XXX_DiscardUnknown()

func (*ChangeTabletTypeResponse) XXX_Marshal added in v0.10.0 

func (m *ChangeTabletTypeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ChangeTabletTypeResponse) XXX_Merge added in v0.10.0 

func (m *ChangeTabletTypeResponse) XXX_Merge(src proto.Message)

func (*ChangeTabletTypeResponse) XXX_Size added in v0.10.0 

func (m *ChangeTabletTypeResponse) XXX_Size() int

func (*ChangeTabletTypeResponse) XXX_Unmarshal added in v0.10.0 

func (m *ChangeTabletTypeResponse) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*CreateKeyspaceRequest) Descriptor added in v0.10.0 

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

func (*CreateKeyspaceRequest) GetAllowEmptyVSchema added in v0.10.0 

func (m *CreateKeyspaceRequest) GetAllowEmptyVSchema() bool

func (*CreateKeyspaceRequest) GetBaseKeyspace added in v0.10.0 

func (m *CreateKeyspaceRequest) GetBaseKeyspace() string

func (*CreateKeyspaceRequest) GetForce added in v0.10.0 

func (m *CreateKeyspaceRequest) GetForce() bool

func (*CreateKeyspaceRequest) GetName added in v0.10.0 

func (m *CreateKeyspaceRequest) GetName() string

func (*CreateKeyspaceRequest) GetServedFroms added in v0.10.0 

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

func (*CreateKeyspaceRequest) GetShardingColumnName added in v0.10.0 

func (m *CreateKeyspaceRequest) GetShardingColumnName() string

func (*CreateKeyspaceRequest) GetShardingColumnType added in v0.10.0 

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

func (*CreateKeyspaceRequest) GetSnapshotTime added in v0.10.0 

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

func (*CreateKeyspaceRequest) GetType added in v0.10.0 

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

func (*CreateKeyspaceRequest) Marshal added in v0.10.0 

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

func (*CreateKeyspaceRequest) MarshalTo added in v0.10.0 

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

func (*CreateKeyspaceRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*CreateKeyspaceRequest) ProtoMessage added in v0.10.0 

func (*CreateKeyspaceRequest) ProtoMessage()

func (*CreateKeyspaceRequest) Reset added in v0.10.0 

func (m *CreateKeyspaceRequest) Reset()

func (*CreateKeyspaceRequest) Size added in v0.10.0 

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

func (*CreateKeyspaceRequest) String added in v0.10.0 

func (m *CreateKeyspaceRequest) String() string

func (*CreateKeyspaceRequest) Unmarshal added in v0.10.0 

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

func (*CreateKeyspaceRequest) XXX_DiscardUnknown added in v0.10.0 

func (m *CreateKeyspaceRequest) XXX_DiscardUnknown()

func (*CreateKeyspaceRequest) XXX_Marshal added in v0.10.0 

func (m *CreateKeyspaceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateKeyspaceRequest) XXX_Merge added in v0.10.0 

func (m *CreateKeyspaceRequest) XXX_Merge(src proto.Message)

func (*CreateKeyspaceRequest) XXX_Size added in v0.10.0 

func (m *CreateKeyspaceRequest) XXX_Size() int

func (*CreateKeyspaceRequest) XXX_Unmarshal added in v0.10.0 

func (m *CreateKeyspaceRequest) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*CreateKeyspaceResponse) Descriptor added in v0.10.0 

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

func (*CreateKeyspaceResponse) GetKeyspace added in v0.10.0 

func (m *CreateKeyspaceResponse) GetKeyspace() *Keyspace

func (*CreateKeyspaceResponse) Marshal added in v0.10.0 

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

func (*CreateKeyspaceResponse) MarshalTo added in v0.10.0 

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

func (*CreateKeyspaceResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*CreateKeyspaceResponse) ProtoMessage added in v0.10.0 

func (*CreateKeyspaceResponse) ProtoMessage()

func (*CreateKeyspaceResponse) Reset added in v0.10.0 

func (m *CreateKeyspaceResponse) Reset()

func (*CreateKeyspaceResponse) Size added in v0.10.0 

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

func (*CreateKeyspaceResponse) String added in v0.10.0 

func (m *CreateKeyspaceResponse) String() string

func (*CreateKeyspaceResponse) Unmarshal added in v0.10.0 

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

func (*CreateKeyspaceResponse) XXX_DiscardUnknown added in v0.10.0 

func (m *CreateKeyspaceResponse) XXX_DiscardUnknown()

func (*CreateKeyspaceResponse) XXX_Marshal added in v0.10.0 

func (m *CreateKeyspaceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateKeyspaceResponse) XXX_Merge added in v0.10.0 

func (m *CreateKeyspaceResponse) XXX_Merge(src proto.Message)

func (*CreateKeyspaceResponse) XXX_Size added in v0.10.0 

func (m *CreateKeyspaceResponse) XXX_Size() int

func (*CreateKeyspaceResponse) XXX_Unmarshal added in v0.10.0 

func (m *CreateKeyspaceResponse) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateShardRequest) Descriptor added in v0.10.0 

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

func (*CreateShardRequest) GetForce added in v0.10.0 

func (m *CreateShardRequest) GetForce() bool

func (*CreateShardRequest) GetIncludeParent added in v0.10.0 

func (m *CreateShardRequest) GetIncludeParent() bool

func (*CreateShardRequest) GetKeyspace added in v0.10.0 

func (m *CreateShardRequest) GetKeyspace() string

func (*CreateShardRequest) GetShardName added in v0.10.0 

func (m *CreateShardRequest) GetShardName() string

func (*CreateShardRequest) Marshal added in v0.10.0 

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

func (*CreateShardRequest) MarshalTo added in v0.10.0 

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

func (*CreateShardRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*CreateShardRequest) ProtoMessage added in v0.10.0 

func (*CreateShardRequest) ProtoMessage()

func (*CreateShardRequest) Reset added in v0.10.0 

func (m *CreateShardRequest) Reset()

func (*CreateShardRequest) Size added in v0.10.0 

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

func (*CreateShardRequest) String added in v0.10.0 

func (m *CreateShardRequest) String() string

func (*CreateShardRequest) Unmarshal added in v0.10.0 

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

func (*CreateShardRequest) XXX_DiscardUnknown added in v0.10.0 

func (m *CreateShardRequest) XXX_DiscardUnknown()

func (*CreateShardRequest) XXX_Marshal added in v0.10.0 

func (m *CreateShardRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateShardRequest) XXX_Merge added in v0.10.0 

func (m *CreateShardRequest) XXX_Merge(src proto.Message)

func (*CreateShardRequest) XXX_Size added in v0.10.0 

func (m *CreateShardRequest) XXX_Size() int

func (*CreateShardRequest) XXX_Unmarshal added in v0.10.0 

func (m *CreateShardRequest) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateShardResponse) Descriptor added in v0.10.0 

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

func (*CreateShardResponse) GetKeyspace added in v0.10.0 

func (m *CreateShardResponse) GetKeyspace() *Keyspace

func (*CreateShardResponse) GetShard added in v0.10.0 

func (m *CreateShardResponse) GetShard() *Shard

func (*CreateShardResponse) GetShardAlreadyExists added in v0.10.0 

func (m *CreateShardResponse) GetShardAlreadyExists() bool

func (*CreateShardResponse) Marshal added in v0.10.0 

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

func (*CreateShardResponse) MarshalTo added in v0.10.0 

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

func (*CreateShardResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*CreateShardResponse) ProtoMessage added in v0.10.0 

func (*CreateShardResponse) ProtoMessage()

func (*CreateShardResponse) Reset added in v0.10.0 

func (m *CreateShardResponse) Reset()

func (*CreateShardResponse) Size added in v0.10.0 

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

func (*CreateShardResponse) String added in v0.10.0 

func (m *CreateShardResponse) String() string

func (*CreateShardResponse) Unmarshal added in v0.10.0 

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

func (*CreateShardResponse) XXX_DiscardUnknown added in v0.10.0 

func (m *CreateShardResponse) XXX_DiscardUnknown()

func (*CreateShardResponse) XXX_Marshal added in v0.10.0 

func (m *CreateShardResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateShardResponse) XXX_Merge added in v0.10.0 

func (m *CreateShardResponse) XXX_Merge(src proto.Message)

func (*CreateShardResponse) XXX_Size added in v0.10.0 

func (m *CreateShardResponse) XXX_Size() int

func (*CreateShardResponse) XXX_Unmarshal added in v0.10.0 

func (m *CreateShardResponse) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteKeyspaceRequest) Descriptor added in v0.10.0 

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

func (*DeleteKeyspaceRequest) GetKeyspace added in v0.10.0 

func (m *DeleteKeyspaceRequest) GetKeyspace() string

func (*DeleteKeyspaceRequest) GetRecursive added in v0.10.0 

func (m *DeleteKeyspaceRequest) GetRecursive() bool

func (*DeleteKeyspaceRequest) Marshal added in v0.10.0 

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

func (*DeleteKeyspaceRequest) MarshalTo added in v0.10.0 

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

func (*DeleteKeyspaceRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*DeleteKeyspaceRequest) ProtoMessage added in v0.10.0 

func (*DeleteKeyspaceRequest) ProtoMessage()

func (*DeleteKeyspaceRequest) Reset added in v0.10.0 

func (m *DeleteKeyspaceRequest) Reset()

func (*DeleteKeyspaceRequest) Size added in v0.10.0 

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

func (*DeleteKeyspaceRequest) String added in v0.10.0 

func (m *DeleteKeyspaceRequest) String() string

func (*DeleteKeyspaceRequest) Unmarshal added in v0.10.0 

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

func (*DeleteKeyspaceRequest) XXX_DiscardUnknown added in v0.10.0 

func (m *DeleteKeyspaceRequest) XXX_DiscardUnknown()

func (*DeleteKeyspaceRequest) XXX_Marshal added in v0.10.0 

func (m *DeleteKeyspaceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteKeyspaceRequest) XXX_Merge added in v0.10.0 

func (m *DeleteKeyspaceRequest) XXX_Merge(src proto.Message)

func (*DeleteKeyspaceRequest) XXX_Size added in v0.10.0 

func (m *DeleteKeyspaceRequest) XXX_Size() int

func (*DeleteKeyspaceRequest) XXX_Unmarshal added in v0.10.0 

func (m *DeleteKeyspaceRequest) XXX_Unmarshal(b []byte) error

type DeleteKeyspaceResponse added in v0.10.0 

type DeleteKeyspaceResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteKeyspaceResponse) Descriptor added in v0.10.0 

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

func (*DeleteKeyspaceResponse) Marshal added in v0.10.0 

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

func (*DeleteKeyspaceResponse) MarshalTo added in v0.10.0 

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

func (*DeleteKeyspaceResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*DeleteKeyspaceResponse) ProtoMessage added in v0.10.0 

func (*DeleteKeyspaceResponse) ProtoMessage()

func (*DeleteKeyspaceResponse) Reset added in v0.10.0 

func (m *DeleteKeyspaceResponse) Reset()

func (*DeleteKeyspaceResponse) Size added in v0.10.0 

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

func (*DeleteKeyspaceResponse) String added in v0.10.0 

func (m *DeleteKeyspaceResponse) String() string

func (*DeleteKeyspaceResponse) Unmarshal added in v0.10.0 

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

func (*DeleteKeyspaceResponse) XXX_DiscardUnknown added in v0.10.0 

func (m *DeleteKeyspaceResponse) XXX_DiscardUnknown()

func (*DeleteKeyspaceResponse) XXX_Marshal added in v0.10.0 

func (m *DeleteKeyspaceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteKeyspaceResponse) XXX_Merge added in v0.10.0 

func (m *DeleteKeyspaceResponse) XXX_Merge(src proto.Message)

func (*DeleteKeyspaceResponse) XXX_Size added in v0.10.0 

func (m *DeleteKeyspaceResponse) XXX_Size() int

func (*DeleteKeyspaceResponse) XXX_Unmarshal added in v0.10.0 

func (m *DeleteKeyspaceResponse) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteShardsRequest) Descriptor added in v0.10.0 

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

func (*DeleteShardsRequest) GetEvenIfServing added in v0.10.0 

func (m *DeleteShardsRequest) GetEvenIfServing() bool

func (*DeleteShardsRequest) GetRecursive added in v0.10.0 

func (m *DeleteShardsRequest) GetRecursive() bool

func (*DeleteShardsRequest) GetShards added in v0.10.0 

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

func (*DeleteShardsRequest) Marshal added in v0.10.0 

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

func (*DeleteShardsRequest) MarshalTo added in v0.10.0 

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

func (*DeleteShardsRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*DeleteShardsRequest) ProtoMessage added in v0.10.0 

func (*DeleteShardsRequest) ProtoMessage()

func (*DeleteShardsRequest) Reset added in v0.10.0 

func (m *DeleteShardsRequest) Reset()

func (*DeleteShardsRequest) Size added in v0.10.0 

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

func (*DeleteShardsRequest) String added in v0.10.0 

func (m *DeleteShardsRequest) String() string

func (*DeleteShardsRequest) Unmarshal added in v0.10.0 

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

func (*DeleteShardsRequest) XXX_DiscardUnknown added in v0.10.0 

func (m *DeleteShardsRequest) XXX_DiscardUnknown()

func (*DeleteShardsRequest) XXX_Marshal added in v0.10.0 

func (m *DeleteShardsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteShardsRequest) XXX_Merge added in v0.10.0 

func (m *DeleteShardsRequest) XXX_Merge(src proto.Message)

func (*DeleteShardsRequest) XXX_Size added in v0.10.0 

func (m *DeleteShardsRequest) XXX_Size() int

func (*DeleteShardsRequest) XXX_Unmarshal added in v0.10.0 

func (m *DeleteShardsRequest) XXX_Unmarshal(b []byte) error

type DeleteShardsResponse added in v0.10.0 

type DeleteShardsResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteShardsResponse) Descriptor added in v0.10.0 

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

func (*DeleteShardsResponse) Marshal added in v0.10.0 

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

func (*DeleteShardsResponse) MarshalTo added in v0.10.0 

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

func (*DeleteShardsResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*DeleteShardsResponse) ProtoMessage added in v0.10.0 

func (*DeleteShardsResponse) ProtoMessage()

func (*DeleteShardsResponse) Reset added in v0.10.0 

func (m *DeleteShardsResponse) Reset()

func (*DeleteShardsResponse) Size added in v0.10.0 

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

func (*DeleteShardsResponse) String added in v0.10.0 

func (m *DeleteShardsResponse) String() string

func (*DeleteShardsResponse) Unmarshal added in v0.10.0 

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

func (*DeleteShardsResponse) XXX_DiscardUnknown added in v0.10.0 

func (m *DeleteShardsResponse) XXX_DiscardUnknown()

func (*DeleteShardsResponse) XXX_Marshal added in v0.10.0 

func (m *DeleteShardsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteShardsResponse) XXX_Merge added in v0.10.0 

func (m *DeleteShardsResponse) XXX_Merge(src proto.Message)

func (*DeleteShardsResponse) XXX_Size added in v0.10.0 

func (m *DeleteShardsResponse) XXX_Size() int

func (*DeleteShardsResponse) XXX_Unmarshal added in v0.10.0 

func (m *DeleteShardsResponse) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteTabletsRequest) Descriptor added in v0.10.0 

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

func (*DeleteTabletsRequest) GetAllowPrimary added in v0.10.0 

func (m *DeleteTabletsRequest) GetAllowPrimary() bool

func (*DeleteTabletsRequest) GetTabletAliases added in v0.10.0 

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

func (*DeleteTabletsRequest) Marshal added in v0.10.0 

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

func (*DeleteTabletsRequest) MarshalTo added in v0.10.0 

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

func (*DeleteTabletsRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*DeleteTabletsRequest) ProtoMessage added in v0.10.0 

func (*DeleteTabletsRequest) ProtoMessage()

func (*DeleteTabletsRequest) Reset added in v0.10.0 

func (m *DeleteTabletsRequest) Reset()

func (*DeleteTabletsRequest) Size added in v0.10.0 

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

func (*DeleteTabletsRequest) String added in v0.10.0 

func (m *DeleteTabletsRequest) String() string

func (*DeleteTabletsRequest) Unmarshal added in v0.10.0 

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

func (*DeleteTabletsRequest) XXX_DiscardUnknown added in v0.10.0 

func (m *DeleteTabletsRequest) XXX_DiscardUnknown()

func (*DeleteTabletsRequest) XXX_Marshal added in v0.10.0 

func (m *DeleteTabletsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteTabletsRequest) XXX_Merge added in v0.10.0 

func (m *DeleteTabletsRequest) XXX_Merge(src proto.Message)

func (*DeleteTabletsRequest) XXX_Size added in v0.10.0 

func (m *DeleteTabletsRequest) XXX_Size() int

func (*DeleteTabletsRequest) XXX_Unmarshal added in v0.10.0 

func (m *DeleteTabletsRequest) XXX_Unmarshal(b []byte) error

type DeleteTabletsResponse added in v0.10.0 

type DeleteTabletsResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteTabletsResponse) Descriptor added in v0.10.0 

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

func (*DeleteTabletsResponse) Marshal added in v0.10.0 

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

func (*DeleteTabletsResponse) MarshalTo added in v0.10.0 

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

func (*DeleteTabletsResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*DeleteTabletsResponse) ProtoMessage added in v0.10.0 

func (*DeleteTabletsResponse) ProtoMessage()

func (*DeleteTabletsResponse) Reset added in v0.10.0 

func (m *DeleteTabletsResponse) Reset()

func (*DeleteTabletsResponse) Size added in v0.10.0 

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

func (*DeleteTabletsResponse) String added in v0.10.0 

func (m *DeleteTabletsResponse) String() string

func (*DeleteTabletsResponse) Unmarshal added in v0.10.0 

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

func (*DeleteTabletsResponse) XXX_DiscardUnknown added in v0.10.0 

func (m *DeleteTabletsResponse) XXX_DiscardUnknown()

func (*DeleteTabletsResponse) XXX_Marshal added in v0.10.0 

func (m *DeleteTabletsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteTabletsResponse) XXX_Merge added in v0.10.0 

func (m *DeleteTabletsResponse) XXX_Merge(src proto.Message)

func (*DeleteTabletsResponse) XXX_Size added in v0.10.0 

func (m *DeleteTabletsResponse) XXX_Size() int

func (*DeleteTabletsResponse) XXX_Unmarshal added in v0.10.0 

func (m *DeleteTabletsResponse) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*EmergencyReparentShardRequest) Descriptor added in v0.10.0 

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

func (*EmergencyReparentShardRequest) GetIgnoreReplicas added in v0.10.0 

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

func (*EmergencyReparentShardRequest) GetKeyspace added in v0.10.0 

func (m *EmergencyReparentShardRequest) GetKeyspace() string

func (*EmergencyReparentShardRequest) GetNewPrimary added in v0.10.0 

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

func (*EmergencyReparentShardRequest) GetShard added in v0.10.0 

func (m *EmergencyReparentShardRequest) GetShard() string

func (*EmergencyReparentShardRequest) GetWaitReplicasTimeout added in v0.10.0 

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

func (*EmergencyReparentShardRequest) Marshal added in v0.10.0 

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

func (*EmergencyReparentShardRequest) MarshalTo added in v0.10.0 

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

func (*EmergencyReparentShardRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*EmergencyReparentShardRequest) ProtoMessage added in v0.10.0 

func (*EmergencyReparentShardRequest) ProtoMessage()

func (*EmergencyReparentShardRequest) Reset added in v0.10.0 

func (m *EmergencyReparentShardRequest) Reset()

func (*EmergencyReparentShardRequest) Size added in v0.10.0 

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

func (*EmergencyReparentShardRequest) String added in v0.10.0 

func (m *EmergencyReparentShardRequest) String() string

func (*EmergencyReparentShardRequest) Unmarshal added in v0.10.0 

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

func (*EmergencyReparentShardRequest) XXX_DiscardUnknown added in v0.10.0 

func (m *EmergencyReparentShardRequest) XXX_DiscardUnknown()

func (*EmergencyReparentShardRequest) XXX_Marshal added in v0.10.0 

func (m *EmergencyReparentShardRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EmergencyReparentShardRequest) XXX_Merge added in v0.10.0 

func (m *EmergencyReparentShardRequest) XXX_Merge(src proto.Message)

func (*EmergencyReparentShardRequest) XXX_Size added in v0.10.0 

func (m *EmergencyReparentShardRequest) XXX_Size() int

func (*EmergencyReparentShardRequest) XXX_Unmarshal added in v0.10.0 

func (m *EmergencyReparentShardRequest) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*EmergencyReparentShardResponse) Descriptor added in v0.10.0 

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

func (*EmergencyReparentShardResponse) GetEvents added in v0.10.0 

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

func (*EmergencyReparentShardResponse) GetKeyspace added in v0.10.0 

func (m *EmergencyReparentShardResponse) GetKeyspace() string

func (*EmergencyReparentShardResponse) GetPromotedPrimary added in v0.10.0 

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

func (*EmergencyReparentShardResponse) GetShard added in v0.10.0 

func (m *EmergencyReparentShardResponse) GetShard() string

func (*EmergencyReparentShardResponse) Marshal added in v0.10.0 

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

func (*EmergencyReparentShardResponse) MarshalTo added in v0.10.0 

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

func (*EmergencyReparentShardResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*EmergencyReparentShardResponse) ProtoMessage added in v0.10.0 

func (*EmergencyReparentShardResponse) ProtoMessage()

func (*EmergencyReparentShardResponse) Reset added in v0.10.0 

func (m *EmergencyReparentShardResponse) Reset()

func (*EmergencyReparentShardResponse) Size added in v0.10.0 

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

func (*EmergencyReparentShardResponse) String added in v0.10.0 

func (m *EmergencyReparentShardResponse) String() string

func (*EmergencyReparentShardResponse) Unmarshal added in v0.10.0 

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

func (*EmergencyReparentShardResponse) XXX_DiscardUnknown added in v0.10.0 

func (m *EmergencyReparentShardResponse) XXX_DiscardUnknown()

func (*EmergencyReparentShardResponse) XXX_Marshal added in v0.10.0 

func (m *EmergencyReparentShardResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EmergencyReparentShardResponse) XXX_Merge added in v0.10.0 

func (m *EmergencyReparentShardResponse) XXX_Merge(src proto.Message)

func (*EmergencyReparentShardResponse) XXX_Size added in v0.10.0 

func (m *EmergencyReparentShardResponse) XXX_Size() int

func (*EmergencyReparentShardResponse) XXX_Unmarshal added in v0.10.0 

func (m *EmergencyReparentShardResponse) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*ExecuteVtctlCommandRequest) Descriptor 

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

func (*ExecuteVtctlCommandRequest) GetActionTimeout 

func (m *ExecuteVtctlCommandRequest) GetActionTimeout() int64

func (*ExecuteVtctlCommandRequest) GetArgs 

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

func (*ExecuteVtctlCommandRequest) Marshal added in v0.10.0 

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

func (*ExecuteVtctlCommandRequest) MarshalTo added in v0.10.0 

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

func (*ExecuteVtctlCommandRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*ExecuteVtctlCommandRequest) ProtoMessage 

func (*ExecuteVtctlCommandRequest) ProtoMessage()

func (*ExecuteVtctlCommandRequest) Reset 

func (m *ExecuteVtctlCommandRequest) Reset()

func (*ExecuteVtctlCommandRequest) Size added in v0.10.0 

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

func (*ExecuteVtctlCommandRequest) String 

func (m *ExecuteVtctlCommandRequest) String() string

func (*ExecuteVtctlCommandRequest) Unmarshal added in v0.10.0 

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

func (*ExecuteVtctlCommandRequest) XXX_DiscardUnknown 

func (m *ExecuteVtctlCommandRequest) XXX_DiscardUnknown()

func (*ExecuteVtctlCommandRequest) XXX_Marshal 

func (m *ExecuteVtctlCommandRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExecuteVtctlCommandRequest) XXX_Merge 

func (m *ExecuteVtctlCommandRequest) XXX_Merge(src proto.Message)

func (*ExecuteVtctlCommandRequest) XXX_Size 

func (m *ExecuteVtctlCommandRequest) XXX_Size() int

func (*ExecuteVtctlCommandRequest) XXX_Unmarshal 

func (m *ExecuteVtctlCommandRequest) XXX_Unmarshal(b []byte) error

type ExecuteVtctlCommandResponse 

type ExecuteVtctlCommandResponse struct {
	Event                *logutil.Event `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

ExecuteVtctlCommandResponse is streamed back by ExecuteVtctlCommand.

func (*ExecuteVtctlCommandResponse) Descriptor 

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

func (*ExecuteVtctlCommandResponse) GetEvent 

func (m *ExecuteVtctlCommandResponse) GetEvent() *logutil.Event

func (*ExecuteVtctlCommandResponse) Marshal added in v0.10.0 

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

func (*ExecuteVtctlCommandResponse) MarshalTo added in v0.10.0 

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

func (*ExecuteVtctlCommandResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*ExecuteVtctlCommandResponse) ProtoMessage 

func (*ExecuteVtctlCommandResponse) ProtoMessage()

func (*ExecuteVtctlCommandResponse) Reset 

func (m *ExecuteVtctlCommandResponse) Reset()

func (*ExecuteVtctlCommandResponse) Size added in v0.10.0 

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

func (*ExecuteVtctlCommandResponse) String 

func (m *ExecuteVtctlCommandResponse) String() string

func (*ExecuteVtctlCommandResponse) Unmarshal added in v0.10.0 

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

func (*ExecuteVtctlCommandResponse) XXX_DiscardUnknown 

func (m *ExecuteVtctlCommandResponse) XXX_DiscardUnknown()

func (*ExecuteVtctlCommandResponse) XXX_Marshal 

func (m *ExecuteVtctlCommandResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExecuteVtctlCommandResponse) XXX_Merge 

func (m *ExecuteVtctlCommandResponse) XXX_Merge(src proto.Message)

func (*ExecuteVtctlCommandResponse) XXX_Size 

func (m *ExecuteVtctlCommandResponse) XXX_Size() int

func (*ExecuteVtctlCommandResponse) XXX_Unmarshal 

func (m *ExecuteVtctlCommandResponse) XXX_Unmarshal(b []byte) error

type FindAllShardsInKeyspaceRequest added in v0.9.0 

type FindAllShardsInKeyspaceRequest struct {
	Keyspace             string   `protobuf:"bytes,1,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FindAllShardsInKeyspaceRequest) Descriptor added in v0.9.0 

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

func (*FindAllShardsInKeyspaceRequest) GetKeyspace added in v0.9.0 

func (m *FindAllShardsInKeyspaceRequest) GetKeyspace() string

func (*FindAllShardsInKeyspaceRequest) Marshal added in v0.10.0 

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

func (*FindAllShardsInKeyspaceRequest) MarshalTo added in v0.10.0 

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

func (*FindAllShardsInKeyspaceRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*FindAllShardsInKeyspaceRequest) ProtoMessage added in v0.9.0 

func (*FindAllShardsInKeyspaceRequest) ProtoMessage()

func (*FindAllShardsInKeyspaceRequest) Reset added in v0.9.0 

func (m *FindAllShardsInKeyspaceRequest) Reset()

func (*FindAllShardsInKeyspaceRequest) Size added in v0.10.0 

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

func (*FindAllShardsInKeyspaceRequest) String added in v0.9.0 

func (m *FindAllShardsInKeyspaceRequest) String() string

func (*FindAllShardsInKeyspaceRequest) Unmarshal added in v0.10.0 

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

func (*FindAllShardsInKeyspaceRequest) XXX_DiscardUnknown added in v0.9.0 

func (m *FindAllShardsInKeyspaceRequest) XXX_DiscardUnknown()

func (*FindAllShardsInKeyspaceRequest) XXX_Marshal added in v0.9.0 

func (m *FindAllShardsInKeyspaceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FindAllShardsInKeyspaceRequest) XXX_Merge added in v0.9.0 

func (m *FindAllShardsInKeyspaceRequest) XXX_Merge(src proto.Message)

func (*FindAllShardsInKeyspaceRequest) XXX_Size added in v0.9.0 

func (m *FindAllShardsInKeyspaceRequest) XXX_Size() int

func (*FindAllShardsInKeyspaceRequest) XXX_Unmarshal added in v0.9.0 

func (m *FindAllShardsInKeyspaceRequest) XXX_Unmarshal(b []byte) error

type FindAllShardsInKeyspaceResponse added in v0.9.0 

type FindAllShardsInKeyspaceResponse struct {
	Shards               map[string]*Shard `` /* 153-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*FindAllShardsInKeyspaceResponse) Descriptor added in v0.9.0 

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

func (*FindAllShardsInKeyspaceResponse) GetShards added in v0.9.0 

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

func (*FindAllShardsInKeyspaceResponse) Marshal added in v0.10.0 

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

func (*FindAllShardsInKeyspaceResponse) MarshalTo added in v0.10.0 

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

func (*FindAllShardsInKeyspaceResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*FindAllShardsInKeyspaceResponse) ProtoMessage added in v0.9.0 

func (*FindAllShardsInKeyspaceResponse) ProtoMessage()

func (*FindAllShardsInKeyspaceResponse) Reset added in v0.9.0 

func (m *FindAllShardsInKeyspaceResponse) Reset()

func (*FindAllShardsInKeyspaceResponse) Size added in v0.10.0 

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

func (*FindAllShardsInKeyspaceResponse) String added in v0.9.0 

func (m *FindAllShardsInKeyspaceResponse) String() string

func (*FindAllShardsInKeyspaceResponse) Unmarshal added in v0.10.0 

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

func (*FindAllShardsInKeyspaceResponse) XXX_DiscardUnknown added in v0.9.0 

func (m *FindAllShardsInKeyspaceResponse) XXX_DiscardUnknown()

func (*FindAllShardsInKeyspaceResponse) XXX_Marshal added in v0.9.0 

func (m *FindAllShardsInKeyspaceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FindAllShardsInKeyspaceResponse) XXX_Merge added in v0.9.0 

func (m *FindAllShardsInKeyspaceResponse) XXX_Merge(src proto.Message)

func (*FindAllShardsInKeyspaceResponse) XXX_Size added in v0.9.0 

func (m *FindAllShardsInKeyspaceResponse) XXX_Size() int

func (*FindAllShardsInKeyspaceResponse) XXX_Unmarshal added in v0.9.0 

func (m *FindAllShardsInKeyspaceResponse) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetBackupsRequest) Descriptor added in v0.10.0 

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

func (*GetBackupsRequest) GetKeyspace added in v0.10.0 

func (m *GetBackupsRequest) GetKeyspace() string

func (*GetBackupsRequest) GetShard added in v0.10.0 

func (m *GetBackupsRequest) GetShard() string

func (*GetBackupsRequest) Marshal added in v0.10.0 

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

func (*GetBackupsRequest) MarshalTo added in v0.10.0 

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

func (*GetBackupsRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*GetBackupsRequest) ProtoMessage added in v0.10.0 

func (*GetBackupsRequest) ProtoMessage()

func (*GetBackupsRequest) Reset added in v0.10.0 

func (m *GetBackupsRequest) Reset()

func (*GetBackupsRequest) Size added in v0.10.0 

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

func (*GetBackupsRequest) String added in v0.10.0 

func (m *GetBackupsRequest) String() string

func (*GetBackupsRequest) Unmarshal added in v0.10.0 

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

func (*GetBackupsRequest) XXX_DiscardUnknown added in v0.10.0 

func (m *GetBackupsRequest) XXX_DiscardUnknown()

func (*GetBackupsRequest) XXX_Marshal added in v0.10.0 

func (m *GetBackupsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetBackupsRequest) XXX_Merge added in v0.10.0 

func (m *GetBackupsRequest) XXX_Merge(src proto.Message)

func (*GetBackupsRequest) XXX_Size added in v0.10.0 

func (m *GetBackupsRequest) XXX_Size() int

func (*GetBackupsRequest) XXX_Unmarshal added in v0.10.0 

func (m *GetBackupsRequest) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*GetBackupsResponse) Descriptor added in v0.10.0 

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

func (*GetBackupsResponse) GetBackups added in v0.10.0 

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

func (*GetBackupsResponse) Marshal added in v0.10.0 

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

func (*GetBackupsResponse) MarshalTo added in v0.10.0 

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

func (*GetBackupsResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*GetBackupsResponse) ProtoMessage added in v0.10.0 

func (*GetBackupsResponse) ProtoMessage()

func (*GetBackupsResponse) Reset added in v0.10.0 

func (m *GetBackupsResponse) Reset()

func (*GetBackupsResponse) Size added in v0.10.0 

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

func (*GetBackupsResponse) String added in v0.10.0 

func (m *GetBackupsResponse) String() string

func (*GetBackupsResponse) Unmarshal added in v0.10.0 

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

func (*GetBackupsResponse) XXX_DiscardUnknown added in v0.10.0 

func (m *GetBackupsResponse) XXX_DiscardUnknown()

func (*GetBackupsResponse) XXX_Marshal added in v0.10.0 

func (m *GetBackupsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetBackupsResponse) XXX_Merge added in v0.10.0 

func (m *GetBackupsResponse) XXX_Merge(src proto.Message)

func (*GetBackupsResponse) XXX_Size added in v0.10.0 

func (m *GetBackupsResponse) XXX_Size() int

func (*GetBackupsResponse) XXX_Unmarshal added in v0.10.0 

func (m *GetBackupsResponse) XXX_Unmarshal(b []byte) error

type GetCellInfoNamesRequest added in v0.10.0 

type GetCellInfoNamesRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetCellInfoNamesRequest) Descriptor added in v0.10.0 

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

func (*GetCellInfoNamesRequest) Marshal added in v0.10.0 

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

func (*GetCellInfoNamesRequest) MarshalTo added in v0.10.0 

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

func (*GetCellInfoNamesRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*GetCellInfoNamesRequest) ProtoMessage added in v0.10.0 

func (*GetCellInfoNamesRequest) ProtoMessage()

func (*GetCellInfoNamesRequest) Reset added in v0.10.0 

func (m *GetCellInfoNamesRequest) Reset()

func (*GetCellInfoNamesRequest) Size added in v0.10.0 

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

func (*GetCellInfoNamesRequest) String added in v0.10.0 

func (m *GetCellInfoNamesRequest) String() string

func (*GetCellInfoNamesRequest) Unmarshal added in v0.10.0 

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

func (*GetCellInfoNamesRequest) XXX_DiscardUnknown added in v0.10.0 

func (m *GetCellInfoNamesRequest) XXX_DiscardUnknown()

func (*GetCellInfoNamesRequest) XXX_Marshal added in v0.10.0 

func (m *GetCellInfoNamesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetCellInfoNamesRequest) XXX_Merge added in v0.10.0 

func (m *GetCellInfoNamesRequest) XXX_Merge(src proto.Message)

func (*GetCellInfoNamesRequest) XXX_Size added in v0.10.0 

func (m *GetCellInfoNamesRequest) XXX_Size() int

func (*GetCellInfoNamesRequest) XXX_Unmarshal added in v0.10.0 

func (m *GetCellInfoNamesRequest) XXX_Unmarshal(b []byte) error

type GetCellInfoNamesResponse added in v0.10.0 

type GetCellInfoNamesResponse struct {
	Names                []string `protobuf:"bytes,1,rep,name=names,proto3" json:"names,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetCellInfoNamesResponse) Descriptor added in v0.10.0 

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

func (*GetCellInfoNamesResponse) GetNames added in v0.10.0 

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

func (*GetCellInfoNamesResponse) Marshal added in v0.10.0 

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

func (*GetCellInfoNamesResponse) MarshalTo added in v0.10.0 

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

func (*GetCellInfoNamesResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*GetCellInfoNamesResponse) ProtoMessage added in v0.10.0 

func (*GetCellInfoNamesResponse) ProtoMessage()

func (*GetCellInfoNamesResponse) Reset added in v0.10.0 

func (m *GetCellInfoNamesResponse) Reset()

func (*GetCellInfoNamesResponse) Size added in v0.10.0 

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

func (*GetCellInfoNamesResponse) String added in v0.10.0 

func (m *GetCellInfoNamesResponse) String() string

func (*GetCellInfoNamesResponse) Unmarshal added in v0.10.0 

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

func (*GetCellInfoNamesResponse) XXX_DiscardUnknown added in v0.10.0 

func (m *GetCellInfoNamesResponse) XXX_DiscardUnknown()

func (*GetCellInfoNamesResponse) XXX_Marshal added in v0.10.0 

func (m *GetCellInfoNamesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetCellInfoNamesResponse) XXX_Merge added in v0.10.0 

func (m *GetCellInfoNamesResponse) XXX_Merge(src proto.Message)

func (*GetCellInfoNamesResponse) XXX_Size added in v0.10.0 

func (m *GetCellInfoNamesResponse) XXX_Size() int

func (*GetCellInfoNamesResponse) XXX_Unmarshal added in v0.10.0 

func (m *GetCellInfoNamesResponse) XXX_Unmarshal(b []byte) error

type GetCellInfoRequest added in v0.10.0 

type GetCellInfoRequest struct {
	Cell                 string   `protobuf:"bytes,1,opt,name=cell,proto3" json:"cell,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetCellInfoRequest) Descriptor added in v0.10.0 

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

func (*GetCellInfoRequest) GetCell added in v0.10.0 

func (m *GetCellInfoRequest) GetCell() string

func (*GetCellInfoRequest) Marshal added in v0.10.0 

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

func (*GetCellInfoRequest) MarshalTo added in v0.10.0 

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

func (*GetCellInfoRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*GetCellInfoRequest) ProtoMessage added in v0.10.0 

func (*GetCellInfoRequest) ProtoMessage()

func (*GetCellInfoRequest) Reset added in v0.10.0 

func (m *GetCellInfoRequest) Reset()

func (*GetCellInfoRequest) Size added in v0.10.0 

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

func (*GetCellInfoRequest) String added in v0.10.0 

func (m *GetCellInfoRequest) String() string

func (*GetCellInfoRequest) Unmarshal added in v0.10.0 

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

func (*GetCellInfoRequest) XXX_DiscardUnknown added in v0.10.0 

func (m *GetCellInfoRequest) XXX_DiscardUnknown()

func (*GetCellInfoRequest) XXX_Marshal added in v0.10.0 

func (m *GetCellInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetCellInfoRequest) XXX_Merge added in v0.10.0 

func (m *GetCellInfoRequest) XXX_Merge(src proto.Message)

func (*GetCellInfoRequest) XXX_Size added in v0.10.0 

func (m *GetCellInfoRequest) XXX_Size() int

func (*GetCellInfoRequest) XXX_Unmarshal added in v0.10.0 

func (m *GetCellInfoRequest) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*GetCellInfoResponse) Descriptor added in v0.10.0 

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

func (*GetCellInfoResponse) GetCellInfo added in v0.10.0 

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

func (*GetCellInfoResponse) Marshal added in v0.10.0 

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

func (*GetCellInfoResponse) MarshalTo added in v0.10.0 

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

func (*GetCellInfoResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*GetCellInfoResponse) ProtoMessage added in v0.10.0 

func (*GetCellInfoResponse) ProtoMessage()

func (*GetCellInfoResponse) Reset added in v0.10.0 

func (m *GetCellInfoResponse) Reset()

func (*GetCellInfoResponse) Size added in v0.10.0 

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

func (*GetCellInfoResponse) String added in v0.10.0 

func (m *GetCellInfoResponse) String() string

func (*GetCellInfoResponse) Unmarshal added in v0.10.0 

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

func (*GetCellInfoResponse) XXX_DiscardUnknown added in v0.10.0 

func (m *GetCellInfoResponse) XXX_DiscardUnknown()

func (*GetCellInfoResponse) XXX_Marshal added in v0.10.0 

func (m *GetCellInfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetCellInfoResponse) XXX_Merge added in v0.10.0 

func (m *GetCellInfoResponse) XXX_Merge(src proto.Message)

func (*GetCellInfoResponse) XXX_Size added in v0.10.0 

func (m *GetCellInfoResponse) XXX_Size() int

func (*GetCellInfoResponse) XXX_Unmarshal added in v0.10.0 

func (m *GetCellInfoResponse) XXX_Unmarshal(b []byte) error

type GetCellsAliasesRequest added in v0.10.0 

type GetCellsAliasesRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetCellsAliasesRequest) Descriptor added in v0.10.0 

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

func (*GetCellsAliasesRequest) Marshal added in v0.10.0 

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

func (*GetCellsAliasesRequest) MarshalTo added in v0.10.0 

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

func (*GetCellsAliasesRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*GetCellsAliasesRequest) ProtoMessage added in v0.10.0 

func (*GetCellsAliasesRequest) ProtoMessage()

func (*GetCellsAliasesRequest) Reset added in v0.10.0 

func (m *GetCellsAliasesRequest) Reset()

func (*GetCellsAliasesRequest) Size added in v0.10.0 

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

func (*GetCellsAliasesRequest) String added in v0.10.0 

func (m *GetCellsAliasesRequest) String() string

func (*GetCellsAliasesRequest) Unmarshal added in v0.10.0 

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

func (*GetCellsAliasesRequest) XXX_DiscardUnknown added in v0.10.0 

func (m *GetCellsAliasesRequest) XXX_DiscardUnknown()

func (*GetCellsAliasesRequest) XXX_Marshal added in v0.10.0 

func (m *GetCellsAliasesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetCellsAliasesRequest) XXX_Merge added in v0.10.0 

func (m *GetCellsAliasesRequest) XXX_Merge(src proto.Message)

func (*GetCellsAliasesRequest) XXX_Size added in v0.10.0 

func (m *GetCellsAliasesRequest) XXX_Size() int

func (*GetCellsAliasesRequest) XXX_Unmarshal added in v0.10.0 

func (m *GetCellsAliasesRequest) XXX_Unmarshal(b []byte) error

type GetCellsAliasesResponse added in v0.10.0 

type GetCellsAliasesResponse struct {
	Aliases              map[string]*topodata.CellsAlias `` /* 155-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

func (*GetCellsAliasesResponse) Descriptor added in v0.10.0 

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

func (*GetCellsAliasesResponse) GetAliases added in v0.10.0 

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

func (*GetCellsAliasesResponse) Marshal added in v0.10.0 

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

func (*GetCellsAliasesResponse) MarshalTo added in v0.10.0 

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

func (*GetCellsAliasesResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*GetCellsAliasesResponse) ProtoMessage added in v0.10.0 

func (*GetCellsAliasesResponse) ProtoMessage()

func (*GetCellsAliasesResponse) Reset added in v0.10.0 

func (m *GetCellsAliasesResponse) Reset()

func (*GetCellsAliasesResponse) Size added in v0.10.0 

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

func (*GetCellsAliasesResponse) String added in v0.10.0 

func (m *GetCellsAliasesResponse) String() string

func (*GetCellsAliasesResponse) Unmarshal added in v0.10.0 

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

func (*GetCellsAliasesResponse) XXX_DiscardUnknown added in v0.10.0 

func (m *GetCellsAliasesResponse) XXX_DiscardUnknown()

func (*GetCellsAliasesResponse) XXX_Marshal added in v0.10.0 

func (m *GetCellsAliasesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetCellsAliasesResponse) XXX_Merge added in v0.10.0 

func (m *GetCellsAliasesResponse) XXX_Merge(src proto.Message)

func (*GetCellsAliasesResponse) XXX_Size added in v0.10.0 

func (m *GetCellsAliasesResponse) XXX_Size() int

func (*GetCellsAliasesResponse) XXX_Unmarshal added in v0.10.0 

func (m *GetCellsAliasesResponse) XXX_Unmarshal(b []byte) error

type GetKeyspaceRequest added in v0.9.0 

type GetKeyspaceRequest struct {
	Keyspace             string   `protobuf:"bytes,1,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetKeyspaceRequest) Descriptor added in v0.9.0 

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

func (*GetKeyspaceRequest) GetKeyspace added in v0.9.0 

func (m *GetKeyspaceRequest) GetKeyspace() string

func (*GetKeyspaceRequest) Marshal added in v0.10.0 

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

func (*GetKeyspaceRequest) MarshalTo added in v0.10.0 

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

func (*GetKeyspaceRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*GetKeyspaceRequest) ProtoMessage added in v0.9.0 

func (*GetKeyspaceRequest) ProtoMessage()

func (*GetKeyspaceRequest) Reset added in v0.9.0 

func (m *GetKeyspaceRequest) Reset()

func (*GetKeyspaceRequest) Size added in v0.10.0 

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

func (*GetKeyspaceRequest) String added in v0.9.0 

func (m *GetKeyspaceRequest) String() string

func (*GetKeyspaceRequest) Unmarshal added in v0.10.0 

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

func (*GetKeyspaceRequest) XXX_DiscardUnknown added in v0.9.0 

func (m *GetKeyspaceRequest) XXX_DiscardUnknown()

func (*GetKeyspaceRequest) XXX_Marshal added in v0.9.0 

func (m *GetKeyspaceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetKeyspaceRequest) XXX_Merge added in v0.9.0 

func (m *GetKeyspaceRequest) XXX_Merge(src proto.Message)

func (*GetKeyspaceRequest) XXX_Size added in v0.9.0 

func (m *GetKeyspaceRequest) XXX_Size() int

func (*GetKeyspaceRequest) XXX_Unmarshal added in v0.9.0 

func (m *GetKeyspaceRequest) XXX_Unmarshal(b []byte) error

type GetKeyspaceResponse added in v0.9.0 

type GetKeyspaceResponse struct {
	Keyspace             *Keyspace `protobuf:"bytes,1,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*GetKeyspaceResponse) Descriptor added in v0.9.0 

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

func (*GetKeyspaceResponse) GetKeyspace added in v0.9.0 

func (m *GetKeyspaceResponse) GetKeyspace() *Keyspace

func (*GetKeyspaceResponse) Marshal added in v0.10.0 

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

func (*GetKeyspaceResponse) MarshalTo added in v0.10.0 

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

func (*GetKeyspaceResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*GetKeyspaceResponse) ProtoMessage added in v0.9.0 

func (*GetKeyspaceResponse) ProtoMessage()

func (*GetKeyspaceResponse) Reset added in v0.9.0 

func (m *GetKeyspaceResponse) Reset()

func (*GetKeyspaceResponse) Size added in v0.10.0 

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

func (*GetKeyspaceResponse) String added in v0.9.0 

func (m *GetKeyspaceResponse) String() string

func (*GetKeyspaceResponse) Unmarshal added in v0.10.0 

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

func (*GetKeyspaceResponse) XXX_DiscardUnknown added in v0.9.0 

func (m *GetKeyspaceResponse) XXX_DiscardUnknown()

func (*GetKeyspaceResponse) XXX_Marshal added in v0.9.0 

func (m *GetKeyspaceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetKeyspaceResponse) XXX_Merge added in v0.9.0 

func (m *GetKeyspaceResponse) XXX_Merge(src proto.Message)

func (*GetKeyspaceResponse) XXX_Size added in v0.9.0 

func (m *GetKeyspaceResponse) XXX_Size() int

func (*GetKeyspaceResponse) XXX_Unmarshal added in v0.9.0 

func (m *GetKeyspaceResponse) XXX_Unmarshal(b []byte) error

type GetKeyspacesRequest added in v0.9.0 

type GetKeyspacesRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetKeyspacesRequest) Descriptor added in v0.9.0 

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

func (*GetKeyspacesRequest) Marshal added in v0.10.0 

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

func (*GetKeyspacesRequest) MarshalTo added in v0.10.0 

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

func (*GetKeyspacesRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*GetKeyspacesRequest) ProtoMessage added in v0.9.0 

func (*GetKeyspacesRequest) ProtoMessage()

func (*GetKeyspacesRequest) Reset added in v0.9.0 

func (m *GetKeyspacesRequest) Reset()

func (*GetKeyspacesRequest) Size added in v0.10.0 

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

func (*GetKeyspacesRequest) String added in v0.9.0 

func (m *GetKeyspacesRequest) String() string

func (*GetKeyspacesRequest) Unmarshal added in v0.10.0 

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

func (*GetKeyspacesRequest) XXX_DiscardUnknown added in v0.9.0 

func (m *GetKeyspacesRequest) XXX_DiscardUnknown()

func (*GetKeyspacesRequest) XXX_Marshal added in v0.9.0 

func (m *GetKeyspacesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetKeyspacesRequest) XXX_Merge added in v0.9.0 

func (m *GetKeyspacesRequest) XXX_Merge(src proto.Message)

func (*GetKeyspacesRequest) XXX_Size added in v0.9.0 

func (m *GetKeyspacesRequest) XXX_Size() int

func (*GetKeyspacesRequest) XXX_Unmarshal added in v0.9.0 

func (m *GetKeyspacesRequest) XXX_Unmarshal(b []byte) error

type GetKeyspacesResponse added in v0.9.0 

type GetKeyspacesResponse struct {
	Keyspaces            []*Keyspace `protobuf:"bytes,1,rep,name=keyspaces,proto3" json:"keyspaces,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*GetKeyspacesResponse) Descriptor added in v0.9.0 

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

func (*GetKeyspacesResponse) GetKeyspaces added in v0.9.0 

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

func (*GetKeyspacesResponse) Marshal added in v0.10.0 

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

func (*GetKeyspacesResponse) MarshalTo added in v0.10.0 

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

func (*GetKeyspacesResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*GetKeyspacesResponse) ProtoMessage added in v0.9.0 

func (*GetKeyspacesResponse) ProtoMessage()

func (*GetKeyspacesResponse) Reset added in v0.9.0 

func (m *GetKeyspacesResponse) Reset()

func (*GetKeyspacesResponse) Size added in v0.10.0 

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

func (*GetKeyspacesResponse) String added in v0.9.0 

func (m *GetKeyspacesResponse) String() string

func (*GetKeyspacesResponse) Unmarshal added in v0.10.0 

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

func (*GetKeyspacesResponse) XXX_DiscardUnknown added in v0.9.0 

func (m *GetKeyspacesResponse) XXX_DiscardUnknown()

func (*GetKeyspacesResponse) XXX_Marshal added in v0.9.0 

func (m *GetKeyspacesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetKeyspacesResponse) XXX_Merge added in v0.9.0 

func (m *GetKeyspacesResponse) XXX_Merge(src proto.Message)

func (*GetKeyspacesResponse) XXX_Size added in v0.9.0 

func (m *GetKeyspacesResponse) XXX_Size() int

func (*GetKeyspacesResponse) XXX_Unmarshal added in v0.9.0 

func (m *GetKeyspacesResponse) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetSchemaRequest) Descriptor added in v0.10.0 

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

func (*GetSchemaRequest) GetExcludeTables added in v0.10.0 

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

func (*GetSchemaRequest) GetIncludeViews added in v0.10.0 

func (m *GetSchemaRequest) GetIncludeViews() bool

func (*GetSchemaRequest) GetTableNamesOnly added in v0.10.0 

func (m *GetSchemaRequest) GetTableNamesOnly() bool

func (*GetSchemaRequest) GetTableSizesOnly added in v0.10.0 

func (m *GetSchemaRequest) GetTableSizesOnly() bool

func (*GetSchemaRequest) GetTables added in v0.10.0 

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

func (*GetSchemaRequest) GetTabletAlias added in v0.10.0 

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

func (*GetSchemaRequest) Marshal added in v0.10.0 

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

func (*GetSchemaRequest) MarshalTo added in v0.10.0 

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

func (*GetSchemaRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*GetSchemaRequest) ProtoMessage added in v0.10.0 

func (*GetSchemaRequest) ProtoMessage()

func (*GetSchemaRequest) Reset added in v0.10.0 

func (m *GetSchemaRequest) Reset()

func (*GetSchemaRequest) Size added in v0.10.0 

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

func (*GetSchemaRequest) String added in v0.10.0 

func (m *GetSchemaRequest) String() string

func (*GetSchemaRequest) Unmarshal added in v0.10.0 

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

func (*GetSchemaRequest) XXX_DiscardUnknown added in v0.10.0 

func (m *GetSchemaRequest) XXX_DiscardUnknown()

func (*GetSchemaRequest) XXX_Marshal added in v0.10.0 

func (m *GetSchemaRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetSchemaRequest) XXX_Merge added in v0.10.0 

func (m *GetSchemaRequest) XXX_Merge(src proto.Message)

func (*GetSchemaRequest) XXX_Size added in v0.10.0 

func (m *GetSchemaRequest) XXX_Size() int

func (*GetSchemaRequest) XXX_Unmarshal added in v0.10.0 

func (m *GetSchemaRequest) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{}                            `json:"-"`
	XXX_unrecognized     []byte                              `json:"-"`
	XXX_sizecache        int32                               `json:"-"`
}

func (*GetSchemaResponse) Descriptor added in v0.10.0 

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

func (*GetSchemaResponse) GetSchema added in v0.10.0 

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

func (*GetSchemaResponse) Marshal added in v0.10.0 

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

func (*GetSchemaResponse) MarshalTo added in v0.10.0 

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

func (*GetSchemaResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*GetSchemaResponse) ProtoMessage added in v0.10.0 

func (*GetSchemaResponse) ProtoMessage()

func (*GetSchemaResponse) Reset added in v0.10.0 

func (m *GetSchemaResponse) Reset()

func (*GetSchemaResponse) Size added in v0.10.0 

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

func (*GetSchemaResponse) String added in v0.10.0 

func (m *GetSchemaResponse) String() string

func (*GetSchemaResponse) Unmarshal added in v0.10.0 

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

func (*GetSchemaResponse) XXX_DiscardUnknown added in v0.10.0 

func (m *GetSchemaResponse) XXX_DiscardUnknown()

func (*GetSchemaResponse) XXX_Marshal added in v0.10.0 

func (m *GetSchemaResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetSchemaResponse) XXX_Merge added in v0.10.0 

func (m *GetSchemaResponse) XXX_Merge(src proto.Message)

func (*GetSchemaResponse) XXX_Size added in v0.10.0 

func (m *GetSchemaResponse) XXX_Size() int

func (*GetSchemaResponse) XXX_Unmarshal added in v0.10.0 

func (m *GetSchemaResponse) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetShardRequest) Descriptor added in v0.10.0 

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

func (*GetShardRequest) GetKeyspace added in v0.10.0 

func (m *GetShardRequest) GetKeyspace() string

func (*GetShardRequest) GetShardName added in v0.10.0 

func (m *GetShardRequest) GetShardName() string

func (*GetShardRequest) Marshal added in v0.10.0 

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

func (*GetShardRequest) MarshalTo added in v0.10.0 

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

func (*GetShardRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*GetShardRequest) ProtoMessage added in v0.10.0 

func (*GetShardRequest) ProtoMessage()

func (*GetShardRequest) Reset added in v0.10.0 

func (m *GetShardRequest) Reset()

func (*GetShardRequest) Size added in v0.10.0 

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

func (*GetShardRequest) String added in v0.10.0 

func (m *GetShardRequest) String() string

func (*GetShardRequest) Unmarshal added in v0.10.0 

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

func (*GetShardRequest) XXX_DiscardUnknown added in v0.10.0 

func (m *GetShardRequest) XXX_DiscardUnknown()

func (*GetShardRequest) XXX_Marshal added in v0.10.0 

func (m *GetShardRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetShardRequest) XXX_Merge added in v0.10.0 

func (m *GetShardRequest) XXX_Merge(src proto.Message)

func (*GetShardRequest) XXX_Size added in v0.10.0 

func (m *GetShardRequest) XXX_Size() int

func (*GetShardRequest) XXX_Unmarshal added in v0.10.0 

func (m *GetShardRequest) XXX_Unmarshal(b []byte) error

type GetShardResponse added in v0.10.0 

type GetShardResponse struct {
	Shard                *Shard   `protobuf:"bytes,1,opt,name=shard,proto3" json:"shard,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetShardResponse) Descriptor added in v0.10.0 

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

func (*GetShardResponse) GetShard added in v0.10.0 

func (m *GetShardResponse) GetShard() *Shard

func (*GetShardResponse) Marshal added in v0.10.0 

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

func (*GetShardResponse) MarshalTo added in v0.10.0 

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

func (*GetShardResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*GetShardResponse) ProtoMessage added in v0.10.0 

func (*GetShardResponse) ProtoMessage()

func (*GetShardResponse) Reset added in v0.10.0 

func (m *GetShardResponse) Reset()

func (*GetShardResponse) Size added in v0.10.0 

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

func (*GetShardResponse) String added in v0.10.0 

func (m *GetShardResponse) String() string

func (*GetShardResponse) Unmarshal added in v0.10.0 

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

func (*GetShardResponse) XXX_DiscardUnknown added in v0.10.0 

func (m *GetShardResponse) XXX_DiscardUnknown()

func (*GetShardResponse) XXX_Marshal added in v0.10.0 

func (m *GetShardResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetShardResponse) XXX_Merge added in v0.10.0 

func (m *GetShardResponse) XXX_Merge(src proto.Message)

func (*GetShardResponse) XXX_Size added in v0.10.0 

func (m *GetShardResponse) XXX_Size() int

func (*GetShardResponse) XXX_Unmarshal added in v0.10.0 

func (m *GetShardResponse) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetSrvKeyspacesRequest) Descriptor added in v0.10.0 

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

func (*GetSrvKeyspacesRequest) GetCells added in v0.10.0 

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

func (*GetSrvKeyspacesRequest) GetKeyspace added in v0.10.0 

func (m *GetSrvKeyspacesRequest) GetKeyspace() string

func (*GetSrvKeyspacesRequest) Marshal added in v0.10.0 

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

func (*GetSrvKeyspacesRequest) MarshalTo added in v0.10.0 

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

func (*GetSrvKeyspacesRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*GetSrvKeyspacesRequest) ProtoMessage added in v0.10.0 

func (*GetSrvKeyspacesRequest) ProtoMessage()

func (*GetSrvKeyspacesRequest) Reset added in v0.10.0 

func (m *GetSrvKeyspacesRequest) Reset()

func (*GetSrvKeyspacesRequest) Size added in v0.10.0 

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

func (*GetSrvKeyspacesRequest) String added in v0.10.0 

func (m *GetSrvKeyspacesRequest) String() string

func (*GetSrvKeyspacesRequest) Unmarshal added in v0.10.0 

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

func (*GetSrvKeyspacesRequest) XXX_DiscardUnknown added in v0.10.0 

func (m *GetSrvKeyspacesRequest) XXX_DiscardUnknown()

func (*GetSrvKeyspacesRequest) XXX_Marshal added in v0.10.0 

func (m *GetSrvKeyspacesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetSrvKeyspacesRequest) XXX_Merge added in v0.10.0 

func (m *GetSrvKeyspacesRequest) XXX_Merge(src proto.Message)

func (*GetSrvKeyspacesRequest) XXX_Size added in v0.10.0 

func (m *GetSrvKeyspacesRequest) XXX_Size() int

func (*GetSrvKeyspacesRequest) XXX_Unmarshal added in v0.10.0 

func (m *GetSrvKeyspacesRequest) XXX_Unmarshal(b []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 */
	XXX_NoUnkeyedLiteral struct{}                         `json:"-"`
	XXX_unrecognized     []byte                           `json:"-"`
	XXX_sizecache        int32                            `json:"-"`
}

func (*GetSrvKeyspacesResponse) Descriptor added in v0.10.0 

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

func (*GetSrvKeyspacesResponse) GetSrvKeyspaces added in v0.10.0 

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

func (*GetSrvKeyspacesResponse) Marshal added in v0.10.0 

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

func (*GetSrvKeyspacesResponse) MarshalTo added in v0.10.0 

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

func (*GetSrvKeyspacesResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*GetSrvKeyspacesResponse) ProtoMessage added in v0.10.0 

func (*GetSrvKeyspacesResponse) ProtoMessage()

func (*GetSrvKeyspacesResponse) Reset added in v0.10.0 

func (m *GetSrvKeyspacesResponse) Reset()

func (*GetSrvKeyspacesResponse) Size added in v0.10.0 

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

func (*GetSrvKeyspacesResponse) String added in v0.10.0 

func (m *GetSrvKeyspacesResponse) String() string

func (*GetSrvKeyspacesResponse) Unmarshal added in v0.10.0 

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

func (*GetSrvKeyspacesResponse) XXX_DiscardUnknown added in v0.10.0 

func (m *GetSrvKeyspacesResponse) XXX_DiscardUnknown()

func (*GetSrvKeyspacesResponse) XXX_Marshal added in v0.10.0 

func (m *GetSrvKeyspacesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetSrvKeyspacesResponse) XXX_Merge added in v0.10.0 

func (m *GetSrvKeyspacesResponse) XXX_Merge(src proto.Message)

func (*GetSrvKeyspacesResponse) XXX_Size added in v0.10.0 

func (m *GetSrvKeyspacesResponse) XXX_Size() int

func (*GetSrvKeyspacesResponse) XXX_Unmarshal added in v0.10.0 

func (m *GetSrvKeyspacesResponse) XXX_Unmarshal(b []byte) error

type GetSrvVSchemaRequest added in v0.10.0 

type GetSrvVSchemaRequest struct {
	Cell                 string   `protobuf:"bytes,1,opt,name=cell,proto3" json:"cell,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetSrvVSchemaRequest) Descriptor added in v0.10.0 

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

func (*GetSrvVSchemaRequest) GetCell added in v0.10.0 

func (m *GetSrvVSchemaRequest) GetCell() string

func (*GetSrvVSchemaRequest) Marshal added in v0.10.0 

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

func (*GetSrvVSchemaRequest) MarshalTo added in v0.10.0 

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

func (*GetSrvVSchemaRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*GetSrvVSchemaRequest) ProtoMessage added in v0.10.0 

func (*GetSrvVSchemaRequest) ProtoMessage()

func (*GetSrvVSchemaRequest) Reset added in v0.10.0 

func (m *GetSrvVSchemaRequest) Reset()

func (*GetSrvVSchemaRequest) Size added in v0.10.0 

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

func (*GetSrvVSchemaRequest) String added in v0.10.0 

func (m *GetSrvVSchemaRequest) String() string

func (*GetSrvVSchemaRequest) Unmarshal added in v0.10.0 

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

func (*GetSrvVSchemaRequest) XXX_DiscardUnknown added in v0.10.0 

func (m *GetSrvVSchemaRequest) XXX_DiscardUnknown()

func (*GetSrvVSchemaRequest) XXX_Marshal added in v0.10.0 

func (m *GetSrvVSchemaRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetSrvVSchemaRequest) XXX_Merge added in v0.10.0 

func (m *GetSrvVSchemaRequest) XXX_Merge(src proto.Message)

func (*GetSrvVSchemaRequest) XXX_Size added in v0.10.0 

func (m *GetSrvVSchemaRequest) XXX_Size() int

func (*GetSrvVSchemaRequest) XXX_Unmarshal added in v0.10.0 

func (m *GetSrvVSchemaRequest) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*GetSrvVSchemaResponse) Descriptor added in v0.10.0 

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

func (*GetSrvVSchemaResponse) GetSrvVSchema added in v0.10.0 

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

func (*GetSrvVSchemaResponse) Marshal added in v0.10.0 

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

func (*GetSrvVSchemaResponse) MarshalTo added in v0.10.0 

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

func (*GetSrvVSchemaResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*GetSrvVSchemaResponse) ProtoMessage added in v0.10.0 

func (*GetSrvVSchemaResponse) ProtoMessage()

func (*GetSrvVSchemaResponse) Reset added in v0.10.0 

func (m *GetSrvVSchemaResponse) Reset()

func (*GetSrvVSchemaResponse) Size added in v0.10.0 

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

func (*GetSrvVSchemaResponse) String added in v0.10.0 

func (m *GetSrvVSchemaResponse) String() string

func (*GetSrvVSchemaResponse) Unmarshal added in v0.10.0 

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

func (*GetSrvVSchemaResponse) XXX_DiscardUnknown added in v0.10.0 

func (m *GetSrvVSchemaResponse) XXX_DiscardUnknown()

func (*GetSrvVSchemaResponse) XXX_Marshal added in v0.10.0 

func (m *GetSrvVSchemaResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetSrvVSchemaResponse) XXX_Merge added in v0.10.0 

func (m *GetSrvVSchemaResponse) XXX_Merge(src proto.Message)

func (*GetSrvVSchemaResponse) XXX_Size added in v0.10.0 

func (m *GetSrvVSchemaResponse) XXX_Size() int

func (*GetSrvVSchemaResponse) XXX_Unmarshal added in v0.10.0 

func (m *GetSrvVSchemaResponse) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*GetTabletRequest) Descriptor added in v0.10.0 

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

func (*GetTabletRequest) GetTabletAlias added in v0.10.0 

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

func (*GetTabletRequest) Marshal added in v0.10.0 

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

func (*GetTabletRequest) MarshalTo added in v0.10.0 

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

func (*GetTabletRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*GetTabletRequest) ProtoMessage added in v0.10.0 

func (*GetTabletRequest) ProtoMessage()

func (*GetTabletRequest) Reset added in v0.10.0 

func (m *GetTabletRequest) Reset()

func (*GetTabletRequest) Size added in v0.10.0 

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

func (*GetTabletRequest) String added in v0.10.0 

func (m *GetTabletRequest) String() string

func (*GetTabletRequest) Unmarshal added in v0.10.0 

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

func (*GetTabletRequest) XXX_DiscardUnknown added in v0.10.0 

func (m *GetTabletRequest) XXX_DiscardUnknown()

func (*GetTabletRequest) XXX_Marshal added in v0.10.0 

func (m *GetTabletRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetTabletRequest) XXX_Merge added in v0.10.0 

func (m *GetTabletRequest) XXX_Merge(src proto.Message)

func (*GetTabletRequest) XXX_Size added in v0.10.0 

func (m *GetTabletRequest) XXX_Size() int

func (*GetTabletRequest) XXX_Unmarshal added in v0.10.0 

func (m *GetTabletRequest) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*GetTabletResponse) Descriptor added in v0.10.0 

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

func (*GetTabletResponse) GetTablet added in v0.10.0 

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

func (*GetTabletResponse) Marshal added in v0.10.0 

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

func (*GetTabletResponse) MarshalTo added in v0.10.0 

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

func (*GetTabletResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*GetTabletResponse) ProtoMessage added in v0.10.0 

func (*GetTabletResponse) ProtoMessage()

func (*GetTabletResponse) Reset added in v0.10.0 

func (m *GetTabletResponse) Reset()

func (*GetTabletResponse) Size added in v0.10.0 

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

func (*GetTabletResponse) String added in v0.10.0 

func (m *GetTabletResponse) String() string

func (*GetTabletResponse) Unmarshal added in v0.10.0 

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

func (*GetTabletResponse) XXX_DiscardUnknown added in v0.10.0 

func (m *GetTabletResponse) XXX_DiscardUnknown()

func (*GetTabletResponse) XXX_Marshal added in v0.10.0 

func (m *GetTabletResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetTabletResponse) XXX_Merge added in v0.10.0 

func (m *GetTabletResponse) XXX_Merge(src proto.Message)

func (*GetTabletResponse) XXX_Size added in v0.10.0 

func (m *GetTabletResponse) XXX_Size() int

func (*GetTabletResponse) XXX_Unmarshal added in v0.10.0 

func (m *GetTabletResponse) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*GetTabletsRequest) Descriptor added in v0.10.0 

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

func (*GetTabletsRequest) GetCells added in v0.10.0 

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

func (*GetTabletsRequest) GetKeyspace added in v0.10.0 

func (m *GetTabletsRequest) GetKeyspace() string

func (*GetTabletsRequest) GetShard added in v0.10.0 

func (m *GetTabletsRequest) GetShard() string

func (*GetTabletsRequest) GetStrict added in v0.10.0 

func (m *GetTabletsRequest) GetStrict() bool

func (*GetTabletsRequest) GetTabletAliases added in v0.10.0 

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

func (*GetTabletsRequest) Marshal added in v0.10.0 

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

func (*GetTabletsRequest) MarshalTo added in v0.10.0 

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

func (*GetTabletsRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*GetTabletsRequest) ProtoMessage added in v0.10.0 

func (*GetTabletsRequest) ProtoMessage()

func (*GetTabletsRequest) Reset added in v0.10.0 

func (m *GetTabletsRequest) Reset()

func (*GetTabletsRequest) Size added in v0.10.0 

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

func (*GetTabletsRequest) String added in v0.10.0 

func (m *GetTabletsRequest) String() string

func (*GetTabletsRequest) Unmarshal added in v0.10.0 

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

func (*GetTabletsRequest) XXX_DiscardUnknown added in v0.10.0 

func (m *GetTabletsRequest) XXX_DiscardUnknown()

func (*GetTabletsRequest) XXX_Marshal added in v0.10.0 

func (m *GetTabletsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetTabletsRequest) XXX_Merge added in v0.10.0 

func (m *GetTabletsRequest) XXX_Merge(src proto.Message)

func (*GetTabletsRequest) XXX_Size added in v0.10.0 

func (m *GetTabletsRequest) XXX_Size() int

func (*GetTabletsRequest) XXX_Unmarshal added in v0.10.0 

func (m *GetTabletsRequest) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*GetTabletsResponse) Descriptor added in v0.10.0 

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

func (*GetTabletsResponse) GetTablets added in v0.10.0 

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

func (*GetTabletsResponse) Marshal added in v0.10.0 

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

func (*GetTabletsResponse) MarshalTo added in v0.10.0 

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

func (*GetTabletsResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*GetTabletsResponse) ProtoMessage added in v0.10.0 

func (*GetTabletsResponse) ProtoMessage()

func (*GetTabletsResponse) Reset added in v0.10.0 

func (m *GetTabletsResponse) Reset()

func (*GetTabletsResponse) Size added in v0.10.0 

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

func (*GetTabletsResponse) String added in v0.10.0 

func (m *GetTabletsResponse) String() string

func (*GetTabletsResponse) Unmarshal added in v0.10.0 

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

func (*GetTabletsResponse) XXX_DiscardUnknown added in v0.10.0 

func (m *GetTabletsResponse) XXX_DiscardUnknown()

func (*GetTabletsResponse) XXX_Marshal added in v0.10.0 

func (m *GetTabletsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetTabletsResponse) XXX_Merge added in v0.10.0 

func (m *GetTabletsResponse) XXX_Merge(src proto.Message)

func (*GetTabletsResponse) XXX_Size added in v0.10.0 

func (m *GetTabletsResponse) XXX_Size() int

func (*GetTabletsResponse) XXX_Unmarshal added in v0.10.0 

func (m *GetTabletsResponse) XXX_Unmarshal(b []byte) error

type GetVSchemaRequest added in v0.10.0 

type GetVSchemaRequest struct {
	Keyspace             string   `protobuf:"bytes,1,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetVSchemaRequest) Descriptor added in v0.10.0 

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

func (*GetVSchemaRequest) GetKeyspace added in v0.10.0 

func (m *GetVSchemaRequest) GetKeyspace() string

func (*GetVSchemaRequest) Marshal added in v0.10.0 

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

func (*GetVSchemaRequest) MarshalTo added in v0.10.0 

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

func (*GetVSchemaRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*GetVSchemaRequest) ProtoMessage added in v0.10.0 

func (*GetVSchemaRequest) ProtoMessage()

func (*GetVSchemaRequest) Reset added in v0.10.0 

func (m *GetVSchemaRequest) Reset()

func (*GetVSchemaRequest) Size added in v0.10.0 

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

func (*GetVSchemaRequest) String added in v0.10.0 

func (m *GetVSchemaRequest) String() string

func (*GetVSchemaRequest) Unmarshal added in v0.10.0 

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

func (*GetVSchemaRequest) XXX_DiscardUnknown added in v0.10.0 

func (m *GetVSchemaRequest) XXX_DiscardUnknown()

func (*GetVSchemaRequest) XXX_Marshal added in v0.10.0 

func (m *GetVSchemaRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetVSchemaRequest) XXX_Merge added in v0.10.0 

func (m *GetVSchemaRequest) XXX_Merge(src proto.Message)

func (*GetVSchemaRequest) XXX_Size added in v0.10.0 

func (m *GetVSchemaRequest) XXX_Size() int

func (*GetVSchemaRequest) XXX_Unmarshal added in v0.10.0 

func (m *GetVSchemaRequest) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*GetVSchemaResponse) Descriptor added in v0.10.0 

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

func (*GetVSchemaResponse) GetVSchema added in v0.10.0 

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

func (*GetVSchemaResponse) Marshal added in v0.10.0 

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

func (*GetVSchemaResponse) MarshalTo added in v0.10.0 

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

func (*GetVSchemaResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*GetVSchemaResponse) ProtoMessage added in v0.10.0 

func (*GetVSchemaResponse) ProtoMessage()

func (*GetVSchemaResponse) Reset added in v0.10.0 

func (m *GetVSchemaResponse) Reset()

func (*GetVSchemaResponse) Size added in v0.10.0 

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

func (*GetVSchemaResponse) String added in v0.10.0 

func (m *GetVSchemaResponse) String() string

func (*GetVSchemaResponse) Unmarshal added in v0.10.0 

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

func (*GetVSchemaResponse) XXX_DiscardUnknown added in v0.10.0 

func (m *GetVSchemaResponse) XXX_DiscardUnknown()

func (*GetVSchemaResponse) XXX_Marshal added in v0.10.0 

func (m *GetVSchemaResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetVSchemaResponse) XXX_Merge added in v0.10.0 

func (m *GetVSchemaResponse) XXX_Merge(src proto.Message)

func (*GetVSchemaResponse) XXX_Size added in v0.10.0 

func (m *GetVSchemaResponse) XXX_Size() int

func (*GetVSchemaResponse) XXX_Unmarshal added in v0.10.0 

func (m *GetVSchemaResponse) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetWorkflowsRequest) Descriptor added in v0.10.0 

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

func (*GetWorkflowsRequest) GetActiveOnly added in v0.10.0 

func (m *GetWorkflowsRequest) GetActiveOnly() bool

func (*GetWorkflowsRequest) GetKeyspace added in v0.10.0 

func (m *GetWorkflowsRequest) GetKeyspace() string

func (*GetWorkflowsRequest) Marshal added in v0.10.0 

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

func (*GetWorkflowsRequest) MarshalTo added in v0.10.0 

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

func (*GetWorkflowsRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*GetWorkflowsRequest) ProtoMessage added in v0.10.0 

func (*GetWorkflowsRequest) ProtoMessage()

func (*GetWorkflowsRequest) Reset added in v0.10.0 

func (m *GetWorkflowsRequest) Reset()

func (*GetWorkflowsRequest) Size added in v0.10.0 

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

func (*GetWorkflowsRequest) String added in v0.10.0 

func (m *GetWorkflowsRequest) String() string

func (*GetWorkflowsRequest) Unmarshal added in v0.10.0 

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

func (*GetWorkflowsRequest) XXX_DiscardUnknown added in v0.10.0 

func (m *GetWorkflowsRequest) XXX_DiscardUnknown()

func (*GetWorkflowsRequest) XXX_Marshal added in v0.10.0 

func (m *GetWorkflowsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetWorkflowsRequest) XXX_Merge added in v0.10.0 

func (m *GetWorkflowsRequest) XXX_Merge(src proto.Message)

func (*GetWorkflowsRequest) XXX_Size added in v0.10.0 

func (m *GetWorkflowsRequest) XXX_Size() int

func (*GetWorkflowsRequest) XXX_Unmarshal added in v0.10.0 

func (m *GetWorkflowsRequest) XXX_Unmarshal(b []byte) error

type GetWorkflowsResponse added in v0.10.0 

type GetWorkflowsResponse struct {
	Workflows            []*Workflow `protobuf:"bytes,1,rep,name=workflows,proto3" json:"workflows,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*GetWorkflowsResponse) Descriptor added in v0.10.0 

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

func (*GetWorkflowsResponse) GetWorkflows added in v0.10.0 

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

func (*GetWorkflowsResponse) Marshal added in v0.10.0 

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

func (*GetWorkflowsResponse) MarshalTo added in v0.10.0 

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

func (*GetWorkflowsResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*GetWorkflowsResponse) ProtoMessage added in v0.10.0 

func (*GetWorkflowsResponse) ProtoMessage()

func (*GetWorkflowsResponse) Reset added in v0.10.0 

func (m *GetWorkflowsResponse) Reset()

func (*GetWorkflowsResponse) Size added in v0.10.0 

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

func (*GetWorkflowsResponse) String added in v0.10.0 

func (m *GetWorkflowsResponse) String() string

func (*GetWorkflowsResponse) Unmarshal added in v0.10.0 

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

func (*GetWorkflowsResponse) XXX_DiscardUnknown added in v0.10.0 

func (m *GetWorkflowsResponse) XXX_DiscardUnknown()

func (*GetWorkflowsResponse) XXX_Marshal added in v0.10.0 

func (m *GetWorkflowsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetWorkflowsResponse) XXX_Merge added in v0.10.0 

func (m *GetWorkflowsResponse) XXX_Merge(src proto.Message)

func (*GetWorkflowsResponse) XXX_Size added in v0.10.0 

func (m *GetWorkflowsResponse) XXX_Size() int

func (*GetWorkflowsResponse) XXX_Unmarshal added in v0.10.0 

func (m *GetWorkflowsResponse) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral    struct{}              `json:"-"`
	XXX_unrecognized        []byte                `json:"-"`
	XXX_sizecache           int32                 `json:"-"`
}

func (*InitShardPrimaryRequest) Descriptor added in v0.10.0 

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

func (*InitShardPrimaryRequest) GetForce added in v0.10.0 

func (m *InitShardPrimaryRequest) GetForce() bool

func (*InitShardPrimaryRequest) GetKeyspace added in v0.10.0 

func (m *InitShardPrimaryRequest) GetKeyspace() string

func (*InitShardPrimaryRequest) GetPrimaryElectTabletAlias added in v0.10.0 

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

func (*InitShardPrimaryRequest) GetShard added in v0.10.0 

func (m *InitShardPrimaryRequest) GetShard() string

func (*InitShardPrimaryRequest) GetWaitReplicasTimeout added in v0.10.0 

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

func (*InitShardPrimaryRequest) Marshal added in v0.10.0 

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

func (*InitShardPrimaryRequest) MarshalTo added in v0.10.0 

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

func (*InitShardPrimaryRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*InitShardPrimaryRequest) ProtoMessage added in v0.10.0 

func (*InitShardPrimaryRequest) ProtoMessage()

func (*InitShardPrimaryRequest) Reset added in v0.10.0 

func (m *InitShardPrimaryRequest) Reset()

func (*InitShardPrimaryRequest) Size added in v0.10.0 

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

func (*InitShardPrimaryRequest) String added in v0.10.0 

func (m *InitShardPrimaryRequest) String() string

func (*InitShardPrimaryRequest) Unmarshal added in v0.10.0 

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

func (*InitShardPrimaryRequest) XXX_DiscardUnknown added in v0.10.0 

func (m *InitShardPrimaryRequest) XXX_DiscardUnknown()

func (*InitShardPrimaryRequest) XXX_Marshal added in v0.10.0 

func (m *InitShardPrimaryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InitShardPrimaryRequest) XXX_Merge added in v0.10.0 

func (m *InitShardPrimaryRequest) XXX_Merge(src proto.Message)

func (*InitShardPrimaryRequest) XXX_Size added in v0.10.0 

func (m *InitShardPrimaryRequest) XXX_Size() int

func (*InitShardPrimaryRequest) XXX_Unmarshal added in v0.10.0 

func (m *InitShardPrimaryRequest) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*InitShardPrimaryResponse) Descriptor added in v0.10.0 

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

func (*InitShardPrimaryResponse) GetEvents added in v0.10.0 

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

func (*InitShardPrimaryResponse) Marshal added in v0.10.0 

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

func (*InitShardPrimaryResponse) MarshalTo added in v0.10.0 

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

func (*InitShardPrimaryResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*InitShardPrimaryResponse) ProtoMessage added in v0.10.0 

func (*InitShardPrimaryResponse) ProtoMessage()

func (*InitShardPrimaryResponse) Reset added in v0.10.0 

func (m *InitShardPrimaryResponse) Reset()

func (*InitShardPrimaryResponse) Size added in v0.10.0 

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

func (*InitShardPrimaryResponse) String added in v0.10.0 

func (m *InitShardPrimaryResponse) String() string

func (*InitShardPrimaryResponse) Unmarshal added in v0.10.0 

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

func (*InitShardPrimaryResponse) XXX_DiscardUnknown added in v0.10.0 

func (m *InitShardPrimaryResponse) XXX_DiscardUnknown()

func (*InitShardPrimaryResponse) XXX_Marshal added in v0.10.0 

func (m *InitShardPrimaryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InitShardPrimaryResponse) XXX_Merge added in v0.10.0 

func (m *InitShardPrimaryResponse) XXX_Merge(src proto.Message)

func (*InitShardPrimaryResponse) XXX_Size added in v0.10.0 

func (m *InitShardPrimaryResponse) XXX_Size() int

func (*InitShardPrimaryResponse) XXX_Unmarshal added in v0.10.0 

func (m *InitShardPrimaryResponse) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*Keyspace) Descriptor added in v0.9.0 

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

func (*Keyspace) GetKeyspace added in v0.9.0 

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

func (*Keyspace) GetName added in v0.9.0 

func (m *Keyspace) GetName() string

func (*Keyspace) Marshal added in v0.10.0 

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

func (*Keyspace) MarshalTo added in v0.10.0 

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

func (*Keyspace) MarshalToSizedBuffer added in v0.10.0 

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

func (*Keyspace) ProtoMessage added in v0.9.0 

func (*Keyspace) ProtoMessage()

func (*Keyspace) Reset added in v0.9.0 

func (m *Keyspace) Reset()

func (*Keyspace) Size added in v0.10.0 

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

func (*Keyspace) String added in v0.9.0 

func (m *Keyspace) String() string

func (*Keyspace) Unmarshal added in v0.10.0 

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

func (*Keyspace) XXX_DiscardUnknown added in v0.9.0 

func (m *Keyspace) XXX_DiscardUnknown()

func (*Keyspace) XXX_Marshal added in v0.9.0 

func (m *Keyspace) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Keyspace) XXX_Merge added in v0.9.0 

func (m *Keyspace) XXX_Merge(src proto.Message)

func (*Keyspace) XXX_Size added in v0.9.0 

func (m *Keyspace) XXX_Size() int

func (*Keyspace) XXX_Unmarshal added in v0.9.0 

func (m *Keyspace) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

MaterializeSettings contains the settings for the Materialize command.

func (*MaterializeSettings) Descriptor 

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

func (*MaterializeSettings) GetCell 

func (m *MaterializeSettings) GetCell() string

func (*MaterializeSettings) GetExternalCluster added in v0.10.0 

func (m *MaterializeSettings) GetExternalCluster() string

func (*MaterializeSettings) GetSourceKeyspace 

func (m *MaterializeSettings) GetSourceKeyspace() string

func (*MaterializeSettings) GetStopAfterCopy 

func (m *MaterializeSettings) GetStopAfterCopy() bool

func (*MaterializeSettings) GetTableSettings 

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

func (*MaterializeSettings) GetTabletTypes 

func (m *MaterializeSettings) GetTabletTypes() string

func (*MaterializeSettings) GetTargetKeyspace 

func (m *MaterializeSettings) GetTargetKeyspace() string

func (*MaterializeSettings) GetWorkflow 

func (m *MaterializeSettings) GetWorkflow() string

func (*MaterializeSettings) Marshal added in v0.10.0 

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

func (*MaterializeSettings) MarshalTo added in v0.10.0 

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

func (*MaterializeSettings) MarshalToSizedBuffer added in v0.10.0 

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

func (*MaterializeSettings) ProtoMessage 

func (*MaterializeSettings) ProtoMessage()

func (*MaterializeSettings) Reset 

func (m *MaterializeSettings) Reset()

func (*MaterializeSettings) Size added in v0.10.0 

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

func (*MaterializeSettings) String 

func (m *MaterializeSettings) String() string

func (*MaterializeSettings) Unmarshal added in v0.10.0 

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

func (*MaterializeSettings) XXX_DiscardUnknown 

func (m *MaterializeSettings) XXX_DiscardUnknown()

func (*MaterializeSettings) XXX_Marshal 

func (m *MaterializeSettings) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MaterializeSettings) XXX_Merge 

func (m *MaterializeSettings) XXX_Merge(src proto.Message)

func (*MaterializeSettings) XXX_Size 

func (m *MaterializeSettings) XXX_Size() int

func (*MaterializeSettings) XXX_Unmarshal 

func (m *MaterializeSettings) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*PlannedReparentShardRequest) Descriptor added in v0.10.0 

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

func (*PlannedReparentShardRequest) GetAvoidPrimary added in v0.10.0 

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

func (*PlannedReparentShardRequest) GetKeyspace added in v0.10.0 

func (m *PlannedReparentShardRequest) GetKeyspace() string

func (*PlannedReparentShardRequest) GetNewPrimary added in v0.10.0 

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

func (*PlannedReparentShardRequest) GetShard added in v0.10.0 

func (m *PlannedReparentShardRequest) GetShard() string

func (*PlannedReparentShardRequest) GetWaitReplicasTimeout added in v0.10.0 

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

func (*PlannedReparentShardRequest) Marshal added in v0.10.0 

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

func (*PlannedReparentShardRequest) MarshalTo added in v0.10.0 

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

func (*PlannedReparentShardRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*PlannedReparentShardRequest) ProtoMessage added in v0.10.0 

func (*PlannedReparentShardRequest) ProtoMessage()

func (*PlannedReparentShardRequest) Reset added in v0.10.0 

func (m *PlannedReparentShardRequest) Reset()

func (*PlannedReparentShardRequest) Size added in v0.10.0 

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

func (*PlannedReparentShardRequest) String added in v0.10.0 

func (m *PlannedReparentShardRequest) String() string

func (*PlannedReparentShardRequest) Unmarshal added in v0.10.0 

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

func (*PlannedReparentShardRequest) XXX_DiscardUnknown added in v0.10.0 

func (m *PlannedReparentShardRequest) XXX_DiscardUnknown()

func (*PlannedReparentShardRequest) XXX_Marshal added in v0.10.0 

func (m *PlannedReparentShardRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PlannedReparentShardRequest) XXX_Merge added in v0.10.0 

func (m *PlannedReparentShardRequest) XXX_Merge(src proto.Message)

func (*PlannedReparentShardRequest) XXX_Size added in v0.10.0 

func (m *PlannedReparentShardRequest) XXX_Size() int

func (*PlannedReparentShardRequest) XXX_Unmarshal added in v0.10.0 

func (m *PlannedReparentShardRequest) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*PlannedReparentShardResponse) Descriptor added in v0.10.0 

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

func (*PlannedReparentShardResponse) GetEvents added in v0.10.0 

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

func (*PlannedReparentShardResponse) GetKeyspace added in v0.10.0 

func (m *PlannedReparentShardResponse) GetKeyspace() string

func (*PlannedReparentShardResponse) GetPromotedPrimary added in v0.10.0 

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

func (*PlannedReparentShardResponse) GetShard added in v0.10.0 

func (m *PlannedReparentShardResponse) GetShard() string

func (*PlannedReparentShardResponse) Marshal added in v0.10.0 

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

func (*PlannedReparentShardResponse) MarshalTo added in v0.10.0 

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

func (*PlannedReparentShardResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*PlannedReparentShardResponse) ProtoMessage added in v0.10.0 

func (*PlannedReparentShardResponse) ProtoMessage()

func (*PlannedReparentShardResponse) Reset added in v0.10.0 

func (m *PlannedReparentShardResponse) Reset()

func (*PlannedReparentShardResponse) Size added in v0.10.0 

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

func (*PlannedReparentShardResponse) String added in v0.10.0 

func (m *PlannedReparentShardResponse) String() string

func (*PlannedReparentShardResponse) Unmarshal added in v0.10.0 

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

func (*PlannedReparentShardResponse) XXX_DiscardUnknown added in v0.10.0 

func (m *PlannedReparentShardResponse) XXX_DiscardUnknown()

func (*PlannedReparentShardResponse) XXX_Marshal added in v0.10.0 

func (m *PlannedReparentShardResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PlannedReparentShardResponse) XXX_Merge added in v0.10.0 

func (m *PlannedReparentShardResponse) XXX_Merge(src proto.Message)

func (*PlannedReparentShardResponse) XXX_Size added in v0.10.0 

func (m *PlannedReparentShardResponse) XXX_Size() int

func (*PlannedReparentShardResponse) XXX_Unmarshal added in v0.10.0 

func (m *PlannedReparentShardResponse) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RemoveKeyspaceCellRequest) Descriptor added in v0.10.0 

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

func (*RemoveKeyspaceCellRequest) GetCell added in v0.10.0 

func (m *RemoveKeyspaceCellRequest) GetCell() string

func (*RemoveKeyspaceCellRequest) GetForce added in v0.10.0 

func (m *RemoveKeyspaceCellRequest) GetForce() bool

func (*RemoveKeyspaceCellRequest) GetKeyspace added in v0.10.0 

func (m *RemoveKeyspaceCellRequest) GetKeyspace() string

func (*RemoveKeyspaceCellRequest) GetRecursive added in v0.10.0 

func (m *RemoveKeyspaceCellRequest) GetRecursive() bool

func (*RemoveKeyspaceCellRequest) Marshal added in v0.10.0 

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

func (*RemoveKeyspaceCellRequest) MarshalTo added in v0.10.0 

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

func (*RemoveKeyspaceCellRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*RemoveKeyspaceCellRequest) ProtoMessage added in v0.10.0 

func (*RemoveKeyspaceCellRequest) ProtoMessage()

func (*RemoveKeyspaceCellRequest) Reset added in v0.10.0 

func (m *RemoveKeyspaceCellRequest) Reset()

func (*RemoveKeyspaceCellRequest) Size added in v0.10.0 

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

func (*RemoveKeyspaceCellRequest) String added in v0.10.0 

func (m *RemoveKeyspaceCellRequest) String() string

func (*RemoveKeyspaceCellRequest) Unmarshal added in v0.10.0 

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

func (*RemoveKeyspaceCellRequest) XXX_DiscardUnknown added in v0.10.0 

func (m *RemoveKeyspaceCellRequest) XXX_DiscardUnknown()

func (*RemoveKeyspaceCellRequest) XXX_Marshal added in v0.10.0 

func (m *RemoveKeyspaceCellRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RemoveKeyspaceCellRequest) XXX_Merge added in v0.10.0 

func (m *RemoveKeyspaceCellRequest) XXX_Merge(src proto.Message)

func (*RemoveKeyspaceCellRequest) XXX_Size added in v0.10.0 

func (m *RemoveKeyspaceCellRequest) XXX_Size() int

func (*RemoveKeyspaceCellRequest) XXX_Unmarshal added in v0.10.0 

func (m *RemoveKeyspaceCellRequest) XXX_Unmarshal(b []byte) error

type RemoveKeyspaceCellResponse added in v0.10.0 

type RemoveKeyspaceCellResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RemoveKeyspaceCellResponse) Descriptor added in v0.10.0 

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

func (*RemoveKeyspaceCellResponse) Marshal added in v0.10.0 

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

func (*RemoveKeyspaceCellResponse) MarshalTo added in v0.10.0 

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

func (*RemoveKeyspaceCellResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*RemoveKeyspaceCellResponse) ProtoMessage added in v0.10.0 

func (*RemoveKeyspaceCellResponse) ProtoMessage()

func (*RemoveKeyspaceCellResponse) Reset added in v0.10.0 

func (m *RemoveKeyspaceCellResponse) Reset()

func (*RemoveKeyspaceCellResponse) Size added in v0.10.0 

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

func (*RemoveKeyspaceCellResponse) String added in v0.10.0 

func (m *RemoveKeyspaceCellResponse) String() string

func (*RemoveKeyspaceCellResponse) Unmarshal added in v0.10.0 

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

func (*RemoveKeyspaceCellResponse) XXX_DiscardUnknown added in v0.10.0 

func (m *RemoveKeyspaceCellResponse) XXX_DiscardUnknown()

func (*RemoveKeyspaceCellResponse) XXX_Marshal added in v0.10.0 

func (m *RemoveKeyspaceCellResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RemoveKeyspaceCellResponse) XXX_Merge added in v0.10.0 

func (m *RemoveKeyspaceCellResponse) XXX_Merge(src proto.Message)

func (*RemoveKeyspaceCellResponse) XXX_Size added in v0.10.0 

func (m *RemoveKeyspaceCellResponse) XXX_Size() int

func (*RemoveKeyspaceCellResponse) XXX_Unmarshal added in v0.10.0 

func (m *RemoveKeyspaceCellResponse) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RemoveShardCellRequest) Descriptor added in v0.10.0 

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

func (*RemoveShardCellRequest) GetCell added in v0.10.0 

func (m *RemoveShardCellRequest) GetCell() string

func (*RemoveShardCellRequest) GetForce added in v0.10.0 

func (m *RemoveShardCellRequest) GetForce() bool

func (*RemoveShardCellRequest) GetKeyspace added in v0.10.0 

func (m *RemoveShardCellRequest) GetKeyspace() string

func (*RemoveShardCellRequest) GetRecursive added in v0.10.0 

func (m *RemoveShardCellRequest) GetRecursive() bool

func (*RemoveShardCellRequest) GetShardName added in v0.10.0 

func (m *RemoveShardCellRequest) GetShardName() string

func (*RemoveShardCellRequest) Marshal added in v0.10.0 

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

func (*RemoveShardCellRequest) MarshalTo added in v0.10.0 

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

func (*RemoveShardCellRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*RemoveShardCellRequest) ProtoMessage added in v0.10.0 

func (*RemoveShardCellRequest) ProtoMessage()

func (*RemoveShardCellRequest) Reset added in v0.10.0 

func (m *RemoveShardCellRequest) Reset()

func (*RemoveShardCellRequest) Size added in v0.10.0 

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

func (*RemoveShardCellRequest) String added in v0.10.0 

func (m *RemoveShardCellRequest) String() string

func (*RemoveShardCellRequest) Unmarshal added in v0.10.0 

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

func (*RemoveShardCellRequest) XXX_DiscardUnknown added in v0.10.0 

func (m *RemoveShardCellRequest) XXX_DiscardUnknown()

func (*RemoveShardCellRequest) XXX_Marshal added in v0.10.0 

func (m *RemoveShardCellRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RemoveShardCellRequest) XXX_Merge added in v0.10.0 

func (m *RemoveShardCellRequest) XXX_Merge(src proto.Message)

func (*RemoveShardCellRequest) XXX_Size added in v0.10.0 

func (m *RemoveShardCellRequest) XXX_Size() int

func (*RemoveShardCellRequest) XXX_Unmarshal added in v0.10.0 

func (m *RemoveShardCellRequest) XXX_Unmarshal(b []byte) error

type RemoveShardCellResponse added in v0.10.0 

type RemoveShardCellResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RemoveShardCellResponse) Descriptor added in v0.10.0 

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

func (*RemoveShardCellResponse) Marshal added in v0.10.0 

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

func (*RemoveShardCellResponse) MarshalTo added in v0.10.0 

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

func (*RemoveShardCellResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*RemoveShardCellResponse) ProtoMessage added in v0.10.0 

func (*RemoveShardCellResponse) ProtoMessage()

func (*RemoveShardCellResponse) Reset added in v0.10.0 

func (m *RemoveShardCellResponse) Reset()

func (*RemoveShardCellResponse) Size added in v0.10.0 

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

func (*RemoveShardCellResponse) String added in v0.10.0 

func (m *RemoveShardCellResponse) String() string

func (*RemoveShardCellResponse) Unmarshal added in v0.10.0 

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

func (*RemoveShardCellResponse) XXX_DiscardUnknown added in v0.10.0 

func (m *RemoveShardCellResponse) XXX_DiscardUnknown()

func (*RemoveShardCellResponse) XXX_Marshal added in v0.10.0 

func (m *RemoveShardCellResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RemoveShardCellResponse) XXX_Merge added in v0.10.0 

func (m *RemoveShardCellResponse) XXX_Merge(src proto.Message)

func (*RemoveShardCellResponse) XXX_Size added in v0.10.0 

func (m *RemoveShardCellResponse) XXX_Size() int

func (*RemoveShardCellResponse) XXX_Unmarshal added in v0.10.0 

func (m *RemoveShardCellResponse) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*ReparentTabletRequest) Descriptor added in v0.10.0 

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

func (*ReparentTabletRequest) GetTablet added in v0.10.0 

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

func (*ReparentTabletRequest) Marshal added in v0.10.0 

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

func (*ReparentTabletRequest) MarshalTo added in v0.10.0 

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

func (*ReparentTabletRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*ReparentTabletRequest) ProtoMessage added in v0.10.0 

func (*ReparentTabletRequest) ProtoMessage()

func (*ReparentTabletRequest) Reset added in v0.10.0 

func (m *ReparentTabletRequest) Reset()

func (*ReparentTabletRequest) Size added in v0.10.0 

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

func (*ReparentTabletRequest) String added in v0.10.0 

func (m *ReparentTabletRequest) String() string

func (*ReparentTabletRequest) Unmarshal added in v0.10.0 

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

func (*ReparentTabletRequest) XXX_DiscardUnknown added in v0.10.0 

func (m *ReparentTabletRequest) XXX_DiscardUnknown()

func (*ReparentTabletRequest) XXX_Marshal added in v0.10.0 

func (m *ReparentTabletRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReparentTabletRequest) XXX_Merge added in v0.10.0 

func (m *ReparentTabletRequest) XXX_Merge(src proto.Message)

func (*ReparentTabletRequest) XXX_Size added in v0.10.0 

func (m *ReparentTabletRequest) XXX_Size() int

func (*ReparentTabletRequest) XXX_Unmarshal added in v0.10.0 

func (m *ReparentTabletRequest) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*ReparentTabletResponse) Descriptor added in v0.10.0 

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

func (*ReparentTabletResponse) GetKeyspace added in v0.10.0 

func (m *ReparentTabletResponse) GetKeyspace() string

func (*ReparentTabletResponse) GetPrimary added in v0.10.0 

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

func (*ReparentTabletResponse) GetShard added in v0.10.0 

func (m *ReparentTabletResponse) GetShard() string

func (*ReparentTabletResponse) Marshal added in v0.10.0 

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

func (*ReparentTabletResponse) MarshalTo added in v0.10.0 

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

func (*ReparentTabletResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*ReparentTabletResponse) ProtoMessage added in v0.10.0 

func (*ReparentTabletResponse) ProtoMessage()

func (*ReparentTabletResponse) Reset added in v0.10.0 

func (m *ReparentTabletResponse) Reset()

func (*ReparentTabletResponse) Size added in v0.10.0 

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

func (*ReparentTabletResponse) String added in v0.10.0 

func (m *ReparentTabletResponse) String() string

func (*ReparentTabletResponse) Unmarshal added in v0.10.0 

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

func (*ReparentTabletResponse) XXX_DiscardUnknown added in v0.10.0 

func (m *ReparentTabletResponse) XXX_DiscardUnknown()

func (*ReparentTabletResponse) XXX_Marshal added in v0.10.0 

func (m *ReparentTabletResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReparentTabletResponse) XXX_Merge added in v0.10.0 

func (m *ReparentTabletResponse) XXX_Merge(src proto.Message)

func (*ReparentTabletResponse) XXX_Size added in v0.10.0 

func (m *ReparentTabletResponse) XXX_Size() int

func (*ReparentTabletResponse) XXX_Unmarshal added in v0.10.0 

func (m *ReparentTabletResponse) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*Shard) Descriptor added in v0.9.0 

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

func (*Shard) GetKeyspace added in v0.9.0 

func (m *Shard) GetKeyspace() string

func (*Shard) GetName added in v0.9.0 

func (m *Shard) GetName() string

func (*Shard) GetShard added in v0.9.0 

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

func (*Shard) Marshal added in v0.10.0 

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

func (*Shard) MarshalTo added in v0.10.0 

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

func (*Shard) MarshalToSizedBuffer added in v0.10.0 

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

func (*Shard) ProtoMessage added in v0.9.0 

func (*Shard) ProtoMessage()

func (*Shard) Reset added in v0.9.0 

func (m *Shard) Reset()

func (*Shard) Size added in v0.10.0 

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

func (*Shard) String added in v0.9.0 

func (m *Shard) String() string

func (*Shard) Unmarshal added in v0.10.0 

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

func (*Shard) XXX_DiscardUnknown added in v0.9.0 

func (m *Shard) XXX_DiscardUnknown()

func (*Shard) XXX_Marshal added in v0.9.0 

func (m *Shard) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Shard) XXX_Merge added in v0.9.0 

func (m *Shard) XXX_Merge(src proto.Message)

func (*Shard) XXX_Size added in v0.9.0 

func (m *Shard) XXX_Size() int

func (*Shard) XXX_Unmarshal added in v0.9.0 

func (m *Shard) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ShardReplicationPositionsRequest) Descriptor added in v0.10.0 

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

func (*ShardReplicationPositionsRequest) GetKeyspace added in v0.10.0 

func (m *ShardReplicationPositionsRequest) GetKeyspace() string

func (*ShardReplicationPositionsRequest) GetShard added in v0.10.0 

func (m *ShardReplicationPositionsRequest) GetShard() string

func (*ShardReplicationPositionsRequest) Marshal added in v0.10.0 

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

func (*ShardReplicationPositionsRequest) MarshalTo added in v0.10.0 

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

func (*ShardReplicationPositionsRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*ShardReplicationPositionsRequest) ProtoMessage added in v0.10.0 

func (*ShardReplicationPositionsRequest) ProtoMessage()

func (*ShardReplicationPositionsRequest) Reset added in v0.10.0 

func (m *ShardReplicationPositionsRequest) Reset()

func (*ShardReplicationPositionsRequest) Size added in v0.10.0 

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

func (*ShardReplicationPositionsRequest) String added in v0.10.0 

func (m *ShardReplicationPositionsRequest) String() string

func (*ShardReplicationPositionsRequest) Unmarshal added in v0.10.0 

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

func (*ShardReplicationPositionsRequest) XXX_DiscardUnknown added in v0.10.0 

func (m *ShardReplicationPositionsRequest) XXX_DiscardUnknown()

func (*ShardReplicationPositionsRequest) XXX_Marshal added in v0.10.0 

func (m *ShardReplicationPositionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ShardReplicationPositionsRequest) XXX_Merge added in v0.10.0 

func (m *ShardReplicationPositionsRequest) XXX_Merge(src proto.Message)

func (*ShardReplicationPositionsRequest) XXX_Size added in v0.10.0 

func (m *ShardReplicationPositionsRequest) XXX_Size() int

func (*ShardReplicationPositionsRequest) XXX_Unmarshal added in v0.10.0 

func (m *ShardReplicationPositionsRequest) XXX_Unmarshal(b []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 */
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func (*ShardReplicationPositionsResponse) Descriptor added in v0.10.0 

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

func (*ShardReplicationPositionsResponse) GetReplicationStatuses added in v0.10.0 

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

func (*ShardReplicationPositionsResponse) GetTabletMap added in v0.10.0 

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

func (*ShardReplicationPositionsResponse) Marshal added in v0.10.0 

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

func (*ShardReplicationPositionsResponse) MarshalTo added in v0.10.0 

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

func (*ShardReplicationPositionsResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*ShardReplicationPositionsResponse) ProtoMessage added in v0.10.0 

func (*ShardReplicationPositionsResponse) ProtoMessage()

func (*ShardReplicationPositionsResponse) Reset added in v0.10.0 

func (m *ShardReplicationPositionsResponse) Reset()

func (*ShardReplicationPositionsResponse) Size added in v0.10.0 

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

func (*ShardReplicationPositionsResponse) String added in v0.10.0 

func (m *ShardReplicationPositionsResponse) String() string

func (*ShardReplicationPositionsResponse) Unmarshal added in v0.10.0 

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

func (*ShardReplicationPositionsResponse) XXX_DiscardUnknown added in v0.10.0 

func (m *ShardReplicationPositionsResponse) XXX_DiscardUnknown()

func (*ShardReplicationPositionsResponse) XXX_Marshal added in v0.10.0 

func (m *ShardReplicationPositionsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ShardReplicationPositionsResponse) XXX_Merge added in v0.10.0 

func (m *ShardReplicationPositionsResponse) XXX_Merge(src proto.Message)

func (*ShardReplicationPositionsResponse) XXX_Size added in v0.10.0 

func (m *ShardReplicationPositionsResponse) XXX_Size() int

func (*ShardReplicationPositionsResponse) XXX_Unmarshal added in v0.10.0 

func (m *ShardReplicationPositionsResponse) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

TableMaterializeSttings contains the settings for one table.

func (*TableMaterializeSettings) Descriptor 

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

func (*TableMaterializeSettings) GetCreateDdl 

func (m *TableMaterializeSettings) GetCreateDdl() string

func (*TableMaterializeSettings) GetSourceExpression 

func (m *TableMaterializeSettings) GetSourceExpression() string

func (*TableMaterializeSettings) GetTargetTable 

func (m *TableMaterializeSettings) GetTargetTable() string

func (*TableMaterializeSettings) Marshal added in v0.10.0 

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

func (*TableMaterializeSettings) MarshalTo added in v0.10.0 

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

func (*TableMaterializeSettings) MarshalToSizedBuffer added in v0.10.0 

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

func (*TableMaterializeSettings) ProtoMessage 

func (*TableMaterializeSettings) ProtoMessage()

func (*TableMaterializeSettings) Reset 

func (m *TableMaterializeSettings) Reset()

func (*TableMaterializeSettings) Size added in v0.10.0 

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

func (*TableMaterializeSettings) String 

func (m *TableMaterializeSettings) String() string

func (*TableMaterializeSettings) Unmarshal added in v0.10.0 

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

func (*TableMaterializeSettings) XXX_DiscardUnknown 

func (m *TableMaterializeSettings) XXX_DiscardUnknown()

func (*TableMaterializeSettings) XXX_Marshal 

func (m *TableMaterializeSettings) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TableMaterializeSettings) XXX_Merge 

func (m *TableMaterializeSettings) XXX_Merge(src proto.Message)

func (*TableMaterializeSettings) XXX_Size 

func (m *TableMaterializeSettings) XXX_Size() int

func (*TableMaterializeSettings) XXX_Unmarshal 

func (m *TableMaterializeSettings) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*TabletExternallyReparentedRequest) Descriptor added in v0.10.0 

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

func (*TabletExternallyReparentedRequest) GetTablet added in v0.10.0 

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

func (*TabletExternallyReparentedRequest) Marshal added in v0.10.0 

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

func (*TabletExternallyReparentedRequest) MarshalTo added in v0.10.0 

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

func (*TabletExternallyReparentedRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*TabletExternallyReparentedRequest) ProtoMessage added in v0.10.0 

func (*TabletExternallyReparentedRequest) ProtoMessage()

func (*TabletExternallyReparentedRequest) Reset added in v0.10.0 

func (m *TabletExternallyReparentedRequest) Reset()

func (*TabletExternallyReparentedRequest) Size added in v0.10.0 

func (m *TabletExternallyReparentedRequest) Size() (n int)

func (*TabletExternallyReparentedRequest) String added in v0.10.0 

func (m *TabletExternallyReparentedRequest) String() string

func (*TabletExternallyReparentedRequest) Unmarshal added in v0.10.0 

func (m *TabletExternallyReparentedRequest) Unmarshal(dAtA []byte) error

func (*TabletExternallyReparentedRequest) XXX_DiscardUnknown added in v0.10.0 

func (m *TabletExternallyReparentedRequest) XXX_DiscardUnknown()

func (*TabletExternallyReparentedRequest) XXX_Marshal added in v0.10.0 

func (m *TabletExternallyReparentedRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TabletExternallyReparentedRequest) XXX_Merge added in v0.10.0 

func (m *TabletExternallyReparentedRequest) XXX_Merge(src proto.Message)

func (*TabletExternallyReparentedRequest) XXX_Size added in v0.10.0 

func (m *TabletExternallyReparentedRequest) XXX_Size() int

func (*TabletExternallyReparentedRequest) XXX_Unmarshal added in v0.10.0 

func (m *TabletExternallyReparentedRequest) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*TabletExternallyReparentedResponse) Descriptor added in v0.10.0 

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

func (*TabletExternallyReparentedResponse) GetKeyspace added in v0.10.0 

func (m *TabletExternallyReparentedResponse) GetKeyspace() string

func (*TabletExternallyReparentedResponse) GetNewPrimary added in v0.10.0 

func (m *TabletExternallyReparentedResponse) GetNewPrimary() *topodata.TabletAlias

func (*TabletExternallyReparentedResponse) GetOldPrimary added in v0.10.0 

func (m *TabletExternallyReparentedResponse) GetOldPrimary() *topodata.TabletAlias

func (*TabletExternallyReparentedResponse) GetShard added in v0.10.0 

func (m *TabletExternallyReparentedResponse) GetShard() string

func (*TabletExternallyReparentedResponse) Marshal added in v0.10.0 

func (m *TabletExternallyReparentedResponse) Marshal() (dAtA []byte, err error)

func (*TabletExternallyReparentedResponse) MarshalTo added in v0.10.0 

func (m *TabletExternallyReparentedResponse) MarshalTo(dAtA []byte) (int, error)

func (*TabletExternallyReparentedResponse) MarshalToSizedBuffer added in v0.10.0 

func (m *TabletExternallyReparentedResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TabletExternallyReparentedResponse) ProtoMessage added in v0.10.0 

func (*TabletExternallyReparentedResponse) ProtoMessage()

func (*TabletExternallyReparentedResponse) Reset added in v0.10.0 

func (m *TabletExternallyReparentedResponse) Reset()

func (*TabletExternallyReparentedResponse) Size added in v0.10.0 

func (m *TabletExternallyReparentedResponse) Size() (n int)

func (*TabletExternallyReparentedResponse) String added in v0.10.0 

func (m *TabletExternallyReparentedResponse) String() string

func (*TabletExternallyReparentedResponse) Unmarshal added in v0.10.0 

func (m *TabletExternallyReparentedResponse) Unmarshal(dAtA []byte) error

func (*TabletExternallyReparentedResponse) XXX_DiscardUnknown added in v0.10.0 

func (m *TabletExternallyReparentedResponse) XXX_DiscardUnknown()

func (*TabletExternallyReparentedResponse) XXX_Marshal added in v0.10.0 

func (m *TabletExternallyReparentedResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TabletExternallyReparentedResponse) XXX_Merge added in v0.10.0 

func (m *TabletExternallyReparentedResponse) XXX_Merge(src proto.Message)

func (*TabletExternallyReparentedResponse) XXX_Size added in v0.10.0 

func (m *TabletExternallyReparentedResponse) XXX_Size() int

func (*TabletExternallyReparentedResponse) XXX_Unmarshal added in v0.10.0 

func (m *TabletExternallyReparentedResponse) XXX_Unmarshal(b []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 */
	XXX_NoUnkeyedLiteral struct{}                         `json:"-"`
	XXX_unrecognized     []byte                           `json:"-"`
	XXX_sizecache        int32                            `json:"-"`
}

TODO: comment the hell out of this.

func (*Workflow) Descriptor added in v0.10.0 

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

func (*Workflow) GetMaxVReplicationLag added in v0.10.0 

func (m *Workflow) GetMaxVReplicationLag() int64

func (*Workflow) GetName added in v0.10.0 

func (m *Workflow) GetName() string

func (*Workflow) GetShardStreams added in v0.10.0 

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

func (*Workflow) GetSource added in v0.10.0 

func (m *Workflow) GetSource() *Workflow_ReplicationLocation

func (*Workflow) GetTarget added in v0.10.0 

func (m *Workflow) GetTarget() *Workflow_ReplicationLocation

func (*Workflow) Marshal added in v0.10.0 

func (m *Workflow) Marshal() (dAtA []byte, err error)

func (*Workflow) MarshalTo added in v0.10.0 

func (m *Workflow) MarshalTo(dAtA []byte) (int, error)

func (*Workflow) MarshalToSizedBuffer added in v0.10.0 

func (m *Workflow) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Workflow) ProtoMessage added in v0.10.0 

func (*Workflow) ProtoMessage()

func (*Workflow) Reset added in v0.10.0 

func (m *Workflow) Reset()

func (*Workflow) Size added in v0.10.0 

func (m *Workflow) Size() (n int)

func (*Workflow) String added in v0.10.0 

func (m *Workflow) String() string

func (*Workflow) Unmarshal added in v0.10.0 

func (m *Workflow) Unmarshal(dAtA []byte) error

func (*Workflow) XXX_DiscardUnknown added in v0.10.0 

func (m *Workflow) XXX_DiscardUnknown()

func (*Workflow) XXX_Marshal added in v0.10.0 

func (m *Workflow) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Workflow) XXX_Merge added in v0.10.0 

func (m *Workflow) XXX_Merge(src proto.Message)

func (*Workflow) XXX_Size added in v0.10.0 

func (m *Workflow) XXX_Size() int

func (*Workflow) XXX_Unmarshal added in v0.10.0 

func (m *Workflow) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Workflow_ReplicationLocation) Descriptor added in v0.10.0 

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

func (*Workflow_ReplicationLocation) GetKeyspace added in v0.10.0 

func (m *Workflow_ReplicationLocation) GetKeyspace() string

func (*Workflow_ReplicationLocation) GetShards added in v0.10.0 

func (m *Workflow_ReplicationLocation) GetShards() []string

func (*Workflow_ReplicationLocation) Marshal added in v0.10.0 

func (m *Workflow_ReplicationLocation) Marshal() (dAtA []byte, err error)

func (*Workflow_ReplicationLocation) MarshalTo added in v0.10.0 

func (m *Workflow_ReplicationLocation) MarshalTo(dAtA []byte) (int, error)

func (*Workflow_ReplicationLocation) MarshalToSizedBuffer added in v0.10.0 

func (m *Workflow_ReplicationLocation) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Workflow_ReplicationLocation) ProtoMessage added in v0.10.0 

func (*Workflow_ReplicationLocation) ProtoMessage()

func (*Workflow_ReplicationLocation) Reset added in v0.10.0 

func (m *Workflow_ReplicationLocation) Reset()

func (*Workflow_ReplicationLocation) Size added in v0.10.0 

func (m *Workflow_ReplicationLocation) Size() (n int)

func (*Workflow_ReplicationLocation) String added in v0.10.0 

func (m *Workflow_ReplicationLocation) String() string

func (*Workflow_ReplicationLocation) Unmarshal added in v0.10.0 

func (m *Workflow_ReplicationLocation) Unmarshal(dAtA []byte) error

func (*Workflow_ReplicationLocation) XXX_DiscardUnknown added in v0.10.0 

func (m *Workflow_ReplicationLocation) XXX_DiscardUnknown()

func (*Workflow_ReplicationLocation) XXX_Marshal added in v0.10.0 

func (m *Workflow_ReplicationLocation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Workflow_ReplicationLocation) XXX_Merge added in v0.10.0 

func (m *Workflow_ReplicationLocation) XXX_Merge(src proto.Message)

func (*Workflow_ReplicationLocation) XXX_Size added in v0.10.0 

func (m *Workflow_ReplicationLocation) XXX_Size() int

func (*Workflow_ReplicationLocation) XXX_Unmarshal added in v0.10.0 

func (m *Workflow_ReplicationLocation) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

func (*Workflow_ShardStream) Descriptor added in v0.10.0 

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

func (*Workflow_ShardStream) GetIsPrimaryServing added in v0.10.0 

func (m *Workflow_ShardStream) GetIsPrimaryServing() bool

func (*Workflow_ShardStream) GetStreams added in v0.10.0 

func (m *Workflow_ShardStream) GetStreams() []*Workflow_Stream

func (*Workflow_ShardStream) GetTabletControls added in v0.10.0 

func (m *Workflow_ShardStream) GetTabletControls() []*topodata.Shard_TabletControl

func (*Workflow_ShardStream) Marshal added in v0.10.0 

func (m *Workflow_ShardStream) Marshal() (dAtA []byte, err error)

func (*Workflow_ShardStream) MarshalTo added in v0.10.0 

func (m *Workflow_ShardStream) MarshalTo(dAtA []byte) (int, error)

func (*Workflow_ShardStream) MarshalToSizedBuffer added in v0.10.0 

func (m *Workflow_ShardStream) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Workflow_ShardStream) ProtoMessage added in v0.10.0 

func (*Workflow_ShardStream) ProtoMessage()

func (*Workflow_ShardStream) Reset added in v0.10.0 

func (m *Workflow_ShardStream) Reset()

func (*Workflow_ShardStream) Size added in v0.10.0 

func (m *Workflow_ShardStream) Size() (n int)

func (*Workflow_ShardStream) String added in v0.10.0 

func (m *Workflow_ShardStream) String() string

func (*Workflow_ShardStream) Unmarshal added in v0.10.0 

func (m *Workflow_ShardStream) Unmarshal(dAtA []byte) error

func (*Workflow_ShardStream) XXX_DiscardUnknown added in v0.10.0 

func (m *Workflow_ShardStream) XXX_DiscardUnknown()

func (*Workflow_ShardStream) XXX_Marshal added in v0.10.0 

func (m *Workflow_ShardStream) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Workflow_ShardStream) XXX_Merge added in v0.10.0 

func (m *Workflow_ShardStream) XXX_Merge(src proto.Message)

func (*Workflow_ShardStream) XXX_Size added in v0.10.0 

func (m *Workflow_ShardStream) XXX_Size() int

func (*Workflow_ShardStream) XXX_Unmarshal added in v0.10.0 

func (m *Workflow_ShardStream) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

func (*Workflow_Stream) Descriptor added in v0.10.0 

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

func (*Workflow_Stream) GetBinlogSource added in v0.10.0 

func (m *Workflow_Stream) GetBinlogSource() *binlogdata.BinlogSource

func (*Workflow_Stream) GetCopyStates added in v0.10.0 

func (m *Workflow_Stream) GetCopyStates() []*Workflow_Stream_CopyState

func (*Workflow_Stream) GetDbName added in v0.10.0 

func (m *Workflow_Stream) GetDbName() string

func (*Workflow_Stream) GetId added in v0.10.0 

func (m *Workflow_Stream) GetId() int64

func (*Workflow_Stream) GetMessage added in v0.10.0 

func (m *Workflow_Stream) GetMessage() string

func (*Workflow_Stream) GetPosition added in v0.10.0 

func (m *Workflow_Stream) GetPosition() string

func (*Workflow_Stream) GetShard added in v0.10.0 

func (m *Workflow_Stream) GetShard() string

func (*Workflow_Stream) GetState added in v0.10.0 

func (m *Workflow_Stream) GetState() string

func (*Workflow_Stream) GetStopPosition added in v0.10.0 

func (m *Workflow_Stream) GetStopPosition() string

func (*Workflow_Stream) GetTablet added in v0.10.0 

func (m *Workflow_Stream) GetTablet() *topodata.TabletAlias

func (*Workflow_Stream) GetTimeUpdated added in v0.10.0 

func (m *Workflow_Stream) GetTimeUpdated() *vttime.Time

func (*Workflow_Stream) GetTransactionTimestamp added in v0.10.0 

func (m *Workflow_Stream) GetTransactionTimestamp() *vttime.Time

func (*Workflow_Stream) Marshal added in v0.10.0 

func (m *Workflow_Stream) Marshal() (dAtA []byte, err error)

func (*Workflow_Stream) MarshalTo added in v0.10.0 

func (m *Workflow_Stream) MarshalTo(dAtA []byte) (int, error)

func (*Workflow_Stream) MarshalToSizedBuffer added in v0.10.0 

func (m *Workflow_Stream) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Workflow_Stream) ProtoMessage added in v0.10.0 

func (*Workflow_Stream) ProtoMessage()

func (*Workflow_Stream) Reset added in v0.10.0 

func (m *Workflow_Stream) Reset()

func (*Workflow_Stream) Size added in v0.10.0 

func (m *Workflow_Stream) Size() (n int)

func (*Workflow_Stream) String added in v0.10.0 

func (m *Workflow_Stream) String() string

func (*Workflow_Stream) Unmarshal added in v0.10.0 

func (m *Workflow_Stream) Unmarshal(dAtA []byte) error

func (*Workflow_Stream) XXX_DiscardUnknown added in v0.10.0 

func (m *Workflow_Stream) XXX_DiscardUnknown()

func (*Workflow_Stream) XXX_Marshal added in v0.10.0 

func (m *Workflow_Stream) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Workflow_Stream) XXX_Merge added in v0.10.0 

func (m *Workflow_Stream) XXX_Merge(src proto.Message)

func (*Workflow_Stream) XXX_Size added in v0.10.0 

func (m *Workflow_Stream) XXX_Size() int

func (*Workflow_Stream) XXX_Unmarshal added in v0.10.0 

func (m *Workflow_Stream) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Workflow_Stream_CopyState) Descriptor added in v0.10.0 

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

func (*Workflow_Stream_CopyState) GetLastPk added in v0.10.0 

func (m *Workflow_Stream_CopyState) GetLastPk() string

func (*Workflow_Stream_CopyState) GetTable added in v0.10.0 

func (m *Workflow_Stream_CopyState) GetTable() string

func (*Workflow_Stream_CopyState) Marshal added in v0.10.0 

func (m *Workflow_Stream_CopyState) Marshal() (dAtA []byte, err error)

func (*Workflow_Stream_CopyState) MarshalTo added in v0.10.0 

func (m *Workflow_Stream_CopyState) MarshalTo(dAtA []byte) (int, error)

func (*Workflow_Stream_CopyState) MarshalToSizedBuffer added in v0.10.0 

func (m *Workflow_Stream_CopyState) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Workflow_Stream_CopyState) ProtoMessage added in v0.10.0 

func (*Workflow_Stream_CopyState) ProtoMessage()

func (*Workflow_Stream_CopyState) Reset added in v0.10.0 

func (m *Workflow_Stream_CopyState) Reset()

func (*Workflow_Stream_CopyState) Size added in v0.10.0 

func (m *Workflow_Stream_CopyState) Size() (n int)

func (*Workflow_Stream_CopyState) String added in v0.10.0 

func (m *Workflow_Stream_CopyState) String() string

func (*Workflow_Stream_CopyState) Unmarshal added in v0.10.0 

func (m *Workflow_Stream_CopyState) Unmarshal(dAtA []byte) error

func (*Workflow_Stream_CopyState) XXX_DiscardUnknown added in v0.10.0 

func (m *Workflow_Stream_CopyState) XXX_DiscardUnknown()

func (*Workflow_Stream_CopyState) XXX_Marshal added in v0.10.0 

func (m *Workflow_Stream_CopyState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Workflow_Stream_CopyState) XXX_Merge added in v0.10.0 

func (m *Workflow_Stream_CopyState) XXX_Merge(src proto.Message)

func (*Workflow_Stream_CopyState) XXX_Size added in v0.10.0 

func (m *Workflow_Stream_CopyState) XXX_Size() int

func (*Workflow_Stream_CopyState) XXX_Unmarshal added in v0.10.0 

func (m *Workflow_Stream_CopyState) XXX_Unmarshal(b []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.