Documentation
      ¶
    
    
  
    
  
    Index ¶
- Constants
 - Variables
 - func RegisterMysqlOperationServer(s grpc.ServiceRegistrar, srv MysqlOperationServer)
 - func RegistryGrpcApp()
 - type ArchMode
 - type CloneRequest
 - func (*CloneRequest) Descriptor() ([]byte, []int)deprecated
 - func (x *CloneRequest) GetPassword() string
 - func (x *CloneRequest) GetSocketFile() string
 - func (x *CloneRequest) GetSourceClonePassword() string
 - func (x *CloneRequest) GetSourceCloneUser() string
 - func (x *CloneRequest) GetSourceHost() string
 - func (x *CloneRequest) GetSourcePort() int64
 - func (x *CloneRequest) GetUsername() string
 - func (*CloneRequest) ProtoMessage()
 - func (x *CloneRequest) ProtoReflect() protoreflect.Message
 - func (x *CloneRequest) Reset()
 - func (x *CloneRequest) String() string
 
- type GtidPurgeRequest
 - func (*GtidPurgeRequest) Descriptor() ([]byte, []int)deprecated
 - func (x *GtidPurgeRequest) GetArchMode() ArchMode
 - func (x *GtidPurgeRequest) GetPassword() string
 - func (x *GtidPurgeRequest) GetSocketFile() string
 - func (x *GtidPurgeRequest) GetUsername() string
 - func (*GtidPurgeRequest) ProtoMessage()
 - func (x *GtidPurgeRequest) ProtoReflect() protoreflect.Message
 - func (x *GtidPurgeRequest) Reset()
 - func (x *GtidPurgeRequest) String() string
 
- type LocalStorage
 - type LogicalBackupMode
 - func (LogicalBackupMode) Descriptor() protoreflect.EnumDescriptor
 - func (x LogicalBackupMode) Enum() *LogicalBackupMode
 - func (LogicalBackupMode) EnumDescriptor() ([]byte, []int)deprecated
 - func (x LogicalBackupMode) Number() protoreflect.EnumNumber
 - func (x LogicalBackupMode) String() string
 - func (LogicalBackupMode) Type() protoreflect.EnumType
 
- type LogicalBackupRequest
 - func (*LogicalBackupRequest) Descriptor() ([]byte, []int)deprecated
 - func (x *LogicalBackupRequest) GetBackupFile() string
 - func (x *LogicalBackupRequest) GetConfFile() string
 - func (x *LogicalBackupRequest) GetDatabase() string
 - func (x *LogicalBackupRequest) GetLocalStorage() *LocalStorage
 - func (x *LogicalBackupRequest) GetLogicalBackupMode() LogicalBackupMode
 - func (x *LogicalBackupRequest) GetPassword() string
 - func (x *LogicalBackupRequest) GetS3Storage() *S3Storage
 - func (x *LogicalBackupRequest) GetSocketFile() string
 - func (x *LogicalBackupRequest) GetStorageType() isLogicalBackupRequest_StorageType
 - func (x *LogicalBackupRequest) GetTable() string
 - func (x *LogicalBackupRequest) GetUsername() string
 - func (*LogicalBackupRequest) ProtoMessage()
 - func (x *LogicalBackupRequest) ProtoReflect() protoreflect.Message
 - func (x *LogicalBackupRequest) Reset()
 - func (x *LogicalBackupRequest) String() string
 
- type LogicalBackupRequest_LocalStorage
 - type LogicalBackupRequest_S3Storage
 - type MysqlOperationClient
 - type MysqlOperationServer
 - type PhysicalBackupRequest
 - func (*PhysicalBackupRequest) Descriptor() ([]byte, []int)deprecated
 - func (x *PhysicalBackupRequest) GetBackupFile() string
 - func (x *PhysicalBackupRequest) GetConfFile() string
 - func (x *PhysicalBackupRequest) GetLocalStorage() *LocalStorage
 - func (x *PhysicalBackupRequest) GetParallel() int64
 - func (x *PhysicalBackupRequest) GetPassword() string
 - func (x *PhysicalBackupRequest) GetPhysicalBackupTool() PhysicalBackupTool
 - func (x *PhysicalBackupRequest) GetS3Storage() *S3Storage
 - func (x *PhysicalBackupRequest) GetSocketFile() string
 - func (x *PhysicalBackupRequest) GetStorageType() isPhysicalBackupRequest_StorageType
 - func (x *PhysicalBackupRequest) GetUsername() string
 - func (*PhysicalBackupRequest) ProtoMessage()
 - func (x *PhysicalBackupRequest) ProtoReflect() protoreflect.Message
 - func (x *PhysicalBackupRequest) Reset()
 - func (x *PhysicalBackupRequest) String() string
 
