mysqlctl

package
v0.19.1 Latest Latest
Warning

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

Go to latest
Published: Mar 14, 2024 License: Apache-2.0 Imports: 14 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: "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 (*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 (*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) Enum added in v0.11.0

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 (BackupInfo_Status) String added in v0.11.0

func (x BackupInfo_Status) String() string

func (BackupInfo_Status) Type added in v0.11.0

type MysqlCtlClient

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

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 (*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 (*ReadBinlogFilesTimestampsRequest) Reset added in v0.18.0

func (*ReadBinlogFilesTimestampsRequest) SizeVT added in v0.18.0

func (m *ReadBinlogFilesTimestampsRequest) SizeVT() (n int)

func (*ReadBinlogFilesTimestampsRequest) String added in v0.18.0

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 (*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 (*ReadBinlogFilesTimestampsResponse) Reset added in v0.18.0

func (*ReadBinlogFilesTimestampsResponse) SizeVT added in v0.18.0

func (m *ReadBinlogFilesTimestampsResponse) SizeVT() (n int)

func (*ReadBinlogFilesTimestampsResponse) String added in v0.18.0

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 (*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 (*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 (*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 (*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 (*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 (*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) ReadBinlogFilesTimestamps added in v0.18.0

func (UnimplementedMysqlCtlServer) RefreshConfig

func (UnimplementedMysqlCtlServer) ReinitConfig

func (UnimplementedMysqlCtlServer) RunMysqlUpgrade

func (UnimplementedMysqlCtlServer) Shutdown

func (UnimplementedMysqlCtlServer) Start

func (UnimplementedMysqlCtlServer) VersionString added in v0.18.0

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 (*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 (*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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL