Documentation ¶
Index ¶
- Variables
- func RegisterMysqlCtlServer(s grpc.ServiceRegistrar, srv MysqlCtlServer)
- type ApplyBinlogFileRequest
- func (m *ApplyBinlogFileRequest) CloneMessageVT() proto.Message
- func (m *ApplyBinlogFileRequest) CloneVT() *ApplyBinlogFileRequest
- func (*ApplyBinlogFileRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ApplyBinlogFileRequest) GetBinlogFileName() string
- func (x *ApplyBinlogFileRequest) GetBinlogRestoreDatetime() *vttime.Time
- func (x *ApplyBinlogFileRequest) GetBinlogRestorePosition() string
- func (m *ApplyBinlogFileRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *ApplyBinlogFileRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *ApplyBinlogFileRequest) MarshalVT() (dAtA []byte, err error)
- func (*ApplyBinlogFileRequest) ProtoMessage()
- func (x *ApplyBinlogFileRequest) ProtoReflect() protoreflect.Message
- func (x *ApplyBinlogFileRequest) Reset()
- func (m *ApplyBinlogFileRequest) SizeVT() (n int)
- func (x *ApplyBinlogFileRequest) String() string
- func (m *ApplyBinlogFileRequest) UnmarshalVT(dAtA []byte) error
- type ApplyBinlogFileResponse
- func (m *ApplyBinlogFileResponse) CloneMessageVT() proto.Message
- func (m *ApplyBinlogFileResponse) CloneVT() *ApplyBinlogFileResponse
- func (*ApplyBinlogFileResponse) Descriptor() ([]byte, []int)deprecated
- func (m *ApplyBinlogFileResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *ApplyBinlogFileResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *ApplyBinlogFileResponse) MarshalVT() (dAtA []byte, err error)
- func (*ApplyBinlogFileResponse) ProtoMessage()
- func (x *ApplyBinlogFileResponse) ProtoReflect() protoreflect.Message
- func (x *ApplyBinlogFileResponse) Reset()
- func (m *ApplyBinlogFileResponse) SizeVT() (n int)
- func (x *ApplyBinlogFileResponse) String() string
- func (m *ApplyBinlogFileResponse) UnmarshalVT(dAtA []byte) error
- type BackupInfo
- func (m *BackupInfo) CloneMessageVT() proto.Message
- func (m *BackupInfo) CloneVT() *BackupInfo
- func (*BackupInfo) Descriptor() ([]byte, []int)deprecated
- func (x *BackupInfo) GetDirectory() string
- func (x *BackupInfo) GetEngine() string
- func (x *BackupInfo) GetKeyspace() string
- func (x *BackupInfo) GetName() string
- func (x *BackupInfo) GetShard() string
- func (x *BackupInfo) GetStatus() BackupInfo_Status
- func (x *BackupInfo) GetTabletAlias() *topodata.TabletAlias
- func (x *BackupInfo) GetTime() *vttime.Time
- func (m *BackupInfo) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *BackupInfo) MarshalToVT(dAtA []byte) (int, error)
- func (m *BackupInfo) MarshalVT() (dAtA []byte, err error)
- func (*BackupInfo) ProtoMessage()
- func (x *BackupInfo) ProtoReflect() protoreflect.Message
- func (x *BackupInfo) Reset()
- func (m *BackupInfo) SizeVT() (n int)
- func (x *BackupInfo) String() string
- func (m *BackupInfo) UnmarshalVT(dAtA []byte) error
- type BackupInfo_Status
- func (BackupInfo_Status) Descriptor() protoreflect.EnumDescriptor
- func (x BackupInfo_Status) Enum() *BackupInfo_Status
- func (BackupInfo_Status) EnumDescriptor() ([]byte, []int)deprecated
- func (x BackupInfo_Status) Number() protoreflect.EnumNumber
- func (x BackupInfo_Status) String() string
- func (BackupInfo_Status) Type() protoreflect.EnumType
- type MysqlCtlClient
- type MysqlCtlServer
- type ReadBinlogFilesTimestampsRequest
- func (m *ReadBinlogFilesTimestampsRequest) CloneMessageVT() proto.Message
- func (m *ReadBinlogFilesTimestampsRequest) CloneVT() *ReadBinlogFilesTimestampsRequest
- func (*ReadBinlogFilesTimestampsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ReadBinlogFilesTimestampsRequest) GetBinlogFileNames() []string
- func (m *ReadBinlogFilesTimestampsRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *ReadBinlogFilesTimestampsRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *ReadBinlogFilesTimestampsRequest) MarshalVT() (dAtA []byte, err error)
- func (*ReadBinlogFilesTimestampsRequest) ProtoMessage()
- func (x *ReadBinlogFilesTimestampsRequest) ProtoReflect() protoreflect.Message
- func (x *ReadBinlogFilesTimestampsRequest) Reset()
- func (m *ReadBinlogFilesTimestampsRequest) SizeVT() (n int)
- func (x *ReadBinlogFilesTimestampsRequest) String() string
- func (m *ReadBinlogFilesTimestampsRequest) UnmarshalVT(dAtA []byte) error
- type ReadBinlogFilesTimestampsResponse
- func (m *ReadBinlogFilesTimestampsResponse) CloneMessageVT() proto.Message
- func (m *ReadBinlogFilesTimestampsResponse) CloneVT() *ReadBinlogFilesTimestampsResponse
- func (*ReadBinlogFilesTimestampsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ReadBinlogFilesTimestampsResponse) GetFirstTimestamp() *vttime.Time
- func (x *ReadBinlogFilesTimestampsResponse) GetFirstTimestampBinlog() string
- func (x *ReadBinlogFilesTimestampsResponse) GetLastTimestamp() *vttime.Time
- func (x *ReadBinlogFilesTimestampsResponse) GetLastTimestampBinlog() string
- func (m *ReadBinlogFilesTimestampsResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *ReadBinlogFilesTimestampsResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *ReadBinlogFilesTimestampsResponse) MarshalVT() (dAtA []byte, err error)
- func (*ReadBinlogFilesTimestampsResponse) ProtoMessage()
- func (x *ReadBinlogFilesTimestampsResponse) ProtoReflect() protoreflect.Message
- func (x *ReadBinlogFilesTimestampsResponse) Reset()
- func (m *ReadBinlogFilesTimestampsResponse) SizeVT() (n int)
- func (x *ReadBinlogFilesTimestampsResponse) String() string
- func (m *ReadBinlogFilesTimestampsResponse) UnmarshalVT(dAtA []byte) error
- type RefreshConfigRequest
- func (m *RefreshConfigRequest) CloneMessageVT() proto.Message
- func (m *RefreshConfigRequest) CloneVT() *RefreshConfigRequest
- func (*RefreshConfigRequest) Descriptor() ([]byte, []int)deprecated
- func (m *RefreshConfigRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *RefreshConfigRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *RefreshConfigRequest) MarshalVT() (dAtA []byte, err error)
- func (*RefreshConfigRequest) ProtoMessage()
- func (x *RefreshConfigRequest) ProtoReflect() protoreflect.Message
- func (x *RefreshConfigRequest) Reset()
- func (m *RefreshConfigRequest) SizeVT() (n int)
- func (x *RefreshConfigRequest) String() string
- func (m *RefreshConfigRequest) UnmarshalVT(dAtA []byte) error
- type RefreshConfigResponse
- func (m *RefreshConfigResponse) CloneMessageVT() proto.Message
- func (m *RefreshConfigResponse) CloneVT() *RefreshConfigResponse
- func (*RefreshConfigResponse) Descriptor() ([]byte, []int)deprecated
- func (m *RefreshConfigResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *RefreshConfigResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *RefreshConfigResponse) MarshalVT() (dAtA []byte, err error)
- func (*RefreshConfigResponse) ProtoMessage()
- func (x *RefreshConfigResponse) ProtoReflect() protoreflect.Message
- func (x *RefreshConfigResponse) Reset()
- func (m *RefreshConfigResponse) SizeVT() (n int)
- func (x *RefreshConfigResponse) String() string
- func (m *RefreshConfigResponse) UnmarshalVT(dAtA []byte) error
- type ReinitConfigRequest
- func (m *ReinitConfigRequest) CloneMessageVT() proto.Message
- func (m *ReinitConfigRequest) CloneVT() *ReinitConfigRequest
- func (*ReinitConfigRequest) Descriptor() ([]byte, []int)deprecated
- func (m *ReinitConfigRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *ReinitConfigRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *ReinitConfigRequest) MarshalVT() (dAtA []byte, err error)
- func (*ReinitConfigRequest) ProtoMessage()
- func (x *ReinitConfigRequest) ProtoReflect() protoreflect.Message
- func (x *ReinitConfigRequest) Reset()
- func (m *ReinitConfigRequest) SizeVT() (n int)
- func (x *ReinitConfigRequest) String() string
- func (m *ReinitConfigRequest) UnmarshalVT(dAtA []byte) error
- type ReinitConfigResponse
- func (m *ReinitConfigResponse) CloneMessageVT() proto.Message
- func (m *ReinitConfigResponse) CloneVT() *ReinitConfigResponse
- func (*ReinitConfigResponse) Descriptor() ([]byte, []int)deprecated
- func (m *ReinitConfigResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *ReinitConfigResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *ReinitConfigResponse) MarshalVT() (dAtA []byte, err error)
- func (*ReinitConfigResponse) ProtoMessage()
- func (x *ReinitConfigResponse) ProtoReflect() protoreflect.Message
- func (x *ReinitConfigResponse) Reset()
- func (m *ReinitConfigResponse) SizeVT() (n int)
- func (x *ReinitConfigResponse) String() string
- func (m *ReinitConfigResponse) UnmarshalVT(dAtA []byte) error
- type RunMysqlUpgradeRequest
- func (m *RunMysqlUpgradeRequest) CloneMessageVT() proto.Message
- func (m *RunMysqlUpgradeRequest) CloneVT() *RunMysqlUpgradeRequest
- func (*RunMysqlUpgradeRequest) Descriptor() ([]byte, []int)deprecated
- func (m *RunMysqlUpgradeRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *RunMysqlUpgradeRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *RunMysqlUpgradeRequest) MarshalVT() (dAtA []byte, err error)
- func (*RunMysqlUpgradeRequest) ProtoMessage()
- func (x *RunMysqlUpgradeRequest) ProtoReflect() protoreflect.Message
- func (x *RunMysqlUpgradeRequest) Reset()
- func (m *RunMysqlUpgradeRequest) SizeVT() (n int)
- func (x *RunMysqlUpgradeRequest) String() string
- func (m *RunMysqlUpgradeRequest) UnmarshalVT(dAtA []byte) error
- type RunMysqlUpgradeResponse
- func (m *RunMysqlUpgradeResponse) CloneMessageVT() proto.Message
- func (m *RunMysqlUpgradeResponse) CloneVT() *RunMysqlUpgradeResponse
- func (*RunMysqlUpgradeResponse) Descriptor() ([]byte, []int)deprecated
- func (m *RunMysqlUpgradeResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *RunMysqlUpgradeResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *RunMysqlUpgradeResponse) MarshalVT() (dAtA []byte, err error)
- func (*RunMysqlUpgradeResponse) ProtoMessage()
- func (x *RunMysqlUpgradeResponse) ProtoReflect() protoreflect.Message
- func (x *RunMysqlUpgradeResponse) Reset()
- func (m *RunMysqlUpgradeResponse) SizeVT() (n int)
- func (x *RunMysqlUpgradeResponse) String() string
- func (m *RunMysqlUpgradeResponse) UnmarshalVT(dAtA []byte) error
- type ShutdownRequest
- func (m *ShutdownRequest) CloneMessageVT() proto.Message
- func (m *ShutdownRequest) CloneVT() *ShutdownRequest
- func (*ShutdownRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ShutdownRequest) GetMysqlShutdownTimeout() *vttime.Duration
- func (x *ShutdownRequest) GetWaitForMysqld() bool
- func (m *ShutdownRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *ShutdownRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *ShutdownRequest) MarshalVT() (dAtA []byte, err error)
- func (*ShutdownRequest) ProtoMessage()
- func (x *ShutdownRequest) ProtoReflect() protoreflect.Message
- func (x *ShutdownRequest) Reset()
- func (m *ShutdownRequest) SizeVT() (n int)
- func (x *ShutdownRequest) String() string
- func (m *ShutdownRequest) UnmarshalVT(dAtA []byte) error
- type ShutdownResponse
- func (m *ShutdownResponse) CloneMessageVT() proto.Message
- func (m *ShutdownResponse) CloneVT() *ShutdownResponse
- func (*ShutdownResponse) Descriptor() ([]byte, []int)deprecated
- func (m *ShutdownResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *ShutdownResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *ShutdownResponse) MarshalVT() (dAtA []byte, err error)
- func (*ShutdownResponse) ProtoMessage()
- func (x *ShutdownResponse) ProtoReflect() protoreflect.Message
- func (x *ShutdownResponse) Reset()
- func (m *ShutdownResponse) SizeVT() (n int)
- func (x *ShutdownResponse) String() string
- func (m *ShutdownResponse) UnmarshalVT(dAtA []byte) error
- type StartRequest
- func (m *StartRequest) CloneMessageVT() proto.Message
- func (m *StartRequest) CloneVT() *StartRequest
- func (*StartRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StartRequest) GetMysqldArgs() []string
- func (m *StartRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *StartRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *StartRequest) MarshalVT() (dAtA []byte, err error)
- func (*StartRequest) ProtoMessage()
- func (x *StartRequest) ProtoReflect() protoreflect.Message
- func (x *StartRequest) Reset()
- func (m *StartRequest) SizeVT() (n int)
- func (x *StartRequest) String() string
- func (m *StartRequest) UnmarshalVT(dAtA []byte) error
- type StartResponse
- func (m *StartResponse) CloneMessageVT() proto.Message
- func (m *StartResponse) CloneVT() *StartResponse
- func (*StartResponse) Descriptor() ([]byte, []int)deprecated
- func (m *StartResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *StartResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *StartResponse) MarshalVT() (dAtA []byte, err error)
- func (*StartResponse) ProtoMessage()
- func (x *StartResponse) ProtoReflect() protoreflect.Message
- func (x *StartResponse) Reset()
- func (m *StartResponse) SizeVT() (n int)
- func (x *StartResponse) String() string
- func (m *StartResponse) UnmarshalVT(dAtA []byte) error
- type UnimplementedMysqlCtlServer
- func (UnimplementedMysqlCtlServer) ApplyBinlogFile(context.Context, *ApplyBinlogFileRequest) (*ApplyBinlogFileResponse, error)
- func (UnimplementedMysqlCtlServer) ReadBinlogFilesTimestamps(context.Context, *ReadBinlogFilesTimestampsRequest) (*ReadBinlogFilesTimestampsResponse, error)
- func (UnimplementedMysqlCtlServer) RefreshConfig(context.Context, *RefreshConfigRequest) (*RefreshConfigResponse, error)
- func (UnimplementedMysqlCtlServer) ReinitConfig(context.Context, *ReinitConfigRequest) (*ReinitConfigResponse, error)
- func (UnimplementedMysqlCtlServer) RunMysqlUpgrade(context.Context, *RunMysqlUpgradeRequest) (*RunMysqlUpgradeResponse, error)
- func (UnimplementedMysqlCtlServer) Shutdown(context.Context, *ShutdownRequest) (*ShutdownResponse, error)
- func (UnimplementedMysqlCtlServer) Start(context.Context, *StartRequest) (*StartResponse, error)
- func (UnimplementedMysqlCtlServer) VersionString(context.Context, *VersionStringRequest) (*VersionStringResponse, error)
- type UnsafeMysqlCtlServer
- type VersionStringRequest
- func (m *VersionStringRequest) CloneMessageVT() proto.Message
- func (m *VersionStringRequest) CloneVT() *VersionStringRequest
- func (*VersionStringRequest) Descriptor() ([]byte, []int)deprecated
- func (m *VersionStringRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *VersionStringRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *VersionStringRequest) MarshalVT() (dAtA []byte, err error)
- func (*VersionStringRequest) ProtoMessage()
- func (x *VersionStringRequest) ProtoReflect() protoreflect.Message
- func (x *VersionStringRequest) Reset()
- func (m *VersionStringRequest) SizeVT() (n int)
- func (x *VersionStringRequest) String() string
- func (m *VersionStringRequest) UnmarshalVT(dAtA []byte) error
- type VersionStringResponse
- func (m *VersionStringResponse) CloneMessageVT() proto.Message
- func (m *VersionStringResponse) CloneVT() *VersionStringResponse
- func (*VersionStringResponse) Descriptor() ([]byte, []int)deprecated
- func (x *VersionStringResponse) GetVersion() string
- func (m *VersionStringResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *VersionStringResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *VersionStringResponse) MarshalVT() (dAtA []byte, err error)
- func (*VersionStringResponse) ProtoMessage()
- func (x *VersionStringResponse) ProtoReflect() protoreflect.Message
- func (x *VersionStringResponse) Reset()
- func (m *VersionStringResponse) SizeVT() (n int)
- func (x *VersionStringResponse) String() string
- func (m *VersionStringResponse) UnmarshalVT(dAtA []byte) error
Constants ¶
This section is empty.
Variables ¶
var ( BackupInfo_Status_name = map[int32]string{ 0: "UNKNOWN", 1: "INCOMPLETE", 2: "COMPLETE", 3: "INVALID", 4: "VALID", } BackupInfo_Status_value = map[string]int32{ "UNKNOWN": 0, "INCOMPLETE": 1, "COMPLETE": 2, "INVALID": 3, "VALID": 4, } )
Enum value maps for BackupInfo_Status.
var ( ErrInvalidLength = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflow = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group") )
var File_mysqlctl_proto protoreflect.FileDescriptor
var MysqlCtl_ServiceDesc = grpc.ServiceDesc{ ServiceName: "mysqlctl.MysqlCtl", HandlerType: (*MysqlCtlServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Start", Handler: _MysqlCtl_Start_Handler, }, { MethodName: "Shutdown", Handler: _MysqlCtl_Shutdown_Handler, }, { MethodName: "RunMysqlUpgrade", Handler: _MysqlCtl_RunMysqlUpgrade_Handler, }, { MethodName: "ApplyBinlogFile", Handler: _MysqlCtl_ApplyBinlogFile_Handler, }, { MethodName: "ReadBinlogFilesTimestamps", Handler: _MysqlCtl_ReadBinlogFilesTimestamps_Handler, }, { MethodName: "ReinitConfig", Handler: _MysqlCtl_ReinitConfig_Handler, }, { MethodName: "RefreshConfig", Handler: _MysqlCtl_RefreshConfig_Handler, }, { MethodName: "VersionString", Handler: _MysqlCtl_VersionString_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "mysqlctl.proto", }
MysqlCtl_ServiceDesc is the grpc.ServiceDesc for MysqlCtl service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterMysqlCtlServer ¶
func RegisterMysqlCtlServer(s grpc.ServiceRegistrar, srv MysqlCtlServer)
Types ¶
type ApplyBinlogFileRequest ¶ added in v0.17.0
type ApplyBinlogFileRequest struct { BinlogFileName string `protobuf:"bytes,1,opt,name=binlog_file_name,json=binlogFileName,proto3" json:"binlog_file_name,omitempty"` BinlogRestorePosition string `` /* 126-byte string literal not displayed */ BinlogRestoreDatetime *vttime.Time `` /* 126-byte string literal not displayed */ // contains filtered or unexported fields }
func (*ApplyBinlogFileRequest) CloneMessageVT ¶ added in v0.18.0
func (m *ApplyBinlogFileRequest) CloneMessageVT() proto.Message
func (*ApplyBinlogFileRequest) CloneVT ¶ added in v0.18.0
func (m *ApplyBinlogFileRequest) CloneVT() *ApplyBinlogFileRequest
func (*ApplyBinlogFileRequest) Descriptor
deprecated
added in
v0.17.0
func (*ApplyBinlogFileRequest) Descriptor() ([]byte, []int)
Deprecated: Use ApplyBinlogFileRequest.ProtoReflect.Descriptor instead.
func (*ApplyBinlogFileRequest) GetBinlogFileName ¶ added in v0.17.0
func (x *ApplyBinlogFileRequest) GetBinlogFileName() string
func (*ApplyBinlogFileRequest) GetBinlogRestoreDatetime ¶ added in v0.18.0
func (x *ApplyBinlogFileRequest) GetBinlogRestoreDatetime() *vttime.Time
func (*ApplyBinlogFileRequest) GetBinlogRestorePosition ¶ added in v0.17.0
func (x *ApplyBinlogFileRequest) GetBinlogRestorePosition() string
func (*ApplyBinlogFileRequest) MarshalToSizedBufferVT ¶ added in v0.17.0
func (m *ApplyBinlogFileRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*ApplyBinlogFileRequest) MarshalToVT ¶ added in v0.17.0
func (m *ApplyBinlogFileRequest) MarshalToVT(dAtA []byte) (int, error)
func (*ApplyBinlogFileRequest) MarshalVT ¶ added in v0.17.0
func (m *ApplyBinlogFileRequest) MarshalVT() (dAtA []byte, err error)
func (*ApplyBinlogFileRequest) ProtoMessage ¶ added in v0.17.0
func (*ApplyBinlogFileRequest) ProtoMessage()
func (*ApplyBinlogFileRequest) ProtoReflect ¶ added in v0.17.0
func (x *ApplyBinlogFileRequest) ProtoReflect() protoreflect.Message
func (*ApplyBinlogFileRequest) Reset ¶ added in v0.17.0
func (x *ApplyBinlogFileRequest) Reset()
func (*ApplyBinlogFileRequest) SizeVT ¶ added in v0.17.0
func (m *ApplyBinlogFileRequest) SizeVT() (n int)
func (*ApplyBinlogFileRequest) String ¶ added in v0.17.0
func (x *ApplyBinlogFileRequest) String() string
func (*ApplyBinlogFileRequest) UnmarshalVT ¶ added in v0.17.0
func (m *ApplyBinlogFileRequest) UnmarshalVT(dAtA []byte) error
type ApplyBinlogFileResponse ¶ added in v0.17.0
type ApplyBinlogFileResponse struct {
// contains filtered or unexported fields
}
func (*ApplyBinlogFileResponse) CloneMessageVT ¶ added in v0.18.0
func (m *ApplyBinlogFileResponse) CloneMessageVT() proto.Message
func (*ApplyBinlogFileResponse) CloneVT ¶ added in v0.18.0
func (m *ApplyBinlogFileResponse) CloneVT() *ApplyBinlogFileResponse
func (*ApplyBinlogFileResponse) Descriptor
deprecated
added in
v0.17.0
func (*ApplyBinlogFileResponse) Descriptor() ([]byte, []int)
Deprecated: Use ApplyBinlogFileResponse.ProtoReflect.Descriptor instead.
func (*ApplyBinlogFileResponse) MarshalToSizedBufferVT ¶ added in v0.17.0
func (m *ApplyBinlogFileResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*ApplyBinlogFileResponse) MarshalToVT ¶ added in v0.17.0
func (m *ApplyBinlogFileResponse) MarshalToVT(dAtA []byte) (int, error)
func (*ApplyBinlogFileResponse) MarshalVT ¶ added in v0.17.0
func (m *ApplyBinlogFileResponse) MarshalVT() (dAtA []byte, err error)
func (*ApplyBinlogFileResponse) ProtoMessage ¶ added in v0.17.0
func (*ApplyBinlogFileResponse) ProtoMessage()
func (*ApplyBinlogFileResponse) ProtoReflect ¶ added in v0.17.0
func (x *ApplyBinlogFileResponse) ProtoReflect() protoreflect.Message
func (*ApplyBinlogFileResponse) Reset ¶ added in v0.17.0
func (x *ApplyBinlogFileResponse) Reset()
func (*ApplyBinlogFileResponse) SizeVT ¶ added in v0.17.0
func (m *ApplyBinlogFileResponse) SizeVT() (n int)
func (*ApplyBinlogFileResponse) String ¶ added in v0.17.0
func (x *ApplyBinlogFileResponse) String() string
func (*ApplyBinlogFileResponse) UnmarshalVT ¶ added in v0.17.0
func (m *ApplyBinlogFileResponse) UnmarshalVT(dAtA []byte) error
type BackupInfo ¶ added in v0.10.0
type BackupInfo struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Directory string `protobuf:"bytes,2,opt,name=directory,proto3" json:"directory,omitempty"` Keyspace string `protobuf:"bytes,3,opt,name=keyspace,proto3" json:"keyspace,omitempty"` Shard string `protobuf:"bytes,4,opt,name=shard,proto3" json:"shard,omitempty"` TabletAlias *topodata.TabletAlias `protobuf:"bytes,5,opt,name=tablet_alias,json=tabletAlias,proto3" json:"tablet_alias,omitempty"` Time *vttime.Time `protobuf:"bytes,6,opt,name=time,proto3" json:"time,omitempty"` // Engine is the name of the backupengine implementation used to create // this backup. Engine string `protobuf:"bytes,7,opt,name=engine,proto3" json:"engine,omitempty"` Status BackupInfo_Status `protobuf:"varint,8,opt,name=status,proto3,enum=mysqlctl.BackupInfo_Status" json:"status,omitempty"` // contains filtered or unexported fields }
BackupInfo is the read-only attributes of a mysqlctl/backupstorage.BackupHandle.
func (*BackupInfo) CloneMessageVT ¶ added in v0.18.0
func (m *BackupInfo) CloneMessageVT() proto.Message
func (*BackupInfo) CloneVT ¶ added in v0.18.0
func (m *BackupInfo) CloneVT() *BackupInfo
func (*BackupInfo) Descriptor
deprecated
added in
v0.10.0
func (*BackupInfo) Descriptor() ([]byte, []int)
Deprecated: Use BackupInfo.ProtoReflect.Descriptor instead.
func (*BackupInfo) GetDirectory ¶ added in v0.10.0
func (x *BackupInfo) GetDirectory() string
func (*BackupInfo) GetEngine ¶ added in v0.11.0
func (x *BackupInfo) GetEngine() string
func (*BackupInfo) GetKeyspace ¶ added in v0.11.0
func (x *BackupInfo) GetKeyspace() string
func (*BackupInfo) GetName ¶ added in v0.10.0
func (x *BackupInfo) GetName() string
func (*BackupInfo) GetShard ¶ added in v0.11.0
func (x *BackupInfo) GetShard() string
func (*BackupInfo) GetStatus ¶ added in v0.11.0
func (x *BackupInfo) GetStatus() BackupInfo_Status
func (*BackupInfo) GetTabletAlias ¶ added in v0.11.0
func (x *BackupInfo) GetTabletAlias() *topodata.TabletAlias
func (*BackupInfo) GetTime ¶ added in v0.11.0
func (x *BackupInfo) GetTime() *vttime.Time
func (*BackupInfo) MarshalToSizedBufferVT ¶ added in v0.11.0
func (m *BackupInfo) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*BackupInfo) MarshalToVT ¶ added in v0.11.0
func (m *BackupInfo) MarshalToVT(dAtA []byte) (int, error)
func (*BackupInfo) MarshalVT ¶ added in v0.11.0
func (m *BackupInfo) MarshalVT() (dAtA []byte, err error)
func (*BackupInfo) ProtoMessage ¶ added in v0.10.0
func (*BackupInfo) ProtoMessage()
func (*BackupInfo) ProtoReflect ¶ added in v0.11.0
func (x *BackupInfo) ProtoReflect() protoreflect.Message
func (*BackupInfo) Reset ¶ added in v0.10.0
func (x *BackupInfo) Reset()
func (*BackupInfo) SizeVT ¶ added in v0.11.0
func (m *BackupInfo) SizeVT() (n int)
func (*BackupInfo) String ¶ added in v0.10.0
func (x *BackupInfo) String() string
func (*BackupInfo) UnmarshalVT ¶ added in v0.11.0
func (m *BackupInfo) UnmarshalVT(dAtA []byte) error
type BackupInfo_Status ¶ added in v0.11.0
type BackupInfo_Status int32
Status is an enum representing the possible status of a backup.
const ( BackupInfo_UNKNOWN BackupInfo_Status = 0 BackupInfo_INCOMPLETE BackupInfo_Status = 1 BackupInfo_COMPLETE BackupInfo_Status = 2 // A backup status of INVALID should be set if the backup is complete // but unusable in some way (partial upload, corrupt file, etc). BackupInfo_INVALID BackupInfo_Status = 3 // A backup status of VALID should be set if the backup is both // complete and usuable. BackupInfo_VALID BackupInfo_Status = 4 )
func (BackupInfo_Status) Descriptor ¶ added in v0.11.0
func (BackupInfo_Status) Descriptor() protoreflect.EnumDescriptor
func (BackupInfo_Status) Enum ¶ added in v0.11.0
func (x BackupInfo_Status) Enum() *BackupInfo_Status
func (BackupInfo_Status) EnumDescriptor
deprecated
added in
v0.11.0
func (BackupInfo_Status) EnumDescriptor() ([]byte, []int)
Deprecated: Use BackupInfo_Status.Descriptor instead.
func (BackupInfo_Status) Number ¶ added in v0.11.0
func (x BackupInfo_Status) Number() protoreflect.EnumNumber
func (BackupInfo_Status) String ¶ added in v0.11.0
func (x BackupInfo_Status) String() string
func (BackupInfo_Status) Type ¶ added in v0.11.0
func (BackupInfo_Status) Type() protoreflect.EnumType
type MysqlCtlClient ¶
type MysqlCtlClient interface { Start(ctx context.Context, in *StartRequest, opts ...grpc.CallOption) (*StartResponse, error) Shutdown(ctx context.Context, in *ShutdownRequest, opts ...grpc.CallOption) (*ShutdownResponse, error) RunMysqlUpgrade(ctx context.Context, in *RunMysqlUpgradeRequest, opts ...grpc.CallOption) (*RunMysqlUpgradeResponse, error) ApplyBinlogFile(ctx context.Context, in *ApplyBinlogFileRequest, opts ...grpc.CallOption) (*ApplyBinlogFileResponse, error) ReadBinlogFilesTimestamps(ctx context.Context, in *ReadBinlogFilesTimestampsRequest, opts ...grpc.CallOption) (*ReadBinlogFilesTimestampsResponse, error) ReinitConfig(ctx context.Context, in *ReinitConfigRequest, opts ...grpc.CallOption) (*ReinitConfigResponse, error) RefreshConfig(ctx context.Context, in *RefreshConfigRequest, opts ...grpc.CallOption) (*RefreshConfigResponse, error) VersionString(ctx context.Context, in *VersionStringRequest, opts ...grpc.CallOption) (*VersionStringResponse, error) }
MysqlCtlClient is the client API for MysqlCtl service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewMysqlCtlClient ¶
func NewMysqlCtlClient(cc grpc.ClientConnInterface) MysqlCtlClient
type MysqlCtlServer ¶
type MysqlCtlServer interface { Start(context.Context, *StartRequest) (*StartResponse, error) Shutdown(context.Context, *ShutdownRequest) (*ShutdownResponse, error) RunMysqlUpgrade(context.Context, *RunMysqlUpgradeRequest) (*RunMysqlUpgradeResponse, error) ApplyBinlogFile(context.Context, *ApplyBinlogFileRequest) (*ApplyBinlogFileResponse, error) ReadBinlogFilesTimestamps(context.Context, *ReadBinlogFilesTimestampsRequest) (*ReadBinlogFilesTimestampsResponse, error) ReinitConfig(context.Context, *ReinitConfigRequest) (*ReinitConfigResponse, error) RefreshConfig(context.Context, *RefreshConfigRequest) (*RefreshConfigResponse, error) VersionString(context.Context, *VersionStringRequest) (*VersionStringResponse, error) // contains filtered or unexported methods }
MysqlCtlServer is the server API for MysqlCtl service. All implementations must embed UnimplementedMysqlCtlServer for forward compatibility
type ReadBinlogFilesTimestampsRequest ¶ added in v0.18.0
type ReadBinlogFilesTimestampsRequest struct { BinlogFileNames []string `protobuf:"bytes,1,rep,name=binlog_file_names,json=binlogFileNames,proto3" json:"binlog_file_names,omitempty"` // contains filtered or unexported fields }
func (*ReadBinlogFilesTimestampsRequest) CloneMessageVT ¶ added in v0.18.0
func (m *ReadBinlogFilesTimestampsRequest) CloneMessageVT() proto.Message
func (*ReadBinlogFilesTimestampsRequest) CloneVT ¶ added in v0.18.0
func (m *ReadBinlogFilesTimestampsRequest) CloneVT() *ReadBinlogFilesTimestampsRequest
func (*ReadBinlogFilesTimestampsRequest) Descriptor
deprecated
added in
v0.18.0
func (*ReadBinlogFilesTimestampsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ReadBinlogFilesTimestampsRequest.ProtoReflect.Descriptor instead.
func (*ReadBinlogFilesTimestampsRequest) GetBinlogFileNames ¶ added in v0.18.0
func (x *ReadBinlogFilesTimestampsRequest) GetBinlogFileNames() []string
func (*ReadBinlogFilesTimestampsRequest) MarshalToSizedBufferVT ¶ added in v0.18.0
func (m *ReadBinlogFilesTimestampsRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*ReadBinlogFilesTimestampsRequest) MarshalToVT ¶ added in v0.18.0
func (m *ReadBinlogFilesTimestampsRequest) MarshalToVT(dAtA []byte) (int, error)
func (*ReadBinlogFilesTimestampsRequest) MarshalVT ¶ added in v0.18.0
func (m *ReadBinlogFilesTimestampsRequest) MarshalVT() (dAtA []byte, err error)
func (*ReadBinlogFilesTimestampsRequest) ProtoMessage ¶ added in v0.18.0
func (*ReadBinlogFilesTimestampsRequest) ProtoMessage()
func (*ReadBinlogFilesTimestampsRequest) ProtoReflect ¶ added in v0.18.0
func (x *ReadBinlogFilesTimestampsRequest) ProtoReflect() protoreflect.Message
func (*ReadBinlogFilesTimestampsRequest) Reset ¶ added in v0.18.0
func (x *ReadBinlogFilesTimestampsRequest) Reset()
func (*ReadBinlogFilesTimestampsRequest) SizeVT ¶ added in v0.18.0
func (m *ReadBinlogFilesTimestampsRequest) SizeVT() (n int)
func (*ReadBinlogFilesTimestampsRequest) String ¶ added in v0.18.0
func (x *ReadBinlogFilesTimestampsRequest) String() string
func (*ReadBinlogFilesTimestampsRequest) UnmarshalVT ¶ added in v0.18.0
func (m *ReadBinlogFilesTimestampsRequest) UnmarshalVT(dAtA []byte) error
type ReadBinlogFilesTimestampsResponse ¶ added in v0.18.0
type ReadBinlogFilesTimestampsResponse struct { // FirstTimestamp is the timestamp of the first found transaction searching in order of given binlog files FirstTimestamp *vttime.Time `protobuf:"bytes,1,opt,name=first_timestamp,json=firstTimestamp,proto3" json:"first_timestamp,omitempty"` // FirstTimestampBinlog is the name of the binary log in which the first timestamp is found FirstTimestampBinlog string `protobuf:"bytes,2,opt,name=first_timestamp_binlog,json=firstTimestampBinlog,proto3" json:"first_timestamp_binlog,omitempty"` // LastTimestamp is the timestamp of the last found transaction in given binlog files LastTimestamp *vttime.Time `protobuf:"bytes,3,opt,name=last_timestamp,json=lastTimestamp,proto3" json:"last_timestamp,omitempty"` // LastTimestampBinlog is the name of the binary log in which the last timestamp is found LastTimestampBinlog string `protobuf:"bytes,4,opt,name=last_timestamp_binlog,json=lastTimestampBinlog,proto3" json:"last_timestamp_binlog,omitempty"` // contains filtered or unexported fields }
func (*ReadBinlogFilesTimestampsResponse) CloneMessageVT ¶ added in v0.18.0
func (m *ReadBinlogFilesTimestampsResponse) CloneMessageVT() proto.Message
func (*ReadBinlogFilesTimestampsResponse) CloneVT ¶ added in v0.18.0
func (m *ReadBinlogFilesTimestampsResponse) CloneVT() *ReadBinlogFilesTimestampsResponse
func (*ReadBinlogFilesTimestampsResponse) Descriptor
deprecated
added in
v0.18.0
func (*ReadBinlogFilesTimestampsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ReadBinlogFilesTimestampsResponse.ProtoReflect.Descriptor instead.
func (*ReadBinlogFilesTimestampsResponse) GetFirstTimestamp ¶ added in v0.18.0
func (x *ReadBinlogFilesTimestampsResponse) GetFirstTimestamp() *vttime.Time
func (*ReadBinlogFilesTimestampsResponse) GetFirstTimestampBinlog ¶ added in v0.18.0
func (x *ReadBinlogFilesTimestampsResponse) GetFirstTimestampBinlog() string
func (*ReadBinlogFilesTimestampsResponse) GetLastTimestamp ¶ added in v0.18.0
func (x *ReadBinlogFilesTimestampsResponse) GetLastTimestamp() *vttime.Time
func (*ReadBinlogFilesTimestampsResponse) GetLastTimestampBinlog ¶ added in v0.18.0
func (x *ReadBinlogFilesTimestampsResponse) GetLastTimestampBinlog() string
func (*ReadBinlogFilesTimestampsResponse) MarshalToSizedBufferVT ¶ added in v0.18.0
func (m *ReadBinlogFilesTimestampsResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*ReadBinlogFilesTimestampsResponse) MarshalToVT ¶ added in v0.18.0
func (m *ReadBinlogFilesTimestampsResponse) MarshalToVT(dAtA []byte) (int, error)
func (*ReadBinlogFilesTimestampsResponse) MarshalVT ¶ added in v0.18.0
func (m *ReadBinlogFilesTimestampsResponse) MarshalVT() (dAtA []byte, err error)
func (*ReadBinlogFilesTimestampsResponse) ProtoMessage ¶ added in v0.18.0
func (*ReadBinlogFilesTimestampsResponse) ProtoMessage()
func (*ReadBinlogFilesTimestampsResponse) ProtoReflect ¶ added in v0.18.0
func (x *ReadBinlogFilesTimestampsResponse) ProtoReflect() protoreflect.Message
func (*ReadBinlogFilesTimestampsResponse) Reset ¶ added in v0.18.0
func (x *ReadBinlogFilesTimestampsResponse) Reset()
func (*ReadBinlogFilesTimestampsResponse) SizeVT ¶ added in v0.18.0
func (m *ReadBinlogFilesTimestampsResponse) SizeVT() (n int)
func (*ReadBinlogFilesTimestampsResponse) String ¶ added in v0.18.0
func (x *ReadBinlogFilesTimestampsResponse) String() string
func (*ReadBinlogFilesTimestampsResponse) UnmarshalVT ¶ added in v0.18.0
func (m *ReadBinlogFilesTimestampsResponse) UnmarshalVT(dAtA []byte) error
type RefreshConfigRequest ¶
type RefreshConfigRequest struct {
// contains filtered or unexported fields
}
func (*RefreshConfigRequest) CloneMessageVT ¶ added in v0.18.0
func (m *RefreshConfigRequest) CloneMessageVT() proto.Message
func (*RefreshConfigRequest) CloneVT ¶ added in v0.18.0
func (m *RefreshConfigRequest) CloneVT() *RefreshConfigRequest
func (*RefreshConfigRequest) Descriptor
deprecated
func (*RefreshConfigRequest) Descriptor() ([]byte, []int)
Deprecated: Use RefreshConfigRequest.ProtoReflect.Descriptor instead.
func (*RefreshConfigRequest) MarshalToSizedBufferVT ¶ added in v0.11.0
func (m *RefreshConfigRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*RefreshConfigRequest) MarshalToVT ¶ added in v0.11.0
func (m *RefreshConfigRequest) MarshalToVT(dAtA []byte) (int, error)
func (*RefreshConfigRequest) MarshalVT ¶ added in v0.11.0
func (m *RefreshConfigRequest) MarshalVT() (dAtA []byte, err error)
func (*RefreshConfigRequest) ProtoMessage ¶
func (*RefreshConfigRequest) ProtoMessage()
func (*RefreshConfigRequest) ProtoReflect ¶ added in v0.11.0
func (x *RefreshConfigRequest) ProtoReflect() protoreflect.Message
func (*RefreshConfigRequest) Reset ¶
func (x *RefreshConfigRequest) Reset()
func (*RefreshConfigRequest) SizeVT ¶ added in v0.11.0
func (m *RefreshConfigRequest) SizeVT() (n int)
func (*RefreshConfigRequest) String ¶
func (x *RefreshConfigRequest) String() string
func (*RefreshConfigRequest) UnmarshalVT ¶ added in v0.11.0
func (m *RefreshConfigRequest) UnmarshalVT(dAtA []byte) error
type RefreshConfigResponse ¶
type RefreshConfigResponse struct {
// contains filtered or unexported fields
}
func (*RefreshConfigResponse) CloneMessageVT ¶ added in v0.18.0
func (m *RefreshConfigResponse) CloneMessageVT() proto.Message
func (*RefreshConfigResponse) CloneVT ¶ added in v0.18.0
func (m *RefreshConfigResponse) CloneVT() *RefreshConfigResponse
func (*RefreshConfigResponse) Descriptor
deprecated
func (*RefreshConfigResponse) Descriptor() ([]byte, []int)
Deprecated: Use RefreshConfigResponse.ProtoReflect.Descriptor instead.
func (*RefreshConfigResponse) MarshalToSizedBufferVT ¶ added in v0.11.0
func (m *RefreshConfigResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*RefreshConfigResponse) MarshalToVT ¶ added in v0.11.0
func (m *RefreshConfigResponse) MarshalToVT(dAtA []byte) (int, error)
func (*RefreshConfigResponse) MarshalVT ¶ added in v0.11.0
func (m *RefreshConfigResponse) MarshalVT() (dAtA []byte, err error)
func (*RefreshConfigResponse) ProtoMessage ¶
func (*RefreshConfigResponse) ProtoMessage()
func (*RefreshConfigResponse) ProtoReflect ¶ added in v0.11.0
func (x *RefreshConfigResponse) ProtoReflect() protoreflect.Message
func (*RefreshConfigResponse) Reset ¶
func (x *RefreshConfigResponse) Reset()
func (*RefreshConfigResponse) SizeVT ¶ added in v0.11.0
func (m *RefreshConfigResponse) SizeVT() (n int)
func (*RefreshConfigResponse) String ¶
func (x *RefreshConfigResponse) String() string
func (*RefreshConfigResponse) UnmarshalVT ¶ added in v0.11.0
func (m *RefreshConfigResponse) UnmarshalVT(dAtA []byte) error
type ReinitConfigRequest ¶
type ReinitConfigRequest struct {
// contains filtered or unexported fields
}
func (*ReinitConfigRequest) CloneMessageVT ¶ added in v0.18.0
func (m *ReinitConfigRequest) CloneMessageVT() proto.Message
func (*ReinitConfigRequest) CloneVT ¶ added in v0.18.0
func (m *ReinitConfigRequest) CloneVT() *ReinitConfigRequest
func (*ReinitConfigRequest) Descriptor
deprecated
func (*ReinitConfigRequest) Descriptor() ([]byte, []int)
Deprecated: Use ReinitConfigRequest.ProtoReflect.Descriptor instead.
func (*ReinitConfigRequest) MarshalToSizedBufferVT ¶ added in v0.11.0
func (m *ReinitConfigRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*ReinitConfigRequest) MarshalToVT ¶ added in v0.11.0
func (m *ReinitConfigRequest) MarshalToVT(dAtA []byte) (int, error)
func (*ReinitConfigRequest) MarshalVT ¶ added in v0.11.0
func (m *ReinitConfigRequest) MarshalVT() (dAtA []byte, err error)
func (*ReinitConfigRequest) ProtoMessage ¶
func (*ReinitConfigRequest) ProtoMessage()
func (*ReinitConfigRequest) ProtoReflect ¶ added in v0.11.0
func (x *ReinitConfigRequest) ProtoReflect() protoreflect.Message
func (*ReinitConfigRequest) Reset ¶
func (x *ReinitConfigRequest) Reset()
func (*ReinitConfigRequest) SizeVT ¶ added in v0.11.0
func (m *ReinitConfigRequest) SizeVT() (n int)
func (*ReinitConfigRequest) String ¶
func (x *ReinitConfigRequest) String() string
func (*ReinitConfigRequest) UnmarshalVT ¶ added in v0.11.0
func (m *ReinitConfigRequest) UnmarshalVT(dAtA []byte) error
type ReinitConfigResponse ¶
type ReinitConfigResponse struct {
// contains filtered or unexported fields
}
func (*ReinitConfigResponse) CloneMessageVT ¶ added in v0.18.0
func (m *ReinitConfigResponse) CloneMessageVT() proto.Message
func (*ReinitConfigResponse) CloneVT ¶ added in v0.18.0
func (m *ReinitConfigResponse) CloneVT() *ReinitConfigResponse
func (*ReinitConfigResponse) Descriptor
deprecated
func (*ReinitConfigResponse) Descriptor() ([]byte, []int)
Deprecated: Use ReinitConfigResponse.ProtoReflect.Descriptor instead.
func (*ReinitConfigResponse) MarshalToSizedBufferVT ¶ added in v0.11.0
func (m *ReinitConfigResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*ReinitConfigResponse) MarshalToVT ¶ added in v0.11.0
func (m *ReinitConfigResponse) MarshalToVT(dAtA []byte) (int, error)
func (*ReinitConfigResponse) MarshalVT ¶ added in v0.11.0
func (m *ReinitConfigResponse) MarshalVT() (dAtA []byte, err error)
func (*ReinitConfigResponse) ProtoMessage ¶
func (*ReinitConfigResponse) ProtoMessage()
func (*ReinitConfigResponse) ProtoReflect ¶ added in v0.11.0
func (x *ReinitConfigResponse) ProtoReflect() protoreflect.Message
func (*ReinitConfigResponse) Reset ¶
func (x *ReinitConfigResponse) Reset()
func (*ReinitConfigResponse) SizeVT ¶ added in v0.11.0
func (m *ReinitConfigResponse) SizeVT() (n int)
func (*ReinitConfigResponse) String ¶
func (x *ReinitConfigResponse) String() string
func (*ReinitConfigResponse) UnmarshalVT ¶ added in v0.11.0
func (m *ReinitConfigResponse) UnmarshalVT(dAtA []byte) error
type RunMysqlUpgradeRequest ¶
type RunMysqlUpgradeRequest struct {
// contains filtered or unexported fields
}
func (*RunMysqlUpgradeRequest) CloneMessageVT ¶ added in v0.18.0
func (m *RunMysqlUpgradeRequest) CloneMessageVT() proto.Message
func (*RunMysqlUpgradeRequest) CloneVT ¶ added in v0.18.0
func (m *RunMysqlUpgradeRequest) CloneVT() *RunMysqlUpgradeRequest
func (*RunMysqlUpgradeRequest) Descriptor
deprecated
func (*RunMysqlUpgradeRequest) Descriptor() ([]byte, []int)
Deprecated: Use RunMysqlUpgradeRequest.ProtoReflect.Descriptor instead.
func (*RunMysqlUpgradeRequest) MarshalToSizedBufferVT ¶ added in v0.11.0
func (m *RunMysqlUpgradeRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*RunMysqlUpgradeRequest) MarshalToVT ¶ added in v0.11.0
func (m *RunMysqlUpgradeRequest) MarshalToVT(dAtA []byte) (int, error)
func (*RunMysqlUpgradeRequest) MarshalVT ¶ added in v0.11.0
func (m *RunMysqlUpgradeRequest) MarshalVT() (dAtA []byte, err error)
func (*RunMysqlUpgradeRequest) ProtoMessage ¶
func (*RunMysqlUpgradeRequest) ProtoMessage()
func (*RunMysqlUpgradeRequest) ProtoReflect ¶ added in v0.11.0
func (x *RunMysqlUpgradeRequest) ProtoReflect() protoreflect.Message
func (*RunMysqlUpgradeRequest) Reset ¶
func (x *RunMysqlUpgradeRequest) Reset()
func (*RunMysqlUpgradeRequest) SizeVT ¶ added in v0.11.0
func (m *RunMysqlUpgradeRequest) SizeVT() (n int)
func (*RunMysqlUpgradeRequest) String ¶
func (x *RunMysqlUpgradeRequest) String() string
func (*RunMysqlUpgradeRequest) UnmarshalVT ¶ added in v0.11.0
func (m *RunMysqlUpgradeRequest) UnmarshalVT(dAtA []byte) error
type RunMysqlUpgradeResponse ¶
type RunMysqlUpgradeResponse struct {
// contains filtered or unexported fields
}
func (*RunMysqlUpgradeResponse) CloneMessageVT ¶ added in v0.18.0
func (m *RunMysqlUpgradeResponse) CloneMessageVT() proto.Message
func (*RunMysqlUpgradeResponse) CloneVT ¶ added in v0.18.0
func (m *RunMysqlUpgradeResponse) CloneVT() *RunMysqlUpgradeResponse
func (*RunMysqlUpgradeResponse) Descriptor
deprecated
func (*RunMysqlUpgradeResponse) Descriptor() ([]byte, []int)
Deprecated: Use RunMysqlUpgradeResponse.ProtoReflect.Descriptor instead.
func (*RunMysqlUpgradeResponse) MarshalToSizedBufferVT ¶ added in v0.11.0
func (m *RunMysqlUpgradeResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*RunMysqlUpgradeResponse) MarshalToVT ¶ added in v0.11.0
func (m *RunMysqlUpgradeResponse) MarshalToVT(dAtA []byte) (int, error)
func (*RunMysqlUpgradeResponse) MarshalVT ¶ added in v0.11.0
func (m *RunMysqlUpgradeResponse) MarshalVT() (dAtA []byte, err error)
func (*RunMysqlUpgradeResponse) ProtoMessage ¶
func (*RunMysqlUpgradeResponse) ProtoMessage()
func (*RunMysqlUpgradeResponse) ProtoReflect ¶ added in v0.11.0
func (x *RunMysqlUpgradeResponse) ProtoReflect() protoreflect.Message
func (*RunMysqlUpgradeResponse) Reset ¶
func (x *RunMysqlUpgradeResponse) Reset()
func (*RunMysqlUpgradeResponse) SizeVT ¶ added in v0.11.0
func (m *RunMysqlUpgradeResponse) SizeVT() (n int)
func (*RunMysqlUpgradeResponse) String ¶
func (x *RunMysqlUpgradeResponse) String() string
func (*RunMysqlUpgradeResponse) UnmarshalVT ¶ added in v0.11.0
func (m *RunMysqlUpgradeResponse) UnmarshalVT(dAtA []byte) error
type ShutdownRequest ¶
type ShutdownRequest struct { WaitForMysqld bool `protobuf:"varint,1,opt,name=wait_for_mysqld,json=waitForMysqld,proto3" json:"wait_for_mysqld,omitempty"` MysqlShutdownTimeout *vttime.Duration `protobuf:"bytes,2,opt,name=mysql_shutdown_timeout,json=mysqlShutdownTimeout,proto3" json:"mysql_shutdown_timeout,omitempty"` // contains filtered or unexported fields }
func (*ShutdownRequest) CloneMessageVT ¶ added in v0.18.0
func (m *ShutdownRequest) CloneMessageVT() proto.Message
func (*ShutdownRequest) CloneVT ¶ added in v0.18.0
func (m *ShutdownRequest) CloneVT() *ShutdownRequest
func (*ShutdownRequest) Descriptor
deprecated
func (*ShutdownRequest) Descriptor() ([]byte, []int)
Deprecated: Use ShutdownRequest.ProtoReflect.Descriptor instead.
func (*ShutdownRequest) GetMysqlShutdownTimeout ¶ added in v0.19.0
func (x *ShutdownRequest) GetMysqlShutdownTimeout() *vttime.Duration
func (*ShutdownRequest) GetWaitForMysqld ¶
func (x *ShutdownRequest) GetWaitForMysqld() bool
func (*ShutdownRequest) MarshalToSizedBufferVT ¶ added in v0.11.0
func (m *ShutdownRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*ShutdownRequest) MarshalToVT ¶ added in v0.11.0
func (m *ShutdownRequest) MarshalToVT(dAtA []byte) (int, error)
func (*ShutdownRequest) MarshalVT ¶ added in v0.11.0
func (m *ShutdownRequest) MarshalVT() (dAtA []byte, err error)
func (*ShutdownRequest) ProtoMessage ¶
func (*ShutdownRequest) ProtoMessage()
func (*ShutdownRequest) ProtoReflect ¶ added in v0.11.0
func (x *ShutdownRequest) ProtoReflect() protoreflect.Message
func (*ShutdownRequest) Reset ¶
func (x *ShutdownRequest) Reset()
func (*ShutdownRequest) SizeVT ¶ added in v0.11.0
func (m *ShutdownRequest) SizeVT() (n int)
func (*ShutdownRequest) String ¶
func (x *ShutdownRequest) String() string
func (*ShutdownRequest) UnmarshalVT ¶ added in v0.11.0
func (m *ShutdownRequest) UnmarshalVT(dAtA []byte) error
type ShutdownResponse ¶
type ShutdownResponse struct {
// contains filtered or unexported fields
}
func (*ShutdownResponse) CloneMessageVT ¶ added in v0.18.0
func (m *ShutdownResponse) CloneMessageVT() proto.Message
func (*ShutdownResponse) CloneVT ¶ added in v0.18.0
func (m *ShutdownResponse) CloneVT() *ShutdownResponse
func (*ShutdownResponse) Descriptor
deprecated
func (*ShutdownResponse) Descriptor() ([]byte, []int)
Deprecated: Use ShutdownResponse.ProtoReflect.Descriptor instead.
func (*ShutdownResponse) MarshalToSizedBufferVT ¶ added in v0.11.0
func (m *ShutdownResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*ShutdownResponse) MarshalToVT ¶ added in v0.11.0
func (m *ShutdownResponse) MarshalToVT(dAtA []byte) (int, error)
func (*ShutdownResponse) MarshalVT ¶ added in v0.11.0
func (m *ShutdownResponse) MarshalVT() (dAtA []byte, err error)
func (*ShutdownResponse) ProtoMessage ¶
func (*ShutdownResponse) ProtoMessage()
func (*ShutdownResponse) ProtoReflect ¶ added in v0.11.0
func (x *ShutdownResponse) ProtoReflect() protoreflect.Message
func (*ShutdownResponse) Reset ¶
func (x *ShutdownResponse) Reset()
func (*ShutdownResponse) SizeVT ¶ added in v0.11.0
func (m *ShutdownResponse) SizeVT() (n int)
func (*ShutdownResponse) String ¶
func (x *ShutdownResponse) String() string
func (*ShutdownResponse) UnmarshalVT ¶ added in v0.11.0
func (m *ShutdownResponse) UnmarshalVT(dAtA []byte) error
type StartRequest ¶
type StartRequest struct { MysqldArgs []string `protobuf:"bytes,1,rep,name=mysqld_args,json=mysqldArgs,proto3" json:"mysqld_args,omitempty"` // contains filtered or unexported fields }
func (*StartRequest) CloneMessageVT ¶ added in v0.18.0
func (m *StartRequest) CloneMessageVT() proto.Message
func (*StartRequest) CloneVT ¶ added in v0.18.0
func (m *StartRequest) CloneVT() *StartRequest
func (*StartRequest) Descriptor
deprecated
func (*StartRequest) Descriptor() ([]byte, []int)
Deprecated: Use StartRequest.ProtoReflect.Descriptor instead.
func (*StartRequest) GetMysqldArgs ¶
func (x *StartRequest) GetMysqldArgs() []string
func (*StartRequest) MarshalToSizedBufferVT ¶ added in v0.11.0
func (m *StartRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*StartRequest) MarshalToVT ¶ added in v0.11.0
func (m *StartRequest) MarshalToVT(dAtA []byte) (int, error)
func (*StartRequest) MarshalVT ¶ added in v0.11.0
func (m *StartRequest) MarshalVT() (dAtA []byte, err error)
func (*StartRequest) ProtoMessage ¶
func (*StartRequest) ProtoMessage()
func (*StartRequest) ProtoReflect ¶ added in v0.11.0
func (x *StartRequest) ProtoReflect() protoreflect.Message
func (*StartRequest) Reset ¶
func (x *StartRequest) Reset()
func (*StartRequest) SizeVT ¶ added in v0.11.0
func (m *StartRequest) SizeVT() (n int)
func (*StartRequest) String ¶
func (x *StartRequest) String() string
func (*StartRequest) UnmarshalVT ¶ added in v0.11.0
func (m *StartRequest) UnmarshalVT(dAtA []byte) error
type StartResponse ¶
type StartResponse struct {
// contains filtered or unexported fields
}
func (*StartResponse) CloneMessageVT ¶ added in v0.18.0
func (m *StartResponse) CloneMessageVT() proto.Message
func (*StartResponse) CloneVT ¶ added in v0.18.0
func (m *StartResponse) CloneVT() *StartResponse
func (*StartResponse) Descriptor
deprecated
func (*StartResponse) Descriptor() ([]byte, []int)
Deprecated: Use StartResponse.ProtoReflect.Descriptor instead.
func (*StartResponse) MarshalToSizedBufferVT ¶ added in v0.11.0
func (m *StartResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*StartResponse) MarshalToVT ¶ added in v0.11.0
func (m *StartResponse) MarshalToVT(dAtA []byte) (int, error)
func (*StartResponse) MarshalVT ¶ added in v0.11.0
func (m *StartResponse) MarshalVT() (dAtA []byte, err error)
func (*StartResponse) ProtoMessage ¶
func (*StartResponse) ProtoMessage()
func (*StartResponse) ProtoReflect ¶ added in v0.11.0
func (x *StartResponse) ProtoReflect() protoreflect.Message
func (*StartResponse) Reset ¶
func (x *StartResponse) Reset()
func (*StartResponse) SizeVT ¶ added in v0.11.0
func (m *StartResponse) SizeVT() (n int)
func (*StartResponse) String ¶
func (x *StartResponse) String() string
func (*StartResponse) UnmarshalVT ¶ added in v0.11.0
func (m *StartResponse) UnmarshalVT(dAtA []byte) error
type UnimplementedMysqlCtlServer ¶
type UnimplementedMysqlCtlServer struct { }
UnimplementedMysqlCtlServer must be embedded to have forward compatible implementations.
func (UnimplementedMysqlCtlServer) ApplyBinlogFile ¶ added in v0.17.0
func (UnimplementedMysqlCtlServer) ApplyBinlogFile(context.Context, *ApplyBinlogFileRequest) (*ApplyBinlogFileResponse, error)
func (UnimplementedMysqlCtlServer) ReadBinlogFilesTimestamps ¶ added in v0.18.0
func (UnimplementedMysqlCtlServer) ReadBinlogFilesTimestamps(context.Context, *ReadBinlogFilesTimestampsRequest) (*ReadBinlogFilesTimestampsResponse, error)
func (UnimplementedMysqlCtlServer) RefreshConfig ¶
func (UnimplementedMysqlCtlServer) RefreshConfig(context.Context, *RefreshConfigRequest) (*RefreshConfigResponse, error)
func (UnimplementedMysqlCtlServer) ReinitConfig ¶
func (UnimplementedMysqlCtlServer) ReinitConfig(context.Context, *ReinitConfigRequest) (*ReinitConfigResponse, error)
func (UnimplementedMysqlCtlServer) RunMysqlUpgrade ¶
func (UnimplementedMysqlCtlServer) RunMysqlUpgrade(context.Context, *RunMysqlUpgradeRequest) (*RunMysqlUpgradeResponse, error)
func (UnimplementedMysqlCtlServer) Shutdown ¶
func (UnimplementedMysqlCtlServer) Shutdown(context.Context, *ShutdownRequest) (*ShutdownResponse, error)
func (UnimplementedMysqlCtlServer) Start ¶
func (UnimplementedMysqlCtlServer) Start(context.Context, *StartRequest) (*StartResponse, error)
func (UnimplementedMysqlCtlServer) VersionString ¶ added in v0.18.0
func (UnimplementedMysqlCtlServer) VersionString(context.Context, *VersionStringRequest) (*VersionStringResponse, error)
type UnsafeMysqlCtlServer ¶ added in v0.11.0
type UnsafeMysqlCtlServer interface {
// contains filtered or unexported methods
}
UnsafeMysqlCtlServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MysqlCtlServer will result in compilation errors.
type VersionStringRequest ¶ added in v0.18.0
type VersionStringRequest struct {
// contains filtered or unexported fields
}
func (*VersionStringRequest) CloneMessageVT ¶ added in v0.18.0
func (m *VersionStringRequest) CloneMessageVT() proto.Message
func (*VersionStringRequest) CloneVT ¶ added in v0.18.0
func (m *VersionStringRequest) CloneVT() *VersionStringRequest
func (*VersionStringRequest) Descriptor
deprecated
added in
v0.18.0
func (*VersionStringRequest) Descriptor() ([]byte, []int)
Deprecated: Use VersionStringRequest.ProtoReflect.Descriptor instead.
func (*VersionStringRequest) MarshalToSizedBufferVT ¶ added in v0.18.0
func (m *VersionStringRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*VersionStringRequest) MarshalToVT ¶ added in v0.18.0
func (m *VersionStringRequest) MarshalToVT(dAtA []byte) (int, error)
func (*VersionStringRequest) MarshalVT ¶ added in v0.18.0
func (m *VersionStringRequest) MarshalVT() (dAtA []byte, err error)
func (*VersionStringRequest) ProtoMessage ¶ added in v0.18.0
func (*VersionStringRequest) ProtoMessage()
func (*VersionStringRequest) ProtoReflect ¶ added in v0.18.0
func (x *VersionStringRequest) ProtoReflect() protoreflect.Message
func (*VersionStringRequest) Reset ¶ added in v0.18.0
func (x *VersionStringRequest) Reset()
func (*VersionStringRequest) SizeVT ¶ added in v0.18.0
func (m *VersionStringRequest) SizeVT() (n int)
func (*VersionStringRequest) String ¶ added in v0.18.0
func (x *VersionStringRequest) String() string
func (*VersionStringRequest) UnmarshalVT ¶ added in v0.18.0
func (m *VersionStringRequest) UnmarshalVT(dAtA []byte) error
type VersionStringResponse ¶ added in v0.18.0
type VersionStringResponse struct { Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"` // contains filtered or unexported fields }
func (*VersionStringResponse) CloneMessageVT ¶ added in v0.18.0
func (m *VersionStringResponse) CloneMessageVT() proto.Message
func (*VersionStringResponse) CloneVT ¶ added in v0.18.0
func (m *VersionStringResponse) CloneVT() *VersionStringResponse
func (*VersionStringResponse) Descriptor
deprecated
added in
v0.18.0
func (*VersionStringResponse) Descriptor() ([]byte, []int)
Deprecated: Use VersionStringResponse.ProtoReflect.Descriptor instead.
func (*VersionStringResponse) GetVersion ¶ added in v0.18.0
func (x *VersionStringResponse) GetVersion() string
func (*VersionStringResponse) MarshalToSizedBufferVT ¶ added in v0.18.0
func (m *VersionStringResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*VersionStringResponse) MarshalToVT ¶ added in v0.18.0
func (m *VersionStringResponse) MarshalToVT(dAtA []byte) (int, error)
func (*VersionStringResponse) MarshalVT ¶ added in v0.18.0
func (m *VersionStringResponse) MarshalVT() (dAtA []byte, err error)
func (*VersionStringResponse) ProtoMessage ¶ added in v0.18.0
func (*VersionStringResponse) ProtoMessage()
func (*VersionStringResponse) ProtoReflect ¶ added in v0.18.0
func (x *VersionStringResponse) ProtoReflect() protoreflect.Message
func (*VersionStringResponse) Reset ¶ added in v0.18.0
func (x *VersionStringResponse) Reset()
func (*VersionStringResponse) SizeVT ¶ added in v0.18.0
func (m *VersionStringResponse) SizeVT() (n int)
func (*VersionStringResponse) String ¶ added in v0.18.0
func (x *VersionStringResponse) String() string
func (*VersionStringResponse) UnmarshalVT ¶ added in v0.18.0
func (m *VersionStringResponse) UnmarshalVT(dAtA []byte) error