Documentation
¶
Overview ¶
Package pb is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Index ¶
- Variables
- 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 RegisterMasterHandlerServer(ctx context.Context, mux *runtime.ServeMux, server MasterServer) error
- func RegisterMasterServer(s *grpc.Server, srv MasterServer)
- func RegisterWorkerServer(s *grpc.Server, srv WorkerServer)
- type CfgType
- type CheckError
- func (*CheckError) Descriptor() ([]byte, []int)
- func (m *CheckError) GetMsg() string
- func (m *CheckError) Marshal() (dAtA []byte, err error)
- func (m *CheckError) MarshalTo(dAtA []byte) (int, error)
- func (m *CheckError) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CheckError) ProtoMessage()
- 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
- func (*CheckStatus) Descriptor() ([]byte, []int)
- 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) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CheckStatus) ProtoMessage()
- 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
- func (*CheckTaskRequest) Descriptor() ([]byte, []int)
- func (m *CheckTaskRequest) GetErrCnt() int64
- func (m *CheckTaskRequest) GetStartTime() string
- func (m *CheckTaskRequest) GetTask() string
- func (m *CheckTaskRequest) GetWarnCnt() int64
- func (m *CheckTaskRequest) Marshal() (dAtA []byte, err error)
- func (m *CheckTaskRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *CheckTaskRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CheckTaskRequest) ProtoMessage()
- func (m *CheckTaskRequest) Reset()
- func (m *CheckTaskRequest) Size() (n int)
- func (m *CheckTaskRequest) String() string
- func (m *CheckTaskRequest) Unmarshal(dAtA []byte) error
- func (m *CheckTaskRequest) XXX_DiscardUnknown()
- func (m *CheckTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CheckTaskRequest) XXX_Merge(src proto.Message)
- func (m *CheckTaskRequest) XXX_Size() int
- func (m *CheckTaskRequest) XXX_Unmarshal(b []byte) error
- type CheckTaskResponse
- func (*CheckTaskResponse) Descriptor() ([]byte, []int)
- 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) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CheckTaskResponse) ProtoMessage()
- func (m *CheckTaskResponse) Reset()
- func (m *CheckTaskResponse) Size() (n int)
- func (m *CheckTaskResponse) String() string
- func (m *CheckTaskResponse) Unmarshal(dAtA []byte) error
- func (m *CheckTaskResponse) XXX_DiscardUnknown()
- func (m *CheckTaskResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CheckTaskResponse) XXX_Merge(src proto.Message)
- func (m *CheckTaskResponse) XXX_Size() int
- func (m *CheckTaskResponse) XXX_Unmarshal(b []byte) error
- type CommonWorkerResponse
- func (*CommonWorkerResponse) Descriptor() ([]byte, []int)
- func (m *CommonWorkerResponse) GetMsg() string
- func (m *CommonWorkerResponse) GetResult() bool
- func (m *CommonWorkerResponse) GetSource() string
- func (m *CommonWorkerResponse) GetWorker() string
- func (m *CommonWorkerResponse) Marshal() (dAtA []byte, err error)
- func (m *CommonWorkerResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *CommonWorkerResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CommonWorkerResponse) ProtoMessage()
- 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 DDLLock
- func (*DDLLock) Descriptor() ([]byte, []int)
- func (m *DDLLock) GetDDLs() []string
- func (m *DDLLock) GetID() string
- func (m *DDLLock) GetMode() 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) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*DDLLock) ProtoMessage()
- func (m *DDLLock) Reset()
- func (m *DDLLock) Size() (n int)
- func (m *DDLLock) String() string
- func (m *DDLLock) Unmarshal(dAtA []byte) error
- func (m *DDLLock) XXX_DiscardUnknown()
- func (m *DDLLock) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DDLLock) XXX_Merge(src proto.Message)
- func (m *DDLLock) XXX_Size() int
- func (m *DDLLock) XXX_Unmarshal(b []byte) error
- type DumpError
- func (*DumpError) Descriptor() ([]byte, []int)
- func (m *DumpError) GetMsg() string
- func (m *DumpError) Marshal() (dAtA []byte, err error)
- func (m *DumpError) MarshalTo(dAtA []byte) (int, error)
- func (m *DumpError) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*DumpError) ProtoMessage()
- 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
- func (*DumpStatus) Descriptor() ([]byte, []int)
- func (m *DumpStatus) GetCompletedTables() float64
- func (m *DumpStatus) GetEstimateTotalRows() float64
- func (m *DumpStatus) GetFinishedBytes() float64
- func (m *DumpStatus) GetFinishedRows() float64
- func (m *DumpStatus) GetTotalTables() int64
- func (m *DumpStatus) Marshal() (dAtA []byte, err error)
- func (m *DumpStatus) MarshalTo(dAtA []byte) (int, error)
- func (m *DumpStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*DumpStatus) ProtoMessage()
- 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 ErrorOp
- type GetCfgRequest
- func (*GetCfgRequest) Descriptor() ([]byte, []int)
- func (m *GetCfgRequest) GetName() string
- func (m *GetCfgRequest) GetType() CfgType
- func (m *GetCfgRequest) Marshal() (dAtA []byte, err error)
- func (m *GetCfgRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *GetCfgRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetCfgRequest) ProtoMessage()
- func (m *GetCfgRequest) Reset()
- func (m *GetCfgRequest) Size() (n int)
- func (m *GetCfgRequest) String() string
- func (m *GetCfgRequest) Unmarshal(dAtA []byte) error
- func (m *GetCfgRequest) XXX_DiscardUnknown()
- func (m *GetCfgRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetCfgRequest) XXX_Merge(src proto.Message)
- func (m *GetCfgRequest) XXX_Size() int
- func (m *GetCfgRequest) XXX_Unmarshal(b []byte) error
- type GetCfgResponse
- func (*GetCfgResponse) Descriptor() ([]byte, []int)
- func (m *GetCfgResponse) GetCfg() string
- func (m *GetCfgResponse) GetMsg() string
- func (m *GetCfgResponse) GetResult() bool
- func (m *GetCfgResponse) Marshal() (dAtA []byte, err error)
- func (m *GetCfgResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *GetCfgResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetCfgResponse) ProtoMessage()
- func (m *GetCfgResponse) Reset()
- func (m *GetCfgResponse) Size() (n int)
- func (m *GetCfgResponse) String() string
- func (m *GetCfgResponse) Unmarshal(dAtA []byte) error
- func (m *GetCfgResponse) XXX_DiscardUnknown()
- func (m *GetCfgResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetCfgResponse) XXX_Merge(src proto.Message)
- func (m *GetCfgResponse) XXX_Size() int
- func (m *GetCfgResponse) XXX_Unmarshal(b []byte) error
- type GetMasterCfgRequest
- func (*GetMasterCfgRequest) Descriptor() ([]byte, []int)
- func (m *GetMasterCfgRequest) Marshal() (dAtA []byte, err error)
- func (m *GetMasterCfgRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *GetMasterCfgRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetMasterCfgRequest) ProtoMessage()
- func (m *GetMasterCfgRequest) Reset()
- func (m *GetMasterCfgRequest) Size() (n int)
- func (m *GetMasterCfgRequest) String() string
- func (m *GetMasterCfgRequest) Unmarshal(dAtA []byte) error
- func (m *GetMasterCfgRequest) XXX_DiscardUnknown()
- func (m *GetMasterCfgRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetMasterCfgRequest) XXX_Merge(src proto.Message)
- func (m *GetMasterCfgRequest) XXX_Size() int
- func (m *GetMasterCfgRequest) XXX_Unmarshal(b []byte) error
- type GetMasterCfgResponse
- func (*GetMasterCfgResponse) Descriptor() ([]byte, []int)
- func (m *GetMasterCfgResponse) GetCfg() string
- func (m *GetMasterCfgResponse) Marshal() (dAtA []byte, err error)
- func (m *GetMasterCfgResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *GetMasterCfgResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetMasterCfgResponse) ProtoMessage()
- func (m *GetMasterCfgResponse) Reset()
- func (m *GetMasterCfgResponse) Size() (n int)
- func (m *GetMasterCfgResponse) String() string
- func (m *GetMasterCfgResponse) Unmarshal(dAtA []byte) error
- func (m *GetMasterCfgResponse) XXX_DiscardUnknown()
- func (m *GetMasterCfgResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetMasterCfgResponse) XXX_Merge(src proto.Message)
- func (m *GetMasterCfgResponse) XXX_Size() int
- func (m *GetMasterCfgResponse) XXX_Unmarshal(b []byte) error
- type GetSubTaskCfgRequest
- func (*GetSubTaskCfgRequest) Descriptor() ([]byte, []int)
- func (m *GetSubTaskCfgRequest) GetName() string
- func (m *GetSubTaskCfgRequest) Marshal() (dAtA []byte, err error)
- func (m *GetSubTaskCfgRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *GetSubTaskCfgRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetSubTaskCfgRequest) ProtoMessage()
- func (m *GetSubTaskCfgRequest) Reset()
- func (m *GetSubTaskCfgRequest) Size() (n int)
- func (m *GetSubTaskCfgRequest) String() string
- func (m *GetSubTaskCfgRequest) Unmarshal(dAtA []byte) error
- func (m *GetSubTaskCfgRequest) XXX_DiscardUnknown()
- func (m *GetSubTaskCfgRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetSubTaskCfgRequest) XXX_Merge(src proto.Message)
- func (m *GetSubTaskCfgRequest) XXX_Size() int
- func (m *GetSubTaskCfgRequest) XXX_Unmarshal(b []byte) error
- type GetSubTaskCfgResponse
- func (*GetSubTaskCfgResponse) Descriptor() ([]byte, []int)
- func (m *GetSubTaskCfgResponse) GetCfgs() []string
- func (m *GetSubTaskCfgResponse) GetMsg() string
- func (m *GetSubTaskCfgResponse) GetResult() bool
- func (m *GetSubTaskCfgResponse) Marshal() (dAtA []byte, err error)
- func (m *GetSubTaskCfgResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *GetSubTaskCfgResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetSubTaskCfgResponse) ProtoMessage()
- func (m *GetSubTaskCfgResponse) Reset()
- func (m *GetSubTaskCfgResponse) Size() (n int)
- func (m *GetSubTaskCfgResponse) String() string
- func (m *GetSubTaskCfgResponse) Unmarshal(dAtA []byte) error
- func (m *GetSubTaskCfgResponse) XXX_DiscardUnknown()
- func (m *GetSubTaskCfgResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetSubTaskCfgResponse) XXX_Merge(src proto.Message)
- func (m *GetSubTaskCfgResponse) XXX_Size() int
- func (m *GetSubTaskCfgResponse) XXX_Unmarshal(b []byte) error
- type GetWorkerCfgRequest
- func (*GetWorkerCfgRequest) Descriptor() ([]byte, []int)
- func (m *GetWorkerCfgRequest) Marshal() (dAtA []byte, err error)
- func (m *GetWorkerCfgRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *GetWorkerCfgRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetWorkerCfgRequest) ProtoMessage()
- func (m *GetWorkerCfgRequest) Reset()
- func (m *GetWorkerCfgRequest) Size() (n int)
- func (m *GetWorkerCfgRequest) String() string
- func (m *GetWorkerCfgRequest) Unmarshal(dAtA []byte) error
- func (m *GetWorkerCfgRequest) XXX_DiscardUnknown()
- func (m *GetWorkerCfgRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetWorkerCfgRequest) XXX_Merge(src proto.Message)
- func (m *GetWorkerCfgRequest) XXX_Size() int
- func (m *GetWorkerCfgRequest) XXX_Unmarshal(b []byte) error
- type GetWorkerCfgResponse
- func (*GetWorkerCfgResponse) Descriptor() ([]byte, []int)
- func (m *GetWorkerCfgResponse) GetCfg() string
- func (m *GetWorkerCfgResponse) Marshal() (dAtA []byte, err error)
- func (m *GetWorkerCfgResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *GetWorkerCfgResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetWorkerCfgResponse) ProtoMessage()
- func (m *GetWorkerCfgResponse) Reset()
- func (m *GetWorkerCfgResponse) Size() (n int)
- func (m *GetWorkerCfgResponse) String() string
- func (m *GetWorkerCfgResponse) Unmarshal(dAtA []byte) error
- func (m *GetWorkerCfgResponse) XXX_DiscardUnknown()
- func (m *GetWorkerCfgResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetWorkerCfgResponse) XXX_Merge(src proto.Message)
- func (m *GetWorkerCfgResponse) XXX_Size() int
- func (m *GetWorkerCfgResponse) XXX_Unmarshal(b []byte) error
- type HandleErrorRequest
- func (*HandleErrorRequest) Descriptor() ([]byte, []int)
- func (m *HandleErrorRequest) GetBinlogPos() string
- func (m *HandleErrorRequest) GetOp() ErrorOp
- func (m *HandleErrorRequest) GetSources() []string
- func (m *HandleErrorRequest) GetSqls() []string
- func (m *HandleErrorRequest) GetTask() string
- func (m *HandleErrorRequest) Marshal() (dAtA []byte, err error)
- func (m *HandleErrorRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *HandleErrorRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*HandleErrorRequest) ProtoMessage()
- func (m *HandleErrorRequest) Reset()
- func (m *HandleErrorRequest) Size() (n int)
- func (m *HandleErrorRequest) String() string
- func (m *HandleErrorRequest) Unmarshal(dAtA []byte) error
- func (m *HandleErrorRequest) XXX_DiscardUnknown()
- func (m *HandleErrorRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *HandleErrorRequest) XXX_Merge(src proto.Message)
- func (m *HandleErrorRequest) XXX_Size() int
- func (m *HandleErrorRequest) XXX_Unmarshal(b []byte) error
- type HandleErrorResponse
- func (*HandleErrorResponse) Descriptor() ([]byte, []int)
- func (m *HandleErrorResponse) GetMsg() string
- func (m *HandleErrorResponse) GetResult() bool
- func (m *HandleErrorResponse) GetSources() []*CommonWorkerResponse
- func (m *HandleErrorResponse) Marshal() (dAtA []byte, err error)
- func (m *HandleErrorResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *HandleErrorResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*HandleErrorResponse) ProtoMessage()
- func (m *HandleErrorResponse) Reset()
- func (m *HandleErrorResponse) Size() (n int)
- func (m *HandleErrorResponse) String() string
- func (m *HandleErrorResponse) Unmarshal(dAtA []byte) error
- func (m *HandleErrorResponse) XXX_DiscardUnknown()
- func (m *HandleErrorResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *HandleErrorResponse) XXX_Merge(src proto.Message)
- func (m *HandleErrorResponse) XXX_Size() int
- func (m *HandleErrorResponse) XXX_Unmarshal(b []byte) error
- type HandleWorkerErrorRequest
- func (*HandleWorkerErrorRequest) Descriptor() ([]byte, []int)
- func (m *HandleWorkerErrorRequest) GetBinlogPos() string
- func (m *HandleWorkerErrorRequest) GetOp() ErrorOp
- func (m *HandleWorkerErrorRequest) GetSqls() []string
- func (m *HandleWorkerErrorRequest) GetTask() string
- func (m *HandleWorkerErrorRequest) Marshal() (dAtA []byte, err error)
- func (m *HandleWorkerErrorRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *HandleWorkerErrorRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*HandleWorkerErrorRequest) ProtoMessage()
- func (m *HandleWorkerErrorRequest) Reset()
- func (m *HandleWorkerErrorRequest) Size() (n int)
- func (m *HandleWorkerErrorRequest) String() string
- func (m *HandleWorkerErrorRequest) Unmarshal(dAtA []byte) error
- func (m *HandleWorkerErrorRequest) XXX_DiscardUnknown()
- func (m *HandleWorkerErrorRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *HandleWorkerErrorRequest) XXX_Merge(src proto.Message)
- func (m *HandleWorkerErrorRequest) XXX_Size() int
- func (m *HandleWorkerErrorRequest) XXX_Unmarshal(b []byte) error
- type LeaderOp
- type ListLeaderMember
- func (*ListLeaderMember) Descriptor() ([]byte, []int)
- func (m *ListLeaderMember) GetAddr() string
- func (m *ListLeaderMember) GetMsg() string
- func (m *ListLeaderMember) GetName() string
- func (m *ListLeaderMember) Marshal() (dAtA []byte, err error)
- func (m *ListLeaderMember) MarshalTo(dAtA []byte) (int, error)
- func (m *ListLeaderMember) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ListLeaderMember) ProtoMessage()
- func (m *ListLeaderMember) Reset()
- func (m *ListLeaderMember) Size() (n int)
- func (m *ListLeaderMember) String() string
- func (m *ListLeaderMember) Unmarshal(dAtA []byte) error
- func (m *ListLeaderMember) XXX_DiscardUnknown()
- func (m *ListLeaderMember) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListLeaderMember) XXX_Merge(src proto.Message)
- func (m *ListLeaderMember) XXX_Size() int
- func (m *ListLeaderMember) XXX_Unmarshal(b []byte) error
- type ListMasterMember
- func (*ListMasterMember) Descriptor() ([]byte, []int)
- func (m *ListMasterMember) GetMasters() []*MasterInfo
- func (m *ListMasterMember) GetMsg() string
- func (m *ListMasterMember) Marshal() (dAtA []byte, err error)
- func (m *ListMasterMember) MarshalTo(dAtA []byte) (int, error)
- func (m *ListMasterMember) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ListMasterMember) ProtoMessage()
- func (m *ListMasterMember) Reset()
- func (m *ListMasterMember) Size() (n int)
- func (m *ListMasterMember) String() string
- func (m *ListMasterMember) Unmarshal(dAtA []byte) error
- func (m *ListMasterMember) XXX_DiscardUnknown()
- func (m *ListMasterMember) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListMasterMember) XXX_Merge(src proto.Message)
- func (m *ListMasterMember) XXX_Size() int
- func (m *ListMasterMember) XXX_Unmarshal(b []byte) error
- type ListMemberRequest
- func (*ListMemberRequest) Descriptor() ([]byte, []int)
- func (m *ListMemberRequest) GetLeader() bool
- func (m *ListMemberRequest) GetMaster() bool
- func (m *ListMemberRequest) GetNames() []string
- func (m *ListMemberRequest) GetWorker() bool
- func (m *ListMemberRequest) Marshal() (dAtA []byte, err error)
- func (m *ListMemberRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ListMemberRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ListMemberRequest) ProtoMessage()
- func (m *ListMemberRequest) Reset()
- func (m *ListMemberRequest) Size() (n int)
- func (m *ListMemberRequest) String() string
- func (m *ListMemberRequest) Unmarshal(dAtA []byte) error
- func (m *ListMemberRequest) XXX_DiscardUnknown()
- func (m *ListMemberRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListMemberRequest) XXX_Merge(src proto.Message)
- func (m *ListMemberRequest) XXX_Size() int
- func (m *ListMemberRequest) XXX_Unmarshal(b []byte) error
- type ListMemberResponse
- func (*ListMemberResponse) Descriptor() ([]byte, []int)
- func (m *ListMemberResponse) GetMembers() []*Members
- func (m *ListMemberResponse) GetMsg() string
- func (m *ListMemberResponse) GetResult() bool
- func (m *ListMemberResponse) Marshal() (dAtA []byte, err error)
- func (m *ListMemberResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *ListMemberResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ListMemberResponse) ProtoMessage()
- func (m *ListMemberResponse) Reset()
- func (m *ListMemberResponse) Size() (n int)
- func (m *ListMemberResponse) String() string
- func (m *ListMemberResponse) Unmarshal(dAtA []byte) error
- func (m *ListMemberResponse) XXX_DiscardUnknown()
- func (m *ListMemberResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListMemberResponse) XXX_Merge(src proto.Message)
- func (m *ListMemberResponse) XXX_Size() int
- func (m *ListMemberResponse) XXX_Unmarshal(b []byte) error
- type ListWorkerMember
- func (*ListWorkerMember) Descriptor() ([]byte, []int)
- func (m *ListWorkerMember) GetMsg() string
- func (m *ListWorkerMember) GetWorkers() []*WorkerInfo
- func (m *ListWorkerMember) Marshal() (dAtA []byte, err error)
- func (m *ListWorkerMember) MarshalTo(dAtA []byte) (int, error)
- func (m *ListWorkerMember) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ListWorkerMember) ProtoMessage()
- func (m *ListWorkerMember) Reset()
- func (m *ListWorkerMember) Size() (n int)
- func (m *ListWorkerMember) String() string
- func (m *ListWorkerMember) Unmarshal(dAtA []byte) error
- func (m *ListWorkerMember) XXX_DiscardUnknown()
- func (m *ListWorkerMember) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListWorkerMember) XXX_Merge(src proto.Message)
- func (m *ListWorkerMember) XXX_Size() int
- func (m *ListWorkerMember) XXX_Unmarshal(b []byte) error
- type LoadError
- func (*LoadError) Descriptor() ([]byte, []int)
- func (m *LoadError) GetMsg() string
- func (m *LoadError) Marshal() (dAtA []byte, err error)
- func (m *LoadError) MarshalTo(dAtA []byte) (int, error)
- func (m *LoadError) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*LoadError) ProtoMessage()
- 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
- func (*LoadStatus) Descriptor() ([]byte, []int)
- func (m *LoadStatus) GetFinishedBytes() int64
- func (m *LoadStatus) GetMetaBinlog() string
- func (m *LoadStatus) GetMetaBinlogGTID() 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) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*LoadStatus) ProtoMessage()
- 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
- type MasterInfo
- func (*MasterInfo) Descriptor() ([]byte, []int)
- func (m *MasterInfo) GetAlive() bool
- func (m *MasterInfo) GetClientURLs() []string
- func (m *MasterInfo) GetMemberID() uint64
- func (m *MasterInfo) GetName() string
- func (m *MasterInfo) GetPeerURLs() []string
- func (m *MasterInfo) Marshal() (dAtA []byte, err error)
- func (m *MasterInfo) MarshalTo(dAtA []byte) (int, error)
- func (m *MasterInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MasterInfo) ProtoMessage()
- func (m *MasterInfo) Reset()
- func (m *MasterInfo) Size() (n int)
- func (m *MasterInfo) String() string
- func (m *MasterInfo) Unmarshal(dAtA []byte) error
- func (m *MasterInfo) XXX_DiscardUnknown()
- func (m *MasterInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MasterInfo) XXX_Merge(src proto.Message)
- func (m *MasterInfo) XXX_Size() int
- func (m *MasterInfo) XXX_Unmarshal(b []byte) error
- type MasterServer
- type Members
- func (*Members) Descriptor() ([]byte, []int)
- func (m *Members) GetLeader() *ListLeaderMember
- func (m *Members) GetMaster() *ListMasterMember
- func (m *Members) GetMember() isMembers_Member
- func (m *Members) GetWorker() *ListWorkerMember
- func (m *Members) Marshal() (dAtA []byte, err error)
- func (m *Members) MarshalTo(dAtA []byte) (int, error)
- func (m *Members) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Members) ProtoMessage()
- func (m *Members) Reset()
- func (m *Members) Size() (n int)
- func (m *Members) String() string
- func (m *Members) Unmarshal(dAtA []byte) error
- func (m *Members) XXX_DiscardUnknown()
- func (m *Members) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Members) XXX_Merge(src proto.Message)
- func (*Members) XXX_OneofWrappers() []interface{}
- func (m *Members) XXX_Size() int
- func (m *Members) XXX_Unmarshal(b []byte) error
- type Members_Leader
- type Members_Master
- type Members_Worker
- type OfflineMemberRequest
- func (*OfflineMemberRequest) Descriptor() ([]byte, []int)
- func (m *OfflineMemberRequest) GetName() string
- func (m *OfflineMemberRequest) GetType() string
- func (m *OfflineMemberRequest) Marshal() (dAtA []byte, err error)
- func (m *OfflineMemberRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *OfflineMemberRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*OfflineMemberRequest) ProtoMessage()
- func (m *OfflineMemberRequest) Reset()
- func (m *OfflineMemberRequest) Size() (n int)
- func (m *OfflineMemberRequest) String() string
- func (m *OfflineMemberRequest) Unmarshal(dAtA []byte) error
- func (m *OfflineMemberRequest) XXX_DiscardUnknown()
- func (m *OfflineMemberRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *OfflineMemberRequest) XXX_Merge(src proto.Message)
- func (m *OfflineMemberRequest) XXX_Size() int
- func (m *OfflineMemberRequest) XXX_Unmarshal(b []byte) error
- type OfflineMemberResponse
- func (*OfflineMemberResponse) Descriptor() ([]byte, []int)
- func (m *OfflineMemberResponse) GetMsg() string
- func (m *OfflineMemberResponse) GetResult() bool
- func (m *OfflineMemberResponse) Marshal() (dAtA []byte, err error)
- func (m *OfflineMemberResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *OfflineMemberResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*OfflineMemberResponse) ProtoMessage()
- func (m *OfflineMemberResponse) Reset()
- func (m *OfflineMemberResponse) Size() (n int)
- func (m *OfflineMemberResponse) String() string
- func (m *OfflineMemberResponse) Unmarshal(dAtA []byte) error
- func (m *OfflineMemberResponse) XXX_DiscardUnknown()
- func (m *OfflineMemberResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *OfflineMemberResponse) XXX_Merge(src proto.Message)
- func (m *OfflineMemberResponse) XXX_Size() int
- func (m *OfflineMemberResponse) XXX_Unmarshal(b []byte) error
- type OperateLeaderRequest
- func (*OperateLeaderRequest) Descriptor() ([]byte, []int)
- func (m *OperateLeaderRequest) GetOp() LeaderOp
- func (m *OperateLeaderRequest) Marshal() (dAtA []byte, err error)
- func (m *OperateLeaderRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *OperateLeaderRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*OperateLeaderRequest) ProtoMessage()
- func (m *OperateLeaderRequest) Reset()
- func (m *OperateLeaderRequest) Size() (n int)
- func (m *OperateLeaderRequest) String() string
- func (m *OperateLeaderRequest) Unmarshal(dAtA []byte) error
- func (m *OperateLeaderRequest) XXX_DiscardUnknown()
- func (m *OperateLeaderRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *OperateLeaderRequest) XXX_Merge(src proto.Message)
- func (m *OperateLeaderRequest) XXX_Size() int
- func (m *OperateLeaderRequest) XXX_Unmarshal(b []byte) error
- type OperateLeaderResponse
- func (*OperateLeaderResponse) Descriptor() ([]byte, []int)
- func (m *OperateLeaderResponse) GetMsg() string
- func (m *OperateLeaderResponse) GetResult() bool
- func (m *OperateLeaderResponse) Marshal() (dAtA []byte, err error)
- func (m *OperateLeaderResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *OperateLeaderResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*OperateLeaderResponse) ProtoMessage()
- func (m *OperateLeaderResponse) Reset()
- func (m *OperateLeaderResponse) Size() (n int)
- func (m *OperateLeaderResponse) String() string
- func (m *OperateLeaderResponse) Unmarshal(dAtA []byte) error
- func (m *OperateLeaderResponse) XXX_DiscardUnknown()
- func (m *OperateLeaderResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *OperateLeaderResponse) XXX_Merge(src proto.Message)
- func (m *OperateLeaderResponse) XXX_Size() int
- func (m *OperateLeaderResponse) XXX_Unmarshal(b []byte) error
- type OperateRelayRequest
- func (*OperateRelayRequest) Descriptor() ([]byte, []int)
- func (m *OperateRelayRequest) GetOp() RelayOpV2
- func (m *OperateRelayRequest) GetSource() string
- func (m *OperateRelayRequest) GetWorker() []string
- func (m *OperateRelayRequest) Marshal() (dAtA []byte, err error)
- func (m *OperateRelayRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *OperateRelayRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*OperateRelayRequest) ProtoMessage()
- 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
- func (*OperateRelayResponse) Descriptor() ([]byte, []int)
- func (m *OperateRelayResponse) GetMsg() string
- func (m *OperateRelayResponse) GetResult() bool
- func (m *OperateRelayResponse) GetSources() []*CommonWorkerResponse
- func (m *OperateRelayResponse) Marshal() (dAtA []byte, err error)
- func (m *OperateRelayResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *OperateRelayResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*OperateRelayResponse) ProtoMessage()
- 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 OperateSchemaRequest
- func (*OperateSchemaRequest) Descriptor() ([]byte, []int)
- func (m *OperateSchemaRequest) GetDatabase() string
- func (m *OperateSchemaRequest) GetFlush() bool
- func (m *OperateSchemaRequest) GetFromSource() bool
- func (m *OperateSchemaRequest) GetFromTarget() bool
- func (m *OperateSchemaRequest) GetOp() SchemaOp
- func (m *OperateSchemaRequest) GetSchema() string
- func (m *OperateSchemaRequest) GetSources() []string
- func (m *OperateSchemaRequest) GetSync() bool
- func (m *OperateSchemaRequest) GetTable() string
- func (m *OperateSchemaRequest) GetTask() string
- func (m *OperateSchemaRequest) Marshal() (dAtA []byte, err error)
- func (m *OperateSchemaRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *OperateSchemaRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*OperateSchemaRequest) ProtoMessage()
- func (m *OperateSchemaRequest) Reset()
- func (m *OperateSchemaRequest) Size() (n int)
- func (m *OperateSchemaRequest) String() string
- func (m *OperateSchemaRequest) Unmarshal(dAtA []byte) error
- func (m *OperateSchemaRequest) XXX_DiscardUnknown()
- func (m *OperateSchemaRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *OperateSchemaRequest) XXX_Merge(src proto.Message)
- func (m *OperateSchemaRequest) XXX_Size() int
- func (m *OperateSchemaRequest) XXX_Unmarshal(b []byte) error
- type OperateSchemaResponse
- func (*OperateSchemaResponse) Descriptor() ([]byte, []int)
- func (m *OperateSchemaResponse) GetMsg() string
- func (m *OperateSchemaResponse) GetResult() bool
- func (m *OperateSchemaResponse) GetSources() []*CommonWorkerResponse
- func (m *OperateSchemaResponse) Marshal() (dAtA []byte, err error)
- func (m *OperateSchemaResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *OperateSchemaResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*OperateSchemaResponse) ProtoMessage()
- func (m *OperateSchemaResponse) Reset()
- func (m *OperateSchemaResponse) Size() (n int)
- func (m *OperateSchemaResponse) String() string
- func (m *OperateSchemaResponse) Unmarshal(dAtA []byte) error
- func (m *OperateSchemaResponse) XXX_DiscardUnknown()
- func (m *OperateSchemaResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *OperateSchemaResponse) XXX_Merge(src proto.Message)
- func (m *OperateSchemaResponse) XXX_Size() int
- func (m *OperateSchemaResponse) XXX_Unmarshal(b []byte) error
- type OperateSourceRequest
- func (*OperateSourceRequest) Descriptor() ([]byte, []int)
- func (m *OperateSourceRequest) GetConfig() []string
- func (m *OperateSourceRequest) GetOp() SourceOp
- func (m *OperateSourceRequest) GetSourceID() []string
- func (m *OperateSourceRequest) GetWorkerName() string
- func (m *OperateSourceRequest) Marshal() (dAtA []byte, err error)
- func (m *OperateSourceRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *OperateSourceRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*OperateSourceRequest) ProtoMessage()
- func (m *OperateSourceRequest) Reset()
- func (m *OperateSourceRequest) Size() (n int)
- func (m *OperateSourceRequest) String() string
- func (m *OperateSourceRequest) Unmarshal(dAtA []byte) error
- func (m *OperateSourceRequest) XXX_DiscardUnknown()
- func (m *OperateSourceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *OperateSourceRequest) XXX_Merge(src proto.Message)
- func (m *OperateSourceRequest) XXX_Size() int
- func (m *OperateSourceRequest) XXX_Unmarshal(b []byte) error
- type OperateSourceResponse
- func (*OperateSourceResponse) Descriptor() ([]byte, []int)
- func (m *OperateSourceResponse) GetMsg() string
- func (m *OperateSourceResponse) GetResult() bool
- func (m *OperateSourceResponse) GetSources() []*CommonWorkerResponse
- func (m *OperateSourceResponse) Marshal() (dAtA []byte, err error)
- func (m *OperateSourceResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *OperateSourceResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*OperateSourceResponse) ProtoMessage()
- func (m *OperateSourceResponse) Reset()
- func (m *OperateSourceResponse) Size() (n int)
- func (m *OperateSourceResponse) String() string
- func (m *OperateSourceResponse) Unmarshal(dAtA []byte) error
- func (m *OperateSourceResponse) XXX_DiscardUnknown()
- func (m *OperateSourceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *OperateSourceResponse) XXX_Merge(src proto.Message)
- func (m *OperateSourceResponse) XXX_Size() int
- func (m *OperateSourceResponse) XXX_Unmarshal(b []byte) error
- type OperateTaskRequest
- func (*OperateTaskRequest) Descriptor() ([]byte, []int)
- func (m *OperateTaskRequest) GetName() string
- func (m *OperateTaskRequest) GetOp() TaskOp
- func (m *OperateTaskRequest) GetSources() []string
- func (m *OperateTaskRequest) Marshal() (dAtA []byte, err error)
- func (m *OperateTaskRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *OperateTaskRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*OperateTaskRequest) ProtoMessage()
- func (m *OperateTaskRequest) Reset()
- func (m *OperateTaskRequest) Size() (n int)
- func (m *OperateTaskRequest) String() string
- func (m *OperateTaskRequest) Unmarshal(dAtA []byte) error
- func (m *OperateTaskRequest) XXX_DiscardUnknown()
- func (m *OperateTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *OperateTaskRequest) XXX_Merge(src proto.Message)
- func (m *OperateTaskRequest) XXX_Size() int
- func (m *OperateTaskRequest) XXX_Unmarshal(b []byte) error
- type OperateTaskResponse
- func (*OperateTaskResponse) Descriptor() ([]byte, []int)
- func (m *OperateTaskResponse) GetMsg() string
- func (m *OperateTaskResponse) GetOp() TaskOp
- func (m *OperateTaskResponse) GetResult() bool
- func (m *OperateTaskResponse) GetSources() []*CommonWorkerResponse
- func (m *OperateTaskResponse) Marshal() (dAtA []byte, err error)
- func (m *OperateTaskResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *OperateTaskResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*OperateTaskResponse) ProtoMessage()
- func (m *OperateTaskResponse) Reset()
- func (m *OperateTaskResponse) Size() (n int)
- func (m *OperateTaskResponse) String() string
- func (m *OperateTaskResponse) Unmarshal(dAtA []byte) error
- func (m *OperateTaskResponse) XXX_DiscardUnknown()
- func (m *OperateTaskResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *OperateTaskResponse) XXX_Merge(src proto.Message)
- func (m *OperateTaskResponse) XXX_Size() int
- func (m *OperateTaskResponse) XXX_Unmarshal(b []byte) error
- type OperateV1MetaRequest
- func (*OperateV1MetaRequest) Descriptor() ([]byte, []int)
- func (m *OperateV1MetaRequest) GetOp() V1MetaOp
- func (m *OperateV1MetaRequest) Marshal() (dAtA []byte, err error)
- func (m *OperateV1MetaRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *OperateV1MetaRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*OperateV1MetaRequest) ProtoMessage()
- func (m *OperateV1MetaRequest) Reset()
- func (m *OperateV1MetaRequest) Size() (n int)
- func (m *OperateV1MetaRequest) String() string
- func (m *OperateV1MetaRequest) Unmarshal(dAtA []byte) error
- func (m *OperateV1MetaRequest) XXX_DiscardUnknown()
- func (m *OperateV1MetaRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *OperateV1MetaRequest) XXX_Merge(src proto.Message)
- func (m *OperateV1MetaRequest) XXX_Size() int
- func (m *OperateV1MetaRequest) XXX_Unmarshal(b []byte) error
- type OperateV1MetaResponse
- func (*OperateV1MetaResponse) Descriptor() ([]byte, []int)
- func (m *OperateV1MetaResponse) GetMeta() map[string]*V1SubTaskMeta
- func (m *OperateV1MetaResponse) GetMsg() string
- func (m *OperateV1MetaResponse) GetResult() bool
- func (m *OperateV1MetaResponse) Marshal() (dAtA []byte, err error)
- func (m *OperateV1MetaResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *OperateV1MetaResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*OperateV1MetaResponse) ProtoMessage()
- func (m *OperateV1MetaResponse) Reset()
- func (m *OperateV1MetaResponse) Size() (n int)
- func (m *OperateV1MetaResponse) String() string
- func (m *OperateV1MetaResponse) Unmarshal(dAtA []byte) error
- func (m *OperateV1MetaResponse) XXX_DiscardUnknown()
- func (m *OperateV1MetaResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *OperateV1MetaResponse) XXX_Merge(src proto.Message)
- func (m *OperateV1MetaResponse) XXX_Size() int
- func (m *OperateV1MetaResponse) XXX_Unmarshal(b []byte) error
- type OperateWorkerRelayRequest
- func (*OperateWorkerRelayRequest) Descriptor() ([]byte, []int)
- func (m *OperateWorkerRelayRequest) GetOp() RelayOp
- func (m *OperateWorkerRelayRequest) GetSources() []string
- func (m *OperateWorkerRelayRequest) Marshal() (dAtA []byte, err error)
- func (m *OperateWorkerRelayRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *OperateWorkerRelayRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*OperateWorkerRelayRequest) ProtoMessage()
- func (m *OperateWorkerRelayRequest) Reset()
- func (m *OperateWorkerRelayRequest) Size() (n int)
- func (m *OperateWorkerRelayRequest) String() string
- func (m *OperateWorkerRelayRequest) Unmarshal(dAtA []byte) error
- func (m *OperateWorkerRelayRequest) XXX_DiscardUnknown()
- func (m *OperateWorkerRelayRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *OperateWorkerRelayRequest) XXX_Merge(src proto.Message)
- func (m *OperateWorkerRelayRequest) XXX_Size() int
- func (m *OperateWorkerRelayRequest) XXX_Unmarshal(b []byte) error
- type OperateWorkerRelayResponse
- func (*OperateWorkerRelayResponse) Descriptor() ([]byte, []int)
- func (m *OperateWorkerRelayResponse) GetMsg() string
- func (m *OperateWorkerRelayResponse) GetOp() RelayOp
- func (m *OperateWorkerRelayResponse) GetResult() bool
- func (m *OperateWorkerRelayResponse) GetSources() []*CommonWorkerResponse
- func (m *OperateWorkerRelayResponse) Marshal() (dAtA []byte, err error)
- func (m *OperateWorkerRelayResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *OperateWorkerRelayResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*OperateWorkerRelayResponse) ProtoMessage()
- func (m *OperateWorkerRelayResponse) Reset()
- func (m *OperateWorkerRelayResponse) Size() (n int)
- func (m *OperateWorkerRelayResponse) String() string
- func (m *OperateWorkerRelayResponse) Unmarshal(dAtA []byte) error
- func (m *OperateWorkerRelayResponse) XXX_DiscardUnknown()
- func (m *OperateWorkerRelayResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *OperateWorkerRelayResponse) XXX_Merge(src proto.Message)
- func (m *OperateWorkerRelayResponse) XXX_Size() int
- func (m *OperateWorkerRelayResponse) XXX_Unmarshal(b []byte) error
- type OperateWorkerSchemaRequest
- func (*OperateWorkerSchemaRequest) Descriptor() ([]byte, []int)
- func (m *OperateWorkerSchemaRequest) GetDatabase() string
- func (m *OperateWorkerSchemaRequest) GetFlush() bool
- func (m *OperateWorkerSchemaRequest) GetFromSource() bool
- func (m *OperateWorkerSchemaRequest) GetFromTarget() bool
- func (m *OperateWorkerSchemaRequest) GetOp() SchemaOp
- func (m *OperateWorkerSchemaRequest) GetSchema() string
- func (m *OperateWorkerSchemaRequest) GetSource() string
- func (m *OperateWorkerSchemaRequest) GetSync() bool
- func (m *OperateWorkerSchemaRequest) GetTable() string
- func (m *OperateWorkerSchemaRequest) GetTask() string
- func (m *OperateWorkerSchemaRequest) Marshal() (dAtA []byte, err error)
- func (m *OperateWorkerSchemaRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *OperateWorkerSchemaRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*OperateWorkerSchemaRequest) ProtoMessage()
- func (m *OperateWorkerSchemaRequest) Reset()
- func (m *OperateWorkerSchemaRequest) Size() (n int)
- func (m *OperateWorkerSchemaRequest) String() string
- func (m *OperateWorkerSchemaRequest) Unmarshal(dAtA []byte) error
- func (m *OperateWorkerSchemaRequest) XXX_DiscardUnknown()
- func (m *OperateWorkerSchemaRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *OperateWorkerSchemaRequest) XXX_Merge(src proto.Message)
- func (m *OperateWorkerSchemaRequest) XXX_Size() int
- func (m *OperateWorkerSchemaRequest) XXX_Unmarshal(b []byte) error
- type ProcessError
- func (*ProcessError) Descriptor() ([]byte, []int)
- func (m *ProcessError) GetErrClass() string
- func (m *ProcessError) GetErrCode() int32
- func (m *ProcessError) GetErrLevel() string
- func (m *ProcessError) GetErrScope() string
- func (m *ProcessError) GetMessage() string
- func (m *ProcessError) GetRawCause() string
- func (m *ProcessError) GetWorkaround() string
- func (m *ProcessError) Marshal() (dAtA []byte, err error)
- func (m *ProcessError) MarshalTo(dAtA []byte) (int, error)
- func (m *ProcessError) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ProcessError) ProtoMessage()
- 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
- func (*ProcessResult) Descriptor() ([]byte, []int)
- 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) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ProcessResult) ProtoMessage()
- 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
- func (*PurgeRelayRequest) Descriptor() ([]byte, []int)
- 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) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PurgeRelayRequest) ProtoMessage()
- 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
- func (*PurgeWorkerRelayRequest) Descriptor() ([]byte, []int)
- func (m *PurgeWorkerRelayRequest) GetFilename() string
- func (m *PurgeWorkerRelayRequest) GetInactive() bool
- func (m *PurgeWorkerRelayRequest) GetSources() []string
- func (m *PurgeWorkerRelayRequest) GetSubDir() string
- func (m *PurgeWorkerRelayRequest) GetTime() int64
- func (m *PurgeWorkerRelayRequest) Marshal() (dAtA []byte, err error)
- func (m *PurgeWorkerRelayRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *PurgeWorkerRelayRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PurgeWorkerRelayRequest) ProtoMessage()
- func (m *PurgeWorkerRelayRequest) Reset()
- func (m *PurgeWorkerRelayRequest) Size() (n int)
- func (m *PurgeWorkerRelayRequest) String() string
- func (m *PurgeWorkerRelayRequest) Unmarshal(dAtA []byte) error
- func (m *PurgeWorkerRelayRequest) XXX_DiscardUnknown()
- func (m *PurgeWorkerRelayRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PurgeWorkerRelayRequest) XXX_Merge(src proto.Message)
- func (m *PurgeWorkerRelayRequest) XXX_Size() int
- func (m *PurgeWorkerRelayRequest) XXX_Unmarshal(b []byte) error
- type PurgeWorkerRelayResponse
- func (*PurgeWorkerRelayResponse) Descriptor() ([]byte, []int)
- func (m *PurgeWorkerRelayResponse) GetMsg() string
- func (m *PurgeWorkerRelayResponse) GetResult() bool
- func (m *PurgeWorkerRelayResponse) GetSources() []*CommonWorkerResponse
- func (m *PurgeWorkerRelayResponse) Marshal() (dAtA []byte, err error)
- func (m *PurgeWorkerRelayResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *PurgeWorkerRelayResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PurgeWorkerRelayResponse) ProtoMessage()
- func (m *PurgeWorkerRelayResponse) Reset()
- func (m *PurgeWorkerRelayResponse) Size() (n int)
- func (m *PurgeWorkerRelayResponse) String() string
- func (m *PurgeWorkerRelayResponse) Unmarshal(dAtA []byte) error
- func (m *PurgeWorkerRelayResponse) XXX_DiscardUnknown()
- func (m *PurgeWorkerRelayResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PurgeWorkerRelayResponse) XXX_Merge(src proto.Message)
- func (m *PurgeWorkerRelayResponse) XXX_Size() int
- func (m *PurgeWorkerRelayResponse) XXX_Unmarshal(b []byte) error
- type QueryStatusListRequest
- func (*QueryStatusListRequest) Descriptor() ([]byte, []int)
- func (m *QueryStatusListRequest) GetName() string
- func (m *QueryStatusListRequest) GetSources() []string
- func (m *QueryStatusListRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryStatusListRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryStatusListRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryStatusListRequest) ProtoMessage()
- func (m *QueryStatusListRequest) Reset()
- func (m *QueryStatusListRequest) Size() (n int)
- func (m *QueryStatusListRequest) String() string
- func (m *QueryStatusListRequest) Unmarshal(dAtA []byte) error
- func (m *QueryStatusListRequest) XXX_DiscardUnknown()
- func (m *QueryStatusListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryStatusListRequest) XXX_Merge(src proto.Message)
- func (m *QueryStatusListRequest) XXX_Size() int
- func (m *QueryStatusListRequest) XXX_Unmarshal(b []byte) error
- type QueryStatusListResponse
- func (*QueryStatusListResponse) Descriptor() ([]byte, []int)
- func (m *QueryStatusListResponse) GetMsg() string
- func (m *QueryStatusListResponse) GetResult() bool
- func (m *QueryStatusListResponse) GetSources() []*QueryStatusResponse
- func (m *QueryStatusListResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryStatusListResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryStatusListResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryStatusListResponse) ProtoMessage()
- func (m *QueryStatusListResponse) Reset()
- func (m *QueryStatusListResponse) Size() (n int)
- func (m *QueryStatusListResponse) String() string
- func (m *QueryStatusListResponse) Unmarshal(dAtA []byte) error
- func (m *QueryStatusListResponse) XXX_DiscardUnknown()
- func (m *QueryStatusListResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryStatusListResponse) XXX_Merge(src proto.Message)
- func (m *QueryStatusListResponse) XXX_Size() int
- func (m *QueryStatusListResponse) XXX_Unmarshal(b []byte) error
- type QueryStatusRequest
- func (*QueryStatusRequest) Descriptor() ([]byte, []int)
- func (m *QueryStatusRequest) GetName() string
- func (m *QueryStatusRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryStatusRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryStatusRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryStatusRequest) ProtoMessage()
- 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
- func (*QueryStatusResponse) Descriptor() ([]byte, []int)
- func (m *QueryStatusResponse) GetMsg() string
- func (m *QueryStatusResponse) GetResult() bool
- func (m *QueryStatusResponse) GetSourceStatus() *SourceStatus
- func (m *QueryStatusResponse) GetSubTaskStatus() []*SubTaskStatus
- func (m *QueryStatusResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryStatusResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryStatusResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryStatusResponse) ProtoMessage()
- 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 RegisterWorkerRequest
- func (*RegisterWorkerRequest) Descriptor() ([]byte, []int)
- func (m *RegisterWorkerRequest) GetAddress() string
- func (m *RegisterWorkerRequest) GetName() string
- func (m *RegisterWorkerRequest) Marshal() (dAtA []byte, err error)
- func (m *RegisterWorkerRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *RegisterWorkerRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*RegisterWorkerRequest) ProtoMessage()
- func (m *RegisterWorkerRequest) Reset()
- func (m *RegisterWorkerRequest) Size() (n int)
- func (m *RegisterWorkerRequest) String() string
- func (m *RegisterWorkerRequest) Unmarshal(dAtA []byte) error
- func (m *RegisterWorkerRequest) XXX_DiscardUnknown()
- func (m *RegisterWorkerRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RegisterWorkerRequest) XXX_Merge(src proto.Message)
- func (m *RegisterWorkerRequest) XXX_Size() int
- func (m *RegisterWorkerRequest) XXX_Unmarshal(b []byte) error
- type RegisterWorkerResponse
- func (*RegisterWorkerResponse) Descriptor() ([]byte, []int)
- func (m *RegisterWorkerResponse) GetMsg() string
- func (m *RegisterWorkerResponse) GetResult() bool
- func (m *RegisterWorkerResponse) Marshal() (dAtA []byte, err error)
- func (m *RegisterWorkerResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *RegisterWorkerResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*RegisterWorkerResponse) ProtoMessage()
- func (m *RegisterWorkerResponse) Reset()
- func (m *RegisterWorkerResponse) Size() (n int)
- func (m *RegisterWorkerResponse) String() string
- func (m *RegisterWorkerResponse) Unmarshal(dAtA []byte) error
- func (m *RegisterWorkerResponse) XXX_DiscardUnknown()
- func (m *RegisterWorkerResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RegisterWorkerResponse) XXX_Merge(src proto.Message)
- func (m *RegisterWorkerResponse) XXX_Size() int
- func (m *RegisterWorkerResponse) XXX_Unmarshal(b []byte) error
- type RelayError
- func (*RelayError) Descriptor() ([]byte, []int)
- func (m *RelayError) GetMsg() string
- func (m *RelayError) Marshal() (dAtA []byte, err error)
- func (m *RelayError) MarshalTo(dAtA []byte) (int, error)
- func (m *RelayError) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*RelayError) ProtoMessage()
- 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
- type RelayOpV2
- type RelayStatus
- func (*RelayStatus) Descriptor() ([]byte, []int)
- 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) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*RelayStatus) ProtoMessage()
- 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 SchemaOp
- type ShardingGroup
- func (*ShardingGroup) Descriptor() ([]byte, []int)
- func (m *ShardingGroup) GetDDLs() []string
- func (m *ShardingGroup) GetFirstLocation() 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) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ShardingGroup) ProtoMessage()
- 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
- func (*ShowDDLLocksRequest) Descriptor() ([]byte, []int)
- func (m *ShowDDLLocksRequest) GetSources() []string
- func (m *ShowDDLLocksRequest) GetTask() string
- func (m *ShowDDLLocksRequest) Marshal() (dAtA []byte, err error)
- func (m *ShowDDLLocksRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ShowDDLLocksRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ShowDDLLocksRequest) ProtoMessage()
- func (m *ShowDDLLocksRequest) Reset()
- func (m *ShowDDLLocksRequest) Size() (n int)
- func (m *ShowDDLLocksRequest) String() string
- func (m *ShowDDLLocksRequest) Unmarshal(dAtA []byte) error
- func (m *ShowDDLLocksRequest) XXX_DiscardUnknown()
- func (m *ShowDDLLocksRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ShowDDLLocksRequest) XXX_Merge(src proto.Message)
- func (m *ShowDDLLocksRequest) XXX_Size() int
- func (m *ShowDDLLocksRequest) XXX_Unmarshal(b []byte) error
- type ShowDDLLocksResponse
- func (*ShowDDLLocksResponse) Descriptor() ([]byte, []int)
- 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) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ShowDDLLocksResponse) ProtoMessage()
- func (m *ShowDDLLocksResponse) Reset()
- func (m *ShowDDLLocksResponse) Size() (n int)
- func (m *ShowDDLLocksResponse) String() string
- func (m *ShowDDLLocksResponse) Unmarshal(dAtA []byte) error
- func (m *ShowDDLLocksResponse) XXX_DiscardUnknown()
- func (m *ShowDDLLocksResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ShowDDLLocksResponse) XXX_Merge(src proto.Message)
- func (m *ShowDDLLocksResponse) XXX_Size() int
- func (m *ShowDDLLocksResponse) XXX_Unmarshal(b []byte) error
- type SourceError
- func (*SourceError) Descriptor() ([]byte, []int)
- func (m *SourceError) GetRelayError() *RelayError
- func (m *SourceError) GetSource() string
- func (m *SourceError) GetSourceError() string
- func (m *SourceError) GetWorker() string
- func (m *SourceError) Marshal() (dAtA []byte, err error)
- func (m *SourceError) MarshalTo(dAtA []byte) (int, error)
- func (m *SourceError) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SourceError) ProtoMessage()
- func (m *SourceError) Reset()
- func (m *SourceError) Size() (n int)
- func (m *SourceError) String() string
- func (m *SourceError) Unmarshal(dAtA []byte) error
- func (m *SourceError) XXX_DiscardUnknown()
- func (m *SourceError) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SourceError) XXX_Merge(src proto.Message)
- func (m *SourceError) XXX_Size() int
- func (m *SourceError) XXX_Unmarshal(b []byte) error
- type SourceOp
- type SourceStatus
- func (*SourceStatus) Descriptor() ([]byte, []int)
- func (m *SourceStatus) GetRelayStatus() *RelayStatus
- func (m *SourceStatus) GetResult() *ProcessResult
- func (m *SourceStatus) GetSource() string
- func (m *SourceStatus) GetWorker() string
- func (m *SourceStatus) Marshal() (dAtA []byte, err error)
- func (m *SourceStatus) MarshalTo(dAtA []byte) (int, error)
- func (m *SourceStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SourceStatus) ProtoMessage()
- func (m *SourceStatus) Reset()
- func (m *SourceStatus) Size() (n int)
- func (m *SourceStatus) String() string
- func (m *SourceStatus) Unmarshal(dAtA []byte) error
- func (m *SourceStatus) XXX_DiscardUnknown()
- func (m *SourceStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SourceStatus) XXX_Merge(src proto.Message)
- func (m *SourceStatus) XXX_Size() int
- func (m *SourceStatus) XXX_Unmarshal(b []byte) error
- type Stage
- type StartTaskRequest
- func (*StartTaskRequest) Descriptor() ([]byte, []int)
- func (m *StartTaskRequest) GetRemoveMeta() bool
- func (m *StartTaskRequest) GetSources() []string
- func (m *StartTaskRequest) GetStartTime() string
- func (m *StartTaskRequest) GetTask() string
- func (m *StartTaskRequest) Marshal() (dAtA []byte, err error)
- func (m *StartTaskRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *StartTaskRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*StartTaskRequest) ProtoMessage()
- func (m *StartTaskRequest) Reset()
- func (m *StartTaskRequest) Size() (n int)
- func (m *StartTaskRequest) String() string
- func (m *StartTaskRequest) Unmarshal(dAtA []byte) error
- func (m *StartTaskRequest) XXX_DiscardUnknown()
- func (m *StartTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StartTaskRequest) XXX_Merge(src proto.Message)
- func (m *StartTaskRequest) XXX_Size() int
- func (m *StartTaskRequest) XXX_Unmarshal(b []byte) error
- type StartTaskResponse
- func (*StartTaskResponse) Descriptor() ([]byte, []int)
- func (m *StartTaskResponse) GetMsg() string
- func (m *StartTaskResponse) GetResult() bool
- func (m *StartTaskResponse) GetSources() []*CommonWorkerResponse
- func (m *StartTaskResponse) Marshal() (dAtA []byte, err error)
- func (m *StartTaskResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *StartTaskResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*StartTaskResponse) ProtoMessage()
- func (m *StartTaskResponse) Reset()
- func (m *StartTaskResponse) Size() (n int)
- func (m *StartTaskResponse) String() string
- func (m *StartTaskResponse) Unmarshal(dAtA []byte) error
- func (m *StartTaskResponse) XXX_DiscardUnknown()
- func (m *StartTaskResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StartTaskResponse) XXX_Merge(src proto.Message)
- func (m *StartTaskResponse) XXX_Size() int
- func (m *StartTaskResponse) XXX_Unmarshal(b []byte) error
- type SubTaskError
- func (*SubTaskError) Descriptor() ([]byte, []int)
- 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) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SubTaskError) ProtoMessage()
- 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 (*SubTaskError) XXX_OneofWrappers() []interface{}
- func (m *SubTaskError) XXX_Size() int
- func (m *SubTaskError) XXX_Unmarshal(b []byte) error
- type SubTaskErrorList
- func (*SubTaskErrorList) Descriptor() ([]byte, []int)
- func (m *SubTaskErrorList) GetError() []*SubTaskError
- func (m *SubTaskErrorList) Marshal() (dAtA []byte, err error)
- func (m *SubTaskErrorList) MarshalTo(dAtA []byte) (int, error)
- func (m *SubTaskErrorList) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SubTaskErrorList) ProtoMessage()
- 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
- type SubTaskError_Dump
- type SubTaskError_Load
- type SubTaskError_Msg
- type SubTaskError_Sync
- type SubTaskStatus
- func (*SubTaskStatus) Descriptor() ([]byte, []int)
- 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) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SubTaskStatus) ProtoMessage()
- 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 (*SubTaskStatus) XXX_OneofWrappers() []interface{}
- func (m *SubTaskStatus) XXX_Size() int
- func (m *SubTaskStatus) XXX_Unmarshal(b []byte) error
- type SubTaskStatusList
- func (*SubTaskStatusList) Descriptor() ([]byte, []int)
- func (m *SubTaskStatusList) GetStatus() []*SubTaskStatus
- func (m *SubTaskStatusList) Marshal() (dAtA []byte, err error)
- func (m *SubTaskStatusList) MarshalTo(dAtA []byte) (int, error)
- func (m *SubTaskStatusList) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SubTaskStatusList) ProtoMessage()
- 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
- type SubTaskStatus_Dump
- type SubTaskStatus_Load
- type SubTaskStatus_Msg
- type SubTaskStatus_Sync
- type SyncError
- func (*SyncError) Descriptor() ([]byte, []int)
- func (m *SyncError) GetErrors() []*SyncSQLError
- func (m *SyncError) Marshal() (dAtA []byte, err error)
- func (m *SyncError) MarshalTo(dAtA []byte) (int, error)
- func (m *SyncError) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SyncError) ProtoMessage()
- 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
- func (*SyncSQLError) Descriptor() ([]byte, []int)
- 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) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SyncSQLError) ProtoMessage()
- 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
- func (*SyncStatus) Descriptor() ([]byte, []int)
- func (m *SyncStatus) GetBinlogType() string
- func (m *SyncStatus) GetBlockingDDLs() []string
- func (m *SyncStatus) GetMasterBinlog() string
- func (m *SyncStatus) GetMasterBinlogGtid() string
- func (m *SyncStatus) GetRecentTps() int64
- func (m *SyncStatus) GetSecondsBehindMaster() 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) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SyncStatus) ProtoMessage()
- 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 TaskOp
- type TransferSourceRequest
- func (*TransferSourceRequest) Descriptor() ([]byte, []int)
- func (m *TransferSourceRequest) GetSource() string
- func (m *TransferSourceRequest) GetWorker() string
- func (m *TransferSourceRequest) Marshal() (dAtA []byte, err error)
- func (m *TransferSourceRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *TransferSourceRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*TransferSourceRequest) ProtoMessage()
- func (m *TransferSourceRequest) Reset()
- func (m *TransferSourceRequest) Size() (n int)
- func (m *TransferSourceRequest) String() string
- func (m *TransferSourceRequest) Unmarshal(dAtA []byte) error
- func (m *TransferSourceRequest) XXX_DiscardUnknown()
- func (m *TransferSourceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TransferSourceRequest) XXX_Merge(src proto.Message)
- func (m *TransferSourceRequest) XXX_Size() int
- func (m *TransferSourceRequest) XXX_Unmarshal(b []byte) error
- type TransferSourceResponse
- func (*TransferSourceResponse) Descriptor() ([]byte, []int)
- func (m *TransferSourceResponse) GetMsg() string
- func (m *TransferSourceResponse) GetResult() bool
- func (m *TransferSourceResponse) Marshal() (dAtA []byte, err error)
- func (m *TransferSourceResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *TransferSourceResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*TransferSourceResponse) ProtoMessage()
- func (m *TransferSourceResponse) Reset()
- func (m *TransferSourceResponse) Size() (n int)
- func (m *TransferSourceResponse) String() string
- func (m *TransferSourceResponse) Unmarshal(dAtA []byte) error
- func (m *TransferSourceResponse) XXX_DiscardUnknown()
- func (m *TransferSourceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TransferSourceResponse) XXX_Merge(src proto.Message)
- func (m *TransferSourceResponse) XXX_Size() int
- func (m *TransferSourceResponse) XXX_Unmarshal(b []byte) error
- type UnimplementedMasterServer
- func (*UnimplementedMasterServer) CheckTask(ctx context.Context, req *CheckTaskRequest) (*CheckTaskResponse, error)
- func (*UnimplementedMasterServer) GetCfg(ctx context.Context, req *GetCfgRequest) (*GetCfgResponse, error)
- func (*UnimplementedMasterServer) GetMasterCfg(ctx context.Context, req *GetMasterCfgRequest) (*GetMasterCfgResponse, error)
- func (*UnimplementedMasterServer) GetSubTaskCfg(ctx context.Context, req *GetSubTaskCfgRequest) (*GetSubTaskCfgResponse, error)
- func (*UnimplementedMasterServer) HandleError(ctx context.Context, req *HandleErrorRequest) (*HandleErrorResponse, error)
- func (*UnimplementedMasterServer) ListMember(ctx context.Context, req *ListMemberRequest) (*ListMemberResponse, error)
- func (*UnimplementedMasterServer) OfflineMember(ctx context.Context, req *OfflineMemberRequest) (*OfflineMemberResponse, error)
- func (*UnimplementedMasterServer) OperateLeader(ctx context.Context, req *OperateLeaderRequest) (*OperateLeaderResponse, error)
- func (*UnimplementedMasterServer) OperateRelay(ctx context.Context, req *OperateRelayRequest) (*OperateRelayResponse, error)
- func (*UnimplementedMasterServer) OperateSchema(ctx context.Context, req *OperateSchemaRequest) (*OperateSchemaResponse, error)
- func (*UnimplementedMasterServer) OperateSource(ctx context.Context, req *OperateSourceRequest) (*OperateSourceResponse, error)
- func (*UnimplementedMasterServer) OperateTask(ctx context.Context, req *OperateTaskRequest) (*OperateTaskResponse, error)
- func (*UnimplementedMasterServer) OperateWorkerRelayTask(ctx context.Context, req *OperateWorkerRelayRequest) (*OperateWorkerRelayResponse, error)
- func (*UnimplementedMasterServer) PurgeWorkerRelay(ctx context.Context, req *PurgeWorkerRelayRequest) (*PurgeWorkerRelayResponse, error)
- func (*UnimplementedMasterServer) QueryStatus(ctx context.Context, req *QueryStatusListRequest) (*QueryStatusListResponse, error)
- func (*UnimplementedMasterServer) RegisterWorker(ctx context.Context, req *RegisterWorkerRequest) (*RegisterWorkerResponse, error)
- func (*UnimplementedMasterServer) ShowDDLLocks(ctx context.Context, req *ShowDDLLocksRequest) (*ShowDDLLocksResponse, error)
- func (*UnimplementedMasterServer) StartTask(ctx context.Context, req *StartTaskRequest) (*StartTaskResponse, error)
- func (*UnimplementedMasterServer) TransferSource(ctx context.Context, req *TransferSourceRequest) (*TransferSourceResponse, error)
- func (*UnimplementedMasterServer) UnlockDDLLock(ctx context.Context, req *UnlockDDLLockRequest) (*UnlockDDLLockResponse, error)
- func (*UnimplementedMasterServer) UpdateTask(ctx context.Context, req *UpdateTaskRequest) (*UpdateTaskResponse, error)
- type UnimplementedWorkerServer
- func (*UnimplementedWorkerServer) GetWorkerCfg(ctx context.Context, req *GetWorkerCfgRequest) (*GetWorkerCfgResponse, error)
- func (*UnimplementedWorkerServer) HandleError(ctx context.Context, req *HandleWorkerErrorRequest) (*CommonWorkerResponse, error)
- func (*UnimplementedWorkerServer) OperateSchema(ctx context.Context, req *OperateWorkerSchemaRequest) (*CommonWorkerResponse, error)
- func (*UnimplementedWorkerServer) OperateV1Meta(ctx context.Context, req *OperateV1MetaRequest) (*OperateV1MetaResponse, error)
- func (*UnimplementedWorkerServer) PurgeRelay(ctx context.Context, req *PurgeRelayRequest) (*CommonWorkerResponse, error)
- func (*UnimplementedWorkerServer) QueryStatus(ctx context.Context, req *QueryStatusRequest) (*QueryStatusResponse, error)
- type UnitType
- type UnlockDDLLockRequest
- func (*UnlockDDLLockRequest) Descriptor() ([]byte, []int)
- func (m *UnlockDDLLockRequest) GetForceRemove() bool
- func (m *UnlockDDLLockRequest) GetID() string
- func (m *UnlockDDLLockRequest) GetReplaceOwner() string
- func (m *UnlockDDLLockRequest) Marshal() (dAtA []byte, err error)
- func (m *UnlockDDLLockRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *UnlockDDLLockRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*UnlockDDLLockRequest) ProtoMessage()
- func (m *UnlockDDLLockRequest) Reset()
- func (m *UnlockDDLLockRequest) Size() (n int)
- func (m *UnlockDDLLockRequest) String() string
- func (m *UnlockDDLLockRequest) Unmarshal(dAtA []byte) error
- func (m *UnlockDDLLockRequest) XXX_DiscardUnknown()
- func (m *UnlockDDLLockRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UnlockDDLLockRequest) XXX_Merge(src proto.Message)
- func (m *UnlockDDLLockRequest) XXX_Size() int
- func (m *UnlockDDLLockRequest) XXX_Unmarshal(b []byte) error
- type UnlockDDLLockResponse
- func (*UnlockDDLLockResponse) Descriptor() ([]byte, []int)
- func (m *UnlockDDLLockResponse) GetMsg() string
- func (m *UnlockDDLLockResponse) GetResult() bool
- func (m *UnlockDDLLockResponse) Marshal() (dAtA []byte, err error)
- func (m *UnlockDDLLockResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *UnlockDDLLockResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*UnlockDDLLockResponse) ProtoMessage()
- func (m *UnlockDDLLockResponse) Reset()
- func (m *UnlockDDLLockResponse) Size() (n int)
- func (m *UnlockDDLLockResponse) String() string
- func (m *UnlockDDLLockResponse) Unmarshal(dAtA []byte) error
- func (m *UnlockDDLLockResponse) XXX_DiscardUnknown()
- func (m *UnlockDDLLockResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UnlockDDLLockResponse) XXX_Merge(src proto.Message)
- func (m *UnlockDDLLockResponse) XXX_Size() int
- func (m *UnlockDDLLockResponse) XXX_Unmarshal(b []byte) error
- type UpdateTaskRequest
- func (*UpdateTaskRequest) Descriptor() ([]byte, []int)
- func (m *UpdateTaskRequest) GetSources() []string
- func (m *UpdateTaskRequest) GetTask() string
- func (m *UpdateTaskRequest) Marshal() (dAtA []byte, err error)
- func (m *UpdateTaskRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *UpdateTaskRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*UpdateTaskRequest) ProtoMessage()
- func (m *UpdateTaskRequest) Reset()
- func (m *UpdateTaskRequest) Size() (n int)
- func (m *UpdateTaskRequest) String() string
- func (m *UpdateTaskRequest) Unmarshal(dAtA []byte) error
- func (m *UpdateTaskRequest) XXX_DiscardUnknown()
- func (m *UpdateTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UpdateTaskRequest) XXX_Merge(src proto.Message)
- func (m *UpdateTaskRequest) XXX_Size() int
- func (m *UpdateTaskRequest) XXX_Unmarshal(b []byte) error
- type UpdateTaskResponse
- func (*UpdateTaskResponse) Descriptor() ([]byte, []int)
- func (m *UpdateTaskResponse) GetMsg() string
- func (m *UpdateTaskResponse) GetResult() bool
- func (m *UpdateTaskResponse) GetSources() []*CommonWorkerResponse
- func (m *UpdateTaskResponse) Marshal() (dAtA []byte, err error)
- func (m *UpdateTaskResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *UpdateTaskResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*UpdateTaskResponse) ProtoMessage()
- func (m *UpdateTaskResponse) Reset()
- func (m *UpdateTaskResponse) Size() (n int)
- func (m *UpdateTaskResponse) String() string
- func (m *UpdateTaskResponse) Unmarshal(dAtA []byte) error
- func (m *UpdateTaskResponse) XXX_DiscardUnknown()
- func (m *UpdateTaskResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UpdateTaskResponse) XXX_Merge(src proto.Message)
- func (m *UpdateTaskResponse) XXX_Size() int
- func (m *UpdateTaskResponse) XXX_Unmarshal(b []byte) error
- type V1MetaOp
- type V1SubTaskMeta
- func (*V1SubTaskMeta) Descriptor() ([]byte, []int)
- func (m *V1SubTaskMeta) GetName() string
- func (m *V1SubTaskMeta) GetOp() TaskOp
- func (m *V1SubTaskMeta) GetStage() Stage
- func (m *V1SubTaskMeta) GetTask() []byte
- func (m *V1SubTaskMeta) Marshal() (dAtA []byte, err error)
- func (m *V1SubTaskMeta) MarshalTo(dAtA []byte) (int, error)
- func (m *V1SubTaskMeta) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*V1SubTaskMeta) ProtoMessage()
- func (m *V1SubTaskMeta) Reset()
- func (m *V1SubTaskMeta) Size() (n int)
- func (m *V1SubTaskMeta) String() string
- func (m *V1SubTaskMeta) Unmarshal(dAtA []byte) error
- func (m *V1SubTaskMeta) XXX_DiscardUnknown()
- func (m *V1SubTaskMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *V1SubTaskMeta) XXX_Merge(src proto.Message)
- func (m *V1SubTaskMeta) XXX_Size() int
- func (m *V1SubTaskMeta) XXX_Unmarshal(b []byte) error
- type WorkerClient
- type WorkerInfo
- func (*WorkerInfo) Descriptor() ([]byte, []int)
- func (m *WorkerInfo) GetAddr() string
- func (m *WorkerInfo) GetName() string
- func (m *WorkerInfo) GetSource() string
- func (m *WorkerInfo) GetStage() string
- func (m *WorkerInfo) Marshal() (dAtA []byte, err error)
- func (m *WorkerInfo) MarshalTo(dAtA []byte) (int, error)
- func (m *WorkerInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*WorkerInfo) ProtoMessage()
- func (m *WorkerInfo) Reset()
- func (m *WorkerInfo) Size() (n int)
- func (m *WorkerInfo) String() string
- func (m *WorkerInfo) Unmarshal(dAtA []byte) error
- func (m *WorkerInfo) XXX_DiscardUnknown()
- func (m *WorkerInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WorkerInfo) XXX_Merge(src proto.Message)
- func (m *WorkerInfo) XXX_Size() int
- func (m *WorkerInfo) XXX_Unmarshal(b []byte) error
- type WorkerServer
Constants ¶
This section is empty.
Variables ¶
var ( ErrInvalidLengthDmmaster = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowDmmaster = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupDmmaster = fmt.Errorf("proto: unexpected end of group") )
var ( ErrInvalidLengthDmworker = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowDmworker = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupDmworker = fmt.Errorf("proto: unexpected end of group") )
var CfgType_name = map[int32]string{
0: "InvalidType",
1: "TaskType",
2: "MasterType",
3: "WorkerType",
4: "SourceType",
5: "TaskTemplateType",
}
var CfgType_value = map[string]int32{
"InvalidType": 0,
"TaskType": 1,
"MasterType": 2,
"WorkerType": 3,
"SourceType": 4,
"TaskTemplateType": 5,
}
var ErrorOp_name = map[int32]string{
0: "InvalidErrorOp",
1: "Skip",
2: "Replace",
3: "Revert",
4: "Inject",
5: "List",
}
var ErrorOp_value = map[string]int32{
"InvalidErrorOp": 0,
"Skip": 1,
"Replace": 2,
"Revert": 3,
"Inject": 4,
"List": 5,
}
var LeaderOp_name = map[int32]string{
0: "InvalidLeaderOp",
1: "EvictLeaderOp",
2: "CancelEvictLeaderOp",
}
var LeaderOp_value = map[string]int32{
"InvalidLeaderOp": 0,
"EvictLeaderOp": 1,
"CancelEvictLeaderOp": 2,
}
var RelayOpV2_name = map[int32]string{
0: "InvalidRelayOpV2",
1: "StartRelayV2",
2: "StopRelayV2",
}
var RelayOpV2_value = map[string]int32{
"InvalidRelayOpV2": 0,
"StartRelayV2": 1,
"StopRelayV2": 2,
}
var RelayOp_name = map[int32]string{
0: "InvalidRelayOp",
1: "StopRelay",
2: "PauseRelay",
3: "ResumeRelay",
}
var RelayOp_value = map[string]int32{
"InvalidRelayOp": 0,
"StopRelay": 1,
"PauseRelay": 2,
"ResumeRelay": 3,
}
var SchemaOp_name = map[int32]string{
0: "InvalidSchemaOp",
1: "GetSchema",
2: "SetSchema",
3: "RemoveSchema",
4: "ListSchema",
5: "ListTable",
}
var SchemaOp_value = map[string]int32{
"InvalidSchemaOp": 0,
"GetSchema": 1,
"SetSchema": 2,
"RemoveSchema": 3,
"ListSchema": 4,
"ListTable": 5,
}
var SourceOp_name = map[int32]string{
0: "InvalidSourceOp",
1: "StartSource",
2: "UpdateSource",
3: "StopSource",
4: "ShowSource",
}
var SourceOp_value = map[string]int32{
"InvalidSourceOp": 0,
"StartSource": 1,
"UpdateSource": 2,
"StopSource": 3,
"ShowSource": 4,
}
var Stage_name = map[int32]string{
0: "InvalidStage",
1: "New",
2: "Running",
3: "Paused",
4: "Stopped",
5: "Finished",
6: "Pausing",
7: "Resuming",
8: "Stopping",
}
var Stage_value = map[string]int32{
"InvalidStage": 0,
"New": 1,
"Running": 2,
"Paused": 3,
"Stopped": 4,
"Finished": 5,
"Pausing": 6,
"Resuming": 7,
"Stopping": 8,
}
var TaskOp_name = map[int32]string{
0: "InvalidOp",
1: "Stop",
2: "Pause",
3: "Resume",
4: "Start",
5: "Update",
6: "AutoResume",
}
var TaskOp_value = map[string]int32{
"InvalidOp": 0,
"Stop": 1,
"Pause": 2,
"Resume": 3,
"Start": 4,
"Update": 5,
"AutoResume": 6,
}
var UnitType_name = map[int32]string{
0: "InvalidUnit",
1: "Check",
2: "Dump",
3: "Load",
4: "Sync",
100: "Relay",
}
var UnitType_value = map[string]int32{
"InvalidUnit": 0,
"Check": 1,
"Dump": 2,
"Load": 3,
"Sync": 4,
"Relay": 100,
}
var V1MetaOp_name = map[int32]string{
0: "InvalidV1MetaOp",
1: "GetV1Meta",
2: "RemoveV1Meta",
}
var V1MetaOp_value = map[string]int32{
"InvalidV1MetaOp": 0,
"GetV1Meta": 1,
"RemoveV1Meta": 2,
}
Functions ¶
func RegisterMasterHandler ¶
RegisterMasterHandler registers the http handlers for service Master to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterMasterHandlerClient ¶
func RegisterMasterHandlerClient(ctx context.Context, mux *runtime.ServeMux, client MasterClient) error
RegisterMasterHandlerClient registers the http handlers for service Master to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "MasterClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "MasterClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "MasterClient" to call the correct interceptors.
func RegisterMasterHandlerFromEndpoint ¶
func RegisterMasterHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterMasterHandlerFromEndpoint is same as RegisterMasterHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterMasterHandlerServer ¶
func RegisterMasterHandlerServer(ctx context.Context, mux *runtime.ServeMux, server MasterServer) error
RegisterMasterHandlerServer registers the http handlers for service Master to "mux". UnaryRPC :call MasterServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterMasterHandlerFromEndpoint instead.
func RegisterMasterServer ¶
func RegisterMasterServer(s *grpc.Server, srv MasterServer)
func RegisterWorkerServer ¶
func RegisterWorkerServer(s *grpc.Server, srv WorkerServer)
Types ¶
type CheckError ¶
type CheckError struct {
Msg string `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
}
CheckError represents error for check unit adds fields later
func (*CheckError) Descriptor ¶
func (*CheckError) Descriptor() ([]byte, []int)
func (*CheckError) GetMsg ¶
func (m *CheckError) GetMsg() string
func (*CheckError) Marshal ¶
func (m *CheckError) Marshal() (dAtA []byte, err error)
func (*CheckError) MarshalToSizedBuffer ¶
func (m *CheckError) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CheckError) ProtoMessage ¶
func (*CheckError) ProtoMessage()
func (*CheckError) Reset ¶
func (m *CheckError) Reset()
func (*CheckError) Size ¶
func (m *CheckError) Size() (n int)
func (*CheckError) String ¶
func (m *CheckError) String() string
func (*CheckError) Unmarshal ¶
func (m *CheckError) Unmarshal(dAtA []byte) error
func (*CheckError) XXX_DiscardUnknown ¶
func (m *CheckError) XXX_DiscardUnknown()
func (*CheckError) XXX_Marshal ¶
func (m *CheckError) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CheckError) XXX_Merge ¶
func (m *CheckError) XXX_Merge(src proto.Message)
func (*CheckError) XXX_Size ¶
func (m *CheckError) XXX_Size() int
func (*CheckError) XXX_Unmarshal ¶
func (m *CheckError) XXX_Unmarshal(b []byte) error
type CheckStatus ¶
type CheckStatus struct { Passed bool `protobuf:"varint,1,opt,name=passed,proto3" json:"passed,omitempty"` Total int32 `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"` Successful int32 `protobuf:"varint,3,opt,name=successful,proto3" json:"successful,omitempty"` Failed int32 `protobuf:"varint,4,opt,name=failed,proto3" json:"failed,omitempty"` Warning int32 `protobuf:"varint,5,opt,name=warning,proto3" json:"warning,omitempty"` Detail []byte `protobuf:"bytes,6,opt,name=detail,proto3" json:"detail,omitempty"` }
CheckStatus represents status for check unit adds fields later
func (*CheckStatus) Descriptor ¶
func (*CheckStatus) Descriptor() ([]byte, []int)
func (*CheckStatus) GetDetail ¶
func (m *CheckStatus) GetDetail() []byte
func (*CheckStatus) GetFailed ¶
func (m *CheckStatus) GetFailed() int32
func (*CheckStatus) GetPassed ¶
func (m *CheckStatus) GetPassed() bool
func (*CheckStatus) GetSuccessful ¶
func (m *CheckStatus) GetSuccessful() int32
func (*CheckStatus) GetTotal ¶
func (m *CheckStatus) GetTotal() int32
func (*CheckStatus) GetWarning ¶
func (m *CheckStatus) GetWarning() int32
func (*CheckStatus) Marshal ¶
func (m *CheckStatus) Marshal() (dAtA []byte, err error)
func (*CheckStatus) MarshalToSizedBuffer ¶
func (m *CheckStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CheckStatus) ProtoMessage ¶
func (*CheckStatus) ProtoMessage()
func (*CheckStatus) Reset ¶
func (m *CheckStatus) Reset()
func (*CheckStatus) Size ¶
func (m *CheckStatus) Size() (n int)
func (*CheckStatus) String ¶
func (m *CheckStatus) String() string
func (*CheckStatus) Unmarshal ¶
func (m *CheckStatus) Unmarshal(dAtA []byte) error
func (*CheckStatus) XXX_DiscardUnknown ¶
func (m *CheckStatus) XXX_DiscardUnknown()
func (*CheckStatus) XXX_Marshal ¶
func (m *CheckStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CheckStatus) XXX_Merge ¶
func (m *CheckStatus) XXX_Merge(src proto.Message)
func (*CheckStatus) XXX_Size ¶
func (m *CheckStatus) XXX_Size() int
func (*CheckStatus) XXX_Unmarshal ¶
func (m *CheckStatus) XXX_Unmarshal(b []byte) error
type CheckTaskRequest ¶
type CheckTaskRequest struct { Task string `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"` ErrCnt int64 `protobuf:"varint,2,opt,name=errCnt,proto3" json:"errCnt,omitempty"` WarnCnt int64 `protobuf:"varint,3,opt,name=warnCnt,proto3" json:"warnCnt,omitempty"` StartTime string `protobuf:"bytes,4,opt,name=startTime,proto3" json:"startTime,omitempty"` }
func (*CheckTaskRequest) Descriptor ¶
func (*CheckTaskRequest) Descriptor() ([]byte, []int)
func (*CheckTaskRequest) GetErrCnt ¶ added in v1.9.0
func (m *CheckTaskRequest) GetErrCnt() int64
func (*CheckTaskRequest) GetStartTime ¶ added in v1.9.0
func (m *CheckTaskRequest) GetStartTime() string
func (*CheckTaskRequest) GetTask ¶
func (m *CheckTaskRequest) GetTask() string
func (*CheckTaskRequest) GetWarnCnt ¶ added in v1.9.0
func (m *CheckTaskRequest) GetWarnCnt() int64
func (*CheckTaskRequest) Marshal ¶
func (m *CheckTaskRequest) Marshal() (dAtA []byte, err error)
func (*CheckTaskRequest) MarshalToSizedBuffer ¶
func (m *CheckTaskRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CheckTaskRequest) ProtoMessage ¶
func (*CheckTaskRequest) ProtoMessage()
func (*CheckTaskRequest) Reset ¶
func (m *CheckTaskRequest) Reset()
func (*CheckTaskRequest) Size ¶
func (m *CheckTaskRequest) Size() (n int)
func (*CheckTaskRequest) String ¶
func (m *CheckTaskRequest) String() string
func (*CheckTaskRequest) Unmarshal ¶
func (m *CheckTaskRequest) Unmarshal(dAtA []byte) error
func (*CheckTaskRequest) XXX_DiscardUnknown ¶
func (m *CheckTaskRequest) XXX_DiscardUnknown()
func (*CheckTaskRequest) XXX_Marshal ¶
func (m *CheckTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CheckTaskRequest) XXX_Merge ¶
func (m *CheckTaskRequest) XXX_Merge(src proto.Message)
func (*CheckTaskRequest) XXX_Size ¶
func (m *CheckTaskRequest) XXX_Size() int
func (*CheckTaskRequest) XXX_Unmarshal ¶
func (m *CheckTaskRequest) XXX_Unmarshal(b []byte) error
type CheckTaskResponse ¶
type CheckTaskResponse struct { Result bool `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"` Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"` }
func (*CheckTaskResponse) Descriptor ¶
func (*CheckTaskResponse) Descriptor() ([]byte, []int)
func (*CheckTaskResponse) GetMsg ¶
func (m *CheckTaskResponse) GetMsg() string
func (*CheckTaskResponse) GetResult ¶
func (m *CheckTaskResponse) GetResult() bool
func (*CheckTaskResponse) Marshal ¶
func (m *CheckTaskResponse) Marshal() (dAtA []byte, err error)
func (*CheckTaskResponse) MarshalTo ¶
func (m *CheckTaskResponse) MarshalTo(dAtA []byte) (int, error)
func (*CheckTaskResponse) MarshalToSizedBuffer ¶
func (m *CheckTaskResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CheckTaskResponse) ProtoMessage ¶
func (*CheckTaskResponse) ProtoMessage()
func (*CheckTaskResponse) Reset ¶
func (m *CheckTaskResponse) Reset()
func (*CheckTaskResponse) Size ¶
func (m *CheckTaskResponse) Size() (n int)
func (*CheckTaskResponse) String ¶
func (m *CheckTaskResponse) String() string
func (*CheckTaskResponse) Unmarshal ¶
func (m *CheckTaskResponse) Unmarshal(dAtA []byte) error
func (*CheckTaskResponse) XXX_DiscardUnknown ¶
func (m *CheckTaskResponse) XXX_DiscardUnknown()
func (*CheckTaskResponse) XXX_Marshal ¶
func (m *CheckTaskResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CheckTaskResponse) XXX_Merge ¶
func (m *CheckTaskResponse) XXX_Merge(src proto.Message)
func (*CheckTaskResponse) XXX_Size ¶
func (m *CheckTaskResponse) XXX_Size() int
func (*CheckTaskResponse) XXX_Unmarshal ¶
func (m *CheckTaskResponse) XXX_Unmarshal(b []byte) error
type CommonWorkerResponse ¶
type CommonWorkerResponse struct { Result bool `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"` Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"` Source string `protobuf:"bytes,3,opt,name=source,proto3" json:"source,omitempty"` Worker string `protobuf:"bytes,4,opt,name=worker,proto3" json:"worker,omitempty"` }
func (*CommonWorkerResponse) Descriptor ¶
func (*CommonWorkerResponse) Descriptor() ([]byte, []int)
func (*CommonWorkerResponse) GetMsg ¶
func (m *CommonWorkerResponse) GetMsg() string
func (*CommonWorkerResponse) GetResult ¶
func (m *CommonWorkerResponse) GetResult() bool
func (*CommonWorkerResponse) GetSource ¶
func (m *CommonWorkerResponse) GetSource() string
func (*CommonWorkerResponse) GetWorker ¶
func (m *CommonWorkerResponse) GetWorker() string
func (*CommonWorkerResponse) Marshal ¶
func (m *CommonWorkerResponse) Marshal() (dAtA []byte, err error)
func (*CommonWorkerResponse) MarshalTo ¶
func (m *CommonWorkerResponse) MarshalTo(dAtA []byte) (int, error)
func (*CommonWorkerResponse) MarshalToSizedBuffer ¶
func (m *CommonWorkerResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CommonWorkerResponse) ProtoMessage ¶
func (*CommonWorkerResponse) ProtoMessage()
func (*CommonWorkerResponse) Reset ¶
func (m *CommonWorkerResponse) Reset()
func (*CommonWorkerResponse) Size ¶
func (m *CommonWorkerResponse) Size() (n int)
func (*CommonWorkerResponse) String ¶
func (m *CommonWorkerResponse) String() string
func (*CommonWorkerResponse) Unmarshal ¶
func (m *CommonWorkerResponse) Unmarshal(dAtA []byte) error
func (*CommonWorkerResponse) XXX_DiscardUnknown ¶
func (m *CommonWorkerResponse) XXX_DiscardUnknown()
func (*CommonWorkerResponse) XXX_Marshal ¶
func (m *CommonWorkerResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CommonWorkerResponse) XXX_Merge ¶
func (m *CommonWorkerResponse) XXX_Merge(src proto.Message)
func (*CommonWorkerResponse) XXX_Size ¶
func (m *CommonWorkerResponse) XXX_Size() int
func (*CommonWorkerResponse) XXX_Unmarshal ¶
func (m *CommonWorkerResponse) XXX_Unmarshal(b []byte) error
type DDLLock ¶
type DDLLock struct { ID string `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"` Task string `protobuf:"bytes,2,opt,name=task,proto3" json:"task,omitempty"` Mode string `protobuf:"bytes,3,opt,name=mode,proto3" json:"mode,omitempty"` Owner string `protobuf:"bytes,4,opt,name=owner,proto3" json:"owner,omitempty"` DDLs []string `protobuf:"bytes,5,rep,name=DDLs,proto3" json:"DDLs,omitempty"` Synced []string `protobuf:"bytes,6,rep,name=synced,proto3" json:"synced,omitempty"` Unsynced []string `protobuf:"bytes,7,rep,name=unsynced,proto3" json:"unsynced,omitempty"` }
DDLLock represents a DDL lock info (I known the name confused with DDLLockInfo, any suggestion?) it been sent from dm-master to dmctl ID: DDL lock generated ID task: lock's corresponding task name mode: the shard DDL mode, `pessimistic` or `optimistic`. owner: lock's owner, a dm-worker DDL: DDL statement synced: already synced dm-workers unsynced: pending to sync dm-workers
func (*DDLLock) Descriptor ¶
func (*DDLLock) GetUnsynced ¶
func (*DDLLock) MarshalToSizedBuffer ¶
func (*DDLLock) ProtoMessage ¶
func (*DDLLock) ProtoMessage()
func (*DDLLock) XXX_DiscardUnknown ¶
func (m *DDLLock) XXX_DiscardUnknown()
func (*DDLLock) XXX_Marshal ¶
func (*DDLLock) XXX_Unmarshal ¶
type DumpError ¶
type DumpError struct {
Msg string `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
}
DumpError represents error for dump unit add fields later
func (*DumpError) Descriptor ¶
func (*DumpError) MarshalToSizedBuffer ¶
func (*DumpError) ProtoMessage ¶
func (*DumpError) ProtoMessage()
func (*DumpError) XXX_DiscardUnknown ¶
func (m *DumpError) XXX_DiscardUnknown()
func (*DumpError) XXX_Marshal ¶
func (*DumpError) XXX_Unmarshal ¶
type DumpStatus ¶
type DumpStatus struct { TotalTables int64 `protobuf:"varint,1,opt,name=totalTables,proto3" json:"totalTables,omitempty"` CompletedTables float64 `protobuf:"fixed64,2,opt,name=completedTables,proto3" json:"completedTables,omitempty"` FinishedBytes float64 `protobuf:"fixed64,3,opt,name=finishedBytes,proto3" json:"finishedBytes,omitempty"` FinishedRows float64 `protobuf:"fixed64,4,opt,name=finishedRows,proto3" json:"finishedRows,omitempty"` EstimateTotalRows float64 `protobuf:"fixed64,5,opt,name=estimateTotalRows,proto3" json:"estimateTotalRows,omitempty"` }
DumpStatus represents status for dump unit add fields later
func (*DumpStatus) Descriptor ¶
func (*DumpStatus) Descriptor() ([]byte, []int)
func (*DumpStatus) GetCompletedTables ¶ added in v1.9.0
func (m *DumpStatus) GetCompletedTables() float64
func (*DumpStatus) GetEstimateTotalRows ¶ added in v1.9.0
func (m *DumpStatus) GetEstimateTotalRows() float64
func (*DumpStatus) GetFinishedBytes ¶ added in v1.9.0
func (m *DumpStatus) GetFinishedBytes() float64
func (*DumpStatus) GetFinishedRows ¶ added in v1.9.0
func (m *DumpStatus) GetFinishedRows() float64
func (*DumpStatus) GetTotalTables ¶ added in v1.9.0
func (m *DumpStatus) GetTotalTables() int64
func (*DumpStatus) Marshal ¶
func (m *DumpStatus) Marshal() (dAtA []byte, err error)
func (*DumpStatus) MarshalToSizedBuffer ¶
func (m *DumpStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*DumpStatus) ProtoMessage ¶
func (*DumpStatus) ProtoMessage()
func (*DumpStatus) Reset ¶
func (m *DumpStatus) Reset()
func (*DumpStatus) Size ¶
func (m *DumpStatus) Size() (n int)
func (*DumpStatus) String ¶
func (m *DumpStatus) String() string
func (*DumpStatus) Unmarshal ¶
func (m *DumpStatus) Unmarshal(dAtA []byte) error
func (*DumpStatus) XXX_DiscardUnknown ¶
func (m *DumpStatus) XXX_DiscardUnknown()
func (*DumpStatus) XXX_Marshal ¶
func (m *DumpStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DumpStatus) XXX_Merge ¶
func (m *DumpStatus) XXX_Merge(src proto.Message)
func (*DumpStatus) XXX_Size ¶
func (m *DumpStatus) XXX_Size() int
func (*DumpStatus) XXX_Unmarshal ¶
func (m *DumpStatus) XXX_Unmarshal(b []byte) error
type GetCfgRequest ¶
type GetCfgRequest struct { Type CfgType `protobuf:"varint,1,opt,name=type,proto3,enum=pb.CfgType" json:"type,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` }
func (*GetCfgRequest) Descriptor ¶
func (*GetCfgRequest) Descriptor() ([]byte, []int)
func (*GetCfgRequest) GetName ¶
func (m *GetCfgRequest) GetName() string
func (*GetCfgRequest) GetType ¶
func (m *GetCfgRequest) GetType() CfgType
func (*GetCfgRequest) Marshal ¶
func (m *GetCfgRequest) Marshal() (dAtA []byte, err error)
func (*GetCfgRequest) MarshalToSizedBuffer ¶
func (m *GetCfgRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetCfgRequest) ProtoMessage ¶
func (*GetCfgRequest) ProtoMessage()
func (*GetCfgRequest) Reset ¶
func (m *GetCfgRequest) Reset()
func (*GetCfgRequest) Size ¶
func (m *GetCfgRequest) Size() (n int)
func (*GetCfgRequest) String ¶
func (m *GetCfgRequest) String() string
func (*GetCfgRequest) Unmarshal ¶
func (m *GetCfgRequest) Unmarshal(dAtA []byte) error
func (*GetCfgRequest) XXX_DiscardUnknown ¶
func (m *GetCfgRequest) XXX_DiscardUnknown()
func (*GetCfgRequest) XXX_Marshal ¶
func (m *GetCfgRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetCfgRequest) XXX_Merge ¶
func (m *GetCfgRequest) XXX_Merge(src proto.Message)
func (*GetCfgRequest) XXX_Size ¶
func (m *GetCfgRequest) XXX_Size() int
func (*GetCfgRequest) XXX_Unmarshal ¶
func (m *GetCfgRequest) XXX_Unmarshal(b []byte) error
type GetCfgResponse ¶
type GetCfgResponse struct { Result bool `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"` Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"` Cfg string `protobuf:"bytes,3,opt,name=cfg,proto3" json:"cfg,omitempty"` }
func (*GetCfgResponse) Descriptor ¶
func (*GetCfgResponse) Descriptor() ([]byte, []int)
func (*GetCfgResponse) GetCfg ¶
func (m *GetCfgResponse) GetCfg() string
func (*GetCfgResponse) GetMsg ¶
func (m *GetCfgResponse) GetMsg() string
func (*GetCfgResponse) GetResult ¶
func (m *GetCfgResponse) GetResult() bool
func (*GetCfgResponse) Marshal ¶
func (m *GetCfgResponse) Marshal() (dAtA []byte, err error)
func (*GetCfgResponse) MarshalToSizedBuffer ¶
func (m *GetCfgResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetCfgResponse) ProtoMessage ¶
func (*GetCfgResponse) ProtoMessage()
func (*GetCfgResponse) Reset ¶
func (m *GetCfgResponse) Reset()
func (*GetCfgResponse) Size ¶
func (m *GetCfgResponse) Size() (n int)
func (*GetCfgResponse) String ¶
func (m *GetCfgResponse) String() string
func (*GetCfgResponse) Unmarshal ¶
func (m *GetCfgResponse) Unmarshal(dAtA []byte) error
func (*GetCfgResponse) XXX_DiscardUnknown ¶
func (m *GetCfgResponse) XXX_DiscardUnknown()
func (*GetCfgResponse) XXX_Marshal ¶
func (m *GetCfgResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetCfgResponse) XXX_Merge ¶
func (m *GetCfgResponse) XXX_Merge(src proto.Message)
func (*GetCfgResponse) XXX_Size ¶
func (m *GetCfgResponse) XXX_Size() int
func (*GetCfgResponse) XXX_Unmarshal ¶
func (m *GetCfgResponse) XXX_Unmarshal(b []byte) error
type GetMasterCfgRequest ¶
type GetMasterCfgRequest struct { }
func (*GetMasterCfgRequest) Descriptor ¶
func (*GetMasterCfgRequest) Descriptor() ([]byte, []int)
func (*GetMasterCfgRequest) Marshal ¶
func (m *GetMasterCfgRequest) Marshal() (dAtA []byte, err error)
func (*GetMasterCfgRequest) MarshalTo ¶
func (m *GetMasterCfgRequest) MarshalTo(dAtA []byte) (int, error)
func (*GetMasterCfgRequest) MarshalToSizedBuffer ¶
func (m *GetMasterCfgRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetMasterCfgRequest) ProtoMessage ¶
func (*GetMasterCfgRequest) ProtoMessage()
func (*GetMasterCfgRequest) Reset ¶
func (m *GetMasterCfgRequest) Reset()
func (*GetMasterCfgRequest) Size ¶
func (m *GetMasterCfgRequest) Size() (n int)
func (*GetMasterCfgRequest) String ¶
func (m *GetMasterCfgRequest) String() string
func (*GetMasterCfgRequest) Unmarshal ¶
func (m *GetMasterCfgRequest) Unmarshal(dAtA []byte) error
func (*GetMasterCfgRequest) XXX_DiscardUnknown ¶
func (m *GetMasterCfgRequest) XXX_DiscardUnknown()
func (*GetMasterCfgRequest) XXX_Marshal ¶
func (m *GetMasterCfgRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetMasterCfgRequest) XXX_Merge ¶
func (m *GetMasterCfgRequest) XXX_Merge(src proto.Message)
func (*GetMasterCfgRequest) XXX_Size ¶
func (m *GetMasterCfgRequest) XXX_Size() int
func (*GetMasterCfgRequest) XXX_Unmarshal ¶
func (m *GetMasterCfgRequest) XXX_Unmarshal(b []byte) error
type GetMasterCfgResponse ¶
type GetMasterCfgResponse struct {
Cfg string `protobuf:"bytes,1,opt,name=cfg,proto3" json:"cfg,omitempty"`
}
func (*GetMasterCfgResponse) Descriptor ¶
func (*GetMasterCfgResponse) Descriptor() ([]byte, []int)
func (*GetMasterCfgResponse) GetCfg ¶
func (m *GetMasterCfgResponse) GetCfg() string
func (*GetMasterCfgResponse) Marshal ¶
func (m *GetMasterCfgResponse) Marshal() (dAtA []byte, err error)
func (*GetMasterCfgResponse) MarshalTo ¶
func (m *GetMasterCfgResponse) MarshalTo(dAtA []byte) (int, error)
func (*GetMasterCfgResponse) MarshalToSizedBuffer ¶
func (m *GetMasterCfgResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetMasterCfgResponse) ProtoMessage ¶
func (*GetMasterCfgResponse) ProtoMessage()
func (*GetMasterCfgResponse) Reset ¶
func (m *GetMasterCfgResponse) Reset()
func (*GetMasterCfgResponse) Size ¶
func (m *GetMasterCfgResponse) Size() (n int)
func (*GetMasterCfgResponse) String ¶
func (m *GetMasterCfgResponse) String() string
func (*GetMasterCfgResponse) Unmarshal ¶
func (m *GetMasterCfgResponse) Unmarshal(dAtA []byte) error
func (*GetMasterCfgResponse) XXX_DiscardUnknown ¶
func (m *GetMasterCfgResponse) XXX_DiscardUnknown()
func (*GetMasterCfgResponse) XXX_Marshal ¶
func (m *GetMasterCfgResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetMasterCfgResponse) XXX_Merge ¶
func (m *GetMasterCfgResponse) XXX_Merge(src proto.Message)
func (*GetMasterCfgResponse) XXX_Size ¶
func (m *GetMasterCfgResponse) XXX_Size() int
func (*GetMasterCfgResponse) XXX_Unmarshal ¶
func (m *GetMasterCfgResponse) XXX_Unmarshal(b []byte) error
type GetSubTaskCfgRequest ¶
type GetSubTaskCfgRequest struct { // the task name Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` }
func (*GetSubTaskCfgRequest) Descriptor ¶
func (*GetSubTaskCfgRequest) Descriptor() ([]byte, []int)
func (*GetSubTaskCfgRequest) GetName ¶
func (m *GetSubTaskCfgRequest) GetName() string
func (*GetSubTaskCfgRequest) Marshal ¶
func (m *GetSubTaskCfgRequest) Marshal() (dAtA []byte, err error)
func (*GetSubTaskCfgRequest) MarshalTo ¶
func (m *GetSubTaskCfgRequest) MarshalTo(dAtA []byte) (int, error)
func (*GetSubTaskCfgRequest) MarshalToSizedBuffer ¶
func (m *GetSubTaskCfgRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetSubTaskCfgRequest) ProtoMessage ¶
func (*GetSubTaskCfgRequest) ProtoMessage()
func (*GetSubTaskCfgRequest) Reset ¶
func (m *GetSubTaskCfgRequest) Reset()
func (*GetSubTaskCfgRequest) Size ¶
func (m *GetSubTaskCfgRequest) Size() (n int)
func (*GetSubTaskCfgRequest) String ¶
func (m *GetSubTaskCfgRequest) String() string
func (*GetSubTaskCfgRequest) Unmarshal ¶
func (m *GetSubTaskCfgRequest) Unmarshal(dAtA []byte) error
func (*GetSubTaskCfgRequest) XXX_DiscardUnknown ¶
func (m *GetSubTaskCfgRequest) XXX_DiscardUnknown()
func (*GetSubTaskCfgRequest) XXX_Marshal ¶
func (m *GetSubTaskCfgRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetSubTaskCfgRequest) XXX_Merge ¶
func (m *GetSubTaskCfgRequest) XXX_Merge(src proto.Message)
func (*GetSubTaskCfgRequest) XXX_Size ¶
func (m *GetSubTaskCfgRequest) XXX_Size() int
func (*GetSubTaskCfgRequest) XXX_Unmarshal ¶
func (m *GetSubTaskCfgRequest) XXX_Unmarshal(b []byte) error
type GetSubTaskCfgResponse ¶
type GetSubTaskCfgResponse struct { Result bool `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"` Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"` Cfgs []string `protobuf:"bytes,3,rep,name=cfgs,proto3" json:"cfgs,omitempty"` }
func (*GetSubTaskCfgResponse) Descriptor ¶
func (*GetSubTaskCfgResponse) Descriptor() ([]byte, []int)
func (*GetSubTaskCfgResponse) GetCfgs ¶
func (m *GetSubTaskCfgResponse) GetCfgs() []string
func (*GetSubTaskCfgResponse) GetMsg ¶
func (m *GetSubTaskCfgResponse) GetMsg() string
func (*GetSubTaskCfgResponse) GetResult ¶
func (m *GetSubTaskCfgResponse) GetResult() bool
func (*GetSubTaskCfgResponse) Marshal ¶
func (m *GetSubTaskCfgResponse) Marshal() (dAtA []byte, err error)
func (*GetSubTaskCfgResponse) MarshalTo ¶
func (m *GetSubTaskCfgResponse) MarshalTo(dAtA []byte) (int, error)
func (*GetSubTaskCfgResponse) MarshalToSizedBuffer ¶
func (m *GetSubTaskCfgResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetSubTaskCfgResponse) ProtoMessage ¶
func (*GetSubTaskCfgResponse) ProtoMessage()
func (*GetSubTaskCfgResponse) Reset ¶
func (m *GetSubTaskCfgResponse) Reset()
func (*GetSubTaskCfgResponse) Size ¶
func (m *GetSubTaskCfgResponse) Size() (n int)
func (*GetSubTaskCfgResponse) String ¶
func (m *GetSubTaskCfgResponse) String() string
func (*GetSubTaskCfgResponse) Unmarshal ¶
func (m *GetSubTaskCfgResponse) Unmarshal(dAtA []byte) error
func (*GetSubTaskCfgResponse) XXX_DiscardUnknown ¶
func (m *GetSubTaskCfgResponse) XXX_DiscardUnknown()
func (*GetSubTaskCfgResponse) XXX_Marshal ¶
func (m *GetSubTaskCfgResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetSubTaskCfgResponse) XXX_Merge ¶
func (m *GetSubTaskCfgResponse) XXX_Merge(src proto.Message)
func (*GetSubTaskCfgResponse) XXX_Size ¶
func (m *GetSubTaskCfgResponse) XXX_Size() int
func (*GetSubTaskCfgResponse) XXX_Unmarshal ¶
func (m *GetSubTaskCfgResponse) XXX_Unmarshal(b []byte) error
type GetWorkerCfgRequest ¶
type GetWorkerCfgRequest struct { }
func (*GetWorkerCfgRequest) Descriptor ¶
func (*GetWorkerCfgRequest) Descriptor() ([]byte, []int)
func (*GetWorkerCfgRequest) Marshal ¶
func (m *GetWorkerCfgRequest) Marshal() (dAtA []byte, err error)
func (*GetWorkerCfgRequest) MarshalTo ¶
func (m *GetWorkerCfgRequest) MarshalTo(dAtA []byte) (int, error)
func (*GetWorkerCfgRequest) MarshalToSizedBuffer ¶
func (m *GetWorkerCfgRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetWorkerCfgRequest) ProtoMessage ¶
func (*GetWorkerCfgRequest) ProtoMessage()
func (*GetWorkerCfgRequest) Reset ¶
func (m *GetWorkerCfgRequest) Reset()
func (*GetWorkerCfgRequest) Size ¶
func (m *GetWorkerCfgRequest) Size() (n int)
func (*GetWorkerCfgRequest) String ¶
func (m *GetWorkerCfgRequest) String() string
func (*GetWorkerCfgRequest) Unmarshal ¶
func (m *GetWorkerCfgRequest) Unmarshal(dAtA []byte) error
func (*GetWorkerCfgRequest) XXX_DiscardUnknown ¶
func (m *GetWorkerCfgRequest) XXX_DiscardUnknown()
func (*GetWorkerCfgRequest) XXX_Marshal ¶
func (m *GetWorkerCfgRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetWorkerCfgRequest) XXX_Merge ¶
func (m *GetWorkerCfgRequest) XXX_Merge(src proto.Message)
func (*GetWorkerCfgRequest) XXX_Size ¶
func (m *GetWorkerCfgRequest) XXX_Size() int
func (*GetWorkerCfgRequest) XXX_Unmarshal ¶
func (m *GetWorkerCfgRequest) XXX_Unmarshal(b []byte) error
type GetWorkerCfgResponse ¶
type GetWorkerCfgResponse struct {
Cfg string `protobuf:"bytes,1,opt,name=cfg,proto3" json:"cfg,omitempty"`
}
func (*GetWorkerCfgResponse) Descriptor ¶
func (*GetWorkerCfgResponse) Descriptor() ([]byte, []int)
func (*GetWorkerCfgResponse) GetCfg ¶
func (m *GetWorkerCfgResponse) GetCfg() string
func (*GetWorkerCfgResponse) Marshal ¶
func (m *GetWorkerCfgResponse) Marshal() (dAtA []byte, err error)
func (*GetWorkerCfgResponse) MarshalTo ¶
func (m *GetWorkerCfgResponse) MarshalTo(dAtA []byte) (int, error)
func (*GetWorkerCfgResponse) MarshalToSizedBuffer ¶
func (m *GetWorkerCfgResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetWorkerCfgResponse) ProtoMessage ¶
func (*GetWorkerCfgResponse) ProtoMessage()
func (*GetWorkerCfgResponse) Reset ¶
func (m *GetWorkerCfgResponse) Reset()
func (*GetWorkerCfgResponse) Size ¶
func (m *GetWorkerCfgResponse) Size() (n int)
func (*GetWorkerCfgResponse) String ¶
func (m *GetWorkerCfgResponse) String() string
func (*GetWorkerCfgResponse) Unmarshal ¶
func (m *GetWorkerCfgResponse) Unmarshal(dAtA []byte) error
func (*GetWorkerCfgResponse) XXX_DiscardUnknown ¶
func (m *GetWorkerCfgResponse) XXX_DiscardUnknown()
func (*GetWorkerCfgResponse) XXX_Marshal ¶
func (m *GetWorkerCfgResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetWorkerCfgResponse) XXX_Merge ¶
func (m *GetWorkerCfgResponse) XXX_Merge(src proto.Message)
func (*GetWorkerCfgResponse) XXX_Size ¶
func (m *GetWorkerCfgResponse) XXX_Size() int
func (*GetWorkerCfgResponse) XXX_Unmarshal ¶
func (m *GetWorkerCfgResponse) XXX_Unmarshal(b []byte) error
type HandleErrorRequest ¶
type HandleErrorRequest struct { Op ErrorOp `protobuf:"varint,1,opt,name=op,proto3,enum=pb.ErrorOp" json:"op,omitempty"` Task string `protobuf:"bytes,2,opt,name=task,proto3" json:"task,omitempty"` Sources []string `protobuf:"bytes,3,rep,name=sources,proto3" json:"sources,omitempty"` BinlogPos string `protobuf:"bytes,4,opt,name=binlogPos,proto3" json:"binlogPos,omitempty"` Sqls []string `protobuf:"bytes,5,rep,name=sqls,proto3" json:"sqls,omitempty"` }
func (*HandleErrorRequest) Descriptor ¶
func (*HandleErrorRequest) Descriptor() ([]byte, []int)
func (*HandleErrorRequest) GetBinlogPos ¶
func (m *HandleErrorRequest) GetBinlogPos() string
func (*HandleErrorRequest) GetOp ¶
func (m *HandleErrorRequest) GetOp() ErrorOp
func (*HandleErrorRequest) GetSources ¶
func (m *HandleErrorRequest) GetSources() []string
func (*HandleErrorRequest) GetSqls ¶
func (m *HandleErrorRequest) GetSqls() []string
func (*HandleErrorRequest) GetTask ¶
func (m *HandleErrorRequest) GetTask() string
func (*HandleErrorRequest) Marshal ¶
func (m *HandleErrorRequest) Marshal() (dAtA []byte, err error)
func (*HandleErrorRequest) MarshalTo ¶
func (m *HandleErrorRequest) MarshalTo(dAtA []byte) (int, error)
func (*HandleErrorRequest) MarshalToSizedBuffer ¶
func (m *HandleErrorRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*HandleErrorRequest) ProtoMessage ¶
func (*HandleErrorRequest) ProtoMessage()
func (*HandleErrorRequest) Reset ¶
func (m *HandleErrorRequest) Reset()
func (*HandleErrorRequest) Size ¶
func (m *HandleErrorRequest) Size() (n int)
func (*HandleErrorRequest) String ¶
func (m *HandleErrorRequest) String() string
func (*HandleErrorRequest) Unmarshal ¶
func (m *HandleErrorRequest) Unmarshal(dAtA []byte) error
func (*HandleErrorRequest) XXX_DiscardUnknown ¶
func (m *HandleErrorRequest) XXX_DiscardUnknown()
func (*HandleErrorRequest) XXX_Marshal ¶
func (m *HandleErrorRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*HandleErrorRequest) XXX_Merge ¶
func (m *HandleErrorRequest) XXX_Merge(src proto.Message)
func (*HandleErrorRequest) XXX_Size ¶
func (m *HandleErrorRequest) XXX_Size() int
func (*HandleErrorRequest) XXX_Unmarshal ¶
func (m *HandleErrorRequest) XXX_Unmarshal(b []byte) error
type HandleErrorResponse ¶
type HandleErrorResponse struct { Result bool `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"` Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"` Sources []*CommonWorkerResponse `protobuf:"bytes,3,rep,name=sources,proto3" json:"sources,omitempty"` }
func (*HandleErrorResponse) Descriptor ¶
func (*HandleErrorResponse) Descriptor() ([]byte, []int)
func (*HandleErrorResponse) GetMsg ¶
func (m *HandleErrorResponse) GetMsg() string
func (*HandleErrorResponse) GetResult ¶
func (m *HandleErrorResponse) GetResult() bool
func (*HandleErrorResponse) GetSources ¶
func (m *HandleErrorResponse) GetSources() []*CommonWorkerResponse
func (*HandleErrorResponse) Marshal ¶
func (m *HandleErrorResponse) Marshal() (dAtA []byte, err error)
func (*HandleErrorResponse) MarshalTo ¶
func (m *HandleErrorResponse) MarshalTo(dAtA []byte) (int, error)
func (*HandleErrorResponse) MarshalToSizedBuffer ¶
func (m *HandleErrorResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*HandleErrorResponse) ProtoMessage ¶
func (*HandleErrorResponse) ProtoMessage()
func (*HandleErrorResponse) Reset ¶
func (m *HandleErrorResponse) Reset()
func (*HandleErrorResponse) Size ¶
func (m *HandleErrorResponse) Size() (n int)
func (*HandleErrorResponse) String ¶
func (m *HandleErrorResponse) String() string
func (*HandleErrorResponse) Unmarshal ¶
func (m *HandleErrorResponse) Unmarshal(dAtA []byte) error
func (*HandleErrorResponse) XXX_DiscardUnknown ¶
func (m *HandleErrorResponse) XXX_DiscardUnknown()
func (*HandleErrorResponse) XXX_Marshal ¶
func (m *HandleErrorResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*HandleErrorResponse) XXX_Merge ¶
func (m *HandleErrorResponse) XXX_Merge(src proto.Message)
func (*HandleErrorResponse) XXX_Size ¶
func (m *HandleErrorResponse) XXX_Size() int
func (*HandleErrorResponse) XXX_Unmarshal ¶
func (m *HandleErrorResponse) XXX_Unmarshal(b []byte) error
type HandleWorkerErrorRequest ¶
type HandleWorkerErrorRequest struct { Op ErrorOp `protobuf:"varint,1,opt,name=op,proto3,enum=pb.ErrorOp" json:"op,omitempty"` Task string `protobuf:"bytes,2,opt,name=task,proto3" json:"task,omitempty"` BinlogPos string `protobuf:"bytes,3,opt,name=binlogPos,proto3" json:"binlogPos,omitempty"` Sqls []string `protobuf:"bytes,4,rep,name=sqls,proto3" json:"sqls,omitempty"` }
func (*HandleWorkerErrorRequest) Descriptor ¶
func (*HandleWorkerErrorRequest) Descriptor() ([]byte, []int)
func (*HandleWorkerErrorRequest) GetBinlogPos ¶
func (m *HandleWorkerErrorRequest) GetBinlogPos() string
func (*HandleWorkerErrorRequest) GetOp ¶
func (m *HandleWorkerErrorRequest) GetOp() ErrorOp
func (*HandleWorkerErrorRequest) GetSqls ¶
func (m *HandleWorkerErrorRequest) GetSqls() []string
func (*HandleWorkerErrorRequest) GetTask ¶
func (m *HandleWorkerErrorRequest) GetTask() string
func (*HandleWorkerErrorRequest) Marshal ¶
func (m *HandleWorkerErrorRequest) Marshal() (dAtA []byte, err error)
func (*HandleWorkerErrorRequest) MarshalTo ¶
func (m *HandleWorkerErrorRequest) MarshalTo(dAtA []byte) (int, error)
func (*HandleWorkerErrorRequest) MarshalToSizedBuffer ¶
func (m *HandleWorkerErrorRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*HandleWorkerErrorRequest) ProtoMessage ¶
func (*HandleWorkerErrorRequest) ProtoMessage()
func (*HandleWorkerErrorRequest) Reset ¶
func (m *HandleWorkerErrorRequest) Reset()
func (*HandleWorkerErrorRequest) Size ¶
func (m *HandleWorkerErrorRequest) Size() (n int)
func (*HandleWorkerErrorRequest) String ¶
func (m *HandleWorkerErrorRequest) String() string
func (*HandleWorkerErrorRequest) Unmarshal ¶
func (m *HandleWorkerErrorRequest) Unmarshal(dAtA []byte) error
func (*HandleWorkerErrorRequest) XXX_DiscardUnknown ¶
func (m *HandleWorkerErrorRequest) XXX_DiscardUnknown()
func (*HandleWorkerErrorRequest) XXX_Marshal ¶
func (m *HandleWorkerErrorRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*HandleWorkerErrorRequest) XXX_Merge ¶
func (m *HandleWorkerErrorRequest) XXX_Merge(src proto.Message)
func (*HandleWorkerErrorRequest) XXX_Size ¶
func (m *HandleWorkerErrorRequest) XXX_Size() int
func (*HandleWorkerErrorRequest) XXX_Unmarshal ¶
func (m *HandleWorkerErrorRequest) XXX_Unmarshal(b []byte) error
type ListLeaderMember ¶
type ListLeaderMember struct { Msg string `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Addr string `protobuf:"bytes,3,opt,name=addr,proto3" json:"addr,omitempty"` }
func (*ListLeaderMember) Descriptor ¶
func (*ListLeaderMember) Descriptor() ([]byte, []int)
func (*ListLeaderMember) GetAddr ¶
func (m *ListLeaderMember) GetAddr() string
func (*ListLeaderMember) GetMsg ¶
func (m *ListLeaderMember) GetMsg() string
func (*ListLeaderMember) GetName ¶
func (m *ListLeaderMember) GetName() string
func (*ListLeaderMember) Marshal ¶
func (m *ListLeaderMember) Marshal() (dAtA []byte, err error)
func (*ListLeaderMember) MarshalToSizedBuffer ¶
func (m *ListLeaderMember) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ListLeaderMember) ProtoMessage ¶
func (*ListLeaderMember) ProtoMessage()
func (*ListLeaderMember) Reset ¶
func (m *ListLeaderMember) Reset()
func (*ListLeaderMember) Size ¶
func (m *ListLeaderMember) Size() (n int)
func (*ListLeaderMember) String ¶
func (m *ListLeaderMember) String() string
func (*ListLeaderMember) Unmarshal ¶
func (m *ListLeaderMember) Unmarshal(dAtA []byte) error
func (*ListLeaderMember) XXX_DiscardUnknown ¶
func (m *ListLeaderMember) XXX_DiscardUnknown()
func (*ListLeaderMember) XXX_Marshal ¶
func (m *ListLeaderMember) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListLeaderMember) XXX_Merge ¶
func (m *ListLeaderMember) XXX_Merge(src proto.Message)
func (*ListLeaderMember) XXX_Size ¶
func (m *ListLeaderMember) XXX_Size() int
func (*ListLeaderMember) XXX_Unmarshal ¶
func (m *ListLeaderMember) XXX_Unmarshal(b []byte) error
type ListMasterMember ¶
type ListMasterMember struct { Msg string `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"` Masters []*MasterInfo `protobuf:"bytes,2,rep,name=masters,proto3" json:"masters,omitempty"` }
func (*ListMasterMember) Descriptor ¶
func (*ListMasterMember) Descriptor() ([]byte, []int)
func (*ListMasterMember) GetMasters ¶
func (m *ListMasterMember) GetMasters() []*MasterInfo
func (*ListMasterMember) GetMsg ¶
func (m *ListMasterMember) GetMsg() string
func (*ListMasterMember) Marshal ¶
func (m *ListMasterMember) Marshal() (dAtA []byte, err error)
func (*ListMasterMember) MarshalToSizedBuffer ¶
func (m *ListMasterMember) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ListMasterMember) ProtoMessage ¶
func (*ListMasterMember) ProtoMessage()
func (*ListMasterMember) Reset ¶
func (m *ListMasterMember) Reset()
func (*ListMasterMember) Size ¶
func (m *ListMasterMember) Size() (n int)
func (*ListMasterMember) String ¶
func (m *ListMasterMember) String() string
func (*ListMasterMember) Unmarshal ¶
func (m *ListMasterMember) Unmarshal(dAtA []byte) error
func (*ListMasterMember) XXX_DiscardUnknown ¶
func (m *ListMasterMember) XXX_DiscardUnknown()
func (*ListMasterMember) XXX_Marshal ¶
func (m *ListMasterMember) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListMasterMember) XXX_Merge ¶
func (m *ListMasterMember) XXX_Merge(src proto.Message)
func (*ListMasterMember) XXX_Size ¶
func (m *ListMasterMember) XXX_Size() int
func (*ListMasterMember) XXX_Unmarshal ¶
func (m *ListMasterMember) XXX_Unmarshal(b []byte) error
type ListMemberRequest ¶
type ListMemberRequest struct { Leader bool `protobuf:"varint,1,opt,name=leader,proto3" json:"leader,omitempty"` Master bool `protobuf:"varint,2,opt,name=master,proto3" json:"master,omitempty"` Worker bool `protobuf:"varint,3,opt,name=worker,proto3" json:"worker,omitempty"` Names []string `protobuf:"bytes,4,rep,name=names,proto3" json:"names,omitempty"` }
func (*ListMemberRequest) Descriptor ¶
func (*ListMemberRequest) Descriptor() ([]byte, []int)
func (*ListMemberRequest) GetLeader ¶
func (m *ListMemberRequest) GetLeader() bool
func (*ListMemberRequest) GetMaster ¶
func (m *ListMemberRequest) GetMaster() bool
func (*ListMemberRequest) GetNames ¶
func (m *ListMemberRequest) GetNames() []string
func (*ListMemberRequest) GetWorker ¶
func (m *ListMemberRequest) GetWorker() bool
func (*ListMemberRequest) Marshal ¶
func (m *ListMemberRequest) Marshal() (dAtA []byte, err error)
func (*ListMemberRequest) MarshalTo ¶
func (m *ListMemberRequest) MarshalTo(dAtA []byte) (int, error)
func (*ListMemberRequest) MarshalToSizedBuffer ¶
func (m *ListMemberRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ListMemberRequest) ProtoMessage ¶
func (*ListMemberRequest) ProtoMessage()
func (*ListMemberRequest) Reset ¶
func (m *ListMemberRequest) Reset()
func (*ListMemberRequest) Size ¶
func (m *ListMemberRequest) Size() (n int)
func (*ListMemberRequest) String ¶
func (m *ListMemberRequest) String() string
func (*ListMemberRequest) Unmarshal ¶
func (m *ListMemberRequest) Unmarshal(dAtA []byte) error
func (*ListMemberRequest) XXX_DiscardUnknown ¶
func (m *ListMemberRequest) XXX_DiscardUnknown()
func (*ListMemberRequest) XXX_Marshal ¶
func (m *ListMemberRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListMemberRequest) XXX_Merge ¶
func (m *ListMemberRequest) XXX_Merge(src proto.Message)
func (*ListMemberRequest) XXX_Size ¶
func (m *ListMemberRequest) XXX_Size() int
func (*ListMemberRequest) XXX_Unmarshal ¶
func (m *ListMemberRequest) XXX_Unmarshal(b []byte) error
type ListMemberResponse ¶
type ListMemberResponse struct { Result bool `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"` Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"` Members []*Members `protobuf:"bytes,3,rep,name=members,proto3" json:"members,omitempty"` }
func (*ListMemberResponse) Descriptor ¶
func (*ListMemberResponse) Descriptor() ([]byte, []int)
func (*ListMemberResponse) GetMembers ¶
func (m *ListMemberResponse) GetMembers() []*Members
func (*ListMemberResponse) GetMsg ¶
func (m *ListMemberResponse) GetMsg() string
func (*ListMemberResponse) GetResult ¶
func (m *ListMemberResponse) GetResult() bool
func (*ListMemberResponse) Marshal ¶
func (m *ListMemberResponse) Marshal() (dAtA []byte, err error)
func (*ListMemberResponse) MarshalTo ¶
func (m *ListMemberResponse) MarshalTo(dAtA []byte) (int, error)
func (*ListMemberResponse) MarshalToSizedBuffer ¶
func (m *ListMemberResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ListMemberResponse) ProtoMessage ¶
func (*ListMemberResponse) ProtoMessage()
func (*ListMemberResponse) Reset ¶
func (m *ListMemberResponse) Reset()
func (*ListMemberResponse) Size ¶
func (m *ListMemberResponse) Size() (n int)
func (*ListMemberResponse) String ¶
func (m *ListMemberResponse) String() string
func (*ListMemberResponse) Unmarshal ¶
func (m *ListMemberResponse) Unmarshal(dAtA []byte) error
func (*ListMemberResponse) XXX_DiscardUnknown ¶
func (m *ListMemberResponse) XXX_DiscardUnknown()
func (*ListMemberResponse) XXX_Marshal ¶
func (m *ListMemberResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListMemberResponse) XXX_Merge ¶
func (m *ListMemberResponse) XXX_Merge(src proto.Message)
func (*ListMemberResponse) XXX_Size ¶
func (m *ListMemberResponse) XXX_Size() int
func (*ListMemberResponse) XXX_Unmarshal ¶
func (m *ListMemberResponse) XXX_Unmarshal(b []byte) error
type ListWorkerMember ¶
type ListWorkerMember struct { Msg string `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"` Workers []*WorkerInfo `protobuf:"bytes,2,rep,name=workers,proto3" json:"workers,omitempty"` }
func (*ListWorkerMember) Descriptor ¶
func (*ListWorkerMember) Descriptor() ([]byte, []int)
func (*ListWorkerMember) GetMsg ¶
func (m *ListWorkerMember) GetMsg() string
func (*ListWorkerMember) GetWorkers ¶
func (m *ListWorkerMember) GetWorkers() []*WorkerInfo
func (*ListWorkerMember) Marshal ¶
func (m *ListWorkerMember) Marshal() (dAtA []byte, err error)
func (*ListWorkerMember) MarshalToSizedBuffer ¶
func (m *ListWorkerMember) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ListWorkerMember) ProtoMessage ¶
func (*ListWorkerMember) ProtoMessage()
func (*ListWorkerMember) Reset ¶
func (m *ListWorkerMember) Reset()
func (*ListWorkerMember) Size ¶
func (m *ListWorkerMember) Size() (n int)
func (*ListWorkerMember) String ¶
func (m *ListWorkerMember) String() string
func (*ListWorkerMember) Unmarshal ¶
func (m *ListWorkerMember) Unmarshal(dAtA []byte) error
func (*ListWorkerMember) XXX_DiscardUnknown ¶
func (m *ListWorkerMember) XXX_DiscardUnknown()
func (*ListWorkerMember) XXX_Marshal ¶
func (m *ListWorkerMember) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListWorkerMember) XXX_Merge ¶
func (m *ListWorkerMember) XXX_Merge(src proto.Message)
func (*ListWorkerMember) XXX_Size ¶
func (m *ListWorkerMember) XXX_Size() int
func (*ListWorkerMember) XXX_Unmarshal ¶
func (m *ListWorkerMember) XXX_Unmarshal(b []byte) error
type LoadError ¶
type LoadError struct {
Msg string `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
}
LoadError represents error for load unit
func (*LoadError) Descriptor ¶
func (*LoadError) MarshalToSizedBuffer ¶
func (*LoadError) ProtoMessage ¶
func (*LoadError) ProtoMessage()
func (*LoadError) XXX_DiscardUnknown ¶
func (m *LoadError) XXX_DiscardUnknown()
func (*LoadError) XXX_Marshal ¶
func (*LoadError) XXX_Unmarshal ¶
type LoadStatus ¶
type LoadStatus struct { FinishedBytes int64 `protobuf:"varint,1,opt,name=finishedBytes,proto3" json:"finishedBytes,omitempty"` TotalBytes int64 `protobuf:"varint,2,opt,name=totalBytes,proto3" json:"totalBytes,omitempty"` Progress string `protobuf:"bytes,3,opt,name=progress,proto3" json:"progress,omitempty"` MetaBinlog string `protobuf:"bytes,4,opt,name=metaBinlog,proto3" json:"metaBinlog,omitempty"` MetaBinlogGTID string `protobuf:"bytes,5,opt,name=metaBinlogGTID,proto3" json:"metaBinlogGTID,omitempty"` }
LoadStatus represents status for load unit
func (*LoadStatus) Descriptor ¶
func (*LoadStatus) Descriptor() ([]byte, []int)
func (*LoadStatus) GetFinishedBytes ¶
func (m *LoadStatus) GetFinishedBytes() int64
func (*LoadStatus) GetMetaBinlog ¶
func (m *LoadStatus) GetMetaBinlog() string
func (*LoadStatus) GetMetaBinlogGTID ¶
func (m *LoadStatus) GetMetaBinlogGTID() string
func (*LoadStatus) GetProgress ¶
func (m *LoadStatus) GetProgress() string
func (*LoadStatus) GetTotalBytes ¶
func (m *LoadStatus) GetTotalBytes() int64
func (*LoadStatus) Marshal ¶
func (m *LoadStatus) Marshal() (dAtA []byte, err error)
func (*LoadStatus) MarshalToSizedBuffer ¶
func (m *LoadStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*LoadStatus) ProtoMessage ¶
func (*LoadStatus) ProtoMessage()
func (*LoadStatus) Reset ¶
func (m *LoadStatus) Reset()
func (*LoadStatus) Size ¶
func (m *LoadStatus) Size() (n int)
func (*LoadStatus) String ¶
func (m *LoadStatus) String() string
func (*LoadStatus) Unmarshal ¶
func (m *LoadStatus) Unmarshal(dAtA []byte) error
func (*LoadStatus) XXX_DiscardUnknown ¶
func (m *LoadStatus) XXX_DiscardUnknown()
func (*LoadStatus) XXX_Marshal ¶
func (m *LoadStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LoadStatus) XXX_Merge ¶
func (m *LoadStatus) XXX_Merge(src proto.Message)
func (*LoadStatus) XXX_Size ¶
func (m *LoadStatus) XXX_Size() int
func (*LoadStatus) XXX_Unmarshal ¶
func (m *LoadStatus) XXX_Unmarshal(b []byte) error
type MasterClient ¶
type MasterClient interface { StartTask(ctx context.Context, in *StartTaskRequest, opts ...grpc.CallOption) (*StartTaskResponse, error) OperateTask(ctx context.Context, in *OperateTaskRequest, opts ...grpc.CallOption) (*OperateTaskResponse, error) UpdateTask(ctx context.Context, in *UpdateTaskRequest, opts ...grpc.CallOption) (*UpdateTaskResponse, error) QueryStatus(ctx context.Context, in *QueryStatusListRequest, opts ...grpc.CallOption) (*QueryStatusListResponse, error) // show un-resolved DDL locks ShowDDLLocks(ctx context.Context, in *ShowDDLLocksRequest, opts ...grpc.CallOption) (*ShowDDLLocksResponse, error) // used by dmctl to manually unlock DDL lock UnlockDDLLock(ctx context.Context, in *UnlockDDLLockRequest, opts ...grpc.CallOption) (*UnlockDDLLockResponse, error) // OperateWorkerRelayTask requests some dm-workers to operate relay unit OperateWorkerRelayTask(ctx context.Context, in *OperateWorkerRelayRequest, opts ...grpc.CallOption) (*OperateWorkerRelayResponse, error) // PurgeWorkerRelay purges relay log files for some dm-workers PurgeWorkerRelay(ctx context.Context, in *PurgeWorkerRelayRequest, opts ...grpc.CallOption) (*PurgeWorkerRelayResponse, error) // CheckTask checks legality of task configuration CheckTask(ctx context.Context, in *CheckTaskRequest, opts ...grpc.CallOption) (*CheckTaskResponse, error) // Operate an upstream MySQL source. OperateSource(ctx context.Context, in *OperateSourceRequest, opts ...grpc.CallOption) (*OperateSourceResponse, error) // RegisterWorker register the dm-workers. RegisterWorker(ctx context.Context, in *RegisterWorkerRequest, opts ...grpc.CallOption) (*RegisterWorkerResponse, error) // OfflineMember offline the dm cluster's members (master/worker). OfflineMember(ctx context.Context, in *OfflineMemberRequest, opts ...grpc.CallOption) (*OfflineMemberResponse, error) // OperateLeader do some operate on master: // - evict leader: make the master resign if it is leader, and will not campaign the leader again // - cancel evict leader: the master can campaign leader again. OperateLeader(ctx context.Context, in *OperateLeaderRequest, opts ...grpc.CallOption) (*OperateLeaderResponse, error) // ListMember list member information ListMember(ctx context.Context, in *ListMemberRequest, opts ...grpc.CallOption) (*ListMemberResponse, error) OperateSchema(ctx context.Context, in *OperateSchemaRequest, opts ...grpc.CallOption) (*OperateSchemaResponse, error) GetSubTaskCfg(ctx context.Context, in *GetSubTaskCfgRequest, opts ...grpc.CallOption) (*GetSubTaskCfgResponse, error) // GetCfg get config GetCfg(ctx context.Context, in *GetCfgRequest, opts ...grpc.CallOption) (*GetCfgResponse, error) HandleError(ctx context.Context, in *HandleErrorRequest, opts ...grpc.CallOption) (*HandleErrorResponse, error) GetMasterCfg(ctx context.Context, in *GetMasterCfgRequest, opts ...grpc.CallOption) (*GetMasterCfgResponse, error) TransferSource(ctx context.Context, in *TransferSourceRequest, opts ...grpc.CallOption) (*TransferSourceResponse, error) OperateRelay(ctx context.Context, in *OperateRelayRequest, opts ...grpc.CallOption) (*OperateRelayResponse, error) }
MasterClient is the client API for Master service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewMasterClient ¶
func NewMasterClient(cc *grpc.ClientConn) MasterClient
type MasterInfo ¶
type MasterInfo struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` MemberID uint64 `protobuf:"varint,2,opt,name=memberID,proto3" json:"memberID,omitempty"` Alive bool `protobuf:"varint,3,opt,name=alive,proto3" json:"alive,omitempty"` PeerURLs []string `protobuf:"bytes,4,rep,name=peerURLs,proto3" json:"peerURLs,omitempty"` ClientURLs []string `protobuf:"bytes,5,rep,name=clientURLs,proto3" json:"clientURLs,omitempty"` }
func (*MasterInfo) Descriptor ¶
func (*MasterInfo) Descriptor() ([]byte, []int)
func (*MasterInfo) GetAlive ¶
func (m *MasterInfo) GetAlive() bool
func (*MasterInfo) GetClientURLs ¶
func (m *MasterInfo) GetClientURLs() []string
func (*MasterInfo) GetMemberID ¶
func (m *MasterInfo) GetMemberID() uint64
func (*MasterInfo) GetName ¶
func (m *MasterInfo) GetName() string
func (*MasterInfo) GetPeerURLs ¶
func (m *MasterInfo) GetPeerURLs() []string
func (*MasterInfo) Marshal ¶
func (m *MasterInfo) Marshal() (dAtA []byte, err error)
func (*MasterInfo) MarshalToSizedBuffer ¶
func (m *MasterInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MasterInfo) ProtoMessage ¶
func (*MasterInfo) ProtoMessage()
func (*MasterInfo) Reset ¶
func (m *MasterInfo) Reset()
func (*MasterInfo) Size ¶
func (m *MasterInfo) Size() (n int)
func (*MasterInfo) String ¶
func (m *MasterInfo) String() string
func (*MasterInfo) Unmarshal ¶
func (m *MasterInfo) Unmarshal(dAtA []byte) error
func (*MasterInfo) XXX_DiscardUnknown ¶
func (m *MasterInfo) XXX_DiscardUnknown()
func (*MasterInfo) XXX_Marshal ¶
func (m *MasterInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MasterInfo) XXX_Merge ¶
func (m *MasterInfo) XXX_Merge(src proto.Message)
func (*MasterInfo) XXX_Size ¶
func (m *MasterInfo) XXX_Size() int
func (*MasterInfo) XXX_Unmarshal ¶
func (m *MasterInfo) XXX_Unmarshal(b []byte) error
type MasterServer ¶
type MasterServer interface { StartTask(context.Context, *StartTaskRequest) (*StartTaskResponse, error) OperateTask(context.Context, *OperateTaskRequest) (*OperateTaskResponse, error) UpdateTask(context.Context, *UpdateTaskRequest) (*UpdateTaskResponse, error) QueryStatus(context.Context, *QueryStatusListRequest) (*QueryStatusListResponse, error) // show un-resolved DDL locks ShowDDLLocks(context.Context, *ShowDDLLocksRequest) (*ShowDDLLocksResponse, error) // used by dmctl to manually unlock DDL lock UnlockDDLLock(context.Context, *UnlockDDLLockRequest) (*UnlockDDLLockResponse, error) // OperateWorkerRelayTask requests some dm-workers to operate relay unit OperateWorkerRelayTask(context.Context, *OperateWorkerRelayRequest) (*OperateWorkerRelayResponse, error) // PurgeWorkerRelay purges relay log files for some dm-workers PurgeWorkerRelay(context.Context, *PurgeWorkerRelayRequest) (*PurgeWorkerRelayResponse, error) // CheckTask checks legality of task configuration CheckTask(context.Context, *CheckTaskRequest) (*CheckTaskResponse, error) // Operate an upstream MySQL source. OperateSource(context.Context, *OperateSourceRequest) (*OperateSourceResponse, error) // RegisterWorker register the dm-workers. RegisterWorker(context.Context, *RegisterWorkerRequest) (*RegisterWorkerResponse, error) // OfflineMember offline the dm cluster's members (master/worker). OfflineMember(context.Context, *OfflineMemberRequest) (*OfflineMemberResponse, error) // OperateLeader do some operate on master: // - evict leader: make the master resign if it is leader, and will not campaign the leader again // - cancel evict leader: the master can campaign leader again. OperateLeader(context.Context, *OperateLeaderRequest) (*OperateLeaderResponse, error) // ListMember list member information ListMember(context.Context, *ListMemberRequest) (*ListMemberResponse, error) OperateSchema(context.Context, *OperateSchemaRequest) (*OperateSchemaResponse, error) GetSubTaskCfg(context.Context, *GetSubTaskCfgRequest) (*GetSubTaskCfgResponse, error) // GetCfg get config GetCfg(context.Context, *GetCfgRequest) (*GetCfgResponse, error) HandleError(context.Context, *HandleErrorRequest) (*HandleErrorResponse, error) GetMasterCfg(context.Context, *GetMasterCfgRequest) (*GetMasterCfgResponse, error) TransferSource(context.Context, *TransferSourceRequest) (*TransferSourceResponse, error) OperateRelay(context.Context, *OperateRelayRequest) (*OperateRelayResponse, error) }
MasterServer is the server API for Master service.
type Members ¶
type Members struct { // Types that are valid to be assigned to Member: // *Members_Leader // *Members_Master // *Members_Worker Member isMembers_Member `protobuf_oneof:"member"` }
func (*Members) Descriptor ¶
func (*Members) GetLeader ¶
func (m *Members) GetLeader() *ListLeaderMember
func (*Members) GetMaster ¶
func (m *Members) GetMaster() *ListMasterMember
func (*Members) GetWorker ¶
func (m *Members) GetWorker() *ListWorkerMember
func (*Members) MarshalToSizedBuffer ¶
func (*Members) ProtoMessage ¶
func (*Members) ProtoMessage()
func (*Members) XXX_DiscardUnknown ¶
func (m *Members) XXX_DiscardUnknown()
func (*Members) XXX_Marshal ¶
func (*Members) XXX_OneofWrappers ¶
func (*Members) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*Members) XXX_Unmarshal ¶
type Members_Leader ¶
type Members_Leader struct {
Leader *ListLeaderMember `protobuf:"bytes,1,opt,name=leader,proto3,oneof" json:"leader,omitempty"`
}
func (*Members_Leader) MarshalToSizedBuffer ¶
func (m *Members_Leader) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Members_Leader) Size ¶
func (m *Members_Leader) Size() (n int)
type Members_Master ¶
type Members_Master struct {
Master *ListMasterMember `protobuf:"bytes,2,opt,name=master,proto3,oneof" json:"master,omitempty"`
}
func (*Members_Master) MarshalToSizedBuffer ¶
func (m *Members_Master) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Members_Master) Size ¶
func (m *Members_Master) Size() (n int)
type Members_Worker ¶
type Members_Worker struct {
Worker *ListWorkerMember `protobuf:"bytes,3,opt,name=worker,proto3,oneof" json:"worker,omitempty"`
}
func (*Members_Worker) MarshalToSizedBuffer ¶
func (m *Members_Worker) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Members_Worker) Size ¶
func (m *Members_Worker) Size() (n int)
type OfflineMemberRequest ¶
type OfflineMemberRequest struct { Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` }
func (*OfflineMemberRequest) Descriptor ¶
func (*OfflineMemberRequest) Descriptor() ([]byte, []int)
func (*OfflineMemberRequest) GetName ¶
func (m *OfflineMemberRequest) GetName() string
func (*OfflineMemberRequest) GetType ¶
func (m *OfflineMemberRequest) GetType() string
func (*OfflineMemberRequest) Marshal ¶
func (m *OfflineMemberRequest) Marshal() (dAtA []byte, err error)
func (*OfflineMemberRequest) MarshalTo ¶
func (m *OfflineMemberRequest) MarshalTo(dAtA []byte) (int, error)
func (*OfflineMemberRequest) MarshalToSizedBuffer ¶
func (m *OfflineMemberRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*OfflineMemberRequest) ProtoMessage ¶
func (*OfflineMemberRequest) ProtoMessage()
func (*OfflineMemberRequest) Reset ¶
func (m *OfflineMemberRequest) Reset()
func (*OfflineMemberRequest) Size ¶
func (m *OfflineMemberRequest) Size() (n int)
func (*OfflineMemberRequest) String ¶
func (m *OfflineMemberRequest) String() string
func (*OfflineMemberRequest) Unmarshal ¶
func (m *OfflineMemberRequest) Unmarshal(dAtA []byte) error
func (*OfflineMemberRequest) XXX_DiscardUnknown ¶
func (m *OfflineMemberRequest) XXX_DiscardUnknown()
func (*OfflineMemberRequest) XXX_Marshal ¶
func (m *OfflineMemberRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*OfflineMemberRequest) XXX_Merge ¶
func (m *OfflineMemberRequest) XXX_Merge(src proto.Message)
func (*OfflineMemberRequest) XXX_Size ¶
func (m *OfflineMemberRequest) XXX_Size() int
func (*OfflineMemberRequest) XXX_Unmarshal ¶
func (m *OfflineMemberRequest) XXX_Unmarshal(b []byte) error
type OfflineMemberResponse ¶
type OfflineMemberResponse struct { Result bool `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"` Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"` }
func (*OfflineMemberResponse) Descriptor ¶
func (*OfflineMemberResponse) Descriptor() ([]byte, []int)
func (*OfflineMemberResponse) GetMsg ¶
func (m *OfflineMemberResponse) GetMsg() string
func (*OfflineMemberResponse) GetResult ¶
func (m *OfflineMemberResponse) GetResult() bool
func (*OfflineMemberResponse) Marshal ¶
func (m *OfflineMemberResponse) Marshal() (dAtA []byte, err error)
func (*OfflineMemberResponse) MarshalTo ¶
func (m *OfflineMemberResponse) MarshalTo(dAtA []byte) (int, error)
func (*OfflineMemberResponse) MarshalToSizedBuffer ¶
func (m *OfflineMemberResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*OfflineMemberResponse) ProtoMessage ¶
func (*OfflineMemberResponse) ProtoMessage()
func (*OfflineMemberResponse) Reset ¶
func (m *OfflineMemberResponse) Reset()
func (*OfflineMemberResponse) Size ¶
func (m *OfflineMemberResponse) Size() (n int)
func (*OfflineMemberResponse) String ¶
func (m *OfflineMemberResponse) String() string
func (*OfflineMemberResponse) Unmarshal ¶
func (m *OfflineMemberResponse) Unmarshal(dAtA []byte) error
func (*OfflineMemberResponse) XXX_DiscardUnknown ¶
func (m *OfflineMemberResponse) XXX_DiscardUnknown()
func (*OfflineMemberResponse) XXX_Marshal ¶
func (m *OfflineMemberResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*OfflineMemberResponse) XXX_Merge ¶
func (m *OfflineMemberResponse) XXX_Merge(src proto.Message)
func (*OfflineMemberResponse) XXX_Size ¶
func (m *OfflineMemberResponse) XXX_Size() int
func (*OfflineMemberResponse) XXX_Unmarshal ¶
func (m *OfflineMemberResponse) XXX_Unmarshal(b []byte) error
type OperateLeaderRequest ¶
type OperateLeaderRequest struct {
Op LeaderOp `protobuf:"varint,1,opt,name=op,proto3,enum=pb.LeaderOp" json:"op,omitempty"`
}
func (*OperateLeaderRequest) Descriptor ¶
func (*OperateLeaderRequest) Descriptor() ([]byte, []int)
func (*OperateLeaderRequest) GetOp ¶
func (m *OperateLeaderRequest) GetOp() LeaderOp
func (*OperateLeaderRequest) Marshal ¶
func (m *OperateLeaderRequest) Marshal() (dAtA []byte, err error)
func (*OperateLeaderRequest) MarshalTo ¶
func (m *OperateLeaderRequest) MarshalTo(dAtA []byte) (int, error)
func (*OperateLeaderRequest) MarshalToSizedBuffer ¶
func (m *OperateLeaderRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*OperateLeaderRequest) ProtoMessage ¶
func (*OperateLeaderRequest) ProtoMessage()
func (*OperateLeaderRequest) Reset ¶
func (m *OperateLeaderRequest) Reset()
func (*OperateLeaderRequest) Size ¶
func (m *OperateLeaderRequest) Size() (n int)
func (*OperateLeaderRequest) String ¶
func (m *OperateLeaderRequest) String() string
func (*OperateLeaderRequest) Unmarshal ¶
func (m *OperateLeaderRequest) Unmarshal(dAtA []byte) error
func (*OperateLeaderRequest) XXX_DiscardUnknown ¶
func (m *OperateLeaderRequest) XXX_DiscardUnknown()
func (*OperateLeaderRequest) XXX_Marshal ¶
func (m *OperateLeaderRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*OperateLeaderRequest) XXX_Merge ¶
func (m *OperateLeaderRequest) XXX_Merge(src proto.Message)
func (*OperateLeaderRequest) XXX_Size ¶
func (m *OperateLeaderRequest) XXX_Size() int
func (*OperateLeaderRequest) XXX_Unmarshal ¶
func (m *OperateLeaderRequest) XXX_Unmarshal(b []byte) error
type OperateLeaderResponse ¶
type OperateLeaderResponse struct { Result bool `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"` Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"` }
func (*OperateLeaderResponse) Descriptor ¶
func (*OperateLeaderResponse) Descriptor() ([]byte, []int)
func (*OperateLeaderResponse) GetMsg ¶
func (m *OperateLeaderResponse) GetMsg() string
func (*OperateLeaderResponse) GetResult ¶
func (m *OperateLeaderResponse) GetResult() bool
func (*OperateLeaderResponse) Marshal ¶
func (m *OperateLeaderResponse) Marshal() (dAtA []byte, err error)
func (*OperateLeaderResponse) MarshalTo ¶
func (m *OperateLeaderResponse) MarshalTo(dAtA []byte) (int, error)
func (*OperateLeaderResponse) MarshalToSizedBuffer ¶
func (m *OperateLeaderResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*OperateLeaderResponse) ProtoMessage ¶
func (*OperateLeaderResponse) ProtoMessage()
func (*OperateLeaderResponse) Reset ¶
func (m *OperateLeaderResponse) Reset()
func (*OperateLeaderResponse) Size ¶
func (m *OperateLeaderResponse) Size() (n int)
func (*OperateLeaderResponse) String ¶
func (m *OperateLeaderResponse) String() string
func (*OperateLeaderResponse) Unmarshal ¶
func (m *OperateLeaderResponse) Unmarshal(dAtA []byte) error
func (*OperateLeaderResponse) XXX_DiscardUnknown ¶
func (m *OperateLeaderResponse) XXX_DiscardUnknown()
func (*OperateLeaderResponse) XXX_Marshal ¶
func (m *OperateLeaderResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*OperateLeaderResponse) XXX_Merge ¶
func (m *OperateLeaderResponse) XXX_Merge(src proto.Message)
func (*OperateLeaderResponse) XXX_Size ¶
func (m *OperateLeaderResponse) XXX_Size() int
func (*OperateLeaderResponse) XXX_Unmarshal ¶
func (m *OperateLeaderResponse) XXX_Unmarshal(b []byte) error
type OperateRelayRequest ¶ added in v1.9.0
type OperateRelayRequest struct { Op RelayOpV2 `protobuf:"varint,1,opt,name=op,proto3,enum=pb.RelayOpV2" json:"op,omitempty"` Source string `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"` Worker []string `protobuf:"bytes,3,rep,name=worker,proto3" json:"worker,omitempty"` }
func (*OperateRelayRequest) Descriptor ¶ added in v1.9.0
func (*OperateRelayRequest) Descriptor() ([]byte, []int)
func (*OperateRelayRequest) GetOp ¶ added in v1.9.0
func (m *OperateRelayRequest) GetOp() RelayOpV2
func (*OperateRelayRequest) GetSource ¶ added in v1.9.0
func (m *OperateRelayRequest) GetSource() string
func (*OperateRelayRequest) GetWorker ¶ added in v1.9.0
func (m *OperateRelayRequest) GetWorker() []string
func (*OperateRelayRequest) Marshal ¶ added in v1.9.0
func (m *OperateRelayRequest) Marshal() (dAtA []byte, err error)
func (*OperateRelayRequest) MarshalTo ¶ added in v1.9.0
func (m *OperateRelayRequest) MarshalTo(dAtA []byte) (int, error)
func (*OperateRelayRequest) MarshalToSizedBuffer ¶ added in v1.9.0
func (m *OperateRelayRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*OperateRelayRequest) ProtoMessage ¶ added in v1.9.0
func (*OperateRelayRequest) ProtoMessage()
func (*OperateRelayRequest) Reset ¶ added in v1.9.0
func (m *OperateRelayRequest) Reset()
func (*OperateRelayRequest) Size ¶ added in v1.9.0
func (m *OperateRelayRequest) Size() (n int)
func (*OperateRelayRequest) String ¶ added in v1.9.0
func (m *OperateRelayRequest) String() string
func (*OperateRelayRequest) Unmarshal ¶ added in v1.9.0
func (m *OperateRelayRequest) Unmarshal(dAtA []byte) error
func (*OperateRelayRequest) XXX_DiscardUnknown ¶ added in v1.9.0
func (m *OperateRelayRequest) XXX_DiscardUnknown()
func (*OperateRelayRequest) XXX_Marshal ¶ added in v1.9.0
func (m *OperateRelayRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*OperateRelayRequest) XXX_Merge ¶ added in v1.9.0
func (m *OperateRelayRequest) XXX_Merge(src proto.Message)
func (*OperateRelayRequest) XXX_Size ¶ added in v1.9.0
func (m *OperateRelayRequest) XXX_Size() int
func (*OperateRelayRequest) XXX_Unmarshal ¶ added in v1.9.0
func (m *OperateRelayRequest) XXX_Unmarshal(b []byte) error
type OperateRelayResponse ¶ added in v1.9.0
type OperateRelayResponse struct { Result bool `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"` Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"` Sources []*CommonWorkerResponse `protobuf:"bytes,3,rep,name=sources,proto3" json:"sources,omitempty"` }
func (*OperateRelayResponse) Descriptor ¶ added in v1.9.0
func (*OperateRelayResponse) Descriptor() ([]byte, []int)
func (*OperateRelayResponse) GetMsg ¶ added in v1.9.0
func (m *OperateRelayResponse) GetMsg() string
func (*OperateRelayResponse) GetResult ¶ added in v1.9.0
func (m *OperateRelayResponse) GetResult() bool
func (*OperateRelayResponse) GetSources ¶ added in v1.9.0
func (m *OperateRelayResponse) GetSources() []*CommonWorkerResponse
func (*OperateRelayResponse) Marshal ¶ added in v1.9.0
func (m *OperateRelayResponse) Marshal() (dAtA []byte, err error)
func (*OperateRelayResponse) MarshalTo ¶ added in v1.9.0
func (m *OperateRelayResponse) MarshalTo(dAtA []byte) (int, error)
func (*OperateRelayResponse) MarshalToSizedBuffer ¶ added in v1.9.0
func (m *OperateRelayResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*OperateRelayResponse) ProtoMessage ¶ added in v1.9.0
func (*OperateRelayResponse) ProtoMessage()
func (*OperateRelayResponse) Reset ¶ added in v1.9.0
func (m *OperateRelayResponse) Reset()
func (*OperateRelayResponse) Size ¶ added in v1.9.0
func (m *OperateRelayResponse) Size() (n int)
func (*OperateRelayResponse) String ¶ added in v1.9.0
func (m *OperateRelayResponse) String() string
func (*OperateRelayResponse) Unmarshal ¶ added in v1.9.0
func (m *OperateRelayResponse) Unmarshal(dAtA []byte) error
func (*OperateRelayResponse) XXX_DiscardUnknown ¶ added in v1.9.0
func (m *OperateRelayResponse) XXX_DiscardUnknown()
func (*OperateRelayResponse) XXX_Marshal ¶ added in v1.9.0
func (m *OperateRelayResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*OperateRelayResponse) XXX_Merge ¶ added in v1.9.0
func (m *OperateRelayResponse) XXX_Merge(src proto.Message)
func (*OperateRelayResponse) XXX_Size ¶ added in v1.9.0
func (m *OperateRelayResponse) XXX_Size() int
func (*OperateRelayResponse) XXX_Unmarshal ¶ added in v1.9.0
func (m *OperateRelayResponse) XXX_Unmarshal(b []byte) error
type OperateSchemaRequest ¶
type OperateSchemaRequest struct { Op SchemaOp `protobuf:"varint,1,opt,name=op,proto3,enum=pb.SchemaOp" json:"op,omitempty"` Task string `protobuf:"bytes,2,opt,name=task,proto3" json:"task,omitempty"` Sources []string `protobuf:"bytes,3,rep,name=sources,proto3" json:"sources,omitempty"` Database string `protobuf:"bytes,4,opt,name=database,proto3" json:"database,omitempty"` Table string `protobuf:"bytes,5,opt,name=table,proto3" json:"table,omitempty"` Schema string `protobuf:"bytes,6,opt,name=schema,proto3" json:"schema,omitempty"` Flush bool `protobuf:"varint,7,opt,name=flush,proto3" json:"flush,omitempty"` Sync bool `protobuf:"varint,8,opt,name=sync,proto3" json:"sync,omitempty"` FromSource bool `protobuf:"varint,9,opt,name=fromSource,proto3" json:"fromSource,omitempty"` FromTarget bool `protobuf:"varint,10,opt,name=fromTarget,proto3" json:"fromTarget,omitempty"` }
func (*OperateSchemaRequest) Descriptor ¶
func (*OperateSchemaRequest) Descriptor() ([]byte, []int)
func (*OperateSchemaRequest) GetDatabase ¶
func (m *OperateSchemaRequest) GetDatabase() string
func (*OperateSchemaRequest) GetFlush ¶ added in v1.9.0
func (m *OperateSchemaRequest) GetFlush() bool
func (*OperateSchemaRequest) GetFromSource ¶ added in v1.9.0
func (m *OperateSchemaRequest) GetFromSource() bool
func (*OperateSchemaRequest) GetFromTarget ¶ added in v1.9.0
func (m *OperateSchemaRequest) GetFromTarget() bool
func (*OperateSchemaRequest) GetOp ¶
func (m *OperateSchemaRequest) GetOp() SchemaOp
func (*OperateSchemaRequest) GetSchema ¶
func (m *OperateSchemaRequest) GetSchema() string
func (*OperateSchemaRequest) GetSources ¶
func (m *OperateSchemaRequest) GetSources() []string
func (*OperateSchemaRequest) GetSync ¶ added in v1.9.0
func (m *OperateSchemaRequest) GetSync() bool
func (*OperateSchemaRequest) GetTable ¶
func (m *OperateSchemaRequest) GetTable() string
func (*OperateSchemaRequest) GetTask ¶
func (m *OperateSchemaRequest) GetTask() string
func (*OperateSchemaRequest) Marshal ¶
func (m *OperateSchemaRequest) Marshal() (dAtA []byte, err error)
func (*OperateSchemaRequest) MarshalTo ¶
func (m *OperateSchemaRequest) MarshalTo(dAtA []byte) (int, error)
func (*OperateSchemaRequest) MarshalToSizedBuffer ¶
func (m *OperateSchemaRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*OperateSchemaRequest) ProtoMessage ¶
func (*OperateSchemaRequest) ProtoMessage()
func (*OperateSchemaRequest) Reset ¶
func (m *OperateSchemaRequest) Reset()
func (*OperateSchemaRequest) Size ¶
func (m *OperateSchemaRequest) Size() (n int)
func (*OperateSchemaRequest) String ¶
func (m *OperateSchemaRequest) String() string
func (*OperateSchemaRequest) Unmarshal ¶
func (m *OperateSchemaRequest) Unmarshal(dAtA []byte) error
func (*OperateSchemaRequest) XXX_DiscardUnknown ¶
func (m *OperateSchemaRequest) XXX_DiscardUnknown()
func (*OperateSchemaRequest) XXX_Marshal ¶
func (m *OperateSchemaRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*OperateSchemaRequest) XXX_Merge ¶
func (m *OperateSchemaRequest) XXX_Merge(src proto.Message)
func (*OperateSchemaRequest) XXX_Size ¶
func (m *OperateSchemaRequest) XXX_Size() int
func (*OperateSchemaRequest) XXX_Unmarshal ¶
func (m *OperateSchemaRequest) XXX_Unmarshal(b []byte) error
type OperateSchemaResponse ¶
type OperateSchemaResponse struct { Result bool `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"` Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"` Sources []*CommonWorkerResponse `protobuf:"bytes,3,rep,name=sources,proto3" json:"sources,omitempty"` }
func (*OperateSchemaResponse) Descriptor ¶
func (*OperateSchemaResponse) Descriptor() ([]byte, []int)
func (*OperateSchemaResponse) GetMsg ¶
func (m *OperateSchemaResponse) GetMsg() string
func (*OperateSchemaResponse) GetResult ¶
func (m *OperateSchemaResponse) GetResult() bool
func (*OperateSchemaResponse) GetSources ¶
func (m *OperateSchemaResponse) GetSources() []*CommonWorkerResponse
func (*OperateSchemaResponse) Marshal ¶
func (m *OperateSchemaResponse) Marshal() (dAtA []byte, err error)
func (*OperateSchemaResponse) MarshalTo ¶
func (m *OperateSchemaResponse) MarshalTo(dAtA []byte) (int, error)
func (*OperateSchemaResponse) MarshalToSizedBuffer ¶
func (m *OperateSchemaResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*OperateSchemaResponse) ProtoMessage ¶
func (*OperateSchemaResponse) ProtoMessage()
func (*OperateSchemaResponse) Reset ¶
func (m *OperateSchemaResponse) Reset()
func (*OperateSchemaResponse) Size ¶
func (m *OperateSchemaResponse) Size() (n int)
func (*OperateSchemaResponse) String ¶
func (m *OperateSchemaResponse) String() string
func (*OperateSchemaResponse) Unmarshal ¶
func (m *OperateSchemaResponse) Unmarshal(dAtA []byte) error
func (*OperateSchemaResponse) XXX_DiscardUnknown ¶
func (m *OperateSchemaResponse) XXX_DiscardUnknown()
func (*OperateSchemaResponse) XXX_Marshal ¶
func (m *OperateSchemaResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*OperateSchemaResponse) XXX_Merge ¶
func (m *OperateSchemaResponse) XXX_Merge(src proto.Message)
func (*OperateSchemaResponse) XXX_Size ¶
func (m *OperateSchemaResponse) XXX_Size() int
func (*OperateSchemaResponse) XXX_Unmarshal ¶
func (m *OperateSchemaResponse) XXX_Unmarshal(b []byte) error
type OperateSourceRequest ¶
type OperateSourceRequest struct { Op SourceOp `protobuf:"varint,1,opt,name=op,proto3,enum=pb.SourceOp" json:"op,omitempty"` Config []string `protobuf:"bytes,2,rep,name=config,proto3" json:"config,omitempty"` SourceID []string `protobuf:"bytes,3,rep,name=sourceID,proto3" json:"sourceID,omitempty"` WorkerName string `protobuf:"bytes,4,opt,name=workerName,proto3" json:"workerName,omitempty"` }
func (*OperateSourceRequest) Descriptor ¶
func (*OperateSourceRequest) Descriptor() ([]byte, []int)
func (*OperateSourceRequest) GetConfig ¶
func (m *OperateSourceRequest) GetConfig() []string
func (*OperateSourceRequest) GetOp ¶
func (m *OperateSourceRequest) GetOp() SourceOp
func (*OperateSourceRequest) GetSourceID ¶
func (m *OperateSourceRequest) GetSourceID() []string
func (*OperateSourceRequest) GetWorkerName ¶ added in v1.9.0
func (m *OperateSourceRequest) GetWorkerName() string
func (*OperateSourceRequest) Marshal ¶
func (m *OperateSourceRequest) Marshal() (dAtA []byte, err error)
func (*OperateSourceRequest) MarshalTo ¶
func (m *OperateSourceRequest) MarshalTo(dAtA []byte) (int, error)
func (*OperateSourceRequest) MarshalToSizedBuffer ¶
func (m *OperateSourceRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*OperateSourceRequest) ProtoMessage ¶
func (*OperateSourceRequest) ProtoMessage()
func (*OperateSourceRequest) Reset ¶
func (m *OperateSourceRequest) Reset()
func (*OperateSourceRequest) Size ¶
func (m *OperateSourceRequest) Size() (n int)
func (*OperateSourceRequest) String ¶
func (m *OperateSourceRequest) String() string
func (*OperateSourceRequest) Unmarshal ¶
func (m *OperateSourceRequest) Unmarshal(dAtA []byte) error
func (*OperateSourceRequest) XXX_DiscardUnknown ¶
func (m *OperateSourceRequest) XXX_DiscardUnknown()
func (*OperateSourceRequest) XXX_Marshal ¶
func (m *OperateSourceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*OperateSourceRequest) XXX_Merge ¶
func (m *OperateSourceRequest) XXX_Merge(src proto.Message)
func (*OperateSourceRequest) XXX_Size ¶
func (m *OperateSourceRequest) XXX_Size() int
func (*OperateSourceRequest) XXX_Unmarshal ¶
func (m *OperateSourceRequest) XXX_Unmarshal(b []byte) error
type OperateSourceResponse ¶
type OperateSourceResponse struct { Result bool `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"` Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"` Sources []*CommonWorkerResponse `protobuf:"bytes,3,rep,name=sources,proto3" json:"sources,omitempty"` }
func (*OperateSourceResponse) Descriptor ¶
func (*OperateSourceResponse) Descriptor() ([]byte, []int)
func (*OperateSourceResponse) GetMsg ¶
func (m *OperateSourceResponse) GetMsg() string
func (*OperateSourceResponse) GetResult ¶
func (m *OperateSourceResponse) GetResult() bool
func (*OperateSourceResponse) GetSources ¶
func (m *OperateSourceResponse) GetSources() []*CommonWorkerResponse
func (*OperateSourceResponse) Marshal ¶
func (m *OperateSourceResponse) Marshal() (dAtA []byte, err error)
func (*OperateSourceResponse) MarshalTo ¶
func (m *OperateSourceResponse) MarshalTo(dAtA []byte) (int, error)
func (*OperateSourceResponse) MarshalToSizedBuffer ¶
func (m *OperateSourceResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*OperateSourceResponse) ProtoMessage ¶
func (*OperateSourceResponse) ProtoMessage()
func (*OperateSourceResponse) Reset ¶
func (m *OperateSourceResponse) Reset()
func (*OperateSourceResponse) Size ¶
func (m *OperateSourceResponse) Size() (n int)
func (*OperateSourceResponse) String ¶
func (m *OperateSourceResponse) String() string
func (*OperateSourceResponse) Unmarshal ¶
func (m *OperateSourceResponse) Unmarshal(dAtA []byte) error
func (*OperateSourceResponse) XXX_DiscardUnknown ¶
func (m *OperateSourceResponse) XXX_DiscardUnknown()
func (*OperateSourceResponse) XXX_Marshal ¶
func (m *OperateSourceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*OperateSourceResponse) XXX_Merge ¶
func (m *OperateSourceResponse) XXX_Merge(src proto.Message)
func (*OperateSourceResponse) XXX_Size ¶
func (m *OperateSourceResponse) XXX_Size() int
func (*OperateSourceResponse) XXX_Unmarshal ¶
func (m *OperateSourceResponse) XXX_Unmarshal(b []byte) error
type OperateTaskRequest ¶
type OperateTaskRequest struct { Op TaskOp `protobuf:"varint,1,opt,name=op,proto3,enum=pb.TaskOp" json:"op,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Sources []string `protobuf:"bytes,3,rep,name=sources,proto3" json:"sources,omitempty"` }
func (*OperateTaskRequest) Descriptor ¶
func (*OperateTaskRequest) Descriptor() ([]byte, []int)
func (*OperateTaskRequest) GetName ¶
func (m *OperateTaskRequest) GetName() string
func (*OperateTaskRequest) GetOp ¶
func (m *OperateTaskRequest) GetOp() TaskOp
func (*OperateTaskRequest) GetSources ¶
func (m *OperateTaskRequest) GetSources() []string
func (*OperateTaskRequest) Marshal ¶
func (m *OperateTaskRequest) Marshal() (dAtA []byte, err error)
func (*OperateTaskRequest) MarshalTo ¶
func (m *OperateTaskRequest) MarshalTo(dAtA []byte) (int, error)
func (*OperateTaskRequest) MarshalToSizedBuffer ¶
func (m *OperateTaskRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*OperateTaskRequest) ProtoMessage ¶
func (*OperateTaskRequest) ProtoMessage()
func (*OperateTaskRequest) Reset ¶
func (m *OperateTaskRequest) Reset()
func (*OperateTaskRequest) Size ¶
func (m *OperateTaskRequest) Size() (n int)
func (*OperateTaskRequest) String ¶
func (m *OperateTaskRequest) String() string
func (*OperateTaskRequest) Unmarshal ¶
func (m *OperateTaskRequest) Unmarshal(dAtA []byte) error
func (*OperateTaskRequest) XXX_DiscardUnknown ¶
func (m *OperateTaskRequest) XXX_DiscardUnknown()
func (*OperateTaskRequest) XXX_Marshal ¶
func (m *OperateTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*OperateTaskRequest) XXX_Merge ¶
func (m *OperateTaskRequest) XXX_Merge(src proto.Message)
func (*OperateTaskRequest) XXX_Size ¶
func (m *OperateTaskRequest) XXX_Size() int
func (*OperateTaskRequest) XXX_Unmarshal ¶
func (m *OperateTaskRequest) XXX_Unmarshal(b []byte) error
type OperateTaskResponse ¶
type OperateTaskResponse struct { Op TaskOp `protobuf:"varint,1,opt,name=op,proto3,enum=pb.TaskOp" json:"op,omitempty"` Result bool `protobuf:"varint,2,opt,name=result,proto3" json:"result,omitempty"` Msg string `protobuf:"bytes,3,opt,name=msg,proto3" json:"msg,omitempty"` Sources []*CommonWorkerResponse `protobuf:"bytes,4,rep,name=sources,proto3" json:"sources,omitempty"` }
func (*OperateTaskResponse) Descriptor ¶
func (*OperateTaskResponse) Descriptor() ([]byte, []int)
func (*OperateTaskResponse) GetMsg ¶
func (m *OperateTaskResponse) GetMsg() string
func (*OperateTaskResponse) GetOp ¶
func (m *OperateTaskResponse) GetOp() TaskOp
func (*OperateTaskResponse) GetResult ¶
func (m *OperateTaskResponse) GetResult() bool
func (*OperateTaskResponse) GetSources ¶
func (m *OperateTaskResponse) GetSources() []*CommonWorkerResponse
func (*OperateTaskResponse) Marshal ¶
func (m *OperateTaskResponse) Marshal() (dAtA []byte, err error)
func (*OperateTaskResponse) MarshalTo ¶
func (m *OperateTaskResponse) MarshalTo(dAtA []byte) (int, error)
func (*OperateTaskResponse) MarshalToSizedBuffer ¶
func (m *OperateTaskResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*OperateTaskResponse) ProtoMessage ¶
func (*OperateTaskResponse) ProtoMessage()
func (*OperateTaskResponse) Reset ¶
func (m *OperateTaskResponse) Reset()
func (*OperateTaskResponse) Size ¶
func (m *OperateTaskResponse) Size() (n int)
func (*OperateTaskResponse) String ¶
func (m *OperateTaskResponse) String() string
func (*OperateTaskResponse) Unmarshal ¶
func (m *OperateTaskResponse) Unmarshal(dAtA []byte) error
func (*OperateTaskResponse) XXX_DiscardUnknown ¶
func (m *OperateTaskResponse) XXX_DiscardUnknown()
func (*OperateTaskResponse) XXX_Marshal ¶
func (m *OperateTaskResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*OperateTaskResponse) XXX_Merge ¶
func (m *OperateTaskResponse) XXX_Merge(src proto.Message)
func (*OperateTaskResponse) XXX_Size ¶
func (m *OperateTaskResponse) XXX_Size() int
func (*OperateTaskResponse) XXX_Unmarshal ¶
func (m *OperateTaskResponse) XXX_Unmarshal(b []byte) error
type OperateV1MetaRequest ¶
type OperateV1MetaRequest struct {
Op V1MetaOp `protobuf:"varint,1,opt,name=op,proto3,enum=pb.V1MetaOp" json:"op,omitempty"`
}
func (*OperateV1MetaRequest) Descriptor ¶
func (*OperateV1MetaRequest) Descriptor() ([]byte, []int)
func (*OperateV1MetaRequest) GetOp ¶
func (m *OperateV1MetaRequest) GetOp() V1MetaOp
func (*OperateV1MetaRequest) Marshal ¶
func (m *OperateV1MetaRequest) Marshal() (dAtA []byte, err error)
func (*OperateV1MetaRequest) MarshalTo ¶
func (m *OperateV1MetaRequest) MarshalTo(dAtA []byte) (int, error)
func (*OperateV1MetaRequest) MarshalToSizedBuffer ¶
func (m *OperateV1MetaRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*OperateV1MetaRequest) ProtoMessage ¶
func (*OperateV1MetaRequest) ProtoMessage()
func (*OperateV1MetaRequest) Reset ¶
func (m *OperateV1MetaRequest) Reset()
func (*OperateV1MetaRequest) Size ¶
func (m *OperateV1MetaRequest) Size() (n int)
func (*OperateV1MetaRequest) String ¶
func (m *OperateV1MetaRequest) String() string
func (*OperateV1MetaRequest) Unmarshal ¶
func (m *OperateV1MetaRequest) Unmarshal(dAtA []byte) error
func (*OperateV1MetaRequest) XXX_DiscardUnknown ¶
func (m *OperateV1MetaRequest) XXX_DiscardUnknown()
func (*OperateV1MetaRequest) XXX_Marshal ¶
func (m *OperateV1MetaRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*OperateV1MetaRequest) XXX_Merge ¶
func (m *OperateV1MetaRequest) XXX_Merge(src proto.Message)
func (*OperateV1MetaRequest) XXX_Size ¶
func (m *OperateV1MetaRequest) XXX_Size() int
func (*OperateV1MetaRequest) XXX_Unmarshal ¶
func (m *OperateV1MetaRequest) XXX_Unmarshal(b []byte) error
type OperateV1MetaResponse ¶
type OperateV1MetaResponse struct { Result bool `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"` Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"` Meta map[string]*V1SubTaskMeta `` /* 149-byte string literal not displayed */ }
func (*OperateV1MetaResponse) Descriptor ¶
func (*OperateV1MetaResponse) Descriptor() ([]byte, []int)
func (*OperateV1MetaResponse) GetMeta ¶
func (m *OperateV1MetaResponse) GetMeta() map[string]*V1SubTaskMeta
func (*OperateV1MetaResponse) GetMsg ¶
func (m *OperateV1MetaResponse) GetMsg() string
func (*OperateV1MetaResponse) GetResult ¶
func (m *OperateV1MetaResponse) GetResult() bool
func (*OperateV1MetaResponse) Marshal ¶
func (m *OperateV1MetaResponse) Marshal() (dAtA []byte, err error)
func (*OperateV1MetaResponse) MarshalTo ¶
func (m *OperateV1MetaResponse) MarshalTo(dAtA []byte) (int, error)
func (*OperateV1MetaResponse) MarshalToSizedBuffer ¶
func (m *OperateV1MetaResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*OperateV1MetaResponse) ProtoMessage ¶
func (*OperateV1MetaResponse) ProtoMessage()
func (*OperateV1MetaResponse) Reset ¶
func (m *OperateV1MetaResponse) Reset()
func (*OperateV1MetaResponse) Size ¶
func (m *OperateV1MetaResponse) Size() (n int)
func (*OperateV1MetaResponse) String ¶
func (m *OperateV1MetaResponse) String() string
func (*OperateV1MetaResponse) Unmarshal ¶
func (m *OperateV1MetaResponse) Unmarshal(dAtA []byte) error
func (*OperateV1MetaResponse) XXX_DiscardUnknown ¶
func (m *OperateV1MetaResponse) XXX_DiscardUnknown()
func (*OperateV1MetaResponse) XXX_Marshal ¶
func (m *OperateV1MetaResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*OperateV1MetaResponse) XXX_Merge ¶
func (m *OperateV1MetaResponse) XXX_Merge(src proto.Message)
func (*OperateV1MetaResponse) XXX_Size ¶
func (m *OperateV1MetaResponse) XXX_Size() int
func (*OperateV1MetaResponse) XXX_Unmarshal ¶
func (m *OperateV1MetaResponse) XXX_Unmarshal(b []byte) error
type OperateWorkerRelayRequest ¶
type OperateWorkerRelayRequest struct { Op RelayOp `protobuf:"varint,1,opt,name=op,proto3,enum=pb.RelayOp" json:"op,omitempty"` Sources []string `protobuf:"bytes,2,rep,name=sources,proto3" json:"sources,omitempty"` }
OperateWorkerRelayRequest represents a request for some dm-workers to operate relay unit
func (*OperateWorkerRelayRequest) Descriptor ¶
func (*OperateWorkerRelayRequest) Descriptor() ([]byte, []int)
func (*OperateWorkerRelayRequest) GetOp ¶
func (m *OperateWorkerRelayRequest) GetOp() RelayOp
func (*OperateWorkerRelayRequest) GetSources ¶
func (m *OperateWorkerRelayRequest) GetSources() []string
func (*OperateWorkerRelayRequest) Marshal ¶
func (m *OperateWorkerRelayRequest) Marshal() (dAtA []byte, err error)
func (*OperateWorkerRelayRequest) MarshalTo ¶
func (m *OperateWorkerRelayRequest) MarshalTo(dAtA []byte) (int, error)
func (*OperateWorkerRelayRequest) MarshalToSizedBuffer ¶
func (m *OperateWorkerRelayRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*OperateWorkerRelayRequest) ProtoMessage ¶
func (*OperateWorkerRelayRequest) ProtoMessage()
func (*OperateWorkerRelayRequest) Reset ¶
func (m *OperateWorkerRelayRequest) Reset()
func (*OperateWorkerRelayRequest) Size ¶
func (m *OperateWorkerRelayRequest) Size() (n int)
func (*OperateWorkerRelayRequest) String ¶
func (m *OperateWorkerRelayRequest) String() string
func (*OperateWorkerRelayRequest) Unmarshal ¶
func (m *OperateWorkerRelayRequest) Unmarshal(dAtA []byte) error
func (*OperateWorkerRelayRequest) XXX_DiscardUnknown ¶
func (m *OperateWorkerRelayRequest) XXX_DiscardUnknown()
func (*OperateWorkerRelayRequest) XXX_Marshal ¶
func (m *OperateWorkerRelayRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*OperateWorkerRelayRequest) XXX_Merge ¶
func (m *OperateWorkerRelayRequest) XXX_Merge(src proto.Message)
func (*OperateWorkerRelayRequest) XXX_Size ¶
func (m *OperateWorkerRelayRequest) XXX_Size() int
func (*OperateWorkerRelayRequest) XXX_Unmarshal ¶
func (m *OperateWorkerRelayRequest) XXX_Unmarshal(b []byte) error
type OperateWorkerRelayResponse ¶
type OperateWorkerRelayResponse struct { Op RelayOp `protobuf:"varint,1,opt,name=op,proto3,enum=pb.RelayOp" json:"op,omitempty"` Result bool `protobuf:"varint,2,opt,name=result,proto3" json:"result,omitempty"` Msg string `protobuf:"bytes,3,opt,name=msg,proto3" json:"msg,omitempty"` Sources []*CommonWorkerResponse `protobuf:"bytes,4,rep,name=sources,proto3" json:"sources,omitempty"` }
func (*OperateWorkerRelayResponse) Descriptor ¶
func (*OperateWorkerRelayResponse) Descriptor() ([]byte, []int)
func (*OperateWorkerRelayResponse) GetMsg ¶
func (m *OperateWorkerRelayResponse) GetMsg() string
func (*OperateWorkerRelayResponse) GetOp ¶
func (m *OperateWorkerRelayResponse) GetOp() RelayOp
func (*OperateWorkerRelayResponse) GetResult ¶
func (m *OperateWorkerRelayResponse) GetResult() bool
func (*OperateWorkerRelayResponse) GetSources ¶
func (m *OperateWorkerRelayResponse) GetSources() []*CommonWorkerResponse
func (*OperateWorkerRelayResponse) Marshal ¶
func (m *OperateWorkerRelayResponse) Marshal() (dAtA []byte, err error)
func (*OperateWorkerRelayResponse) MarshalTo ¶
func (m *OperateWorkerRelayResponse) MarshalTo(dAtA []byte) (int, error)
func (*OperateWorkerRelayResponse) MarshalToSizedBuffer ¶
func (m *OperateWorkerRelayResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*OperateWorkerRelayResponse) ProtoMessage ¶
func (*OperateWorkerRelayResponse) ProtoMessage()
func (*OperateWorkerRelayResponse) Reset ¶
func (m *OperateWorkerRelayResponse) Reset()
func (*OperateWorkerRelayResponse) Size ¶
func (m *OperateWorkerRelayResponse) Size() (n int)
func (*OperateWorkerRelayResponse) String ¶
func (m *OperateWorkerRelayResponse) String() string
func (*OperateWorkerRelayResponse) Unmarshal ¶
func (m *OperateWorkerRelayResponse) Unmarshal(dAtA []byte) error
func (*OperateWorkerRelayResponse) XXX_DiscardUnknown ¶
func (m *OperateWorkerRelayResponse) XXX_DiscardUnknown()
func (*OperateWorkerRelayResponse) XXX_Marshal ¶
func (m *OperateWorkerRelayResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*OperateWorkerRelayResponse) XXX_Merge ¶
func (m *OperateWorkerRelayResponse) XXX_Merge(src proto.Message)
func (*OperateWorkerRelayResponse) XXX_Size ¶
func (m *OperateWorkerRelayResponse) XXX_Size() int
func (*OperateWorkerRelayResponse) XXX_Unmarshal ¶
func (m *OperateWorkerRelayResponse) XXX_Unmarshal(b []byte) error
type OperateWorkerSchemaRequest ¶
type OperateWorkerSchemaRequest struct { Op SchemaOp `protobuf:"varint,1,opt,name=op,proto3,enum=pb.SchemaOp" json:"op,omitempty"` Task string `protobuf:"bytes,2,opt,name=task,proto3" json:"task,omitempty"` Source string `protobuf:"bytes,3,opt,name=source,proto3" json:"source,omitempty"` Database string `protobuf:"bytes,4,opt,name=database,proto3" json:"database,omitempty"` Table string `protobuf:"bytes,5,opt,name=table,proto3" json:"table,omitempty"` Schema string `protobuf:"bytes,6,opt,name=schema,proto3" json:"schema,omitempty"` Flush bool `protobuf:"varint,7,opt,name=flush,proto3" json:"flush,omitempty"` Sync bool `protobuf:"varint,8,opt,name=sync,proto3" json:"sync,omitempty"` FromSource bool `protobuf:"varint,9,opt,name=fromSource,proto3" json:"fromSource,omitempty"` FromTarget bool `protobuf:"varint,10,opt,name=fromTarget,proto3" json:"fromTarget,omitempty"` }
func (*OperateWorkerSchemaRequest) Descriptor ¶
func (*OperateWorkerSchemaRequest) Descriptor() ([]byte, []int)
func (*OperateWorkerSchemaRequest) GetDatabase ¶
func (m *OperateWorkerSchemaRequest) GetDatabase() string
func (*OperateWorkerSchemaRequest) GetFlush ¶ added in v1.9.0
func (m *OperateWorkerSchemaRequest) GetFlush() bool
func (*OperateWorkerSchemaRequest) GetFromSource ¶ added in v1.9.0
func (m *OperateWorkerSchemaRequest) GetFromSource() bool
func (*OperateWorkerSchemaRequest) GetFromTarget ¶ added in v1.9.0
func (m *OperateWorkerSchemaRequest) GetFromTarget() bool
func (*OperateWorkerSchemaRequest) GetOp ¶
func (m *OperateWorkerSchemaRequest) GetOp() SchemaOp
func (*OperateWorkerSchemaRequest) GetSchema ¶
func (m *OperateWorkerSchemaRequest) GetSchema() string
func (*OperateWorkerSchemaRequest) GetSource ¶
func (m *OperateWorkerSchemaRequest) GetSource() string
func (*OperateWorkerSchemaRequest) GetSync ¶ added in v1.9.0
func (m *OperateWorkerSchemaRequest) GetSync() bool
func (*OperateWorkerSchemaRequest) GetTable ¶
func (m *OperateWorkerSchemaRequest) GetTable() string
func (*OperateWorkerSchemaRequest) GetTask ¶
func (m *OperateWorkerSchemaRequest) GetTask() string
func (*OperateWorkerSchemaRequest) Marshal ¶
func (m *OperateWorkerSchemaRequest) Marshal() (dAtA []byte, err error)
func (*OperateWorkerSchemaRequest) MarshalTo ¶
func (m *OperateWorkerSchemaRequest) MarshalTo(dAtA []byte) (int, error)
func (*OperateWorkerSchemaRequest) MarshalToSizedBuffer ¶
func (m *OperateWorkerSchemaRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*OperateWorkerSchemaRequest) ProtoMessage ¶
func (*OperateWorkerSchemaRequest) ProtoMessage()
func (*OperateWorkerSchemaRequest) Reset ¶
func (m *OperateWorkerSchemaRequest) Reset()
func (*OperateWorkerSchemaRequest) Size ¶
func (m *OperateWorkerSchemaRequest) Size() (n int)
func (*OperateWorkerSchemaRequest) String ¶
func (m *OperateWorkerSchemaRequest) String() string
func (*OperateWorkerSchemaRequest) Unmarshal ¶
func (m *OperateWorkerSchemaRequest) Unmarshal(dAtA []byte) error
func (*OperateWorkerSchemaRequest) XXX_DiscardUnknown ¶
func (m *OperateWorkerSchemaRequest) XXX_DiscardUnknown()
func (*OperateWorkerSchemaRequest) XXX_Marshal ¶
func (m *OperateWorkerSchemaRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*OperateWorkerSchemaRequest) XXX_Merge ¶
func (m *OperateWorkerSchemaRequest) XXX_Merge(src proto.Message)
func (*OperateWorkerSchemaRequest) XXX_Size ¶
func (m *OperateWorkerSchemaRequest) XXX_Size() int
func (*OperateWorkerSchemaRequest) XXX_Unmarshal ¶
func (m *OperateWorkerSchemaRequest) XXX_Unmarshal(b []byte) error
type ProcessError ¶
type ProcessError struct { ErrCode int32 `protobuf:"varint,1,opt,name=ErrCode,proto3" json:"ErrCode,omitempty"` ErrClass string `protobuf:"bytes,2,opt,name=ErrClass,proto3" json:"ErrClass,omitempty"` ErrScope string `protobuf:"bytes,3,opt,name=ErrScope,proto3" json:"ErrScope,omitempty"` ErrLevel string `protobuf:"bytes,4,opt,name=ErrLevel,proto3" json:"ErrLevel,omitempty"` Message string `protobuf:"bytes,5,opt,name=Message,proto3" json:"Message,omitempty"` RawCause string `protobuf:"bytes,6,opt,name=RawCause,proto3" json:"RawCause,omitempty"` Workaround string `protobuf:"bytes,7,opt,name=Workaround,proto3" json:"Workaround,omitempty"` }
ProcessError is same as terror used in dm NOTE: currently stack trace is not supported, `Message` is the `terror.Error.getMsg` result and `RawCause` is the `Error` result of error from `terror.Error.Cause()`.
func (*ProcessError) Descriptor ¶
func (*ProcessError) Descriptor() ([]byte, []int)
func (*ProcessError) GetErrClass ¶
func (m *ProcessError) GetErrClass() string
func (*ProcessError) GetErrCode ¶
func (m *ProcessError) GetErrCode() int32
func (*ProcessError) GetErrLevel ¶
func (m *ProcessError) GetErrLevel() string
func (*ProcessError) GetErrScope ¶
func (m *ProcessError) GetErrScope() string
func (*ProcessError) GetMessage ¶
func (m *ProcessError) GetMessage() string
func (*ProcessError) GetRawCause ¶
func (m *ProcessError) GetRawCause() string
func (*ProcessError) GetWorkaround ¶
func (m *ProcessError) GetWorkaround() string
func (*ProcessError) Marshal ¶
func (m *ProcessError) Marshal() (dAtA []byte, err error)
func (*ProcessError) MarshalToSizedBuffer ¶
func (m *ProcessError) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ProcessError) ProtoMessage ¶
func (*ProcessError) ProtoMessage()
func (*ProcessError) Reset ¶
func (m *ProcessError) Reset()
func (*ProcessError) Size ¶
func (m *ProcessError) Size() (n int)
func (*ProcessError) String ¶
func (m *ProcessError) String() string
func (*ProcessError) Unmarshal ¶
func (m *ProcessError) Unmarshal(dAtA []byte) error
func (*ProcessError) XXX_DiscardUnknown ¶
func (m *ProcessError) XXX_DiscardUnknown()
func (*ProcessError) XXX_Marshal ¶
func (m *ProcessError) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ProcessError) XXX_Merge ¶
func (m *ProcessError) XXX_Merge(src proto.Message)
func (*ProcessError) XXX_Size ¶
func (m *ProcessError) XXX_Size() int
func (*ProcessError) XXX_Unmarshal ¶
func (m *ProcessError) XXX_Unmarshal(b []byte) error
type ProcessResult ¶
type ProcessResult struct { IsCanceled bool `protobuf:"varint,1,opt,name=isCanceled,proto3" json:"isCanceled,omitempty"` Errors []*ProcessError `protobuf:"bytes,2,rep,name=errors,proto3" json:"errors,omitempty"` Detail []byte `protobuf:"bytes,3,opt,name=detail,proto3" json:"detail,omitempty"` }
ProcessResult represents results produced by a dm unit isCanceled: indicates whether the process is canceled from external
when Stop or Pause is requested from external, isCanceled will be true
errors: includes all (potential) errors occured when processing
func (*ProcessResult) Descriptor ¶
func (*ProcessResult) Descriptor() ([]byte, []int)
func (*ProcessResult) GetDetail ¶
func (m *ProcessResult) GetDetail() []byte
func (*ProcessResult) GetErrors ¶
func (m *ProcessResult) GetErrors() []*ProcessError
func (*ProcessResult) GetIsCanceled ¶
func (m *ProcessResult) GetIsCanceled() bool
func (*ProcessResult) Marshal ¶
func (m *ProcessResult) Marshal() (dAtA []byte, err error)
func (*ProcessResult) MarshalToSizedBuffer ¶
func (m *ProcessResult) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ProcessResult) ProtoMessage ¶
func (*ProcessResult) ProtoMessage()
func (*ProcessResult) Reset ¶
func (m *ProcessResult) Reset()
func (*ProcessResult) Size ¶
func (m *ProcessResult) Size() (n int)
func (*ProcessResult) String ¶
func (m *ProcessResult) String() string
func (*ProcessResult) Unmarshal ¶
func (m *ProcessResult) Unmarshal(dAtA []byte) error
func (*ProcessResult) XXX_DiscardUnknown ¶
func (m *ProcessResult) XXX_DiscardUnknown()
func (*ProcessResult) XXX_Marshal ¶
func (m *ProcessResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ProcessResult) XXX_Merge ¶
func (m *ProcessResult) XXX_Merge(src proto.Message)
func (*ProcessResult) XXX_Size ¶
func (m *ProcessResult) XXX_Size() int
func (*ProcessResult) XXX_Unmarshal ¶
func (m *ProcessResult) XXX_Unmarshal(b []byte) error
type PurgeRelayRequest ¶
type PurgeRelayRequest struct { Inactive bool `protobuf:"varint,1,opt,name=inactive,proto3" json:"inactive,omitempty"` Time int64 `protobuf:"varint,2,opt,name=time,proto3" json:"time,omitempty"` Filename string `protobuf:"bytes,3,opt,name=filename,proto3" json:"filename,omitempty"` SubDir string `protobuf:"bytes,4,opt,name=subDir,proto3" json:"subDir,omitempty"` }
PurgeRelayRequest represents a request to purge relay log files for this dm-worker inactive: whether purge inactive relay log files time: whether purge relay log files before this time, the number of seconds elapsed since January 1, 1970 UTC filename: whether purge relay log files before this filename subDir: specify relay sub directory for @filename
func (*PurgeRelayRequest) Descriptor ¶
func (*PurgeRelayRequest) Descriptor() ([]byte, []int)
func (*PurgeRelayRequest) GetFilename ¶
func (m *PurgeRelayRequest) GetFilename() string
func (*PurgeRelayRequest) GetInactive ¶
func (m *PurgeRelayRequest) GetInactive() bool
func (*PurgeRelayRequest) GetSubDir ¶
func (m *PurgeRelayRequest) GetSubDir() string
func (*PurgeRelayRequest) GetTime ¶
func (m *PurgeRelayRequest) GetTime() int64
func (*PurgeRelayRequest) Marshal ¶
func (m *PurgeRelayRequest) Marshal() (dAtA []byte, err error)
func (*PurgeRelayRequest) MarshalTo ¶
func (m *PurgeRelayRequest) MarshalTo(dAtA []byte) (int, error)
func (*PurgeRelayRequest) MarshalToSizedBuffer ¶
func (m *PurgeRelayRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PurgeRelayRequest) ProtoMessage ¶
func (*PurgeRelayRequest) ProtoMessage()
func (*PurgeRelayRequest) Reset ¶
func (m *PurgeRelayRequest) Reset()
func (*PurgeRelayRequest) Size ¶
func (m *PurgeRelayRequest) Size() (n int)
func (*PurgeRelayRequest) String ¶
func (m *PurgeRelayRequest) String() string
func (*PurgeRelayRequest) Unmarshal ¶
func (m *PurgeRelayRequest) Unmarshal(dAtA []byte) error
func (*PurgeRelayRequest) XXX_DiscardUnknown ¶
func (m *PurgeRelayRequest) XXX_DiscardUnknown()
func (*PurgeRelayRequest) XXX_Marshal ¶
func (m *PurgeRelayRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PurgeRelayRequest) XXX_Merge ¶
func (m *PurgeRelayRequest) XXX_Merge(src proto.Message)
func (*PurgeRelayRequest) XXX_Size ¶
func (m *PurgeRelayRequest) XXX_Size() int
func (*PurgeRelayRequest) XXX_Unmarshal ¶
func (m *PurgeRelayRequest) XXX_Unmarshal(b []byte) error
type PurgeWorkerRelayRequest ¶
type PurgeWorkerRelayRequest struct { Sources []string `protobuf:"bytes,1,rep,name=sources,proto3" json:"sources,omitempty"` Inactive bool `protobuf:"varint,2,opt,name=inactive,proto3" json:"inactive,omitempty"` Time int64 `protobuf:"varint,3,opt,name=time,proto3" json:"time,omitempty"` Filename string `protobuf:"bytes,4,opt,name=filename,proto3" json:"filename,omitempty"` SubDir string `protobuf:"bytes,5,opt,name=subDir,proto3" json:"subDir,omitempty"` }
PurgeWorkerRelayRequest represents a request to purge relay log files for some dm-workers workers: dm-workers need to purge relay log files inactive: whether purge inactive relay log files time: whether purge relay log files before this time, the number of seconds elapsed since January 1, 1970 UTC filename: whether purge relay log files before this filename subDir: specify relay sub directory for @filename
func (*PurgeWorkerRelayRequest) Descriptor ¶
func (*PurgeWorkerRelayRequest) Descriptor() ([]byte, []int)
func (*PurgeWorkerRelayRequest) GetFilename ¶
func (m *PurgeWorkerRelayRequest) GetFilename() string
func (*PurgeWorkerRelayRequest) GetInactive ¶
func (m *PurgeWorkerRelayRequest) GetInactive() bool
func (*PurgeWorkerRelayRequest) GetSources ¶
func (m *PurgeWorkerRelayRequest) GetSources() []string
func (*PurgeWorkerRelayRequest) GetSubDir ¶
func (m *PurgeWorkerRelayRequest) GetSubDir() string
func (*PurgeWorkerRelayRequest) GetTime ¶
func (m *PurgeWorkerRelayRequest) GetTime() int64
func (*PurgeWorkerRelayRequest) Marshal ¶
func (m *PurgeWorkerRelayRequest) Marshal() (dAtA []byte, err error)
func (*PurgeWorkerRelayRequest) MarshalTo ¶
func (m *PurgeWorkerRelayRequest) MarshalTo(dAtA []byte) (int, error)
func (*PurgeWorkerRelayRequest) MarshalToSizedBuffer ¶
func (m *PurgeWorkerRelayRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PurgeWorkerRelayRequest) ProtoMessage ¶
func (*PurgeWorkerRelayRequest) ProtoMessage()
func (*PurgeWorkerRelayRequest) Reset ¶
func (m *PurgeWorkerRelayRequest) Reset()
func (*PurgeWorkerRelayRequest) Size ¶
func (m *PurgeWorkerRelayRequest) Size() (n int)
func (*PurgeWorkerRelayRequest) String ¶
func (m *PurgeWorkerRelayRequest) String() string
func (*PurgeWorkerRelayRequest) Unmarshal ¶
func (m *PurgeWorkerRelayRequest) Unmarshal(dAtA []byte) error
func (*PurgeWorkerRelayRequest) XXX_DiscardUnknown ¶
func (m *PurgeWorkerRelayRequest) XXX_DiscardUnknown()
func (*PurgeWorkerRelayRequest) XXX_Marshal ¶
func (m *PurgeWorkerRelayRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PurgeWorkerRelayRequest) XXX_Merge ¶
func (m *PurgeWorkerRelayRequest) XXX_Merge(src proto.Message)
func (*PurgeWorkerRelayRequest) XXX_Size ¶
func (m *PurgeWorkerRelayRequest) XXX_Size() int
func (*PurgeWorkerRelayRequest) XXX_Unmarshal ¶
func (m *PurgeWorkerRelayRequest) XXX_Unmarshal(b []byte) error
type PurgeWorkerRelayResponse ¶
type PurgeWorkerRelayResponse struct { Result bool `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"` Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"` Sources []*CommonWorkerResponse `protobuf:"bytes,3,rep,name=sources,proto3" json:"sources,omitempty"` }
func (*PurgeWorkerRelayResponse) Descriptor ¶
func (*PurgeWorkerRelayResponse) Descriptor() ([]byte, []int)
func (*PurgeWorkerRelayResponse) GetMsg ¶
func (m *PurgeWorkerRelayResponse) GetMsg() string
func (*PurgeWorkerRelayResponse) GetResult ¶
func (m *PurgeWorkerRelayResponse) GetResult() bool
func (*PurgeWorkerRelayResponse) GetSources ¶
func (m *PurgeWorkerRelayResponse) GetSources() []*CommonWorkerResponse
func (*PurgeWorkerRelayResponse) Marshal ¶
func (m *PurgeWorkerRelayResponse) Marshal() (dAtA []byte, err error)
func (*PurgeWorkerRelayResponse) MarshalTo ¶
func (m *PurgeWorkerRelayResponse) MarshalTo(dAtA []byte) (int, error)
func (*PurgeWorkerRelayResponse) MarshalToSizedBuffer ¶
func (m *PurgeWorkerRelayResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PurgeWorkerRelayResponse) ProtoMessage ¶
func (*PurgeWorkerRelayResponse) ProtoMessage()
func (*PurgeWorkerRelayResponse) Reset ¶
func (m *PurgeWorkerRelayResponse) Reset()
func (*PurgeWorkerRelayResponse) Size ¶
func (m *PurgeWorkerRelayResponse) Size() (n int)
func (*PurgeWorkerRelayResponse) String ¶
func (m *PurgeWorkerRelayResponse) String() string
func (*PurgeWorkerRelayResponse) Unmarshal ¶
func (m *PurgeWorkerRelayResponse) Unmarshal(dAtA []byte) error
func (*PurgeWorkerRelayResponse) XXX_DiscardUnknown ¶
func (m *PurgeWorkerRelayResponse) XXX_DiscardUnknown()
func (*PurgeWorkerRelayResponse) XXX_Marshal ¶
func (m *PurgeWorkerRelayResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PurgeWorkerRelayResponse) XXX_Merge ¶
func (m *PurgeWorkerRelayResponse) XXX_Merge(src proto.Message)
func (*PurgeWorkerRelayResponse) XXX_Size ¶
func (m *PurgeWorkerRelayResponse) XXX_Size() int
func (*PurgeWorkerRelayResponse) XXX_Unmarshal ¶
func (m *PurgeWorkerRelayResponse) XXX_Unmarshal(b []byte) error
type QueryStatusListRequest ¶
type QueryStatusListRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Sources []string `protobuf:"bytes,2,rep,name=sources,proto3" json:"sources,omitempty"` }
func (*QueryStatusListRequest) Descriptor ¶
func (*QueryStatusListRequest) Descriptor() ([]byte, []int)
func (*QueryStatusListRequest) GetName ¶
func (m *QueryStatusListRequest) GetName() string
func (*QueryStatusListRequest) GetSources ¶
func (m *QueryStatusListRequest) GetSources() []string
func (*QueryStatusListRequest) Marshal ¶
func (m *QueryStatusListRequest) Marshal() (dAtA []byte, err error)
func (*QueryStatusListRequest) MarshalTo ¶
func (m *QueryStatusListRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryStatusListRequest) MarshalToSizedBuffer ¶
func (m *QueryStatusListRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryStatusListRequest) ProtoMessage ¶
func (*QueryStatusListRequest) ProtoMessage()
func (*QueryStatusListRequest) Reset ¶
func (m *QueryStatusListRequest) Reset()
func (*QueryStatusListRequest) Size ¶
func (m *QueryStatusListRequest) Size() (n int)
func (*QueryStatusListRequest) String ¶
func (m *QueryStatusListRequest) String() string
func (*QueryStatusListRequest) Unmarshal ¶
func (m *QueryStatusListRequest) Unmarshal(dAtA []byte) error
func (*QueryStatusListRequest) XXX_DiscardUnknown ¶
func (m *QueryStatusListRequest) XXX_DiscardUnknown()
func (*QueryStatusListRequest) XXX_Marshal ¶
func (m *QueryStatusListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryStatusListRequest) XXX_Merge ¶
func (m *QueryStatusListRequest) XXX_Merge(src proto.Message)
func (*QueryStatusListRequest) XXX_Size ¶
func (m *QueryStatusListRequest) XXX_Size() int
func (*QueryStatusListRequest) XXX_Unmarshal ¶
func (m *QueryStatusListRequest) XXX_Unmarshal(b []byte) error
type QueryStatusListResponse ¶
type QueryStatusListResponse struct { Result bool `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"` Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"` Sources []*QueryStatusResponse `protobuf:"bytes,3,rep,name=sources,proto3" json:"sources,omitempty"` }
func (*QueryStatusListResponse) Descriptor ¶
func (*QueryStatusListResponse) Descriptor() ([]byte, []int)
func (*QueryStatusListResponse) GetMsg ¶
func (m *QueryStatusListResponse) GetMsg() string
func (*QueryStatusListResponse) GetResult ¶
func (m *QueryStatusListResponse) GetResult() bool
func (*QueryStatusListResponse) GetSources ¶
func (m *QueryStatusListResponse) GetSources() []*QueryStatusResponse
func (*QueryStatusListResponse) Marshal ¶
func (m *QueryStatusListResponse) Marshal() (dAtA []byte, err error)
func (*QueryStatusListResponse) MarshalTo ¶
func (m *QueryStatusListResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryStatusListResponse) MarshalToSizedBuffer ¶
func (m *QueryStatusListResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryStatusListResponse) ProtoMessage ¶
func (*QueryStatusListResponse) ProtoMessage()
func (*QueryStatusListResponse) Reset ¶
func (m *QueryStatusListResponse) Reset()
func (*QueryStatusListResponse) Size ¶
func (m *QueryStatusListResponse) Size() (n int)
func (*QueryStatusListResponse) String ¶
func (m *QueryStatusListResponse) String() string
func (*QueryStatusListResponse) Unmarshal ¶
func (m *QueryStatusListResponse) Unmarshal(dAtA []byte) error
func (*QueryStatusListResponse) XXX_DiscardUnknown ¶
func (m *QueryStatusListResponse) XXX_DiscardUnknown()
func (*QueryStatusListResponse) XXX_Marshal ¶
func (m *QueryStatusListResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryStatusListResponse) XXX_Merge ¶
func (m *QueryStatusListResponse) XXX_Merge(src proto.Message)
func (*QueryStatusListResponse) XXX_Size ¶
func (m *QueryStatusListResponse) XXX_Size() int
func (*QueryStatusListResponse) XXX_Unmarshal ¶
func (m *QueryStatusListResponse) XXX_Unmarshal(b []byte) error
type QueryStatusRequest ¶
type QueryStatusRequest struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
}
func (*QueryStatusRequest) Descriptor ¶
func (*QueryStatusRequest) Descriptor() ([]byte, []int)
func (*QueryStatusRequest) GetName ¶
func (m *QueryStatusRequest) GetName() string
func (*QueryStatusRequest) Marshal ¶
func (m *QueryStatusRequest) Marshal() (dAtA []byte, err error)
func (*QueryStatusRequest) MarshalTo ¶
func (m *QueryStatusRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryStatusRequest) MarshalToSizedBuffer ¶
func (m *QueryStatusRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryStatusRequest) ProtoMessage ¶
func (*QueryStatusRequest) ProtoMessage()
func (*QueryStatusRequest) Reset ¶
func (m *QueryStatusRequest) Reset()
func (*QueryStatusRequest) Size ¶
func (m *QueryStatusRequest) Size() (n int)
func (*QueryStatusRequest) String ¶
func (m *QueryStatusRequest) String() string
func (*QueryStatusRequest) Unmarshal ¶
func (m *QueryStatusRequest) Unmarshal(dAtA []byte) error
func (*QueryStatusRequest) XXX_DiscardUnknown ¶
func (m *QueryStatusRequest) XXX_DiscardUnknown()
func (*QueryStatusRequest) XXX_Marshal ¶
func (m *QueryStatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryStatusRequest) XXX_Merge ¶
func (m *QueryStatusRequest) XXX_Merge(src proto.Message)
func (*QueryStatusRequest) XXX_Size ¶
func (m *QueryStatusRequest) XXX_Size() int
func (*QueryStatusRequest) XXX_Unmarshal ¶
func (m *QueryStatusRequest) XXX_Unmarshal(b []byte) error
type QueryStatusResponse ¶
type QueryStatusResponse struct { Result bool `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"` Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"` SourceStatus *SourceStatus `protobuf:"bytes,3,opt,name=sourceStatus,proto3" json:"sourceStatus,omitempty"` SubTaskStatus []*SubTaskStatus `protobuf:"bytes,4,rep,name=subTaskStatus,proto3" json:"subTaskStatus,omitempty"` }
QueryStatusResponse represents status response for query on a dm-worker status: dm-worker's current sub tasks' status
func (*QueryStatusResponse) Descriptor ¶
func (*QueryStatusResponse) Descriptor() ([]byte, []int)
func (*QueryStatusResponse) GetMsg ¶
func (m *QueryStatusResponse) GetMsg() string
func (*QueryStatusResponse) GetResult ¶
func (m *QueryStatusResponse) GetResult() bool
func (*QueryStatusResponse) GetSourceStatus ¶
func (m *QueryStatusResponse) GetSourceStatus() *SourceStatus
func (*QueryStatusResponse) GetSubTaskStatus ¶
func (m *QueryStatusResponse) GetSubTaskStatus() []*SubTaskStatus
func (*QueryStatusResponse) Marshal ¶
func (m *QueryStatusResponse) Marshal() (dAtA []byte, err error)
func (*QueryStatusResponse) MarshalTo ¶
func (m *QueryStatusResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryStatusResponse) MarshalToSizedBuffer ¶
func (m *QueryStatusResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryStatusResponse) ProtoMessage ¶
func (*QueryStatusResponse) ProtoMessage()
func (*QueryStatusResponse) Reset ¶
func (m *QueryStatusResponse) Reset()
func (*QueryStatusResponse) Size ¶
func (m *QueryStatusResponse) Size() (n int)
func (*QueryStatusResponse) String ¶
func (m *QueryStatusResponse) String() string
func (*QueryStatusResponse) Unmarshal ¶
func (m *QueryStatusResponse) Unmarshal(dAtA []byte) error
func (*QueryStatusResponse) XXX_DiscardUnknown ¶
func (m *QueryStatusResponse) XXX_DiscardUnknown()
func (*QueryStatusResponse) XXX_Marshal ¶
func (m *QueryStatusResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryStatusResponse) XXX_Merge ¶
func (m *QueryStatusResponse) XXX_Merge(src proto.Message)
func (*QueryStatusResponse) XXX_Size ¶
func (m *QueryStatusResponse) XXX_Size() int
func (*QueryStatusResponse) XXX_Unmarshal ¶
func (m *QueryStatusResponse) XXX_Unmarshal(b []byte) error
type RegisterWorkerRequest ¶
type RegisterWorkerRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"` }
func (*RegisterWorkerRequest) Descriptor ¶
func (*RegisterWorkerRequest) Descriptor() ([]byte, []int)
func (*RegisterWorkerRequest) GetAddress ¶
func (m *RegisterWorkerRequest) GetAddress() string
func (*RegisterWorkerRequest) GetName ¶
func (m *RegisterWorkerRequest) GetName() string
func (*RegisterWorkerRequest) Marshal ¶
func (m *RegisterWorkerRequest) Marshal() (dAtA []byte, err error)
func (*RegisterWorkerRequest) MarshalTo ¶
func (m *RegisterWorkerRequest) MarshalTo(dAtA []byte) (int, error)
func (*RegisterWorkerRequest) MarshalToSizedBuffer ¶
func (m *RegisterWorkerRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*RegisterWorkerRequest) ProtoMessage ¶
func (*RegisterWorkerRequest) ProtoMessage()
func (*RegisterWorkerRequest) Reset ¶
func (m *RegisterWorkerRequest) Reset()
func (*RegisterWorkerRequest) Size ¶
func (m *RegisterWorkerRequest) Size() (n int)
func (*RegisterWorkerRequest) String ¶
func (m *RegisterWorkerRequest) String() string
func (*RegisterWorkerRequest) Unmarshal ¶
func (m *RegisterWorkerRequest) Unmarshal(dAtA []byte) error
func (*RegisterWorkerRequest) XXX_DiscardUnknown ¶
func (m *RegisterWorkerRequest) XXX_DiscardUnknown()
func (*RegisterWorkerRequest) XXX_Marshal ¶
func (m *RegisterWorkerRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RegisterWorkerRequest) XXX_Merge ¶
func (m *RegisterWorkerRequest) XXX_Merge(src proto.Message)
func (*RegisterWorkerRequest) XXX_Size ¶
func (m *RegisterWorkerRequest) XXX_Size() int
func (*RegisterWorkerRequest) XXX_Unmarshal ¶
func (m *RegisterWorkerRequest) XXX_Unmarshal(b []byte) error
type RegisterWorkerResponse ¶
type RegisterWorkerResponse struct { Result bool `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"` Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"` }
func (*RegisterWorkerResponse) Descriptor ¶
func (*RegisterWorkerResponse) Descriptor() ([]byte, []int)
func (*RegisterWorkerResponse) GetMsg ¶
func (m *RegisterWorkerResponse) GetMsg() string
func (*RegisterWorkerResponse) GetResult ¶
func (m *RegisterWorkerResponse) GetResult() bool
func (*RegisterWorkerResponse) Marshal ¶
func (m *RegisterWorkerResponse) Marshal() (dAtA []byte, err error)
func (*RegisterWorkerResponse) MarshalTo ¶
func (m *RegisterWorkerResponse) MarshalTo(dAtA []byte) (int, error)
func (*RegisterWorkerResponse) MarshalToSizedBuffer ¶
func (m *RegisterWorkerResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*RegisterWorkerResponse) ProtoMessage ¶
func (*RegisterWorkerResponse) ProtoMessage()
func (*RegisterWorkerResponse) Reset ¶
func (m *RegisterWorkerResponse) Reset()
func (*RegisterWorkerResponse) Size ¶
func (m *RegisterWorkerResponse) Size() (n int)
func (*RegisterWorkerResponse) String ¶
func (m *RegisterWorkerResponse) String() string
func (*RegisterWorkerResponse) Unmarshal ¶
func (m *RegisterWorkerResponse) Unmarshal(dAtA []byte) error
func (*RegisterWorkerResponse) XXX_DiscardUnknown ¶
func (m *RegisterWorkerResponse) XXX_DiscardUnknown()
func (*RegisterWorkerResponse) XXX_Marshal ¶
func (m *RegisterWorkerResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RegisterWorkerResponse) XXX_Merge ¶
func (m *RegisterWorkerResponse) XXX_Merge(src proto.Message)
func (*RegisterWorkerResponse) XXX_Size ¶
func (m *RegisterWorkerResponse) XXX_Size() int
func (*RegisterWorkerResponse) XXX_Unmarshal ¶
func (m *RegisterWorkerResponse) XXX_Unmarshal(b []byte) error
type RelayError ¶
type RelayError struct {
Msg string `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
}
RelayError represents error for relay unit.
func (*RelayError) Descriptor ¶
func (*RelayError) Descriptor() ([]byte, []int)
func (*RelayError) GetMsg ¶
func (m *RelayError) GetMsg() string
func (*RelayError) Marshal ¶
func (m *RelayError) Marshal() (dAtA []byte, err error)
func (*RelayError) MarshalToSizedBuffer ¶
func (m *RelayError) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*RelayError) ProtoMessage ¶
func (*RelayError) ProtoMessage()
func (*RelayError) Reset ¶
func (m *RelayError) Reset()
func (*RelayError) Size ¶
func (m *RelayError) Size() (n int)
func (*RelayError) String ¶
func (m *RelayError) String() string
func (*RelayError) Unmarshal ¶
func (m *RelayError) Unmarshal(dAtA []byte) error
func (*RelayError) XXX_DiscardUnknown ¶
func (m *RelayError) XXX_DiscardUnknown()
func (*RelayError) XXX_Marshal ¶
func (m *RelayError) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RelayError) XXX_Merge ¶
func (m *RelayError) XXX_Merge(src proto.Message)
func (*RelayError) XXX_Size ¶
func (m *RelayError) XXX_Size() int
func (*RelayError) XXX_Unmarshal ¶
func (m *RelayError) XXX_Unmarshal(b []byte) error
type RelayOpV2 ¶ added in v1.9.0
type RelayOpV2 int32
func (RelayOpV2) EnumDescriptor ¶ added in v1.9.0
type RelayStatus ¶
type RelayStatus struct { MasterBinlog string `protobuf:"bytes,1,opt,name=masterBinlog,proto3" json:"masterBinlog,omitempty"` MasterBinlogGtid string `protobuf:"bytes,2,opt,name=masterBinlogGtid,proto3" json:"masterBinlogGtid,omitempty"` RelaySubDir string `protobuf:"bytes,3,opt,name=relaySubDir,proto3" json:"relaySubDir,omitempty"` RelayBinlog string `protobuf:"bytes,4,opt,name=relayBinlog,proto3" json:"relayBinlog,omitempty"` RelayBinlogGtid string `protobuf:"bytes,5,opt,name=relayBinlogGtid,proto3" json:"relayBinlogGtid,omitempty"` RelayCatchUpMaster bool `protobuf:"varint,6,opt,name=relayCatchUpMaster,proto3" json:"relayCatchUpMaster,omitempty"` Stage Stage `protobuf:"varint,7,opt,name=stage,proto3,enum=pb.Stage" json:"stage,omitempty"` Result *ProcessResult `protobuf:"bytes,8,opt,name=result,proto3" json:"result,omitempty"` }
RelayStatus represents status for relay unit.
func (*RelayStatus) Descriptor ¶
func (*RelayStatus) Descriptor() ([]byte, []int)
func (*RelayStatus) GetMasterBinlog ¶
func (m *RelayStatus) GetMasterBinlog() string
func (*RelayStatus) GetMasterBinlogGtid ¶
func (m *RelayStatus) GetMasterBinlogGtid() string
func (*RelayStatus) GetRelayBinlog ¶
func (m *RelayStatus) GetRelayBinlog() string
func (*RelayStatus) GetRelayBinlogGtid ¶
func (m *RelayStatus) GetRelayBinlogGtid() string
func (*RelayStatus) GetRelayCatchUpMaster ¶
func (m *RelayStatus) GetRelayCatchUpMaster() bool
func (*RelayStatus) GetRelaySubDir ¶
func (m *RelayStatus) GetRelaySubDir() string
func (*RelayStatus) GetResult ¶
func (m *RelayStatus) GetResult() *ProcessResult
func (*RelayStatus) GetStage ¶
func (m *RelayStatus) GetStage() Stage
func (*RelayStatus) Marshal ¶
func (m *RelayStatus) Marshal() (dAtA []byte, err error)
func (*RelayStatus) MarshalToSizedBuffer ¶
func (m *RelayStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*RelayStatus) ProtoMessage ¶
func (*RelayStatus) ProtoMessage()
func (*RelayStatus) Reset ¶
func (m *RelayStatus) Reset()
func (*RelayStatus) Size ¶
func (m *RelayStatus) Size() (n int)
func (*RelayStatus) String ¶
func (m *RelayStatus) String() string
func (*RelayStatus) Unmarshal ¶
func (m *RelayStatus) Unmarshal(dAtA []byte) error
func (*RelayStatus) XXX_DiscardUnknown ¶
func (m *RelayStatus) XXX_DiscardUnknown()
func (*RelayStatus) XXX_Marshal ¶
func (m *RelayStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RelayStatus) XXX_Merge ¶
func (m *RelayStatus) XXX_Merge(src proto.Message)
func (*RelayStatus) XXX_Size ¶
func (m *RelayStatus) XXX_Size() int
func (*RelayStatus) XXX_Unmarshal ¶
func (m *RelayStatus) XXX_Unmarshal(b []byte) error
type ShardingGroup ¶
type ShardingGroup struct { Target string `protobuf:"bytes,1,opt,name=target,proto3" json:"target,omitempty"` DDLs []string `protobuf:"bytes,2,rep,name=DDLs,proto3" json:"DDLs,omitempty"` FirstLocation string `protobuf:"bytes,3,opt,name=firstLocation,proto3" json:"firstLocation,omitempty"` Synced []string `protobuf:"bytes,4,rep,name=synced,proto3" json:"synced,omitempty"` Unsynced []string `protobuf:"bytes,5,rep,name=unsynced,proto3" json:"unsynced,omitempty"` }
ShardingGroup represents a DDL sharding group, this is used by SyncStatus, and is differ from ShardingGroup in syncer pkg target: target table name DDL: in syncing DDL firstPos: first DDL binlog pos for this group synced: synced source tables unsynced: unsynced source tables
func (*ShardingGroup) Descriptor ¶
func (*ShardingGroup) Descriptor() ([]byte, []int)
func (*ShardingGroup) GetDDLs ¶
func (m *ShardingGroup) GetDDLs() []string
func (*ShardingGroup) GetFirstLocation ¶
func (m *ShardingGroup) GetFirstLocation() string
func (*ShardingGroup) GetSynced ¶
func (m *ShardingGroup) GetSynced() []string
func (*ShardingGroup) GetTarget ¶
func (m *ShardingGroup) GetTarget() string
func (*ShardingGroup) GetUnsynced ¶
func (m *ShardingGroup) GetUnsynced() []string
func (*ShardingGroup) Marshal ¶
func (m *ShardingGroup) Marshal() (dAtA []byte, err error)
func (*ShardingGroup) MarshalToSizedBuffer ¶
func (m *ShardingGroup) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ShardingGroup) ProtoMessage ¶
func (*ShardingGroup) ProtoMessage()
func (*ShardingGroup) Reset ¶
func (m *ShardingGroup) Reset()
func (*ShardingGroup) Size ¶
func (m *ShardingGroup) Size() (n int)
func (*ShardingGroup) String ¶
func (m *ShardingGroup) String() string
func (*ShardingGroup) Unmarshal ¶
func (m *ShardingGroup) Unmarshal(dAtA []byte) error
func (*ShardingGroup) XXX_DiscardUnknown ¶
func (m *ShardingGroup) XXX_DiscardUnknown()
func (*ShardingGroup) XXX_Marshal ¶
func (m *ShardingGroup) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ShardingGroup) XXX_Merge ¶
func (m *ShardingGroup) XXX_Merge(src proto.Message)
func (*ShardingGroup) XXX_Size ¶
func (m *ShardingGroup) XXX_Size() int
func (*ShardingGroup) XXX_Unmarshal ¶
func (m *ShardingGroup) XXX_Unmarshal(b []byte) error
type ShowDDLLocksRequest ¶
type ShowDDLLocksRequest struct { Task string `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"` Sources []string `protobuf:"bytes,2,rep,name=sources,proto3" json:"sources,omitempty"` }
ShowDDLLocksRequest used to query DDL locks which are un-resolved task: task's name, empty for all tasks sources: source need to query, empty for all sources
any DDL lock in which the source is synced or unsynced will return
if specify task and sources both, and sources not doing the task , it will return empty DDL locks
func (*ShowDDLLocksRequest) Descriptor ¶
func (*ShowDDLLocksRequest) Descriptor() ([]byte, []int)
func (*ShowDDLLocksRequest) GetSources ¶
func (m *ShowDDLLocksRequest) GetSources() []string
func (*ShowDDLLocksRequest) GetTask ¶
func (m *ShowDDLLocksRequest) GetTask() string
func (*ShowDDLLocksRequest) Marshal ¶
func (m *ShowDDLLocksRequest) Marshal() (dAtA []byte, err error)
func (*ShowDDLLocksRequest) MarshalTo ¶
func (m *ShowDDLLocksRequest) MarshalTo(dAtA []byte) (int, error)
func (*ShowDDLLocksRequest) MarshalToSizedBuffer ¶
func (m *ShowDDLLocksRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ShowDDLLocksRequest) ProtoMessage ¶
func (*ShowDDLLocksRequest) ProtoMessage()
func (*ShowDDLLocksRequest) Reset ¶
func (m *ShowDDLLocksRequest) Reset()
func (*ShowDDLLocksRequest) Size ¶
func (m *ShowDDLLocksRequest) Size() (n int)
func (*ShowDDLLocksRequest) String ¶
func (m *ShowDDLLocksRequest) String() string
func (*ShowDDLLocksRequest) Unmarshal ¶
func (m *ShowDDLLocksRequest) Unmarshal(dAtA []byte) error
func (*ShowDDLLocksRequest) XXX_DiscardUnknown ¶
func (m *ShowDDLLocksRequest) XXX_DiscardUnknown()
func (*ShowDDLLocksRequest) XXX_Marshal ¶
func (m *ShowDDLLocksRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ShowDDLLocksRequest) XXX_Merge ¶
func (m *ShowDDLLocksRequest) XXX_Merge(src proto.Message)
func (*ShowDDLLocksRequest) XXX_Size ¶
func (m *ShowDDLLocksRequest) XXX_Size() int
func (*ShowDDLLocksRequest) XXX_Unmarshal ¶
func (m *ShowDDLLocksRequest) XXX_Unmarshal(b []byte) error
type ShowDDLLocksResponse ¶
type ShowDDLLocksResponse struct { Result bool `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"` Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"` Locks []*DDLLock `protobuf:"bytes,3,rep,name=locks,proto3" json:"locks,omitempty"` }
func (*ShowDDLLocksResponse) Descriptor ¶
func (*ShowDDLLocksResponse) Descriptor() ([]byte, []int)
func (*ShowDDLLocksResponse) GetLocks ¶
func (m *ShowDDLLocksResponse) GetLocks() []*DDLLock
func (*ShowDDLLocksResponse) GetMsg ¶
func (m *ShowDDLLocksResponse) GetMsg() string
func (*ShowDDLLocksResponse) GetResult ¶
func (m *ShowDDLLocksResponse) GetResult() bool
func (*ShowDDLLocksResponse) Marshal ¶
func (m *ShowDDLLocksResponse) Marshal() (dAtA []byte, err error)
func (*ShowDDLLocksResponse) MarshalTo ¶
func (m *ShowDDLLocksResponse) MarshalTo(dAtA []byte) (int, error)
func (*ShowDDLLocksResponse) MarshalToSizedBuffer ¶
func (m *ShowDDLLocksResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ShowDDLLocksResponse) ProtoMessage ¶
func (*ShowDDLLocksResponse) ProtoMessage()
func (*ShowDDLLocksResponse) Reset ¶
func (m *ShowDDLLocksResponse) Reset()
func (*ShowDDLLocksResponse) Size ¶
func (m *ShowDDLLocksResponse) Size() (n int)
func (*ShowDDLLocksResponse) String ¶
func (m *ShowDDLLocksResponse) String() string
func (*ShowDDLLocksResponse) Unmarshal ¶
func (m *ShowDDLLocksResponse) Unmarshal(dAtA []byte) error
func (*ShowDDLLocksResponse) XXX_DiscardUnknown ¶
func (m *ShowDDLLocksResponse) XXX_DiscardUnknown()
func (*ShowDDLLocksResponse) XXX_Marshal ¶
func (m *ShowDDLLocksResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ShowDDLLocksResponse) XXX_Merge ¶
func (m *ShowDDLLocksResponse) XXX_Merge(src proto.Message)
func (*ShowDDLLocksResponse) XXX_Size ¶
func (m *ShowDDLLocksResponse) XXX_Size() int
func (*ShowDDLLocksResponse) XXX_Unmarshal ¶
func (m *ShowDDLLocksResponse) XXX_Unmarshal(b []byte) error
type SourceError ¶
type SourceError struct { Source string `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"` Worker string `protobuf:"bytes,2,opt,name=worker,proto3" json:"worker,omitempty"` SourceError string `protobuf:"bytes,3,opt,name=SourceError,proto3" json:"SourceError,omitempty"` RelayError *RelayError `protobuf:"bytes,4,opt,name=RelayError,proto3" json:"RelayError,omitempty"` }
SourceError represents error for start/stop source on dm-worker
func (*SourceError) Descriptor ¶
func (*SourceError) Descriptor() ([]byte, []int)
func (*SourceError) GetRelayError ¶
func (m *SourceError) GetRelayError() *RelayError
func (*SourceError) GetSource ¶
func (m *SourceError) GetSource() string
func (*SourceError) GetSourceError ¶
func (m *SourceError) GetSourceError() string
func (*SourceError) GetWorker ¶
func (m *SourceError) GetWorker() string
func (*SourceError) Marshal ¶
func (m *SourceError) Marshal() (dAtA []byte, err error)
func (*SourceError) MarshalToSizedBuffer ¶
func (m *SourceError) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SourceError) ProtoMessage ¶
func (*SourceError) ProtoMessage()
func (*SourceError) Reset ¶
func (m *SourceError) Reset()
func (*SourceError) Size ¶
func (m *SourceError) Size() (n int)
func (*SourceError) String ¶
func (m *SourceError) String() string
func (*SourceError) Unmarshal ¶
func (m *SourceError) Unmarshal(dAtA []byte) error
func (*SourceError) XXX_DiscardUnknown ¶
func (m *SourceError) XXX_DiscardUnknown()
func (*SourceError) XXX_Marshal ¶
func (m *SourceError) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SourceError) XXX_Merge ¶
func (m *SourceError) XXX_Merge(src proto.Message)
func (*SourceError) XXX_Size ¶
func (m *SourceError) XXX_Size() int
func (*SourceError) XXX_Unmarshal ¶
func (m *SourceError) XXX_Unmarshal(b []byte) error
type SourceStatus ¶
type SourceStatus struct { Source string `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"` Worker string `protobuf:"bytes,2,opt,name=worker,proto3" json:"worker,omitempty"` Result *ProcessResult `protobuf:"bytes,3,opt,name=result,proto3" json:"result,omitempty"` RelayStatus *RelayStatus `protobuf:"bytes,4,opt,name=relayStatus,proto3" json:"relayStatus,omitempty"` }
SourceStatus represents status for source runing on dm-worker
func (*SourceStatus) Descriptor ¶
func (*SourceStatus) Descriptor() ([]byte, []int)
func (*SourceStatus) GetRelayStatus ¶
func (m *SourceStatus) GetRelayStatus() *RelayStatus
func (*SourceStatus) GetResult ¶
func (m *SourceStatus) GetResult() *ProcessResult
func (*SourceStatus) GetSource ¶
func (m *SourceStatus) GetSource() string
func (*SourceStatus) GetWorker ¶
func (m *SourceStatus) GetWorker() string
func (*SourceStatus) Marshal ¶
func (m *SourceStatus) Marshal() (dAtA []byte, err error)
func (*SourceStatus) MarshalToSizedBuffer ¶
func (m *SourceStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SourceStatus) ProtoMessage ¶
func (*SourceStatus) ProtoMessage()
func (*SourceStatus) Reset ¶
func (m *SourceStatus) Reset()
func (*SourceStatus) Size ¶
func (m *SourceStatus) Size() (n int)
func (*SourceStatus) String ¶
func (m *SourceStatus) String() string
func (*SourceStatus) Unmarshal ¶
func (m *SourceStatus) Unmarshal(dAtA []byte) error
func (*SourceStatus) XXX_DiscardUnknown ¶
func (m *SourceStatus) XXX_DiscardUnknown()
func (*SourceStatus) XXX_Marshal ¶
func (m *SourceStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SourceStatus) XXX_Merge ¶
func (m *SourceStatus) XXX_Merge(src proto.Message)
func (*SourceStatus) XXX_Size ¶
func (m *SourceStatus) XXX_Size() int
func (*SourceStatus) XXX_Unmarshal ¶
func (m *SourceStatus) XXX_Unmarshal(b []byte) error
type Stage ¶
type Stage int32
Stage represents current stage for a (sub) task a (sub) task should be always in one stage of the following stages (sub) task can transfer from on stage to some special other stages New: initial stage when a sub task is created
can not be transferred from other stages transfers to Running when initialize with no error
Running: indicates the sub task is processing
is transferred from New when created successfully is transferred from Paused when resuming is requested transfers to Paused when error occurred or requested from external transfers to Stopped when requested from external transfers to Finished when sub task processing completed (no Syncer used)
Paused: indicates the processing is paused, and can be resume from external request
is transferred from Running when error occurred or requested from external transfers to Running when resuming is requested from external transfers to Stopped when requested from external
Stopped: indicates the processing is stopped, and can not be resume (or re-run) again
is transferred from Running / Paused when requested from external can not transfer to any stages
Finished: indicates the processing is finished, and no need to re-run
is transferred from Running when processing completed should not transfer to any stages
func (Stage) EnumDescriptor ¶
type StartTaskRequest ¶
type StartTaskRequest struct { Task string `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"` Sources []string `protobuf:"bytes,2,rep,name=sources,proto3" json:"sources,omitempty"` RemoveMeta bool `protobuf:"varint,3,opt,name=removeMeta,proto3" json:"removeMeta,omitempty"` StartTime string `protobuf:"bytes,4,opt,name=startTime,proto3" json:"startTime,omitempty"` }
func (*StartTaskRequest) Descriptor ¶
func (*StartTaskRequest) Descriptor() ([]byte, []int)
func (*StartTaskRequest) GetRemoveMeta ¶
func (m *StartTaskRequest) GetRemoveMeta() bool
func (*StartTaskRequest) GetSources ¶
func (m *StartTaskRequest) GetSources() []string
func (*StartTaskRequest) GetStartTime ¶ added in v1.9.0
func (m *StartTaskRequest) GetStartTime() string
func (*StartTaskRequest) GetTask ¶
func (m *StartTaskRequest) GetTask() string
func (*StartTaskRequest) Marshal ¶
func (m *StartTaskRequest) Marshal() (dAtA []byte, err error)
func (*StartTaskRequest) MarshalToSizedBuffer ¶
func (m *StartTaskRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*StartTaskRequest) ProtoMessage ¶
func (*StartTaskRequest) ProtoMessage()
func (*StartTaskRequest) Reset ¶
func (m *StartTaskRequest) Reset()
func (*StartTaskRequest) Size ¶
func (m *StartTaskRequest) Size() (n int)
func (*StartTaskRequest) String ¶
func (m *StartTaskRequest) String() string
func (*StartTaskRequest) Unmarshal ¶
func (m *StartTaskRequest) Unmarshal(dAtA []byte) error
func (*StartTaskRequest) XXX_DiscardUnknown ¶
func (m *StartTaskRequest) XXX_DiscardUnknown()
func (*StartTaskRequest) XXX_Marshal ¶
func (m *StartTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StartTaskRequest) XXX_Merge ¶
func (m *StartTaskRequest) XXX_Merge(src proto.Message)
func (*StartTaskRequest) XXX_Size ¶
func (m *StartTaskRequest) XXX_Size() int
func (*StartTaskRequest) XXX_Unmarshal ¶
func (m *StartTaskRequest) XXX_Unmarshal(b []byte) error
type StartTaskResponse ¶
type StartTaskResponse struct { Result bool `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"` Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"` Sources []*CommonWorkerResponse `protobuf:"bytes,3,rep,name=sources,proto3" json:"sources,omitempty"` }
func (*StartTaskResponse) Descriptor ¶
func (*StartTaskResponse) Descriptor() ([]byte, []int)
func (*StartTaskResponse) GetMsg ¶
func (m *StartTaskResponse) GetMsg() string
func (*StartTaskResponse) GetResult ¶
func (m *StartTaskResponse) GetResult() bool
func (*StartTaskResponse) GetSources ¶
func (m *StartTaskResponse) GetSources() []*CommonWorkerResponse
func (*StartTaskResponse) Marshal ¶
func (m *StartTaskResponse) Marshal() (dAtA []byte, err error)
func (*StartTaskResponse) MarshalTo ¶
func (m *StartTaskResponse) MarshalTo(dAtA []byte) (int, error)
func (*StartTaskResponse) MarshalToSizedBuffer ¶
func (m *StartTaskResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*StartTaskResponse) ProtoMessage ¶
func (*StartTaskResponse) ProtoMessage()
func (*StartTaskResponse) Reset ¶
func (m *StartTaskResponse) Reset()
func (*StartTaskResponse) Size ¶
func (m *StartTaskResponse) Size() (n int)
func (*StartTaskResponse) String ¶
func (m *StartTaskResponse) String() string
func (*StartTaskResponse) Unmarshal ¶
func (m *StartTaskResponse) Unmarshal(dAtA []byte) error
func (*StartTaskResponse) XXX_DiscardUnknown ¶
func (m *StartTaskResponse) XXX_DiscardUnknown()
func (*StartTaskResponse) XXX_Marshal ¶
func (m *StartTaskResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StartTaskResponse) XXX_Merge ¶
func (m *StartTaskResponse) XXX_Merge(src proto.Message)
func (*StartTaskResponse) XXX_Size ¶
func (m *StartTaskResponse) XXX_Size() int
func (*StartTaskResponse) XXX_Unmarshal ¶
func (m *StartTaskResponse) XXX_Unmarshal(b []byte) error
type SubTaskError ¶
type SubTaskError struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Stage Stage `protobuf:"varint,2,opt,name=stage,proto3,enum=pb.Stage" json:"stage,omitempty"` Unit UnitType `protobuf:"varint,3,opt,name=unit,proto3,enum=pb.UnitType" json:"unit,omitempty"` // Types that are valid to be assigned to Error: // *SubTaskError_Msg // *SubTaskError_Check // *SubTaskError_Dump // *SubTaskError_Load // *SubTaskError_Sync Error isSubTaskError_Error `protobuf_oneof:"error"` }
SubTaskError represents error for a sub task during running name: sub task'name, when starting a sub task the name should be unique stage: sub task's current stage unit: sub task's current dm unit's UnitType error: current unit's error information
for Sync, includes failed sql, failed sql pos in binlog, etc.
func (*SubTaskError) Descriptor ¶
func (*SubTaskError) Descriptor() ([]byte, []int)
func (*SubTaskError) GetCheck ¶
func (m *SubTaskError) GetCheck() *CheckError
func (*SubTaskError) GetDump ¶
func (m *SubTaskError) GetDump() *DumpError
func (*SubTaskError) GetError ¶
func (m *SubTaskError) GetError() isSubTaskError_Error
func (*SubTaskError) GetLoad ¶
func (m *SubTaskError) GetLoad() *LoadError
func (*SubTaskError) GetMsg ¶
func (m *SubTaskError) GetMsg() string
func (*SubTaskError) GetName ¶
func (m *SubTaskError) GetName() string
func (*SubTaskError) GetStage ¶
func (m *SubTaskError) GetStage() Stage
func (*SubTaskError) GetSync ¶
func (m *SubTaskError) GetSync() *SyncError
func (*SubTaskError) GetUnit ¶
func (m *SubTaskError) GetUnit() UnitType
func (*SubTaskError) Marshal ¶
func (m *SubTaskError) Marshal() (dAtA []byte, err error)
func (*SubTaskError) MarshalToSizedBuffer ¶
func (m *SubTaskError) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SubTaskError) ProtoMessage ¶
func (*SubTaskError) ProtoMessage()
func (*SubTaskError) Reset ¶
func (m *SubTaskError) Reset()
func (*SubTaskError) Size ¶
func (m *SubTaskError) Size() (n int)
func (*SubTaskError) String ¶
func (m *SubTaskError) String() string
func (*SubTaskError) Unmarshal ¶
func (m *SubTaskError) Unmarshal(dAtA []byte) error
func (*SubTaskError) XXX_DiscardUnknown ¶
func (m *SubTaskError) XXX_DiscardUnknown()
func (*SubTaskError) XXX_Marshal ¶
func (m *SubTaskError) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SubTaskError) XXX_Merge ¶
func (m *SubTaskError) XXX_Merge(src proto.Message)
func (*SubTaskError) XXX_OneofWrappers ¶
func (*SubTaskError) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*SubTaskError) XXX_Size ¶
func (m *SubTaskError) XXX_Size() int
func (*SubTaskError) XXX_Unmarshal ¶
func (m *SubTaskError) XXX_Unmarshal(b []byte) error
type SubTaskErrorList ¶
type SubTaskErrorList struct {
Error []*SubTaskError `protobuf:"bytes,1,rep,name=error,proto3" json:"error,omitempty"`
}
SubTaskErrorList used for internal jsonpb marshal
func (*SubTaskErrorList) Descriptor ¶
func (*SubTaskErrorList) Descriptor() ([]byte, []int)
func (*SubTaskErrorList) GetError ¶
func (m *SubTaskErrorList) GetError() []*SubTaskError
func (*SubTaskErrorList) Marshal ¶
func (m *SubTaskErrorList) Marshal() (dAtA []byte, err error)
func (*SubTaskErrorList) MarshalToSizedBuffer ¶
func (m *SubTaskErrorList) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SubTaskErrorList) ProtoMessage ¶
func (*SubTaskErrorList) ProtoMessage()
func (*SubTaskErrorList) Reset ¶
func (m *SubTaskErrorList) Reset()
func (*SubTaskErrorList) Size ¶
func (m *SubTaskErrorList) Size() (n int)
func (*SubTaskErrorList) String ¶
func (m *SubTaskErrorList) String() string
func (*SubTaskErrorList) Unmarshal ¶
func (m *SubTaskErrorList) Unmarshal(dAtA []byte) error
func (*SubTaskErrorList) XXX_DiscardUnknown ¶
func (m *SubTaskErrorList) XXX_DiscardUnknown()
func (*SubTaskErrorList) XXX_Marshal ¶
func (m *SubTaskErrorList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SubTaskErrorList) XXX_Merge ¶
func (m *SubTaskErrorList) XXX_Merge(src proto.Message)
func (*SubTaskErrorList) XXX_Size ¶
func (m *SubTaskErrorList) XXX_Size() int
func (*SubTaskErrorList) XXX_Unmarshal ¶
func (m *SubTaskErrorList) XXX_Unmarshal(b []byte) error
type SubTaskError_Check ¶
type SubTaskError_Check struct {
Check *CheckError `protobuf:"bytes,5,opt,name=check,proto3,oneof" json:"check,omitempty"`
}
func (*SubTaskError_Check) MarshalTo ¶
func (m *SubTaskError_Check) MarshalTo(dAtA []byte) (int, error)
func (*SubTaskError_Check) MarshalToSizedBuffer ¶
func (m *SubTaskError_Check) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SubTaskError_Check) Size ¶
func (m *SubTaskError_Check) Size() (n int)
type SubTaskError_Dump ¶
type SubTaskError_Dump struct {
Dump *DumpError `protobuf:"bytes,6,opt,name=dump,proto3,oneof" json:"dump,omitempty"`
}
func (*SubTaskError_Dump) MarshalTo ¶
func (m *SubTaskError_Dump) MarshalTo(dAtA []byte) (int, error)
func (*SubTaskError_Dump) MarshalToSizedBuffer ¶
func (m *SubTaskError_Dump) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SubTaskError_Dump) Size ¶
func (m *SubTaskError_Dump) Size() (n int)
type SubTaskError_Load ¶
type SubTaskError_Load struct {
Load *LoadError `protobuf:"bytes,7,opt,name=load,proto3,oneof" json:"load,omitempty"`
}
func (*SubTaskError_Load) MarshalTo ¶
func (m *SubTaskError_Load) MarshalTo(dAtA []byte) (int, error)
func (*SubTaskError_Load) MarshalToSizedBuffer ¶
func (m *SubTaskError_Load) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SubTaskError_Load) Size ¶
func (m *SubTaskError_Load) Size() (n int)
type SubTaskError_Msg ¶
type SubTaskError_Msg struct {
Msg string `protobuf:"bytes,4,opt,name=msg,proto3,oneof" json:"msg,omitempty"`
}
func (*SubTaskError_Msg) MarshalToSizedBuffer ¶
func (m *SubTaskError_Msg) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SubTaskError_Msg) Size ¶
func (m *SubTaskError_Msg) Size() (n int)
type SubTaskError_Sync ¶
type SubTaskError_Sync struct {
Sync *SyncError `protobuf:"bytes,8,opt,name=sync,proto3,oneof" json:"sync,omitempty"`
}
func (*SubTaskError_Sync) MarshalTo ¶
func (m *SubTaskError_Sync) MarshalTo(dAtA []byte) (int, error)
func (*SubTaskError_Sync) MarshalToSizedBuffer ¶
func (m *SubTaskError_Sync) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SubTaskError_Sync) Size ¶
func (m *SubTaskError_Sync) Size() (n int)
type SubTaskStatus ¶
type SubTaskStatus struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Stage Stage `protobuf:"varint,2,opt,name=stage,proto3,enum=pb.Stage" json:"stage,omitempty"` Unit UnitType `protobuf:"varint,3,opt,name=unit,proto3,enum=pb.UnitType" json:"unit,omitempty"` Result *ProcessResult `protobuf:"bytes,4,opt,name=result,proto3" json:"result,omitempty"` UnresolvedDDLLockID string `protobuf:"bytes,5,opt,name=unresolvedDDLLockID,proto3" json:"unresolvedDDLLockID,omitempty"` // Types that are valid to be assigned to Status: // *SubTaskStatus_Msg // *SubTaskStatus_Check // *SubTaskStatus_Dump // *SubTaskStatus_Load // *SubTaskStatus_Sync Status isSubTaskStatus_Status `protobuf_oneof:"status"` }
SubTaskStatus represents status for a sub task name: sub task'name, when starting a sub task the name should be unique stage: sub task's current stage unit: sub task's current dm unit's UnitType result: current unit's process result, when the stage is Running, no result unresolvedDDLLockID: un-resolved sharding DDL lock ID (ref DDLLockInfo)
if needed, we can put this to SyncStatus
status: current unit's statistics
for Load, includes total bytes, progress, etc. for Sync, includes TPS, binlog meta, etc.
func (*SubTaskStatus) Descriptor ¶
func (*SubTaskStatus) Descriptor() ([]byte, []int)
func (*SubTaskStatus) GetCheck ¶
func (m *SubTaskStatus) GetCheck() *CheckStatus
func (*SubTaskStatus) GetDump ¶
func (m *SubTaskStatus) GetDump() *DumpStatus
func (*SubTaskStatus) GetLoad ¶
func (m *SubTaskStatus) GetLoad() *LoadStatus
func (*SubTaskStatus) GetMsg ¶
func (m *SubTaskStatus) GetMsg() string
func (*SubTaskStatus) GetName ¶
func (m *SubTaskStatus) GetName() string
func (*SubTaskStatus) GetResult ¶
func (m *SubTaskStatus) GetResult() *ProcessResult
func (*SubTaskStatus) GetStage ¶
func (m *SubTaskStatus) GetStage() Stage
func (*SubTaskStatus) GetStatus ¶
func (m *SubTaskStatus) GetStatus() isSubTaskStatus_Status
func (*SubTaskStatus) GetSync ¶
func (m *SubTaskStatus) GetSync() *SyncStatus
func (*SubTaskStatus) GetUnit ¶
func (m *SubTaskStatus) GetUnit() UnitType
func (*SubTaskStatus) GetUnresolvedDDLLockID ¶
func (m *SubTaskStatus) GetUnresolvedDDLLockID() string
func (*SubTaskStatus) Marshal ¶
func (m *SubTaskStatus) Marshal() (dAtA []byte, err error)
func (*SubTaskStatus) MarshalToSizedBuffer ¶
func (m *SubTaskStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SubTaskStatus) ProtoMessage ¶
func (*SubTaskStatus) ProtoMessage()
func (*SubTaskStatus) Reset ¶
func (m *SubTaskStatus) Reset()
func (*SubTaskStatus) Size ¶
func (m *SubTaskStatus) Size() (n int)
func (*SubTaskStatus) String ¶
func (m *SubTaskStatus) String() string
func (*SubTaskStatus) Unmarshal ¶
func (m *SubTaskStatus) Unmarshal(dAtA []byte) error
func (*SubTaskStatus) XXX_DiscardUnknown ¶
func (m *SubTaskStatus) XXX_DiscardUnknown()
func (*SubTaskStatus) XXX_Marshal ¶
func (m *SubTaskStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SubTaskStatus) XXX_Merge ¶
func (m *SubTaskStatus) XXX_Merge(src proto.Message)
func (*SubTaskStatus) XXX_OneofWrappers ¶
func (*SubTaskStatus) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*SubTaskStatus) XXX_Size ¶
func (m *SubTaskStatus) XXX_Size() int
func (*SubTaskStatus) XXX_Unmarshal ¶
func (m *SubTaskStatus) XXX_Unmarshal(b []byte) error
type SubTaskStatusList ¶
type SubTaskStatusList struct {
Status []*SubTaskStatus `protobuf:"bytes,1,rep,name=status,proto3" json:"status,omitempty"`
}
SubTaskStatusList used for internal jsonpb marshal
func (*SubTaskStatusList) Descriptor ¶
func (*SubTaskStatusList) Descriptor() ([]byte, []int)
func (*SubTaskStatusList) GetStatus ¶
func (m *SubTaskStatusList) GetStatus() []*SubTaskStatus
func (*SubTaskStatusList) Marshal ¶
func (m *SubTaskStatusList) Marshal() (dAtA []byte, err error)
func (*SubTaskStatusList) MarshalTo ¶
func (m *SubTaskStatusList) MarshalTo(dAtA []byte) (int, error)
func (*SubTaskStatusList) MarshalToSizedBuffer ¶
func (m *SubTaskStatusList) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SubTaskStatusList) ProtoMessage ¶
func (*SubTaskStatusList) ProtoMessage()
func (*SubTaskStatusList) Reset ¶
func (m *SubTaskStatusList) Reset()
func (*SubTaskStatusList) Size ¶
func (m *SubTaskStatusList) Size() (n int)
func (*SubTaskStatusList) String ¶
func (m *SubTaskStatusList) String() string
func (*SubTaskStatusList) Unmarshal ¶
func (m *SubTaskStatusList) Unmarshal(dAtA []byte) error
func (*SubTaskStatusList) XXX_DiscardUnknown ¶
func (m *SubTaskStatusList) XXX_DiscardUnknown()
func (*SubTaskStatusList) XXX_Marshal ¶
func (m *SubTaskStatusList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SubTaskStatusList) XXX_Merge ¶
func (m *SubTaskStatusList) XXX_Merge(src proto.Message)
func (*SubTaskStatusList) XXX_Size ¶
func (m *SubTaskStatusList) XXX_Size() int
func (*SubTaskStatusList) XXX_Unmarshal ¶
func (m *SubTaskStatusList) XXX_Unmarshal(b []byte) error
type SubTaskStatus_Check ¶
type SubTaskStatus_Check struct {
Check *CheckStatus `protobuf:"bytes,7,opt,name=check,proto3,oneof" json:"check,omitempty"`
}
func (*SubTaskStatus_Check) MarshalTo ¶
func (m *SubTaskStatus_Check) MarshalTo(dAtA []byte) (int, error)
func (*SubTaskStatus_Check) MarshalToSizedBuffer ¶
func (m *SubTaskStatus_Check) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SubTaskStatus_Check) Size ¶
func (m *SubTaskStatus_Check) Size() (n int)
type SubTaskStatus_Dump ¶
type SubTaskStatus_Dump struct {
Dump *DumpStatus `protobuf:"bytes,8,opt,name=dump,proto3,oneof" json:"dump,omitempty"`
}
func (*SubTaskStatus_Dump) MarshalTo ¶
func (m *SubTaskStatus_Dump) MarshalTo(dAtA []byte) (int, error)
func (*SubTaskStatus_Dump) MarshalToSizedBuffer ¶
func (m *SubTaskStatus_Dump) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SubTaskStatus_Dump) Size ¶
func (m *SubTaskStatus_Dump) Size() (n int)
type SubTaskStatus_Load ¶
type SubTaskStatus_Load struct {
Load *LoadStatus `protobuf:"bytes,9,opt,name=load,proto3,oneof" json:"load,omitempty"`
}
func (*SubTaskStatus_Load) MarshalTo ¶
func (m *SubTaskStatus_Load) MarshalTo(dAtA []byte) (int, error)
func (*SubTaskStatus_Load) MarshalToSizedBuffer ¶
func (m *SubTaskStatus_Load) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SubTaskStatus_Load) Size ¶
func (m *SubTaskStatus_Load) Size() (n int)
type SubTaskStatus_Msg ¶
type SubTaskStatus_Msg struct {
Msg string `protobuf:"bytes,6,opt,name=msg,proto3,oneof" json:"msg,omitempty"`
}
func (*SubTaskStatus_Msg) MarshalTo ¶
func (m *SubTaskStatus_Msg) MarshalTo(dAtA []byte) (int, error)
func (*SubTaskStatus_Msg) MarshalToSizedBuffer ¶
func (m *SubTaskStatus_Msg) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SubTaskStatus_Msg) Size ¶
func (m *SubTaskStatus_Msg) Size() (n int)
type SubTaskStatus_Sync ¶
type SubTaskStatus_Sync struct {
Sync *SyncStatus `protobuf:"bytes,10,opt,name=sync,proto3,oneof" json:"sync,omitempty"`
}
func (*SubTaskStatus_Sync) MarshalTo ¶
func (m *SubTaskStatus_Sync) MarshalTo(dAtA []byte) (int, error)
func (*SubTaskStatus_Sync) MarshalToSizedBuffer ¶
func (m *SubTaskStatus_Sync) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SubTaskStatus_Sync) Size ¶
func (m *SubTaskStatus_Sync) Size() (n int)
type SyncError ¶
type SyncError struct {
Errors []*SyncSQLError `protobuf:"bytes,1,rep,name=errors,proto3" json:"errors,omitempty"`
}
SyncError represents error list for sync unit
func (*SyncError) Descriptor ¶
func (*SyncError) GetErrors ¶
func (m *SyncError) GetErrors() []*SyncSQLError
func (*SyncError) MarshalToSizedBuffer ¶
func (*SyncError) ProtoMessage ¶
func (*SyncError) ProtoMessage()
func (*SyncError) XXX_DiscardUnknown ¶
func (m *SyncError) XXX_DiscardUnknown()
func (*SyncError) XXX_Marshal ¶
func (*SyncError) XXX_Unmarshal ¶
type SyncSQLError ¶
type SyncSQLError struct { Msg string `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"` FailedBinlogPosition string `protobuf:"bytes,2,opt,name=failedBinlogPosition,proto3" json:"failedBinlogPosition,omitempty"` ErrorSQL string `protobuf:"bytes,3,opt,name=errorSQL,proto3" json:"errorSQL,omitempty"` }
SyncSQLError represents a sql error in sync unit
func (*SyncSQLError) Descriptor ¶
func (*SyncSQLError) Descriptor() ([]byte, []int)
func (*SyncSQLError) GetErrorSQL ¶
func (m *SyncSQLError) GetErrorSQL() string
func (*SyncSQLError) GetFailedBinlogPosition ¶
func (m *SyncSQLError) GetFailedBinlogPosition() string
func (*SyncSQLError) GetMsg ¶
func (m *SyncSQLError) GetMsg() string
func (*SyncSQLError) Marshal ¶
func (m *SyncSQLError) Marshal() (dAtA []byte, err error)
func (*SyncSQLError) MarshalToSizedBuffer ¶
func (m *SyncSQLError) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SyncSQLError) ProtoMessage ¶
func (*SyncSQLError) ProtoMessage()
func (*SyncSQLError) Reset ¶
func (m *SyncSQLError) Reset()
func (*SyncSQLError) Size ¶
func (m *SyncSQLError) Size() (n int)
func (*SyncSQLError) String ¶
func (m *SyncSQLError) String() string
func (*SyncSQLError) Unmarshal ¶
func (m *SyncSQLError) Unmarshal(dAtA []byte) error
func (*SyncSQLError) XXX_DiscardUnknown ¶
func (m *SyncSQLError) XXX_DiscardUnknown()
func (*SyncSQLError) XXX_Marshal ¶
func (m *SyncSQLError) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SyncSQLError) XXX_Merge ¶
func (m *SyncSQLError) XXX_Merge(src proto.Message)
func (*SyncSQLError) XXX_Size ¶
func (m *SyncSQLError) XXX_Size() int
func (*SyncSQLError) XXX_Unmarshal ¶
func (m *SyncSQLError) XXX_Unmarshal(b []byte) error
type SyncStatus ¶
type SyncStatus struct { TotalEvents int64 `protobuf:"varint,1,opt,name=totalEvents,proto3" json:"totalEvents,omitempty"` TotalTps int64 `protobuf:"varint,2,opt,name=totalTps,proto3" json:"totalTps,omitempty"` RecentTps int64 `protobuf:"varint,3,opt,name=recentTps,proto3" json:"recentTps,omitempty"` MasterBinlog string `protobuf:"bytes,4,opt,name=masterBinlog,proto3" json:"masterBinlog,omitempty"` MasterBinlogGtid string `protobuf:"bytes,5,opt,name=masterBinlogGtid,proto3" json:"masterBinlogGtid,omitempty"` SyncerBinlog string `protobuf:"bytes,6,opt,name=syncerBinlog,proto3" json:"syncerBinlog,omitempty"` SyncerBinlogGtid string `protobuf:"bytes,7,opt,name=syncerBinlogGtid,proto3" json:"syncerBinlogGtid,omitempty"` BlockingDDLs []string `protobuf:"bytes,8,rep,name=blockingDDLs,proto3" json:"blockingDDLs,omitempty"` UnresolvedGroups []*ShardingGroup `protobuf:"bytes,9,rep,name=unresolvedGroups,proto3" json:"unresolvedGroups,omitempty"` Synced bool `protobuf:"varint,10,opt,name=synced,proto3" json:"synced,omitempty"` BinlogType string `protobuf:"bytes,11,opt,name=binlogType,proto3" json:"binlogType,omitempty"` SecondsBehindMaster int64 `protobuf:"varint,12,opt,name=secondsBehindMaster,proto3" json:"secondsBehindMaster,omitempty"` }
SyncStatus represents status for sync unit
func (*SyncStatus) Descriptor ¶
func (*SyncStatus) Descriptor() ([]byte, []int)
func (*SyncStatus) GetBinlogType ¶
func (m *SyncStatus) GetBinlogType() string
func (*SyncStatus) GetBlockingDDLs ¶
func (m *SyncStatus) GetBlockingDDLs() []string
func (*SyncStatus) GetMasterBinlog ¶
func (m *SyncStatus) GetMasterBinlog() string
func (*SyncStatus) GetMasterBinlogGtid ¶
func (m *SyncStatus) GetMasterBinlogGtid() string
func (*SyncStatus) GetRecentTps ¶
func (m *SyncStatus) GetRecentTps() int64
func (*SyncStatus) GetSecondsBehindMaster ¶ added in v1.9.0
func (m *SyncStatus) GetSecondsBehindMaster() int64
func (*SyncStatus) GetSynced ¶
func (m *SyncStatus) GetSynced() bool
func (*SyncStatus) GetSyncerBinlog ¶
func (m *SyncStatus) GetSyncerBinlog() string
func (*SyncStatus) GetSyncerBinlogGtid ¶
func (m *SyncStatus) GetSyncerBinlogGtid() string
func (*SyncStatus) GetTotalEvents ¶
func (m *SyncStatus) GetTotalEvents() int64
func (*SyncStatus) GetTotalTps ¶
func (m *SyncStatus) GetTotalTps() int64
func (*SyncStatus) GetUnresolvedGroups ¶
func (m *SyncStatus) GetUnresolvedGroups() []*ShardingGroup
func (*SyncStatus) Marshal ¶
func (m *SyncStatus) Marshal() (dAtA []byte, err error)
func (*SyncStatus) MarshalToSizedBuffer ¶
func (m *SyncStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SyncStatus) ProtoMessage ¶
func (*SyncStatus) ProtoMessage()
func (*SyncStatus) Reset ¶
func (m *SyncStatus) Reset()
func (*SyncStatus) Size ¶
func (m *SyncStatus) Size() (n int)
func (*SyncStatus) String ¶
func (m *SyncStatus) String() string
func (*SyncStatus) Unmarshal ¶
func (m *SyncStatus) Unmarshal(dAtA []byte) error
func (*SyncStatus) XXX_DiscardUnknown ¶
func (m *SyncStatus) XXX_DiscardUnknown()
func (*SyncStatus) XXX_Marshal ¶
func (m *SyncStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SyncStatus) XXX_Merge ¶
func (m *SyncStatus) XXX_Merge(src proto.Message)
func (*SyncStatus) XXX_Size ¶
func (m *SyncStatus) XXX_Size() int
func (*SyncStatus) XXX_Unmarshal ¶
func (m *SyncStatus) XXX_Unmarshal(b []byte) error
type TransferSourceRequest ¶ added in v1.9.0
type TransferSourceRequest struct { Source string `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"` Worker string `protobuf:"bytes,2,opt,name=worker,proto3" json:"worker,omitempty"` }
func (*TransferSourceRequest) Descriptor ¶ added in v1.9.0
func (*TransferSourceRequest) Descriptor() ([]byte, []int)
func (*TransferSourceRequest) GetSource ¶ added in v1.9.0
func (m *TransferSourceRequest) GetSource() string
func (*TransferSourceRequest) GetWorker ¶ added in v1.9.0
func (m *TransferSourceRequest) GetWorker() string
func (*TransferSourceRequest) Marshal ¶ added in v1.9.0
func (m *TransferSourceRequest) Marshal() (dAtA []byte, err error)
func (*TransferSourceRequest) MarshalTo ¶ added in v1.9.0
func (m *TransferSourceRequest) MarshalTo(dAtA []byte) (int, error)
func (*TransferSourceRequest) MarshalToSizedBuffer ¶ added in v1.9.0
func (m *TransferSourceRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*TransferSourceRequest) ProtoMessage ¶ added in v1.9.0
func (*TransferSourceRequest) ProtoMessage()
func (*TransferSourceRequest) Reset ¶ added in v1.9.0
func (m *TransferSourceRequest) Reset()
func (*TransferSourceRequest) Size ¶ added in v1.9.0
func (m *TransferSourceRequest) Size() (n int)
func (*TransferSourceRequest) String ¶ added in v1.9.0
func (m *TransferSourceRequest) String() string
func (*TransferSourceRequest) Unmarshal ¶ added in v1.9.0
func (m *TransferSourceRequest) Unmarshal(dAtA []byte) error
func (*TransferSourceRequest) XXX_DiscardUnknown ¶ added in v1.9.0
func (m *TransferSourceRequest) XXX_DiscardUnknown()
func (*TransferSourceRequest) XXX_Marshal ¶ added in v1.9.0
func (m *TransferSourceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TransferSourceRequest) XXX_Merge ¶ added in v1.9.0
func (m *TransferSourceRequest) XXX_Merge(src proto.Message)
func (*TransferSourceRequest) XXX_Size ¶ added in v1.9.0
func (m *TransferSourceRequest) XXX_Size() int
func (*TransferSourceRequest) XXX_Unmarshal ¶ added in v1.9.0
func (m *TransferSourceRequest) XXX_Unmarshal(b []byte) error
type TransferSourceResponse ¶ added in v1.9.0
type TransferSourceResponse struct { Result bool `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"` Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"` }
func (*TransferSourceResponse) Descriptor ¶ added in v1.9.0
func (*TransferSourceResponse) Descriptor() ([]byte, []int)
func (*TransferSourceResponse) GetMsg ¶ added in v1.9.0
func (m *TransferSourceResponse) GetMsg() string
func (*TransferSourceResponse) GetResult ¶ added in v1.9.0
func (m *TransferSourceResponse) GetResult() bool
func (*TransferSourceResponse) Marshal ¶ added in v1.9.0
func (m *TransferSourceResponse) Marshal() (dAtA []byte, err error)
func (*TransferSourceResponse) MarshalTo ¶ added in v1.9.0
func (m *TransferSourceResponse) MarshalTo(dAtA []byte) (int, error)
func (*TransferSourceResponse) MarshalToSizedBuffer ¶ added in v1.9.0
func (m *TransferSourceResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*TransferSourceResponse) ProtoMessage ¶ added in v1.9.0
func (*TransferSourceResponse) ProtoMessage()
func (*TransferSourceResponse) Reset ¶ added in v1.9.0
func (m *TransferSourceResponse) Reset()
func (*TransferSourceResponse) Size ¶ added in v1.9.0
func (m *TransferSourceResponse) Size() (n int)
func (*TransferSourceResponse) String ¶ added in v1.9.0
func (m *TransferSourceResponse) String() string
func (*TransferSourceResponse) Unmarshal ¶ added in v1.9.0
func (m *TransferSourceResponse) Unmarshal(dAtA []byte) error
func (*TransferSourceResponse) XXX_DiscardUnknown ¶ added in v1.9.0
func (m *TransferSourceResponse) XXX_DiscardUnknown()
func (*TransferSourceResponse) XXX_Marshal ¶ added in v1.9.0
func (m *TransferSourceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TransferSourceResponse) XXX_Merge ¶ added in v1.9.0
func (m *TransferSourceResponse) XXX_Merge(src proto.Message)
func (*TransferSourceResponse) XXX_Size ¶ added in v1.9.0
func (m *TransferSourceResponse) XXX_Size() int
func (*TransferSourceResponse) XXX_Unmarshal ¶ added in v1.9.0
func (m *TransferSourceResponse) XXX_Unmarshal(b []byte) error
type UnimplementedMasterServer ¶
type UnimplementedMasterServer struct { }
UnimplementedMasterServer can be embedded to have forward compatible implementations.
func (*UnimplementedMasterServer) CheckTask ¶
func (*UnimplementedMasterServer) CheckTask(ctx context.Context, req *CheckTaskRequest) (*CheckTaskResponse, error)
func (*UnimplementedMasterServer) GetCfg ¶
func (*UnimplementedMasterServer) GetCfg(ctx context.Context, req *GetCfgRequest) (*GetCfgResponse, error)
func (*UnimplementedMasterServer) GetMasterCfg ¶
func (*UnimplementedMasterServer) GetMasterCfg(ctx context.Context, req *GetMasterCfgRequest) (*GetMasterCfgResponse, error)
func (*UnimplementedMasterServer) GetSubTaskCfg ¶
func (*UnimplementedMasterServer) GetSubTaskCfg(ctx context.Context, req *GetSubTaskCfgRequest) (*GetSubTaskCfgResponse, error)
func (*UnimplementedMasterServer) HandleError ¶
func (*UnimplementedMasterServer) HandleError(ctx context.Context, req *HandleErrorRequest) (*HandleErrorResponse, error)
func (*UnimplementedMasterServer) ListMember ¶
func (*UnimplementedMasterServer) ListMember(ctx context.Context, req *ListMemberRequest) (*ListMemberResponse, error)
func (*UnimplementedMasterServer) OfflineMember ¶
func (*UnimplementedMasterServer) OfflineMember(ctx context.Context, req *OfflineMemberRequest) (*OfflineMemberResponse, error)
func (*UnimplementedMasterServer) OperateLeader ¶
func (*UnimplementedMasterServer) OperateLeader(ctx context.Context, req *OperateLeaderRequest) (*OperateLeaderResponse, error)
func (*UnimplementedMasterServer) OperateRelay ¶ added in v1.9.0
func (*UnimplementedMasterServer) OperateRelay(ctx context.Context, req *OperateRelayRequest) (*OperateRelayResponse, error)
func (*UnimplementedMasterServer) OperateSchema ¶
func (*UnimplementedMasterServer) OperateSchema(ctx context.Context, req *OperateSchemaRequest) (*OperateSchemaResponse, error)
func (*UnimplementedMasterServer) OperateSource ¶
func (*UnimplementedMasterServer) OperateSource(ctx context.Context, req *OperateSourceRequest) (*OperateSourceResponse, error)
func (*UnimplementedMasterServer) OperateTask ¶
func (*UnimplementedMasterServer) OperateTask(ctx context.Context, req *OperateTaskRequest) (*OperateTaskResponse, error)
func (*UnimplementedMasterServer) OperateWorkerRelayTask ¶
func (*UnimplementedMasterServer) OperateWorkerRelayTask(ctx context.Context, req *OperateWorkerRelayRequest) (*OperateWorkerRelayResponse, error)
func (*UnimplementedMasterServer) PurgeWorkerRelay ¶
func (*UnimplementedMasterServer) PurgeWorkerRelay(ctx context.Context, req *PurgeWorkerRelayRequest) (*PurgeWorkerRelayResponse, error)
func (*UnimplementedMasterServer) QueryStatus ¶
func (*UnimplementedMasterServer) QueryStatus(ctx context.Context, req *QueryStatusListRequest) (*QueryStatusListResponse, error)
func (*UnimplementedMasterServer) RegisterWorker ¶
func (*UnimplementedMasterServer) RegisterWorker(ctx context.Context, req *RegisterWorkerRequest) (*RegisterWorkerResponse, error)
func (*UnimplementedMasterServer) ShowDDLLocks ¶
func (*UnimplementedMasterServer) ShowDDLLocks(ctx context.Context, req *ShowDDLLocksRequest) (*ShowDDLLocksResponse, error)
func (*UnimplementedMasterServer) StartTask ¶
func (*UnimplementedMasterServer) StartTask(ctx context.Context, req *StartTaskRequest) (*StartTaskResponse, error)
func (*UnimplementedMasterServer) TransferSource ¶ added in v1.9.0
func (*UnimplementedMasterServer) TransferSource(ctx context.Context, req *TransferSourceRequest) (*TransferSourceResponse, error)
func (*UnimplementedMasterServer) UnlockDDLLock ¶
func (*UnimplementedMasterServer) UnlockDDLLock(ctx context.Context, req *UnlockDDLLockRequest) (*UnlockDDLLockResponse, error)
func (*UnimplementedMasterServer) UpdateTask ¶
func (*UnimplementedMasterServer) UpdateTask(ctx context.Context, req *UpdateTaskRequest) (*UpdateTaskResponse, error)
type UnimplementedWorkerServer ¶
type UnimplementedWorkerServer struct { }
UnimplementedWorkerServer can be embedded to have forward compatible implementations.
func (*UnimplementedWorkerServer) GetWorkerCfg ¶
func (*UnimplementedWorkerServer) GetWorkerCfg(ctx context.Context, req *GetWorkerCfgRequest) (*GetWorkerCfgResponse, error)
func (*UnimplementedWorkerServer) HandleError ¶
func (*UnimplementedWorkerServer) HandleError(ctx context.Context, req *HandleWorkerErrorRequest) (*CommonWorkerResponse, error)
func (*UnimplementedWorkerServer) OperateSchema ¶
func (*UnimplementedWorkerServer) OperateSchema(ctx context.Context, req *OperateWorkerSchemaRequest) (*CommonWorkerResponse, error)
func (*UnimplementedWorkerServer) OperateV1Meta ¶
func (*UnimplementedWorkerServer) OperateV1Meta(ctx context.Context, req *OperateV1MetaRequest) (*OperateV1MetaResponse, error)
func (*UnimplementedWorkerServer) PurgeRelay ¶
func (*UnimplementedWorkerServer) PurgeRelay(ctx context.Context, req *PurgeRelayRequest) (*CommonWorkerResponse, error)
func (*UnimplementedWorkerServer) QueryStatus ¶
func (*UnimplementedWorkerServer) QueryStatus(ctx context.Context, req *QueryStatusRequest) (*QueryStatusResponse, error)
type UnitType ¶
type UnitType int32
UnitType represents the dm unit's type
func (UnitType) EnumDescriptor ¶
type UnlockDDLLockRequest ¶
type UnlockDDLLockRequest struct { ID string `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"` ReplaceOwner string `protobuf:"bytes,2,opt,name=replaceOwner,proto3" json:"replaceOwner,omitempty"` ForceRemove bool `protobuf:"varint,3,opt,name=forceRemove,proto3" json:"forceRemove,omitempty"` }
UnlockDDLLockRequest used to unlock (resolve) DDL lock manually ID: DDL lock ID replaceOwner: dm-worker used to replace the original DDL lock's owner forceRemove: force to remove the DDL lock even fail to execute the DDL for the owner.
func (*UnlockDDLLockRequest) Descriptor ¶
func (*UnlockDDLLockRequest) Descriptor() ([]byte, []int)
func (*UnlockDDLLockRequest) GetForceRemove ¶
func (m *UnlockDDLLockRequest) GetForceRemove() bool
func (*UnlockDDLLockRequest) GetID ¶
func (m *UnlockDDLLockRequest) GetID() string
func (*UnlockDDLLockRequest) GetReplaceOwner ¶
func (m *UnlockDDLLockRequest) GetReplaceOwner() string
func (*UnlockDDLLockRequest) Marshal ¶
func (m *UnlockDDLLockRequest) Marshal() (dAtA []byte, err error)
func (*UnlockDDLLockRequest) MarshalTo ¶
func (m *UnlockDDLLockRequest) MarshalTo(dAtA []byte) (int, error)
func (*UnlockDDLLockRequest) MarshalToSizedBuffer ¶
func (m *UnlockDDLLockRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*UnlockDDLLockRequest) ProtoMessage ¶
func (*UnlockDDLLockRequest) ProtoMessage()
func (*UnlockDDLLockRequest) Reset ¶
func (m *UnlockDDLLockRequest) Reset()
func (*UnlockDDLLockRequest) Size ¶
func (m *UnlockDDLLockRequest) Size() (n int)
func (*UnlockDDLLockRequest) String ¶
func (m *UnlockDDLLockRequest) String() string
func (*UnlockDDLLockRequest) Unmarshal ¶
func (m *UnlockDDLLockRequest) Unmarshal(dAtA []byte) error
func (*UnlockDDLLockRequest) XXX_DiscardUnknown ¶
func (m *UnlockDDLLockRequest) XXX_DiscardUnknown()
func (*UnlockDDLLockRequest) XXX_Marshal ¶
func (m *UnlockDDLLockRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*UnlockDDLLockRequest) XXX_Merge ¶
func (m *UnlockDDLLockRequest) XXX_Merge(src proto.Message)
func (*UnlockDDLLockRequest) XXX_Size ¶
func (m *UnlockDDLLockRequest) XXX_Size() int
func (*UnlockDDLLockRequest) XXX_Unmarshal ¶
func (m *UnlockDDLLockRequest) XXX_Unmarshal(b []byte) error
type UnlockDDLLockResponse ¶
type UnlockDDLLockResponse struct { Result bool `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"` Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"` }
func (*UnlockDDLLockResponse) Descriptor ¶
func (*UnlockDDLLockResponse) Descriptor() ([]byte, []int)
func (*UnlockDDLLockResponse) GetMsg ¶
func (m *UnlockDDLLockResponse) GetMsg() string
func (*UnlockDDLLockResponse) GetResult ¶
func (m *UnlockDDLLockResponse) GetResult() bool
func (*UnlockDDLLockResponse) Marshal ¶
func (m *UnlockDDLLockResponse) Marshal() (dAtA []byte, err error)
func (*UnlockDDLLockResponse) MarshalTo ¶
func (m *UnlockDDLLockResponse) MarshalTo(dAtA []byte) (int, error)
func (*UnlockDDLLockResponse) MarshalToSizedBuffer ¶
func (m *UnlockDDLLockResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*UnlockDDLLockResponse) ProtoMessage ¶
func (*UnlockDDLLockResponse) ProtoMessage()
func (*UnlockDDLLockResponse) Reset ¶
func (m *UnlockDDLLockResponse) Reset()
func (*UnlockDDLLockResponse) Size ¶
func (m *UnlockDDLLockResponse) Size() (n int)
func (*UnlockDDLLockResponse) String ¶
func (m *UnlockDDLLockResponse) String() string
func (*UnlockDDLLockResponse) Unmarshal ¶
func (m *UnlockDDLLockResponse) Unmarshal(dAtA []byte) error
func (*UnlockDDLLockResponse) XXX_DiscardUnknown ¶
func (m *UnlockDDLLockResponse) XXX_DiscardUnknown()
func (*UnlockDDLLockResponse) XXX_Marshal ¶
func (m *UnlockDDLLockResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*UnlockDDLLockResponse) XXX_Merge ¶
func (m *UnlockDDLLockResponse) XXX_Merge(src proto.Message)
func (*UnlockDDLLockResponse) XXX_Size ¶
func (m *UnlockDDLLockResponse) XXX_Size() int
func (*UnlockDDLLockResponse) XXX_Unmarshal ¶
func (m *UnlockDDLLockResponse) XXX_Unmarshal(b []byte) error
type UpdateTaskRequest ¶
type UpdateTaskRequest struct { Task string `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"` Sources []string `protobuf:"bytes,2,rep,name=sources,proto3" json:"sources,omitempty"` }
UpdateTaskRequest used to update task after it has beed started task: task's configuration, yaml format
now, only support to update config for routes, filters, column-mappings, block-allow-list support update partial config for syncer, loader, etc later
sources need to do update, empty for all sources in processing the task
func (*UpdateTaskRequest) Descriptor ¶
func (*UpdateTaskRequest) Descriptor() ([]byte, []int)
func (*UpdateTaskRequest) GetSources ¶
func (m *UpdateTaskRequest) GetSources() []string
func (*UpdateTaskRequest) GetTask ¶
func (m *UpdateTaskRequest) GetTask() string
func (*UpdateTaskRequest) Marshal ¶
func (m *UpdateTaskRequest) Marshal() (dAtA []byte, err error)
func (*UpdateTaskRequest) MarshalTo ¶
func (m *UpdateTaskRequest) MarshalTo(dAtA []byte) (int, error)
func (*UpdateTaskRequest) MarshalToSizedBuffer ¶
func (m *UpdateTaskRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*UpdateTaskRequest) ProtoMessage ¶
func (*UpdateTaskRequest) ProtoMessage()
func (*UpdateTaskRequest) Reset ¶
func (m *UpdateTaskRequest) Reset()
func (*UpdateTaskRequest) Size ¶
func (m *UpdateTaskRequest) Size() (n int)
func (*UpdateTaskRequest) String ¶
func (m *UpdateTaskRequest) String() string
func (*UpdateTaskRequest) Unmarshal ¶
func (m *UpdateTaskRequest) Unmarshal(dAtA []byte) error
func (*UpdateTaskRequest) XXX_DiscardUnknown ¶
func (m *UpdateTaskRequest) XXX_DiscardUnknown()
func (*UpdateTaskRequest) XXX_Marshal ¶
func (m *UpdateTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*UpdateTaskRequest) XXX_Merge ¶
func (m *UpdateTaskRequest) XXX_Merge(src proto.Message)
func (*UpdateTaskRequest) XXX_Size ¶
func (m *UpdateTaskRequest) XXX_Size() int
func (*UpdateTaskRequest) XXX_Unmarshal ¶
func (m *UpdateTaskRequest) XXX_Unmarshal(b []byte) error
type UpdateTaskResponse ¶
type UpdateTaskResponse struct { Result bool `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"` Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"` Sources []*CommonWorkerResponse `protobuf:"bytes,3,rep,name=sources,proto3" json:"sources,omitempty"` }
func (*UpdateTaskResponse) Descriptor ¶
func (*UpdateTaskResponse) Descriptor() ([]byte, []int)
func (*UpdateTaskResponse) GetMsg ¶
func (m *UpdateTaskResponse) GetMsg() string
func (*UpdateTaskResponse) GetResult ¶
func (m *UpdateTaskResponse) GetResult() bool
func (*UpdateTaskResponse) GetSources ¶
func (m *UpdateTaskResponse) GetSources() []*CommonWorkerResponse
func (*UpdateTaskResponse) Marshal ¶
func (m *UpdateTaskResponse) Marshal() (dAtA []byte, err error)
func (*UpdateTaskResponse) MarshalTo ¶
func (m *UpdateTaskResponse) MarshalTo(dAtA []byte) (int, error)
func (*UpdateTaskResponse) MarshalToSizedBuffer ¶
func (m *UpdateTaskResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*UpdateTaskResponse) ProtoMessage ¶
func (*UpdateTaskResponse) ProtoMessage()
func (*UpdateTaskResponse) Reset ¶
func (m *UpdateTaskResponse) Reset()
func (*UpdateTaskResponse) Size ¶
func (m *UpdateTaskResponse) Size() (n int)
func (*UpdateTaskResponse) String ¶
func (m *UpdateTaskResponse) String() string
func (*UpdateTaskResponse) Unmarshal ¶
func (m *UpdateTaskResponse) Unmarshal(dAtA []byte) error
func (*UpdateTaskResponse) XXX_DiscardUnknown ¶
func (m *UpdateTaskResponse) XXX_DiscardUnknown()
func (*UpdateTaskResponse) XXX_Marshal ¶
func (m *UpdateTaskResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*UpdateTaskResponse) XXX_Merge ¶
func (m *UpdateTaskResponse) XXX_Merge(src proto.Message)
func (*UpdateTaskResponse) XXX_Size ¶
func (m *UpdateTaskResponse) XXX_Size() int
func (*UpdateTaskResponse) XXX_Unmarshal ¶
func (m *UpdateTaskResponse) XXX_Unmarshal(b []byte) error
type V1SubTaskMeta ¶
type V1SubTaskMeta struct { Op TaskOp `protobuf:"varint,1,opt,name=op,proto3,enum=pb.TaskOp" json:"op,omitempty"` Stage Stage `protobuf:"varint,2,opt,name=stage,proto3,enum=pb.Stage" json:"stage,omitempty"` Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"` Task []byte `protobuf:"bytes,4,opt,name=task,proto3" json:"task,omitempty"` }
copied `TaskMeta` from release-1.0 branch.
func (*V1SubTaskMeta) Descriptor ¶
func (*V1SubTaskMeta) Descriptor() ([]byte, []int)
func (*V1SubTaskMeta) GetName ¶
func (m *V1SubTaskMeta) GetName() string
func (*V1SubTaskMeta) GetOp ¶
func (m *V1SubTaskMeta) GetOp() TaskOp
func (*V1SubTaskMeta) GetStage ¶
func (m *V1SubTaskMeta) GetStage() Stage
func (*V1SubTaskMeta) GetTask ¶
func (m *V1SubTaskMeta) GetTask() []byte
func (*V1SubTaskMeta) Marshal ¶
func (m *V1SubTaskMeta) Marshal() (dAtA []byte, err error)
func (*V1SubTaskMeta) MarshalToSizedBuffer ¶
func (m *V1SubTaskMeta) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*V1SubTaskMeta) ProtoMessage ¶
func (*V1SubTaskMeta) ProtoMessage()
func (*V1SubTaskMeta) Reset ¶
func (m *V1SubTaskMeta) Reset()
func (*V1SubTaskMeta) Size ¶
func (m *V1SubTaskMeta) Size() (n int)
func (*V1SubTaskMeta) String ¶
func (m *V1SubTaskMeta) String() string
func (*V1SubTaskMeta) Unmarshal ¶
func (m *V1SubTaskMeta) Unmarshal(dAtA []byte) error
func (*V1SubTaskMeta) XXX_DiscardUnknown ¶
func (m *V1SubTaskMeta) XXX_DiscardUnknown()
func (*V1SubTaskMeta) XXX_Marshal ¶
func (m *V1SubTaskMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*V1SubTaskMeta) XXX_Merge ¶
func (m *V1SubTaskMeta) XXX_Merge(src proto.Message)
func (*V1SubTaskMeta) XXX_Size ¶
func (m *V1SubTaskMeta) XXX_Size() int
func (*V1SubTaskMeta) XXX_Unmarshal ¶
func (m *V1SubTaskMeta) XXX_Unmarshal(b []byte) error
type WorkerClient ¶
type WorkerClient interface { QueryStatus(ctx context.Context, in *QueryStatusRequest, opts ...grpc.CallOption) (*QueryStatusResponse, error) // PurgeRelay purges relay log files for this dm-worker PurgeRelay(ctx context.Context, in *PurgeRelayRequest, opts ...grpc.CallOption) (*CommonWorkerResponse, error) // Operate (get/set/remove) schema for a specified table in tracker. // a `set`/`remove` operation should be an one-time operation (only take effect once), // so we use a gRPC method rather than a etcd operation now (no persistent operation state). OperateSchema(ctx context.Context, in *OperateWorkerSchemaRequest, opts ...grpc.CallOption) (*CommonWorkerResponse, error) OperateV1Meta(ctx context.Context, in *OperateV1MetaRequest, opts ...grpc.CallOption) (*OperateV1MetaResponse, error) HandleError(ctx context.Context, in *HandleWorkerErrorRequest, opts ...grpc.CallOption) (*CommonWorkerResponse, error) GetWorkerCfg(ctx context.Context, in *GetWorkerCfgRequest, opts ...grpc.CallOption) (*GetWorkerCfgResponse, error) }
WorkerClient is the client API for Worker service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewWorkerClient ¶
func NewWorkerClient(cc *grpc.ClientConn) WorkerClient
type WorkerInfo ¶
type WorkerInfo struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Addr string `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"` Stage string `protobuf:"bytes,3,opt,name=stage,proto3" json:"stage,omitempty"` Source string `protobuf:"bytes,4,opt,name=source,proto3" json:"source,omitempty"` }
func (*WorkerInfo) Descriptor ¶
func (*WorkerInfo) Descriptor() ([]byte, []int)
func (*WorkerInfo) GetAddr ¶
func (m *WorkerInfo) GetAddr() string
func (*WorkerInfo) GetName ¶
func (m *WorkerInfo) GetName() string
func (*WorkerInfo) GetSource ¶
func (m *WorkerInfo) GetSource() string
func (*WorkerInfo) GetStage ¶
func (m *WorkerInfo) GetStage() string
func (*WorkerInfo) Marshal ¶
func (m *WorkerInfo) Marshal() (dAtA []byte, err error)
func (*WorkerInfo) MarshalToSizedBuffer ¶
func (m *WorkerInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*WorkerInfo) ProtoMessage ¶
func (*WorkerInfo) ProtoMessage()
func (*WorkerInfo) Reset ¶
func (m *WorkerInfo) Reset()
func (*WorkerInfo) Size ¶
func (m *WorkerInfo) Size() (n int)
func (*WorkerInfo) String ¶
func (m *WorkerInfo) String() string
func (*WorkerInfo) Unmarshal ¶
func (m *WorkerInfo) Unmarshal(dAtA []byte) error
func (*WorkerInfo) XXX_DiscardUnknown ¶
func (m *WorkerInfo) XXX_DiscardUnknown()
func (*WorkerInfo) XXX_Marshal ¶
func (m *WorkerInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*WorkerInfo) XXX_Merge ¶
func (m *WorkerInfo) XXX_Merge(src proto.Message)
func (*WorkerInfo) XXX_Size ¶
func (m *WorkerInfo) XXX_Size() int
func (*WorkerInfo) XXX_Unmarshal ¶
func (m *WorkerInfo) XXX_Unmarshal(b []byte) error
type WorkerServer ¶
type WorkerServer interface { QueryStatus(context.Context, *QueryStatusRequest) (*QueryStatusResponse, error) // PurgeRelay purges relay log files for this dm-worker PurgeRelay(context.Context, *PurgeRelayRequest) (*CommonWorkerResponse, error) // Operate (get/set/remove) schema for a specified table in tracker. // a `set`/`remove` operation should be an one-time operation (only take effect once), // so we use a gRPC method rather than a etcd operation now (no persistent operation state). OperateSchema(context.Context, *OperateWorkerSchemaRequest) (*CommonWorkerResponse, error) OperateV1Meta(context.Context, *OperateV1MetaRequest) (*OperateV1MetaResponse, error) HandleError(context.Context, *HandleWorkerErrorRequest) (*CommonWorkerResponse, error) GetWorkerCfg(context.Context, *GetWorkerCfgRequest) (*GetWorkerCfgResponse, error) }
WorkerServer is the server API for Worker service.