dmpb

package
v0.0.6 Latest Latest
Warning

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

Go to latest
Published: Aug 5, 2023 License: Apache-2.0 Imports: 16 Imported by: 0

README

This package is imported from DM.

Documentation

Overview

Package pb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthDmmaster        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowDmmaster          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupDmmaster = fmt.Errorf("proto: unexpected end of group")
)
View Source
var (
	ErrInvalidLengthDmworker        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowDmworker          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupDmworker = fmt.Errorf("proto: unexpected end of group")
)
View Source
var CfgType_name = map[int32]string{
	0: "InvalidType",
	1: "TaskType",
	2: "MasterType",
	3: "WorkerType",
	4: "SourceType",
}
View Source
var CfgType_value = map[string]int32{
	"InvalidType": 0,
	"TaskType":    1,
	"MasterType":  2,
	"WorkerType":  3,
	"SourceType":  4,
}
View Source
var ErrorOp_name = map[int32]string{
	0: "InvalidErrorOp",
	1: "Skip",
	2: "Replace",
	3: "Revert",
}
View Source
var ErrorOp_value = map[string]int32{
	"InvalidErrorOp": 0,
	"Skip":           1,
	"Replace":        2,
	"Revert":         3,
}
View Source
var LeaderOp_name = map[int32]string{
	0: "InvalidLeaderOp",
	1: "EvictLeaderOp",
	2: "CancelEvictLeaderOp",
}
View Source
var LeaderOp_value = map[string]int32{
	"InvalidLeaderOp":     0,
	"EvictLeaderOp":       1,
	"CancelEvictLeaderOp": 2,
}
View Source
var RelayOp_name = map[int32]string{
	0: "InvalidRelayOp",
	1: "StopRelay",
	2: "PauseRelay",
	3: "ResumeRelay",
}
View Source
var RelayOp_value = map[string]int32{
	"InvalidRelayOp": 0,
	"StopRelay":      1,
	"PauseRelay":     2,
	"ResumeRelay":    3,
}
View Source
var SchemaOp_name = map[int32]string{
	0: "InvalidSchemaOp",
	1: "GetSchema",
	2: "SetSchema",
	3: "RemoveSchema",
}
View Source
var SchemaOp_value = map[string]int32{
	"InvalidSchemaOp": 0,
	"GetSchema":       1,
	"SetSchema":       2,
	"RemoveSchema":    3,
}
View Source
var SourceOp_name = map[int32]string{
	0: "InvalidSourceOp",
	1: "StartSource",
	2: "UpdateSource",
	3: "StopSource",
	4: "ShowSource",
}
View Source
var SourceOp_value = map[string]int32{
	"InvalidSourceOp": 0,
	"StartSource":     1,
	"UpdateSource":    2,
	"StopSource":      3,
	"ShowSource":      4,
}
View Source
var Stage_name = map[int32]string{
	0: "InvalidStage",
	1: "New",
	2: "Running",
	3: "Paused",
	4: "Stopped",
	5: "Finished",
	6: "Pausing",
	7: "Resuming",
}
View Source
var Stage_value = map[string]int32{
	"InvalidStage": 0,
	"New":          1,
	"Running":      2,
	"Paused":       3,
	"Stopped":      4,
	"Finished":     5,
	"Pausing":      6,
	"Resuming":     7,
}
View Source
var TaskOp_name = map[int32]string{
	0: "InvalidOp",
	1: "Stop",
	2: "Pause",
	3: "Resume",
	4: "Start",
	5: "Update",
	6: "AutoResume",
}
View Source
var TaskOp_value = map[string]int32{
	"InvalidOp":  0,
	"Stop":       1,
	"Pause":      2,
	"Resume":     3,
	"Start":      4,
	"Update":     5,
	"AutoResume": 6,
}
View Source
var UnitType_name = map[int32]string{
	0:   "InvalidUnit",
	1:   "Check",
	2:   "Dump",
	3:   "Load",
	4:   "Sync",
	100: "Relay",
}
View Source
var UnitType_value = map[string]int32{
	"InvalidUnit": 0,
	"Check":       1,
	"Dump":        2,
	"Load":        3,
	"Sync":        4,
	"Relay":       100,
}
View Source
var V1MetaOp_name = map[int32]string{
	0: "InvalidV1MetaOp",
	1: "GetV1Meta",
	2: "RemoveV1Meta",
}
View Source
var V1MetaOp_value = map[string]int32{
	"InvalidV1MetaOp": 0,
	"GetV1Meta":       1,
	"RemoveV1Meta":    2,
}

Functions

func RegisterMasterHandler

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

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

func RegisterMasterHandlerClient

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

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

func RegisterMasterHandlerFromEndpoint

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

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

func RegisterMasterHandlerServer

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

RegisterMasterHandlerServer registers the http handlers for service Master to "mux". UnaryRPC :call MasterServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.

func RegisterMasterServer

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

func RegisterWorkerServer

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

Types

type CfgType

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

func (CfgType) EnumDescriptor

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

func (CfgType) String

func (x CfgType) String() string

type CheckError

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

CheckError represents error for check unit adds fields later

func (*CheckError) Descriptor

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

func (*CheckError) GetMsg

func (m *CheckError) GetMsg() string

func (*CheckError) Marshal

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

func (*CheckError) MarshalTo

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

func (*CheckError) MarshalToSizedBuffer

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

func (*CheckError) ProtoMessage

func (*CheckError) ProtoMessage()

func (*CheckError) Reset

func (m *CheckError) Reset()

func (*CheckError) Size

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

func (*CheckError) String

func (m *CheckError) String() string

func (*CheckError) Unmarshal

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

func (*CheckError) XXX_DiscardUnknown

func (m *CheckError) XXX_DiscardUnknown()

func (*CheckError) XXX_Marshal

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

func (*CheckError) XXX_Merge

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

func (*CheckError) XXX_Size

func (m *CheckError) XXX_Size() int

func (*CheckError) XXX_Unmarshal

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

type CheckStatus

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

CheckStatus represents status for check unit adds fields later

func (*CheckStatus) Descriptor

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

func (*CheckStatus) GetDetail

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

func (*CheckStatus) GetFailed

func (m *CheckStatus) GetFailed() int32

func (*CheckStatus) GetPassed

func (m *CheckStatus) GetPassed() bool

func (*CheckStatus) GetSuccessful

func (m *CheckStatus) GetSuccessful() int32

func (*CheckStatus) GetTotal

func (m *CheckStatus) GetTotal() int32

func (*CheckStatus) GetWarning

func (m *CheckStatus) GetWarning() int32

func (*CheckStatus) Marshal

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

func (*CheckStatus) MarshalTo

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

func (*CheckStatus) MarshalToSizedBuffer

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

func (*CheckStatus) ProtoMessage

func (*CheckStatus) ProtoMessage()

func (*CheckStatus) Reset

func (m *CheckStatus) Reset()

func (*CheckStatus) Size

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

func (*CheckStatus) String

func (m *CheckStatus) String() string

func (*CheckStatus) Unmarshal

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

func (*CheckStatus) XXX_DiscardUnknown

func (m *CheckStatus) XXX_DiscardUnknown()

func (*CheckStatus) XXX_Marshal

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

func (*CheckStatus) XXX_Merge

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

func (*CheckStatus) XXX_Size

func (m *CheckStatus) XXX_Size() int

func (*CheckStatus) XXX_Unmarshal

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

type CheckTaskRequest

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

func (*CheckTaskRequest) Descriptor

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

func (*CheckTaskRequest) GetTask

func (m *CheckTaskRequest) GetTask() string

func (*CheckTaskRequest) Marshal

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

func (*CheckTaskRequest) MarshalTo

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

func (*CheckTaskRequest) MarshalToSizedBuffer

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

func (*CheckTaskRequest) ProtoMessage

func (*CheckTaskRequest) ProtoMessage()

func (*CheckTaskRequest) Reset

func (m *CheckTaskRequest) Reset()

func (*CheckTaskRequest) Size

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

func (*CheckTaskRequest) String

func (m *CheckTaskRequest) String() string

func (*CheckTaskRequest) Unmarshal

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

func (*CheckTaskRequest) XXX_DiscardUnknown

func (m *CheckTaskRequest) XXX_DiscardUnknown()

func (*CheckTaskRequest) XXX_Marshal

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

func (*CheckTaskRequest) XXX_Merge

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

func (*CheckTaskRequest) XXX_Size

func (m *CheckTaskRequest) XXX_Size() int

func (*CheckTaskRequest) XXX_Unmarshal

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

type CheckTaskResponse

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

func (*CheckTaskResponse) Descriptor

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

func (*CheckTaskResponse) GetMsg

func (m *CheckTaskResponse) GetMsg() string

func (*CheckTaskResponse) GetResult

func (m *CheckTaskResponse) GetResult() bool

func (*CheckTaskResponse) Marshal

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

func (*CheckTaskResponse) MarshalTo

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

func (*CheckTaskResponse) MarshalToSizedBuffer

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

func (*CheckTaskResponse) ProtoMessage

func (*CheckTaskResponse) ProtoMessage()

func (*CheckTaskResponse) Reset

func (m *CheckTaskResponse) Reset()

func (*CheckTaskResponse) Size

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

func (*CheckTaskResponse) String

func (m *CheckTaskResponse) String() string

func (*CheckTaskResponse) Unmarshal

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

func (*CheckTaskResponse) XXX_DiscardUnknown

func (m *CheckTaskResponse) XXX_DiscardUnknown()

func (*CheckTaskResponse) XXX_Marshal

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

func (*CheckTaskResponse) XXX_Merge

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

func (*CheckTaskResponse) XXX_Size

func (m *CheckTaskResponse) XXX_Size() int

func (*CheckTaskResponse) XXX_Unmarshal

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

type CommonWorkerResponse

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

func (*CommonWorkerResponse) Descriptor

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

func (*CommonWorkerResponse) GetMsg

func (m *CommonWorkerResponse) GetMsg() string

func (*CommonWorkerResponse) GetResult

func (m *CommonWorkerResponse) GetResult() bool

func (*CommonWorkerResponse) GetSource

func (m *CommonWorkerResponse) GetSource() string

func (*CommonWorkerResponse) GetWorker

func (m *CommonWorkerResponse) GetWorker() string

func (*CommonWorkerResponse) Marshal

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

func (*CommonWorkerResponse) MarshalTo

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

func (*CommonWorkerResponse) MarshalToSizedBuffer

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

func (*CommonWorkerResponse) ProtoMessage

func (*CommonWorkerResponse) ProtoMessage()

func (*CommonWorkerResponse) Reset

func (m *CommonWorkerResponse) Reset()

func (*CommonWorkerResponse) Size

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

func (*CommonWorkerResponse) String

func (m *CommonWorkerResponse) String() string

func (*CommonWorkerResponse) Unmarshal

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

func (*CommonWorkerResponse) XXX_DiscardUnknown

func (m *CommonWorkerResponse) XXX_DiscardUnknown()

func (*CommonWorkerResponse) XXX_Marshal

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

func (*CommonWorkerResponse) XXX_Merge

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

func (*CommonWorkerResponse) XXX_Size

func (m *CommonWorkerResponse) XXX_Size() int

func (*CommonWorkerResponse) XXX_Unmarshal

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

type DDLLock

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

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

func (*DDLLock) Descriptor

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

func (*DDLLock) GetDDLs

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

func (*DDLLock) GetID

func (m *DDLLock) GetID() string

func (*DDLLock) GetMode

func (m *DDLLock) GetMode() string

func (*DDLLock) GetOwner

func (m *DDLLock) GetOwner() string

func (*DDLLock) GetSynced

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

func (*DDLLock) GetTask

func (m *DDLLock) GetTask() string

func (*DDLLock) GetUnsynced

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

func (*DDLLock) Marshal

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

func (*DDLLock) MarshalTo

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

func (*DDLLock) MarshalToSizedBuffer

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

func (*DDLLock) ProtoMessage

func (*DDLLock) ProtoMessage()

func (*DDLLock) Reset

func (m *DDLLock) Reset()

func (*DDLLock) Size

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

func (*DDLLock) String

func (m *DDLLock) String() string

func (*DDLLock) Unmarshal

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

func (*DDLLock) XXX_DiscardUnknown

func (m *DDLLock) XXX_DiscardUnknown()

func (*DDLLock) XXX_Marshal

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

func (*DDLLock) XXX_Merge

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

func (*DDLLock) XXX_Size

func (m *DDLLock) XXX_Size() int

func (*DDLLock) XXX_Unmarshal

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

type DumpError

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

DumpError represents error for dump unit add fields later

func (*DumpError) Descriptor

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

func (*DumpError) GetMsg

func (m *DumpError) GetMsg() string

func (*DumpError) Marshal

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

func (*DumpError) MarshalTo

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

func (*DumpError) MarshalToSizedBuffer

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

func (*DumpError) ProtoMessage

func (*DumpError) ProtoMessage()

func (*DumpError) Reset

func (m *DumpError) Reset()

func (*DumpError) Size

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

func (*DumpError) String

func (m *DumpError) String() string

func (*DumpError) Unmarshal

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

func (*DumpError) XXX_DiscardUnknown

func (m *DumpError) XXX_DiscardUnknown()

func (*DumpError) XXX_Marshal

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

func (*DumpError) XXX_Merge

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

func (*DumpError) XXX_Size

func (m *DumpError) XXX_Size() int

func (*DumpError) XXX_Unmarshal

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

type DumpStatus

type DumpStatus struct {
}

DumpStatus represents status for dump unit add fields later

func (*DumpStatus) Descriptor

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

func (*DumpStatus) Marshal

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

func (*DumpStatus) MarshalTo

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

func (*DumpStatus) MarshalToSizedBuffer

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

func (*DumpStatus) ProtoMessage

func (*DumpStatus) ProtoMessage()

func (*DumpStatus) Reset

func (m *DumpStatus) Reset()

func (*DumpStatus) Size

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

func (*DumpStatus) String

func (m *DumpStatus) String() string

func (*DumpStatus) Unmarshal

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

func (*DumpStatus) XXX_DiscardUnknown

func (m *DumpStatus) XXX_DiscardUnknown()

func (*DumpStatus) XXX_Marshal

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

func (*DumpStatus) XXX_Merge

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

func (*DumpStatus) XXX_Size

func (m *DumpStatus) XXX_Size() int

func (*DumpStatus) XXX_Unmarshal

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

type ErrorOp

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

func (ErrorOp) EnumDescriptor

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

func (ErrorOp) String

func (x ErrorOp) String() string

type GetCfgRequest

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

func (*GetCfgRequest) Descriptor

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

func (*GetCfgRequest) GetName

func (m *GetCfgRequest) GetName() string

func (*GetCfgRequest) GetType

func (m *GetCfgRequest) GetType() CfgType

func (*GetCfgRequest) Marshal

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

func (*GetCfgRequest) MarshalTo

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

func (*GetCfgRequest) MarshalToSizedBuffer

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

func (*GetCfgRequest) ProtoMessage

func (*GetCfgRequest) ProtoMessage()

func (*GetCfgRequest) Reset

func (m *GetCfgRequest) Reset()

func (*GetCfgRequest) Size

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

func (*GetCfgRequest) String

func (m *GetCfgRequest) String() string

func (*GetCfgRequest) Unmarshal

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

func (*GetCfgRequest) XXX_DiscardUnknown

func (m *GetCfgRequest) XXX_DiscardUnknown()

func (*GetCfgRequest) XXX_Marshal

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

func (*GetCfgRequest) XXX_Merge

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

func (*GetCfgRequest) XXX_Size

func (m *GetCfgRequest) XXX_Size() int

func (*GetCfgRequest) XXX_Unmarshal

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

type GetCfgResponse

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

func (*GetCfgResponse) Descriptor

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

func (*GetCfgResponse) GetCfg

func (m *GetCfgResponse) GetCfg() string

func (*GetCfgResponse) GetMsg

func (m *GetCfgResponse) GetMsg() string

func (*GetCfgResponse) GetResult

func (m *GetCfgResponse) GetResult() bool

func (*GetCfgResponse) Marshal

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

func (*GetCfgResponse) MarshalTo

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

func (*GetCfgResponse) MarshalToSizedBuffer

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

func (*GetCfgResponse) ProtoMessage

func (*GetCfgResponse) ProtoMessage()

func (*GetCfgResponse) Reset

func (m *GetCfgResponse) Reset()

func (*GetCfgResponse) Size

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

func (*GetCfgResponse) String

func (m *GetCfgResponse) String() string

func (*GetCfgResponse) Unmarshal

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

func (*GetCfgResponse) XXX_DiscardUnknown

func (m *GetCfgResponse) XXX_DiscardUnknown()

func (*GetCfgResponse) XXX_Marshal

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

func (*GetCfgResponse) XXX_Merge

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

func (*GetCfgResponse) XXX_Size

func (m *GetCfgResponse) XXX_Size() int

func (*GetCfgResponse) XXX_Unmarshal

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

type GetMasterCfgRequest

type GetMasterCfgRequest struct {
}

