mysqlctl

package
v0.15.10 Latest Latest
Warning

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

 Go to latest Published: Jul 31, 2024 License: Apache-2.0 Imports: 14 Imported by: 0

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 

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 

func (m *ApplyBinlogFileRequest) CloneMessageVT() proto.Message

func (*ApplyBinlogFileRequest) CloneVT 

func (m *ApplyBinlogFileRequest) CloneVT() *ApplyBinlogFileRequest

func (*ApplyBinlogFileRequest) Descriptor deprecated 

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

Deprecated: Use ApplyBinlogFileRequest.ProtoReflect.Descriptor instead.

func (*ApplyBinlogFileRequest) GetBinlogFileName 

func (x *ApplyBinlogFileRequest) GetBinlogFileName() string

func (*ApplyBinlogFileRequest) GetBinlogRestoreDatetime 

func (x *ApplyBinlogFileRequest) GetBinlogRestoreDatetime() *vttime.Time

func (*ApplyBinlogFileRequest) GetBinlogRestorePosition 

func (x *ApplyBinlogFileRequest) GetBinlogRestorePosition() string

func (*ApplyBinlogFileRequest) MarshalToSizedBufferVT 

func (m *ApplyBinlogFileRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ApplyBinlogFileRequest) MarshalToVT 

func (m *ApplyBinlogFileRequest) MarshalToVT(dAtA []byte) (int, error)

func (*ApplyBinlogFileRequest) MarshalVT 

func (m *ApplyBinlogFileRequest) MarshalVT() (dAtA []byte, err error)

func (*ApplyBinlogFileRequest) ProtoMessage 

func (*ApplyBinlogFileRequest) ProtoMessage()

func (*ApplyBinlogFileRequest) ProtoReflect 

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

func (*ApplyBinlogFileRequest) Reset 

func (x *ApplyBinlogFileRequest) Reset()

func (*ApplyBinlogFileRequest) SizeVT 

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

func (*ApplyBinlogFileRequest) String 

func (x *ApplyBinlogFileRequest) String() string

func (*ApplyBinlogFileRequest) UnmarshalVT 

func (m *ApplyBinlogFileRequest) UnmarshalVT(dAtA []byte) error

type ApplyBinlogFileResponse 

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

func (*ApplyBinlogFileResponse) CloneMessageVT 

func (m *ApplyBinlogFileResponse) CloneMessageVT() proto.Message

func (*ApplyBinlogFileResponse) CloneVT 

func (m *ApplyBinlogFileResponse) CloneVT() *ApplyBinlogFileResponse

func (*ApplyBinlogFileResponse) Descriptor deprecated 

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

Deprecated: Use ApplyBinlogFileResponse.ProtoReflect.Descriptor instead.

func (*ApplyBinlogFileResponse) MarshalToSizedBufferVT 

func (m *ApplyBinlogFileResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ApplyBinlogFileResponse) MarshalToVT 

func (m *ApplyBinlogFileResponse) MarshalToVT(dAtA []byte) (int, error)

func (*ApplyBinlogFileResponse) MarshalVT 

func (m *ApplyBinlogFileResponse) MarshalVT() (dAtA []byte, err error)

func (*ApplyBinlogFileResponse) ProtoMessage 

func (*ApplyBinlogFileResponse) ProtoMessage()

func (*ApplyBinlogFileResponse) ProtoReflect 

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

func (*ApplyBinlogFileResponse) Reset 

func (x *ApplyBinlogFileResponse) Reset()

func (*ApplyBinlogFileResponse) SizeVT 

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

func (*ApplyBinlogFileResponse) String 

func (x *ApplyBinlogFileResponse) String() string

func (*ApplyBinlogFileResponse) UnmarshalVT 

func (m *ApplyBinlogFileResponse) UnmarshalVT(dAtA []byte) error

type BackupInfo 

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 

func (m *BackupInfo) CloneMessageVT() proto.Message

func (*BackupInfo) CloneVT 

func (m *BackupInfo) CloneVT() *BackupInfo

