pb

package
v0.0.0-...-44a46bf Latest Latest
Warning

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

 Go to latest Published: Dec 25, 2024 License: Apache-2.0 Imports: 21 Imported by: 2

Documentation

Overview

Package pb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthDmmaster        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowDmmaster          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupDmmaster = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthDmworker        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowDmworker          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupDmworker = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var CfgType_name = map[int32]string{
	0: "InvalidType",
	1: "TaskType",
	2: "MasterType",
	3: "WorkerType",
	4: "SourceType",
	5: "TaskTemplateType",
}
View Source 
var CfgType_value = map[string]int32{
	"InvalidType":      0,
	"TaskType":         1,
	"MasterType":       2,
	"WorkerType":       3,
	"SourceType":       4,
	"TaskTemplateType": 5,
}
View Source 
var ErrorOp_name = map[int32]string{
	0: "InvalidErrorOp",
	1: "Skip",
	2: "Replace",
	3: "Revert",
	4: "Inject",
	5: "List",
}
View Source 
var ErrorOp_value = map[string]int32{
	"InvalidErrorOp": 0,
	"Skip":           1,
	"Replace":        2,
	"Revert":         3,
	"Inject":         4,
	"List":           5,
}
View Source 
var LeaderOp_name = map[int32]string{
	0: "InvalidLeaderOp",
	1: "EvictLeaderOp",
	2: "CancelEvictLeaderOp",
}
View Source 
var LeaderOp_value = map[string]int32{
	"InvalidLeaderOp":     0,
	"EvictLeaderOp":       1,
	"CancelEvictLeaderOp": 2,
}
View Source 
var RelayOpV2_name = map[int32]string{
	0: "InvalidRelayOpV2",
	1: "StartRelayV2",
	2: "StopRelayV2",
}
View Source 
var RelayOpV2_value = map[string]int32{
	"InvalidRelayOpV2": 0,
	"StartRelayV2":     1,
	"StopRelayV2":      2,
}
View Source 
var RelayOp_name = map[int32]string{
	0: "InvalidRelayOp",
	1: "StopRelay",
	2: "PauseRelay",
	3: "ResumeRelay",
}
View Source 
var RelayOp_value = map[string]int32{
	"InvalidRelayOp": 0,
	"StopRelay":      1,
	"PauseRelay":     2,
	"ResumeRelay":    3,
}
View Source 
var SchemaOp_name = map[int32]string{
	0: "InvalidSchemaOp",
	1: "GetSchema",
	2: "SetSchema",
	3: "RemoveSchema",
	4: "ListSchema",
	5: "ListTable",
	6: "ListMigrateTargets",
}
View Source 
var SchemaOp_value = map[string]int32{
	"InvalidSchemaOp":    0,
	"GetSchema":          1,
	"SetSchema":          2,
	"RemoveSchema":       3,
	"ListSchema":         4,
	"ListTable":          5,
	"ListMigrateTargets": 6,
}
View Source 
var SourceOp_name = map[int32]string{
	0: "InvalidSourceOp",
	1: "StartSource",
	2: "UpdateSource",
	3: "StopSource",
	4: "ShowSource",
}
View Source 
var SourceOp_value = map[string]int32{
	"InvalidSourceOp": 0,
	"StartSource":     1,
	"UpdateSource":    2,
	"StopSource":      3,
	"ShowSource":      4,
}
View Source 
var Stage_name = map[int32]string{
	0: "InvalidStage",
	1: "New",
	2: "Running",
	3: "Paused",
	4: "Stopped",
	5: "Finished",
	6: "Pausing",
	7: "Resuming",
	8: "Stopping",
}
View Source 
var Stage_value = map[string]int32{
	"InvalidStage": 0,
	"New":          1,
	"Running":      2,
	"Paused":       3,
	"Stopped":      4,
	"Finished":     5,
	"Pausing":      6,
	"Resuming":     7,
	"Stopping":     8,
}
View Source 
var TaskOp_name = map[int32]string{
	0: "InvalidOp",
	1: "Stop",
	2: "Pause",
	3: "Resume",
	4: "Start",
	5: "Update",
	6: "AutoResume",
	7: "Delete",
}
View Source 
var TaskOp_value = map[string]int32{
	"InvalidOp":  0,
	"Stop":       1,
	"Pause":      2,
	"Resume":     3,
	"Start":      4,
	"Update":     5,
	"AutoResume": 6,
	"Delete":     7,
}
View Source 
var UnitType_name = map[int32]string{
	0:   "InvalidUnit",
	1:   "Check",
	2:   "Dump",
	3:   "Load",
	4:   "Sync",
	100: "Relay",
}
View Source 
var UnitType_value = map[string]int32{
	"InvalidUnit": 0,
	"Check":       1,
	"Dump":        2,
	"Load":        3,
	"Sync":        4,
	"Relay":       100,
}
View Source 
var UnlockDDLLockOp_name = map[int32]string{
	0: "InvalidLockOp",
	1: "SkipLock",
	2: "ExecLock",
}
View Source 
var UnlockDDLLockOp_value = map[string]int32{
	"InvalidLockOp": 0,
	"SkipLock":      1,
	"ExecLock":      2,
}
View Source 
var V1MetaOp_name = map[int32]string{
	0: "InvalidV1MetaOp",
	1: "GetV1Meta",
	2: "RemoveV1Meta",
}
View Source 
var V1MetaOp_value = map[string]int32{
	"InvalidV1MetaOp": 0,
	"GetV1Meta":       1,
	"RemoveV1Meta":    2,
}
View Source 
var ValidateErrorState_name = map[int32]string{
	0: "InvalidErr",
	1: "NewErr",
	2: "IgnoredErr",
	3: "ResolvedErr",
}
View Source 
var ValidateErrorState_value = map[string]int32{
	"InvalidErr":  0,
	"NewErr":      1,
	"IgnoredErr":  2,
	"ResolvedErr": 3,
}
View Source 
var ValidationErrOp_name = map[int32]string{
	0: "InvalidErrOp",
	1: "IgnoreErrOp",
	2: "ResolveErrOp",
	3: "ClearErrOp",
}
View Source 
var ValidationErrOp_value = map[string]int32{
	"InvalidErrOp": 0,
	"IgnoreErrOp":  1,
	"ResolveErrOp": 2,
	"ClearErrOp":   3,
}
View Source 
var ValidatorOp_name = map[int32]string{
	0: "InvalidValidatorOp",
	1: "StartValidator",
	2: "StopValidator",
}
View Source 
var ValidatorOp_value = map[string]int32{
	"InvalidValidatorOp": 0,
	"StartValidator":     1,
	"StopValidator":      2,
}

Functions

func RegisterMasterHandler 

func RegisterMasterHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterMasterHandler registers the http handlers for service Master to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterMasterHandlerClient 

func RegisterMasterHandlerClient(ctx context.Context, mux *runtime.ServeMux, client MasterClient) error

RegisterMasterHandlerClient registers the http handlers for service Master to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "MasterClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "MasterClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "MasterClient" to call the correct interceptors.

func RegisterMasterHandlerFromEndpoint 

func RegisterMasterHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterMasterHandlerFromEndpoint is same as RegisterMasterHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterMasterHandlerServer 

func RegisterMasterHandlerServer(ctx context.Context, mux *runtime.ServeMux, server MasterServer) error

RegisterMasterHandlerServer registers the http handlers for service Master to "mux". UnaryRPC :call MasterServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterMasterHandlerFromEndpoint instead.

func RegisterMasterServer 

func RegisterMasterServer(s *grpc.Server, srv MasterServer)

func RegisterWorkerServer 

func RegisterWorkerServer(s *grpc.Server, srv WorkerServer)

Types

type CfgType 

type CfgType int32
const (
	CfgType_InvalidType      CfgType = 0
	CfgType_TaskType         CfgType = 1
	CfgType_MasterType       CfgType = 2
	CfgType_WorkerType       CfgType = 3
	CfgType_SourceType       CfgType = 4
	CfgType_TaskTemplateType CfgType = 5
)

func (CfgType) EnumDescriptor 

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

func (CfgType) String 

func (x CfgType) String() string

type CheckError 

type CheckError struct {
	Msg string `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
}

CheckError represents error for check unit adds fields later

func (*CheckError) Descriptor 

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

func (*CheckError) GetMsg 

func (m *CheckError) GetMsg() string

func (*CheckError) Marshal 

func (m *CheckError) Marshal() (dAtA []byte, err error)

func (*CheckError) MarshalTo 

func (m *CheckError) MarshalTo(dAtA []byte) (int, error)

func (*CheckError) MarshalToSizedBuffer 

func (m *CheckError) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CheckError) ProtoMessage 

func (*CheckError) ProtoMessage()

func (*CheckError) Reset 

func (m *CheckError) Reset()

func (*CheckError) Size 

func (m *CheckError) Size() (n int)

func (*CheckError) String 

func (m *CheckError) String() string

func (*CheckError) Unmarshal 

func (m *CheckError) Unmarshal(dAtA []byte) error

func (*CheckError) XXX_DiscardUnknown 

func (m *CheckError) XXX_DiscardUnknown()

func (*CheckError) XXX_Marshal 

func (m *CheckError) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CheckError) XXX_Merge 

func (m *CheckError) XXX_Merge(src proto.Message)

func (*CheckError) XXX_Size 

func (m *CheckError) XXX_Size() int

func (*CheckError) XXX_Unmarshal 

func (m *CheckError) XXX_Unmarshal(b []byte) error

type CheckStatus 

type CheckStatus struct {
	Passed     bool   `protobuf:"varint,1,opt,name=passed,proto3" json:"passed,omitempty"`
	Total      int32  `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"`
	Successful int32  `protobuf:"varint,3,opt,name=successful,proto3" json:"successful,omitempty"`
	Failed     int32  `protobuf:"varint,4,opt,name=failed,proto3" json:"failed,omitempty"`
	Warning    int32  `protobuf:"varint,5,opt,name=warning,proto3" json:"warning,omitempty"`
	Detail     []byte `protobuf:"bytes,6,opt,name=detail,proto3" json:"detail,omitempty"`
}

CheckStatus represents status for check unit adds fields later

func (*CheckStatus) Descriptor 

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

func (*CheckStatus) GetDetail 

func (m *CheckStatus) GetDetail() []byte

func (*CheckStatus) GetFailed 

func (m *CheckStatus) GetFailed() int32

func (*CheckStatus) GetPassed 

func (m *CheckStatus) GetPassed() bool

func (*CheckStatus) GetSuccessful 

func (m *CheckStatus) GetSuccessful() int32

func (*CheckStatus) GetTotal 

func (m *CheckStatus) GetTotal() int32

func (*CheckStatus) GetWarning 

func (m *CheckStatus) GetWarning() int32

func (*CheckStatus) Marshal 

func (m *CheckStatus) Marshal() (dAtA []byte, err error)

func (*CheckStatus) MarshalTo 

func (m *CheckStatus) MarshalTo(dAtA []byte) (int, error)

func (*CheckStatus) MarshalToSizedBuffer 

func (m *CheckStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CheckStatus) ProtoMessage 

func (*CheckStatus) ProtoMessage()

func (*CheckStatus) Reset 

func (m *CheckStatus) Reset()

func (*CheckStatus) Size 

func (m *CheckStatus) Size() (n int)

func (*CheckStatus) String 

func (m *CheckStatus) String() string

func (*CheckStatus) Unmarshal 

func (m *CheckStatus) Unmarshal(dAtA []byte) error

func (*CheckStatus) XXX_DiscardUnknown 

func (m *CheckStatus) XXX_DiscardUnknown()

func (*CheckStatus) XXX_Marshal 

func (m *CheckStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CheckStatus) XXX_Merge 

func (m *CheckStatus) XXX_Merge(src proto.Message)

func (*CheckStatus) XXX_Size 

func (m *CheckStatus) XXX_Size() int

func (*CheckStatus) XXX_Unmarshal 

func (m *CheckStatus) XXX_Unmarshal(b []byte) error

type CheckSubtasksCanUpdateRequest 

type CheckSubtasksCanUpdateRequest struct {
	SubtaskCfgTomlString string `protobuf:"bytes,1,opt,name=subtaskCfgTomlString,proto3" json:"subtaskCfgTomlString,omitempty"`
}

func (*CheckSubtasksCanUpdateRequest) Descriptor 

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

func (*CheckSubtasksCanUpdateRequest) GetSubtaskCfgTomlString 

func (m *CheckSubtasksCanUpdateRequest) GetSubtaskCfgTomlString() string

func (*CheckSubtasksCanUpdateRequest) Marshal 

func (m *CheckSubtasksCanUpdateRequest) Marshal() (dAtA []byte, err error)

func (*CheckSubtasksCanUpdateRequest) MarshalTo 

func (m *CheckSubtasksCanUpdateRequest) MarshalTo(dAtA []byte) (int, error)

func (*CheckSubtasksCanUpdateRequest) MarshalToSizedBuffer 

func (m *CheckSubtasksCanUpdateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CheckSubtasksCanUpdateRequest) ProtoMessage 

func (*CheckSubtasksCanUpdateRequest) ProtoMessage()

func (*CheckSubtasksCanUpdateRequest) Reset 

func (m *CheckSubtasksCanUpdateRequest) Reset()

func (*CheckSubtasksCanUpdateRequest) Size 

func (m *CheckSubtasksCanUpdateRequest) Size() (n int)

func (*CheckSubtasksCanUpdateRequest) String 

func (m *CheckSubtasksCanUpdateRequest) String() string

func (*CheckSubtasksCanUpdateRequest) Unmarshal 

func (m *CheckSubtasksCanUpdateRequest) Unmarshal(dAtA []byte) error

func (*CheckSubtasksCanUpdateRequest) XXX_DiscardUnknown 

func (m *CheckSubtasksCanUpdateRequest) XXX_DiscardUnknown()

func (*CheckSubtasksCanUpdateRequest) XXX_Marshal 

func (m *CheckSubtasksCanUpdateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CheckSubtasksCanUpdateRequest) XXX_Merge 

func (m *CheckSubtasksCanUpdateRequest) XXX_Merge(src proto.Message)

func (*CheckSubtasksCanUpdateRequest) XXX_Size 

func (m *CheckSubtasksCanUpdateRequest) XXX_Size() int

func (*CheckSubtasksCanUpdateRequest) XXX_Unmarshal 

func (m *CheckSubtasksCanUpdateRequest) XXX_Unmarshal(b []byte) error

type CheckSubtasksCanUpdateResponse 

type CheckSubtasksCanUpdateResponse struct {
	Success bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Msg     string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
}

func (*CheckSubtasksCanUpdateResponse) Descriptor 

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

func (*CheckSubtasksCanUpdateResponse) GetMsg 

func (m *CheckSubtasksCanUpdateResponse) GetMsg() string

func (*CheckSubtasksCanUpdateResponse) GetSuccess 

func (m *CheckSubtasksCanUpdateResponse) GetSuccess() bool

func (*CheckSubtasksCanUpdateResponse) Marshal 

func (m *CheckSubtasksCanUpdateResponse) Marshal() (dAtA []byte, err error)

func (*CheckSubtasksCanUpdateResponse) MarshalTo 

func (m *CheckSubtasksCanUpdateResponse) MarshalTo(dAtA []byte) (int, error)

func (*CheckSubtasksCanUpdateResponse) MarshalToSizedBuffer 

func (m *CheckSubtasksCanUpdateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CheckSubtasksCanUpdateResponse) ProtoMessage 

func (*CheckSubtasksCanUpdateResponse) ProtoMessage()

func (*CheckSubtasksCanUpdateResponse) Reset 

func (m *CheckSubtasksCanUpdateResponse) Reset()

func (*CheckSubtasksCanUpdateResponse) Size 

func (m *CheckSubtasksCanUpdateResponse) Size() (n int)

func (*CheckSubtasksCanUpdateResponse) String 

func (m *CheckSubtasksCanUpdateResponse) String() string

func (*CheckSubtasksCanUpdateResponse) Unmarshal 

func (m *CheckSubtasksCanUpdateResponse) Unmarshal(dAtA []byte) error

func (*CheckSubtasksCanUpdateResponse) XXX_DiscardUnknown 

func (m *CheckSubtasksCanUpdateResponse) XXX_DiscardUnknown()

func (*CheckSubtasksCanUpdateResponse) XXX_Marshal 

func (m *CheckSubtasksCanUpdateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CheckSubtasksCanUpdateResponse) XXX_Merge 

func (m *CheckSubtasksCanUpdateResponse) XXX_Merge(src proto.Message)

func (*CheckSubtasksCanUpdateResponse) XXX_Size 

func (m *CheckSubtasksCanUpdateResponse) XXX_Size() int

func (*CheckSubtasksCanUpdateResponse) XXX_Unmarshal 

func (m *CheckSubtasksCanUpdateResponse) XXX_Unmarshal(b []byte) error

type CheckTaskRequest 

type CheckTaskRequest struct {
	Task      string `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	ErrCnt    int64  `protobuf:"varint,2,opt,name=errCnt,proto3" json:"errCnt,omitempty"`
	WarnCnt   int64  `protobuf:"varint,3,opt,name=warnCnt,proto3" json:"warnCnt,omitempty"`
	StartTime string `protobuf:"bytes,4,opt,name=startTime,proto3" json:"startTime,omitempty"`
}

func (*CheckTaskRequest) Descriptor 

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

func (*CheckTaskRequest) GetErrCnt 

func (m *CheckTaskRequest) GetErrCnt() int64

func (*CheckTaskRequest) GetStartTime 

func (m *CheckTaskRequest) GetStartTime() string

func (*CheckTaskRequest) GetTask 

func (m *CheckTaskRequest) GetTask() string

func (*CheckTaskRequest) GetWarnCnt 

func (m *CheckTaskRequest) GetWarnCnt() int64

func (*CheckTaskRequest) Marshal 

func (m *CheckTaskRequest) Marshal() (dAtA []byte, err error)

func (*CheckTaskRequest) MarshalTo 

func (m *CheckTaskRequest) MarshalTo(dAtA []byte) (int, error)

func (*CheckTaskRequest) MarshalToSizedBuffer 

func (m *CheckTaskRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CheckTaskRequest) ProtoMessage 

func (*CheckTaskRequest) ProtoMessage()

func (*CheckTaskRequest) Reset 

func (m *CheckTaskRequest) Reset()

func (*CheckTaskRequest) Size 

func (m *CheckTaskRequest) Size() (n int)

func (*CheckTaskRequest) String 

func (m *CheckTaskRequest) String() string

func (*CheckTaskRequest) Unmarshal 

func (m *CheckTaskRequest) Unmarshal(dAtA []byte) error

func (*CheckTaskRequest) XXX_DiscardUnknown 

func (m *CheckTaskRequest) XXX_DiscardUnknown()

func (*CheckTaskRequest) XXX_Marshal 

func (m *CheckTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CheckTaskRequest) XXX_Merge 

func (m *CheckTaskRequest) XXX_Merge(src proto.Message)

func (*CheckTaskRequest) XXX_Size 

func (m *CheckTaskRequest) XXX_Size() int

func (*CheckTaskRequest) XXX_Unmarshal 

func (m *CheckTaskRequest) XXX_Unmarshal(b []byte) error

type CheckTaskResponse 

type CheckTaskResponse struct {
	Result bool   `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"`
	Msg    string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
}

func (*CheckTaskResponse) Descriptor 

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

func (*CheckTaskResponse) GetMsg 

func (m *CheckTaskResponse) GetMsg() string

func (*CheckTaskResponse) GetResult 

func (m *CheckTaskResponse) GetResult() bool

func (*CheckTaskResponse) Marshal 

func (m *CheckTaskResponse) Marshal() (dAtA []byte, err error)

func (*CheckTaskResponse) MarshalTo 

func (m *CheckTaskResponse) MarshalTo(dAtA []byte) (int, error)

func (*CheckTaskResponse) MarshalToSizedBuffer 

func (m *CheckTaskResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CheckTaskResponse) ProtoMessage 

func (*CheckTaskResponse) ProtoMessage()

func (*CheckTaskResponse) Reset 

func (m *CheckTaskResponse) Reset()

func (*CheckTaskResponse) Size 

func (m *CheckTaskResponse) Size() (n int)

func (*CheckTaskResponse) String 

func (m *CheckTaskResponse) String() string

func (*CheckTaskResponse) Unmarshal 

func (m *CheckTaskResponse) Unmarshal(dAtA []byte) error

func (*CheckTaskResponse) XXX_DiscardUnknown 

func (m *CheckTaskResponse) XXX_DiscardUnknown()

func (*CheckTaskResponse) XXX_Marshal 

func (m *CheckTaskResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CheckTaskResponse) XXX_Merge 

func (m *CheckTaskResponse) XXX_Merge(src proto.Message)

func (*CheckTaskResponse) XXX_Size 

func (m *CheckTaskResponse) XXX_Size() int

func (*CheckTaskResponse) XXX_Unmarshal 

func (m *CheckTaskResponse) XXX_Unmarshal(b []byte) error

type CommonWorkerResponse 

type CommonWorkerResponse struct {
	Result bool   `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"`
	Msg    string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	Source string `protobuf:"bytes,3,opt,name=source,proto3" json:"source,omitempty"`
	Worker string `protobuf:"bytes,4,opt,name=worker,proto3" json:"worker,omitempty"`
}

func (*CommonWorkerResponse) Descriptor 

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

func (*CommonWorkerResponse) GetMsg 

func (m *CommonWorkerResponse) GetMsg() string

func (*CommonWorkerResponse) GetResult 

func (m *CommonWorkerResponse) GetResult() bool

func (*CommonWorkerResponse) GetSource 

func (m *CommonWorkerResponse) GetSource() string

func (*CommonWorkerResponse) GetWorker 

func (m *CommonWorkerResponse) GetWorker() string

func (*CommonWorkerResponse) Marshal 

func (m *CommonWorkerResponse) Marshal() (dAtA []byte, err error)

func (*CommonWorkerResponse) MarshalTo 

func (m *CommonWorkerResponse) MarshalTo(dAtA []byte) (int, error)

func (*CommonWorkerResponse) MarshalToSizedBuffer 

func (m *CommonWorkerResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CommonWorkerResponse) ProtoMessage 

func (*CommonWorkerResponse) ProtoMessage()

func (*CommonWorkerResponse) Reset 

func (m *CommonWorkerResponse) Reset()

func (*CommonWorkerResponse) Size 

func (m *CommonWorkerResponse) Size() (n int)

func (*CommonWorkerResponse) String 

func (m *CommonWorkerResponse) String() string

func (*CommonWorkerResponse) Unmarshal 

func (m *CommonWorkerResponse) Unmarshal(dAtA []byte) error

func (*CommonWorkerResponse) XXX_DiscardUnknown 

func (m *CommonWorkerResponse) XXX_DiscardUnknown()

func (*CommonWorkerResponse) XXX_Marshal 

func (m *CommonWorkerResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommonWorkerResponse) XXX_Merge 

func (m *CommonWorkerResponse) XXX_Merge(src proto.Message)

func (*CommonWorkerResponse) XXX_Size 

func (m *CommonWorkerResponse) XXX_Size() int

func (*CommonWorkerResponse) XXX_Unmarshal 

func (m *CommonWorkerResponse) XXX_Unmarshal(b []byte) error

type DDLLock 

type DDLLock struct {
	ID       string   `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Task     string   `protobuf:"bytes,2,opt,name=task,proto3" json:"task,omitempty"`
	Mode     string   `protobuf:"bytes,3,opt,name=mode,proto3" json:"mode,omitempty"`
	Owner    string   `protobuf:"bytes,4,opt,name=owner,proto3" json:"owner,omitempty"`
	DDLs     []string `protobuf:"bytes,5,rep,name=DDLs,proto3" json:"DDLs,omitempty"`
	Synced   []string `protobuf:"bytes,6,rep,name=synced,proto3" json:"synced,omitempty"`
	Unsynced []string `protobuf:"bytes,7,rep,name=unsynced,proto3" json:"unsynced,omitempty"`
}

DDLLock represents a DDL lock info (I known the name confused with DDLLockInfo, any suggestion?) it been sent from dm-master to dmctl ID: DDL lock generated ID task: lock's corresponding task name mode: the shard DDL mode, `pessimistic` or `optimistic`. owner: lock's owner, a dm-worker DDL: DDL statement synced: already synced dm-workers unsynced: pending to sync dm-workers

func (*DDLLock) Descriptor 

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

func (*DDLLock) GetDDLs 

func (m *DDLLock) GetDDLs() []string

func (*DDLLock) GetID 

func (m *DDLLock) GetID() string

func (*DDLLock) GetMode 

func (m *DDLLock) GetMode() string

func (*DDLLock) GetOwner 

func (m *DDLLock) GetOwner() string

func (*DDLLock) GetSynced 

func (m *DDLLock) GetSynced() []string

func (*DDLLock) GetTask 

func (m *DDLLock) GetTask() string

func (*DDLLock) GetUnsynced 

func (m *DDLLock) GetUnsynced() []string

func (*DDLLock) Marshal 

func (m *DDLLock) Marshal() (dAtA []byte, err error)

func (*DDLLock) MarshalTo 

func (m *DDLLock) MarshalTo(dAtA []byte) (int, error)

func (*DDLLock) MarshalToSizedBuffer 

func (m *DDLLock) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DDLLock) ProtoMessage 

func (*DDLLock) ProtoMessage()

func (*DDLLock) Reset 

func (m *DDLLock) Reset()

func (*DDLLock) Size 

func (m *DDLLock) Size() (n int)

func (*DDLLock) String 

func (m *DDLLock) String() string

func (*DDLLock) Unmarshal 

func (m *DDLLock) Unmarshal(dAtA []byte) error

func (*DDLLock) XXX_DiscardUnknown 

func (m *DDLLock) XXX_DiscardUnknown()

func (*DDLLock) XXX_Marshal 

func (m *DDLLock) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DDLLock) XXX_Merge 

func (m *DDLLock) XXX_Merge(src proto.Message)

func (*DDLLock) XXX_Size 

func (m *DDLLock) XXX_Size() int

func (*DDLLock) XXX_Unmarshal 

func (m *DDLLock) XXX_Unmarshal(b []byte) error

type DumpError 

type DumpError struct {
	Msg string `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
}

DumpError represents error for dump unit add fields later

func (*DumpError) Descriptor 

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

func (*DumpError) GetMsg 

func (m *DumpError) GetMsg() string

func (*DumpError) Marshal 

func (m *DumpError) Marshal() (dAtA []byte, err error)

func (*DumpError) MarshalTo 

func (m *DumpError) MarshalTo(dAtA []byte) (int, error)

func (*DumpError) MarshalToSizedBuffer 

func (m *DumpError) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DumpError) ProtoMessage 

func (*DumpError) ProtoMessage()

func (*DumpError) Reset 

func (m *DumpError) Reset()

func (*DumpError) Size 

func (m *DumpError) Size() (n int)

func (*DumpError) String 

func (m *DumpError) String() string

func (*DumpError) Unmarshal 

func (m *DumpError) Unmarshal(dAtA []byte) error

func (*DumpError) XXX_DiscardUnknown 

func (m *DumpError) XXX_DiscardUnknown()

func (*DumpError) XXX_Marshal 

func (m *DumpError) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DumpError) XXX_Merge 

func (m *DumpError) XXX_Merge(src proto.Message)

func (*DumpError) XXX_Size 

func (m *DumpError) XXX_Size() int

func (*DumpError) XXX_Unmarshal 

func (m *DumpError) XXX_Unmarshal(b []byte) error

type DumpStatus 

type DumpStatus struct {
	TotalTables       int64   `protobuf:"varint,1,opt,name=totalTables,proto3" json:"totalTables,omitempty"`
	CompletedTables   float64 `protobuf:"fixed64,2,opt,name=completedTables,proto3" json:"completedTables,omitempty"`
	FinishedBytes     float64 `protobuf:"fixed64,3,opt,name=finishedBytes,proto3" json:"finishedBytes,omitempty"`
	FinishedRows      float64 `protobuf:"fixed64,4,opt,name=finishedRows,proto3" json:"finishedRows,omitempty"`
	EstimateTotalRows float64 `protobuf:"fixed64,5,opt,name=estimateTotalRows,proto3" json:"estimateTotalRows,omitempty"`
	Bps               int64   `protobuf:"varint,6,opt,name=bps,proto3" json:"bps,omitempty"`
	Progress          string  `protobuf:"bytes,7,opt,name=progress,proto3" json:"progress,omitempty"`
}

DumpStatus represents status for dump unit add fields later

func (*DumpStatus) Descriptor 

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

func (*DumpStatus) GetBps 

func (m *DumpStatus) GetBps() int64

func (*DumpStatus) GetCompletedTables 

func (m *DumpStatus) GetCompletedTables() float64

func (*DumpStatus) GetEstimateTotalRows 

func (m *DumpStatus) GetEstimateTotalRows() float64

func (*DumpStatus) GetFinishedBytes 

func (m *DumpStatus) GetFinishedBytes() float64

func (*DumpStatus) GetFinishedRows 

func (m *DumpStatus) GetFinishedRows() float64

func (*DumpStatus) GetProgress 

func (m *DumpStatus) GetProgress() string

func (*DumpStatus) GetTotalTables 

func (m *DumpStatus) GetTotalTables() int64

func (*DumpStatus) Marshal 

func (m *DumpStatus) Marshal() (dAtA []byte, err error)

func (*DumpStatus) MarshalTo 

func (m *DumpStatus) MarshalTo(dAtA []byte) (int, error)

func (*DumpStatus) MarshalToSizedBuffer 

func (m *DumpStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DumpStatus) ProtoMessage 

func (*DumpStatus) ProtoMessage()

func (*DumpStatus) Reset 

func (m *DumpStatus) Reset()

func (*DumpStatus) Size 

func (m *DumpStatus) Size() (n int)

func (*DumpStatus) String 

func (m *DumpStatus) String() string

func (*DumpStatus) Unmarshal 

func (m *DumpStatus) Unmarshal(dAtA []byte) error

func (*DumpStatus) XXX_DiscardUnknown 

func (m *DumpStatus) XXX_DiscardUnknown()

func (*DumpStatus) XXX_Marshal 

func (m *DumpStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DumpStatus) XXX_Merge 

func (m *DumpStatus) XXX_Merge(src proto.Message)

func (*DumpStatus) XXX_Size 

func (m *DumpStatus) XXX_Size() int

func (*DumpStatus) XXX_Unmarshal 

func (m *DumpStatus) XXX_Unmarshal(b []byte) error

type EncryptRequest 

type EncryptRequest struct {
	Plaintext string `protobuf:"bytes,1,opt,name=plaintext,proto3" json:"plaintext,omitempty"`
}

func (*EncryptRequest) Descriptor 

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

func (*EncryptRequest) GetPlaintext 

func (m *EncryptRequest) GetPlaintext() string

func (*EncryptRequest) Marshal 

func (m *EncryptRequest) Marshal() (dAtA []byte, err error)

func (*EncryptRequest) MarshalTo 

func (m *EncryptRequest) MarshalTo(dAtA []byte) (int, error)

func (*EncryptRequest) MarshalToSizedBuffer 

func (m *EncryptRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EncryptRequest) ProtoMessage 

func (*EncryptRequest) ProtoMessage()

func (*EncryptRequest) Reset 

func (m *EncryptRequest) Reset()

func (*EncryptRequest) Size 

func (m *EncryptRequest) Size() (n int)

func (*EncryptRequest) String 

func (m *EncryptRequest) String() string

func (*EncryptRequest) Unmarshal 

func (m *EncryptRequest) Unmarshal(dAtA []byte) error

func (*EncryptRequest) XXX_DiscardUnknown 

func (m *EncryptRequest) XXX_DiscardUnknown()

func (*EncryptRequest) XXX_Marshal 

func (m *EncryptRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EncryptRequest) XXX_Merge 

func (m *EncryptRequest) XXX_Merge(src proto.Message)

func (*EncryptRequest) XXX_Size 

func (m *EncryptRequest) XXX_Size() int

func (*EncryptRequest) XXX_Unmarshal 

func (m *EncryptRequest) XXX_Unmarshal(b []byte) error

type EncryptResponse 

type EncryptResponse struct {
	Result     bool   `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"`
	Msg        string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	Ciphertext string `protobuf:"bytes,3,opt,name=ciphertext,proto3" json:"ciphertext,omitempty"`
}

func (*EncryptResponse) Descriptor 

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

func (*EncryptResponse) GetCiphertext 

func (m *EncryptResponse) GetCiphertext() string

func (*EncryptResponse) GetMsg 

func (m *EncryptResponse) GetMsg() string

func (*EncryptResponse) GetResult 

func (m *EncryptResponse) GetResult() bool

func (*EncryptResponse) Marshal 

func (m *EncryptResponse) Marshal() (dAtA []byte, err error)

func (*EncryptResponse) MarshalTo 

func (m *EncryptResponse) MarshalTo(dAtA []byte) (int, error)

func (*EncryptResponse) MarshalToSizedBuffer 

func (m *EncryptResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EncryptResponse) ProtoMessage 

func (*EncryptResponse) ProtoMessage()

func (*EncryptResponse) Reset 

func (m *EncryptResponse) Reset()

func (*EncryptResponse) Size 

func (m *EncryptResponse) Size() (n int)

func (*EncryptResponse) String 

func (m *EncryptResponse) String() string

func (*EncryptResponse) Unmarshal 

func (m *EncryptResponse) Unmarshal(dAtA []byte) error

func (*EncryptResponse) XXX_DiscardUnknown 

func (m *EncryptResponse) XXX_DiscardUnknown()

func (*EncryptResponse) XXX_Marshal 

func (m *EncryptResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EncryptResponse) XXX_Merge 

func (m *EncryptResponse) XXX_Merge(src proto.Message)

func (*EncryptResponse) XXX_Size 

func (m *EncryptResponse) XXX_Size() int

func (*EncryptResponse) XXX_Unmarshal 

func (m *EncryptResponse) XXX_Unmarshal(b []byte) error

type ErrorOp 

type ErrorOp int32
const (
	ErrorOp_InvalidErrorOp ErrorOp = 0
	ErrorOp_Skip           ErrorOp = 1
	ErrorOp_Replace        ErrorOp = 2
	ErrorOp_Revert         ErrorOp = 3
	ErrorOp_Inject         ErrorOp = 4
	ErrorOp_List           ErrorOp = 5
)

func (ErrorOp) EnumDescriptor 

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

func (ErrorOp) String 

func (x ErrorOp) String() string

type GetCfgRequest 

type GetCfgRequest struct {
	Type CfgType `protobuf:"varint,1,opt,name=type,proto3,enum=pb.CfgType" json:"type,omitempty"`
	Name string  `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
}

func (*GetCfgRequest) Descriptor 

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

func (*GetCfgRequest) GetName 

func (m *GetCfgRequest) GetName() string

func (*GetCfgRequest) GetType 

func (m *GetCfgRequest) GetType() CfgType

func (*GetCfgRequest) Marshal 

func (m *GetCfgRequest) Marshal() (dAtA []byte, err error)

func (*GetCfgRequest) MarshalTo 

func (m *GetCfgRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetCfgRequest) MarshalToSizedBuffer 

func (m *GetCfgRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetCfgRequest) ProtoMessage 

func (*GetCfgRequest) ProtoMessage()

func (*GetCfgRequest) Reset 

func (m *GetCfgRequest) Reset()

func (*GetCfgRequest) Size 

func (m *GetCfgRequest) Size() (n int)

func (*GetCfgRequest) String 

func (m *GetCfgRequest) String() string

func (*GetCfgRequest) Unmarshal 

func (m *GetCfgRequest) Unmarshal(dAtA []byte) error

func (*GetCfgRequest) XXX_DiscardUnknown 

func (m *GetCfgRequest) XXX_DiscardUnknown()

func (*GetCfgRequest) XXX_Marshal 

func (m *GetCfgRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetCfgRequest) XXX_Merge 

func (m *GetCfgRequest) XXX_Merge(src proto.Message)

func (*GetCfgRequest) XXX_Size 

func (m *GetCfgRequest) XXX_Size() int

func (*GetCfgRequest) XXX_Unmarshal 

func (m *GetCfgRequest) XXX_Unmarshal(b []byte) error

type GetCfgResponse 

type GetCfgResponse struct {
	Result bool   `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"`
	Msg    string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	Cfg    string `protobuf:"bytes,3,opt,name=cfg,proto3" json:"cfg,omitempty"`
}

func (*GetCfgResponse) Descriptor 

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

func (*GetCfgResponse) GetCfg 

func (m *GetCfgResponse) GetCfg() string

func (*GetCfgResponse) GetMsg 

func (m *GetCfgResponse) GetMsg() string

func (*GetCfgResponse) GetResult 

func (m *GetCfgResponse) GetResult() bool

func (*GetCfgResponse) Marshal 

func (m *GetCfgResponse) Marshal() (dAtA []byte, err error)

func (*GetCfgResponse) MarshalTo 

func (m *GetCfgResponse) MarshalTo(dAtA []byte) (int, error)

func (*GetCfgResponse) MarshalToSizedBuffer 

func (m *GetCfgResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetCfgResponse) ProtoMessage 

func (*GetCfgResponse) ProtoMessage()

func (*GetCfgResponse) Reset 

func (m *GetCfgResponse) Reset()

func (*GetCfgResponse) Size 

func (m *GetCfgResponse) Size() (n int)

func (*GetCfgResponse) String 

func (m *GetCfgResponse) String() string

func (*GetCfgResponse) Unmarshal 

func (m *GetCfgResponse) Unmarshal(dAtA []byte) error

func (*GetCfgResponse) XXX_DiscardUnknown 

func (m *GetCfgResponse) XXX_DiscardUnknown()

func (*GetCfgResponse) XXX_Marshal 

func (m *GetCfgResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetCfgResponse) XXX_Merge 

func (m *GetCfgResponse) XXX_Merge(src proto.Message)

func (*GetCfgResponse) XXX_Size 

func (m *GetCfgResponse) XXX_Size() int

func (*GetCfgResponse) XXX_Unmarshal 

func (m *GetCfgResponse) XXX_Unmarshal(b []byte) error

type GetMasterCfgRequest 

type GetMasterCfgRequest struct {
}

func (*GetMasterCfgRequest) Descriptor 

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

func (*GetMasterCfgRequest) Marshal 

func (m *GetMasterCfgRequest) Marshal() (dAtA []byte, err error)

func (*GetMasterCfgRequest) MarshalTo 

func (m *GetMasterCfgRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetMasterCfgRequest) MarshalToSizedBuffer 

func (m *GetMasterCfgRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetMasterCfgRequest) ProtoMessage 

func (*GetMasterCfgRequest) ProtoMessage()

func (*GetMasterCfgRequest) Reset 

func (m *GetMasterCfgRequest) Reset()

func (*GetMasterCfgRequest) Size 

func (m *GetMasterCfgRequest) Size() (n int)

func (*GetMasterCfgRequest) String 

func (m *GetMasterCfgRequest) String() string

func (*GetMasterCfgRequest) Unmarshal 

func (m *GetMasterCfgRequest) Unmarshal(dAtA []byte) error

func (*GetMasterCfgRequest) XXX_DiscardUnknown 

func (m *GetMasterCfgRequest) XXX_DiscardUnknown()

func (*GetMasterCfgRequest) XXX_Marshal 

func (m *GetMasterCfgRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetMasterCfgRequest) XXX_Merge 

func (m *GetMasterCfgRequest) XXX_Merge(src proto.Message)

func (*GetMasterCfgRequest) XXX_Size 

func (m *GetMasterCfgRequest) XXX_Size() int

func (*GetMasterCfgRequest) XXX_Unmarshal 

func (m *GetMasterCfgRequest) XXX_Unmarshal(b []byte) error

type GetMasterCfgResponse 

type GetMasterCfgResponse struct {
	Cfg string `protobuf:"bytes,1,opt,name=cfg,proto3" json:"cfg,omitempty"`
}

func (*GetMasterCfgResponse) Descriptor 

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

func (*GetMasterCfgResponse) GetCfg 

func (m *GetMasterCfgResponse) GetCfg() string

func (*GetMasterCfgResponse) Marshal 

func (m *GetMasterCfgResponse) Marshal() (dAtA []byte, err error)

func (*GetMasterCfgResponse) MarshalTo 

func (m *GetMasterCfgResponse) MarshalTo(dAtA []byte) (int, error)

func (*GetMasterCfgResponse) MarshalToSizedBuffer 

func (m *GetMasterCfgResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetMasterCfgResponse) ProtoMessage 

func (*GetMasterCfgResponse) ProtoMessage()

func (*GetMasterCfgResponse) Reset 

func (m *GetMasterCfgResponse) Reset()

func (*GetMasterCfgResponse) Size 

func (m *GetMasterCfgResponse) Size() (n int)

func (*GetMasterCfgResponse) String 

func (m *GetMasterCfgResponse) String() string

func (*GetMasterCfgResponse) Unmarshal 

func (m *GetMasterCfgResponse) Unmarshal(dAtA []byte) error

func (*GetMasterCfgResponse) XXX_DiscardUnknown 

func (m *GetMasterCfgResponse) XXX_DiscardUnknown()

func (*GetMasterCfgResponse) XXX_Marshal 

func (m *GetMasterCfgResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetMasterCfgResponse) XXX_Merge 

func (m *GetMasterCfgResponse) XXX_Merge(src proto.Message)

func (*GetMasterCfgResponse) XXX_Size 

func (m *GetMasterCfgResponse) XXX_Size() int

func (*GetMasterCfgResponse) XXX_Unmarshal 

func (m *GetMasterCfgResponse) XXX_Unmarshal(b []byte) error

type GetSubTaskCfgRequest 

type GetSubTaskCfgRequest struct {
	// the task name
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
}

func (*GetSubTaskCfgRequest) Descriptor 

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

func (*GetSubTaskCfgRequest) GetName 

func (m *GetSubTaskCfgRequest) GetName() string

func (*GetSubTaskCfgRequest) Marshal 

func (m *GetSubTaskCfgRequest) Marshal() (dAtA []byte, err error)

func (*GetSubTaskCfgRequest) MarshalTo 

func (m *GetSubTaskCfgRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetSubTaskCfgRequest) MarshalToSizedBuffer 

func (m *GetSubTaskCfgRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetSubTaskCfgRequest) ProtoMessage 

func (*GetSubTaskCfgRequest) ProtoMessage()

func (*GetSubTaskCfgRequest) Reset 

func (m *GetSubTaskCfgRequest) Reset()

func (*GetSubTaskCfgRequest) Size 

func (m *GetSubTaskCfgRequest) Size() (n int)

func (*GetSubTaskCfgRequest) String 

func (m *GetSubTaskCfgRequest) String() string

func (*GetSubTaskCfgRequest) Unmarshal 

func (m *GetSubTaskCfgRequest) Unmarshal(dAtA []byte) error

func (*GetSubTaskCfgRequest) XXX_DiscardUnknown 

func (m *GetSubTaskCfgRequest) XXX_DiscardUnknown()

func (*GetSubTaskCfgRequest) XXX_Marshal 

func (m *GetSubTaskCfgRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetSubTaskCfgRequest) XXX_Merge 

func (m *GetSubTaskCfgRequest) XXX_Merge(src proto.Message)

func (*GetSubTaskCfgRequest) XXX_Size 

func (m *GetSubTaskCfgRequest) XXX_Size() int

func (*GetSubTaskCfgRequest) XXX_Unmarshal 

func (m *GetSubTaskCfgRequest) XXX_Unmarshal(b []byte) error

type GetSubTaskCfgResponse 

type GetSubTaskCfgResponse struct {
	Result bool     `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"`
	Msg    string   `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	Cfgs   []string `protobuf:"bytes,3,rep,name=cfgs,proto3" json:"cfgs,omitempty"`
}

func (*GetSubTaskCfgResponse) Descriptor 

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

func (*GetSubTaskCfgResponse) GetCfgs 

func (m *GetSubTaskCfgResponse) GetCfgs() []string

func (*GetSubTaskCfgResponse) GetMsg 

func (m *GetSubTaskCfgResponse) GetMsg() string

func (*GetSubTaskCfgResponse) GetResult 

func (m *GetSubTaskCfgResponse) GetResult() bool

func (*GetSubTaskCfgResponse) Marshal 

func (m *GetSubTaskCfgResponse) Marshal() (dAtA []byte, err error)

func (*GetSubTaskCfgResponse) MarshalTo 

func (m *GetSubTaskCfgResponse) MarshalTo(dAtA []byte) (int, error)

func (*GetSubTaskCfgResponse) MarshalToSizedBuffer 

func (m *GetSubTaskCfgResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetSubTaskCfgResponse) ProtoMessage 

func (*GetSubTaskCfgResponse) ProtoMessage()

func (*GetSubTaskCfgResponse) Reset 

func (m *GetSubTaskCfgResponse) Reset()

func (*GetSubTaskCfgResponse) Size 

func (m *GetSubTaskCfgResponse) Size() (n int)

func (*GetSubTaskCfgResponse) String 

func (m *GetSubTaskCfgResponse) String() string

func (*GetSubTaskCfgResponse) Unmarshal 

func (m *GetSubTaskCfgResponse) Unmarshal(dAtA []byte) error

func (*GetSubTaskCfgResponse) XXX_DiscardUnknown 

func (m *GetSubTaskCfgResponse) XXX_DiscardUnknown()

func (*GetSubTaskCfgResponse) XXX_Marshal 

func (m *GetSubTaskCfgResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetSubTaskCfgResponse) XXX_Merge 

func (m *GetSubTaskCfgResponse) XXX_Merge(src proto.Message)

func (*GetSubTaskCfgResponse) XXX_Size 

func (m *GetSubTaskCfgResponse) XXX_Size() int

func (*GetSubTaskCfgResponse) XXX_Unmarshal 

func (m *GetSubTaskCfgResponse) XXX_Unmarshal(b []byte) error

type GetValidationErrorRequest 

type GetValidationErrorRequest struct {
	ErrState ValidateErrorState `protobuf:"varint,1,opt,name=errState,proto3,enum=pb.ValidateErrorState" json:"errState,omitempty"`
	TaskName string             `protobuf:"bytes,2,opt,name=taskName,proto3" json:"taskName,omitempty"`
}

func (*GetValidationErrorRequest) Descriptor 

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

func (*GetValidationErrorRequest) GetErrState 

func (m *GetValidationErrorRequest) GetErrState() ValidateErrorState

func (*GetValidationErrorRequest) GetTaskName 

func (m *GetValidationErrorRequest) GetTaskName() string

func (*GetValidationErrorRequest) Marshal 

func (m *GetValidationErrorRequest) Marshal() (dAtA []byte, err error)

func (*GetValidationErrorRequest) MarshalTo 

func (m *GetValidationErrorRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetValidationErrorRequest) MarshalToSizedBuffer 

func (m *GetValidationErrorRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetValidationErrorRequest) ProtoMessage 

func (*GetValidationErrorRequest) ProtoMessage()

func (*GetValidationErrorRequest) Reset 

func (m *GetValidationErrorRequest) Reset()

func (*GetValidationErrorRequest) Size 

func (m *GetValidationErrorRequest) Size() (n int)

func (*GetValidationErrorRequest) String 

func (m *GetValidationErrorRequest) String() string

func (*GetValidationErrorRequest) Unmarshal 

func (m *GetValidationErrorRequest) Unmarshal(dAtA []byte) error

func (*GetValidationErrorRequest) XXX_DiscardUnknown 

func (m *GetValidationErrorRequest) XXX_DiscardUnknown()

func (*GetValidationErrorRequest) XXX_Marshal 

func (m *GetValidationErrorRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetValidationErrorRequest) XXX_Merge 

func (m *GetValidationErrorRequest) XXX_Merge(src proto.Message)

func (*GetValidationErrorRequest) XXX_Size 

func (m *GetValidationErrorRequest) XXX_Size() int

func (*GetValidationErrorRequest) XXX_Unmarshal 

func (m *GetValidationErrorRequest) XXX_Unmarshal(b []byte) error

type GetValidationErrorResponse 

type GetValidationErrorResponse struct {
	Result bool               `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"`
	Msg    string             `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	Error  []*ValidationError `protobuf:"bytes,3,rep,name=error,proto3" json:"error,omitempty"`
}

func (*GetValidationErrorResponse) Descriptor 

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

func (*GetValidationErrorResponse) GetError 

func (m *GetValidationErrorResponse) GetError() []*ValidationError

func (*GetValidationErrorResponse) GetMsg 

func (m *GetValidationErrorResponse) GetMsg() string

func (*GetValidationErrorResponse) GetResult 

func (m *GetValidationErrorResponse) GetResult() bool

func (*GetValidationErrorResponse) Marshal 

func (m *GetValidationErrorResponse) Marshal() (dAtA []byte, err error)

func (*GetValidationErrorResponse) MarshalTo 

func (m *GetValidationErrorResponse) MarshalTo(dAtA []byte) (int, error)

func (*GetValidationErrorResponse) MarshalToSizedBuffer 

func (m *GetValidationErrorResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetValidationErrorResponse) ProtoMessage 

func (*GetValidationErrorResponse) ProtoMessage()

func (*GetValidationErrorResponse) Reset 

func (m *GetValidationErrorResponse) Reset()

func (*GetValidationErrorResponse) Size 

func (m *GetValidationErrorResponse) Size() (n int)

func (*GetValidationErrorResponse) String 

func (m *GetValidationErrorResponse) String() string

func (*GetValidationErrorResponse) Unmarshal 

func (m *GetValidationErrorResponse) Unmarshal(dAtA []byte) error

func (*GetValidationErrorResponse) XXX_DiscardUnknown 

func (m *GetValidationErrorResponse) XXX_DiscardUnknown()

func (*GetValidationErrorResponse) XXX_Marshal 

func (m *GetValidationErrorResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetValidationErrorResponse) XXX_Merge 

func (m *GetValidationErrorResponse) XXX_Merge(src proto.Message)

func (*GetValidationErrorResponse) XXX_Size 

func (m *GetValidationErrorResponse) XXX_Size() int

func (*GetValidationErrorResponse) XXX_Unmarshal 

func (m *GetValidationErrorResponse) XXX_Unmarshal(b []byte) error

type GetValidationStatusRequest 

type GetValidationStatusRequest struct {
	TaskName     string `protobuf:"bytes,1,opt,name=taskName,proto3" json:"taskName,omitempty"`
	FilterStatus Stage  `protobuf:"varint,2,opt,name=filterStatus,proto3,enum=pb.Stage" json:"filterStatus,omitempty"`
}

func (*GetValidationStatusRequest) Descriptor 

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

func (*GetValidationStatusRequest) GetFilterStatus 

func (m *GetValidationStatusRequest) GetFilterStatus() Stage

func (*GetValidationStatusRequest) GetTaskName 

func (m *GetValidationStatusRequest) GetTaskName() string

func (*GetValidationStatusRequest) Marshal 

func (m *GetValidationStatusRequest) Marshal() (dAtA []byte, err error)

func (*GetValidationStatusRequest) MarshalTo 

func (m *GetValidationStatusRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetValidationStatusRequest) MarshalToSizedBuffer 

func (m *GetValidationStatusRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetValidationStatusRequest) ProtoMessage 

func (*GetValidationStatusRequest) ProtoMessage()

func (*GetValidationStatusRequest) Reset 

func (m *GetValidationStatusRequest) Reset()

func (*GetValidationStatusRequest) Size 

func (m *GetValidationStatusRequest) Size() (n int)

func (*GetValidationStatusRequest) String 

func (m *GetValidationStatusRequest) String() string

func (*GetValidationStatusRequest) Unmarshal 

func (m *GetValidationStatusRequest) Unmarshal(dAtA []byte) error

func (*GetValidationStatusRequest) XXX_DiscardUnknown 

func (m *GetValidationStatusRequest) XXX_DiscardUnknown()

func (*GetValidationStatusRequest) XXX_Marshal 

func (m *GetValidationStatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetValidationStatusRequest) XXX_Merge 

func (m *GetValidationStatusRequest) XXX_Merge(src proto.Message)

func (*GetValidationStatusRequest) XXX_Size 

func (m *GetValidationStatusRequest) XXX_Size() int

func (*GetValidationStatusRequest) XXX_Unmarshal 

func (m *GetValidationStatusRequest) XXX_Unmarshal(b []byte) error

type GetValidationStatusResponse 

type GetValidationStatusResponse struct {
	Result        bool                     `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"`
	Msg           string                   `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	Validators    []*ValidationStatus      `protobuf:"bytes,3,rep,name=validators,proto3" json:"validators,omitempty"`
	TableStatuses []*ValidationTableStatus `protobuf:"bytes,4,rep,name=tableStatuses,proto3" json:"tableStatuses,omitempty"`
}

func (*GetValidationStatusResponse) Descriptor 

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

func (*GetValidationStatusResponse) GetMsg 

func (m *GetValidationStatusResponse) GetMsg() string

func (*GetValidationStatusResponse) GetResult 

func (m *GetValidationStatusResponse) GetResult() bool

func (*GetValidationStatusResponse) GetTableStatuses 

func (m *GetValidationStatusResponse) GetTableStatuses() []*ValidationTableStatus

func (*GetValidationStatusResponse) GetValidators 

func (m *GetValidationStatusResponse) GetValidators() []*ValidationStatus

func (*GetValidationStatusResponse) Marshal 

func (m *GetValidationStatusResponse) Marshal() (dAtA []byte, err error)

func (*GetValidationStatusResponse) MarshalTo 

func (m *GetValidationStatusResponse) MarshalTo(dAtA []byte) (int, error)

func (*GetValidationStatusResponse) MarshalToSizedBuffer 

func (m *GetValidationStatusResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetValidationStatusResponse) ProtoMessage 

func (*GetValidationStatusResponse) ProtoMessage()

func (*GetValidationStatusResponse) Reset 

func (m *GetValidationStatusResponse) Reset()

func (*GetValidationStatusResponse) Size 

func (m *GetValidationStatusResponse) Size() (n int)

func (*GetValidationStatusResponse) String 

func (m *GetValidationStatusResponse) String() string

func (*GetValidationStatusResponse) Unmarshal 

func (m *GetValidationStatusResponse) Unmarshal(dAtA []byte) error

func (*GetValidationStatusResponse) XXX_DiscardUnknown 

func (m *GetValidationStatusResponse) XXX_DiscardUnknown()

func (*GetValidationStatusResponse) XXX_Marshal 

func (m *GetValidationStatusResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetValidationStatusResponse) XXX_Merge 

func (m *GetValidationStatusResponse) XXX_Merge(src proto.Message)

func (*GetValidationStatusResponse) XXX_Size 

func (m *GetValidationStatusResponse) XXX_Size() int

func (*GetValidationStatusResponse) XXX_Unmarshal 

func (m *GetValidationStatusResponse) XXX_Unmarshal(b []byte) error

type GetWorkerCfgRequest 

type GetWorkerCfgRequest struct {
}

func (*GetWorkerCfgRequest) Descriptor 

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

func (*GetWorkerCfgRequest) Marshal 

func (m *GetWorkerCfgRequest) Marshal() (dAtA []byte, err error)

func (*GetWorkerCfgRequest) MarshalTo 

func (m *GetWorkerCfgRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetWorkerCfgRequest) MarshalToSizedBuffer 

func (m *GetWorkerCfgRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetWorkerCfgRequest) ProtoMessage 

func (*GetWorkerCfgRequest) ProtoMessage()

func (*GetWorkerCfgRequest) Reset 

func (m *GetWorkerCfgRequest) Reset()

func (*GetWorkerCfgRequest) Size 

func (m *GetWorkerCfgRequest) Size() (n int)

func (*GetWorkerCfgRequest) String 

func (m *GetWorkerCfgRequest) String() string

func (*GetWorkerCfgRequest) Unmarshal 

func (m *GetWorkerCfgRequest) Unmarshal(dAtA []byte) error

func (*GetWorkerCfgRequest) XXX_DiscardUnknown 

func (m *GetWorkerCfgRequest) XXX_DiscardUnknown()

func (*GetWorkerCfgRequest) XXX_Marshal 

func (m *GetWorkerCfgRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetWorkerCfgRequest) XXX_Merge 

func (m *GetWorkerCfgRequest) XXX_Merge(src proto.Message)

func (*GetWorkerCfgRequest) XXX_Size 

func (m *GetWorkerCfgRequest) XXX_Size() int

func (*GetWorkerCfgRequest) XXX_Unmarshal 

func (m *GetWorkerCfgRequest) XXX_Unmarshal(b []byte) error

type GetWorkerCfgResponse 

type GetWorkerCfgResponse struct {
	Cfg string `protobuf:"bytes,1,opt,name=cfg,proto3" json:"cfg,omitempty"`
}

func (*GetWorkerCfgResponse) Descriptor 

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

func (*GetWorkerCfgResponse) GetCfg 

func (m *GetWorkerCfgResponse) GetCfg() string

func (*GetWorkerCfgResponse) Marshal 

func (m *GetWorkerCfgResponse) Marshal() (dAtA []byte, err error)

func (*GetWorkerCfgResponse) MarshalTo 

func (m *GetWorkerCfgResponse) MarshalTo(dAtA []byte) (int, error)

func (*GetWorkerCfgResponse) MarshalToSizedBuffer 

func (m *GetWorkerCfgResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetWorkerCfgResponse) ProtoMessage 

func (*GetWorkerCfgResponse) ProtoMessage()

func (*GetWorkerCfgResponse) Reset 

func (m *GetWorkerCfgResponse) Reset()

func (*GetWorkerCfgResponse) Size 

func (m *GetWorkerCfgResponse) Size() (n int)

func (*GetWorkerCfgResponse) String 

func (m *GetWorkerCfgResponse) String() string

func (*GetWorkerCfgResponse) Unmarshal 

func (m *GetWorkerCfgResponse) Unmarshal(dAtA []byte) error

func (*GetWorkerCfgResponse) XXX_DiscardUnknown 

func (m *GetWorkerCfgResponse) XXX_DiscardUnknown()

func (*GetWorkerCfgResponse) XXX_Marshal 

func (m *GetWorkerCfgResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetWorkerCfgResponse) XXX_Merge 

func (m *GetWorkerCfgResponse) XXX_Merge(src proto.Message)

func (*GetWorkerCfgResponse) XXX_Size 

func (m *GetWorkerCfgResponse) XXX_Size() int

func (*GetWorkerCfgResponse) XXX_Unmarshal 

func (m *GetWorkerCfgResponse) XXX_Unmarshal(b []byte) error

type HandleErrorRequest 

type HandleErrorRequest struct {
	Op        ErrorOp  `protobuf:"varint,1,opt,name=op,proto3,enum=pb.ErrorOp" json:"op,omitempty"`
	Task      string   `protobuf:"bytes,2,opt,name=task,proto3" json:"task,omitempty"`
	Sources   []string `protobuf:"bytes,3,rep,name=sources,proto3" json:"sources,omitempty"`
	BinlogPos string   `protobuf:"bytes,4,opt,name=binlogPos,proto3" json:"binlogPos,omitempty"`
	Sqls      []string `protobuf:"bytes,5,rep,name=sqls,proto3" json:"sqls,omitempty"`
}

func (*HandleErrorRequest) Descriptor 

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

func (*HandleErrorRequest) GetBinlogPos 

func (m *HandleErrorRequest) GetBinlogPos() string

func (*HandleErrorRequest) GetOp 

func (m *HandleErrorRequest) GetOp() ErrorOp

func (*HandleErrorRequest) GetSources 

func (m *HandleErrorRequest) GetSources() []string

func (*HandleErrorRequest) GetSqls 

func (m *HandleErrorRequest) GetSqls() []string

func (*HandleErrorRequest) GetTask 

func (m *HandleErrorRequest) GetTask() string

func (*HandleErrorRequest) Marshal 

func (m *HandleErrorRequest) Marshal() (dAtA []byte, err error)

func (*HandleErrorRequest) MarshalTo 

func (m *HandleErrorRequest) MarshalTo(dAtA []byte) (int, error)

func (*HandleErrorRequest) MarshalToSizedBuffer 

func (m *HandleErrorRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*HandleErrorRequest) ProtoMessage 

func (*HandleErrorRequest) ProtoMessage()

func (*HandleErrorRequest) Reset 

func (m *HandleErrorRequest) Reset()

func (*HandleErrorRequest) Size 

func (m *HandleErrorRequest) Size() (n int)

func (*HandleErrorRequest) String 

func (m *HandleErrorRequest) String() string

func (*HandleErrorRequest) Unmarshal 

func (m *HandleErrorRequest) Unmarshal(dAtA []byte) error

func (*HandleErrorRequest) XXX_DiscardUnknown 

func (m *HandleErrorRequest) XXX_DiscardUnknown()

func (*HandleErrorRequest) XXX_Marshal 

func (m *HandleErrorRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HandleErrorRequest) XXX_Merge 

func (m *HandleErrorRequest) XXX_Merge(src proto.Message)

func (*HandleErrorRequest) XXX_Size 

func (m *HandleErrorRequest) XXX_Size() int

func (*HandleErrorRequest) XXX_Unmarshal 

func (m *HandleErrorRequest) XXX_Unmarshal(b []byte) error

type HandleErrorResponse 

type HandleErrorResponse struct {
	Result  bool                    `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"`
	Msg     string                  `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	Sources []*CommonWorkerResponse `protobuf:"bytes,3,rep,name=sources,proto3" json:"sources,omitempty"`
}

func (*HandleErrorResponse) Descriptor 

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

func (*HandleErrorResponse) GetMsg 

func (m *HandleErrorResponse) GetMsg() string

func (*HandleErrorResponse) GetResult 

func (m *HandleErrorResponse) GetResult() bool

func (*HandleErrorResponse) GetSources 

func (m *HandleErrorResponse) GetSources() []*CommonWorkerResponse

func (*HandleErrorResponse) Marshal 

func (m *HandleErrorResponse) Marshal() (dAtA []byte, err error)

func (*HandleErrorResponse) MarshalTo 

func (m *HandleErrorResponse) MarshalTo(dAtA []byte) (int, error)

func (*HandleErrorResponse) MarshalToSizedBuffer 

func (m *HandleErrorResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*HandleErrorResponse) ProtoMessage 

func (*HandleErrorResponse) ProtoMessage()

func (*HandleErrorResponse) Reset 

func (m *HandleErrorResponse) Reset()

func (*HandleErrorResponse) Size 

func (m *HandleErrorResponse) Size() (n int)

func (*HandleErrorResponse) String 

func (m *HandleErrorResponse) String() string

func (*HandleErrorResponse) Unmarshal 

func (m *HandleErrorResponse) Unmarshal(dAtA []byte) error

func (*HandleErrorResponse) XXX_DiscardUnknown 

func (m *HandleErrorResponse) XXX_DiscardUnknown()

func (*HandleErrorResponse) XXX_Marshal 

func (m *HandleErrorResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HandleErrorResponse) XXX_Merge 

func (m *HandleErrorResponse) XXX_Merge(src proto.Message)

func (*HandleErrorResponse) XXX_Size 

func (m *HandleErrorResponse) XXX_Size() int

func (*HandleErrorResponse) XXX_Unmarshal 

func (m *HandleErrorResponse) XXX_Unmarshal(b []byte) error

type HandleWorkerErrorRequest 

type HandleWorkerErrorRequest struct {
	Op        ErrorOp  `protobuf:"varint,1,opt,name=op,proto3,enum=pb.ErrorOp" json:"op,omitempty"`
	Task      string   `protobuf:"bytes,2,opt,name=task,proto3" json:"task,omitempty"`
	BinlogPos string   `protobuf:"bytes,3,opt,name=binlogPos,proto3" json:"binlogPos,omitempty"`
	Sqls      []string `protobuf:"bytes,4,rep,name=sqls,proto3" json:"sqls,omitempty"`
}

func (*HandleWorkerErrorRequest) Descriptor 

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

func (*HandleWorkerErrorRequest) GetBinlogPos 

func (m *HandleWorkerErrorRequest) GetBinlogPos() string

func (*HandleWorkerErrorRequest) GetOp 

func (m *HandleWorkerErrorRequest) GetOp() ErrorOp

func (*HandleWorkerErrorRequest) GetSqls 

func (m *HandleWorkerErrorRequest) GetSqls() []string

func (*HandleWorkerErrorRequest) GetTask 

func (m *HandleWorkerErrorRequest) GetTask() string

func (*HandleWorkerErrorRequest) Marshal 

func (m *HandleWorkerErrorRequest) Marshal() (dAtA []byte, err error)

func (*HandleWorkerErrorRequest) MarshalTo 

func (m *HandleWorkerErrorRequest) MarshalTo(dAtA []byte) (int, error)

func (*HandleWorkerErrorRequest) MarshalToSizedBuffer 

func (m *HandleWorkerErrorRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*HandleWorkerErrorRequest) ProtoMessage 

func (*HandleWorkerErrorRequest) ProtoMessage()

func (*HandleWorkerErrorRequest) Reset 

func (m *HandleWorkerErrorRequest) Reset()

func (*HandleWorkerErrorRequest) Size 

func (m *HandleWorkerErrorRequest) Size() (n int)

func (*HandleWorkerErrorRequest) String 

func (m *HandleWorkerErrorRequest) String() string

func (*HandleWorkerErrorRequest) Unmarshal 

func (m *HandleWorkerErrorRequest) Unmarshal(dAtA []byte) error

func (*HandleWorkerErrorRequest) XXX_DiscardUnknown 

func (m *HandleWorkerErrorRequest) XXX_DiscardUnknown()

func (*HandleWorkerErrorRequest) XXX_Marshal 

func (m *HandleWorkerErrorRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HandleWorkerErrorRequest) XXX_Merge 

func (m *HandleWorkerErrorRequest) XXX_Merge(src proto.Message)

func (*HandleWorkerErrorRequest) XXX_Size 

func (m *HandleWorkerErrorRequest) XXX_Size() int

func (*HandleWorkerErrorRequest) XXX_Unmarshal 

func (m *HandleWorkerErrorRequest) XXX_Unmarshal(b []byte) error

type LeaderOp 

type LeaderOp int32
const (
	LeaderOp_InvalidLeaderOp     LeaderOp = 0
	LeaderOp_EvictLeaderOp       LeaderOp = 1
	LeaderOp_CancelEvictLeaderOp LeaderOp = 2
)

func (LeaderOp) EnumDescriptor 

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

func (LeaderOp) String 

func (x LeaderOp) String() string

type ListLeaderMember 

type ListLeaderMember struct {
	Msg  string `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Addr string `protobuf:"bytes,3,opt,name=addr,proto3" json:"addr,omitempty"`
}

func (*ListLeaderMember) Descriptor 

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

func (*ListLeaderMember) GetAddr 

func (m *ListLeaderMember) GetAddr() string

func (*ListLeaderMember) GetMsg 

func (m *ListLeaderMember) GetMsg() string

func (*ListLeaderMember) GetName 

func (m *ListLeaderMember) GetName() string

func (*ListLeaderMember) Marshal 

func (m *ListLeaderMember) Marshal() (dAtA []byte, err error)

func (*ListLeaderMember) MarshalTo 

func (m *ListLeaderMember) MarshalTo(dAtA []byte) (int, error)

func (*ListLeaderMember) MarshalToSizedBuffer 

func (m *ListLeaderMember) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListLeaderMember) ProtoMessage 

func (*ListLeaderMember) ProtoMessage()

func (*ListLeaderMember) Reset 

func (m *ListLeaderMember) Reset()

func (*ListLeaderMember) Size 

func (m *ListLeaderMember) Size() (n int)

func (*ListLeaderMember) String 

func (m *ListLeaderMember) String() string

func (*ListLeaderMember) Unmarshal 

func (m *ListLeaderMember) Unmarshal(dAtA []byte) error

func (*ListLeaderMember) XXX_DiscardUnknown 

func (m *ListLeaderMember) XXX_DiscardUnknown()

func (*ListLeaderMember) XXX_Marshal 

func (m *ListLeaderMember) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListLeaderMember) XXX_Merge 

func (m *ListLeaderMember) XXX_Merge(src proto.Message)

func (*ListLeaderMember) XXX_Size 

func (m *ListLeaderMember) XXX_Size() int

func (*ListLeaderMember) XXX_Unmarshal 

func (m *ListLeaderMember) XXX_Unmarshal(b []byte) error

type ListMasterMember 