func (*GetMasterCfgRequest) Descriptor

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

func (*GetMasterCfgRequest) Marshal

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

func (*GetMasterCfgRequest) MarshalTo

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

func (*GetMasterCfgRequest) MarshalToSizedBuffer

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

func (*GetMasterCfgRequest) ProtoMessage

func (*GetMasterCfgRequest) ProtoMessage()

func (*GetMasterCfgRequest) Reset

func (m *GetMasterCfgRequest) Reset()

func (*GetMasterCfgRequest) Size

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

func (*GetMasterCfgRequest) String

func (m *GetMasterCfgRequest) String() string

func (*GetMasterCfgRequest) Unmarshal

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

func (*GetMasterCfgRequest) XXX_DiscardUnknown

func (m *GetMasterCfgRequest) XXX_DiscardUnknown()

func (*GetMasterCfgRequest) XXX_Marshal

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

func (*GetMasterCfgRequest) XXX_Merge

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

func (*GetMasterCfgRequest) XXX_Size

func (m *GetMasterCfgRequest) XXX_Size() int

func (*GetMasterCfgRequest) XXX_Unmarshal

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

type GetMasterCfgResponse

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

func (*GetMasterCfgResponse) Descriptor

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

func (*GetMasterCfgResponse) GetCfg

func (m *GetMasterCfgResponse) GetCfg() string

func (*GetMasterCfgResponse) Marshal

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

func (*GetMasterCfgResponse) MarshalTo

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

func (*GetMasterCfgResponse) MarshalToSizedBuffer

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

func (*GetMasterCfgResponse) ProtoMessage

func (*GetMasterCfgResponse) ProtoMessage()

func (*GetMasterCfgResponse) Reset

func (m *GetMasterCfgResponse) Reset()

func (*GetMasterCfgResponse) Size

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

func (*GetMasterCfgResponse) String

func (m *GetMasterCfgResponse) String() string

func (*GetMasterCfgResponse) Unmarshal

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

func (*GetMasterCfgResponse) XXX_DiscardUnknown

func (m *GetMasterCfgResponse) XXX_DiscardUnknown()

func (*GetMasterCfgResponse) XXX_Marshal

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

func (*GetMasterCfgResponse) XXX_Merge

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

func (*GetMasterCfgResponse) XXX_Size

func (m *GetMasterCfgResponse) XXX_Size() int

func (*GetMasterCfgResponse) XXX_Unmarshal

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

type GetSubTaskCfgRequest

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

func (*GetSubTaskCfgRequest) Descriptor

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

func (*GetSubTaskCfgRequest) GetName

func (m *GetSubTaskCfgRequest) GetName() string

func (*GetSubTaskCfgRequest) Marshal

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

func (*GetSubTaskCfgRequest) MarshalTo

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

func (*GetSubTaskCfgRequest) MarshalToSizedBuffer

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

func (*GetSubTaskCfgRequest) ProtoMessage

func (*GetSubTaskCfgRequest) ProtoMessage()

func (*GetSubTaskCfgRequest) Reset

func (m *GetSubTaskCfgRequest) Reset()

func (*GetSubTaskCfgRequest) Size

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

func (*GetSubTaskCfgRequest) String

func (m *GetSubTaskCfgRequest) String() string

func (*GetSubTaskCfgRequest) Unmarshal

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

func (*GetSubTaskCfgRequest) XXX_DiscardUnknown

func (m *GetSubTaskCfgRequest) XXX_DiscardUnknown()

func (*GetSubTaskCfgRequest) XXX_Marshal

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

func (*GetSubTaskCfgRequest) XXX_Merge

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

func (*GetSubTaskCfgRequest) XXX_Size

func (m *GetSubTaskCfgRequest) XXX_Size() int

func (*GetSubTaskCfgRequest) XXX_Unmarshal

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

type GetSubTaskCfgResponse

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

func (*GetSubTaskCfgResponse) Descriptor

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

func (*GetSubTaskCfgResponse) GetCfgs

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

func (*GetSubTaskCfgResponse) GetMsg

func (m *GetSubTaskCfgResponse) GetMsg() string

func (*GetSubTaskCfgResponse) GetResult

func (m *GetSubTaskCfgResponse) GetResult() bool

func (*GetSubTaskCfgResponse) Marshal

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

func (*GetSubTaskCfgResponse) MarshalTo

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

func (*GetSubTaskCfgResponse) MarshalToSizedBuffer

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

func (*GetSubTaskCfgResponse) ProtoMessage

func (*GetSubTaskCfgResponse) ProtoMessage()

func (*GetSubTaskCfgResponse) Reset

func (m *GetSubTaskCfgResponse) Reset()

func (*GetSubTaskCfgResponse) Size

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

func (*GetSubTaskCfgResponse) String

func (m *GetSubTaskCfgResponse) String() string

func (*GetSubTaskCfgResponse) Unmarshal

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

func (*GetSubTaskCfgResponse) XXX_DiscardUnknown

func (m *GetSubTaskCfgResponse) XXX_DiscardUnknown()

func (*GetSubTaskCfgResponse) XXX_Marshal

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

func (*GetSubTaskCfgResponse) XXX_Merge

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

func (*GetSubTaskCfgResponse) XXX_Size

func (m *GetSubTaskCfgResponse) XXX_Size() int

func (*GetSubTaskCfgResponse) XXX_Unmarshal

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

type GetWorkerCfgRequest

type GetWorkerCfgRequest struct {
}

func (*GetWorkerCfgRequest) Descriptor

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

func (*GetWorkerCfgRequest) Marshal

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

func (*GetWorkerCfgRequest) MarshalTo

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

func (*GetWorkerCfgRequest) MarshalToSizedBuffer

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

func (*GetWorkerCfgRequest) ProtoMessage

func (*GetWorkerCfgRequest) ProtoMessage()

func (*GetWorkerCfgRequest) Reset

func (m *GetWorkerCfgRequest) Reset()

func (*GetWorkerCfgRequest) Size

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

func (*GetWorkerCfgRequest) String

func (m *GetWorkerCfgRequest) String() string

func (*GetWorkerCfgRequest) Unmarshal

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

func (*GetWorkerCfgRequest) XXX_DiscardUnknown

func (m *GetWorkerCfgRequest) XXX_DiscardUnknown()

func (*GetWorkerCfgRequest) XXX_Marshal

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

func (*GetWorkerCfgRequest) XXX_Merge

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

func (*GetWorkerCfgRequest) XXX_Size

func (m *GetWorkerCfgRequest) XXX_Size() int

func (*GetWorkerCfgRequest) XXX_Unmarshal

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

type GetWorkerCfgResponse

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

func (*GetWorkerCfgResponse) Descriptor

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

func (*GetWorkerCfgResponse) GetCfg

func (m *GetWorkerCfgResponse) GetCfg() string

func (*GetWorkerCfgResponse) Marshal

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

func (*GetWorkerCfgResponse) MarshalTo

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

func (*GetWorkerCfgResponse) MarshalToSizedBuffer

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

func (*GetWorkerCfgResponse) ProtoMessage

func (*GetWorkerCfgResponse) ProtoMessage()

func (*GetWorkerCfgResponse) Reset

func (m *GetWorkerCfgResponse) Reset()

func (*GetWorkerCfgResponse) Size

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

func (*GetWorkerCfgResponse) String

func (m *GetWorkerCfgResponse) String() string

func (*GetWorkerCfgResponse) Unmarshal

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

func (*GetWorkerCfgResponse) XXX_DiscardUnknown

func (m *GetWorkerCfgResponse) XXX_DiscardUnknown()

func (*GetWorkerCfgResponse) XXX_Marshal

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

func (*GetWorkerCfgResponse) XXX_Merge

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

func (*GetWorkerCfgResponse) XXX_Size

func (m *GetWorkerCfgResponse) XXX_Size() int

func (*GetWorkerCfgResponse) XXX_Unmarshal

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

type HandleErrorRequest

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

func (*HandleErrorRequest) Descriptor

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

func (*HandleErrorRequest) GetBinlogPos

func (m *HandleErrorRequest) GetBinlogPos() string

func (*HandleErrorRequest) GetOp

func (m *HandleErrorRequest) GetOp() ErrorOp

func (*HandleErrorRequest) GetSources

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

func (*HandleErrorRequest) GetSqls

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

func (*HandleErrorRequest) GetTask

func (m *HandleErrorRequest) GetTask() string

func (*HandleErrorRequest) Marshal

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

func (*HandleErrorRequest) MarshalTo

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

func (*HandleErrorRequest) MarshalToSizedBuffer

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

func (*HandleErrorRequest) ProtoMessage

func (*HandleErrorRequest) ProtoMessage()

func (*HandleErrorRequest) Reset

func (m *HandleErrorRequest) Reset()

func (*HandleErrorRequest) Size

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

func (*HandleErrorRequest) String

func (m *HandleErrorRequest) String() string

func (*HandleErrorRequest) Unmarshal

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

func (*HandleErrorRequest) XXX_DiscardUnknown

func (m *HandleErrorRequest) XXX_DiscardUnknown()

func (*HandleErrorRequest) XXX_Marshal

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

func (*HandleErrorRequest) XXX_Merge

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

func (*HandleErrorRequest) XXX_Size

func (m *HandleErrorRequest) XXX_Size() int

func (*HandleErrorRequest) XXX_Unmarshal

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

type HandleErrorResponse

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

func (*HandleErrorResponse) Descriptor

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

func (*HandleErrorResponse) GetMsg

func (m *HandleErrorResponse) GetMsg() string

func (*HandleErrorResponse) GetResult

func (m *HandleErrorResponse) GetResult() bool

func (*HandleErrorResponse) GetSources

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

func (*HandleErrorResponse) Marshal

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

func (*HandleErrorResponse) MarshalTo

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

func (*HandleErrorResponse) MarshalToSizedBuffer

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

func (*HandleErrorResponse) ProtoMessage

func (*HandleErrorResponse) ProtoMessage()

func (*HandleErrorResponse) Reset

func (m *HandleErrorResponse) Reset()

func (*HandleErrorResponse) Size

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

func (*HandleErrorResponse) String

func (m *HandleErrorResponse) String() string

func (*HandleErrorResponse) Unmarshal

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

func (*HandleErrorResponse) XXX_DiscardUnknown

func (m *HandleErrorResponse) XXX_DiscardUnknown()

func (*HandleErrorResponse) XXX_Marshal

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

func (*HandleErrorResponse) XXX_Merge

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

func (*HandleErrorResponse) XXX_Size

func (m *HandleErrorResponse) XXX_Size() int

func (*HandleErrorResponse) XXX_Unmarshal

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

type HandleWorkerErrorRequest

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

func (*HandleWorkerErrorRequest) Descriptor

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

func (*HandleWorkerErrorRequest) GetBinlogPos

func (m *HandleWorkerErrorRequest) GetBinlogPos() string

func (*HandleWorkerErrorRequest) GetOp

func (m *HandleWorkerErrorRequest) GetOp() ErrorOp

func (*HandleWorkerErrorRequest) GetSqls

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

func (*HandleWorkerErrorRequest) GetTask

func (m *HandleWorkerErrorRequest) GetTask() string

func (*HandleWorkerErrorRequest) Marshal

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

func (*HandleWorkerErrorRequest) MarshalTo

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

func (*HandleWorkerErrorRequest) MarshalToSizedBuffer

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

func (*HandleWorkerErrorRequest) ProtoMessage

func (*HandleWorkerErrorRequest) ProtoMessage()

func (*HandleWorkerErrorRequest) Reset

func (m *HandleWorkerErrorRequest) Reset()

func (*HandleWorkerErrorRequest) Size

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

func (*HandleWorkerErrorRequest) String

func (m *HandleWorkerErrorRequest) String() string

func (*HandleWorkerErrorRequest) Unmarshal

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

func (*HandleWorkerErrorRequest) XXX_DiscardUnknown

func (m *HandleWorkerErrorRequest) XXX_DiscardUnknown()

func (*HandleWorkerErrorRequest) XXX_Marshal

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

func (*HandleWorkerErrorRequest) XXX_Merge

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

func (*HandleWorkerErrorRequest) XXX_Size

func (m *HandleWorkerErrorRequest) XXX_Size() int

func (*HandleWorkerErrorRequest) XXX_Unmarshal

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

type LeaderOp

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

func (LeaderOp) EnumDescriptor

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

func (LeaderOp) String

func (x LeaderOp) String() string

type ListLeaderMember

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

func (*ListLeaderMember) Descriptor

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

func (*ListLeaderMember) GetAddr

func (m *ListLeaderMember) GetAddr() string

func (*ListLeaderMember) GetMsg

func (m *ListLeaderMember) GetMsg() string

func (*ListLeaderMember) GetName

func (m *ListLeaderMember) GetName() string

func (*ListLeaderMember) Marshal

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

func (*ListLeaderMember) MarshalTo

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

func (*ListLeaderMember) MarshalToSizedBuffer

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

func (*ListLeaderMember) ProtoMessage

func (*ListLeaderMember) ProtoMessage()

func (*ListLeaderMember) Reset

func (m *ListLeaderMember) Reset()

func (*ListLeaderMember) Size

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

func (*ListLeaderMember) String

func (m *ListLeaderMember) String() string

func (*ListLeaderMember) Unmarshal

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

func (*ListLeaderMember) XXX_DiscardUnknown

func (m *ListLeaderMember) XXX_DiscardUnknown()

func (*ListLeaderMember) XXX_Marshal

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

func (*ListLeaderMember) XXX_Merge

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

func (*ListLeaderMember) XXX_Size

func (m *ListLeaderMember) XXX_Size() int

func (*ListLeaderMember) XXX_Unmarshal

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

type ListMasterMember

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

func (*ListMasterMember) Descriptor

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

func (*ListMasterMember) GetMasters

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

func (*ListMasterMember) GetMsg

func (m *ListMasterMember) GetMsg() string

func (*ListMasterMember) Marshal

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

func (*ListMasterMember) MarshalTo

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

func (*ListMasterMember) MarshalToSizedBuffer

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

func (*ListMasterMember) ProtoMessage

func (*ListMasterMember) ProtoMessage()

func (*ListMasterMember) Reset

func (m *ListMasterMember) Reset()

func (*ListMasterMember) Size

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

func (*ListMasterMember) String

func (m *ListMasterMember) String() string

func (*ListMasterMember) Unmarshal

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

func (*ListMasterMember) XXX_DiscardUnknown

func (m *ListMasterMember) XXX_DiscardUnknown()

func (*ListMasterMember) XXX_Marshal

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

func (*ListMasterMember) XXX_Merge

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

func (*ListMasterMember) XXX_Size

func (m *ListMasterMember) XXX_Size() int

func (*ListMasterMember) XXX_Unmarshal

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

type ListMemberRequest

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

func (*ListMemberRequest) Descriptor

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

func (*ListMemberRequest) GetLeader

func (m *ListMemberRequest) GetLeader() bool

func (*ListMemberRequest) GetMaster

func (m *ListMemberRequest) GetMaster() bool

func (*ListMemberRequest) GetNames

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

func (*ListMemberRequest) GetWorker

func (m *ListMemberRequest) GetWorker() bool

func (*ListMemberRequest) Marshal

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

func (*ListMemberRequest) MarshalTo

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

func (*ListMemberRequest) MarshalToSizedBuffer

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

func (*ListMemberRequest) ProtoMessage

func (*ListMemberRequest) ProtoMessage()

func (*ListMemberRequest) Reset

func (m *ListMemberRequest) Reset()

func (*ListMemberRequest) Size

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

func (*ListMemberRequest) String

func (m *ListMemberRequest) String() string

func (*ListMemberRequest) Unmarshal

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

func (*ListMemberRequest) XXX_DiscardUnknown

func (m *ListMemberRequest) XXX_DiscardUnknown()

func (*ListMemberRequest) XXX_Marshal

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

func (*ListMemberRequest) XXX_Merge

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

func (*ListMemberRequest) XXX_Size

func (m *ListMemberRequest) XXX_Size() int

func (*ListMemberRequest) XXX_Unmarshal

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

type ListMemberResponse

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

func (*ListMemberResponse) Descriptor

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

func (*ListMemberResponse) GetMembers

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

func (*ListMemberResponse) GetMsg

func (m *ListMemberResponse) GetMsg() string

func (*ListMemberResponse) GetResult

func (m *ListMemberResponse) GetResult() bool

func (*ListMemberResponse) Marshal

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

func (*ListMemberResponse) MarshalTo

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

func (*ListMemberResponse) MarshalToSizedBuffer

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

func (*ListMemberResponse) ProtoMessage

func (*ListMemberResponse) ProtoMessage()

func (*ListMemberResponse) Reset

func (m *ListMemberResponse) Reset()

func (*ListMemberResponse) Size

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

func (*ListMemberResponse) String

func (m *ListMemberResponse) String() string

func (*ListMemberResponse) Unmarshal

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

func (*ListMemberResponse) XXX_DiscardUnknown

func (m *ListMemberResponse) XXX_DiscardUnknown()

func (*ListMemberResponse) XXX_Marshal

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

