mysql

package
v1.1.0 Latest Latest
Warning

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

 Go to latest Published: Aug 30, 2025 License: Apache-2.0 Imports: 29 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	SetValidDonorListSql = `SET GLOBAL clone_valid_donor_list = ?;`
	ExecCloneSql         = `CLONE INSTANCE FROM %s@'%s':%d IDENTIFIED BY '%s';`
)

Variables

View Source 
var (
	PhysicalBackupTool_name = map[int32]string{
		0: "Xtrabackup",
		1: "Meb",
	}
	PhysicalBackupTool_value = map[string]int32{
		"Xtrabackup": 0,
		"Meb":        1,
	}
)

Enum value maps for PhysicalBackupTool.

View Source 
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.

View Source 
var (
	ArchMode_name = map[int32]string{
		0: "Replication",
		1: "GroupReplication",
	}
	ArchMode_value = map[string]int32{
		"Replication":      0,
		"GroupReplication": 1,
	}
)

Enum value maps for ArchMode.

View Source 
var File_pkg_agent_app_mysql_pb_mysql_proto protoreflect.FileDescriptor
View Source 
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
const (
	ArchMode_Replication      ArchMode = 0
	ArchMode_GroupReplication ArchMode = 1
)

func (ArchMode) Descriptor 

func (ArchMode) Descriptor() protoreflect.EnumDescriptor

func (ArchMode) Enum 

func (x ArchMode) Enum() *ArchMode

func (ArchMode) EnumDescriptor deprecated 

func (ArchMode) EnumDescriptor() ([]byte, []int)

Deprecated: Use ArchMode.Descriptor instead.

func (ArchMode) Number 

func (x ArchMode) Number() protoreflect.EnumNumber

func (ArchMode) String 

func (x ArchMode) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Response.ProtoReflect.Descriptor instead.

func (*Response) GetMessage 

func (x *Response) GetMessage() string

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) ProtoReflect 

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

func (*Response) Reset 

func (x *Response) Reset()

func (*Response) String 

func (x *Response) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use S3Storage.ProtoReflect.Descriptor instead.

func (*S3Storage) GetAccessKey 

func (x *S3Storage) GetAccessKey() string

func (*S3Storage) GetBucket 

func (x *S3Storage) GetBucket() string

func (*S3Storage) GetEndpoint 

func (x *S3Storage) GetEndpoint() string

func (*S3Storage) GetSecretKey 

func (x *S3Storage) GetSecretKey() string

func (*S3Storage) ProtoMessage 

func (*S3Storage) ProtoMessage()

func (*S3Storage) ProtoReflect 

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

func (*S3Storage) Reset 

func (x *S3Storage) Reset()

func (*S3Storage) String 

func (x *S3Storage) String() string

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.

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.