pb

package
v1.0.7 Latest Latest
Warning

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

 Go to latest Published: Jun 21, 2021 License: Apache-2.0 Imports: 15 Imported by: 14

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")
)
View Source 
var (
	ErrInvalidLengthDmworker = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowDmworker   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthTracer = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTracer   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthTracerBase = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTracerBase   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthTracerSyncer = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTracerSyncer   = fmt.Errorf("proto: integer overflow")
)
View Source 
var ErrorType_name = map[int32]string{
	0: "UnknownError",
	1: "ExecSQL",
	2: "CheckFailed",
}
View Source 
var ErrorType_value = map[string]int32{
	"UnknownError": 0,
	"ExecSQL":      1,
	"CheckFailed":  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 SQLOp_name = map[int32]string{
	0: "SKIP",
	1: "REPLACE",
	2: "INJECT",
}
View Source 
var SQLOp_value = map[string]int32{
	"SKIP":    0,
	"REPLACE": 1,
	"INJECT":  2,
}
View Source 
var Stage_name = map[int32]string{
	0: "InvalidStage",
	1: "New",
	2: "Running",
	3: "Paused",
	4: "Stopped",
	5: "Finished",
}
View Source 
var Stage_value = map[string]int32{
	"InvalidStage": 0,
	"New":          1,
	"Running":      2,
	"Paused":       3,
	"Stopped":      4,
	"Finished":     5,
}
View Source 
var SyncerJobState_name = map[int32]string{
	0: "init",
	1: "queued",
	2: "success",
	3: "error",
}
View Source 
var SyncerJobState_value = map[string]int32{
	"init":    0,
	"queued":  1,
	"success": 2,
	"error":   3,
}
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 TraceType_name = map[int32]string{
	0: "DummyEvent",
	1: "BinlogEvent",
	2: "JobEvent",
}
View Source 
var TraceType_value = map[string]int32{
	"DummyEvent":  0,
	"BinlogEvent": 1,
	"JobEvent":    2,
}
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,
}

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 RegisterMasterServer 

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

func RegisterTracerServer 

func RegisterTracerServer(s *grpc.Server, srv TracerServer)

func RegisterWorkerServer 

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

Types

type BaseEvent 

type BaseEvent struct {
	Filename string    `protobuf:"bytes,1,opt,name=filename,proto3" json:"filename,omitempty"`
	Line     int32     `protobuf:"varint,2,opt,name=line,proto3" json:"line,omitempty"`
	Tso      int64     `protobuf:"varint,3,opt,name=tso,proto3" json:"tso,omitempty"`
	TraceID  string    `protobuf:"bytes,4,opt,name=traceID,proto3" json:"traceID,omitempty"`
	GroupID  string    `protobuf:"bytes,5,opt,name=groupID,proto3" json:"groupID,omitempty"`
	Type     TraceType `protobuf:"varint,6,opt,name=type,proto3,enum=pb.TraceType" json:"type,omitempty"`
}

func (*BaseEvent) Descriptor 

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

func (*BaseEvent) GetFilename 

func (m *BaseEvent) GetFilename() string

func (*BaseEvent) GetGroupID 

func (m *BaseEvent) GetGroupID() string

func (*BaseEvent) GetLine 

func (m *BaseEvent) GetLine() int32

func (*BaseEvent) GetTraceID 

func (m *BaseEvent) GetTraceID() string

func (*BaseEvent) GetTso 

func (m *BaseEvent) GetTso() int64

func (*BaseEvent) GetType 

func (m *BaseEvent) GetType() TraceType

func (*BaseEvent) Marshal 

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

func (*BaseEvent) MarshalTo 

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

func (*BaseEvent) ProtoMessage 

func (*BaseEvent) ProtoMessage()

func (*BaseEvent) Reset 

func (m *BaseEvent) Reset()

func (*BaseEvent) Size 

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

func (*BaseEvent) String 

func (m *BaseEvent) String() string

func (*BaseEvent) Unmarshal 

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

func (*BaseEvent) XXX_DiscardUnknown 

func (m *BaseEvent) XXX_DiscardUnknown()

func (*BaseEvent) XXX_Marshal 

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

func (*BaseEvent) XXX_Merge 

func (dst *BaseEvent) XXX_Merge(src proto.Message)

func (*BaseEvent) XXX_Size 

func (m *BaseEvent) XXX_Size() int

func (*BaseEvent) XXX_Unmarshal 

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

type BreakDDLLockRequest 

type BreakDDLLockRequest struct {
	Task         string `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	RemoveLockID string `protobuf:"bytes,2,opt,name=removeLockID,proto3" json:"removeLockID,omitempty"`
	ExecDDL      bool   `protobuf:"varint,3,opt,name=execDDL,proto3" json:"execDDL,omitempty"`
	SkipDDL      bool   `protobuf:"varint,4,opt,name=skipDDL,proto3" json:"skipDDL,omitempty"`
}

BreakDDLLockRequest represents a request for a dm-worker to force to break the DDL lock task: sub task's name removeLockID: DDLLockInfo's ID which need to remove execDDL: execute DDL which is blocking skipDDL: skip DDL which is blocking execDDL and skipDDL can not specify both at the same time, but can specify neither

func (*BreakDDLLockRequest) Descriptor 

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

func (*BreakDDLLockRequest) GetExecDDL 

func (m *BreakDDLLockRequest) GetExecDDL() bool

func (*BreakDDLLockRequest) GetRemoveLockID 

func (m *BreakDDLLockRequest) GetRemoveLockID() string

func (*BreakDDLLockRequest) GetSkipDDL 

func (m *BreakDDLLockRequest) GetSkipDDL() bool

func (*BreakDDLLockRequest) GetTask 

func (m *BreakDDLLockRequest) GetTask() string

func (*BreakDDLLockRequest) Marshal 

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

func (*BreakDDLLockRequest) MarshalTo 

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

func (*BreakDDLLockRequest) ProtoMessage 

func (*BreakDDLLockRequest) ProtoMessage()

func (*BreakDDLLockRequest) Reset 

func (m *BreakDDLLockRequest) Reset()

func (*BreakDDLLockRequest) Size 

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

func (*BreakDDLLockRequest) String 

func (m *BreakDDLLockRequest) String() string

func (*BreakDDLLockRequest) Unmarshal 

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

func (*BreakDDLLockRequest) XXX_DiscardUnknown 

func (m *BreakDDLLockRequest) XXX_DiscardUnknown()

func (*BreakDDLLockRequest) XXX_Marshal 

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

func (*BreakDDLLockRequest) XXX_Merge 

func (dst *BreakDDLLockRequest) XXX_Merge(src proto.Message)

func (*BreakDDLLockRequest) XXX_Size 

func (m *BreakDDLLockRequest) XXX_Size() int

func (*BreakDDLLockRequest) XXX_Unmarshal 

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

type BreakWorkerDDLLockRequest 

type BreakWorkerDDLLockRequest struct {
	Workers      []string `protobuf:"bytes,1,rep,name=workers" json:"workers,omitempty"`
	Task         string   `protobuf:"bytes,2,opt,name=task,proto3" json:"task,omitempty"`
	RemoveLockID string   `protobuf:"bytes,3,opt,name=removeLockID,proto3" json:"removeLockID,omitempty"`
	ExecDDL      bool     `protobuf:"varint,4,opt,name=execDDL,proto3" json:"execDDL,omitempty"`
	SkipDDL      bool     `protobuf:"varint,5,opt,name=skipDDL,proto3" json:"skipDDL,omitempty"`
}

BreakWorkerDDLLockRequest represents a request for some dm-workers to force to break the DDL lock workers: dm-workers need to break DDL lock task: sub task's name removeLockID: DDLLockInfo's ID which need to remove execDDL: execute DDL which is blocking skipDDL: skip DDL which is blocking 

execDDL and skipDDL can not specify both at the same time, but can specify neither

func (*BreakWorkerDDLLockRequest) Descriptor 

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

func (*BreakWorkerDDLLockRequest) GetExecDDL 

func (m *BreakWorkerDDLLockRequest) GetExecDDL() bool

func (*BreakWorkerDDLLockRequest) GetRemoveLockID 

func (m *BreakWorkerDDLLockRequest) GetRemoveLockID() string

func (*BreakWorkerDDLLockRequest) GetSkipDDL 

func (m *BreakWorkerDDLLockRequest) GetSkipDDL() bool

func (*BreakWorkerDDLLockRequest) GetTask 

func (m *BreakWorkerDDLLockRequest) GetTask() string

func (*BreakWorkerDDLLockRequest) GetWorkers 

func (m *BreakWorkerDDLLockRequest) GetWorkers() []string

func (*BreakWorkerDDLLockRequest) Marshal 

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

func (*BreakWorkerDDLLockRequest) MarshalTo 

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

func (*BreakWorkerDDLLockRequest) ProtoMessage 

func (*BreakWorkerDDLLockRequest) ProtoMessage()

func (*BreakWorkerDDLLockRequest) Reset 

func (m *BreakWorkerDDLLockRequest) Reset()

func (*BreakWorkerDDLLockRequest) Size 

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

func (*BreakWorkerDDLLockRequest) String 

func (m *BreakWorkerDDLLockRequest) String() string

func (*BreakWorkerDDLLockRequest) Unmarshal 

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

func (*BreakWorkerDDLLockRequest) XXX_DiscardUnknown added in v1.0.2 

func (m *BreakWorkerDDLLockRequest) XXX_DiscardUnknown()

func (*BreakWorkerDDLLockRequest) XXX_Marshal added in v1.0.2 

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

func (*BreakWorkerDDLLockRequest) XXX_Merge added in v1.0.2 

func (dst *BreakWorkerDDLLockRequest) XXX_Merge(src proto.Message)

func (*BreakWorkerDDLLockRequest) XXX_Size added in v1.0.2 

func (m *BreakWorkerDDLLockRequest) XXX_Size() int

func (*BreakWorkerDDLLockRequest) XXX_Unmarshal added in v1.0.2 

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

type BreakWorkerDDLLockResponse 

type BreakWorkerDDLLockResponse 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"`
	Workers []*CommonWorkerResponse `protobuf:"bytes,3,rep,name=workers" json:"workers,omitempty"`
}

func (*BreakWorkerDDLLockResponse) Descriptor 

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

func (*BreakWorkerDDLLockResponse) GetMsg 

func (m *BreakWorkerDDLLockResponse) GetMsg() string

func (*BreakWorkerDDLLockResponse) GetResult 

func (m *BreakWorkerDDLLockResponse) GetResult() bool

func (*BreakWorkerDDLLockResponse) GetWorkers 

func (m *BreakWorkerDDLLockResponse) GetWorkers() []*CommonWorkerResponse

func (*BreakWorkerDDLLockResponse) Marshal 

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

func (*BreakWorkerDDLLockResponse) MarshalTo 

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

func (*BreakWorkerDDLLockResponse) ProtoMessage 

func (*BreakWorkerDDLLockResponse) ProtoMessage()

func (*BreakWorkerDDLLockResponse) Reset 

func (m *BreakWorkerDDLLockResponse) Reset()

func (*BreakWorkerDDLLockResponse) Size 

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

func (*BreakWorkerDDLLockResponse) String 

func (m *BreakWorkerDDLLockResponse) String() string

func (*BreakWorkerDDLLockResponse) Unmarshal 

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

func (*BreakWorkerDDLLockResponse) XXX_DiscardUnknown added in v1.0.2 

func (m *BreakWorkerDDLLockResponse) XXX_DiscardUnknown()

func (*BreakWorkerDDLLockResponse) XXX_Marshal added in v1.0.2 

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

func (*BreakWorkerDDLLockResponse) XXX_Merge added in v1.0.2 

func (dst *BreakWorkerDDLLockResponse) XXX_Merge(src proto.Message)

func (*BreakWorkerDDLLockResponse) XXX_Size added in v1.0.2 

func (m *BreakWorkerDDLLockResponse) XXX_Size() int

func (*BreakWorkerDDLLockResponse) XXX_Unmarshal added in v1.0.2 

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

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) 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 (dst *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) 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 (dst *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) 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 added in v1.0.2 

func (m *CheckTaskRequest) XXX_DiscardUnknown()

func (*CheckTaskRequest) XXX_Marshal added in v1.0.2 

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

func (*CheckTaskRequest) XXX_Merge added in v1.0.2 

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

func (*CheckTaskRequest) XXX_Size added in v1.0.2 

func (m *CheckTaskRequest) XXX_Size() int

func (*CheckTaskRequest) XXX_Unmarshal added in v1.0.2 

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) 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 added in v1.0.2 

func (m *CheckTaskResponse) XXX_DiscardUnknown()

func (*CheckTaskResponse) XXX_Marshal added in v1.0.2 

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

func (*CheckTaskResponse) XXX_Merge added in v1.0.2 

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

func (*CheckTaskResponse) XXX_Size added in v1.0.2 

func (m *CheckTaskResponse) XXX_Size() int

func (*CheckTaskResponse) XXX_Unmarshal added in v1.0.2 

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

type CommonUploadResponse 

type CommonUploadResponse 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 (*CommonUploadResponse) Descriptor 

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

func (*CommonUploadResponse) GetMsg 

func (m *CommonUploadResponse) GetMsg() string

func (*CommonUploadResponse) GetResult 

func (m *CommonUploadResponse) GetResult() bool

func (*CommonUploadResponse) Marshal 

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

func (*CommonUploadResponse) MarshalTo 

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

func (*CommonUploadResponse) ProtoMessage 

func (*CommonUploadResponse) ProtoMessage()

func (*CommonUploadResponse) Reset 

func (m *CommonUploadResponse) Reset()

func (*CommonUploadResponse) Size 

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

func (*CommonUploadResponse) String 

func (m *CommonUploadResponse) String() string

func (*CommonUploadResponse) Unmarshal 

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

func (*CommonUploadResponse) XXX_DiscardUnknown 

func (m *CommonUploadResponse) XXX_DiscardUnknown()

func (*CommonUploadResponse) XXX_Marshal 

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

func (*CommonUploadResponse) XXX_Merge 

func (dst *CommonUploadResponse) XXX_Merge(src proto.Message)

func (*CommonUploadResponse) XXX_Size 

func (m *CommonUploadResponse) XXX_Size() int

func (*CommonUploadResponse) XXX_Unmarshal 

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

type CommonWorkerResponse 

type CommonWorkerResponse struct {
	Result bool   `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"`
	Worker string `protobuf:"bytes,2,opt,name=worker,proto3" json:"worker,omitempty"`
	Msg    string `protobuf:"bytes,3,opt,name=msg,proto3" json:"msg,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) 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) 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 (dst *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 DDLInfo 

type DDLInfo struct {
	Task   string   `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	Schema string   `protobuf:"bytes,2,opt,name=schema,proto3" json:"schema,omitempty"`
	Table  string   `protobuf:"bytes,3,opt,name=table,proto3" json:"table,omitempty"`
	DDLs   []string `protobuf:"bytes,4,rep,name=DDLs" json:"DDLs,omitempty"`
}

DDLInfo represents a occurred DDL in a sub task it been sent from dm-worker to dm-master dm-master uses it to contruct a DDL lock and do syncing with other dm-workers add more fields if needed

func (*DDLInfo) Descriptor 

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

func (*DDLInfo) GetDDLs 

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

func (*DDLInfo) GetSchema 

func (m *DDLInfo) GetSchema() string

func (*DDLInfo) GetTable 

func (m *DDLInfo) GetTable() string

func (*DDLInfo) GetTask 

func (m *DDLInfo) GetTask() string

func (*DDLInfo) Marshal 

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

func (*DDLInfo) MarshalTo 

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

func (*DDLInfo) ProtoMessage 

func (*DDLInfo) ProtoMessage()

func (*DDLInfo) Reset 

func (m *DDLInfo) Reset()

func (*DDLInfo) Size 

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

func (*DDLInfo) String 

func (m *DDLInfo) String() string

func (*DDLInfo) Unmarshal 

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

func (*DDLInfo) XXX_DiscardUnknown 

func (m *DDLInfo) XXX_DiscardUnknown()

func (*DDLInfo) XXX_Marshal 

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

func (*DDLInfo) XXX_Merge 

func (dst *DDLInfo) XXX_Merge(src proto.Message)

func (*DDLInfo) XXX_Size 

func (m *DDLInfo) XXX_Size() int

func (*DDLInfo) XXX_Unmarshal 

func (m *DDLInfo) 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"`
	Owner    string   `protobuf:"bytes,3,opt,name=owner,proto3" json:"owner,omitempty"`
	DDLs     []string `protobuf:"bytes,4,rep,name=DDLs" json:"DDLs,omitempty"`
	Synced   []string `protobuf:"bytes,5,rep,name=synced" json:"synced,omitempty"`
	Unsynced []string `protobuf:"bytes,6,rep,name=unsynced" 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 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) 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) 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 added in v1.0.2 

func (m *DDLLock) XXX_DiscardUnknown()

func (*DDLLock) XXX_Marshal added in v1.0.2 

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

func (*DDLLock) XXX_Merge added in v1.0.2 

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

func (*DDLLock) XXX_Size added in v1.0.2 

func (m *DDLLock) XXX_Size() int

func (*DDLLock) XXX_Unmarshal added in v1.0.2 

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

type DDLLockInfo 

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

DDLLockInfo represents a DDL lock it been sent from dm-master to dm-worker add more fields if needed

func (*DDLLockInfo) Descriptor 

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

func (*DDLLockInfo) GetID 

func (m *DDLLockInfo) GetID() string

func (*DDLLockInfo) GetTask 

func (m *DDLLockInfo) GetTask() string

func (*DDLLockInfo) Marshal 

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

func (*DDLLockInfo) MarshalTo 

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

func (*DDLLockInfo) ProtoMessage 

func (*DDLLockInfo) ProtoMessage()

func (*DDLLockInfo) Reset 

func (m *DDLLockInfo) Reset()

func (*DDLLockInfo) Size 

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

func (*DDLLockInfo) String 

func (m *DDLLockInfo) String() string

func (*DDLLockInfo) Unmarshal 

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

func (*DDLLockInfo) XXX_DiscardUnknown 

func (m *DDLLockInfo) XXX_DiscardUnknown()

func (*DDLLockInfo) XXX_Marshal 

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

func (*DDLLockInfo) XXX_Merge 

func (dst *DDLLockInfo) XXX_Merge(src proto.Message)

func (*DDLLockInfo) XXX_Size 

func (m *DDLLockInfo) XXX_Size() int

func (*DDLLockInfo) XXX_Unmarshal 

func (m *DDLLockInfo) 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) 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 (dst *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) 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 (dst *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 ErrorType 

type ErrorType int32

ErrorType represents type of error produced by a dm unit NOTE: add new if needed 

const (
	ErrorType_UnknownError ErrorType = 0
	ErrorType_ExecSQL      ErrorType = 1
	ErrorType_CheckFailed  ErrorType = 2
)

func (ErrorType) EnumDescriptor 

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

func (ErrorType) String 

func (x ErrorType) String() string

type ExecDDLInfo 

type ExecDDLInfo struct {
	LockID string `protobuf:"bytes,1,opt,name=lockID,proto3" json:"lockID,omitempty"`
	Exec   bool   `protobuf:"varint,2,opt,name=exec,proto3" json:"exec,omitempty"`
}

func (*ExecDDLInfo) Descriptor 

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

func (*ExecDDLInfo) GetExec 

func (m *ExecDDLInfo) GetExec() bool

func (*ExecDDLInfo) GetLockID 

func (m *ExecDDLInfo) GetLockID() string

func (*ExecDDLInfo) Marshal 

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

func (*ExecDDLInfo) MarshalTo 

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

func (*ExecDDLInfo) ProtoMessage 

func (*ExecDDLInfo) ProtoMessage()

func (*ExecDDLInfo) Reset 

func (m *ExecDDLInfo) Reset()

func (*ExecDDLInfo) Size 

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

func (*ExecDDLInfo) String 

func (m *ExecDDLInfo) String() string

func (*ExecDDLInfo) Unmarshal 

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

func (*ExecDDLInfo) XXX_DiscardUnknown 

func (m *ExecDDLInfo) XXX_DiscardUnknown()

func (*ExecDDLInfo) XXX_Marshal 

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

func (*ExecDDLInfo) XXX_Merge 

func (dst *ExecDDLInfo) XXX_Merge(src proto.Message)

func (*ExecDDLInfo) XXX_Size 

func (m *ExecDDLInfo) XXX_Size() int

func (*ExecDDLInfo) XXX_Unmarshal 

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

type ExecDDLRequest 

type ExecDDLRequest struct {
	Task     string   `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	LockID   string   `protobuf:"bytes,2,opt,name=lockID,proto3" json:"lockID,omitempty"`
	Exec     bool     `protobuf:"varint,3,opt,name=exec,proto3" json:"exec,omitempty"`
	TraceGID string   `protobuf:"bytes,4,opt,name=traceGID,proto3" json:"traceGID,omitempty"`
	DDLs     []string `protobuf:"bytes,5,rep,name=DDLs" json:"DDLs,omitempty"`
}

ExecDDLRequest represents a request for a dm-worker to execute (or ignore) a DDL

func (*ExecDDLRequest) Descriptor 

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

func (*ExecDDLRequest) GetDDLs added in v1.0.2 

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

func (*ExecDDLRequest) GetExec 

func (m *ExecDDLRequest) GetExec() bool

func (*ExecDDLRequest) GetLockID 

func (m *ExecDDLRequest) GetLockID() string

func (*ExecDDLRequest) GetTask 

func (m *ExecDDLRequest) GetTask() string

func (*ExecDDLRequest) GetTraceGID 

func (m *ExecDDLRequest) GetTraceGID() string

func (*ExecDDLRequest) Marshal 

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

func (*ExecDDLRequest) MarshalTo 

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

func (*ExecDDLRequest) ProtoMessage 

func (*ExecDDLRequest) ProtoMessage()

func (*ExecDDLRequest) Reset 

func (m *ExecDDLRequest) Reset()

func (*ExecDDLRequest) Size 

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

func (*ExecDDLRequest) String 

func (m *ExecDDLRequest) String() string

func (*ExecDDLRequest) Unmarshal 

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

func (*ExecDDLRequest) XXX_DiscardUnknown 

func (m *ExecDDLRequest) XXX_DiscardUnknown()

func (*ExecDDLRequest) XXX_Marshal 

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

func (*ExecDDLRequest) XXX_Merge 

func (dst *ExecDDLRequest) XXX_Merge(src proto.Message)

func (*ExecDDLRequest) XXX_Size 

func (m *ExecDDLRequest) XXX_Size() int

func (*ExecDDLRequest) XXX_Unmarshal 

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

type GetTSORequest 

type GetTSORequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
}

func (*GetTSORequest) Descriptor 

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

func (*GetTSORequest) GetId 

func (m *GetTSORequest) GetId() string

func (*GetTSORequest) Marshal 

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

func (*GetTSORequest) MarshalTo 

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

func (*GetTSORequest) ProtoMessage 

func (*GetTSORequest) ProtoMessage()

func (*GetTSORequest) Reset 

func (m *GetTSORequest) Reset()

func (*GetTSORequest) Size 

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

func (*GetTSORequest) String 

func (m *GetTSORequest) String() string

func (*GetTSORequest) Unmarshal 

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

func (*GetTSORequest) XXX_DiscardUnknown 

func (m *GetTSORequest) XXX_DiscardUnknown()

func (*GetTSORequest) XXX_Marshal 

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

func (*GetTSORequest) XXX_Merge 

func (dst *GetTSORequest) XXX_Merge(src proto.Message)

func (*GetTSORequest) XXX_Size 

func (m *GetTSORequest) XXX_Size() int

func (*GetTSORequest) XXX_Unmarshal 

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

type GetTSOResponse 

type GetTSOResponse 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"`
	Ts     int64  `protobuf:"varint,3,opt,name=ts,proto3" json:"ts,omitempty"`
}

func (*GetTSOResponse) Descriptor 

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

func (*GetTSOResponse) GetMsg 

func (m *GetTSOResponse) GetMsg() string

func (*GetTSOResponse) GetResult 

func (m *GetTSOResponse) GetResult() bool

func (*GetTSOResponse) GetTs 

func (m *GetTSOResponse) GetTs() int64

func (*GetTSOResponse) Marshal 

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

func (*GetTSOResponse) MarshalTo 

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

func (*GetTSOResponse) ProtoMessage 

func (*GetTSOResponse) ProtoMessage()

func (*GetTSOResponse) Reset 

func (m *GetTSOResponse) Reset()

func (*GetTSOResponse) Size 

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

func (*GetTSOResponse) String 

func (m *GetTSOResponse) String() string

func (*GetTSOResponse) Unmarshal 

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

func (*GetTSOResponse) XXX_DiscardUnknown 

func (m *GetTSOResponse) XXX_DiscardUnknown()

func (*GetTSOResponse) XXX_Marshal 

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

func (*GetTSOResponse) XXX_Merge 

func (dst *GetTSOResponse) XXX_Merge(src proto.Message)

func (*GetTSOResponse) XXX_Size 

func (m *GetTSOResponse) XXX_Size() int

func (*GetTSOResponse) XXX_Unmarshal 

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

type HandleSQLsRequest 

type HandleSQLsRequest struct {
	Name       string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Op         SQLOp    `protobuf:"varint,2,opt,name=op,proto3,enum=pb.SQLOp" json:"op,omitempty"`
	Args       []string `protobuf:"bytes,3,rep,name=args" json:"args,omitempty"`
	BinlogPos  string   `protobuf:"bytes,4,opt,name=binlogPos,proto3" json:"binlogPos,omitempty"`
	Worker     string   `protobuf:"bytes,5,opt,name=worker,proto3" json:"worker,omitempty"`
	SqlPattern string   `protobuf:"bytes,6,opt,name=sqlPattern,proto3" json:"sqlPattern,omitempty"`
	Sharding   bool     `protobuf:"varint,7,opt,name=sharding,proto3" json:"sharding,omitempty"`
}

func (*HandleSQLsRequest) Descriptor 

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

func (*HandleSQLsRequest) GetArgs 

func (m *HandleSQLsRequest) GetArgs() []string

func (*HandleSQLsRequest) GetBinlogPos 

func (m *HandleSQLsRequest) GetBinlogPos() string

func (*HandleSQLsRequest) GetName 

func (m *HandleSQLsRequest) GetName() string

func (*HandleSQLsRequest) GetOp 

func (m *HandleSQLsRequest) GetOp() SQLOp

func (*HandleSQLsRequest) GetSharding 

func (m *HandleSQLsRequest) GetSharding() bool

func (*HandleSQLsRequest) GetSqlPattern 

func (m *HandleSQLsRequest) GetSqlPattern() string

func (*HandleSQLsRequest) GetWorker 

func (m *HandleSQLsRequest) GetWorker() string

func (*HandleSQLsRequest) Marshal 

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

func (*HandleSQLsRequest) MarshalTo 

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

func (*HandleSQLsRequest) ProtoMessage 

func (*HandleSQLsRequest) ProtoMessage()

func (*HandleSQLsRequest) Reset 

func (m *HandleSQLsRequest) Reset()

func (*HandleSQLsRequest) Size 

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

func (*HandleSQLsRequest) String 

func (m *HandleSQLsRequest) String() string

func (*HandleSQLsRequest) Unmarshal 

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

func (*HandleSQLsRequest) XXX_DiscardUnknown added in v1.0.2 

func (m *HandleSQLsRequest) XXX_DiscardUnknown()

func (*HandleSQLsRequest) XXX_Marshal added in v1.0.2 

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

func (*HandleSQLsRequest) XXX_Merge added in v1.0.2 

func (dst *HandleSQLsRequest) XXX_Merge(src proto.Message)

func (*HandleSQLsRequest) XXX_Size added in v1.0.2 

func (m *HandleSQLsRequest) XXX_Size() int

func (*HandleSQLsRequest) XXX_Unmarshal added in v1.0.2 

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

type HandleSQLsResponse 

type HandleSQLsResponse 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"`
	Workers []*CommonWorkerResponse `protobuf:"bytes,3,rep,name=workers" json:"workers,omitempty"`
}

func (*HandleSQLsResponse) Descriptor 

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

func (*HandleSQLsResponse) GetMsg 

func (m *HandleSQLsResponse) GetMsg() string

func (*HandleSQLsResponse) GetResult 

func (m *HandleSQLsResponse) GetResult() bool

func (*HandleSQLsResponse) GetWorkers 

func (m *HandleSQLsResponse) GetWorkers() []*CommonWorkerResponse

func (*HandleSQLsResponse) Marshal 

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

func (*HandleSQLsResponse) MarshalTo 

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

func (*HandleSQLsResponse) ProtoMessage 

func (*HandleSQLsResponse) ProtoMessage()

func (*HandleSQLsResponse) Reset 

func (m *HandleSQLsResponse) Reset()

func (*HandleSQLsResponse) Size 

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

func (*HandleSQLsResponse) String 

func (m *HandleSQLsResponse) String() string

func (*HandleSQLsResponse) Unmarshal 

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

func (*HandleSQLsResponse) XXX_DiscardUnknown added in v1.0.2 

func (m *HandleSQLsResponse) XXX_DiscardUnknown()

func (*HandleSQLsResponse) XXX_Marshal added in v1.0.2 

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

func (*HandleSQLsResponse) XXX_Merge added in v1.0.2 

func (dst *HandleSQLsResponse) XXX_Merge(src proto.Message)

func (*HandleSQLsResponse) XXX_Size added in v1.0.2 

func (m *HandleSQLsResponse) XXX_Size() int

func (*HandleSQLsResponse) XXX_Unmarshal added in v1.0.2 

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

type HandleSubTaskSQLsRequest 

type HandleSubTaskSQLsRequest struct {
	Name       string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Op         SQLOp    `protobuf:"varint,2,opt,name=op,proto3,enum=pb.SQLOp" json:"op,omitempty"`
	Args       []string `protobuf:"bytes,3,rep,name=args" json:"args,omitempty"`
	BinlogPos  string   `protobuf:"bytes,4,opt,name=binlogPos,proto3" json:"binlogPos,omitempty"`
	SqlPattern string   `protobuf:"bytes,5,opt,name=sqlPattern,proto3" json:"sqlPattern,omitempty"`
}

NOTE: we can extract some common(optional) arguments from `args`, like `meta`

func (*HandleSubTaskSQLsRequest) Descriptor 

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

func (*HandleSubTaskSQLsRequest) GetArgs 

func (m *HandleSubTaskSQLsRequest) GetArgs() []string

func (*HandleSubTaskSQLsRequest) GetBinlogPos 

func (m *HandleSubTaskSQLsRequest) GetBinlogPos() string

func (*HandleSubTaskSQLsRequest) GetName 

func (m *HandleSubTaskSQLsRequest) GetName() string

func (*HandleSubTaskSQLsRequest) GetOp 

func (m *HandleSubTaskSQLsRequest) GetOp() SQLOp

func (*HandleSubTaskSQLsRequest) GetSqlPattern 

func (m *HandleSubTaskSQLsRequest) GetSqlPattern() string

func (*HandleSubTaskSQLsRequest) Marshal 

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

func (*HandleSubTaskSQLsRequest) MarshalTo 

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

func (*HandleSubTaskSQLsRequest) ProtoMessage 

func (*HandleSubTaskSQLsRequest) ProtoMessage()

func (*HandleSubTaskSQLsRequest) Reset 

func (m *HandleSubTaskSQLsRequest) Reset()

func (*HandleSubTaskSQLsRequest) Size 

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

func (*HandleSubTaskSQLsRequest) String 

func (m *HandleSubTaskSQLsRequest) String() string

func (*HandleSubTaskSQLsRequest) Unmarshal 

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

func (*HandleSubTaskSQLsRequest) XXX_DiscardUnknown 

func (m *HandleSubTaskSQLsRequest) XXX_DiscardUnknown()

func (*HandleSubTaskSQLsRequest) XXX_Marshal 

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

func (*HandleSubTaskSQLsRequest) XXX_Merge 

func (dst *HandleSubTaskSQLsRequest) XXX_Merge(src proto.Message)

func (*HandleSubTaskSQLsRequest) XXX_Size 

func (m *HandleSubTaskSQLsRequest) XXX_Size() int

func (*HandleSubTaskSQLsRequest) XXX_Unmarshal 

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

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) 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) 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 (dst *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)
	QueryError(ctx context.Context, in *QueryErrorListRequest, opts ...grpc.CallOption) (*QueryErrorListResponse, 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)
	UpdateMasterConfig(ctx context.Context, in *UpdateMasterConfigRequest, opts ...grpc.CallOption) (*UpdateMasterConfigResponse, error)
	UpdateWorkerRelayConfig(ctx context.Context, in *UpdateWorkerRelayConfigRequest, opts ...grpc.CallOption) (*CommonWorkerResponse, error)
	// BreakDDLLock request some dm-workers to break a DDL lock
	// including remove DDLLockInfo and/or execute/skip DDL
	BreakWorkerDDLLock(ctx context.Context, in *BreakWorkerDDLLockRequest, opts ...grpc.CallOption) (*BreakWorkerDDLLockResponse, error)
	HandleSQLs(ctx context.Context, in *HandleSQLsRequest, opts ...grpc.CallOption) (*HandleSQLsResponse, error)
	// SwitchWorkerRelayMaster requests some dm-workers to switch relay unit's master server
	SwitchWorkerRelayMaster(ctx context.Context, in *SwitchWorkerRelayMasterRequest, opts ...grpc.CallOption) (*SwitchWorkerRelayMasterResponse, 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)
	// used by dmctl, to force refresh the task -> workers mapper
	// it should be used rarely only when task -> workers mapper corrupted
	RefreshWorkerTasks(ctx context.Context, in *RefreshWorkerTasksRequest, opts ...grpc.CallOption) (*RefreshWorkerTasksResponse, error)
	// MigrateRelay request migrate old dm-woker to a new one.
	MigrateWorkerRelay(ctx context.Context, in *MigrateWorkerRelayRequest, opts ...grpc.CallOption) (*CommonWorkerResponse, error)
	// CheckTask checks legality of task configuration
	CheckTask(ctx context.Context, in *CheckTaskRequest, opts ...grpc.CallOption) (*CheckTaskResponse, 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 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)
	QueryError(context.Context, *QueryErrorListRequest) (*QueryErrorListResponse, 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)
	UpdateMasterConfig(context.Context, *UpdateMasterConfigRequest) (*UpdateMasterConfigResponse, error)
	UpdateWorkerRelayConfig(context.Context, *UpdateWorkerRelayConfigRequest) (*CommonWorkerResponse, error)
	// BreakDDLLock request some dm-workers to break a DDL lock
	// including remove DDLLockInfo and/or execute/skip DDL
	BreakWorkerDDLLock(context.Context, *BreakWorkerDDLLockRequest) (*BreakWorkerDDLLockResponse, error)
	HandleSQLs(context.Context, *HandleSQLsRequest) (*HandleSQLsResponse, error)
	// SwitchWorkerRelayMaster requests some dm-workers to switch relay unit's master server
	SwitchWorkerRelayMaster(context.Context, *SwitchWorkerRelayMasterRequest) (*SwitchWorkerRelayMasterResponse, 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)
	// used by dmctl, to force refresh the task -> workers mapper
	// it should be used rarely only when task -> workers mapper corrupted
	RefreshWorkerTasks(context.Context, *RefreshWorkerTasksRequest) (*RefreshWorkerTasksResponse, error)
	// MigrateRelay request migrate old dm-woker to a new one.
	MigrateWorkerRelay(context.Context, *MigrateWorkerRelayRequest) (*CommonWorkerResponse, error)
	// CheckTask checks legality of task configuration
	CheckTask(context.Context, *CheckTaskRequest) (*CheckTaskResponse, error)
}

MasterServer is the server API for Master service.

type MigrateRelayRequest 

type MigrateRelayRequest struct {
	BinlogName string `protobuf:"bytes,1,opt,name=BinlogName,proto3" json:"BinlogName,omitempty"`
	BinlogPos  uint32 `protobuf:"varint,2,opt,name=BinlogPos,proto3" json:"BinlogPos,omitempty"`
}

func (*MigrateRelayRequest) Descriptor 

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

func (*MigrateRelayRequest) GetBinlogName 

func (m *MigrateRelayRequest) GetBinlogName() string

func (*MigrateRelayRequest) GetBinlogPos 

func (m *MigrateRelayRequest) GetBinlogPos() uint32

func (*MigrateRelayRequest) Marshal 

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

func (*MigrateRelayRequest) MarshalTo 

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

func (*MigrateRelayRequest) ProtoMessage 

func (*MigrateRelayRequest) ProtoMessage()

func (*MigrateRelayRequest) Reset 

func (m *MigrateRelayRequest) Reset()

func (*MigrateRelayRequest) Size 

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

func (*MigrateRelayRequest) String 

func (m *MigrateRelayRequest) String() string

func (*MigrateRelayRequest) Unmarshal 

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

func (*MigrateRelayRequest) XXX_DiscardUnknown 

func (m *MigrateRelayRequest) XXX_DiscardUnknown()

func (*MigrateRelayRequest) XXX_Marshal 

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

func (*MigrateRelayRequest) XXX_Merge 

func (dst *MigrateRelayRequest) XXX_Merge(src proto.Message)

func (*MigrateRelayRequest) XXX_Size 

func (m *MigrateRelayRequest) XXX_Size() int

func (*MigrateRelayRequest) XXX_Unmarshal 

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

type MigrateWorkerRelayRequest 

type MigrateWorkerRelayRequest struct {
	BinlogName string `protobuf:"bytes,1,opt,name=BinlogName,proto3" json:"BinlogName,omitempty"`
	BinlogPos  uint32 `protobuf:"varint,2,opt,name=BinlogPos,proto3" json:"BinlogPos,omitempty"`
	Worker     string `protobuf:"bytes,3,opt,name=worker,proto3" json:"worker,omitempty"`
}

func (*MigrateWorkerRelayRequest) Descriptor 

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

func (*MigrateWorkerRelayRequest) GetBinlogName 

func (m *MigrateWorkerRelayRequest) GetBinlogName() string

func (*MigrateWorkerRelayRequest) GetBinlogPos 

func (m *MigrateWorkerRelayRequest) GetBinlogPos() uint32

func (*MigrateWorkerRelayRequest) GetWorker 

func (m *MigrateWorkerRelayRequest) GetWorker() string

func (*MigrateWorkerRelayRequest) Marshal 

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

func (*MigrateWorkerRelayRequest) MarshalTo 

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

func (*MigrateWorkerRelayRequest) ProtoMessage 

func (*MigrateWorkerRelayRequest) ProtoMessage()

func (*MigrateWorkerRelayRequest) Reset 

func (m *MigrateWorkerRelayRequest) Reset()

func (*MigrateWorkerRelayRequest) Size 

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

func (*MigrateWorkerRelayRequest) String 

func (m *MigrateWorkerRelayRequest) String() string

func (*MigrateWorkerRelayRequest) Unmarshal 

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

func (*MigrateWorkerRelayRequest) XXX_DiscardUnknown added in v1.0.2 

func (m *MigrateWorkerRelayRequest) XXX_DiscardUnknown()

func (*MigrateWorkerRelayRequest) XXX_Marshal added in v1.0.2 

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

func (*MigrateWorkerRelayRequest) XXX_Merge added in v1.0.2 

func (dst *MigrateWorkerRelayRequest) XXX_Merge(src proto.Message)

func (*MigrateWorkerRelayRequest) XXX_Size added in v1.0.2 

func (m *MigrateWorkerRelayRequest) XXX_Size() int

func (*MigrateWorkerRelayRequest) XXX_Unmarshal added in v1.0.2 

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

type MySQLPosition 

type MySQLPosition struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Pos  uint32 `protobuf:"varint,2,opt,name=pos,proto3" json:"pos,omitempty"`
}

func (*MySQLPosition) Descriptor 

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

func (*MySQLPosition) GetName 

func (m *MySQLPosition) GetName() string

func (*MySQLPosition) GetPos 

func (m *MySQLPosition) GetPos() uint32

func (*MySQLPosition) Marshal 

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

func (*MySQLPosition) MarshalTo 

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

func (*MySQLPosition) ProtoMessage 

func (*MySQLPosition) ProtoMessage()

func (*MySQLPosition) Reset 

func (m *MySQLPosition) Reset()

func (*MySQLPosition) Size 

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

func (*MySQLPosition) String 

func (m *MySQLPosition) String() string

func (*MySQLPosition) Unmarshal 

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

func (*MySQLPosition) XXX_DiscardUnknown 

func (m *MySQLPosition) XXX_DiscardUnknown()

func (*MySQLPosition) XXX_Marshal 

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

func (*MySQLPosition) XXX_Merge 

func (dst *MySQLPosition) XXX_Merge(src proto.Message)

func (*MySQLPosition) XXX_Size 

func (m *MySQLPosition) XXX_Size() int

func (*MySQLPosition) XXX_Unmarshal 

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

type OperateRelayRequest 

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

OperateRelayRequest represents a request for operate relay unit

func (*OperateRelayRequest) Descriptor 

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

func (*OperateRelayRequest) GetOp 

func (m *OperateRelayRequest) GetOp() RelayOp

func (*OperateRelayRequest) Marshal 

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

func (*OperateRelayRequest) MarshalTo 

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

func (*OperateRelayRequest) ProtoMessage 

func (*OperateRelayRequest) ProtoMessage()

func (*OperateRelayRequest) Reset 

func (m *OperateRelayRequest) Reset()

func (*OperateRelayRequest) Size 

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

func (*OperateRelayRequest) String 

func (m *OperateRelayRequest) String() string

func (*OperateRelayRequest) Unmarshal 

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

func (*OperateRelayRequest) XXX_DiscardUnknown 

func (m *OperateRelayRequest) XXX_DiscardUnknown()

func (*OperateRelayRequest) XXX_Marshal 

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

func (*OperateRelayRequest) XXX_Merge 

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

func (*OperateRelayRequest) XXX_Size 

func (m *OperateRelayRequest) XXX_Size() int

func (*OperateRelayRequest) XXX_Unmarshal 

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

type OperateRelayResponse 

type OperateRelayResponse struct {
	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"`
	Worker string  `protobuf:"bytes,3,opt,name=worker,proto3" json:"worker,omitempty"`
	Msg    string  `protobuf:"bytes,4,opt,name=msg,proto3" json:"msg,omitempty"`
}

func (*OperateRelayResponse) Descriptor 

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

func (*OperateRelayResponse) GetMsg 

func (m *OperateRelayResponse) GetMsg() string

func (*OperateRelayResponse) GetOp 

func (m *OperateRelayResponse) GetOp() RelayOp

func (*OperateRelayResponse) GetResult 

func (m *OperateRelayResponse) GetResult() bool

func (*OperateRelayResponse) GetWorker 

func (m *OperateRelayResponse) GetWorker() string

func (*OperateRelayResponse) Marshal 

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

func (*OperateRelayResponse) MarshalTo 

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

func (*OperateRelayResponse) ProtoMessage 

func (*OperateRelayResponse) ProtoMessage()

func (*OperateRelayResponse) Reset 

func (m *OperateRelayResponse) Reset()

func (*OperateRelayResponse) Size 

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

func (*OperateRelayResponse) String 

func (m *OperateRelayResponse) String() string

func (*OperateRelayResponse) Unmarshal 

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

func (*OperateRelayResponse) XXX_DiscardUnknown 

func (m *OperateRelayResponse) XXX_DiscardUnknown()

func (*OperateRelayResponse) XXX_Marshal 

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

func (*OperateRelayResponse) XXX_Merge 

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

func (*OperateRelayResponse) XXX_Size 

func (m *OperateRelayResponse) XXX_Size() int

func (*OperateRelayResponse) XXX_Unmarshal 

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

type OperateSubTaskRequest 

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

func (*OperateSubTaskRequest) Descriptor 

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

func (*OperateSubTaskRequest) GetName 

func (m *OperateSubTaskRequest) GetName() string

func (*OperateSubTaskRequest) GetOp 

func (m *OperateSubTaskRequest) GetOp() TaskOp

func (*OperateSubTaskRequest) Marshal 

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

func (*OperateSubTaskRequest) MarshalTo 

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

func (*OperateSubTaskRequest) ProtoMessage 

func (*OperateSubTaskRequest) ProtoMessage()

func (*OperateSubTaskRequest) Reset 

func (m *OperateSubTaskRequest) Reset()

func (*OperateSubTaskRequest) Size 

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

func (*OperateSubTaskRequest) String 

func (m *OperateSubTaskRequest) String() string

func (*OperateSubTaskRequest) Unmarshal 

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

func (*OperateSubTaskRequest) XXX_DiscardUnknown 

func (m *OperateSubTaskRequest) XXX_DiscardUnknown()

func (*OperateSubTaskRequest) XXX_Marshal 

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

func (*OperateSubTaskRequest) XXX_Merge 

func (dst *OperateSubTaskRequest) XXX_Merge(src proto.Message)

func (*OperateSubTaskRequest) XXX_Size 

func (m *OperateSubTaskRequest) XXX_Size() int

func (*OperateSubTaskRequest) XXX_Unmarshal 

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

type OperateSubTaskResponse 

type OperateSubTaskResponse struct {
	Meta  *CommonWorkerResponse `protobuf:"bytes,1,opt,name=meta" json:"meta,omitempty"`
	Op    TaskOp                `protobuf:"varint,2,opt,name=op,proto3,enum=pb.TaskOp" json:"op,omitempty"`
	LogID int64                 `protobuf:"varint,3,opt,name=logID,proto3" json:"logID,omitempty"`
}

func (*OperateSubTaskResponse) Descriptor 

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

func (*OperateSubTaskResponse) GetLogID 

func (m *OperateSubTaskResponse) GetLogID() int64

func (*OperateSubTaskResponse) GetMeta 

func (m *OperateSubTaskResponse) GetMeta() *CommonWorkerResponse

func (*OperateSubTaskResponse) GetOp 

func (m *OperateSubTaskResponse) GetOp() TaskOp

func (*OperateSubTaskResponse) Marshal 

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

func (*OperateSubTaskResponse) MarshalTo 

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

func (*OperateSubTaskResponse) ProtoMessage 

func (*OperateSubTaskResponse) ProtoMessage()

func (*OperateSubTaskResponse) Reset 

func (m *OperateSubTaskResponse) Reset()

func (*OperateSubTaskResponse) Size 

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

func (*OperateSubTaskResponse) String 

func (m *OperateSubTaskResponse) String() string

func (*OperateSubTaskResponse) Unmarshal 

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

func (*OperateSubTaskResponse) XXX_DiscardUnknown 

func (m *OperateSubTaskResponse) XXX_DiscardUnknown()

func (*OperateSubTaskResponse) XXX_Marshal 

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

func (*OperateSubTaskResponse) XXX_Merge 

func (dst *OperateSubTaskResponse) XXX_Merge(src proto.Message)

func (*OperateSubTaskResponse) XXX_Size 

func (m *OperateSubTaskResponse) XXX_Size() int

func (*OperateSubTaskResponse) XXX_Unmarshal 

func (m *OperateSubTaskResponse) 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"`
	Workers []string `protobuf:"bytes,3,rep,name=workers" json:"workers,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) GetWorkers 

func (m *OperateTaskRequest) GetWorkers() []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) 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 added in v1.0.2 

func (m *OperateTaskRequest) XXX_DiscardUnknown()

func (*OperateTaskRequest) XXX_Marshal added in v1.0.2 

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

func (*OperateTaskRequest) XXX_Merge added in v1.0.2 

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

func (*OperateTaskRequest) XXX_Size added in v1.0.2 

func (m *OperateTaskRequest) XXX_Size() int

func (*OperateTaskRequest) XXX_Unmarshal added in v1.0.2 

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"`
	Workers []*OperateSubTaskResponse `protobuf:"bytes,4,rep,name=workers" json:"workers,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) GetWorkers 

func (m *OperateTaskResponse) GetWorkers() []*OperateSubTaskResponse

func (*OperateTaskResponse) Marshal 

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

func (*OperateTaskResponse) MarshalTo 

func (m *OperateTaskResponse) MarshalTo(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 added in v1.0.2 

func (m *OperateTaskResponse) XXX_DiscardUnknown()

func (*OperateTaskResponse) XXX_Marshal added in v1.0.2 

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

func (*OperateTaskResponse) XXX_Merge added in v1.0.2 

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

func (*OperateTaskResponse) XXX_Size added in v1.0.2 

func (m *OperateTaskResponse) XXX_Size() int

func (*OperateTaskResponse) XXX_Unmarshal added in v1.0.2 

func (m *OperateTaskResponse) 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"`
	Workers []string `protobuf:"bytes,2,rep,name=workers" json:"workers,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) GetWorkers 

func (m *OperateWorkerRelayRequest) GetWorkers() []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) 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 added in v1.0.2 

func (m *OperateWorkerRelayRequest) XXX_DiscardUnknown()

func (*OperateWorkerRelayRequest) XXX_Marshal added in v1.0.2 

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

func (*OperateWorkerRelayRequest) XXX_Merge added in v1.0.2 

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

func (*OperateWorkerRelayRequest) XXX_Size added in v1.0.2 

func (m *OperateWorkerRelayRequest) XXX_Size() int

func (*OperateWorkerRelayRequest) XXX_Unmarshal added in v1.0.2 

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"`
	Workers []*OperateRelayResponse `protobuf:"bytes,4,rep,name=workers" json:"workers,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) GetWorkers 

func (m *OperateWorkerRelayResponse) GetWorkers() []*OperateRelayResponse

func (*OperateWorkerRelayResponse) Marshal 

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

func (*OperateWorkerRelayResponse) MarshalTo 

func (m *OperateWorkerRelayResponse) MarshalTo(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 added in v1.0.2 

func (m *OperateWorkerRelayResponse) XXX_DiscardUnknown()

func (*OperateWorkerRelayResponse) XXX_Marshal added in v1.0.2 

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

func (*OperateWorkerRelayResponse) XXX_Merge added in v1.0.2 

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

func (*OperateWorkerRelayResponse) XXX_Size added in v1.0.2 

func (m *OperateWorkerRelayResponse) XXX_Size() int

func (*OperateWorkerRelayResponse) XXX_Unmarshal added in v1.0.2 

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

type ProcessError 

type ProcessError struct {
	Type  ErrorType `protobuf:"varint,1,opt,name=Type,proto3,enum=pb.ErrorType" json:"Type,omitempty"`
	Msg   string    `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	Error *TError   `protobuf:"bytes,3,opt,name=error" json:"error,omitempty"`
}

ProcessError represents error produced by a dm unit NOTE: refine later, like add error scope field

func (*ProcessError) Descriptor 

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

func (*ProcessError) GetError added in v1.0.2 

func (m *ProcessError) GetError() *TError

func (*ProcessError) GetMsg 

func (m *ProcessError) GetMsg() string

func (*ProcessError) GetType 

func (m *ProcessError) GetType() ErrorType

func (*ProcessError) Marshal 

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

func (*ProcessError) MarshalTo 

func (m *ProcessError) MarshalTo(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 (dst *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" 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) 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 (dst *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) 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 (dst *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 {
	Workers  []string `protobuf:"bytes,1,rep,name=workers" json:"workers,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) GetSubDir 

func (m *PurgeWorkerRelayRequest) GetSubDir() string

func (*PurgeWorkerRelayRequest) GetTime 

func (m *PurgeWorkerRelayRequest) GetTime() int64

func (*PurgeWorkerRelayRequest) GetWorkers 

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

func (*PurgeWorkerRelayRequest) Marshal 

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

func (*PurgeWorkerRelayRequest) MarshalTo 

func (m *PurgeWorkerRelayRequest) MarshalTo(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 added in v1.0.2 

func (m *PurgeWorkerRelayRequest) XXX_DiscardUnknown()

func (*PurgeWorkerRelayRequest) XXX_Marshal added in v1.0.2 

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

func (*PurgeWorkerRelayRequest) XXX_Merge added in v1.0.2 

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

func (*PurgeWorkerRelayRequest) XXX_Size added in v1.0.2 

func (m *PurgeWorkerRelayRequest) XXX_Size() int

func (*PurgeWorkerRelayRequest) XXX_Unmarshal added in v1.0.2 

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"`
	Workers []*CommonWorkerResponse `protobuf:"bytes,3,rep,name=workers" json:"workers,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) GetWorkers 

func (m *PurgeWorkerRelayResponse) GetWorkers() []*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) 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 added in v1.0.2 

func (m *PurgeWorkerRelayResponse) XXX_DiscardUnknown()

func (*PurgeWorkerRelayResponse) XXX_Marshal added in v1.0.2 

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

func (*PurgeWorkerRelayResponse) XXX_Merge added in v1.0.2 

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

func (*PurgeWorkerRelayResponse) XXX_Size added in v1.0.2 

func (m *PurgeWorkerRelayResponse) XXX_Size() int

func (*PurgeWorkerRelayResponse) XXX_Unmarshal added in v1.0.2 

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

type QueryErrorListRequest 

type QueryErrorListRequest struct {
	Name    string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Workers []string `protobuf:"bytes,2,rep,name=workers" json:"workers,omitempty"`
}

func (*QueryErrorListRequest) Descriptor 

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

func (*QueryErrorListRequest) GetName 

func (m *QueryErrorListRequest) GetName() string

func (*QueryErrorListRequest) GetWorkers 

func (m *QueryErrorListRequest) GetWorkers() []string

func (*QueryErrorListRequest) Marshal 

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

func (*QueryErrorListRequest) MarshalTo 

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

func (*QueryErrorListRequest) ProtoMessage 

func (*QueryErrorListRequest) ProtoMessage()

func (*QueryErrorListRequest) Reset 

func (m *QueryErrorListRequest) Reset()

func (*QueryErrorListRequest) Size 

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

func (*QueryErrorListRequest) String 

func (m *QueryErrorListRequest) String() string

func (*QueryErrorListRequest) Unmarshal 

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

func (*QueryErrorListRequest) XXX_DiscardUnknown added in v1.0.2 

func (m *QueryErrorListRequest) XXX_DiscardUnknown()

func (*QueryErrorListRequest) XXX_Marshal added in v1.0.2 

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

func (*QueryErrorListRequest) XXX_Merge added in v1.0.2 

func (dst *QueryErrorListRequest) XXX_Merge(src proto.Message)

func (*QueryErrorListRequest) XXX_Size added in v1.0.2 

func (m *QueryErrorListRequest) XXX_Size() int

func (*QueryErrorListRequest) XXX_Unmarshal added in v1.0.2 

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

type QueryErrorListResponse 

type QueryErrorListResponse 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"`
	Workers []*QueryErrorResponse `protobuf:"bytes,3,rep,name=workers" json:"workers,omitempty"`
}

func (*QueryErrorListResponse) Descriptor 

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

func (*QueryErrorListResponse) GetMsg 

func (m *QueryErrorListResponse) GetMsg() string

func (*QueryErrorListResponse) GetResult 

func (m *QueryErrorListResponse) GetResult() bool

func (*QueryErrorListResponse) GetWorkers 

func (m *QueryErrorListResponse) GetWorkers() []*QueryErrorResponse

func (*QueryErrorListResponse) Marshal 

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

func (*QueryErrorListResponse) MarshalTo 

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

func (*QueryErrorListResponse) ProtoMessage 

func (*QueryErrorListResponse) ProtoMessage()

func (*QueryErrorListResponse) Reset 

func (m *QueryErrorListResponse) Reset()

func (*QueryErrorListResponse) Size 

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

func (*QueryErrorListResponse) String 

func (m *QueryErrorListResponse) String() string

func (*QueryErrorListResponse) Unmarshal 

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

func (*QueryErrorListResponse) XXX_DiscardUnknown added in v1.0.2 

func (m *QueryErrorListResponse) XXX_DiscardUnknown()

func (*QueryErrorListResponse) XXX_Marshal added in v1.0.2 

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

func (*QueryErrorListResponse) XXX_Merge added in v1.0.2 

func (dst *QueryErrorListResponse) XXX_Merge(src proto.Message)

func (*QueryErrorListResponse) XXX_Size added in v1.0.2 

func (m *QueryErrorListResponse) XXX_Size() int

func (*QueryErrorListResponse) XXX_Unmarshal added in v1.0.2 

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

type QueryErrorRequest 

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

func (*QueryErrorRequest) Descriptor 

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

func (*QueryErrorRequest) GetName 

func (m *QueryErrorRequest) GetName() string

func (*QueryErrorRequest) Marshal 

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

func (*QueryErrorRequest) MarshalTo 

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

func (*QueryErrorRequest) ProtoMessage 

func (*QueryErrorRequest) ProtoMessage()

func (*QueryErrorRequest) Reset 

func (m *QueryErrorRequest) Reset()

func (*QueryErrorRequest) Size 

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

func (*QueryErrorRequest) String 

func (m *QueryErrorRequest) String() string

func (*QueryErrorRequest) Unmarshal 

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

func (*QueryErrorRequest) XXX_DiscardUnknown 

func (m *QueryErrorRequest) XXX_DiscardUnknown()

func (*QueryErrorRequest) XXX_Marshal 

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

func (*QueryErrorRequest) XXX_Merge 

func (dst *QueryErrorRequest) XXX_Merge(src proto.Message)

func (*QueryErrorRequest) XXX_Size 

func (m *QueryErrorRequest) XXX_Size() int

func (*QueryErrorRequest) XXX_Unmarshal 

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

type QueryErrorResponse 

type QueryErrorResponse struct {
	Result       bool            `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"`
	Worker       string          `protobuf:"bytes,2,opt,name=worker,proto3" json:"worker,omitempty"`
	Msg          string          `protobuf:"bytes,3,opt,name=msg,proto3" json:"msg,omitempty"`
	SubTaskError []*SubTaskError `protobuf:"bytes,4,rep,name=subTaskError" json:"subTaskError,omitempty"`
	RelayError   *RelayError     `protobuf:"bytes,5,opt,name=RelayError" json:"RelayError,omitempty"`
}

QueryErrorResponse represents response for query on a dm-worker

func (*QueryErrorResponse) Descriptor 

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

func (*QueryErrorResponse) GetMsg 

func (m *QueryErrorResponse) GetMsg() string

func (*QueryErrorResponse) GetRelayError 

func (m *QueryErrorResponse) GetRelayError() *RelayError

func (*QueryErrorResponse) GetResult 

func (m *QueryErrorResponse) GetResult() bool

func (*QueryErrorResponse) GetSubTaskError 

func (m *QueryErrorResponse) GetSubTaskError() []*SubTaskError

func (*QueryErrorResponse) GetWorker 

func (m *QueryErrorResponse) GetWorker() string

func (*QueryErrorResponse) Marshal 

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

func (*QueryErrorResponse) MarshalTo 

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

func (*QueryErrorResponse) ProtoMessage 

func (*QueryErrorResponse) ProtoMessage()

func (*QueryErrorResponse) Reset 

func (m *QueryErrorResponse) Reset()

func (*QueryErrorResponse) Size 

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

func (*QueryErrorResponse) String 

func (m *QueryErrorResponse) String() string

func (*QueryErrorResponse) Unmarshal 

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

func (*QueryErrorResponse) XXX_DiscardUnknown 

func (m *QueryErrorResponse) XXX_DiscardUnknown()

func (*QueryErrorResponse) XXX_Marshal 

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

func (*QueryErrorResponse) XXX_Merge 

func (dst *QueryErrorResponse) XXX_Merge(src proto.Message)

func (*QueryErrorResponse) XXX_Size 

func (m *QueryErrorResponse) XXX_Size() int

func (*QueryErrorResponse) XXX_Unmarshal 

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

type QueryStatusListRequest 

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

func (*QueryStatusListRequest) Descriptor 

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

func (*QueryStatusListRequest) GetName 

func (m *QueryStatusListRequest) GetName() string

func (*QueryStatusListRequest) GetWorkers 

func (m *QueryStatusListRequest) GetWorkers() []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) 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 added in v1.0.2 

func (m *QueryStatusListRequest) XXX_DiscardUnknown()

func (*QueryStatusListRequest) XXX_Marshal added in v1.0.2 

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

func (*QueryStatusListRequest) XXX_Merge added in v1.0.2 

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

func (*QueryStatusListRequest) XXX_Size added in v1.0.2 

func (m *QueryStatusListRequest) XXX_Size() int

func (*QueryStatusListRequest) XXX_Unmarshal added in v1.0.2 

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"`
	Workers []*QueryStatusResponse `protobuf:"bytes,3,rep,name=workers" json:"workers,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) GetWorkers 

func (m *QueryStatusListResponse) GetWorkers() []*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) 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 added in v1.0.2 

func (m *QueryStatusListResponse) XXX_DiscardUnknown()

func (*QueryStatusListResponse) XXX_Marshal added in v1.0.2 

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

func (*QueryStatusListResponse) XXX_Merge added in v1.0.2 

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

func (*QueryStatusListResponse) XXX_Size added in v1.0.2 

func (m *QueryStatusListResponse) XXX_Size() int

func (*QueryStatusListResponse) XXX_Unmarshal added in v1.0.2 

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) 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 (dst *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"`
	Worker        string           `protobuf:"bytes,2,opt,name=worker,proto3" json:"worker,omitempty"`
	Msg           string           `protobuf:"bytes,3,opt,name=msg,proto3" json:"msg,omitempty"`
	SubTaskStatus []*SubTaskStatus `protobuf:"bytes,4,rep,name=subTaskStatus" json:"subTaskStatus,omitempty"`
	RelayStatus   *RelayStatus     `protobuf:"bytes,5,opt,name=relayStatus" json:"relayStatus,omitempty"`
	SourceID      string           `protobuf:"bytes,6,opt,name=sourceID,proto3" json:"sourceID,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) GetRelayStatus 

func (m *QueryStatusResponse) GetRelayStatus() *RelayStatus

func (*QueryStatusResponse) GetResult 

func (m *QueryStatusResponse) GetResult() bool

func (*QueryStatusResponse) GetSourceID 

func (m *QueryStatusResponse) GetSourceID() string

func (*QueryStatusResponse) GetSubTaskStatus 

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

func (*QueryStatusResponse) GetWorker 

func (m *QueryStatusResponse) GetWorker() string

func (*QueryStatusResponse) Marshal 

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

func (*QueryStatusResponse) MarshalTo 

func (m *QueryStatusResponse) MarshalTo(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 (dst *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 QueryTaskOperationRequest 

type QueryTaskOperationRequest struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	LogID int64  `protobuf:"varint,2,opt,name=logID,proto3" json:"logID,omitempty"`
}

func (*QueryTaskOperationRequest) Descriptor 

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

func (*QueryTaskOperationRequest) GetLogID 

func (m *QueryTaskOperationRequest) GetLogID() int64

func (*QueryTaskOperationRequest) GetName 

func (m *QueryTaskOperationRequest) GetName() string

func (*QueryTaskOperationRequest) Marshal 

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

func (*QueryTaskOperationRequest) MarshalTo 

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

func (*QueryTaskOperationRequest) ProtoMessage 

func (*QueryTaskOperationRequest) ProtoMessage()

func (*QueryTaskOperationRequest) Reset 

func (m *QueryTaskOperationRequest) Reset()

func (*QueryTaskOperationRequest) Size 

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

func (*QueryTaskOperationRequest) String 

func (m *QueryTaskOperationRequest) String() string

func (*QueryTaskOperationRequest) Unmarshal 

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

func (*QueryTaskOperationRequest) XXX_DiscardUnknown 

func (m *QueryTaskOperationRequest) XXX_DiscardUnknown()

func (*QueryTaskOperationRequest) XXX_Marshal 

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

func (*QueryTaskOperationRequest) XXX_Merge 

func (dst *QueryTaskOperationRequest) XXX_Merge(src proto.Message)

func (*QueryTaskOperationRequest) XXX_Size 

func (m *QueryTaskOperationRequest) XXX_Size() int

func (*QueryTaskOperationRequest) XXX_Unmarshal 

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

type QueryTaskOperationResponse 

type QueryTaskOperationResponse struct {
	Meta *CommonWorkerResponse `protobuf:"bytes,1,opt,name=meta" json:"meta,omitempty"`
	Log  *TaskLog              `protobuf:"bytes,2,opt,name=log" json:"log,omitempty"`
}

func (*QueryTaskOperationResponse) Descriptor 

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

func (*QueryTaskOperationResponse) GetLog 

func (m *QueryTaskOperationResponse) GetLog() *TaskLog

func (*QueryTaskOperationResponse) GetMeta 

func (m *QueryTaskOperationResponse) GetMeta() *CommonWorkerResponse

func (*QueryTaskOperationResponse) Marshal 

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

func (*QueryTaskOperationResponse) MarshalTo 

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

func (*QueryTaskOperationResponse) ProtoMessage 

func (*QueryTaskOperationResponse) ProtoMessage()

func (*QueryTaskOperationResponse) Reset 

func (m *QueryTaskOperationResponse) Reset()

func (*QueryTaskOperationResponse) Size 

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

func (*QueryTaskOperationResponse) String 

func (m *QueryTaskOperationResponse) String() string

func (*QueryTaskOperationResponse) Unmarshal 

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

func (*QueryTaskOperationResponse) XXX_DiscardUnknown 

func (m *QueryTaskOperationResponse) XXX_DiscardUnknown()

func (*QueryTaskOperationResponse) XXX_Marshal 

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

func (*QueryTaskOperationResponse) XXX_Merge 

func (dst *QueryTaskOperationResponse) XXX_Merge(src proto.Message)

func (*QueryTaskOperationResponse) XXX_Size 

func (m *QueryTaskOperationResponse) XXX_Size() int

func (*QueryTaskOperationResponse) XXX_Unmarshal 

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

type QueryWorkerConfigRequest 

type QueryWorkerConfigRequest struct {
}

func (*QueryWorkerConfigRequest) Descriptor 

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

func (*QueryWorkerConfigRequest) Marshal 

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

func (*QueryWorkerConfigRequest) MarshalTo 

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

func (*QueryWorkerConfigRequest) ProtoMessage 

func (*QueryWorkerConfigRequest) ProtoMessage()

func (*QueryWorkerConfigRequest) Reset 

func (m *QueryWorkerConfigRequest) Reset()

func (*QueryWorkerConfigRequest) Size 

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

func (*QueryWorkerConfigRequest) String 

func (m *QueryWorkerConfigRequest) String() string

func (*QueryWorkerConfigRequest) Unmarshal 

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

func (*QueryWorkerConfigRequest) XXX_DiscardUnknown 

func (m *QueryWorkerConfigRequest) XXX_DiscardUnknown()

func (*QueryWorkerConfigRequest) XXX_Marshal 

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

func (*QueryWorkerConfigRequest) XXX_Merge 

func (dst *QueryWorkerConfigRequest) XXX_Merge(src proto.Message)

func (*QueryWorkerConfigRequest) XXX_Size 

func (m *QueryWorkerConfigRequest) XXX_Size() int

func (*QueryWorkerConfigRequest) XXX_Unmarshal 

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

type QueryWorkerConfigResponse 

type QueryWorkerConfigResponse struct {
	Result   bool   `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"`
	Worker   string `protobuf:"bytes,2,opt,name=worker,proto3" json:"worker,omitempty"`
	Msg      string `protobuf:"bytes,3,opt,name=msg,proto3" json:"msg,omitempty"`
	SourceID string `protobuf:"bytes,4,opt,name=sourceID,proto3" json:"sourceID,omitempty"`
	Content  string `protobuf:"bytes,5,opt,name=content,proto3" json:"content,omitempty"`
}

func (*QueryWorkerConfigResponse) Descriptor 

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

func (*QueryWorkerConfigResponse) GetContent 

func (m *QueryWorkerConfigResponse) GetContent() string

func (*QueryWorkerConfigResponse) GetMsg 

func (m *QueryWorkerConfigResponse) GetMsg() string

func (*QueryWorkerConfigResponse) GetResult 

func (m *QueryWorkerConfigResponse) GetResult() bool

func (*QueryWorkerConfigResponse) GetSourceID 

func (m *QueryWorkerConfigResponse) GetSourceID() string

func (*QueryWorkerConfigResponse) GetWorker 

func (m *QueryWorkerConfigResponse) GetWorker() string

func (*QueryWorkerConfigResponse) Marshal 

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

func (*QueryWorkerConfigResponse) MarshalTo 

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

func (*QueryWorkerConfigResponse) ProtoMessage 

func (*QueryWorkerConfigResponse) ProtoMessage()

func (*QueryWorkerConfigResponse) Reset 

func (m *QueryWorkerConfigResponse) Reset()

func (*QueryWorkerConfigResponse) Size 

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

func (*QueryWorkerConfigResponse) String 

func (m *QueryWorkerConfigResponse) String() string

func (*QueryWorkerConfigResponse) Unmarshal 

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

func (*QueryWorkerConfigResponse) XXX_DiscardUnknown 

func (m *QueryWorkerConfigResponse) XXX_DiscardUnknown()

func (*QueryWorkerConfigResponse) XXX_Marshal 

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

func (*QueryWorkerConfigResponse) XXX_Merge 

func (dst *QueryWorkerConfigResponse) XXX_Merge(src proto.Message)

func (*QueryWorkerConfigResponse) XXX_Size 

func (m *QueryWorkerConfigResponse) XXX_Size() int

func (*QueryWorkerConfigResponse) XXX_Unmarshal 

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

type RefreshWorkerTasksMsg 

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

func (*RefreshWorkerTasksMsg) Descriptor 

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

func (*RefreshWorkerTasksMsg) GetMsg 

func (m *RefreshWorkerTasksMsg) GetMsg() string

func (*RefreshWorkerTasksMsg) GetWorker 

func (m *RefreshWorkerTasksMsg) GetWorker() string

func (*RefreshWorkerTasksMsg) Marshal 

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

func (*RefreshWorkerTasksMsg) MarshalTo 

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

func (*RefreshWorkerTasksMsg) ProtoMessage 

func (*RefreshWorkerTasksMsg) ProtoMessage()

func (*RefreshWorkerTasksMsg) Reset 

func (m *RefreshWorkerTasksMsg) Reset()

func (*RefreshWorkerTasksMsg) Size 

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

func (*RefreshWorkerTasksMsg) String 

func (m *RefreshWorkerTasksMsg) String() string

func (*RefreshWorkerTasksMsg) Unmarshal 

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

func (*RefreshWorkerTasksMsg) XXX_DiscardUnknown added in v1.0.2 

func (m *RefreshWorkerTasksMsg) XXX_DiscardUnknown()

func (*RefreshWorkerTasksMsg) XXX_Marshal added in v1.0.2 

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

func (*RefreshWorkerTasksMsg) XXX_Merge added in v1.0.2 

func (dst *RefreshWorkerTasksMsg) XXX_Merge(src proto.Message)

func (*RefreshWorkerTasksMsg) XXX_Size added in v1.0.2 

func (m *RefreshWorkerTasksMsg) XXX_Size() int

func (*RefreshWorkerTasksMsg) XXX_Unmarshal added in v1.0.2 

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

type RefreshWorkerTasksRequest 

type RefreshWorkerTasksRequest struct {
}

func (*RefreshWorkerTasksRequest) Descriptor 

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

func (*RefreshWorkerTasksRequest) Marshal 

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

func (*RefreshWorkerTasksRequest) MarshalTo 

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

func (*RefreshWorkerTasksRequest) ProtoMessage 

func (*RefreshWorkerTasksRequest) ProtoMessage()

func (*RefreshWorkerTasksRequest) Reset 

func (m *RefreshWorkerTasksRequest) Reset()

func (*RefreshWorkerTasksRequest) Size 

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

func (*RefreshWorkerTasksRequest) String 

func (m *RefreshWorkerTasksRequest) String() string

func (*RefreshWorkerTasksRequest) Unmarshal 

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

func (*RefreshWorkerTasksRequest) XXX_DiscardUnknown added in v1.0.2 

func (m *RefreshWorkerTasksRequest) XXX_DiscardUnknown()

func (*RefreshWorkerTasksRequest) XXX_Marshal added in v1.0.2 

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

func (*RefreshWorkerTasksRequest) XXX_Merge added in v1.0.2 

func (dst *RefreshWorkerTasksRequest) XXX_Merge(src proto.Message)

func (*RefreshWorkerTasksRequest) XXX_Size added in v1.0.2 

func (m *RefreshWorkerTasksRequest) XXX_Size() int

func (*RefreshWorkerTasksRequest) XXX_Unmarshal added in v1.0.2 

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

type RefreshWorkerTasksResponse 

type RefreshWorkerTasksResponse struct {
	Result  bool                     `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"`
	Workers []*RefreshWorkerTasksMsg `protobuf:"bytes,2,rep,name=workers" json:"workers,omitempty"`
}

func (*RefreshWorkerTasksResponse) Descriptor 

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

func (*RefreshWorkerTasksResponse) GetResult 

func (m *RefreshWorkerTasksResponse) GetResult() bool

func (*RefreshWorkerTasksResponse) GetWorkers 

func (m *RefreshWorkerTasksResponse) GetWorkers() []*RefreshWorkerTasksMsg

func (*RefreshWorkerTasksResponse) Marshal 

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

func (*RefreshWorkerTasksResponse) MarshalTo 

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

func (*RefreshWorkerTasksResponse) ProtoMessage 

func (*RefreshWorkerTasksResponse) ProtoMessage()

func (*RefreshWorkerTasksResponse) Reset 

func (m *RefreshWorkerTasksResponse) Reset()

func (*RefreshWorkerTasksResponse) Size 

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

func (*RefreshWorkerTasksResponse) String 

func (m *RefreshWorkerTasksResponse) String() string

func (*RefreshWorkerTasksResponse) Unmarshal 

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

func (*RefreshWorkerTasksResponse) XXX_DiscardUnknown added in v1.0.2 

func (m *RefreshWorkerTasksResponse) XXX_DiscardUnknown()

func (*RefreshWorkerTasksResponse) XXX_Marshal added in v1.0.2 

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

func (*RefreshWorkerTasksResponse) XXX_Merge added in v1.0.2 

func (dst *RefreshWorkerTasksResponse) XXX_Merge(src proto.Message)

func (*RefreshWorkerTasksResponse) XXX_Size added in v1.0.2 

func (m *RefreshWorkerTasksResponse) XXX_Size() int

func (*RefreshWorkerTasksResponse) XXX_Unmarshal added in v1.0.2 

func (m *RefreshWorkerTasksResponse) 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) 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 (dst *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" 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) 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 (dst *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 SQLOp 

type SQLOp int32
const (
	SQLOp_SKIP    SQLOp = 0
	SQLOp_REPLACE SQLOp = 1
	SQLOp_INJECT  SQLOp = 2
)

func (SQLOp) EnumDescriptor 

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

func (SQLOp) String 

func (x SQLOp) 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" json:"DDLs,omitempty"`
	FirstPos string   `protobuf:"bytes,3,opt,name=firstPos,proto3" json:"firstPos,omitempty"`
	Synced   []string `protobuf:"bytes,4,rep,name=synced" json:"synced,omitempty"`
	Unsynced []string `protobuf:"bytes,5,rep,name=unsynced" 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) GetFirstPos 

func (m *ShardingGroup) GetFirstPos() 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) 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 (dst *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"`
	Workers []string `protobuf:"bytes,2,rep,name=workers" json:"workers,omitempty"`
}

ShowDDLLocksRequest used to query DDL locks which are un-resolved task: task's name, empty for all tasks workers: worker need to query, empty for all workers 

any DDL lock in which the worker is synced or unsynced will return

if specify task and workers both, and workers not doing the task , it will return empty DDL locks

func (*ShowDDLLocksRequest) Descriptor 

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

func (*ShowDDLLocksRequest) GetTask 

func (m *ShowDDLLocksRequest) GetTask() string

func (*ShowDDLLocksRequest) GetWorkers 

func (m *ShowDDLLocksRequest) GetWorkers() []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) 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 added in v1.0.2 

func (m *ShowDDLLocksRequest) XXX_DiscardUnknown()

func (*ShowDDLLocksRequest) XXX_Marshal added in v1.0.2 

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

func (*ShowDDLLocksRequest) XXX_Merge added in v1.0.2 

func (dst *ShowDDLLocksRequest) XXX_Merge(src proto.Message)

func (*ShowDDLLocksRequest) XXX_Size added in v1.0.2 

func (m *ShowDDLLocksRequest) XXX_Size() int

func (*ShowDDLLocksRequest) XXX_Unmarshal added in v1.0.2 

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" 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) 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 added in v1.0.2 

func (m *ShowDDLLocksResponse) XXX_DiscardUnknown()

func (*ShowDDLLocksResponse) XXX_Marshal added in v1.0.2 

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

func (*ShowDDLLocksResponse) XXX_Merge added in v1.0.2 

func (dst *ShowDDLLocksResponse) XXX_Merge(src proto.Message)

func (*ShowDDLLocksResponse) XXX_Size added in v1.0.2 

func (m *ShowDDLLocksResponse) XXX_Size() int

func (*ShowDDLLocksResponse) XXX_Unmarshal added in v1.0.2 

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

func (Stage) EnumDescriptor 

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

func (Stage) String 

func (x Stage) String() string

type StartSubTaskRequest 

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

func (*StartSubTaskRequest) Descriptor 

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

func (*StartSubTaskRequest) GetTask 

func (m *StartSubTaskRequest) GetTask() string

func (*StartSubTaskRequest) Marshal 

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

func (*StartSubTaskRequest) MarshalTo 

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

func (*StartSubTaskRequest) ProtoMessage 

func (*StartSubTaskRequest) ProtoMessage()

func (*StartSubTaskRequest) Reset 

func (m *StartSubTaskRequest) Reset()

func (*StartSubTaskRequest) Size 

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

func (*StartSubTaskRequest) String 

func (m *StartSubTaskRequest) String() string

func (*StartSubTaskRequest) Unmarshal 

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

func (*StartSubTaskRequest) XXX_DiscardUnknown 

func (m *StartSubTaskRequest) XXX_DiscardUnknown()

func (*StartSubTaskRequest) XXX_Marshal 

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

func (*StartSubTaskRequest) XXX_Merge 

func (dst *StartSubTaskRequest) XXX_Merge(src proto.Message)

func (*StartSubTaskRequest) XXX_Size 

func (m *StartSubTaskRequest) XXX_Size() int

func (*StartSubTaskRequest) XXX_Unmarshal 

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

type StartTaskRequest 

type StartTaskRequest struct {
	Task    string   `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	Workers []string `protobuf:"bytes,2,rep,name=workers" json:"workers,omitempty"`
}

func (*StartTaskRequest) Descriptor 

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

func (*StartTaskRequest) GetTask 

func (m *StartTaskRequest) GetTask() string

func (*StartTaskRequest) GetWorkers 

func (m *StartTaskRequest) GetWorkers() []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) 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 added in v1.0.2 

func (m *StartTaskRequest) XXX_DiscardUnknown()

func (*StartTaskRequest) XXX_Marshal added in v1.0.2 

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

func (*StartTaskRequest) XXX_Merge added in v1.0.2 

func (dst *StartTaskRequest) XXX_Merge(src proto.Message)

func (*StartTaskRequest) XXX_Size added in v1.0.2 

func (m *StartTaskRequest) XXX_Size() int

func (*StartTaskRequest) XXX_Unmarshal added in v1.0.2 

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"`
	Workers []*CommonWorkerResponse `protobuf:"bytes,3,rep,name=workers" json:"workers,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) GetWorkers 

func (m *StartTaskResponse) GetWorkers() []*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) 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 added in v1.0.2 

func (m *StartTaskResponse) XXX_DiscardUnknown()

func (*StartTaskResponse) XXX_Marshal added in v1.0.2 

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

func (*StartTaskResponse) XXX_Merge added in v1.0.2 

func (dst *StartTaskResponse) XXX_Merge(src proto.Message)

func (*StartTaskResponse) XXX_Size added in v1.0.2 

func (m *StartTaskResponse) XXX_Size() int

func (*StartTaskResponse) XXX_Unmarshal added in v1.0.2 

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) 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 (dst *SubTaskError) XXX_Merge(src proto.Message)

func (*SubTaskError) XXX_OneofFuncs 

func (*SubTaskError) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs 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" 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) 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 (dst *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,oneof"`
}

func (*SubTaskError_Check) MarshalTo 

func (m *SubTaskError_Check) MarshalTo(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,oneof"`
}

func (*SubTaskError_Dump) MarshalTo 

func (m *SubTaskError_Dump) MarshalTo(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,oneof"`
}

func (*SubTaskError_Load) MarshalTo 

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

func (*SubTaskError_Msg) MarshalTo 

func (m *SubTaskError_Msg) MarshalTo(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,oneof"`
}

func (*SubTaskError_Sync) MarshalTo 

func (m *SubTaskError_Sync) MarshalTo(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" 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) 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 (dst *SubTaskStatus) XXX_Merge(src proto.Message)

func (*SubTaskStatus) XXX_OneofFuncs 

func (*SubTaskStatus) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs 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" 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) 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 (dst *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,oneof"`
}

func (*SubTaskStatus_Check) MarshalTo 

func (m *SubTaskStatus_Check) MarshalTo(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,oneof"`
}

func (*SubTaskStatus_Dump) MarshalTo 

func (m *SubTaskStatus_Dump) MarshalTo(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,oneof"`
}

func (*SubTaskStatus_Load) MarshalTo 

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

func (*SubTaskStatus_Msg) MarshalTo 

func (m *SubTaskStatus_Msg) MarshalTo(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,oneof"`
}

func (*SubTaskStatus_Sync) MarshalTo 

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

func (*SubTaskStatus_Sync) Size 

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

type SwitchRelayMasterRequest 

type SwitchRelayMasterRequest struct {
}

SwitchRelayMasterRequest represents a request for switching a dm-worker's relay unit to another master server

func (*SwitchRelayMasterRequest) Descriptor 

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

func (*SwitchRelayMasterRequest) Marshal 

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

func (*SwitchRelayMasterRequest) MarshalTo 

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

func (*SwitchRelayMasterRequest) ProtoMessage 

func (*SwitchRelayMasterRequest) ProtoMessage()

func (*SwitchRelayMasterRequest) Reset 

func (m *SwitchRelayMasterRequest) Reset()

func (*SwitchRelayMasterRequest) Size 

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

func (*SwitchRelayMasterRequest) String 

func (m *SwitchRelayMasterRequest) String() string

func (*SwitchRelayMasterRequest) Unmarshal 

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

func (*SwitchRelayMasterRequest) XXX_DiscardUnknown 

func (m *SwitchRelayMasterRequest) XXX_DiscardUnknown()

func (*SwitchRelayMasterRequest) XXX_Marshal 

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

func (*SwitchRelayMasterRequest) XXX_Merge 

func (dst *SwitchRelayMasterRequest) XXX_Merge(src proto.Message)

func (*SwitchRelayMasterRequest) XXX_Size 

func (m *SwitchRelayMasterRequest) XXX_Size() int

func (*SwitchRelayMasterRequest) XXX_Unmarshal 

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

type SwitchWorkerRelayMasterRequest 

type SwitchWorkerRelayMasterRequest struct {
	Workers []string `protobuf:"bytes,1,rep,name=workers" json:"workers,omitempty"`
}

SwitchWorkerRelayMasterRequest represents a request for some dm-workers to switch relay unit's master server workers: relay unit in these dm-workers need to switch master server

func (*SwitchWorkerRelayMasterRequest) Descriptor 

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

func (*SwitchWorkerRelayMasterRequest) GetWorkers 

func (m *SwitchWorkerRelayMasterRequest) GetWorkers() []string

func (*SwitchWorkerRelayMasterRequest) Marshal 

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

func (*SwitchWorkerRelayMasterRequest) MarshalTo 

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

func (*SwitchWorkerRelayMasterRequest) ProtoMessage 

func (*SwitchWorkerRelayMasterRequest) ProtoMessage()

func (*SwitchWorkerRelayMasterRequest) Reset 

func (m *SwitchWorkerRelayMasterRequest) Reset()

func (*SwitchWorkerRelayMasterRequest) Size 

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

func (*SwitchWorkerRelayMasterRequest) String 

func (m *SwitchWorkerRelayMasterRequest) String() string

func (*SwitchWorkerRelayMasterRequest) Unmarshal 

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

func (*SwitchWorkerRelayMasterRequest) XXX_DiscardUnknown added in v1.0.2 

func (m *SwitchWorkerRelayMasterRequest) XXX_DiscardUnknown()

func (*SwitchWorkerRelayMasterRequest) XXX_Marshal added in v1.0.2 

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

func (*SwitchWorkerRelayMasterRequest) XXX_Merge added in v1.0.2 

func (dst *SwitchWorkerRelayMasterRequest) XXX_Merge(src proto.Message)

func (*SwitchWorkerRelayMasterRequest) XXX_Size added in v1.0.2 

func (m *SwitchWorkerRelayMasterRequest) XXX_Size() int

func (*SwitchWorkerRelayMasterRequest) XXX_Unmarshal added in v1.0.2 

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

type SwitchWorkerRelayMasterResponse 

type SwitchWorkerRelayMasterResponse 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"`
	Workers []*CommonWorkerResponse `protobuf:"bytes,3,rep,name=workers" json:"workers,omitempty"`
}

func (*SwitchWorkerRelayMasterResponse) Descriptor 

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

func (*SwitchWorkerRelayMasterResponse) GetMsg 

func (m *SwitchWorkerRelayMasterResponse) GetMsg() string

func (*SwitchWorkerRelayMasterResponse) GetResult 

func (m *SwitchWorkerRelayMasterResponse) GetResult() bool

func (*SwitchWorkerRelayMasterResponse) GetWorkers 

func (m *SwitchWorkerRelayMasterResponse) GetWorkers() []*CommonWorkerResponse

func (*SwitchWorkerRelayMasterResponse) Marshal 

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

func (*SwitchWorkerRelayMasterResponse) MarshalTo 

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

func (*SwitchWorkerRelayMasterResponse) ProtoMessage 

func (*SwitchWorkerRelayMasterResponse) ProtoMessage()

func (*SwitchWorkerRelayMasterResponse) Reset 

func (m *SwitchWorkerRelayMasterResponse) Reset()

func (*SwitchWorkerRelayMasterResponse) Size 

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

func (*SwitchWorkerRelayMasterResponse) String 

func (m *SwitchWorkerRelayMasterResponse) String() string

func (*SwitchWorkerRelayMasterResponse) Unmarshal 

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

func (*SwitchWorkerRelayMasterResponse) XXX_DiscardUnknown added in v1.0.2 

func (m *SwitchWorkerRelayMasterResponse) XXX_DiscardUnknown()

func (*SwitchWorkerRelayMasterResponse) XXX_Marshal added in v1.0.2 

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

func (*SwitchWorkerRelayMasterResponse) XXX_Merge added in v1.0.2 

func (dst *SwitchWorkerRelayMasterResponse) XXX_Merge(src proto.Message)

func (*SwitchWorkerRelayMasterResponse) XXX_Size added in v1.0.2 

func (m *SwitchWorkerRelayMasterResponse) XXX_Size() int

func (*SwitchWorkerRelayMasterResponse) XXX_Unmarshal added in v1.0.2 

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

type SyncError 

type SyncError struct {
	Errors []*SyncSQLError `protobuf:"bytes,1,rep,name=errors" 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) 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 (dst *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) 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 (dst *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" json:"blockingDDLs,omitempty"`
	UnresolvedGroups []*ShardingGroup `protobuf:"bytes,9,rep,name=unresolvedGroups" json:"unresolvedGroups,omitempty"`
	Synced           bool             `protobuf:"varint,10,opt,name=synced,proto3" json:"synced,omitempty"`
}

SyncStatus represents status for sync unit

func (*SyncStatus) Descriptor 

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

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) 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 (dst *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 SyncerBinlogEvent 

type SyncerBinlogEvent struct {
	Base      *BaseEvent   `protobuf:"bytes,1,opt,name=base" json:"base,omitempty"`
	State     *SyncerState `protobuf:"bytes,2,opt,name=state" json:"state,omitempty"`
	EventType int32        `protobuf:"varint,3,opt,name=eventType,proto3" json:"eventType,omitempty"`
	OpType    int32        `protobuf:"varint,4,opt,name=opType,proto3" json:"opType,omitempty"`
}

func (*SyncerBinlogEvent) Descriptor 

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

func (*SyncerBinlogEvent) GetBase 

func (m *SyncerBinlogEvent) GetBase() *BaseEvent

func (*SyncerBinlogEvent) GetEventType 

func (m *SyncerBinlogEvent) GetEventType() int32

func (*SyncerBinlogEvent) GetOpType 

func (m *SyncerBinlogEvent) GetOpType() int32

func (*SyncerBinlogEvent) GetState 

func (m *SyncerBinlogEvent) GetState() *SyncerState

func (*SyncerBinlogEvent) Marshal 

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

func (*SyncerBinlogEvent) MarshalTo 

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

func (*SyncerBinlogEvent) ProtoMessage 

func (*SyncerBinlogEvent) ProtoMessage()

func (*SyncerBinlogEvent) Reset 

func (m *SyncerBinlogEvent) Reset()

func (*SyncerBinlogEvent) Size 

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

func (*SyncerBinlogEvent) String 

func (m *SyncerBinlogEvent) String() string

func (*SyncerBinlogEvent) Unmarshal 

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

func (*SyncerBinlogEvent) XXX_DiscardUnknown 

func (m *SyncerBinlogEvent) XXX_DiscardUnknown()

func (*SyncerBinlogEvent) XXX_Marshal 

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

func (*SyncerBinlogEvent) XXX_Merge 

func (dst *SyncerBinlogEvent) XXX_Merge(src proto.Message)

func (*SyncerBinlogEvent) XXX_Size 

func (m *SyncerBinlogEvent) XXX_Size() int

func (*SyncerBinlogEvent) XXX_Unmarshal 

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

type SyncerJobEvent 

type SyncerJobEvent struct {
	Base         *BaseEvent     `protobuf:"bytes,1,opt,name=base" json:"base,omitempty"`
	OpType       int32          `protobuf:"varint,2,opt,name=opType,proto3" json:"opType,omitempty"`
	Pos          *MySQLPosition `protobuf:"bytes,3,opt,name=pos" json:"pos,omitempty"`
	CurrentPos   *MySQLPosition `protobuf:"bytes,4,opt,name=currentPos" json:"currentPos,omitempty"`
	Sql          string         `protobuf:"bytes,5,opt,name=sql,proto3" json:"sql,omitempty"`
	Ddls         []string       `protobuf:"bytes,6,rep,name=ddls" json:"ddls,omitempty"`
	ArgsChecksum uint32         `protobuf:"varint,7,opt,name=argsChecksum,proto3" json:"argsChecksum,omitempty"`
	DdlInfo      *ExecDDLInfo   `protobuf:"bytes,8,opt,name=ddlInfo" json:"ddlInfo,omitempty"`
	QueueBucket  string         `protobuf:"bytes,9,opt,name=queueBucket,proto3" json:"queueBucket,omitempty"`
	State        SyncerJobState `protobuf:"varint,10,opt,name=state,proto3,enum=pb.SyncerJobState" json:"state,omitempty"`
}

func (*SyncerJobEvent) Descriptor 

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

func (*SyncerJobEvent) GetArgsChecksum 

func (m *SyncerJobEvent) GetArgsChecksum() uint32

func (*SyncerJobEvent) GetBase 

func (m *SyncerJobEvent) GetBase() *BaseEvent

func (*SyncerJobEvent) GetCurrentPos 

func (m *SyncerJobEvent) GetCurrentPos() *MySQLPosition

func (*SyncerJobEvent) GetDdlInfo 

func (m *SyncerJobEvent) GetDdlInfo() *ExecDDLInfo

func (*SyncerJobEvent) GetDdls 

func (m *SyncerJobEvent) GetDdls() []string

func (*SyncerJobEvent) GetOpType 

func (m *SyncerJobEvent) GetOpType() int32

func (*SyncerJobEvent) GetPos 

func (m *SyncerJobEvent) GetPos() *MySQLPosition

func (*SyncerJobEvent) GetQueueBucket 

func (m *SyncerJobEvent) GetQueueBucket() string

func (*SyncerJobEvent) GetSql 

func (m *SyncerJobEvent) GetSql() string

func (*SyncerJobEvent) GetState 

func (m *SyncerJobEvent) GetState() SyncerJobState

func (*SyncerJobEvent) Marshal 

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

func (*SyncerJobEvent) MarshalTo 

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

func (*SyncerJobEvent) ProtoMessage 

func (*SyncerJobEvent) ProtoMessage()

func (*SyncerJobEvent) Reset 

func (m *SyncerJobEvent) Reset()

func (*SyncerJobEvent) Size 

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

func (*SyncerJobEvent) String 

func (m *SyncerJobEvent) String() string

func (*SyncerJobEvent) Unmarshal 

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

func (*SyncerJobEvent) XXX_DiscardUnknown 

func (m *SyncerJobEvent) XXX_DiscardUnknown()

func (*SyncerJobEvent) XXX_Marshal 

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

func (*SyncerJobEvent) XXX_Merge 

func (dst *SyncerJobEvent) XXX_Merge(src proto.Message)

func (*SyncerJobEvent) XXX_Size 

func (m *SyncerJobEvent) XXX_Size() int

func (*SyncerJobEvent) XXX_Unmarshal 

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

type SyncerJobState 

type SyncerJobState int32
const (
	SyncerJobState_init    SyncerJobState = 0
	SyncerJobState_queued  SyncerJobState = 1
	SyncerJobState_success SyncerJobState = 2
	SyncerJobState_error   SyncerJobState = 3
)

func (SyncerJobState) EnumDescriptor 

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

func (SyncerJobState) String 

func (x SyncerJobState) String() string

type SyncerState 

type SyncerState struct {
	SafeMode   bool           `protobuf:"varint,1,opt,name=safeMode,proto3" json:"safeMode,omitempty"`
	TryReSync  bool           `protobuf:"varint,2,opt,name=tryReSync,proto3" json:"tryReSync,omitempty"`
	LastPos    *MySQLPosition `protobuf:"bytes,3,opt,name=lastPos" json:"lastPos,omitempty"`
	CurrentPos *MySQLPosition `protobuf:"bytes,4,opt,name=currentPos" json:"currentPos,omitempty"`
}

func (*SyncerState) Descriptor 

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

func (*SyncerState) GetCurrentPos 

func (m *SyncerState) GetCurrentPos() *MySQLPosition

func (*SyncerState) GetLastPos 

func (m *SyncerState) GetLastPos() *MySQLPosition

func (*SyncerState) GetSafeMode 

func (m *SyncerState) GetSafeMode() bool

func (*SyncerState) GetTryReSync 

func (m *SyncerState) GetTryReSync() bool

func (*SyncerState) Marshal 

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

func (*SyncerState) MarshalTo 

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

func (*SyncerState) ProtoMessage 

func (*SyncerState) ProtoMessage()

func (*SyncerState) Reset 

func (m *SyncerState) Reset()

func (*SyncerState) Size 

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

func (*SyncerState) String 

func (m *SyncerState) String() string

func (*SyncerState) Unmarshal 

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

func (*SyncerState) XXX_DiscardUnknown 

func (m *SyncerState) XXX_DiscardUnknown()

func (*SyncerState) XXX_Marshal 

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

func (*SyncerState) XXX_Merge 

func (dst *SyncerState) XXX_Merge(src proto.Message)

func (*SyncerState) XXX_Size 

func (m *SyncerState) XXX_Size() int

func (*SyncerState) XXX_Unmarshal 

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

type TError added in v1.0.2 

type TError struct {
	ErrCode  int32  `protobuf:"varint,1,opt,name=ErrCode,proto3" json:"ErrCode,omitempty"`
	ErrClass int32  `protobuf:"varint,2,opt,name=ErrClass,proto3" json:"ErrClass,omitempty"`
	ErrScope int32  `protobuf:"varint,3,opt,name=ErrScope,proto3" json:"ErrScope,omitempty"`
	ErrLevel int32  `protobuf:"varint,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"`
}

TError represents error 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 (*TError) Descriptor added in v1.0.2 

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

func (*TError) GetErrClass added in v1.0.2 

func (m *TError) GetErrClass() int32

func (*TError) GetErrCode added in v1.0.2 

func (m *TError) GetErrCode() int32

func (*TError) GetErrLevel added in v1.0.2 

func (m *TError) GetErrLevel() int32

func (*TError) GetErrScope added in v1.0.2 

func (m *TError) GetErrScope() int32

func (*TError) GetMessage added in v1.0.2 

func (m *TError) GetMessage() string

func (*TError) GetRawCause added in v1.0.2 

func (m *TError) GetRawCause() string

func (*TError) Marshal added in v1.0.2 

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

func (*TError) MarshalTo added in v1.0.2 

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

func (*TError) ProtoMessage added in v1.0.2 

func (*TError) ProtoMessage()

func (*TError) Reset added in v1.0.2 

func (m *TError) Reset()

func (*TError) Size added in v1.0.2 

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

func (*TError) String added in v1.0.2 

func (m *TError) String() string

func (*TError) Unmarshal added in v1.0.2 

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

func (*TError) XXX_DiscardUnknown added in v1.0.2 

func (m *TError) XXX_DiscardUnknown()

func (*TError) XXX_Marshal added in v1.0.2 

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

func (*TError) XXX_Merge added in v1.0.2 

func (dst *TError) XXX_Merge(src proto.Message)

func (*TError) XXX_Size added in v1.0.2 

func (m *TError) XXX_Size() int

func (*TError) XXX_Unmarshal added in v1.0.2 

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

type TaskLog 

type TaskLog struct {
	Id   int64     `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Task *TaskMeta `protobuf:"bytes,2,opt,name=task" json:"task,omitempty"`
	Ts   int64     `protobuf:"varint,3,opt,name=ts,proto3" json:"ts,omitempty"`
	// true means this log is applied successfully
	Success bool   `protobuf:"varint,4,opt,name=success,proto3" json:"success,omitempty"`
	Message string `protobuf:"bytes,5,opt,name=message,proto3" json:"message,omitempty"`
}

func (*TaskLog) Descriptor 

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

func (*TaskLog) GetId 

func (m *TaskLog) GetId() int64

func (*TaskLog) GetMessage 

func (m *TaskLog) GetMessage() string

func (*TaskLog) GetSuccess 

func (m *TaskLog) GetSuccess() bool

func (*TaskLog) GetTask 

func (m *TaskLog) GetTask() *TaskMeta

func (*TaskLog) GetTs 

func (m *TaskLog) GetTs() int64

func (*TaskLog) Marshal 

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

func (*TaskLog) MarshalTo 

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

func (*TaskLog) ProtoMessage 

func (*TaskLog) ProtoMessage()

func (*TaskLog) Reset 

func (m *TaskLog) Reset()

func (*TaskLog) Size 

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

func (*TaskLog) String 

func (m *TaskLog) String() string

func (*TaskLog) Unmarshal 

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

func (*TaskLog) XXX_DiscardUnknown 

func (m *TaskLog) XXX_DiscardUnknown()

func (*TaskLog) XXX_Marshal 

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

func (*TaskLog) XXX_Merge 

func (dst *TaskLog) XXX_Merge(src proto.Message)

func (*TaskLog) XXX_Size 

func (m *TaskLog) XXX_Size() int

func (*TaskLog) XXX_Unmarshal 

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

type TaskMeta 

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

func (*TaskMeta) Descriptor 

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

func (*TaskMeta) GetName 

func (m *TaskMeta) GetName() string

func (*TaskMeta) GetOp 

func (m *TaskMeta) GetOp() TaskOp

func (*TaskMeta) GetStage 

func (m *TaskMeta) GetStage() Stage

func (*TaskMeta) GetTask 

func (m *TaskMeta) GetTask() []byte

func (*TaskMeta) Marshal 

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

func (*TaskMeta) MarshalTo 

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

func (*TaskMeta) ProtoMessage 

func (*TaskMeta) ProtoMessage()

func (*TaskMeta) Reset 

func (m *TaskMeta) Reset()

func (*TaskMeta) Size 

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

func (*TaskMeta) String 

func (m *TaskMeta) String() string

func (*TaskMeta) Unmarshal 

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

func (*TaskMeta) XXX_DiscardUnknown 

func (m *TaskMeta) XXX_DiscardUnknown()

func (*TaskMeta) XXX_Marshal 

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

func (*TaskMeta) XXX_Merge 

func (dst *TaskMeta) XXX_Merge(src proto.Message)

func (*TaskMeta) XXX_Size 

func (m *TaskMeta) XXX_Size() int

func (*TaskMeta) XXX_Unmarshal 

func (m *TaskMeta) 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 TraceType 

type TraceType int32
const (
	TraceType_DummyEvent  TraceType = 0
	TraceType_BinlogEvent TraceType = 1
	TraceType_JobEvent    TraceType = 2
)

func (TraceType) EnumDescriptor 

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

func (TraceType) String 

func (x TraceType) String() string

type TracerClient 

type TracerClient interface {
	GetTSO(ctx context.Context, in *GetTSORequest, opts ...grpc.CallOption) (*GetTSOResponse, error)
	UploadSyncerBinlogEvent(ctx context.Context, in *UploadSyncerBinlogEventRequest, opts ...grpc.CallOption) (*CommonUploadResponse, error)
	UploadSyncerJobEvent(ctx context.Context, in *UploadSyncerJobEventRequest, opts ...grpc.CallOption) (*CommonUploadResponse, error)
}

TracerClient is the client API for Tracer service.

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

func NewTracerClient 

func NewTracerClient(cc *grpc.ClientConn) TracerClient

type TracerServer 

type TracerServer interface {
	GetTSO(context.Context, *GetTSORequest) (*GetTSOResponse, error)
	UploadSyncerBinlogEvent(context.Context, *UploadSyncerBinlogEventRequest) (*CommonUploadResponse, error)
	UploadSyncerJobEvent(context.Context, *UploadSyncerJobEventRequest) (*CommonUploadResponse, error)
}

TracerServer is the server API for Tracer service.

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"`
	Workers      []string `protobuf:"bytes,3,rep,name=workers" json:"workers,omitempty"`
	ForceRemove  bool     `protobuf:"varint,4,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 workers: dm-workers need to execute / skip DDL, empty for all dm-workers 

replaceOwner in or not in workers are both fine

forceRemove: force to remove the DDL lock even unlock fail

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

func (m *UnlockDDLLockRequest) GetWorkers() []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) 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 added in v1.0.2 

func (m *UnlockDDLLockRequest) XXX_DiscardUnknown()

func (*UnlockDDLLockRequest) XXX_Marshal added in v1.0.2 

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

func (*UnlockDDLLockRequest) XXX_Merge added in v1.0.2 

func (dst *UnlockDDLLockRequest) XXX_Merge(src proto.Message)

func (*UnlockDDLLockRequest) XXX_Size added in v1.0.2 

func (m *UnlockDDLLockRequest) XXX_Size() int

func (*UnlockDDLLockRequest) XXX_Unmarshal added in v1.0.2 

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"`
	Workers []*CommonWorkerResponse `protobuf:"bytes,3,rep,name=workers" json:"workers,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) GetWorkers 

func (m *UnlockDDLLockResponse) GetWorkers() []*CommonWorkerResponse

func (*UnlockDDLLockResponse) Marshal 

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

func (*UnlockDDLLockResponse) MarshalTo 

func (m *UnlockDDLLockResponse) MarshalTo(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 added in v1.0.2 

func (m *UnlockDDLLockResponse) XXX_DiscardUnknown()

func (*UnlockDDLLockResponse) XXX_Marshal added in v1.0.2 

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

func (*UnlockDDLLockResponse) XXX_Merge added in v1.0.2 

func (dst *UnlockDDLLockResponse) XXX_Merge(src proto.Message)

func (*UnlockDDLLockResponse) XXX_Size added in v1.0.2 

func (m *UnlockDDLLockResponse) XXX_Size() int

func (*UnlockDDLLockResponse) XXX_Unmarshal added in v1.0.2 

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

type UpdateMasterConfigRequest 

type UpdateMasterConfigRequest struct {
	Config string `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
}

func (*UpdateMasterConfigRequest) Descriptor 

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

func (*UpdateMasterConfigRequest) GetConfig 

func (m *UpdateMasterConfigRequest) GetConfig() string

func (*UpdateMasterConfigRequest) Marshal 

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

func (*UpdateMasterConfigRequest) MarshalTo 

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

func (*UpdateMasterConfigRequest) ProtoMessage 

func (*UpdateMasterConfigRequest) ProtoMessage()

func (*UpdateMasterConfigRequest) Reset 

func (m *UpdateMasterConfigRequest) Reset()

func (*UpdateMasterConfigRequest) Size 

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

func (*UpdateMasterConfigRequest) String 

func (m *UpdateMasterConfigRequest) String() string

func (*UpdateMasterConfigRequest) Unmarshal 

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

func (*UpdateMasterConfigRequest) XXX_DiscardUnknown added in v1.0.2 

func (m *UpdateMasterConfigRequest) XXX_DiscardUnknown()

func (*UpdateMasterConfigRequest) XXX_Marshal added in v1.0.2 

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

func (*UpdateMasterConfigRequest) XXX_Merge added in v1.0.2 

func (dst *UpdateMasterConfigRequest) XXX_Merge(src proto.Message)

func (*UpdateMasterConfigRequest) XXX_Size added in v1.0.2 

func (m *UpdateMasterConfigRequest) XXX_Size() int

func (*UpdateMasterConfigRequest) XXX_Unmarshal added in v1.0.2 

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

type UpdateMasterConfigResponse 

type UpdateMasterConfigResponse 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"`
	Workers []*QueryStatusResponse `protobuf:"bytes,3,rep,name=workers" json:"workers,omitempty"`
}

func (*UpdateMasterConfigResponse) Descriptor 

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

func (*UpdateMasterConfigResponse) GetMsg 

func (m *UpdateMasterConfigResponse) GetMsg() string

func (*UpdateMasterConfigResponse) GetResult 

func (m *UpdateMasterConfigResponse) GetResult() bool

func (*UpdateMasterConfigResponse) GetWorkers 

func (m *UpdateMasterConfigResponse) GetWorkers() []*QueryStatusResponse

func (*UpdateMasterConfigResponse) Marshal 

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

func (*UpdateMasterConfigResponse) MarshalTo 

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

func (*UpdateMasterConfigResponse) ProtoMessage 

func (*UpdateMasterConfigResponse) ProtoMessage()

func (*UpdateMasterConfigResponse) Reset 

func (m *UpdateMasterConfigResponse) Reset()

func (*UpdateMasterConfigResponse) Size 

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

func (*UpdateMasterConfigResponse) String 

func (m *UpdateMasterConfigResponse) String() string

func (*UpdateMasterConfigResponse) Unmarshal 

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

func (*UpdateMasterConfigResponse) XXX_DiscardUnknown added in v1.0.2 

func (m *UpdateMasterConfigResponse) XXX_DiscardUnknown()

func (*UpdateMasterConfigResponse) XXX_Marshal added in v1.0.2 

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

func (*UpdateMasterConfigResponse) XXX_Merge added in v1.0.2 

func (dst *UpdateMasterConfigResponse) XXX_Merge(src proto.Message)

func (*UpdateMasterConfigResponse) XXX_Size added in v1.0.2 

func (m *UpdateMasterConfigResponse) XXX_Size() int

func (*UpdateMasterConfigResponse) XXX_Unmarshal added in v1.0.2 

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

type UpdateRelayRequest 

type UpdateRelayRequest struct {
	Content string `protobuf:"bytes,1,opt,name=content,proto3" json:"content,omitempty"`
}

func (*UpdateRelayRequest) Descriptor 

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

func (*UpdateRelayRequest) GetContent 

func (m *UpdateRelayRequest) GetContent() string

func (*UpdateRelayRequest) Marshal 

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

func (*UpdateRelayRequest) MarshalTo 

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

func (*UpdateRelayRequest) ProtoMessage 

func (*UpdateRelayRequest) ProtoMessage()

func (*UpdateRelayRequest) Reset 

func (m *UpdateRelayRequest) Reset()

func (*UpdateRelayRequest) Size 

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

func (*UpdateRelayRequest) String 

func (m *UpdateRelayRequest) String() string

func (*UpdateRelayRequest) Unmarshal 

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

func (*UpdateRelayRequest) XXX_DiscardUnknown 

func (m *UpdateRelayRequest) XXX_DiscardUnknown()

func (*UpdateRelayRequest) XXX_Marshal 

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

func (*UpdateRelayRequest) XXX_Merge 

func (dst *UpdateRelayRequest) XXX_Merge(src proto.Message)

func (*UpdateRelayRequest) XXX_Size 

func (m *UpdateRelayRequest) XXX_Size() int

func (*UpdateRelayRequest) XXX_Unmarshal 

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

type UpdateSubTaskRequest 

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

func (*UpdateSubTaskRequest) Descriptor 

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

func (*UpdateSubTaskRequest) GetTask 

func (m *UpdateSubTaskRequest) GetTask() string

func (*UpdateSubTaskRequest) Marshal 

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

func (*UpdateSubTaskRequest) MarshalTo 

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

func (*UpdateSubTaskRequest) ProtoMessage 

func (*UpdateSubTaskRequest) ProtoMessage()

func (*UpdateSubTaskRequest) Reset 

func (m *UpdateSubTaskRequest) Reset()

func (*UpdateSubTaskRequest) Size 

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

func (*UpdateSubTaskRequest) String 

func (m *UpdateSubTaskRequest) String() string

func (*UpdateSubTaskRequest) Unmarshal 

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

func (*UpdateSubTaskRequest) XXX_DiscardUnknown 

func (m *UpdateSubTaskRequest) XXX_DiscardUnknown()

func (*UpdateSubTaskRequest) XXX_Marshal 

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

func (*UpdateSubTaskRequest) XXX_Merge 

func (dst *UpdateSubTaskRequest) XXX_Merge(src proto.Message)

func (*UpdateSubTaskRequest) XXX_Size 

func (m *UpdateSubTaskRequest) XXX_Size() int

func (*UpdateSubTaskRequest) XXX_Unmarshal 

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

type UpdateTaskRequest 

type UpdateTaskRequest struct {
	Task    string   `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	Workers []string `protobuf:"bytes,2,rep,name=workers" json:"workers,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, black-white-list
support update partial config for syncer, loader, etc later

workers need to do update, empty for all workers in processing the task

func (*UpdateTaskRequest) Descriptor 

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

func (*UpdateTaskRequest) GetTask 

func (m *UpdateTaskRequest) GetTask() string

func (*UpdateTaskRequest) GetWorkers 

func (m *UpdateTaskRequest) GetWorkers() []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) 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 added in v1.0.2 

func (m *UpdateTaskRequest) XXX_DiscardUnknown()

func (*UpdateTaskRequest) XXX_Marshal added in v1.0.2 

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

func (*UpdateTaskRequest) XXX_Merge added in v1.0.2 

func (dst *UpdateTaskRequest) XXX_Merge(src proto.Message)

func (*UpdateTaskRequest) XXX_Size added in v1.0.2 

func (m *UpdateTaskRequest) XXX_Size() int

func (*UpdateTaskRequest) XXX_Unmarshal added in v1.0.2 

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"`
	Workers []*CommonWorkerResponse `protobuf:"bytes,3,rep,name=workers" json:"workers,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) GetWorkers 

func (m *UpdateTaskResponse) GetWorkers() []*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) 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 added in v1.0.2 

func (m *UpdateTaskResponse) XXX_DiscardUnknown()

func (*UpdateTaskResponse) XXX_Marshal added in v1.0.2 

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

func (*UpdateTaskResponse) XXX_Merge added in v1.0.2 

func (dst *UpdateTaskResponse) XXX_Merge(src proto.Message)

func (*UpdateTaskResponse) XXX_Size added in v1.0.2 

func (m *UpdateTaskResponse) XXX_Size() int

func (*UpdateTaskResponse) XXX_Unmarshal added in v1.0.2 

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

type UpdateWorkerRelayConfigRequest 

type UpdateWorkerRelayConfigRequest struct {
	Config string `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	Worker string `protobuf:"bytes,2,opt,name=worker,proto3" json:"worker,omitempty"`
}

func (*UpdateWorkerRelayConfigRequest) Descriptor 

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

func (*UpdateWorkerRelayConfigRequest) GetConfig 

func (m *UpdateWorkerRelayConfigRequest) GetConfig() string

func (*UpdateWorkerRelayConfigRequest) GetWorker 

func (m *UpdateWorkerRelayConfigRequest) GetWorker() string

func (*UpdateWorkerRelayConfigRequest) Marshal 

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

func (*UpdateWorkerRelayConfigRequest) MarshalTo 

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

func (*UpdateWorkerRelayConfigRequest) ProtoMessage 

func (*UpdateWorkerRelayConfigRequest) ProtoMessage()

func (*UpdateWorkerRelayConfigRequest) Reset 

func (m *UpdateWorkerRelayConfigRequest) Reset()

func (*UpdateWorkerRelayConfigRequest) Size 

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

func (*UpdateWorkerRelayConfigRequest) String 

func (m *UpdateWorkerRelayConfigRequest) String() string

func (*UpdateWorkerRelayConfigRequest) Unmarshal 

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

func (*UpdateWorkerRelayConfigRequest) XXX_DiscardUnknown added in v1.0.2 

func (m *UpdateWorkerRelayConfigRequest) XXX_DiscardUnknown()

func (*UpdateWorkerRelayConfigRequest) XXX_Marshal added in v1.0.2 

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

func (*UpdateWorkerRelayConfigRequest) XXX_Merge added in v1.0.2 

func (dst *UpdateWorkerRelayConfigRequest) XXX_Merge(src proto.Message)

func (*UpdateWorkerRelayConfigRequest) XXX_Size added in v1.0.2 

func (m *UpdateWorkerRelayConfigRequest) XXX_Size() int

func (*UpdateWorkerRelayConfigRequest) XXX_Unmarshal added in v1.0.2 

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

type UploadSyncerBinlogEventRequest 

type UploadSyncerBinlogEventRequest struct {
	Events []*SyncerBinlogEvent `protobuf:"bytes,1,rep,name=events" json:"events,omitempty"`
}

func (*UploadSyncerBinlogEventRequest) Descriptor 

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

func (*UploadSyncerBinlogEventRequest) GetEvents 

func (m *UploadSyncerBinlogEventRequest) GetEvents() []*SyncerBinlogEvent

func (*UploadSyncerBinlogEventRequest) Marshal 

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

func (*UploadSyncerBinlogEventRequest) MarshalTo 

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

func (*UploadSyncerBinlogEventRequest) ProtoMessage 

func (*UploadSyncerBinlogEventRequest) ProtoMessage()

func (*UploadSyncerBinlogEventRequest) Reset 

func (m *UploadSyncerBinlogEventRequest) Reset()

func (*UploadSyncerBinlogEventRequest) Size 

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

func (*UploadSyncerBinlogEventRequest) String 

func (m *UploadSyncerBinlogEventRequest) String() string

func (*UploadSyncerBinlogEventRequest) Unmarshal 

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

func (*UploadSyncerBinlogEventRequest) XXX_DiscardUnknown 

func (m *UploadSyncerBinlogEventRequest) XXX_DiscardUnknown()

func (*UploadSyncerBinlogEventRequest) XXX_Marshal 

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

func (*UploadSyncerBinlogEventRequest) XXX_Merge 

func (dst *UploadSyncerBinlogEventRequest) XXX_Merge(src proto.Message)

func (*UploadSyncerBinlogEventRequest) XXX_Size 

func (m *UploadSyncerBinlogEventRequest) XXX_Size() int

func (*UploadSyncerBinlogEventRequest) XXX_Unmarshal 

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

type UploadSyncerJobEventRequest 

type UploadSyncerJobEventRequest struct {
	Events []*SyncerJobEvent `protobuf:"bytes,1,rep,name=events" json:"events,omitempty"`
}

func (*UploadSyncerJobEventRequest) Descriptor 

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

func (*UploadSyncerJobEventRequest) GetEvents 

func (m *UploadSyncerJobEventRequest) GetEvents() []*SyncerJobEvent

func (*UploadSyncerJobEventRequest) Marshal 

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

func (*UploadSyncerJobEventRequest) MarshalTo 

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

func (*UploadSyncerJobEventRequest) ProtoMessage 

func (*UploadSyncerJobEventRequest) ProtoMessage()

func (*UploadSyncerJobEventRequest) Reset 

func (m *UploadSyncerJobEventRequest) Reset()

func (*UploadSyncerJobEventRequest) Size 

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

func (*UploadSyncerJobEventRequest) String 

func (m *UploadSyncerJobEventRequest) String() string

func (*UploadSyncerJobEventRequest) Unmarshal 

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

func (*UploadSyncerJobEventRequest) XXX_DiscardUnknown 

func (m *UploadSyncerJobEventRequest) XXX_DiscardUnknown()

func (*UploadSyncerJobEventRequest) XXX_Marshal 

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

func (*UploadSyncerJobEventRequest) XXX_Merge 

func (dst *UploadSyncerJobEventRequest) XXX_Merge(src proto.Message)

func (*UploadSyncerJobEventRequest) XXX_Size 

func (m *UploadSyncerJobEventRequest) XXX_Size() int

func (*UploadSyncerJobEventRequest) XXX_Unmarshal 

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

type WorkerClient 

type WorkerClient interface {
	StartSubTask(ctx context.Context, in *StartSubTaskRequest, opts ...grpc.CallOption) (*OperateSubTaskResponse, error)
	OperateSubTask(ctx context.Context, in *OperateSubTaskRequest, opts ...grpc.CallOption) (*OperateSubTaskResponse, error)
	UpdateSubTask(ctx context.Context, in *UpdateSubTaskRequest, opts ...grpc.CallOption) (*OperateSubTaskResponse, error)
	QueryStatus(ctx context.Context, in *QueryStatusRequest, opts ...grpc.CallOption) (*QueryStatusResponse, error)
	QueryError(ctx context.Context, in *QueryErrorRequest, opts ...grpc.CallOption) (*QueryErrorResponse, error)
	QueryTaskOperation(ctx context.Context, in *QueryTaskOperationRequest, opts ...grpc.CallOption) (*QueryTaskOperationResponse, error)
	HandleSQLs(ctx context.Context, in *HandleSubTaskSQLsRequest, opts ...grpc.CallOption) (*CommonWorkerResponse, error)
	// FetchDDLInfo fetches DDL info from dm-worker by dm-master
	// and sends the relevant DDL lock info back to dm-worker
	// NOTE: split to two RPCs if needed
	FetchDDLInfo(ctx context.Context, opts ...grpc.CallOption) (Worker_FetchDDLInfoClient, error)
	// ExecuteDDL request a dm-worker to execute or ignore (skip) a DDL
	ExecuteDDL(ctx context.Context, in *ExecDDLRequest, opts ...grpc.CallOption) (*CommonWorkerResponse, error)
	// BreakDDLLock request a dm-worker to break a DDL lock
	// including remove DDLLockInfo and/or execute/skip DDL
	BreakDDLLock(ctx context.Context, in *BreakDDLLockRequest, opts ...grpc.CallOption) (*CommonWorkerResponse, error)
	// SwitchRelayMaster request a dm-worker's relay unit switching to another master server
	SwitchRelayMaster(ctx context.Context, in *SwitchRelayMasterRequest, opts ...grpc.CallOption) (*CommonWorkerResponse, error)
	// OperateRelay operates relay unit
	// differ from SwitchRelayMaster which may add more args in the future
	OperateRelay(ctx context.Context, in *OperateRelayRequest, opts ...grpc.CallOption) (*OperateRelayResponse, error)
	// PurgeRelay purges relay log files for this dm-worker
	PurgeRelay(ctx context.Context, in *PurgeRelayRequest, opts ...grpc.CallOption) (*CommonWorkerResponse, error)
	UpdateRelayConfig(ctx context.Context, in *UpdateRelayRequest, opts ...grpc.CallOption) (*CommonWorkerResponse, error)
	QueryWorkerConfig(ctx context.Context, in *QueryWorkerConfigRequest, opts ...grpc.CallOption) (*QueryWorkerConfigResponse, error)
	MigrateRelay(ctx context.Context, in *MigrateRelayRequest, opts ...grpc.CallOption) (*CommonWorkerResponse, error)
}

WorkerClient is the client API for Worker service.

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

func NewWorkerClient 

func NewWorkerClient(cc *grpc.ClientConn) WorkerClient

type WorkerServer 

type WorkerServer interface {
	StartSubTask(context.Context, *StartSubTaskRequest) (*OperateSubTaskResponse, error)
	OperateSubTask(context.Context, *OperateSubTaskRequest) (*OperateSubTaskResponse, error)
	UpdateSubTask(context.Context, *UpdateSubTaskRequest) (*OperateSubTaskResponse, error)
	QueryStatus(context.Context, *QueryStatusRequest) (*QueryStatusResponse, error)
	QueryError(context.Context, *QueryErrorRequest) (*QueryErrorResponse, error)
	QueryTaskOperation(context.Context, *QueryTaskOperationRequest) (*QueryTaskOperationResponse, error)
	HandleSQLs(context.Context, *HandleSubTaskSQLsRequest) (*CommonWorkerResponse, error)
	// FetchDDLInfo fetches DDL info from dm-worker by dm-master
	// and sends the relevant DDL lock info back to dm-worker
	// NOTE: split to two RPCs if needed
	FetchDDLInfo(Worker_FetchDDLInfoServer) error
	// ExecuteDDL request a dm-worker to execute or ignore (skip) a DDL
	ExecuteDDL(context.Context, *ExecDDLRequest) (*CommonWorkerResponse, error)
	// BreakDDLLock request a dm-worker to break a DDL lock
	// including remove DDLLockInfo and/or execute/skip DDL
	BreakDDLLock(context.Context, *BreakDDLLockRequest) (*CommonWorkerResponse, error)
	// SwitchRelayMaster request a dm-worker's relay unit switching to another master server
	SwitchRelayMaster(context.Context, *SwitchRelayMasterRequest) (*CommonWorkerResponse, error)
	// OperateRelay operates relay unit
	// differ from SwitchRelayMaster which may add more args in the future
	OperateRelay(context.Context, *OperateRelayRequest) (*OperateRelayResponse, error)
	// PurgeRelay purges relay log files for this dm-worker
	PurgeRelay(context.Context, *PurgeRelayRequest) (*CommonWorkerResponse, error)
	UpdateRelayConfig(context.Context, *UpdateRelayRequest) (*CommonWorkerResponse, error)
	QueryWorkerConfig(context.Context, *QueryWorkerConfigRequest) (*QueryWorkerConfigResponse, error)
	MigrateRelay(context.Context, *MigrateRelayRequest) (*CommonWorkerResponse, error)
}

WorkerServer is the server API for Worker service.

type Worker_FetchDDLInfoClient 

type Worker_FetchDDLInfoClient interface {
	Send(*DDLLockInfo) error
	Recv() (*DDLInfo, error)
	grpc.ClientStream
}

type Worker_FetchDDLInfoServer 

type Worker_FetchDDLInfoServer interface {
	Send(*DDLInfo) error
	Recv() (*DDLLockInfo, error)
	grpc.ServerStream
}

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.