func (*ListMemberResponse) XXX_Merge

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

func (*ListMemberResponse) XXX_Size

func (m *ListMemberResponse) XXX_Size() int

func (*ListMemberResponse) XXX_Unmarshal

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

type ListWorkerMember

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

func (*ListWorkerMember) Descriptor

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

func (*ListWorkerMember) GetMsg

func (m *ListWorkerMember) GetMsg() string

func (*ListWorkerMember) GetWorkers

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

func (*ListWorkerMember) Marshal

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

func (*ListWorkerMember) MarshalTo

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

func (*ListWorkerMember) MarshalToSizedBuffer

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

func (*ListWorkerMember) ProtoMessage

func (*ListWorkerMember) ProtoMessage()

func (*ListWorkerMember) Reset

func (m *ListWorkerMember) Reset()

func (*ListWorkerMember) Size

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

func (*ListWorkerMember) String

func (m *ListWorkerMember) String() string

func (*ListWorkerMember) Unmarshal

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

func (*ListWorkerMember) XXX_DiscardUnknown

func (m *ListWorkerMember) XXX_DiscardUnknown()

func (*ListWorkerMember) XXX_Marshal

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

func (*ListWorkerMember) XXX_Merge

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

func (*ListWorkerMember) XXX_Size

func (m *ListWorkerMember) XXX_Size() int

func (*ListWorkerMember) XXX_Unmarshal

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

type LoadError

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

LoadError represents error for load unit

func (*LoadError) Descriptor

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

func (*LoadError) GetMsg

func (m *LoadError) GetMsg() string

func (*LoadError) Marshal

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

func (*LoadError) MarshalTo

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

func (*LoadError) MarshalToSizedBuffer

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

func (*LoadError) ProtoMessage

func (*LoadError) ProtoMessage()

func (*LoadError) Reset

func (m *LoadError) Reset()

func (*LoadError) Size

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

func (*LoadError) String

func (m *LoadError) String() string

func (*LoadError) Unmarshal

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

func (*LoadError) XXX_DiscardUnknown

func (m *LoadError) XXX_DiscardUnknown()

func (*LoadError) XXX_Marshal

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

func (*LoadError) XXX_Merge

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

func (*LoadError) XXX_Size

func (m *LoadError) XXX_Size() int

func (*LoadError) XXX_Unmarshal

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

type LoadStatus

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

LoadStatus represents status for load unit

func (*LoadStatus) Descriptor

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

func (*LoadStatus) GetFinishedBytes

func (m *LoadStatus) GetFinishedBytes() int64

func (*LoadStatus) GetMetaBinlog

func (m *LoadStatus) GetMetaBinlog() string

func (*LoadStatus) GetMetaBinlogGTID

func (m *LoadStatus) GetMetaBinlogGTID() string

func (*LoadStatus) GetProgress

func (m *LoadStatus) GetProgress() string

func (*LoadStatus) GetTotalBytes

func (m *LoadStatus) GetTotalBytes() int64

func (*LoadStatus) Marshal

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

func (*LoadStatus) MarshalTo

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

func (*LoadStatus) MarshalToSizedBuffer

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

func (*LoadStatus) ProtoMessage

func (*LoadStatus) ProtoMessage()

func (*LoadStatus) Reset

func (m *LoadStatus) Reset()

func (*LoadStatus) Size

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

func (*LoadStatus) String

func (m *LoadStatus) String() string

func (*LoadStatus) Unmarshal

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

func (*LoadStatus) XXX_DiscardUnknown

func (m *LoadStatus) XXX_DiscardUnknown()

func (*LoadStatus) XXX_Marshal

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

func (*LoadStatus) XXX_Merge

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

func (*LoadStatus) XXX_Size

func (m *LoadStatus) XXX_Size() int

func (*LoadStatus) XXX_Unmarshal

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

type MasterClient

type MasterClient interface {
	StartTask(ctx context.Context, in *StartTaskRequest, opts ...grpc.CallOption) (*StartTaskResponse, error)
	OperateTask(ctx context.Context, in *OperateTaskRequest, opts ...grpc.CallOption) (*OperateTaskResponse, error)
	UpdateTask(ctx context.Context, in *UpdateTaskRequest, opts ...grpc.CallOption) (*UpdateTaskResponse, error)
	QueryStatus(ctx context.Context, in *QueryStatusListRequest, opts ...grpc.CallOption) (*QueryStatusListResponse, error)
	// show un-resolved DDL locks
	ShowDDLLocks(ctx context.Context, in *ShowDDLLocksRequest, opts ...grpc.CallOption) (*ShowDDLLocksResponse, error)
	// used by dmctl to manually unlock DDL lock
	UnlockDDLLock(ctx context.Context, in *UnlockDDLLockRequest, opts ...grpc.CallOption) (*UnlockDDLLockResponse, error)
	// OperateWorkerRelayTask requests some dm-workers to operate relay unit
	OperateWorkerRelayTask(ctx context.Context, in *OperateWorkerRelayRequest, opts ...grpc.CallOption) (*OperateWorkerRelayResponse, error)
	// PurgeWorkerRelay purges relay log files for some dm-workers
	PurgeWorkerRelay(ctx context.Context, in *PurgeWorkerRelayRequest, opts ...grpc.CallOption) (*PurgeWorkerRelayResponse, error)
	// CheckTask checks legality of task configuration
	CheckTask(ctx context.Context, in *CheckTaskRequest, opts ...grpc.CallOption) (*CheckTaskResponse, error)
	// Operate an upstream MySQL source.
	OperateSource(ctx context.Context, in *OperateSourceRequest, opts ...grpc.CallOption) (*OperateSourceResponse, error)
	// RegisterWorker register the dm-workers.
	RegisterWorker(ctx context.Context, in *RegisterWorkerRequest, opts ...grpc.CallOption) (*RegisterWorkerResponse, error)
	// OfflineMember offline the dm cluster's members (master/worker).
	OfflineMember(ctx context.Context, in *OfflineMemberRequest, opts ...grpc.CallOption) (*OfflineMemberResponse, error)
	// OperateLeader do some operate on master:
	//   - evict leader: make the master resign if it is leader, and will not campaign the leader again
	//   - cancel evict leader: the master can campaign leader again.
	OperateLeader(ctx context.Context, in *OperateLeaderRequest, opts ...grpc.CallOption) (*OperateLeaderResponse, error)
	// ListMember list member information
	ListMember(ctx context.Context, in *ListMemberRequest, opts ...grpc.CallOption) (*ListMemberResponse, error)
	OperateSchema(ctx context.Context, in *OperateSchemaRequest, opts ...grpc.CallOption) (*OperateSchemaResponse, error)
	GetSubTaskCfg(ctx context.Context, in *GetSubTaskCfgRequest, opts ...grpc.CallOption) (*GetSubTaskCfgResponse, error)
	// GetCfg get config
	GetCfg(ctx context.Context, in *GetCfgRequest, opts ...grpc.CallOption) (*GetCfgResponse, error)
	HandleError(ctx context.Context, in *HandleErrorRequest, opts ...grpc.CallOption) (*HandleErrorResponse, error)
	GetMasterCfg(ctx context.Context, in *GetMasterCfgRequest, opts ...grpc.CallOption) (*GetMasterCfgResponse, error)
}

MasterClient is the client API for Master service.

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

func NewMasterClient

func NewMasterClient(cc *grpc.ClientConn) MasterClient

type MasterInfo

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

func (*MasterInfo) Descriptor

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

func (*MasterInfo) GetAlive

func (m *MasterInfo) GetAlive() bool

func (*MasterInfo) GetClientURLs

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

func (*MasterInfo) GetMemberID

func (m *MasterInfo) GetMemberID() uint64

func (*MasterInfo) GetName

func (m *MasterInfo) GetName() string

func (*MasterInfo) GetPeerURLs

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

func (*MasterInfo) Marshal

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

func (*MasterInfo) MarshalTo

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

func (*MasterInfo) MarshalToSizedBuffer

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

func (*MasterInfo) ProtoMessage

func (*MasterInfo) ProtoMessage()

func (*MasterInfo) Reset

func (m *MasterInfo) Reset()

func (*MasterInfo) Size

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

func (*MasterInfo) String

func (m *MasterInfo) String() string

func (*MasterInfo) Unmarshal

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

func (*MasterInfo) XXX_DiscardUnknown

func (m *MasterInfo) XXX_DiscardUnknown()

func (*MasterInfo) XXX_Marshal

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

func (*MasterInfo) XXX_Merge

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

func (*MasterInfo) XXX_Size

func (m *MasterInfo) XXX_Size() int

func (*MasterInfo) XXX_Unmarshal

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

type MasterServer

type MasterServer interface {
	StartTask(context.Context, *StartTaskRequest) (*StartTaskResponse, error)
	OperateTask(context.Context, *OperateTaskRequest) (*OperateTaskResponse, error)
	UpdateTask(context.Context, *UpdateTaskRequest) (*UpdateTaskResponse, error)
	QueryStatus(context.Context, *QueryStatusListRequest) (*QueryStatusListResponse, error)
	// show un-resolved DDL locks
	ShowDDLLocks(context.Context, *ShowDDLLocksRequest) (*ShowDDLLocksResponse, error)
	// used by dmctl to manually unlock DDL lock
	UnlockDDLLock(context.Context, *UnlockDDLLockRequest) (*UnlockDDLLockResponse, error)
	// OperateWorkerRelayTask requests some dm-workers to operate relay unit
	OperateWorkerRelayTask(context.Context, *OperateWorkerRelayRequest) (*OperateWorkerRelayResponse, error)
	// PurgeWorkerRelay purges relay log files for some dm-workers
	PurgeWorkerRelay(context.Context, *PurgeWorkerRelayRequest) (*PurgeWorkerRelayResponse, error)
	// CheckTask checks legality of task configuration
	CheckTask(context.Context, *CheckTaskRequest) (*CheckTaskResponse, error)
	// Operate an upstream MySQL source.
	OperateSource(context.Context, *OperateSourceRequest) (*OperateSourceResponse, error)
	// RegisterWorker register the dm-workers.
	RegisterWorker(context.Context, *RegisterWorkerRequest) (*RegisterWorkerResponse, error)
	// OfflineMember offline the dm cluster's members (master/worker).
	OfflineMember(context.Context, *OfflineMemberRequest) (*OfflineMemberResponse, error)
	// OperateLeader do some operate on master:
	//   - evict leader: make the master resign if it is leader, and will not campaign the leader again
	//   - cancel evict leader: the master can campaign leader again.
	OperateLeader(context.Context, *OperateLeaderRequest) (*OperateLeaderResponse, error)
	// ListMember list member information
	ListMember(context.Context, *ListMemberRequest) (*ListMemberResponse, error)
	OperateSchema(context.Context, *OperateSchemaRequest) (*OperateSchemaResponse, error)
	GetSubTaskCfg(context.Context, *GetSubTaskCfgRequest) (*GetSubTaskCfgResponse, error)
	// GetCfg get config
	GetCfg(context.Context, *GetCfgRequest) (*GetCfgResponse, error)
	HandleError(context.Context, *HandleErrorRequest) (*HandleErrorResponse, error)
	GetMasterCfg(context.Context, *GetMasterCfgRequest) (*GetMasterCfgResponse, error)
}

MasterServer is the server API for Master service.

type Members

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

func (*Members) Descriptor

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

func (*Members) GetLeader

func (m *Members) GetLeader() *ListLeaderMember

func (*Members) GetMaster

func (m *Members) GetMaster() *ListMasterMember

func (*Members) GetMember

func (m *Members) GetMember() isMembers_Member

func (*Members) GetWorker

func (m *Members) GetWorker() *ListWorkerMember

func (*Members) Marshal

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

func (*Members) MarshalTo

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

func (*Members) MarshalToSizedBuffer

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

func (*Members) ProtoMessage

func (*Members) ProtoMessage()

func (*Members) Reset

func (m *Members) Reset()

func (*Members) Size

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

func (*Members) String

func (m *Members) String() string

func (*Members) Unmarshal

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

func (*Members) XXX_DiscardUnknown

func (m *Members) XXX_DiscardUnknown()

func (*Members) XXX_Marshal

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

func (*Members) XXX_Merge

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

func (*Members) XXX_OneofWrappers

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*Members) XXX_Size

func (m *Members) XXX_Size() int

func (*Members) XXX_Unmarshal

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

type Members_Leader

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

func (*Members_Leader) MarshalTo

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

func (*Members_Leader) MarshalToSizedBuffer

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

func (*Members_Leader) Size

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

type Members_Master

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

func (*Members_Master) MarshalTo

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

func (*Members_Master) MarshalToSizedBuffer

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

func (*Members_Master) Size

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

type Members_Worker

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

func (*Members_Worker) MarshalTo

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

func (*Members_Worker) MarshalToSizedBuffer

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

func (*Members_Worker) Size

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

type OfflineMemberRequest

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

func (*OfflineMemberRequest) Descriptor

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

func (*OfflineMemberRequest) GetName

func (m *OfflineMemberRequest) GetName() string

func (*OfflineMemberRequest) GetType

func (m *OfflineMemberRequest) GetType() string

func (*OfflineMemberRequest) Marshal

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

func (*OfflineMemberRequest) MarshalTo

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

func (*OfflineMemberRequest) MarshalToSizedBuffer

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

func (*OfflineMemberRequest) ProtoMessage

func (*OfflineMemberRequest) ProtoMessage()

func (*OfflineMemberRequest) Reset

func (m *OfflineMemberRequest) Reset()

func (*OfflineMemberRequest) Size

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

func (*OfflineMemberRequest) String

func (m *OfflineMemberRequest) String() string

func (*OfflineMemberRequest) Unmarshal

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

func (*OfflineMemberRequest) XXX_DiscardUnknown

func (m *OfflineMemberRequest) XXX_DiscardUnknown()

func (*OfflineMemberRequest) XXX_Marshal

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

func (*OfflineMemberRequest) XXX_Merge

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

func (*OfflineMemberRequest) XXX_Size

func (m *OfflineMemberRequest) XXX_Size() int

func (*OfflineMemberRequest) XXX_Unmarshal

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

type OfflineMemberResponse

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

func (*OfflineMemberResponse) Descriptor

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

func (*OfflineMemberResponse) GetMsg

func (m *OfflineMemberResponse) GetMsg() string

func (*OfflineMemberResponse) GetResult

func (m *OfflineMemberResponse) GetResult() bool

func (*OfflineMemberResponse) Marshal

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

func (*OfflineMemberResponse) MarshalTo

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

func (*OfflineMemberResponse) MarshalToSizedBuffer

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

func (*OfflineMemberResponse) ProtoMessage

func (*OfflineMemberResponse) ProtoMessage()

func (*OfflineMemberResponse) Reset

func (m *OfflineMemberResponse) Reset()

func (*OfflineMemberResponse) Size

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

func (*OfflineMemberResponse) String

func (m *OfflineMemberResponse) String() string

func (*OfflineMemberResponse) Unmarshal

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

func (*OfflineMemberResponse) XXX_DiscardUnknown

func (m *OfflineMemberResponse) XXX_DiscardUnknown()

func (*OfflineMemberResponse) XXX_Marshal

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

func (*OfflineMemberResponse) XXX_Merge

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

func (*OfflineMemberResponse) XXX_Size

func (m *OfflineMemberResponse) XXX_Size() int

func (*OfflineMemberResponse) XXX_Unmarshal

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

type OperateLeaderRequest

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

func (*OperateLeaderRequest) Descriptor

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

func (*OperateLeaderRequest) GetOp

func (m *OperateLeaderRequest) GetOp() LeaderOp

func (*OperateLeaderRequest) Marshal

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

func (*OperateLeaderRequest) MarshalTo

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

func (*OperateLeaderRequest) MarshalToSizedBuffer

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

func (*OperateLeaderRequest) ProtoMessage

func (*OperateLeaderRequest) ProtoMessage()

func (*OperateLeaderRequest) Reset

func (m *OperateLeaderRequest) Reset()

func (*OperateLeaderRequest) Size

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

func (*OperateLeaderRequest) String

func (m *OperateLeaderRequest) String() string

func (*OperateLeaderRequest) Unmarshal

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

func (*OperateLeaderRequest) XXX_DiscardUnknown

func (m *OperateLeaderRequest) XXX_DiscardUnknown()

func (*OperateLeaderRequest) XXX_Marshal

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

func (*OperateLeaderRequest) XXX_Merge

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

func (*OperateLeaderRequest) XXX_Size

func (m *OperateLeaderRequest) XXX_Size() int

func (*OperateLeaderRequest) XXX_Unmarshal

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

type OperateLeaderResponse

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

func (*OperateLeaderResponse) Descriptor

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

func (*OperateLeaderResponse) GetMsg

func (m *OperateLeaderResponse) GetMsg() string

func (*OperateLeaderResponse) GetResult

func (m *OperateLeaderResponse) GetResult() bool

func (*OperateLeaderResponse) Marshal

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

func (*OperateLeaderResponse) MarshalTo

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