func (*BackupInfo) Descriptor deprecated 

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

Deprecated: Use BackupInfo.ProtoReflect.Descriptor instead.

func (*BackupInfo) GetDirectory 

func (x *BackupInfo) GetDirectory() string

func (*BackupInfo) GetEngine 

func (x *BackupInfo) GetEngine() string

func (*BackupInfo) GetKeyspace 

func (x *BackupInfo) GetKeyspace() string

func (*BackupInfo) GetName 

func (x *BackupInfo) GetName() string

func (*BackupInfo) GetShard 

func (x *BackupInfo) GetShard() string

func (*BackupInfo) GetStatus 

func (x *BackupInfo) GetStatus() BackupInfo_Status

func (*BackupInfo) GetTabletAlias 

func (x *BackupInfo) GetTabletAlias() *topodata.TabletAlias

func (*BackupInfo) GetTime 

func (x *BackupInfo) GetTime() *vttime.Time

func (*BackupInfo) MarshalToSizedBufferVT 

func (m *BackupInfo) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*BackupInfo) MarshalToVT 

func (m *BackupInfo) MarshalToVT(dAtA []byte) (int, error)

func (*BackupInfo) MarshalVT 

func (m *BackupInfo) MarshalVT() (dAtA []byte, err error)

func (*BackupInfo) ProtoMessage 

func (*BackupInfo) ProtoMessage()

func (*BackupInfo) ProtoReflect 

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

func (*BackupInfo) Reset 

func (x *BackupInfo) Reset()

func (*BackupInfo) SizeVT 

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

func (*BackupInfo) String 

func (x *BackupInfo) String() string

func (*BackupInfo) UnmarshalVT 

func (m *BackupInfo) UnmarshalVT(dAtA []byte) error

type BackupInfo_Status 

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 

func (BackupInfo_Status) Descriptor() protoreflect.EnumDescriptor

func (BackupInfo_Status) Enum 

func (x BackupInfo_Status) Enum() *BackupInfo_Status

func (BackupInfo_Status) EnumDescriptor deprecated 

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

Deprecated: Use BackupInfo_Status.Descriptor instead.

func (BackupInfo_Status) Number 

func (x BackupInfo_Status) Number() protoreflect.EnumNumber

func (BackupInfo_Status) String 

func (x BackupInfo_Status) String() string

func (BackupInfo_Status) Type 

func (BackupInfo_Status) Type() protoreflect.EnumType

type MysqlCtlClient 

type MysqlCtlClient interface {
	Start(ctx context.Context, in *StartRequest, opts ...grpc.CallOption) (*StartResponse, error)
	Shutdown(ctx context.Context, in *ShutdownRequest, opts ...grpc.CallOption) (*ShutdownResponse, error)
	RunMysqlUpgrade(ctx context.Context, in *RunMysqlUpgradeRequest, opts ...grpc.CallOption) (*RunMysqlUpgradeResponse, error)
	ApplyBinlogFile(ctx context.Context, in *ApplyBinlogFileRequest, opts ...grpc.CallOption) (*ApplyBinlogFileResponse, error)
	ReadBinlogFilesTimestamps(ctx context.Context, in *ReadBinlogFilesTimestampsRequest, opts ...grpc.CallOption) (*ReadBinlogFilesTimestampsResponse, error)
	ReinitConfig(ctx context.Context, in *ReinitConfigRequest, opts ...grpc.CallOption) (*ReinitConfigResponse, error)
	RefreshConfig(ctx context.Context, in *RefreshConfigRequest, opts ...grpc.CallOption) (*RefreshConfigResponse, error)
	VersionString(ctx context.Context, in *VersionStringRequest, opts ...grpc.CallOption) (*VersionStringResponse, error)
}

MysqlCtlClient is the client API for MysqlCtl service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewMysqlCtlClient 

func NewMysqlCtlClient(cc grpc.ClientConnInterface) MysqlCtlClient

type MysqlCtlServer 

type MysqlCtlServer interface {
	Start(context.Context, *StartRequest) (*StartResponse, error)
	Shutdown(context.Context, *ShutdownRequest) (*ShutdownResponse, error)
	RunMysqlUpgrade(context.Context, *RunMysqlUpgradeRequest) (*RunMysqlUpgradeResponse, error)
	ApplyBinlogFile(context.Context, *ApplyBinlogFileRequest) (*ApplyBinlogFileResponse, error)
	ReadBinlogFilesTimestamps(context.Context, *ReadBinlogFilesTimestampsRequest) (*ReadBinlogFilesTimestampsResponse, error)
	ReinitConfig(context.Context, *ReinitConfigRequest) (*ReinitConfigResponse, error)
	RefreshConfig(context.Context, *RefreshConfigRequest) (*RefreshConfigResponse, error)
	VersionString(context.Context, *VersionStringRequest) (*VersionStringResponse, error)
	// contains filtered or unexported methods
}

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

type ReadBinlogFilesTimestampsRequest 

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 

func (m *ReadBinlogFilesTimestampsRequest) CloneMessageVT() proto.Message

func (*ReadBinlogFilesTimestampsRequest) CloneVT 

func (m *ReadBinlogFilesTimestampsRequest) CloneVT() *ReadBinlogFilesTimestampsRequest

func (*ReadBinlogFilesTimestampsRequest) Descriptor deprecated 

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

Deprecated: Use ReadBinlogFilesTimestampsRequest.ProtoReflect.Descriptor instead.

func (*ReadBinlogFilesTimestampsRequest) GetBinlogFileNames 

func (x *ReadBinlogFilesTimestampsRequest) GetBinlogFileNames() []string

func (*ReadBinlogFilesTimestampsRequest) MarshalToSizedBufferVT 

func (m *ReadBinlogFilesTimestampsRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ReadBinlogFilesTimestampsRequest) MarshalToVT 

func (m *ReadBinlogFilesTimestampsRequest) MarshalToVT(dAtA []byte) (int, error)

func (*ReadBinlogFilesTimestampsRequest) MarshalVT 

func (m *ReadBinlogFilesTimestampsRequest) MarshalVT() (dAtA []byte, err error)

func (*ReadBinlogFilesTimestampsRequest) ProtoMessage 

func (*ReadBinlogFilesTimestampsRequest) ProtoMessage()

func (*ReadBinlogFilesTimestampsRequest) ProtoReflect 

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

func (*ReadBinlogFilesTimestampsRequest) Reset 

func (x *ReadBinlogFilesTimestampsRequest) Reset()

func (*ReadBinlogFilesTimestampsRequest) SizeVT 

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

func (*ReadBinlogFilesTimestampsRequest) String 

func (x *ReadBinlogFilesTimestampsRequest) String() string

func (*ReadBinlogFilesTimestampsRequest) UnmarshalVT 

func (m *ReadBinlogFilesTimestampsRequest) UnmarshalVT(dAtA []byte) error

type ReadBinlogFilesTimestampsResponse 

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 

func (m *ReadBinlogFilesTimestampsResponse) CloneMessageVT() proto.Message

func (*ReadBinlogFilesTimestampsResponse) CloneVT 

func (m *ReadBinlogFilesTimestampsResponse) CloneVT() *ReadBinlogFilesTimestampsResponse

func (*ReadBinlogFilesTimestampsResponse) Descriptor deprecated 

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

Deprecated: Use ReadBinlogFilesTimestampsResponse.ProtoReflect.Descriptor instead.

func (*ReadBinlogFilesTimestampsResponse) GetFirstTimestamp 

func (x *ReadBinlogFilesTimestampsResponse) GetFirstTimestamp() *vttime.Time

func (*ReadBinlogFilesTimestampsResponse) GetFirstTimestampBinlog 

func (x *ReadBinlogFilesTimestampsResponse) GetFirstTimestampBinlog() string

func (*ReadBinlogFilesTimestampsResponse) GetLastTimestamp 

func (x *ReadBinlogFilesTimestampsResponse) GetLastTimestamp() *vttime.Time

func (*ReadBinlogFilesTimestampsResponse) GetLastTimestampBinlog 

func (x *ReadBinlogFilesTimestampsResponse) GetLastTimestampBinlog() string

func (*ReadBinlogFilesTimestampsResponse) MarshalToSizedBufferVT 

func (m *ReadBinlogFilesTimestampsResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ReadBinlogFilesTimestampsResponse) MarshalToVT 

func (m *ReadBinlogFilesTimestampsResponse) MarshalToVT(dAtA []byte) (int, error)

func (*ReadBinlogFilesTimestampsResponse) MarshalVT 

func (m *ReadBinlogFilesTimestampsResponse) MarshalVT() (dAtA []byte, err error)

func (*ReadBinlogFilesTimestampsResponse) ProtoMessage 

func (*ReadBinlogFilesTimestampsResponse) ProtoMessage()

func (*ReadBinlogFilesTimestampsResponse) ProtoReflect 

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

func (*ReadBinlogFilesTimestampsResponse) Reset 

func (x *ReadBinlogFilesTimestampsResponse) Reset()

func (*ReadBinlogFilesTimestampsResponse) SizeVT 

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

func (*ReadBinlogFilesTimestampsResponse) String 

func (x *ReadBinlogFilesTimestampsResponse) String() string

func (*ReadBinlogFilesTimestampsResponse) UnmarshalVT 

func (m *ReadBinlogFilesTimestampsResponse) UnmarshalVT(dAtA []byte) error

type RefreshConfigRequest 

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

func (*RefreshConfigRequest) CloneMessageVT 

func (m *RefreshConfigRequest) CloneMessageVT() proto.Message

func (*RefreshConfigRequest) CloneVT 

func (m *RefreshConfigRequest) CloneVT() *RefreshConfigRequest

func (*RefreshConfigRequest) Descriptor deprecated 

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

Deprecated: Use RefreshConfigRequest.ProtoReflect.Descriptor instead.

func (*RefreshConfigRequest) MarshalToSizedBufferVT 

func (m *RefreshConfigRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RefreshConfigRequest) MarshalToVT 

func (m *RefreshConfigRequest) MarshalToVT(dAtA []byte) (int, error)

func (*RefreshConfigRequest) MarshalVT 

func (m *RefreshConfigRequest) MarshalVT() (dAtA []byte, err error)

func (*RefreshConfigRequest) ProtoMessage 

func (*RefreshConfigRequest) ProtoMessage()

func (*RefreshConfigRequest) ProtoReflect 

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

func (*RefreshConfigRequest) Reset 

func (x *RefreshConfigRequest) Reset()

func (*RefreshConfigRequest) SizeVT 

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

func (*RefreshConfigRequest) String 

func (x *RefreshConfigRequest) String() string

func (*RefreshConfigRequest) UnmarshalVT 

func (m *RefreshConfigRequest) UnmarshalVT(dAtA []byte) error

type RefreshConfigResponse 

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

func (*RefreshConfigResponse) CloneMessageVT 

func (m *RefreshConfigResponse) CloneMessageVT() proto.Message

func (*RefreshConfigResponse) CloneVT 

func (m *RefreshConfigResponse) CloneVT() *RefreshConfigResponse

func (*RefreshConfigResponse) Descriptor deprecated 

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

Deprecated: Use RefreshConfigResponse.ProtoReflect.Descriptor instead.

func (*RefreshConfigResponse) MarshalToSizedBufferVT 

func (m *RefreshConfigResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RefreshConfigResponse) MarshalToVT 

func (m *RefreshConfigResponse) MarshalToVT(dAtA []byte) (int, error)

func (*RefreshConfigResponse) MarshalVT 

func (m *RefreshConfigResponse) MarshalVT() (dAtA []byte, err error)

func (*RefreshConfigResponse) ProtoMessage 

func (*RefreshConfigResponse) ProtoMessage()

func (*RefreshConfigResponse) ProtoReflect 

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

func (*RefreshConfigResponse) Reset 

func (x *RefreshConfigResponse) Reset()

func (*RefreshConfigResponse) SizeVT 

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

func (*RefreshConfigResponse) String 

func (x *RefreshConfigResponse) String() string

func (*RefreshConfigResponse) UnmarshalVT 

func (m *RefreshConfigResponse) UnmarshalVT(dAtA []byte) error

type ReinitConfigRequest 

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

func (*ReinitConfigRequest) CloneMessageVT 

func (m *ReinitConfigRequest) CloneMessageVT() proto.Message

func (*ReinitConfigRequest) CloneVT 

func (m *ReinitConfigRequest) CloneVT() *ReinitConfigRequest

func (*ReinitConfigRequest) Descriptor deprecated 

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

Deprecated: Use ReinitConfigRequest.ProtoReflect.Descriptor instead.

func (*ReinitConfigRequest) MarshalToSizedBufferVT 

func (m *ReinitConfigRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ReinitConfigRequest) MarshalToVT 

func (m *ReinitConfigRequest) MarshalToVT(dAtA []byte) (int, error)

func (*ReinitConfigRequest) MarshalVT 

func (m *ReinitConfigRequest) MarshalVT() (dAtA []byte, err error)

func (*ReinitConfigRequest) ProtoMessage 

func (*ReinitConfigRequest) ProtoMessage()

func (*ReinitConfigRequest) ProtoReflect 

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

func (*ReinitConfigRequest) Reset 

func (x *ReinitConfigRequest) Reset()

func (*ReinitConfigRequest) SizeVT 

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

func (*ReinitConfigRequest) String 

func (x *ReinitConfigRequest) String() string

func (*ReinitConfigRequest) UnmarshalVT 

func (m *ReinitConfigRequest) UnmarshalVT(dAtA []byte) error

type ReinitConfigResponse 

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

func (*ReinitConfigResponse) CloneMessageVT 

func (m *ReinitConfigResponse) CloneMessageVT() proto.Message

func (*ReinitConfigResponse) CloneVT 

func (m *ReinitConfigResponse) CloneVT() *ReinitConfigResponse

func (*ReinitConfigResponse) Descriptor deprecated 

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

Deprecated: Use ReinitConfigResponse.ProtoReflect.Descriptor instead.

func (*ReinitConfigResponse) MarshalToSizedBufferVT 

func (m *ReinitConfigResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ReinitConfigResponse) MarshalToVT 

func (m *ReinitConfigResponse) MarshalToVT(dAtA []byte) (int, error)

func (*ReinitConfigResponse) MarshalVT 

func (m *ReinitConfigResponse) MarshalVT() (dAtA []byte, err error)

func (*ReinitConfigResponse) ProtoMessage 

func (*ReinitConfigResponse) ProtoMessage()

func (*ReinitConfigResponse) ProtoReflect 

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

func (*ReinitConfigResponse) Reset 

func (x *ReinitConfigResponse) Reset()

func (*ReinitConfigResponse) SizeVT 

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

func (*ReinitConfigResponse) String 

func (x *ReinitConfigResponse) String() string

func (*ReinitConfigResponse) UnmarshalVT 

func (m *ReinitConfigResponse) UnmarshalVT(dAtA []byte) error

type RunMysqlUpgradeRequest 

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

func (*RunMysqlUpgradeRequest) CloneMessageVT 

func (m *RunMysqlUpgradeRequest) CloneMessageVT() proto.Message

func (*RunMysqlUpgradeRequest) CloneVT 

func (m *RunMysqlUpgradeRequest) CloneVT() *RunMysqlUpgradeRequest

func (*RunMysqlUpgradeRequest) Descriptor deprecated 

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

Deprecated: Use RunMysqlUpgradeRequest.ProtoReflect.Descriptor instead.

func (*RunMysqlUpgradeRequest) MarshalToSizedBufferVT 

func (m *RunMysqlUpgradeRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RunMysqlUpgradeRequest) MarshalToVT 

func (m *RunMysqlUpgradeRequest) MarshalToVT(dAtA []byte) (int, error)

func (*RunMysqlUpgradeRequest) MarshalVT 

func (m *RunMysqlUpgradeRequest) MarshalVT() (dAtA []byte, err error)

func (*RunMysqlUpgradeRequest) ProtoMessage 

func (*RunMysqlUpgradeRequest) ProtoMessage()

func (*RunMysqlUpgradeRequest) ProtoReflect 

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

func (*RunMysqlUpgradeRequest) Reset 

func (x *RunMysqlUpgradeRequest) Reset()

func (*RunMysqlUpgradeRequest) SizeVT 

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

func (*RunMysqlUpgradeRequest) String 

func (x *RunMysqlUpgradeRequest) String() string

func (*RunMysqlUpgradeRequest) UnmarshalVT 

func (m *RunMysqlUpgradeRequest) UnmarshalVT(dAtA []byte) error

type RunMysqlUpgradeResponse 

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

func (*RunMysqlUpgradeResponse) CloneMessageVT 

func (m *RunMysqlUpgradeResponse) CloneMessageVT() proto.Message

func (*RunMysqlUpgradeResponse) CloneVT 

func (m *RunMysqlUpgradeResponse) CloneVT() *RunMysqlUpgradeResponse

func (*RunMysqlUpgradeResponse) Descriptor deprecated 

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

Deprecated: Use RunMysqlUpgradeResponse.ProtoReflect.Descriptor instead.

func (*RunMysqlUpgradeResponse) MarshalToSizedBufferVT 

func (m *RunMysqlUpgradeResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RunMysqlUpgradeResponse) MarshalToVT 

func (m *RunMysqlUpgradeResponse) MarshalToVT(dAtA []byte) (int, error)

func (*RunMysqlUpgradeResponse) MarshalVT 

func (m *RunMysqlUpgradeResponse) MarshalVT() (dAtA []byte, err error)

func (*RunMysqlUpgradeResponse) ProtoMessage 

func (*RunMysqlUpgradeResponse) ProtoMessage()

func (*RunMysqlUpgradeResponse) ProtoReflect 

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

func (*RunMysqlUpgradeResponse) Reset 

func (x *RunMysqlUpgradeResponse) Reset()

func (*RunMysqlUpgradeResponse) SizeVT 

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

func (*RunMysqlUpgradeResponse) String 

func (x *RunMysqlUpgradeResponse) String() string

func (*RunMysqlUpgradeResponse) UnmarshalVT 

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 

func (m *ShutdownRequest) CloneMessageVT() proto.Message

func (*ShutdownRequest) CloneVT 

func (m *ShutdownRequest) CloneVT() *ShutdownRequest

func (*ShutdownRequest) Descriptor deprecated 

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

Deprecated: Use ShutdownRequest.ProtoReflect.Descriptor instead.

func (*ShutdownRequest) GetMysqlShutdownTimeout 

func (x *ShutdownRequest) GetMysqlShutdownTimeout() *vttime.Duration

func (*ShutdownRequest) GetWaitForMysqld 

func (x *ShutdownRequest) GetWaitForMysqld() bool

func (*ShutdownRequest) MarshalToSizedBufferVT 

func (m *ShutdownRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ShutdownRequest) MarshalToVT 

func (m *ShutdownRequest) MarshalToVT(dAtA []byte) (int, error)

func (*ShutdownRequest) MarshalVT 

func (m *ShutdownRequest) MarshalVT() (dAtA []byte, err error)

func (*ShutdownRequest) ProtoMessage 

func (*ShutdownRequest) ProtoMessage()

func (*ShutdownRequest) ProtoReflect 

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

func (*ShutdownRequest) Reset 

func (x *ShutdownRequest) Reset()

func (*ShutdownRequest) SizeVT 

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

func (*ShutdownRequest) String 

func (x *ShutdownRequest) String() string

func (*ShutdownRequest) UnmarshalVT 

func (m *ShutdownRequest) UnmarshalVT(dAtA []byte) error

type ShutdownResponse 

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

func (*ShutdownResponse) CloneMessageVT 

func (m *ShutdownResponse) CloneMessageVT() proto.Message

func (*ShutdownResponse) CloneVT 

func (m *ShutdownResponse) CloneVT() *ShutdownResponse

func (*ShutdownResponse) Descriptor deprecated 

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

Deprecated: Use ShutdownResponse.ProtoReflect.Descriptor instead.

func (*ShutdownResponse) MarshalToSizedBufferVT 

func (m *ShutdownResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ShutdownResponse) MarshalToVT 

func (m *ShutdownResponse) MarshalToVT(dAtA []byte) (int, error)

func (*ShutdownResponse) MarshalVT 

func (m *ShutdownResponse) MarshalVT() (dAtA []byte, err error)

func (*ShutdownResponse) ProtoMessage 

func (*ShutdownResponse) ProtoMessage()

func (*ShutdownResponse) ProtoReflect 

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

func (*ShutdownResponse) Reset 

func (x *ShutdownResponse) Reset()

func (*ShutdownResponse) SizeVT 

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

func (*ShutdownResponse) String 

func (x *ShutdownResponse) String() string

func (*ShutdownResponse) UnmarshalVT 

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 

func (m *StartRequest) CloneMessageVT() proto.Message

func (*StartRequest) CloneVT 

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 

func (m *StartRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*StartRequest) MarshalToVT 

func (m *StartRequest) MarshalToVT(dAtA []byte) (int, error)

func (*StartRequest) MarshalVT 

func (m *StartRequest) MarshalVT() (dAtA []byte, err error)

func (*StartRequest) ProtoMessage 

func (*StartRequest) ProtoMessage()

func (*StartRequest) ProtoReflect 

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

func (*StartRequest) Reset 

func (x *StartRequest) Reset()

func (*StartRequest) SizeVT 

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

func (*StartRequest) String 

func (x *StartRequest) String() string

func (*StartRequest) UnmarshalVT 

func (m *StartRequest) UnmarshalVT(dAtA []byte) error

type StartResponse 

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

func (*StartResponse) CloneMessageVT 

func (m *StartResponse) CloneMessageVT() proto.Message

func (*StartResponse) CloneVT 

func (m *StartResponse) CloneVT() *StartResponse

func (*StartResponse) Descriptor deprecated 

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

Deprecated: Use StartResponse.ProtoReflect.Descriptor instead.

func (*StartResponse) MarshalToSizedBufferVT 

func (m *StartResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*StartResponse) MarshalToVT 

func (m *StartResponse) MarshalToVT(dAtA []byte) (int, error)

func (*StartResponse) MarshalVT 

func (m *StartResponse) MarshalVT() (dAtA []byte, err error)

func (*StartResponse) ProtoMessage 

func (*StartResponse) ProtoMessage()

func (*StartResponse) ProtoReflect 

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

func (*StartResponse) Reset 

func (x *StartResponse) Reset()

func (*StartResponse) SizeVT 

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

func (*StartResponse) String 

func (x *StartResponse) String() string

func (*StartResponse) UnmarshalVT 

func (m *StartResponse) UnmarshalVT(dAtA []byte) error

type UnimplementedMysqlCtlServer 

type UnimplementedMysqlCtlServer struct {
}

UnimplementedMysqlCtlServer must be embedded to have forward compatible implementations.

func (UnimplementedMysqlCtlServer) ApplyBinlogFile 

func (UnimplementedMysqlCtlServer) ApplyBinlogFile(context.Context, *ApplyBinlogFileRequest) (*ApplyBinlogFileResponse, error)

func (UnimplementedMysqlCtlServer) ReadBinlogFilesTimestamps 

func (UnimplementedMysqlCtlServer) ReadBinlogFilesTimestamps(context.Context, *ReadBinlogFilesTimestampsRequest) (*ReadBinlogFilesTimestampsResponse, error)

func (UnimplementedMysqlCtlServer) RefreshConfig 

func (UnimplementedMysqlCtlServer) RefreshConfig(context.Context, *RefreshConfigRequest) (*RefreshConfigResponse, error)

func (UnimplementedMysqlCtlServer) ReinitConfig 

func (UnimplementedMysqlCtlServer) ReinitConfig(context.Context, *ReinitConfigRequest) (*ReinitConfigResponse, error)

func (UnimplementedMysqlCtlServer) RunMysqlUpgrade 

func (UnimplementedMysqlCtlServer) RunMysqlUpgrade(context.Context, *RunMysqlUpgradeRequest) (*RunMysqlUpgradeResponse, error)

func (UnimplementedMysqlCtlServer) Shutdown 

func (UnimplementedMysqlCtlServer) Shutdown(context.Context, *ShutdownRequest) (*ShutdownResponse, error)

func (UnimplementedMysqlCtlServer) Start 

func (UnimplementedMysqlCtlServer) Start(context.Context, *StartRequest) (*StartResponse, error)

func (UnimplementedMysqlCtlServer) VersionString 

func (UnimplementedMysqlCtlServer) VersionString(context.Context, *VersionStringRequest) (*VersionStringResponse, error)

type UnsafeMysqlCtlServer 

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 

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

func (*VersionStringRequest) CloneMessageVT 

func (m *VersionStringRequest) CloneMessageVT() proto.Message

func (*VersionStringRequest) CloneVT 

func (m *VersionStringRequest) CloneVT() *VersionStringRequest

func (*VersionStringRequest) Descriptor deprecated 

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

Deprecated: Use VersionStringRequest.ProtoReflect.Descriptor instead.

func (*VersionStringRequest) MarshalToSizedBufferVT 

func (m *VersionStringRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*VersionStringRequest) MarshalToVT 

func (m *VersionStringRequest) MarshalToVT(dAtA []byte) (int, error)

func (*VersionStringRequest) MarshalVT 

func (m *VersionStringRequest) MarshalVT() (dAtA []byte, err error)

func (*VersionStringRequest) ProtoMessage 

func (*VersionStringRequest) ProtoMessage()

func (*VersionStringRequest) ProtoReflect 

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

func (*VersionStringRequest) Reset 

func (x *VersionStringRequest) Reset()

func (*VersionStringRequest) SizeVT 

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

func (*VersionStringRequest) String 

func (x *VersionStringRequest) String() string

func (*VersionStringRequest) UnmarshalVT 

func (m *VersionStringRequest) UnmarshalVT(dAtA []byte) error

type VersionStringResponse 

type VersionStringResponse struct {
	Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*VersionStringResponse) CloneMessageVT 

func (m *VersionStringResponse) CloneMessageVT() proto.Message

func (*VersionStringResponse) CloneVT 

func (m *VersionStringResponse) CloneVT() *VersionStringResponse

func (*VersionStringResponse) Descriptor deprecated 

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

Deprecated: Use VersionStringResponse.ProtoReflect.Descriptor instead.

func (*VersionStringResponse) GetVersion 

func (x *VersionStringResponse) GetVersion() string

func (*VersionStringResponse) MarshalToSizedBufferVT 

func (m *VersionStringResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*VersionStringResponse) MarshalToVT 

func (m *VersionStringResponse) MarshalToVT(dAtA []byte) (int, error)

func (*VersionStringResponse) MarshalVT 

func (m *VersionStringResponse) MarshalVT() (dAtA []byte, err error)

func (*VersionStringResponse) ProtoMessage 

func (*VersionStringResponse) ProtoMessage()

func (*VersionStringResponse) ProtoReflect 

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

func (*VersionStringResponse) Reset 

func (x *VersionStringResponse) Reset()

func (*VersionStringResponse) SizeVT 

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

func (*VersionStringResponse) String 

func (x *VersionStringResponse) String() string

func (*VersionStringResponse) UnmarshalVT 

func (m *VersionStringResponse) UnmarshalVT(dAtA []byte) error

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.