tabletmanagerdata

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: 9 Imported by: 28

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthTabletmanagerdata        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTabletmanagerdata          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTabletmanagerdata = fmt.Errorf("proto: unexpected end of group")
)

Functions

This section is empty.

Types

type ApplySchemaRequest 

type ApplySchemaRequest struct {
	Sql                  string            `protobuf:"bytes,1,opt,name=sql,proto3" json:"sql,omitempty"`
	Force                bool              `protobuf:"varint,2,opt,name=force,proto3" json:"force,omitempty"`
	AllowReplication     bool              `protobuf:"varint,3,opt,name=allow_replication,json=allowReplication,proto3" json:"allow_replication,omitempty"`
	BeforeSchema         *SchemaDefinition `protobuf:"bytes,4,opt,name=before_schema,json=beforeSchema,proto3" json:"before_schema,omitempty"`
	AfterSchema          *SchemaDefinition `protobuf:"bytes,5,opt,name=after_schema,json=afterSchema,proto3" json:"after_schema,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*ApplySchemaRequest) Descriptor 

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

func (*ApplySchemaRequest) GetAfterSchema 

func (m *ApplySchemaRequest) GetAfterSchema() *SchemaDefinition

func (*ApplySchemaRequest) GetAllowReplication 

func (m *ApplySchemaRequest) GetAllowReplication() bool

func (*ApplySchemaRequest) GetBeforeSchema 

func (m *ApplySchemaRequest) GetBeforeSchema() *SchemaDefinition

func (*ApplySchemaRequest) GetForce 

func (m *ApplySchemaRequest) GetForce() bool

func (*ApplySchemaRequest) GetSql 

func (m *ApplySchemaRequest) GetSql() string

func (*ApplySchemaRequest) Marshal added in v0.10.0 

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

func (*ApplySchemaRequest) MarshalTo added in v0.10.0 

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

func (*ApplySchemaRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*ApplySchemaRequest) ProtoMessage 

func (*ApplySchemaRequest) ProtoMessage()

func (*ApplySchemaRequest) Reset 

func (m *ApplySchemaRequest) Reset()

func (*ApplySchemaRequest) Size added in v0.10.0 

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

func (*ApplySchemaRequest) String 

func (m *ApplySchemaRequest) String() string

func (*ApplySchemaRequest) Unmarshal added in v0.10.0 

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

func (*ApplySchemaRequest) XXX_DiscardUnknown 

func (m *ApplySchemaRequest) XXX_DiscardUnknown()

func (*ApplySchemaRequest) XXX_Marshal 

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

func (*ApplySchemaRequest) XXX_Merge 

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

func (*ApplySchemaRequest) XXX_Size 

func (m *ApplySchemaRequest) XXX_Size() int

func (*ApplySchemaRequest) XXX_Unmarshal 

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

type ApplySchemaResponse 

type ApplySchemaResponse struct {
	BeforeSchema         *SchemaDefinition `protobuf:"bytes,1,opt,name=before_schema,json=beforeSchema,proto3" json:"before_schema,omitempty"`
	AfterSchema          *SchemaDefinition `protobuf:"bytes,2,opt,name=after_schema,json=afterSchema,proto3" json:"after_schema,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*ApplySchemaResponse) Descriptor 

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

func (*ApplySchemaResponse) GetAfterSchema 

func (m *ApplySchemaResponse) GetAfterSchema() *SchemaDefinition

func (*ApplySchemaResponse) GetBeforeSchema 

func (m *ApplySchemaResponse) GetBeforeSchema() *SchemaDefinition

func (*ApplySchemaResponse) Marshal added in v0.10.0 

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

func (*ApplySchemaResponse) MarshalTo added in v0.10.0 

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

func (*ApplySchemaResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*ApplySchemaResponse) ProtoMessage 

func (*ApplySchemaResponse) ProtoMessage()

func (*ApplySchemaResponse) Reset 

func (m *ApplySchemaResponse) Reset()

func (*ApplySchemaResponse) Size added in v0.10.0 

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

func (*ApplySchemaResponse) String 

func (m *ApplySchemaResponse) String() string

func (*ApplySchemaResponse) Unmarshal added in v0.10.0 

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

func (*ApplySchemaResponse) XXX_DiscardUnknown 

func (m *ApplySchemaResponse) XXX_DiscardUnknown()

func (*ApplySchemaResponse) XXX_Marshal 

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

func (*ApplySchemaResponse) XXX_Merge 

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

func (*ApplySchemaResponse) XXX_Size 

func (m *ApplySchemaResponse) XXX_Size() int

func (*ApplySchemaResponse) XXX_Unmarshal 

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

type BackupRequest 

type BackupRequest struct {
	Concurrency          int64    `protobuf:"varint,1,opt,name=concurrency,proto3" json:"concurrency,omitempty"`
	AllowMaster          bool     `protobuf:"varint,2,opt,name=allowMaster,proto3" json:"allowMaster,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BackupRequest) Descriptor 

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

func (*BackupRequest) GetAllowMaster 

func (m *BackupRequest) GetAllowMaster() bool

func (*BackupRequest) GetConcurrency 

func (m *BackupRequest) GetConcurrency() int64

func (*BackupRequest) Marshal added in v0.10.0 

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

func (*BackupRequest) MarshalTo added in v0.10.0 

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

func (*BackupRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*BackupRequest) ProtoMessage 

func (*BackupRequest) ProtoMessage()

func (*BackupRequest) Reset 

func (m *BackupRequest) Reset()

func (*BackupRequest) Size added in v0.10.0 

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

func (*BackupRequest) String 

func (m *BackupRequest) String() string

func (*BackupRequest) Unmarshal added in v0.10.0 

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

func (*BackupRequest) XXX_DiscardUnknown 

func (m *BackupRequest) XXX_DiscardUnknown()

func (*BackupRequest) XXX_Marshal 

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

func (*BackupRequest) XXX_Merge 

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

func (*BackupRequest) XXX_Size 

func (m *BackupRequest) XXX_Size() int

func (*BackupRequest) XXX_Unmarshal 

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

type BackupResponse 

type BackupResponse 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:"-"`
}

func (*BackupResponse) Descriptor 

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

func (*BackupResponse) GetEvent 

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

func (*BackupResponse) Marshal added in v0.10.0 

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

func (*BackupResponse) MarshalTo added in v0.10.0 

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

func (*BackupResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*BackupResponse) ProtoMessage 

func (*BackupResponse) ProtoMessage()

func (*BackupResponse) Reset 

func (m *BackupResponse) Reset()

func (*BackupResponse) Size added in v0.10.0 

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

func (*BackupResponse) String 

func (m *BackupResponse) String() string

func (*BackupResponse) Unmarshal added in v0.10.0 

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

func (*BackupResponse) XXX_DiscardUnknown 

func (m *BackupResponse) XXX_DiscardUnknown()

func (*BackupResponse) XXX_Marshal 

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

func (*BackupResponse) XXX_Merge 

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

func (*BackupResponse) XXX_Size 

func (m *BackupResponse) XXX_Size() int

func (*BackupResponse) XXX_Unmarshal 

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

type ChangeTypeRequest 

type ChangeTypeRequest struct {
	TabletType           topodata.TabletType `protobuf:"varint,1,opt,name=tablet_type,json=tabletType,proto3,enum=topodata.TabletType" json:"tablet_type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*ChangeTypeRequest) Descriptor 

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

func (*ChangeTypeRequest) GetTabletType 

func (m *ChangeTypeRequest) GetTabletType() topodata.TabletType

func (*ChangeTypeRequest) Marshal added in v0.10.0 

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

func (*ChangeTypeRequest) MarshalTo added in v0.10.0 

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

func (*ChangeTypeRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*ChangeTypeRequest) ProtoMessage 

func (*ChangeTypeRequest) ProtoMessage()

func (*ChangeTypeRequest) Reset 

func (m *ChangeTypeRequest) Reset()

func (*ChangeTypeRequest) Size added in v0.10.0 

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

func (*ChangeTypeRequest) String 

func (m *ChangeTypeRequest) String() string

func (*ChangeTypeRequest) Unmarshal added in v0.10.0 

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

func (*ChangeTypeRequest) XXX_DiscardUnknown 

func (m *ChangeTypeRequest) XXX_DiscardUnknown()

func (*ChangeTypeRequest) XXX_Marshal 

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

func (*ChangeTypeRequest) XXX_Merge 

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

func (*ChangeTypeRequest) XXX_Size 

func (m *ChangeTypeRequest) XXX_Size() int

func (*ChangeTypeRequest) XXX_Unmarshal 

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

type ChangeTypeResponse 

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

func (*ChangeTypeResponse) Descriptor 

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

func (*ChangeTypeResponse) Marshal added in v0.10.0 

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

func (*ChangeTypeResponse) MarshalTo added in v0.10.0 

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

func (*ChangeTypeResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*ChangeTypeResponse) ProtoMessage 

func (*ChangeTypeResponse) ProtoMessage()

func (*ChangeTypeResponse) Reset 

func (m *ChangeTypeResponse) Reset()

func (*ChangeTypeResponse) Size added in v0.10.0 

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

func (*ChangeTypeResponse) String 

func (m *ChangeTypeResponse) String() string

func (*ChangeTypeResponse) Unmarshal added in v0.10.0 

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

func (*ChangeTypeResponse) XXX_DiscardUnknown 

func (m *ChangeTypeResponse) XXX_DiscardUnknown()

func (*ChangeTypeResponse) XXX_Marshal 

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

func (*ChangeTypeResponse) XXX_Merge 

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

func (*ChangeTypeResponse) XXX_Size 

func (m *ChangeTypeResponse) XXX_Size() int

func (*ChangeTypeResponse) XXX_Unmarshal 

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

type DbPermission 

type DbPermission struct {
	Host                 string            `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	Db                   string            `protobuf:"bytes,2,opt,name=db,proto3" json:"db,omitempty"`
	User                 string            `protobuf:"bytes,3,opt,name=user,proto3" json:"user,omitempty"`
	Privileges           map[string]string `` /* 161-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

DbPermission describes a single row in the mysql.db table Primary key is Host+Db+User

func (*DbPermission) Descriptor 

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

func (*DbPermission) GetDb 

func (m *DbPermission) GetDb() string

func (*DbPermission) GetHost 

func (m *DbPermission) GetHost() string

func (*DbPermission) GetPrivileges 

func (m *DbPermission) GetPrivileges() map[string]string

func (*DbPermission) GetUser 

func (m *DbPermission) GetUser() string

func (*DbPermission) Marshal added in v0.10.0 

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

func (*DbPermission) MarshalTo added in v0.10.0 

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

func (*DbPermission) MarshalToSizedBuffer added in v0.10.0 

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

func (*DbPermission) ProtoMessage 

func (*DbPermission) ProtoMessage()

func (*DbPermission) Reset 

func (m *DbPermission) Reset()

func (*DbPermission) Size added in v0.10.0 

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

func (*DbPermission) String 

func (m *DbPermission) String() string

func (*DbPermission) Unmarshal added in v0.10.0 

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

func (*DbPermission) XXX_DiscardUnknown 

func (m *DbPermission) XXX_DiscardUnknown()

func (*DbPermission) XXX_Marshal 

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

func (*DbPermission) XXX_Merge 

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

func (*DbPermission) XXX_Size 

func (m *DbPermission) XXX_Size() int

func (*DbPermission) XXX_Unmarshal 

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

type DemoteMasterRequest 

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

func (*DemoteMasterRequest) Descriptor 

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

func (*DemoteMasterRequest) Marshal added in v0.10.0 

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

func (*DemoteMasterRequest) MarshalTo added in v0.10.0 

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

func (*DemoteMasterRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*DemoteMasterRequest) ProtoMessage 

func (*DemoteMasterRequest) ProtoMessage()

func (*DemoteMasterRequest) Reset 

func (m *DemoteMasterRequest) Reset()

func (*DemoteMasterRequest) Size added in v0.10.0 

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

func (*DemoteMasterRequest) String 

func (m *DemoteMasterRequest) String() string

func (*DemoteMasterRequest) Unmarshal added in v0.10.0 

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

func (*DemoteMasterRequest) XXX_DiscardUnknown 

func (m *DemoteMasterRequest) XXX_DiscardUnknown()

func (*DemoteMasterRequest) XXX_Marshal 

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

func (*DemoteMasterRequest) XXX_Merge 

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

func (*DemoteMasterRequest) XXX_Size 

func (m *DemoteMasterRequest) XXX_Size() int

func (*DemoteMasterRequest) XXX_Unmarshal 

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

type DemoteMasterResponse 

type DemoteMasterResponse struct {
	// Position is deprecated, and is a string representation of a demoted masters executed position.
	DeprecatedPosition string `protobuf:"bytes,1,opt,name=deprecated_position,json=deprecatedPosition,proto3" json:"deprecated_position,omitempty"` // Deprecated: Do not use.
	// MasterStatus represents the response from calling `SHOW MASTER STATUS` on a master that has been demoted.
	MasterStatus         *replicationdata.MasterStatus `protobuf:"bytes,2,opt,name=master_status,json=masterStatus,proto3" json:"master_status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                      `json:"-"`
	XXX_unrecognized     []byte                        `json:"-"`
	XXX_sizecache        int32                         `json:"-"`
}

func (*DemoteMasterResponse) Descriptor 

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

func (*DemoteMasterResponse) GetDeprecatedPosition deprecated 

func (m *DemoteMasterResponse) GetDeprecatedPosition() string

Deprecated: Do not use.

func (*DemoteMasterResponse) GetMasterStatus 

func (m *DemoteMasterResponse) GetMasterStatus() *replicationdata.MasterStatus

func (*DemoteMasterResponse) Marshal added in v0.10.0 

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

func (*DemoteMasterResponse) MarshalTo added in v0.10.0 

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

func (*DemoteMasterResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*DemoteMasterResponse) ProtoMessage 

func (*DemoteMasterResponse) ProtoMessage()

func (*DemoteMasterResponse) Reset 

func (m *DemoteMasterResponse) Reset()

func (*DemoteMasterResponse) Size added in v0.10.0 

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

func (*DemoteMasterResponse) String 

func (m *DemoteMasterResponse) String() string

func (*DemoteMasterResponse) Unmarshal added in v0.10.0 

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

func (*DemoteMasterResponse) XXX_DiscardUnknown 

func (m *DemoteMasterResponse) XXX_DiscardUnknown()

func (*DemoteMasterResponse) XXX_Marshal 

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

func (*DemoteMasterResponse) XXX_Merge 

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

func (*DemoteMasterResponse) XXX_Size 

func (m *DemoteMasterResponse) XXX_Size() int

func (*DemoteMasterResponse) XXX_Unmarshal 

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

type ExecuteFetchAsAllPrivsRequest 

type ExecuteFetchAsAllPrivsRequest struct {
	Query                []byte   `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	DbName               string   `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	MaxRows              uint64   `protobuf:"varint,3,opt,name=max_rows,json=maxRows,proto3" json:"max_rows,omitempty"`
	ReloadSchema         bool     `protobuf:"varint,4,opt,name=reload_schema,json=reloadSchema,proto3" json:"reload_schema,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ExecuteFetchAsAllPrivsRequest) Descriptor 

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

func (*ExecuteFetchAsAllPrivsRequest) GetDbName 

func (m *ExecuteFetchAsAllPrivsRequest) GetDbName() string

func (*ExecuteFetchAsAllPrivsRequest) GetMaxRows 

func (m *ExecuteFetchAsAllPrivsRequest) GetMaxRows() uint64

func (*ExecuteFetchAsAllPrivsRequest) GetQuery 

func (m *ExecuteFetchAsAllPrivsRequest) GetQuery() []byte

func (*ExecuteFetchAsAllPrivsRequest) GetReloadSchema 

func (m *ExecuteFetchAsAllPrivsRequest) GetReloadSchema() bool

func (*ExecuteFetchAsAllPrivsRequest) Marshal added in v0.10.0 

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

func (*ExecuteFetchAsAllPrivsRequest) MarshalTo added in v0.10.0 

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

func (*ExecuteFetchAsAllPrivsRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*ExecuteFetchAsAllPrivsRequest) ProtoMessage 

func (*ExecuteFetchAsAllPrivsRequest) ProtoMessage()

func (*ExecuteFetchAsAllPrivsRequest) Reset 

func (m *ExecuteFetchAsAllPrivsRequest) Reset()

func (*ExecuteFetchAsAllPrivsRequest) Size added in v0.10.0 

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

func (*ExecuteFetchAsAllPrivsRequest) String 

func (m *ExecuteFetchAsAllPrivsRequest) String() string

func (*ExecuteFetchAsAllPrivsRequest) Unmarshal added in v0.10.0 

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

func (*ExecuteFetchAsAllPrivsRequest) XXX_DiscardUnknown 

func (m *ExecuteFetchAsAllPrivsRequest) XXX_DiscardUnknown()

func (*ExecuteFetchAsAllPrivsRequest) XXX_Marshal 

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

func (*ExecuteFetchAsAllPrivsRequest) XXX_Merge 

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

func (*ExecuteFetchAsAllPrivsRequest) XXX_Size 

func (m *ExecuteFetchAsAllPrivsRequest) XXX_Size() int

func (*ExecuteFetchAsAllPrivsRequest) XXX_Unmarshal 

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

type ExecuteFetchAsAllPrivsResponse 

type ExecuteFetchAsAllPrivsResponse struct {
	Result               *query.QueryResult `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*ExecuteFetchAsAllPrivsResponse) Descriptor 

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

func (*ExecuteFetchAsAllPrivsResponse) GetResult 

func (m *ExecuteFetchAsAllPrivsResponse) GetResult() *query.QueryResult

func (*ExecuteFetchAsAllPrivsResponse) Marshal added in v0.10.0 

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

func (*ExecuteFetchAsAllPrivsResponse) MarshalTo added in v0.10.0 

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

func (*ExecuteFetchAsAllPrivsResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*ExecuteFetchAsAllPrivsResponse) ProtoMessage 

func (*ExecuteFetchAsAllPrivsResponse) ProtoMessage()

func (*ExecuteFetchAsAllPrivsResponse) Reset 

func (m *ExecuteFetchAsAllPrivsResponse) Reset()

func (*ExecuteFetchAsAllPrivsResponse) Size added in v0.10.0 

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

func (*ExecuteFetchAsAllPrivsResponse) String 

func (m *ExecuteFetchAsAllPrivsResponse) String() string

func (*ExecuteFetchAsAllPrivsResponse) Unmarshal added in v0.10.0 

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

func (*ExecuteFetchAsAllPrivsResponse) XXX_DiscardUnknown 

func (m *ExecuteFetchAsAllPrivsResponse) XXX_DiscardUnknown()

func (*ExecuteFetchAsAllPrivsResponse) XXX_Marshal 

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

func (*ExecuteFetchAsAllPrivsResponse) XXX_Merge 

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

func (*ExecuteFetchAsAllPrivsResponse) XXX_Size 

func (m *ExecuteFetchAsAllPrivsResponse) XXX_Size() int

func (*ExecuteFetchAsAllPrivsResponse) XXX_Unmarshal 

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

type ExecuteFetchAsAppRequest 

type ExecuteFetchAsAppRequest struct {
	Query                []byte   `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	MaxRows              uint64   `protobuf:"varint,2,opt,name=max_rows,json=maxRows,proto3" json:"max_rows,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ExecuteFetchAsAppRequest) Descriptor 

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

func (*ExecuteFetchAsAppRequest) GetMaxRows 

func (m *ExecuteFetchAsAppRequest) GetMaxRows() uint64

func (*ExecuteFetchAsAppRequest) GetQuery 

func (m *ExecuteFetchAsAppRequest) GetQuery() []byte

func (*ExecuteFetchAsAppRequest) Marshal added in v0.10.0 

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

func (*ExecuteFetchAsAppRequest) MarshalTo added in v0.10.0 

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

func (*ExecuteFetchAsAppRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*ExecuteFetchAsAppRequest) ProtoMessage 

func (*ExecuteFetchAsAppRequest) ProtoMessage()

func (*ExecuteFetchAsAppRequest) Reset 

func (m *ExecuteFetchAsAppRequest) Reset()

func (*ExecuteFetchAsAppRequest) Size added in v0.10.0 

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

func (*ExecuteFetchAsAppRequest) String 

func (m *ExecuteFetchAsAppRequest) String() string

func (*ExecuteFetchAsAppRequest) Unmarshal added in v0.10.0 

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

func (*ExecuteFetchAsAppRequest) XXX_DiscardUnknown 

func (m *ExecuteFetchAsAppRequest) XXX_DiscardUnknown()

func (*ExecuteFetchAsAppRequest) XXX_Marshal 

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

func (*ExecuteFetchAsAppRequest) XXX_Merge 

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

func (*ExecuteFetchAsAppRequest) XXX_Size 

func (m *ExecuteFetchAsAppRequest) XXX_Size() int

func (*ExecuteFetchAsAppRequest) XXX_Unmarshal 

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

type ExecuteFetchAsAppResponse 

type ExecuteFetchAsAppResponse struct {
	Result               *query.QueryResult `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*ExecuteFetchAsAppResponse) Descriptor 

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

func (*ExecuteFetchAsAppResponse) GetResult 

func (m *ExecuteFetchAsAppResponse) GetResult() *query.QueryResult

func (*ExecuteFetchAsAppResponse) Marshal added in v0.10.0 

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

func (*ExecuteFetchAsAppResponse) MarshalTo added in v0.10.0 

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

func (*ExecuteFetchAsAppResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*ExecuteFetchAsAppResponse) ProtoMessage 

func (*ExecuteFetchAsAppResponse) ProtoMessage()

func (*ExecuteFetchAsAppResponse) Reset 

func (m *ExecuteFetchAsAppResponse) Reset()

func (*ExecuteFetchAsAppResponse) Size added in v0.10.0 

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

func (*ExecuteFetchAsAppResponse) String 

func (m *ExecuteFetchAsAppResponse) String() string

func (*ExecuteFetchAsAppResponse) Unmarshal added in v0.10.0 

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

func (*ExecuteFetchAsAppResponse) XXX_DiscardUnknown 

func (m *ExecuteFetchAsAppResponse) XXX_DiscardUnknown()

func (*ExecuteFetchAsAppResponse) XXX_Marshal 

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

func (*ExecuteFetchAsAppResponse) XXX_Merge 

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

func (*ExecuteFetchAsAppResponse) XXX_Size 

func (m *ExecuteFetchAsAppResponse) XXX_Size() int

func (*ExecuteFetchAsAppResponse) XXX_Unmarshal 

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

type ExecuteFetchAsDbaRequest 

type ExecuteFetchAsDbaRequest struct {
	Query                []byte   `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	DbName               string   `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	MaxRows              uint64   `protobuf:"varint,3,opt,name=max_rows,json=maxRows,proto3" json:"max_rows,omitempty"`
	DisableBinlogs       bool     `protobuf:"varint,4,opt,name=disable_binlogs,json=disableBinlogs,proto3" json:"disable_binlogs,omitempty"`
	ReloadSchema         bool     `protobuf:"varint,5,opt,name=reload_schema,json=reloadSchema,proto3" json:"reload_schema,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ExecuteFetchAsDbaRequest) Descriptor 

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

func (*ExecuteFetchAsDbaRequest) GetDbName 

func (m *ExecuteFetchAsDbaRequest) GetDbName() string

func (*ExecuteFetchAsDbaRequest) GetDisableBinlogs 

func (m *ExecuteFetchAsDbaRequest) GetDisableBinlogs() bool

func (*ExecuteFetchAsDbaRequest) GetMaxRows 

func (m *ExecuteFetchAsDbaRequest) GetMaxRows() uint64

func (*ExecuteFetchAsDbaRequest) GetQuery 

func (m *ExecuteFetchAsDbaRequest) GetQuery() []byte

func (*ExecuteFetchAsDbaRequest) GetReloadSchema 

func (m *ExecuteFetchAsDbaRequest) GetReloadSchema() bool

func (*ExecuteFetchAsDbaRequest) Marshal added in v0.10.0 

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

func (*ExecuteFetchAsDbaRequest) MarshalTo added in v0.10.0 

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

func (*ExecuteFetchAsDbaRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*ExecuteFetchAsDbaRequest) ProtoMessage 

func (*ExecuteFetchAsDbaRequest) ProtoMessage()

func (*ExecuteFetchAsDbaRequest) Reset 

func (m *ExecuteFetchAsDbaRequest) Reset()

func (*ExecuteFetchAsDbaRequest) Size added in v0.10.0 

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

func (*ExecuteFetchAsDbaRequest) String 

func (m *ExecuteFetchAsDbaRequest) String() string

func (*ExecuteFetchAsDbaRequest) Unmarshal added in v0.10.0 

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

func (*ExecuteFetchAsDbaRequest) XXX_DiscardUnknown 

func (m *ExecuteFetchAsDbaRequest) XXX_DiscardUnknown()

func (*ExecuteFetchAsDbaRequest) XXX_Marshal 

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

func (*ExecuteFetchAsDbaRequest) XXX_Merge 

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

func (*ExecuteFetchAsDbaRequest) XXX_Size 

func (m *ExecuteFetchAsDbaRequest) XXX_Size() int

func (*ExecuteFetchAsDbaRequest) XXX_Unmarshal 

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

type ExecuteFetchAsDbaResponse 

type ExecuteFetchAsDbaResponse struct {
	Result               *query.QueryResult `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*ExecuteFetchAsDbaResponse) Descriptor 

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

func (*ExecuteFetchAsDbaResponse) GetResult 

func (m *ExecuteFetchAsDbaResponse) GetResult() *query.QueryResult

func (*ExecuteFetchAsDbaResponse) Marshal added in v0.10.0 

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

func (*ExecuteFetchAsDbaResponse) MarshalTo added in v0.10.0 

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

func (*ExecuteFetchAsDbaResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*ExecuteFetchAsDbaResponse) ProtoMessage 

func (*ExecuteFetchAsDbaResponse) ProtoMessage()

func (*ExecuteFetchAsDbaResponse) Reset 

func (m *ExecuteFetchAsDbaResponse) Reset()

func (*ExecuteFetchAsDbaResponse) Size added in v0.10.0 

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

func (*ExecuteFetchAsDbaResponse) String 

func (m *ExecuteFetchAsDbaResponse) String() string

func (*ExecuteFetchAsDbaResponse) Unmarshal added in v0.10.0 

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

func (*ExecuteFetchAsDbaResponse) XXX_DiscardUnknown 

func (m *ExecuteFetchAsDbaResponse) XXX_DiscardUnknown()

func (*ExecuteFetchAsDbaResponse) XXX_Marshal 

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

func (*ExecuteFetchAsDbaResponse) XXX_Merge 

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

func (*ExecuteFetchAsDbaResponse) XXX_Size 

func (m *ExecuteFetchAsDbaResponse) XXX_Size() int

func (*ExecuteFetchAsDbaResponse) XXX_Unmarshal 

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

type ExecuteHookRequest 

type ExecuteHookRequest struct {
	Name                 string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Parameters           []string          `protobuf:"bytes,2,rep,name=parameters,proto3" json:"parameters,omitempty"`
	ExtraEnv             map[string]string `` /* 173-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*ExecuteHookRequest) Descriptor 

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

func (*ExecuteHookRequest) GetExtraEnv 

func (m *ExecuteHookRequest) GetExtraEnv() map[string]string

func (*ExecuteHookRequest) GetName 

func (m *ExecuteHookRequest) GetName() string

func (*ExecuteHookRequest) GetParameters 

func (m *ExecuteHookRequest) GetParameters() []string

func (*ExecuteHookRequest) Marshal added in v0.10.0 

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

func (*ExecuteHookRequest) MarshalTo added in v0.10.0 

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

func (*ExecuteHookRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*ExecuteHookRequest) ProtoMessage 

func (*ExecuteHookRequest) ProtoMessage()

func (*ExecuteHookRequest) Reset 

func (m *ExecuteHookRequest) Reset()

func (*ExecuteHookRequest) Size added in v0.10.0 

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

func (*ExecuteHookRequest) String 

func (m *ExecuteHookRequest) String() string

func (*ExecuteHookRequest) Unmarshal added in v0.10.0 

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

func (*ExecuteHookRequest) XXX_DiscardUnknown 

func (m *ExecuteHookRequest) XXX_DiscardUnknown()

func (*ExecuteHookRequest) XXX_Marshal 

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

func (*ExecuteHookRequest) XXX_Merge 

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

func (*ExecuteHookRequest) XXX_Size 

func (m *ExecuteHookRequest) XXX_Size() int

func (*ExecuteHookRequest) XXX_Unmarshal 

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

type ExecuteHookResponse 

type ExecuteHookResponse struct {
	ExitStatus           int64    `protobuf:"varint,1,opt,name=exit_status,json=exitStatus,proto3" json:"exit_status,omitempty"`
	Stdout               string   `protobuf:"bytes,2,opt,name=stdout,proto3" json:"stdout,omitempty"`
	Stderr               string   `protobuf:"bytes,3,opt,name=stderr,proto3" json:"stderr,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ExecuteHookResponse) Descriptor 

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

func (*ExecuteHookResponse) GetExitStatus 

func (m *ExecuteHookResponse) GetExitStatus() int64

func (*ExecuteHookResponse) GetStderr 

func (m *ExecuteHookResponse) GetStderr() string

func (*ExecuteHookResponse) GetStdout 

func (m *ExecuteHookResponse) GetStdout() string

func (*ExecuteHookResponse) Marshal added in v0.10.0 

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

func (*ExecuteHookResponse) MarshalTo added in v0.10.0 

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

func (*ExecuteHookResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*ExecuteHookResponse) ProtoMessage 

func (*ExecuteHookResponse) ProtoMessage()

func (*ExecuteHookResponse) Reset 

func (m *ExecuteHookResponse) Reset()

func (*ExecuteHookResponse) Size added in v0.10.0 

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

func (*ExecuteHookResponse) String 

func (m *ExecuteHookResponse) String() string

func (*ExecuteHookResponse) Unmarshal added in v0.10.0 

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

func (*ExecuteHookResponse) XXX_DiscardUnknown 

func (m *ExecuteHookResponse) XXX_DiscardUnknown()

func (*ExecuteHookResponse) XXX_Marshal 

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

func (*ExecuteHookResponse) XXX_Merge 

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

func (*ExecuteHookResponse) XXX_Size 

func (m *ExecuteHookResponse) XXX_Size() int

func (*ExecuteHookResponse) XXX_Unmarshal 

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

type GetPermissionsRequest 

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

func (*GetPermissionsRequest) Descriptor 

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

func (*GetPermissionsRequest) Marshal added in v0.10.0 

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

func (*GetPermissionsRequest) MarshalTo added in v0.10.0 

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

func (*GetPermissionsRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*GetPermissionsRequest) ProtoMessage 

func (*GetPermissionsRequest) ProtoMessage()

func (*GetPermissionsRequest) Reset 

func (m *GetPermissionsRequest) Reset()

func (*GetPermissionsRequest) Size added in v0.10.0 

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

func (*GetPermissionsRequest) String 

func (m *GetPermissionsRequest) String() string

func (*GetPermissionsRequest) Unmarshal added in v0.10.0 

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

func (*GetPermissionsRequest) XXX_DiscardUnknown 

func (m *GetPermissionsRequest) XXX_DiscardUnknown()

func (*GetPermissionsRequest) XXX_Marshal 

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

func (*GetPermissionsRequest) XXX_Merge 

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

func (*GetPermissionsRequest) XXX_Size 

func (m *GetPermissionsRequest) XXX_Size() int

func (*GetPermissionsRequest) XXX_Unmarshal 

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

type GetPermissionsResponse 

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

func (*GetPermissionsResponse) Descriptor 

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

func (*GetPermissionsResponse) GetPermissions 

func (m *GetPermissionsResponse) GetPermissions() *Permissions

func (*GetPermissionsResponse) Marshal added in v0.10.0 

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

func (*GetPermissionsResponse) MarshalTo added in v0.10.0 

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

func (*GetPermissionsResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*GetPermissionsResponse) ProtoMessage 

func (*GetPermissionsResponse) ProtoMessage()

func (*GetPermissionsResponse) Reset 

func (m *GetPermissionsResponse) Reset()

func (*GetPermissionsResponse) Size added in v0.10.0 

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

func (*GetPermissionsResponse) String 

func (m *GetPermissionsResponse) String() string

func (*GetPermissionsResponse) Unmarshal added in v0.10.0 

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

func (*GetPermissionsResponse) XXX_DiscardUnknown 

func (m *GetPermissionsResponse) XXX_DiscardUnknown()

func (*GetPermissionsResponse) XXX_Marshal 

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

func (*GetPermissionsResponse) XXX_Merge 

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

func (*GetPermissionsResponse) XXX_Size 

func (m *GetPermissionsResponse) XXX_Size() int

func (*GetPermissionsResponse) XXX_Unmarshal 

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

type GetReplicasRequest 

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

func (*GetReplicasRequest) Descriptor 

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

func (*GetReplicasRequest) Marshal added in v0.10.0 

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

func (*GetReplicasRequest) MarshalTo added in v0.10.0 

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

func (*GetReplicasRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*GetReplicasRequest) ProtoMessage 

func (*GetReplicasRequest) ProtoMessage()

func (*GetReplicasRequest) Reset 

func (m *GetReplicasRequest) Reset()

func (*GetReplicasRequest) Size added in v0.10.0 

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

func (*GetReplicasRequest) String 

func (m *GetReplicasRequest) String() string

func (*GetReplicasRequest) Unmarshal added in v0.10.0 

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

func (*GetReplicasRequest) XXX_DiscardUnknown 

func (m *GetReplicasRequest) XXX_DiscardUnknown()

func (*GetReplicasRequest) XXX_Marshal 

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

func (*GetReplicasRequest) XXX_Merge 

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

func (*GetReplicasRequest) XXX_Size 

func (m *GetReplicasRequest) XXX_Size() int

func (*GetReplicasRequest) XXX_Unmarshal 

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

type GetReplicasResponse 

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

func (*GetReplicasResponse) Descriptor 

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

func (*GetReplicasResponse) GetAddrs 

func (m *GetReplicasResponse) GetAddrs() []string

func (*GetReplicasResponse) Marshal added in v0.10.0 

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

func (*GetReplicasResponse) MarshalTo added in v0.10.0 

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

func (*GetReplicasResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*GetReplicasResponse) ProtoMessage 

func (*GetReplicasResponse) ProtoMessage()

func (*GetReplicasResponse) Reset 

func (m *GetReplicasResponse) Reset()

func (*GetReplicasResponse) Size added in v0.10.0 

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

func (*GetReplicasResponse) String 

func (m *GetReplicasResponse) String() string

func (*GetReplicasResponse) Unmarshal added in v0.10.0 

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

func (*GetReplicasResponse) XXX_DiscardUnknown 

func (m *GetReplicasResponse) XXX_DiscardUnknown()

func (*GetReplicasResponse) XXX_Marshal 

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

func (*GetReplicasResponse) XXX_Merge 

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

func (*GetReplicasResponse) XXX_Size 

func (m *GetReplicasResponse) XXX_Size() int

func (*GetReplicasResponse) XXX_Unmarshal 

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

type GetSchemaRequest 

type GetSchemaRequest struct {
	Tables               []string `protobuf:"bytes,1,rep,name=tables,proto3" json:"tables,omitempty"`
	IncludeViews         bool     `protobuf:"varint,2,opt,name=include_views,json=includeViews,proto3" json:"include_views,omitempty"`
	ExcludeTables        []string `protobuf:"bytes,3,rep,name=exclude_tables,json=excludeTables,proto3" json:"exclude_tables,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetSchemaRequest) Descriptor 

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

func (*GetSchemaRequest) GetExcludeTables 

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

func (*GetSchemaRequest) GetIncludeViews 

func (m *GetSchemaRequest) GetIncludeViews() bool

func (*GetSchemaRequest) GetTables 

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

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 

func (*GetSchemaRequest) ProtoMessage()

func (*GetSchemaRequest) Reset 

func (m *GetSchemaRequest) Reset()

func (*GetSchemaRequest) Size added in v0.10.0 

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

func (*GetSchemaRequest) String 

func (m *GetSchemaRequest) String() string

func (*GetSchemaRequest) Unmarshal added in v0.10.0 

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

func (*GetSchemaRequest) XXX_DiscardUnknown 

func (m *GetSchemaRequest) XXX_DiscardUnknown()

func (*GetSchemaRequest) XXX_Marshal 

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

func (*GetSchemaRequest) XXX_Merge 

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

func (*GetSchemaRequest) XXX_Size 

func (m *GetSchemaRequest) XXX_Size() int

func (*GetSchemaRequest) XXX_Unmarshal 

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

type GetSchemaResponse 

type GetSchemaResponse struct {
	SchemaDefinition     *SchemaDefinition `protobuf:"bytes,1,opt,name=schema_definition,json=schemaDefinition,proto3" json:"schema_definition,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*GetSchemaResponse) Descriptor 

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

func (*GetSchemaResponse) GetSchemaDefinition 

func (m *GetSchemaResponse) GetSchemaDefinition() *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 

func (*GetSchemaResponse) ProtoMessage()

func (*GetSchemaResponse) Reset 

func (m *GetSchemaResponse) Reset()

func (*GetSchemaResponse) Size added in v0.10.0 

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

func (*GetSchemaResponse) String 

func (m *GetSchemaResponse) String() string

func (*GetSchemaResponse) Unmarshal added in v0.10.0 

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

func (*GetSchemaResponse) XXX_DiscardUnknown 

func (m *GetSchemaResponse) XXX_DiscardUnknown()

func (*GetSchemaResponse) XXX_Marshal 

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

func (*GetSchemaResponse) XXX_Merge 

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

func (*GetSchemaResponse) XXX_Size 

func (m *GetSchemaResponse) XXX_Size() int

func (*GetSchemaResponse) XXX_Unmarshal 

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

type IgnoreHealthErrorRequest 

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

func (*IgnoreHealthErrorRequest) Descriptor 

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

func (*IgnoreHealthErrorRequest) GetPattern 

func (m *IgnoreHealthErrorRequest) GetPattern() string

func (*IgnoreHealthErrorRequest) Marshal added in v0.10.0 

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

func (*IgnoreHealthErrorRequest) MarshalTo added in v0.10.0 

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

func (*IgnoreHealthErrorRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*IgnoreHealthErrorRequest) ProtoMessage 

func (*IgnoreHealthErrorRequest) ProtoMessage()

func (*IgnoreHealthErrorRequest) Reset 

func (m *IgnoreHealthErrorRequest) Reset()

func (*IgnoreHealthErrorRequest) Size added in v0.10.0 

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

func (*IgnoreHealthErrorRequest) String 

func (m *IgnoreHealthErrorRequest) String() string

func (*IgnoreHealthErrorRequest) Unmarshal added in v0.10.0 

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

func (*IgnoreHealthErrorRequest) XXX_DiscardUnknown 

func (m *IgnoreHealthErrorRequest) XXX_DiscardUnknown()

func (*IgnoreHealthErrorRequest) XXX_Marshal 

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

func (*IgnoreHealthErrorRequest) XXX_Merge 

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

func (*IgnoreHealthErrorRequest) XXX_Size 

func (m *IgnoreHealthErrorRequest) XXX_Size() int

func (*IgnoreHealthErrorRequest) XXX_Unmarshal 

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

type IgnoreHealthErrorResponse 

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

func (*IgnoreHealthErrorResponse) Descriptor 

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

func (*IgnoreHealthErrorResponse) Marshal added in v0.10.0 

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

func (*IgnoreHealthErrorResponse) MarshalTo added in v0.10.0 

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

func (*IgnoreHealthErrorResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*IgnoreHealthErrorResponse) ProtoMessage 

func (*IgnoreHealthErrorResponse) ProtoMessage()

func (*IgnoreHealthErrorResponse) Reset 

func (m *IgnoreHealthErrorResponse) Reset()

func (*IgnoreHealthErrorResponse) Size added in v0.10.0 

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

func (*IgnoreHealthErrorResponse) String 

func (m *IgnoreHealthErrorResponse) String() string

func (*IgnoreHealthErrorResponse) Unmarshal added in v0.10.0 

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

func (*IgnoreHealthErrorResponse) XXX_DiscardUnknown 

func (m *IgnoreHealthErrorResponse) XXX_DiscardUnknown()

func (*IgnoreHealthErrorResponse) XXX_Marshal 

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

func (*IgnoreHealthErrorResponse) XXX_Merge 

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

func (*IgnoreHealthErrorResponse) XXX_Size 

func (m *IgnoreHealthErrorResponse) XXX_Size() int

func (*IgnoreHealthErrorResponse) XXX_Unmarshal 

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

type InitMasterRequest 

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

func (*InitMasterRequest) Descriptor 

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

func (*InitMasterRequest) Marshal added in v0.10.0 

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

func (*InitMasterRequest) MarshalTo added in v0.10.0 

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

func (*InitMasterRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*InitMasterRequest) ProtoMessage 

func (*InitMasterRequest) ProtoMessage()

func (*InitMasterRequest) Reset 

func (m *InitMasterRequest) Reset()

func (*InitMasterRequest) Size added in v0.10.0 

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

func (*InitMasterRequest) String 

func (m *InitMasterRequest) String() string

func (*InitMasterRequest) Unmarshal added in v0.10.0 

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

func (*InitMasterRequest) XXX_DiscardUnknown 

func (m *InitMasterRequest) XXX_DiscardUnknown()

func (*InitMasterRequest) XXX_Marshal 

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

func (*InitMasterRequest) XXX_Merge 

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

func (*InitMasterRequest) XXX_Size 

func (m *InitMasterRequest) XXX_Size() int

func (*InitMasterRequest) XXX_Unmarshal 

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

type InitMasterResponse 

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

func (*InitMasterResponse) Descriptor 

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

func (*InitMasterResponse) GetPosition 

func (m *InitMasterResponse) GetPosition() string

func (*InitMasterResponse) Marshal added in v0.10.0 

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

func (*InitMasterResponse) MarshalTo added in v0.10.0 

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

func (*InitMasterResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*InitMasterResponse) ProtoMessage 

func (*InitMasterResponse) ProtoMessage()

func (*InitMasterResponse) Reset 

func (m *InitMasterResponse) Reset()

func (*InitMasterResponse) Size added in v0.10.0 

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

func (*InitMasterResponse) String 

func (m *InitMasterResponse) String() string

func (*InitMasterResponse) Unmarshal added in v0.10.0 

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

func (*InitMasterResponse) XXX_DiscardUnknown 

func (m *InitMasterResponse) XXX_DiscardUnknown()

func (*InitMasterResponse) XXX_Marshal 

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

func (*InitMasterResponse) XXX_Merge 

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

func (*InitMasterResponse) XXX_Size 

func (m *InitMasterResponse) XXX_Size() int

func (*InitMasterResponse) XXX_Unmarshal 

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

type InitReplicaRequest 

type InitReplicaRequest struct {
	Parent               *topodata.TabletAlias `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	ReplicationPosition  string                `protobuf:"bytes,2,opt,name=replication_position,json=replicationPosition,proto3" json:"replication_position,omitempty"`
	TimeCreatedNs        int64                 `protobuf:"varint,3,opt,name=time_created_ns,json=timeCreatedNs,proto3" json:"time_created_ns,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*InitReplicaRequest) Descriptor 

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

func (*InitReplicaRequest) GetParent 

func (m *InitReplicaRequest) GetParent() *topodata.TabletAlias

func (*InitReplicaRequest) GetReplicationPosition 

func (m *InitReplicaRequest) GetReplicationPosition() string

func (*InitReplicaRequest) GetTimeCreatedNs 

func (m *InitReplicaRequest) GetTimeCreatedNs() int64

func (*InitReplicaRequest) Marshal added in v0.10.0 

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

func (*InitReplicaRequest) MarshalTo added in v0.10.0 

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

func (*InitReplicaRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*InitReplicaRequest) ProtoMessage 

func (*InitReplicaRequest) ProtoMessage()

func (*InitReplicaRequest) Reset 

func (m *InitReplicaRequest) Reset()

func (*InitReplicaRequest) Size added in v0.10.0 

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

func (*InitReplicaRequest) String 

func (m *InitReplicaRequest) String() string

func (*InitReplicaRequest) Unmarshal added in v0.10.0 

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

func (*InitReplicaRequest) XXX_DiscardUnknown 

func (m *InitReplicaRequest) XXX_DiscardUnknown()

func (*InitReplicaRequest) XXX_Marshal 

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

func (*InitReplicaRequest) XXX_Merge 

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

func (*InitReplicaRequest) XXX_Size 

func (m *InitReplicaRequest) XXX_Size() int

func (*InitReplicaRequest) XXX_Unmarshal 

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

type InitReplicaResponse 

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

func (*InitReplicaResponse) Descriptor 

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

func (*InitReplicaResponse) Marshal added in v0.10.0 

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

func (*InitReplicaResponse) MarshalTo added in v0.10.0 

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

func (*InitReplicaResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*InitReplicaResponse) ProtoMessage 

func (*InitReplicaResponse) ProtoMessage()

func (*InitReplicaResponse) Reset 

func (m *InitReplicaResponse) Reset()

func (*InitReplicaResponse) Size added in v0.10.0 

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

func (*InitReplicaResponse) String 

func (m *InitReplicaResponse) String() string

func (*InitReplicaResponse) Unmarshal added in v0.10.0 

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

func (*InitReplicaResponse) XXX_DiscardUnknown 

func (m *InitReplicaResponse) XXX_DiscardUnknown()

func (*InitReplicaResponse) XXX_Marshal 

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

func (*InitReplicaResponse) XXX_Merge 

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

func (*InitReplicaResponse) XXX_Size 

func (m *InitReplicaResponse) XXX_Size() int

func (*InitReplicaResponse) XXX_Unmarshal 

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

type LockTablesRequest 

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

func (*LockTablesRequest) Descriptor 

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

func (*LockTablesRequest) Marshal added in v0.10.0 

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

func (*LockTablesRequest) MarshalTo added in v0.10.0 

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

func (*LockTablesRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*LockTablesRequest) ProtoMessage 

func (*LockTablesRequest) ProtoMessage()

func (*LockTablesRequest) Reset 

func (m *LockTablesRequest) Reset()

func (*LockTablesRequest) Size added in v0.10.0 

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

func (*LockTablesRequest) String 

func (m *LockTablesRequest) String() string

func (*LockTablesRequest) Unmarshal added in v0.10.0 

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

func (*LockTablesRequest) XXX_DiscardUnknown 

func (m *LockTablesRequest) XXX_DiscardUnknown()

func (*LockTablesRequest) XXX_Marshal 

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

func (*LockTablesRequest) XXX_Merge 

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

func (*LockTablesRequest) XXX_Size 

func (m *LockTablesRequest) XXX_Size() int

func (*LockTablesRequest) XXX_Unmarshal 

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

type LockTablesResponse 

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

func (*LockTablesResponse) Descriptor 

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

func (*LockTablesResponse) Marshal added in v0.10.0 

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

func (*LockTablesResponse) MarshalTo added in v0.10.0 

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

func (*LockTablesResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*LockTablesResponse) ProtoMessage 

func (*LockTablesResponse) ProtoMessage()

func (*LockTablesResponse) Reset 

func (m *LockTablesResponse) Reset()

func (*LockTablesResponse) Size added in v0.10.0 

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

func (*LockTablesResponse) String 

func (m *LockTablesResponse) String() string

func (*LockTablesResponse) Unmarshal added in v0.10.0 

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

func (*LockTablesResponse) XXX_DiscardUnknown 

func (m *LockTablesResponse) XXX_DiscardUnknown()

func (*LockTablesResponse) XXX_Marshal 

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

func (*LockTablesResponse) XXX_Merge 

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

func (*LockTablesResponse) XXX_Size 

func (m *LockTablesResponse) XXX_Size() int

func (*LockTablesResponse) XXX_Unmarshal 

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

type MasterPositionRequest 

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

func (*MasterPositionRequest) Descriptor 

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

func (*MasterPositionRequest) Marshal added in v0.10.0 

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

func (*MasterPositionRequest) MarshalTo added in v0.10.0 

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

func (*MasterPositionRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*MasterPositionRequest) ProtoMessage 

func (*MasterPositionRequest) ProtoMessage()

func (*MasterPositionRequest) Reset 

func (m *MasterPositionRequest) Reset()

func (*MasterPositionRequest) Size added in v0.10.0 

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

func (*MasterPositionRequest) String 

func (m *MasterPositionRequest) String() string

func (*MasterPositionRequest) Unmarshal added in v0.10.0 

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

func (*MasterPositionRequest) XXX_DiscardUnknown 

func (m *MasterPositionRequest) XXX_DiscardUnknown()

func (*MasterPositionRequest) XXX_Marshal 

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

func (*MasterPositionRequest) XXX_Merge 

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

func (*MasterPositionRequest) XXX_Size 

func (m *MasterPositionRequest) XXX_Size() int

func (*MasterPositionRequest) XXX_Unmarshal 

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

type MasterPositionResponse 

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

func (*MasterPositionResponse) Descriptor 

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

func (*MasterPositionResponse) GetPosition 

func (m *MasterPositionResponse) GetPosition() string

func (*MasterPositionResponse) Marshal added in v0.10.0 

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

func (*MasterPositionResponse) MarshalTo added in v0.10.0 

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

func (*MasterPositionResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*MasterPositionResponse) ProtoMessage 

func (*MasterPositionResponse) ProtoMessage()

func (*MasterPositionResponse) Reset 

func (m *MasterPositionResponse) Reset()

func (*MasterPositionResponse) Size added in v0.10.0 

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

func (*MasterPositionResponse) String 

func (m *MasterPositionResponse) String() string

func (*MasterPositionResponse) Unmarshal added in v0.10.0 

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

func (*MasterPositionResponse) XXX_DiscardUnknown 

func (m *MasterPositionResponse) XXX_DiscardUnknown()

func (*MasterPositionResponse) XXX_Marshal 

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

func (*MasterPositionResponse) XXX_Merge 

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

func (*MasterPositionResponse) XXX_Size 

func (m *MasterPositionResponse) XXX_Size() int

func (*MasterPositionResponse) XXX_Unmarshal 

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

type MasterStatusRequest 

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

func (*MasterStatusRequest) Descriptor 

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

func (*MasterStatusRequest) Marshal added in v0.10.0 

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

func (*MasterStatusRequest) MarshalTo added in v0.10.0 

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

func (*MasterStatusRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*MasterStatusRequest) ProtoMessage 

func (*MasterStatusRequest) ProtoMessage()

func (*MasterStatusRequest) Reset 

func (m *MasterStatusRequest) Reset()

func (*MasterStatusRequest) Size added in v0.10.0 

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

func (*MasterStatusRequest) String 

func (m *MasterStatusRequest) String() string

func (*MasterStatusRequest) Unmarshal added in v0.10.0 

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

func (*MasterStatusRequest) XXX_DiscardUnknown 

func (m *MasterStatusRequest) XXX_DiscardUnknown()

func (*MasterStatusRequest) XXX_Marshal 

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

func (*MasterStatusRequest) XXX_Merge 

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

func (*MasterStatusRequest) XXX_Size 

func (m *MasterStatusRequest) XXX_Size() int

func (*MasterStatusRequest) XXX_Unmarshal 

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

type MasterStatusResponse 

type MasterStatusResponse struct {
	Status               *replicationdata.MasterStatus `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                      `json:"-"`
	XXX_unrecognized     []byte                        `json:"-"`
	XXX_sizecache        int32                         `json:"-"`
}

func (*MasterStatusResponse) Descriptor 

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

func (*MasterStatusResponse) GetStatus 

func (m *MasterStatusResponse) GetStatus() *replicationdata.MasterStatus

func (*MasterStatusResponse) Marshal added in v0.10.0 

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

func (*MasterStatusResponse) MarshalTo added in v0.10.0 

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

func (*MasterStatusResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*MasterStatusResponse) ProtoMessage 

func (*MasterStatusResponse) ProtoMessage()

func (*MasterStatusResponse) Reset 

func (m *MasterStatusResponse) Reset()

func (*MasterStatusResponse) Size added in v0.10.0 

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

func (*MasterStatusResponse) String 

func (m *MasterStatusResponse) String() string

func (*MasterStatusResponse) Unmarshal added in v0.10.0 

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

func (*MasterStatusResponse) XXX_DiscardUnknown 

func (m *MasterStatusResponse) XXX_DiscardUnknown()

func (*MasterStatusResponse) XXX_Marshal 

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

func (*MasterStatusResponse) XXX_Merge 

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

func (*MasterStatusResponse) XXX_Size 

func (m *MasterStatusResponse) XXX_Size() int

func (*MasterStatusResponse) XXX_Unmarshal 

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

type Permissions 

type Permissions struct {
	UserPermissions      []*UserPermission `protobuf:"bytes,1,rep,name=user_permissions,json=userPermissions,proto3" json:"user_permissions,omitempty"`
	DbPermissions        []*DbPermission   `protobuf:"bytes,2,rep,name=db_permissions,json=dbPermissions,proto3" json:"db_permissions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

Permissions have all the rows in mysql.{user,db} tables, (all rows are sorted by primary key)

func (*Permissions) Descriptor 

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

func (*Permissions) GetDbPermissions 

func (m *Permissions) GetDbPermissions() []*DbPermission

func (*Permissions) GetUserPermissions 

func (m *Permissions) GetUserPermissions() []*UserPermission

func (*Permissions) Marshal added in v0.10.0 

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

func (*Permissions) MarshalTo added in v0.10.0 

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

func (*Permissions) MarshalToSizedBuffer added in v0.10.0 

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

func (*Permissions) ProtoMessage 

func (*Permissions) ProtoMessage()

func (*Permissions) Reset 

func (m *Permissions) Reset()

func (*Permissions) Size added in v0.10.0 

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

func (*Permissions) String 

func (m *Permissions) String() string

func (*Permissions) Unmarshal added in v0.10.0 

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

func (*Permissions) XXX_DiscardUnknown 

func (m *Permissions) XXX_DiscardUnknown()

func (*Permissions) XXX_Marshal 

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

func (*Permissions) XXX_Merge 

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

func (*Permissions) XXX_Size 

func (m *Permissions) XXX_Size() int

func (*Permissions) XXX_Unmarshal 

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

type PingRequest 

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

func (*PingRequest) Descriptor 

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

func (*PingRequest) GetPayload 

func (m *PingRequest) GetPayload() string

func (*PingRequest) Marshal added in v0.10.0 

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

func (*PingRequest) MarshalTo added in v0.10.0 

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

func (*PingRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*PingRequest) ProtoMessage 

func (*PingRequest) ProtoMessage()

func (*PingRequest) Reset 

func (m *PingRequest) Reset()

func (*PingRequest) Size added in v0.10.0 

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

func (*PingRequest) String 

func (m *PingRequest) String() string

func (*PingRequest) Unmarshal added in v0.10.0 

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

func (*PingRequest) XXX_DiscardUnknown 

func (m *PingRequest) XXX_DiscardUnknown()

func (*PingRequest) XXX_Marshal 

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

func (*PingRequest) XXX_Merge 

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

func (*PingRequest) XXX_Size 

func (m *PingRequest) XXX_Size() int

func (*PingRequest) XXX_Unmarshal 

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

type PingResponse 

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

func (*PingResponse) Descriptor 

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

func (*PingResponse) GetPayload 

func (m *PingResponse) GetPayload() string

func (*PingResponse) Marshal added in v0.10.0 

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

func (*PingResponse) MarshalTo added in v0.10.0 

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

func (*PingResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*PingResponse) ProtoMessage 

func (*PingResponse) ProtoMessage()

func (*PingResponse) Reset 

func (m *PingResponse) Reset()

func (*PingResponse) Size added in v0.10.0 

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

func (*PingResponse) String 

func (m *PingResponse) String() string

func (*PingResponse) Unmarshal added in v0.10.0 

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

func (*PingResponse) XXX_DiscardUnknown 

func (m *PingResponse) XXX_DiscardUnknown()

func (*PingResponse) XXX_Marshal 

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

func (*PingResponse) XXX_Merge 

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

func (*PingResponse) XXX_Size 

func (m *PingResponse) XXX_Size() int

func (*PingResponse) XXX_Unmarshal 

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

type PopulateReparentJournalRequest 

type PopulateReparentJournalRequest struct {
	TimeCreatedNs        int64                 `protobuf:"varint,1,opt,name=time_created_ns,json=timeCreatedNs,proto3" json:"time_created_ns,omitempty"`
	ActionName           string                `protobuf:"bytes,2,opt,name=action_name,json=actionName,proto3" json:"action_name,omitempty"`
	MasterAlias          *topodata.TabletAlias `protobuf:"bytes,3,opt,name=master_alias,json=masterAlias,proto3" json:"master_alias,omitempty"`
	ReplicationPosition  string                `protobuf:"bytes,4,opt,name=replication_position,json=replicationPosition,proto3" json:"replication_position,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*PopulateReparentJournalRequest) Descriptor 

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

func (*PopulateReparentJournalRequest) GetActionName 

func (m *PopulateReparentJournalRequest) GetActionName() string

func (*PopulateReparentJournalRequest) GetMasterAlias 

func (m *PopulateReparentJournalRequest) GetMasterAlias() *topodata.TabletAlias

func (*PopulateReparentJournalRequest) GetReplicationPosition 

func (m *PopulateReparentJournalRequest) GetReplicationPosition() string

func (*PopulateReparentJournalRequest) GetTimeCreatedNs 

func (m *PopulateReparentJournalRequest) GetTimeCreatedNs() int64

func (*PopulateReparentJournalRequest) Marshal added in v0.10.0 

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

func (*PopulateReparentJournalRequest) MarshalTo added in v0.10.0 

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

func (*PopulateReparentJournalRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*PopulateReparentJournalRequest) ProtoMessage 

func (*PopulateReparentJournalRequest) ProtoMessage()

func (*PopulateReparentJournalRequest) Reset 

func (m *PopulateReparentJournalRequest) Reset()

func (*PopulateReparentJournalRequest) Size added in v0.10.0 

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

func (*PopulateReparentJournalRequest) String 

func (m *PopulateReparentJournalRequest) String() string

func (*PopulateReparentJournalRequest) Unmarshal added in v0.10.0 

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

func (*PopulateReparentJournalRequest) XXX_DiscardUnknown 

func (m *PopulateReparentJournalRequest) XXX_DiscardUnknown()

func (*PopulateReparentJournalRequest) XXX_Marshal 

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

func (*PopulateReparentJournalRequest) XXX_Merge 

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

func (*PopulateReparentJournalRequest) XXX_Size 

func (m *PopulateReparentJournalRequest) XXX_Size() int

func (*PopulateReparentJournalRequest) XXX_Unmarshal 

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

type PopulateReparentJournalResponse 

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

func (*PopulateReparentJournalResponse) Descriptor 

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

func (*PopulateReparentJournalResponse) Marshal added in v0.10.0 

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

func (*PopulateReparentJournalResponse) MarshalTo added in v0.10.0 

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

func (*PopulateReparentJournalResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*PopulateReparentJournalResponse) ProtoMessage 

func (*PopulateReparentJournalResponse) ProtoMessage()

func (*PopulateReparentJournalResponse) Reset 

func (m *PopulateReparentJournalResponse) Reset()

func (*PopulateReparentJournalResponse) Size added in v0.10.0 

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

func (*PopulateReparentJournalResponse) String 

func (m *PopulateReparentJournalResponse) String() string

func (*PopulateReparentJournalResponse) Unmarshal added in v0.10.0 

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

func (*PopulateReparentJournalResponse) XXX_DiscardUnknown 

func (m *PopulateReparentJournalResponse) XXX_DiscardUnknown()

func (*PopulateReparentJournalResponse) XXX_Marshal 

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

func (*PopulateReparentJournalResponse) XXX_Merge 

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

func (*PopulateReparentJournalResponse) XXX_Size 

func (m *PopulateReparentJournalResponse) XXX_Size() int

func (*PopulateReparentJournalResponse) XXX_Unmarshal 

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

type PreflightSchemaRequest 

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

func (*PreflightSchemaRequest) Descriptor 

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

func (*PreflightSchemaRequest) GetChanges 

func (m *PreflightSchemaRequest) GetChanges() []string

func (*PreflightSchemaRequest) Marshal added in v0.10.0 

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

func (*PreflightSchemaRequest) MarshalTo added in v0.10.0 

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

func (*PreflightSchemaRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*PreflightSchemaRequest) ProtoMessage 

func (*PreflightSchemaRequest) ProtoMessage()

func (*PreflightSchemaRequest) Reset 

func (m *PreflightSchemaRequest) Reset()

func (*PreflightSchemaRequest) Size added in v0.10.0 

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

func (*PreflightSchemaRequest) String 

func (m *PreflightSchemaRequest) String() string

func (*PreflightSchemaRequest) Unmarshal added in v0.10.0 

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

func (*PreflightSchemaRequest) XXX_DiscardUnknown 

func (m *PreflightSchemaRequest) XXX_DiscardUnknown()

func (*PreflightSchemaRequest) XXX_Marshal 

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

func (*PreflightSchemaRequest) XXX_Merge 

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

func (*PreflightSchemaRequest) XXX_Size 

func (m *PreflightSchemaRequest) XXX_Size() int

func (*PreflightSchemaRequest) XXX_Unmarshal 

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

type PreflightSchemaResponse 

type PreflightSchemaResponse struct {
	// change_results has for each change the schema before and after it.
	// The number of elements is identical to the length of "changes" in the request.
	ChangeResults        []*SchemaChangeResult `protobuf:"bytes,1,rep,name=change_results,json=changeResults,proto3" json:"change_results,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*PreflightSchemaResponse) Descriptor 

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

func (*PreflightSchemaResponse) GetChangeResults 

func (m *PreflightSchemaResponse) GetChangeResults() []*SchemaChangeResult

func (*PreflightSchemaResponse) Marshal added in v0.10.0 

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

func (*PreflightSchemaResponse) MarshalTo added in v0.10.0 

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

func (*PreflightSchemaResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*PreflightSchemaResponse) ProtoMessage 

func (*PreflightSchemaResponse) ProtoMessage()

func (*PreflightSchemaResponse) Reset 

func (m *PreflightSchemaResponse) Reset()

func (*PreflightSchemaResponse) Size added in v0.10.0 

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

func (*PreflightSchemaResponse) String 

func (m *PreflightSchemaResponse) String() string

func (*PreflightSchemaResponse) Unmarshal added in v0.10.0 

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

func (*PreflightSchemaResponse) XXX_DiscardUnknown 

func (m *PreflightSchemaResponse) XXX_DiscardUnknown()

func (*PreflightSchemaResponse) XXX_Marshal 

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

func (*PreflightSchemaResponse) XXX_Merge 

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

func (*PreflightSchemaResponse) XXX_Size 

func (m *PreflightSchemaResponse) XXX_Size() int

func (*PreflightSchemaResponse) XXX_Unmarshal 

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

type PromoteReplicaRequest 

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

func (*PromoteReplicaRequest) Descriptor 

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

func (*PromoteReplicaRequest) Marshal added in v0.10.0 

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

func (*PromoteReplicaRequest) MarshalTo added in v0.10.0 

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

func (*PromoteReplicaRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*PromoteReplicaRequest) ProtoMessage 

func (*PromoteReplicaRequest) ProtoMessage()

func (*PromoteReplicaRequest) Reset 

func (m *PromoteReplicaRequest) Reset()

func (*PromoteReplicaRequest) Size added in v0.10.0 

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

func (*PromoteReplicaRequest) String 

func (m *PromoteReplicaRequest) String() string

func (*PromoteReplicaRequest) Unmarshal added in v0.10.0 

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

func (*PromoteReplicaRequest) XXX_DiscardUnknown 

func (m *PromoteReplicaRequest) XXX_DiscardUnknown()

func (*PromoteReplicaRequest) XXX_Marshal 

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

func (*PromoteReplicaRequest) XXX_Merge 

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

func (*PromoteReplicaRequest) XXX_Size 

func (m *PromoteReplicaRequest) XXX_Size() int

func (*PromoteReplicaRequest) XXX_Unmarshal 

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

type PromoteReplicaResponse 

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

func (*PromoteReplicaResponse) Descriptor 

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

func (*PromoteReplicaResponse) GetPosition 

func (m *PromoteReplicaResponse) GetPosition() string

func (*PromoteReplicaResponse) Marshal added in v0.10.0 

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

func (*PromoteReplicaResponse) MarshalTo added in v0.10.0 

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

func (*PromoteReplicaResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*PromoteReplicaResponse) ProtoMessage 

func (*PromoteReplicaResponse) ProtoMessage()

func (*PromoteReplicaResponse) Reset 

func (m *PromoteReplicaResponse) Reset()

func (*PromoteReplicaResponse) Size added in v0.10.0 

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

func (*PromoteReplicaResponse) String 

func (m *PromoteReplicaResponse) String() string

func (*PromoteReplicaResponse) Unmarshal added in v0.10.0 

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

func (*PromoteReplicaResponse) XXX_DiscardUnknown 

func (m *PromoteReplicaResponse) XXX_DiscardUnknown()

func (*PromoteReplicaResponse) XXX_Marshal 

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

func (*PromoteReplicaResponse) XXX_Merge 

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

func (*PromoteReplicaResponse) XXX_Size 

func (m *PromoteReplicaResponse) XXX_Size() int

func (*PromoteReplicaResponse) XXX_Unmarshal 

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

type RefreshStateRequest 

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

func (*RefreshStateRequest) Descriptor 

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

func (*RefreshStateRequest) Marshal added in v0.10.0 

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

func (*RefreshStateRequest) MarshalTo added in v0.10.0 

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

func (*RefreshStateRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*RefreshStateRequest) ProtoMessage 

func (*RefreshStateRequest) ProtoMessage()

func (*RefreshStateRequest) Reset 

func (m *RefreshStateRequest) Reset()

func (*RefreshStateRequest) Size added in v0.10.0 

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

func (*RefreshStateRequest) String 

func (m *RefreshStateRequest) String() string

func (*RefreshStateRequest) Unmarshal added in v0.10.0 

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

func (*RefreshStateRequest) XXX_DiscardUnknown 

func (m *RefreshStateRequest) XXX_DiscardUnknown()

func (*RefreshStateRequest) XXX_Marshal 

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

func (*RefreshStateRequest) XXX_Merge 

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

func (*RefreshStateRequest) XXX_Size 

func (m *RefreshStateRequest) XXX_Size() int

func (*RefreshStateRequest) XXX_Unmarshal 

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

type RefreshStateResponse 

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

func (*RefreshStateResponse) Descriptor 

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

func (*RefreshStateResponse) Marshal added in v0.10.0 

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

func (*RefreshStateResponse) MarshalTo added in v0.10.0 

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

func (*RefreshStateResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*RefreshStateResponse) ProtoMessage 

func (*RefreshStateResponse) ProtoMessage()

func (*RefreshStateResponse) Reset 

func (m *RefreshStateResponse) Reset()

func (*RefreshStateResponse) Size added in v0.10.0 

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

func (*RefreshStateResponse) String 

func (m *RefreshStateResponse) String() string

func (*RefreshStateResponse) Unmarshal added in v0.10.0 

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

func (*RefreshStateResponse) XXX_DiscardUnknown 

func (m *RefreshStateResponse) XXX_DiscardUnknown()

func (*RefreshStateResponse) XXX_Marshal 

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

func (*RefreshStateResponse) XXX_Merge 

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

func (*RefreshStateResponse) XXX_Size 

func (m *RefreshStateResponse) XXX_Size() int

func (*RefreshStateResponse) XXX_Unmarshal 

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

type ReloadSchemaRequest 

type ReloadSchemaRequest struct {
	// wait_position allows scheduling a schema reload to occur after a
	// given DDL has replicated to this server, by specifying a replication
	// position to wait for. Leave empty to trigger the reload immediately.
	WaitPosition         string   `protobuf:"bytes,1,opt,name=wait_position,json=waitPosition,proto3" json:"wait_position,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReloadSchemaRequest) Descriptor 

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

func (*ReloadSchemaRequest) GetWaitPosition 

func (m *ReloadSchemaRequest) GetWaitPosition() string

func (*ReloadSchemaRequest) Marshal added in v0.10.0 

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

func (*ReloadSchemaRequest) MarshalTo added in v0.10.0 

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

func (*ReloadSchemaRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*ReloadSchemaRequest) ProtoMessage 

func (*ReloadSchemaRequest) ProtoMessage()

func (*ReloadSchemaRequest) Reset 

func (m *ReloadSchemaRequest) Reset()

func (*ReloadSchemaRequest) Size added in v0.10.0 

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

func (*ReloadSchemaRequest) String 

func (m *ReloadSchemaRequest) String() string

func (*ReloadSchemaRequest) Unmarshal added in v0.10.0 

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

func (*ReloadSchemaRequest) XXX_DiscardUnknown 

func (m *ReloadSchemaRequest) XXX_DiscardUnknown()

func (*ReloadSchemaRequest) XXX_Marshal 

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

func (*ReloadSchemaRequest) XXX_Merge 

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

func (*ReloadSchemaRequest) XXX_Size 

func (m *ReloadSchemaRequest) XXX_Size() int

func (*ReloadSchemaRequest) XXX_Unmarshal 

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

type ReloadSchemaResponse 

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

func (*ReloadSchemaResponse) Descriptor 

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

func (*ReloadSchemaResponse) Marshal added in v0.10.0 

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

func (*ReloadSchemaResponse) MarshalTo added in v0.10.0 

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

func (*ReloadSchemaResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*ReloadSchemaResponse) ProtoMessage 

func (*ReloadSchemaResponse) ProtoMessage()

func (*ReloadSchemaResponse) Reset 

func (m *ReloadSchemaResponse) Reset()

func (*ReloadSchemaResponse) Size added in v0.10.0 

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

func (*ReloadSchemaResponse) String 

func (m *ReloadSchemaResponse) String() string

func (*ReloadSchemaResponse) Unmarshal added in v0.10.0 

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

func (*ReloadSchemaResponse) XXX_DiscardUnknown 

func (m *ReloadSchemaResponse) XXX_DiscardUnknown()

func (*ReloadSchemaResponse) XXX_Marshal 

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

func (*ReloadSchemaResponse) XXX_Merge 

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

func (*ReloadSchemaResponse) XXX_Size 

func (m *ReloadSchemaResponse) XXX_Size() int

func (*ReloadSchemaResponse) XXX_Unmarshal 

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

type ReplicaWasPromotedRequest 

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

func (*ReplicaWasPromotedRequest) Descriptor 

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

func (*ReplicaWasPromotedRequest) Marshal added in v0.10.0 

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

func (*ReplicaWasPromotedRequest) MarshalTo added in v0.10.0 

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

func (*ReplicaWasPromotedRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*ReplicaWasPromotedRequest) ProtoMessage 

func (*ReplicaWasPromotedRequest) ProtoMessage()

func (*ReplicaWasPromotedRequest) Reset 

func (m *ReplicaWasPromotedRequest) Reset()

func (*ReplicaWasPromotedRequest) Size added in v0.10.0 

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

func (*ReplicaWasPromotedRequest) String 

func (m *ReplicaWasPromotedRequest) String() string

func (*ReplicaWasPromotedRequest) Unmarshal added in v0.10.0 

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

func (*ReplicaWasPromotedRequest) XXX_DiscardUnknown 

func (m *ReplicaWasPromotedRequest) XXX_DiscardUnknown()

func (*ReplicaWasPromotedRequest) XXX_Marshal 

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

func (*ReplicaWasPromotedRequest) XXX_Merge 

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

func (*ReplicaWasPromotedRequest) XXX_Size 

func (m *ReplicaWasPromotedRequest) XXX_Size() int

func (*ReplicaWasPromotedRequest) XXX_Unmarshal 

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

type ReplicaWasPromotedResponse 

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

func (*ReplicaWasPromotedResponse) Descriptor 

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

func (*ReplicaWasPromotedResponse) Marshal added in v0.10.0 

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

func (*ReplicaWasPromotedResponse) MarshalTo added in v0.10.0 

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

func (*ReplicaWasPromotedResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*ReplicaWasPromotedResponse) ProtoMessage 

func (*ReplicaWasPromotedResponse) ProtoMessage()

func (*ReplicaWasPromotedResponse) Reset 

func (m *ReplicaWasPromotedResponse) Reset()

func (*ReplicaWasPromotedResponse) Size added in v0.10.0 

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

func (*ReplicaWasPromotedResponse) String 

func (m *ReplicaWasPromotedResponse) String() string

func (*ReplicaWasPromotedResponse) Unmarshal added in v0.10.0 

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

func (*ReplicaWasPromotedResponse) XXX_DiscardUnknown 

func (m *ReplicaWasPromotedResponse) XXX_DiscardUnknown()

func (*ReplicaWasPromotedResponse) XXX_Marshal 

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

func (*ReplicaWasPromotedResponse) XXX_Merge 

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

func (*ReplicaWasPromotedResponse) XXX_Size 

func (m *ReplicaWasPromotedResponse) XXX_Size() int

func (*ReplicaWasPromotedResponse) XXX_Unmarshal 

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

type ReplicaWasRestartedRequest 

type ReplicaWasRestartedRequest struct {
	// the parent alias the tablet should have
	Parent               *topodata.TabletAlias `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*ReplicaWasRestartedRequest) Descriptor 

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

func (*ReplicaWasRestartedRequest) GetParent 

func (m *ReplicaWasRestartedRequest) GetParent() *topodata.TabletAlias

func (*ReplicaWasRestartedRequest) Marshal added in v0.10.0 

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

func (*ReplicaWasRestartedRequest) MarshalTo added in v0.10.0 

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

func (*ReplicaWasRestartedRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*ReplicaWasRestartedRequest) ProtoMessage 

func (*ReplicaWasRestartedRequest) ProtoMessage()

func (*ReplicaWasRestartedRequest) Reset 

func (m *ReplicaWasRestartedRequest) Reset()

func (*ReplicaWasRestartedRequest) Size added in v0.10.0 

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

func (*ReplicaWasRestartedRequest) String 

func (m *ReplicaWasRestartedRequest) String() string

func (*ReplicaWasRestartedRequest) Unmarshal added in v0.10.0 

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

func (*ReplicaWasRestartedRequest) XXX_DiscardUnknown 

func (m *ReplicaWasRestartedRequest) XXX_DiscardUnknown()

func (*ReplicaWasRestartedRequest) XXX_Marshal 

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

func (*ReplicaWasRestartedRequest) XXX_Merge 

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

func (*ReplicaWasRestartedRequest) XXX_Size 

func (m *ReplicaWasRestartedRequest) XXX_Size() int

func (*ReplicaWasRestartedRequest) XXX_Unmarshal 

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

type ReplicaWasRestartedResponse 

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

func (*ReplicaWasRestartedResponse) Descriptor 

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

func (*ReplicaWasRestartedResponse) Marshal added in v0.10.0 

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

func (*ReplicaWasRestartedResponse) MarshalTo added in v0.10.0 

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

func (*ReplicaWasRestartedResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*ReplicaWasRestartedResponse) ProtoMessage 

func (*ReplicaWasRestartedResponse) ProtoMessage()

func (*ReplicaWasRestartedResponse) Reset 

func (m *ReplicaWasRestartedResponse) Reset()

func (*ReplicaWasRestartedResponse) Size added in v0.10.0 

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

func (*ReplicaWasRestartedResponse) String 

func (m *ReplicaWasRestartedResponse) String() string

func (*ReplicaWasRestartedResponse) Unmarshal added in v0.10.0 

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

func (*ReplicaWasRestartedResponse) XXX_DiscardUnknown 

func (m *ReplicaWasRestartedResponse) XXX_DiscardUnknown()

func (*ReplicaWasRestartedResponse) XXX_Marshal 

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

func (*ReplicaWasRestartedResponse) XXX_Merge 

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

func (*ReplicaWasRestartedResponse) XXX_Size 

func (m *ReplicaWasRestartedResponse) XXX_Size() int

func (*ReplicaWasRestartedResponse) XXX_Unmarshal 

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

type ReplicationStatusRequest 

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

func (*ReplicationStatusRequest) Descriptor 

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

func (*ReplicationStatusRequest) Marshal added in v0.10.0 

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

func (*ReplicationStatusRequest) MarshalTo added in v0.10.0 

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

func (*ReplicationStatusRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*ReplicationStatusRequest) ProtoMessage 

func (*ReplicationStatusRequest) ProtoMessage()

func (*ReplicationStatusRequest) Reset 

func (m *ReplicationStatusRequest) Reset()

func (*ReplicationStatusRequest) Size added in v0.10.0 

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

func (*ReplicationStatusRequest) String 

func (m *ReplicationStatusRequest) String() string

func (*ReplicationStatusRequest) Unmarshal added in v0.10.0 

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

func (*ReplicationStatusRequest) XXX_DiscardUnknown 

func (m *ReplicationStatusRequest) XXX_DiscardUnknown()

func (*ReplicationStatusRequest) XXX_Marshal 

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

func (*ReplicationStatusRequest) XXX_Merge 

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

func (*ReplicationStatusRequest) XXX_Size 

func (m *ReplicationStatusRequest) XXX_Size() int

func (*ReplicationStatusRequest) XXX_Unmarshal 

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

type ReplicationStatusResponse 

type ReplicationStatusResponse struct {
	Status               *replicationdata.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*ReplicationStatusResponse) Descriptor 

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

func (*ReplicationStatusResponse) GetStatus 

func (m *ReplicationStatusResponse) GetStatus() *replicationdata.Status

func (*ReplicationStatusResponse) Marshal added in v0.10.0 

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

func (*ReplicationStatusResponse) MarshalTo added in v0.10.0 

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

func (*ReplicationStatusResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*ReplicationStatusResponse) ProtoMessage 

func (*ReplicationStatusResponse) ProtoMessage()

func (*ReplicationStatusResponse) Reset 

func (m *ReplicationStatusResponse) Reset()

func (*ReplicationStatusResponse) Size added in v0.10.0 

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

func (*ReplicationStatusResponse) String 

func (m *ReplicationStatusResponse) String() string

func (*ReplicationStatusResponse) Unmarshal added in v0.10.0 

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

func (*ReplicationStatusResponse) XXX_DiscardUnknown 

func (m *ReplicationStatusResponse) XXX_DiscardUnknown()

func (*ReplicationStatusResponse) XXX_Marshal 

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

func (*ReplicationStatusResponse) XXX_Merge 

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

func (*ReplicationStatusResponse) XXX_Size 

func (m *ReplicationStatusResponse) XXX_Size() int

func (*ReplicationStatusResponse) XXX_Unmarshal 

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

type ResetReplicationRequest 

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

func (*ResetReplicationRequest) Descriptor 

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

func (*ResetReplicationRequest) Marshal added in v0.10.0 

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

func (*ResetReplicationRequest) MarshalTo added in v0.10.0 

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

func (*ResetReplicationRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*ResetReplicationRequest) ProtoMessage 

func (*ResetReplicationRequest) ProtoMessage()

func (*ResetReplicationRequest) Reset 

func (m *ResetReplicationRequest) Reset()

func (*ResetReplicationRequest) Size added in v0.10.0 

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

func (*ResetReplicationRequest) String 

func (m *ResetReplicationRequest) String() string

func (*ResetReplicationRequest) Unmarshal added in v0.10.0 

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

func (*ResetReplicationRequest) XXX_DiscardUnknown 

func (m *ResetReplicationRequest) XXX_DiscardUnknown()

func (*ResetReplicationRequest) XXX_Marshal 

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

func (*ResetReplicationRequest) XXX_Merge 

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

func (*ResetReplicationRequest) XXX_Size 

func (m *ResetReplicationRequest) XXX_Size() int

func (*ResetReplicationRequest) XXX_Unmarshal 

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

type ResetReplicationResponse 

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

func (*ResetReplicationResponse) Descriptor 

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

func (*ResetReplicationResponse) Marshal added in v0.10.0 

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

func (*ResetReplicationResponse) MarshalTo added in v0.10.0 

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

func (*ResetReplicationResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*ResetReplicationResponse) ProtoMessage 

func (*ResetReplicationResponse) ProtoMessage()

func (*ResetReplicationResponse) Reset 

func (m *ResetReplicationResponse) Reset()

func (*ResetReplicationResponse) Size added in v0.10.0 

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

func (*ResetReplicationResponse) String 

func (m *ResetReplicationResponse) String() string

func (*ResetReplicationResponse) Unmarshal added in v0.10.0 

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

func (*ResetReplicationResponse) XXX_DiscardUnknown 

func (m *ResetReplicationResponse) XXX_DiscardUnknown()

func (*ResetReplicationResponse) XXX_Marshal 

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

func (*ResetReplicationResponse) XXX_Merge 

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

func (*ResetReplicationResponse) XXX_Size 

func (m *ResetReplicationResponse) XXX_Size() int

func (*ResetReplicationResponse) XXX_Unmarshal 

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

type RestoreFromBackupRequest 

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

func (*RestoreFromBackupRequest) Descriptor 

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

func (*RestoreFromBackupRequest) Marshal added in v0.10.0 

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

func (*RestoreFromBackupRequest) MarshalTo added in v0.10.0 

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

func (*RestoreFromBackupRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*RestoreFromBackupRequest) ProtoMessage 

func (*RestoreFromBackupRequest) ProtoMessage()

func (*RestoreFromBackupRequest) Reset 

func (m *RestoreFromBackupRequest) Reset()

func (*RestoreFromBackupRequest) Size added in v0.10.0 

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

func (*RestoreFromBackupRequest) String 

func (m *RestoreFromBackupRequest) String() string

func (*RestoreFromBackupRequest) Unmarshal added in v0.10.0 

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

func (*RestoreFromBackupRequest) XXX_DiscardUnknown 

func (m *RestoreFromBackupRequest) XXX_DiscardUnknown()

func (*RestoreFromBackupRequest) XXX_Marshal 

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

func (*RestoreFromBackupRequest) XXX_Merge 

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

func (*RestoreFromBackupRequest) XXX_Size 

func (m *RestoreFromBackupRequest) XXX_Size() int

func (*RestoreFromBackupRequest) XXX_Unmarshal 

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

type RestoreFromBackupResponse 

type RestoreFromBackupResponse 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:"-"`
}

func (*RestoreFromBackupResponse) Descriptor 

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

func (*RestoreFromBackupResponse) GetEvent 

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

func (*RestoreFromBackupResponse) Marshal added in v0.10.0 

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

func (*RestoreFromBackupResponse) MarshalTo added in v0.10.0 

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

func (*RestoreFromBackupResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*RestoreFromBackupResponse) ProtoMessage 

func (*RestoreFromBackupResponse) ProtoMessage()

func (*RestoreFromBackupResponse) Reset 

func (m *RestoreFromBackupResponse) Reset()

func (*RestoreFromBackupResponse) Size added in v0.10.0 

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

func (*RestoreFromBackupResponse) String 

func (m *RestoreFromBackupResponse) String() string

func (*RestoreFromBackupResponse) Unmarshal added in v0.10.0 

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

func (*RestoreFromBackupResponse) XXX_DiscardUnknown 

func (m *RestoreFromBackupResponse) XXX_DiscardUnknown()

func (*RestoreFromBackupResponse) XXX_Marshal 

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

func (*RestoreFromBackupResponse) XXX_Merge 

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

func (*RestoreFromBackupResponse) XXX_Size 

func (m *RestoreFromBackupResponse) XXX_Size() int

func (*RestoreFromBackupResponse) XXX_Unmarshal 

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

type RunHealthCheckRequest 

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

func (*RunHealthCheckRequest) Descriptor 

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

func (*RunHealthCheckRequest) Marshal added in v0.10.0 

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

func (*RunHealthCheckRequest) MarshalTo added in v0.10.0 

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

func (*RunHealthCheckRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*RunHealthCheckRequest) ProtoMessage 

func (*RunHealthCheckRequest) ProtoMessage()

func (*RunHealthCheckRequest) Reset 

func (m *RunHealthCheckRequest) Reset()

func (*RunHealthCheckRequest) Size added in v0.10.0 

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

func (*RunHealthCheckRequest) String 

func (m *RunHealthCheckRequest) String() string

func (*RunHealthCheckRequest) Unmarshal added in v0.10.0 

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

func (*RunHealthCheckRequest) XXX_DiscardUnknown 

func (m *RunHealthCheckRequest) XXX_DiscardUnknown()

func (*RunHealthCheckRequest) XXX_Marshal 

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

func (*RunHealthCheckRequest) XXX_Merge 

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

func (*RunHealthCheckRequest) XXX_Size 

func (m *RunHealthCheckRequest) XXX_Size() int

func (*RunHealthCheckRequest) XXX_Unmarshal 

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

type RunHealthCheckResponse 

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

func (*RunHealthCheckResponse) Descriptor 

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

func (*RunHealthCheckResponse) Marshal added in v0.10.0 

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

func (*RunHealthCheckResponse) MarshalTo added in v0.10.0 

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

func (*RunHealthCheckResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*RunHealthCheckResponse) ProtoMessage 

func (*RunHealthCheckResponse) ProtoMessage()

func (*RunHealthCheckResponse) Reset 

func (m *RunHealthCheckResponse) Reset()

func (*RunHealthCheckResponse) Size added in v0.10.0 

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

func (*RunHealthCheckResponse) String 

func (m *RunHealthCheckResponse) String() string

func (*RunHealthCheckResponse) Unmarshal added in v0.10.0 

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

func (*RunHealthCheckResponse) XXX_DiscardUnknown 

func (m *RunHealthCheckResponse) XXX_DiscardUnknown()

func (*RunHealthCheckResponse) XXX_Marshal 

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

func (*RunHealthCheckResponse) XXX_Merge 

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

func (*RunHealthCheckResponse) XXX_Size 

func (m *RunHealthCheckResponse) XXX_Size() int

func (*RunHealthCheckResponse) XXX_Unmarshal 

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

type SchemaChangeResult 

type SchemaChangeResult struct {
	// before_schema holds the schema before each change.
	BeforeSchema *SchemaDefinition `protobuf:"bytes,1,opt,name=before_schema,json=beforeSchema,proto3" json:"before_schema,omitempty"`
	// after_schema holds the schema after each change.
	AfterSchema          *SchemaDefinition `protobuf:"bytes,2,opt,name=after_schema,json=afterSchema,proto3" json:"after_schema,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*SchemaChangeResult) Descriptor 

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

func (*SchemaChangeResult) GetAfterSchema 

func (m *SchemaChangeResult) GetAfterSchema() *SchemaDefinition

func (*SchemaChangeResult) GetBeforeSchema 

func (m *SchemaChangeResult) GetBeforeSchema() *SchemaDefinition

func (*SchemaChangeResult) Marshal added in v0.10.0 

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

func (*SchemaChangeResult) MarshalTo added in v0.10.0 

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

func (*SchemaChangeResult) MarshalToSizedBuffer added in v0.10.0 

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

func (*SchemaChangeResult) ProtoMessage 

func (*SchemaChangeResult) ProtoMessage()

func (*SchemaChangeResult) Reset 

func (m *SchemaChangeResult) Reset()

func (*SchemaChangeResult) Size added in v0.10.0 

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

func (*SchemaChangeResult) String 

func (m *SchemaChangeResult) String() string

func (*SchemaChangeResult) Unmarshal added in v0.10.0 

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

func (*SchemaChangeResult) XXX_DiscardUnknown 

func (m *SchemaChangeResult) XXX_DiscardUnknown()

func (*SchemaChangeResult) XXX_Marshal 

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

func (*SchemaChangeResult) XXX_Merge 

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

func (*SchemaChangeResult) XXX_Size 

func (m *SchemaChangeResult) XXX_Size() int

func (*SchemaChangeResult) XXX_Unmarshal 

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

type SchemaDefinition 

type SchemaDefinition struct {
	DatabaseSchema       string             `protobuf:"bytes,1,opt,name=database_schema,json=databaseSchema,proto3" json:"database_schema,omitempty"`
	TableDefinitions     []*TableDefinition `protobuf:"bytes,2,rep,name=table_definitions,json=tableDefinitions,proto3" json:"table_definitions,omitempty"`
	Version              string             `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*SchemaDefinition) Descriptor 

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

func (*SchemaDefinition) GetDatabaseSchema 

func (m *SchemaDefinition) GetDatabaseSchema() string

func (*SchemaDefinition) GetTableDefinitions 

func (m *SchemaDefinition) GetTableDefinitions() []*TableDefinition

func (*SchemaDefinition) GetVersion 

func (m *SchemaDefinition) GetVersion() string

func (*SchemaDefinition) Marshal added in v0.10.0 

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

func (*SchemaDefinition) MarshalTo added in v0.10.0 

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

func (*SchemaDefinition) MarshalToSizedBuffer added in v0.10.0 

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

func (*SchemaDefinition) ProtoMessage 

func (*SchemaDefinition) ProtoMessage()

func (*SchemaDefinition) Reset 

func (m *SchemaDefinition) Reset()

func (*SchemaDefinition) Size added in v0.10.0 

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

func (*SchemaDefinition) String 

func (m *SchemaDefinition) String() string

func (*SchemaDefinition) Unmarshal added in v0.10.0 

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

func (*SchemaDefinition) XXX_DiscardUnknown 

func (m *SchemaDefinition) XXX_DiscardUnknown()

func (*SchemaDefinition) XXX_Marshal 

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

func (*SchemaDefinition) XXX_Merge 

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

func (*SchemaDefinition) XXX_Size 

func (m *SchemaDefinition) XXX_Size() int

func (*SchemaDefinition) XXX_Unmarshal 

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

type SetMasterRequest 

type SetMasterRequest struct {
	Parent                *topodata.TabletAlias `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	TimeCreatedNs         int64                 `protobuf:"varint,2,opt,name=time_created_ns,json=timeCreatedNs,proto3" json:"time_created_ns,omitempty"`
	ForceStartReplication bool                  `` /* 127-byte string literal not displayed */
	WaitPosition          string                `protobuf:"bytes,4,opt,name=wait_position,json=waitPosition,proto3" json:"wait_position,omitempty"`
	XXX_NoUnkeyedLiteral  struct{}              `json:"-"`
	XXX_unrecognized      []byte                `json:"-"`
	XXX_sizecache         int32                 `json:"-"`
}

func (*SetMasterRequest) Descriptor 

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

func (*SetMasterRequest) GetForceStartReplication 

func (m *SetMasterRequest) GetForceStartReplication() bool

func (*SetMasterRequest) GetParent 

func (m *SetMasterRequest) GetParent() *topodata.TabletAlias

func (*SetMasterRequest) GetTimeCreatedNs 

func (m *SetMasterRequest) GetTimeCreatedNs() int64

func (*SetMasterRequest) GetWaitPosition 

func (m *SetMasterRequest) GetWaitPosition() string

func (*SetMasterRequest) Marshal added in v0.10.0 

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

func (*SetMasterRequest) MarshalTo added in v0.10.0 

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

func (*SetMasterRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*SetMasterRequest) ProtoMessage 

func (*SetMasterRequest) ProtoMessage()

func (*SetMasterRequest) Reset 

func (m *SetMasterRequest) Reset()

func (*SetMasterRequest) Size added in v0.10.0 

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

func (*SetMasterRequest) String 

func (m *SetMasterRequest) String() string

func (*SetMasterRequest) Unmarshal added in v0.10.0 

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

func (*SetMasterRequest) XXX_DiscardUnknown 

func (m *SetMasterRequest) XXX_DiscardUnknown()

func (*SetMasterRequest) XXX_Marshal 

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

func (*SetMasterRequest) XXX_Merge 

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

func (*SetMasterRequest) XXX_Size 

func (m *SetMasterRequest) XXX_Size() int

func (*SetMasterRequest) XXX_Unmarshal 

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

type SetMasterResponse 

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

func (*SetMasterResponse) Descriptor 

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

func (*SetMasterResponse) Marshal added in v0.10.0 

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

func (*SetMasterResponse) MarshalTo added in v0.10.0 

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

func (*SetMasterResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*SetMasterResponse) ProtoMessage 

func (*SetMasterResponse) ProtoMessage()

func (*SetMasterResponse) Reset 

func (m *SetMasterResponse) Reset()

func (*SetMasterResponse) Size added in v0.10.0 

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

func (*SetMasterResponse) String 

func (m *SetMasterResponse) String() string

func (*SetMasterResponse) Unmarshal added in v0.10.0 

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

func (*SetMasterResponse) XXX_DiscardUnknown 

func (m *SetMasterResponse) XXX_DiscardUnknown()

func (*SetMasterResponse) XXX_Marshal 

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

func (*SetMasterResponse) XXX_Merge 

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

func (*SetMasterResponse) XXX_Size 

func (m *SetMasterResponse) XXX_Size() int

func (*SetMasterResponse) XXX_Unmarshal 

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

type SetReadOnlyRequest 

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

func (*SetReadOnlyRequest) Descriptor 

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

func (*SetReadOnlyRequest) Marshal added in v0.10.0 

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

func (*SetReadOnlyRequest) MarshalTo added in v0.10.0 

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

func (*SetReadOnlyRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*SetReadOnlyRequest) ProtoMessage 

func (*SetReadOnlyRequest) ProtoMessage()

func (*SetReadOnlyRequest) Reset 

func (m *SetReadOnlyRequest) Reset()

func (*SetReadOnlyRequest) Size added in v0.10.0 

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

func (*SetReadOnlyRequest) String 

func (m *SetReadOnlyRequest) String() string

func (*SetReadOnlyRequest) Unmarshal added in v0.10.0 

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

func (*SetReadOnlyRequest) XXX_DiscardUnknown 

func (m *SetReadOnlyRequest) XXX_DiscardUnknown()

func (*SetReadOnlyRequest) XXX_Marshal 

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

func (*SetReadOnlyRequest) XXX_Merge 

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

func (*SetReadOnlyRequest) XXX_Size 

func (m *SetReadOnlyRequest) XXX_Size() int

func (*SetReadOnlyRequest) XXX_Unmarshal 

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

type SetReadOnlyResponse 

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

func (*SetReadOnlyResponse) Descriptor 

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

func (*SetReadOnlyResponse) Marshal added in v0.10.0 

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

func (*SetReadOnlyResponse) MarshalTo added in v0.10.0 

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

func (*SetReadOnlyResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*SetReadOnlyResponse) ProtoMessage 

func (*SetReadOnlyResponse) ProtoMessage()

func (*SetReadOnlyResponse) Reset 

func (m *SetReadOnlyResponse) Reset()

func (*SetReadOnlyResponse) Size added in v0.10.0 

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

func (*SetReadOnlyResponse) String 

func (m *SetReadOnlyResponse) String() string

func (*SetReadOnlyResponse) Unmarshal added in v0.10.0 

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

func (*SetReadOnlyResponse) XXX_DiscardUnknown 

func (m *SetReadOnlyResponse) XXX_DiscardUnknown()

func (*SetReadOnlyResponse) XXX_Marshal 

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

func (*SetReadOnlyResponse) XXX_Merge 

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

func (*SetReadOnlyResponse) XXX_Size 

func (m *SetReadOnlyResponse) XXX_Size() int

func (*SetReadOnlyResponse) XXX_Unmarshal 

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

type SetReadWriteRequest 

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

func (*SetReadWriteRequest) Descriptor 

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

func (*SetReadWriteRequest) Marshal added in v0.10.0 

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

func (*SetReadWriteRequest) MarshalTo added in v0.10.0 

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

func (*SetReadWriteRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*SetReadWriteRequest) ProtoMessage 

func (*SetReadWriteRequest) ProtoMessage()

func (*SetReadWriteRequest) Reset 

func (m *SetReadWriteRequest) Reset()

func (*SetReadWriteRequest) Size added in v0.10.0 

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

func (*SetReadWriteRequest) String 

func (m *SetReadWriteRequest) String() string

func (*SetReadWriteRequest) Unmarshal added in v0.10.0 

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

func (*SetReadWriteRequest) XXX_DiscardUnknown 

func (m *SetReadWriteRequest) XXX_DiscardUnknown()

func (*SetReadWriteRequest) XXX_Marshal 

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

func (*SetReadWriteRequest) XXX_Merge 

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

func (*SetReadWriteRequest) XXX_Size 

func (m *SetReadWriteRequest) XXX_Size() int

func (*SetReadWriteRequest) XXX_Unmarshal 

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

type SetReadWriteResponse 

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

func (*SetReadWriteResponse) Descriptor 

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

func (*SetReadWriteResponse) Marshal added in v0.10.0 

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

func (*SetReadWriteResponse) MarshalTo added in v0.10.0 

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

func (*SetReadWriteResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*SetReadWriteResponse) ProtoMessage 

func (*SetReadWriteResponse) ProtoMessage()

func (*SetReadWriteResponse) Reset 

func (m *SetReadWriteResponse) Reset()

func (*SetReadWriteResponse) Size added in v0.10.0 

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

func (*SetReadWriteResponse) String 

func (m *SetReadWriteResponse) String() string

func (*SetReadWriteResponse) Unmarshal added in v0.10.0 

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

func (*SetReadWriteResponse) XXX_DiscardUnknown 

func (m *SetReadWriteResponse) XXX_DiscardUnknown()

func (*SetReadWriteResponse) XXX_Marshal 

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

func (*SetReadWriteResponse) XXX_Merge 

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

func (*SetReadWriteResponse) XXX_Size 

func (m *SetReadWriteResponse) XXX_Size() int

func (*SetReadWriteResponse) XXX_Unmarshal 

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

type SleepRequest 

type SleepRequest struct {
	// duration is in nanoseconds
	Duration             int64    `protobuf:"varint,1,opt,name=duration,proto3" json:"duration,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SleepRequest) Descriptor 

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

func (*SleepRequest) GetDuration 

func (m *SleepRequest) GetDuration() int64

func (*SleepRequest) Marshal added in v0.10.0 

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

func (*SleepRequest) MarshalTo added in v0.10.0 

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

func (*SleepRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*SleepRequest) ProtoMessage 

func (*SleepRequest) ProtoMessage()

func (*SleepRequest) Reset 

func (m *SleepRequest) Reset()

func (*SleepRequest) Size added in v0.10.0 

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

func (*SleepRequest) String 

func (m *SleepRequest) String() string

func (*SleepRequest) Unmarshal added in v0.10.0 

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

func (*SleepRequest) XXX_DiscardUnknown 

func (m *SleepRequest) XXX_DiscardUnknown()

func (*SleepRequest) XXX_Marshal 

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

func (*SleepRequest) XXX_Merge 

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

func (*SleepRequest) XXX_Size 

func (m *SleepRequest) XXX_Size() int

func (*SleepRequest) XXX_Unmarshal 

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

type SleepResponse 

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

func (*SleepResponse) Descriptor 

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

func (*SleepResponse) Marshal added in v0.10.0 

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

func (*SleepResponse) MarshalTo added in v0.10.0 

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

func (*SleepResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*SleepResponse) ProtoMessage 

func (*SleepResponse) ProtoMessage()

func (*SleepResponse) Reset 

func (m *SleepResponse) Reset()

func (*SleepResponse) Size added in v0.10.0 

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

func (*SleepResponse) String 

func (m *SleepResponse) String() string

func (*SleepResponse) Unmarshal added in v0.10.0 

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

func (*SleepResponse) XXX_DiscardUnknown 

func (m *SleepResponse) XXX_DiscardUnknown()

func (*SleepResponse) XXX_Marshal 

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

func (*SleepResponse) XXX_Merge 

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

func (*SleepResponse) XXX_Size 

func (m *SleepResponse) XXX_Size() int

func (*SleepResponse) XXX_Unmarshal 

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

type StartReplicationRequest 

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

func (*StartReplicationRequest) Descriptor 

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

func (*StartReplicationRequest) Marshal added in v0.10.0 

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

func (*StartReplicationRequest) MarshalTo added in v0.10.0 

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

func (*StartReplicationRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*StartReplicationRequest) ProtoMessage 

func (*StartReplicationRequest) ProtoMessage()

func (*StartReplicationRequest) Reset 

func (m *StartReplicationRequest) Reset()

func (*StartReplicationRequest) Size added in v0.10.0 

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

func (*StartReplicationRequest) String 

func (m *StartReplicationRequest) String() string

func (*StartReplicationRequest) Unmarshal added in v0.10.0 

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

func (*StartReplicationRequest) XXX_DiscardUnknown 

func (m *StartReplicationRequest) XXX_DiscardUnknown()

func (*StartReplicationRequest) XXX_Marshal 

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

func (*StartReplicationRequest) XXX_Merge 

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

func (*StartReplicationRequest) XXX_Size 

func (m *StartReplicationRequest) XXX_Size() int

func (*StartReplicationRequest) XXX_Unmarshal 

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

type StartReplicationResponse 

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

func (*StartReplicationResponse) Descriptor 

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

func (*StartReplicationResponse) Marshal added in v0.10.0 

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

func (*StartReplicationResponse) MarshalTo added in v0.10.0 

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

func (*StartReplicationResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*StartReplicationResponse) ProtoMessage 

func (*StartReplicationResponse) ProtoMessage()

func (*StartReplicationResponse) Reset 

func (m *StartReplicationResponse) Reset()

func (*StartReplicationResponse) Size added in v0.10.0 

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

func (*StartReplicationResponse) String 

func (m *StartReplicationResponse) String() string

func (*StartReplicationResponse) Unmarshal added in v0.10.0 

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

func (*StartReplicationResponse) XXX_DiscardUnknown 

func (m *StartReplicationResponse) XXX_DiscardUnknown()

func (*StartReplicationResponse) XXX_Marshal 

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

func (*StartReplicationResponse) XXX_Merge 

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

func (*StartReplicationResponse) XXX_Size 

func (m *StartReplicationResponse) XXX_Size() int

func (*StartReplicationResponse) XXX_Unmarshal 

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

type StartReplicationUntilAfterRequest 

type StartReplicationUntilAfterRequest struct {
	Position             string   `protobuf:"bytes,1,opt,name=position,proto3" json:"position,omitempty"`
	WaitTimeout          int64    `protobuf:"varint,2,opt,name=wait_timeout,json=waitTimeout,proto3" json:"wait_timeout,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StartReplicationUntilAfterRequest) Descriptor 

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

func (*StartReplicationUntilAfterRequest) GetPosition 

func (m *StartReplicationUntilAfterRequest) GetPosition() string

func (*StartReplicationUntilAfterRequest) GetWaitTimeout 

func (m *StartReplicationUntilAfterRequest) GetWaitTimeout() int64

func (*StartReplicationUntilAfterRequest) Marshal added in v0.10.0 

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

func (*StartReplicationUntilAfterRequest) MarshalTo added in v0.10.0 

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

func (*StartReplicationUntilAfterRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*StartReplicationUntilAfterRequest) ProtoMessage 

func (*StartReplicationUntilAfterRequest) ProtoMessage()

func (*StartReplicationUntilAfterRequest) Reset 

func (m *StartReplicationUntilAfterRequest) Reset()

func (*StartReplicationUntilAfterRequest) Size added in v0.10.0 

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

func (*StartReplicationUntilAfterRequest) String 

func (m *StartReplicationUntilAfterRequest) String() string

func (*StartReplicationUntilAfterRequest) Unmarshal added in v0.10.0 

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

func (*StartReplicationUntilAfterRequest) XXX_DiscardUnknown 

func (m *StartReplicationUntilAfterRequest) XXX_DiscardUnknown()

func (*StartReplicationUntilAfterRequest) XXX_Marshal 

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

func (*StartReplicationUntilAfterRequest) XXX_Merge 

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

func (*StartReplicationUntilAfterRequest) XXX_Size 

func (m *StartReplicationUntilAfterRequest) XXX_Size() int

func (*StartReplicationUntilAfterRequest) XXX_Unmarshal 

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

type StartReplicationUntilAfterResponse 

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

func (*StartReplicationUntilAfterResponse) Descriptor 

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

func (*StartReplicationUntilAfterResponse) Marshal added in v0.10.0 

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

func (*StartReplicationUntilAfterResponse) MarshalTo added in v0.10.0 

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

func (*StartReplicationUntilAfterResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*StartReplicationUntilAfterResponse) ProtoMessage 

func (*StartReplicationUntilAfterResponse) ProtoMessage()

func (*StartReplicationUntilAfterResponse) Reset 

func (m *StartReplicationUntilAfterResponse) Reset()

func (*StartReplicationUntilAfterResponse) Size added in v0.10.0 

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

func (*StartReplicationUntilAfterResponse) String 

func (m *StartReplicationUntilAfterResponse) String() string

func (*StartReplicationUntilAfterResponse) Unmarshal added in v0.10.0 

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

func (*StartReplicationUntilAfterResponse) XXX_DiscardUnknown 

func (m *StartReplicationUntilAfterResponse) XXX_DiscardUnknown()

func (*StartReplicationUntilAfterResponse) XXX_Marshal 

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

func (*StartReplicationUntilAfterResponse) XXX_Merge 

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

func (*StartReplicationUntilAfterResponse) XXX_Size 

func (m *StartReplicationUntilAfterResponse) XXX_Size() int

func (*StartReplicationUntilAfterResponse) XXX_Unmarshal 

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

type StopReplicationAndGetStatusRequest 

type StopReplicationAndGetStatusRequest struct {
	StopReplicationMode  replicationdata.StopReplicationMode `` /* 162-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                            `json:"-"`
	XXX_unrecognized     []byte                              `json:"-"`
	XXX_sizecache        int32                               `json:"-"`
}

func (*StopReplicationAndGetStatusRequest) Descriptor 

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

func (*StopReplicationAndGetStatusRequest) GetStopReplicationMode 

func (m *StopReplicationAndGetStatusRequest) GetStopReplicationMode() replicationdata.StopReplicationMode

func (*StopReplicationAndGetStatusRequest) Marshal added in v0.10.0 

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

func (*StopReplicationAndGetStatusRequest) MarshalTo added in v0.10.0 

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

func (*StopReplicationAndGetStatusRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*StopReplicationAndGetStatusRequest) ProtoMessage 

func (*StopReplicationAndGetStatusRequest) ProtoMessage()

func (*StopReplicationAndGetStatusRequest) Reset 

func (m *StopReplicationAndGetStatusRequest) Reset()

func (*StopReplicationAndGetStatusRequest) Size added in v0.10.0 

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

func (*StopReplicationAndGetStatusRequest) String 

func (m *StopReplicationAndGetStatusRequest) String() string

func (*StopReplicationAndGetStatusRequest) Unmarshal added in v0.10.0 

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

func (*StopReplicationAndGetStatusRequest) XXX_DiscardUnknown 

func (m *StopReplicationAndGetStatusRequest) XXX_DiscardUnknown()

func (*StopReplicationAndGetStatusRequest) XXX_Marshal 

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

func (*StopReplicationAndGetStatusRequest) XXX_Merge 

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

func (*StopReplicationAndGetStatusRequest) XXX_Size 

func (m *StopReplicationAndGetStatusRequest) XXX_Size() int

func (*StopReplicationAndGetStatusRequest) XXX_Unmarshal 

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

type StopReplicationAndGetStatusResponse 

type StopReplicationAndGetStatusResponse struct {
	// HybridStatus is deprecated. It currently represents a hybrid struct where all data represents the before state,
	// except for all position related data which comes from the after state. Please use status instead, which holds
	// discrete replication status calls before and after stopping the replica, or stopping the replica's io_thread.
	HybridStatus *replicationdata.Status `protobuf:"bytes,1,opt,name=hybrid_status,json=hybridStatus,proto3" json:"hybrid_status,omitempty"` // Deprecated: Do not use.
	// Status represents the replication status call right before, and right after telling the replica to stop.
	Status               *replicationdata.StopReplicationStatus `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                               `json:"-"`
	XXX_unrecognized     []byte                                 `json:"-"`
	XXX_sizecache        int32                                  `json:"-"`
}

func (*StopReplicationAndGetStatusResponse) Descriptor 

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

func (*StopReplicationAndGetStatusResponse) GetHybridStatus deprecated 

func (m *StopReplicationAndGetStatusResponse) GetHybridStatus() *replicationdata.Status

Deprecated: Do not use.

func (*StopReplicationAndGetStatusResponse) GetStatus 

func (m *StopReplicationAndGetStatusResponse) GetStatus() *replicationdata.StopReplicationStatus

func (*StopReplicationAndGetStatusResponse) Marshal added in v0.10.0 

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

func (*StopReplicationAndGetStatusResponse) MarshalTo added in v0.10.0 

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

func (*StopReplicationAndGetStatusResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*StopReplicationAndGetStatusResponse) ProtoMessage 

func (*StopReplicationAndGetStatusResponse) ProtoMessage()

func (*StopReplicationAndGetStatusResponse) Reset 

func (m *StopReplicationAndGetStatusResponse) Reset()

func (*StopReplicationAndGetStatusResponse) Size added in v0.10.0 

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

func (*StopReplicationAndGetStatusResponse) String 

func (m *StopReplicationAndGetStatusResponse) String() string

func (*StopReplicationAndGetStatusResponse) Unmarshal added in v0.10.0 

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

func (*StopReplicationAndGetStatusResponse) XXX_DiscardUnknown 

func (m *StopReplicationAndGetStatusResponse) XXX_DiscardUnknown()

func (*StopReplicationAndGetStatusResponse) XXX_Marshal 

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

func (*StopReplicationAndGetStatusResponse) XXX_Merge 

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

func (*StopReplicationAndGetStatusResponse) XXX_Size 

func (m *StopReplicationAndGetStatusResponse) XXX_Size() int

func (*StopReplicationAndGetStatusResponse) XXX_Unmarshal 

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

type StopReplicationMinimumRequest 

type StopReplicationMinimumRequest struct {
	Position             string   `protobuf:"bytes,1,opt,name=position,proto3" json:"position,omitempty"`
	WaitTimeout          int64    `protobuf:"varint,2,opt,name=wait_timeout,json=waitTimeout,proto3" json:"wait_timeout,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StopReplicationMinimumRequest) Descriptor 

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

func (*StopReplicationMinimumRequest) GetPosition 

func (m *StopReplicationMinimumRequest) GetPosition() string

func (*StopReplicationMinimumRequest) GetWaitTimeout 

func (m *StopReplicationMinimumRequest) GetWaitTimeout() int64

func (*StopReplicationMinimumRequest) Marshal added in v0.10.0 

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

func (*StopReplicationMinimumRequest) MarshalTo added in v0.10.0 

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

func (*StopReplicationMinimumRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*StopReplicationMinimumRequest) ProtoMessage 

func (*StopReplicationMinimumRequest) ProtoMessage()

func (*StopReplicationMinimumRequest) Reset 

func (m *StopReplicationMinimumRequest) Reset()

func (*StopReplicationMinimumRequest) Size added in v0.10.0 

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

func (*StopReplicationMinimumRequest) String 

func (m *StopReplicationMinimumRequest) String() string

func (*StopReplicationMinimumRequest) Unmarshal added in v0.10.0 

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

func (*StopReplicationMinimumRequest) XXX_DiscardUnknown 

func (m *StopReplicationMinimumRequest) XXX_DiscardUnknown()

func (*StopReplicationMinimumRequest) XXX_Marshal 

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

func (*StopReplicationMinimumRequest) XXX_Merge 

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

func (*StopReplicationMinimumRequest) XXX_Size 

func (m *StopReplicationMinimumRequest) XXX_Size() int

func (*StopReplicationMinimumRequest) XXX_Unmarshal 

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

type StopReplicationMinimumResponse 

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

func (*StopReplicationMinimumResponse) Descriptor 

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

func (*StopReplicationMinimumResponse) GetPosition 

func (m *StopReplicationMinimumResponse) GetPosition() string

func (*StopReplicationMinimumResponse) Marshal added in v0.10.0 

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

func (*StopReplicationMinimumResponse) MarshalTo added in v0.10.0 

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

func (*StopReplicationMinimumResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*StopReplicationMinimumResponse) ProtoMessage 

func (*StopReplicationMinimumResponse) ProtoMessage()

func (*StopReplicationMinimumResponse) Reset 

func (m *StopReplicationMinimumResponse) Reset()

func (*StopReplicationMinimumResponse) Size added in v0.10.0 

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

func (*StopReplicationMinimumResponse) String 

func (m *StopReplicationMinimumResponse) String() string

func (*StopReplicationMinimumResponse) Unmarshal added in v0.10.0 

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

func (*StopReplicationMinimumResponse) XXX_DiscardUnknown 

func (m *StopReplicationMinimumResponse) XXX_DiscardUnknown()

func (*StopReplicationMinimumResponse) XXX_Marshal 

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

func (*StopReplicationMinimumResponse) XXX_Merge 

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

func (*StopReplicationMinimumResponse) XXX_Size 

func (m *StopReplicationMinimumResponse) XXX_Size() int

func (*StopReplicationMinimumResponse) XXX_Unmarshal 

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

type StopReplicationRequest 

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

func (*StopReplicationRequest) Descriptor 

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

func (*StopReplicationRequest) Marshal added in v0.10.0 

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

func (*StopReplicationRequest) MarshalTo added in v0.10.0 

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

func (*StopReplicationRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*StopReplicationRequest) ProtoMessage 

func (*StopReplicationRequest) ProtoMessage()

func (*StopReplicationRequest) Reset 

func (m *StopReplicationRequest) Reset()

func (*StopReplicationRequest) Size added in v0.10.0 

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

func (*StopReplicationRequest) String 

func (m *StopReplicationRequest) String() string

func (*StopReplicationRequest) Unmarshal added in v0.10.0 

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

func (*StopReplicationRequest) XXX_DiscardUnknown 

func (m *StopReplicationRequest) XXX_DiscardUnknown()

func (*StopReplicationRequest) XXX_Marshal 

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

func (*StopReplicationRequest) XXX_Merge 

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

func (*StopReplicationRequest) XXX_Size 

func (m *StopReplicationRequest) XXX_Size() int

func (*StopReplicationRequest) XXX_Unmarshal 

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

type StopReplicationResponse 

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

func (*StopReplicationResponse) Descriptor 

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

func (*StopReplicationResponse) Marshal added in v0.10.0 

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

func (*StopReplicationResponse) MarshalTo added in v0.10.0 

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

func (*StopReplicationResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*StopReplicationResponse) ProtoMessage 

func (*StopReplicationResponse) ProtoMessage()

func (*StopReplicationResponse) Reset 

func (m *StopReplicationResponse) Reset()

func (*StopReplicationResponse) Size added in v0.10.0 

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

func (*StopReplicationResponse) String 

func (m *StopReplicationResponse) String() string

func (*StopReplicationResponse) Unmarshal added in v0.10.0 

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

func (*StopReplicationResponse) XXX_DiscardUnknown 

func (m *StopReplicationResponse) XXX_DiscardUnknown()

func (*StopReplicationResponse) XXX_Marshal 

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

func (*StopReplicationResponse) XXX_Merge 

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

func (*StopReplicationResponse) XXX_Size 

func (m *StopReplicationResponse) XXX_Size() int

func (*StopReplicationResponse) XXX_Unmarshal 

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

type TableDefinition 

type TableDefinition struct {
	// the table name
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// the SQL to run to create the table
	Schema string `protobuf:"bytes,2,opt,name=schema,proto3" json:"schema,omitempty"`
	// the columns in the order that will be used to dump and load the data
	Columns []string `protobuf:"bytes,3,rep,name=columns,proto3" json:"columns,omitempty"`
	// the primary key columns in the primary key order
	PrimaryKeyColumns []string `protobuf:"bytes,4,rep,name=primary_key_columns,json=primaryKeyColumns,proto3" json:"primary_key_columns,omitempty"`
	// type is either mysqlctl.TableBaseTable or mysqlctl.TableView
	Type string `protobuf:"bytes,5,opt,name=type,proto3" json:"type,omitempty"`
	// how much space the data file takes.
	DataLength uint64 `protobuf:"varint,6,opt,name=data_length,json=dataLength,proto3" json:"data_length,omitempty"`
	// approximate number of rows
	RowCount uint64 `protobuf:"varint,7,opt,name=row_count,json=rowCount,proto3" json:"row_count,omitempty"`
	// column names along with their types.
	// NOTE: this is a superset of columns.
	Fields               []*query.Field `protobuf:"bytes,8,rep,name=fields,proto3" json:"fields,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*TableDefinition) Descriptor 

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

func (*TableDefinition) GetColumns 

func (m *TableDefinition) GetColumns() []string

func (*TableDefinition) GetDataLength 

func (m *TableDefinition) GetDataLength() uint64

func (*TableDefinition) GetFields 

func (m *TableDefinition) GetFields() []*query.Field

func (*TableDefinition) GetName 

func (m *TableDefinition) GetName() string

func (*TableDefinition) GetPrimaryKeyColumns 

func (m *TableDefinition) GetPrimaryKeyColumns() []string

func (*TableDefinition) GetRowCount 

func (m *TableDefinition) GetRowCount() uint64

func (*TableDefinition) GetSchema 

func (m *TableDefinition) GetSchema() string

func (*TableDefinition) GetType 

func (m *TableDefinition) GetType() string

func (*TableDefinition) Marshal added in v0.10.0 

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

func (*TableDefinition) MarshalTo added in v0.10.0 

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

func (*TableDefinition) MarshalToSizedBuffer added in v0.10.0 

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

func (*TableDefinition) ProtoMessage 

func (*TableDefinition) ProtoMessage()

func (*TableDefinition) Reset 

func (m *TableDefinition) Reset()

func (*TableDefinition) Size added in v0.10.0 

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

func (*TableDefinition) String 

func (m *TableDefinition) String() string

func (*TableDefinition) Unmarshal added in v0.10.0 

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

func (*TableDefinition) XXX_DiscardUnknown 

func (m *TableDefinition) XXX_DiscardUnknown()

func (*TableDefinition) XXX_Marshal 

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

func (*TableDefinition) XXX_Merge 

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

func (*TableDefinition) XXX_Size 

func (m *TableDefinition) XXX_Size() int

func (*TableDefinition) XXX_Unmarshal 

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

type UndoDemoteMasterRequest 

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

func (*UndoDemoteMasterRequest) Descriptor 

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

func (*UndoDemoteMasterRequest) Marshal added in v0.10.0 

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

func (*UndoDemoteMasterRequest) MarshalTo added in v0.10.0 

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

func (*UndoDemoteMasterRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*UndoDemoteMasterRequest) ProtoMessage 

func (*UndoDemoteMasterRequest) ProtoMessage()

func (*UndoDemoteMasterRequest) Reset 

func (m *UndoDemoteMasterRequest) Reset()

func (*UndoDemoteMasterRequest) Size added in v0.10.0 

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

func (*UndoDemoteMasterRequest) String 

func (m *UndoDemoteMasterRequest) String() string

func (*UndoDemoteMasterRequest) Unmarshal added in v0.10.0 

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

func (*UndoDemoteMasterRequest) XXX_DiscardUnknown 

func (m *UndoDemoteMasterRequest) XXX_DiscardUnknown()

func (*UndoDemoteMasterRequest) XXX_Marshal 

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

func (*UndoDemoteMasterRequest) XXX_Merge 

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

func (*UndoDemoteMasterRequest) XXX_Size 

func (m *UndoDemoteMasterRequest) XXX_Size() int

func (*UndoDemoteMasterRequest) XXX_Unmarshal 

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

type UndoDemoteMasterResponse 

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

func (*UndoDemoteMasterResponse) Descriptor 

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

func (*UndoDemoteMasterResponse) Marshal added in v0.10.0 

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

func (*UndoDemoteMasterResponse) MarshalTo added in v0.10.0 

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

func (*UndoDemoteMasterResponse) MarshalToSizedBuffer added in v0.10.0 

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

func (*UndoDemoteMasterResponse) ProtoMessage 

func (*UndoDemoteMasterResponse) ProtoMessage()

func (*UndoDemoteMasterResponse) Reset 

func (m *UndoDemoteMasterResponse) Reset()

func (*UndoDemoteMasterResponse) Size added in v0.10.0 

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

func (*UndoDemoteMasterResponse) String 

func (m *UndoDemoteMasterResponse) String() string

func (*UndoDemoteMasterResponse) Unmarshal added in v0.10.0 

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

func (*UndoDemoteMasterResponse) XXX_DiscardUnknown 

func (m *UndoDemoteMasterResponse) XXX_DiscardUnknown()

func (*UndoDemoteMasterResponse) XXX_Marshal 

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

func (*UndoDemoteMasterResponse) XXX_Merge 

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

func (*UndoDemoteMasterResponse) XXX_Size 

func (m *UndoDemoteMasterResponse) XXX_Size() int

func (*UndoDemoteMasterResponse) XXX_Unmarshal 

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

type UnlockTablesRequest 

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

func (*UnlockTablesRequest) Descriptor 

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

func (*UnlockTablesRequest) Marshal added in v0.10.0 

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

func (*UnlockTablesRequest) MarshalTo added in v0.10.0 

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

func (*UnlockTablesRequest) MarshalToSizedBuffer added in v0.10.0 

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

func (*UnlockTablesRequest) ProtoMessage 

func (*UnlockTablesRequest) ProtoMessage()

func (*UnlockTablesRequest) Reset 

func (m *UnlockTablesRequest) Reset()

func (*UnlockTablesRequest) Size added in v0.10.0 

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

func (*UnlockTablesRequest) String 

func (m *UnlockTablesRequest) String() string

func (*UnlockTablesRequest) Unmarshal added in v0.10.0 

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

func (*UnlockTablesRequest) XXX_DiscardUnknown 

func (m *UnlockTablesRequest) XXX_DiscardUnknown()

func (*UnlockTablesRequest) XXX_Marshal 

func (m *UnlockTablesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UnlockTablesRequest) XXX_Merge 

func (m *UnlockTablesRequest) XXX_Merge(src proto.Message)

func (*UnlockTablesRequest) XXX_Size 

func (m *UnlockTablesRequest) XXX_Size() int

func (*UnlockTablesRequest) XXX_Unmarshal 

func (m *UnlockTablesRequest) XXX_Unmarshal(b []byte) error

type UnlockTablesResponse 

type UnlockTablesResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UnlockTablesResponse) Descriptor 

func (*UnlockTablesResponse) Descriptor() ([]byte, []int)

func (*UnlockTablesResponse) Marshal added in v0.10.0 

func (m *UnlockTablesResponse) Marshal() (dAtA []byte, err error)

func (*UnlockTablesResponse) MarshalTo added in v0.10.0 

func (m *UnlockTablesResponse) MarshalTo(dAtA []byte) (int, error)

func (*UnlockTablesResponse) MarshalToSizedBuffer added in v0.10.0 

func (m *UnlockTablesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UnlockTablesResponse) ProtoMessage 

func (*UnlockTablesResponse) ProtoMessage()

func (*UnlockTablesResponse) Reset 

func (m *UnlockTablesResponse) Reset()

func (*UnlockTablesResponse) Size added in v0.10.0 

func (m *UnlockTablesResponse) Size() (n int)

func (*UnlockTablesResponse) String 

func (m *UnlockTablesResponse) String() string

func (*UnlockTablesResponse) Unmarshal added in v0.10.0 

func (m *UnlockTablesResponse) Unmarshal(dAtA []byte) error

func (*UnlockTablesResponse) XXX_DiscardUnknown 

func (m *UnlockTablesResponse) XXX_DiscardUnknown()

func (*UnlockTablesResponse) XXX_Marshal 

func (m *UnlockTablesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UnlockTablesResponse) XXX_Merge 

func (m *UnlockTablesResponse) XXX_Merge(src proto.Message)

func (*UnlockTablesResponse) XXX_Size 

func (m *UnlockTablesResponse) XXX_Size() int

func (*UnlockTablesResponse) XXX_Unmarshal 

func (m *UnlockTablesResponse) XXX_Unmarshal(b []byte) error

type UserPermission 

type UserPermission struct {
	Host                 string            `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	User                 string            `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"`
	PasswordChecksum     uint64            `protobuf:"varint,3,opt,name=password_checksum,json=passwordChecksum,proto3" json:"password_checksum,omitempty"`
	Privileges           map[string]string `` /* 161-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

UserPermission describes a single row in the mysql.user table Primary key is Host+User PasswordChecksum is the crc64 of the password, for security reasons

func (*UserPermission) Descriptor 

func (*UserPermission) Descriptor() ([]byte, []int)

func (*UserPermission) GetHost 

func (m *UserPermission) GetHost() string

func (*UserPermission) GetPasswordChecksum 

func (m *UserPermission) GetPasswordChecksum() uint64

func (*UserPermission) GetPrivileges 

func (m *UserPermission) GetPrivileges() map[string]string

func (*UserPermission) GetUser 

func (m *UserPermission) GetUser() string

func (*UserPermission) Marshal added in v0.10.0 

func (m *UserPermission) Marshal() (dAtA []byte, err error)

func (*UserPermission) MarshalTo added in v0.10.0 

func (m *UserPermission) MarshalTo(dAtA []byte) (int, error)

func (*UserPermission) MarshalToSizedBuffer added in v0.10.0 

func (m *UserPermission) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UserPermission) ProtoMessage 

func (*UserPermission) ProtoMessage()

func (*UserPermission) Reset 

func (m *UserPermission) Reset()

func (*UserPermission) Size added in v0.10.0 

func (m *UserPermission) Size() (n int)

func (*UserPermission) String 

func (m *UserPermission) String() string

func (*UserPermission) Unmarshal added in v0.10.0 

func (m *UserPermission) Unmarshal(dAtA []byte) error

func (*UserPermission) XXX_DiscardUnknown 

func (m *UserPermission) XXX_DiscardUnknown()

func (*UserPermission) XXX_Marshal 

func (m *UserPermission) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UserPermission) XXX_Merge 

func (m *UserPermission) XXX_Merge(src proto.Message)

func (*UserPermission) XXX_Size 

func (m *UserPermission) XXX_Size() int

func (*UserPermission) XXX_Unmarshal 

func (m *UserPermission) XXX_Unmarshal(b []byte) error

type VExecRequest added in v0.8.0 

type VExecRequest struct {
	Query                string   `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	Workflow             string   `protobuf:"bytes,2,opt,name=workflow,proto3" json:"workflow,omitempty"`
	Keyspace             string   `protobuf:"bytes,3,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*VExecRequest) Descriptor added in v0.8.0 

func (*VExecRequest) Descriptor() ([]byte, []int)

func (*VExecRequest) GetKeyspace added in v0.8.0 

func (m *VExecRequest) GetKeyspace() string

func (*VExecRequest) GetQuery added in v0.8.0 

func (m *VExecRequest) GetQuery() string

func (*VExecRequest) GetWorkflow added in v0.8.0 

func (m *VExecRequest) GetWorkflow() string

func (*VExecRequest) Marshal added in v0.10.0 

func (m *VExecRequest) Marshal() (dAtA []byte, err error)

func (*VExecRequest) MarshalTo added in v0.10.0 

func (m *VExecRequest) MarshalTo(dAtA []byte) (int, error)

func (*VExecRequest) MarshalToSizedBuffer added in v0.10.0 

func (m *VExecRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*VExecRequest) ProtoMessage added in v0.8.0 

func (*VExecRequest) ProtoMessage()

func (*VExecRequest) Reset added in v0.8.0 

func (m *VExecRequest) Reset()

func (*VExecRequest) Size added in v0.10.0 

func (m *VExecRequest) Size() (n int)

func (*VExecRequest) String added in v0.8.0 

func (m *VExecRequest) String() string

func (*VExecRequest) Unmarshal added in v0.10.0 

func (m *VExecRequest) Unmarshal(dAtA []byte) error

func (*VExecRequest) XXX_DiscardUnknown added in v0.8.0 

func (m *VExecRequest) XXX_DiscardUnknown()

func (*VExecRequest) XXX_Marshal added in v0.8.0 

func (m *VExecRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VExecRequest) XXX_Merge added in v0.8.0 

func (m *VExecRequest) XXX_Merge(src proto.Message)

func (*VExecRequest) XXX_Size added in v0.8.0 

func (m *VExecRequest) XXX_Size() int

func (*VExecRequest) XXX_Unmarshal added in v0.8.0 

func (m *VExecRequest) XXX_Unmarshal(b []byte) error

type VExecResponse added in v0.8.0 

type VExecResponse struct {
	Result               *query.QueryResult `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*VExecResponse) Descriptor added in v0.8.0 

func (*VExecResponse) Descriptor() ([]byte, []int)

func (*VExecResponse) GetResult added in v0.8.0 

func (m *VExecResponse) GetResult() *query.QueryResult

func (*VExecResponse) Marshal added in v0.10.0 

func (m *VExecResponse) Marshal() (dAtA []byte, err error)

func (*VExecResponse) MarshalTo added in v0.10.0 

func (m *VExecResponse) MarshalTo(dAtA []byte) (int, error)

func (*VExecResponse) MarshalToSizedBuffer added in v0.10.0 

func (m *VExecResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*VExecResponse) ProtoMessage added in v0.8.0 

func (*VExecResponse) ProtoMessage()

func (*VExecResponse) Reset added in v0.8.0 

func (m *VExecResponse) Reset()

func (*VExecResponse) Size added in v0.10.0 

func (m *VExecResponse) Size() (n int)

func (*VExecResponse) String added in v0.8.0 

func (m *VExecResponse) String() string

func (*VExecResponse) Unmarshal added in v0.10.0 

func (m *VExecResponse) Unmarshal(dAtA []byte) error

func (*VExecResponse) XXX_DiscardUnknown added in v0.8.0 

func (m *VExecResponse) XXX_DiscardUnknown()

func (*VExecResponse) XXX_Marshal added in v0.8.0 

func (m *VExecResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VExecResponse) XXX_Merge added in v0.8.0 

func (m *VExecResponse) XXX_Merge(src proto.Message)

func (*VExecResponse) XXX_Size added in v0.8.0 

func (m *VExecResponse) XXX_Size() int

func (*VExecResponse) XXX_Unmarshal added in v0.8.0 

func (m *VExecResponse) XXX_Unmarshal(b []byte) error

type VReplicationExecRequest 

type VReplicationExecRequest struct {
	Query                string   `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*VReplicationExecRequest) Descriptor 

func (*VReplicationExecRequest) Descriptor() ([]byte, []int)

func (*VReplicationExecRequest) GetQuery 

func (m *VReplicationExecRequest) GetQuery() string

func (*VReplicationExecRequest) Marshal added in v0.10.0 

func (m *VReplicationExecRequest) Marshal() (dAtA []byte, err error)

func (*VReplicationExecRequest) MarshalTo added in v0.10.0 

func (m *VReplicationExecRequest) MarshalTo(dAtA []byte) (int, error)

func (*VReplicationExecRequest) MarshalToSizedBuffer added in v0.10.0 

func (m *VReplicationExecRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*VReplicationExecRequest) ProtoMessage 

func (*VReplicationExecRequest) ProtoMessage()

func (*VReplicationExecRequest) Reset 

func (m *VReplicationExecRequest) Reset()

func (*VReplicationExecRequest) Size added in v0.10.0 

func (m *VReplicationExecRequest) Size() (n int)

func (*VReplicationExecRequest) String 

func (m *VReplicationExecRequest) String() string

func (*VReplicationExecRequest) Unmarshal added in v0.10.0 

func (m *VReplicationExecRequest) Unmarshal(dAtA []byte) error

func (*VReplicationExecRequest) XXX_DiscardUnknown 

func (m *VReplicationExecRequest) XXX_DiscardUnknown()

func (*VReplicationExecRequest) XXX_Marshal 

func (m *VReplicationExecRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VReplicationExecRequest) XXX_Merge 

func (m *VReplicationExecRequest) XXX_Merge(src proto.Message)

func (*VReplicationExecRequest) XXX_Size 

func (m *VReplicationExecRequest) XXX_Size() int

func (*VReplicationExecRequest) XXX_Unmarshal 

func (m *VReplicationExecRequest) XXX_Unmarshal(b []byte) error

type VReplicationExecResponse 

type VReplicationExecResponse struct {
	Result               *query.QueryResult `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*VReplicationExecResponse) Descriptor 

func (*VReplicationExecResponse) Descriptor() ([]byte, []int)

func (*VReplicationExecResponse) GetResult 

func (m *VReplicationExecResponse) GetResult() *query.QueryResult

func (*VReplicationExecResponse) Marshal added in v0.10.0 

func (m *VReplicationExecResponse) Marshal() (dAtA []byte, err error)

func (*VReplicationExecResponse) MarshalTo added in v0.10.0 

func (m *VReplicationExecResponse) MarshalTo(dAtA []byte) (int, error)

func (*VReplicationExecResponse) MarshalToSizedBuffer added in v0.10.0 

func (m *VReplicationExecResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*VReplicationExecResponse) ProtoMessage 

func (*VReplicationExecResponse) ProtoMessage()

func (*VReplicationExecResponse) Reset 

func (m *VReplicationExecResponse) Reset()

func (*VReplicationExecResponse) Size added in v0.10.0 

func (m *VReplicationExecResponse) Size() (n int)

func (*VReplicationExecResponse) String 

func (m *VReplicationExecResponse) String() string

func (*VReplicationExecResponse) Unmarshal added in v0.10.0 

func (m *VReplicationExecResponse) Unmarshal(dAtA []byte) error

func (*VReplicationExecResponse) XXX_DiscardUnknown 

func (m *VReplicationExecResponse) XXX_DiscardUnknown()

func (*VReplicationExecResponse) XXX_Marshal 

func (m *VReplicationExecResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VReplicationExecResponse) XXX_Merge 

func (m *VReplicationExecResponse) XXX_Merge(src proto.Message)

func (*VReplicationExecResponse) XXX_Size 

func (m *VReplicationExecResponse) XXX_Size() int

func (*VReplicationExecResponse) XXX_Unmarshal 

func (m *VReplicationExecResponse) XXX_Unmarshal(b []byte) error

type VReplicationWaitForPosRequest 

type VReplicationWaitForPosRequest struct {
	Id                   int64    `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Position             string   `protobuf:"bytes,2,opt,name=position,proto3" json:"position,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*VReplicationWaitForPosRequest) Descriptor 

func (*VReplicationWaitForPosRequest) Descriptor() ([]byte, []int)

func (*VReplicationWaitForPosRequest) GetId 

func (m *VReplicationWaitForPosRequest) GetId() int64

func (*VReplicationWaitForPosRequest) GetPosition 

func (m *VReplicationWaitForPosRequest) GetPosition() string

func (*VReplicationWaitForPosRequest) Marshal added in v0.10.0 

func (m *VReplicationWaitForPosRequest) Marshal() (dAtA []byte, err error)

func (*VReplicationWaitForPosRequest) MarshalTo added in v0.10.0 

func (m *VReplicationWaitForPosRequest) MarshalTo(dAtA []byte) (int, error)

func (*VReplicationWaitForPosRequest) MarshalToSizedBuffer added in v0.10.0 

func (m *VReplicationWaitForPosRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*VReplicationWaitForPosRequest) ProtoMessage 

func (*VReplicationWaitForPosRequest) ProtoMessage()

func (*VReplicationWaitForPosRequest) Reset 

func (m *VReplicationWaitForPosRequest) Reset()

func (*VReplicationWaitForPosRequest) Size added in v0.10.0 

func (m *VReplicationWaitForPosRequest) Size() (n int)

func (*VReplicationWaitForPosRequest) String 

func (m *VReplicationWaitForPosRequest) String() string

func (*VReplicationWaitForPosRequest) Unmarshal added in v0.10.0 

func (m *VReplicationWaitForPosRequest) Unmarshal(dAtA []byte) error

func (*VReplicationWaitForPosRequest) XXX_DiscardUnknown 

func (m *VReplicationWaitForPosRequest) XXX_DiscardUnknown()

func (*VReplicationWaitForPosRequest) XXX_Marshal 

func (m *VReplicationWaitForPosRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VReplicationWaitForPosRequest) XXX_Merge 

func (m *VReplicationWaitForPosRequest) XXX_Merge(src proto.Message)

func (*VReplicationWaitForPosRequest) XXX_Size 

func (m *VReplicationWaitForPosRequest) XXX_Size() int

func (*VReplicationWaitForPosRequest) XXX_Unmarshal 

func (m *VReplicationWaitForPosRequest) XXX_Unmarshal(b []byte) error

type VReplicationWaitForPosResponse 

type VReplicationWaitForPosResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*VReplicationWaitForPosResponse) Descriptor 

func (*VReplicationWaitForPosResponse) Descriptor() ([]byte, []int)

func (*VReplicationWaitForPosResponse) Marshal added in v0.10.0 

func (m *VReplicationWaitForPosResponse) Marshal() (dAtA []byte, err error)

func (*VReplicationWaitForPosResponse) MarshalTo added in v0.10.0 

func (m *VReplicationWaitForPosResponse) MarshalTo(dAtA []byte) (int, error)

func (*VReplicationWaitForPosResponse) MarshalToSizedBuffer added in v0.10.0 

func (m *VReplicationWaitForPosResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*VReplicationWaitForPosResponse) ProtoMessage 

func (*VReplicationWaitForPosResponse) ProtoMessage()

func (*VReplicationWaitForPosResponse) Reset 

func (m *VReplicationWaitForPosResponse) Reset()

func (*VReplicationWaitForPosResponse) Size added in v0.10.0 

func (m *VReplicationWaitForPosResponse) Size() (n int)

func (*VReplicationWaitForPosResponse) String 

func (m *VReplicationWaitForPosResponse) String() string

func (*VReplicationWaitForPosResponse) Unmarshal added in v0.10.0 

func (m *VReplicationWaitForPosResponse) Unmarshal(dAtA []byte) error

func (*VReplicationWaitForPosResponse) XXX_DiscardUnknown 

func (m *VReplicationWaitForPosResponse) XXX_DiscardUnknown()

func (*VReplicationWaitForPosResponse) XXX_Marshal 

func (m *VReplicationWaitForPosResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VReplicationWaitForPosResponse) XXX_Merge 

func (m *VReplicationWaitForPosResponse) XXX_Merge(src proto.Message)

func (*VReplicationWaitForPosResponse) XXX_Size 

func (m *VReplicationWaitForPosResponse) XXX_Size() int

func (*VReplicationWaitForPosResponse) XXX_Unmarshal 

func (m *VReplicationWaitForPosResponse) XXX_Unmarshal(b []byte) error

type WaitForPositionRequest 

type WaitForPositionRequest struct {
	Position             string   `protobuf:"bytes,1,opt,name=position,proto3" json:"position,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WaitForPositionRequest) Descriptor 

func (*WaitForPositionRequest) Descriptor() ([]byte, []int)

func (*WaitForPositionRequest) GetPosition 

func (m *WaitForPositionRequest) GetPosition() string

func (*WaitForPositionRequest) Marshal added in v0.10.0 

func (m *WaitForPositionRequest) Marshal() (dAtA []byte, err error)

func (*WaitForPositionRequest) MarshalTo added in v0.10.0 

func (m *WaitForPositionRequest) MarshalTo(dAtA []byte) (int, error)

func (*WaitForPositionRequest) MarshalToSizedBuffer added in v0.10.0 

func (m *WaitForPositionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WaitForPositionRequest) ProtoMessage 

func (*WaitForPositionRequest) ProtoMessage()

func (*WaitForPositionRequest) Reset 

func (m *WaitForPositionRequest) Reset()

func (*WaitForPositionRequest) Size added in v0.10.0 

func (m *WaitForPositionRequest) Size() (n int)

func (*WaitForPositionRequest) String 

func (m *WaitForPositionRequest) String() string

func (*WaitForPositionRequest) Unmarshal added in v0.10.0 

func (m *WaitForPositionRequest) Unmarshal(dAtA []byte) error

func (*WaitForPositionRequest) XXX_DiscardUnknown 

func (m *WaitForPositionRequest) XXX_DiscardUnknown()

func (*WaitForPositionRequest) XXX_Marshal 

func (m *WaitForPositionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WaitForPositionRequest) XXX_Merge 

func (m *WaitForPositionRequest) XXX_Merge(src proto.Message)

func (*WaitForPositionRequest) XXX_Size 

func (m *WaitForPositionRequest) XXX_Size() int

func (*WaitForPositionRequest) XXX_Unmarshal 

func (m *WaitForPositionRequest) XXX_Unmarshal(b []byte) error

type WaitForPositionResponse 

type WaitForPositionResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WaitForPositionResponse) Descriptor 

func (*WaitForPositionResponse) Descriptor() ([]byte, []int)

func (*WaitForPositionResponse) Marshal added in v0.10.0 

func (m *WaitForPositionResponse) Marshal() (dAtA []byte, err error)

func (*WaitForPositionResponse) MarshalTo added in v0.10.0 

func (m *WaitForPositionResponse) MarshalTo(dAtA []byte) (int, error)

func (*WaitForPositionResponse) MarshalToSizedBuffer added in v0.10.0 

func (m *WaitForPositionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WaitForPositionResponse) ProtoMessage 

func (*WaitForPositionResponse) ProtoMessage()

func (*WaitForPositionResponse) Reset 

func (m *WaitForPositionResponse) Reset()

func (*WaitForPositionResponse) Size added in v0.10.0 

func (m *WaitForPositionResponse) Size() (n int)

func (*WaitForPositionResponse) String 

func (m *WaitForPositionResponse) String() string

func (*WaitForPositionResponse) Unmarshal added in v0.10.0 

func (m *WaitForPositionResponse) Unmarshal(dAtA []byte) error

func (*WaitForPositionResponse) XXX_DiscardUnknown 

func (m *WaitForPositionResponse) XXX_DiscardUnknown()

func (*WaitForPositionResponse) XXX_Marshal 

func (m *WaitForPositionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WaitForPositionResponse) XXX_Merge 

func (m *WaitForPositionResponse) XXX_Merge(src proto.Message)

func (*WaitForPositionResponse) XXX_Size 

func (m *WaitForPositionResponse) XXX_Size() int

func (*WaitForPositionResponse) XXX_Unmarshal 

func (m *WaitForPositionResponse) 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.