// Code generated by protoc-gen-gogo. DO NOT EDIT. // source: dmmaster.proto /* Package pb is a generated protocol buffer package. It is generated from these files: dmmaster.proto dmworker.proto tracer.proto tracer_base.proto tracer_syncer.proto It has these top-level messages: MigrateWorkerRelayRequest UpdateWorkerRelayConfigRequest StartTaskRequest StartTaskResponse UpdateMasterConfigRequest UpdateMasterConfigResponse OperateTaskRequest OperateTaskResponse UpdateTaskRequest UpdateTaskResponse QueryStatusListRequest QueryStatusListResponse QueryErrorListRequest QueryErrorListResponse ShowDDLLocksRequest DDLLock ShowDDLLocksResponse UnlockDDLLockRequest UnlockDDLLockResponse BreakWorkerDDLLockRequest BreakWorkerDDLLockResponse SwitchWorkerRelayMasterRequest SwitchWorkerRelayMasterResponse OperateWorkerRelayRequest OperateWorkerRelayResponse RefreshWorkerTasksRequest RefreshWorkerTasksMsg RefreshWorkerTasksResponse HandleSQLsRequest HandleSQLsResponse PurgeWorkerRelayRequest PurgeWorkerRelayResponse CheckTaskRequest CheckTaskResponse StartSubTaskRequest UpdateRelayRequest MigrateRelayRequest OperateSubTaskRequest OperateSubTaskResponse QueryTaskOperationRequest QueryTaskOperationResponse UpdateSubTaskRequest QueryStatusRequest QueryErrorRequest HandleSubTaskSQLsRequest CommonWorkerResponse QueryStatusResponse QueryErrorResponse CheckStatus DumpStatus LoadStatus ShardingGroup SyncStatus RelayStatus SubTaskStatus SubTaskStatusList CheckError DumpError LoadError SyncSQLError SyncError RelayError SubTaskError SubTaskErrorList ProcessResult ProcessError DDLInfo DDLLockInfo ExecDDLRequest BreakDDLLockRequest SwitchRelayMasterRequest OperateRelayRequest OperateRelayResponse PurgeRelayRequest QueryWorkerConfigRequest QueryWorkerConfigResponse TaskMeta TaskLog GetTSORequest GetTSOResponse CommonUploadResponse UploadSyncerBinlogEventRequest UploadSyncerJobEventRequest BaseEvent MySQLPosition SyncerState ExecDDLInfo SyncerBinlogEvent SyncerJobEvent */ package pb import ( "fmt" proto "github.com/gogo/protobuf/proto" math "math" _ "google.golang.org/genproto/googleapis/api/annotations" context "golang.org/x/net/context" grpc "google.golang.org/grpc" io "io" ) // Reference imports to suppress errors if they are not otherwise used. var _ = proto.Marshal var _ = fmt.Errorf var _ = math.Inf // This is a compile-time assertion to ensure that this generated file // is compatible with the proto package it is being compiled against. // A compilation error at this line likely means your copy of the // proto package needs to be updated. const _ = proto.GoGoProtoPackageIsVersion2 // please upgrade the proto package type MigrateWorkerRelayRequest struct { BinlogName string `protobuf:"bytes,1,opt,name=BinlogName,proto3" json:"BinlogName,omitempty"` BinlogPos uint32 `protobuf:"varint,2,opt,name=BinlogPos,proto3" json:"BinlogPos,omitempty"` Worker string `protobuf:"bytes,3,opt,name=worker,proto3" json:"worker,omitempty"` } func (m *MigrateWorkerRelayRequest) Reset() { *m = MigrateWorkerRelayRequest{} } func (m *MigrateWorkerRelayRequest) String() string { return proto.CompactTextString(m) } func (*MigrateWorkerRelayRequest) ProtoMessage() {} func (*MigrateWorkerRelayRequest) Descriptor() ([]byte, []int) { return fileDescriptorDmmaster, []int{0} } func (m *MigrateWorkerRelayRequest) GetBinlogName() string { if m != nil { return m.BinlogName } return "" } func (m *MigrateWorkerRelayRequest) GetBinlogPos() uint32 { if m != nil { return m.BinlogPos } return 0 } func (m *MigrateWorkerRelayRequest) GetWorker() string { if m != nil { return m.Worker } return "" } type UpdateWorkerRelayConfigRequest struct { Config string `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"` Worker string `protobuf:"bytes,2,opt,name=worker,proto3" json:"worker,omitempty"` } func (m *UpdateWorkerRelayConfigRequest) Reset() { *m = UpdateWorkerRelayConfigRequest{} } func (m *UpdateWorkerRelayConfigRequest) String() string { return proto.CompactTextString(m) } func (*UpdateWorkerRelayConfigRequest) ProtoMessage() {} func (*UpdateWorkerRelayConfigRequest) Descriptor() ([]byte, []int) { return fileDescriptorDmmaster, []int{1} } func (m *UpdateWorkerRelayConfigRequest) GetConfig() string { if m != nil { return m.Config } return "" } func (m *UpdateWorkerRelayConfigRequest) GetWorker() string { if m != nil { return m.Worker } return "" } type StartTaskRequest struct { Task string `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"` Workers []string `protobuf:"bytes,2,rep,name=workers" json:"workers,omitempty"` } func (m *StartTaskRequest) Reset() { *m = StartTaskRequest{} } func (m *StartTaskRequest) String() string { return proto.CompactTextString(m) } func (*StartTaskRequest) ProtoMessage() {} func (*StartTaskRequest) Descriptor() ([]byte, []int) { return fileDescriptorDmmaster, []int{2} } func (m *StartTaskRequest) GetTask() string { if m != nil { return m.Task } return "" } func (m *StartTaskRequest) GetWorkers() []string { if m != nil { return m.Workers } return nil } type StartTaskResponse struct { Result bool `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"` Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"` Workers []*CommonWorkerResponse `protobuf:"bytes,3,rep,name=workers" json:"workers,omitempty"` } func (m *StartTaskResponse) Reset() { *m = StartTaskResponse{} } func (m *StartTaskResponse) String() string { return proto.CompactTextString(m) } func (*StartTaskResponse) ProtoMessage() {} func (*StartTaskResponse) Descriptor() ([]byte, []int) { return fileDescriptorDmmaster, []int{3} } func (m *StartTaskResponse) GetResult() bool { if m != nil { return m.Result } return false } func (m *StartTaskResponse) GetMsg() string { if m != nil { return m.Msg } return "" } func (m *StartTaskResponse) GetWorkers() []*CommonWorkerResponse { if m != nil { return m.Workers } return nil } type UpdateMasterConfigRequest struct { Config string `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"` } func (m *UpdateMasterConfigRequest) Reset() { *m = UpdateMasterConfigRequest{} } func (m *UpdateMasterConfigRequest) String() string { return proto.CompactTextString(m) } func (*UpdateMasterConfigRequest) ProtoMessage() {} func (*UpdateMasterConfigRequest) Descriptor() ([]byte, []int) { return fileDescriptorDmmaster, []int{4} } func (m *UpdateMasterConfigRequest) GetConfig() string { if m != nil { return m.Config } return "" } type UpdateMasterConfigResponse struct { Result bool `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"` Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"` Workers []*QueryStatusResponse `protobuf:"bytes,3,rep,name=workers" json:"workers,omitempty"` } func (m *UpdateMasterConfigResponse) Reset() { *m = UpdateMasterConfigResponse{} } func (m *UpdateMasterConfigResponse) String() string { return proto.CompactTextString(m) } func (*UpdateMasterConfigResponse) ProtoMessage() {} func (*UpdateMasterConfigResponse) Descriptor() ([]byte, []int) { return fileDescriptorDmmaster, []int{5} } func (m *UpdateMasterConfigResponse) GetResult() bool { if m != nil { return m.Result } return false } func (m *UpdateMasterConfigResponse) GetMsg() string { if m != nil { return m.Msg } return "" } func (m *UpdateMasterConfigResponse) GetWorkers() []*QueryStatusResponse { if m != nil { return m.Workers } return nil } type OperateTaskRequest struct { Op TaskOp `protobuf:"varint,1,opt,name=op,proto3,enum=pb.TaskOp" json:"op,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Workers []string `protobuf:"bytes,3,rep,name=workers" json:"workers,omitempty"` } func (m *OperateTaskRequest) Reset() { *m = OperateTaskRequest{} } func (m *OperateTaskRequest) String() string { return proto.CompactTextString(m) } func (*OperateTaskRequest) ProtoMessage() {} func (*OperateTaskRequest) Descriptor() ([]byte, []int) { return fileDescriptorDmmaster, []int{6} } func (m *OperateTaskRequest) GetOp() TaskOp { if m != nil { return m.Op } return TaskOp_InvalidOp } func (m *OperateTaskRequest) GetName() string { if m != nil { return m.Name } return "" } func (m *OperateTaskRequest) GetWorkers() []string { if m != nil { return m.Workers } return nil } type OperateTaskResponse struct { Op TaskOp `protobuf:"varint,1,opt,name=op,proto3,enum=pb.TaskOp" json:"op,omitempty"` Result bool `protobuf:"varint,2,opt,name=result,proto3" json:"result,omitempty"` Msg string `protobuf:"bytes,3,opt,name=msg,proto3" json:"msg,omitempty"` Workers []*OperateSubTaskResponse `protobuf:"bytes,4,rep,name=workers" json:"workers,omitempty"` } func (m *OperateTaskResponse) Reset() { *m = OperateTaskResponse{} } func (m *OperateTaskResponse) String() string { return proto.CompactTextString(m) } func (*OperateTaskResponse) ProtoMessage() {} func (*OperateTaskResponse) Descriptor() ([]byte, []int) { return fileDescriptorDmmaster, []int{7} } func (m *OperateTaskResponse) GetOp() TaskOp { if m != nil { return m.Op } return TaskOp_InvalidOp } func (m *OperateTaskResponse) GetResult() bool { if m != nil { return m.Result } return false } func (m *OperateTaskResponse) GetMsg() string { if m != nil { return m.Msg } return "" } func (m *OperateTaskResponse) GetWorkers() []*OperateSubTaskResponse { if m != nil { return m.Workers } return nil } // UpdateTaskRequest used to update task after it has beed started // task: task's configuration, yaml format // now, only support to update config for routes, filters, column-mappings, black-white-list // support update partial config for syncer, loader, etc later // workers need to do update, empty for all workers in processing the task type UpdateTaskRequest struct { Task string `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"` Workers []string `protobuf:"bytes,2,rep,name=workers" json:"workers,omitempty"` } func (m *UpdateTaskRequest) Reset() { *m = UpdateTaskRequest{} } func (m *UpdateTaskRequest) String() string { return proto.CompactTextString(m) } func (*UpdateTaskRequest) ProtoMessage() {} func (*UpdateTaskRequest) Descriptor() ([]byte, []int) { return fileDescriptorDmmaster, []int{8} } func (m *UpdateTaskRequest) GetTask() string { if m != nil { return m.Task } return "" } func (m *UpdateTaskRequest) GetWorkers() []string { if m != nil { return m.Workers } return nil } type UpdateTaskResponse struct { Result bool `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"` Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"` Workers []*CommonWorkerResponse `protobuf:"bytes,3,rep,name=workers" json:"workers,omitempty"` } func (m *UpdateTaskResponse) Reset() { *m = UpdateTaskResponse{} } func (m *UpdateTaskResponse) String() string { return proto.CompactTextString(m) } func (*UpdateTaskResponse) ProtoMessage() {} func (*UpdateTaskResponse) Descriptor() ([]byte, []int) { return fileDescriptorDmmaster, []int{9} } func (m *UpdateTaskResponse) GetResult() bool { if m != nil { return m.Result } return false } func (m *UpdateTaskResponse) GetMsg() string { if m != nil { return m.Msg } return "" } func (m *UpdateTaskResponse) GetWorkers() []*CommonWorkerResponse { if m != nil { return m.Workers } return nil } type QueryStatusListRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Workers []string `protobuf:"bytes,2,rep,name=workers" json:"workers,omitempty"` } func (m *QueryStatusListRequest) Reset() { *m = QueryStatusListRequest{} } func (m *QueryStatusListRequest) String() string { return proto.CompactTextString(m) } func (*QueryStatusListRequest) ProtoMessage() {} func (*QueryStatusListRequest) Descriptor() ([]byte, []int) { return fileDescriptorDmmaster, []int{10} } func (m *QueryStatusListRequest) GetName() string { if m != nil { return m.Name } return "" } func (m *QueryStatusListRequest) GetWorkers() []string { if m != nil { return m.Workers } return nil } type QueryStatusListResponse struct { Result bool `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"` Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"` Workers []*QueryStatusResponse `protobuf:"bytes,3,rep,name=workers" json:"workers,omitempty"` } func (m *QueryStatusListResponse) Reset() { *m = QueryStatusListResponse{} } func (m *QueryStatusListResponse) String() string { return proto.CompactTextString(m) } func (*QueryStatusListResponse) ProtoMessage() {} func (*QueryStatusListResponse) Descriptor() ([]byte, []int) { return fileDescriptorDmmaster, []int{11} } func (m *QueryStatusListResponse) GetResult() bool { if m != nil { return m.Result } return false } func (m *QueryStatusListResponse) GetMsg() string { if m != nil { return m.Msg } return "" } func (m *QueryStatusListResponse) GetWorkers() []*QueryStatusResponse { if m != nil { return m.Workers } return nil } type QueryErrorListRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Workers []string `protobuf:"bytes,2,rep,name=workers" json:"workers,omitempty"` } func (m *QueryErrorListRequest) Reset() { *m = QueryErrorListRequest{} } func (m *QueryErrorListRequest) String() string { return proto.CompactTextString(m) } func (*QueryErrorListRequest) ProtoMessage() {} func (*QueryErrorListRequest) Descriptor() ([]byte, []int) { return fileDescriptorDmmaster, []int{12} } func (m *QueryErrorListRequest) GetName() string { if m != nil { return m.Name } return "" } func (m *QueryErrorListRequest) GetWorkers() []string { if m != nil { return m.Workers } return nil } type QueryErrorListResponse struct { Result bool `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"` Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"` Workers []*QueryErrorResponse `protobuf:"bytes,3,rep,name=workers" json:"workers,omitempty"` } func (m *QueryErrorListResponse) Reset() { *m = QueryErrorListResponse{} } func (m *QueryErrorListResponse) String() string { return proto.CompactTextString(m) } func (*QueryErrorListResponse) ProtoMessage() {} func (*QueryErrorListResponse) Descriptor() ([]byte, []int) { return fileDescriptorDmmaster, []int{13} } func (m *QueryErrorListResponse) GetResult() bool { if m != nil { return m.Result } return false } func (m *QueryErrorListResponse) GetMsg() string { if m != nil { return m.Msg } return "" } func (m *QueryErrorListResponse) GetWorkers() []*QueryErrorResponse { if m != nil { return m.Workers } return nil } // ShowDDLLocksRequest used to query DDL locks which are un-resolved // task: task's name, empty for all tasks // workers: worker need to query, empty for all workers // any DDL lock in which the worker is synced or unsynced will return // if specify task and workers both, and workers not doing the task , it will return empty DDL locks type ShowDDLLocksRequest struct { Task string `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"` Workers []string `protobuf:"bytes,2,rep,name=workers" json:"workers,omitempty"` } func (m *ShowDDLLocksRequest) Reset() { *m = ShowDDLLocksRequest{} } func (m *ShowDDLLocksRequest) String() string { return proto.CompactTextString(m) } func (*ShowDDLLocksRequest) ProtoMessage() {} func (*ShowDDLLocksRequest) Descriptor() ([]byte, []int) { return fileDescriptorDmmaster, []int{14} } func (m *ShowDDLLocksRequest) GetTask() string { if m != nil { return m.Task } return "" } func (m *ShowDDLLocksRequest) GetWorkers() []string { if m != nil { return m.Workers } return nil } // DDLLock represents a DDL lock info (I known the name confused with DDLLockInfo, any suggestion?) // it been sent from dm-master to dmctl // ID: DDL lock generated ID // task: lock's corresponding task name // owner: lock's owner, a dm-worker // DDL: DDL statement // synced: already synced dm-workers // unsynced: pending to sync dm-workers type DDLLock struct { ID string `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"` Task string `protobuf:"bytes,2,opt,name=task,proto3" json:"task,omitempty"` Owner string `protobuf:"bytes,3,opt,name=owner,proto3" json:"owner,omitempty"` DDLs []string `protobuf:"bytes,4,rep,name=DDLs" json:"DDLs,omitempty"` Synced []string `protobuf:"bytes,5,rep,name=synced" json:"synced,omitempty"` Unsynced []string `protobuf:"bytes,6,rep,name=unsynced" json:"unsynced,omitempty"` } func (m *DDLLock) Reset() { *m = DDLLock{} } func (m *DDLLock) String() string { return proto.CompactTextString(m) } func (*DDLLock) ProtoMessage() {} func (*DDLLock) Descriptor() ([]byte, []int) { return fileDescriptorDmmaster, []int{15} } func (m *DDLLock) GetID() string { if m != nil { return m.ID } return "" } func (m *DDLLock) GetTask() string { if m != nil { return m.Task } return "" } func (m *DDLLock) GetOwner() string { if m != nil { return m.Owner } return "" } func (m *DDLLock) GetDDLs() []string { if m != nil { return m.DDLs } return nil } func (m *DDLLock) GetSynced() []string { if m != nil { return m.Synced } return nil } func (m *DDLLock) GetUnsynced() []string { if m != nil { return m.Unsynced } return nil } type ShowDDLLocksResponse struct { Result bool `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"` Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"` Locks []*DDLLock `protobuf:"bytes,3,rep,name=locks" json:"locks,omitempty"` } func (m *ShowDDLLocksResponse) Reset() { *m = ShowDDLLocksResponse{} } func (m *ShowDDLLocksResponse) String() string { return proto.CompactTextString(m) } func (*ShowDDLLocksResponse) ProtoMessage() {} func (*ShowDDLLocksResponse) Descriptor() ([]byte, []int) { return fileDescriptorDmmaster, []int{16} } func (m *ShowDDLLocksResponse) GetResult() bool { if m != nil { return m.Result } return false } func (m *ShowDDLLocksResponse) GetMsg() string { if m != nil { return m.Msg } return "" } func (m *ShowDDLLocksResponse) GetLocks() []*DDLLock { if m != nil { return m.Locks } return nil } // UnlockDDLLockRequest used to unlock (resolve) DDL lock manually // ID: DDL lock ID // replaceOwner: dm-worker used to replace the original DDL lock's owner // workers: dm-workers need to execute / skip DDL, empty for all dm-workers // replaceOwner in or not in workers are both fine // forceRemove: force to remove the DDL lock even unlock fail type UnlockDDLLockRequest struct { ID string `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"` ReplaceOwner string `protobuf:"bytes,2,opt,name=replaceOwner,proto3" json:"replaceOwner,omitempty"` Workers []string `protobuf:"bytes,3,rep,name=workers" json:"workers,omitempty"` ForceRemove bool `protobuf:"varint,4,opt,name=forceRemove,proto3" json:"forceRemove,omitempty"` } func (m *UnlockDDLLockRequest) Reset() { *m = UnlockDDLLockRequest{} } func (m *UnlockDDLLockRequest) String() string { return proto.CompactTextString(m) } func (*UnlockDDLLockRequest) ProtoMessage() {} func (*UnlockDDLLockRequest) Descriptor() ([]byte, []int) { return fileDescriptorDmmaster, []int{17} } func (m *UnlockDDLLockRequest) GetID() string { if m != nil { return m.ID } return "" } func (m *UnlockDDLLockRequest) GetReplaceOwner() string { if m != nil { return m.ReplaceOwner } return "" } func (m *UnlockDDLLockRequest) GetWorkers() []string { if m != nil { return m.Workers } return nil } func (m *UnlockDDLLockRequest) GetForceRemove() bool { if m != nil { return m.ForceRemove } return false } type UnlockDDLLockResponse struct { Result bool `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"` Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"` Workers []*CommonWorkerResponse `protobuf:"bytes,3,rep,name=workers" json:"workers,omitempty"` } func (m *UnlockDDLLockResponse) Reset() { *m = UnlockDDLLockResponse{} } func (m *UnlockDDLLockResponse) String() string { return proto.CompactTextString(m) } func (*UnlockDDLLockResponse) ProtoMessage() {} func (*UnlockDDLLockResponse) Descriptor() ([]byte, []int) { return fileDescriptorDmmaster, []int{18} } func (m *UnlockDDLLockResponse) GetResult() bool { if m != nil { return m.Result } return false } func (m *UnlockDDLLockResponse) GetMsg() string { if m != nil { return m.Msg } return "" } func (m *UnlockDDLLockResponse) GetWorkers() []*CommonWorkerResponse { if m != nil { return m.Workers } return nil } // BreakWorkerDDLLockRequest represents a request for some dm-workers to force to break the DDL lock // workers: dm-workers need to break DDL lock // task: sub task's name // removeLockID: DDLLockInfo's ID which need to remove // execDDL: execute DDL which is blocking // skipDDL: skip DDL which is blocking // execDDL and skipDDL can not specify both at the same time, but can specify neither type BreakWorkerDDLLockRequest struct { Workers []string `protobuf:"bytes,1,rep,name=workers" json:"workers,omitempty"` Task string `protobuf:"bytes,2,opt,name=task,proto3" json:"task,omitempty"` RemoveLockID string `protobuf:"bytes,3,opt,name=removeLockID,proto3" json:"removeLockID,omitempty"` ExecDDL bool `protobuf:"varint,4,opt,name=execDDL,proto3" json:"execDDL,omitempty"` SkipDDL bool `protobuf:"varint,5,opt,name=skipDDL,proto3" json:"skipDDL,omitempty"` } func (m *BreakWorkerDDLLockRequest) Reset() { *m = BreakWorkerDDLLockRequest{} } func (m *BreakWorkerDDLLockRequest) String() string { return proto.CompactTextString(m) } func (*BreakWorkerDDLLockRequest) ProtoMessage() {} func (*BreakWorkerDDLLockRequest) Descriptor() ([]byte, []int) { return fileDescriptorDmmaster, []int{19} } func (m *BreakWorkerDDLLockRequest) GetWorkers() []string { if m != nil { return m.Workers } return nil } func (m *BreakWorkerDDLLockRequest) GetTask() string { if m != nil { return m.Task } return "" } func (m *BreakWorkerDDLLockRequest) GetRemoveLockID() string { if m != nil { return m.RemoveLockID } return "" } func (m *BreakWorkerDDLLockRequest) GetExecDDL() bool { if m != nil { return m.ExecDDL } return false } func (m *BreakWorkerDDLLockRequest) GetSkipDDL() bool { if m != nil { return m.SkipDDL } return false } type BreakWorkerDDLLockResponse struct { Result bool `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"` Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"` Workers []*CommonWorkerResponse `protobuf:"bytes,3,rep,name=workers" json:"workers,omitempty"` } func (m *BreakWorkerDDLLockResponse) Reset() { *m = BreakWorkerDDLLockResponse{} } func (m *BreakWorkerDDLLockResponse) String() string { return proto.CompactTextString(m) } func (*BreakWorkerDDLLockResponse) ProtoMessage() {} func (*BreakWorkerDDLLockResponse) Descriptor() ([]byte, []int) { return fileDescriptorDmmaster, []int{20} } func (m *BreakWorkerDDLLockResponse) GetResult() bool { if m != nil { return m.Result } return false } func (m *BreakWorkerDDLLockResponse) GetMsg() string { if m != nil { return m.Msg } return "" } func (m *BreakWorkerDDLLockResponse) GetWorkers() []*CommonWorkerResponse { if m != nil { return m.Workers } return nil } // SwitchWorkerRelayMasterRequest represents a request for some dm-workers to switch relay unit's master server // workers: relay unit in these dm-workers need to switch master server type SwitchWorkerRelayMasterRequest struct { Workers []string `protobuf:"bytes,1,rep,name=workers" json:"workers,omitempty"` } func (m *SwitchWorkerRelayMasterRequest) Reset() { *m = SwitchWorkerRelayMasterRequest{} } func (m *SwitchWorkerRelayMasterRequest) String() string { return proto.CompactTextString(m) } func (*SwitchWorkerRelayMasterRequest) ProtoMessage() {} func (*SwitchWorkerRelayMasterRequest) Descriptor() ([]byte, []int) { return fileDescriptorDmmaster, []int{21} } func (m *SwitchWorkerRelayMasterRequest) GetWorkers() []string { if m != nil { return m.Workers } return nil } type SwitchWorkerRelayMasterResponse struct { Result bool `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"` Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"` Workers []*CommonWorkerResponse `protobuf:"bytes,3,rep,name=workers" json:"workers,omitempty"` } func (m *SwitchWorkerRelayMasterResponse) Reset() { *m = SwitchWorkerRelayMasterResponse{} } func (m *SwitchWorkerRelayMasterResponse) String() string { return proto.CompactTextString(m) } func (*SwitchWorkerRelayMasterResponse) ProtoMessage() {} func (*SwitchWorkerRelayMasterResponse) Descriptor() ([]byte, []int) { return fileDescriptorDmmaster, []int{22} } func (m *SwitchWorkerRelayMasterResponse) GetResult() bool { if m != nil { return m.Result } return false } func (m *SwitchWorkerRelayMasterResponse) GetMsg() string { if m != nil { return m.Msg } return "" } func (m *SwitchWorkerRelayMasterResponse) GetWorkers() []*CommonWorkerResponse { if m != nil { return m.Workers } return nil } // OperateWorkerRelayRequest represents a request for some dm-workers to operate relay unit type OperateWorkerRelayRequest struct { Op RelayOp `protobuf:"varint,1,opt,name=op,proto3,enum=pb.RelayOp" json:"op,omitempty"` Workers []string `protobuf:"bytes,2,rep,name=workers" json:"workers,omitempty"` } func (m *OperateWorkerRelayRequest) Reset() { *m = OperateWorkerRelayRequest{} } func (m *OperateWorkerRelayRequest) String() string { return proto.CompactTextString(m) } func (*OperateWorkerRelayRequest) ProtoMessage() {} func (*OperateWorkerRelayRequest) Descriptor() ([]byte, []int) { return fileDescriptorDmmaster, []int{23} } func (m *OperateWorkerRelayRequest) GetOp() RelayOp { if m != nil { return m.Op } return RelayOp_InvalidRelayOp } func (m *OperateWorkerRelayRequest) GetWorkers() []string { if m != nil { return m.Workers } return nil } type OperateWorkerRelayResponse struct { Op RelayOp `protobuf:"varint,1,opt,name=op,proto3,enum=pb.RelayOp" json:"op,omitempty"` Result bool `protobuf:"varint,2,opt,name=result,proto3" json:"result,omitempty"` Msg string `protobuf:"bytes,3,opt,name=msg,proto3" json:"msg,omitempty"` Workers []*OperateRelayResponse `protobuf:"bytes,4,rep,name=workers" json:"workers,omitempty"` } func (m *OperateWorkerRelayResponse) Reset() { *m = OperateWorkerRelayResponse{} } func (m *OperateWorkerRelayResponse) String() string { return proto.CompactTextString(m) } func (*OperateWorkerRelayResponse) ProtoMessage() {} func (*OperateWorkerRelayResponse) Descriptor() ([]byte, []int) { return fileDescriptorDmmaster, []int{24} } func (m *OperateWorkerRelayResponse) GetOp() RelayOp { if m != nil { return m.Op } return RelayOp_InvalidRelayOp } func (m *OperateWorkerRelayResponse) GetResult() bool { if m != nil { return m.Result } return false } func (m *OperateWorkerRelayResponse) GetMsg() string { if m != nil { return m.Msg } return "" } func (m *OperateWorkerRelayResponse) GetWorkers() []*OperateRelayResponse { if m != nil { return m.Workers } return nil } type RefreshWorkerTasksRequest struct { } func (m *RefreshWorkerTasksRequest) Reset() { *m = RefreshWorkerTasksRequest{} } func (m *RefreshWorkerTasksRequest) String() string { return proto.CompactTextString(m) } func (*RefreshWorkerTasksRequest) ProtoMessage() {} func (*RefreshWorkerTasksRequest) Descriptor() ([]byte, []int) { return fileDescriptorDmmaster, []int{25} } type RefreshWorkerTasksMsg struct { Worker string `protobuf:"bytes,1,opt,name=worker,proto3" json:"worker,omitempty"` Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"` } func (m *RefreshWorkerTasksMsg) Reset() { *m = RefreshWorkerTasksMsg{} } func (m *RefreshWorkerTasksMsg) String() string { return proto.CompactTextString(m) } func (*RefreshWorkerTasksMsg) ProtoMessage() {} func (*RefreshWorkerTasksMsg) Descriptor() ([]byte, []int) { return fileDescriptorDmmaster, []int{26} } func (m *RefreshWorkerTasksMsg) GetWorker() string { if m != nil { return m.Worker } return "" } func (m *RefreshWorkerTasksMsg) GetMsg() string { if m != nil { return m.Msg } return "" } type RefreshWorkerTasksResponse struct { Result bool `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"` Workers []*RefreshWorkerTasksMsg `protobuf:"bytes,2,rep,name=workers" json:"workers,omitempty"` } func (m *RefreshWorkerTasksResponse) Reset() { *m = RefreshWorkerTasksResponse{} } func (m *RefreshWorkerTasksResponse) String() string { return proto.CompactTextString(m) } func (*RefreshWorkerTasksResponse) ProtoMessage() {} func (*RefreshWorkerTasksResponse) Descriptor() ([]byte, []int) { return fileDescriptorDmmaster, []int{27} } func (m *RefreshWorkerTasksResponse) GetResult() bool { if m != nil { return m.Result } return false } func (m *RefreshWorkerTasksResponse) GetWorkers() []*RefreshWorkerTasksMsg { if m != nil { return m.Workers } return nil } type HandleSQLsRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Op SQLOp `protobuf:"varint,2,opt,name=op,proto3,enum=pb.SQLOp" json:"op,omitempty"` Args []string `protobuf:"bytes,3,rep,name=args" json:"args,omitempty"` BinlogPos string `protobuf:"bytes,4,opt,name=binlogPos,proto3" json:"binlogPos,omitempty"` Worker string `protobuf:"bytes,5,opt,name=worker,proto3" json:"worker,omitempty"` SqlPattern string `protobuf:"bytes,6,opt,name=sqlPattern,proto3" json:"sqlPattern,omitempty"` Sharding bool `protobuf:"varint,7,opt,name=sharding,proto3" json:"sharding,omitempty"` } func (m *HandleSQLsRequest) Reset() { *m = HandleSQLsRequest{} } func (m *HandleSQLsRequest) String() string { return proto.CompactTextString(m) } func (*HandleSQLsRequest) ProtoMessage() {} func (*HandleSQLsRequest) Descriptor() ([]byte, []int) { return fileDescriptorDmmaster, []int{28} } func (m *HandleSQLsRequest) GetName() string { if m != nil { return m.Name } return "" } func (m *HandleSQLsRequest) GetOp() SQLOp { if m != nil { return m.Op } return SQLOp_SKIP } func (m *HandleSQLsRequest) GetArgs() []string { if m != nil { return m.Args } return nil } func (m *HandleSQLsRequest) GetBinlogPos() string { if m != nil { return m.BinlogPos } return "" } func (m *HandleSQLsRequest) GetWorker() string { if m != nil { return m.Worker } return "" } func (m *HandleSQLsRequest) GetSqlPattern() string { if m != nil { return m.SqlPattern } return "" } func (m *HandleSQLsRequest) GetSharding() bool { if m != nil { return m.Sharding } return false } type HandleSQLsResponse struct { Result bool `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"` Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"` Workers []*CommonWorkerResponse `protobuf:"bytes,3,rep,name=workers" json:"workers,omitempty"` } func (m *HandleSQLsResponse) Reset() { *m = HandleSQLsResponse{} } func (m *HandleSQLsResponse) String() string { return proto.CompactTextString(m) } func (*HandleSQLsResponse) ProtoMessage() {} func (*HandleSQLsResponse) Descriptor() ([]byte, []int) { return fileDescriptorDmmaster, []int{29} } func (m *HandleSQLsResponse) GetResult() bool { if m != nil { return m.Result } return false } func (m *HandleSQLsResponse) GetMsg() string { if m != nil { return m.Msg } return "" } func (m *HandleSQLsResponse) GetWorkers() []*CommonWorkerResponse { if m != nil { return m.Workers } return nil } // 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 type PurgeWorkerRelayRequest struct { Workers []string `protobuf:"bytes,1,rep,name=workers" json:"workers,omitempty"` Inactive bool `protobuf:"varint,2,opt,name=inactive,proto3" json:"inactive,omitempty"` Time int64 `protobuf:"varint,3,opt,name=time,proto3" json:"time,omitempty"` Filename string `protobuf:"bytes,4,opt,name=filename,proto3" json:"filename,omitempty"` SubDir string `protobuf:"bytes,5,opt,name=subDir,proto3" json:"subDir,omitempty"` } func (m *PurgeWorkerRelayRequest) Reset() { *m = PurgeWorkerRelayRequest{} } func (m *PurgeWorkerRelayRequest) String() string { return proto.CompactTextString(m) } func (*PurgeWorkerRelayRequest) ProtoMessage() {} func (*PurgeWorkerRelayRequest) Descriptor() ([]byte, []int) { return fileDescriptorDmmaster, []int{30} } func (m *PurgeWorkerRelayRequest) GetWorkers() []string { if m != nil { return m.Workers } return nil } func (m *PurgeWorkerRelayRequest) GetInactive() bool { if m != nil { return m.Inactive } return false } func (m *PurgeWorkerRelayRequest) GetTime() int64 { if m != nil { return m.Time } return 0 } func (m *PurgeWorkerRelayRequest) GetFilename() string { if m != nil { return m.Filename } return "" } func (m *PurgeWorkerRelayRequest) GetSubDir() string { if m != nil { return m.SubDir } return "" } type PurgeWorkerRelayResponse struct { Result bool `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"` Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"` Workers []*CommonWorkerResponse `protobuf:"bytes,3,rep,name=workers" json:"workers,omitempty"` } func (m *PurgeWorkerRelayResponse) Reset() { *m = PurgeWorkerRelayResponse{} } func (m *PurgeWorkerRelayResponse) String() string { return proto.CompactTextString(m) } func (*PurgeWorkerRelayResponse) ProtoMessage() {} func (*PurgeWorkerRelayResponse) Descriptor() ([]byte, []int) { return fileDescriptorDmmaster, []int{31} } func (m *PurgeWorkerRelayResponse) GetResult() bool { if m != nil { return m.Result } return false } func (m *PurgeWorkerRelayResponse) GetMsg() string { if m != nil { return m.Msg } return "" } func (m *PurgeWorkerRelayResponse) GetWorkers() []*CommonWorkerResponse { if m != nil { return m.Workers } return nil } type CheckTaskRequest struct { Task string `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"` } func (m *CheckTaskRequest) Reset() { *m = CheckTaskRequest{} } func (m *CheckTaskRequest) String() string { return proto.CompactTextString(m) } func (*CheckTaskRequest) ProtoMessage() {} func (*CheckTaskRequest) Descriptor() ([]byte, []int) { return fileDescriptorDmmaster, []int{32} } func (m *CheckTaskRequest) GetTask() string { if m != nil { return m.Task } return "" } 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 (m *CheckTaskResponse) Reset() { *m = CheckTaskResponse{} } func (m *CheckTaskResponse) String() string { return proto.CompactTextString(m) } func (*CheckTaskResponse) ProtoMessage() {} func (*CheckTaskResponse) Descriptor() ([]byte, []int) { return fileDescriptorDmmaster, []int{33} } func (m *CheckTaskResponse) GetResult() bool { if m != nil { return m.Result } return false } func (m *CheckTaskResponse) GetMsg() string { if m != nil { return m.Msg } return "" } func init() { proto.RegisterType((*MigrateWorkerRelayRequest)(nil), "pb.MigrateWorkerRelayRequest") proto.RegisterType((*UpdateWorkerRelayConfigRequest)(nil), "pb.UpdateWorkerRelayConfigRequest") proto.RegisterType((*StartTaskRequest)(nil), "pb.StartTaskRequest") proto.RegisterType((*StartTaskResponse)(nil), "pb.StartTaskResponse") proto.RegisterType((*UpdateMasterConfigRequest)(nil), "pb.UpdateMasterConfigRequest") proto.RegisterType((*UpdateMasterConfigResponse)(nil), "pb.UpdateMasterConfigResponse") proto.RegisterType((*OperateTaskRequest)(nil), "pb.OperateTaskRequest") proto.RegisterType((*OperateTaskResponse)(nil), "pb.OperateTaskResponse") proto.RegisterType((*UpdateTaskRequest)(nil), "pb.UpdateTaskRequest") proto.RegisterType((*UpdateTaskResponse)(nil), "pb.UpdateTaskResponse") proto.RegisterType((*QueryStatusListRequest)(nil), "pb.QueryStatusListRequest") proto.RegisterType((*QueryStatusListResponse)(nil), "pb.QueryStatusListResponse") proto.RegisterType((*QueryErrorListRequest)(nil), "pb.QueryErrorListRequest") proto.RegisterType((*QueryErrorListResponse)(nil), "pb.QueryErrorListResponse") proto.RegisterType((*ShowDDLLocksRequest)(nil), "pb.ShowDDLLocksRequest") proto.RegisterType((*DDLLock)(nil), "pb.DDLLock") proto.RegisterType((*ShowDDLLocksResponse)(nil), "pb.ShowDDLLocksResponse") proto.RegisterType((*UnlockDDLLockRequest)(nil), "pb.UnlockDDLLockRequest") proto.RegisterType((*UnlockDDLLockResponse)(nil), "pb.UnlockDDLLockResponse") proto.RegisterType((*BreakWorkerDDLLockRequest)(nil), "pb.BreakWorkerDDLLockRequest") proto.RegisterType((*BreakWorkerDDLLockResponse)(nil), "pb.BreakWorkerDDLLockResponse") proto.RegisterType((*SwitchWorkerRelayMasterRequest)(nil), "pb.SwitchWorkerRelayMasterRequest") proto.RegisterType((*SwitchWorkerRelayMasterResponse)(nil), "pb.SwitchWorkerRelayMasterResponse") proto.RegisterType((*OperateWorkerRelayRequest)(nil), "pb.OperateWorkerRelayRequest") proto.RegisterType((*OperateWorkerRelayResponse)(nil), "pb.OperateWorkerRelayResponse") proto.RegisterType((*RefreshWorkerTasksRequest)(nil), "pb.RefreshWorkerTasksRequest") proto.RegisterType((*RefreshWorkerTasksMsg)(nil), "pb.RefreshWorkerTasksMsg") proto.RegisterType((*RefreshWorkerTasksResponse)(nil), "pb.RefreshWorkerTasksResponse") proto.RegisterType((*HandleSQLsRequest)(nil), "pb.HandleSQLsRequest") proto.RegisterType((*HandleSQLsResponse)(nil), "pb.HandleSQLsResponse") proto.RegisterType((*PurgeWorkerRelayRequest)(nil), "pb.PurgeWorkerRelayRequest") proto.RegisterType((*PurgeWorkerRelayResponse)(nil), "pb.PurgeWorkerRelayResponse") proto.RegisterType((*CheckTaskRequest)(nil), "pb.CheckTaskRequest") proto.RegisterType((*CheckTaskResponse)(nil), "pb.CheckTaskResponse") } // Reference imports to suppress errors if they are not otherwise used. var _ context.Context var _ grpc.ClientConn // This is a compile-time assertion to ensure that this generated file // is compatible with the grpc package it is being compiled against. const _ = grpc.SupportPackageIsVersion4 // Client API for Master service type MasterClient interface { StartTask(ctx context.Context, in *StartTaskRequest, opts ...grpc.CallOption) (*StartTaskResponse, error) OperateTask(ctx context.Context, in *OperateTaskRequest, opts ...grpc.CallOption) (*OperateTaskResponse, error) UpdateTask(ctx context.Context, in *UpdateTaskRequest, opts ...grpc.CallOption) (*UpdateTaskResponse, error) QueryStatus(ctx context.Context, in *QueryStatusListRequest, opts ...grpc.CallOption) (*QueryStatusListResponse, error) QueryError(ctx context.Context, in *QueryErrorListRequest, opts ...grpc.CallOption) (*QueryErrorListResponse, error) // show un-resolved DDL locks ShowDDLLocks(ctx context.Context, in *ShowDDLLocksRequest, opts ...grpc.CallOption) (*ShowDDLLocksResponse, error) // used by dmctl to manually unlock DDL lock UnlockDDLLock(ctx context.Context, in *UnlockDDLLockRequest, opts ...grpc.CallOption) (*UnlockDDLLockResponse, error) UpdateMasterConfig(ctx context.Context, in *UpdateMasterConfigRequest, opts ...grpc.CallOption) (*UpdateMasterConfigResponse, error) UpdateWorkerRelayConfig(ctx context.Context, in *UpdateWorkerRelayConfigRequest, opts ...grpc.CallOption) (*CommonWorkerResponse, error) // BreakDDLLock request some dm-workers to break a DDL lock // including remove DDLLockInfo and/or execute/skip DDL BreakWorkerDDLLock(ctx context.Context, in *BreakWorkerDDLLockRequest, opts ...grpc.CallOption) (*BreakWorkerDDLLockResponse, error) HandleSQLs(ctx context.Context, in *HandleSQLsRequest, opts ...grpc.CallOption) (*HandleSQLsResponse, error) // SwitchWorkerRelayMaster requests some dm-workers to switch relay unit's master server SwitchWorkerRelayMaster(ctx context.Context, in *SwitchWorkerRelayMasterRequest, opts ...grpc.CallOption) (*SwitchWorkerRelayMasterResponse, error) // OperateWorkerRelayTask requests some dm-workers to operate relay unit OperateWorkerRelayTask(ctx context.Context, in *OperateWorkerRelayRequest, opts ...grpc.CallOption) (*OperateWorkerRelayResponse, error) // PurgeWorkerRelay purges relay log files for some dm-workers PurgeWorkerRelay(ctx context.Context, in *PurgeWorkerRelayRequest, opts ...grpc.CallOption) (*PurgeWorkerRelayResponse, error) // used by dmctl, to force refresh the task -> workers mapper // it should be used rarely only when task -> workers mapper corrupted RefreshWorkerTasks(ctx context.Context, in *RefreshWorkerTasksRequest, opts ...grpc.CallOption) (*RefreshWorkerTasksResponse, error) // MigrateRelay request migrate old dm-woker to a new one. MigrateWorkerRelay(ctx context.Context, in *MigrateWorkerRelayRequest, opts ...grpc.CallOption) (*CommonWorkerResponse, error) // CheckTask checks legality of task configuration CheckTask(ctx context.Context, in *CheckTaskRequest, opts ...grpc.CallOption) (*CheckTaskResponse, error) } type masterClient struct { cc *grpc.ClientConn } func NewMasterClient(cc *grpc.ClientConn) MasterClient { return &masterClient{cc} } func (c *masterClient) StartTask(ctx context.Context, in *StartTaskRequest, opts ...grpc.CallOption) (*StartTaskResponse, error) { out := new(StartTaskResponse) err := grpc.Invoke(ctx, "/pb.Master/StartTask", in, out, c.cc, opts...) if err != nil { return nil, err } return out, nil } func (c *masterClient) OperateTask(ctx context.Context, in *OperateTaskRequest, opts ...grpc.CallOption) (*OperateTaskResponse, error) { out := new(OperateTaskResponse) err := grpc.Invoke(ctx, "/pb.Master/OperateTask", in, out, c.cc, opts...) if err != nil { return nil, err } return out, nil } func (c *masterClient) UpdateTask(ctx context.Context, in *UpdateTaskRequest, opts ...grpc.CallOption) (*UpdateTaskResponse, error) { out := new(UpdateTaskResponse) err := grpc.Invoke(ctx, "/pb.Master/UpdateTask", in, out, c.cc, opts...) if err != nil { return nil, err } return out, nil } func (c *masterClient) QueryStatus(ctx context.Context, in *QueryStatusListRequest, opts ...grpc.CallOption) (*QueryStatusListResponse, error) { out := new(QueryStatusListResponse) err := grpc.Invoke(ctx, "/pb.Master/QueryStatus", in, out, c.cc, opts...) if err != nil { return nil, err } return out, nil } func (c *masterClient) QueryError(ctx context.Context, in *QueryErrorListRequest, opts ...grpc.CallOption) (*QueryErrorListResponse, error) { out := new(QueryErrorListResponse) err := grpc.Invoke(ctx, "/pb.Master/QueryError", in, out, c.cc, opts...) if err != nil { return nil, err } return out, nil } func (c *masterClient) ShowDDLLocks(ctx context.Context, in *ShowDDLLocksRequest, opts ...grpc.CallOption) (*ShowDDLLocksResponse, error) { out := new(ShowDDLLocksResponse) err := grpc.Invoke(ctx, "/pb.Master/ShowDDLLocks", in, out, c.cc, opts...) if err != nil { return nil, err } return out, nil } func (c *masterClient) UnlockDDLLock(ctx context.Context, in *UnlockDDLLockRequest, opts ...grpc.CallOption) (*UnlockDDLLockResponse, error) { out := new(UnlockDDLLockResponse) err := grpc.Invoke(ctx, "/pb.Master/UnlockDDLLock", in, out, c.cc, opts...) if err != nil { return nil, err } return out, nil } func (c *masterClient) UpdateMasterConfig(ctx context.Context, in *UpdateMasterConfigRequest, opts ...grpc.CallOption) (*UpdateMasterConfigResponse, error) { out := new(UpdateMasterConfigResponse) err := grpc.Invoke(ctx, "/pb.Master/UpdateMasterConfig", in, out, c.cc, opts...) if err != nil { return nil, err } return out, nil } func (c *masterClient) UpdateWorkerRelayConfig(ctx context.Context, in *UpdateWorkerRelayConfigRequest, opts ...grpc.CallOption) (*CommonWorkerResponse, error) { out := new(CommonWorkerResponse) err := grpc.Invoke(ctx, "/pb.Master/UpdateWorkerRelayConfig", in, out, c.cc, opts...) if err != nil { return nil, err } return out, nil } func (c *masterClient) BreakWorkerDDLLock(ctx context.Context, in *BreakWorkerDDLLockRequest, opts ...grpc.CallOption) (*BreakWorkerDDLLockResponse, error) { out := new(BreakWorkerDDLLockResponse) err := grpc.Invoke(ctx, "/pb.Master/BreakWorkerDDLLock", in, out, c.cc, opts...) if err != nil { return nil, err } return out, nil } func (c *masterClient) HandleSQLs(ctx context.Context, in *HandleSQLsRequest, opts ...grpc.CallOption) (*HandleSQLsResponse, error) { out := new(HandleSQLsResponse) err := grpc.Invoke(ctx, "/pb.Master/HandleSQLs", in, out, c.cc, opts...) if err != nil { return nil, err } return out, nil } func (c *masterClient) SwitchWorkerRelayMaster(ctx context.Context, in *SwitchWorkerRelayMasterRequest, opts ...grpc.CallOption) (*SwitchWorkerRelayMasterResponse, error) { out := new(SwitchWorkerRelayMasterResponse) err := grpc.Invoke(ctx, "/pb.Master/SwitchWorkerRelayMaster", in, out, c.cc, opts...) if err != nil { return nil, err } return out, nil } func (c *masterClient) OperateWorkerRelayTask(ctx context.Context, in *OperateWorkerRelayRequest, opts ...grpc.CallOption) (*OperateWorkerRelayResponse, error) { out := new(OperateWorkerRelayResponse) err := grpc.Invoke(ctx, "/pb.Master/OperateWorkerRelayTask", in, out, c.cc, opts...) if err != nil { return nil, err } return out, nil } func (c *masterClient) PurgeWorkerRelay(ctx context.Context, in *PurgeWorkerRelayRequest, opts ...grpc.CallOption) (*PurgeWorkerRelayResponse, error) { out := new(PurgeWorkerRelayResponse) err := grpc.Invoke(ctx, "/pb.Master/PurgeWorkerRelay", in, out, c.cc, opts...) if err != nil { return nil, err } return out, nil } func (c *masterClient) RefreshWorkerTasks(ctx context.Context, in *RefreshWorkerTasksRequest, opts ...grpc.CallOption) (*RefreshWorkerTasksResponse, error) { out := new(RefreshWorkerTasksResponse) err := grpc.Invoke(ctx, "/pb.Master/RefreshWorkerTasks", in, out, c.cc, opts...) if err != nil { return nil, err } return out, nil } func (c *masterClient) MigrateWorkerRelay(ctx context.Context, in *MigrateWorkerRelayRequest, opts ...grpc.CallOption) (*CommonWorkerResponse, error) { out := new(CommonWorkerResponse) err := grpc.Invoke(ctx, "/pb.Master/MigrateWorkerRelay", in, out, c.cc, opts...) if err != nil { return nil, err } return out, nil } func (c *masterClient) CheckTask(ctx context.Context, in *CheckTaskRequest, opts ...grpc.CallOption) (*CheckTaskResponse, error) { out := new(CheckTaskResponse) err := grpc.Invoke(ctx, "/pb.Master/CheckTask", in, out, c.cc, opts...) if err != nil { return nil, err } return out, nil } // Server API for Master service type MasterServer interface { StartTask(context.Context, *StartTaskRequest) (*StartTaskResponse, error) OperateTask(context.Context, *OperateTaskRequest) (*OperateTaskResponse, error) UpdateTask(context.Context, *UpdateTaskRequest) (*UpdateTaskResponse, error) QueryStatus(context.Context, *QueryStatusListRequest) (*QueryStatusListResponse, error) QueryError(context.Context, *QueryErrorListRequest) (*QueryErrorListResponse, error) // show un-resolved DDL locks ShowDDLLocks(context.Context, *ShowDDLLocksRequest) (*ShowDDLLocksResponse, error) // used by dmctl to manually unlock DDL lock UnlockDDLLock(context.Context, *UnlockDDLLockRequest) (*UnlockDDLLockResponse, error) UpdateMasterConfig(context.Context, *UpdateMasterConfigRequest) (*UpdateMasterConfigResponse, error) UpdateWorkerRelayConfig(context.Context, *UpdateWorkerRelayConfigRequest) (*CommonWorkerResponse, error) // BreakDDLLock request some dm-workers to break a DDL lock // including remove DDLLockInfo and/or execute/skip DDL BreakWorkerDDLLock(context.Context, *BreakWorkerDDLLockRequest) (*BreakWorkerDDLLockResponse, error) HandleSQLs(context.Context, *HandleSQLsRequest) (*HandleSQLsResponse, error) // SwitchWorkerRelayMaster requests some dm-workers to switch relay unit's master server SwitchWorkerRelayMaster(context.Context, *SwitchWorkerRelayMasterRequest) (*SwitchWorkerRelayMasterResponse, error) // OperateWorkerRelayTask requests some dm-workers to operate relay unit OperateWorkerRelayTask(context.Context, *OperateWorkerRelayRequest) (*OperateWorkerRelayResponse, error) // PurgeWorkerRelay purges relay log files for some dm-workers PurgeWorkerRelay(context.Context, *PurgeWorkerRelayRequest) (*PurgeWorkerRelayResponse, error) // used by dmctl, to force refresh the task -> workers mapper // it should be used rarely only when task -> workers mapper corrupted RefreshWorkerTasks(context.Context, *RefreshWorkerTasksRequest) (*RefreshWorkerTasksResponse, error) // MigrateRelay request migrate old dm-woker to a new one. MigrateWorkerRelay(context.Context, *MigrateWorkerRelayRequest) (*CommonWorkerResponse, error) // CheckTask checks legality of task configuration CheckTask(context.Context, *CheckTaskRequest) (*CheckTaskResponse, error) } func RegisterMasterServer(s *grpc.Server, srv MasterServer) { s.RegisterService(&_Master_serviceDesc, srv) } func _Master_StartTask_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(StartTaskRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MasterServer).StartTask(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/pb.Master/StartTask", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MasterServer).StartTask(ctx, req.(*StartTaskRequest)) } return interceptor(ctx, in, info, handler) } func _Master_OperateTask_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(OperateTaskRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MasterServer).OperateTask(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/pb.Master/OperateTask", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MasterServer).OperateTask(ctx, req.(*OperateTaskRequest)) } return interceptor(ctx, in, info, handler) } func _Master_UpdateTask_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(UpdateTaskRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MasterServer).UpdateTask(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/pb.Master/UpdateTask", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MasterServer).UpdateTask(ctx, req.(*UpdateTaskRequest)) } return interceptor(ctx, in, info, handler) } func _Master_QueryStatus_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(QueryStatusListRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MasterServer).QueryStatus(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/pb.Master/QueryStatus", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MasterServer).QueryStatus(ctx, req.(*QueryStatusListRequest)) } return interceptor(ctx, in, info, handler) } func _Master_QueryError_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(QueryErrorListRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MasterServer).QueryError(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/pb.Master/QueryError", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MasterServer).QueryError(ctx, req.(*QueryErrorListRequest)) } return interceptor(ctx, in, info, handler) } func _Master_ShowDDLLocks_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(ShowDDLLocksRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MasterServer).ShowDDLLocks(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/pb.Master/ShowDDLLocks", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MasterServer).ShowDDLLocks(ctx, req.(*ShowDDLLocksRequest)) } return interceptor(ctx, in, info, handler) } func _Master_UnlockDDLLock_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(UnlockDDLLockRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MasterServer).UnlockDDLLock(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/pb.Master/UnlockDDLLock", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MasterServer).UnlockDDLLock(ctx, req.(*UnlockDDLLockRequest)) } return interceptor(ctx, in, info, handler) } func _Master_UpdateMasterConfig_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(UpdateMasterConfigRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MasterServer).UpdateMasterConfig(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/pb.Master/UpdateMasterConfig", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MasterServer).UpdateMasterConfig(ctx, req.(*UpdateMasterConfigRequest)) } return interceptor(ctx, in, info, handler) } func _Master_UpdateWorkerRelayConfig_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(UpdateWorkerRelayConfigRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MasterServer).UpdateWorkerRelayConfig(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/pb.Master/UpdateWorkerRelayConfig", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MasterServer).UpdateWorkerRelayConfig(ctx, req.(*UpdateWorkerRelayConfigRequest)) } return interceptor(ctx, in, info, handler) } func _Master_BreakWorkerDDLLock_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(BreakWorkerDDLLockRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MasterServer).BreakWorkerDDLLock(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/pb.Master/BreakWorkerDDLLock", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MasterServer).BreakWorkerDDLLock(ctx, req.(*BreakWorkerDDLLockRequest)) } return interceptor(ctx, in, info, handler) } func _Master_HandleSQLs_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(HandleSQLsRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MasterServer).HandleSQLs(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/pb.Master/HandleSQLs", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MasterServer).HandleSQLs(ctx, req.(*HandleSQLsRequest)) } return interceptor(ctx, in, info, handler) } func _Master_SwitchWorkerRelayMaster_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(SwitchWorkerRelayMasterRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MasterServer).SwitchWorkerRelayMaster(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/pb.Master/SwitchWorkerRelayMaster", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MasterServer).SwitchWorkerRelayMaster(ctx, req.(*SwitchWorkerRelayMasterRequest)) } return interceptor(ctx, in, info, handler) } func _Master_OperateWorkerRelayTask_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(OperateWorkerRelayRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MasterServer).OperateWorkerRelayTask(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/pb.Master/OperateWorkerRelayTask", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MasterServer).OperateWorkerRelayTask(ctx, req.(*OperateWorkerRelayRequest)) } return interceptor(ctx, in, info, handler) } func _Master_PurgeWorkerRelay_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(PurgeWorkerRelayRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MasterServer).PurgeWorkerRelay(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/pb.Master/PurgeWorkerRelay", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MasterServer).PurgeWorkerRelay(ctx, req.(*PurgeWorkerRelayRequest)) } return interceptor(ctx, in, info, handler) } func _Master_RefreshWorkerTasks_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(RefreshWorkerTasksRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MasterServer).RefreshWorkerTasks(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/pb.Master/RefreshWorkerTasks", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MasterServer).RefreshWorkerTasks(ctx, req.(*RefreshWorkerTasksRequest)) } return interceptor(ctx, in, info, handler) } func _Master_MigrateWorkerRelay_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(MigrateWorkerRelayRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MasterServer).MigrateWorkerRelay(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/pb.Master/MigrateWorkerRelay", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MasterServer).MigrateWorkerRelay(ctx, req.(*MigrateWorkerRelayRequest)) } return interceptor(ctx, in, info, handler) } func _Master_CheckTask_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(CheckTaskRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MasterServer).CheckTask(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/pb.Master/CheckTask", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MasterServer).CheckTask(ctx, req.(*CheckTaskRequest)) } return interceptor(ctx, in, info, handler) } var _Master_serviceDesc = grpc.ServiceDesc{ ServiceName: "pb.Master", HandlerType: (*MasterServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "StartTask", Handler: _Master_StartTask_Handler, }, { MethodName: "OperateTask", Handler: _Master_OperateTask_Handler, }, { MethodName: "UpdateTask", Handler: _Master_UpdateTask_Handler, }, { MethodName: "QueryStatus", Handler: _Master_QueryStatus_Handler, }, { MethodName: "QueryError", Handler: _Master_QueryError_Handler, }, { MethodName: "ShowDDLLocks", Handler: _Master_ShowDDLLocks_Handler, }, { MethodName: "UnlockDDLLock", Handler: _Master_UnlockDDLLock_Handler, }, { MethodName: "UpdateMasterConfig", Handler: _Master_UpdateMasterConfig_Handler, }, { MethodName: "UpdateWorkerRelayConfig", Handler: _Master_UpdateWorkerRelayConfig_Handler, }, { MethodName: "BreakWorkerDDLLock", Handler: _Master_BreakWorkerDDLLock_Handler, }, { MethodName: "HandleSQLs", Handler: _Master_HandleSQLs_Handler, }, { MethodName: "SwitchWorkerRelayMaster", Handler: _Master_SwitchWorkerRelayMaster_Handler, }, { MethodName: "OperateWorkerRelayTask", Handler: _Master_OperateWorkerRelayTask_Handler, }, { MethodName: "PurgeWorkerRelay", Handler: _Master_PurgeWorkerRelay_Handler, }, { MethodName: "RefreshWorkerTasks", Handler: _Master_RefreshWorkerTasks_Handler, }, { MethodName: "MigrateWorkerRelay", Handler: _Master_MigrateWorkerRelay_Handler, }, { MethodName: "CheckTask", Handler: _Master_CheckTask_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "dmmaster.proto", } func (m *MigrateWorkerRelayRequest) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalTo(dAtA) if err != nil { return nil, err } return dAtA[:n], nil } func (m *MigrateWorkerRelayRequest) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if len(m.BinlogName) > 0 { dAtA[i] = 0xa i++ i = encodeVarintDmmaster(dAtA, i, uint64(len(m.BinlogName))) i += copy(dAtA[i:], m.BinlogName) } if m.BinlogPos != 0 { dAtA[i] = 0x10 i++ i = encodeVarintDmmaster(dAtA, i, uint64(m.BinlogPos)) } if len(m.Worker) > 0 { dAtA[i] = 0x1a i++ i = encodeVarintDmmaster(dAtA, i, uint64(len(m.Worker))) i += copy(dAtA[i:], m.Worker) } return i, nil } func (m *UpdateWorkerRelayConfigRequest) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalTo(dAtA) if err != nil { return nil, err } return dAtA[:n], nil } func (m *UpdateWorkerRelayConfigRequest) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if len(m.Config) > 0 { dAtA[i] = 0xa i++ i = encodeVarintDmmaster(dAtA, i, uint64(len(m.Config))) i += copy(dAtA[i:], m.Config) } if len(m.Worker) > 0 { dAtA[i] = 0x12 i++ i = encodeVarintDmmaster(dAtA, i, uint64(len(m.Worker))) i += copy(dAtA[i:], m.Worker) } return i, nil } func (m *StartTaskRequest) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalTo(dAtA) if err != nil { return nil, err } return dAtA[:n], nil } func (m *StartTaskRequest) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if len(m.Task) > 0 { dAtA[i] = 0xa i++ i = encodeVarintDmmaster(dAtA, i, uint64(len(m.Task))) i += copy(dAtA[i:], m.Task) } if len(m.Workers) > 0 { for _, s := range m.Workers { dAtA[i] = 0x12 i++ l = len(s) for l >= 1<<7 { dAtA[i] = uint8(uint64(l)&0x7f | 0x80) l >>= 7 i++ } dAtA[i] = uint8(l) i++ i += copy(dAtA[i:], s) } } return i, nil } func (m *StartTaskResponse) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalTo(dAtA) if err != nil { return nil, err } return dAtA[:n], nil } func (m *StartTaskResponse) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if m.Result { dAtA[i] = 0x8 i++ if m.Result { dAtA[i] = 1 } else { dAtA[i] = 0 } i++ } if len(m.Msg) > 0 { dAtA[i] = 0x12 i++ i = encodeVarintDmmaster(dAtA, i, uint64(len(m.Msg))) i += copy(dAtA[i:], m.Msg) } if len(m.Workers) > 0 { for _, msg := range m.Workers { dAtA[i] = 0x1a i++ i = encodeVarintDmmaster(dAtA, i, uint64(msg.Size())) n, err := msg.MarshalTo(dAtA[i:]) if err != nil { return 0, err } i += n } } return i, nil } func (m *UpdateMasterConfigRequest) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalTo(dAtA) if err != nil { return nil, err } return dAtA[:n], nil } func (m *UpdateMasterConfigRequest) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if len(m.Config) > 0 { dAtA[i] = 0xa i++ i = encodeVarintDmmaster(dAtA, i, uint64(len(m.Config))) i += copy(dAtA[i:], m.Config) } return i, nil } func (m *UpdateMasterConfigResponse) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalTo(dAtA) if err != nil { return nil, err } return dAtA[:n], nil } func (m *UpdateMasterConfigResponse) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if m.Result { dAtA[i] = 0x8 i++ if m.Result { dAtA[i] = 1 } else { dAtA[i] = 0 } i++ } if len(m.Msg) > 0 { dAtA[i] = 0x12 i++ i = encodeVarintDmmaster(dAtA, i, uint64(len(m.Msg))) i += copy(dAtA[i:], m.Msg) } if len(m.Workers) > 0 { for _, msg := range m.Workers { dAtA[i] = 0x1a i++ i = encodeVarintDmmaster(dAtA, i, uint64(msg.Size())) n, err := msg.MarshalTo(dAtA[i:]) if err != nil { return 0, err } i += n } } return i, nil } func (m *OperateTaskRequest) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalTo(dAtA) if err != nil { return nil, err } return dAtA[:n], nil } func (m *OperateTaskRequest) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if m.Op != 0 { dAtA[i] = 0x8 i++ i = encodeVarintDmmaster(dAtA, i, uint64(m.Op)) } if len(m.Name) > 0 { dAtA[i] = 0x12 i++ i = encodeVarintDmmaster(dAtA, i, uint64(len(m.Name))) i += copy(dAtA[i:], m.Name) } if len(m.Workers) > 0 { for _, s := range m.Workers { dAtA[i] = 0x1a i++ l = len(s) for l >= 1<<7 { dAtA[i] = uint8(uint64(l)&0x7f | 0x80) l >>= 7 i++ } dAtA[i] = uint8(l) i++ i += copy(dAtA[i:], s) } } return i, nil } func (m *OperateTaskResponse) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalTo(dAtA) if err != nil { return nil, err } return dAtA[:n], nil } func (m *OperateTaskResponse) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if m.Op != 0 { dAtA[i] = 0x8 i++ i = encodeVarintDmmaster(dAtA, i, uint64(m.Op)) } if m.Result { dAtA[i] = 0x10 i++ if m.Result { dAtA[i] = 1 } else { dAtA[i] = 0 } i++ } if len(m.Msg) > 0 { dAtA[i] = 0x1a i++ i = encodeVarintDmmaster(dAtA, i, uint64(len(m.Msg))) i += copy(dAtA[i:], m.Msg) } if len(m.Workers) > 0 { for _, msg := range m.Workers { dAtA[i] = 0x22 i++ i = encodeVarintDmmaster(dAtA, i, uint64(msg.Size())) n, err := msg.MarshalTo(dAtA[i:]) if err != nil { return 0, err } i += n } } return i, nil } func (m *UpdateTaskRequest) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalTo(dAtA) if err != nil { return nil, err } return dAtA[:n], nil } func (m *UpdateTaskRequest) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if len(m.Task) > 0 { dAtA[i] = 0xa i++ i = encodeVarintDmmaster(dAtA, i, uint64(len(m.Task))) i += copy(dAtA[i:], m.Task) } if len(m.Workers) > 0 { for _, s := range m.Workers { dAtA[i] = 0x12 i++ l = len(s) for l >= 1<<7 { dAtA[i] = uint8(uint64(l)&0x7f | 0x80) l >>= 7 i++ } dAtA[i] = uint8(l) i++ i += copy(dAtA[i:], s) } } return i, nil } func (m *UpdateTaskResponse) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalTo(dAtA) if err != nil { return nil, err } return dAtA[:n], nil } func (m *UpdateTaskResponse) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if m.Result { dAtA[i] = 0x8 i++ if m.Result { dAtA[i] = 1 } else { dAtA[i] = 0 } i++ } if len(m.Msg) > 0 { dAtA[i] = 0x12 i++ i = encodeVarintDmmaster(dAtA, i, uint64(len(m.Msg))) i += copy(dAtA[i:], m.Msg) } if len(m.Workers) > 0 { for _, msg := range m.Workers { dAtA[i] = 0x1a i++ i = encodeVarintDmmaster(dAtA, i, uint64(msg.Size())) n, err := msg.MarshalTo(dAtA[i:]) if err != nil { return 0, err } i += n } } return i, nil } func (m *QueryStatusListRequest) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalTo(dAtA) if err != nil { return nil, err } return dAtA[:n], nil } func (m *QueryStatusListRequest) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if len(m.Name) > 0 { dAtA[i] = 0xa i++ i = encodeVarintDmmaster(dAtA, i, uint64(len(m.Name))) i += copy(dAtA[i:], m.Name) } if len(m.Workers) > 0 { for _, s := range m.Workers { dAtA[i] = 0x12 i++ l = len(s) for l >= 1<<7 { dAtA[i] = uint8(uint64(l)&0x7f | 0x80) l >>= 7 i++ } dAtA[i] = uint8(l) i++ i += copy(dAtA[i:], s) } } return i, nil } func (m *QueryStatusListResponse) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalTo(dAtA) if err != nil { return nil, err } return dAtA[:n], nil } func (m *QueryStatusListResponse) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if m.Result { dAtA[i] = 0x8 i++ if m.Result { dAtA[i] = 1 } else { dAtA[i] = 0 } i++ } if len(m.Msg) > 0 { dAtA[i] = 0x12 i++ i = encodeVarintDmmaster(dAtA, i, uint64(len(m.Msg))) i += copy(dAtA[i:], m.Msg) } if len(m.Workers) > 0 { for _, msg := range m.Workers { dAtA[i] = 0x1a i++ i = encodeVarintDmmaster(dAtA, i, uint64(msg.Size())) n, err := msg.MarshalTo(dAtA[i:]) if err != nil { return 0, err } i += n } } return i, nil } func (m *QueryErrorListRequest) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalTo(dAtA) if err != nil { return nil, err } return dAtA[:n], nil } func (m *QueryErrorListRequest) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if len(m.Name) > 0 { dAtA[i] = 0xa i++ i = encodeVarintDmmaster(dAtA, i, uint64(len(m.Name))) i += copy(dAtA[i:], m.Name) } if len(m.Workers) > 0 { for _, s := range m.Workers { dAtA[i] = 0x12 i++ l = len(s) for l >= 1<<7 { dAtA[i] = uint8(uint64(l)&0x7f | 0x80) l >>= 7 i++ } dAtA[i] = uint8(l) i++ i += copy(dAtA[i:], s) } } return i, nil } func (m *QueryErrorListResponse) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalTo(dAtA) if err != nil { return nil, err } return dAtA[:n], nil } func (m *QueryErrorListResponse) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if m.Result { dAtA[i] = 0x8 i++ if m.Result { dAtA[i] = 1 } else { dAtA[i] = 0 } i++ } if len(m.Msg) > 0 { dAtA[i] = 0x12 i++ i = encodeVarintDmmaster(dAtA, i, uint64(len(m.Msg))) i += copy(dAtA[i:], m.Msg) } if len(m.Workers) > 0 { for _, msg := range m.Workers { dAtA[i] = 0x1a i++ i = encodeVarintDmmaster(dAtA, i, uint64(msg.Size())) n, err := msg.MarshalTo(dAtA[i:]) if err != nil { return 0, err } i += n } } return i, nil } func (m *ShowDDLLocksRequest) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalTo(dAtA) if err != nil { return nil, err } return dAtA[:n], nil } func (m *ShowDDLLocksRequest) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if len(m.Task) > 0 { dAtA[i] = 0xa i++ i = encodeVarintDmmaster(dAtA, i, uint64(len(m.Task))) i += copy(dAtA[i:], m.Task) } if len(m.Workers) > 0 { for _, s := range m.Workers { dAtA[i] = 0x12 i++ l = len(s) for l >= 1<<7 { dAtA[i] = uint8(uint64(l)&0x7f | 0x80) l >>= 7 i++ } dAtA[i] = uint8(l) i++ i += copy(dAtA[i:], s) } } return i, nil } func (m *DDLLock) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalTo(dAtA) if err != nil { return nil, err } return dAtA[:n], nil } func (m *DDLLock) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if len(m.ID) > 0 { dAtA[i] = 0xa i++ i = encodeVarintDmmaster(dAtA, i, uint64(len(m.ID))) i += copy(dAtA[i:], m.ID) } if len(m.Task) > 0 { dAtA[i] = 0x12 i++ i = encodeVarintDmmaster(dAtA, i, uint64(len(m.Task))) i += copy(dAtA[i:], m.Task) } if len(m.Owner) > 0 { dAtA[i] = 0x1a i++ i = encodeVarintDmmaster(dAtA, i, uint64(len(m.Owner))) i += copy(dAtA[i:], m.Owner) } if len(m.DDLs) > 0 { for _, s := range m.DDLs { dAtA[i] = 0x22 i++ l = len(s) for l >= 1<<7 { dAtA[i] = uint8(uint64(l)&0x7f | 0x80) l >>= 7 i++ } dAtA[i] = uint8(l) i++ i += copy(dAtA[i:], s) } } if len(m.Synced) > 0 { for _, s := range m.Synced { dAtA[i] = 0x2a i++ l = len(s) for l >= 1<<7 { dAtA[i] = uint8(uint64(l)&0x7f | 0x80) l >>= 7 i++ } dAtA[i] = uint8(l) i++ i += copy(dAtA[i:], s) } } if len(m.Unsynced) > 0 { for _, s := range m.Unsynced { dAtA[i] = 0x32 i++ l = len(s) for l >= 1<<7 { dAtA[i] = uint8(uint64(l)&0x7f | 0x80) l >>= 7 i++ } dAtA[i] = uint8(l) i++ i += copy(dAtA[i:], s) } } return i, nil } func (m *ShowDDLLocksResponse) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalTo(dAtA) if err != nil { return nil, err } return dAtA[:n], nil } func (m *ShowDDLLocksResponse) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if m.Result { dAtA[i] = 0x8 i++ if m.Result { dAtA[i] = 1 } else { dAtA[i] = 0 } i++ } if len(m.Msg) > 0 { dAtA[i] = 0x12 i++ i = encodeVarintDmmaster(dAtA, i, uint64(len(m.Msg))) i += copy(dAtA[i:], m.Msg) } if len(m.Locks) > 0 { for _, msg := range m.Locks { dAtA[i] = 0x1a i++ i = encodeVarintDmmaster(dAtA, i, uint64(msg.Size())) n, err := msg.MarshalTo(dAtA[i:]) if err != nil { return 0, err } i += n } } return i, nil } func (m *UnlockDDLLockRequest) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalTo(dAtA) if err != nil { return nil, err } return dAtA[:n], nil } func (m *UnlockDDLLockRequest) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if len(m.ID) > 0 { dAtA[i] = 0xa i++ i = encodeVarintDmmaster(dAtA, i, uint64(len(m.ID))) i += copy(dAtA[i:], m.ID) } if len(m.ReplaceOwner) > 0 { dAtA[i] = 0x12 i++ i = encodeVarintDmmaster(dAtA, i, uint64(len(m.ReplaceOwner))) i += copy(dAtA[i:], m.ReplaceOwner) } if len(m.Workers) > 0 { for _, s := range m.Workers { dAtA[i] = 0x1a i++ l = len(s) for l >= 1<<7 { dAtA[i] = uint8(uint64(l)&0x7f | 0x80) l >>= 7 i++ } dAtA[i] = uint8(l) i++ i += copy(dAtA[i:], s) } } if m.ForceRemove { dAtA[i] = 0x20 i++ if m.ForceRemove { dAtA[i] = 1 } else { dAtA[i] = 0 } i++ } return i, nil } func (m *UnlockDDLLockResponse) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalTo(dAtA) if err != nil { return nil, err } return dAtA[:n], nil } func (m *UnlockDDLLockResponse) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if m.Result { dAtA[i] = 0x8 i++ if m.Result { dAtA[i] = 1 } else { dAtA[i] = 0 } i++ } if len(m.Msg) > 0 { dAtA[i] = 0x12 i++ i = encodeVarintDmmaster(dAtA, i, uint64(len(m.Msg))) i += copy(dAtA[i:], m.Msg) } if len(m.Workers) > 0 { for _, msg := range m.Workers { dAtA[i] = 0x1a i++ i = encodeVarintDmmaster(dAtA, i, uint64(msg.Size())) n, err := msg.MarshalTo(dAtA[i:]) if err != nil { return 0, err } i += n } } return i, nil } func (m *BreakWorkerDDLLockRequest) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalTo(dAtA) if err != nil { return nil, err } return dAtA[:n], nil } func (m *BreakWorkerDDLLockRequest) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if len(m.Workers) > 0 { for _, s := range m.Workers { dAtA[i] = 0xa i++ l = len(s) for l >= 1<<7 { dAtA[i] = uint8(uint64(l)&0x7f | 0x80) l >>= 7 i++ } dAtA[i] = uint8(l) i++ i += copy(dAtA[i:], s) } } if len(m.Task) > 0 { dAtA[i] = 0x12 i++ i = encodeVarintDmmaster(dAtA, i, uint64(len(m.Task))) i += copy(dAtA[i:], m.Task) } if len(m.RemoveLockID) > 0 { dAtA[i] = 0x1a i++ i = encodeVarintDmmaster(dAtA, i, uint64(len(m.RemoveLockID))) i += copy(dAtA[i:], m.RemoveLockID) } if m.ExecDDL { dAtA[i] = 0x20 i++ if m.ExecDDL { dAtA[i] = 1 } else { dAtA[i] = 0 } i++ } if m.SkipDDL { dAtA[i] = 0x28 i++ if m.SkipDDL { dAtA[i] = 1 } else { dAtA[i] = 0 } i++ } return i, nil } func (m *BreakWorkerDDLLockResponse) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalTo(dAtA) if err != nil { return nil, err } return dAtA[:n], nil } func (m *BreakWorkerDDLLockResponse) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if m.Result { dAtA[i] = 0x8 i++ if m.Result { dAtA[i] = 1 } else { dAtA[i] = 0 } i++ } if len(m.Msg) > 0 { dAtA[i] = 0x12 i++ i = encodeVarintDmmaster(dAtA, i, uint64(len(m.Msg))) i += copy(dAtA[i:], m.Msg) } if len(m.Workers) > 0 { for _, msg := range m.Workers { dAtA[i] = 0x1a i++ i = encodeVarintDmmaster(dAtA, i, uint64(msg.Size())) n, err := msg.MarshalTo(dAtA[i:]) if err != nil { return 0, err } i += n } } return i, nil } func (m *SwitchWorkerRelayMasterRequest) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalTo(dAtA) if err != nil { return nil, err } return dAtA[:n], nil } func (m *SwitchWorkerRelayMasterRequest) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if len(m.Workers) > 0 { for _, s := range m.Workers { dAtA[i] = 0xa i++ l = len(s) for l >= 1<<7 { dAtA[i] = uint8(uint64(l)&0x7f | 0x80) l >>= 7 i++ } dAtA[i] = uint8(l) i++ i += copy(dAtA[i:], s) } } return i, nil } func (m *SwitchWorkerRelayMasterResponse) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalTo(dAtA) if err != nil { return nil, err } return dAtA[:n], nil } func (m *SwitchWorkerRelayMasterResponse) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if m.Result { dAtA[i] = 0x8 i++ if m.Result { dAtA[i] = 1 } else { dAtA[i] = 0 } i++ } if len(m.Msg) > 0 { dAtA[i] = 0x12 i++ i = encodeVarintDmmaster(dAtA, i, uint64(len(m.Msg))) i += copy(dAtA[i:], m.Msg) } if len(m.Workers) > 0 { for _, msg := range m.Workers { dAtA[i] = 0x1a i++ i = encodeVarintDmmaster(dAtA, i, uint64(msg.Size())) n, err := msg.MarshalTo(dAtA[i:]) if err != nil { return 0, err } i += n } } return i, nil } func (m *OperateWorkerRelayRequest) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalTo(dAtA) if err != nil { return nil, err } return dAtA[:n], nil } func (m *OperateWorkerRelayRequest) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if m.Op != 0 { dAtA[i] = 0x8 i++ i = encodeVarintDmmaster(dAtA, i, uint64(m.Op)) } if len(m.Workers) > 0 { for _, s := range m.Workers { dAtA[i] = 0x12 i++ l = len(s) for l >= 1<<7 { dAtA[i] = uint8(uint64(l)&0x7f | 0x80) l >>= 7 i++ } dAtA[i] = uint8(l) i++ i += copy(dAtA[i:], s) } } return i, nil } func (m *OperateWorkerRelayResponse) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalTo(dAtA) if err != nil { return nil, err } return dAtA[:n], nil } func (m *OperateWorkerRelayResponse) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if m.Op != 0 { dAtA[i] = 0x8 i++ i = encodeVarintDmmaster(dAtA, i, uint64(m.Op)) } if m.Result { dAtA[i] = 0x10 i++ if m.Result { dAtA[i] = 1 } else { dAtA[i] = 0 } i++ } if len(m.Msg) > 0 { dAtA[i] = 0x1a i++ i = encodeVarintDmmaster(dAtA, i, uint64(len(m.Msg))) i += copy(dAtA[i:], m.Msg) } if len(m.Workers) > 0 { for _, msg := range m.Workers { dAtA[i] = 0x22 i++ i = encodeVarintDmmaster(dAtA, i, uint64(msg.Size())) n, err := msg.MarshalTo(dAtA[i:]) if err != nil { return 0, err } i += n } } return i, nil } func (m *RefreshWorkerTasksRequest) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalTo(dAtA) if err != nil { return nil, err } return dAtA[:n], nil } func (m *RefreshWorkerTasksRequest) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l return i, nil } func (m *RefreshWorkerTasksMsg) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalTo(dAtA) if err != nil { return nil, err } return dAtA[:n], nil } func (m *RefreshWorkerTasksMsg) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if len(m.Worker) > 0 { dAtA[i] = 0xa i++ i = encodeVarintDmmaster(dAtA, i, uint64(len(m.Worker))) i += copy(dAtA[i:], m.Worker) } if len(m.Msg) > 0 { dAtA[i] = 0x12 i++ i = encodeVarintDmmaster(dAtA, i, uint64(len(m.Msg))) i += copy(dAtA[i:], m.Msg) } return i, nil } func (m *RefreshWorkerTasksResponse) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalTo(dAtA) if err != nil { return nil, err } return dAtA[:n], nil } func (m *RefreshWorkerTasksResponse) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if m.Result { dAtA[i] = 0x8 i++ if m.Result { dAtA[i] = 1 } else { dAtA[i] = 0 } i++ } if len(m.Workers) > 0 { for _, msg := range m.Workers { dAtA[i] = 0x12 i++ i = encodeVarintDmmaster(dAtA, i, uint64(msg.Size())) n, err := msg.MarshalTo(dAtA[i:]) if err != nil { return 0, err } i += n } } return i, nil } func (m *HandleSQLsRequest) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalTo(dAtA) if err != nil { return nil, err } return dAtA[:n], nil } func (m *HandleSQLsRequest) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if len(m.Name) > 0 { dAtA[i] = 0xa i++ i = encodeVarintDmmaster(dAtA, i, uint64(len(m.Name))) i += copy(dAtA[i:], m.Name) } if m.Op != 0 { dAtA[i] = 0x10 i++ i = encodeVarintDmmaster(dAtA, i, uint64(m.Op)) } if len(m.Args) > 0 { for _, s := range m.Args { dAtA[i] = 0x1a i++ l = len(s) for l >= 1<<7 { dAtA[i] = uint8(uint64(l)&0x7f | 0x80) l >>= 7 i++ } dAtA[i] = uint8(l) i++ i += copy(dAtA[i:], s) } } if len(m.BinlogPos) > 0 { dAtA[i] = 0x22 i++ i = encodeVarintDmmaster(dAtA, i, uint64(len(m.BinlogPos))) i += copy(dAtA[i:], m.BinlogPos) } if len(m.Worker) > 0 { dAtA[i] = 0x2a i++ i = encodeVarintDmmaster(dAtA, i, uint64(len(m.Worker))) i += copy(dAtA[i:], m.Worker) } if len(m.SqlPattern) > 0 { dAtA[i] = 0x32 i++ i = encodeVarintDmmaster(dAtA, i, uint64(len(m.SqlPattern))) i += copy(dAtA[i:], m.SqlPattern) } if m.Sharding { dAtA[i] = 0x38 i++ if m.Sharding { dAtA[i] = 1 } else { dAtA[i] = 0 } i++ } return i, nil } func (m *HandleSQLsResponse) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalTo(dAtA) if err != nil { return nil, err } return dAtA[:n], nil } func (m *HandleSQLsResponse) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if m.Result { dAtA[i] = 0x8 i++ if m.Result { dAtA[i] = 1 } else { dAtA[i] = 0 } i++ } if len(m.Msg) > 0 { dAtA[i] = 0x12 i++ i = encodeVarintDmmaster(dAtA, i, uint64(len(m.Msg))) i += copy(dAtA[i:], m.Msg) } if len(m.Workers) > 0 { for _, msg := range m.Workers { dAtA[i] = 0x1a i++ i = encodeVarintDmmaster(dAtA, i, uint64(msg.Size())) n, err := msg.MarshalTo(dAtA[i:]) if err != nil { return 0, err } i += n } } return i, nil } func (m *PurgeWorkerRelayRequest) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalTo(dAtA) if err != nil { return nil, err } return dAtA[:n], nil } func (m *PurgeWorkerRelayRequest) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if len(m.Workers) > 0 { for _, s := range m.Workers { dAtA[i] = 0xa i++ l = len(s) for l >= 1<<7 { dAtA[i] = uint8(uint64(l)&0x7f | 0x80) l >>= 7 i++ } dAtA[i] = uint8(l) i++ i += copy(dAtA[i:], s) } } if m.Inactive { dAtA[i] = 0x10 i++ if m.Inactive { dAtA[i] = 1 } else { dAtA[i] = 0 } i++ } if m.Time != 0 { dAtA[i] = 0x18 i++ i = encodeVarintDmmaster(dAtA, i, uint64(m.Time)) } if len(m.Filename) > 0 { dAtA[i] = 0x22 i++ i = encodeVarintDmmaster(dAtA, i, uint64(len(m.Filename))) i += copy(dAtA[i:], m.Filename) } if len(m.SubDir) > 0 { dAtA[i] = 0x2a i++ i = encodeVarintDmmaster(dAtA, i, uint64(len(m.SubDir))) i += copy(dAtA[i:], m.SubDir) } return i, nil } func (m *PurgeWorkerRelayResponse) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalTo(dAtA) if err != nil { return nil, err } return dAtA[:n], nil } func (m *PurgeWorkerRelayResponse) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if m.Result { dAtA[i] = 0x8 i++ if m.Result { dAtA[i] = 1 } else { dAtA[i] = 0 } i++ } if len(m.Msg) > 0 { dAtA[i] = 0x12 i++ i = encodeVarintDmmaster(dAtA, i, uint64(len(m.Msg))) i += copy(dAtA[i:], m.Msg) } if len(m.Workers) > 0 { for _, msg := range m.Workers { dAtA[i] = 0x1a i++ i = encodeVarintDmmaster(dAtA, i, uint64(msg.Size())) n, err := msg.MarshalTo(dAtA[i:]) if err != nil { return 0, err } i += n } } return i, nil } func (m *CheckTaskRequest) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalTo(dAtA) if err != nil { return nil, err } return dAtA[:n], nil } func (m *CheckTaskRequest) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if len(m.Task) > 0 { dAtA[i] = 0xa i++ i = encodeVarintDmmaster(dAtA, i, uint64(len(m.Task))) i += copy(dAtA[i:], m.Task) } return i, nil } func (m *CheckTaskResponse) Marshal() (dAtA []byte, err error) { size := m.Size() dAtA = make([]byte, size) n, err := m.MarshalTo(dAtA) if err != nil { return nil, err } return dAtA[:n], nil } func (m *CheckTaskResponse) MarshalTo(dAtA []byte) (int, error) { var i int _ = i var l int _ = l if m.Result { dAtA[i] = 0x8 i++ if m.Result { dAtA[i] = 1 } else { dAtA[i] = 0 } i++ } if len(m.Msg) > 0 { dAtA[i] = 0x12 i++ i = encodeVarintDmmaster(dAtA, i, uint64(len(m.Msg))) i += copy(dAtA[i:], m.Msg) } return i, nil } func encodeVarintDmmaster(dAtA []byte, offset int, v uint64) int { for v >= 1<<7 { dAtA[offset] = uint8(v&0x7f | 0x80) v >>= 7 offset++ } dAtA[offset] = uint8(v) return offset + 1 } func (m *MigrateWorkerRelayRequest) Size() (n int) { var l int _ = l l = len(m.BinlogName) if l > 0 { n += 1 + l + sovDmmaster(uint64(l)) } if m.BinlogPos != 0 { n += 1 + sovDmmaster(uint64(m.BinlogPos)) } l = len(m.Worker) if l > 0 { n += 1 + l + sovDmmaster(uint64(l)) } return n } func (m *UpdateWorkerRelayConfigRequest) Size() (n int) { var l int _ = l l = len(m.Config) if l > 0 { n += 1 + l + sovDmmaster(uint64(l)) } l = len(m.Worker) if l > 0 { n += 1 + l + sovDmmaster(uint64(l)) } return n } func (m *StartTaskRequest) Size() (n int) { var l int _ = l l = len(m.Task) if l > 0 { n += 1 + l + sovDmmaster(uint64(l)) } if len(m.Workers) > 0 { for _, s := range m.Workers { l = len(s) n += 1 + l + sovDmmaster(uint64(l)) } } return n } func (m *StartTaskResponse) Size() (n int) { var l int _ = l if m.Result { n += 2 } l = len(m.Msg) if l > 0 { n += 1 + l + sovDmmaster(uint64(l)) } if len(m.Workers) > 0 { for _, e := range m.Workers { l = e.Size() n += 1 + l + sovDmmaster(uint64(l)) } } return n } func (m *UpdateMasterConfigRequest) Size() (n int) { var l int _ = l l = len(m.Config) if l > 0 { n += 1 + l + sovDmmaster(uint64(l)) } return n } func (m *UpdateMasterConfigResponse) Size() (n int) { var l int _ = l if m.Result { n += 2 } l = len(m.Msg) if l > 0 { n += 1 + l + sovDmmaster(uint64(l)) } if len(m.Workers) > 0 { for _, e := range m.Workers { l = e.Size() n += 1 + l + sovDmmaster(uint64(l)) } } return n } func (m *OperateTaskRequest) Size() (n int) { var l int _ = l if m.Op != 0 { n += 1 + sovDmmaster(uint64(m.Op)) } l = len(m.Name) if l > 0 { n += 1 + l + sovDmmaster(uint64(l)) } if len(m.Workers) > 0 { for _, s := range m.Workers { l = len(s) n += 1 + l + sovDmmaster(uint64(l)) } } return n } func (m *OperateTaskResponse) Size() (n int) { var l int _ = l if m.Op != 0 { n += 1 + sovDmmaster(uint64(m.Op)) } if m.Result { n += 2 } l = len(m.Msg) if l > 0 { n += 1 + l + sovDmmaster(uint64(l)) } if len(m.Workers) > 0 { for _, e := range m.Workers { l = e.Size() n += 1 + l + sovDmmaster(uint64(l)) } } return n } func (m *UpdateTaskRequest) Size() (n int) { var l int _ = l l = len(m.Task) if l > 0 { n += 1 + l + sovDmmaster(uint64(l)) } if len(m.Workers) > 0 { for _, s := range m.Workers { l = len(s) n += 1 + l + sovDmmaster(uint64(l)) } } return n } func (m *UpdateTaskResponse) Size() (n int) { var l int _ = l if m.Result { n += 2 } l = len(m.Msg) if l > 0 { n += 1 + l + sovDmmaster(uint64(l)) } if len(m.Workers) > 0 { for _, e := range m.Workers { l = e.Size() n += 1 + l + sovDmmaster(uint64(l)) } } return n } func (m *QueryStatusListRequest) Size() (n int) { var l int _ = l l = len(m.Name) if l > 0 { n += 1 + l + sovDmmaster(uint64(l)) } if len(m.Workers) > 0 { for _, s := range m.Workers { l = len(s) n += 1 + l + sovDmmaster(uint64(l)) } } return n } func (m *QueryStatusListResponse) Size() (n int) { var l int _ = l if m.Result { n += 2 } l = len(m.Msg) if l > 0 { n += 1 + l + sovDmmaster(uint64(l)) } if len(m.Workers) > 0 { for _, e := range m.Workers { l = e.Size() n += 1 + l + sovDmmaster(uint64(l)) } } return n } func (m *QueryErrorListRequest) Size() (n int) { var l int _ = l l = len(m.Name) if l > 0 { n += 1 + l + sovDmmaster(uint64(l)) } if len(m.Workers) > 0 { for _, s := range m.Workers { l = len(s) n += 1 + l + sovDmmaster(uint64(l)) } } return n } func (m *QueryErrorListResponse) Size() (n int) { var l int _ = l if m.Result { n += 2 } l = len(m.Msg) if l > 0 { n += 1 + l + sovDmmaster(uint64(l)) } if len(m.Workers) > 0 { for _, e := range m.Workers { l = e.Size() n += 1 + l + sovDmmaster(uint64(l)) } } return n } func (m *ShowDDLLocksRequest) Size() (n int) { var l int _ = l l = len(m.Task) if l > 0 { n += 1 + l + sovDmmaster(uint64(l)) } if len(m.Workers) > 0 { for _, s := range m.Workers { l = len(s) n += 1 + l + sovDmmaster(uint64(l)) } } return n } func (m *DDLLock) Size() (n int) { var l int _ = l l = len(m.ID) if l > 0 { n += 1 + l + sovDmmaster(uint64(l)) } l = len(m.Task) if l > 0 { n += 1 + l + sovDmmaster(uint64(l)) } l = len(m.Owner) if l > 0 { n += 1 + l + sovDmmaster(uint64(l)) } if len(m.DDLs) > 0 { for _, s := range m.DDLs { l = len(s) n += 1 + l + sovDmmaster(uint64(l)) } } if len(m.Synced) > 0 { for _, s := range m.Synced { l = len(s) n += 1 + l + sovDmmaster(uint64(l)) } } if len(m.Unsynced) > 0 { for _, s := range m.Unsynced { l = len(s) n += 1 + l + sovDmmaster(uint64(l)) } } return n } func (m *ShowDDLLocksResponse) Size() (n int) { var l int _ = l if m.Result { n += 2 } l = len(m.Msg) if l > 0 { n += 1 + l + sovDmmaster(uint64(l)) } if len(m.Locks) > 0 { for _, e := range m.Locks { l = e.Size() n += 1 + l + sovDmmaster(uint64(l)) } } return n } func (m *UnlockDDLLockRequest) Size() (n int) { var l int _ = l l = len(m.ID) if l > 0 { n += 1 + l + sovDmmaster(uint64(l)) } l = len(m.ReplaceOwner) if l > 0 { n += 1 + l + sovDmmaster(uint64(l)) } if len(m.Workers) > 0 { for _, s := range m.Workers { l = len(s) n += 1 + l + sovDmmaster(uint64(l)) } } if m.ForceRemove { n += 2 } return n } func (m *UnlockDDLLockResponse) Size() (n int) { var l int _ = l if m.Result { n += 2 } l = len(m.Msg) if l > 0 { n += 1 + l + sovDmmaster(uint64(l)) } if len(m.Workers) > 0 { for _, e := range m.Workers { l = e.Size() n += 1 + l + sovDmmaster(uint64(l)) } } return n } func (m *BreakWorkerDDLLockRequest) Size() (n int) { var l int _ = l if len(m.Workers) > 0 { for _, s := range m.Workers { l = len(s) n += 1 + l + sovDmmaster(uint64(l)) } } l = len(m.Task) if l > 0 { n += 1 + l + sovDmmaster(uint64(l)) } l = len(m.RemoveLockID) if l > 0 { n += 1 + l + sovDmmaster(uint64(l)) } if m.ExecDDL { n += 2 } if m.SkipDDL { n += 2 } return n } func (m *BreakWorkerDDLLockResponse) Size() (n int) { var l int _ = l if m.Result { n += 2 } l = len(m.Msg) if l > 0 { n += 1 + l + sovDmmaster(uint64(l)) } if len(m.Workers) > 0 { for _, e := range m.Workers { l = e.Size() n += 1 + l + sovDmmaster(uint64(l)) } } return n } func (m *SwitchWorkerRelayMasterRequest) Size() (n int) { var l int _ = l if len(m.Workers) > 0 { for _, s := range m.Workers { l = len(s) n += 1 + l + sovDmmaster(uint64(l)) } } return n } func (m *SwitchWorkerRelayMasterResponse) Size() (n int) { var l int _ = l if m.Result { n += 2 } l = len(m.Msg) if l > 0 { n += 1 + l + sovDmmaster(uint64(l)) } if len(m.Workers) > 0 { for _, e := range m.Workers { l = e.Size() n += 1 + l + sovDmmaster(uint64(l)) } } return n } func (m *OperateWorkerRelayRequest) Size() (n int) { var l int _ = l if m.Op != 0 { n += 1 + sovDmmaster(uint64(m.Op)) } if len(m.Workers) > 0 { for _, s := range m.Workers { l = len(s) n += 1 + l + sovDmmaster(uint64(l)) } } return n } func (m *OperateWorkerRelayResponse) Size() (n int) { var l int _ = l if m.Op != 0 { n += 1 + sovDmmaster(uint64(m.Op)) } if m.Result { n += 2 } l = len(m.Msg) if l > 0 { n += 1 + l + sovDmmaster(uint64(l)) } if len(m.Workers) > 0 { for _, e := range m.Workers { l = e.Size() n += 1 + l + sovDmmaster(uint64(l)) } } return n } func (m *RefreshWorkerTasksRequest) Size() (n int) { var l int _ = l return n } func (m *RefreshWorkerTasksMsg) Size() (n int) { var l int _ = l l = len(m.Worker) if l > 0 { n += 1 + l + sovDmmaster(uint64(l)) } l = len(m.Msg) if l > 0 { n += 1 + l + sovDmmaster(uint64(l)) } return n } func (m *RefreshWorkerTasksResponse) Size() (n int) { var l int _ = l if m.Result { n += 2 } if len(m.Workers) > 0 { for _, e := range m.Workers { l = e.Size() n += 1 + l + sovDmmaster(uint64(l)) } } return n } func (m *HandleSQLsRequest) Size() (n int) { var l int _ = l l = len(m.Name) if l > 0 { n += 1 + l + sovDmmaster(uint64(l)) } if m.Op != 0 { n += 1 + sovDmmaster(uint64(m.Op)) } if len(m.Args) > 0 { for _, s := range m.Args { l = len(s) n += 1 + l + sovDmmaster(uint64(l)) } } l = len(m.BinlogPos) if l > 0 { n += 1 + l + sovDmmaster(uint64(l)) } l = len(m.Worker) if l > 0 { n += 1 + l + sovDmmaster(uint64(l)) } l = len(m.SqlPattern) if l > 0 { n += 1 + l + sovDmmaster(uint64(l)) } if m.Sharding { n += 2 } return n } func (m *HandleSQLsResponse) Size() (n int) { var l int _ = l if m.Result { n += 2 } l = len(m.Msg) if l > 0 { n += 1 + l + sovDmmaster(uint64(l)) } if len(m.Workers) > 0 { for _, e := range m.Workers { l = e.Size() n += 1 + l + sovDmmaster(uint64(l)) } } return n } func (m *PurgeWorkerRelayRequest) Size() (n int) { var l int _ = l if len(m.Workers) > 0 { for _, s := range m.Workers { l = len(s) n += 1 + l + sovDmmaster(uint64(l)) } } if m.Inactive { n += 2 } if m.Time != 0 { n += 1 + sovDmmaster(uint64(m.Time)) } l = len(m.Filename) if l > 0 { n += 1 + l + sovDmmaster(uint64(l)) } l = len(m.SubDir) if l > 0 { n += 1 + l + sovDmmaster(uint64(l)) } return n } func (m *PurgeWorkerRelayResponse) Size() (n int) { var l int _ = l if m.Result { n += 2 } l = len(m.Msg) if l > 0 { n += 1 + l + sovDmmaster(uint64(l)) } if len(m.Workers) > 0 { for _, e := range m.Workers { l = e.Size() n += 1 + l + sovDmmaster(uint64(l)) } } return n } func (m *CheckTaskRequest) Size() (n int) { var l int _ = l l = len(m.Task) if l > 0 { n += 1 + l + sovDmmaster(uint64(l)) } return n } func (m *CheckTaskResponse) Size() (n int) { var l int _ = l if m.Result { n += 2 } l = len(m.Msg) if l > 0 { n += 1 + l + sovDmmaster(uint64(l)) } return n } func sovDmmaster(x uint64) (n int) { for { n++ x >>= 7 if x == 0 { break } } return n } func sozDmmaster(x uint64) (n int) { return sovDmmaster(uint64((x << 1) ^ uint64((int64(x) >> 63)))) } func (m *MigrateWorkerRelayRequest) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 for iNdEx < l { preIndex := iNdEx var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ wire |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } fieldNum := int32(wire >> 3) wireType := int(wire & 0x7) if wireType == 4 { return fmt.Errorf("proto: MigrateWorkerRelayRequest: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: MigrateWorkerRelayRequest: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field BinlogName", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + intStringLen if postIndex > l { return io.ErrUnexpectedEOF } m.BinlogName = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 2: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field BinlogPos", wireType) } m.BinlogPos = 0 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ m.BinlogPos |= (uint32(b) & 0x7F) << shift if b < 0x80 { break } } case 3: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Worker", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + intStringLen if postIndex > l { return io.ErrUnexpectedEOF } m.Worker = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipDmmaster(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthDmmaster } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *UpdateWorkerRelayConfigRequest) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 for iNdEx < l { preIndex := iNdEx var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ wire |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } fieldNum := int32(wire >> 3) wireType := int(wire & 0x7) if wireType == 4 { return fmt.Errorf("proto: UpdateWorkerRelayConfigRequest: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: UpdateWorkerRelayConfigRequest: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Config", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + intStringLen if postIndex > l { return io.ErrUnexpectedEOF } m.Config = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 2: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Worker", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + intStringLen if postIndex > l { return io.ErrUnexpectedEOF } m.Worker = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipDmmaster(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthDmmaster } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *StartTaskRequest) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 for iNdEx < l { preIndex := iNdEx var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ wire |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } fieldNum := int32(wire >> 3) wireType := int(wire & 0x7) if wireType == 4 { return fmt.Errorf("proto: StartTaskRequest: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: StartTaskRequest: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Task", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + intStringLen if postIndex > l { return io.ErrUnexpectedEOF } m.Task = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 2: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Workers", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + intStringLen if postIndex > l { return io.ErrUnexpectedEOF } m.Workers = append(m.Workers, string(dAtA[iNdEx:postIndex])) iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipDmmaster(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthDmmaster } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *StartTaskResponse) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 for iNdEx < l { preIndex := iNdEx var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ wire |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } fieldNum := int32(wire >> 3) wireType := int(wire & 0x7) if wireType == 4 { return fmt.Errorf("proto: StartTaskResponse: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: StartTaskResponse: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field Result", wireType) } var v int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ v |= (int(b) & 0x7F) << shift if b < 0x80 { break } } m.Result = bool(v != 0) case 2: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Msg", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + intStringLen if postIndex > l { return io.ErrUnexpectedEOF } m.Msg = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 3: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Workers", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= (int(b) & 0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + msglen if postIndex > l { return io.ErrUnexpectedEOF } m.Workers = append(m.Workers, &CommonWorkerResponse{}) if err := m.Workers[len(m.Workers)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipDmmaster(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthDmmaster } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *UpdateMasterConfigRequest) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 for iNdEx < l { preIndex := iNdEx var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ wire |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } fieldNum := int32(wire >> 3) wireType := int(wire & 0x7) if wireType == 4 { return fmt.Errorf("proto: UpdateMasterConfigRequest: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: UpdateMasterConfigRequest: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Config", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + intStringLen if postIndex > l { return io.ErrUnexpectedEOF } m.Config = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipDmmaster(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthDmmaster } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *UpdateMasterConfigResponse) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 for iNdEx < l { preIndex := iNdEx var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ wire |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } fieldNum := int32(wire >> 3) wireType := int(wire & 0x7) if wireType == 4 { return fmt.Errorf("proto: UpdateMasterConfigResponse: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: UpdateMasterConfigResponse: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field Result", wireType) } var v int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ v |= (int(b) & 0x7F) << shift if b < 0x80 { break } } m.Result = bool(v != 0) case 2: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Msg", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + intStringLen if postIndex > l { return io.ErrUnexpectedEOF } m.Msg = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 3: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Workers", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= (int(b) & 0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + msglen if postIndex > l { return io.ErrUnexpectedEOF } m.Workers = append(m.Workers, &QueryStatusResponse{}) if err := m.Workers[len(m.Workers)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipDmmaster(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthDmmaster } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *OperateTaskRequest) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 for iNdEx < l { preIndex := iNdEx var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ wire |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } fieldNum := int32(wire >> 3) wireType := int(wire & 0x7) if wireType == 4 { return fmt.Errorf("proto: OperateTaskRequest: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: OperateTaskRequest: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field Op", wireType) } m.Op = 0 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ m.Op |= (TaskOp(b) & 0x7F) << shift if b < 0x80 { break } } case 2: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Name", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + intStringLen if postIndex > l { return io.ErrUnexpectedEOF } m.Name = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 3: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Workers", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + intStringLen if postIndex > l { return io.ErrUnexpectedEOF } m.Workers = append(m.Workers, string(dAtA[iNdEx:postIndex])) iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipDmmaster(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthDmmaster } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *OperateTaskResponse) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 for iNdEx < l { preIndex := iNdEx var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ wire |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } fieldNum := int32(wire >> 3) wireType := int(wire & 0x7) if wireType == 4 { return fmt.Errorf("proto: OperateTaskResponse: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: OperateTaskResponse: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field Op", wireType) } m.Op = 0 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ m.Op |= (TaskOp(b) & 0x7F) << shift if b < 0x80 { break } } case 2: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field Result", wireType) } var v int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ v |= (int(b) & 0x7F) << shift if b < 0x80 { break } } m.Result = bool(v != 0) case 3: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Msg", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + intStringLen if postIndex > l { return io.ErrUnexpectedEOF } m.Msg = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 4: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Workers", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= (int(b) & 0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + msglen if postIndex > l { return io.ErrUnexpectedEOF } m.Workers = append(m.Workers, &OperateSubTaskResponse{}) if err := m.Workers[len(m.Workers)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipDmmaster(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthDmmaster } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *UpdateTaskRequest) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 for iNdEx < l { preIndex := iNdEx var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ wire |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } fieldNum := int32(wire >> 3) wireType := int(wire & 0x7) if wireType == 4 { return fmt.Errorf("proto: UpdateTaskRequest: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: UpdateTaskRequest: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Task", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + intStringLen if postIndex > l { return io.ErrUnexpectedEOF } m.Task = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 2: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Workers", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + intStringLen if postIndex > l { return io.ErrUnexpectedEOF } m.Workers = append(m.Workers, string(dAtA[iNdEx:postIndex])) iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipDmmaster(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthDmmaster } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *UpdateTaskResponse) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 for iNdEx < l { preIndex := iNdEx var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ wire |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } fieldNum := int32(wire >> 3) wireType := int(wire & 0x7) if wireType == 4 { return fmt.Errorf("proto: UpdateTaskResponse: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: UpdateTaskResponse: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field Result", wireType) } var v int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ v |= (int(b) & 0x7F) << shift if b < 0x80 { break } } m.Result = bool(v != 0) case 2: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Msg", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + intStringLen if postIndex > l { return io.ErrUnexpectedEOF } m.Msg = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 3: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Workers", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= (int(b) & 0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + msglen if postIndex > l { return io.ErrUnexpectedEOF } m.Workers = append(m.Workers, &CommonWorkerResponse{}) if err := m.Workers[len(m.Workers)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipDmmaster(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthDmmaster } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *QueryStatusListRequest) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 for iNdEx < l { preIndex := iNdEx var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ wire |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } fieldNum := int32(wire >> 3) wireType := int(wire & 0x7) if wireType == 4 { return fmt.Errorf("proto: QueryStatusListRequest: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: QueryStatusListRequest: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Name", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + intStringLen if postIndex > l { return io.ErrUnexpectedEOF } m.Name = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 2: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Workers", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + intStringLen if postIndex > l { return io.ErrUnexpectedEOF } m.Workers = append(m.Workers, string(dAtA[iNdEx:postIndex])) iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipDmmaster(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthDmmaster } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *QueryStatusListResponse) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 for iNdEx < l { preIndex := iNdEx var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ wire |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } fieldNum := int32(wire >> 3) wireType := int(wire & 0x7) if wireType == 4 { return fmt.Errorf("proto: QueryStatusListResponse: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: QueryStatusListResponse: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field Result", wireType) } var v int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ v |= (int(b) & 0x7F) << shift if b < 0x80 { break } } m.Result = bool(v != 0) case 2: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Msg", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + intStringLen if postIndex > l { return io.ErrUnexpectedEOF } m.Msg = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 3: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Workers", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= (int(b) & 0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + msglen if postIndex > l { return io.ErrUnexpectedEOF } m.Workers = append(m.Workers, &QueryStatusResponse{}) if err := m.Workers[len(m.Workers)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipDmmaster(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthDmmaster } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *QueryErrorListRequest) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 for iNdEx < l { preIndex := iNdEx var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ wire |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } fieldNum := int32(wire >> 3) wireType := int(wire & 0x7) if wireType == 4 { return fmt.Errorf("proto: QueryErrorListRequest: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: QueryErrorListRequest: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Name", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + intStringLen if postIndex > l { return io.ErrUnexpectedEOF } m.Name = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 2: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Workers", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + intStringLen if postIndex > l { return io.ErrUnexpectedEOF } m.Workers = append(m.Workers, string(dAtA[iNdEx:postIndex])) iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipDmmaster(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthDmmaster } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *QueryErrorListResponse) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 for iNdEx < l { preIndex := iNdEx var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ wire |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } fieldNum := int32(wire >> 3) wireType := int(wire & 0x7) if wireType == 4 { return fmt.Errorf("proto: QueryErrorListResponse: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: QueryErrorListResponse: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field Result", wireType) } var v int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ v |= (int(b) & 0x7F) << shift if b < 0x80 { break } } m.Result = bool(v != 0) case 2: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Msg", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + intStringLen if postIndex > l { return io.ErrUnexpectedEOF } m.Msg = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 3: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Workers", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= (int(b) & 0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + msglen if postIndex > l { return io.ErrUnexpectedEOF } m.Workers = append(m.Workers, &QueryErrorResponse{}) if err := m.Workers[len(m.Workers)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipDmmaster(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthDmmaster } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *ShowDDLLocksRequest) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 for iNdEx < l { preIndex := iNdEx var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ wire |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } fieldNum := int32(wire >> 3) wireType := int(wire & 0x7) if wireType == 4 { return fmt.Errorf("proto: ShowDDLLocksRequest: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: ShowDDLLocksRequest: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Task", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + intStringLen if postIndex > l { return io.ErrUnexpectedEOF } m.Task = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 2: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Workers", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + intStringLen if postIndex > l { return io.ErrUnexpectedEOF } m.Workers = append(m.Workers, string(dAtA[iNdEx:postIndex])) iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipDmmaster(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthDmmaster } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *DDLLock) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 for iNdEx < l { preIndex := iNdEx var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ wire |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } fieldNum := int32(wire >> 3) wireType := int(wire & 0x7) if wireType == 4 { return fmt.Errorf("proto: DDLLock: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: DDLLock: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field ID", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + intStringLen if postIndex > l { return io.ErrUnexpectedEOF } m.ID = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 2: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Task", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + intStringLen if postIndex > l { return io.ErrUnexpectedEOF } m.Task = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 3: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Owner", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + intStringLen if postIndex > l { return io.ErrUnexpectedEOF } m.Owner = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 4: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field DDLs", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + intStringLen if postIndex > l { return io.ErrUnexpectedEOF } m.DDLs = append(m.DDLs, string(dAtA[iNdEx:postIndex])) iNdEx = postIndex case 5: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Synced", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + intStringLen if postIndex > l { return io.ErrUnexpectedEOF } m.Synced = append(m.Synced, string(dAtA[iNdEx:postIndex])) iNdEx = postIndex case 6: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Unsynced", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + intStringLen if postIndex > l { return io.ErrUnexpectedEOF } m.Unsynced = append(m.Unsynced, string(dAtA[iNdEx:postIndex])) iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipDmmaster(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthDmmaster } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *ShowDDLLocksResponse) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 for iNdEx < l { preIndex := iNdEx var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ wire |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } fieldNum := int32(wire >> 3) wireType := int(wire & 0x7) if wireType == 4 { return fmt.Errorf("proto: ShowDDLLocksResponse: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: ShowDDLLocksResponse: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field Result", wireType) } var v int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ v |= (int(b) & 0x7F) << shift if b < 0x80 { break } } m.Result = bool(v != 0) case 2: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Msg", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + intStringLen if postIndex > l { return io.ErrUnexpectedEOF } m.Msg = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 3: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Locks", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= (int(b) & 0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + msglen if postIndex > l { return io.ErrUnexpectedEOF } m.Locks = append(m.Locks, &DDLLock{}) if err := m.Locks[len(m.Locks)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipDmmaster(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthDmmaster } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *UnlockDDLLockRequest) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 for iNdEx < l { preIndex := iNdEx var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ wire |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } fieldNum := int32(wire >> 3) wireType := int(wire & 0x7) if wireType == 4 { return fmt.Errorf("proto: UnlockDDLLockRequest: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: UnlockDDLLockRequest: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field ID", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + intStringLen if postIndex > l { return io.ErrUnexpectedEOF } m.ID = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 2: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field ReplaceOwner", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + intStringLen if postIndex > l { return io.ErrUnexpectedEOF } m.ReplaceOwner = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 3: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Workers", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + intStringLen if postIndex > l { return io.ErrUnexpectedEOF } m.Workers = append(m.Workers, string(dAtA[iNdEx:postIndex])) iNdEx = postIndex case 4: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field ForceRemove", wireType) } var v int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ v |= (int(b) & 0x7F) << shift if b < 0x80 { break } } m.ForceRemove = bool(v != 0) default: iNdEx = preIndex skippy, err := skipDmmaster(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthDmmaster } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *UnlockDDLLockResponse) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 for iNdEx < l { preIndex := iNdEx var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ wire |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } fieldNum := int32(wire >> 3) wireType := int(wire & 0x7) if wireType == 4 { return fmt.Errorf("proto: UnlockDDLLockResponse: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: UnlockDDLLockResponse: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field Result", wireType) } var v int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ v |= (int(b) & 0x7F) << shift if b < 0x80 { break } } m.Result = bool(v != 0) case 2: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Msg", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + intStringLen if postIndex > l { return io.ErrUnexpectedEOF } m.Msg = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 3: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Workers", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= (int(b) & 0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + msglen if postIndex > l { return io.ErrUnexpectedEOF } m.Workers = append(m.Workers, &CommonWorkerResponse{}) if err := m.Workers[len(m.Workers)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipDmmaster(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthDmmaster } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *BreakWorkerDDLLockRequest) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 for iNdEx < l { preIndex := iNdEx var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ wire |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } fieldNum := int32(wire >> 3) wireType := int(wire & 0x7) if wireType == 4 { return fmt.Errorf("proto: BreakWorkerDDLLockRequest: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: BreakWorkerDDLLockRequest: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Workers", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + intStringLen if postIndex > l { return io.ErrUnexpectedEOF } m.Workers = append(m.Workers, string(dAtA[iNdEx:postIndex])) iNdEx = postIndex case 2: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Task", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + intStringLen if postIndex > l { return io.ErrUnexpectedEOF } m.Task = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 3: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field RemoveLockID", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + intStringLen if postIndex > l { return io.ErrUnexpectedEOF } m.RemoveLockID = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 4: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field ExecDDL", wireType) } var v int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ v |= (int(b) & 0x7F) << shift if b < 0x80 { break } } m.ExecDDL = bool(v != 0) case 5: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field SkipDDL", wireType) } var v int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ v |= (int(b) & 0x7F) << shift if b < 0x80 { break } } m.SkipDDL = bool(v != 0) default: iNdEx = preIndex skippy, err := skipDmmaster(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthDmmaster } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *BreakWorkerDDLLockResponse) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 for iNdEx < l { preIndex := iNdEx var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ wire |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } fieldNum := int32(wire >> 3) wireType := int(wire & 0x7) if wireType == 4 { return fmt.Errorf("proto: BreakWorkerDDLLockResponse: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: BreakWorkerDDLLockResponse: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field Result", wireType) } var v int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ v |= (int(b) & 0x7F) << shift if b < 0x80 { break } } m.Result = bool(v != 0) case 2: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Msg", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + intStringLen if postIndex > l { return io.ErrUnexpectedEOF } m.Msg = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 3: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Workers", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= (int(b) & 0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + msglen if postIndex > l { return io.ErrUnexpectedEOF } m.Workers = append(m.Workers, &CommonWorkerResponse{}) if err := m.Workers[len(m.Workers)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipDmmaster(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthDmmaster } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *SwitchWorkerRelayMasterRequest) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 for iNdEx < l { preIndex := iNdEx var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ wire |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } fieldNum := int32(wire >> 3) wireType := int(wire & 0x7) if wireType == 4 { return fmt.Errorf("proto: SwitchWorkerRelayMasterRequest: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: SwitchWorkerRelayMasterRequest: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Workers", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + intStringLen if postIndex > l { return io.ErrUnexpectedEOF } m.Workers = append(m.Workers, string(dAtA[iNdEx:postIndex])) iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipDmmaster(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthDmmaster } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *SwitchWorkerRelayMasterResponse) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 for iNdEx < l { preIndex := iNdEx var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ wire |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } fieldNum := int32(wire >> 3) wireType := int(wire & 0x7) if wireType == 4 { return fmt.Errorf("proto: SwitchWorkerRelayMasterResponse: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: SwitchWorkerRelayMasterResponse: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field Result", wireType) } var v int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ v |= (int(b) & 0x7F) << shift if b < 0x80 { break } } m.Result = bool(v != 0) case 2: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Msg", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + intStringLen if postIndex > l { return io.ErrUnexpectedEOF } m.Msg = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 3: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Workers", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= (int(b) & 0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + msglen if postIndex > l { return io.ErrUnexpectedEOF } m.Workers = append(m.Workers, &CommonWorkerResponse{}) if err := m.Workers[len(m.Workers)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipDmmaster(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthDmmaster } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *OperateWorkerRelayRequest) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 for iNdEx < l { preIndex := iNdEx var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ wire |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } fieldNum := int32(wire >> 3) wireType := int(wire & 0x7) if wireType == 4 { return fmt.Errorf("proto: OperateWorkerRelayRequest: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: OperateWorkerRelayRequest: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field Op", wireType) } m.Op = 0 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ m.Op |= (RelayOp(b) & 0x7F) << shift if b < 0x80 { break } } case 2: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Workers", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + intStringLen if postIndex > l { return io.ErrUnexpectedEOF } m.Workers = append(m.Workers, string(dAtA[iNdEx:postIndex])) iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipDmmaster(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthDmmaster } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *OperateWorkerRelayResponse) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 for iNdEx < l { preIndex := iNdEx var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ wire |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } fieldNum := int32(wire >> 3) wireType := int(wire & 0x7) if wireType == 4 { return fmt.Errorf("proto: OperateWorkerRelayResponse: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: OperateWorkerRelayResponse: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field Op", wireType) } m.Op = 0 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ m.Op |= (RelayOp(b) & 0x7F) << shift if b < 0x80 { break } } case 2: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field Result", wireType) } var v int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ v |= (int(b) & 0x7F) << shift if b < 0x80 { break } } m.Result = bool(v != 0) case 3: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Msg", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + intStringLen if postIndex > l { return io.ErrUnexpectedEOF } m.Msg = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 4: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Workers", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= (int(b) & 0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + msglen if postIndex > l { return io.ErrUnexpectedEOF } m.Workers = append(m.Workers, &OperateRelayResponse{}) if err := m.Workers[len(m.Workers)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipDmmaster(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthDmmaster } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *RefreshWorkerTasksRequest) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 for iNdEx < l { preIndex := iNdEx var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ wire |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } fieldNum := int32(wire >> 3) wireType := int(wire & 0x7) if wireType == 4 { return fmt.Errorf("proto: RefreshWorkerTasksRequest: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: RefreshWorkerTasksRequest: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { default: iNdEx = preIndex skippy, err := skipDmmaster(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthDmmaster } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *RefreshWorkerTasksMsg) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 for iNdEx < l { preIndex := iNdEx var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ wire |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } fieldNum := int32(wire >> 3) wireType := int(wire & 0x7) if wireType == 4 { return fmt.Errorf("proto: RefreshWorkerTasksMsg: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: RefreshWorkerTasksMsg: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Worker", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + intStringLen if postIndex > l { return io.ErrUnexpectedEOF } m.Worker = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 2: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Msg", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + intStringLen if postIndex > l { return io.ErrUnexpectedEOF } m.Msg = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipDmmaster(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthDmmaster } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *RefreshWorkerTasksResponse) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 for iNdEx < l { preIndex := iNdEx var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ wire |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } fieldNum := int32(wire >> 3) wireType := int(wire & 0x7) if wireType == 4 { return fmt.Errorf("proto: RefreshWorkerTasksResponse: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: RefreshWorkerTasksResponse: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field Result", wireType) } var v int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ v |= (int(b) & 0x7F) << shift if b < 0x80 { break } } m.Result = bool(v != 0) case 2: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Workers", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= (int(b) & 0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + msglen if postIndex > l { return io.ErrUnexpectedEOF } m.Workers = append(m.Workers, &RefreshWorkerTasksMsg{}) if err := m.Workers[len(m.Workers)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipDmmaster(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthDmmaster } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *HandleSQLsRequest) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 for iNdEx < l { preIndex := iNdEx var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ wire |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } fieldNum := int32(wire >> 3) wireType := int(wire & 0x7) if wireType == 4 { return fmt.Errorf("proto: HandleSQLsRequest: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: HandleSQLsRequest: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Name", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + intStringLen if postIndex > l { return io.ErrUnexpectedEOF } m.Name = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 2: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field Op", wireType) } m.Op = 0 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ m.Op |= (SQLOp(b) & 0x7F) << shift if b < 0x80 { break } } case 3: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Args", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + intStringLen if postIndex > l { return io.ErrUnexpectedEOF } m.Args = append(m.Args, string(dAtA[iNdEx:postIndex])) iNdEx = postIndex case 4: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field BinlogPos", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + intStringLen if postIndex > l { return io.ErrUnexpectedEOF } m.BinlogPos = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 5: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Worker", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + intStringLen if postIndex > l { return io.ErrUnexpectedEOF } m.Worker = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 6: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field SqlPattern", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + intStringLen if postIndex > l { return io.ErrUnexpectedEOF } m.SqlPattern = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 7: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field Sharding", wireType) } var v int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ v |= (int(b) & 0x7F) << shift if b < 0x80 { break } } m.Sharding = bool(v != 0) default: iNdEx = preIndex skippy, err := skipDmmaster(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthDmmaster } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *HandleSQLsResponse) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 for iNdEx < l { preIndex := iNdEx var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ wire |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } fieldNum := int32(wire >> 3) wireType := int(wire & 0x7) if wireType == 4 { return fmt.Errorf("proto: HandleSQLsResponse: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: HandleSQLsResponse: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field Result", wireType) } var v int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ v |= (int(b) & 0x7F) << shift if b < 0x80 { break } } m.Result = bool(v != 0) case 2: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Msg", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + intStringLen if postIndex > l { return io.ErrUnexpectedEOF } m.Msg = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 3: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Workers", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= (int(b) & 0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + msglen if postIndex > l { return io.ErrUnexpectedEOF } m.Workers = append(m.Workers, &CommonWorkerResponse{}) if err := m.Workers[len(m.Workers)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipDmmaster(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthDmmaster } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *PurgeWorkerRelayRequest) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 for iNdEx < l { preIndex := iNdEx var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ wire |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } fieldNum := int32(wire >> 3) wireType := int(wire & 0x7) if wireType == 4 { return fmt.Errorf("proto: PurgeWorkerRelayRequest: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: PurgeWorkerRelayRequest: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Workers", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + intStringLen if postIndex > l { return io.ErrUnexpectedEOF } m.Workers = append(m.Workers, string(dAtA[iNdEx:postIndex])) iNdEx = postIndex case 2: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field Inactive", wireType) } var v int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ v |= (int(b) & 0x7F) << shift if b < 0x80 { break } } m.Inactive = bool(v != 0) case 3: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field Time", wireType) } m.Time = 0 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ m.Time |= (int64(b) & 0x7F) << shift if b < 0x80 { break } } case 4: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Filename", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + intStringLen if postIndex > l { return io.ErrUnexpectedEOF } m.Filename = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 5: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field SubDir", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + intStringLen if postIndex > l { return io.ErrUnexpectedEOF } m.SubDir = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipDmmaster(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthDmmaster } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *PurgeWorkerRelayResponse) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 for iNdEx < l { preIndex := iNdEx var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ wire |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } fieldNum := int32(wire >> 3) wireType := int(wire & 0x7) if wireType == 4 { return fmt.Errorf("proto: PurgeWorkerRelayResponse: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: PurgeWorkerRelayResponse: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field Result", wireType) } var v int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ v |= (int(b) & 0x7F) << shift if b < 0x80 { break } } m.Result = bool(v != 0) case 2: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Msg", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + intStringLen if postIndex > l { return io.ErrUnexpectedEOF } m.Msg = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex case 3: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Workers", wireType) } var msglen int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ msglen |= (int(b) & 0x7F) << shift if b < 0x80 { break } } if msglen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + msglen if postIndex > l { return io.ErrUnexpectedEOF } m.Workers = append(m.Workers, &CommonWorkerResponse{}) if err := m.Workers[len(m.Workers)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil { return err } iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipDmmaster(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthDmmaster } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *CheckTaskRequest) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 for iNdEx < l { preIndex := iNdEx var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ wire |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } fieldNum := int32(wire >> 3) wireType := int(wire & 0x7) if wireType == 4 { return fmt.Errorf("proto: CheckTaskRequest: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: CheckTaskRequest: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Task", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + intStringLen if postIndex > l { return io.ErrUnexpectedEOF } m.Task = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipDmmaster(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthDmmaster } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func (m *CheckTaskResponse) Unmarshal(dAtA []byte) error { l := len(dAtA) iNdEx := 0 for iNdEx < l { preIndex := iNdEx var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ wire |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } fieldNum := int32(wire >> 3) wireType := int(wire & 0x7) if wireType == 4 { return fmt.Errorf("proto: CheckTaskResponse: wiretype end group for non-group") } if fieldNum <= 0 { return fmt.Errorf("proto: CheckTaskResponse: illegal tag %d (wire type %d)", fieldNum, wire) } switch fieldNum { case 1: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field Result", wireType) } var v int for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ v |= (int(b) & 0x7F) << shift if b < 0x80 { break } } m.Result = bool(v != 0) case 2: if wireType != 2 { return fmt.Errorf("proto: wrong wireType = %d for field Msg", wireType) } var stringLen uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowDmmaster } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ stringLen |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } intStringLen := int(stringLen) if intStringLen < 0 { return ErrInvalidLengthDmmaster } postIndex := iNdEx + intStringLen if postIndex > l { return io.ErrUnexpectedEOF } m.Msg = string(dAtA[iNdEx:postIndex]) iNdEx = postIndex default: iNdEx = preIndex skippy, err := skipDmmaster(dAtA[iNdEx:]) if err != nil { return err } if skippy < 0 { return ErrInvalidLengthDmmaster } if (iNdEx + skippy) > l { return io.ErrUnexpectedEOF } iNdEx += skippy } } if iNdEx > l { return io.ErrUnexpectedEOF } return nil } func skipDmmaster(dAtA []byte) (n int, err error) { l := len(dAtA) iNdEx := 0 for iNdEx < l { var wire uint64 for shift := uint(0); ; shift += 7 { if shift >= 64 { return 0, ErrIntOverflowDmmaster } if iNdEx >= l { return 0, io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ wire |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } wireType := int(wire & 0x7) switch wireType { case 0: for shift := uint(0); ; shift += 7 { if shift >= 64 { return 0, ErrIntOverflowDmmaster } if iNdEx >= l { return 0, io.ErrUnexpectedEOF } iNdEx++ if dAtA[iNdEx-1] < 0x80 { break } } return iNdEx, nil case 1: iNdEx += 8 return iNdEx, nil case 2: var length int for shift := uint(0); ; shift += 7 { if shift >= 64 { return 0, ErrIntOverflowDmmaster } if iNdEx >= l { return 0, io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ length |= (int(b) & 0x7F) << shift if b < 0x80 { break } } iNdEx += length if length < 0 { return 0, ErrInvalidLengthDmmaster } return iNdEx, nil case 3: for { var innerWire uint64 var start int = iNdEx for shift := uint(0); ; shift += 7 { if shift >= 64 { return 0, ErrIntOverflowDmmaster } if iNdEx >= l { return 0, io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ innerWire |= (uint64(b) & 0x7F) << shift if b < 0x80 { break } } innerWireType := int(innerWire & 0x7) if innerWireType == 4 { break } next, err := skipDmmaster(dAtA[start:]) if err != nil { return 0, err } iNdEx = start + next } return iNdEx, nil case 4: return iNdEx, nil case 5: iNdEx += 4 return iNdEx, nil default: return 0, fmt.Errorf("proto: illegal wireType %d", wireType) } } panic("unreachable") } var ( ErrInvalidLengthDmmaster = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowDmmaster = fmt.Errorf("proto: integer overflow") ) func init() { proto.RegisterFile("dmmaster.proto", fileDescriptorDmmaster) } var fileDescriptorDmmaster = []byte{ // 1353 bytes of a gzipped FileDescriptorProto 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xbc, 0x58, 0x4f, 0x4f, 0xe3, 0x46, 0x14, 0x8f, 0x13, 0xc8, 0x6e, 0x5e, 0x76, 0x11, 0xcc, 0x42, 0xe2, 0x18, 0x36, 0x4b, 0xdd, 0x6a, 0x85, 0x7a, 0x58, 0x4a, 0xe8, 0x09, 0x69, 0xa5, 0x2e, 0x84, 0x55, 0x91, 0x42, 0x01, 0xa7, 0xa8, 0xda, 0x4b, 0x25, 0x27, 0x19, 0x82, 0x95, 0xc4, 0x36, 0x1e, 0x07, 0x96, 0x56, 0x55, 0xa5, 0x1e, 0x7a, 0x68, 0x2f, 0xad, 0x7a, 0xd8, 0x73, 0xbf, 0xcd, 0x1e, 0x2b, 0xf5, 0x0b, 0x54, 0xb4, 0x1f, 0xa4, 0x9a, 0x3f, 0xb1, 0xc7, 0xff, 0xc2, 0xc2, 0x21, 0x37, 0xcf, 0x3c, 0xcf, 0xef, 0xfd, 0xde, 0x9b, 0x37, 0x6f, 0x7e, 0x36, 0x2c, 0xf4, 0x46, 0x23, 0x93, 0xf8, 0xd8, 0x7b, 0xe1, 0x7a, 0x8e, 0xef, 0xa0, 0xbc, 0xdb, 0xd1, 0x16, 0x7a, 0xa3, 0x2b, 0xc7, 0x1b, 0x4c, 0xe6, 0xb4, 0xb5, 0xbe, 0xe3, 0xf4, 0x87, 0x78, 0xd3, 0x74, 0xad, 0x4d, 0xd3, 0xb6, 0x1d, 0xdf, 0xf4, 0x2d, 0xc7, 0x26, 0xdc, 0xaa, 0x5f, 0x40, 0xed, 0xd0, 0xea, 0x7b, 0xa6, 0x8f, 0xbf, 0x61, 0x8b, 0x0c, 0x3c, 0x34, 0xaf, 0x0d, 0x7c, 0x31, 0xc6, 0xc4, 0x47, 0x75, 0x80, 0x5d, 0xcb, 0x1e, 0x3a, 0xfd, 0xaf, 0xcc, 0x11, 0x56, 0x95, 0x75, 0x65, 0xa3, 0x64, 0x48, 0x33, 0x68, 0x0d, 0x4a, 0x7c, 0x74, 0xec, 0x10, 0x35, 0xbf, 0xae, 0x6c, 0x3c, 0x36, 0xc2, 0x09, 0x54, 0x81, 0x22, 0x27, 0xa2, 0x16, 0xd8, 0x4a, 0x31, 0xd2, 0x8f, 0xa1, 0x7e, 0xea, 0xf6, 0xa2, 0x1e, 0xf7, 0x1c, 0xfb, 0xcc, 0xea, 0x4f, 0xfc, 0x56, 0xa0, 0xd8, 0x65, 0x13, 0xc2, 0xa7, 0x18, 0x49, 0x88, 0xf9, 0x08, 0xe2, 0x17, 0xb0, 0xd8, 0xf6, 0x4d, 0xcf, 0xff, 0xda, 0x24, 0x83, 0x09, 0x06, 0x82, 0x39, 0xdf, 0x24, 0x03, 0x81, 0xc0, 0x9e, 0x91, 0x0a, 0x0f, 0xf8, 0x0a, 0xca, 0xb6, 0xb0, 0x51, 0x32, 0x26, 0x43, 0xfd, 0x02, 0x96, 0x24, 0x04, 0xe2, 0x3a, 0x36, 0xc1, 0xd4, 0x9d, 0x87, 0xc9, 0x78, 0xe8, 0x33, 0x90, 0x87, 0x86, 0x18, 0xa1, 0x45, 0x28, 0x8c, 0x48, 0x5f, 0x70, 0xa0, 0x8f, 0xa8, 0x11, 0x02, 0x17, 0xd6, 0x0b, 0x1b, 0xe5, 0x86, 0xfa, 0xc2, 0xed, 0xbc, 0xd8, 0x73, 0x46, 0x23, 0xc7, 0x9e, 0x44, 0xc9, 0x41, 0x43, 0x97, 0xdb, 0x50, 0xe3, 0x69, 0x38, 0x64, 0x3b, 0xf8, 0x41, 0x19, 0xd0, 0xaf, 0x41, 0x4b, 0x5b, 0x74, 0x67, 0xc2, 0x5b, 0x71, 0xc2, 0x55, 0x4a, 0xf8, 0x64, 0x8c, 0xbd, 0xeb, 0xb6, 0x6f, 0xfa, 0x63, 0x92, 0xe4, 0xfb, 0x2d, 0xa0, 0x23, 0x17, 0xd3, 0x4a, 0x91, 0xd3, 0xac, 0x41, 0xde, 0x71, 0x99, 0xbb, 0x85, 0x06, 0x50, 0x0c, 0x6a, 0x3c, 0x72, 0x8d, 0xbc, 0xe3, 0xd2, 0x2d, 0xb0, 0x69, 0xe1, 0x70, 0xbf, 0xec, 0x59, 0xde, 0x82, 0x42, 0x74, 0x0b, 0x7e, 0x57, 0xe0, 0x49, 0xc4, 0x81, 0x08, 0x6a, 0x9a, 0x87, 0x30, 0xe0, 0x7c, 0x5a, 0xc0, 0x85, 0x30, 0xe0, 0xcf, 0x43, 0xbf, 0x73, 0x2c, 0x60, 0x8d, 0x42, 0x09, 0x7f, 0xed, 0x71, 0x47, 0x76, 0x19, 0x72, 0x7a, 0x05, 0x4b, 0x3c, 0xdd, 0xf7, 0xaf, 0x2c, 0x0f, 0x90, 0x0c, 0x31, 0x93, 0xd2, 0x7a, 0x0d, 0x15, 0x69, 0x2b, 0x5b, 0x16, 0xf1, 0x25, 0xee, 0x76, 0x78, 0x96, 0x13, 0x5b, 0x12, 0xe3, 0x7e, 0x09, 0xd5, 0x04, 0xce, 0x2c, 0x4a, 0x6d, 0x1f, 0x56, 0x98, 0x7d, 0xdf, 0xf3, 0x1c, 0xef, 0xfe, 0xf4, 0x7d, 0x91, 0x06, 0x09, 0xe6, 0xce, 0xec, 0x3f, 0x8b, 0xb3, 0xaf, 0x04, 0xec, 0x19, 0x6c, 0x92, 0xfc, 0x1e, 0x3c, 0x69, 0x9f, 0x3b, 0x57, 0xcd, 0x66, 0xab, 0xe5, 0x74, 0x07, 0xe4, 0x7e, 0x55, 0xf3, 0xab, 0x02, 0x0f, 0x04, 0x02, 0x5a, 0x80, 0xfc, 0x41, 0x53, 0xac, 0xcb, 0x1f, 0x34, 0x03, 0xa4, 0xbc, 0x84, 0xb4, 0x0c, 0xf3, 0xce, 0x95, 0x1d, 0xb4, 0x5a, 0x3e, 0xa0, 0x6f, 0x36, 0x9b, 0x2d, 0x5e, 0xf1, 0x25, 0x83, 0x3d, 0xd3, 0xd0, 0xc9, 0xb5, 0xdd, 0xc5, 0x3d, 0x75, 0x9e, 0xcd, 0x8a, 0x11, 0xd2, 0xe0, 0xe1, 0xd8, 0x16, 0x96, 0x22, 0xb3, 0x04, 0x63, 0xbd, 0x0b, 0xcb, 0xd1, 0x90, 0xee, 0x9c, 0xc6, 0x8f, 0x60, 0x7e, 0x48, 0x97, 0x8a, 0x24, 0x96, 0x69, 0x12, 0x05, 0x9c, 0xc1, 0x2d, 0xfa, 0xcf, 0x0a, 0x2c, 0x9f, 0xda, 0xf4, 0x79, 0x62, 0x10, 0x99, 0x8b, 0xc7, 0xaf, 0xc3, 0x23, 0x0f, 0xbb, 0x43, 0xb3, 0x8b, 0x8f, 0x58, 0xc8, 0xdc, 0x4d, 0x64, 0x2e, 0xbb, 0xcd, 0xa0, 0x75, 0x28, 0x9f, 0x39, 0x5e, 0x17, 0x1b, 0x78, 0xe4, 0x5c, 0x62, 0x75, 0x8e, 0x11, 0x97, 0xa7, 0xf4, 0x31, 0xac, 0xc4, 0x78, 0xcc, 0xe4, 0xd0, 0xfe, 0xa9, 0x40, 0x6d, 0xd7, 0xc3, 0xe6, 0x80, 0xbf, 0x10, 0x4b, 0x82, 0x14, 0x90, 0x12, 0x0d, 0x28, 0xad, 0x1c, 0x58, 0x8a, 0x68, 0x30, 0x14, 0xe2, 0xa0, 0x29, 0xaa, 0x22, 0x32, 0x47, 0x11, 0xf1, 0x5b, 0xdc, 0x6d, 0x36, 0x5b, 0x22, 0x09, 0x93, 0x21, 0xb5, 0x90, 0x81, 0xe5, 0x52, 0xcb, 0x3c, 0xb7, 0x88, 0xa1, 0xfe, 0x1d, 0x68, 0x69, 0x14, 0x67, 0x92, 0x9f, 0x1d, 0xa8, 0xb7, 0xaf, 0x2c, 0xbf, 0x7b, 0x2e, 0xc9, 0x06, 0x7e, 0x0b, 0xde, 0x9a, 0x23, 0xfd, 0x47, 0x78, 0x96, 0xb9, 0x76, 0x26, 0xe4, 0x0d, 0xa8, 0x89, 0xbb, 0x26, 0x45, 0x66, 0xad, 0x4a, 0x37, 0x1c, 0x3b, 0x19, 0xcc, 0x2a, 0xae, 0xb8, 0xec, 0x1e, 0xf1, 0x4e, 0x01, 0x2d, 0x0d, 0x54, 0x04, 0x34, 0x15, 0xf5, 0xc3, 0x2f, 0xce, 0x46, 0xfc, 0xe2, 0x54, 0xa5, 0x8b, 0x33, 0xe2, 0x31, 0x64, 0xb6, 0x0a, 0x35, 0x03, 0x9f, 0x79, 0x98, 0x88, 0x7c, 0xd3, 0xab, 0x6f, 0xd2, 0x08, 0xf5, 0x57, 0xb0, 0x92, 0x34, 0x1e, 0x12, 0x59, 0xdd, 0x29, 0xb2, 0xba, 0x4b, 0xee, 0x80, 0x6e, 0x81, 0x96, 0x86, 0x7f, 0xcb, 0x4e, 0x6e, 0x47, 0x33, 0x59, 0x6e, 0xd4, 0x78, 0x56, 0x52, 0xb8, 0x84, 0xa1, 0xbc, 0x57, 0x60, 0xe9, 0x4b, 0xd3, 0xee, 0x0d, 0x71, 0xfb, 0xa4, 0x45, 0xa6, 0xdd, 0x43, 0x35, 0x96, 0xef, 0x3c, 0xcb, 0x77, 0x89, 0x22, 0xb7, 0x4f, 0x5a, 0xa1, 0x10, 0x32, 0xbd, 0xfe, 0xa4, 0x15, 0xb1, 0x67, 0xaa, 0x9d, 0x3b, 0x81, 0x76, 0x9e, 0x63, 0x38, 0xe1, 0x84, 0x94, 0x8b, 0xf9, 0x48, 0x2e, 0xea, 0x00, 0xe4, 0x62, 0x78, 0x6c, 0xfa, 0x3e, 0xf6, 0x6c, 0xb5, 0xc8, 0x15, 0x79, 0x38, 0x43, 0xbb, 0x38, 0x39, 0x37, 0xbd, 0x9e, 0x65, 0xf7, 0xd5, 0x07, 0x2c, 0xfa, 0x60, 0x4c, 0x95, 0x88, 0x1c, 0xc9, 0x4c, 0xea, 0xfe, 0x9d, 0x02, 0xd5, 0xe3, 0xb1, 0xd7, 0x4f, 0x2b, 0xfb, 0xec, 0x96, 0xa6, 0xc1, 0x43, 0xcb, 0x36, 0xbb, 0xbe, 0x75, 0x89, 0x45, 0x7d, 0x06, 0x63, 0xd6, 0xee, 0xac, 0x11, 0x66, 0x25, 0x5a, 0x30, 0xd8, 0x33, 0x7d, 0xff, 0xcc, 0x1a, 0x62, 0xb6, 0x25, 0x3c, 0x95, 0xc1, 0x98, 0xdd, 0x77, 0xe3, 0x4e, 0xd3, 0x0a, 0x32, 0xc9, 0x47, 0xfa, 0x5b, 0x50, 0x93, 0xc4, 0x66, 0x92, 0x93, 0xe7, 0xb0, 0xb8, 0x77, 0x8e, 0xbb, 0x83, 0x5b, 0x34, 0xa5, 0xfe, 0x12, 0x96, 0xa4, 0xf7, 0xee, 0x4a, 0xad, 0xf1, 0x4b, 0x19, 0x8a, 0xbc, 0xc7, 0xa1, 0x37, 0x50, 0x0a, 0xbe, 0x6e, 0xd0, 0x32, 0xab, 0xcd, 0xd8, 0xe7, 0x92, 0xb6, 0x12, 0x9b, 0xe5, 0xee, 0xf4, 0x67, 0x3f, 0xfd, 0xfd, 0xdf, 0x1f, 0xf9, 0x9a, 0xbe, 0x4c, 0x3f, 0x1f, 0xc9, 0xe6, 0xe5, 0x96, 0x39, 0x74, 0xcf, 0xcd, 0xad, 0x4d, 0x4a, 0x90, 0xec, 0x28, 0x9f, 0xa2, 0x33, 0x28, 0x4b, 0xa2, 0x1d, 0x55, 0xa4, 0xe6, 0x20, 0xc3, 0x57, 0x13, 0xf3, 0xc2, 0xc1, 0x73, 0xe6, 0x60, 0x5d, 0x5b, 0x4d, 0x73, 0xb0, 0xf9, 0x3d, 0xdd, 0xc2, 0x1f, 0xa8, 0x9f, 0x97, 0x00, 0xa1, 0x8c, 0x46, 0x8c, 0x6d, 0x42, 0x99, 0x6b, 0x95, 0xf8, 0xb4, 0x70, 0x92, 0x43, 0x43, 0x28, 0x4b, 0x8a, 0x13, 0x69, 0x31, 0x09, 0x2a, 0x69, 0x4c, 0x6d, 0x35, 0xd5, 0x26, 0x90, 0x3e, 0x61, 0x74, 0xeb, 0x68, 0x2d, 0x46, 0x97, 0xb0, 0x57, 0x05, 0x5f, 0xb4, 0x0f, 0x10, 0x2a, 0x44, 0x54, 0x8b, 0x2a, 0x46, 0xd9, 0x97, 0x96, 0x66, 0x0a, 0x48, 0xef, 0xc1, 0x23, 0x59, 0x76, 0x21, 0x96, 0xc4, 0x14, 0x6d, 0xa9, 0xa9, 0x49, 0x43, 0x00, 0xf2, 0x1a, 0x1e, 0x47, 0xd4, 0x0c, 0x62, 0x2f, 0xa7, 0x09, 0x2d, 0xad, 0x96, 0x62, 0x09, 0x70, 0x4e, 0x27, 0xdf, 0x31, 0xf2, 0x97, 0x27, 0x7a, 0x1a, 0x66, 0x3c, 0xe5, 0x33, 0x56, 0xab, 0x67, 0x99, 0x03, 0xd8, 0x37, 0x50, 0xcd, 0xf8, 0x19, 0x80, 0xf4, 0x70, 0x71, 0xd6, 0x9f, 0x02, 0x2d, 0xf3, 0xb8, 0x71, 0xc6, 0x49, 0xb1, 0xc2, 0x19, 0x67, 0xea, 0x2c, 0xce, 0x38, 0x5b, 0xe3, 0xe8, 0x39, 0x5a, 0x89, 0x61, 0x1b, 0xe5, 0x95, 0x98, 0xb8, 0x20, 0x78, 0x25, 0x26, 0xbb, 0xad, 0x9e, 0x43, 0x3d, 0xa8, 0x66, 0x48, 0x11, 0x1e, 0xf0, 0x74, 0x8d, 0xa3, 0x7d, 0x3c, 0xf5, 0x1d, 0x29, 0xad, 0x95, 0xa4, 0x34, 0x60, 0x47, 0xe7, 0xa9, 0x74, 0x12, 0x93, 0x4d, 0x99, 0xc7, 0x9f, 0xad, 0x2a, 0xf4, 0x1c, 0x3a, 0x82, 0xc5, 0x78, 0xe3, 0x44, 0xec, 0xcc, 0x64, 0xf4, 0x79, 0x6d, 0x2d, 0xdd, 0x28, 0xef, 0x53, 0xf2, 0x12, 0xe6, 0x3c, 0x33, 0x55, 0x04, 0xe7, 0x99, 0x2d, 0x02, 0x18, 0x4f, 0x94, 0xfc, 0xb3, 0xc5, 0x61, 0x33, 0xff, 0x78, 0x4d, 0xad, 0xa7, 0x1d, 0x28, 0x05, 0xfd, 0x98, 0x77, 0xd1, 0x78, 0x1b, 0xe7, 0x5d, 0x34, 0xd1, 0xb4, 0xf5, 0xdc, 0xee, 0xe2, 0xfb, 0x9b, 0xba, 0xf2, 0xd7, 0x4d, 0x5d, 0xf9, 0xe7, 0xa6, 0xae, 0xfc, 0xf6, 0x6f, 0x3d, 0xd7, 0x29, 0xb2, 0xff, 0x6f, 0xdb, 0xff, 0x07, 0x00, 0x00, 0xff, 0xff, 0x41, 0xaf, 0xf0, 0x55, 0xc3, 0x13, 0x00, 0x00, }