func (*OperateLeaderResponse) MarshalToSizedBuffer

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

func (*OperateLeaderResponse) ProtoMessage

func (*OperateLeaderResponse) ProtoMessage()

func (*OperateLeaderResponse) Reset

func (m *OperateLeaderResponse) Reset()

func (*OperateLeaderResponse) Size

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

func (*OperateLeaderResponse) String

func (m *OperateLeaderResponse) String() string

func (*OperateLeaderResponse) Unmarshal

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

func (*OperateLeaderResponse) XXX_DiscardUnknown

func (m *OperateLeaderResponse) XXX_DiscardUnknown()

func (*OperateLeaderResponse) XXX_Marshal

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

func (*OperateLeaderResponse) XXX_Merge

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

func (*OperateLeaderResponse) XXX_Size

func (m *OperateLeaderResponse) XXX_Size() int

func (*OperateLeaderResponse) XXX_Unmarshal

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

type OperateSchemaRequest

type OperateSchemaRequest struct {
	Op       SchemaOp `protobuf:"varint,1,opt,name=op,proto3,enum=pb.SchemaOp" json:"op,omitempty"`
	Task     string   `protobuf:"bytes,2,opt,name=task,proto3" json:"task,omitempty"`
	Sources  []string `protobuf:"bytes,3,rep,name=sources,proto3" json:"sources,omitempty"`
	Database string   `protobuf:"bytes,4,opt,name=database,proto3" json:"database,omitempty"`
	Table    string   `protobuf:"bytes,5,opt,name=table,proto3" json:"table,omitempty"`
	Schema   string   `protobuf:"bytes,6,opt,name=schema,proto3" json:"schema,omitempty"`
}

func (*OperateSchemaRequest) Descriptor

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

func (*OperateSchemaRequest) GetDatabase

func (m *OperateSchemaRequest) GetDatabase() string

func (*OperateSchemaRequest) GetOp

func (m *OperateSchemaRequest) GetOp() SchemaOp

func (*OperateSchemaRequest) GetSchema

func (m *OperateSchemaRequest) GetSchema() string

func (*OperateSchemaRequest) GetSources

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

func (*OperateSchemaRequest) GetTable

func (m *OperateSchemaRequest) GetTable() string

func (*OperateSchemaRequest) GetTask

func (m *OperateSchemaRequest) GetTask() string

func (*OperateSchemaRequest) Marshal

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

func (*OperateSchemaRequest) MarshalTo

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

func (*OperateSchemaRequest) MarshalToSizedBuffer

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

func (*OperateSchemaRequest) ProtoMessage

func (*OperateSchemaRequest) ProtoMessage()

func (*OperateSchemaRequest) Reset

func (m *OperateSchemaRequest) Reset()

func (*OperateSchemaRequest) Size

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

func (*OperateSchemaRequest) String

func (m *OperateSchemaRequest) String() string

func (*OperateSchemaRequest) Unmarshal

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

func (*OperateSchemaRequest) XXX_DiscardUnknown

func (m *OperateSchemaRequest) XXX_DiscardUnknown()

func (*OperateSchemaRequest) XXX_Marshal

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

func (*OperateSchemaRequest) XXX_Merge

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

func (*OperateSchemaRequest) XXX_Size

func (m *OperateSchemaRequest) XXX_Size() int

func (*OperateSchemaRequest) XXX_Unmarshal

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

type OperateSchemaResponse

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

func (*OperateSchemaResponse) Descriptor

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

func (*OperateSchemaResponse) GetMsg

func (m *OperateSchemaResponse) GetMsg() string

func (*OperateSchemaResponse) GetResult

func (m *OperateSchemaResponse) GetResult() bool

func (*OperateSchemaResponse) GetSources

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

func (*OperateSchemaResponse) Marshal

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

func (*OperateSchemaResponse) MarshalTo

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

func (*OperateSchemaResponse) MarshalToSizedBuffer

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

func (*OperateSchemaResponse) ProtoMessage

func (*OperateSchemaResponse) ProtoMessage()

func (*OperateSchemaResponse) Reset

func (m *OperateSchemaResponse) Reset()

func (*OperateSchemaResponse) Size

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

func (*OperateSchemaResponse) String

func (m *OperateSchemaResponse) String() string

func (*OperateSchemaResponse) Unmarshal

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

func (*OperateSchemaResponse) XXX_DiscardUnknown

func (m *OperateSchemaResponse) XXX_DiscardUnknown()

func (*OperateSchemaResponse) XXX_Marshal

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

func (*OperateSchemaResponse) XXX_Merge

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

func (*OperateSchemaResponse) XXX_Size

func (m *OperateSchemaResponse) XXX_Size() int

func (*OperateSchemaResponse) XXX_Unmarshal

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

type OperateSourceRequest

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

func (*OperateSourceRequest) Descriptor

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

func (*OperateSourceRequest) GetConfig

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

func (*OperateSourceRequest) GetOp

func (m *OperateSourceRequest) GetOp() SourceOp

func (*OperateSourceRequest) GetSourceID

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

func (*OperateSourceRequest) Marshal

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

func (*OperateSourceRequest) MarshalTo

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

func (*OperateSourceRequest) MarshalToSizedBuffer

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

func (*OperateSourceRequest) ProtoMessage

func (*OperateSourceRequest) ProtoMessage()

func (*OperateSourceRequest) Reset

func (m *OperateSourceRequest) Reset()

func (*OperateSourceRequest) Size

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

func (*OperateSourceRequest) String

func (m *OperateSourceRequest) String() string

func (*OperateSourceRequest) Unmarshal

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

func (*OperateSourceRequest) XXX_DiscardUnknown

func (m *OperateSourceRequest) XXX_DiscardUnknown()

func (*OperateSourceRequest) XXX_Marshal

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

func (*OperateSourceRequest) XXX_Merge

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

func (*OperateSourceRequest) XXX_Size

func (m *OperateSourceRequest) XXX_Size() int

func (*OperateSourceRequest) XXX_Unmarshal

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

type OperateSourceResponse

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

func (*OperateSourceResponse) Descriptor

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

func (*OperateSourceResponse) GetMsg

func (m *OperateSourceResponse) GetMsg() string

func (*OperateSourceResponse) GetResult

func (m *OperateSourceResponse) GetResult() bool

func (*OperateSourceResponse) GetSources

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

func (*OperateSourceResponse) Marshal

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

func (*OperateSourceResponse) MarshalTo

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

func (*OperateSourceResponse) MarshalToSizedBuffer

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

func (*OperateSourceResponse) ProtoMessage

func (*OperateSourceResponse) ProtoMessage()

func (*OperateSourceResponse) Reset

func (m *OperateSourceResponse) Reset()

func (*OperateSourceResponse) Size

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

func (*OperateSourceResponse) String

func (m *OperateSourceResponse) String() string

func (*OperateSourceResponse) Unmarshal

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

func (*OperateSourceResponse) XXX_DiscardUnknown

func (m *OperateSourceResponse) XXX_DiscardUnknown()

func (*OperateSourceResponse) XXX_Marshal

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

func (*OperateSourceResponse) XXX_Merge

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

func (*OperateSourceResponse) XXX_Size

func (m *OperateSourceResponse) XXX_Size() int

func (*OperateSourceResponse) XXX_Unmarshal

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

type OperateTaskRequest

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

func (*OperateTaskRequest) Descriptor

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

func (*OperateTaskRequest) GetName

func (m *OperateTaskRequest) GetName() string

func (*OperateTaskRequest) GetOp

func (m *OperateTaskRequest) GetOp() TaskOp

func (*OperateTaskRequest) GetSources

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

func (*OperateTaskRequest) Marshal

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

func (*OperateTaskRequest) MarshalTo

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

func (*OperateTaskRequest) MarshalToSizedBuffer

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

func (*OperateTaskRequest) ProtoMessage

func (*OperateTaskRequest) ProtoMessage()

func (*OperateTaskRequest) Reset

func (m *OperateTaskRequest) Reset()

func (*OperateTaskRequest) Size

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

func (*OperateTaskRequest) String

func (m *OperateTaskRequest) String() string

func (*OperateTaskRequest) Unmarshal

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

func (*OperateTaskRequest) XXX_DiscardUnknown

func (m *OperateTaskRequest) XXX_DiscardUnknown()

func (*OperateTaskRequest) XXX_Marshal

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

func (*OperateTaskRequest) XXX_Merge

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

func (*OperateTaskRequest) XXX_Size

func (m *OperateTaskRequest) XXX_Size() int

func (*OperateTaskRequest) XXX_Unmarshal

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

type OperateTaskResponse

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

func (*OperateTaskResponse) Descriptor

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

func (*OperateTaskResponse) GetMsg

func (m *OperateTaskResponse) GetMsg() string

func (*OperateTaskResponse) GetOp

func (m *OperateTaskResponse) GetOp() TaskOp

func (*OperateTaskResponse) GetResult

func (m *OperateTaskResponse) GetResult() bool

func (*OperateTaskResponse) GetSources

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

func (*OperateTaskResponse) Marshal

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

func (*OperateTaskResponse) MarshalTo

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

func (*OperateTaskResponse) MarshalToSizedBuffer

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

func (*OperateTaskResponse) ProtoMessage

func (*OperateTaskResponse) ProtoMessage()

func (*OperateTaskResponse) Reset

func (m *OperateTaskResponse) Reset()

func (*OperateTaskResponse) Size

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

func (*OperateTaskResponse) String

func (m *OperateTaskResponse) String() string

func (*OperateTaskResponse) Unmarshal

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

func (*OperateTaskResponse) XXX_DiscardUnknown

func (m *OperateTaskResponse) XXX_DiscardUnknown()

func (*OperateTaskResponse) XXX_Marshal

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

func (*OperateTaskResponse) XXX_Merge

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

func (*OperateTaskResponse) XXX_Size

func (m *OperateTaskResponse) XXX_Size() int

func (*OperateTaskResponse) XXX_Unmarshal

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

type OperateV1MetaRequest

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

func (*OperateV1MetaRequest) Descriptor

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

func (*OperateV1MetaRequest) GetOp

func (m *OperateV1MetaRequest) GetOp() V1MetaOp

func (*OperateV1MetaRequest) Marshal

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

func (*OperateV1MetaRequest) MarshalTo

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

func (*OperateV1MetaRequest) MarshalToSizedBuffer

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

func (*OperateV1MetaRequest) ProtoMessage

func (*OperateV1MetaRequest) ProtoMessage()

func (*OperateV1MetaRequest) Reset

func (m *OperateV1MetaRequest) Reset()

func (*OperateV1MetaRequest) Size

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

func (*OperateV1MetaRequest) String

func (m *OperateV1MetaRequest) String() string

func (*OperateV1MetaRequest) Unmarshal

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

func (*OperateV1MetaRequest) XXX_DiscardUnknown

func (m *OperateV1MetaRequest) XXX_DiscardUnknown()

func (*OperateV1MetaRequest) XXX_Marshal

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

func (*OperateV1MetaRequest) XXX_Merge

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

func (*OperateV1MetaRequest) XXX_Size

func (m *OperateV1MetaRequest) XXX_Size() int

func (*OperateV1MetaRequest) XXX_Unmarshal

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

type OperateV1MetaResponse

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

func (*OperateV1MetaResponse) Descriptor

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

func (*OperateV1MetaResponse) GetMeta

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

func (*OperateV1MetaResponse) GetMsg

func (m *OperateV1MetaResponse) GetMsg() string

func (*OperateV1MetaResponse) GetResult

func (m *OperateV1MetaResponse) GetResult() bool

func (*OperateV1MetaResponse) Marshal

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

func (*OperateV1MetaResponse) MarshalTo

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

func (*OperateV1MetaResponse) MarshalToSizedBuffer

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

func (*OperateV1MetaResponse) ProtoMessage

func (*OperateV1MetaResponse) ProtoMessage()

func (*OperateV1MetaResponse) Reset

func (m *OperateV1MetaResponse) Reset()

func (*OperateV1MetaResponse) Size

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

func (*OperateV1MetaResponse) String

func (m *OperateV1MetaResponse) String() string

func (*OperateV1MetaResponse) Unmarshal

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

func (*OperateV1MetaResponse) XXX_DiscardUnknown

func (m *OperateV1MetaResponse) XXX_DiscardUnknown()

func (*OperateV1MetaResponse) XXX_Marshal

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

func (*OperateV1MetaResponse) XXX_Merge

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

func (*OperateV1MetaResponse) XXX_Size

func (m *OperateV1MetaResponse) XXX_Size() int

func (*OperateV1MetaResponse) XXX_Unmarshal

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

type OperateWorkerRelayRequest

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

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

func (*OperateWorkerRelayRequest) Descriptor

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

func (*OperateWorkerRelayRequest) GetOp

func (*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 (*OperateWorkerRelayResponse) GetResult

func (m *OperateWorkerRelayResponse) GetResult() bool

func (*OperateWorkerRelayResponse) GetSources

func (*OperateWorkerRelayResponse) Marshal

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

func (*OperateWorkerRelayResponse) MarshalTo

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

func (*OperateWorkerRelayResponse) MarshalToSizedBuffer

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

func (*OperateWorkerRelayResponse) ProtoMessage

func (*OperateWorkerRelayResponse) ProtoMessage()

func (*OperateWorkerRelayResponse) Reset

func (m *OperateWorkerRelayResponse) Reset()

func (*OperateWorkerRelayResponse) Size

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

func (*OperateWorkerRelayResponse) String

func (m *OperateWorkerRelayResponse) String() string

func (*OperateWorkerRelayResponse) Unmarshal

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

func (*OperateWorkerRelayResponse) XXX_DiscardUnknown

func (m *OperateWorkerRelayResponse) XXX_DiscardUnknown()

func (*OperateWorkerRelayResponse) XXX_Marshal

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

func (*OperateWorkerRelayResponse) XXX_Merge

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

func (*OperateWorkerRelayResponse) XXX_Size

func (m *OperateWorkerRelayResponse) XXX_Size() int

func (*OperateWorkerRelayResponse) XXX_Unmarshal

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

type OperateWorkerSchemaRequest

type OperateWorkerSchemaRequest struct {
	Op       SchemaOp `protobuf:"varint,1,opt,name=op,proto3,enum=pb.SchemaOp" json:"op,omitempty"`
	Task     string   `protobuf:"bytes,2,opt,name=task,proto3" json:"task,omitempty"`
	Source   string   `protobuf:"bytes,3,opt,name=source,proto3" json:"source,omitempty"`
	Database string   `protobuf:"bytes,4,opt,name=database,proto3" json:"database,omitempty"`
	Table    string   `protobuf:"bytes,5,opt,name=table,proto3" json:"table,omitempty"`
	Schema   string   `protobuf:"bytes,6,opt,name=schema,proto3" json:"schema,omitempty"`
}

func (*OperateWorkerSchemaRequest) Descriptor

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

func (*OperateWorkerSchemaRequest) GetDatabase

func (m *OperateWorkerSchemaRequest) GetDatabase() string

func (*OperateWorkerSchemaRequest) GetOp

func (*OperateWorkerSchemaRequest) GetSchema

func (m *OperateWorkerSchemaRequest) GetSchema() string

func (*OperateWorkerSchemaRequest) GetSource

func (m *OperateWorkerSchemaRequest) GetSource() string

func (*OperateWorkerSchemaRequest) GetTable

func (m *OperateWorkerSchemaRequest) GetTable() string

func (*OperateWorkerSchemaRequest) GetTask

func (m *OperateWorkerSchemaRequest) GetTask() string

func (*OperateWorkerSchemaRequest) Marshal

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

func (*OperateWorkerSchemaRequest) MarshalTo

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

func (*OperateWorkerSchemaRequest) MarshalToSizedBuffer

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

func (*OperateWorkerSchemaRequest) ProtoMessage

func (*OperateWorkerSchemaRequest) ProtoMessage()

func (*OperateWorkerSchemaRequest) Reset

func (m *OperateWorkerSchemaRequest) Reset()

func (*OperateWorkerSchemaRequest) Size

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

func (*OperateWorkerSchemaRequest) String

func (m *OperateWorkerSchemaRequest) String() string

func (*OperateWorkerSchemaRequest) Unmarshal

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

func (*OperateWorkerSchemaRequest) XXX_DiscardUnknown

func (m *OperateWorkerSchemaRequest) XXX_DiscardUnknown()

func (*OperateWorkerSchemaRequest) XXX_Marshal

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

func (*OperateWorkerSchemaRequest) XXX_Merge

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

func (*OperateWorkerSchemaRequest) XXX_Size

func (m *OperateWorkerSchemaRequest) XXX_Size() int

func (*OperateWorkerSchemaRequest) XXX_Unmarshal

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

type ProcessError

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

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

func (*ProcessError) Descriptor

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

func (*ProcessError) GetErrClass

func (m *ProcessError) GetErrClass() string

func (*ProcessError) GetErrCode

func (m *ProcessError) GetErrCode() int32

func (*ProcessError) GetErrLevel

func (m *ProcessError) GetErrLevel() string

func (*ProcessError) GetErrScope

func (m *ProcessError) GetErrScope() string

func (*ProcessError) GetMessage

func (m *ProcessError) GetMessage() string

func (*ProcessError) GetRawCause

func (m *ProcessError) GetRawCause() string

func (*ProcessError) GetWorkaround

func (m *ProcessError) GetWorkaround() string

func (*ProcessError) Marshal

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

func (*ProcessError) MarshalTo

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

func (*ProcessError) MarshalToSizedBuffer

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

func (*ProcessError) ProtoMessage

func (*ProcessError) ProtoMessage()

func (*ProcessError) Reset

func (m *ProcessError) Reset()

func (*ProcessError) Size

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

func (*ProcessError) String

func (m *ProcessError) String() string

func (*ProcessError) Unmarshal

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

func (*ProcessError) XXX_DiscardUnknown

func (m *ProcessError) XXX_DiscardUnknown()

func (*ProcessError) XXX_Marshal

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

func (*ProcessError) XXX_Merge

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

func (*ProcessError) XXX_Size

func (m *ProcessError) XXX_Size() int

func (*ProcessError) XXX_Unmarshal

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

type ProcessResult

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

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

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

errors: includes all (potential) errors occured when processing

func (*ProcessResult) Descriptor

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

func (*ProcessResult) GetDetail

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

func (*ProcessResult) GetErrors

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

func (*ProcessResult) GetIsCanceled

func (m *ProcessResult) GetIsCanceled() bool

func (*ProcessResult) Marshal

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

func (*ProcessResult) MarshalTo

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

func (*ProcessResult) MarshalToSizedBuffer

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

func (*ProcessResult) ProtoMessage

func (*ProcessResult) ProtoMessage()

func (*ProcessResult) Reset

func (m *ProcessResult) Reset()

func (*ProcessResult) Size

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

func (*ProcessResult) String

func (m *ProcessResult) String() string

func (*ProcessResult) Unmarshal

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

func (*ProcessResult) XXX_DiscardUnknown

func (m *ProcessResult) XXX_DiscardUnknown()

func (*ProcessResult) XXX_Marshal

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

func (*ProcessResult) XXX_Merge

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

func (*ProcessResult) XXX_Size

func (m *ProcessResult) XXX_Size() int

func (*ProcessResult) XXX_Unmarshal

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

type PurgeRelayRequest

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

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

func (*PurgeRelayRequest) Descriptor

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

func (*PurgeRelayRequest) GetFilename

func (m *PurgeRelayRequest) GetFilename() string

func (*PurgeRelayRequest) GetInactive

func (m *PurgeRelayRequest) GetInactive() bool

func (*PurgeRelayRequest) GetSubDir

func (m *PurgeRelayRequest) GetSubDir() string

func (*PurgeRelayRequest) GetTime

func (m *PurgeRelayRequest) GetTime() int64

func (*PurgeRelayRequest) Marshal

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

func (*PurgeRelayRequest) MarshalTo

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

func (*PurgeRelayRequest) MarshalToSizedBuffer

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

func (*PurgeRelayRequest) ProtoMessage

func (*PurgeRelayRequest) ProtoMessage()

func (*PurgeRelayRequest) Reset

func (m *PurgeRelayRequest) Reset()

func (*PurgeRelayRequest) Size

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

func (*PurgeRelayRequest) String

func (m *PurgeRelayRequest) String() string

func (*PurgeRelayRequest) Unmarshal

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

func (*PurgeRelayRequest) XXX_DiscardUnknown

func (m *PurgeRelayRequest) XXX_DiscardUnknown()

func (*PurgeRelayRequest) XXX_Marshal

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

func (*PurgeRelayRequest) XXX_Merge

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

func (*PurgeRelayRequest) XXX_Size

func (m *PurgeRelayRequest) XXX_Size() int

func (*PurgeRelayRequest) XXX_Unmarshal

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

type PurgeWorkerRelayRequest

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

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

func (*PurgeWorkerRelayRequest) Descriptor

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

func (*PurgeWorkerRelayRequest) GetFilename

func (m *PurgeWorkerRelayRequest) GetFilename() string

func (*PurgeWorkerRelayRequest) GetInactive

func (m *PurgeWorkerRelayRequest) GetInactive() bool

func (*PurgeWorkerRelayRequest) GetSources

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

func (*PurgeWorkerRelayRequest) GetSubDir

func (m *PurgeWorkerRelayRequest) GetSubDir() string

func (*PurgeWorkerRelayRequest) GetTime

func (m *PurgeWorkerRelayRequest) GetTime() int64

func (*PurgeWorkerRelayRequest) Marshal

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

func (*PurgeWorkerRelayRequest) MarshalTo

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

func (*PurgeWorkerRelayRequest) MarshalToSizedBuffer

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

func (*PurgeWorkerRelayRequest) ProtoMessage

func (*PurgeWorkerRelayRequest) ProtoMessage()

func (*PurgeWorkerRelayRequest) Reset

func (m *PurgeWorkerRelayRequest) Reset()

func (*PurgeWorkerRelayRequest) Size

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

func (*PurgeWorkerRelayRequest) String

func (m *PurgeWorkerRelayRequest) String() string

func (*PurgeWorkerRelayRequest) Unmarshal

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

func (*PurgeWorkerRelayRequest) XXX_DiscardUnknown

func (m *PurgeWorkerRelayRequest) XXX_DiscardUnknown()

func (*PurgeWorkerRelayRequest) XXX_Marshal

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

func (*PurgeWorkerRelayRequest) XXX_Merge

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

func (*PurgeWorkerRelayRequest) XXX_Size

func (m *PurgeWorkerRelayRequest) XXX_Size() int

func (*PurgeWorkerRelayRequest) XXX_Unmarshal

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

type PurgeWorkerRelayResponse

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

func (*PurgeWorkerRelayResponse) Descriptor

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

func (*PurgeWorkerRelayResponse) GetMsg

func (m *PurgeWorkerRelayResponse) GetMsg() string

func (*PurgeWorkerRelayResponse) GetResult

func (m *PurgeWorkerRelayResponse) GetResult() bool

func (*PurgeWorkerRelayResponse) GetSources

func (*PurgeWorkerRelayResponse) Marshal

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

func (*PurgeWorkerRelayResponse) MarshalTo

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

func (*PurgeWorkerRelayResponse) MarshalToSizedBuffer

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

func (*PurgeWorkerRelayResponse) ProtoMessage

func (*PurgeWorkerRelayResponse) ProtoMessage()

func (*PurgeWorkerRelayResponse) Reset

func (m *PurgeWorkerRelayResponse) Reset()

func (*PurgeWorkerRelayResponse) Size

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

func (*PurgeWorkerRelayResponse) String

func (m *PurgeWorkerRelayResponse) String() string

func (*PurgeWorkerRelayResponse) Unmarshal

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

func (*PurgeWorkerRelayResponse) XXX_DiscardUnknown

func (m *PurgeWorkerRelayResponse) XXX_DiscardUnknown()

func (*PurgeWorkerRelayResponse) XXX_Marshal

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

func (*PurgeWorkerRelayResponse) XXX_Merge

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

func (*PurgeWorkerRelayResponse) XXX_Size

func (m *PurgeWorkerRelayResponse) XXX_Size() int

func (*PurgeWorkerRelayResponse) XXX_Unmarshal

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

type QueryStatusListRequest

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

func (*QueryStatusListRequest) Descriptor

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

func (*QueryStatusListRequest) GetName

func (m *QueryStatusListRequest) GetName() string

func (*QueryStatusListRequest) GetSources

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

func (*QueryStatusListRequest) Marshal

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

func (*QueryStatusListRequest) MarshalTo

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

func (*QueryStatusListRequest) MarshalToSizedBuffer

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

func (*QueryStatusListRequest) ProtoMessage

func (*QueryStatusListRequest) ProtoMessage()

func (*QueryStatusListRequest) Reset

func (m *QueryStatusListRequest) Reset()

func (*QueryStatusListRequest) Size

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

func (*QueryStatusListRequest) String

func (m *QueryStatusListRequest) String() string

func (*QueryStatusListRequest) Unmarshal

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

func (*QueryStatusListRequest) XXX_DiscardUnknown

func (m *QueryStatusListRequest) XXX_DiscardUnknown()

func (*QueryStatusListRequest) XXX_Marshal

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

func (*QueryStatusListRequest) XXX_Merge

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

func (*QueryStatusListRequest) XXX_Size

func (m *QueryStatusListRequest) XXX_Size() int

func (*QueryStatusListRequest) XXX_Unmarshal

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

type QueryStatusListResponse

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

func (*QueryStatusListResponse) Descriptor

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

func (*QueryStatusListResponse) GetMsg

func (m *QueryStatusListResponse) GetMsg() string

func (*QueryStatusListResponse) GetResult

func (m *QueryStatusListResponse) GetResult() bool

func (*QueryStatusListResponse) GetSources

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

func (*QueryStatusListResponse) Marshal

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

func (*QueryStatusListResponse) MarshalTo

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

func (*QueryStatusListResponse) MarshalToSizedBuffer

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

func (*QueryStatusListResponse) ProtoMessage

func (*QueryStatusListResponse) ProtoMessage()

func (*QueryStatusListResponse) Reset

func (m *QueryStatusListResponse) Reset()

func (*QueryStatusListResponse) Size

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

func (*QueryStatusListResponse) String

func (m *QueryStatusListResponse) String() string

func (*QueryStatusListResponse) Unmarshal

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

func (*QueryStatusListResponse) XXX_DiscardUnknown

func (m *QueryStatusListResponse) XXX_DiscardUnknown()

func (*QueryStatusListResponse) XXX_Marshal

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

func (*QueryStatusListResponse) XXX_Merge

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

func (*QueryStatusListResponse) XXX_Size

func (m *QueryStatusListResponse) XXX_Size() int

func (*QueryStatusListResponse) XXX_Unmarshal

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

type QueryStatusRequest

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

func (*QueryStatusRequest) Descriptor

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

func (*QueryStatusRequest) GetName

func (m *QueryStatusRequest) GetName() string

func (*QueryStatusRequest) Marshal

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

func (*QueryStatusRequest) MarshalTo

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

func (*QueryStatusRequest) MarshalToSizedBuffer

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

func (*QueryStatusRequest) ProtoMessage

func (*QueryStatusRequest) ProtoMessage()

func (*QueryStatusRequest) Reset

func (m *QueryStatusRequest) Reset()

func (*QueryStatusRequest) Size

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

func (*QueryStatusRequest) String

func (m *QueryStatusRequest) String() string

func (*QueryStatusRequest) Unmarshal

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

func (*QueryStatusRequest) XXX_DiscardUnknown

func (m *QueryStatusRequest) XXX_DiscardUnknown()

func (*QueryStatusRequest) XXX_Marshal

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

func (*QueryStatusRequest) XXX_Merge

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

func (*QueryStatusRequest) XXX_Size

func (m *QueryStatusRequest) XXX_Size() int

func (*QueryStatusRequest) XXX_Unmarshal

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

type QueryStatusResponse

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

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

func (*QueryStatusResponse) Descriptor

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

func (*QueryStatusResponse) GetMsg

func (m *QueryStatusResponse) GetMsg() string

func (*QueryStatusResponse) GetResult

func (m *QueryStatusResponse) GetResult() bool

func (*QueryStatusResponse) GetSourceStatus

func (m *QueryStatusResponse) GetSourceStatus() *SourceStatus

func (*QueryStatusResponse) GetSubTaskStatus

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

func (*QueryStatusResponse) Marshal

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

func (*QueryStatusResponse) MarshalTo

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

func (*QueryStatusResponse) MarshalToSizedBuffer

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

func (*QueryStatusResponse) ProtoMessage

func (*QueryStatusResponse) ProtoMessage()

func (*QueryStatusResponse) Reset

func (m *QueryStatusResponse) Reset()

func (*QueryStatusResponse) Size

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

func (*QueryStatusResponse) String

func (m *QueryStatusResponse) String() string

func (*QueryStatusResponse) Unmarshal

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

func (*QueryStatusResponse) XXX_DiscardUnknown

func (m *QueryStatusResponse) XXX_DiscardUnknown()

func (*QueryStatusResponse) XXX_Marshal

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

func (*QueryStatusResponse) XXX_Merge

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

func (*QueryStatusResponse) XXX_Size

func (m *QueryStatusResponse) XXX_Size() int

func (*QueryStatusResponse) XXX_Unmarshal

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

type RegisterWorkerRequest

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

func (*RegisterWorkerRequest) Descriptor

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

func (*RegisterWorkerRequest) GetAddress

func (m *RegisterWorkerRequest) GetAddress() string

func (*RegisterWorkerRequest) GetName

func (m *RegisterWorkerRequest) GetName() string

func (*RegisterWorkerRequest) Marshal

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

func (*RegisterWorkerRequest) MarshalTo

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

func (*RegisterWorkerRequest) MarshalToSizedBuffer

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

func (*RegisterWorkerRequest) ProtoMessage

func (*RegisterWorkerRequest) ProtoMessage()

func (*RegisterWorkerRequest) Reset

func (m *RegisterWorkerRequest) Reset()

func (*RegisterWorkerRequest) Size

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

func (*RegisterWorkerRequest) String

func (m *RegisterWorkerRequest) String() string

func (*RegisterWorkerRequest) Unmarshal

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

func (*RegisterWorkerRequest) XXX_DiscardUnknown

func (m *RegisterWorkerRequest) XXX_DiscardUnknown()

func (*RegisterWorkerRequest) XXX_Marshal

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

func (*RegisterWorkerRequest) XXX_Merge

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

func (*RegisterWorkerRequest) XXX_Size

func (m *RegisterWorkerRequest) XXX_Size() int

func (*RegisterWorkerRequest) XXX_Unmarshal

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

type RegisterWorkerResponse

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

func (*RegisterWorkerResponse) Descriptor

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

func (*RegisterWorkerResponse) GetMsg

func (m *RegisterWorkerResponse) GetMsg() string

func (*RegisterWorkerResponse) GetResult

func (m *RegisterWorkerResponse) GetResult() bool

func (*RegisterWorkerResponse) Marshal

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

func (*RegisterWorkerResponse) MarshalTo

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

func (*RegisterWorkerResponse) MarshalToSizedBuffer

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

func (*RegisterWorkerResponse) ProtoMessage

func (*RegisterWorkerResponse) ProtoMessage()

func (*RegisterWorkerResponse) Reset

func (m *RegisterWorkerResponse) Reset()

func (*RegisterWorkerResponse) Size

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

func (*RegisterWorkerResponse) String

func (m *RegisterWorkerResponse) String() string

func (*RegisterWorkerResponse) Unmarshal

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

func (*RegisterWorkerResponse) XXX_DiscardUnknown

func (m *RegisterWorkerResponse) XXX_DiscardUnknown()

func (*RegisterWorkerResponse) XXX_Marshal

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

func (*RegisterWorkerResponse) XXX_Merge

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

func (*RegisterWorkerResponse) XXX_Size

func (m *RegisterWorkerResponse) XXX_Size() int

func (*RegisterWorkerResponse) XXX_Unmarshal

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

type RelayError

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

RelayError represents error for relay unit.

func (*RelayError) Descriptor

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

func (*RelayError) GetMsg

func (m *RelayError) GetMsg() string

func (*RelayError) Marshal

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

func (*RelayError) MarshalTo

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

func (*RelayError) MarshalToSizedBuffer

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

func (*RelayError) ProtoMessage

func (*RelayError) ProtoMessage()

func (*RelayError) Reset

func (m *RelayError) Reset()

func (*RelayError) Size

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

func (*RelayError) String

func (m *RelayError) String() string

func (*RelayError) Unmarshal

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

func (*RelayError) XXX_DiscardUnknown

func (m *RelayError) XXX_DiscardUnknown()

func (*RelayError) XXX_Marshal

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

func (*RelayError) XXX_Merge

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

func (*RelayError) XXX_Size

func (m *RelayError) XXX_Size() int

func (*RelayError) XXX_Unmarshal

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

type RelayOp

type RelayOp int32

RelayOp differs from TaskOp

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

func (RelayOp) EnumDescriptor

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

func (RelayOp) String

func (x RelayOp) String() string

type RelayStatus

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

RelayStatus represents status for relay unit.

func (*RelayStatus) Descriptor

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

func (*RelayStatus) GetMasterBinlog

func (m *RelayStatus) GetMasterBinlog() string

func (*RelayStatus) GetMasterBinlogGtid

func (m *RelayStatus) GetMasterBinlogGtid() string

func (*RelayStatus) GetRelayBinlog

func (m *RelayStatus) GetRelayBinlog() string

func (*RelayStatus) GetRelayBinlogGtid

func (m *RelayStatus) GetRelayBinlogGtid() string

func (*RelayStatus) GetRelayCatchUpMaster

func (m *RelayStatus) GetRelayCatchUpMaster() bool

func (*RelayStatus) GetRelaySubDir

func (m *RelayStatus) GetRelaySubDir() string

func (*RelayStatus) GetResult

func (m *RelayStatus) GetResult() *ProcessResult

func (*RelayStatus) GetStage

func (m *RelayStatus) GetStage() Stage

func (*RelayStatus) Marshal

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

func (*RelayStatus) MarshalTo

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

func (*RelayStatus) MarshalToSizedBuffer

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

func (*RelayStatus) ProtoMessage

func (*RelayStatus) ProtoMessage()

func (*RelayStatus) Reset

func (m *RelayStatus) Reset()

func (*RelayStatus) Size

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

func (*RelayStatus) String

func (m *RelayStatus) String() string

func (*RelayStatus) Unmarshal

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

func (*RelayStatus) XXX_DiscardUnknown

func (m *RelayStatus) XXX_DiscardUnknown()

func (*RelayStatus) XXX_Marshal

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

func (*RelayStatus) XXX_Merge

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

func (*RelayStatus) XXX_Size

func (m *RelayStatus) XXX_Size() int

func (*RelayStatus) XXX_Unmarshal

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

type SchemaOp

type SchemaOp int32
const (
	SchemaOp_InvalidSchemaOp SchemaOp = 0
	SchemaOp_GetSchema       SchemaOp = 1
	SchemaOp_SetSchema       SchemaOp = 2
	SchemaOp_RemoveSchema    SchemaOp = 3
)

func (SchemaOp) EnumDescriptor

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

func (SchemaOp) String

func (x SchemaOp) String() string

type ShardingGroup

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

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

func (*ShardingGroup) Descriptor

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

func (*ShardingGroup) GetDDLs

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

func (*ShardingGroup) GetFirstLocation

func (m *ShardingGroup) GetFirstLocation() string

func (*ShardingGroup) GetSynced

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

func (*ShardingGroup) GetTarget

func (m *ShardingGroup) GetTarget() string

func (*ShardingGroup) GetUnsynced

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

func (*ShardingGroup) Marshal

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

func (*ShardingGroup) MarshalTo

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

func (*ShardingGroup) MarshalToSizedBuffer

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

func (*ShardingGroup) ProtoMessage

func (*ShardingGroup) ProtoMessage()

func (*ShardingGroup) Reset

func (m *ShardingGroup) Reset()

func (*ShardingGroup) Size

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

func (*ShardingGroup) String

func (m *ShardingGroup) String() string

func (*ShardingGroup) Unmarshal

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

func (*ShardingGroup) XXX_DiscardUnknown

func (m *ShardingGroup) XXX_DiscardUnknown()

func (*ShardingGroup) XXX_Marshal

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

func (*ShardingGroup) XXX_Merge

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

func (*ShardingGroup) XXX_Size

func (m *ShardingGroup) XXX_Size() int

func (*ShardingGroup) XXX_Unmarshal

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

type ShowDDLLocksRequest

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

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

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

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

func (*ShowDDLLocksRequest) Descriptor

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

func (*ShowDDLLocksRequest) GetSources

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

func (*ShowDDLLocksRequest) GetTask

func (m *ShowDDLLocksRequest) GetTask() string

func (*ShowDDLLocksRequest) Marshal

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

func (*ShowDDLLocksRequest) MarshalTo

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

func (*ShowDDLLocksRequest) MarshalToSizedBuffer

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

func (*ShowDDLLocksRequest) ProtoMessage

func (*ShowDDLLocksRequest) ProtoMessage()

func (*ShowDDLLocksRequest) Reset

func (m *ShowDDLLocksRequest) Reset()

func (*ShowDDLLocksRequest) Size

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

func (*ShowDDLLocksRequest) String

func (m *ShowDDLLocksRequest) String() string

func (*ShowDDLLocksRequest) Unmarshal

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

func (*ShowDDLLocksRequest) XXX_DiscardUnknown

func (m *ShowDDLLocksRequest) XXX_DiscardUnknown()

func (*ShowDDLLocksRequest) XXX_Marshal

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

func (*ShowDDLLocksRequest) XXX_Merge

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

func (*ShowDDLLocksRequest) XXX_Size

func (m *ShowDDLLocksRequest) XXX_Size() int

func (*ShowDDLLocksRequest) XXX_Unmarshal

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

type ShowDDLLocksResponse

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

func (*ShowDDLLocksResponse) Descriptor

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

func (*ShowDDLLocksResponse) GetLocks

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

func (*ShowDDLLocksResponse) GetMsg

func (m *ShowDDLLocksResponse) GetMsg() string

func (*ShowDDLLocksResponse) GetResult

func (m *ShowDDLLocksResponse) GetResult() bool

func (*ShowDDLLocksResponse) Marshal

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

func (*ShowDDLLocksResponse) MarshalTo

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

func (*ShowDDLLocksResponse) MarshalToSizedBuffer

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

func (*ShowDDLLocksResponse) ProtoMessage

func (*ShowDDLLocksResponse) ProtoMessage()

func (*ShowDDLLocksResponse) Reset

func (m *ShowDDLLocksResponse) Reset()

func (*ShowDDLLocksResponse) Size

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

func (*ShowDDLLocksResponse) String

func (m *ShowDDLLocksResponse) String() string

func (*ShowDDLLocksResponse) Unmarshal

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

func (*ShowDDLLocksResponse) XXX_DiscardUnknown

func (m *ShowDDLLocksResponse) XXX_DiscardUnknown()

func (*ShowDDLLocksResponse) XXX_Marshal

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

func (*ShowDDLLocksResponse) XXX_Merge

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

func (*ShowDDLLocksResponse) XXX_Size

func (m *ShowDDLLocksResponse) XXX_Size() int

func (*ShowDDLLocksResponse) XXX_Unmarshal

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

type SourceError

type SourceError struct {
	Source      string      `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`
	Worker      string      `protobuf:"bytes,2,opt,name=worker,proto3" json:"worker,omitempty"`
	SourceError string      `protobuf:"bytes,3,opt,name=SourceError,proto3" json:"SourceError,omitempty"`
	RelayError  *RelayError `protobuf:"bytes,4,opt,name=RelayError,proto3" json:"RelayError,omitempty"`
}

SourceError represents error for start/stop source on dm-worker

func (*SourceError) Descriptor

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

func (*SourceError) GetRelayError

func (m *SourceError) GetRelayError() *RelayError

func (*SourceError) GetSource

func (m *SourceError) GetSource() string

func (*SourceError) GetSourceError

func (m *SourceError) GetSourceError() string

func (*SourceError) GetWorker

func (m *SourceError) GetWorker() string

func (*SourceError) Marshal

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

func (*SourceError) MarshalTo

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

func (*SourceError) MarshalToSizedBuffer

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

func (*SourceError) ProtoMessage

func (*SourceError) ProtoMessage()

func (*SourceError) Reset

func (m *SourceError) Reset()

func (*SourceError) Size

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

func (*SourceError) String

func (m *SourceError) String() string

func (*SourceError) Unmarshal

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

func (*SourceError) XXX_DiscardUnknown

func (m *SourceError) XXX_DiscardUnknown()

func (*SourceError) XXX_Marshal

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

func (*SourceError) XXX_Merge

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

func (*SourceError) XXX_Size

func (m *SourceError) XXX_Size() int

func (*SourceError) XXX_Unmarshal

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

type SourceOp

type SourceOp int32
const (
	SourceOp_InvalidSourceOp SourceOp = 0
	SourceOp_StartSource     SourceOp = 1
	SourceOp_UpdateSource    SourceOp = 2
	SourceOp_StopSource      SourceOp = 3
	SourceOp_ShowSource      SourceOp = 4
)

func (SourceOp) EnumDescriptor

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

func (SourceOp) String

func (x SourceOp) String() string

type SourceStatus

type SourceStatus struct {
	Source      string         `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`
	Worker      string         `protobuf:"bytes,2,opt,name=worker,proto3" json:"worker,omitempty"`
	Result      *ProcessResult `protobuf:"bytes,3,opt,name=result,proto3" json:"result,omitempty"`
	RelayStatus *RelayStatus   `protobuf:"bytes,4,opt,name=relayStatus,proto3" json:"relayStatus,omitempty"`
}

SourceStatus represents status for source runing on dm-worker

func (*SourceStatus) Descriptor

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

func (*SourceStatus) GetRelayStatus

func (m *SourceStatus) GetRelayStatus() *RelayStatus

func (*SourceStatus) GetResult

func (m *SourceStatus) GetResult() *ProcessResult

func (*SourceStatus) GetSource

func (m *SourceStatus) GetSource() string

func (*SourceStatus) GetWorker

func (m *SourceStatus) GetWorker() string

func (*SourceStatus) Marshal

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

func (*SourceStatus) MarshalTo

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

func (*SourceStatus) MarshalToSizedBuffer

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

func (*SourceStatus) ProtoMessage

func (*SourceStatus) ProtoMessage()

func (*SourceStatus) Reset

func (m *SourceStatus) Reset()

func (*SourceStatus) Size

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

func (*SourceStatus) String

func (m *SourceStatus) String() string

func (*SourceStatus) Unmarshal

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

func (*SourceStatus) XXX_DiscardUnknown

func (m *SourceStatus) XXX_DiscardUnknown()

func (*SourceStatus) XXX_Marshal

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

func (*SourceStatus) XXX_Merge

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

func (*SourceStatus) XXX_Size

func (m *SourceStatus) XXX_Size() int

func (*SourceStatus) XXX_Unmarshal

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

type Stage

type Stage int32

Stage represents current stage for a (sub) task a (sub) task should be always in one stage of the following stages (sub) task can transfer from on stage to some special other stages New: initial stage when a sub task is created

can not transfered from other stages
transfer to Running when initialize with no error

Running: indicates the sub task is processing

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

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

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

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

transfered from Running / Paused when requested from external
can not transfer to any stages

Finished: indicates the processing is finished, and no need to re-run

transfered from Running when processing completed
should not transfer to any stages
const (
	Stage_InvalidStage Stage = 0
	Stage_New          Stage = 1
	Stage_Running      Stage = 2
	Stage_Paused       Stage = 3
	Stage_Stopped      Stage = 4
	Stage_Finished     Stage = 5
	Stage_Pausing      Stage = 6
	Stage_Resuming     Stage = 7
)

func (Stage) EnumDescriptor

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

func (Stage) String

func (x Stage) String() string

type StartTaskRequest

type StartTaskRequest struct {
	Task       string   `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	Sources    []string `protobuf:"bytes,2,rep,name=sources,proto3" json:"sources,omitempty"`
	RemoveMeta bool     `protobuf:"varint,3,opt,name=removeMeta,proto3" json:"removeMeta,omitempty"`
}

func (*StartTaskRequest) Descriptor

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

func (*StartTaskRequest) GetRemoveMeta

func (m *StartTaskRequest) GetRemoveMeta() bool

func (*StartTaskRequest) GetSources

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

func (*StartTaskRequest) GetTask

func (m *StartTaskRequest) GetTask() string

func (*StartTaskRequest) Marshal

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

func (*StartTaskRequest) MarshalTo

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

func (*StartTaskRequest) MarshalToSizedBuffer

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

func (*StartTaskRequest) ProtoMessage

func (*StartTaskRequest) ProtoMessage()

func (*StartTaskRequest) Reset

func (m *StartTaskRequest) Reset()

func (*StartTaskRequest) Size

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

func (*StartTaskRequest) String

func (m *StartTaskRequest) String() string

func (*StartTaskRequest) Unmarshal

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

func (*StartTaskRequest) XXX_DiscardUnknown

func (m *StartTaskRequest) XXX_DiscardUnknown()

func (*StartTaskRequest) XXX_Marshal

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

func (*StartTaskRequest) XXX_Merge

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

func (*StartTaskRequest) XXX_Size

func (m *StartTaskRequest) XXX_Size() int

func (*StartTaskRequest) XXX_Unmarshal

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

type StartTaskResponse

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

func (*StartTaskResponse) Descriptor

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

func (*StartTaskResponse) GetMsg

func (m *StartTaskResponse) GetMsg() string

func (*StartTaskResponse) GetResult

func (m *StartTaskResponse) GetResult() bool

func (*StartTaskResponse) GetSources

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

func (*StartTaskResponse) Marshal

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

func (*StartTaskResponse) MarshalTo

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

func (*StartTaskResponse) MarshalToSizedBuffer

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

func (*StartTaskResponse) ProtoMessage

func (*StartTaskResponse) ProtoMessage()

func (*StartTaskResponse) Reset

func (m *StartTaskResponse) Reset()

func (*StartTaskResponse) Size

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

func (*StartTaskResponse) String

func (m *StartTaskResponse) String() string

func (*StartTaskResponse) Unmarshal

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

func (*StartTaskResponse) XXX_DiscardUnknown

func (m *StartTaskResponse) XXX_DiscardUnknown()

func (*StartTaskResponse) XXX_Marshal

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

func (*StartTaskResponse) XXX_Merge

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

func (*StartTaskResponse) XXX_Size

func (m *StartTaskResponse) XXX_Size() int

func (*StartTaskResponse) XXX_Unmarshal

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

type SubTaskError

type SubTaskError struct {
	Name  string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Stage Stage    `protobuf:"varint,2,opt,name=stage,proto3,enum=pb.Stage" json:"stage,omitempty"`
	Unit  UnitType `protobuf:"varint,3,opt,name=unit,proto3,enum=pb.UnitType" json:"unit,omitempty"`
	// Types that are valid to be assigned to Error:
	//	*SubTaskError_Msg
	//	*SubTaskError_Check
	//	*SubTaskError_Dump
	//	*SubTaskError_Load
	//	*SubTaskError_Sync
	Error isSubTaskError_Error `protobuf_oneof:"error"`
}

SubTaskError represents error for a sub task during running name: sub task'name, when starting a sub task the name should be unique stage: sub task's current stage unit: sub task's current dm unit's UnitType error: current unit's error information

for Sync, includes failed sql, failed sql pos in binlog, etc.

func (*SubTaskError) Descriptor

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

func (*SubTaskError) GetCheck

func (m *SubTaskError) GetCheck() *CheckError

func (*SubTaskError) GetDump

func (m *SubTaskError) GetDump() *DumpError

func (*SubTaskError) GetError

func (m *SubTaskError) GetError() isSubTaskError_Error

func (*SubTaskError) GetLoad

func (m *SubTaskError) GetLoad() *LoadError

func (*SubTaskError) GetMsg

func (m *SubTaskError) GetMsg() string

func (*SubTaskError) GetName

func (m *SubTaskError) GetName() string

func (*SubTaskError) GetStage

func (m *SubTaskError) GetStage() Stage

func (*SubTaskError) GetSync

func (m *SubTaskError) GetSync() *SyncError

func (*SubTaskError) GetUnit

func (m *SubTaskError) GetUnit() UnitType

func (*SubTaskError) Marshal

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

func (*SubTaskError) MarshalTo

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

func (*SubTaskError) MarshalToSizedBuffer

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

func (*SubTaskError) ProtoMessage

func (*SubTaskError) ProtoMessage()

func (*SubTaskError) Reset

func (m *SubTaskError) Reset()

func (*SubTaskError) Size

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

func (*SubTaskError) String

func (m *SubTaskError) String() string

func (*SubTaskError) Unmarshal

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

func (*SubTaskError) XXX_DiscardUnknown

func (m *SubTaskError) XXX_DiscardUnknown()

func (*SubTaskError) XXX_Marshal

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

func (*SubTaskError) XXX_Merge

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

func (*SubTaskError) XXX_OneofWrappers

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*SubTaskError) XXX_Size

func (m *SubTaskError) XXX_Size() int

func (*SubTaskError) XXX_Unmarshal

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

type SubTaskErrorList

type SubTaskErrorList struct {
	Error []*SubTaskError `protobuf:"bytes,1,rep,name=error,proto3" json:"error,omitempty"`
}

SubTaskErrorList used for internal jsonpb marshal

func (*SubTaskErrorList) Descriptor

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

func (*SubTaskErrorList) GetError

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

func (*SubTaskErrorList) Marshal

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

func (*SubTaskErrorList) MarshalTo

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

func (*SubTaskErrorList) MarshalToSizedBuffer

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

func (*SubTaskErrorList) ProtoMessage

func (*SubTaskErrorList) ProtoMessage()

func (*SubTaskErrorList) Reset

func (m *SubTaskErrorList) Reset()

func (*SubTaskErrorList) Size

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

func (*SubTaskErrorList) String

func (m *SubTaskErrorList) String() string

func (*SubTaskErrorList) Unmarshal

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

func (*SubTaskErrorList) XXX_DiscardUnknown

func (m *SubTaskErrorList) XXX_DiscardUnknown()

func (*SubTaskErrorList) XXX_Marshal

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

func (*SubTaskErrorList) XXX_Merge

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

func (*SubTaskErrorList) XXX_Size

func (m *SubTaskErrorList) XXX_Size() int

func (*SubTaskErrorList) XXX_Unmarshal

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

type SubTaskError_Check

type SubTaskError_Check struct {
	Check *CheckError `protobuf:"bytes,5,opt,name=check,proto3,oneof" json:"check,omitempty"`
}

func (*SubTaskError_Check) MarshalTo

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

func (*SubTaskError_Check) MarshalToSizedBuffer

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

func (*SubTaskError_Check) Size

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

type SubTaskError_Dump

type SubTaskError_Dump struct {
	Dump *DumpError `protobuf:"bytes,6,opt,name=dump,proto3,oneof" json:"dump,omitempty"`
}

func (*SubTaskError_Dump) MarshalTo

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

func (*SubTaskError_Dump) MarshalToSizedBuffer

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

func (*SubTaskError_Dump) Size

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

type SubTaskError_Load

type SubTaskError_Load struct {
	Load *LoadError `protobuf:"bytes,7,opt,name=load,proto3,oneof" json:"load,omitempty"`
}

func (*SubTaskError_Load) MarshalTo

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

func (*SubTaskError_Load) MarshalToSizedBuffer

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

func (*SubTaskError_Load) Size

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

type SubTaskError_Msg

type SubTaskError_Msg struct {
	Msg string `protobuf:"bytes,4,opt,name=msg,proto3,oneof" json:"msg,omitempty"`
}

func (*SubTaskError_Msg) MarshalTo

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

func (*SubTaskError_Msg) MarshalToSizedBuffer

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

func (*SubTaskError_Msg) Size

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

type SubTaskError_Sync

type SubTaskError_Sync struct {
	Sync *SyncError `protobuf:"bytes,8,opt,name=sync,proto3,oneof" json:"sync,omitempty"`
}

func (*SubTaskError_Sync) MarshalTo

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

func (*SubTaskError_Sync) MarshalToSizedBuffer

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

func (*SubTaskError_Sync) Size

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

type SubTaskStatus

type SubTaskStatus struct {
	Name                string         `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Stage               Stage          `protobuf:"varint,2,opt,name=stage,proto3,enum=pb.Stage" json:"stage,omitempty"`
	Unit                UnitType       `protobuf:"varint,3,opt,name=unit,proto3,enum=pb.UnitType" json:"unit,omitempty"`
	Result              *ProcessResult `protobuf:"bytes,4,opt,name=result,proto3" json:"result,omitempty"`
	UnresolvedDDLLockID string         `protobuf:"bytes,5,opt,name=unresolvedDDLLockID,proto3" json:"unresolvedDDLLockID,omitempty"`
	// Types that are valid to be assigned to Status:
	//	*SubTaskStatus_Msg
	//	*SubTaskStatus_Check
	//	*SubTaskStatus_Dump
	//	*SubTaskStatus_Load
	//	*SubTaskStatus_Sync
	Status isSubTaskStatus_Status `protobuf_oneof:"status"`
}

SubTaskStatus represents status for a sub task name: sub task'name, when starting a sub task the name should be unique stage: sub task's current stage unit: sub task's current dm unit's UnitType result: current unit's process result, when the stage is Running, no result unresolvedDDLLockID: un-resolved sharding DDL lock ID (ref DDLLockInfo)

if needed, we can put this to SyncStatus

status: current unit's statistics

for Load, includes total bytes, progress, etc.
for Sync, includes TPS, binlog meta, etc.

func (*SubTaskStatus) Descriptor

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

func (*SubTaskStatus) GetCheck

func (m *SubTaskStatus) GetCheck() *CheckStatus

func (*SubTaskStatus) GetDump

func (m *SubTaskStatus) GetDump() *DumpStatus

func (*SubTaskStatus) GetLoad

func (m *SubTaskStatus) GetLoad() *LoadStatus

func (*SubTaskStatus) GetMsg

func (m *SubTaskStatus) GetMsg() string

func (*SubTaskStatus) GetName

func (m *SubTaskStatus) GetName() string

func (*SubTaskStatus) GetResult

func (m *SubTaskStatus) GetResult() *ProcessResult

func (*SubTaskStatus) GetStage

func (m *SubTaskStatus) GetStage() Stage

func (*SubTaskStatus) GetStatus

func (m *SubTaskStatus) GetStatus() isSubTaskStatus_Status

func (*SubTaskStatus) GetSync

func (m *SubTaskStatus) GetSync() *SyncStatus

func (*SubTaskStatus) GetUnit

func (m *SubTaskStatus) GetUnit() UnitType

func (*SubTaskStatus) GetUnresolvedDDLLockID

func (m *SubTaskStatus) GetUnresolvedDDLLockID() string

func (*SubTaskStatus) Marshal

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

func (*SubTaskStatus) MarshalTo

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

func (*SubTaskStatus) MarshalToSizedBuffer

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

func (*SubTaskStatus) ProtoMessage

func (*SubTaskStatus) ProtoMessage()

func (*SubTaskStatus) Reset

func (m *SubTaskStatus) Reset()

func (*SubTaskStatus) Size

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

func (*SubTaskStatus) String

func (m *SubTaskStatus) String() string

func (*SubTaskStatus) Unmarshal

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

func (*SubTaskStatus) XXX_DiscardUnknown

func (m *SubTaskStatus) XXX_DiscardUnknown()

func (*SubTaskStatus) XXX_Marshal

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

func (*SubTaskStatus) XXX_Merge

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

func (*SubTaskStatus) XXX_OneofWrappers

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*SubTaskStatus) XXX_Size

func (m *SubTaskStatus) XXX_Size() int

func (*SubTaskStatus) XXX_Unmarshal

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

type SubTaskStatusList

type SubTaskStatusList struct {
	Status []*SubTaskStatus `protobuf:"bytes,1,rep,name=status,proto3" json:"status,omitempty"`
}

SubTaskStatusList used for internal jsonpb marshal

func (*SubTaskStatusList) Descriptor

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

func (*SubTaskStatusList) GetStatus

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

func (*SubTaskStatusList) Marshal

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

func (*SubTaskStatusList) MarshalTo

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

func (*SubTaskStatusList) MarshalToSizedBuffer

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

func (*SubTaskStatusList) ProtoMessage

func (*SubTaskStatusList) ProtoMessage()

func (*SubTaskStatusList) Reset

func (m *SubTaskStatusList) Reset()

func (*SubTaskStatusList) Size

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

func (*SubTaskStatusList) String

func (m *SubTaskStatusList) String() string

func (*SubTaskStatusList) Unmarshal

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

func (*SubTaskStatusList) XXX_DiscardUnknown

func (m *SubTaskStatusList) XXX_DiscardUnknown()

func (*SubTaskStatusList) XXX_Marshal

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

func (*SubTaskStatusList) XXX_Merge

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

func (*SubTaskStatusList) XXX_Size

