pb

package

Go to main page

Versions in this module

v1

v1.1.0-alpha

Sep 10, 2019

v1.0.7

Jun 21, 2021

v1.0.6

Jun 17, 2020

v1.0.5

Apr 27, 2020

v1.0.4

Mar 13, 2020

v1.0.4-hotfix-2

Apr 29, 2021

v1.0.4-hotfix

Mar 19, 2020

v1.0.3

Dec 13, 2019

v1.0.2

Oct 30, 2019

Changes in this version

type BreakWorkerDDLLockRequest

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

+ func (m *BreakWorkerDDLLockRequest) XXX_DiscardUnknown()

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

+ func (m *BreakWorkerDDLLockRequest) XXX_Size() int

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

type BreakWorkerDDLLockResponse

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

+ func (m *BreakWorkerDDLLockResponse) XXX_DiscardUnknown()

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

+ func (m *BreakWorkerDDLLockResponse) XXX_Size() int

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

type CheckTaskRequest

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

+ func (m *CheckTaskRequest) XXX_DiscardUnknown()

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

+ func (m *CheckTaskRequest) XXX_Size() int

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

type CheckTaskResponse

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

+ func (m *CheckTaskResponse) XXX_DiscardUnknown()

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

+ func (m *CheckTaskResponse) XXX_Size() int

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

type DDLLock

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

+ func (m *DDLLock) XXX_DiscardUnknown()

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

+ func (m *DDLLock) XXX_Size() int

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

type ExecDDLRequest

+ DDLs []string

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

type HandleSQLsRequest

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

+ func (m *HandleSQLsRequest) XXX_DiscardUnknown()

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

+ func (m *HandleSQLsRequest) XXX_Size() int

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

type HandleSQLsResponse

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

+ func (m *HandleSQLsResponse) XXX_DiscardUnknown()

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

+ func (m *HandleSQLsResponse) XXX_Size() int

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

type MigrateWorkerRelayRequest

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

+ func (m *MigrateWorkerRelayRequest) XXX_DiscardUnknown()

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

+ func (m *MigrateWorkerRelayRequest) XXX_Size() int

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

type OperateTaskRequest

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

+ func (m *OperateTaskRequest) XXX_DiscardUnknown()

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

+ func (m *OperateTaskRequest) XXX_Size() int

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

type OperateTaskResponse

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

+ func (m *OperateTaskResponse) XXX_DiscardUnknown()

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

+ func (m *OperateTaskResponse) XXX_Size() int

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

type OperateWorkerRelayRequest

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

+ func (m *OperateWorkerRelayRequest) XXX_DiscardUnknown()

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

+ func (m *OperateWorkerRelayRequest) XXX_Size() int

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

type OperateWorkerRelayResponse

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

+ func (m *OperateWorkerRelayResponse) XXX_DiscardUnknown()

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

+ func (m *OperateWorkerRelayResponse) XXX_Size() int

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

type ProcessError

+ Error *TError

+ func (m *ProcessError) GetError() *TError

type PurgeWorkerRelayRequest

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

+ func (m *PurgeWorkerRelayRequest) XXX_DiscardUnknown()

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

+ func (m *PurgeWorkerRelayRequest) XXX_Size() int

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

type PurgeWorkerRelayResponse

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

+ func (m *PurgeWorkerRelayResponse) XXX_DiscardUnknown()

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

+ func (m *PurgeWorkerRelayResponse) XXX_Size() int

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

type QueryErrorListRequest

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

+ func (m *QueryErrorListRequest) XXX_DiscardUnknown()

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

+ func (m *QueryErrorListRequest) XXX_Size() int

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

type QueryErrorListResponse

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

+ func (m *QueryErrorListResponse) XXX_DiscardUnknown()

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

+ func (m *QueryErrorListResponse) XXX_Size() int

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

type QueryStatusListRequest

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

+ func (m *QueryStatusListRequest) XXX_DiscardUnknown()

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

+ func (m *QueryStatusListRequest) XXX_Size() int

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

type QueryStatusListResponse

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

+ func (m *QueryStatusListResponse) XXX_DiscardUnknown()

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

+ func (m *QueryStatusListResponse) XXX_Size() int

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

type RefreshWorkerTasksMsg

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

+ func (m *RefreshWorkerTasksMsg) XXX_DiscardUnknown()

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

+ func (m *RefreshWorkerTasksMsg) XXX_Size() int

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

type RefreshWorkerTasksRequest

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

+ func (m *RefreshWorkerTasksRequest) XXX_DiscardUnknown()

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

+ func (m *RefreshWorkerTasksRequest) XXX_Size() int

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

type RefreshWorkerTasksResponse

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

+ func (m *RefreshWorkerTasksResponse) XXX_DiscardUnknown()

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

+ func (m *RefreshWorkerTasksResponse) XXX_Size() int

+ func (m *RefreshWorkerTasksResponse) XXX_Unmarshal(b []byte) error

type ShowDDLLocksRequest

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

+ func (m *ShowDDLLocksRequest) XXX_DiscardUnknown()

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

+ func (m *ShowDDLLocksRequest) XXX_Size() int

+ func (m *ShowDDLLocksRequest) XXX_Unmarshal(b []byte) error

type ShowDDLLocksResponse

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

+ func (m *ShowDDLLocksResponse) XXX_DiscardUnknown()

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

+ func (m *ShowDDLLocksResponse) XXX_Size() int

+ func (m *ShowDDLLocksResponse) XXX_Unmarshal(b []byte) error

type StartTaskRequest

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

+ func (m *StartTaskRequest) XXX_DiscardUnknown()

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

+ func (m *StartTaskRequest) XXX_Size() int

+ func (m *StartTaskRequest) XXX_Unmarshal(b []byte) error

type StartTaskResponse

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

+ func (m *StartTaskResponse) XXX_DiscardUnknown()

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

+ func (m *StartTaskResponse) XXX_Size() int

+ func (m *StartTaskResponse) XXX_Unmarshal(b []byte) error

type SwitchWorkerRelayMasterRequest

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

+ func (m *SwitchWorkerRelayMasterRequest) XXX_DiscardUnknown()

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

+ func (m *SwitchWorkerRelayMasterRequest) XXX_Size() int

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

type SwitchWorkerRelayMasterResponse

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

+ func (m *SwitchWorkerRelayMasterResponse) XXX_DiscardUnknown()

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

+ func (m *SwitchWorkerRelayMasterResponse) XXX_Size() int

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

+ type TError struct

+ ErrClass int32

+ ErrCode int32

+ ErrLevel int32

+ ErrScope int32

+ Message string

+ RawCause string

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

+ func (*TError) ProtoMessage()

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

+ func (m *TError) GetErrClass() int32

+ func (m *TError) GetErrCode() int32

+ func (m *TError) GetErrLevel() int32

+ func (m *TError) GetErrScope() int32

+ func (m *TError) GetMessage() string

+ func (m *TError) GetRawCause() string

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

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

+ func (m *TError) Reset()

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

+ func (m *TError) String() string

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

+ func (m *TError) XXX_DiscardUnknown()

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

+ func (m *TError) XXX_Size() int

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

type UnlockDDLLockRequest

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

+ func (m *UnlockDDLLockRequest) XXX_DiscardUnknown()

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

+ func (m *UnlockDDLLockRequest) XXX_Size() int

+ func (m *UnlockDDLLockRequest) XXX_Unmarshal(b []byte) error

type UnlockDDLLockResponse

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

+ func (m *UnlockDDLLockResponse) XXX_DiscardUnknown()

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

+ func (m *UnlockDDLLockResponse) XXX_Size() int

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

type UpdateMasterConfigRequest

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

+ func (m *UpdateMasterConfigRequest) XXX_DiscardUnknown()

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

+ func (m *UpdateMasterConfigRequest) XXX_Size() int

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

type UpdateMasterConfigResponse

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

+ func (m *UpdateMasterConfigResponse) XXX_DiscardUnknown()

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

+ func (m *UpdateMasterConfigResponse) XXX_Size() int

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

type UpdateTaskRequest

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

+ func (m *UpdateTaskRequest) XXX_DiscardUnknown()

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

+ func (m *UpdateTaskRequest) XXX_Size() int

+ func (m *UpdateTaskRequest) XXX_Unmarshal(b []byte) error

type UpdateTaskResponse

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

+ func (m *UpdateTaskResponse) XXX_DiscardUnknown()

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

+ func (m *UpdateTaskResponse) XXX_Size() int

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

type UpdateWorkerRelayConfigRequest

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

+ func (m *UpdateWorkerRelayConfigRequest) XXX_DiscardUnknown()

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

+ func (m *UpdateWorkerRelayConfigRequest) XXX_Size() int

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

v1.0.1

Sep 10, 2019

v1.0.0

Sep 6, 2019

Changes in this version

+ var ErrIntOverflowDmmaster = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowDmworker = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowTracer = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowTracerBase = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowTracerSyncer = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthDmmaster = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthDmworker = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthTracer = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthTracerBase = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthTracerSyncer = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrorType_name = map[int32]string

+ var ErrorType_value = map[string]int32

+ var RelayOp_name = map[int32]string

+ var RelayOp_value = map[string]int32

+ var SQLOp_name = map[int32]string

+ var SQLOp_value = map[string]int32

+ var Stage_name = map[int32]string

+ var Stage_value = map[string]int32

+ var SyncerJobState_name = map[int32]string

+ var SyncerJobState_value = map[string]int32

+ var TaskOp_name = map[int32]string

+ var TaskOp_value = map[string]int32

+ var TraceType_name = map[int32]string

+ var TraceType_value = map[string]int32

+ var UnitType_name = map[int32]string

+ var UnitType_value = map[string]int32

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

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

+ func RegisterMasterHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)

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

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

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

+ type BaseEvent struct

+ Filename string

+ GroupID string

+ Line int32

+ TraceID string

+ Tso int64

+ Type TraceType

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

+ func (*BaseEvent) ProtoMessage()

+ func (m *BaseEvent) GetFilename() string

+ func (m *BaseEvent) GetGroupID() string

+ func (m *BaseEvent) GetLine() int32

+ func (m *BaseEvent) GetTraceID() string

+ func (m *BaseEvent) GetTso() int64

+ func (m *BaseEvent) GetType() TraceType

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

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

+ func (m *BaseEvent) Reset()

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

+ func (m *BaseEvent) String() string

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

+ func (m *BaseEvent) XXX_DiscardUnknown()

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

+ func (m *BaseEvent) XXX_Merge(src proto.Message)

+ func (m *BaseEvent) XXX_Size() int

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

+ type BreakDDLLockRequest struct

+ ExecDDL bool

+ RemoveLockID string

+ SkipDDL bool

+ Task string

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

+ func (*BreakDDLLockRequest) ProtoMessage()

+ func (m *BreakDDLLockRequest) GetExecDDL() bool

+ func (m *BreakDDLLockRequest) GetRemoveLockID() string

+ func (m *BreakDDLLockRequest) GetSkipDDL() bool

+ func (m *BreakDDLLockRequest) GetTask() string

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

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

+ func (m *BreakDDLLockRequest) Reset()

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

+ func (m *BreakDDLLockRequest) String() string

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

+ func (m *BreakDDLLockRequest) XXX_DiscardUnknown()

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

+ func (m *BreakDDLLockRequest) XXX_Merge(src proto.Message)

+ func (m *BreakDDLLockRequest) XXX_Size() int

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

+ type BreakWorkerDDLLockRequest struct

+ ExecDDL bool

+ RemoveLockID string

+ SkipDDL bool

+ Task string

+ Workers []string

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

+ func (*BreakWorkerDDLLockRequest) ProtoMessage()

+ func (m *BreakWorkerDDLLockRequest) GetExecDDL() bool

+ func (m *BreakWorkerDDLLockRequest) GetRemoveLockID() string

+ func (m *BreakWorkerDDLLockRequest) GetSkipDDL() bool

+ func (m *BreakWorkerDDLLockRequest) GetTask() string

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

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

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

+ func (m *BreakWorkerDDLLockRequest) Reset()

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

+ func (m *BreakWorkerDDLLockRequest) String() string

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

+ type BreakWorkerDDLLockResponse struct

+ Msg string

+ Result bool

+ Workers []*CommonWorkerResponse

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

+ func (*BreakWorkerDDLLockResponse) ProtoMessage()

+ func (m *BreakWorkerDDLLockResponse) GetMsg() string

+ func (m *BreakWorkerDDLLockResponse) GetResult() bool

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

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

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

+ func (m *BreakWorkerDDLLockResponse) Reset()

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

+ func (m *BreakWorkerDDLLockResponse) String() string

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

+ type CheckError struct

+ Msg string

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

+ func (*CheckError) ProtoMessage()

+ func (m *CheckError) GetMsg() string

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

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

+ func (m *CheckError) Reset()

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

+ func (m *CheckError) String() string

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

+ func (m *CheckError) XXX_DiscardUnknown()

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

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

+ func (m *CheckError) XXX_Size() int

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

+ type CheckStatus struct

+ Detail []byte

+ Failed int32

+ Passed bool

+ Successful int32

+ Total int32

+ Warning int32

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

+ func (*CheckStatus) ProtoMessage()

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

+ func (m *CheckStatus) GetFailed() int32

+ func (m *CheckStatus) GetPassed() bool

+ func (m *CheckStatus) GetSuccessful() int32

+ func (m *CheckStatus) GetTotal() int32

+ func (m *CheckStatus) GetWarning() int32

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

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

+ func (m *CheckStatus) Reset()

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

+ func (m *CheckStatus) String() string

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

+ func (m *CheckStatus) XXX_DiscardUnknown()

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

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

+ func (m *CheckStatus) XXX_Size() int

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

+ type CheckTaskRequest struct

+ Task string

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

+ func (*CheckTaskRequest) ProtoMessage()

+ func (m *CheckTaskRequest) GetTask() string

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

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

+ func (m *CheckTaskRequest) Reset()

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

+ func (m *CheckTaskRequest) String() string

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

+ type CheckTaskResponse struct

+ Msg string

+ Result bool

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

+ func (*CheckTaskResponse) ProtoMessage()

+ func (m *CheckTaskResponse) GetMsg() string

+ func (m *CheckTaskResponse) GetResult() bool

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

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

+ func (m *CheckTaskResponse) Reset()

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

+ func (m *CheckTaskResponse) String() string

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

+ type CommonUploadResponse struct

+ Msg string

+ Result bool

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

+ func (*CommonUploadResponse) ProtoMessage()

+ func (m *CommonUploadResponse) GetMsg() string

+ func (m *CommonUploadResponse) GetResult() bool

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

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

+ func (m *CommonUploadResponse) Reset()

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

+ func (m *CommonUploadResponse) String() string

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

+ func (m *CommonUploadResponse) XXX_DiscardUnknown()

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

+ func (m *CommonUploadResponse) XXX_Merge(src proto.Message)

+ func (m *CommonUploadResponse) XXX_Size() int

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

+ type CommonWorkerResponse struct

+ Msg string

+ Result bool

+ Worker string

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

+ func (*CommonWorkerResponse) ProtoMessage()

+ func (m *CommonWorkerResponse) GetMsg() string

+ func (m *CommonWorkerResponse) GetResult() bool

+ func (m *CommonWorkerResponse) GetWorker() string

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

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

+ func (m *CommonWorkerResponse) Reset()

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

+ func (m *CommonWorkerResponse) String() string

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

+ func (m *CommonWorkerResponse) XXX_DiscardUnknown()

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

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

+ func (m *CommonWorkerResponse) XXX_Size() int

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

+ type DDLInfo struct

+ DDLs []string

+ Schema string

+ Table string

+ Task string

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

+ func (*DDLInfo) ProtoMessage()

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

+ func (m *DDLInfo) GetSchema() string

+ func (m *DDLInfo) GetTable() string

+ func (m *DDLInfo) GetTask() string

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

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

+ func (m *DDLInfo) Reset()

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

+ func (m *DDLInfo) String() string

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

+ func (m *DDLInfo) XXX_DiscardUnknown()

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

+ func (m *DDLInfo) XXX_Merge(src proto.Message)

+ func (m *DDLInfo) XXX_Size() int

+ func (m *DDLInfo) XXX_Unmarshal(b []byte) error

+ type DDLLock struct

+ DDLs []string

+ ID string

+ Owner string

+ Synced []string

+ Task string

+ Unsynced []string

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

+ func (*DDLLock) ProtoMessage()

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

+ func (m *DDLLock) GetID() string

+ func (m *DDLLock) GetOwner() string

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

+ func (m *DDLLock) GetTask() string

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

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

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

+ func (m *DDLLock) Reset()

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

+ func (m *DDLLock) String() string

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

+ type DDLLockInfo struct

+ ID string

+ Task string

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

+ func (*DDLLockInfo) ProtoMessage()

+ func (m *DDLLockInfo) GetID() string

+ func (m *DDLLockInfo) GetTask() string

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

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

+ func (m *DDLLockInfo) Reset()

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

+ func (m *DDLLockInfo) String() string

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

+ func (m *DDLLockInfo) XXX_DiscardUnknown()

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

+ func (m *DDLLockInfo) XXX_Merge(src proto.Message)

+ func (m *DDLLockInfo) XXX_Size() int

+ func (m *DDLLockInfo) XXX_Unmarshal(b []byte) error

+ type DumpError struct

+ Msg string

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

+ func (*DumpError) ProtoMessage()

+ func (m *DumpError) GetMsg() string

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

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

+ func (m *DumpError) Reset()

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

+ func (m *DumpError) String() string

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

+ func (m *DumpError) XXX_DiscardUnknown()

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

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

+ func (m *DumpError) XXX_Size() int

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

+ type DumpStatus struct

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

+ func (*DumpStatus) ProtoMessage()

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

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

+ func (m *DumpStatus) Reset()

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

+ func (m *DumpStatus) String() string

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

+ func (m *DumpStatus) XXX_DiscardUnknown()

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

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

+ func (m *DumpStatus) XXX_Size() int

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

+ type ErrorType int32

+ const ErrorType_CheckFailed

+ const ErrorType_ExecSQL

+ const ErrorType_UnknownError

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

+ func (x ErrorType) String() string

+ type ExecDDLInfo struct

+ Exec bool

+ LockID string

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

+ func (*ExecDDLInfo) ProtoMessage()

+ func (m *ExecDDLInfo) GetExec() bool

+ func (m *ExecDDLInfo) GetLockID() string

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

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

+ func (m *ExecDDLInfo) Reset()

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

+ func (m *ExecDDLInfo) String() string

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

+ func (m *ExecDDLInfo) XXX_DiscardUnknown()

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

+ func (m *ExecDDLInfo) XXX_Merge(src proto.Message)

+ func (m *ExecDDLInfo) XXX_Size() int

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

+ type ExecDDLRequest struct

+ Exec bool

+ LockID string

+ Task string

+ TraceGID string

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

+ func (*ExecDDLRequest) ProtoMessage()

+ func (m *ExecDDLRequest) GetExec() bool

+ func (m *ExecDDLRequest) GetLockID() string

+ func (m *ExecDDLRequest) GetTask() string

+ func (m *ExecDDLRequest) GetTraceGID() string

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

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

+ func (m *ExecDDLRequest) Reset()

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

+ func (m *ExecDDLRequest) String() string

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

+ func (m *ExecDDLRequest) XXX_DiscardUnknown()

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

+ func (m *ExecDDLRequest) XXX_Merge(src proto.Message)

+ func (m *ExecDDLRequest) XXX_Size() int

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

+ type GetTSORequest struct

+ Id string

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

+ func (*GetTSORequest) ProtoMessage()

+ func (m *GetTSORequest) GetId() string

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

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

+ func (m *GetTSORequest) Reset()

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

+ func (m *GetTSORequest) String() string

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

+ func (m *GetTSORequest) XXX_DiscardUnknown()

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

+ func (m *GetTSORequest) XXX_Merge(src proto.Message)

+ func (m *GetTSORequest) XXX_Size() int

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

+ type GetTSOResponse struct

+ Msg string

+ Result bool

+ Ts int64

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

+ func (*GetTSOResponse) ProtoMessage()

+ func (m *GetTSOResponse) GetMsg() string

+ func (m *GetTSOResponse) GetResult() bool

+ func (m *GetTSOResponse) GetTs() int64

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

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

+ func (m *GetTSOResponse) Reset()

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

+ func (m *GetTSOResponse) String() string

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

+ func (m *GetTSOResponse) XXX_DiscardUnknown()

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

+ func (m *GetTSOResponse) XXX_Merge(src proto.Message)

+ func (m *GetTSOResponse) XXX_Size() int

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

+ type HandleSQLsRequest struct

+ Args []string

+ BinlogPos string

+ Name string

+ Op SQLOp

+ Sharding bool

+ SqlPattern string

+ Worker string

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

+ func (*HandleSQLsRequest) ProtoMessage()

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

+ func (m *HandleSQLsRequest) GetBinlogPos() string

+ func (m *HandleSQLsRequest) GetName() string

+ func (m *HandleSQLsRequest) GetOp() SQLOp

+ func (m *HandleSQLsRequest) GetSharding() bool

+ func (m *HandleSQLsRequest) GetSqlPattern() string

+ func (m *HandleSQLsRequest) GetWorker() string

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

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

+ func (m *HandleSQLsRequest) Reset()

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

+ func (m *HandleSQLsRequest) String() string

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

+ type HandleSQLsResponse struct

+ Msg string

+ Result bool

+ Workers []*CommonWorkerResponse

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

+ func (*HandleSQLsResponse) ProtoMessage()

+ func (m *HandleSQLsResponse) GetMsg() string

+ func (m *HandleSQLsResponse) GetResult() bool

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

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

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

+ func (m *HandleSQLsResponse) Reset()

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

+ func (m *HandleSQLsResponse) String() string

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

+ type HandleSubTaskSQLsRequest struct

+ Args []string

+ BinlogPos string

+ Name string

+ Op SQLOp

+ SqlPattern string

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

+ func (*HandleSubTaskSQLsRequest) ProtoMessage()

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

+ func (m *HandleSubTaskSQLsRequest) GetBinlogPos() string

+ func (m *HandleSubTaskSQLsRequest) GetName() string

+ func (m *HandleSubTaskSQLsRequest) GetOp() SQLOp

+ func (m *HandleSubTaskSQLsRequest) GetSqlPattern() string

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

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

+ func (m *HandleSubTaskSQLsRequest) Reset()

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

+ func (m *HandleSubTaskSQLsRequest) String() string

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

+ func (m *HandleSubTaskSQLsRequest) XXX_DiscardUnknown()

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

+ func (m *HandleSubTaskSQLsRequest) XXX_Merge(src proto.Message)

+ func (m *HandleSubTaskSQLsRequest) XXX_Size() int

+ func (m *HandleSubTaskSQLsRequest) XXX_Unmarshal(b []byte) error

+ type LoadError struct

+ Msg string

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

+ func (*LoadError) ProtoMessage()

+ func (m *LoadError) GetMsg() string

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

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

+ func (m *LoadError) Reset()

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

+ func (m *LoadError) String() string

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

+ func (m *LoadError) XXX_DiscardUnknown()

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

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

+ func (m *LoadError) XXX_Size() int

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

+ type LoadStatus struct

+ FinishedBytes int64

+ MetaBinlog string

+ Progress string

+ TotalBytes int64

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

+ func (*LoadStatus) ProtoMessage()

+ func (m *LoadStatus) GetFinishedBytes() int64

+ func (m *LoadStatus) GetMetaBinlog() string

+ func (m *LoadStatus) GetProgress() string

+ func (m *LoadStatus) GetTotalBytes() int64

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

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

+ func (m *LoadStatus) Reset()

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

+ func (m *LoadStatus) String() string

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

+ func (m *LoadStatus) XXX_DiscardUnknown()

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

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

+ func (m *LoadStatus) XXX_Size() int

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

+ type MasterClient interface

+ BreakWorkerDDLLock func(ctx context.Context, in *BreakWorkerDDLLockRequest, opts ...grpc.CallOption) (*BreakWorkerDDLLockResponse, error)

+ CheckTask func(ctx context.Context, in *CheckTaskRequest, opts ...grpc.CallOption) (*CheckTaskResponse, error)

+ HandleSQLs func(ctx context.Context, in *HandleSQLsRequest, opts ...grpc.CallOption) (*HandleSQLsResponse, error)

+ MigrateWorkerRelay func(ctx context.Context, in *MigrateWorkerRelayRequest, opts ...grpc.CallOption) (*CommonWorkerResponse, error)

+ OperateTask func(ctx context.Context, in *OperateTaskRequest, opts ...grpc.CallOption) (*OperateTaskResponse, error)

+ OperateWorkerRelayTask func(ctx context.Context, in *OperateWorkerRelayRequest, opts ...grpc.CallOption) (*OperateWorkerRelayResponse, error)

+ PurgeWorkerRelay func(ctx context.Context, in *PurgeWorkerRelayRequest, opts ...grpc.CallOption) (*PurgeWorkerRelayResponse, error)

+ QueryError func(ctx context.Context, in *QueryErrorListRequest, opts ...grpc.CallOption) (*QueryErrorListResponse, error)

+ QueryStatus func(ctx context.Context, in *QueryStatusListRequest, opts ...grpc.CallOption) (*QueryStatusListResponse, error)

+ RefreshWorkerTasks func(ctx context.Context, in *RefreshWorkerTasksRequest, opts ...grpc.CallOption) (*RefreshWorkerTasksResponse, error)

+ ShowDDLLocks func(ctx context.Context, in *ShowDDLLocksRequest, opts ...grpc.CallOption) (*ShowDDLLocksResponse, error)

+ StartTask func(ctx context.Context, in *StartTaskRequest, opts ...grpc.CallOption) (*StartTaskResponse, error)

+ SwitchWorkerRelayMaster func(ctx context.Context, in *SwitchWorkerRelayMasterRequest, ...) (*SwitchWorkerRelayMasterResponse, error)

+ UnlockDDLLock func(ctx context.Context, in *UnlockDDLLockRequest, opts ...grpc.CallOption) (*UnlockDDLLockResponse, error)

+ UpdateMasterConfig func(ctx context.Context, in *UpdateMasterConfigRequest, opts ...grpc.CallOption) (*UpdateMasterConfigResponse, error)

+ UpdateTask func(ctx context.Context, in *UpdateTaskRequest, opts ...grpc.CallOption) (*UpdateTaskResponse, error)

+ UpdateWorkerRelayConfig func(ctx context.Context, in *UpdateWorkerRelayConfigRequest, ...) (*CommonWorkerResponse, error)

+ func NewMasterClient(cc *grpc.ClientConn) MasterClient

+ type MasterServer interface

+ BreakWorkerDDLLock func(context.Context, *BreakWorkerDDLLockRequest) (*BreakWorkerDDLLockResponse, error)

+ CheckTask func(context.Context, *CheckTaskRequest) (*CheckTaskResponse, error)

+ HandleSQLs func(context.Context, *HandleSQLsRequest) (*HandleSQLsResponse, error)

+ MigrateWorkerRelay func(context.Context, *MigrateWorkerRelayRequest) (*CommonWorkerResponse, error)

+ OperateTask func(context.Context, *OperateTaskRequest) (*OperateTaskResponse, error)

+ OperateWorkerRelayTask func(context.Context, *OperateWorkerRelayRequest) (*OperateWorkerRelayResponse, error)

+ PurgeWorkerRelay func(context.Context, *PurgeWorkerRelayRequest) (*PurgeWorkerRelayResponse, error)

+ QueryError func(context.Context, *QueryErrorListRequest) (*QueryErrorListResponse, error)

+ QueryStatus func(context.Context, *QueryStatusListRequest) (*QueryStatusListResponse, error)

+ RefreshWorkerTasks func(context.Context, *RefreshWorkerTasksRequest) (*RefreshWorkerTasksResponse, error)

+ ShowDDLLocks func(context.Context, *ShowDDLLocksRequest) (*ShowDDLLocksResponse, error)

+ StartTask func(context.Context, *StartTaskRequest) (*StartTaskResponse, error)

+ SwitchWorkerRelayMaster func(context.Context, *SwitchWorkerRelayMasterRequest) (*SwitchWorkerRelayMasterResponse, error)

+ UnlockDDLLock func(context.Context, *UnlockDDLLockRequest) (*UnlockDDLLockResponse, error)

+ UpdateMasterConfig func(context.Context, *UpdateMasterConfigRequest) (*UpdateMasterConfigResponse, error)

+ UpdateTask func(context.Context, *UpdateTaskRequest) (*UpdateTaskResponse, error)

+ UpdateWorkerRelayConfig func(context.Context, *UpdateWorkerRelayConfigRequest) (*CommonWorkerResponse, error)

+ type MigrateRelayRequest struct

+ BinlogName string

+ BinlogPos uint32

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

+ func (*MigrateRelayRequest) ProtoMessage()

+ func (m *MigrateRelayRequest) GetBinlogName() string

+ func (m *MigrateRelayRequest) GetBinlogPos() uint32

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

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

+ func (m *MigrateRelayRequest) Reset()

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

+ func (m *MigrateRelayRequest) String() string

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

+ func (m *MigrateRelayRequest) XXX_DiscardUnknown()

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

+ func (m *MigrateRelayRequest) XXX_Merge(src proto.Message)

+ func (m *MigrateRelayRequest) XXX_Size() int

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

+ type MigrateWorkerRelayRequest struct

+ BinlogName string

+ BinlogPos uint32

+ Worker string

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

+ func (*MigrateWorkerRelayRequest) ProtoMessage()

+ func (m *MigrateWorkerRelayRequest) GetBinlogName() string

+ func (m *MigrateWorkerRelayRequest) GetBinlogPos() uint32

+ func (m *MigrateWorkerRelayRequest) GetWorker() string

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

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

+ func (m *MigrateWorkerRelayRequest) Reset()

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

+ func (m *MigrateWorkerRelayRequest) String() string

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

+ type MySQLPosition struct

+ Name string

+ Pos uint32

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

+ func (*MySQLPosition) ProtoMessage()

+ func (m *MySQLPosition) GetName() string

+ func (m *MySQLPosition) GetPos() uint32

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

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

+ func (m *MySQLPosition) Reset()

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

+ func (m *MySQLPosition) String() string

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

+ func (m *MySQLPosition) XXX_DiscardUnknown()

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

+ func (m *MySQLPosition) XXX_Merge(src proto.Message)

+ func (m *MySQLPosition) XXX_Size() int

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

+ type OperateRelayRequest struct

+ Op RelayOp

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

+ func (*OperateRelayRequest) ProtoMessage()

+ func (m *OperateRelayRequest) GetOp() RelayOp

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

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

+ func (m *OperateRelayRequest) Reset()

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

+ func (m *OperateRelayRequest) String() string

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

+ func (m *OperateRelayRequest) XXX_DiscardUnknown()

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

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

+ func (m *OperateRelayRequest) XXX_Size() int

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

+ type OperateRelayResponse struct

+ Msg string

+ Op RelayOp

+ Result bool

+ Worker string

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

+ func (*OperateRelayResponse) ProtoMessage()

+ func (m *OperateRelayResponse) GetMsg() string

+ func (m *OperateRelayResponse) GetOp() RelayOp

+ func (m *OperateRelayResponse) GetResult() bool

+ func (m *OperateRelayResponse) GetWorker() string

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

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

+ func (m *OperateRelayResponse) Reset()

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

+ func (m *OperateRelayResponse) String() string

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

+ func (m *OperateRelayResponse) XXX_DiscardUnknown()

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

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

+ func (m *OperateRelayResponse) XXX_Size() int

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

+ type OperateSubTaskRequest struct

+ Name string

+ Op TaskOp

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

+ func (*OperateSubTaskRequest) ProtoMessage()

+ func (m *OperateSubTaskRequest) GetName() string

+ func (m *OperateSubTaskRequest) GetOp() TaskOp

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

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

+ func (m *OperateSubTaskRequest) Reset()

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

+ func (m *OperateSubTaskRequest) String() string

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

+ func (m *OperateSubTaskRequest) XXX_DiscardUnknown()

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

+ func (m *OperateSubTaskRequest) XXX_Merge(src proto.Message)

+ func (m *OperateSubTaskRequest) XXX_Size() int

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

+ type OperateSubTaskResponse struct

+ LogID int64

+ Meta *CommonWorkerResponse

+ Op TaskOp

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

+ func (*OperateSubTaskResponse) ProtoMessage()

+ func (m *OperateSubTaskResponse) GetLogID() int64

+ func (m *OperateSubTaskResponse) GetMeta() *CommonWorkerResponse

+ func (m *OperateSubTaskResponse) GetOp() TaskOp

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

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

+ func (m *OperateSubTaskResponse) Reset()

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

+ func (m *OperateSubTaskResponse) String() string

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

+ func (m *OperateSubTaskResponse) XXX_DiscardUnknown()

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

+ func (m *OperateSubTaskResponse) XXX_Merge(src proto.Message)

+ func (m *OperateSubTaskResponse) XXX_Size() int

+ func (m *OperateSubTaskResponse) XXX_Unmarshal(b []byte) error

+ type OperateTaskRequest struct

+ Name string

+ Op TaskOp

+ Workers []string

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

+ func (*OperateTaskRequest) ProtoMessage()

+ func (m *OperateTaskRequest) GetName() string

+ func (m *OperateTaskRequest) GetOp() TaskOp

+ func (m *OperateTaskRequest) GetWorkers() []string

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

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

+ func (m *OperateTaskRequest) Reset()

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

+ func (m *OperateTaskRequest) String() string

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

+ type OperateTaskResponse struct

+ Msg string

+ Op TaskOp

+ Result bool

+ Workers []*OperateSubTaskResponse

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

+ func (*OperateTaskResponse) ProtoMessage()

+ func (m *OperateTaskResponse) GetMsg() string

+ func (m *OperateTaskResponse) GetOp() TaskOp

+ func (m *OperateTaskResponse) GetResult() bool

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

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

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

+ func (m *OperateTaskResponse) Reset()

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

+ func (m *OperateTaskResponse) String() string

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

+ type OperateWorkerRelayRequest struct

+ Op RelayOp

+ Workers []string

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

+ func (*OperateWorkerRelayRequest) ProtoMessage()

+ func (m *OperateWorkerRelayRequest) GetOp() RelayOp

+ func (m *OperateWorkerRelayRequest) GetWorkers() []string

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

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

+ func (m *OperateWorkerRelayRequest) Reset()

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

+ func (m *OperateWorkerRelayRequest) String() string

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

+ type OperateWorkerRelayResponse struct

+ Msg string

+ Op RelayOp

+ Result bool

+ Workers []*OperateRelayResponse

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

+ func (*OperateWorkerRelayResponse) ProtoMessage()

+ func (m *OperateWorkerRelayResponse) GetMsg() string

+ func (m *OperateWorkerRelayResponse) GetOp() RelayOp

+ func (m *OperateWorkerRelayResponse) GetResult() bool

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

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

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

+ func (m *OperateWorkerRelayResponse) Reset()

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

+ func (m *OperateWorkerRelayResponse) String() string

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

+ type ProcessError struct

+ Msg string

+ Type ErrorType

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

+ func (*ProcessError) ProtoMessage()

+ func (m *ProcessError) GetMsg() string

+ func (m *ProcessError) GetType() ErrorType

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

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

+ func (m *ProcessError) Reset()

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

+ func (m *ProcessError) String() string

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

+ func (m *ProcessError) XXX_DiscardUnknown()

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

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

+ func (m *ProcessError) XXX_Size() int

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

+ type ProcessResult struct

+ Detail []byte

+ Errors []*ProcessError

+ IsCanceled bool

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

+ func (*ProcessResult) ProtoMessage()

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

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

+ func (m *ProcessResult) GetIsCanceled() bool

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

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

+ func (m *ProcessResult) Reset()

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

+ func (m *ProcessResult) String() string

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

+ func (m *ProcessResult) XXX_DiscardUnknown()

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

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

+ func (m *ProcessResult) XXX_Size() int

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

+ type PurgeRelayRequest struct

+ Filename string

+ Inactive bool

+ SubDir string

+ Time int64

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

+ func (*PurgeRelayRequest) ProtoMessage()

+ func (m *PurgeRelayRequest) GetFilename() string

+ func (m *PurgeRelayRequest) GetInactive() bool

+ func (m *PurgeRelayRequest) GetSubDir() string

+ func (m *PurgeRelayRequest) GetTime() int64

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

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

+ func (m *PurgeRelayRequest) Reset()

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

+ func (m *PurgeRelayRequest) String() string

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

+ func (m *PurgeRelayRequest) XXX_DiscardUnknown()

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

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

+ func (m *PurgeRelayRequest) XXX_Size() int

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

+ type PurgeWorkerRelayRequest struct

+ Filename string

+ Inactive bool

+ SubDir string

+ Time int64

+ Workers []string

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

+ func (*PurgeWorkerRelayRequest) ProtoMessage()

+ func (m *PurgeWorkerRelayRequest) GetFilename() string

+ func (m *PurgeWorkerRelayRequest) GetInactive() bool

+ func (m *PurgeWorkerRelayRequest) GetSubDir() string

+ func (m *PurgeWorkerRelayRequest) GetTime() int64

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

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

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

+ func (m *PurgeWorkerRelayRequest) Reset()

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

+ func (m *PurgeWorkerRelayRequest) String() string

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

+ type PurgeWorkerRelayResponse struct

+ Msg string

+ Result bool

+ Workers []*CommonWorkerResponse

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

+ func (*PurgeWorkerRelayResponse) ProtoMessage()

+ func (m *PurgeWorkerRelayResponse) GetMsg() string

+ func (m *PurgeWorkerRelayResponse) GetResult() bool

+ func (m *PurgeWorkerRelayResponse) GetWorkers() []*CommonWorkerResponse

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

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

+ func (m *PurgeWorkerRelayResponse) Reset()

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

+ func (m *PurgeWorkerRelayResponse) String() string

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

+ type QueryErrorListRequest struct

+ Name string

+ Workers []string

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

+ func (*QueryErrorListRequest) ProtoMessage()

+ func (m *QueryErrorListRequest) GetName() string

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

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

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

+ func (m *QueryErrorListRequest) Reset()

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

+ func (m *QueryErrorListRequest) String() string

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

+ type QueryErrorListResponse struct

+ Msg string

+ Result bool

+ Workers []*QueryErrorResponse

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

+ func (*QueryErrorListResponse) ProtoMessage()

+ func (m *QueryErrorListResponse) GetMsg() string

+ func (m *QueryErrorListResponse) GetResult() bool

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

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

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

+ func (m *QueryErrorListResponse) Reset()

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

+ func (m *QueryErrorListResponse) String() string

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

+ type QueryErrorRequest struct

+ Name string

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

+ func (*QueryErrorRequest) ProtoMessage()

+ func (m *QueryErrorRequest) GetName() string

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

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

+ func (m *QueryErrorRequest) Reset()

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

+ func (m *QueryErrorRequest) String() string

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

+ func (m *QueryErrorRequest) XXX_DiscardUnknown()

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

+ func (m *QueryErrorRequest) XXX_Merge(src proto.Message)

+ func (m *QueryErrorRequest) XXX_Size() int

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

+ type QueryErrorResponse struct

+ Msg string

+ RelayError *RelayError

+ Result bool

+ SubTaskError []*SubTaskError

+ Worker string

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

+ func (*QueryErrorResponse) ProtoMessage()

+ func (m *QueryErrorResponse) GetMsg() string

+ func (m *QueryErrorResponse) GetRelayError() *RelayError

+ func (m *QueryErrorResponse) GetResult() bool

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

+ func (m *QueryErrorResponse) GetWorker() string

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

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

+ func (m *QueryErrorResponse) Reset()

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

+ func (m *QueryErrorResponse) String() string

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

+ func (m *QueryErrorResponse) XXX_DiscardUnknown()

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

+ func (m *QueryErrorResponse) XXX_Merge(src proto.Message)

+ func (m *QueryErrorResponse) XXX_Size() int

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

+ type QueryStatusListRequest struct

+ Name string

+ Workers []string

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

+ func (*QueryStatusListRequest) ProtoMessage()

+ func (m *QueryStatusListRequest) GetName() string

+ func (m *QueryStatusListRequest) GetWorkers() []string

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

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

+ func (m *QueryStatusListRequest) Reset()

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

+ func (m *QueryStatusListRequest) String() string

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

+ type QueryStatusListResponse struct

+ Msg string

+ Result bool

+ Workers []*QueryStatusResponse

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

+ func (*QueryStatusListResponse) ProtoMessage()

+ func (m *QueryStatusListResponse) GetMsg() string

+ func (m *QueryStatusListResponse) GetResult() bool

+ func (m *QueryStatusListResponse) GetWorkers() []*QueryStatusResponse

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

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

+ func (m *QueryStatusListResponse) Reset()

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

+ func (m *QueryStatusListResponse) String() string

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

+ type QueryStatusRequest struct

+ Name string

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

+ func (*QueryStatusRequest) ProtoMessage()

+ func (m *QueryStatusRequest) GetName() string

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

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

+ func (m *QueryStatusRequest) Reset()

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

+ func (m *QueryStatusRequest) String() string

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

+ func (m *QueryStatusRequest) XXX_DiscardUnknown()

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

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

+ func (m *QueryStatusRequest) XXX_Size() int

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

+ type QueryStatusResponse struct

+ Msg string

+ RelayStatus *RelayStatus

+ Result bool

+ SourceID string

+ SubTaskStatus []*SubTaskStatus

+ Worker string

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

+ func (*QueryStatusResponse) ProtoMessage()

+ func (m *QueryStatusResponse) GetMsg() string

+ func (m *QueryStatusResponse) GetRelayStatus() *RelayStatus

+ func (m *QueryStatusResponse) GetResult() bool

+ func (m *QueryStatusResponse) GetSourceID() string

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

+ func (m *QueryStatusResponse) GetWorker() string

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

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

+ func (m *QueryStatusResponse) Reset()

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

+ func (m *QueryStatusResponse) String() string

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

+ func (m *QueryStatusResponse) XXX_DiscardUnknown()

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

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

+ func (m *QueryStatusResponse) XXX_Size() int

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

+ type QueryTaskOperationRequest struct

+ LogID int64

+ Name string

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

+ func (*QueryTaskOperationRequest) ProtoMessage()

+ func (m *QueryTaskOperationRequest) GetLogID() int64

+ func (m *QueryTaskOperationRequest) GetName() string

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

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

+ func (m *QueryTaskOperationRequest) Reset()

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

+ func (m *QueryTaskOperationRequest) String() string

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

+ func (m *QueryTaskOperationRequest) XXX_DiscardUnknown()

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

+ func (m *QueryTaskOperationRequest) XXX_Merge(src proto.Message)

+ func (m *QueryTaskOperationRequest) XXX_Size() int

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

+ type QueryTaskOperationResponse struct

+ Log *TaskLog

+ Meta *CommonWorkerResponse

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

+ func (*QueryTaskOperationResponse) ProtoMessage()

+ func (m *QueryTaskOperationResponse) GetLog() *TaskLog

+ func (m *QueryTaskOperationResponse) GetMeta() *CommonWorkerResponse

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

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

+ func (m *QueryTaskOperationResponse) Reset()

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

+ func (m *QueryTaskOperationResponse) String() string

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

+ func (m *QueryTaskOperationResponse) XXX_DiscardUnknown()

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

+ func (m *QueryTaskOperationResponse) XXX_Merge(src proto.Message)

+ func (m *QueryTaskOperationResponse) XXX_Size() int

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

+ type QueryWorkerConfigRequest struct

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

+ func (*QueryWorkerConfigRequest) ProtoMessage()

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

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

+ func (m *QueryWorkerConfigRequest) Reset()

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

+ func (m *QueryWorkerConfigRequest) String() string

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

+ func (m *QueryWorkerConfigRequest) XXX_DiscardUnknown()

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

+ func (m *QueryWorkerConfigRequest) XXX_Merge(src proto.Message)

+ func (m *QueryWorkerConfigRequest) XXX_Size() int

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

+ type QueryWorkerConfigResponse struct

+ Content string

+ Msg string

+ Result bool

+ SourceID string

+ Worker string

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

+ func (*QueryWorkerConfigResponse) ProtoMessage()

+ func (m *QueryWorkerConfigResponse) GetContent() string

+ func (m *QueryWorkerConfigResponse) GetMsg() string

+ func (m *QueryWorkerConfigResponse) GetResult() bool

+ func (m *QueryWorkerConfigResponse) GetSourceID() string

+ func (m *QueryWorkerConfigResponse) GetWorker() string

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

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

+ func (m *QueryWorkerConfigResponse) Reset()

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

+ func (m *QueryWorkerConfigResponse) String() string

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

+ func (m *QueryWorkerConfigResponse) XXX_DiscardUnknown()

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

+ func (m *QueryWorkerConfigResponse) XXX_Merge(src proto.Message)

+ func (m *QueryWorkerConfigResponse) XXX_Size() int

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

+ type RefreshWorkerTasksMsg struct

+ Msg string

+ Worker string

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

+ func (*RefreshWorkerTasksMsg) ProtoMessage()

+ func (m *RefreshWorkerTasksMsg) GetMsg() string

+ func (m *RefreshWorkerTasksMsg) GetWorker() string

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

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

+ func (m *RefreshWorkerTasksMsg) Reset()

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

+ func (m *RefreshWorkerTasksMsg) String() string

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

+ type RefreshWorkerTasksRequest struct

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

+ func (*RefreshWorkerTasksRequest) ProtoMessage()

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

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

+ func (m *RefreshWorkerTasksRequest) Reset()

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

+ func (m *RefreshWorkerTasksRequest) String() string

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

+ type RefreshWorkerTasksResponse struct

+ Result bool

+ Workers []*RefreshWorkerTasksMsg

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

+ func (*RefreshWorkerTasksResponse) ProtoMessage()

+ func (m *RefreshWorkerTasksResponse) GetResult() bool

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

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

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

+ func (m *RefreshWorkerTasksResponse) Reset()

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

+ func (m *RefreshWorkerTasksResponse) String() string

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

+ type RelayError struct

+ Msg string

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

+ func (*RelayError) ProtoMessage()

+ func (m *RelayError) GetMsg() string

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

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

+ func (m *RelayError) Reset()

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

+ func (m *RelayError) String() string

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

+ func (m *RelayError) XXX_DiscardUnknown()

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

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

+ func (m *RelayError) XXX_Size() int

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

+ type RelayOp int32

+ const RelayOp_InvalidRelayOp

+ const RelayOp_PauseRelay

+ const RelayOp_ResumeRelay

+ const RelayOp_StopRelay

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

+ func (x RelayOp) String() string

+ type RelayStatus struct

+ MasterBinlog string

+ MasterBinlogGtid string

+ RelayBinlog string

+ RelayBinlogGtid string

+ RelayCatchUpMaster bool

+ RelaySubDir string

+ Result *ProcessResult

+ Stage Stage

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

+ func (*RelayStatus) ProtoMessage()

+ func (m *RelayStatus) GetMasterBinlog() string

+ func (m *RelayStatus) GetMasterBinlogGtid() string

+ func (m *RelayStatus) GetRelayBinlog() string

+ func (m *RelayStatus) GetRelayBinlogGtid() string

+ func (m *RelayStatus) GetRelayCatchUpMaster() bool

+ func (m *RelayStatus) GetRelaySubDir() string

+ func (m *RelayStatus) GetResult() *ProcessResult

+ func (m *RelayStatus) GetStage() Stage

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

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

+ func (m *RelayStatus) Reset()

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

+ func (m *RelayStatus) String() string

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

+ func (m *RelayStatus) XXX_DiscardUnknown()

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

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

+ func (m *RelayStatus) XXX_Size() int

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

+ type SQLOp int32

+ const SQLOp_INJECT

+ const SQLOp_REPLACE

+ const SQLOp_SKIP

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

+ func (x SQLOp) String() string

+ type ShardingGroup struct

+ DDLs []string

+ FirstPos string

+ Synced []string

+ Target string

+ Unsynced []string

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

+ func (*ShardingGroup) ProtoMessage()

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

+ func (m *ShardingGroup) GetFirstPos() string

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

+ func (m *ShardingGroup) GetTarget() string

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

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

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

+ func (m *ShardingGroup) Reset()

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

+ func (m *ShardingGroup) String() string

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

+ func (m *ShardingGroup) XXX_DiscardUnknown()

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

+ func (m *ShardingGroup) XXX_Merge(src proto.Message)

+ func (m *ShardingGroup) XXX_Size() int

+ func (m *ShardingGroup) XXX_Unmarshal(b []byte) error

+ type ShowDDLLocksRequest struct

+ Task string

+ Workers []string

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

+ func (*ShowDDLLocksRequest) ProtoMessage()

+ func (m *ShowDDLLocksRequest) GetTask() string

+ func (m *ShowDDLLocksRequest) GetWorkers() []string

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

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

+ func (m *ShowDDLLocksRequest) Reset()

+ func (m *ShowDDLLocksRequest) Size() (n int)

+ func (m *ShowDDLLocksRequest) String() string

+ func (m *ShowDDLLocksRequest) Unmarshal(dAtA []byte) error

+ type ShowDDLLocksResponse struct

+ Locks []*DDLLock

+ Msg string

+ Result bool

+ func (*ShowDDLLocksResponse) Descriptor() ([]byte, []int)

+ func (*ShowDDLLocksResponse) ProtoMessage()

+ func (m *ShowDDLLocksResponse) GetLocks() []*DDLLock

+ func (m *ShowDDLLocksResponse) GetMsg() string

+ func (m *ShowDDLLocksResponse) GetResult() bool

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

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

+ func (m *ShowDDLLocksResponse) Reset()

+ func (m *ShowDDLLocksResponse) Size() (n int)

+ func (m *ShowDDLLocksResponse) String() string

+ func (m *ShowDDLLocksResponse) Unmarshal(dAtA []byte) error

+ type Stage int32

+ const Stage_Finished

+ const Stage_InvalidStage

+ const Stage_New

+ const Stage_Paused

+ const Stage_Running

+ const Stage_Stopped

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

+ func (x Stage) String() string

+ type StartSubTaskRequest struct

+ Task string

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

+ func (*StartSubTaskRequest) ProtoMessage()

+ func (m *StartSubTaskRequest) GetTask() string

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

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

+ func (m *StartSubTaskRequest) Reset()

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

+ func (m *StartSubTaskRequest) String() string

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

+ func (m *StartSubTaskRequest) XXX_DiscardUnknown()

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

+ func (m *StartSubTaskRequest) XXX_Merge(src proto.Message)

+ func (m *StartSubTaskRequest) XXX_Size() int

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

+ type StartTaskRequest struct

+ Task string

+ Workers []string

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

+ func (*StartTaskRequest) ProtoMessage()

+ func (m *StartTaskRequest) GetTask() string

+ func (m *StartTaskRequest) GetWorkers() []string

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

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

+ func (m *StartTaskRequest) Reset()

+ func (m *StartTaskRequest) Size() (n int)

+ func (m *StartTaskRequest) String() string

+ func (m *StartTaskRequest) Unmarshal(dAtA []byte) error

+ type StartTaskResponse struct

+ Msg string

+ Result bool

+ Workers []*CommonWorkerResponse

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

+ func (*StartTaskResponse) ProtoMessage()

+ func (m *StartTaskResponse) GetMsg() string

+ func (m *StartTaskResponse) GetResult() bool

+ func (m *StartTaskResponse) GetWorkers() []*CommonWorkerResponse

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

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

+ func (m *StartTaskResponse) Reset()

+ func (m *StartTaskResponse) Size() (n int)

+ func (m *StartTaskResponse) String() string

+ func (m *StartTaskResponse) Unmarshal(dAtA []byte) error

+ type SubTaskError struct

+ Error isSubTaskError_Error

+ Name string

+ Stage Stage

+ Unit UnitType

+ func (*SubTaskError) Descriptor() ([]byte, []int)

+ func (*SubTaskError) ProtoMessage()

+ func (*SubTaskError) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (m *SubTaskError) GetCheck() *CheckError

+ func (m *SubTaskError) GetDump() *DumpError

+ func (m *SubTaskError) GetError() isSubTaskError_Error

+ func (m *SubTaskError) GetLoad() *LoadError

+ func (m *SubTaskError) GetMsg() string

+ func (m *SubTaskError) GetName() string

+ func (m *SubTaskError) GetStage() Stage

+ func (m *SubTaskError) GetSync() *SyncError

+ func (m *SubTaskError) GetUnit() UnitType

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

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

+ func (m *SubTaskError) Reset()

+ func (m *SubTaskError) Size() (n int)

+ func (m *SubTaskError) String() string

+ func (m *SubTaskError) Unmarshal(dAtA []byte) error

+ func (m *SubTaskError) XXX_DiscardUnknown()

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

+ func (m *SubTaskError) XXX_Merge(src proto.Message)

+ func (m *SubTaskError) XXX_Size() int

+ func (m *SubTaskError) XXX_Unmarshal(b []byte) error

+ type SubTaskErrorList struct

+ Error []*SubTaskError

+ func (*SubTaskErrorList) Descriptor() ([]byte, []int)

+ func (*SubTaskErrorList) ProtoMessage()

+ func (m *SubTaskErrorList) GetError() []*SubTaskError

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

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

+ func (m *SubTaskErrorList) Reset()

+ func (m *SubTaskErrorList) Size() (n int)

+ func (m *SubTaskErrorList) String() string

+ func (m *SubTaskErrorList) Unmarshal(dAtA []byte) error

+ func (m *SubTaskErrorList) XXX_DiscardUnknown()

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

+ func (m *SubTaskErrorList) XXX_Merge(src proto.Message)

+ func (m *SubTaskErrorList) XXX_Size() int

+ func (m *SubTaskErrorList) XXX_Unmarshal(b []byte) error

+ type SubTaskError_Check struct

+ Check *CheckError

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

+ func (m *SubTaskError_Check) Size() (n int)

+ type SubTaskError_Dump struct

+ Dump *DumpError

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

+ func (m *SubTaskError_Dump) Size() (n int)

+ type SubTaskError_Load struct

+ Load *LoadError

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

+ func (m *SubTaskError_Load) Size() (n int)

+ type SubTaskError_Msg struct

+ Msg string

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

+ func (m *SubTaskError_Msg) Size() (n int)

+ type SubTaskError_Sync struct

+ Sync *SyncError

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

+ func (m *SubTaskError_Sync) Size() (n int)

+ type SubTaskStatus struct

+ Name string

+ Result *ProcessResult

+ Stage Stage

+ Status isSubTaskStatus_Status

+ Unit UnitType

+ UnresolvedDDLLockID string

+ func (*SubTaskStatus) Descriptor() ([]byte, []int)

+ func (*SubTaskStatus) ProtoMessage()

+ func (*SubTaskStatus) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (m *SubTaskStatus) GetCheck() *CheckStatus

+ func (m *SubTaskStatus) GetDump() *DumpStatus

+ func (m *SubTaskStatus) GetLoad() *LoadStatus

+ func (m *SubTaskStatus) GetMsg() string

+ func (m *SubTaskStatus) GetName() string

+ func (m *SubTaskStatus) GetResult() *ProcessResult

+ func (m *SubTaskStatus) GetStage() Stage

+ func (m *SubTaskStatus) GetStatus() isSubTaskStatus_Status

+ func (m *SubTaskStatus) GetSync() *SyncStatus

+ func (m *SubTaskStatus) GetUnit() UnitType

+ func (m *SubTaskStatus) GetUnresolvedDDLLockID() string

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

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

+ func (m *SubTaskStatus) Reset()

+ func (m *SubTaskStatus) Size() (n int)

+ func (m *SubTaskStatus) String() string

+ func (m *SubTaskStatus) Unmarshal(dAtA []byte) error

+ func (m *SubTaskStatus) XXX_DiscardUnknown()

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

+ func (m *SubTaskStatus) XXX_Merge(src proto.Message)

+ func (m *SubTaskStatus) XXX_Size() int

+ func (m *SubTaskStatus) XXX_Unmarshal(b []byte) error

+ type SubTaskStatusList struct

+ Status []*SubTaskStatus

+ func (*SubTaskStatusList) Descriptor() ([]byte, []int)

+ func (*SubTaskStatusList) ProtoMessage()

+ func (m *SubTaskStatusList) GetStatus() []*SubTaskStatus

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

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

+ func (m *SubTaskStatusList) Reset()

+ func (m *SubTaskStatusList) Size() (n int)

+ func (m *SubTaskStatusList) String() string

+ func (m *SubTaskStatusList) Unmarshal(dAtA []byte) error

+ func (m *SubTaskStatusList) XXX_DiscardUnknown()

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

+ func (m *SubTaskStatusList) XXX_Merge(src proto.Message)

+ func (m *SubTaskStatusList) XXX_Size() int

+ func (m *SubTaskStatusList) XXX_Unmarshal(b []byte) error

+ type SubTaskStatus_Check struct

+ Check *CheckStatus

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

+ func (m *SubTaskStatus_Check) Size() (n int)

+ type SubTaskStatus_Dump struct

+ Dump *DumpStatus

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

+ func (m *SubTaskStatus_Dump) Size() (n int)

+ type SubTaskStatus_Load struct

+ Load *LoadStatus

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

+ func (m *SubTaskStatus_Load) Size() (n int)

+ type SubTaskStatus_Msg struct

+ Msg string

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

+ func (m *SubTaskStatus_Msg) Size() (n int)

+ type SubTaskStatus_Sync struct

+ Sync *SyncStatus

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

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

+ type SwitchRelayMasterRequest struct

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

+ func (*SwitchRelayMasterRequest) ProtoMessage()

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

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

+ func (m *SwitchRelayMasterRequest) Reset()

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

+ func (m *SwitchRelayMasterRequest) String() string

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

+ func (m *SwitchRelayMasterRequest) XXX_DiscardUnknown()

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

+ func (m *SwitchRelayMasterRequest) XXX_Merge(src proto.Message)

+ func (m *SwitchRelayMasterRequest) XXX_Size() int

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

+ type SwitchWorkerRelayMasterRequest struct

+ Workers []string

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

+ func (*SwitchWorkerRelayMasterRequest) ProtoMessage()

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

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

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

+ func (m *SwitchWorkerRelayMasterRequest) Reset()

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

+ func (m *SwitchWorkerRelayMasterRequest) String() string

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

+ type SwitchWorkerRelayMasterResponse struct

+ Msg string

+ Result bool

+ Workers []*CommonWorkerResponse

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

+ func (*SwitchWorkerRelayMasterResponse) ProtoMessage()

+ func (m *SwitchWorkerRelayMasterResponse) GetMsg() string

+ func (m *SwitchWorkerRelayMasterResponse) GetResult() bool

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

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

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

+ func (m *SwitchWorkerRelayMasterResponse) Reset()

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

+ func (m *SwitchWorkerRelayMasterResponse) String() string

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

+ type SyncError struct

+ Errors []*SyncSQLError

+ func (*SyncError) Descriptor() ([]byte, []int)

+ func (*SyncError) ProtoMessage()

+ func (m *SyncError) GetErrors() []*SyncSQLError

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

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

+ func (m *SyncError) Reset()

+ func (m *SyncError) Size() (n int)

+ func (m *SyncError) String() string

+ func (m *SyncError) Unmarshal(dAtA []byte) error

+ func (m *SyncError) XXX_DiscardUnknown()

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

+ func (m *SyncError) XXX_Merge(src proto.Message)

+ func (m *SyncError) XXX_Size() int

+ func (m *SyncError) XXX_Unmarshal(b []byte) error

+ type SyncSQLError struct

+ ErrorSQL string

+ FailedBinlogPosition string

+ Msg string

+ func (*SyncSQLError) Descriptor() ([]byte, []int)

+ func (*SyncSQLError) ProtoMessage()

+ func (m *SyncSQLError) GetErrorSQL() string

+ func (m *SyncSQLError) GetFailedBinlogPosition() string

+ func (m *SyncSQLError) GetMsg() string

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

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

+ func (m *SyncSQLError) Reset()

+ func (m *SyncSQLError) Size() (n int)

+ func (m *SyncSQLError) String() string

+ func (m *SyncSQLError) Unmarshal(dAtA []byte) error

+ func (m *SyncSQLError) XXX_DiscardUnknown()

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

+ func (m *SyncSQLError) XXX_Merge(src proto.Message)

+ func (m *SyncSQLError) XXX_Size() int

+ func (m *SyncSQLError) XXX_Unmarshal(b []byte) error

+ type SyncStatus struct

+ BlockingDDLs []string

+ MasterBinlog string

+ MasterBinlogGtid string

+ RecentTps int64

+ Synced bool

+ SyncerBinlog string

+ SyncerBinlogGtid string

+ TotalEvents int64

+ TotalTps int64

+ UnresolvedGroups []*ShardingGroup

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

+ func (*SyncStatus) ProtoMessage()

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

+ func (m *SyncStatus) GetMasterBinlog() string

+ func (m *SyncStatus) GetMasterBinlogGtid() string

+ func (m *SyncStatus) GetRecentTps() int64

+ func (m *SyncStatus) GetSynced() bool

+ func (m *SyncStatus) GetSyncerBinlog() string

+ func (m *SyncStatus) GetSyncerBinlogGtid() string

+ func (m *SyncStatus) GetTotalEvents() int64

+ func (m *SyncStatus) GetTotalTps() int64

+ func (m *SyncStatus) GetUnresolvedGroups() []*ShardingGroup

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

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

+ func (m *SyncStatus) Reset()

+ func (m *SyncStatus) Size() (n int)

+ func (m *SyncStatus) String() string

+ func (m *SyncStatus) Unmarshal(dAtA []byte) error

+ func (m *SyncStatus) XXX_DiscardUnknown()

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

+ func (m *SyncStatus) XXX_Merge(src proto.Message)

+ func (m *SyncStatus) XXX_Size() int

+ func (m *SyncStatus) XXX_Unmarshal(b []byte) error

+ type SyncerBinlogEvent struct

+ Base *BaseEvent

+ EventType int32

+ OpType int32

+ State *SyncerState

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

+ func (*SyncerBinlogEvent) ProtoMessage()

+ func (m *SyncerBinlogEvent) GetBase() *BaseEvent

+ func (m *SyncerBinlogEvent) GetEventType() int32

+ func (m *SyncerBinlogEvent) GetOpType() int32

+ func (m *SyncerBinlogEvent) GetState() *SyncerState

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

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

+ func (m *SyncerBinlogEvent) Reset()

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

+ func (m *SyncerBinlogEvent) String() string

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

+ func (m *SyncerBinlogEvent) XXX_DiscardUnknown()

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

+ func (m *SyncerBinlogEvent) XXX_Merge(src proto.Message)

+ func (m *SyncerBinlogEvent) XXX_Size() int

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

+ type SyncerJobEvent struct

+ ArgsChecksum uint32

+ Base *BaseEvent

+ CurrentPos *MySQLPosition

+ DdlInfo *ExecDDLInfo

+ Ddls []string

+ OpType int32

+ Pos *MySQLPosition

+ QueueBucket string

+ Sql string

+ State SyncerJobState

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

+ func (*SyncerJobEvent) ProtoMessage()

+ func (m *SyncerJobEvent) GetArgsChecksum() uint32

+ func (m *SyncerJobEvent) GetBase() *BaseEvent

+ func (m *SyncerJobEvent) GetCurrentPos() *MySQLPosition

+ func (m *SyncerJobEvent) GetDdlInfo() *ExecDDLInfo

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

+ func (m *SyncerJobEvent) GetOpType() int32

+ func (m *SyncerJobEvent) GetPos() *MySQLPosition

+ func (m *SyncerJobEvent) GetQueueBucket() string

+ func (m *SyncerJobEvent) GetSql() string

+ func (m *SyncerJobEvent) GetState() SyncerJobState

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

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

+ func (m *SyncerJobEvent) Reset()

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

+ func (m *SyncerJobEvent) String() string

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

+ func (m *SyncerJobEvent) XXX_DiscardUnknown()

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

+ func (m *SyncerJobEvent) XXX_Merge(src proto.Message)

+ func (m *SyncerJobEvent) XXX_Size() int

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

+ type SyncerJobState int32

+ const SyncerJobState_error

+ const SyncerJobState_init

+ const SyncerJobState_queued

+ const SyncerJobState_success

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

+ func (x SyncerJobState) String() string

+ type SyncerState struct

+ CurrentPos *MySQLPosition

+ LastPos *MySQLPosition

+ SafeMode bool

+ TryReSync bool

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

+ func (*SyncerState) ProtoMessage()

+ func (m *SyncerState) GetCurrentPos() *MySQLPosition

+ func (m *SyncerState) GetLastPos() *MySQLPosition

+ func (m *SyncerState) GetSafeMode() bool

+ func (m *SyncerState) GetTryReSync() bool

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

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

+ func (m *SyncerState) Reset()

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

+ func (m *SyncerState) String() string

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

+ func (m *SyncerState) XXX_DiscardUnknown()

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

+ func (m *SyncerState) XXX_Merge(src proto.Message)

+ func (m *SyncerState) XXX_Size() int

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

+ type TaskLog struct

+ Id int64

+ Message string

+ Success bool

+ Task *TaskMeta

+ Ts int64

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

+ func (*TaskLog) ProtoMessage()

+ func (m *TaskLog) GetId() int64

+ func (m *TaskLog) GetMessage() string

+ func (m *TaskLog) GetSuccess() bool

+ func (m *TaskLog) GetTask() *TaskMeta

+ func (m *TaskLog) GetTs() int64

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

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

+ func (m *TaskLog) Reset()

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

+ func (m *TaskLog) String() string

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

+ func (m *TaskLog) XXX_DiscardUnknown()

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

+ func (m *TaskLog) XXX_Merge(src proto.Message)

+ func (m *TaskLog) XXX_Size() int

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

+ type TaskMeta struct

+ Name string

+ Op TaskOp

+ Stage Stage

+ Task []byte

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

+ func (*TaskMeta) ProtoMessage()

+ func (m *TaskMeta) GetName() string

+ func (m *TaskMeta) GetOp() TaskOp

+ func (m *TaskMeta) GetStage() Stage

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

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

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

+ func (m *TaskMeta) Reset()

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

+ func (m *TaskMeta) String() string

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

+ func (m *TaskMeta) XXX_DiscardUnknown()

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

+ func (m *TaskMeta) XXX_Merge(src proto.Message)

+ func (m *TaskMeta) XXX_Size() int

+ func (m *TaskMeta) XXX_Unmarshal(b []byte) error

+ type TaskOp int32

+ const TaskOp_AutoResume

+ const TaskOp_InvalidOp

+ const TaskOp_Pause

+ const TaskOp_Resume

+ const TaskOp_Start

+ const TaskOp_Stop

+ const TaskOp_Update

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

+ func (x TaskOp) String() string

+ type TraceType int32

+ const TraceType_BinlogEvent

+ const TraceType_DummyEvent

+ const TraceType_JobEvent

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

+ func (x TraceType) String() string

+ type TracerClient interface

+ GetTSO func(ctx context.Context, in *GetTSORequest, opts ...grpc.CallOption) (*GetTSOResponse, error)

+ UploadSyncerBinlogEvent func(ctx context.Context, in *UploadSyncerBinlogEventRequest, ...) (*CommonUploadResponse, error)

+ UploadSyncerJobEvent func(ctx context.Context, in *UploadSyncerJobEventRequest, opts ...grpc.CallOption) (*CommonUploadResponse, error)

+ func NewTracerClient(cc *grpc.ClientConn) TracerClient

+ type TracerServer interface

+ GetTSO func(context.Context, *GetTSORequest) (*GetTSOResponse, error)

+ UploadSyncerBinlogEvent func(context.Context, *UploadSyncerBinlogEventRequest) (*CommonUploadResponse, error)

+ UploadSyncerJobEvent func(context.Context, *UploadSyncerJobEventRequest) (*CommonUploadResponse, error)

+ type UnitType int32

+ const UnitType_Check

+ const UnitType_Dump

+ const UnitType_InvalidUnit

+ const UnitType_Load

+ const UnitType_Relay

+ const UnitType_Sync

+ func (UnitType) EnumDescriptor() ([]byte, []int)

+ func (x UnitType) String() string

+ type UnlockDDLLockRequest struct

+ ForceRemove bool

+ ID string

+ ReplaceOwner string

+ Workers []string

+ func (*UnlockDDLLockRequest) Descriptor() ([]byte, []int)

+ func (*UnlockDDLLockRequest) ProtoMessage()

+ func (m *UnlockDDLLockRequest) GetForceRemove() bool

+ func (m *UnlockDDLLockRequest) GetID() string

+ func (m *UnlockDDLLockRequest) GetReplaceOwner() string

+ func (m *UnlockDDLLockRequest) GetWorkers() []string

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

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

+ func (m *UnlockDDLLockRequest) Reset()

+ func (m *UnlockDDLLockRequest) Size() (n int)

+ func (m *UnlockDDLLockRequest) String() string

+ func (m *UnlockDDLLockRequest) Unmarshal(dAtA []byte) error

+ type UnlockDDLLockResponse struct

+ Msg string

+ Result bool

+ Workers []*CommonWorkerResponse

+ func (*UnlockDDLLockResponse) Descriptor() ([]byte, []int)

+ func (*UnlockDDLLockResponse) ProtoMessage()

+ func (m *UnlockDDLLockResponse) GetMsg() string

+ func (m *UnlockDDLLockResponse) GetResult() bool

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

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

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

+ func (m *UnlockDDLLockResponse) Reset()

+ func (m *UnlockDDLLockResponse) Size() (n int)

+ func (m *UnlockDDLLockResponse) String() string

+ func (m *UnlockDDLLockResponse) Unmarshal(dAtA []byte) error

+ type UpdateMasterConfigRequest struct

+ Config string

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

+ func (*UpdateMasterConfigRequest) ProtoMessage()

+ func (m *UpdateMasterConfigRequest) GetConfig() string

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

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

+ func (m *UpdateMasterConfigRequest) Reset()

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

+ func (m *UpdateMasterConfigRequest) String() string

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

+ type UpdateMasterConfigResponse struct

+ Msg string

+ Result bool

+ Workers []*QueryStatusResponse

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

+ func (*UpdateMasterConfigResponse) ProtoMessage()

+ func (m *UpdateMasterConfigResponse) GetMsg() string

+ func (m *UpdateMasterConfigResponse) GetResult() bool

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

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

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

+ func (m *UpdateMasterConfigResponse) Reset()

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

+ func (m *UpdateMasterConfigResponse) String() string

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

+ type UpdateRelayRequest struct

+ Content string

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

+ func (*UpdateRelayRequest) ProtoMessage()

+ func (m *UpdateRelayRequest) GetContent() string

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

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

+ func (m *UpdateRelayRequest) Reset()

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

+ func (m *UpdateRelayRequest) String() string

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

+ func (m *UpdateRelayRequest) XXX_DiscardUnknown()

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

+ func (m *UpdateRelayRequest) XXX_Merge(src proto.Message)

+ func (m *UpdateRelayRequest) XXX_Size() int

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

+ type UpdateSubTaskRequest struct

+ Task string

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

+ func (*UpdateSubTaskRequest) ProtoMessage()

+ func (m *UpdateSubTaskRequest) GetTask() string

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

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

+ func (m *UpdateSubTaskRequest) Reset()

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

+ func (m *UpdateSubTaskRequest) String() string

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

+ func (m *UpdateSubTaskRequest) XXX_DiscardUnknown()

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

+ func (m *UpdateSubTaskRequest) XXX_Merge(src proto.Message)

+ func (m *UpdateSubTaskRequest) XXX_Size() int

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

+ type UpdateTaskRequest struct

+ Task string

+ Workers []string

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

+ func (*UpdateTaskRequest) ProtoMessage()

+ func (m *UpdateTaskRequest) GetTask() string

+ func (m *UpdateTaskRequest) GetWorkers() []string

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

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

+ func (m *UpdateTaskRequest) Reset()

+ func (m *UpdateTaskRequest) Size() (n int)

+ func (m *UpdateTaskRequest) String() string

+ func (m *UpdateTaskRequest) Unmarshal(dAtA []byte) error

+ type UpdateTaskResponse struct

+ Msg string

+ Result bool

+ Workers []*CommonWorkerResponse

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

+ func (*UpdateTaskResponse) ProtoMessage()

+ func (m *UpdateTaskResponse) GetMsg() string

+ func (m *UpdateTaskResponse) GetResult() bool

+ func (m *UpdateTaskResponse) GetWorkers() []*CommonWorkerResponse

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

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

+ func (m *UpdateTaskResponse) Reset()

+ func (m *UpdateTaskResponse) Size() (n int)

+ func (m *UpdateTaskResponse) String() string

+ func (m *UpdateTaskResponse) Unmarshal(dAtA []byte) error

+ type UpdateWorkerRelayConfigRequest struct

+ Config string

+ Worker string

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

+ func (*UpdateWorkerRelayConfigRequest) ProtoMessage()

+ func (m *UpdateWorkerRelayConfigRequest) GetConfig() string

+ func (m *UpdateWorkerRelayConfigRequest) GetWorker() string

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

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

+ func (m *UpdateWorkerRelayConfigRequest) Reset()

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

+ func (m *UpdateWorkerRelayConfigRequest) String() string

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

+ type UploadSyncerBinlogEventRequest struct

+ Events []*SyncerBinlogEvent

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

+ func (*UploadSyncerBinlogEventRequest) ProtoMessage()

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

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

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

+ func (m *UploadSyncerBinlogEventRequest) Reset()

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

+ func (m *UploadSyncerBinlogEventRequest) String() string

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

+ func (m *UploadSyncerBinlogEventRequest) XXX_DiscardUnknown()

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

+ func (m *UploadSyncerBinlogEventRequest) XXX_Merge(src proto.Message)

+ func (m *UploadSyncerBinlogEventRequest) XXX_Size() int

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

+ type UploadSyncerJobEventRequest struct

+ Events []*SyncerJobEvent

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

+ func (*UploadSyncerJobEventRequest) ProtoMessage()

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

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

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

+ func (m *UploadSyncerJobEventRequest) Reset()

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

+ func (m *UploadSyncerJobEventRequest) String() string

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

+ func (m *UploadSyncerJobEventRequest) XXX_DiscardUnknown()

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

+ func (m *UploadSyncerJobEventRequest) XXX_Merge(src proto.Message)

+ func (m *UploadSyncerJobEventRequest) XXX_Size() int

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

+ type WorkerClient interface

+ BreakDDLLock func(ctx context.Context, in *BreakDDLLockRequest, opts ...grpc.CallOption) (*CommonWorkerResponse, error)

+ ExecuteDDL func(ctx context.Context, in *ExecDDLRequest, opts ...grpc.CallOption) (*CommonWorkerResponse, error)

+ FetchDDLInfo func(ctx context.Context, opts ...grpc.CallOption) (Worker_FetchDDLInfoClient, error)

+ HandleSQLs func(ctx context.Context, in *HandleSubTaskSQLsRequest, opts ...grpc.CallOption) (*CommonWorkerResponse, error)

+ MigrateRelay func(ctx context.Context, in *MigrateRelayRequest, opts ...grpc.CallOption) (*CommonWorkerResponse, error)

+ OperateRelay func(ctx context.Context, in *OperateRelayRequest, opts ...grpc.CallOption) (*OperateRelayResponse, error)

+ OperateSubTask func(ctx context.Context, in *OperateSubTaskRequest, opts ...grpc.CallOption) (*OperateSubTaskResponse, error)

+ PurgeRelay func(ctx context.Context, in *PurgeRelayRequest, opts ...grpc.CallOption) (*CommonWorkerResponse, error)

+ QueryError func(ctx context.Context, in *QueryErrorRequest, opts ...grpc.CallOption) (*QueryErrorResponse, error)

+ QueryStatus func(ctx context.Context, in *QueryStatusRequest, opts ...grpc.CallOption) (*QueryStatusResponse, error)

+ QueryTaskOperation func(ctx context.Context, in *QueryTaskOperationRequest, opts ...grpc.CallOption) (*QueryTaskOperationResponse, error)

+ QueryWorkerConfig func(ctx context.Context, in *QueryWorkerConfigRequest, opts ...grpc.CallOption) (*QueryWorkerConfigResponse, error)

+ StartSubTask func(ctx context.Context, in *StartSubTaskRequest, opts ...grpc.CallOption) (*OperateSubTaskResponse, error)

+ SwitchRelayMaster func(ctx context.Context, in *SwitchRelayMasterRequest, opts ...grpc.CallOption) (*CommonWorkerResponse, error)

+ UpdateRelayConfig func(ctx context.Context, in *UpdateRelayRequest, opts ...grpc.CallOption) (*CommonWorkerResponse, error)

+ UpdateSubTask func(ctx context.Context, in *UpdateSubTaskRequest, opts ...grpc.CallOption) (*OperateSubTaskResponse, error)

+ func NewWorkerClient(cc *grpc.ClientConn) WorkerClient

+ type WorkerServer interface

+ BreakDDLLock func(context.Context, *BreakDDLLockRequest) (*CommonWorkerResponse, error)

+ ExecuteDDL func(context.Context, *ExecDDLRequest) (*CommonWorkerResponse, error)

+ FetchDDLInfo func(Worker_FetchDDLInfoServer) error

+ HandleSQLs func(context.Context, *HandleSubTaskSQLsRequest) (*CommonWorkerResponse, error)

+ MigrateRelay func(context.Context, *MigrateRelayRequest) (*CommonWorkerResponse, error)

+ OperateRelay func(context.Context, *OperateRelayRequest) (*OperateRelayResponse, error)

+ OperateSubTask func(context.Context, *OperateSubTaskRequest) (*OperateSubTaskResponse, error)

+ PurgeRelay func(context.Context, *PurgeRelayRequest) (*CommonWorkerResponse, error)

+ QueryError func(context.Context, *QueryErrorRequest) (*QueryErrorResponse, error)

+ QueryStatus func(context.Context, *QueryStatusRequest) (*QueryStatusResponse, error)

+ QueryTaskOperation func(context.Context, *QueryTaskOperationRequest) (*QueryTaskOperationResponse, error)

+ QueryWorkerConfig func(context.Context, *QueryWorkerConfigRequest) (*QueryWorkerConfigResponse, error)

+ StartSubTask func(context.Context, *StartSubTaskRequest) (*OperateSubTaskResponse, error)

+ SwitchRelayMaster func(context.Context, *SwitchRelayMasterRequest) (*CommonWorkerResponse, error)

+ UpdateRelayConfig func(context.Context, *UpdateRelayRequest) (*CommonWorkerResponse, error)

+ UpdateSubTask func(context.Context, *UpdateSubTaskRequest) (*OperateSubTaskResponse, error)

+ type Worker_FetchDDLInfoClient interface

+ Recv func() (*DDLInfo, error)

+ Send func(*DDLLockInfo) error

+ type Worker_FetchDDLInfoServer interface

+ Recv func() (*DDLLockInfo, error)

+ Send func(*DDLInfo) error

v1.0.0-rc.1

Jul 1, 2019

v1.0.0-alpha

Jan 21, 2019

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