- type PhysicalBackupRequest_LocalStorage
 - type PhysicalBackupRequest_S3Storage
 - type PhysicalBackupTool
 - func (PhysicalBackupTool) Descriptor() protoreflect.EnumDescriptor
 - func (x PhysicalBackupTool) Enum() *PhysicalBackupTool
 - func (PhysicalBackupTool) EnumDescriptor() ([]byte, []int)deprecated
 - func (x PhysicalBackupTool) Number() protoreflect.EnumNumber
 - func (x PhysicalBackupTool) String() string
 - func (PhysicalBackupTool) Type() protoreflect.EnumType
 
- type Response
 - type RestoreRequest
 - func (*RestoreRequest) Descriptor() ([]byte, []int)deprecated
 - func (x *RestoreRequest) GetBackupFile() string
 - func (x *RestoreRequest) GetLocalStorage() *LocalStorage
 - func (x *RestoreRequest) GetParallel() int64
 - func (x *RestoreRequest) GetS3Storage() *S3Storage
 - func (x *RestoreRequest) GetStorageType() isRestoreRequest_StorageType
 - func (*RestoreRequest) ProtoMessage()
 - func (x *RestoreRequest) ProtoReflect() protoreflect.Message
 - func (x *RestoreRequest) Reset()
 - func (x *RestoreRequest) String() string
 
- type RestoreRequest_LocalStorage
 - type RestoreRequest_S3Storage
 - type S3Storage
 - func (*S3Storage) Descriptor() ([]byte, []int)deprecated
 - func (x *S3Storage) GetAccessKey() string
 - func (x *S3Storage) GetBucket() string
 - func (x *S3Storage) GetEndpoint() string
 - func (x *S3Storage) GetSecretKey() string
 - func (*S3Storage) ProtoMessage()
 - func (x *S3Storage) ProtoReflect() protoreflect.Message
 - func (x *S3Storage) Reset()
 - func (x *S3Storage) String() string
 
- type SetVariableRequest
 - func (*SetVariableRequest) Descriptor() ([]byte, []int)deprecated
 - func (x *SetVariableRequest) GetKey() string
 - func (x *SetVariableRequest) GetPassword() string
 - func (x *SetVariableRequest) GetSocketFile() string
 - func (x *SetVariableRequest) GetUsername() string
 - func (x *SetVariableRequest) GetValue() string
 - func (*SetVariableRequest) ProtoMessage()
 - func (x *SetVariableRequest) ProtoReflect() protoreflect.Message
 - func (x *SetVariableRequest) Reset()
 - func (x *SetVariableRequest) String() string
 
- type UnimplementedMysqlOperationServer
 - func (UnimplementedMysqlOperationServer) Clone(context.Context, *CloneRequest) (*Response, error)
 - func (UnimplementedMysqlOperationServer) GtidPurge(context.Context, *GtidPurgeRequest) (*Response, error)
 - func (UnimplementedMysqlOperationServer) LogicalBackup(context.Context, *LogicalBackupRequest) (*Response, error)
 - func (UnimplementedMysqlOperationServer) PhysicalBackup(context.Context, *PhysicalBackupRequest) (*Response, error)
 - func (UnimplementedMysqlOperationServer) Restore(context.Context, *RestoreRequest) (*Response, error)
 - func (UnimplementedMysqlOperationServer) SetVariable(context.Context, *SetVariableRequest) (*Response, error)
 
- type UnsafeMysqlOperationServer
 
