dmpb

package
v0.0.0-...-a027a2a Latest Latest
Warning

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

 Go to latest Published: Jan 26, 2022 License: Apache-2.0 Imports: 16 Imported by: 0

README

This package is imported from DM.

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",
}
View Source 
var CfgType_value = map[string]int32{
	"InvalidType": 0,
	"TaskType":    1,
	"MasterType":  2,
	"WorkerType":  3,
	"SourceType":  4,
}
View Source 
var ErrorOp_name = map[int32]string{
	0: "InvalidErrorOp",
	1: "Skip",
	2: "Replace",
	3: "Revert",
}
View Source 
var ErrorOp_value = map[string]int32{
	"InvalidErrorOp": 0,
	"Skip":           1,
	"Replace":        2,
	"Revert":         3,
}
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 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",
}
View Source 
var SchemaOp_value = map[string]int32{
	"InvalidSchemaOp": 0,
	"GetSchema":       1,
	"SetSchema":       2,
	"RemoveSchema":    3,
}
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",
}
View Source 
var Stage_value = map[string]int32{
	"InvalidStage": 0,
	"New":          1,
	"Running":      2,
	"Paused":       3,
	"Stopped":      4,
	"Finished":     5,
	"Pausing":      6,
	"Resuming":     7,
}
View Source 
var TaskOp_name = map[int32]string{
	0: "InvalidOp",
	1: "Stop",
	2: "Pause",
	3: "Resume",
	4: "Start",
	5: "Update",
	6: "AutoResume",
}
View Source 
var TaskOp_value = map[string]int32{
	"InvalidOp":  0,
	"Stop":       1,
	"Pause":      2,
	"Resume":     3,
	"Start":      4,
	"Update":     5,
	"AutoResume": 6,
}
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 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,
}

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.

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
)

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 CheckTaskRequest 

type CheckTaskRequest struct {
	Task string `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
}

func (*CheckTaskRequest) Descriptor 

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

func (*CheckTaskRequest) GetTask 

func (m *CheckTaskRequest) GetTask() string

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 {
}

DumpStatus represents status for dump unit add fields later

func (*DumpStatus) Descriptor 

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

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 ErrorOp 

type ErrorOp int32
const (
	ErrorOp_InvalidErrorOp ErrorOp = 0
	ErrorOp_Skip           ErrorOp = 1
	ErrorOp_Replace        ErrorOp = 2
	ErrorOp_Revert         ErrorOp = 3
)

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 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 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"`
}

LoadStatus represents status for load unit

func (*LoadStatus) Descriptor 

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

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

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

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 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"`
}

func (*OperateSchemaRequest) Descriptor 

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

func (*OperateSchemaRequest) GetDatabase 

func (m *OperateSchemaRequest) GetDatabase() string

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) 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"`
}

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

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

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 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"`
}

func (*OperateWorkerSchemaRequest) Descriptor 

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

func (*OperateWorkerSchemaRequest) GetDatabase 

func (m *OperateWorkerSchemaRequest) GetDatabase() string

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) 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"`
}

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

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 transfered from other stages
transfer to Running when initialize with no error

Running: indicates the sub task is processing 

transfered from New when created successfully
transfered from Paused when resuming is requested
transfer to Paused when error occured or requested from external
transfer to Stopped when requested from external
transfer to Finished when sub task processing completed (no Syncer used)

Paused: indicates the processing is paused, and can be resume from external request 

transfered from Running when error occured or requested from external
transfer to Running when resuming is requested from external
transfer to Stopped when requested from external

Stopped: indicates the processing is stopped, and can not be resume (or re-run) again 

transfered 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 

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

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"`
}

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

func (m *StartTaskRequest) GetTask() string

func (*StartTaskRequest) Marshal 

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

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"`
}

func (*StartTaskResponse) Descriptor 

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

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 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"`
}

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) 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      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"`
}

SyncStatus represents status for sync unit

func (*SyncStatus) Descriptor 

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

func (*SyncStatus) GetBinlogType 

func (m *SyncStatus) GetBinlogType() string

func (*SyncStatus) GetBlockingDDLs 

func (m *SyncStatus) GetBlockingDDLs() []string

func (*SyncStatus) GetMasterBinlog 

func (m *SyncStatus) GetMasterBinlog() string

func (*SyncStatus) GetMasterBinlogGtid 

func (m *SyncStatus) GetMasterBinlogGtid() string

func (*SyncStatus) GetRecentTps 

func (m *SyncStatus) GetRecentTps() 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) 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
)

func (TaskOp) EnumDescriptor 

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

func (TaskOp) String 

func (x TaskOp) String() string

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

func (*UnimplementedMasterServer) UnlockDDLLock(ctx context.Context, req *UnlockDDLLockRequest) (*UnlockDDLLockResponse, error)

func (*UnimplementedMasterServer) UpdateTask 

func (*UnimplementedMasterServer) UpdateTask(ctx context.Context, req *UpdateTaskRequest) (*UpdateTaskResponse, error)

type UnimplementedWorkerServer 

type UnimplementedWorkerServer struct {
}

UnimplementedWorkerServer can be embedded to have forward compatible implementations.

func (*UnimplementedWorkerServer) GetWorkerCfg 

func (*UnimplementedWorkerServer) GetWorkerCfg(ctx context.Context, req *GetWorkerCfgRequest) (*GetWorkerCfgResponse, 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) PurgeRelay 

func (*UnimplementedWorkerServer) PurgeRelay(ctx context.Context, req *PurgeRelayRequest) (*CommonWorkerResponse, error)

func (*UnimplementedWorkerServer) QueryStatus 

func (*UnimplementedWorkerServer) QueryStatus(ctx context.Context, req *QueryStatusRequest) (*QueryStatusResponse, 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 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"`
}

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

func (m *UnlockDDLLockRequest) GetForceRemove() bool

func (*UnlockDDLLockRequest) GetID 

func (m *UnlockDDLLockRequest) GetID() string

func (*UnlockDDLLockRequest) GetReplaceOwner 

func (m *UnlockDDLLockRequest) GetReplaceOwner() 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"`
}

func (*UpdateTaskResponse) Descriptor 

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

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 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 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 upstream table.
	// 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)
}

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 upstream table.
	// 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)
}

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.