enginepb

type BrokerServiceClient interface {
	RemoveResource(ctx context.Context, in *RemoveLocalResourceRequest, opts ...grpc.CallOption) (*RemoveLocalResourceResponse, error)
}

type BrokerServiceServer interface {
	RemoveResource(context.Context, *RemoveLocalResourceRequest) (*RemoveLocalResourceResponse, error)
}

type CancelJobRequest struct {
	Id        string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	TenantId  string `protobuf:"bytes,2,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	ProjectId string `protobuf:"bytes,3,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// contains filtered or unexported fields
}

type CheckDirRequest struct {
	Dir string `protobuf:"bytes,1,opt,name=dir,proto3" json:"dir,omitempty"`
	// contains filtered or unexported fields
}

type CheckDirResponse struct {
	ErrMsg     string `protobuf:"bytes,1,opt,name=err_msg,json=errMsg,proto3" json:"err_msg,omitempty"`
	ErrFileIdx int32  `protobuf:"varint,2,opt,name=err_file_idx,json=errFileIdx,proto3" json:"err_file_idx,omitempty"`
	// contains filtered or unexported fields
}

type ConfirmDispatchTaskRequest struct {
	WorkerId  string `protobuf:"bytes,1,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	RequestId string `protobuf:"bytes,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// contains filtered or unexported fields
}

type ConfirmDispatchTaskResponse struct {
	// contains filtered or unexported fields
}

type CreateJobRequest struct {
	Job       *Job   `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	TenantId  string `protobuf:"bytes,2,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	ProjectId string `protobuf:"bytes,3,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// contains filtered or unexported fields
}

type CreateResourceRequest struct {
	ProjectInfo     *ProjectInfo `protobuf:"bytes,1,opt,name=project_info,json=projectInfo,proto3" json:"project_info,omitempty"`
	ResourceId      string       `protobuf:"bytes,2,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"`
	CreatorExecutor string       `protobuf:"bytes,3,opt,name=creator_executor,json=creatorExecutor,proto3" json:"creator_executor,omitempty"`
	JobId           string       `protobuf:"bytes,4,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	CreatorWorkerId string       `protobuf:"bytes,5,opt,name=creator_worker_id,json=creatorWorkerId,proto3" json:"creator_worker_id,omitempty"`
	// contains filtered or unexported fields
}

type CreateResourceResponse struct {
	// contains filtered or unexported fields
}

type DataRWServiceClient interface {
	ReadLines(ctx context.Context, in *ReadLinesRequest, opts ...grpc.CallOption) (DataRWService_ReadLinesClient, error)
	WriteLines(ctx context.Context, opts ...grpc.CallOption) (DataRWService_WriteLinesClient, error)
	GenerateData(ctx context.Context, in *GenerateDataRequest, opts ...grpc.CallOption) (*GenerateDataResponse, error)
	ListFiles(ctx context.Context, in *ListFilesReq, opts ...grpc.CallOption) (*ListFilesResponse, error)
	IsReady(ctx context.Context, in *IsReadyRequest, opts ...grpc.CallOption) (*IsReadyResponse, error)
	CheckDir(ctx context.Context, in *CheckDirRequest, opts ...grpc.CallOption) (*CheckDirResponse, error)
}

type DataRWServiceServer interface {
	ReadLines(*ReadLinesRequest, DataRWService_ReadLinesServer) error
	WriteLines(DataRWService_WriteLinesServer) error
	GenerateData(context.Context, *GenerateDataRequest) (*GenerateDataResponse, error)
	ListFiles(context.Context, *ListFilesReq) (*ListFilesResponse, error)
	IsReady(context.Context, *IsReadyRequest) (*IsReadyResponse, error)
	CheckDir(context.Context, *CheckDirRequest) (*CheckDirResponse, error)
}

type DataRWService_ReadLinesClient interface {
	Recv() (*ReadLinesResponse, error)
	grpc.ClientStream
}

type DataRWService_ReadLinesServer interface {
	Send(*ReadLinesResponse) error
	grpc.ServerStream
}

type DataRWService_WriteLinesClient interface {
	Send(*WriteLinesRequest) error
	CloseAndRecv() (*WriteLinesResponse, error)
	grpc.ClientStream
}

type DataRWService_WriteLinesServer interface {
	SendAndClose(*WriteLinesResponse) error
	Recv() (*WriteLinesRequest, error)
	grpc.ServerStream
}

type DeleteJobRequest struct {
	Id        string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	TenantId  string `protobuf:"bytes,2,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	ProjectId string `protobuf:"bytes,3,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// contains filtered or unexported fields
}

type DiscoveryClient interface {
	RegisterExecutor(ctx context.Context, in *RegisterExecutorRequest, opts ...grpc.CallOption) (*Executor, error)
	// ListExecutors lists all executors.
	// Executors will use this API to discover other executors.
	// Currently, we assume that there aren't too many executors.
	// If the number of executors becomes very large in the future,
	// we can consider a mechanism to watch the changes of the executors.
	ListExecutors(ctx context.Context, in *ListExecutorsRequest, opts ...grpc.CallOption) (*ListExecutorsResponse, error)
	ListMasters(ctx context.Context, in *ListMastersRequest, opts ...grpc.CallOption) (*ListMastersResponse, error)
	Heartbeat(ctx context.Context, in *HeartbeatRequest, opts ...grpc.CallOption) (*HeartbeatResponse, error)
	// QueryMetaStore queries metastore manager and returns the information of a matching metastore.
	QueryMetaStore(ctx context.Context, in *QueryMetaStoreRequest, opts ...grpc.CallOption) (*QueryMetaStoreResponse, error)
	// QueryStorageConfig queries and returns external storage config.
	QueryStorageConfig(ctx context.Context, in *QueryStorageConfigRequest, opts ...grpc.CallOption) (*QueryStorageConfigResponse, error)
	GetLeader(ctx context.Context, in *GetLeaderRequest, opts ...grpc.CallOption) (*GetLeaderResponse, error)
	ResignLeader(ctx context.Context, in *ResignLeaderRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

type DiscoveryServer interface {
	RegisterExecutor(context.Context, *RegisterExecutorRequest) (*Executor, error)
	// ListExecutors lists all executors.
	// Executors will use this API to discover other executors.
	// Currently, we assume that there aren't too many executors.
	// If the number of executors becomes very large in the future,
	// we can consider a mechanism to watch the changes of the executors.
	ListExecutors(context.Context, *ListExecutorsRequest) (*ListExecutorsResponse, error)
	ListMasters(context.Context, *ListMastersRequest) (*ListMastersResponse, error)
	Heartbeat(context.Context, *HeartbeatRequest) (*HeartbeatResponse, error)
	// QueryMetaStore queries metastore manager and returns the information of a matching metastore.
	QueryMetaStore(context.Context, *QueryMetaStoreRequest) (*QueryMetaStoreResponse, error)
	// QueryStorageConfig queries and returns external storage config.
	QueryStorageConfig(context.Context, *QueryStorageConfigRequest) (*QueryStorageConfigResponse, error)
	GetLeader(context.Context, *GetLeaderRequest) (*GetLeaderResponse, error)
	ResignLeader(context.Context, *ResignLeaderRequest) (*emptypb.Empty, error)
}

type Executor struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// name is the readable name of the executor.
	Name    string            `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Address string            `protobuf:"bytes,3,opt,name=address,proto3" json:"address,omitempty"`
	Labels  map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

type ExecutorServiceClient interface {
	PreDispatchTask(ctx context.Context, in *PreDispatchTaskRequest, opts ...grpc.CallOption) (*PreDispatchTaskResponse, error)
	ConfirmDispatchTask(ctx context.Context, in *ConfirmDispatchTaskRequest, opts ...grpc.CallOption) (*ConfirmDispatchTaskResponse, error)
}

type ExecutorServiceServer interface {
	PreDispatchTask(context.Context, *PreDispatchTaskRequest) (*PreDispatchTaskResponse, error)
	ConfirmDispatchTask(context.Context, *ConfirmDispatchTaskRequest) (*ConfirmDispatchTaskResponse, error)
}

type GenerateDataRequest struct {
	FileNum   int32 `protobuf:"varint,1,opt,name=file_num,json=fileNum,proto3" json:"file_num,omitempty"`
	RecordNum int32 `protobuf:"varint,2,opt,name=record_num,json=recordNum,proto3" json:"record_num,omitempty"`
	// contains filtered or unexported fields
}

type GenerateDataResponse struct {
	ErrMsg string `protobuf:"bytes,1,opt,name=err_msg,json=errMsg,proto3" json:"err_msg,omitempty"`
	// contains filtered or unexported fields
}

type GetJobRequest struct {
	Id        string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	TenantId  string `protobuf:"bytes,2,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	ProjectId string `protobuf:"bytes,3,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// Whether to return the config of the job.
	// Config may contain sensitive information, it is not returned by default.
	IncludeConfig bool `protobuf:"varint,4,opt,name=include_config,json=includeConfig,proto3" json:"include_config,omitempty"`
	// contains filtered or unexported fields
}

type GetLeaderRequest struct {
	// contains filtered or unexported fields
}

type GetLeaderResponse struct {
	AdvertiseAddr string `protobuf:"bytes,1,opt,name=advertise_addr,json=advertiseAddr,proto3" json:"advertise_addr,omitempty"`
	// contains filtered or unexported fields
}

type HeartbeatRequest struct {
	ExecutorId string `protobuf:"bytes,1,opt,name=executor_id,json=executorId,proto3" json:"executor_id,omitempty"`
	Timestamp  uint64 `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Ttl        uint64 `protobuf:"varint,3,opt,name=ttl,proto3" json:"ttl,omitempty"`
	// contains filtered or unexported fields
}

type HeartbeatResponse struct {
	// contains filtered or unexported fields
}

type IsReadyRequest struct {
	// contains filtered or unexported fields
}

type IsReadyResponse struct {
	Ready bool `protobuf:"varint,1,opt,name=ready,proto3" json:"ready,omitempty"`
	// contains filtered or unexported fields
}

type Job struct {
	Id    string    `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Type  Job_Type  `protobuf:"varint,2,opt,name=type,proto3,enum=enginepb.Job_Type" json:"type,omitempty"`
	State Job_State `protobuf:"varint,3,opt,name=state,proto3,enum=enginepb.Job_State" json:"state,omitempty"`
	// Output will ignore this field by default unless include_config is set to true.
	Config    []byte      `protobuf:"bytes,4,opt,name=config,proto3" json:"config,omitempty"`
	Detail    []byte      `protobuf:"bytes,5,opt,name=detail,proto3" json:"detail,omitempty"`
	Error     *Job_Error  `protobuf:"bytes,6,opt,name=error,proto3" json:"error,omitempty"`
	Selectors []*Selector `protobuf:"bytes,7,rep,name=selectors,proto3" json:"selectors,omitempty"`
	// contains filtered or unexported fields
}

type JobManagerClient interface {
	CreateJob(ctx context.Context, in *CreateJobRequest, opts ...grpc.CallOption) (*Job, error)
	GetJob(ctx context.Context, in *GetJobRequest, opts ...grpc.CallOption) (*Job, error)
	ListJobs(ctx context.Context, in *ListJobsRequest, opts ...grpc.CallOption) (*ListJobsResponse, error)
	// NOTE: for the compatibility of existing openapi(ticdc) format,
	// we use `/cancel` but not `:cancel`(google api suggested)
	// refer to: https://cloud.google.com/apis/design/custom_methods
	CancelJob(ctx context.Context, in *CancelJobRequest, opts ...grpc.CallOption) (*Job, error)
	DeleteJob(ctx context.Context, in *DeleteJobRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

type JobManagerServer interface {
	CreateJob(context.Context, *CreateJobRequest) (*Job, error)
	GetJob(context.Context, *GetJobRequest) (*Job, error)
	ListJobs(context.Context, *ListJobsRequest) (*ListJobsResponse, error)
	// NOTE: for the compatibility of existing openapi(ticdc) format,
	// we use `/cancel` but not `:cancel`(google api suggested)
	// refer to: https://cloud.google.com/apis/design/custom_methods
	CancelJob(context.Context, *CancelJobRequest) (*Job, error)
	DeleteJob(context.Context, *DeleteJobRequest) (*emptypb.Empty, error)
}

type Job_Error struct {
	Code    string `protobuf:"bytes,1,opt,name=code,proto3" json:"code,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

type Job_State int32

type Job_Type int32

type ListExecutorsRequest struct {
	// contains filtered or unexported fields
}

type ListExecutorsResponse struct {
	Executors []*Executor `protobuf:"bytes,1,rep,name=executors,proto3" json:"executors,omitempty"`
	// contains filtered or unexported fields
}

type ListFilesReq struct {
	// contains filtered or unexported fields
}

type ListFilesResponse struct {
	FileNum int32 `protobuf:"varint,1,opt,name=fileNum,proto3" json:"fileNum,omitempty"`
	// contains filtered or unexported fields
}

type ListJobsRequest struct {

	// The maximum number of jobs to return.
	// If it is unspecified or less than 1, at most 100 jobs will be returned.
	// The maximum value is 1000. Larger values will be coerced to 1000.
	PageSize int32 `protobuf:"varint,1,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// The page token, returned by a previous call, to request the next page of results.
	PageToken string `protobuf:"bytes,2,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	TenantId  string `protobuf:"bytes,3,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	ProjectId string `protobuf:"bytes,4,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// Whether to return the config of the job.
	// Config may contain sensitive information, it is not returned by default.
	IncludeConfig bool      `protobuf:"varint,5,opt,name=include_config,json=includeConfig,proto3" json:"include_config,omitempty"`
	Type          Job_Type  `protobuf:"varint,6,opt,name=type,proto3,enum=enginepb.Job_Type" json:"type,omitempty"`
	State         Job_State `protobuf:"varint,7,opt,name=state,proto3,enum=enginepb.Job_State" json:"state,omitempty"`
	// contains filtered or unexported fields
}

type ListJobsResponse struct {
	Jobs []*Job `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"`
	// A token to retrieve next page of results.
	// If this field is empty, it means no more pages.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

type ListMastersRequest struct {
	// contains filtered or unexported fields
}

type ListMastersResponse struct {
	Masters []*Master `protobuf:"bytes,1,rep,name=masters,proto3" json:"masters,omitempty"`
	// contains filtered or unexported fields
}

type Master struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// name is the readable name of the master.
	Name     string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Address  string `protobuf:"bytes,3,opt,name=address,proto3" json:"address,omitempty"`
	IsLeader bool   `protobuf:"varint,4,opt,name=is_leader,json=isLeader,proto3" json:"is_leader,omitempty"`
	// contains filtered or unexported fields
}

type PreDispatchTaskRequest struct {
	TaskTypeId  int64        `protobuf:"varint,1,opt,name=task_type_id,json=taskTypeId,proto3" json:"task_type_id,omitempty"`
	TaskConfig  []byte       `protobuf:"bytes,2,opt,name=task_config,json=taskConfig,proto3" json:"task_config,omitempty"`
	MasterId    string       `protobuf:"bytes,3,opt,name=master_id,json=masterId,proto3" json:"master_id,omitempty"`
	WorkerId    string       `protobuf:"bytes,4,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	ProjectInfo *ProjectInfo `protobuf:"bytes,5,opt,name=project_info,json=projectInfo,proto3" json:"project_info,omitempty"`
	// request_id should be a UUID unique for each RPC call.
	RequestId   string `protobuf:"bytes,6,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	WorkerEpoch int64  `protobuf:"varint,7,opt,name=worker_epoch,json=workerEpoch,proto3" json:"worker_epoch,omitempty"`
	// contains filtered or unexported fields
}

type PreDispatchTaskResponse struct {
	// contains filtered or unexported fields
}

type ProjectInfo struct {
	TenantId  string `protobuf:"bytes,1,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	ProjectId string `protobuf:"bytes,2,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// contains filtered or unexported fields
}

type QueryMetaStoreRequest struct {
	Tp StoreType `protobuf:"varint,1,opt,name=tp,proto3,enum=enginepb.StoreType" json:"tp,omitempty"`
	// contains filtered or unexported fields
}

type QueryMetaStoreResponse struct {
	Config []byte `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

type QueryResourceRequest struct {
	ResourceKey *ResourceKey `protobuf:"bytes,1,opt,name=resource_key,json=resourceKey,proto3" json:"resource_key,omitempty"`
	// contains filtered or unexported fields
}

type QueryResourceResponse struct {
	CreatorExecutor string `protobuf:"bytes,1,opt,name=creator_executor,json=creatorExecutor,proto3" json:"creator_executor,omitempty"`
	JobId           string `protobuf:"bytes,2,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	CreatorWorkerId string `protobuf:"bytes,3,opt,name=creator_worker_id,json=creatorWorkerId,proto3" json:"creator_worker_id,omitempty"`
	// contains filtered or unexported fields
}

type QueryStorageConfigRequest struct {
	// contains filtered or unexported fields
}

type QueryStorageConfigResponse struct {
	Config []byte `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

type ReadLinesRequest struct {
	FileIdx int32  `protobuf:"varint,1,opt,name=fileIdx,proto3" json:"fileIdx,omitempty"`
	LineNo  []byte `protobuf:"bytes,2,opt,name=lineNo,proto3" json:"lineNo,omitempty"`
	// contains filtered or unexported fields
}

type ReadLinesResponse struct {
	Key    []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Val    []byte `protobuf:"bytes,2,opt,name=val,proto3" json:"val,omitempty"`
	IsEof  bool   `protobuf:"varint,3,opt,name=isEof,proto3" json:"isEof,omitempty"`
	ErrMsg string `protobuf:"bytes,4,opt,name=errMsg,proto3" json:"errMsg,omitempty"`
	// contains filtered or unexported fields
}

type Record struct {
	Tp        Record_RecordType `protobuf:"varint,1,opt,name=tp,proto3,enum=enginepb.Record_RecordType" json:"tp,omitempty"`
	SchemaVer int32             `protobuf:"varint,2,opt,name=schema_ver,json=schemaVer,proto3" json:"schema_ver,omitempty"`
	Tid       int32             `protobuf:"varint,3,opt,name=tid,proto3" json:"tid,omitempty"`
	Gtid      int32             `protobuf:"varint,4,opt,name=gtid,proto3" json:"gtid,omitempty"`
	Pk        int32             `protobuf:"varint,5,opt,name=pk,proto3" json:"pk,omitempty"`
	// for record time
	TimeTracer []int64 `protobuf:"varint,6,rep,packed,name=time_tracer,json=timeTracer,proto3" json:"time_tracer,omitempty"`
	// contains filtered or unexported fields
}

type Record_RecordType int32

type RegisterExecutorRequest struct {
	Executor *Executor `protobuf:"bytes,1,opt,name=executor,proto3" json:"executor,omitempty"`
	// contains filtered or unexported fields
}

type RemoveLocalResourceRequest struct {
	ResourceId string `protobuf:"bytes,1,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"`
	// creator of the resource
	WorkerId string `protobuf:"bytes,2,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	// contains filtered or unexported fields
}

type RemoveLocalResourceResponse struct {
	// contains filtered or unexported fields
}

type RemoveResourceRequest struct {
	ResourceKey *ResourceKey `protobuf:"bytes,1,opt,name=resource_key,json=resourceKey,proto3" json:"resource_key,omitempty"`
	// contains filtered or unexported fields
}

type RemoveResourceResponse struct {
	// contains filtered or unexported fields
}

type ResignLeaderRequest struct {
	// contains filtered or unexported fields
}

type ResourceKey struct {
	JobId      string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	ResourceId string `protobuf:"bytes,2,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"`
	// contains filtered or unexported fields
}

type ResourceManagerClient interface {
	CreateResource(ctx context.Context, in *CreateResourceRequest, opts ...grpc.CallOption) (*CreateResourceResponse, error)
	QueryResource(ctx context.Context, in *QueryResourceRequest, opts ...grpc.CallOption) (*QueryResourceResponse, error)
	// RemoveResource only cleans up the metadata of the resource.
	// The invoker should handle the actual resource cleaning up on its own.
	RemoveResource(ctx context.Context, in *RemoveResourceRequest, opts ...grpc.CallOption) (*RemoveResourceResponse, error)
}

type ResourceManagerServer interface {
	CreateResource(context.Context, *CreateResourceRequest) (*CreateResourceResponse, error)
	QueryResource(context.Context, *QueryResourceRequest) (*QueryResourceResponse, error)
	// RemoveResource only cleans up the metadata of the resource.
	// The invoker should handle the actual resource cleaning up on its own.
	RemoveResource(context.Context, *RemoveResourceRequest) (*RemoveResourceResponse, error)
}

type ScheduleTaskRequest struct {
	TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// resources required by the task.
	Resources []*ResourceKey `protobuf:"bytes,2,rep,name=resources,proto3" json:"resources,omitempty"`
	Selectors []*Selector    `protobuf:"bytes,3,rep,name=selectors,proto3" json:"selectors,omitempty"`
	// contains filtered or unexported fields
}

type ScheduleTaskResponse struct {
	ExecutorId   string `protobuf:"bytes,1,opt,name=executor_id,json=executorId,proto3" json:"executor_id,omitempty"`
	ExecutorAddr string `protobuf:"bytes,2,opt,name=executor_addr,json=executorAddr,proto3" json:"executor_addr,omitempty"`
	// contains filtered or unexported fields
}

type Selector struct {
	Label  string      `protobuf:"bytes,1,opt,name=label,proto3" json:"label,omitempty"`
	Target string      `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"`
	Op     Selector_Op `protobuf:"varint,3,opt,name=op,proto3,enum=enginepb.Selector_Op" json:"op,omitempty"`
	// contains filtered or unexported fields
}

type Selector_Op int32

type StoreType int32

type TaskSchedulerClient interface {
	ScheduleTask(ctx context.Context, in *ScheduleTaskRequest, opts ...grpc.CallOption) (*ScheduleTaskResponse, error)
}

type TaskSchedulerServer interface {
	ScheduleTask(context.Context, *ScheduleTaskRequest) (*ScheduleTaskResponse, error)
}

type TestBinlogRequest struct {
	Gtid int32 `protobuf:"varint,1,opt,name=gtid,proto3" json:"gtid,omitempty"`
	// contains filtered or unexported fields
}

type TestServiceClient interface {
	FeedBinlog(ctx context.Context, in *TestBinlogRequest, opts ...grpc.CallOption) (TestService_FeedBinlogClient, error)
}

type TestServiceServer interface {
	FeedBinlog(*TestBinlogRequest, TestService_FeedBinlogServer) error
}

type TestService_FeedBinlogClient interface {
	Recv() (*Record, error)
	grpc.ClientStream
}

type TestService_FeedBinlogServer interface {
	Send(*Record) error
	grpc.ServerStream
}

type UnimplementedBrokerServiceServer struct {
}

type UnimplementedDataRWServiceServer struct {
}

type UnimplementedDiscoveryServer struct {
}

type UnimplementedExecutorServiceServer struct {
}