Constants ¶
const ( SetValidDonorListSql = `SET GLOBAL clone_valid_donor_list = ?;` ExecCloneSql = `CLONE INSTANCE FROM %s@'%s':%d IDENTIFIED BY '%s';` )
Variables ¶
var ( PhysicalBackupTool_name = map[int32]string{ 0: "Xtrabackup", 1: "Meb", } PhysicalBackupTool_value = map[string]int32{ "Xtrabackup": 0, "Meb": 1, } )
Enum value maps for PhysicalBackupTool.
var ( LogicalBackupMode_name = map[int32]string{ 0: "Full", 1: "Database", 2: "Table", } LogicalBackupMode_value = map[string]int32{ "Full": 0, "Database": 1, "Table": 2, } )
Enum value maps for LogicalBackupMode.
var ( ArchMode_name = map[int32]string{ 0: "Replication", 1: "GroupReplication", } ArchMode_value = map[string]int32{ "Replication": 0, "GroupReplication": 1, } )
Enum value maps for ArchMode.
var File_pkg_agent_app_mysql_pb_mysql_proto protoreflect.FileDescriptor
    var MysqlOperation_ServiceDesc = grpc.ServiceDesc{ ServiceName: "mysql.MysqlOperation", HandlerType: (*MysqlOperationServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Clone", Handler: _MysqlOperation_Clone_Handler, }, { MethodName: "PhysicalBackup", Handler: _MysqlOperation_PhysicalBackup_Handler, }, { MethodName: "LogicalBackup", Handler: _MysqlOperation_LogicalBackup_Handler, }, { MethodName: "Restore", Handler: _MysqlOperation_Restore_Handler, }, { MethodName: "GtidPurge", Handler: _MysqlOperation_GtidPurge_Handler, }, { MethodName: "SetVariable", Handler: _MysqlOperation_SetVariable_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "pkg/agent/app/mysql/pb/mysql.proto", }
MysqlOperation_ServiceDesc is the grpc.ServiceDesc for MysqlOperation service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterMysqlOperationServer ¶
func RegisterMysqlOperationServer(s grpc.ServiceRegistrar, srv MysqlOperationServer)
func RegistryGrpcApp ¶
func RegistryGrpcApp()
Types ¶
type ArchMode ¶
type ArchMode int32
func (ArchMode) Descriptor ¶
func (ArchMode) Descriptor() protoreflect.EnumDescriptor
        
          
            func (ArchMode) EnumDescriptor
            deprecated
            
          
  
    
  
      
      
    func (ArchMode) Number ¶
func (x ArchMode) Number() protoreflect.EnumNumber
func (ArchMode) Type ¶
func (ArchMode) Type() protoreflect.EnumType
type CloneRequest ¶
type CloneRequest struct {
	SourceCloneUser     string `protobuf:"bytes,1,opt,name=source_clone_user,json=sourceCloneUser,proto3" json:"source_clone_user,omitempty"`
	SourceClonePassword string `protobuf:"bytes,2,opt,name=source_clone_password,json=sourceClonePassword,proto3" json:"source_clone_password,omitempty"`
	SourceHost          string `protobuf:"bytes,3,opt,name=source_host,json=sourceHost,proto3" json:"source_host,omitempty"`
	SourcePort          int64  `protobuf:"varint,4,opt,name=source_port,json=sourcePort,proto3" json:"source_port,omitempty"`
	SocketFile          string `protobuf:"bytes,5,opt,name=socket_file,json=socketFile,proto3" json:"socket_file,omitempty"`
	Username            string `protobuf:"bytes,6,opt,name=username,proto3" json:"username,omitempty"`
	Password            string `protobuf:"bytes,7,opt,name=password,proto3" json:"password,omitempty"`
	// contains filtered or unexported fields
}
    
        
          
            func (*CloneRequest) Descriptor
            deprecated
            
          
  
    
  
      
      func (*CloneRequest) Descriptor() ([]byte, []int)
Deprecated: Use CloneRequest.ProtoReflect.Descriptor instead.
func (*CloneRequest) GetPassword ¶
func (x *CloneRequest) GetPassword() string
func (*CloneRequest) GetSocketFile ¶
func (x *CloneRequest) GetSocketFile() string
func (*CloneRequest) GetSourceClonePassword ¶
func (x *CloneRequest) GetSourceClonePassword() string
func (*CloneRequest) GetSourceCloneUser ¶
func (x *CloneRequest) GetSourceCloneUser() string
func (*CloneRequest) GetSourceHost ¶
func (x *CloneRequest) GetSourceHost() string
func (*CloneRequest) GetSourcePort ¶
func (x *CloneRequest) GetSourcePort() int64
func (*CloneRequest) GetUsername ¶
func (x *CloneRequest) GetUsername() string
func (*CloneRequest) ProtoMessage ¶
func (*CloneRequest) ProtoMessage()
func (*CloneRequest) ProtoReflect ¶
func (x *CloneRequest) ProtoReflect() protoreflect.Message
func (*CloneRequest) Reset ¶
func (x *CloneRequest) Reset()
func (*CloneRequest) String ¶
func (x *CloneRequest) String() string
type GtidPurgeRequest ¶
type GtidPurgeRequest struct {
	SocketFile string   `protobuf:"bytes,1,opt,name=socket_file,json=socketFile,proto3" json:"socket_file,omitempty"`
	Username   string   `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty"`
	Password   string   `protobuf:"bytes,3,opt,name=password,proto3" json:"password,omitempty"`
	ArchMode   ArchMode `protobuf:"varint,4,opt,name=arch_mode,json=archMode,proto3,enum=mysql.ArchMode" json:"arch_mode,omitempty"`
	// contains filtered or unexported fields
}
    
        
          
            func (*GtidPurgeRequest) Descriptor
            deprecated
            
          
  
    
  
      
      func (*GtidPurgeRequest) Descriptor() ([]byte, []int)
Deprecated: Use GtidPurgeRequest.ProtoReflect.Descriptor instead.
func (*GtidPurgeRequest) GetArchMode ¶
func (x *GtidPurgeRequest) GetArchMode() ArchMode
func (*GtidPurgeRequest) GetPassword ¶
func (x *GtidPurgeRequest) GetPassword() string
func (*GtidPurgeRequest) GetSocketFile ¶
func (x *GtidPurgeRequest) GetSocketFile() string
func (*GtidPurgeRequest) GetUsername ¶
func (x *GtidPurgeRequest) GetUsername() string
func (*GtidPurgeRequest) ProtoMessage ¶
func (*GtidPurgeRequest) ProtoMessage()
func (*GtidPurgeRequest) ProtoReflect ¶
func (x *GtidPurgeRequest) ProtoReflect() protoreflect.Message
func (*GtidPurgeRequest) Reset ¶
func (x *GtidPurgeRequest) Reset()
func (*GtidPurgeRequest) String ¶
func (x *GtidPurgeRequest) String() string
type LocalStorage ¶
type LocalStorage struct {
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}
    
        
          
            func (*LocalStorage) Descriptor
            deprecated
            
          
  
    
  
      
      func (*LocalStorage) Descriptor() ([]byte, []int)
Deprecated: Use LocalStorage.ProtoReflect.Descriptor instead.
func (*LocalStorage) GetPath ¶
func (x *LocalStorage) GetPath() string
func (*LocalStorage) ProtoMessage ¶
func (*LocalStorage) ProtoMessage()
func (*LocalStorage) ProtoReflect ¶
func (x *LocalStorage) ProtoReflect() protoreflect.Message
func (*LocalStorage) Reset ¶
func (x *LocalStorage) Reset()
func (*LocalStorage) String ¶
func (x *LocalStorage) String() string
type LogicalBackupMode ¶
type LogicalBackupMode int32
const ( LogicalBackupMode_Full LogicalBackupMode = 0 LogicalBackupMode_Database LogicalBackupMode = 1 LogicalBackupMode_Table LogicalBackupMode = 2 )
func (LogicalBackupMode) Descriptor ¶
func (LogicalBackupMode) Descriptor() protoreflect.EnumDescriptor
func (LogicalBackupMode) Enum ¶
func (x LogicalBackupMode) Enum() *LogicalBackupMode
        
          
            func (LogicalBackupMode) EnumDescriptor
            deprecated
            
          
  
    
  
      
      func (LogicalBackupMode) EnumDescriptor() ([]byte, []int)
Deprecated: Use LogicalBackupMode.Descriptor instead.
func (LogicalBackupMode) Number ¶
func (x LogicalBackupMode) Number() protoreflect.EnumNumber
func (LogicalBackupMode) String ¶
func (x LogicalBackupMode) String() string
func (LogicalBackupMode) Type ¶
func (LogicalBackupMode) Type() protoreflect.EnumType
type LogicalBackupRequest ¶
type LogicalBackupRequest struct {
	BackupFile        string            `protobuf:"bytes,1,opt,name=backup_file,json=backupFile,proto3" json:"backup_file,omitempty"`
	ConfFile          string            `protobuf:"bytes,2,opt,name=conf_file,json=confFile,proto3" json:"conf_file,omitempty"`
	SocketFile        string            `protobuf:"bytes,3,opt,name=socket_file,json=socketFile,proto3" json:"socket_file,omitempty"`
	Username          string            `protobuf:"bytes,4,opt,name=username,proto3" json:"username,omitempty"`
	Password          string            `protobuf:"bytes,5,opt,name=password,proto3" json:"password,omitempty"`
	Database          string            `protobuf:"bytes,6,opt,name=database,proto3" json:"database,omitempty"`
	Table             string            `protobuf:"bytes,7,opt,name=table,proto3" json:"table,omitempty"`
	LogicalBackupMode LogicalBackupMode `` /* 144-byte string literal not displayed */
	// Types that are valid to be assigned to StorageType:
	//
	//	*LogicalBackupRequest_S3Storage
	//	*LogicalBackupRequest_LocalStorage
	StorageType isLogicalBackupRequest_StorageType `protobuf_oneof:"StorageType"`
	// contains filtered or unexported fields
}
    
        
          
            func (*LogicalBackupRequest) Descriptor
            deprecated
            
          
  
    
  
      
      func (*LogicalBackupRequest) Descriptor() ([]byte, []int)
Deprecated: Use LogicalBackupRequest.ProtoReflect.Descriptor instead.
func (*LogicalBackupRequest) GetBackupFile ¶
func (x *LogicalBackupRequest) GetBackupFile() string
func (*LogicalBackupRequest) GetConfFile ¶
func (x *LogicalBackupRequest) GetConfFile() string
func (*LogicalBackupRequest) GetDatabase ¶
func (x *LogicalBackupRequest) GetDatabase() string
func (*LogicalBackupRequest) GetLocalStorage ¶
func (x *LogicalBackupRequest) GetLocalStorage() *LocalStorage
func (*LogicalBackupRequest) GetLogicalBackupMode ¶
func (x *LogicalBackupRequest) GetLogicalBackupMode() LogicalBackupMode
func (*LogicalBackupRequest) GetPassword ¶
func (x *LogicalBackupRequest) GetPassword() string
func (*LogicalBackupRequest) GetS3Storage ¶
func (x *LogicalBackupRequest) GetS3Storage() *S3Storage
func (*LogicalBackupRequest) GetSocketFile ¶
func (x *LogicalBackupRequest) GetSocketFile() string
func (*LogicalBackupRequest) GetStorageType ¶
func (x *LogicalBackupRequest) GetStorageType() isLogicalBackupRequest_StorageType
func (*LogicalBackupRequest) GetTable ¶
func (x *LogicalBackupRequest) GetTable() string
func (*LogicalBackupRequest) GetUsername ¶
func (x *LogicalBackupRequest) GetUsername() string
func (*LogicalBackupRequest) ProtoMessage ¶
func (*LogicalBackupRequest) ProtoMessage()
func (*LogicalBackupRequest) ProtoReflect ¶
func (x *LogicalBackupRequest) ProtoReflect() protoreflect.Message
func (*LogicalBackupRequest) Reset ¶
func (x *LogicalBackupRequest) Reset()
func (*LogicalBackupRequest) String ¶
func (x *LogicalBackupRequest) String() string
type LogicalBackupRequest_LocalStorage ¶
type LogicalBackupRequest_LocalStorage struct {
	LocalStorage *LocalStorage `protobuf:"bytes,10,opt,name=local_storage,json=localStorage,proto3,oneof"`
}
    type LogicalBackupRequest_S3Storage ¶
type LogicalBackupRequest_S3Storage struct {
	S3Storage *S3Storage `protobuf:"bytes,9,opt,name=s3_storage,json=s3Storage,proto3,oneof"`
}
    type MysqlOperationClient ¶
type MysqlOperationClient interface {
	Clone(ctx context.Context, in *CloneRequest, opts ...grpc.CallOption) (*Response, error)
	PhysicalBackup(ctx context.Context, in *PhysicalBackupRequest, opts ...grpc.CallOption) (*Response, error)
	LogicalBackup(ctx context.Context, in *LogicalBackupRequest, opts ...grpc.CallOption) (*Response, error)
	Restore(ctx context.Context, in *RestoreRequest, opts ...grpc.CallOption) (*Response, error)
	GtidPurge(ctx context.Context, in *GtidPurgeRequest, opts ...grpc.CallOption) (*Response, error)
	SetVariable(ctx context.Context, in *SetVariableRequest, opts ...grpc.CallOption) (*Response, error)
}
    MysqlOperationClient is the client API for MysqlOperation 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 NewMysqlOperationClient ¶
func NewMysqlOperationClient(cc grpc.ClientConnInterface) MysqlOperationClient
type MysqlOperationServer ¶
type MysqlOperationServer interface {
	Clone(context.Context, *CloneRequest) (*Response, error)
	PhysicalBackup(context.Context, *PhysicalBackupRequest) (*Response, error)
	LogicalBackup(context.Context, *LogicalBackupRequest) (*Response, error)
	Restore(context.Context, *RestoreRequest) (*Response, error)
	GtidPurge(context.Context, *GtidPurgeRequest) (*Response, error)
	SetVariable(context.Context, *SetVariableRequest) (*Response, error)
	// contains filtered or unexported methods
}
    MysqlOperationServer is the server API for MysqlOperation service. All implementations must embed UnimplementedMysqlOperationServer for forward compatibility
type PhysicalBackupRequest ¶
type PhysicalBackupRequest struct {
	BackupFile         string             `protobuf:"bytes,1,opt,name=backup_file,json=backupFile,proto3" json:"backup_file,omitempty"`
	ConfFile           string             `protobuf:"bytes,2,opt,name=conf_file,json=confFile,proto3" json:"conf_file,omitempty"`
	SocketFile         string             `protobuf:"bytes,3,opt,name=socket_file,json=socketFile,proto3" json:"socket_file,omitempty"`
	Username           string             `protobuf:"bytes,4,opt,name=username,proto3" json:"username,omitempty"`
	Password           string             `protobuf:"bytes,5,opt,name=password,proto3" json:"password,omitempty"`
	Parallel           int64              `protobuf:"varint,6,opt,name=parallel,proto3" json:"parallel,omitempty"`
	PhysicalBackupTool PhysicalBackupTool `` /* 148-byte string literal not displayed */
	// Types that are valid to be assigned to StorageType:
	//
	//	*PhysicalBackupRequest_S3Storage
	//	*PhysicalBackupRequest_LocalStorage
	StorageType isPhysicalBackupRequest_StorageType `protobuf_oneof:"StorageType"`
	// contains filtered or unexported fields
}
    
        
          
            func (*PhysicalBackupRequest) Descriptor
            deprecated
            
          
  
    
  
      
      func (*PhysicalBackupRequest) Descriptor() ([]byte, []int)
Deprecated: Use PhysicalBackupRequest.ProtoReflect.Descriptor instead.
func (*PhysicalBackupRequest) GetBackupFile ¶
func (x *PhysicalBackupRequest) GetBackupFile() string
func (*PhysicalBackupRequest) GetConfFile ¶
func (x *PhysicalBackupRequest) GetConfFile() string
func (*PhysicalBackupRequest) GetLocalStorage ¶
func (x *PhysicalBackupRequest) GetLocalStorage() *LocalStorage
func (*PhysicalBackupRequest) GetParallel ¶
func (x *PhysicalBackupRequest) GetParallel() int64
func (*PhysicalBackupRequest) GetPassword ¶
func (x *PhysicalBackupRequest) GetPassword() string
func (*PhysicalBackupRequest) GetPhysicalBackupTool ¶
func (x *PhysicalBackupRequest) GetPhysicalBackupTool() PhysicalBackupTool
func (*PhysicalBackupRequest) GetS3Storage ¶
func (x *PhysicalBackupRequest) GetS3Storage() *S3Storage
func (*PhysicalBackupRequest) GetSocketFile ¶
func (x *PhysicalBackupRequest) GetSocketFile() string
func (*PhysicalBackupRequest) GetStorageType ¶
func (x *PhysicalBackupRequest) GetStorageType() isPhysicalBackupRequest_StorageType
func (*PhysicalBackupRequest) GetUsername ¶
func (x *PhysicalBackupRequest) GetUsername() string
func (*PhysicalBackupRequest) ProtoMessage ¶
func (*PhysicalBackupRequest) ProtoMessage()
func (*PhysicalBackupRequest) ProtoReflect ¶
func (x *PhysicalBackupRequest) ProtoReflect() protoreflect.Message
func (*PhysicalBackupRequest) Reset ¶
func (x *PhysicalBackupRequest) Reset()
func (*PhysicalBackupRequest) String ¶
func (x *PhysicalBackupRequest) String() string
type PhysicalBackupRequest_LocalStorage ¶
type PhysicalBackupRequest_LocalStorage struct {
	LocalStorage *LocalStorage `protobuf:"bytes,9,opt,name=local_storage,json=localStorage,proto3,oneof"`
}
    type PhysicalBackupRequest_S3Storage ¶
type PhysicalBackupRequest_S3Storage struct {
	S3Storage *S3Storage `protobuf:"bytes,8,opt,name=s3_storage,json=s3Storage,proto3,oneof"`
}
    type PhysicalBackupTool ¶
type PhysicalBackupTool int32
const ( PhysicalBackupTool_Xtrabackup PhysicalBackupTool = 0 PhysicalBackupTool_Meb PhysicalBackupTool = 1 )
func (PhysicalBackupTool) Descriptor ¶
func (PhysicalBackupTool) Descriptor() protoreflect.EnumDescriptor
func (PhysicalBackupTool) Enum ¶
func (x PhysicalBackupTool) Enum() *PhysicalBackupTool
        
          
            func (PhysicalBackupTool) EnumDescriptor
            deprecated
            
          
  
    
  
      
      func (PhysicalBackupTool) EnumDescriptor() ([]byte, []int)
Deprecated: Use PhysicalBackupTool.Descriptor instead.
func (PhysicalBackupTool) Number ¶
func (x PhysicalBackupTool) Number() protoreflect.EnumNumber
func (PhysicalBackupTool) String ¶
func (x PhysicalBackupTool) String() string
func (PhysicalBackupTool) Type ¶
func (PhysicalBackupTool) Type() protoreflect.EnumType
type Response ¶
type Response struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}
    
        
          
            func (*Response) Descriptor
            deprecated
            
          
  
    
  
      
      
    func (*Response) GetMessage ¶
func (*Response) ProtoMessage ¶
func (*Response) ProtoMessage()
func (*Response) ProtoReflect ¶
func (x *Response) ProtoReflect() protoreflect.Message
type RestoreRequest ¶
type RestoreRequest struct {
	BackupFile string `protobuf:"bytes,1,opt,name=backup_file,json=backupFile,proto3" json:"backup_file,omitempty"`
	Parallel   int64  `protobuf:"varint,2,opt,name=parallel,proto3" json:"parallel,omitempty"`
	// Types that are valid to be assigned to StorageType:
	//
	//	*RestoreRequest_S3Storage
	//	*RestoreRequest_LocalStorage
	StorageType isRestoreRequest_StorageType `protobuf_oneof:"StorageType"`
	// contains filtered or unexported fields
}
    
        
          
            func (*RestoreRequest) Descriptor
            deprecated
            
          
  
    
  
      
      func (*RestoreRequest) Descriptor() ([]byte, []int)
Deprecated: Use RestoreRequest.ProtoReflect.Descriptor instead.
func (*RestoreRequest) GetBackupFile ¶
func (x *RestoreRequest) GetBackupFile() string
func (*RestoreRequest) GetLocalStorage ¶
func (x *RestoreRequest) GetLocalStorage() *LocalStorage
func (*RestoreRequest) GetParallel ¶
func (x *RestoreRequest) GetParallel() int64
func (*RestoreRequest) GetS3Storage ¶
func (x *RestoreRequest) GetS3Storage() *S3Storage
func (*RestoreRequest) GetStorageType ¶
func (x *RestoreRequest) GetStorageType() isRestoreRequest_StorageType
func (*RestoreRequest) ProtoMessage ¶
func (*RestoreRequest) ProtoMessage()
func (*RestoreRequest) ProtoReflect ¶
func (x *RestoreRequest) ProtoReflect() protoreflect.Message
func (*RestoreRequest) Reset ¶
func (x *RestoreRequest) Reset()
func (*RestoreRequest) String ¶
func (x *RestoreRequest) String() string
type RestoreRequest_LocalStorage ¶
type RestoreRequest_LocalStorage struct {
	LocalStorage *LocalStorage `protobuf:"bytes,4,opt,name=local_storage,json=localStorage,proto3,oneof"`
}
    type RestoreRequest_S3Storage ¶
type RestoreRequest_S3Storage struct {
	S3Storage *S3Storage `protobuf:"bytes,3,opt,name=s3_storage,json=s3Storage,proto3,oneof"`
}
    type S3Storage ¶
type S3Storage struct {
	Endpoint  string `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	Bucket    string `protobuf:"bytes,2,opt,name=bucket,proto3" json:"bucket,omitempty"`
	AccessKey string `protobuf:"bytes,3,opt,name=access_key,json=accessKey,proto3" json:"access_key,omitempty"`
	SecretKey string `protobuf:"bytes,4,opt,name=secret_key,json=secretKey,proto3" json:"secret_key,omitempty"`
	// contains filtered or unexported fields
}
    
        
          
            func (*S3Storage) Descriptor
            deprecated
            
          
  
    
  
      
      
    func (*S3Storage) GetAccessKey ¶
func (*S3Storage) GetEndpoint ¶
func (*S3Storage) GetSecretKey ¶
func (*S3Storage) ProtoMessage ¶
func (*S3Storage) ProtoMessage()
func (*S3Storage) ProtoReflect ¶
func (x *S3Storage) ProtoReflect() protoreflect.Message
type SetVariableRequest ¶
type SetVariableRequest struct {
	Key        string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value      string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	SocketFile string `protobuf:"bytes,3,opt,name=socket_file,json=socketFile,proto3" json:"socket_file,omitempty"`
	Username   string `protobuf:"bytes,4,opt,name=username,proto3" json:"username,omitempty"`
	Password   string `protobuf:"bytes,5,opt,name=password,proto3" json:"password,omitempty"`
	// contains filtered or unexported fields
}
    
        
          
            func (*SetVariableRequest) Descriptor
            deprecated
            
          
  
    
  
      
      func (*SetVariableRequest) Descriptor() ([]byte, []int)
Deprecated: Use SetVariableRequest.ProtoReflect.Descriptor instead.
func (*SetVariableRequest) GetKey ¶
func (x *SetVariableRequest) GetKey() string
func (*SetVariableRequest) GetPassword ¶
func (x *SetVariableRequest) GetPassword() string
func (*SetVariableRequest) GetSocketFile ¶
func (x *SetVariableRequest) GetSocketFile() string
func (*SetVariableRequest) GetUsername ¶
func (x *SetVariableRequest) GetUsername() string
func (*SetVariableRequest) GetValue ¶
func (x *SetVariableRequest) GetValue() string
func (*SetVariableRequest) ProtoMessage ¶
func (*SetVariableRequest) ProtoMessage()
func (*SetVariableRequest) ProtoReflect ¶
func (x *SetVariableRequest) ProtoReflect() protoreflect.Message
func (*SetVariableRequest) Reset ¶
func (x *SetVariableRequest) Reset()
func (*SetVariableRequest) String ¶
func (x *SetVariableRequest) String() string
type UnimplementedMysqlOperationServer ¶
type UnimplementedMysqlOperationServer struct {
}
    UnimplementedMysqlOperationServer must be embedded to have forward compatible implementations.
func (UnimplementedMysqlOperationServer) Clone ¶
func (UnimplementedMysqlOperationServer) Clone(context.Context, *CloneRequest) (*Response, error)
func (UnimplementedMysqlOperationServer) GtidPurge ¶
func (UnimplementedMysqlOperationServer) GtidPurge(context.Context, *GtidPurgeRequest) (*Response, error)
func (UnimplementedMysqlOperationServer) LogicalBackup ¶
func (UnimplementedMysqlOperationServer) LogicalBackup(context.Context, *LogicalBackupRequest) (*Response, error)
func (UnimplementedMysqlOperationServer) PhysicalBackup ¶
func (UnimplementedMysqlOperationServer) PhysicalBackup(context.Context, *PhysicalBackupRequest) (*Response, error)
func (UnimplementedMysqlOperationServer) Restore ¶
func (UnimplementedMysqlOperationServer) Restore(context.Context, *RestoreRequest) (*Response, error)
func (UnimplementedMysqlOperationServer) SetVariable ¶
func (UnimplementedMysqlOperationServer) SetVariable(context.Context, *SetVariableRequest) (*Response, error)
type UnsafeMysqlOperationServer ¶
type UnsafeMysqlOperationServer interface {
	// contains filtered or unexported methods
}
    UnsafeMysqlOperationServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MysqlOperationServer will result in compilation errors.