type ListMasterMember struct {
	Msg     string        `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
	Masters []*MasterInfo `protobuf:"bytes,2,rep,name=masters,proto3" json:"masters,omitempty"`
}

func (*ListMasterMember) Descriptor 

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

func (*ListMasterMember) GetMasters 

func (m *ListMasterMember) GetMasters() []*MasterInfo

func (*ListMasterMember) GetMsg 

func (m *ListMasterMember) GetMsg() string

func (*ListMasterMember) Marshal 

func (m *ListMasterMember) Marshal() (dAtA []byte, err error)

func (*ListMasterMember) MarshalTo 

func (m *ListMasterMember) MarshalTo(dAtA []byte) (int, error)

func (*ListMasterMember) MarshalToSizedBuffer 

func (m *ListMasterMember) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListMasterMember) ProtoMessage 

func (*ListMasterMember) ProtoMessage()

func (*ListMasterMember) Reset 

func (m *ListMasterMember) Reset()

func (*ListMasterMember) Size 

func (m *ListMasterMember) Size() (n int)

func (*ListMasterMember) String 

func (m *ListMasterMember) String() string

func (*ListMasterMember) Unmarshal 

func (m *ListMasterMember) Unmarshal(dAtA []byte) error

func (*ListMasterMember) XXX_DiscardUnknown 

func (m *ListMasterMember) XXX_DiscardUnknown()

func (*ListMasterMember) XXX_Marshal 

func (m *ListMasterMember) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListMasterMember) XXX_Merge 

func (m *ListMasterMember) XXX_Merge(src proto.Message)

func (*ListMasterMember) XXX_Size 

func (m *ListMasterMember) XXX_Size() int

func (*ListMasterMember) XXX_Unmarshal 

func (m *ListMasterMember) XXX_Unmarshal(b []byte) error

type ListMemberRequest 

type ListMemberRequest struct {
	Leader bool     `protobuf:"varint,1,opt,name=leader,proto3" json:"leader,omitempty"`
	Master bool     `protobuf:"varint,2,opt,name=master,proto3" json:"master,omitempty"`
	Worker bool     `protobuf:"varint,3,opt,name=worker,proto3" json:"worker,omitempty"`
	Names  []string `protobuf:"bytes,4,rep,name=names,proto3" json:"names,omitempty"`
}

func (*ListMemberRequest) Descriptor 

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

func (*ListMemberRequest) GetLeader 

func (m *ListMemberRequest) GetLeader() bool

func (*ListMemberRequest) GetMaster 

func (m *ListMemberRequest) GetMaster() bool

func (*ListMemberRequest) GetNames 

func (m *ListMemberRequest) GetNames() []string

func (*ListMemberRequest) GetWorker 

func (m *ListMemberRequest) GetWorker() bool

func (*ListMemberRequest) Marshal 

func (m *ListMemberRequest) Marshal() (dAtA []byte, err error)

func (*ListMemberRequest) MarshalTo 

func (m *ListMemberRequest) MarshalTo(dAtA []byte) (int, error)

func (*ListMemberRequest) MarshalToSizedBuffer 

func (m *ListMemberRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListMemberRequest) ProtoMessage 

func (*ListMemberRequest) ProtoMessage()

func (*ListMemberRequest) Reset 

func (m *ListMemberRequest) Reset()

func (*ListMemberRequest) Size 

func (m *ListMemberRequest) Size() (n int)

func (*ListMemberRequest) String 

func (m *ListMemberRequest) String() string

func (*ListMemberRequest) Unmarshal 

func (m *ListMemberRequest) Unmarshal(dAtA []byte) error

func (*ListMemberRequest) XXX_DiscardUnknown 

func (m *ListMemberRequest) XXX_DiscardUnknown()

func (*ListMemberRequest) XXX_Marshal 

func (m *ListMemberRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListMemberRequest) XXX_Merge 

func (m *ListMemberRequest) XXX_Merge(src proto.Message)

func (*ListMemberRequest) XXX_Size 

func (m *ListMemberRequest) XXX_Size() int

func (*ListMemberRequest) XXX_Unmarshal 

func (m *ListMemberRequest) XXX_Unmarshal(b []byte) error

type ListMemberResponse 

type ListMemberResponse struct {
	Result  bool       `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"`
	Msg     string     `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	Members []*Members `protobuf:"bytes,3,rep,name=members,proto3" json:"members,omitempty"`
}

func (*ListMemberResponse) Descriptor 

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

func (*ListMemberResponse) GetMembers 

func (m *ListMemberResponse) GetMembers() []*Members

func (*ListMemberResponse) GetMsg 

func (m *ListMemberResponse) GetMsg() string

func (*ListMemberResponse) GetResult 

func (m *ListMemberResponse) GetResult() bool

func (*ListMemberResponse) Marshal 

func (m *ListMemberResponse) Marshal() (dAtA []byte, err error)

func (*ListMemberResponse) MarshalTo 

func (m *ListMemberResponse) MarshalTo(dAtA []byte) (int, error)

func (*ListMemberResponse) MarshalToSizedBuffer 

func (m *ListMemberResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListMemberResponse) ProtoMessage 

func (*ListMemberResponse) ProtoMessage()

func (*ListMemberResponse) Reset 

func (m *ListMemberResponse) Reset()

func (*ListMemberResponse) Size 

func (m *ListMemberResponse) Size() (n int)

func (*ListMemberResponse) String 

func (m *ListMemberResponse) String() string

func (*ListMemberResponse) Unmarshal 

func (m *ListMemberResponse) Unmarshal(dAtA []byte) error

func (*ListMemberResponse) XXX_DiscardUnknown 

func (m *ListMemberResponse) XXX_DiscardUnknown()

func (*ListMemberResponse) XXX_Marshal 

func (m *ListMemberResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListMemberResponse) XXX_Merge 

func (m *ListMemberResponse) XXX_Merge(src proto.Message)

func (*ListMemberResponse) XXX_Size 

func (m *ListMemberResponse) XXX_Size() int

func (*ListMemberResponse) XXX_Unmarshal 

func (m *ListMemberResponse) XXX_Unmarshal(b []byte) error

type ListSourceConfigsResponse 

type ListSourceConfigsResponse struct {
	Result        bool              `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"`
	Msg           string            `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	SourceConfigs map[string]string `` /* 167-byte string literal not displayed */
}

func (*ListSourceConfigsResponse) Descriptor 

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

func (*ListSourceConfigsResponse) GetMsg 

func (m *ListSourceConfigsResponse) GetMsg() string

func (*ListSourceConfigsResponse) GetResult 

func (m *ListSourceConfigsResponse) GetResult() bool

func (*ListSourceConfigsResponse) GetSourceConfigs 

func (m *ListSourceConfigsResponse) GetSourceConfigs() map[string]string

func (*ListSourceConfigsResponse) Marshal 

func (m *ListSourceConfigsResponse) Marshal() (dAtA []byte, err error)

func (*ListSourceConfigsResponse) MarshalTo 

func (m *ListSourceConfigsResponse) MarshalTo(dAtA []byte) (int, error)

func (*ListSourceConfigsResponse) MarshalToSizedBuffer 

func (m *ListSourceConfigsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListSourceConfigsResponse) ProtoMessage 

func (*ListSourceConfigsResponse) ProtoMessage()

func (*ListSourceConfigsResponse) Reset 

func (m *ListSourceConfigsResponse) Reset()

func (*ListSourceConfigsResponse) Size 

func (m *ListSourceConfigsResponse) Size() (n int)

func (*ListSourceConfigsResponse) String 

func (m *ListSourceConfigsResponse) String() string

func (*ListSourceConfigsResponse) Unmarshal 

func (m *ListSourceConfigsResponse) Unmarshal(dAtA []byte) error

func (*ListSourceConfigsResponse) XXX_DiscardUnknown 

func (m *ListSourceConfigsResponse) XXX_DiscardUnknown()

func (*ListSourceConfigsResponse) XXX_Marshal 

func (m *ListSourceConfigsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListSourceConfigsResponse) XXX_Merge 

func (m *ListSourceConfigsResponse) XXX_Merge(src proto.Message)

func (*ListSourceConfigsResponse) XXX_Size 

func (m *ListSourceConfigsResponse) XXX_Size() int

func (*ListSourceConfigsResponse) XXX_Unmarshal 

func (m *ListSourceConfigsResponse) XXX_Unmarshal(b []byte) error

type ListTaskConfigsResponse 

type ListTaskConfigsResponse struct {
	Result      bool              `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"`
	Msg         string            `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	TaskConfigs map[string]string `` /* 163-byte string literal not displayed */
}

func (*ListTaskConfigsResponse) Descriptor 

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

func (*ListTaskConfigsResponse) GetMsg 

func (m *ListTaskConfigsResponse) GetMsg() string

func (*ListTaskConfigsResponse) GetResult 

func (m *ListTaskConfigsResponse) GetResult() bool

func (*ListTaskConfigsResponse) GetTaskConfigs 

func (m *ListTaskConfigsResponse) GetTaskConfigs() map[string]string

func (*ListTaskConfigsResponse) Marshal 

func (m *ListTaskConfigsResponse) Marshal() (dAtA []byte, err error)

func (*ListTaskConfigsResponse) MarshalTo 

func (m *ListTaskConfigsResponse) MarshalTo(dAtA []byte) (int, error)

func (*ListTaskConfigsResponse) MarshalToSizedBuffer 

func (m *ListTaskConfigsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListTaskConfigsResponse) ProtoMessage 

func (*ListTaskConfigsResponse) ProtoMessage()

func (*ListTaskConfigsResponse) Reset 

func (m *ListTaskConfigsResponse) Reset()

func (*ListTaskConfigsResponse) Size 

func (m *ListTaskConfigsResponse) Size() (n int)

func (*ListTaskConfigsResponse) String 

func (m *ListTaskConfigsResponse) String() string

func (*ListTaskConfigsResponse) Unmarshal 

func (m *ListTaskConfigsResponse) Unmarshal(dAtA []byte) error

func (*ListTaskConfigsResponse) XXX_DiscardUnknown 

func (m *ListTaskConfigsResponse) XXX_DiscardUnknown()

func (*ListTaskConfigsResponse) XXX_Marshal 

func (m *ListTaskConfigsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListTaskConfigsResponse) XXX_Merge 

func (m *ListTaskConfigsResponse) XXX_Merge(src proto.Message)

func (*ListTaskConfigsResponse) XXX_Size 

func (m *ListTaskConfigsResponse) XXX_Size() int

func (*ListTaskConfigsResponse) XXX_Unmarshal 

func (m *ListTaskConfigsResponse) XXX_Unmarshal(b []byte) error

type ListWorkerMember 

type ListWorkerMember struct {
	Msg     string        `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
	Workers []*WorkerInfo `protobuf:"bytes,2,rep,name=workers,proto3" json:"workers,omitempty"`
}

func (*ListWorkerMember) Descriptor 

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

func (*ListWorkerMember) GetMsg 

func (m *ListWorkerMember) GetMsg() string

func (*ListWorkerMember) GetWorkers 

func (m *ListWorkerMember) GetWorkers() []*WorkerInfo

func (*ListWorkerMember) Marshal 

func (m *ListWorkerMember) Marshal() (dAtA []byte, err error)

func (*ListWorkerMember) MarshalTo 

func (m *ListWorkerMember) MarshalTo(dAtA []byte) (int, error)

func (*ListWorkerMember) MarshalToSizedBuffer 

func (m *ListWorkerMember) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListWorkerMember) ProtoMessage 

func (*ListWorkerMember) ProtoMessage()

func (*ListWorkerMember) Reset 

func (m *ListWorkerMember) Reset()

func (*ListWorkerMember) Size 

func (m *ListWorkerMember) Size() (n int)

func (*ListWorkerMember) String 

func (m *ListWorkerMember) String() string

func (*ListWorkerMember) Unmarshal 

func (m *ListWorkerMember) Unmarshal(dAtA []byte) error

func (*ListWorkerMember) XXX_DiscardUnknown 

func (m *ListWorkerMember) XXX_DiscardUnknown()

func (*ListWorkerMember) XXX_Marshal 

func (m *ListWorkerMember) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListWorkerMember) XXX_Merge 

func (m *ListWorkerMember) XXX_Merge(src proto.Message)

func (*ListWorkerMember) XXX_Size 

func (m *ListWorkerMember) XXX_Size() int

func (*ListWorkerMember) XXX_Unmarshal 

func (m *ListWorkerMember) XXX_Unmarshal(b []byte) error

type LoadError 

type LoadError struct {
	Msg string `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
}

LoadError represents error for load unit

func (*LoadError) Descriptor 

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

func (*LoadError) GetMsg 

func (m *LoadError) GetMsg() string

func (*LoadError) Marshal 

func (m *LoadError) Marshal() (dAtA []byte, err error)

func (*LoadError) MarshalTo 

func (m *LoadError) MarshalTo(dAtA []byte) (int, error)

func (*LoadError) MarshalToSizedBuffer 

func (m *LoadError) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LoadError) ProtoMessage 

func (*LoadError) ProtoMessage()

func (*LoadError) Reset 

func (m *LoadError) Reset()

func (*LoadError) Size 

func (m *LoadError) Size() (n int)

func (*LoadError) String 

func (m *LoadError) String() string

func (*LoadError) Unmarshal 

func (m *LoadError) Unmarshal(dAtA []byte) error

func (*LoadError) XXX_DiscardUnknown 

func (m *LoadError) XXX_DiscardUnknown()

func (*LoadError) XXX_Marshal 

func (m *LoadError) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LoadError) XXX_Merge 

func (m *LoadError) XXX_Merge(src proto.Message)

func (*LoadError) XXX_Size 

func (m *LoadError) XXX_Size() int

func (*LoadError) XXX_Unmarshal 

func (m *LoadError) XXX_Unmarshal(b []byte) error

type LoadStatus 

type LoadStatus struct {
	FinishedBytes  int64  `protobuf:"varint,1,opt,name=finishedBytes,proto3" json:"finishedBytes,omitempty"`
	TotalBytes     int64  `protobuf:"varint,2,opt,name=totalBytes,proto3" json:"totalBytes,omitempty"`
	Progress       string `protobuf:"bytes,3,opt,name=progress,proto3" json:"progress,omitempty"`
	MetaBinlog     string `protobuf:"bytes,4,opt,name=metaBinlog,proto3" json:"metaBinlog,omitempty"`
	MetaBinlogGTID string `protobuf:"bytes,5,opt,name=metaBinlogGTID,proto3" json:"metaBinlogGTID,omitempty"`
	Bps            int64  `protobuf:"varint,6,opt,name=bps,proto3" json:"bps,omitempty"`
}

LoadStatus represents status for load unit

func (*LoadStatus) Descriptor 

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

func (*LoadStatus) GetBps 

func (m *LoadStatus) GetBps() int64

func (*LoadStatus) GetFinishedBytes 

func (m *LoadStatus) GetFinishedBytes() int64

func (*LoadStatus) GetMetaBinlog 

func (m *LoadStatus) GetMetaBinlog() string

func (*LoadStatus) GetMetaBinlogGTID 

func (m *LoadStatus) GetMetaBinlogGTID() string

func (*LoadStatus) GetProgress 

func (m *LoadStatus) GetProgress() string

func (*LoadStatus) GetTotalBytes 

func (m *LoadStatus) GetTotalBytes() int64

func (*LoadStatus) Marshal 

func (m *LoadStatus) Marshal() (dAtA []byte, err error)

func (*LoadStatus) MarshalTo 

func (m *LoadStatus) MarshalTo(dAtA []byte) (int, error)

func (*LoadStatus) MarshalToSizedBuffer 

func (m *LoadStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LoadStatus) ProtoMessage 

func (*LoadStatus) ProtoMessage()

func (*LoadStatus) Reset 

func (m *LoadStatus) Reset()

func (*LoadStatus) Size 

func (m *LoadStatus) Size() (n int)

func (*LoadStatus) String 

func (m *LoadStatus) String() string

func (*LoadStatus) Unmarshal 

func (m *LoadStatus) Unmarshal(dAtA []byte) error

func (*LoadStatus) XXX_DiscardUnknown 

func (m *LoadStatus) XXX_DiscardUnknown()

func (*LoadStatus) XXX_Marshal 

func (m *LoadStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LoadStatus) XXX_Merge 

func (m *LoadStatus) XXX_Merge(src proto.Message)

func (*LoadStatus) XXX_Size 

func (m *LoadStatus) XXX_Size() int

func (*LoadStatus) XXX_Unmarshal 

func (m *LoadStatus) XXX_Unmarshal(b []byte) error

type MasterClient 

type MasterClient interface {
	StartTask(ctx context.Context, in *StartTaskRequest, opts ...grpc.CallOption) (*StartTaskResponse, error)
	OperateTask(ctx context.Context, in *OperateTaskRequest, opts ...grpc.CallOption) (*OperateTaskResponse, error)
	UpdateTask(ctx context.Context, in *UpdateTaskRequest, opts ...grpc.CallOption) (*UpdateTaskResponse, error)
	QueryStatus(ctx context.Context, in *QueryStatusListRequest, opts ...grpc.CallOption) (*QueryStatusListResponse, error)
	// show un-resolved DDL locks
	ShowDDLLocks(ctx context.Context, in *ShowDDLLocksRequest, opts ...grpc.CallOption) (*ShowDDLLocksResponse, error)
	// used by dmctl to manually unlock DDL lock
	UnlockDDLLock(ctx context.Context, in *UnlockDDLLockRequest, opts ...grpc.CallOption) (*UnlockDDLLockResponse, error)
	// OperateWorkerRelayTask requests some dm-workers to operate relay unit
	OperateWorkerRelayTask(ctx context.Context, in *OperateWorkerRelayRequest, opts ...grpc.CallOption) (*OperateWorkerRelayResponse, error)
	// PurgeWorkerRelay purges relay log files for some dm-workers
	PurgeWorkerRelay(ctx context.Context, in *PurgeWorkerRelayRequest, opts ...grpc.CallOption) (*PurgeWorkerRelayResponse, error)
	// CheckTask checks legality of task configuration
	CheckTask(ctx context.Context, in *CheckTaskRequest, opts ...grpc.CallOption) (*CheckTaskResponse, error)
	// Operate an upstream MySQL source.
	OperateSource(ctx context.Context, in *OperateSourceRequest, opts ...grpc.CallOption) (*OperateSourceResponse, error)
	// RegisterWorker register the dm-workers.
	RegisterWorker(ctx context.Context, in *RegisterWorkerRequest, opts ...grpc.CallOption) (*RegisterWorkerResponse, error)
	// OfflineMember offline the dm cluster's members (master/worker).
	OfflineMember(ctx context.Context, in *OfflineMemberRequest, opts ...grpc.CallOption) (*OfflineMemberResponse, error)
	// OperateLeader do some operate on master:
	//   - evict leader: make the master resign if it is leader, and will not campaign the leader again
	//   - cancel evict leader: the master can campaign leader again.
	OperateLeader(ctx context.Context, in *OperateLeaderRequest, opts ...grpc.CallOption) (*OperateLeaderResponse, error)
	// ListMember list member information
	ListMember(ctx context.Context, in *ListMemberRequest, opts ...grpc.CallOption) (*ListMemberResponse, error)
	OperateSchema(ctx context.Context, in *OperateSchemaRequest, opts ...grpc.CallOption) (*OperateSchemaResponse, error)
	GetSubTaskCfg(ctx context.Context, in *GetSubTaskCfgRequest, opts ...grpc.CallOption) (*GetSubTaskCfgResponse, error)
	// GetCfg get config
	GetCfg(ctx context.Context, in *GetCfgRequest, opts ...grpc.CallOption) (*GetCfgResponse, error)
	HandleError(ctx context.Context, in *HandleErrorRequest, opts ...grpc.CallOption) (*HandleErrorResponse, error)
	GetMasterCfg(ctx context.Context, in *GetMasterCfgRequest, opts ...grpc.CallOption) (*GetMasterCfgResponse, error)
	TransferSource(ctx context.Context, in *TransferSourceRequest, opts ...grpc.CallOption) (*TransferSourceResponse, error)
	OperateRelay(ctx context.Context, in *OperateRelayRequest, opts ...grpc.CallOption) (*OperateRelayResponse, error)
	StartValidation(ctx context.Context, in *StartValidationRequest, opts ...grpc.CallOption) (*StartValidationResponse, error)
	StopValidation(ctx context.Context, in *StopValidationRequest, opts ...grpc.CallOption) (*StopValidationResponse, error)
	GetValidationStatus(ctx context.Context, in *GetValidationStatusRequest, opts ...grpc.CallOption) (*GetValidationStatusResponse, error)
	GetValidationError(ctx context.Context, in *GetValidationErrorRequest, opts ...grpc.CallOption) (*GetValidationErrorResponse, error)
	OperateValidationError(ctx context.Context, in *OperateValidationErrorRequest, opts ...grpc.CallOption) (*OperateValidationErrorResponse, error)
	UpdateValidation(ctx context.Context, in *UpdateValidationRequest, opts ...grpc.CallOption) (*UpdateValidationResponse, error)
	// Encrypt encrypts the plaintext using the secret key of dm-master
	Encrypt(ctx context.Context, in *EncryptRequest, opts ...grpc.CallOption) (*EncryptResponse, error)
	ListTaskConfigs(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ListTaskConfigsResponse, error)
	ListSourceConfigs(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ListSourceConfigsResponse, error)
}

MasterClient is the client API for Master service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewMasterClient 

func NewMasterClient(cc *grpc.ClientConn) MasterClient

type MasterInfo 

type MasterInfo struct {
	Name       string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	MemberID   uint64   `protobuf:"varint,2,opt,name=memberID,proto3" json:"memberID,omitempty"`
	Alive      bool     `protobuf:"varint,3,opt,name=alive,proto3" json:"alive,omitempty"`
	PeerURLs   []string `protobuf:"bytes,4,rep,name=peerURLs,proto3" json:"peerURLs,omitempty"`
	ClientURLs []string `protobuf:"bytes,5,rep,name=clientURLs,proto3" json:"clientURLs,omitempty"`
}

func (*MasterInfo) Descriptor 

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

func (*MasterInfo) GetAlive 

func (m *MasterInfo) GetAlive() bool

func (*MasterInfo) GetClientURLs 

func (m *MasterInfo) GetClientURLs() []string

func (*MasterInfo) GetMemberID 

func (m *MasterInfo) GetMemberID() uint64

func (*MasterInfo) GetName 

func (m *MasterInfo) GetName() string

func (*MasterInfo) GetPeerURLs 

func (m *MasterInfo) GetPeerURLs() []string

func (*MasterInfo) Marshal 

func (m *MasterInfo) Marshal() (dAtA []byte, err error)

func (*MasterInfo) MarshalTo 

func (m *MasterInfo) MarshalTo(dAtA []byte) (int, error)

func (*MasterInfo) MarshalToSizedBuffer 

func (m *MasterInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MasterInfo) ProtoMessage 

func (*MasterInfo) ProtoMessage()

func (*MasterInfo) Reset 

func (m *MasterInfo) Reset()

func (*MasterInfo) Size 

func (m *MasterInfo) Size() (n int)

func (*MasterInfo) String 

func (m *MasterInfo) String() string

func (*MasterInfo) Unmarshal 

func (m *MasterInfo) Unmarshal(dAtA []byte) error

func (*MasterInfo) XXX_DiscardUnknown 

func (m *MasterInfo) XXX_DiscardUnknown()

func (*MasterInfo) XXX_Marshal 

func (m *MasterInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MasterInfo) XXX_Merge 

func (m *MasterInfo) XXX_Merge(src proto.Message)

func (*MasterInfo) XXX_Size 

func (m *MasterInfo) XXX_Size() int

func (*MasterInfo) XXX_Unmarshal 

func (m *MasterInfo) XXX_Unmarshal(b []byte) error

type MasterServer 

type MasterServer interface {
	StartTask(context.Context, *StartTaskRequest) (*StartTaskResponse, error)
	OperateTask(context.Context, *OperateTaskRequest) (*OperateTaskResponse, error)
	UpdateTask(context.Context, *UpdateTaskRequest) (*UpdateTaskResponse, error)
	QueryStatus(context.Context, *QueryStatusListRequest) (*QueryStatusListResponse, error)
	// show un-resolved DDL locks
	ShowDDLLocks(context.Context, *ShowDDLLocksRequest) (*ShowDDLLocksResponse, error)
	// used by dmctl to manually unlock DDL lock
	UnlockDDLLock(context.Context, *UnlockDDLLockRequest) (*UnlockDDLLockResponse, error)
	// OperateWorkerRelayTask requests some dm-workers to operate relay unit
	OperateWorkerRelayTask(context.Context, *OperateWorkerRelayRequest) (*OperateWorkerRelayResponse, error)
	// PurgeWorkerRelay purges relay log files for some dm-workers
	PurgeWorkerRelay(context.Context, *PurgeWorkerRelayRequest) (*PurgeWorkerRelayResponse, error)
	// CheckTask checks legality of task configuration
	CheckTask(context.Context, *CheckTaskRequest) (*CheckTaskResponse, error)
	// Operate an upstream MySQL source.
	OperateSource(context.Context, *OperateSourceRequest) (*OperateSourceResponse, error)
	// RegisterWorker register the dm-workers.
	RegisterWorker(context.Context, *RegisterWorkerRequest) (*RegisterWorkerResponse, error)
	// OfflineMember offline the dm cluster's members (master/worker).
	OfflineMember(context.Context, *OfflineMemberRequest) (*OfflineMemberResponse, error)
	// OperateLeader do some operate on master:
	//   - evict leader: make the master resign if it is leader, and will not campaign the leader again
	//   - cancel evict leader: the master can campaign leader again.
	OperateLeader(context.Context, *OperateLeaderRequest) (*OperateLeaderResponse, error)
	// ListMember list member information
	ListMember(context.Context, *ListMemberRequest) (*ListMemberResponse, error)
	OperateSchema(context.Context, *OperateSchemaRequest) (*OperateSchemaResponse, error)
	GetSubTaskCfg(context.Context, *GetSubTaskCfgRequest) (*GetSubTaskCfgResponse, error)
	// GetCfg get config
	GetCfg(context.Context, *GetCfgRequest) (*GetCfgResponse, error)
	HandleError(context.Context, *HandleErrorRequest) (*HandleErrorResponse, error)
	GetMasterCfg(context.Context, *GetMasterCfgRequest) (*GetMasterCfgResponse, error)
	TransferSource(context.Context, *TransferSourceRequest) (*TransferSourceResponse, error)
	OperateRelay(context.Context, *OperateRelayRequest) (*OperateRelayResponse, error)
	StartValidation(context.Context, *StartValidationRequest) (*StartValidationResponse, error)
	StopValidation(context.Context, *StopValidationRequest) (*StopValidationResponse, error)
	GetValidationStatus(context.Context, *GetValidationStatusRequest) (*GetValidationStatusResponse, error)
	GetValidationError(context.Context, *GetValidationErrorRequest) (*GetValidationErrorResponse, error)
	OperateValidationError(context.Context, *OperateValidationErrorRequest) (*OperateValidationErrorResponse, error)
	UpdateValidation(context.Context, *UpdateValidationRequest) (*UpdateValidationResponse, error)
	// Encrypt encrypts the plaintext using the secret key of dm-master
	Encrypt(context.Context, *EncryptRequest) (*EncryptResponse, error)
	ListTaskConfigs(context.Context, *emptypb.Empty) (*ListTaskConfigsResponse, error)
	ListSourceConfigs(context.Context, *emptypb.Empty) (*ListSourceConfigsResponse, error)
}

MasterServer is the server API for Master service.

type Members 

type Members struct {
	// Types that are valid to be assigned to Member:
	//
	//	*Members_Leader
	//	*Members_Master
	//	*Members_Worker
	Member isMembers_Member `protobuf_oneof:"member"`
}

func (*Members) Descriptor 

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

func (*Members) GetLeader 

func (m *Members) GetLeader() *ListLeaderMember

func (*Members) GetMaster 

func (m *Members) GetMaster() *ListMasterMember

func (*Members) GetMember 

func (m *Members) GetMember() isMembers_Member

func (*Members) GetWorker 

func (m *Members) GetWorker() *ListWorkerMember

func (*Members) Marshal 

func (m *Members) Marshal() (dAtA []byte, err error)

func (*Members) MarshalTo 

func (m *Members) MarshalTo(dAtA []byte) (int, error)

func (*Members) MarshalToSizedBuffer 

func (m *Members) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Members) ProtoMessage 

func (*Members) ProtoMessage()

func (*Members) Reset 

func (m *Members) Reset()

func (*Members) Size 

func (m *Members) Size() (n int)

func (*Members) String 

func (m *Members) String() string

func (*Members) Unmarshal 

func (m *Members) Unmarshal(dAtA []byte) error

func (*Members) XXX_DiscardUnknown 

func (m *Members) XXX_DiscardUnknown()

func (*Members) XXX_Marshal 

func (m *Members) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Members) XXX_Merge 

func (m *Members) XXX_Merge(src proto.Message)

func (*Members) XXX_OneofWrappers 

func (*Members) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Members) XXX_Size 

func (m *Members) XXX_Size() int

func (*Members) XXX_Unmarshal 

func (m *Members) XXX_Unmarshal(b []byte) error

type Members_Leader 

type Members_Leader struct {
	Leader *ListLeaderMember `protobuf:"bytes,1,opt,name=leader,proto3,oneof" json:"leader,omitempty"`
}

func (*Members_Leader) MarshalTo 

func (m *Members_Leader) MarshalTo(dAtA []byte) (int, error)

func (*Members_Leader) MarshalToSizedBuffer 

func (m *Members_Leader) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Members_Leader) Size 

func (m *Members_Leader) Size() (n int)

type Members_Master 

type Members_Master struct {
	Master *ListMasterMember `protobuf:"bytes,2,opt,name=master,proto3,oneof" json:"master,omitempty"`
}

func (*Members_Master) MarshalTo 

func (m *Members_Master) MarshalTo(dAtA []byte) (int, error)

func (*Members_Master) MarshalToSizedBuffer 

func (m *Members_Master) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Members_Master) Size 

func (m *Members_Master) Size() (n int)

type Members_Worker 

type Members_Worker struct {
	Worker *ListWorkerMember `protobuf:"bytes,3,opt,name=worker,proto3,oneof" json:"worker,omitempty"`
}

func (*Members_Worker) MarshalTo 

func (m *Members_Worker) MarshalTo(dAtA []byte) (int, error)

func (*Members_Worker) MarshalToSizedBuffer 

func (m *Members_Worker) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Members_Worker) Size 

func (m *Members_Worker) Size() (n int)

type OfflineMemberRequest 

type OfflineMemberRequest struct {
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
}

func (*OfflineMemberRequest) Descriptor 

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

func (*OfflineMemberRequest) GetName 

func (m *OfflineMemberRequest) GetName() string

func (*OfflineMemberRequest) GetType 

func (m *OfflineMemberRequest) GetType() string

func (*OfflineMemberRequest) Marshal 

func (m *OfflineMemberRequest) Marshal() (dAtA []byte, err error)

func (*OfflineMemberRequest) MarshalTo 

func (m *OfflineMemberRequest) MarshalTo(dAtA []byte) (int, error)

func (*OfflineMemberRequest) MarshalToSizedBuffer 

func (m *OfflineMemberRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*OfflineMemberRequest) ProtoMessage 

func (*OfflineMemberRequest) ProtoMessage()

func (*OfflineMemberRequest) Reset 

func (m *OfflineMemberRequest) Reset()

func (*OfflineMemberRequest) Size 

func (m *OfflineMemberRequest) Size() (n int)

func (*OfflineMemberRequest) String 

func (m *OfflineMemberRequest) String() string

func (*OfflineMemberRequest) Unmarshal 

func (m *OfflineMemberRequest) Unmarshal(dAtA []byte) error

func (*OfflineMemberRequest) XXX_DiscardUnknown 

func (m *OfflineMemberRequest) XXX_DiscardUnknown()

func (*OfflineMemberRequest) XXX_Marshal 

func (m *OfflineMemberRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OfflineMemberRequest) XXX_Merge 

func (m *OfflineMemberRequest) XXX_Merge(src proto.Message)

func (*OfflineMemberRequest) XXX_Size 

func (m *OfflineMemberRequest) XXX_Size() int

func (*OfflineMemberRequest) XXX_Unmarshal 

func (m *OfflineMemberRequest) XXX_Unmarshal(b []byte) error

type OfflineMemberResponse 

type OfflineMemberResponse struct {
	Result bool   `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"`
	Msg    string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
}

func (*OfflineMemberResponse) Descriptor 

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

func (*OfflineMemberResponse) GetMsg 

func (m *OfflineMemberResponse) GetMsg() string

func (*OfflineMemberResponse) GetResult 

func (m *OfflineMemberResponse) GetResult() bool

func (*OfflineMemberResponse) Marshal 

func (m *OfflineMemberResponse) Marshal() (dAtA []byte, err error)

func (*OfflineMemberResponse) MarshalTo 

func (m *OfflineMemberResponse) MarshalTo(dAtA []byte) (int, error)

func (*OfflineMemberResponse) MarshalToSizedBuffer 

func (m *OfflineMemberResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*OfflineMemberResponse) ProtoMessage 

func (*OfflineMemberResponse) ProtoMessage()

func (*OfflineMemberResponse) Reset 

func (m *OfflineMemberResponse) Reset()

func (*OfflineMemberResponse) Size 

func (m *OfflineMemberResponse) Size() (n int)

func (*OfflineMemberResponse) String 

func (m *OfflineMemberResponse) String() string

func (*OfflineMemberResponse) Unmarshal 

func (m *OfflineMemberResponse) Unmarshal(dAtA []byte) error

func (*OfflineMemberResponse) XXX_DiscardUnknown 

func (m *OfflineMemberResponse) XXX_DiscardUnknown()

func (*OfflineMemberResponse) XXX_Marshal 

func (m *OfflineMemberResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OfflineMemberResponse) XXX_Merge 

func (m *OfflineMemberResponse) XXX_Merge(src proto.Message)

func (*OfflineMemberResponse) XXX_Size 

func (m *OfflineMemberResponse) XXX_Size() int

func (*OfflineMemberResponse) XXX_Unmarshal 

func (m *OfflineMemberResponse) XXX_Unmarshal(b []byte) error

type OperateLeaderRequest 

type OperateLeaderRequest struct {
	Op LeaderOp `protobuf:"varint,1,opt,name=op,proto3,enum=pb.LeaderOp" json:"op,omitempty"`
}

func (*OperateLeaderRequest) Descriptor 

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

func (*OperateLeaderRequest) GetOp 

func (m *OperateLeaderRequest) GetOp() LeaderOp

func (*OperateLeaderRequest) Marshal 

func (m *OperateLeaderRequest) Marshal() (dAtA []byte, err error)

func (*OperateLeaderRequest) MarshalTo 

func (m *OperateLeaderRequest) MarshalTo(dAtA []byte) (int, error)

func (*OperateLeaderRequest) MarshalToSizedBuffer 

func (m *OperateLeaderRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*OperateLeaderRequest) ProtoMessage 

func (*OperateLeaderRequest) ProtoMessage()

func (*OperateLeaderRequest) Reset 

func (m *OperateLeaderRequest) Reset()

func (*OperateLeaderRequest) Size 

func (m *OperateLeaderRequest) Size() (n int)

func (*OperateLeaderRequest) String 

func (m *OperateLeaderRequest) String() string

func (*OperateLeaderRequest) Unmarshal 

func (m *OperateLeaderRequest) Unmarshal(dAtA []byte) error

func (*OperateLeaderRequest) XXX_DiscardUnknown 

func (m *OperateLeaderRequest) XXX_DiscardUnknown()

func (*OperateLeaderRequest) XXX_Marshal 

func (m *OperateLeaderRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OperateLeaderRequest) XXX_Merge 

func (m *OperateLeaderRequest) XXX_Merge(src proto.Message)

func (*OperateLeaderRequest) XXX_Size 

func (m *OperateLeaderRequest) XXX_Size() int

func (*OperateLeaderRequest) XXX_Unmarshal 

func (m *OperateLeaderRequest) XXX_Unmarshal(b []byte) error

type OperateLeaderResponse 

type OperateLeaderResponse struct {
	Result bool   `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"`
	Msg    string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
}

func (*OperateLeaderResponse) Descriptor 

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

func (*OperateLeaderResponse) GetMsg 

func (m *OperateLeaderResponse) GetMsg() string

func (*OperateLeaderResponse) GetResult 

func (m *OperateLeaderResponse) GetResult() bool

func (*OperateLeaderResponse) Marshal 

func (m *OperateLeaderResponse) Marshal() (dAtA []byte, err error)

func (*OperateLeaderResponse) MarshalTo 

func (m *OperateLeaderResponse) MarshalTo(dAtA []byte) (int, error)

func (*OperateLeaderResponse) MarshalToSizedBuffer 

func (m *OperateLeaderResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*OperateLeaderResponse) ProtoMessage 

func (*OperateLeaderResponse) ProtoMessage()

func (*OperateLeaderResponse) Reset 

func (m *OperateLeaderResponse) Reset()

func (*OperateLeaderResponse) Size 

func (m *OperateLeaderResponse) Size() (n int)

func (*OperateLeaderResponse) String 

func (m *OperateLeaderResponse) String() string

func (*OperateLeaderResponse) Unmarshal 

func (m *OperateLeaderResponse) Unmarshal(dAtA []byte) error

func (*OperateLeaderResponse) XXX_DiscardUnknown 

func (m *OperateLeaderResponse) XXX_DiscardUnknown()

func (*OperateLeaderResponse) XXX_Marshal 

func (m *OperateLeaderResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OperateLeaderResponse) XXX_Merge 

func (m *OperateLeaderResponse) XXX_Merge(src proto.Message)

func (*OperateLeaderResponse) XXX_Size 

func (m *OperateLeaderResponse) XXX_Size() int

func (*OperateLeaderResponse) XXX_Unmarshal 

func (m *OperateLeaderResponse) XXX_Unmarshal(b []byte) error

type OperateRelayRequest 

type OperateRelayRequest struct {
	Op     RelayOpV2 `protobuf:"varint,1,opt,name=op,proto3,enum=pb.RelayOpV2" json:"op,omitempty"`
	Source string    `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"`
	Worker []string  `protobuf:"bytes,3,rep,name=worker,proto3" json:"worker,omitempty"`
}

func (*OperateRelayRequest) Descriptor 

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

func (*OperateRelayRequest) GetOp 

func (m *OperateRelayRequest) GetOp() RelayOpV2

func (*OperateRelayRequest) GetSource 

func (m *OperateRelayRequest) GetSource() string

func (*OperateRelayRequest) GetWorker 

func (m *OperateRelayRequest) GetWorker() []string

func (*OperateRelayRequest) Marshal 

func (m *OperateRelayRequest) Marshal() (dAtA []byte, err error)

func (*OperateRelayRequest) MarshalTo 

func (m *OperateRelayRequest) MarshalTo(dAtA []byte) (int, error)

func (*OperateRelayRequest) MarshalToSizedBuffer 

func (m *OperateRelayRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*OperateRelayRequest) ProtoMessage 

func (*OperateRelayRequest) ProtoMessage()

func (*OperateRelayRequest) Reset 

func (m *OperateRelayRequest) Reset()

func (*OperateRelayRequest) Size 

func (m *OperateRelayRequest) Size() (n int)

func (*OperateRelayRequest) String 

func (m *OperateRelayRequest) String() string

func (*OperateRelayRequest) Unmarshal 

func (m *OperateRelayRequest) Unmarshal(dAtA []byte) error

func (*OperateRelayRequest) XXX_DiscardUnknown 

func (m *OperateRelayRequest) XXX_DiscardUnknown()

func (*OperateRelayRequest) XXX_Marshal 

func (m *OperateRelayRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OperateRelayRequest) XXX_Merge 

func (m *OperateRelayRequest) XXX_Merge(src proto.Message)

func (*OperateRelayRequest) XXX_Size 

func (m *OperateRelayRequest) XXX_Size() int

func (*OperateRelayRequest) XXX_Unmarshal 

func (m *OperateRelayRequest) XXX_Unmarshal(b []byte) error

type OperateRelayResponse 

type OperateRelayResponse struct {
	Result  bool                    `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"`
	Msg     string                  `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	Sources []*CommonWorkerResponse `protobuf:"bytes,3,rep,name=sources,proto3" json:"sources,omitempty"`
}

func (*OperateRelayResponse) Descriptor 

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

func (*OperateRelayResponse) GetMsg 

func (m *OperateRelayResponse) GetMsg() string

func (*OperateRelayResponse) GetResult 

func (m *OperateRelayResponse) GetResult() bool

func (*OperateRelayResponse) GetSources 

func (m *OperateRelayResponse) GetSources() []*CommonWorkerResponse

func (*OperateRelayResponse) Marshal 

func (m *OperateRelayResponse) Marshal() (dAtA []byte, err error)

func (*OperateRelayResponse) MarshalTo 

func (m *OperateRelayResponse) MarshalTo(dAtA []byte) (int, error)

func (*OperateRelayResponse) MarshalToSizedBuffer 

func (m *OperateRelayResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*OperateRelayResponse) ProtoMessage 

func (*OperateRelayResponse) ProtoMessage()

func (*OperateRelayResponse) Reset 

func (m *OperateRelayResponse) Reset()

func (*OperateRelayResponse) Size 

func (m *OperateRelayResponse) Size() (n int)

func (*OperateRelayResponse) String 

func (m *OperateRelayResponse) String() string

func (*OperateRelayResponse) Unmarshal 

func (m *OperateRelayResponse) Unmarshal(dAtA []byte) error

func (*OperateRelayResponse) XXX_DiscardUnknown 

func (m *OperateRelayResponse) XXX_DiscardUnknown()

func (*OperateRelayResponse) XXX_Marshal 

func (m *OperateRelayResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OperateRelayResponse) XXX_Merge 

func (m *OperateRelayResponse) XXX_Merge(src proto.Message)

func (*OperateRelayResponse) XXX_Size 

func (m *OperateRelayResponse) XXX_Size() int

func (*OperateRelayResponse) XXX_Unmarshal 

func (m *OperateRelayResponse) XXX_Unmarshal(b []byte) error

type OperateSchemaRequest 

type OperateSchemaRequest struct {
	Op         SchemaOp `protobuf:"varint,1,opt,name=op,proto3,enum=pb.SchemaOp" json:"op,omitempty"`
	Task       string   `protobuf:"bytes,2,opt,name=task,proto3" json:"task,omitempty"`
	Sources    []string `protobuf:"bytes,3,rep,name=sources,proto3" json:"sources,omitempty"`
	Database   string   `protobuf:"bytes,4,opt,name=database,proto3" json:"database,omitempty"`
	Table      string   `protobuf:"bytes,5,opt,name=table,proto3" json:"table,omitempty"`
	Schema     string   `protobuf:"bytes,6,opt,name=schema,proto3" json:"schema,omitempty"`
	Flush      bool     `protobuf:"varint,7,opt,name=flush,proto3" json:"flush,omitempty"`
	Sync       bool     `protobuf:"varint,8,opt,name=sync,proto3" json:"sync,omitempty"`
	FromSource bool     `protobuf:"varint,9,opt,name=fromSource,proto3" json:"fromSource,omitempty"`
	FromTarget bool     `protobuf:"varint,10,opt,name=fromTarget,proto3" json:"fromTarget,omitempty"`
}

func (*OperateSchemaRequest) Descriptor 

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

func (*OperateSchemaRequest) GetDatabase 

func (m *OperateSchemaRequest) GetDatabase() string

func (*OperateSchemaRequest) GetFlush 

func (m *OperateSchemaRequest) GetFlush() bool

func (*OperateSchemaRequest) GetFromSource 

func (m *OperateSchemaRequest) GetFromSource() bool

func (*OperateSchemaRequest) GetFromTarget 

func (m *OperateSchemaRequest) GetFromTarget() bool

func (*OperateSchemaRequest) GetOp 

func (m *OperateSchemaRequest) GetOp() SchemaOp

func (*OperateSchemaRequest) GetSchema 

func (m *OperateSchemaRequest) GetSchema() string

func (*OperateSchemaRequest) GetSources 

func (m *OperateSchemaRequest) GetSources() []string

func (*OperateSchemaRequest) GetSync 

func (m *OperateSchemaRequest) GetSync() bool

func (*OperateSchemaRequest) GetTable 

func (m *OperateSchemaRequest) GetTable() string

func (*OperateSchemaRequest) GetTask 

func (m *OperateSchemaRequest) GetTask() string

func (*OperateSchemaRequest) Marshal 

func (m *OperateSchemaRequest) Marshal() (dAtA []byte, err error)

func (*OperateSchemaRequest) MarshalTo 

func (m *OperateSchemaRequest) MarshalTo(dAtA []byte) (int, error)

func (*OperateSchemaRequest) MarshalToSizedBuffer 

func (m *OperateSchemaRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*OperateSchemaRequest) ProtoMessage 

func (*OperateSchemaRequest) ProtoMessage()

func (*OperateSchemaRequest) Reset 

func (m *OperateSchemaRequest) Reset()

func (*OperateSchemaRequest) Size 

func (m *OperateSchemaRequest) Size() (n int)

func (*OperateSchemaRequest) String 

func (m *OperateSchemaRequest) String() string

func (*OperateSchemaRequest) Unmarshal 

func (m *OperateSchemaRequest) Unmarshal(dAtA []byte) error

func (*OperateSchemaRequest) XXX_DiscardUnknown 

func (m *OperateSchemaRequest) XXX_DiscardUnknown()

func (*OperateSchemaRequest) XXX_Marshal 

func (m *OperateSchemaRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OperateSchemaRequest) XXX_Merge 

func (m *OperateSchemaRequest) XXX_Merge(src proto.Message)

func (*OperateSchemaRequest) XXX_Size 

func (m *OperateSchemaRequest) XXX_Size() int

func (*OperateSchemaRequest) XXX_Unmarshal 

func (m *OperateSchemaRequest) XXX_Unmarshal(b []byte) error

type OperateSchemaResponse 

type OperateSchemaResponse struct {
	Result  bool                    `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"`
	Msg     string                  `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	Sources []*CommonWorkerResponse `protobuf:"bytes,3,rep,name=sources,proto3" json:"sources,omitempty"`
}

func (*OperateSchemaResponse) Descriptor 

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

func (*OperateSchemaResponse) GetMsg 

func (m *OperateSchemaResponse) GetMsg() string

func (*OperateSchemaResponse) GetResult 

func (m *OperateSchemaResponse) GetResult() bool

func (*OperateSchemaResponse) GetSources 

func (m *OperateSchemaResponse) GetSources() []*CommonWorkerResponse

func (*OperateSchemaResponse) Marshal 

func (m *OperateSchemaResponse) Marshal() (dAtA []byte, err error)

func (*OperateSchemaResponse) MarshalTo 

func (m *OperateSchemaResponse) MarshalTo(dAtA []byte) (int, error)

func (*OperateSchemaResponse) MarshalToSizedBuffer 

func (m *OperateSchemaResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*OperateSchemaResponse) ProtoMessage 

func (*OperateSchemaResponse) ProtoMessage()

func (*OperateSchemaResponse) Reset 

func (m *OperateSchemaResponse) Reset()

func (*OperateSchemaResponse) Size 

func (m *OperateSchemaResponse) Size() (n int)

func (*OperateSchemaResponse) String 

func (m *OperateSchemaResponse) String() string

func (*OperateSchemaResponse) Unmarshal 

func (m *OperateSchemaResponse) Unmarshal(dAtA []byte) error

func (*OperateSchemaResponse) XXX_DiscardUnknown 

func (m *OperateSchemaResponse) XXX_DiscardUnknown()

func (*OperateSchemaResponse) XXX_Marshal 

func (m *OperateSchemaResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OperateSchemaResponse) XXX_Merge 

func (m *OperateSchemaResponse) XXX_Merge(src proto.Message)

func (*OperateSchemaResponse) XXX_Size 

func (m *OperateSchemaResponse) XXX_Size() int

func (*OperateSchemaResponse) XXX_Unmarshal 

func (m *OperateSchemaResponse) XXX_Unmarshal(b []byte) error

type OperateSourceRequest 

type OperateSourceRequest struct {
	Op         SourceOp `protobuf:"varint,1,opt,name=op,proto3,enum=pb.SourceOp" json:"op,omitempty"`
	Config     []string `protobuf:"bytes,2,rep,name=config,proto3" json:"config,omitempty"`
	SourceID   []string `protobuf:"bytes,3,rep,name=sourceID,proto3" json:"sourceID,omitempty"`
	WorkerName string   `protobuf:"bytes,4,opt,name=workerName,proto3" json:"workerName,omitempty"`
}

func (*OperateSourceRequest) Descriptor 

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

func (*OperateSourceRequest) GetConfig 

func (m *OperateSourceRequest) GetConfig() []string

func (*OperateSourceRequest) GetOp 

func (m *OperateSourceRequest) GetOp() SourceOp

func (*OperateSourceRequest) GetSourceID 

func (m *OperateSourceRequest) GetSourceID() []string

func (*OperateSourceRequest) GetWorkerName 

func (m *OperateSourceRequest) GetWorkerName() string

func (*OperateSourceRequest) Marshal 

func (m *OperateSourceRequest) Marshal() (dAtA []byte, err error)

func (*OperateSourceRequest) MarshalLogObject 

func (m *OperateSourceRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

MarshalLogObject implements zapcore.ObjectMarshaler.

func (*OperateSourceRequest) MarshalTo 

func (m *OperateSourceRequest) MarshalTo(dAtA []byte) (int, error)

func (*OperateSourceRequest) MarshalToSizedBuffer 

func (m *OperateSourceRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*OperateSourceRequest) ProtoMessage 

func (*OperateSourceRequest) ProtoMessage()

func (*OperateSourceRequest) Reset 

func (m *OperateSourceRequest) Reset()

func (*OperateSourceRequest) Size 

func (m *OperateSourceRequest) Size() (n int)

func (*OperateSourceRequest) String 

func (m *OperateSourceRequest) String() string

func (*OperateSourceRequest) Unmarshal 

func (m *OperateSourceRequest) Unmarshal(dAtA []byte) error

func (*OperateSourceRequest) XXX_DiscardUnknown 

func (m *OperateSourceRequest) XXX_DiscardUnknown()

func (*OperateSourceRequest) XXX_Marshal 

func (m *OperateSourceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OperateSourceRequest) XXX_Merge 

func (m *OperateSourceRequest) XXX_Merge(src proto.Message)

func (*OperateSourceRequest) XXX_Size 

func (m *OperateSourceRequest) XXX_Size() int

func (*OperateSourceRequest) XXX_Unmarshal 

func (m *OperateSourceRequest) XXX_Unmarshal(b []byte) error

type OperateSourceResponse 

type OperateSourceResponse struct {
	Result  bool                    `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"`
	Msg     string                  `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	Sources []*CommonWorkerResponse `protobuf:"bytes,3,rep,name=sources,proto3" json:"sources,omitempty"`
}

func (*OperateSourceResponse) Descriptor 

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

func (*OperateSourceResponse) GetMsg 

func (m *OperateSourceResponse) GetMsg() string

func (*OperateSourceResponse) GetResult 

func (m *OperateSourceResponse) GetResult() bool

func (*OperateSourceResponse) GetSources 

func (m *OperateSourceResponse) GetSources() []*CommonWorkerResponse

func (*OperateSourceResponse) Marshal 

func (m *OperateSourceResponse) Marshal() (dAtA []byte, err error)

func (*OperateSourceResponse) MarshalTo 

func (m *OperateSourceResponse) MarshalTo(dAtA []byte) (int, error)

func (*OperateSourceResponse) MarshalToSizedBuffer 

func (m *OperateSourceResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*OperateSourceResponse) ProtoMessage 

func (*OperateSourceResponse) ProtoMessage()

func (*OperateSourceResponse) Reset 

func (m *OperateSourceResponse) Reset()

func (*OperateSourceResponse) Size 

func (m *OperateSourceResponse) Size() (n int)

func (*OperateSourceResponse) String 

func (m *OperateSourceResponse) String() string

func (*OperateSourceResponse) Unmarshal 

func (m *OperateSourceResponse) Unmarshal(dAtA []byte) error

func (*OperateSourceResponse) XXX_DiscardUnknown 

func (m *OperateSourceResponse) XXX_DiscardUnknown()

func (*OperateSourceResponse) XXX_Marshal 

func (m *OperateSourceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OperateSourceResponse) XXX_Merge 

func (m *OperateSourceResponse) XXX_Merge(src proto.Message)

func (*OperateSourceResponse) XXX_Size 

func (m *OperateSourceResponse) XXX_Size() int

func (*OperateSourceResponse) XXX_Unmarshal 

func (m *OperateSourceResponse) XXX_Unmarshal(b []byte) error

type OperateTaskRequest 

type OperateTaskRequest struct {
	Op      TaskOp   `protobuf:"varint,1,opt,name=op,proto3,enum=pb.TaskOp" json:"op,omitempty"`
	Name    string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Sources []string `protobuf:"bytes,3,rep,name=sources,proto3" json:"sources,omitempty"`
}

func (*OperateTaskRequest) Descriptor 

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

func (*OperateTaskRequest) GetName 

func (m *OperateTaskRequest) GetName() string

func (*OperateTaskRequest) GetOp 

func (m *OperateTaskRequest) GetOp() TaskOp

func (*OperateTaskRequest) GetSources 

func (m *OperateTaskRequest) GetSources() []string

func (*OperateTaskRequest) Marshal 

func (m *OperateTaskRequest) Marshal() (dAtA []byte, err error)

func (*OperateTaskRequest) MarshalTo 

func (m *OperateTaskRequest) MarshalTo(dAtA []byte) (int, error)

func (*OperateTaskRequest) MarshalToSizedBuffer 

func (m *OperateTaskRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*OperateTaskRequest) ProtoMessage 

func (*OperateTaskRequest) ProtoMessage()

func (*OperateTaskRequest) Reset 

func (m *OperateTaskRequest) Reset()

func (*OperateTaskRequest) Size 

func (m *OperateTaskRequest) Size() (n int)

func (*OperateTaskRequest) String 

func (m *OperateTaskRequest) String() string

func (*OperateTaskRequest) Unmarshal 

func (m *OperateTaskRequest) Unmarshal(dAtA []byte) error

func (*OperateTaskRequest) XXX_DiscardUnknown 

func (m *OperateTaskRequest) XXX_DiscardUnknown()

func (*OperateTaskRequest) XXX_Marshal 

func (m *OperateTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OperateTaskRequest) XXX_Merge 

func (m *OperateTaskRequest) XXX_Merge(src proto.Message)

func (*OperateTaskRequest) XXX_Size 

func (m *OperateTaskRequest) XXX_Size() int

func (*OperateTaskRequest) XXX_Unmarshal 

func (m *OperateTaskRequest) XXX_Unmarshal(b []byte) error

type OperateTaskResponse 

type OperateTaskResponse struct {
	Op      TaskOp                  `protobuf:"varint,1,opt,name=op,proto3,enum=pb.TaskOp" json:"op,omitempty"`
	Result  bool                    `protobuf:"varint,2,opt,name=result,proto3" json:"result,omitempty"`
	Msg     string                  `protobuf:"bytes,3,opt,name=msg,proto3" json:"msg,omitempty"`
	Sources []*CommonWorkerResponse `protobuf:"bytes,4,rep,name=sources,proto3" json:"sources,omitempty"`
}

func (*OperateTaskResponse) Descriptor 

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

func (*OperateTaskResponse) GetMsg 

func (m *OperateTaskResponse) GetMsg() string

func (*OperateTaskResponse) GetOp 

func (m *OperateTaskResponse) GetOp() TaskOp

func (*OperateTaskResponse) GetResult 

func (m *OperateTaskResponse) GetResult() bool

func (*OperateTaskResponse) GetSources 

func (m *OperateTaskResponse) GetSources() []*CommonWorkerResponse

func (*OperateTaskResponse) Marshal 

func (m *OperateTaskResponse) Marshal() (dAtA []byte, err error)

func (*OperateTaskResponse) MarshalTo 

func (m *OperateTaskResponse) MarshalTo(dAtA []byte) (int, error)

func (*OperateTaskResponse) MarshalToSizedBuffer 

func (m *OperateTaskResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*OperateTaskResponse) ProtoMessage 

func (*OperateTaskResponse) ProtoMessage()

func (*OperateTaskResponse) Reset 

func (m *OperateTaskResponse) Reset()

func (*OperateTaskResponse) Size 

func (m *OperateTaskResponse) Size() (n int)

func (*OperateTaskResponse) String 

func (m *OperateTaskResponse) String() string

func (*OperateTaskResponse) Unmarshal 

func (m *OperateTaskResponse) Unmarshal(dAtA []byte) error

func (*OperateTaskResponse) XXX_DiscardUnknown 

func (m *OperateTaskResponse) XXX_DiscardUnknown()

func (*OperateTaskResponse) XXX_Marshal 

func (m *OperateTaskResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OperateTaskResponse) XXX_Merge 

func (m *OperateTaskResponse) XXX_Merge(src proto.Message)

func (*OperateTaskResponse) XXX_Size 

func (m *OperateTaskResponse) XXX_Size() int

func (*OperateTaskResponse) XXX_Unmarshal 

func (m *OperateTaskResponse) XXX_Unmarshal(b []byte) error

type OperateV1MetaRequest 

type OperateV1MetaRequest struct {
	Op V1MetaOp `protobuf:"varint,1,opt,name=op,proto3,enum=pb.V1MetaOp" json:"op,omitempty"`
}

func (*OperateV1MetaRequest) Descriptor 

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

func (*OperateV1MetaRequest) GetOp 

func (m *OperateV1MetaRequest) GetOp() V1MetaOp

func (*OperateV1MetaRequest) Marshal 

func (m *OperateV1MetaRequest) Marshal() (dAtA []byte, err error)

func (*OperateV1MetaRequest) MarshalTo 

func (m *OperateV1MetaRequest) MarshalTo(dAtA []byte) (int, error)

func (*OperateV1MetaRequest) MarshalToSizedBuffer 

func (m *OperateV1MetaRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*OperateV1MetaRequest) ProtoMessage 

func (*OperateV1MetaRequest) ProtoMessage()

func (*OperateV1MetaRequest) Reset 

func (m *OperateV1MetaRequest) Reset()

func (*OperateV1MetaRequest) Size 

func (m *OperateV1MetaRequest) Size() (n int)

func (*OperateV1MetaRequest) String 

func (m *OperateV1MetaRequest) String() string

func (*OperateV1MetaRequest) Unmarshal 

func (m *OperateV1MetaRequest) Unmarshal(dAtA []byte) error

func (*OperateV1MetaRequest) XXX_DiscardUnknown 

func (m *OperateV1MetaRequest) XXX_DiscardUnknown()

func (*OperateV1MetaRequest) XXX_Marshal 

func (m *OperateV1MetaRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OperateV1MetaRequest) XXX_Merge 

func (m *OperateV1MetaRequest) XXX_Merge(src proto.Message)

func (*OperateV1MetaRequest) XXX_Size 

func (m *OperateV1MetaRequest) XXX_Size() int

func (*OperateV1MetaRequest) XXX_Unmarshal 

func (m *OperateV1MetaRequest) XXX_Unmarshal(b []byte) error

type OperateV1MetaResponse 

type OperateV1MetaResponse struct {
	Result bool                      `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"`
	Msg    string                    `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	Meta   map[string]*V1SubTaskMeta `` /* 149-byte string literal not displayed */
}

func (*OperateV1MetaResponse) Descriptor 

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

func (*OperateV1MetaResponse) GetMeta 

func (m *OperateV1MetaResponse) GetMeta() map[string]*V1SubTaskMeta

func (*OperateV1MetaResponse) GetMsg 

func (m *OperateV1MetaResponse) GetMsg() string

func (*OperateV1MetaResponse) GetResult 

func (m *OperateV1MetaResponse) GetResult() bool

func (*OperateV1MetaResponse) Marshal 

func (m *OperateV1MetaResponse) Marshal() (dAtA []byte, err error)

func (*OperateV1MetaResponse) MarshalTo 

func (m *OperateV1MetaResponse) MarshalTo(dAtA []byte) (int, error)

func (*OperateV1MetaResponse) MarshalToSizedBuffer 

func (m *OperateV1MetaResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*OperateV1MetaResponse) ProtoMessage 

func (*OperateV1MetaResponse) ProtoMessage()

func (*OperateV1MetaResponse) Reset 

func (m *OperateV1MetaResponse) Reset()

func (*OperateV1MetaResponse) Size 

func (m *OperateV1MetaResponse) Size() (n int)

func (*OperateV1MetaResponse) String 

func (m *OperateV1MetaResponse) String() string

func (*OperateV1MetaResponse) Unmarshal 

func (m *OperateV1MetaResponse) Unmarshal(dAtA []byte) error

func (*OperateV1MetaResponse) XXX_DiscardUnknown 

func (m *OperateV1MetaResponse) XXX_DiscardUnknown()

func (*OperateV1MetaResponse) XXX_Marshal 

func (m *OperateV1MetaResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OperateV1MetaResponse) XXX_Merge 

func (m *OperateV1MetaResponse) XXX_Merge(src proto.Message)

func (*OperateV1MetaResponse) XXX_Size 

func (m *OperateV1MetaResponse) XXX_Size() int

func (*OperateV1MetaResponse) XXX_Unmarshal 

func (m *OperateV1MetaResponse) XXX_Unmarshal(b []byte) error

type OperateValidationErrorRequest 

type OperateValidationErrorRequest struct {
	Op         ValidationErrOp `protobuf:"varint,1,opt,name=op,proto3,enum=pb.ValidationErrOp" json:"op,omitempty"`
	IsAllError bool            `protobuf:"varint,2,opt,name=isAllError,proto3" json:"isAllError,omitempty"`
	TaskName   string          `protobuf:"bytes,3,opt,name=taskName,proto3" json:"taskName,omitempty"`
	ErrId      uint64          `protobuf:"varint,4,opt,name=errId,proto3" json:"errId,omitempty"`
}

func (*OperateValidationErrorRequest) Descriptor 

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

func (*OperateValidationErrorRequest) GetErrId 

func (m *OperateValidationErrorRequest) GetErrId() uint64

func (*OperateValidationErrorRequest) GetIsAllError 

func (m *OperateValidationErrorRequest) GetIsAllError() bool

func (*OperateValidationErrorRequest) GetOp 

func (m *OperateValidationErrorRequest) GetOp() ValidationErrOp

func (*OperateValidationErrorRequest) GetTaskName 

func (m *OperateValidationErrorRequest) GetTaskName() string

func (*OperateValidationErrorRequest) Marshal 

func (m *OperateValidationErrorRequest) Marshal() (dAtA []byte, err error)

func (*OperateValidationErrorRequest) MarshalTo 

func (m *OperateValidationErrorRequest) MarshalTo(dAtA []byte) (int, error)

func (*OperateValidationErrorRequest) MarshalToSizedBuffer 

func (m *OperateValidationErrorRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*OperateValidationErrorRequest) ProtoMessage 

func (*OperateValidationErrorRequest) ProtoMessage()

func (*OperateValidationErrorRequest) Reset 

func (m *OperateValidationErrorRequest) Reset()

func (*OperateValidationErrorRequest) Size 

func (m *OperateValidationErrorRequest) Size() (n int)

func (*OperateValidationErrorRequest) String 

func (m *OperateValidationErrorRequest) String() string

func (*OperateValidationErrorRequest) Unmarshal 

func (m *OperateValidationErrorRequest) Unmarshal(dAtA []byte) error

func (*OperateValidationErrorRequest) XXX_DiscardUnknown 

func (m *OperateValidationErrorRequest) XXX_DiscardUnknown()

func (*OperateValidationErrorRequest) XXX_Marshal 

func (m *OperateValidationErrorRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OperateValidationErrorRequest) XXX_Merge 

func (m *OperateValidationErrorRequest) XXX_Merge(src proto.Message)

func (*OperateValidationErrorRequest) XXX_Size 

func (m *OperateValidationErrorRequest) XXX_Size() int

func (*OperateValidationErrorRequest) XXX_Unmarshal 

func (m *OperateValidationErrorRequest) XXX_Unmarshal(b []byte) error

type OperateValidationErrorResponse 

type OperateValidationErrorResponse struct {
	Result bool   `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"`
	Msg    string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
}

func (*OperateValidationErrorResponse) Descriptor 

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

func (*OperateValidationErrorResponse) GetMsg 

func (m *OperateValidationErrorResponse) GetMsg() string

func (*OperateValidationErrorResponse) GetResult 

func (m *OperateValidationErrorResponse) GetResult() bool

func (*OperateValidationErrorResponse) Marshal 

func (m *OperateValidationErrorResponse) Marshal() (dAtA []byte, err error)

func (*OperateValidationErrorResponse) MarshalTo 

func (m *OperateValidationErrorResponse) MarshalTo(dAtA []byte) (int, error)

func (*OperateValidationErrorResponse) MarshalToSizedBuffer 

func (m *OperateValidationErrorResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*OperateValidationErrorResponse) ProtoMessage 

func (*OperateValidationErrorResponse) ProtoMessage()

func (*OperateValidationErrorResponse) Reset 

func (m *OperateValidationErrorResponse) Reset()

func (*OperateValidationErrorResponse) Size 

func (m *OperateValidationErrorResponse) Size() (n int)

func (*OperateValidationErrorResponse) String 

func (m *OperateValidationErrorResponse) String() string

func (*OperateValidationErrorResponse) Unmarshal 

func (m *OperateValidationErrorResponse) Unmarshal(dAtA []byte) error

func (*OperateValidationErrorResponse) XXX_DiscardUnknown 

func (m *OperateValidationErrorResponse) XXX_DiscardUnknown()

func (*OperateValidationErrorResponse) XXX_Marshal 

func (m *OperateValidationErrorResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OperateValidationErrorResponse) XXX_Merge 

func (m *OperateValidationErrorResponse) XXX_Merge(src proto.Message)

func (*OperateValidationErrorResponse) XXX_Size 

func (m *OperateValidationErrorResponse) XXX_Size() int

func (*OperateValidationErrorResponse) XXX_Unmarshal 

func (m *OperateValidationErrorResponse) XXX_Unmarshal(b []byte) error

type OperateWorkerRelayRequest 

type OperateWorkerRelayRequest struct {
	Op      RelayOp  `protobuf:"varint,1,opt,name=op,proto3,enum=pb.RelayOp" json:"op,omitempty"`
	Sources []string `protobuf:"bytes,2,rep,name=sources,proto3" json:"sources,omitempty"`
}

OperateWorkerRelayRequest represents a request for some dm-workers to operate relay unit

func (*OperateWorkerRelayRequest) Descriptor 

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

func (*OperateWorkerRelayRequest) GetOp 

func (m *OperateWorkerRelayRequest) GetOp() RelayOp

func (*OperateWorkerRelayRequest) GetSources 

func (m *OperateWorkerRelayRequest) GetSources() []string

func (*OperateWorkerRelayRequest) Marshal 

func (m *OperateWorkerRelayRequest) Marshal() (dAtA []byte, err error)

func (*OperateWorkerRelayRequest) MarshalTo 

func (m *OperateWorkerRelayRequest) MarshalTo(dAtA []byte) (int, error)

func (*OperateWorkerRelayRequest) MarshalToSizedBuffer 

func (m *OperateWorkerRelayRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*OperateWorkerRelayRequest) ProtoMessage 

func (*OperateWorkerRelayRequest) ProtoMessage()

func (*OperateWorkerRelayRequest) Reset 

func (m *OperateWorkerRelayRequest) Reset()

func (*OperateWorkerRelayRequest) Size 

func (m *OperateWorkerRelayRequest) Size() (n int)

func (*OperateWorkerRelayRequest) String 

func (m *OperateWorkerRelayRequest) String() string

func (*OperateWorkerRelayRequest) Unmarshal 

func (m *OperateWorkerRelayRequest) Unmarshal(dAtA []byte) error

func (*OperateWorkerRelayRequest) XXX_DiscardUnknown 

func (m *OperateWorkerRelayRequest) XXX_DiscardUnknown()

func (*OperateWorkerRelayRequest) XXX_Marshal 

func (m *OperateWorkerRelayRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OperateWorkerRelayRequest) XXX_Merge 

func (m *OperateWorkerRelayRequest) XXX_Merge(src proto.Message)

func (*OperateWorkerRelayRequest) XXX_Size 

func (m *OperateWorkerRelayRequest) XXX_Size() int

func (*OperateWorkerRelayRequest) XXX_Unmarshal 

func (m *OperateWorkerRelayRequest) XXX_Unmarshal(b []byte) error

type OperateWorkerRelayResponse 

type OperateWorkerRelayResponse struct {
	Op      RelayOp                 `protobuf:"varint,1,opt,name=op,proto3,enum=pb.RelayOp" json:"op,omitempty"`
	Result  bool                    `protobuf:"varint,2,opt,name=result,proto3" json:"result,omitempty"`
	Msg     string                  `protobuf:"bytes,3,opt,name=msg,proto3" json:"msg,omitempty"`
	Sources []*CommonWorkerResponse `protobuf:"bytes,4,rep,name=sources,proto3" json:"sources,omitempty"`
}

func (*OperateWorkerRelayResponse) Descriptor 

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

func (*OperateWorkerRelayResponse) GetMsg 

func (m *OperateWorkerRelayResponse) GetMsg() string

func (*OperateWorkerRelayResponse) GetOp 

func (m *OperateWorkerRelayResponse) GetOp() RelayOp

func (*OperateWorkerRelayResponse) GetResult 

func (m *OperateWorkerRelayResponse) GetResult() bool

func (*OperateWorkerRelayResponse) GetSources 

func (m *OperateWorkerRelayResponse) GetSources() []*CommonWorkerResponse

func (*OperateWorkerRelayResponse) Marshal 

func (m *OperateWorkerRelayResponse) Marshal() (dAtA []byte, err error)

func (*OperateWorkerRelayResponse) MarshalTo 

func (m *OperateWorkerRelayResponse) MarshalTo(dAtA []byte) (int, error)

func (*OperateWorkerRelayResponse) MarshalToSizedBuffer 

func (m *OperateWorkerRelayResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*OperateWorkerRelayResponse) ProtoMessage 

func (*OperateWorkerRelayResponse) ProtoMessage()

func (*OperateWorkerRelayResponse) Reset 

func (m *OperateWorkerRelayResponse) Reset()

func (*OperateWorkerRelayResponse) Size 

func (m *OperateWorkerRelayResponse) Size() (n int)

func (*OperateWorkerRelayResponse) String 

func (m *OperateWorkerRelayResponse) String() string

func (*OperateWorkerRelayResponse) Unmarshal 

func (m *OperateWorkerRelayResponse) Unmarshal(dAtA []byte) error

func (*OperateWorkerRelayResponse) XXX_DiscardUnknown 

func (m *OperateWorkerRelayResponse) XXX_DiscardUnknown()

func (*OperateWorkerRelayResponse) XXX_Marshal 

func (m *OperateWorkerRelayResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OperateWorkerRelayResponse) XXX_Merge 

func (m *OperateWorkerRelayResponse) XXX_Merge(src proto.Message)

func (*OperateWorkerRelayResponse) XXX_Size 

func (m *OperateWorkerRelayResponse) XXX_Size() int

func (*OperateWorkerRelayResponse) XXX_Unmarshal 

func (m *OperateWorkerRelayResponse) XXX_Unmarshal(b []byte) error

type OperateWorkerSchemaRequest 

type OperateWorkerSchemaRequest struct {
	Op         SchemaOp `protobuf:"varint,1,opt,name=op,proto3,enum=pb.SchemaOp" json:"op,omitempty"`
	Task       string   `protobuf:"bytes,2,opt,name=task,proto3" json:"task,omitempty"`
	Source     string   `protobuf:"bytes,3,opt,name=source,proto3" json:"source,omitempty"`
	Database   string   `protobuf:"bytes,4,opt,name=database,proto3" json:"database,omitempty"`
	Table      string   `protobuf:"bytes,5,opt,name=table,proto3" json:"table,omitempty"`
	Schema     string   `protobuf:"bytes,6,opt,name=schema,proto3" json:"schema,omitempty"`
	Flush      bool     `protobuf:"varint,7,opt,name=flush,proto3" json:"flush,omitempty"`
	Sync       bool     `protobuf:"varint,8,opt,name=sync,proto3" json:"sync,omitempty"`
	FromSource bool     `protobuf:"varint,9,opt,name=fromSource,proto3" json:"fromSource,omitempty"`
	FromTarget bool     `protobuf:"varint,10,opt,name=fromTarget,proto3" json:"fromTarget,omitempty"`
}

func (*OperateWorkerSchemaRequest) Descriptor 

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

func (*OperateWorkerSchemaRequest) GetDatabase 

func (m *OperateWorkerSchemaRequest) GetDatabase() string

func (*OperateWorkerSchemaRequest) GetFlush 

func (m *OperateWorkerSchemaRequest) GetFlush() bool

func (*OperateWorkerSchemaRequest) GetFromSource 

func (m *OperateWorkerSchemaRequest) GetFromSource() bool

func (*OperateWorkerSchemaRequest) GetFromTarget 

func (m *OperateWorkerSchemaRequest) GetFromTarget() bool

func (*OperateWorkerSchemaRequest) GetOp 

func (m *OperateWorkerSchemaRequest) GetOp() SchemaOp

func (*OperateWorkerSchemaRequest) GetSchema 

func (m *OperateWorkerSchemaRequest) GetSchema() string

func (*OperateWorkerSchemaRequest) GetSource 

func (m *OperateWorkerSchemaRequest) GetSource() string

func (*OperateWorkerSchemaRequest) GetSync 

func (m *OperateWorkerSchemaRequest) GetSync() bool

func (*OperateWorkerSchemaRequest) GetTable 

func (m *OperateWorkerSchemaRequest) GetTable() string

func (*OperateWorkerSchemaRequest) GetTask 

func (m *OperateWorkerSchemaRequest) GetTask() string

func (*OperateWorkerSchemaRequest) Marshal 

func (m *OperateWorkerSchemaRequest) Marshal() (dAtA []byte, err error)

func (*OperateWorkerSchemaRequest) MarshalTo 

func (m *OperateWorkerSchemaRequest) MarshalTo(dAtA []byte) (int, error)

func (*OperateWorkerSchemaRequest) MarshalToSizedBuffer 

func (m *OperateWorkerSchemaRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*OperateWorkerSchemaRequest) ProtoMessage 

func (*OperateWorkerSchemaRequest) ProtoMessage()

func (*OperateWorkerSchemaRequest) Reset 

func (m *OperateWorkerSchemaRequest) Reset()

func (*OperateWorkerSchemaRequest) Size 

func (m *OperateWorkerSchemaRequest) Size() (n int)

func (*OperateWorkerSchemaRequest) String 

func (m *OperateWorkerSchemaRequest) String() string

func (*OperateWorkerSchemaRequest) Unmarshal 

func (m *OperateWorkerSchemaRequest) Unmarshal(dAtA []byte) error

func (*OperateWorkerSchemaRequest) XXX_DiscardUnknown 

func (m *OperateWorkerSchemaRequest) XXX_DiscardUnknown()

func (*OperateWorkerSchemaRequest) XXX_Marshal 

func (m *OperateWorkerSchemaRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OperateWorkerSchemaRequest) XXX_Merge 

func (m *OperateWorkerSchemaRequest) XXX_Merge(src proto.Message)

func (*OperateWorkerSchemaRequest) XXX_Size 

func (m *OperateWorkerSchemaRequest) XXX_Size() int

func (*OperateWorkerSchemaRequest) XXX_Unmarshal 

func (m *OperateWorkerSchemaRequest) XXX_Unmarshal(b []byte) error

type ProcessError 

type ProcessError struct {
	ErrCode    int32  `protobuf:"varint,1,opt,name=ErrCode,proto3" json:"ErrCode,omitempty"`
	ErrClass   string `protobuf:"bytes,2,opt,name=ErrClass,proto3" json:"ErrClass,omitempty"`
	ErrScope   string `protobuf:"bytes,3,opt,name=ErrScope,proto3" json:"ErrScope,omitempty"`
	ErrLevel   string `protobuf:"bytes,4,opt,name=ErrLevel,proto3" json:"ErrLevel,omitempty"`
	Message    string `protobuf:"bytes,5,opt,name=Message,proto3" json:"Message,omitempty"`
	RawCause   string `protobuf:"bytes,6,opt,name=RawCause,proto3" json:"RawCause,omitempty"`
	Workaround string `protobuf:"bytes,7,opt,name=Workaround,proto3" json:"Workaround,omitempty"`
}

ProcessError is same as terror used in dm NOTE: currently stack trace is not supported, `Message` is the `terror.Error.getMsg` result and `RawCause` is the `Error` result of error from `terror.Error.Cause()`.

func (*ProcessError) Descriptor 

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

func (*ProcessError) GetErrClass 

func (m *ProcessError) GetErrClass() string

func (*ProcessError) GetErrCode 

func (m *ProcessError) GetErrCode() int32

func (*ProcessError) GetErrLevel 

func (m *ProcessError) GetErrLevel() string

func (*ProcessError) GetErrScope 

func (m *ProcessError) GetErrScope() string

func (*ProcessError) GetMessage 

func (m *ProcessError) GetMessage() string

func (*ProcessError) GetRawCause 

func (m *ProcessError) GetRawCause() string

func (*ProcessError) GetWorkaround 

func (m *ProcessError) GetWorkaround() string

func (*ProcessError) Marshal 

func (m *ProcessError) Marshal() (dAtA []byte, err error)

func (*ProcessError) MarshalTo 

func (m *ProcessError) MarshalTo(dAtA []byte) (int, error)

func (*ProcessError) MarshalToSizedBuffer 

func (m *ProcessError) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ProcessError) ProtoMessage 

func (*ProcessError) ProtoMessage()

func (*ProcessError) Reset 

func (m *ProcessError) Reset()

func (*ProcessError) Size 

func (m *ProcessError) Size() (n int)

func (*ProcessError) String 

func (m *ProcessError) String() string

func (*ProcessError) Unmarshal 

func (m *ProcessError) Unmarshal(dAtA []byte) error

func (*ProcessError) XXX_DiscardUnknown 

func (m *ProcessError) XXX_DiscardUnknown()

func (*ProcessError) XXX_Marshal 

func (m *ProcessError) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProcessError) XXX_Merge 

func (m *ProcessError) XXX_Merge(src proto.Message)

func (*ProcessError) XXX_Size 

func (m *ProcessError) XXX_Size() int

func (*ProcessError) XXX_Unmarshal 

func (m *ProcessError) XXX_Unmarshal(b []byte) error

type ProcessResult 

type ProcessResult struct {
	IsCanceled bool            `protobuf:"varint,1,opt,name=isCanceled,proto3" json:"isCanceled,omitempty"`
	Errors     []*ProcessError `protobuf:"bytes,2,rep,name=errors,proto3" json:"errors,omitempty"`
	Detail     []byte          `protobuf:"bytes,3,opt,name=detail,proto3" json:"detail,omitempty"`
}

ProcessResult represents results produced by a dm unit isCanceled: indicates whether the process is canceled from external 

when Stop or Pause is requested from external, isCanceled will be true

errors: includes all (potential) errors occured when processing

func (*ProcessResult) Descriptor 

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

func (*ProcessResult) GetDetail 

func (m *ProcessResult) GetDetail() []byte

func (*ProcessResult) GetErrors 

func (m *ProcessResult) GetErrors() []*ProcessError

func (*ProcessResult) GetIsCanceled 

func (m *ProcessResult) GetIsCanceled() bool

func (*ProcessResult) Marshal 

func (m *ProcessResult) Marshal() (dAtA []byte, err error)

func (*ProcessResult) MarshalTo 

func (m *ProcessResult) MarshalTo(dAtA []byte) (int, error)

func (*ProcessResult) MarshalToSizedBuffer 

func (m *ProcessResult) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ProcessResult) ProtoMessage 

func (*ProcessResult) ProtoMessage()

func (*ProcessResult) Reset 

func (m *ProcessResult) Reset()

func (*ProcessResult) Size 

func (m *ProcessResult) Size() (n int)

func (*ProcessResult) String 

func (m *ProcessResult) String() string

func (*ProcessResult) Unmarshal 

func (m *ProcessResult) Unmarshal(dAtA []byte) error

func (*ProcessResult) XXX_DiscardUnknown 

func (m *ProcessResult) XXX_DiscardUnknown()

func (*ProcessResult) XXX_Marshal 

func (m *ProcessResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProcessResult) XXX_Merge 

func (m *ProcessResult) XXX_Merge(src proto.Message)

func (*ProcessResult) XXX_Size 

func (m *ProcessResult) XXX_Size() int

func (*ProcessResult) XXX_Unmarshal 

func (m *ProcessResult) XXX_Unmarshal(b []byte) error

type PurgeRelayRequest 

type PurgeRelayRequest struct {
	Inactive bool   `protobuf:"varint,1,opt,name=inactive,proto3" json:"inactive,omitempty"`
	Time     int64  `protobuf:"varint,2,opt,name=time,proto3" json:"time,omitempty"`
	Filename string `protobuf:"bytes,3,opt,name=filename,proto3" json:"filename,omitempty"`
	SubDir   string `protobuf:"bytes,4,opt,name=subDir,proto3" json:"subDir,omitempty"`
}

PurgeRelayRequest represents a request to purge relay log files for this dm-worker inactive: whether purge inactive relay log files time: whether purge relay log files before this time, the number of seconds elapsed since January 1, 1970 UTC filename: whether purge relay log files before this filename subDir: specify relay sub directory for @filename

func (*PurgeRelayRequest) Descriptor 

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

func (*PurgeRelayRequest) GetFilename 

func (m *PurgeRelayRequest) GetFilename() string

func (*PurgeRelayRequest) GetInactive 

func (m *PurgeRelayRequest) GetInactive() bool

func (*PurgeRelayRequest) GetSubDir 

func (m *PurgeRelayRequest) GetSubDir() string

func (*PurgeRelayRequest) GetTime 

func (m *PurgeRelayRequest) GetTime() int64

func (*PurgeRelayRequest) Marshal 

func (m *PurgeRelayRequest) Marshal() (dAtA []byte, err error)

func (*PurgeRelayRequest) MarshalTo 

func (m *PurgeRelayRequest) MarshalTo(dAtA []byte) (int, error)

func (*PurgeRelayRequest) MarshalToSizedBuffer 

func (m *PurgeRelayRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PurgeRelayRequest) ProtoMessage 

func (*PurgeRelayRequest) ProtoMessage()

func (*PurgeRelayRequest) Reset 

func (m *PurgeRelayRequest) Reset()

func (*PurgeRelayRequest) Size 

func (m *PurgeRelayRequest) Size() (n int)

func (*PurgeRelayRequest) String 

func (m *PurgeRelayRequest) String() string

func (*PurgeRelayRequest) Unmarshal 

func (m *PurgeRelayRequest) Unmarshal(dAtA []byte) error

func (*PurgeRelayRequest) XXX_DiscardUnknown 

func (m *PurgeRelayRequest) XXX_DiscardUnknown()

func (*PurgeRelayRequest) XXX_Marshal 

func (m *PurgeRelayRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PurgeRelayRequest) XXX_Merge 

func (m *PurgeRelayRequest) XXX_Merge(src proto.Message)

func (*PurgeRelayRequest) XXX_Size 

func (m *PurgeRelayRequest) XXX_Size() int

func (*PurgeRelayRequest) XXX_Unmarshal 

func (m *PurgeRelayRequest) XXX_Unmarshal(b []byte) error

type PurgeWorkerRelayRequest 

type PurgeWorkerRelayRequest struct {
	Sources  []string `protobuf:"bytes,1,rep,name=sources,proto3" json:"sources,omitempty"`
	Inactive bool     `protobuf:"varint,2,opt,name=inactive,proto3" json:"inactive,omitempty"`
	Time     int64    `protobuf:"varint,3,opt,name=time,proto3" json:"time,omitempty"`
	Filename string   `protobuf:"bytes,4,opt,name=filename,proto3" json:"filename,omitempty"`
	SubDir   string   `protobuf:"bytes,5,opt,name=subDir,proto3" json:"subDir,omitempty"`
}

PurgeWorkerRelayRequest represents a request to purge relay log files for some dm-workers workers: dm-workers need to purge relay log files inactive: whether purge inactive relay log files time: whether purge relay log files before this time, the number of seconds elapsed since January 1, 1970 UTC filename: whether purge relay log files before this filename subDir: specify relay sub directory for @filename

func (*PurgeWorkerRelayRequest) Descriptor 

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

func (*PurgeWorkerRelayRequest) GetFilename 

func (m *PurgeWorkerRelayRequest) GetFilename() string

func (*PurgeWorkerRelayRequest) GetInactive 

func (m *PurgeWorkerRelayRequest) GetInactive() bool

func (*PurgeWorkerRelayRequest) GetSources 

func (m *PurgeWorkerRelayRequest) GetSources() []string

func (*PurgeWorkerRelayRequest) GetSubDir 

func (m *PurgeWorkerRelayRequest) GetSubDir() string

func (*PurgeWorkerRelayRequest) GetTime 

func (m *PurgeWorkerRelayRequest) GetTime() int64

func (*PurgeWorkerRelayRequest) Marshal 

func (m *PurgeWorkerRelayRequest) Marshal() (dAtA []byte, err error)

func (*PurgeWorkerRelayRequest) MarshalTo 

func (m *PurgeWorkerRelayRequest) MarshalTo(dAtA []byte) (int, error)

func (*PurgeWorkerRelayRequest) MarshalToSizedBuffer 

func (m *PurgeWorkerRelayRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PurgeWorkerRelayRequest) ProtoMessage 

func (*PurgeWorkerRelayRequest) ProtoMessage()

func (*PurgeWorkerRelayRequest) Reset 

func (m *PurgeWorkerRelayRequest) Reset()

func (*PurgeWorkerRelayRequest) Size 

func (m *PurgeWorkerRelayRequest) Size() (n int)

func (*PurgeWorkerRelayRequest) String 

func (m *PurgeWorkerRelayRequest) String() string

func (*PurgeWorkerRelayRequest) Unmarshal 

func (m *PurgeWorkerRelayRequest) Unmarshal(dAtA []byte) error

func (*PurgeWorkerRelayRequest) XXX_DiscardUnknown 

func (m *PurgeWorkerRelayRequest) XXX_DiscardUnknown()

func (*PurgeWorkerRelayRequest) XXX_Marshal 

func (m *PurgeWorkerRelayRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PurgeWorkerRelayRequest) XXX_Merge 

func (m *PurgeWorkerRelayRequest) XXX_Merge(src proto.Message)

func (*PurgeWorkerRelayRequest) XXX_Size 

func (m *PurgeWorkerRelayRequest) XXX_Size() int

func (*PurgeWorkerRelayRequest) XXX_Unmarshal 

func (m *PurgeWorkerRelayRequest) XXX_Unmarshal(b []byte) error

type PurgeWorkerRelayResponse 

type PurgeWorkerRelayResponse struct {
	Result  bool                    `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"`
	Msg     string                  `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	Sources []*CommonWorkerResponse `protobuf:"bytes,3,rep,name=sources,proto3" json:"sources,omitempty"`
}

func (*PurgeWorkerRelayResponse) Descriptor 

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

func (*PurgeWorkerRelayResponse) GetMsg 

func (m *PurgeWorkerRelayResponse) GetMsg() string

func (*PurgeWorkerRelayResponse) GetResult 

func (m *PurgeWorkerRelayResponse) GetResult() bool

func (*PurgeWorkerRelayResponse) GetSources 

func (m *PurgeWorkerRelayResponse) GetSources() []*CommonWorkerResponse

func (*PurgeWorkerRelayResponse) Marshal 

func (m *PurgeWorkerRelayResponse) Marshal() (dAtA []byte, err error)

func (*PurgeWorkerRelayResponse) MarshalTo 

func (m *PurgeWorkerRelayResponse) MarshalTo(dAtA []byte) (int, error)

func (*PurgeWorkerRelayResponse) MarshalToSizedBuffer 

func (m *PurgeWorkerRelayResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PurgeWorkerRelayResponse) ProtoMessage 

func (*PurgeWorkerRelayResponse) ProtoMessage()

func (*PurgeWorkerRelayResponse) Reset 

func (m *PurgeWorkerRelayResponse) Reset()

func (*PurgeWorkerRelayResponse) Size 

func (m *PurgeWorkerRelayResponse) Size() (n int)

func (*PurgeWorkerRelayResponse) String 

func (m *PurgeWorkerRelayResponse) String() string

func (*PurgeWorkerRelayResponse) Unmarshal 

func (m *PurgeWorkerRelayResponse) Unmarshal(dAtA []byte) error

func (*PurgeWorkerRelayResponse) XXX_DiscardUnknown 

func (m *PurgeWorkerRelayResponse) XXX_DiscardUnknown()

func (*PurgeWorkerRelayResponse) XXX_Marshal 

func (m *PurgeWorkerRelayResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PurgeWorkerRelayResponse) XXX_Merge 

func (m *PurgeWorkerRelayResponse) XXX_Merge(src proto.Message)

func (*PurgeWorkerRelayResponse) XXX_Size 

func (m *PurgeWorkerRelayResponse) XXX_Size() int

func (*PurgeWorkerRelayResponse) XXX_Unmarshal 

func (m *PurgeWorkerRelayResponse) XXX_Unmarshal(b []byte) error

type QueryStatusListRequest 

type QueryStatusListRequest struct {
	Name    string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Sources []string `protobuf:"bytes,2,rep,name=sources,proto3" json:"sources,omitempty"`
}

func (*QueryStatusListRequest) Descriptor 

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

func (*QueryStatusListRequest) GetName 

func (m *QueryStatusListRequest) GetName() string

func (*QueryStatusListRequest) GetSources 

func (m *QueryStatusListRequest) GetSources() []string

func (*QueryStatusListRequest) Marshal 

func (m *QueryStatusListRequest) Marshal() (dAtA []byte, err error)

func (*QueryStatusListRequest) MarshalTo 

func (m *QueryStatusListRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueryStatusListRequest) MarshalToSizedBuffer 

func (m *QueryStatusListRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryStatusListRequest) ProtoMessage 

func (*QueryStatusListRequest) ProtoMessage()

func (*QueryStatusListRequest) Reset 

func (m *QueryStatusListRequest) Reset()

func (*QueryStatusListRequest) Size 

func (m *QueryStatusListRequest) Size() (n int)

func (*QueryStatusListRequest) String 

func (m *QueryStatusListRequest) String() string

func (*QueryStatusListRequest) Unmarshal 

func (m *QueryStatusListRequest) Unmarshal(dAtA []byte) error

func (*QueryStatusListRequest) XXX_DiscardUnknown 

func (m *QueryStatusListRequest) XXX_DiscardUnknown()

func (*QueryStatusListRequest) XXX_Marshal 

func (m *QueryStatusListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryStatusListRequest) XXX_Merge 

func (m *QueryStatusListRequest) XXX_Merge(src proto.Message)

func (*QueryStatusListRequest) XXX_Size 

func (m *QueryStatusListRequest) XXX_Size() int

func (*QueryStatusListRequest) XXX_Unmarshal 

func (m *QueryStatusListRequest) XXX_Unmarshal(b []byte) error

type QueryStatusListResponse 

type QueryStatusListResponse struct {
	Result  bool                   `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"`
	Msg     string                 `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	Sources []*QueryStatusResponse `protobuf:"bytes,3,rep,name=sources,proto3" json:"sources,omitempty"`
}

func (*QueryStatusListResponse) Descriptor 

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

func (*QueryStatusListResponse) GetMsg 

func (m *QueryStatusListResponse) GetMsg() string

func (*QueryStatusListResponse) GetResult 

func (m *QueryStatusListResponse) GetResult() bool

func (*QueryStatusListResponse) GetSources 

func (m *QueryStatusListResponse) GetSources() []*QueryStatusResponse

func (*QueryStatusListResponse) Marshal 

func (m *QueryStatusListResponse) Marshal() (dAtA []byte, err error)

func (*QueryStatusListResponse) MarshalTo 

func (m *QueryStatusListResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryStatusListResponse) MarshalToSizedBuffer 

func (m *QueryStatusListResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryStatusListResponse) ProtoMessage 

func (*QueryStatusListResponse) ProtoMessage()

func (*QueryStatusListResponse) Reset 

func (m *QueryStatusListResponse) Reset()

func (*QueryStatusListResponse) Size 

func (m *QueryStatusListResponse) Size() (n int)

func (*QueryStatusListResponse) String 

func (m *QueryStatusListResponse) String() string

func (*QueryStatusListResponse) Unmarshal 

func (m *QueryStatusListResponse) Unmarshal(dAtA []byte) error

func (*QueryStatusListResponse) XXX_DiscardUnknown 

func (m *QueryStatusListResponse) XXX_DiscardUnknown()

func (*QueryStatusListResponse) XXX_Marshal 

func (m *QueryStatusListResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryStatusListResponse) XXX_Merge 

func (m *QueryStatusListResponse) XXX_Merge(src proto.Message)

func (*QueryStatusListResponse) XXX_Size 

func (m *QueryStatusListResponse) XXX_Size() int

func (*QueryStatusListResponse) XXX_Unmarshal 

func (m *QueryStatusListResponse) XXX_Unmarshal(b []byte) error

type QueryStatusRequest 

type QueryStatusRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
}

func (*QueryStatusRequest) Descriptor 

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

func (*QueryStatusRequest) GetName 

func (m *QueryStatusRequest) GetName() string

func (*QueryStatusRequest) Marshal 

func (m *QueryStatusRequest) Marshal() (dAtA []byte, err error)

func (*QueryStatusRequest) MarshalTo 

func (m *QueryStatusRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueryStatusRequest) MarshalToSizedBuffer 

func (m *QueryStatusRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryStatusRequest) ProtoMessage 

func (*QueryStatusRequest) ProtoMessage()

func (*QueryStatusRequest) Reset 

func (m *QueryStatusRequest) Reset()

func (*QueryStatusRequest) Size 

func (m *QueryStatusRequest) Size() (n int)

func (*QueryStatusRequest) String 

func (m *QueryStatusRequest) String() string

func (*QueryStatusRequest) Unmarshal 

func (m *QueryStatusRequest) Unmarshal(dAtA []byte) error

func (*QueryStatusRequest) XXX_DiscardUnknown 

func (m *QueryStatusRequest) XXX_DiscardUnknown()

func (*QueryStatusRequest) XXX_Marshal 

func (m *QueryStatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryStatusRequest) XXX_Merge 

func (m *QueryStatusRequest) XXX_Merge(src proto.Message)

func (*QueryStatusRequest) XXX_Size 

func (m *QueryStatusRequest) XXX_Size() int

func (*QueryStatusRequest) XXX_Unmarshal 

func (m *QueryStatusRequest) XXX_Unmarshal(b []byte) error

type QueryStatusResponse 

type QueryStatusResponse struct {
	Result        bool             `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"`
	Msg           string           `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	SourceStatus  *SourceStatus    `protobuf:"bytes,3,opt,name=sourceStatus,proto3" json:"sourceStatus,omitempty"`
	SubTaskStatus []*SubTaskStatus `protobuf:"bytes,4,rep,name=subTaskStatus,proto3" json:"subTaskStatus,omitempty"`
}

QueryStatusResponse represents status response for query on a dm-worker status: dm-worker's current sub tasks' status

func (*QueryStatusResponse) Descriptor 

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

func (*QueryStatusResponse) GetMsg 

func (m *QueryStatusResponse) GetMsg() string

func (*QueryStatusResponse) GetResult 

func (m *QueryStatusResponse) GetResult() bool

func (*QueryStatusResponse) GetSourceStatus 

func (m *QueryStatusResponse) GetSourceStatus() *SourceStatus

func (*QueryStatusResponse) GetSubTaskStatus 

func (m *QueryStatusResponse) GetSubTaskStatus() []*SubTaskStatus

func (*QueryStatusResponse) Marshal 

func (m *QueryStatusResponse) Marshal() (dAtA []byte, err error)

func (*QueryStatusResponse) MarshalTo 

func (m *QueryStatusResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryStatusResponse) MarshalToSizedBuffer 

func (m *QueryStatusResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryStatusResponse) ProtoMessage 

func (*QueryStatusResponse) ProtoMessage()

func (*QueryStatusResponse) Reset 

func (m *QueryStatusResponse) Reset()

func (*QueryStatusResponse) Size 

func (m *QueryStatusResponse) Size() (n int)

func (*QueryStatusResponse) String 

func (m *QueryStatusResponse) String() string

func (*QueryStatusResponse) Unmarshal 

func (m *QueryStatusResponse) Unmarshal(dAtA []byte) error

func (*QueryStatusResponse) XXX_DiscardUnknown 

func (m *QueryStatusResponse) XXX_DiscardUnknown()

func (*QueryStatusResponse) XXX_Marshal 

func (m *QueryStatusResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryStatusResponse) XXX_Merge 

func (m *QueryStatusResponse) XXX_Merge(src proto.Message)

func (*QueryStatusResponse) XXX_Size 

func (m *QueryStatusResponse) XXX_Size() int

func (*QueryStatusResponse) XXX_Unmarshal 

func (m *QueryStatusResponse) XXX_Unmarshal(b []byte) error

type RegisterWorkerRequest 

type RegisterWorkerRequest struct {
	Name    string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
}

func (*RegisterWorkerRequest) Descriptor 

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

func (*RegisterWorkerRequest) GetAddress 

func (m *RegisterWorkerRequest) GetAddress() string

func (*RegisterWorkerRequest) GetName 

func (m *RegisterWorkerRequest) GetName() string

func (*RegisterWorkerRequest) Marshal 

func (m *RegisterWorkerRequest) Marshal() (dAtA []byte, err error)

func (*RegisterWorkerRequest) MarshalTo 

func (m *RegisterWorkerRequest) MarshalTo(dAtA []byte) (int, error)

func (*RegisterWorkerRequest) MarshalToSizedBuffer 

func (m *RegisterWorkerRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RegisterWorkerRequest) ProtoMessage 

func (*RegisterWorkerRequest) ProtoMessage()

func (*RegisterWorkerRequest) Reset 

func (m *RegisterWorkerRequest) Reset()

func (*RegisterWorkerRequest) Size 

func (m *RegisterWorkerRequest) Size() (n int)

func (*RegisterWorkerRequest) String 

func (m *RegisterWorkerRequest) String() string

func (*RegisterWorkerRequest) Unmarshal 

func (m *RegisterWorkerRequest) Unmarshal(dAtA []byte) error

func (*RegisterWorkerRequest) XXX_DiscardUnknown 

func (m *RegisterWorkerRequest) XXX_DiscardUnknown()

func (*RegisterWorkerRequest) XXX_Marshal 

func (m *RegisterWorkerRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RegisterWorkerRequest) XXX_Merge 

func (m *RegisterWorkerRequest) XXX_Merge(src proto.Message)

func (*RegisterWorkerRequest) XXX_Size 

func (m *RegisterWorkerRequest) XXX_Size() int

func (*RegisterWorkerRequest) XXX_Unmarshal 

func (m *RegisterWorkerRequest) XXX_Unmarshal(b []byte) error

type RegisterWorkerResponse 

type RegisterWorkerResponse struct {
	Result    bool   `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"`
	Msg       string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	SecretKey []byte `protobuf:"bytes,3,opt,name=secretKey,proto3" json:"secretKey,omitempty"`
}

func (*RegisterWorkerResponse) Descriptor 

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

func (*RegisterWorkerResponse) GetMsg 

func (m *RegisterWorkerResponse) GetMsg() string

func (*RegisterWorkerResponse) GetResult 

func (m *RegisterWorkerResponse) GetResult() bool

func (*RegisterWorkerResponse) GetSecretKey 

func (m *RegisterWorkerResponse) GetSecretKey() []byte

func (*RegisterWorkerResponse) Marshal 

func (m *RegisterWorkerResponse) Marshal() (dAtA []byte, err error)

func (*RegisterWorkerResponse) MarshalTo 

func (m *RegisterWorkerResponse) MarshalTo(dAtA []byte) (int, error)

func (*RegisterWorkerResponse) MarshalToSizedBuffer 

func (m *RegisterWorkerResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RegisterWorkerResponse) ProtoMessage 

func (*RegisterWorkerResponse) ProtoMessage()

func (*RegisterWorkerResponse) Reset 

func (m *RegisterWorkerResponse) Reset()

func (*RegisterWorkerResponse) Size 

func (m *RegisterWorkerResponse) Size() (n int)

func (*RegisterWorkerResponse) String 

func (m *RegisterWorkerResponse) String() string

func (*RegisterWorkerResponse) Unmarshal 

func (m *RegisterWorkerResponse) Unmarshal(dAtA []byte) error

func (*RegisterWorkerResponse) XXX_DiscardUnknown 

func (m *RegisterWorkerResponse) XXX_DiscardUnknown()

func (*RegisterWorkerResponse) XXX_Marshal 

func (m *RegisterWorkerResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RegisterWorkerResponse) XXX_Merge 

func (m *RegisterWorkerResponse) XXX_Merge(src proto.Message)

func (*RegisterWorkerResponse) XXX_Size 

func (m *RegisterWorkerResponse) XXX_Size() int

func (*RegisterWorkerResponse) XXX_Unmarshal 

func (m *RegisterWorkerResponse) XXX_Unmarshal(b []byte) error

type RelayError 

type RelayError struct {
	Msg string `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
}

RelayError represents error for relay unit.

func (*RelayError) Descriptor 

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

func (*RelayError) GetMsg 

func (m *RelayError) GetMsg() string

func (*RelayError) Marshal 

func (m *RelayError) Marshal() (dAtA []byte, err error)

func (*RelayError) MarshalTo 

func (m *RelayError) MarshalTo(dAtA []byte) (int, error)

func (*RelayError) MarshalToSizedBuffer 

func (m *RelayError) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RelayError) ProtoMessage 

func (*RelayError) ProtoMessage()

func (*RelayError) Reset 

func (m *RelayError) Reset()

func (*RelayError) Size 

func (m *RelayError) Size() (n int)

func (*RelayError) String 

func (m *RelayError) String() string

func (*RelayError) Unmarshal 

func (m *RelayError) Unmarshal(dAtA []byte) error

func (*RelayError) XXX_DiscardUnknown 

func (m *RelayError) XXX_DiscardUnknown()

func (*RelayError) XXX_Marshal 

func (m *RelayError) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RelayError) XXX_Merge 

func (m *RelayError) XXX_Merge(src proto.Message)

func (*RelayError) XXX_Size 

func (m *RelayError) XXX_Size() int

func (*RelayError) XXX_Unmarshal 

func (m *RelayError) XXX_Unmarshal(b []byte) error

type RelayOp 

type RelayOp int32

RelayOp differs from TaskOp 

const (
	RelayOp_InvalidRelayOp RelayOp = 0
	RelayOp_StopRelay      RelayOp = 1
	RelayOp_PauseRelay     RelayOp = 2
	RelayOp_ResumeRelay    RelayOp = 3
)

func (RelayOp) EnumDescriptor 

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

func (RelayOp) String 

func (x RelayOp) String() string

type RelayOpV2 

type RelayOpV2 int32
const (
	RelayOpV2_InvalidRelayOpV2 RelayOpV2 = 0
	RelayOpV2_StartRelayV2     RelayOpV2 = 1
	RelayOpV2_StopRelayV2      RelayOpV2 = 2
)

func (RelayOpV2) EnumDescriptor 

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

func (RelayOpV2) String 

func (x RelayOpV2) String() string

type RelayStatus 

type RelayStatus struct {
	MasterBinlog       string         `protobuf:"bytes,1,opt,name=masterBinlog,proto3" json:"masterBinlog,omitempty"`
	MasterBinlogGtid   string         `protobuf:"bytes,2,opt,name=masterBinlogGtid,proto3" json:"masterBinlogGtid,omitempty"`
	RelaySubDir        string         `protobuf:"bytes,3,opt,name=relaySubDir,proto3" json:"relaySubDir,omitempty"`
	RelayBinlog        string         `protobuf:"bytes,4,opt,name=relayBinlog,proto3" json:"relayBinlog,omitempty"`
	RelayBinlogGtid    string         `protobuf:"bytes,5,opt,name=relayBinlogGtid,proto3" json:"relayBinlogGtid,omitempty"`
	RelayCatchUpMaster bool           `protobuf:"varint,6,opt,name=relayCatchUpMaster,proto3" json:"relayCatchUpMaster,omitempty"`
	Stage              Stage          `protobuf:"varint,7,opt,name=stage,proto3,enum=pb.Stage" json:"stage,omitempty"`
	Result             *ProcessResult `protobuf:"bytes,8,opt,name=result,proto3" json:"result,omitempty"`
}

RelayStatus represents status for relay unit.

func (*RelayStatus) Descriptor 

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

func (*RelayStatus) GetMasterBinlog 

func (m *RelayStatus) GetMasterBinlog() string

func (*RelayStatus) GetMasterBinlogGtid 

func (m *RelayStatus) GetMasterBinlogGtid() string

func (*RelayStatus) GetRelayBinlog 

func (m *RelayStatus) GetRelayBinlog() string

func (*RelayStatus) GetRelayBinlogGtid 

func (m *RelayStatus) GetRelayBinlogGtid() string

func (*RelayStatus) GetRelayCatchUpMaster 

func (m *RelayStatus) GetRelayCatchUpMaster() bool

func (*RelayStatus) GetRelaySubDir 

func (m *RelayStatus) GetRelaySubDir() string

func (*RelayStatus) GetResult 

func (m *RelayStatus) GetResult() *ProcessResult

func (*RelayStatus) GetStage 

func (m *RelayStatus) GetStage() Stage

func (*RelayStatus) Marshal 

func (m *RelayStatus) Marshal() (dAtA []byte, err error)

func (*RelayStatus) MarshalTo 

func (m *RelayStatus) MarshalTo(dAtA []byte) (int, error)

func (*RelayStatus) MarshalToSizedBuffer 

func (m *RelayStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RelayStatus) ProtoMessage 

func (*RelayStatus) ProtoMessage()

func (*RelayStatus) Reset 

func (m *RelayStatus) Reset()

func (*RelayStatus) Size 

func (m *RelayStatus) Size() (n int)

func (*RelayStatus) String 

func (m *RelayStatus) String() string

func (*RelayStatus) Unmarshal 

func (m *RelayStatus) Unmarshal(dAtA []byte) error

func (*RelayStatus) XXX_DiscardUnknown 

func (m *RelayStatus) XXX_DiscardUnknown()

func (*RelayStatus) XXX_Marshal 

func (m *RelayStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RelayStatus) XXX_Merge 

func (m *RelayStatus) XXX_Merge(src proto.Message)

func (*RelayStatus) XXX_Size 

func (m *RelayStatus) XXX_Size() int

func (*RelayStatus) XXX_Unmarshal 

func (m *RelayStatus) XXX_Unmarshal(b []byte) error

type SchemaOp 

type SchemaOp int32
const (
	SchemaOp_InvalidSchemaOp    SchemaOp = 0
	SchemaOp_GetSchema          SchemaOp = 1
	SchemaOp_SetSchema          SchemaOp = 2
	SchemaOp_RemoveSchema       SchemaOp = 3
	SchemaOp_ListSchema         SchemaOp = 4
	SchemaOp_ListTable          SchemaOp = 5
	SchemaOp_ListMigrateTargets SchemaOp = 6
)

func (SchemaOp) EnumDescriptor 

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

func (SchemaOp) String 

func (x SchemaOp) String() string

type ShardingGroup 

type ShardingGroup struct {
	Target        string   `protobuf:"bytes,1,opt,name=target,proto3" json:"target,omitempty"`
	DDLs          []string `protobuf:"bytes,2,rep,name=DDLs,proto3" json:"DDLs,omitempty"`
	FirstLocation string   `protobuf:"bytes,3,opt,name=firstLocation,proto3" json:"firstLocation,omitempty"`
	Synced        []string `protobuf:"bytes,4,rep,name=synced,proto3" json:"synced,omitempty"`
	Unsynced      []string `protobuf:"bytes,5,rep,name=unsynced,proto3" json:"unsynced,omitempty"`
}

ShardingGroup represents a DDL sharding group, this is used by SyncStatus, and is differ from ShardingGroup in syncer pkg target: target table name DDL: in syncing DDL firstPos: first DDL binlog pos for this group synced: synced source tables unsynced: unsynced source tables

func (*ShardingGroup) Descriptor 

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

func (*ShardingGroup) GetDDLs 

func (m *ShardingGroup) GetDDLs() []string

func (*ShardingGroup) GetFirstLocation 

func (m *ShardingGroup) GetFirstLocation() string

func (*ShardingGroup) GetSynced 

func (m *ShardingGroup) GetSynced() []string

func (*ShardingGroup) GetTarget 

func (m *ShardingGroup) GetTarget() string

func (*ShardingGroup) GetUnsynced 

func (m *ShardingGroup) GetUnsynced() []string

func (*ShardingGroup) Marshal 

func (m *ShardingGroup) Marshal() (dAtA []byte, err error)

func (*ShardingGroup) MarshalTo 

func (m *ShardingGroup) MarshalTo(dAtA []byte) (int, error)

func (*ShardingGroup) MarshalToSizedBuffer 

func (m *ShardingGroup) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ShardingGroup) ProtoMessage 

func (*ShardingGroup) ProtoMessage()

func (*ShardingGroup) Reset 

func (m *ShardingGroup) Reset()

func (*ShardingGroup) Size 

func (m *ShardingGroup) Size() (n int)

func (*ShardingGroup) String 

func (m *ShardingGroup) String() string

func (*ShardingGroup) Unmarshal 

func (m *ShardingGroup) Unmarshal(dAtA []byte) error

func (*ShardingGroup) XXX_DiscardUnknown 

func (m *ShardingGroup) XXX_DiscardUnknown()

func (*ShardingGroup) XXX_Marshal 

func (m *ShardingGroup) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ShardingGroup) XXX_Merge 

func (m *ShardingGroup) XXX_Merge(src proto.Message)

func (*ShardingGroup) XXX_Size 

func (m *ShardingGroup) XXX_Size() int

func (*ShardingGroup) XXX_Unmarshal 

func (m *ShardingGroup) XXX_Unmarshal(b []byte) error

type ShowDDLLocksRequest 

type ShowDDLLocksRequest struct {
	Task    string   `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	Sources []string `protobuf:"bytes,2,rep,name=sources,proto3" json:"sources,omitempty"`
}

ShowDDLLocksRequest used to query DDL locks which are un-resolved task: task's name, empty for all tasks sources: source need to query, empty for all sources 

any DDL lock in which the source is synced or unsynced will return

if specify task and sources both, and sources not doing the task , it will return empty DDL locks

func (*ShowDDLLocksRequest) Descriptor 

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

func (*ShowDDLLocksRequest) GetSources 

func (m *ShowDDLLocksRequest) GetSources() []string

func (*ShowDDLLocksRequest) GetTask 

func (m *ShowDDLLocksRequest) GetTask() string

func (*ShowDDLLocksRequest) Marshal 

func (m *ShowDDLLocksRequest) Marshal() (dAtA []byte, err error)

func (*ShowDDLLocksRequest) MarshalTo 

func (m *ShowDDLLocksRequest) MarshalTo(dAtA []byte) (int, error)

func (*ShowDDLLocksRequest) MarshalToSizedBuffer 

func (m *ShowDDLLocksRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ShowDDLLocksRequest) ProtoMessage 

func (*ShowDDLLocksRequest) ProtoMessage()

func (*ShowDDLLocksRequest) Reset 

func (m *ShowDDLLocksRequest) Reset()

func (*ShowDDLLocksRequest) Size 

func (m *ShowDDLLocksRequest) Size() (n int)

func (*ShowDDLLocksRequest) String 

func (m *ShowDDLLocksRequest) String() string

func (*ShowDDLLocksRequest) Unmarshal 

func (m *ShowDDLLocksRequest) Unmarshal(dAtA []byte) error

func (*ShowDDLLocksRequest) XXX_DiscardUnknown 

func (m *ShowDDLLocksRequest) XXX_DiscardUnknown()

func (*ShowDDLLocksRequest) XXX_Marshal 

func (m *ShowDDLLocksRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ShowDDLLocksRequest) XXX_Merge 

func (m *ShowDDLLocksRequest) XXX_Merge(src proto.Message)

func (*ShowDDLLocksRequest) XXX_Size 

func (m *ShowDDLLocksRequest) XXX_Size() int

func (*ShowDDLLocksRequest) XXX_Unmarshal 

func (m *ShowDDLLocksRequest) XXX_Unmarshal(b []byte) error

type ShowDDLLocksResponse 

type ShowDDLLocksResponse struct {
	Result bool       `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"`
	Msg    string     `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	Locks  []*DDLLock `protobuf:"bytes,3,rep,name=locks,proto3" json:"locks,omitempty"`
}

func (*ShowDDLLocksResponse) Descriptor 

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

func (*ShowDDLLocksResponse) GetLocks 

func (m *ShowDDLLocksResponse) GetLocks() []*DDLLock

func (*ShowDDLLocksResponse) GetMsg 

func (m *ShowDDLLocksResponse) GetMsg() string

func (*ShowDDLLocksResponse) GetResult 

func (m *ShowDDLLocksResponse) GetResult() bool

func (*ShowDDLLocksResponse) Marshal 

func (m *ShowDDLLocksResponse) Marshal() (dAtA []byte, err error)

func (*ShowDDLLocksResponse) MarshalTo 

func (m *ShowDDLLocksResponse) MarshalTo(dAtA []byte) (int, error)

func (*ShowDDLLocksResponse) MarshalToSizedBuffer 

func (m *ShowDDLLocksResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ShowDDLLocksResponse) ProtoMessage 

func (*ShowDDLLocksResponse) ProtoMessage()

func (*ShowDDLLocksResponse) Reset 

func (m *ShowDDLLocksResponse) Reset()

func (*ShowDDLLocksResponse) Size 

func (m *ShowDDLLocksResponse) Size() (n int)

func (*ShowDDLLocksResponse) String 

func (m *ShowDDLLocksResponse) String() string

func (*ShowDDLLocksResponse) Unmarshal 

func (m *ShowDDLLocksResponse) Unmarshal(dAtA []byte) error

func (*ShowDDLLocksResponse) XXX_DiscardUnknown 

func (m *ShowDDLLocksResponse) XXX_DiscardUnknown()

func (*ShowDDLLocksResponse) XXX_Marshal 

func (m *ShowDDLLocksResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ShowDDLLocksResponse) XXX_Merge 

func (m *ShowDDLLocksResponse) XXX_Merge(src proto.Message)

func (*ShowDDLLocksResponse) XXX_Size 

func (m *ShowDDLLocksResponse) XXX_Size() int

func (*ShowDDLLocksResponse) XXX_Unmarshal 

func (m *ShowDDLLocksResponse) XXX_Unmarshal(b []byte) error

type SourceError 

type SourceError struct {
	Source      string      `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`
	Worker      string      `protobuf:"bytes,2,opt,name=worker,proto3" json:"worker,omitempty"`
	SourceError string      `protobuf:"bytes,3,opt,name=SourceError,proto3" json:"SourceError,omitempty"`
	RelayError  *RelayError `protobuf:"bytes,4,opt,name=RelayError,proto3" json:"RelayError,omitempty"`
}

SourceError represents error for start/stop source on dm-worker

func (*SourceError) Descriptor 

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

func (*SourceError) GetRelayError 

func (m *SourceError) GetRelayError() *RelayError

func (*SourceError) GetSource 

func (m *SourceError) GetSource() string

func (*SourceError) GetSourceError 

func (m *SourceError) GetSourceError() string

func (*SourceError) GetWorker 

func (m *SourceError) GetWorker() string

func (*SourceError) Marshal 

func (m *SourceError) Marshal() (dAtA []byte, err error)

func (*SourceError) MarshalTo 

func (m *SourceError) MarshalTo(dAtA []byte) (int, error)

func (*SourceError) MarshalToSizedBuffer 

func (m *SourceError) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SourceError) ProtoMessage 

func (*SourceError) ProtoMessage()

func (*SourceError) Reset 

func (m *SourceError) Reset()

func (*SourceError) Size 

func (m *SourceError) Size() (n int)

func (*SourceError) String 

func (m *SourceError) String() string

func (*SourceError) Unmarshal 

func (m *SourceError) Unmarshal(dAtA []byte) error

func (*SourceError) XXX_DiscardUnknown 

func (m *SourceError) XXX_DiscardUnknown()

func (*SourceError) XXX_Marshal 

func (m *SourceError) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SourceError) XXX_Merge 

func (m *SourceError) XXX_Merge(src proto.Message)

func (*SourceError) XXX_Size 

func (m *SourceError) XXX_Size() int

func (*SourceError) XXX_Unmarshal 

func (m *SourceError) XXX_Unmarshal(b []byte) error

type SourceOp 

type SourceOp int32
const (
	SourceOp_InvalidSourceOp SourceOp = 0
	SourceOp_StartSource     SourceOp = 1
	SourceOp_UpdateSource    SourceOp = 2
	SourceOp_StopSource      SourceOp = 3
	SourceOp_ShowSource      SourceOp = 4
)

func (SourceOp) EnumDescriptor 

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

func (SourceOp) String 

func (x SourceOp) String() string

type SourceStatus 

type SourceStatus struct {
	Source      string         `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`
	Worker      string         `protobuf:"bytes,2,opt,name=worker,proto3" json:"worker,omitempty"`
	Result      *ProcessResult `protobuf:"bytes,3,opt,name=result,proto3" json:"result,omitempty"`
	RelayStatus *RelayStatus   `protobuf:"bytes,4,opt,name=relayStatus,proto3" json:"relayStatus,omitempty"`
}

SourceStatus represents status for source runing on dm-worker

func (*SourceStatus) Descriptor 

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

func (*SourceStatus) GetRelayStatus 

func (m *SourceStatus) GetRelayStatus() *RelayStatus

func (*SourceStatus) GetResult 

func (m *SourceStatus) GetResult() *ProcessResult

func (*SourceStatus) GetSource 

func (m *SourceStatus) GetSource() string

func (*SourceStatus) GetWorker 

func (m *SourceStatus) GetWorker() string

func (*SourceStatus) Marshal 

func (m *SourceStatus) Marshal() (dAtA []byte, err error)

func (*SourceStatus) MarshalTo 

func (m *SourceStatus) MarshalTo(dAtA []byte) (int, error)

func (*SourceStatus) MarshalToSizedBuffer 

func (m *SourceStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SourceStatus) ProtoMessage 

func (*SourceStatus) ProtoMessage()

func (*SourceStatus) Reset 

func (m *SourceStatus) Reset()

func (*SourceStatus) Size 

func (m *SourceStatus) Size() (n int)

func (*SourceStatus) String 

func (m *SourceStatus) String() string

func (*SourceStatus) Unmarshal 

func (m *SourceStatus) Unmarshal(dAtA []byte) error

func (*SourceStatus) XXX_DiscardUnknown 

func (m *SourceStatus) XXX_DiscardUnknown()

func (*SourceStatus) XXX_Marshal 

func (m *SourceStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SourceStatus) XXX_Merge 

func (m *SourceStatus) XXX_Merge(src proto.Message)

func (*SourceStatus) XXX_Size 

func (m *SourceStatus) XXX_Size() int

func (*SourceStatus) XXX_Unmarshal 

func (m *SourceStatus) XXX_Unmarshal(b []byte) error

type Stage 

type Stage int32

Stage represents current stage for a (sub) task a (sub) task should be always in one stage of the following stages (sub) task can transfer from on stage to some special other stages New: initial stage when a sub task is created 

can not be transferred from other stages
transfers to Running when initialize with no error

Running: indicates the sub task is processing 

is transferred from New when created successfully
is transferred from Paused when resuming is requested
transfers to Paused when error occurred or requested from external
transfers to Stopped when requested from external
transfers to Finished when sub task processing completed (no Syncer used)

Paused: indicates the processing is paused, and can be resume from external request 

is transferred from Running when error occurred or requested from external
transfers to Running when resuming is requested from external
transfers to Stopped when requested from external

Stopped: indicates the processing is stopped, and can not be resume (or re-run) again 

is transferred from Running / Paused when requested from external
can not transfer to any stages

Finished: indicates the processing is finished, and no need to re-run 

is transferred from Running when processing completed
should not transfer to any stages

const (
	Stage_InvalidStage Stage = 0
	Stage_New          Stage = 1
	Stage_Running      Stage = 2
	Stage_Paused       Stage = 3
	Stage_Stopped      Stage = 4
	Stage_Finished     Stage = 5
	Stage_Pausing      Stage = 6
	Stage_Resuming     Stage = 7
	Stage_Stopping     Stage = 8
)

func (Stage) EnumDescriptor 

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

func (Stage) String 

func (x Stage) String() string

type StartTaskRequest 

type StartTaskRequest struct {
	Task       string   `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	Sources    []string `protobuf:"bytes,2,rep,name=sources,proto3" json:"sources,omitempty"`
	RemoveMeta bool     `protobuf:"varint,3,opt,name=removeMeta,proto3" json:"removeMeta,omitempty"`
	StartTime  string   `protobuf:"bytes,4,opt,name=startTime,proto3" json:"startTime,omitempty"`
}

func (*StartTaskRequest) Descriptor 

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

func (*StartTaskRequest) GetRemoveMeta 

func (m *StartTaskRequest) GetRemoveMeta() bool

func (*StartTaskRequest) GetSources 

func (m *StartTaskRequest) GetSources() []string

func (*StartTaskRequest) GetStartTime 

func (m *StartTaskRequest) GetStartTime() string

func (*StartTaskRequest) GetTask 

func (m *StartTaskRequest) GetTask() string

func (*StartTaskRequest) Marshal 

func (m *StartTaskRequest) Marshal() (dAtA []byte, err error)

func (*StartTaskRequest) MarshalLogObject 

func (m *StartTaskRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

MarshalLogObject implements zapcore.ObjectMarshaler.

func (*StartTaskRequest) MarshalTo 

func (m *StartTaskRequest) MarshalTo(dAtA []byte) (int, error)

func (*StartTaskRequest) MarshalToSizedBuffer 

func (m *StartTaskRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StartTaskRequest) ProtoMessage 

func (*StartTaskRequest) ProtoMessage()

func (*StartTaskRequest) Reset 

func (m *StartTaskRequest) Reset()

func (*StartTaskRequest) Size 

func (m *StartTaskRequest) Size() (n int)

func (*StartTaskRequest) String 

func (m *StartTaskRequest) String() string

func (*StartTaskRequest) Unmarshal 

func (m *StartTaskRequest) Unmarshal(dAtA []byte) error

func (*StartTaskRequest) XXX_DiscardUnknown 

func (m *StartTaskRequest) XXX_DiscardUnknown()

func (*StartTaskRequest) XXX_Marshal 

func (m *StartTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StartTaskRequest) XXX_Merge 

func (m *StartTaskRequest) XXX_Merge(src proto.Message)

func (*StartTaskRequest) XXX_Size 

func (m *StartTaskRequest) XXX_Size() int

func (*StartTaskRequest) XXX_Unmarshal 

func (m *StartTaskRequest) XXX_Unmarshal(b []byte) error

type StartTaskResponse 

type StartTaskResponse struct {
	Result      bool                    `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"`
	Msg         string                  `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	Sources     []*CommonWorkerResponse `protobuf:"bytes,3,rep,name=sources,proto3" json:"sources,omitempty"`
	CheckResult string                  `protobuf:"bytes,4,opt,name=checkResult,proto3" json:"checkResult,omitempty"`
}

func (*StartTaskResponse) Descriptor 

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

func (*StartTaskResponse) GetCheckResult 

func (m *StartTaskResponse) GetCheckResult() string

func (*StartTaskResponse) GetMsg 

func (m *StartTaskResponse) GetMsg() string

func (*StartTaskResponse) GetResult 

func (m *StartTaskResponse) GetResult() bool

func (*StartTaskResponse) GetSources 

func (m *StartTaskResponse) GetSources() []*CommonWorkerResponse

func (*StartTaskResponse) Marshal 

func (m *StartTaskResponse) Marshal() (dAtA []byte, err error)

func (*StartTaskResponse) MarshalTo 

func (m *StartTaskResponse) MarshalTo(dAtA []byte) (int, error)

func (*StartTaskResponse) MarshalToSizedBuffer 

func (m *StartTaskResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StartTaskResponse) ProtoMessage 

func (*StartTaskResponse) ProtoMessage()

func (*StartTaskResponse) Reset 

func (m *StartTaskResponse) Reset()

func (*StartTaskResponse) Size 

func (m *StartTaskResponse) Size() (n int)

func (*StartTaskResponse) String 

func (m *StartTaskResponse) String() string

func (*StartTaskResponse) Unmarshal 

func (m *StartTaskResponse) Unmarshal(dAtA []byte) error

func (*StartTaskResponse) XXX_DiscardUnknown 

func (m *StartTaskResponse) XXX_DiscardUnknown()

func (*StartTaskResponse) XXX_Marshal 

func (m *StartTaskResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StartTaskResponse) XXX_Merge 

func (m *StartTaskResponse) XXX_Merge(src proto.Message)

func (*StartTaskResponse) XXX_Size 

func (m *StartTaskResponse) XXX_Size() int

func (*StartTaskResponse) XXX_Unmarshal 

func (m *StartTaskResponse) XXX_Unmarshal(b []byte) error

type StartValidationRequest 

type StartValidationRequest struct {
	// proto3 support optional, but need to upgrade protoc-gen-gogofaster, not do it in this pr
	// see https://github.com/protocolbuffers/protobuf/issues/1606
	//
	// Types that are valid to be assigned to Mode:
	//
	//	*StartValidationRequest_ModeValue
	Mode isStartValidationRequest_Mode `protobuf_oneof:"mode"`
	// Types that are valid to be assigned to StartTime:
	//
	//	*StartValidationRequest_StartTimeValue
	StartTime isStartValidationRequest_StartTime `protobuf_oneof:"startTime"`
	Sources   []string                           `protobuf:"bytes,3,rep,name=sources,proto3" json:"sources,omitempty"`
	TaskName  string                             `protobuf:"bytes,4,opt,name=taskName,proto3" json:"taskName,omitempty"`
}

func (*StartValidationRequest) Descriptor 

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

func (*StartValidationRequest) GetMode 

func (m *StartValidationRequest) GetMode() isStartValidationRequest_Mode

func (*StartValidationRequest) GetModeValue 

func (m *StartValidationRequest) GetModeValue() string

func (*StartValidationRequest) GetSources 

func (m *StartValidationRequest) GetSources() []string

func (*StartValidationRequest) GetStartTime 

func (m *StartValidationRequest) GetStartTime() isStartValidationRequest_StartTime

func (*StartValidationRequest) GetStartTimeValue 

func (m *StartValidationRequest) GetStartTimeValue() string

func (*StartValidationRequest) GetTaskName 

func (m *StartValidationRequest) GetTaskName() string

func (*StartValidationRequest) Marshal 

func (m *StartValidationRequest) Marshal() (dAtA []byte, err error)

func (*StartValidationRequest) MarshalTo 

func (m *StartValidationRequest) MarshalTo(dAtA []byte) (int, error)

func (*StartValidationRequest) MarshalToSizedBuffer 

func (m *StartValidationRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StartValidationRequest) ProtoMessage 

func (*StartValidationRequest) ProtoMessage()

func (*StartValidationRequest) Reset 

func (m *StartValidationRequest) Reset()

func (*StartValidationRequest) Size 

func (m *StartValidationRequest) Size() (n int)

func (*StartValidationRequest) String 

func (m *StartValidationRequest) String() string

func (*StartValidationRequest) Unmarshal 

func (m *StartValidationRequest) Unmarshal(dAtA []byte) error

func (*StartValidationRequest) XXX_DiscardUnknown 

func (m *StartValidationRequest) XXX_DiscardUnknown()

func (*StartValidationRequest) XXX_Marshal 

func (m *StartValidationRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StartValidationRequest) XXX_Merge 

func (m *StartValidationRequest) XXX_Merge(src proto.Message)

func (*StartValidationRequest) XXX_OneofWrappers 

func (*StartValidationRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*StartValidationRequest) XXX_Size 

func (m *StartValidationRequest) XXX_Size() int

func (*StartValidationRequest) XXX_Unmarshal 

func (m *StartValidationRequest) XXX_Unmarshal(b []byte) error

type StartValidationRequest_ModeValue 

type StartValidationRequest_ModeValue struct {
	ModeValue string `protobuf:"bytes,1,opt,name=mode_value,json=modeValue,proto3,oneof" json:"mode_value,omitempty"`
}

func (*StartValidationRequest_ModeValue) MarshalTo 

func (m *StartValidationRequest_ModeValue) MarshalTo(dAtA []byte) (int, error)

func (*StartValidationRequest_ModeValue) MarshalToSizedBuffer 

func (m *StartValidationRequest_ModeValue) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StartValidationRequest_ModeValue) Size 

func (m *StartValidationRequest_ModeValue) Size() (n int)

type StartValidationRequest_StartTimeValue 

type StartValidationRequest_StartTimeValue struct {
	StartTimeValue string `protobuf:"bytes,2,opt,name=start_time_value,json=startTimeValue,proto3,oneof" json:"start_time_value,omitempty"`
}

func (*StartValidationRequest_StartTimeValue) MarshalTo 

func (m *StartValidationRequest_StartTimeValue) MarshalTo(dAtA []byte) (int, error)

func (*StartValidationRequest_StartTimeValue) MarshalToSizedBuffer 

func (m *StartValidationRequest_StartTimeValue) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StartValidationRequest_StartTimeValue) Size 

func (m *StartValidationRequest_StartTimeValue) Size() (n int)

type StartValidationResponse 

type StartValidationResponse struct {
	Result  bool                    `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"`
	Msg     string                  `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	Sources []*CommonWorkerResponse `protobuf:"bytes,3,rep,name=sources,proto3" json:"sources,omitempty"`
}

func (*StartValidationResponse) Descriptor 

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

func (*StartValidationResponse) GetMsg 

func (m *StartValidationResponse) GetMsg() string

func (*StartValidationResponse) GetResult 

func (m *StartValidationResponse) GetResult() bool

func (*StartValidationResponse) GetSources 

func (m *StartValidationResponse) GetSources() []*CommonWorkerResponse

func (*StartValidationResponse) Marshal 

func (m *StartValidationResponse) Marshal() (dAtA []byte, err error)

func (*StartValidationResponse) MarshalTo 

func (m *StartValidationResponse) MarshalTo(dAtA []byte) (int, error)

func (*StartValidationResponse) MarshalToSizedBuffer 

func (m *StartValidationResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StartValidationResponse) ProtoMessage 

func (*StartValidationResponse) ProtoMessage()

func (*StartValidationResponse) Reset 

func (m *StartValidationResponse) Reset()

func (*StartValidationResponse) Size 

func (m *StartValidationResponse) Size() (n int)

func (*StartValidationResponse) String 

func (m *StartValidationResponse) String() string

func (*StartValidationResponse) Unmarshal 

func (m *StartValidationResponse) Unmarshal(dAtA []byte) error

func (*StartValidationResponse) XXX_DiscardUnknown 

func (m *StartValidationResponse) XXX_DiscardUnknown()

func (*StartValidationResponse) XXX_Marshal 

func (m *StartValidationResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StartValidationResponse) XXX_Merge 

func (m *StartValidationResponse) XXX_Merge(src proto.Message)

func (*StartValidationResponse) XXX_Size 

func (m *StartValidationResponse) XXX_Size() int

func (*StartValidationResponse) XXX_Unmarshal 

func (m *StartValidationResponse) XXX_Unmarshal(b []byte) error

type StopValidationRequest 

type StopValidationRequest struct {
	Sources  []string `protobuf:"bytes,1,rep,name=sources,proto3" json:"sources,omitempty"`
	TaskName string   `protobuf:"bytes,2,opt,name=taskName,proto3" json:"taskName,omitempty"`
}

func (*StopValidationRequest) Descriptor 

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

func (*StopValidationRequest) GetSources 

func (m *StopValidationRequest) GetSources() []string

func (*StopValidationRequest) GetTaskName 

func (m *StopValidationRequest) GetTaskName() string

func (*StopValidationRequest) Marshal 

func (m *StopValidationRequest) Marshal() (dAtA []byte, err error)

func (*StopValidationRequest) MarshalTo 

func (m *StopValidationRequest) MarshalTo(dAtA []byte) (int, error)

func (*StopValidationRequest) MarshalToSizedBuffer 

func (m *StopValidationRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StopValidationRequest) ProtoMessage 

func (*StopValidationRequest) ProtoMessage()

func (*StopValidationRequest) Reset 

func (m *StopValidationRequest) Reset()

func (*StopValidationRequest) Size 

func (m *StopValidationRequest) Size() (n int)

func (*StopValidationRequest) String 

func (m *StopValidationRequest) String() string

func (*StopValidationRequest) Unmarshal 

func (m *StopValidationRequest) Unmarshal(dAtA []byte) error

func (*StopValidationRequest) XXX_DiscardUnknown 

func (m *StopValidationRequest) XXX_DiscardUnknown()

func (*StopValidationRequest) XXX_Marshal 

func (m *StopValidationRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StopValidationRequest) XXX_Merge 

func (m *StopValidationRequest) XXX_Merge(src proto.Message)

func (*StopValidationRequest) XXX_Size 

func (m *StopValidationRequest) XXX_Size() int

func (*StopValidationRequest) XXX_Unmarshal 

func (m *StopValidationRequest) XXX_Unmarshal(b []byte) error

type StopValidationResponse 

type StopValidationResponse struct {
	Result  bool                    `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"`
	Msg     string                  `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	Sources []*CommonWorkerResponse `protobuf:"bytes,3,rep,name=sources,proto3" json:"sources,omitempty"`
}

func (*StopValidationResponse) Descriptor 

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

func (*StopValidationResponse) GetMsg 

func (m *StopValidationResponse) GetMsg() string

func (*StopValidationResponse) GetResult 

func (m *StopValidationResponse) GetResult() bool

func (*StopValidationResponse) GetSources 

func (m *StopValidationResponse) GetSources() []*CommonWorkerResponse

func (*StopValidationResponse) Marshal 

func (m *StopValidationResponse) Marshal() (dAtA []byte, err error)

func (*StopValidationResponse) MarshalTo 

func (m *StopValidationResponse) MarshalTo(dAtA []byte) (int, error)

func (*StopValidationResponse) MarshalToSizedBuffer 

func (m *StopValidationResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StopValidationResponse) ProtoMessage 

func (*StopValidationResponse) ProtoMessage()

func (*StopValidationResponse) Reset 

func (m *StopValidationResponse) Reset()

func (*StopValidationResponse) Size 

func (m *StopValidationResponse) Size() (n int)

func (*StopValidationResponse) String 

func (m *StopValidationResponse) String() string

func (*StopValidationResponse) Unmarshal 

func (m *StopValidationResponse) Unmarshal(dAtA []byte) error

func (*StopValidationResponse) XXX_DiscardUnknown 

func (m *StopValidationResponse) XXX_DiscardUnknown()

func (*StopValidationResponse) XXX_Marshal 

func (m *StopValidationResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StopValidationResponse) XXX_Merge 

func (m *StopValidationResponse) XXX_Merge(src proto.Message)

func (*StopValidationResponse) XXX_Size 

func (m *StopValidationResponse) XXX_Size() int

func (*StopValidationResponse) XXX_Unmarshal 

func (m *StopValidationResponse) XXX_Unmarshal(b []byte) error

type SubTaskError 

type SubTaskError struct {
	Name  string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Stage Stage    `protobuf:"varint,2,opt,name=stage,proto3,enum=pb.Stage" json:"stage,omitempty"`
	Unit  UnitType `protobuf:"varint,3,opt,name=unit,proto3,enum=pb.UnitType" json:"unit,omitempty"`
	// Types that are valid to be assigned to Error:
	//
	//	*SubTaskError_Msg
	//	*SubTaskError_Check
	//	*SubTaskError_Dump
	//	*SubTaskError_Load
	//	*SubTaskError_Sync
	Error isSubTaskError_Error `protobuf_oneof:"error"`
}

SubTaskError represents error for a sub task during running name: sub task'name, when starting a sub task the name should be unique stage: sub task's current stage unit: sub task's current dm unit's UnitType error: current unit's error information 

for Sync, includes failed sql, failed sql pos in binlog, etc.

func (*SubTaskError) Descriptor 

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

func (*SubTaskError) GetCheck 

func (m *SubTaskError) GetCheck() *CheckError

func (*SubTaskError) GetDump 

func (m *SubTaskError) GetDump() *DumpError

func (*SubTaskError) GetError 

func (m *SubTaskError) GetError() isSubTaskError_Error

func (*SubTaskError) GetLoad 

func (m *SubTaskError) GetLoad() *LoadError

func (*SubTaskError) GetMsg 

func (m *SubTaskError) GetMsg() string

func (*SubTaskError) GetName 

func (m *SubTaskError) GetName() string

func (*SubTaskError) GetStage 

func (m *SubTaskError) GetStage() Stage

func (*SubTaskError) GetSync 

func (m *SubTaskError) GetSync() *SyncError

func (*SubTaskError) GetUnit 

func (m *SubTaskError) GetUnit() UnitType

func (*SubTaskError) Marshal 

func (m *SubTaskError) Marshal() (dAtA []byte, err error)

func (*SubTaskError) MarshalTo 

func (m *SubTaskError) MarshalTo(dAtA []byte) (int, error)

func (*SubTaskError) MarshalToSizedBuffer 

func (m *SubTaskError) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SubTaskError) ProtoMessage 

func (*SubTaskError) ProtoMessage()

func (*SubTaskError) Reset 

func (m *SubTaskError) Reset()

func (*SubTaskError) Size 

func (m *SubTaskError) Size() (n int)

func (*SubTaskError) String 

func (m *SubTaskError) String() string

func (*SubTaskError) Unmarshal 

func (m *SubTaskError) Unmarshal(dAtA []byte) error

func (*SubTaskError) XXX_DiscardUnknown 

func (m *SubTaskError) XXX_DiscardUnknown()

func (*SubTaskError) XXX_Marshal 

func (m *SubTaskError) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SubTaskError) XXX_Merge 

func (m *SubTaskError) XXX_Merge(src proto.Message)

func (*SubTaskError) XXX_OneofWrappers 

func (*SubTaskError) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*SubTaskError) XXX_Size 

func (m *SubTaskError) XXX_Size() int

func (*SubTaskError) XXX_Unmarshal 

func (m *SubTaskError) XXX_Unmarshal(b []byte) error

type SubTaskErrorList 

type SubTaskErrorList struct {
	Error []*SubTaskError `protobuf:"bytes,1,rep,name=error,proto3" json:"error,omitempty"`
}

SubTaskErrorList used for internal jsonpb marshal

func (*SubTaskErrorList) Descriptor 

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

func (*SubTaskErrorList) GetError 

func (m *SubTaskErrorList) GetError() []*SubTaskError

func (*SubTaskErrorList) Marshal 

func (m *SubTaskErrorList) Marshal() (dAtA []byte, err error)

func (*SubTaskErrorList) MarshalTo 

func (m *SubTaskErrorList) MarshalTo(dAtA []byte) (int, error)

func (*SubTaskErrorList) MarshalToSizedBuffer 

func (m *SubTaskErrorList) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SubTaskErrorList) ProtoMessage 

func (*SubTaskErrorList) ProtoMessage()

func (*SubTaskErrorList) Reset 

func (m *SubTaskErrorList) Reset()

func (*SubTaskErrorList) Size 

func (m *SubTaskErrorList) Size() (n int)

func (*SubTaskErrorList) String 

func (m *SubTaskErrorList) String() string

func (*SubTaskErrorList) Unmarshal 

func (m *SubTaskErrorList) Unmarshal(dAtA []byte) error

func (*SubTaskErrorList) XXX_DiscardUnknown 

func (m *SubTaskErrorList) XXX_DiscardUnknown()

func (*SubTaskErrorList) XXX_Marshal 

func (m *SubTaskErrorList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SubTaskErrorList) XXX_Merge 

func (m *SubTaskErrorList) XXX_Merge(src proto.Message)

func (*SubTaskErrorList) XXX_Size 

func (m *SubTaskErrorList) XXX_Size() int

func (*SubTaskErrorList) XXX_Unmarshal 

func (m *SubTaskErrorList) XXX_Unmarshal(b []byte) error

type SubTaskError_Check 

type SubTaskError_Check struct {
	Check *CheckError `protobuf:"bytes,5,opt,name=check,proto3,oneof" json:"check,omitempty"`
}

func (*SubTaskError_Check) MarshalTo 

func (m *SubTaskError_Check) MarshalTo(dAtA []byte) (int, error)

func (*SubTaskError_Check) MarshalToSizedBuffer 

func (m *SubTaskError_Check) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SubTaskError_Check) Size 

func (m *SubTaskError_Check) Size() (n int)

type SubTaskError_Dump 

type SubTaskError_Dump struct {
	Dump *DumpError `protobuf:"bytes,6,opt,name=dump,proto3,oneof" json:"dump,omitempty"`
}

func (*SubTaskError_Dump) MarshalTo 

func (m *SubTaskError_Dump) MarshalTo(dAtA []byte) (int, error)

func (*SubTaskError_Dump) MarshalToSizedBuffer 

func (m *SubTaskError_Dump) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SubTaskError_Dump) Size 

func (m *SubTaskError_Dump) Size() (n int)

type SubTaskError_Load 

type SubTaskError_Load struct {
	Load *LoadError `protobuf:"bytes,7,opt,name=load,proto3,oneof" json:"load,omitempty"`
}

func (*SubTaskError_Load) MarshalTo 

func (m *SubTaskError_Load) MarshalTo(dAtA []byte) (int, error)

func (*SubTaskError_Load) MarshalToSizedBuffer 

func (m *SubTaskError_Load) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SubTaskError_Load) Size 

func (m *SubTaskError_Load) Size() (n int)

type SubTaskError_Msg 

type SubTaskError_Msg struct {
	Msg string `protobuf:"bytes,4,opt,name=msg,proto3,oneof" json:"msg,omitempty"`
}

func (*SubTaskError_Msg) MarshalTo 

func (m *SubTaskError_Msg) MarshalTo(dAtA []byte) (int, error)

func (*SubTaskError_Msg) MarshalToSizedBuffer 

func (m *SubTaskError_Msg) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SubTaskError_Msg) Size 

func (m *SubTaskError_Msg) Size() (n int)

type SubTaskError_Sync 

type SubTaskError_Sync struct {
	Sync *SyncError `protobuf:"bytes,8,opt,name=sync,proto3,oneof" json:"sync,omitempty"`
}

func (*SubTaskError_Sync) MarshalTo 

func (m *SubTaskError_Sync) MarshalTo(dAtA []byte) (int, error)

func (*SubTaskError_Sync) MarshalToSizedBuffer 

func (m *SubTaskError_Sync) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SubTaskError_Sync) Size 

func (m *SubTaskError_Sync) Size() (n int)

type SubTaskStatus 

type SubTaskStatus struct {
	Name                string         `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Stage               Stage          `protobuf:"varint,2,opt,name=stage,proto3,enum=pb.Stage" json:"stage,omitempty"`
	Unit                UnitType       `protobuf:"varint,3,opt,name=unit,proto3,enum=pb.UnitType" json:"unit,omitempty"`
	Result              *ProcessResult `protobuf:"bytes,4,opt,name=result,proto3" json:"result,omitempty"`
	UnresolvedDDLLockID string         `protobuf:"bytes,5,opt,name=unresolvedDDLLockID,proto3" json:"unresolvedDDLLockID,omitempty"`
	// Types that are valid to be assigned to Status:
	//
	//	*SubTaskStatus_Msg
	//	*SubTaskStatus_Check
	//	*SubTaskStatus_Dump
	//	*SubTaskStatus_Load
	//	*SubTaskStatus_Sync
	Status     isSubTaskStatus_Status `protobuf_oneof:"status"`
	Validation *ValidationStatus      `protobuf:"bytes,11,opt,name=validation,proto3" json:"validation,omitempty"`
}

SubTaskStatus represents status for a sub task name: sub task'name, when starting a sub task the name should be unique stage: sub task's current stage unit: sub task's current dm unit's UnitType result: current unit's process result, when the stage is Running, no result unresolvedDDLLockID: un-resolved sharding DDL lock ID (ref DDLLockInfo) 

if needed, we can put this to SyncStatus

status: current unit's statistics 

for Load, includes total bytes, progress, etc.
for Sync, includes TPS, binlog meta, etc.

func (*SubTaskStatus) Descriptor 

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

func (*SubTaskStatus) GetCheck 

func (m *SubTaskStatus) GetCheck() *CheckStatus

func (*SubTaskStatus) GetDump 

func (m *SubTaskStatus) GetDump() *DumpStatus

func (*SubTaskStatus) GetLoad 

func (m *SubTaskStatus) GetLoad() *LoadStatus

func (*SubTaskStatus) GetMsg 

func (m *SubTaskStatus) GetMsg() string

func (*SubTaskStatus) GetName 

func (m *SubTaskStatus) GetName() string

func (*SubTaskStatus) GetResult 

func (m *SubTaskStatus) GetResult() *ProcessResult

func (*SubTaskStatus) GetStage 

func (m *SubTaskStatus) GetStage() Stage

func (*SubTaskStatus) GetStatus 

func (m *SubTaskStatus) GetStatus() isSubTaskStatus_Status

func (*SubTaskStatus) GetSync 

func (m *SubTaskStatus) GetSync() *SyncStatus

func (*SubTaskStatus) GetUnit 

func (m *SubTaskStatus) GetUnit() UnitType

func (*SubTaskStatus) GetUnresolvedDDLLockID 

func (m *SubTaskStatus) GetUnresolvedDDLLockID() string

func (*SubTaskStatus) GetValidation 

func (m *SubTaskStatus) GetValidation() *ValidationStatus

func (*SubTaskStatus) Marshal 

func (m *SubTaskStatus) Marshal() (dAtA []byte, err error)

func (*SubTaskStatus) MarshalTo 

func (m *SubTaskStatus) MarshalTo(dAtA []byte) (int, error)

func (*SubTaskStatus) MarshalToSizedBuffer 

func (m *SubTaskStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SubTaskStatus) ProtoMessage 

func (*SubTaskStatus) ProtoMessage()

func (*SubTaskStatus) Reset 

func (m *SubTaskStatus) Reset()

func (*SubTaskStatus) Size 

func (m *SubTaskStatus) Size() (n int)

func (*SubTaskStatus) String 

func (m *SubTaskStatus) String() string

func (*SubTaskStatus) Unmarshal 

func (m *SubTaskStatus) Unmarshal(dAtA []byte) error

func (*SubTaskStatus) XXX_DiscardUnknown 

func (m *SubTaskStatus) XXX_DiscardUnknown()

func (*SubTaskStatus) XXX_Marshal 

func (m *SubTaskStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SubTaskStatus) XXX_Merge 

func (m *SubTaskStatus) XXX_Merge(src proto.Message)

func (*SubTaskStatus) XXX_OneofWrappers 

func (*SubTaskStatus) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*SubTaskStatus) XXX_Size 

func (m *SubTaskStatus) XXX_Size() int

func (*SubTaskStatus) XXX_Unmarshal 

func (m *SubTaskStatus) XXX_Unmarshal(b []byte) error

type SubTaskStatusList 

type SubTaskStatusList struct {
	Status []*SubTaskStatus `protobuf:"bytes,1,rep,name=status,proto3" json:"status,omitempty"`
}

SubTaskStatusList used for internal jsonpb marshal

func (*SubTaskStatusList) Descriptor 

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

func (*SubTaskStatusList) GetStatus 

func (m *SubTaskStatusList) GetStatus() []*SubTaskStatus

func (*SubTaskStatusList) Marshal 

func (m *SubTaskStatusList) Marshal() (dAtA []byte, err error)

func (*SubTaskStatusList) MarshalTo 

func (m *SubTaskStatusList) MarshalTo(dAtA []byte) (int, error)

func (*SubTaskStatusList) MarshalToSizedBuffer 

func (m *SubTaskStatusList) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SubTaskStatusList) ProtoMessage 

func (*SubTaskStatusList) ProtoMessage()

func (*SubTaskStatusList) Reset 

func (m *SubTaskStatusList) Reset()

func (*SubTaskStatusList) Size 

func (m *SubTaskStatusList) Size() (n int)

func (*SubTaskStatusList) String 

func (m *SubTaskStatusList) String() string

func (*SubTaskStatusList) Unmarshal 

func (m *SubTaskStatusList) Unmarshal(dAtA []byte) error

func (*SubTaskStatusList) XXX_DiscardUnknown 

func (m *SubTaskStatusList) XXX_DiscardUnknown()

func (*SubTaskStatusList) XXX_Marshal 

func (m *SubTaskStatusList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SubTaskStatusList) XXX_Merge 

func (m *SubTaskStatusList) XXX_Merge(src proto.Message)

func (*SubTaskStatusList) XXX_Size 

func (m *SubTaskStatusList) XXX_Size() int

func (*SubTaskStatusList) XXX_Unmarshal 

func (m *SubTaskStatusList) XXX_Unmarshal(b []byte) error

type SubTaskStatus_Check 

type SubTaskStatus_Check struct {
	Check *CheckStatus `protobuf:"bytes,7,opt,name=check,proto3,oneof" json:"check,omitempty"`
}

func (*SubTaskStatus_Check) MarshalTo 

func (m *SubTaskStatus_Check) MarshalTo(dAtA []byte) (int, error)

func (*SubTaskStatus_Check) MarshalToSizedBuffer 

func (m *SubTaskStatus_Check) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SubTaskStatus_Check) Size 

func (m *SubTaskStatus_Check) Size() (n int)

type SubTaskStatus_Dump 

type SubTaskStatus_Dump struct {
	Dump *DumpStatus `protobuf:"bytes,8,opt,name=dump,proto3,oneof" json:"dump,omitempty"`
}

func (*SubTaskStatus_Dump) MarshalTo 

func (m *SubTaskStatus_Dump) MarshalTo(dAtA []byte) (int, error)

func (*SubTaskStatus_Dump) MarshalToSizedBuffer 

func (m *SubTaskStatus_Dump) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SubTaskStatus_Dump) Size 

func (m *SubTaskStatus_Dump) Size() (n int)

type SubTaskStatus_Load 

type SubTaskStatus_Load struct {
	Load *LoadStatus `protobuf:"bytes,9,opt,name=load,proto3,oneof" json:"load,omitempty"`
}

func (*SubTaskStatus_Load) MarshalTo 

func (m *SubTaskStatus_Load) MarshalTo(dAtA []byte) (int, error)

func (*SubTaskStatus_Load) MarshalToSizedBuffer 

func (m *SubTaskStatus_Load) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SubTaskStatus_Load) Size 

func (m *SubTaskStatus_Load) Size() (n int)

type SubTaskStatus_Msg 

type SubTaskStatus_Msg struct {
	Msg string `protobuf:"bytes,6,opt,name=msg,proto3,oneof" json:"msg,omitempty"`
}

func (*SubTaskStatus_Msg) MarshalTo 

func (m *SubTaskStatus_Msg) MarshalTo(dAtA []byte) (int, error)

func (*SubTaskStatus_Msg) MarshalToSizedBuffer 

func (m *SubTaskStatus_Msg) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SubTaskStatus_Msg) Size 

func (m *SubTaskStatus_Msg) Size() (n int)

type SubTaskStatus_Sync 

type SubTaskStatus_Sync struct {
	Sync *SyncStatus `protobuf:"bytes,10,opt,name=sync,proto3,oneof" json:"sync,omitempty"`
}

func (*SubTaskStatus_Sync) MarshalTo 

func (m *SubTaskStatus_Sync) MarshalTo(dAtA []byte) (int, error)

func (*SubTaskStatus_Sync) MarshalToSizedBuffer 

func (m *SubTaskStatus_Sync) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SubTaskStatus_Sync) Size 

func (m *SubTaskStatus_Sync) Size() (n int)

type SyncError 

type SyncError struct {
	Errors []*SyncSQLError `protobuf:"bytes,1,rep,name=errors,proto3" json:"errors,omitempty"`
}

SyncError represents error list for sync unit

func (*SyncError) Descriptor 

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

func (*SyncError) GetErrors 

func (m *SyncError) GetErrors() []*SyncSQLError

func (*SyncError) Marshal 

func (m *SyncError) Marshal() (dAtA []byte, err error)

func (*SyncError) MarshalTo 

func (m *SyncError) MarshalTo(dAtA []byte) (int, error)

func (*SyncError) MarshalToSizedBuffer 

func (m *SyncError) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SyncError) ProtoMessage 

func (*SyncError) ProtoMessage()

func (*SyncError) Reset 

func (m *SyncError) Reset()

func (*SyncError) Size 

func (m *SyncError) Size() (n int)

func (*SyncError) String 

func (m *SyncError) String() string

func (*SyncError) Unmarshal 

func (m *SyncError) Unmarshal(dAtA []byte) error

func (*SyncError) XXX_DiscardUnknown 

func (m *SyncError) XXX_DiscardUnknown()

func (*SyncError) XXX_Marshal 

func (m *SyncError) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SyncError) XXX_Merge 

func (m *SyncError) XXX_Merge(src proto.Message)

func (*SyncError) XXX_Size 

func (m *SyncError) XXX_Size() int

func (*SyncError) XXX_Unmarshal 

func (m *SyncError) XXX_Unmarshal(b []byte) error

type SyncSQLError 

type SyncSQLError struct {
	Msg                  string `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
	FailedBinlogPosition string `protobuf:"bytes,2,opt,name=failedBinlogPosition,proto3" json:"failedBinlogPosition,omitempty"`
	ErrorSQL             string `protobuf:"bytes,3,opt,name=errorSQL,proto3" json:"errorSQL,omitempty"`
}

SyncSQLError represents a sql error in sync unit

func (*SyncSQLError) Descriptor 

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

func (*SyncSQLError) GetErrorSQL 

func (m *SyncSQLError) GetErrorSQL() string

func (*SyncSQLError) GetFailedBinlogPosition 

func (m *SyncSQLError) GetFailedBinlogPosition() string

func (*SyncSQLError) GetMsg 

func (m *SyncSQLError) GetMsg() string

func (*SyncSQLError) Marshal 

func (m *SyncSQLError) Marshal() (dAtA []byte, err error)

func (*SyncSQLError) MarshalTo 

func (m *SyncSQLError) MarshalTo(dAtA []byte) (int, error)

func (*SyncSQLError) MarshalToSizedBuffer 

func (m *SyncSQLError) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SyncSQLError) ProtoMessage 

func (*SyncSQLError) ProtoMessage()

func (*SyncSQLError) Reset 

func (m *SyncSQLError) Reset()

func (*SyncSQLError) Size 

func (m *SyncSQLError) Size() (n int)

func (*SyncSQLError) String 

func (m *SyncSQLError) String() string

func (*SyncSQLError) Unmarshal 

func (m *SyncSQLError) Unmarshal(dAtA []byte) error

func (*SyncSQLError) XXX_DiscardUnknown 

func (m *SyncSQLError) XXX_DiscardUnknown()

func (*SyncSQLError) XXX_Marshal 

func (m *SyncSQLError) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SyncSQLError) XXX_Merge 

func (m *SyncSQLError) XXX_Merge(src proto.Message)

func (*SyncSQLError) XXX_Size 

func (m *SyncSQLError) XXX_Size() int

func (*SyncSQLError) XXX_Unmarshal 

func (m *SyncSQLError) XXX_Unmarshal(b []byte) error

type SyncStatus 

type SyncStatus struct {
	// totalEvents/totalTps/recentTps has been deprecated now
	TotalEvents         int64            `protobuf:"varint,1,opt,name=totalEvents,proto3" json:"totalEvents,omitempty"`
	TotalTps            int64            `protobuf:"varint,2,opt,name=totalTps,proto3" json:"totalTps,omitempty"`
	RecentTps           int64            `protobuf:"varint,3,opt,name=recentTps,proto3" json:"recentTps,omitempty"`
	MasterBinlog        string           `protobuf:"bytes,4,opt,name=masterBinlog,proto3" json:"masterBinlog,omitempty"`
	MasterBinlogGtid    string           `protobuf:"bytes,5,opt,name=masterBinlogGtid,proto3" json:"masterBinlogGtid,omitempty"`
	SyncerBinlog        string           `protobuf:"bytes,6,opt,name=syncerBinlog,proto3" json:"syncerBinlog,omitempty"`
	SyncerBinlogGtid    string           `protobuf:"bytes,7,opt,name=syncerBinlogGtid,proto3" json:"syncerBinlogGtid,omitempty"`
	BlockingDDLs        []string         `protobuf:"bytes,8,rep,name=blockingDDLs,proto3" json:"blockingDDLs,omitempty"`
	UnresolvedGroups    []*ShardingGroup `protobuf:"bytes,9,rep,name=unresolvedGroups,proto3" json:"unresolvedGroups,omitempty"`
	Synced              bool             `protobuf:"varint,10,opt,name=synced,proto3" json:"synced,omitempty"`
	BinlogType          string           `protobuf:"bytes,11,opt,name=binlogType,proto3" json:"binlogType,omitempty"`
	SecondsBehindMaster int64            `protobuf:"varint,12,opt,name=secondsBehindMaster,proto3" json:"secondsBehindMaster,omitempty"`
	BlockDDLOwner       string           `protobuf:"bytes,13,opt,name=blockDDLOwner,proto3" json:"blockDDLOwner,omitempty"`
	ConflictMsg         string           `protobuf:"bytes,14,opt,name=conflictMsg,proto3" json:"conflictMsg,omitempty"`
	TotalRows           int64            `protobuf:"varint,15,opt,name=totalRows,proto3" json:"totalRows,omitempty"`
	TotalRps            int64            `protobuf:"varint,16,opt,name=totalRps,proto3" json:"totalRps,omitempty"`
	RecentRps           int64            `protobuf:"varint,17,opt,name=recentRps,proto3" json:"recentRps,omitempty"`
	// meter TCP io to downstream of the subtask
	IoTotalBytes uint64 `protobuf:"varint,18,opt,name=ioTotalBytes,proto3" json:"ioTotalBytes,omitempty"`
	// meter TCP io from upstream of the subtask
	DumpIOTotalBytes uint64 `protobuf:"varint,19,opt,name=dumpIOTotalBytes,proto3" json:"dumpIOTotalBytes,omitempty"`
}

SyncStatus represents status for sync unit

func (*SyncStatus) Descriptor 

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

func (*SyncStatus) GetBinlogType 

func (m *SyncStatus) GetBinlogType() string

func (*SyncStatus) GetBlockDDLOwner 

func (m *SyncStatus) GetBlockDDLOwner() string

func (*SyncStatus) GetBlockingDDLs 

func (m *SyncStatus) GetBlockingDDLs() []string

func (*SyncStatus) GetConflictMsg 

func (m *SyncStatus) GetConflictMsg() string

func (*SyncStatus) GetDumpIOTotalBytes 

func (m *SyncStatus) GetDumpIOTotalBytes() uint64

func (*SyncStatus) GetIoTotalBytes 

func (m *SyncStatus) GetIoTotalBytes() uint64

func (*SyncStatus) GetMasterBinlog 

func (m *SyncStatus) GetMasterBinlog() string

func (*SyncStatus) GetMasterBinlogGtid 

func (m *SyncStatus) GetMasterBinlogGtid() string

func (*SyncStatus) GetRecentRps 

func (m *SyncStatus) GetRecentRps() int64

func (*SyncStatus) GetRecentTps 

func (m *SyncStatus) GetRecentTps() int64

func (*SyncStatus) GetSecondsBehindMaster 

func (m *SyncStatus) GetSecondsBehindMaster() int64

func (*SyncStatus) GetSynced 

func (m *SyncStatus) GetSynced() bool

func (*SyncStatus) GetSyncerBinlog 

func (m *SyncStatus) GetSyncerBinlog() string

func (*SyncStatus) GetSyncerBinlogGtid 

func (m *SyncStatus) GetSyncerBinlogGtid() string

func (*SyncStatus) GetTotalEvents 

func (m *SyncStatus) GetTotalEvents() int64

func (*SyncStatus) GetTotalRows 

func (m *SyncStatus) GetTotalRows() int64

func (*SyncStatus) GetTotalRps 

func (m *SyncStatus) GetTotalRps() int64

func (*SyncStatus) GetTotalTps 

func (m *SyncStatus) GetTotalTps() int64

func (*SyncStatus) GetUnresolvedGroups 

func (m *SyncStatus) GetUnresolvedGroups() []*ShardingGroup

func (*SyncStatus) Marshal 

func (m *SyncStatus) Marshal() (dAtA []byte, err error)

func (*SyncStatus) MarshalTo 

func (m *SyncStatus) MarshalTo(dAtA []byte) (int, error)

func (*SyncStatus) MarshalToSizedBuffer 

func (m *SyncStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SyncStatus) ProtoMessage 

func (*SyncStatus) ProtoMessage()

func (*SyncStatus) Reset 

func (m *SyncStatus) Reset()

func (*SyncStatus) Size 

func (m *SyncStatus) Size() (n int)

func (*SyncStatus) String 

func (m *SyncStatus) String() string

func (*SyncStatus) Unmarshal 

func (m *SyncStatus) Unmarshal(dAtA []byte) error

func (*SyncStatus) XXX_DiscardUnknown 

func (m *SyncStatus) XXX_DiscardUnknown()

func (*SyncStatus) XXX_Marshal 

func (m *SyncStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SyncStatus) XXX_Merge 

func (m *SyncStatus) XXX_Merge(src proto.Message)

func (*SyncStatus) XXX_Size 

func (m *SyncStatus) XXX_Size() int

func (*SyncStatus) XXX_Unmarshal 

func (m *SyncStatus) XXX_Unmarshal(b []byte) error

type TaskOp 

type TaskOp int32
const (
	TaskOp_InvalidOp  TaskOp = 0
	TaskOp_Stop       TaskOp = 1
	TaskOp_Pause      TaskOp = 2
	TaskOp_Resume     TaskOp = 3
	TaskOp_Start      TaskOp = 4
	TaskOp_Update     TaskOp = 5
	TaskOp_AutoResume TaskOp = 6
	TaskOp_Delete     TaskOp = 7
)

func (TaskOp) EnumDescriptor 

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

func (TaskOp) String 

func (x TaskOp) String() string

type TransferSourceRequest 

type TransferSourceRequest struct {
	Source string `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`
	Worker string `protobuf:"bytes,2,opt,name=worker,proto3" json:"worker,omitempty"`
}

func (*TransferSourceRequest) Descriptor 

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

func (*TransferSourceRequest) GetSource 

func (m *TransferSourceRequest) GetSource() string

func (*TransferSourceRequest) GetWorker 

func (m *TransferSourceRequest) GetWorker() string

func (*TransferSourceRequest) Marshal 

func (m *TransferSourceRequest) Marshal() (dAtA []byte, err error)

func (*TransferSourceRequest) MarshalTo 

func (m *TransferSourceRequest) MarshalTo(dAtA []byte) (int, error)

func (*TransferSourceRequest) MarshalToSizedBuffer 

func (m *TransferSourceRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TransferSourceRequest) ProtoMessage 

func (*TransferSourceRequest) ProtoMessage()

func (*TransferSourceRequest) Reset 

func (m *TransferSourceRequest) Reset()

func (*TransferSourceRequest) Size 

func (m *TransferSourceRequest) Size() (n int)

func (*TransferSourceRequest) String 

func (m *TransferSourceRequest) String() string

func (*TransferSourceRequest) Unmarshal 

func (m *TransferSourceRequest) Unmarshal(dAtA []byte) error

func (*TransferSourceRequest) XXX_DiscardUnknown 

func (m *TransferSourceRequest) XXX_DiscardUnknown()

func (*TransferSourceRequest) XXX_Marshal 

func (m *TransferSourceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TransferSourceRequest) XXX_Merge 

func (m *TransferSourceRequest) XXX_Merge(src proto.Message)

func (*TransferSourceRequest) XXX_Size 

func (m *TransferSourceRequest) XXX_Size() int

func (*TransferSourceRequest) XXX_Unmarshal 

func (m *TransferSourceRequest) XXX_Unmarshal(b []byte) error

type TransferSourceResponse 

type TransferSourceResponse struct {
	Result bool   `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"`
	Msg    string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
}

func (*TransferSourceResponse) Descriptor 

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

func (*TransferSourceResponse) GetMsg 

func (m *TransferSourceResponse) GetMsg() string

func (*TransferSourceResponse) GetResult 

func (m *TransferSourceResponse) GetResult() bool

func (*TransferSourceResponse) Marshal 

func (m *TransferSourceResponse) Marshal() (dAtA []byte, err error)

func (*TransferSourceResponse) MarshalTo 

func (m *TransferSourceResponse) MarshalTo(dAtA []byte) (int, error)

func (*TransferSourceResponse) MarshalToSizedBuffer 

func (m *TransferSourceResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TransferSourceResponse) ProtoMessage 

func (*TransferSourceResponse) ProtoMessage()

func (*TransferSourceResponse) Reset 

func (m *TransferSourceResponse) Reset()

func (*TransferSourceResponse) Size 

func (m *TransferSourceResponse) Size() (n int)

func (*TransferSourceResponse) String 

func (m *TransferSourceResponse) String() string

func (*TransferSourceResponse) Unmarshal 

func (m *TransferSourceResponse) Unmarshal(dAtA []byte) error

func (*TransferSourceResponse) XXX_DiscardUnknown 

func (m *TransferSourceResponse) XXX_DiscardUnknown()

func (*TransferSourceResponse) XXX_Marshal 

func (m *TransferSourceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TransferSourceResponse) XXX_Merge 

func (m *TransferSourceResponse) XXX_Merge(src proto.Message)

func (*TransferSourceResponse) XXX_Size 

func (m *TransferSourceResponse) XXX_Size() int

func (*TransferSourceResponse) XXX_Unmarshal 

func (m *TransferSourceResponse) XXX_Unmarshal(b []byte) error

type UnimplementedMasterServer 

type UnimplementedMasterServer struct {
}

UnimplementedMasterServer can be embedded to have forward compatible implementations.

func (*UnimplementedMasterServer) CheckTask 

func (*UnimplementedMasterServer) CheckTask(ctx context.Context, req *CheckTaskRequest) (*CheckTaskResponse, error)

func (*UnimplementedMasterServer) Encrypt 

func (*UnimplementedMasterServer) Encrypt(ctx context.Context, req *EncryptRequest) (*EncryptResponse, error)

func (*UnimplementedMasterServer) GetCfg 

func (*UnimplementedMasterServer) GetCfg(ctx context.Context, req *GetCfgRequest) (*GetCfgResponse, error)

func (*UnimplementedMasterServer) GetMasterCfg 

func (*UnimplementedMasterServer) GetMasterCfg(ctx context.Context, req *GetMasterCfgRequest) (*GetMasterCfgResponse, error)

func (*UnimplementedMasterServer) GetSubTaskCfg 

func (*UnimplementedMasterServer) GetSubTaskCfg(ctx context.Context, req *GetSubTaskCfgRequest) (*GetSubTaskCfgResponse, error)

func (*UnimplementedMasterServer) GetValidationError 

func (*UnimplementedMasterServer) GetValidationError(ctx context.Context, req *GetValidationErrorRequest) (*GetValidationErrorResponse, error)

func (*UnimplementedMasterServer) GetValidationStatus 

func (*UnimplementedMasterServer) GetValidationStatus(ctx context.Context, req *GetValidationStatusRequest) (*GetValidationStatusResponse, error)

func (*UnimplementedMasterServer) HandleError 

func (*UnimplementedMasterServer) HandleError(ctx context.Context, req *HandleErrorRequest) (*HandleErrorResponse, error)

func (*UnimplementedMasterServer) ListMember 

func (*UnimplementedMasterServer) ListMember(ctx context.Context, req *ListMemberRequest) (*ListMemberResponse, error)

func (*UnimplementedMasterServer) ListSourceConfigs 

func (*UnimplementedMasterServer) ListSourceConfigs(ctx context.Context, req *emptypb.Empty) (*ListSourceConfigsResponse, error)

func (*UnimplementedMasterServer) ListTaskConfigs 

func (*UnimplementedMasterServer) ListTaskConfigs(ctx context.Context, req *emptypb.Empty) (*ListTaskConfigsResponse, error)

func (*UnimplementedMasterServer) OfflineMember 

func (*UnimplementedMasterServer) OfflineMember(ctx context.Context, req *OfflineMemberRequest) (*OfflineMemberResponse, error)

func (*UnimplementedMasterServer) OperateLeader 

func (*UnimplementedMasterServer) OperateLeader(ctx context.Context, req *OperateLeaderRequest) (*OperateLeaderResponse, error)

func (*UnimplementedMasterServer) OperateRelay 

func (*UnimplementedMasterServer) OperateRelay(ctx context.Context, req *OperateRelayRequest) (*OperateRelayResponse, error)

func (*UnimplementedMasterServer) OperateSchema 

func (*UnimplementedMasterServer) OperateSchema(ctx context.Context, req *OperateSchemaRequest) (*OperateSchemaResponse, error)

func (*UnimplementedMasterServer) OperateSource 

func (*UnimplementedMasterServer) OperateSource(ctx context.Context, req *OperateSourceRequest) (*OperateSourceResponse, error)

func (*UnimplementedMasterServer) OperateTask 

func (*UnimplementedMasterServer) OperateTask(ctx context.Context, req *OperateTaskRequest) (*OperateTaskResponse, error)

func (*UnimplementedMasterServer) OperateValidationError 

func (*UnimplementedMasterServer) OperateValidationError(ctx context.Context, req *OperateValidationErrorRequest) (*OperateValidationErrorResponse, error)

func (*UnimplementedMasterServer) OperateWorkerRelayTask 

func (*UnimplementedMasterServer) OperateWorkerRelayTask(ctx context.Context, req *OperateWorkerRelayRequest) (*OperateWorkerRelayResponse, error)

func (*UnimplementedMasterServer) PurgeWorkerRelay 

func (*UnimplementedMasterServer) PurgeWorkerRelay(ctx context.Context, req *PurgeWorkerRelayRequest) (*PurgeWorkerRelayResponse, error)

func (*UnimplementedMasterServer) QueryStatus 

func (*UnimplementedMasterServer) QueryStatus(ctx context.Context, req *QueryStatusListRequest) (*QueryStatusListResponse, error)

func (*UnimplementedMasterServer) RegisterWorker 

func (*UnimplementedMasterServer) RegisterWorker(ctx context.Context, req *RegisterWorkerRequest) (*RegisterWorkerResponse, error)

func (*UnimplementedMasterServer) ShowDDLLocks 

func (*UnimplementedMasterServer) ShowDDLLocks(ctx context.Context, req *ShowDDLLocksRequest) (*ShowDDLLocksResponse, error)

func (*UnimplementedMasterServer) StartTask 

func (*UnimplementedMasterServer) StartTask(ctx context.Context, req *StartTaskRequest) (*StartTaskResponse, error)

func (*UnimplementedMasterServer) StartValidation 

func (*UnimplementedMasterServer) StartValidation(ctx context.Context, req *StartValidationRequest) (*StartValidationResponse, error)

func (*UnimplementedMasterServer) StopValidation 

func (*UnimplementedMasterServer) StopValidation(ctx context.Context, req *StopValidationRequest) (*StopValidationResponse, error)

func (*UnimplementedMasterServer) TransferSource 

func (*UnimplementedMasterServer) TransferSource(ctx context.Context, req *TransferSourceRequest) (*TransferSourceResponse, error)

func (*UnimplementedMasterServer) UnlockDDLLock 

func (*UnimplementedMasterServer) UnlockDDLLock(ctx context.Context, req *UnlockDDLLockRequest) (*UnlockDDLLockResponse, error)

func (*UnimplementedMasterServer) UpdateTask 

func (*UnimplementedMasterServer) UpdateTask(ctx context.Context, req *UpdateTaskRequest) (*UpdateTaskResponse, error)

func (*UnimplementedMasterServer) UpdateValidation 

func (*UnimplementedMasterServer) UpdateValidation(ctx context.Context, req *UpdateValidationRequest) (*UpdateValidationResponse, error)

type UnimplementedWorkerServer 

type UnimplementedWorkerServer struct {
}

UnimplementedWorkerServer can be embedded to have forward compatible implementations.

func (*UnimplementedWorkerServer) CheckSubtasksCanUpdate 

func (*UnimplementedWorkerServer) CheckSubtasksCanUpdate(ctx context.Context, req *CheckSubtasksCanUpdateRequest) (*CheckSubtasksCanUpdateResponse, error)

func (*UnimplementedWorkerServer) GetValidatorError 

func (*UnimplementedWorkerServer) GetValidatorError(ctx context.Context, req *GetValidationErrorRequest) (*GetValidationErrorResponse, error)

func (*UnimplementedWorkerServer) GetWorkerCfg 

func (*UnimplementedWorkerServer) GetWorkerCfg(ctx context.Context, req *GetWorkerCfgRequest) (*GetWorkerCfgResponse, error)

func (*UnimplementedWorkerServer) GetWorkerValidatorStatus 

func (*UnimplementedWorkerServer) GetWorkerValidatorStatus(ctx context.Context, req *GetValidationStatusRequest) (*GetValidationStatusResponse, error)

func (*UnimplementedWorkerServer) HandleError 

func (*UnimplementedWorkerServer) HandleError(ctx context.Context, req *HandleWorkerErrorRequest) (*CommonWorkerResponse, error)

func (*UnimplementedWorkerServer) OperateSchema 

func (*UnimplementedWorkerServer) OperateSchema(ctx context.Context, req *OperateWorkerSchemaRequest) (*CommonWorkerResponse, error)

func (*UnimplementedWorkerServer) OperateV1Meta 

func (*UnimplementedWorkerServer) OperateV1Meta(ctx context.Context, req *OperateV1MetaRequest) (*OperateV1MetaResponse, error)

func (*UnimplementedWorkerServer) OperateValidatorError 

func (*UnimplementedWorkerServer) OperateValidatorError(ctx context.Context, req *OperateValidationErrorRequest) (*OperateValidationErrorResponse, error)

func (*UnimplementedWorkerServer) PurgeRelay 

func (*UnimplementedWorkerServer) PurgeRelay(ctx context.Context, req *PurgeRelayRequest) (*CommonWorkerResponse, error)

func (*UnimplementedWorkerServer) QueryStatus 

func (*UnimplementedWorkerServer) QueryStatus(ctx context.Context, req *QueryStatusRequest) (*QueryStatusResponse, error)

func (*UnimplementedWorkerServer) UpdateValidator 

func (*UnimplementedWorkerServer) UpdateValidator(ctx context.Context, req *UpdateValidationWorkerRequest) (*CommonWorkerResponse, error)

type UnitType 

type UnitType int32

UnitType represents the dm unit's type 

const (
	UnitType_InvalidUnit UnitType = 0
	UnitType_Check       UnitType = 1
	UnitType_Dump        UnitType = 2
	UnitType_Load        UnitType = 3
	UnitType_Sync        UnitType = 4
	UnitType_Relay       UnitType = 100
)

func (UnitType) EnumDescriptor 

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

func (UnitType) String 

func (x UnitType) String() string

type UnlockDDLLockOp 

type UnlockDDLLockOp int32
const (
	UnlockDDLLockOp_InvalidLockOp UnlockDDLLockOp = 0
	UnlockDDLLockOp_SkipLock      UnlockDDLLockOp = 1
	UnlockDDLLockOp_ExecLock      UnlockDDLLockOp = 2
)

func (UnlockDDLLockOp) EnumDescriptor 

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

func (UnlockDDLLockOp) String 

func (x UnlockDDLLockOp) String() string

type UnlockDDLLockRequest 

type UnlockDDLLockRequest struct {
	ID           string          `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	ReplaceOwner string          `protobuf:"bytes,2,opt,name=replaceOwner,proto3" json:"replaceOwner,omitempty"`
	ForceRemove  bool            `protobuf:"varint,3,opt,name=forceRemove,proto3" json:"forceRemove,omitempty"`
	Op           UnlockDDLLockOp `protobuf:"varint,4,opt,name=op,proto3,enum=pb.UnlockDDLLockOp" json:"op,omitempty"`
	Sources      []string        `protobuf:"bytes,5,rep,name=sources,proto3" json:"sources,omitempty"`
	Database     string          `protobuf:"bytes,6,opt,name=database,proto3" json:"database,omitempty"`
	Table        string          `protobuf:"bytes,7,opt,name=table,proto3" json:"table,omitempty"`
}

UnlockDDLLockRequest used to unlock (resolve) DDL lock manually ID: DDL lock ID replaceOwner: dm-worker used to replace the original DDL lock's owner forceRemove: force to remove the DDL lock even fail to execute the DDL for the owner.

func (*UnlockDDLLockRequest) Descriptor 

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

func (*UnlockDDLLockRequest) GetDatabase 

func (m *UnlockDDLLockRequest) GetDatabase() string

func (*UnlockDDLLockRequest) GetForceRemove 

func (m *UnlockDDLLockRequest) GetForceRemove() bool

func (*UnlockDDLLockRequest) GetID 

func (m *UnlockDDLLockRequest) GetID() string

func (*UnlockDDLLockRequest) GetOp 

func (m *UnlockDDLLockRequest) GetOp() UnlockDDLLockOp

func (*UnlockDDLLockRequest) GetReplaceOwner 

func (m *UnlockDDLLockRequest) GetReplaceOwner() string

func (*UnlockDDLLockRequest) GetSources 

func (m *UnlockDDLLockRequest) GetSources() []string

func (*UnlockDDLLockRequest) GetTable 

func (m *UnlockDDLLockRequest) GetTable() string

func (*UnlockDDLLockRequest) Marshal 

func (m *UnlockDDLLockRequest) Marshal() (dAtA []byte, err error)

func (*UnlockDDLLockRequest) MarshalTo 

func (m *UnlockDDLLockRequest) MarshalTo(dAtA []byte) (int, error)

func (*UnlockDDLLockRequest) MarshalToSizedBuffer 

func (m *UnlockDDLLockRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UnlockDDLLockRequest) ProtoMessage 

func (*UnlockDDLLockRequest) ProtoMessage()

func (*UnlockDDLLockRequest) Reset 

func (m *UnlockDDLLockRequest) Reset()

func (*UnlockDDLLockRequest) Size 

func (m *UnlockDDLLockRequest) Size() (n int)

func (*UnlockDDLLockRequest) String 

func (m *UnlockDDLLockRequest) String() string

func (*UnlockDDLLockRequest) Unmarshal 

func (m *UnlockDDLLockRequest) Unmarshal(dAtA []byte) error

func (*UnlockDDLLockRequest) XXX_DiscardUnknown 

func (m *UnlockDDLLockRequest) XXX_DiscardUnknown()

func (*UnlockDDLLockRequest) XXX_Marshal 

func (m *UnlockDDLLockRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UnlockDDLLockRequest) XXX_Merge 

func (m *UnlockDDLLockRequest) XXX_Merge(src proto.Message)

func (*UnlockDDLLockRequest) XXX_Size 

func (m *UnlockDDLLockRequest) XXX_Size() int

func (*UnlockDDLLockRequest) XXX_Unmarshal 

func (m *UnlockDDLLockRequest) XXX_Unmarshal(b []byte) error

type UnlockDDLLockResponse 

type UnlockDDLLockResponse struct {
	Result bool   `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"`
	Msg    string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
}

func (*UnlockDDLLockResponse) Descriptor 

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

func (*UnlockDDLLockResponse) GetMsg 

func (m *UnlockDDLLockResponse) GetMsg() string

func (*UnlockDDLLockResponse) GetResult 

func (m *UnlockDDLLockResponse) GetResult() bool

func (*UnlockDDLLockResponse) Marshal 

func (m *UnlockDDLLockResponse) Marshal() (dAtA []byte, err error)

func (*UnlockDDLLockResponse) MarshalTo 

func (m *UnlockDDLLockResponse) MarshalTo(dAtA []byte) (int, error)

func (*UnlockDDLLockResponse) MarshalToSizedBuffer 

func (m *UnlockDDLLockResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UnlockDDLLockResponse) ProtoMessage 

func (*UnlockDDLLockResponse) ProtoMessage()

func (*UnlockDDLLockResponse) Reset 

func (m *UnlockDDLLockResponse) Reset()

func (*UnlockDDLLockResponse) Size 

func (m *UnlockDDLLockResponse) Size() (n int)

func (*UnlockDDLLockResponse) String 

func (m *UnlockDDLLockResponse) String() string

func (*UnlockDDLLockResponse) Unmarshal 

func (m *UnlockDDLLockResponse) Unmarshal(dAtA []byte) error

func (*UnlockDDLLockResponse) XXX_DiscardUnknown 

func (m *UnlockDDLLockResponse) XXX_DiscardUnknown()

func (*UnlockDDLLockResponse) XXX_Marshal 

func (m *UnlockDDLLockResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UnlockDDLLockResponse) XXX_Merge 

func (m *UnlockDDLLockResponse) XXX_Merge(src proto.Message)

func (*UnlockDDLLockResponse) XXX_Size 

func (m *UnlockDDLLockResponse) XXX_Size() int

func (*UnlockDDLLockResponse) XXX_Unmarshal 

func (m *UnlockDDLLockResponse) XXX_Unmarshal(b []byte) error

type UpdateTaskRequest 

type UpdateTaskRequest struct {
	Task    string   `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	Sources []string `protobuf:"bytes,2,rep,name=sources,proto3" json:"sources,omitempty"`
}

UpdateTaskRequest used to update task after it has beed started task: task's configuration, yaml format 

now, only support to update config for routes, filters, column-mappings, block-allow-list
support update partial config for syncer, loader, etc later

sources need to do update, empty for all sources in processing the task

func (*UpdateTaskRequest) Descriptor 

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

func (*UpdateTaskRequest) GetSources 

func (m *UpdateTaskRequest) GetSources() []string

func (*UpdateTaskRequest) GetTask 

func (m *UpdateTaskRequest) GetTask() string

func (*UpdateTaskRequest) Marshal 

func (m *UpdateTaskRequest) Marshal() (dAtA []byte, err error)

func (*UpdateTaskRequest) MarshalTo 

func (m *UpdateTaskRequest) MarshalTo(dAtA []byte) (int, error)

func (*UpdateTaskRequest) MarshalToSizedBuffer 

func (m *UpdateTaskRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UpdateTaskRequest) ProtoMessage 

func (*UpdateTaskRequest) ProtoMessage()

func (*UpdateTaskRequest) Reset 

func (m *UpdateTaskRequest) Reset()

func (*UpdateTaskRequest) Size 

func (m *UpdateTaskRequest) Size() (n int)

func (*UpdateTaskRequest) String 

func (m *UpdateTaskRequest) String() string

func (*UpdateTaskRequest) Unmarshal 

func (m *UpdateTaskRequest) Unmarshal(dAtA []byte) error

func (*UpdateTaskRequest) XXX_DiscardUnknown 

func (m *UpdateTaskRequest) XXX_DiscardUnknown()

func (*UpdateTaskRequest) XXX_Marshal 

func (m *UpdateTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateTaskRequest) XXX_Merge 

func (m *UpdateTaskRequest) XXX_Merge(src proto.Message)

func (*UpdateTaskRequest) XXX_Size 

func (m *UpdateTaskRequest) XXX_Size() int

func (*UpdateTaskRequest) XXX_Unmarshal 

func (m *UpdateTaskRequest) XXX_Unmarshal(b []byte) error

type UpdateTaskResponse 

type UpdateTaskResponse struct {
	Result      bool                    `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"`
	Msg         string                  `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	Sources     []*CommonWorkerResponse `protobuf:"bytes,3,rep,name=sources,proto3" json:"sources,omitempty"`
	CheckResult string                  `protobuf:"bytes,4,opt,name=checkResult,proto3" json:"checkResult,omitempty"`
}

func (*UpdateTaskResponse) Descriptor 

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

func (*UpdateTaskResponse) GetCheckResult 

func (m *UpdateTaskResponse) GetCheckResult() string

func (*UpdateTaskResponse) GetMsg 

func (m *UpdateTaskResponse) GetMsg() string

func (*UpdateTaskResponse) GetResult 

func (m *UpdateTaskResponse) GetResult() bool

func (*UpdateTaskResponse) GetSources 

func (m *UpdateTaskResponse) GetSources() []*CommonWorkerResponse

func (*UpdateTaskResponse) Marshal 

func (m *UpdateTaskResponse) Marshal() (dAtA []byte, err error)

func (*UpdateTaskResponse) MarshalTo 

func (m *UpdateTaskResponse) MarshalTo(dAtA []byte) (int, error)

func (*UpdateTaskResponse) MarshalToSizedBuffer 

func (m *UpdateTaskResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UpdateTaskResponse) ProtoMessage 

func (*UpdateTaskResponse) ProtoMessage()

func (*UpdateTaskResponse) Reset 

func (m *UpdateTaskResponse) Reset()

func (*UpdateTaskResponse) Size 

func (m *UpdateTaskResponse) Size() (n int)

func (*UpdateTaskResponse) String 

func (m *UpdateTaskResponse) String() string

func (*UpdateTaskResponse) Unmarshal 

func (m *UpdateTaskResponse) Unmarshal(dAtA []byte) error

func (*UpdateTaskResponse) XXX_DiscardUnknown 

func (m *UpdateTaskResponse) XXX_DiscardUnknown()

func (*UpdateTaskResponse) XXX_Marshal 

func (m *UpdateTaskResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateTaskResponse) XXX_Merge 

func (m *UpdateTaskResponse) XXX_Merge(src proto.Message)

func (*UpdateTaskResponse) XXX_Size 

func (m *UpdateTaskResponse) XXX_Size() int

func (*UpdateTaskResponse) XXX_Unmarshal 

func (m *UpdateTaskResponse) XXX_Unmarshal(b []byte) error

type UpdateValidationRequest 

type UpdateValidationRequest struct {
	TaskName   string   `protobuf:"bytes,1,opt,name=taskName,proto3" json:"taskName,omitempty"`
	Sources    []string `protobuf:"bytes,2,rep,name=sources,proto3" json:"sources,omitempty"`
	BinlogPos  string   `protobuf:"bytes,3,opt,name=binlogPos,proto3" json:"binlogPos,omitempty"`
	BinlogGTID string   `protobuf:"bytes,4,opt,name=binlogGTID,proto3" json:"binlogGTID,omitempty"`
}

func (*UpdateValidationRequest) Descriptor 

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

func (*UpdateValidationRequest) GetBinlogGTID 

func (m *UpdateValidationRequest) GetBinlogGTID() string

func (*UpdateValidationRequest) GetBinlogPos 

func (m *UpdateValidationRequest) GetBinlogPos() string

func (*UpdateValidationRequest) GetSources 

func (m *UpdateValidationRequest) GetSources() []string

func (*UpdateValidationRequest) GetTaskName 

func (m *UpdateValidationRequest) GetTaskName() string

func (*UpdateValidationRequest) Marshal 

func (m *UpdateValidationRequest) Marshal() (dAtA []byte, err error)

func (*UpdateValidationRequest) MarshalTo 

func (m *UpdateValidationRequest) MarshalTo(dAtA []byte) (int, error)

func (*UpdateValidationRequest) MarshalToSizedBuffer 

func (m *UpdateValidationRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UpdateValidationRequest) ProtoMessage 

func (*UpdateValidationRequest) ProtoMessage()

func (*UpdateValidationRequest) Reset 

func (m *UpdateValidationRequest) Reset()

func (*UpdateValidationRequest) Size 

func (m *UpdateValidationRequest) Size() (n int)

func (*UpdateValidationRequest) String 

func (m *UpdateValidationRequest) String() string

func (*UpdateValidationRequest) Unmarshal 

func (m *UpdateValidationRequest) Unmarshal(dAtA []byte) error

func (*UpdateValidationRequest) XXX_DiscardUnknown 

func (m *UpdateValidationRequest) XXX_DiscardUnknown()

func (*UpdateValidationRequest) XXX_Marshal 

func (m *UpdateValidationRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateValidationRequest) XXX_Merge 

func (m *UpdateValidationRequest) XXX_Merge(src proto.Message)

func (*UpdateValidationRequest) XXX_Size 

func (m *UpdateValidationRequest) XXX_Size() int

func (*UpdateValidationRequest) XXX_Unmarshal 

func (m *UpdateValidationRequest) XXX_Unmarshal(b []byte) error

type UpdateValidationResponse 

type UpdateValidationResponse struct {
	Result  bool                    `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"`
	Msg     string                  `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	Sources []*CommonWorkerResponse `protobuf:"bytes,3,rep,name=sources,proto3" json:"sources,omitempty"`
}

func (*UpdateValidationResponse) Descriptor 

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

func (*UpdateValidationResponse) GetMsg 

func (m *UpdateValidationResponse) GetMsg() string

func (*UpdateValidationResponse) GetResult 

func (m *UpdateValidationResponse) GetResult() bool

func (*UpdateValidationResponse) GetSources 

func (m *UpdateValidationResponse) GetSources() []*CommonWorkerResponse

func (*UpdateValidationResponse) Marshal 

func (m *UpdateValidationResponse) Marshal() (dAtA []byte, err error)

func (*UpdateValidationResponse) MarshalTo 

func (m *UpdateValidationResponse) MarshalTo(dAtA []byte) (int, error)

func (*UpdateValidationResponse) MarshalToSizedBuffer 

func (m *UpdateValidationResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UpdateValidationResponse) ProtoMessage 

func (*UpdateValidationResponse) ProtoMessage()

func (*UpdateValidationResponse) Reset 

func (m *UpdateValidationResponse) Reset()

func (*UpdateValidationResponse) Size 

func (m *UpdateValidationResponse) Size() (n int)

func (*UpdateValidationResponse) String 

func (m *UpdateValidationResponse) String() string

func (*UpdateValidationResponse) Unmarshal 

func (m *UpdateValidationResponse) Unmarshal(dAtA []byte) error

func (*UpdateValidationResponse) XXX_DiscardUnknown 

func (m *UpdateValidationResponse) XXX_DiscardUnknown()

func (*UpdateValidationResponse) XXX_Marshal 

func (m *UpdateValidationResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateValidationResponse) XXX_Merge 

func (m *UpdateValidationResponse) XXX_Merge(src proto.Message)

func (*UpdateValidationResponse) XXX_Size 

func (m *UpdateValidationResponse) XXX_Size() int

func (*UpdateValidationResponse) XXX_Unmarshal 

func (m *UpdateValidationResponse) XXX_Unmarshal(b []byte) error

type UpdateValidationWorkerRequest 

type UpdateValidationWorkerRequest struct {
	TaskName   string `protobuf:"bytes,1,opt,name=taskName,proto3" json:"taskName,omitempty"`
	BinlogPos  string `protobuf:"bytes,2,opt,name=binlogPos,proto3" json:"binlogPos,omitempty"`
	BinlogGTID string `protobuf:"bytes,3,opt,name=binlogGTID,proto3" json:"binlogGTID,omitempty"`
}

func (*UpdateValidationWorkerRequest) Descriptor 

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

func (*UpdateValidationWorkerRequest) GetBinlogGTID 

func (m *UpdateValidationWorkerRequest) GetBinlogGTID() string

func (*UpdateValidationWorkerRequest) GetBinlogPos 

func (m *UpdateValidationWorkerRequest) GetBinlogPos() string

func (*UpdateValidationWorkerRequest) GetTaskName 

func (m *UpdateValidationWorkerRequest) GetTaskName() string

func (*UpdateValidationWorkerRequest) Marshal 

func (m *UpdateValidationWorkerRequest) Marshal() (dAtA []byte, err error)

func (*UpdateValidationWorkerRequest) MarshalTo 

func (m *UpdateValidationWorkerRequest) MarshalTo(dAtA []byte) (int, error)

func (*UpdateValidationWorkerRequest) MarshalToSizedBuffer 

func (m *UpdateValidationWorkerRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UpdateValidationWorkerRequest) ProtoMessage 

func (*UpdateValidationWorkerRequest) ProtoMessage()

func (*UpdateValidationWorkerRequest) Reset 

func (m *UpdateValidationWorkerRequest) Reset()

func (*UpdateValidationWorkerRequest) Size 

func (m *UpdateValidationWorkerRequest) Size() (n int)

func (*UpdateValidationWorkerRequest) String 

func (m *UpdateValidationWorkerRequest) String() string

func (*UpdateValidationWorkerRequest) Unmarshal 

func (m *UpdateValidationWorkerRequest) Unmarshal(dAtA []byte) error

func (*UpdateValidationWorkerRequest) XXX_DiscardUnknown 

func (m *UpdateValidationWorkerRequest) XXX_DiscardUnknown()

func (*UpdateValidationWorkerRequest) XXX_Marshal 

func (m *UpdateValidationWorkerRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateValidationWorkerRequest) XXX_Merge 

func (m *UpdateValidationWorkerRequest) XXX_Merge(src proto.Message)

func (*UpdateValidationWorkerRequest) XXX_Size 

func (m *UpdateValidationWorkerRequest) XXX_Size() int

func (*UpdateValidationWorkerRequest) XXX_Unmarshal 

func (m *UpdateValidationWorkerRequest) XXX_Unmarshal(b []byte) error

type V1MetaOp 

type V1MetaOp int32
const (
	V1MetaOp_InvalidV1MetaOp V1MetaOp = 0
	V1MetaOp_GetV1Meta       V1MetaOp = 1
	V1MetaOp_RemoveV1Meta    V1MetaOp = 2
)

func (V1MetaOp) EnumDescriptor 

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

func (V1MetaOp) String 

func (x V1MetaOp) String() string

type V1SubTaskMeta 

type V1SubTaskMeta struct {
	Op    TaskOp `protobuf:"varint,1,opt,name=op,proto3,enum=pb.TaskOp" json:"op,omitempty"`
	Stage Stage  `protobuf:"varint,2,opt,name=stage,proto3,enum=pb.Stage" json:"stage,omitempty"`
	Name  string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Task  []byte `protobuf:"bytes,4,opt,name=task,proto3" json:"task,omitempty"`
}

copied `TaskMeta` from release-1.0 branch.

func (*V1SubTaskMeta) Descriptor 

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

func (*V1SubTaskMeta) GetName 

func (m *V1SubTaskMeta) GetName() string

func (*V1SubTaskMeta) GetOp 

func (m *V1SubTaskMeta) GetOp() TaskOp

func (*V1SubTaskMeta) GetStage 

func (m *V1SubTaskMeta) GetStage() Stage

func (*V1SubTaskMeta) GetTask 

func (m *V1SubTaskMeta) GetTask() []byte

func (*V1SubTaskMeta) Marshal 

func (m *V1SubTaskMeta) Marshal() (dAtA []byte, err error)

func (*V1SubTaskMeta) MarshalTo 

func (m *V1SubTaskMeta) MarshalTo(dAtA []byte) (int, error)

func (*V1SubTaskMeta) MarshalToSizedBuffer 

func (m *V1SubTaskMeta) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*V1SubTaskMeta) ProtoMessage 

func (*V1SubTaskMeta) ProtoMessage()

func (*V1SubTaskMeta) Reset 

func (m *V1SubTaskMeta) Reset()

func (*V1SubTaskMeta) Size 

func (m *V1SubTaskMeta) Size() (n int)

func (*V1SubTaskMeta) String 

func (m *V1SubTaskMeta) String() string

func (*V1SubTaskMeta) Unmarshal 

func (m *V1SubTaskMeta) Unmarshal(dAtA []byte) error

func (*V1SubTaskMeta) XXX_DiscardUnknown 

func (m *V1SubTaskMeta) XXX_DiscardUnknown()

func (*V1SubTaskMeta) XXX_Marshal 

func (m *V1SubTaskMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*V1SubTaskMeta) XXX_Merge 

func (m *V1SubTaskMeta) XXX_Merge(src proto.Message)

func (*V1SubTaskMeta) XXX_Size 

func (m *V1SubTaskMeta) XXX_Size() int

func (*V1SubTaskMeta) XXX_Unmarshal 

func (m *V1SubTaskMeta) XXX_Unmarshal(b []byte) error

type ValidateErrorState 

type ValidateErrorState int32
const (
	ValidateErrorState_InvalidErr  ValidateErrorState = 0
	ValidateErrorState_NewErr      ValidateErrorState = 1
	ValidateErrorState_IgnoredErr  ValidateErrorState = 2
	ValidateErrorState_ResolvedErr ValidateErrorState = 3
)

func (ValidateErrorState) EnumDescriptor 

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

func (ValidateErrorState) String 

func (x ValidateErrorState) String() string

type ValidationErrOp 

type ValidationErrOp int32
const (
	ValidationErrOp_InvalidErrOp ValidationErrOp = 0
	ValidationErrOp_IgnoreErrOp  ValidationErrOp = 1
	ValidationErrOp_ResolveErrOp ValidationErrOp = 2
	ValidationErrOp_ClearErrOp   ValidationErrOp = 3
)

func (ValidationErrOp) EnumDescriptor 

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

func (ValidationErrOp) String 

func (x ValidationErrOp) String() string

type ValidationError 

type ValidationError struct {
	Id        string             `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Source    string             `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"`
	SrcTable  string             `protobuf:"bytes,3,opt,name=srcTable,proto3" json:"srcTable,omitempty"`
	SrcData   string             `protobuf:"bytes,4,opt,name=srcData,proto3" json:"srcData,omitempty"`
	DstTable  string             `protobuf:"bytes,5,opt,name=dstTable,proto3" json:"dstTable,omitempty"`
	DstData   string             `protobuf:"bytes,6,opt,name=dstData,proto3" json:"dstData,omitempty"`
	ErrorType string             `protobuf:"bytes,7,opt,name=errorType,proto3" json:"errorType,omitempty"`
	Status    ValidateErrorState `protobuf:"varint,8,opt,name=status,proto3,enum=pb.ValidateErrorState" json:"status,omitempty"`
	Time      string             `protobuf:"bytes,9,opt,name=time,proto3" json:"time,omitempty"`
	Message   string             `protobuf:"bytes,10,opt,name=message,proto3" json:"message,omitempty"`
}

func (*ValidationError) Descriptor 

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

func (*ValidationError) GetDstData 

func (m *ValidationError) GetDstData() string

func (*ValidationError) GetDstTable 

func (m *ValidationError) GetDstTable() string

func (*ValidationError) GetErrorType 

func (m *ValidationError) GetErrorType() string

func (*ValidationError) GetId 

func (m *ValidationError) GetId() string

func (*ValidationError) GetMessage 

func (m *ValidationError) GetMessage() string

func (*ValidationError) GetSource 

func (m *ValidationError) GetSource() string

func (*ValidationError) GetSrcData 

func (m *ValidationError) GetSrcData() string

func (*ValidationError) GetSrcTable 

func (m *ValidationError) GetSrcTable() string

func (*ValidationError) GetStatus 

func (m *ValidationError) GetStatus() ValidateErrorState

func (*ValidationError) GetTime 

func (m *ValidationError) GetTime() string

func (*ValidationError) Marshal 

func (m *ValidationError) Marshal() (dAtA []byte, err error)

func (*ValidationError) MarshalTo 

func (m *ValidationError) MarshalTo(dAtA []byte) (int, error)

func (*ValidationError) MarshalToSizedBuffer 

func (m *ValidationError) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ValidationError) ProtoMessage 

func (*ValidationError) ProtoMessage()

func (*ValidationError) Reset 

func (m *ValidationError) Reset()

func (*ValidationError) Size 

func (m *ValidationError) Size() (n int)

func (*ValidationError) String 

func (m *ValidationError) String() string

func (*ValidationError) Unmarshal 

func (m *ValidationError) Unmarshal(dAtA []byte) error

func (*ValidationError) XXX_DiscardUnknown 

func (m *ValidationError) XXX_DiscardUnknown()

func (*ValidationError) XXX_Marshal 

func (m *ValidationError) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ValidationError) XXX_Merge 

func (m *ValidationError) XXX_Merge(src proto.Message)

func (*ValidationError) XXX_Size 

func (m *ValidationError) XXX_Size() int

func (*ValidationError) XXX_Unmarshal 

func (m *ValidationError) XXX_Unmarshal(b []byte) error

type ValidationStatus 

type ValidationStatus struct {
	Task                string         `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	Source              string         `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"`
	Mode                string         `protobuf:"bytes,3,opt,name=mode,proto3" json:"mode,omitempty"`
	Stage               Stage          `protobuf:"varint,4,opt,name=stage,proto3,enum=pb.Stage" json:"stage,omitempty"`
	ValidatorBinlog     string         `protobuf:"bytes,5,opt,name=validatorBinlog,proto3" json:"validatorBinlog,omitempty"`
	ValidatorBinlogGtid string         `protobuf:"bytes,6,opt,name=validatorBinlogGtid,proto3" json:"validatorBinlogGtid,omitempty"`
	Result              *ProcessResult `protobuf:"bytes,7,opt,name=result,proto3" json:"result,omitempty"`
	ProcessedRowsStatus string         `protobuf:"bytes,8,opt,name=processedRowsStatus,proto3" json:"processedRowsStatus,omitempty"`
	PendingRowsStatus   string         `protobuf:"bytes,9,opt,name=pendingRowsStatus,proto3" json:"pendingRowsStatus,omitempty"`
	ErrorRowsStatus     string         `protobuf:"bytes,10,opt,name=errorRowsStatus,proto3" json:"errorRowsStatus,omitempty"`
	CutoverBinlogPos    string         `protobuf:"bytes,11,opt,name=cutoverBinlogPos,proto3" json:"cutoverBinlogPos,omitempty"`
	CutoverBinlogGtid   string         `protobuf:"bytes,12,opt,name=cutoverBinlogGtid,proto3" json:"cutoverBinlogGtid,omitempty"`
}

func (*ValidationStatus) Descriptor 

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

func (*ValidationStatus) GetCutoverBinlogGtid 

func (m *ValidationStatus) GetCutoverBinlogGtid() string

func (*ValidationStatus) GetCutoverBinlogPos 

func (m *ValidationStatus) GetCutoverBinlogPos() string

func (*ValidationStatus) GetErrorRowsStatus 

func (m *ValidationStatus) GetErrorRowsStatus() string

func (*ValidationStatus) GetMode 

func (m *ValidationStatus) GetMode() string

func (*ValidationStatus) GetPendingRowsStatus 

func (m *ValidationStatus) GetPendingRowsStatus() string

func (*ValidationStatus) GetProcessedRowsStatus 

func (m *ValidationStatus) GetProcessedRowsStatus() string

func (*ValidationStatus) GetResult 

func (m *ValidationStatus) GetResult() *ProcessResult

func (*ValidationStatus) GetSource 

func (m *ValidationStatus) GetSource() string

func (*ValidationStatus) GetStage 

func (m *ValidationStatus) GetStage() Stage

func (*ValidationStatus) GetTask 

func (m *ValidationStatus) GetTask() string

func (*ValidationStatus) GetValidatorBinlog 

func (m *ValidationStatus) GetValidatorBinlog() string

func (*ValidationStatus) GetValidatorBinlogGtid 

func (m *ValidationStatus) GetValidatorBinlogGtid() string

func (*ValidationStatus) Marshal 

func (m *ValidationStatus) Marshal() (dAtA []byte, err error)

func (*ValidationStatus) MarshalTo 

func (m *ValidationStatus) MarshalTo(dAtA []byte) (int, error)

func (*ValidationStatus) MarshalToSizedBuffer 

func (m *ValidationStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ValidationStatus) ProtoMessage 

func (*ValidationStatus) ProtoMessage()

func (*ValidationStatus) Reset 

func (m *ValidationStatus) Reset()

func (*ValidationStatus) Size 

func (m *ValidationStatus) Size() (n int)

func (*ValidationStatus) String 

func (m *ValidationStatus) String() string

func (*ValidationStatus) Unmarshal 

func (m *ValidationStatus) Unmarshal(dAtA []byte) error

func (*ValidationStatus) XXX_DiscardUnknown 

func (m *ValidationStatus) XXX_DiscardUnknown()

func (*ValidationStatus) XXX_Marshal 

func (m *ValidationStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ValidationStatus) XXX_Merge 

func (m *ValidationStatus) XXX_Merge(src proto.Message)

func (*ValidationStatus) XXX_Size 

func (m *ValidationStatus) XXX_Size() int

func (*ValidationStatus) XXX_Unmarshal 

func (m *ValidationStatus) XXX_Unmarshal(b []byte) error

type ValidationTableStatus 

type ValidationTableStatus struct {
	Source   string `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`
	SrcTable string `protobuf:"bytes,2,opt,name=srcTable,proto3" json:"srcTable,omitempty"`
	DstTable string `protobuf:"bytes,3,opt,name=dstTable,proto3" json:"dstTable,omitempty"`
	Stage    Stage  `protobuf:"varint,4,opt,name=stage,proto3,enum=pb.Stage" json:"stage,omitempty"`
	Message  string `protobuf:"bytes,5,opt,name=message,proto3" json:"message,omitempty"`
}

func (*ValidationTableStatus) Descriptor 

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

func (*ValidationTableStatus) GetDstTable 

func (m *ValidationTableStatus) GetDstTable() string

func (*ValidationTableStatus) GetMessage 

func (m *ValidationTableStatus) GetMessage() string

func (*ValidationTableStatus) GetSource 

func (m *ValidationTableStatus) GetSource() string

func (*ValidationTableStatus) GetSrcTable 

func (m *ValidationTableStatus) GetSrcTable() string

func (*ValidationTableStatus) GetStage 

func (m *ValidationTableStatus) GetStage() Stage

func (*ValidationTableStatus) Marshal 

func (m *ValidationTableStatus) Marshal() (dAtA []byte, err error)

func (*ValidationTableStatus) MarshalTo 

func (m *ValidationTableStatus) MarshalTo(dAtA []byte) (int, error)

func (*ValidationTableStatus) MarshalToSizedBuffer 

func (m *ValidationTableStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ValidationTableStatus) ProtoMessage 

func (*ValidationTableStatus) ProtoMessage()

func (*ValidationTableStatus) Reset 

func (m *ValidationTableStatus) Reset()

func (*ValidationTableStatus) Size 

func (m *ValidationTableStatus) Size() (n int)

func (*ValidationTableStatus) String 

func (m *ValidationTableStatus) String() string

func (*ValidationTableStatus) Unmarshal 

func (m *ValidationTableStatus) Unmarshal(dAtA []byte) error

func (*ValidationTableStatus) XXX_DiscardUnknown 

func (m *ValidationTableStatus) XXX_DiscardUnknown()

func (*ValidationTableStatus) XXX_Marshal 

func (m *ValidationTableStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ValidationTableStatus) XXX_Merge 

func (m *ValidationTableStatus) XXX_Merge(src proto.Message)

func (*ValidationTableStatus) XXX_Size 

func (m *ValidationTableStatus) XXX_Size() int

func (*ValidationTableStatus) XXX_Unmarshal 

func (m *ValidationTableStatus) XXX_Unmarshal(b []byte) error

type ValidatorOp 

type ValidatorOp int32
const (
	ValidatorOp_InvalidValidatorOp ValidatorOp = 0
	ValidatorOp_StartValidator     ValidatorOp = 1
	ValidatorOp_StopValidator      ValidatorOp = 2
)

func (ValidatorOp) EnumDescriptor 

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

func (ValidatorOp) String 

func (x ValidatorOp) String() string

type WorkerClient 

type WorkerClient interface {
	QueryStatus(ctx context.Context, in *QueryStatusRequest, opts ...grpc.CallOption) (*QueryStatusResponse, error)
	// PurgeRelay purges relay log files for this dm-worker
	PurgeRelay(ctx context.Context, in *PurgeRelayRequest, opts ...grpc.CallOption) (*CommonWorkerResponse, error)
	// Operate (get/set/remove) schema for a specified table in tracker.
	// a `set`/`remove` operation should be an one-time operation (only take effect once),
	// so we use a gRPC method rather than a etcd operation now (no persistent operation state).
	OperateSchema(ctx context.Context, in *OperateWorkerSchemaRequest, opts ...grpc.CallOption) (*CommonWorkerResponse, error)
	OperateV1Meta(ctx context.Context, in *OperateV1MetaRequest, opts ...grpc.CallOption) (*OperateV1MetaResponse, error)
	HandleError(ctx context.Context, in *HandleWorkerErrorRequest, opts ...grpc.CallOption) (*CommonWorkerResponse, error)
	GetWorkerCfg(ctx context.Context, in *GetWorkerCfgRequest, opts ...grpc.CallOption) (*GetWorkerCfgResponse, error)
	// only some fields of the configuration of the subtask in the sync phase can be updated
	CheckSubtasksCanUpdate(ctx context.Context, in *CheckSubtasksCanUpdateRequest, opts ...grpc.CallOption) (*CheckSubtasksCanUpdateResponse, error)
	GetWorkerValidatorStatus(ctx context.Context, in *GetValidationStatusRequest, opts ...grpc.CallOption) (*GetValidationStatusResponse, error)
	GetValidatorError(ctx context.Context, in *GetValidationErrorRequest, opts ...grpc.CallOption) (*GetValidationErrorResponse, error)
	OperateValidatorError(ctx context.Context, in *OperateValidationErrorRequest, opts ...grpc.CallOption) (*OperateValidationErrorResponse, error)
	UpdateValidator(ctx context.Context, in *UpdateValidationWorkerRequest, opts ...grpc.CallOption) (*CommonWorkerResponse, error)
}

WorkerClient is the client API for Worker service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewWorkerClient 

func NewWorkerClient(cc *grpc.ClientConn) WorkerClient

type WorkerInfo 

type WorkerInfo struct {
	Name   string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Addr   string `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"`
	Stage  string `protobuf:"bytes,3,opt,name=stage,proto3" json:"stage,omitempty"`
	Source string `protobuf:"bytes,4,opt,name=source,proto3" json:"source,omitempty"`
}

func (*WorkerInfo) Descriptor 

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

func (*WorkerInfo) GetAddr 

func (m *WorkerInfo) GetAddr() string

func (*WorkerInfo) GetName 

func (m *WorkerInfo) GetName() string

func (*WorkerInfo) GetSource 

func (m *WorkerInfo) GetSource() string

func (*WorkerInfo) GetStage 

func (m *WorkerInfo) GetStage() string

func (*WorkerInfo) Marshal 

func (m *WorkerInfo) Marshal() (dAtA []byte, err error)

func (*WorkerInfo) MarshalTo 

func (m *WorkerInfo) MarshalTo(dAtA []byte) (int, error)

func (*WorkerInfo) MarshalToSizedBuffer 

func (m *WorkerInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WorkerInfo) ProtoMessage 

func (*WorkerInfo) ProtoMessage()

func (*WorkerInfo) Reset 

func (m *WorkerInfo) Reset()

func (*WorkerInfo) Size 

func (m *WorkerInfo) Size() (n int)

func (*WorkerInfo) String 

func (m *WorkerInfo) String() string

func (*WorkerInfo) Unmarshal 

func (m *WorkerInfo) Unmarshal(dAtA []byte) error

func (*WorkerInfo) XXX_DiscardUnknown 

func (m *WorkerInfo) XXX_DiscardUnknown()

func (*WorkerInfo) XXX_Marshal 

func (m *WorkerInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WorkerInfo) XXX_Merge 

func (m *WorkerInfo) XXX_Merge(src proto.Message)

func (*WorkerInfo) XXX_Size 

func (m *WorkerInfo) XXX_Size() int

func (*WorkerInfo) XXX_Unmarshal 

func (m *WorkerInfo) XXX_Unmarshal(b []byte) error

type WorkerServer 

type WorkerServer interface {
	QueryStatus(context.Context, *QueryStatusRequest) (*QueryStatusResponse, error)
	// PurgeRelay purges relay log files for this dm-worker
	PurgeRelay(context.Context, *PurgeRelayRequest) (*CommonWorkerResponse, error)
	// Operate (get/set/remove) schema for a specified table in tracker.
	// a `set`/`remove` operation should be an one-time operation (only take effect once),
	// so we use a gRPC method rather than a etcd operation now (no persistent operation state).
	OperateSchema(context.Context, *OperateWorkerSchemaRequest) (*CommonWorkerResponse, error)
	OperateV1Meta(context.Context, *OperateV1MetaRequest) (*OperateV1MetaResponse, error)
	HandleError(context.Context, *HandleWorkerErrorRequest) (*CommonWorkerResponse, error)
	GetWorkerCfg(context.Context, *GetWorkerCfgRequest) (*GetWorkerCfgResponse, error)
	// only some fields of the configuration of the subtask in the sync phase can be updated
	CheckSubtasksCanUpdate(context.Context, *CheckSubtasksCanUpdateRequest) (*CheckSubtasksCanUpdateResponse, error)
	GetWorkerValidatorStatus(context.Context, *GetValidationStatusRequest) (*GetValidationStatusResponse, error)
	GetValidatorError(context.Context, *GetValidationErrorRequest) (*GetValidationErrorResponse, error)
	OperateValidatorError(context.Context, *OperateValidationErrorRequest) (*OperateValidationErrorResponse, error)
	UpdateValidator(context.Context, *UpdateValidationWorkerRequest) (*CommonWorkerResponse, error)
}

WorkerServer is the server API for Worker service.

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.