func (m *SubTaskStatusList) XXX_Size() int

func (*SubTaskStatusList) XXX_Unmarshal

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

type SubTaskStatus_Check

type SubTaskStatus_Check struct {
	Check *CheckStatus `protobuf:"bytes,7,opt,name=check,proto3,oneof" json:"check,omitempty"`
}

func (*SubTaskStatus_Check) MarshalTo

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

func (*SubTaskStatus_Check) MarshalToSizedBuffer

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

func (*SubTaskStatus_Check) Size

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

type SubTaskStatus_Dump

type SubTaskStatus_Dump struct {
	Dump *DumpStatus `protobuf:"bytes,8,opt,name=dump,proto3,oneof" json:"dump,omitempty"`
}

func (*SubTaskStatus_Dump) MarshalTo

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

func (*SubTaskStatus_Dump) MarshalToSizedBuffer

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

func (*SubTaskStatus_Dump) Size

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

type SubTaskStatus_Load

type SubTaskStatus_Load struct {
	Load *LoadStatus `protobuf:"bytes,9,opt,name=load,proto3,oneof" json:"load,omitempty"`
}

func (*SubTaskStatus_Load) MarshalTo

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

func (*SubTaskStatus_Load) MarshalToSizedBuffer

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

func (*SubTaskStatus_Load) Size

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

type SubTaskStatus_Msg

type SubTaskStatus_Msg struct {
	Msg string `protobuf:"bytes,6,opt,name=msg,proto3,oneof" json:"msg,omitempty"`
}

func (*SubTaskStatus_Msg) MarshalTo

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

func (*SubTaskStatus_Msg) MarshalToSizedBuffer

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

func (*SubTaskStatus_Msg) Size

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

type SubTaskStatus_Sync

type SubTaskStatus_Sync struct {
	Sync *SyncStatus `protobuf:"bytes,10,opt,name=sync,proto3,oneof" json:"sync,omitempty"`
}

func (*SubTaskStatus_Sync) MarshalTo

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

func (*SubTaskStatus_Sync) MarshalToSizedBuffer

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

func (*SubTaskStatus_Sync) Size

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

type SyncError

type SyncError struct {
	Errors []*SyncSQLError `protobuf:"bytes,1,rep,name=errors,proto3" json:"errors,omitempty"`
}

SyncError represents error list for sync unit

func (*SyncError) Descriptor

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

func (*SyncError) GetErrors

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

func (*SyncError) Marshal

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

func (*SyncError) MarshalTo

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

func (*SyncError) MarshalToSizedBuffer

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

func (*SyncError) ProtoMessage

func (*SyncError) ProtoMessage()

func (*SyncError) Reset

func (m *SyncError) Reset()

func (*SyncError) Size

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

func (*SyncError) String

func (m *SyncError) String() string

func (*SyncError) Unmarshal

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

func (*SyncError) XXX_DiscardUnknown

func (m *SyncError) XXX_DiscardUnknown()

func (*SyncError) XXX_Marshal

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

func (*SyncError) XXX_Merge

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

func (*SyncError) XXX_Size

func (m *SyncError) XXX_Size() int

func (*SyncError) XXX_Unmarshal

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

type SyncSQLError

type SyncSQLError struct {
	Msg                  string `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
	FailedBinlogPosition string `protobuf:"bytes,2,opt,name=failedBinlogPosition,proto3" json:"failedBinlogPosition,omitempty"`
	ErrorSQL             string `protobuf:"bytes,3,opt,name=errorSQL,proto3" json:"errorSQL,omitempty"`
}

SyncSQLError represents a sql error in sync unit

func (*SyncSQLError) Descriptor

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

func (*SyncSQLError) GetErrorSQL

func (m *SyncSQLError) GetErrorSQL() string

func (*SyncSQLError) GetFailedBinlogPosition

func (m *SyncSQLError) GetFailedBinlogPosition() string

func (*SyncSQLError) GetMsg

func (m *SyncSQLError) GetMsg() string

func (*SyncSQLError) Marshal

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

func (*SyncSQLError) MarshalTo

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

func (*SyncSQLError) MarshalToSizedBuffer

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

func (*SyncSQLError) ProtoMessage

func (*SyncSQLError) ProtoMessage()

func (*SyncSQLError) Reset

func (m *SyncSQLError) Reset()

func (*SyncSQLError) Size

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

func (*SyncSQLError) String

func (m *SyncSQLError) String() string

func (*SyncSQLError) Unmarshal

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

func (*SyncSQLError) XXX_DiscardUnknown

func (m *SyncSQLError) XXX_DiscardUnknown()

func (*SyncSQLError) XXX_Marshal

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

func (*SyncSQLError) XXX_Merge

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

func (*SyncSQLError) XXX_Size

func (m *SyncSQLError) XXX_Size() int

func (*SyncSQLError) XXX_Unmarshal

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

type SyncStatus

type SyncStatus struct {
	TotalEvents      int64            `protobuf:"varint,1,opt,name=totalEvents,proto3" json:"totalEvents,omitempty"`
	TotalTps         int64            `protobuf:"varint,2,opt,name=totalTps,proto3" json:"totalTps,omitempty"`
	RecentTps        int64            `protobuf:"varint,3,opt,name=recentTps,proto3" json:"recentTps,omitempty"`
	MasterBinlog     string           `protobuf:"bytes,4,opt,name=masterBinlog,proto3" json:"masterBinlog,omitempty"`
	MasterBinlogGtid string           `protobuf:"bytes,5,opt,name=masterBinlogGtid,proto3" json:"masterBinlogGtid,omitempty"`
	SyncerBinlog     string           `protobuf:"bytes,6,opt,name=syncerBinlog,proto3" json:"syncerBinlog,omitempty"`
	SyncerBinlogGtid string           `protobuf:"bytes,7,opt,name=syncerBinlogGtid,proto3" json:"syncerBinlogGtid,omitempty"`
	BlockingDDLs     []string         `protobuf:"bytes,8,rep,name=blockingDDLs,proto3" json:"blockingDDLs,omitempty"`
	UnresolvedGroups []*ShardingGroup `protobuf:"bytes,9,rep,name=unresolvedGroups,proto3" json:"unresolvedGroups,omitempty"`
	Synced           bool             `protobuf:"varint,10,opt,name=synced,proto3" json:"synced,omitempty"`
	BinlogType       string           `protobuf:"bytes,11,opt,name=binlogType,proto3" json:"binlogType,omitempty"`
}

SyncStatus represents status for sync unit

func (*SyncStatus) Descriptor

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

func (*SyncStatus) GetBinlogType

func (m *SyncStatus) GetBinlogType() string

func (*SyncStatus) GetBlockingDDLs

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

func (*SyncStatus) GetMasterBinlog

func (m *SyncStatus) GetMasterBinlog() string

func (*SyncStatus) GetMasterBinlogGtid

func (m *SyncStatus) GetMasterBinlogGtid() string

func (*SyncStatus) GetRecentTps

func (m *SyncStatus) GetRecentTps() int64

func (*SyncStatus) GetSynced

func (m *SyncStatus) GetSynced() bool

func (*SyncStatus) GetSyncerBinlog

func (m *SyncStatus) GetSyncerBinlog() string

func (*SyncStatus) GetSyncerBinlogGtid

func (m *SyncStatus) GetSyncerBinlogGtid() string

func (*SyncStatus) GetTotalEvents

func (m *SyncStatus) GetTotalEvents() int64

func (*SyncStatus) GetTotalTps

func (m *SyncStatus) GetTotalTps() int64

func (*SyncStatus) GetUnresolvedGroups

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

func (*SyncStatus) Marshal

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

func (*SyncStatus) MarshalTo

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

func (*SyncStatus) MarshalToSizedBuffer

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

func (*SyncStatus) ProtoMessage

func (*SyncStatus) ProtoMessage()

func (*SyncStatus) Reset

func (m *SyncStatus) Reset()

func (*SyncStatus) Size

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

func (*SyncStatus) String

func (m *SyncStatus) String() string

func (*SyncStatus) Unmarshal

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

func (*SyncStatus) XXX_DiscardUnknown

func (m *SyncStatus) XXX_DiscardUnknown()

func (*SyncStatus) XXX_Marshal

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

func (*SyncStatus) XXX_Merge

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

func (*SyncStatus) XXX_Size

func (m *SyncStatus) XXX_Size() int

func (*SyncStatus) XXX_Unmarshal

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

type TaskOp

type TaskOp int32
const (
	TaskOp_InvalidOp  TaskOp = 0
	TaskOp_Stop       TaskOp = 1
	TaskOp_Pause      TaskOp = 2
	TaskOp_Resume     TaskOp = 3
	TaskOp_Start      TaskOp = 4
	TaskOp_Update     TaskOp = 5
	TaskOp_AutoResume TaskOp = 6
)

func (TaskOp) EnumDescriptor

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

func (TaskOp) String

func (x TaskOp) String() string

type UnimplementedMasterServer

type UnimplementedMasterServer struct {
}

UnimplementedMasterServer can be embedded to have forward compatible implementations.

func (*UnimplementedMasterServer) CheckTask

func (*UnimplementedMasterServer) GetCfg

func (*UnimplementedMasterServer) GetMasterCfg

func (*UnimplementedMasterServer) GetSubTaskCfg

func (*UnimplementedMasterServer) HandleError

func (*UnimplementedMasterServer) ListMember

func (*UnimplementedMasterServer) OfflineMember

func (*UnimplementedMasterServer) OperateLeader

func (*UnimplementedMasterServer) OperateSchema

func (*UnimplementedMasterServer) OperateSource

func (*UnimplementedMasterServer) OperateTask

func (*UnimplementedMasterServer) OperateWorkerRelayTask

func (*UnimplementedMasterServer) PurgeWorkerRelay

func (*UnimplementedMasterServer) QueryStatus

func (*UnimplementedMasterServer) RegisterWorker

func (*UnimplementedMasterServer) ShowDDLLocks

func (*UnimplementedMasterServer) StartTask

func (*UnimplementedMasterServer) UnlockDDLLock

func (*UnimplementedMasterServer) UpdateTask

type UnimplementedWorkerServer

type UnimplementedWorkerServer struct {
}

UnimplementedWorkerServer can be embedded to have forward compatible implementations.

func (*UnimplementedWorkerServer) GetWorkerCfg

func (*UnimplementedWorkerServer) HandleError

func (*UnimplementedWorkerServer) OperateSchema

func (*UnimplementedWorkerServer) OperateV1Meta

func (*UnimplementedWorkerServer) PurgeRelay

func (*UnimplementedWorkerServer) QueryStatus

type UnitType

type UnitType int32

UnitType represents the dm unit's type

const (
	UnitType_InvalidUnit UnitType = 0
	UnitType_Check       UnitType = 1
	UnitType_Dump        UnitType = 2
	UnitType_Load        UnitType = 3
	UnitType_Sync        UnitType = 4
	UnitType_Relay       UnitType = 100
)

func (UnitType) EnumDescriptor

func (UnitType) EnumDescriptor() ([]byte, []int)

func (UnitType) String

func (x UnitType) String() string

type UnlockDDLLockRequest

type UnlockDDLLockRequest struct {
	ID           string `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	ReplaceOwner string `protobuf:"bytes,2,opt,name=replaceOwner,proto3" json:"replaceOwner,omitempty"`
	ForceRemove  bool   `protobuf:"varint,3,opt,name=forceRemove,proto3" json:"forceRemove,omitempty"`
}

UnlockDDLLockRequest used to unlock (resolve) DDL lock manually ID: DDL lock ID replaceOwner: dm-worker used to replace the original DDL lock's owner forceRemove: force to remove the DDL lock even fail to execute the DDL for the owner.

func (*UnlockDDLLockRequest) Descriptor

func (*UnlockDDLLockRequest) Descriptor() ([]byte, []int)

func (*UnlockDDLLockRequest) GetForceRemove

func (m *UnlockDDLLockRequest) GetForceRemove() bool

func (*UnlockDDLLockRequest) GetID

func (m *UnlockDDLLockRequest) GetID() string

func (*UnlockDDLLockRequest) GetReplaceOwner

func (m *UnlockDDLLockRequest) GetReplaceOwner() string

func (*UnlockDDLLockRequest) Marshal

func (m *UnlockDDLLockRequest) Marshal() (dAtA []byte, err error)

func (*UnlockDDLLockRequest) MarshalTo

func (m *UnlockDDLLockRequest) MarshalTo(dAtA []byte) (int, error)

func (*UnlockDDLLockRequest) MarshalToSizedBuffer

func (m *UnlockDDLLockRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UnlockDDLLockRequest) ProtoMessage

func (*UnlockDDLLockRequest) ProtoMessage()

func (*UnlockDDLLockRequest) Reset

func (m *UnlockDDLLockRequest) Reset()

func (*UnlockDDLLockRequest) Size

func (m *UnlockDDLLockRequest) Size() (n int)

func (*UnlockDDLLockRequest) String

func (m *UnlockDDLLockRequest) String() string

func (*UnlockDDLLockRequest) Unmarshal

func (m *UnlockDDLLockRequest) Unmarshal(dAtA []byte) error

func (*UnlockDDLLockRequest) XXX_DiscardUnknown

func (m *UnlockDDLLockRequest) XXX_DiscardUnknown()

func (*UnlockDDLLockRequest) XXX_Marshal

func (m *UnlockDDLLockRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UnlockDDLLockRequest) XXX_Merge

func (m *UnlockDDLLockRequest) XXX_Merge(src proto.Message)

func (*UnlockDDLLockRequest) XXX_Size

func (m *UnlockDDLLockRequest) XXX_Size() int

func (*UnlockDDLLockRequest) XXX_Unmarshal

func (m *UnlockDDLLockRequest) XXX_Unmarshal(b []byte) error

type UnlockDDLLockResponse

type UnlockDDLLockResponse struct {
	Result bool   `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"`
	Msg    string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
}

func (*UnlockDDLLockResponse) Descriptor

func (*UnlockDDLLockResponse) Descriptor() ([]byte, []int)

func (*UnlockDDLLockResponse) GetMsg

func (m *UnlockDDLLockResponse) GetMsg() string

func (*UnlockDDLLockResponse) GetResult

func (m *UnlockDDLLockResponse) GetResult() bool

func (*UnlockDDLLockResponse) Marshal

func (m *UnlockDDLLockResponse) Marshal() (dAtA []byte, err error)

func (*UnlockDDLLockResponse) MarshalTo

func (m *UnlockDDLLockResponse) MarshalTo(dAtA []byte) (int, error)

func (*UnlockDDLLockResponse) MarshalToSizedBuffer

func (m *UnlockDDLLockResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UnlockDDLLockResponse) ProtoMessage

func (*UnlockDDLLockResponse) ProtoMessage()

func (*UnlockDDLLockResponse) Reset

func (m *UnlockDDLLockResponse) Reset()

func (*UnlockDDLLockResponse) Size

func (m *UnlockDDLLockResponse) Size() (n int)

func (*UnlockDDLLockResponse) String

func (m *UnlockDDLLockResponse) String() string

func (*UnlockDDLLockResponse) Unmarshal

func (m *UnlockDDLLockResponse) Unmarshal(dAtA []byte) error

func (*UnlockDDLLockResponse) XXX_DiscardUnknown

func (m *UnlockDDLLockResponse) XXX_DiscardUnknown()

func (*UnlockDDLLockResponse) XXX_Marshal

func (m *UnlockDDLLockResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UnlockDDLLockResponse) XXX_Merge

func (m *UnlockDDLLockResponse) XXX_Merge(src proto.Message)

func (*UnlockDDLLockResponse) XXX_Size

func (m *UnlockDDLLockResponse) XXX_Size() int

func (*UnlockDDLLockResponse) XXX_Unmarshal

func (m *UnlockDDLLockResponse) XXX_Unmarshal(b []byte) error

type UpdateTaskRequest

type UpdateTaskRequest struct {
	Task    string   `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	Sources []string `protobuf:"bytes,2,rep,name=sources,proto3" json:"sources,omitempty"`
}

UpdateTaskRequest used to update task after it has beed started task: task's configuration, yaml format

now, only support to update config for routes, filters, column-mappings, block-allow-list
support update partial config for syncer, loader, etc later

sources need to do update, empty for all sources in processing the task

func (*UpdateTaskRequest) Descriptor

func (*UpdateTaskRequest) Descriptor() ([]byte, []int)

func (*UpdateTaskRequest) GetSources

func (m *UpdateTaskRequest) GetSources() []string

func (*UpdateTaskRequest) GetTask

func (m *UpdateTaskRequest) GetTask() string

func (*UpdateTaskRequest) Marshal

func (m *UpdateTaskRequest) Marshal() (dAtA []byte, err error)

func (*UpdateTaskRequest) MarshalTo

func (m *UpdateTaskRequest) MarshalTo(dAtA []byte) (int, error)

func (*UpdateTaskRequest) MarshalToSizedBuffer

func (m *UpdateTaskRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UpdateTaskRequest) ProtoMessage

func (*UpdateTaskRequest) ProtoMessage()

func (*UpdateTaskRequest) Reset

func (m *UpdateTaskRequest) Reset()

func (*UpdateTaskRequest) Size

func (m *UpdateTaskRequest) Size() (n int)

func (*UpdateTaskRequest) String

func (m *UpdateTaskRequest) String() string

func (*UpdateTaskRequest) Unmarshal

func (m *UpdateTaskRequest) Unmarshal(dAtA []byte) error

func (*UpdateTaskRequest) XXX_DiscardUnknown

func (m *UpdateTaskRequest) XXX_DiscardUnknown()

func (*UpdateTaskRequest) XXX_Marshal

func (m *UpdateTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateTaskRequest) XXX_Merge

func (m *UpdateTaskRequest) XXX_Merge(src proto.Message)

func (*UpdateTaskRequest) XXX_Size

func (m *UpdateTaskRequest) XXX_Size() int

func (*UpdateTaskRequest) XXX_Unmarshal

func (m *UpdateTaskRequest) XXX_Unmarshal(b []byte) error

type UpdateTaskResponse

type UpdateTaskResponse struct {
	Result  bool                    `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"`
	Msg     string                  `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	Sources []*CommonWorkerResponse `protobuf:"bytes,3,rep,name=sources,proto3" json:"sources,omitempty"`
}

func (*UpdateTaskResponse) Descriptor

func (*UpdateTaskResponse) Descriptor() ([]byte, []int)

func (*UpdateTaskResponse) GetMsg

func (m *UpdateTaskResponse) GetMsg() string

func (*UpdateTaskResponse) GetResult

func (m *UpdateTaskResponse) GetResult() bool

func (*UpdateTaskResponse) GetSources

func (m *UpdateTaskResponse) GetSources() []*CommonWorkerResponse

func (*UpdateTaskResponse) Marshal

func (m *UpdateTaskResponse) Marshal() (dAtA []byte, err error)

func (*UpdateTaskResponse) MarshalTo

func (m *UpdateTaskResponse) MarshalTo(dAtA []byte) (int, error)

func (*UpdateTaskResponse) MarshalToSizedBuffer

func (m *UpdateTaskResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UpdateTaskResponse) ProtoMessage

func (*UpdateTaskResponse) ProtoMessage()

func (*UpdateTaskResponse) Reset

func (m *UpdateTaskResponse) Reset()

func (*UpdateTaskResponse) Size

func (m *UpdateTaskResponse) Size() (n int)

func (*UpdateTaskResponse) String

func (m *UpdateTaskResponse) String() string

func (*UpdateTaskResponse) Unmarshal

func (m *UpdateTaskResponse) Unmarshal(dAtA []byte) error

func (*UpdateTaskResponse) XXX_DiscardUnknown

func (m *UpdateTaskResponse) XXX_DiscardUnknown()

func (*UpdateTaskResponse) XXX_Marshal

func (m *UpdateTaskResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateTaskResponse) XXX_Merge

func (m *UpdateTaskResponse) XXX_Merge(src proto.Message)

func (*UpdateTaskResponse) XXX_Size

func (m *UpdateTaskResponse) XXX_Size() int

func (*UpdateTaskResponse) XXX_Unmarshal

func (m *UpdateTaskResponse) XXX_Unmarshal(b []byte) error

type V1MetaOp

type V1MetaOp int32
const (
	V1MetaOp_InvalidV1MetaOp V1MetaOp = 0
	V1MetaOp_GetV1Meta       V1MetaOp = 1
	V1MetaOp_RemoveV1Meta    V1MetaOp = 2
)

func (V1MetaOp) EnumDescriptor

func (V1MetaOp) EnumDescriptor() ([]byte, []int)

func (V1MetaOp) String

func (x V1MetaOp) String() string

type V1SubTaskMeta

type V1SubTaskMeta struct {
	Op    TaskOp `protobuf:"varint,1,opt,name=op,proto3,enum=pb.TaskOp" json:"op,omitempty"`
	Stage Stage  `protobuf:"varint,2,opt,name=stage,proto3,enum=pb.Stage" json:"stage,omitempty"`
	Name  string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Task  []byte `protobuf:"bytes,4,opt,name=task,proto3" json:"task,omitempty"`
}

copied `TaskMeta` from release-1.0 branch.

func (*V1SubTaskMeta) Descriptor

func (*V1SubTaskMeta) Descriptor() ([]byte, []int)

func (*V1SubTaskMeta) GetName

func (m *V1SubTaskMeta) GetName() string

func (*V1SubTaskMeta) GetOp

func (m *V1SubTaskMeta) GetOp() TaskOp

func (*V1SubTaskMeta) GetStage

func (m *V1SubTaskMeta) GetStage() Stage

func (*V1SubTaskMeta) GetTask

func (m *V1SubTaskMeta) GetTask() []byte

func (*V1SubTaskMeta) Marshal

func (m *V1SubTaskMeta) Marshal() (dAtA []byte, err error)

func (*V1SubTaskMeta) MarshalTo

func (m *V1SubTaskMeta) MarshalTo(dAtA []byte) (int, error)

func (*V1SubTaskMeta) MarshalToSizedBuffer

func (m *V1SubTaskMeta) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*V1SubTaskMeta) ProtoMessage

func (*V1SubTaskMeta) ProtoMessage()

func (*V1SubTaskMeta) Reset

func (m *V1SubTaskMeta) Reset()

func (*V1SubTaskMeta) Size

func (m *V1SubTaskMeta) Size() (n int)

func (*V1SubTaskMeta) String

func (m *V1SubTaskMeta) String() string

func (*V1SubTaskMeta) Unmarshal

func (m *V1SubTaskMeta) Unmarshal(dAtA []byte) error

func (*V1SubTaskMeta) XXX_DiscardUnknown

func (m *V1SubTaskMeta) XXX_DiscardUnknown()

func (*V1SubTaskMeta) XXX_Marshal

func (m *V1SubTaskMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*V1SubTaskMeta) XXX_Merge

func (m *V1SubTaskMeta) XXX_Merge(src proto.Message)

func (*V1SubTaskMeta) XXX_Size

func (m *V1SubTaskMeta) XXX_Size() int

func (*V1SubTaskMeta) XXX_Unmarshal

func (m *V1SubTaskMeta) XXX_Unmarshal(b []byte) error

type WorkerClient

type WorkerClient interface {
	QueryStatus(ctx context.Context, in *QueryStatusRequest, opts ...grpc.CallOption) (*QueryStatusResponse, error)
	// PurgeRelay purges relay log files for this dm-worker
	PurgeRelay(ctx context.Context, in *PurgeRelayRequest, opts ...grpc.CallOption) (*CommonWorkerResponse, error)
	// Operate (get/set/remove) schema for a specified upstream table.
	// a `set`/`remove` operation should be an one-time operation (only take effect once),
	// so we use a gRPC method rather than a etcd operation now (no persistent operation state).
	OperateSchema(ctx context.Context, in *OperateWorkerSchemaRequest, opts ...grpc.CallOption) (*CommonWorkerResponse, error)
	OperateV1Meta(ctx context.Context, in *OperateV1MetaRequest, opts ...grpc.CallOption) (*OperateV1MetaResponse, error)
	HandleError(ctx context.Context, in *HandleWorkerErrorRequest, opts ...grpc.CallOption) (*CommonWorkerResponse, error)
	GetWorkerCfg(ctx context.Context, in *GetWorkerCfgRequest, opts ...grpc.CallOption) (*GetWorkerCfgResponse, error)
}

WorkerClient is the client API for Worker service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewWorkerClient

func NewWorkerClient(cc *grpc.ClientConn) WorkerClient

type WorkerInfo

type WorkerInfo struct {
	Name   string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Addr   string `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"`
	Stage  string `protobuf:"bytes,3,opt,name=stage,proto3" json:"stage,omitempty"`
	Source string `protobuf:"bytes,4,opt,name=source,proto3" json:"source,omitempty"`
}

func (*WorkerInfo) Descriptor

func (*WorkerInfo) Descriptor() ([]byte, []int)

func (*WorkerInfo) GetAddr

func (m *WorkerInfo) GetAddr() string

func (*WorkerInfo) GetName

func (m *WorkerInfo) GetName() string

func (*WorkerInfo) GetSource

func (m *WorkerInfo) GetSource() string

func (*WorkerInfo) GetStage

func (m *WorkerInfo) GetStage() string

func (*WorkerInfo) Marshal

func (m *WorkerInfo) Marshal() (dAtA []byte, err error)

func (*WorkerInfo) MarshalTo

func (m *WorkerInfo) MarshalTo(dAtA []byte) (int, error)

func (*WorkerInfo) MarshalToSizedBuffer

func (m *WorkerInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WorkerInfo) ProtoMessage

func (*WorkerInfo) ProtoMessage()

func (*WorkerInfo) Reset

func (m *WorkerInfo) Reset()

func (*WorkerInfo) Size

func (m *WorkerInfo) Size() (n int)

func (*WorkerInfo) String

func (m *WorkerInfo) String() string

func (*WorkerInfo) Unmarshal

func (m *WorkerInfo) Unmarshal(dAtA []byte) error

func (*WorkerInfo) XXX_DiscardUnknown

func (m *WorkerInfo) XXX_DiscardUnknown()

func (*WorkerInfo) XXX_Marshal

func (m *WorkerInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WorkerInfo) XXX_Merge

func (m *WorkerInfo) XXX_Merge(src proto.Message)

func (*WorkerInfo) XXX_Size

func (m *WorkerInfo) XXX_Size() int

func (*WorkerInfo) XXX_Unmarshal

func (m *WorkerInfo) XXX_Unmarshal(b []byte) error

type WorkerServer

type WorkerServer interface {
	QueryStatus(context.Context, *QueryStatusRequest) (*QueryStatusResponse, error)
	// PurgeRelay purges relay log files for this dm-worker
	PurgeRelay(context.Context, *PurgeRelayRequest) (*CommonWorkerResponse, error)
	// Operate (get/set/remove) schema for a specified upstream table.
	// a `set`/`remove` operation should be an one-time operation (only take effect once),
	// so we use a gRPC method rather than a etcd operation now (no persistent operation state).
	OperateSchema(context.Context, *OperateWorkerSchemaRequest) (*CommonWorkerResponse, error)
	OperateV1Meta(context.Context, *OperateV1MetaRequest) (*OperateV1MetaResponse, error)
	HandleError(context.Context, *HandleWorkerErrorRequest) (*CommonWorkerResponse, error)
	GetWorkerCfg(context.Context, *GetWorkerCfgRequest) (*GetWorkerCfgResponse, error)
}

WorkerServer is the server API for Worker service.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL