mysqlctl

package
v0.17.0-rc2 Latest Latest
Warning

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

 Go to latest Published: Jun 13, 2023 License: Apache-2.0 Imports: 13 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

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

View Source 
var (
	ErrInvalidLength        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflow          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var File_mysqlctl_proto protoreflect.FileDescriptor
View Source 
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: "ReinitConfig",
			Handler:    _MysqlCtl_ReinitConfig_Handler,
		},
		{
			MethodName: "RefreshConfig",
			Handler:    _MysqlCtl_RefreshConfig_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 */
	// contains filtered or unexported fields
}

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) 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) 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) 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)
	ReinitConfig(ctx context.Context, in *ReinitConfigRequest, opts ...grpc.CallOption) (*ReinitConfigResponse, error)
	RefreshConfig(ctx context.Context, in *RefreshConfigRequest, opts ...grpc.CallOption) (*RefreshConfigResponse, 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)
	ReinitConfig(context.Context, *ReinitConfigRequest) (*ReinitConfigResponse, error)
	RefreshConfig(context.Context, *RefreshConfigRequest) (*RefreshConfigResponse, error)
	// contains filtered or unexported methods
}

MysqlCtlServer is the server API for MysqlCtl service. All implementations must embed UnimplementedMysqlCtlServer for forward compatibility

type RefreshConfigRequest 

type RefreshConfigRequest struct {
	// contains filtered or unexported fields
}

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) 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) 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) 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) 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) 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"`
	// contains filtered or unexported fields
}

func (*ShutdownRequest) Descriptor deprecated 

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

Deprecated: Use ShutdownRequest.ProtoReflect.Descriptor instead.

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) 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) 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) 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) 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)

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.

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.