enginepb

package
v0.0.0-...-0e0b615 Latest Latest
Warning

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

 Go to latest Published: Nov 12, 2024 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Overview

Package enginepb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var (
	StoreType_name = map[int32]string{
		0: "SystemMetaStore",
		1: "AppMetaStore",
	}
	StoreType_value = map[string]int32{
		"SystemMetaStore": 0,
		"AppMetaStore":    1,
	}
)

Enum value maps for StoreType.

View Source 
var (
	Selector_Op_name = map[int32]string{
		0: "OpUnknown",
		1: "Eq",
		2: "Neq",
		3: "Regex",
	}
	Selector_Op_value = map[string]int32{
		"OpUnknown": 0,
		"Eq":        1,
		"Neq":       2,
		"Regex":     3,
	}
)

Enum value maps for Selector_Op.

View Source 
var (
	Job_Type_name = map[int32]string{
		0: "TypeUnknown",
		1: "CVSDemo",
		2: "DM",
		3: "CDC",
		4: "FakeJob",
	}
	Job_Type_value = map[string]int32{
		"TypeUnknown": 0,
		"CVSDemo":     1,
		"DM":          2,
		"CDC":         3,
		"FakeJob":     4,
	}
)

Enum value maps for Job_Type.

View Source 
var (
	Job_State_name = map[int32]string{
		0: "StateUnknown",
		1: "Created",
		2: "Running",
		3: "Failed",
		4: "Finished",
		5: "Canceling",
		6: "Canceled",
	}
	Job_State_value = map[string]int32{
		"StateUnknown": 0,
		"Created":      1,
		"Running":      2,
		"Failed":       3,
		"Finished":     4,
		"Canceling":    5,
		"Canceled":     6,
	}
)

Enum value maps for Job_State.

View Source 
var (
	Record_RecordType_name = map[int32]string{
		0: "Data",
		1: "DDL",
	}
	Record_RecordType_value = map[string]int32{
		"Data": 0,
		"DDL":  1,
	}
)

Enum value maps for Record_RecordType.

View Source 
var BrokerService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "enginepb.BrokerService",
	HandlerType: (*BrokerServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "RemoveResource",
			Handler:    _BrokerService_RemoveResource_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "engine/proto/executor.proto",
}

BrokerService_ServiceDesc is the grpc.ServiceDesc for BrokerService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var DataRWService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "enginepb.DataRWService",
	HandlerType: (*DataRWServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GenerateData",
			Handler:    _DataRWService_GenerateData_Handler,
		},
		{
			MethodName: "ListFiles",
			Handler:    _DataRWService_ListFiles_Handler,
		},
		{
			MethodName: "IsReady",
			Handler:    _DataRWService_IsReady_Handler,
		},
		{
			MethodName: "CheckDir",
			Handler:    _DataRWService_CheckDir_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ReadLines",
			Handler:       _DataRWService_ReadLines_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "WriteLines",
			Handler:       _DataRWService_WriteLines_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "engine/proto/datarw.proto",
}

DataRWService_ServiceDesc is the grpc.ServiceDesc for DataRWService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var Discovery_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "enginepb.Discovery",
	HandlerType: (*DiscoveryServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "RegisterExecutor",
			Handler:    _Discovery_RegisterExecutor_Handler,
		},
		{
			MethodName: "ListExecutors",
			Handler:    _Discovery_ListExecutors_Handler,
		},
		{
			MethodName: "ListMasters",
			Handler:    _Discovery_ListMasters_Handler,
		},
		{
			MethodName: "Heartbeat",
			Handler:    _Discovery_Heartbeat_Handler,
		},
		{
			MethodName: "QueryMetaStore",
			Handler:    _Discovery_QueryMetaStore_Handler,
		},
		{
			MethodName: "QueryStorageConfig",
			Handler:    _Discovery_QueryStorageConfig_Handler,
		},
		{
			MethodName: "GetLeader",
			Handler:    _Discovery_GetLeader_Handler,
		},
		{
			MethodName: "ResignLeader",
			Handler:    _Discovery_ResignLeader_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "engine/proto/master.proto",
}

Discovery_ServiceDesc is the grpc.ServiceDesc for Discovery service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var ExecutorService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "enginepb.ExecutorService",
	HandlerType: (*ExecutorServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "PreDispatchTask",
			Handler:    _ExecutorService_PreDispatchTask_Handler,
		},
		{
			MethodName: "ConfirmDispatchTask",
			Handler:    _ExecutorService_ConfirmDispatchTask_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "engine/proto/executor.proto",
}

ExecutorService_ServiceDesc is the grpc.ServiceDesc for ExecutorService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_engine_proto_datarw_proto protoreflect.FileDescriptor
View Source 
var File_engine_proto_executor_proto protoreflect.FileDescriptor
View Source 
var File_engine_proto_master_proto protoreflect.FileDescriptor
View Source 
var File_engine_proto_projects_proto protoreflect.FileDescriptor
View Source 
var File_engine_proto_resources_proto protoreflect.FileDescriptor
View Source 
var File_engine_proto_test_proto protoreflect.FileDescriptor
View Source 
var JobManager_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "enginepb.JobManager",
	HandlerType: (*JobManagerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateJob",
			Handler:    _JobManager_CreateJob_Handler,
		},
		{
			MethodName: "GetJob",
			Handler:    _JobManager_GetJob_Handler,
		},
		{
			MethodName: "ListJobs",
			Handler:    _JobManager_ListJobs_Handler,
		},
		{
			MethodName: "CancelJob",
			Handler:    _JobManager_CancelJob_Handler,
		},
		{
			MethodName: "DeleteJob",
			Handler:    _JobManager_DeleteJob_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "engine/proto/master.proto",
}

JobManager_ServiceDesc is the grpc.ServiceDesc for JobManager service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var ResourceManager_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "enginepb.ResourceManager",
	HandlerType: (*ResourceManagerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateResource",
			Handler:    _ResourceManager_CreateResource_Handler,
		},
		{
			MethodName: "QueryResource",
			Handler:    _ResourceManager_QueryResource_Handler,
		},
		{
			MethodName: "RemoveResource",
			Handler:    _ResourceManager_RemoveResource_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "engine/proto/resources.proto",
}

ResourceManager_ServiceDesc is the grpc.ServiceDesc for ResourceManager service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var TaskScheduler_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "enginepb.TaskScheduler",
	HandlerType: (*TaskSchedulerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ScheduleTask",
			Handler:    _TaskScheduler_ScheduleTask_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "engine/proto/master.proto",
}

TaskScheduler_ServiceDesc is the grpc.ServiceDesc for TaskScheduler service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var TestService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "enginepb.TestService",
	HandlerType: (*TestServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "FeedBinlog",
			Handler:       _TestService_FeedBinlog_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "engine/proto/test.proto",
}

TestService_ServiceDesc is the grpc.ServiceDesc for TestService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterBrokerServiceServer 

func RegisterBrokerServiceServer(s grpc.ServiceRegistrar, srv BrokerServiceServer)

func RegisterDataRWServiceServer 

func RegisterDataRWServiceServer(s grpc.ServiceRegistrar, srv DataRWServiceServer)

func RegisterDiscoveryHandler 

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

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

func RegisterDiscoveryHandlerClient 

func RegisterDiscoveryHandlerClient(ctx context.Context, mux *runtime.ServeMux, client DiscoveryClient) error

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

func RegisterDiscoveryHandlerFromEndpoint 

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

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

func RegisterDiscoveryHandlerServer 

func RegisterDiscoveryHandlerServer(ctx context.Context, mux *runtime.ServeMux, server DiscoveryServer) error

RegisterDiscoveryHandlerServer registers the http handlers for service Discovery to "mux". UnaryRPC :call DiscoveryServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterDiscoveryHandlerFromEndpoint instead.

func RegisterDiscoveryServer 

func RegisterDiscoveryServer(s grpc.ServiceRegistrar, srv DiscoveryServer)

func RegisterExecutorServiceServer 

func RegisterExecutorServiceServer(s grpc.ServiceRegistrar, srv ExecutorServiceServer)

func RegisterJobManagerHandler 

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

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

func RegisterJobManagerHandlerClient 

func RegisterJobManagerHandlerClient(ctx context.Context, mux *runtime.ServeMux, client JobManagerClient) error

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

func RegisterJobManagerHandlerFromEndpoint 

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

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

func RegisterJobManagerHandlerServer 

func RegisterJobManagerHandlerServer(ctx context.Context, mux *runtime.ServeMux, server JobManagerServer) error

RegisterJobManagerHandlerServer registers the http handlers for service JobManager to "mux". UnaryRPC :call JobManagerServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterJobManagerHandlerFromEndpoint instead.

func RegisterJobManagerServer 

func RegisterJobManagerServer(s grpc.ServiceRegistrar, srv JobManagerServer)

func RegisterResourceManagerServer 

func RegisterResourceManagerServer(s grpc.ServiceRegistrar, srv ResourceManagerServer)

func RegisterTaskSchedulerServer 

func RegisterTaskSchedulerServer(s grpc.ServiceRegistrar, srv TaskSchedulerServer)

func RegisterTestServiceServer 

func RegisterTestServiceServer(s grpc.ServiceRegistrar, srv TestServiceServer)

Types

type BrokerServiceClient 

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

BrokerServiceClient is the client API for BrokerService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewBrokerServiceClient 

func NewBrokerServiceClient(cc grpc.ClientConnInterface) BrokerServiceClient

type BrokerServiceServer 

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

BrokerServiceServer is the server API for BrokerService service. All implementations should embed UnimplementedBrokerServiceServer for forward compatibility

type CancelJobRequest 

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
}

func (*CancelJobRequest) Descriptor deprecated 

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

Deprecated: Use CancelJobRequest.ProtoReflect.Descriptor instead.

func (*CancelJobRequest) GetId 

func (x *CancelJobRequest) GetId() string

func (*CancelJobRequest) GetProjectId 

func (x *CancelJobRequest) GetProjectId() string

func (*CancelJobRequest) GetTenantId 

func (x *CancelJobRequest) GetTenantId() string

func (*CancelJobRequest) ProtoMessage 

func (*CancelJobRequest) ProtoMessage()

func (*CancelJobRequest) ProtoReflect 

func (x *CancelJobRequest) ProtoReflect() protoreflect.Message

func (*CancelJobRequest) Reset 

func (x *CancelJobRequest) Reset()

func (*CancelJobRequest) String 

func (x *CancelJobRequest) String() string

type CheckDirRequest 

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

func (*CheckDirRequest) Descriptor deprecated 

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

Deprecated: Use CheckDirRequest.ProtoReflect.Descriptor instead.

func (*CheckDirRequest) GetDir 

func (x *CheckDirRequest) GetDir() string

func (*CheckDirRequest) ProtoMessage 

func (*CheckDirRequest) ProtoMessage()

func (*CheckDirRequest) ProtoReflect 

func (x *CheckDirRequest) ProtoReflect() protoreflect.Message

func (*CheckDirRequest) Reset 

func (x *CheckDirRequest) Reset()

func (*CheckDirRequest) String 

func (x *CheckDirRequest) String() string

type CheckDirResponse 

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
}

func (*CheckDirResponse) Descriptor deprecated 

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

Deprecated: Use CheckDirResponse.ProtoReflect.Descriptor instead.

func (*CheckDirResponse) GetErrFileIdx 

func (x *CheckDirResponse) GetErrFileIdx() int32

func (*CheckDirResponse) GetErrMsg 

func (x *CheckDirResponse) GetErrMsg() string

func (*CheckDirResponse) ProtoMessage 

func (*CheckDirResponse) ProtoMessage()

func (*CheckDirResponse) ProtoReflect 

func (x *CheckDirResponse) ProtoReflect() protoreflect.Message

func (*CheckDirResponse) Reset 

func (x *CheckDirResponse) Reset()

func (*CheckDirResponse) String 

func (x *CheckDirResponse) String() string

type ConfirmDispatchTaskRequest 

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
}

func (*ConfirmDispatchTaskRequest) Descriptor deprecated 

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

Deprecated: Use ConfirmDispatchTaskRequest.ProtoReflect.Descriptor instead.

func (*ConfirmDispatchTaskRequest) GetRequestId 

func (x *ConfirmDispatchTaskRequest) GetRequestId() string

func (*ConfirmDispatchTaskRequest) GetWorkerId 

func (x *ConfirmDispatchTaskRequest) GetWorkerId() string

func (*ConfirmDispatchTaskRequest) ProtoMessage 

func (*ConfirmDispatchTaskRequest) ProtoMessage()

func (*ConfirmDispatchTaskRequest) ProtoReflect 

func (x *ConfirmDispatchTaskRequest) ProtoReflect() protoreflect.Message

func (*ConfirmDispatchTaskRequest) Reset 

func (x *ConfirmDispatchTaskRequest) Reset()

func (*ConfirmDispatchTaskRequest) String 

func (x *ConfirmDispatchTaskRequest) String() string

type ConfirmDispatchTaskResponse 

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

func (*ConfirmDispatchTaskResponse) Descriptor deprecated 

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

Deprecated: Use ConfirmDispatchTaskResponse.ProtoReflect.Descriptor instead.

func (*ConfirmDispatchTaskResponse) ProtoMessage 

func (*ConfirmDispatchTaskResponse) ProtoMessage()

func (*ConfirmDispatchTaskResponse) ProtoReflect 

func (x *ConfirmDispatchTaskResponse) ProtoReflect() protoreflect.Message

func (*ConfirmDispatchTaskResponse) Reset 

func (x *ConfirmDispatchTaskResponse) Reset()

func (*ConfirmDispatchTaskResponse) String 

func (x *ConfirmDispatchTaskResponse) String() string

type CreateJobRequest 

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
}

func (*CreateJobRequest) Descriptor deprecated 

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

Deprecated: Use CreateJobRequest.ProtoReflect.Descriptor instead.

func (*CreateJobRequest) GetJob 

func (x *CreateJobRequest) GetJob() *Job

func (*CreateJobRequest) GetProjectId 

func (x *CreateJobRequest) GetProjectId() string

func (*CreateJobRequest) GetTenantId 

func (x *CreateJobRequest) GetTenantId() string

func (*CreateJobRequest) MarshalLogObject 

func (m *CreateJobRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

MarshalLogObject implements zapcore.ObjectMarshaler.

func (*CreateJobRequest) ProtoMessage 

func (*CreateJobRequest) ProtoMessage()

func (*CreateJobRequest) ProtoReflect 

func (x *CreateJobRequest) ProtoReflect() protoreflect.Message

func (*CreateJobRequest) Reset 

func (x *CreateJobRequest) Reset()

func (*CreateJobRequest) String 

func (x *CreateJobRequest) String() string

type CreateResourceRequest 

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
}

func (*CreateResourceRequest) Descriptor deprecated 

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

Deprecated: Use CreateResourceRequest.ProtoReflect.Descriptor instead.

func (*CreateResourceRequest) GetCreatorExecutor 

func (x *CreateResourceRequest) GetCreatorExecutor() string

func (*CreateResourceRequest) GetCreatorWorkerId 

func (x *CreateResourceRequest) GetCreatorWorkerId() string

func (*CreateResourceRequest) GetJobId 

func (x *CreateResourceRequest) GetJobId() string

func (*CreateResourceRequest) GetProjectInfo 

func (x *CreateResourceRequest) GetProjectInfo() *ProjectInfo

func (*CreateResourceRequest) GetResourceId 

func (x *CreateResourceRequest) GetResourceId() string

func (*CreateResourceRequest) ProtoMessage 

func (*CreateResourceRequest) ProtoMessage()

func (*CreateResourceRequest) ProtoReflect 

func (x *CreateResourceRequest) ProtoReflect() protoreflect.Message

func (*CreateResourceRequest) Reset 

func (x *CreateResourceRequest) Reset()

func (*CreateResourceRequest) String 

func (x *CreateResourceRequest) String() string

type CreateResourceResponse 

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

func (*CreateResourceResponse) Descriptor deprecated 

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

Deprecated: Use CreateResourceResponse.ProtoReflect.Descriptor instead.

func (*CreateResourceResponse) ProtoMessage 

func (*CreateResourceResponse) ProtoMessage()

func (*CreateResourceResponse) ProtoReflect 

func (x *CreateResourceResponse) ProtoReflect() protoreflect.Message

func (*CreateResourceResponse) Reset 

func (x *CreateResourceResponse) Reset()

func (*CreateResourceResponse) String 

func (x *CreateResourceResponse) String() string

type DataRWServiceClient 

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)
}

DataRWServiceClient is the client API for DataRWService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewDataRWServiceClient 

func NewDataRWServiceClient(cc grpc.ClientConnInterface) DataRWServiceClient

type DataRWServiceServer 

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)
}

DataRWServiceServer is the server API for DataRWService service. All implementations should embed UnimplementedDataRWServiceServer for forward compatibility

type DataRWService_ReadLinesClient 

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

type DataRWService_ReadLinesServer 

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

type DataRWService_WriteLinesClient 

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

type DataRWService_WriteLinesServer 

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

type DeleteJobRequest 

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
}

func (*DeleteJobRequest) Descriptor deprecated 

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

Deprecated: Use DeleteJobRequest.ProtoReflect.Descriptor instead.

func (*DeleteJobRequest) GetId 

func (x *DeleteJobRequest) GetId() string

func (*DeleteJobRequest) GetProjectId 

func (x *DeleteJobRequest) GetProjectId() string

func (*DeleteJobRequest) GetTenantId 

func (x *DeleteJobRequest) GetTenantId() string

func (*DeleteJobRequest) ProtoMessage 

func (*DeleteJobRequest) ProtoMessage()

func (*DeleteJobRequest) ProtoReflect 

func (x *DeleteJobRequest) ProtoReflect() protoreflect.Message

func (*DeleteJobRequest) Reset 

func (x *DeleteJobRequest) Reset()

func (*DeleteJobRequest) String 

func (x *DeleteJobRequest) String() string

type DiscoveryClient 

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)
}

DiscoveryClient is the client API for Discovery service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewDiscoveryClient 

func NewDiscoveryClient(cc grpc.ClientConnInterface) DiscoveryClient

type DiscoveryServer 

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)
}

DiscoveryServer is the server API for Discovery service. All implementations should embed UnimplementedDiscoveryServer for forward compatibility

type Executor 

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
}

func (*Executor) Descriptor deprecated 

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

Deprecated: Use Executor.ProtoReflect.Descriptor instead.

func (*Executor) GetAddress 

func (x *Executor) GetAddress() string

func (*Executor) GetId 

func (x *Executor) GetId() string

func (*Executor) GetLabels 

func (x *Executor) GetLabels() map[string]string

func (*Executor) GetName 

func (x *Executor) GetName() string

func (*Executor) ProtoMessage 

func (*Executor) ProtoMessage()

func (*Executor) ProtoReflect 

func (x *Executor) ProtoReflect() protoreflect.Message

func (*Executor) Reset 

func (x *Executor) Reset()

func (*Executor) String 

func (x *Executor) String() string

type ExecutorServiceClient 

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)
}

ExecutorServiceClient is the client API for ExecutorService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewExecutorServiceClient 

func NewExecutorServiceClient(cc grpc.ClientConnInterface) ExecutorServiceClient

type ExecutorServiceServer 

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

ExecutorServiceServer is the server API for ExecutorService service. All implementations should embed UnimplementedExecutorServiceServer for forward compatibility

type GenerateDataRequest 

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
}

func (*GenerateDataRequest) Descriptor deprecated 

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

Deprecated: Use GenerateDataRequest.ProtoReflect.Descriptor instead.

func (*GenerateDataRequest) GetFileNum 

func (x *GenerateDataRequest) GetFileNum() int32

func (*GenerateDataRequest) GetRecordNum 

func (x *GenerateDataRequest) GetRecordNum() int32

func (*GenerateDataRequest) ProtoMessage 

func (*GenerateDataRequest) ProtoMessage()

func (*GenerateDataRequest) ProtoReflect 

func (x *GenerateDataRequest) ProtoReflect() protoreflect.Message

func (*GenerateDataRequest) Reset 

func (x *GenerateDataRequest) Reset()

func (*GenerateDataRequest) String 

func (x *GenerateDataRequest) String() string

type GenerateDataResponse 

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

func (*GenerateDataResponse) Descriptor deprecated 

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

Deprecated: Use GenerateDataResponse.ProtoReflect.Descriptor instead.

func (*GenerateDataResponse) GetErrMsg 

func (x *GenerateDataResponse) GetErrMsg() string

func (*GenerateDataResponse) ProtoMessage 

func (*GenerateDataResponse) ProtoMessage()

func (*GenerateDataResponse) ProtoReflect 

func (x *GenerateDataResponse) ProtoReflect() protoreflect.Message

func (*GenerateDataResponse) Reset 

func (x *GenerateDataResponse) Reset()

func (*GenerateDataResponse) String 

func (x *GenerateDataResponse) String() string

type GetJobRequest 

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
}

func (*GetJobRequest) Descriptor deprecated 

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

Deprecated: Use GetJobRequest.ProtoReflect.Descriptor instead.

func (*GetJobRequest) GetId 

func (x *GetJobRequest) GetId() string

func (*GetJobRequest) GetIncludeConfig 

func (x *GetJobRequest) GetIncludeConfig() bool

func (*GetJobRequest) GetProjectId 

func (x *GetJobRequest) GetProjectId() string

func (*GetJobRequest) GetTenantId 

func (x *GetJobRequest) GetTenantId() string

func (*GetJobRequest) ProtoMessage 

func (*GetJobRequest) ProtoMessage()

func (*GetJobRequest) ProtoReflect 

func (x *GetJobRequest) ProtoReflect() protoreflect.Message

func (*GetJobRequest) Reset 

func (x *GetJobRequest) Reset()

func (*GetJobRequest) String 

func (x *GetJobRequest) String() string

type GetLeaderRequest 

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

func (*GetLeaderRequest) Descriptor deprecated 

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

Deprecated: Use GetLeaderRequest.ProtoReflect.Descriptor instead.

func (*GetLeaderRequest) ProtoMessage 

func (*GetLeaderRequest) ProtoMessage()

func (*GetLeaderRequest) ProtoReflect 

func (x *GetLeaderRequest) ProtoReflect() protoreflect.Message

func (*GetLeaderRequest) Reset 

func (x *GetLeaderRequest) Reset()

func (*GetLeaderRequest) String 

func (x *GetLeaderRequest) String() string

type GetLeaderResponse 

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

func (*GetLeaderResponse) Descriptor deprecated 

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

Deprecated: Use GetLeaderResponse.ProtoReflect.Descriptor instead.

func (*GetLeaderResponse) GetAdvertiseAddr 

func (x *GetLeaderResponse) GetAdvertiseAddr() string

func (*GetLeaderResponse) ProtoMessage 

func (*GetLeaderResponse) ProtoMessage()

func (*GetLeaderResponse) ProtoReflect 

func (x *GetLeaderResponse) ProtoReflect() protoreflect.Message

func (*GetLeaderResponse) Reset 

func (x *GetLeaderResponse) Reset()

func (*GetLeaderResponse) String 

func (x *GetLeaderResponse) String() string

type HeartbeatRequest 

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
}

func (*HeartbeatRequest) Descriptor deprecated 

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

Deprecated: Use HeartbeatRequest.ProtoReflect.Descriptor instead.

func (*HeartbeatRequest) GetExecutorId 

func (x *HeartbeatRequest) GetExecutorId() string

func (*HeartbeatRequest) GetTimestamp 

func (x *HeartbeatRequest) GetTimestamp() uint64

func (*HeartbeatRequest) GetTtl 

func (x *HeartbeatRequest) GetTtl() uint64

func (*HeartbeatRequest) ProtoMessage 

func (*HeartbeatRequest) ProtoMessage()

func (*HeartbeatRequest) ProtoReflect 

func (x *HeartbeatRequest) ProtoReflect() protoreflect.Message

func (*HeartbeatRequest) Reset 

func (x *HeartbeatRequest) Reset()

func (*HeartbeatRequest) String 

func (x *HeartbeatRequest) String() string

type HeartbeatResponse 

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

func (*HeartbeatResponse) Descriptor deprecated 

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

Deprecated: Use HeartbeatResponse.ProtoReflect.Descriptor instead.

func (*HeartbeatResponse) ProtoMessage 

func (*HeartbeatResponse) ProtoMessage()

func (*HeartbeatResponse) ProtoReflect 

func (x *HeartbeatResponse) ProtoReflect() protoreflect.Message

func (*HeartbeatResponse) Reset 

func (x *HeartbeatResponse) Reset()

func (*HeartbeatResponse) String 

func (x *HeartbeatResponse) String() string

type IsReadyRequest 

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

func (*IsReadyRequest) Descriptor deprecated 

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

Deprecated: Use IsReadyRequest.ProtoReflect.Descriptor instead.

func (*IsReadyRequest) ProtoMessage 

func (*IsReadyRequest) ProtoMessage()

func (*IsReadyRequest) ProtoReflect 

func (x *IsReadyRequest) ProtoReflect() protoreflect.Message

func (*IsReadyRequest) Reset 

func (x *IsReadyRequest) Reset()

func (*IsReadyRequest) String 

func (x *IsReadyRequest) String() string

type IsReadyResponse 

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

func (*IsReadyResponse) Descriptor deprecated 

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

Deprecated: Use IsReadyResponse.ProtoReflect.Descriptor instead.

func (*IsReadyResponse) GetReady 

func (x *IsReadyResponse) GetReady() bool

func (*IsReadyResponse) ProtoMessage 

func (*IsReadyResponse) ProtoMessage()

func (*IsReadyResponse) ProtoReflect 

func (x *IsReadyResponse) ProtoReflect() protoreflect.Message

func (*IsReadyResponse) Reset 

func (x *IsReadyResponse) Reset()

func (*IsReadyResponse) String 

func (x *IsReadyResponse) String() string

type Job 

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
}

func (*Job) Descriptor deprecated 

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

Deprecated: Use Job.ProtoReflect.Descriptor instead.

func (*Job) GetConfig 

func (x *Job) GetConfig() []byte

func (*Job) GetDetail 

func (x *Job) GetDetail() []byte

func (*Job) GetError 

func (x *Job) GetError() *Job_Error

func (*Job) GetId 

func (x *Job) GetId() string

func (*Job) GetSelectors 

func (x *Job) GetSelectors() []*Selector

func (*Job) GetState 

func (x *Job) GetState() Job_State

func (*Job) GetType 

func (x *Job) GetType() Job_Type

func (*Job) MarshalLogObject 

func (m *Job) MarshalLogObject(enc zapcore.ObjectEncoder) error

MarshalLogObject implements zapcore.ObjectMarshaler.

func (*Job) ProtoMessage 

func (*Job) ProtoMessage()

func (*Job) ProtoReflect 

func (x *Job) ProtoReflect() protoreflect.Message

func (*Job) Reset 

func (x *Job) Reset()

func (*Job) String 

func (x *Job) String() string

type JobManagerClient 

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)
}

JobManagerClient is the client API for JobManager service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewJobManagerClient 

func NewJobManagerClient(cc grpc.ClientConnInterface) JobManagerClient

type JobManagerServer 

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)
}

JobManagerServer is the server API for JobManager service. All implementations should embed UnimplementedJobManagerServer for forward compatibility

type Job_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
}

func (*Job_Error) Descriptor deprecated 

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

Deprecated: Use Job_Error.ProtoReflect.Descriptor instead.

func (*Job_Error) GetCode 

func (x *Job_Error) GetCode() string

func (*Job_Error) GetMessage 

func (x *Job_Error) GetMessage() string

func (*Job_Error) ProtoMessage 

func (*Job_Error) ProtoMessage()

func (*Job_Error) ProtoReflect 

func (x *Job_Error) ProtoReflect() protoreflect.Message

func (*Job_Error) Reset 

func (x *Job_Error) Reset()

func (*Job_Error) String 

func (x *Job_Error) String() string

type Job_State 

type Job_State int32
const (
	Job_StateUnknown Job_State = 0
	Job_Created      Job_State = 1
	Job_Running      Job_State = 2
	Job_Failed       Job_State = 3
	Job_Finished     Job_State = 4
	Job_Canceling    Job_State = 5
	Job_Canceled     Job_State = 6
)

func (Job_State) Descriptor 

func (Job_State) Descriptor() protoreflect.EnumDescriptor

func (Job_State) Enum 

func (x Job_State) Enum() *Job_State

func (Job_State) EnumDescriptor deprecated 

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

Deprecated: Use Job_State.Descriptor instead.

func (Job_State) Number 

func (x Job_State) Number() protoreflect.EnumNumber

func (Job_State) String 

func (x Job_State) String() string

func (Job_State) Type 

func (Job_State) Type() protoreflect.EnumType

type Job_Type 

type Job_Type int32
const (
	Job_TypeUnknown Job_Type = 0
	Job_CVSDemo     Job_Type = 1
	Job_DM          Job_Type = 2
	Job_CDC         Job_Type = 3
	Job_FakeJob     Job_Type = 4
)

func (Job_Type) Descriptor 

func (Job_Type) Descriptor() protoreflect.EnumDescriptor

func (Job_Type) Enum 

func (x Job_Type) Enum() *Job_Type

func (Job_Type) EnumDescriptor deprecated 

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

Deprecated: Use Job_Type.Descriptor instead.

func (Job_Type) Number 

func (x Job_Type) Number() protoreflect.EnumNumber

func (Job_Type) String 

func (x Job_Type) String() string

func (Job_Type) Type 

func (Job_Type) Type() protoreflect.EnumType

type ListExecutorsRequest 

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

func (*ListExecutorsRequest) Descriptor deprecated 

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

Deprecated: Use ListExecutorsRequest.ProtoReflect.Descriptor instead.

func (*ListExecutorsRequest) ProtoMessage 

func (*ListExecutorsRequest) ProtoMessage()

func (*ListExecutorsRequest) ProtoReflect 

func (x *ListExecutorsRequest) ProtoReflect() protoreflect.Message

func (*ListExecutorsRequest) Reset 

func (x *ListExecutorsRequest) Reset()

func (*ListExecutorsRequest) String 

func (x *ListExecutorsRequest) String() string

type ListExecutorsResponse 

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

func (*ListExecutorsResponse) Descriptor deprecated 

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

Deprecated: Use ListExecutorsResponse.ProtoReflect.Descriptor instead.

func (*ListExecutorsResponse) GetExecutors 

func (x *ListExecutorsResponse) GetExecutors() []*Executor

func (*ListExecutorsResponse) ProtoMessage 

func (*ListExecutorsResponse) ProtoMessage()

func (*ListExecutorsResponse) ProtoReflect 

func (x *ListExecutorsResponse) ProtoReflect() protoreflect.Message

func (*ListExecutorsResponse) Reset 

func (x *ListExecutorsResponse) Reset()

func (*ListExecutorsResponse) String 

func (x *ListExecutorsResponse) String() string

type ListFilesReq 

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

func (*ListFilesReq) Descriptor deprecated 

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

Deprecated: Use ListFilesReq.ProtoReflect.Descriptor instead.

func (*ListFilesReq) ProtoMessage 

func (*ListFilesReq) ProtoMessage()

func (*ListFilesReq) ProtoReflect 

func (x *ListFilesReq) ProtoReflect() protoreflect.Message

func (*ListFilesReq) Reset 

func (x *ListFilesReq) Reset()

func (*ListFilesReq) String 

func (x *ListFilesReq) String() string

type ListFilesResponse 

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

func (*ListFilesResponse) Descriptor deprecated 

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

Deprecated: Use ListFilesResponse.ProtoReflect.Descriptor instead.

func (*ListFilesResponse) GetFileNum 

func (x *ListFilesResponse) GetFileNum() int32

func (*ListFilesResponse) ProtoMessage 

func (*ListFilesResponse) ProtoMessage()

func (*ListFilesResponse) ProtoReflect 

func (x *ListFilesResponse) ProtoReflect() protoreflect.Message

func (*ListFilesResponse) Reset 

func (x *ListFilesResponse) Reset()

func (*ListFilesResponse) String 

func (x *ListFilesResponse) String() string

type ListJobsRequest 

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
}

func (*ListJobsRequest) Descriptor deprecated 

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

Deprecated: Use ListJobsRequest.ProtoReflect.Descriptor instead.

func (*ListJobsRequest) GetIncludeConfig 

func (x *ListJobsRequest) GetIncludeConfig() bool

func (*ListJobsRequest) GetPageSize 

func (x *ListJobsRequest) GetPageSize() int32

func (*ListJobsRequest) GetPageToken 

func (x *ListJobsRequest) GetPageToken() string

func (*ListJobsRequest) GetProjectId 

func (x *ListJobsRequest) GetProjectId() string

func (*ListJobsRequest) GetState 

func (x *ListJobsRequest) GetState() Job_State

func (*ListJobsRequest) GetTenantId 

func (x *ListJobsRequest) GetTenantId() string

func (*ListJobsRequest) GetType 

func (x *ListJobsRequest) GetType() Job_Type

func (*ListJobsRequest) ProtoMessage 

func (*ListJobsRequest) ProtoMessage()

func (*ListJobsRequest) ProtoReflect 

func (x *ListJobsRequest) ProtoReflect() protoreflect.Message

func (*ListJobsRequest) Reset 

func (x *ListJobsRequest) Reset()

func (*ListJobsRequest) String 

func (x *ListJobsRequest) String() string

type ListJobsResponse 

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
}

func (*ListJobsResponse) Descriptor deprecated 

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

Deprecated: Use ListJobsResponse.ProtoReflect.Descriptor instead.

func (*ListJobsResponse) GetJobs 

func (x *ListJobsResponse) GetJobs() []*Job

func (*ListJobsResponse) GetNextPageToken 

func (x *ListJobsResponse) GetNextPageToken() string

func (*ListJobsResponse) ProtoMessage 

func (*ListJobsResponse) ProtoMessage()

func (*ListJobsResponse) ProtoReflect 

func (x *ListJobsResponse) ProtoReflect() protoreflect.Message

func (*ListJobsResponse) Reset 

func (x *ListJobsResponse) Reset()

func (*ListJobsResponse) String 

func (x *ListJobsResponse) String() string

type ListMastersRequest 

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

func (*ListMastersRequest) Descriptor deprecated 

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

Deprecated: Use ListMastersRequest.ProtoReflect.Descriptor instead.

func (*ListMastersRequest) ProtoMessage 

func (*ListMastersRequest) ProtoMessage()

func (*ListMastersRequest) ProtoReflect 

func (x *ListMastersRequest) ProtoReflect() protoreflect.Message

func (*ListMastersRequest) Reset 

func (x *ListMastersRequest) Reset()

func (*ListMastersRequest) String 

func (x *ListMastersRequest) String() string

type ListMastersResponse 

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

func (*ListMastersResponse) Descriptor deprecated 

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

Deprecated: Use ListMastersResponse.ProtoReflect.Descriptor instead.

func (*ListMastersResponse) GetMasters 

func (x *ListMastersResponse) GetMasters() []*Master

func (*ListMastersResponse) ProtoMessage 

func (*ListMastersResponse) ProtoMessage()

func (*ListMastersResponse) ProtoReflect 

func (x *ListMastersResponse) ProtoReflect() protoreflect.Message

func (*ListMastersResponse) Reset 

func (x *ListMastersResponse) Reset()

func (*ListMastersResponse) String 

func (x *ListMastersResponse) String() string

type Master 

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
}

func (*Master) Descriptor deprecated 

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

Deprecated: Use Master.ProtoReflect.Descriptor instead.

func (*Master) GetAddress 

func (x *Master) GetAddress() string

func (*Master) GetId 

func (x *Master) GetId() string

func (*Master) GetIsLeader 

func (x *Master) GetIsLeader() bool

func (*Master) GetName 

func (x *Master) GetName() string

func (*Master) ProtoMessage 

func (*Master) ProtoMessage()

func (*Master) ProtoReflect 

func (x *Master) ProtoReflect() protoreflect.Message

func (*Master) Reset 

func (x *Master) Reset()

func (*Master) String 

func (x *Master) String() string

type PreDispatchTaskRequest 

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
}

func (*PreDispatchTaskRequest) Descriptor deprecated 

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

Deprecated: Use PreDispatchTaskRequest.ProtoReflect.Descriptor instead.

func (*PreDispatchTaskRequest) GetMasterId 

func (x *PreDispatchTaskRequest) GetMasterId() string

func (*PreDispatchTaskRequest) GetProjectInfo 

func (x *PreDispatchTaskRequest) GetProjectInfo() *ProjectInfo

func (*PreDispatchTaskRequest) GetRequestId 

func (x *PreDispatchTaskRequest) GetRequestId() string

func (*PreDispatchTaskRequest) GetTaskConfig 

func (x *PreDispatchTaskRequest) GetTaskConfig() []byte

func (*PreDispatchTaskRequest) GetTaskTypeId 

func (x *PreDispatchTaskRequest) GetTaskTypeId() int64

func (*PreDispatchTaskRequest) GetWorkerEpoch 

func (x *PreDispatchTaskRequest) GetWorkerEpoch() int64

func (*PreDispatchTaskRequest) GetWorkerId 

func (x *PreDispatchTaskRequest) GetWorkerId() string

func (*PreDispatchTaskRequest) MarshalLogObject 

func (m *PreDispatchTaskRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

MarshalLogObject implements zapcore.ObjectMarshaler.

func (*PreDispatchTaskRequest) ProtoMessage 

func (*PreDispatchTaskRequest) ProtoMessage()

func (*PreDispatchTaskRequest) ProtoReflect 

func (x *PreDispatchTaskRequest) ProtoReflect() protoreflect.Message

func (*PreDispatchTaskRequest) Reset 

func (x *PreDispatchTaskRequest) Reset()

func (*PreDispatchTaskRequest) String 

func (x *PreDispatchTaskRequest) String() string

type PreDispatchTaskResponse 

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

func (*PreDispatchTaskResponse) Descriptor deprecated 

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

Deprecated: Use PreDispatchTaskResponse.ProtoReflect.Descriptor instead.

func (*PreDispatchTaskResponse) ProtoMessage 

func (*PreDispatchTaskResponse) ProtoMessage()

func (*PreDispatchTaskResponse) ProtoReflect 

func (x *PreDispatchTaskResponse) ProtoReflect() protoreflect.Message

func (*PreDispatchTaskResponse) Reset 

func (x *PreDispatchTaskResponse) Reset()

func (*PreDispatchTaskResponse) String 

func (x *PreDispatchTaskResponse) String() string

type ProjectInfo 

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
}

func (*ProjectInfo) Descriptor deprecated 

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

Deprecated: Use ProjectInfo.ProtoReflect.Descriptor instead.

func (*ProjectInfo) GetProjectId 

func (x *ProjectInfo) GetProjectId() string

func (*ProjectInfo) GetTenantId 

func (x *ProjectInfo) GetTenantId() string

func (*ProjectInfo) ProtoMessage 

func (*ProjectInfo) ProtoMessage()

func (*ProjectInfo) ProtoReflect 

func (x *ProjectInfo) ProtoReflect() protoreflect.Message

func (*ProjectInfo) Reset 

func (x *ProjectInfo) Reset()

func (*ProjectInfo) String 

func (x *ProjectInfo) String() string

type QueryMetaStoreRequest 

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

func (*QueryMetaStoreRequest) Descriptor deprecated 

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

Deprecated: Use QueryMetaStoreRequest.ProtoReflect.Descriptor instead.

func (*QueryMetaStoreRequest) GetTp 

func (x *QueryMetaStoreRequest) GetTp() StoreType

func (*QueryMetaStoreRequest) ProtoMessage 

func (*QueryMetaStoreRequest) ProtoMessage()

func (*QueryMetaStoreRequest) ProtoReflect 

func (x *QueryMetaStoreRequest) ProtoReflect() protoreflect.Message

func (*QueryMetaStoreRequest) Reset 

func (x *QueryMetaStoreRequest) Reset()

func (*QueryMetaStoreRequest) String 

func (x *QueryMetaStoreRequest) String() string

type QueryMetaStoreResponse 

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

func (*QueryMetaStoreResponse) Descriptor deprecated 

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

Deprecated: Use QueryMetaStoreResponse.ProtoReflect.Descriptor instead.

func (*QueryMetaStoreResponse) GetConfig 

func (x *QueryMetaStoreResponse) GetConfig() []byte

func (*QueryMetaStoreResponse) MarshalLogObject 

func (m *QueryMetaStoreResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error

MarshalLogObject implements zapcore.ObjectMarshaler.

func (*QueryMetaStoreResponse) ProtoMessage 

func (*QueryMetaStoreResponse) ProtoMessage()

func (*QueryMetaStoreResponse) ProtoReflect 

func (x *QueryMetaStoreResponse) ProtoReflect() protoreflect.Message

func (*QueryMetaStoreResponse) Reset 

func (x *QueryMetaStoreResponse) Reset()

func (*QueryMetaStoreResponse) String 

func (x *QueryMetaStoreResponse) String() string

type QueryResourceRequest 

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

func (*QueryResourceRequest) Descriptor deprecated 

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

Deprecated: Use QueryResourceRequest.ProtoReflect.Descriptor instead.

func (*QueryResourceRequest) GetResourceKey 

func (x *QueryResourceRequest) GetResourceKey() *ResourceKey

func (*QueryResourceRequest) ProtoMessage 

func (*QueryResourceRequest) ProtoMessage()

func (*QueryResourceRequest) ProtoReflect 

func (x *QueryResourceRequest) ProtoReflect() protoreflect.Message

func (*QueryResourceRequest) Reset 

func (x *QueryResourceRequest) Reset()

func (*QueryResourceRequest) String 

func (x *QueryResourceRequest) String() string

type QueryResourceResponse 

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
}

func (*QueryResourceResponse) Descriptor deprecated 

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

Deprecated: Use QueryResourceResponse.ProtoReflect.Descriptor instead.

func (*QueryResourceResponse) GetCreatorExecutor 

func (x *QueryResourceResponse) GetCreatorExecutor() string

func (*QueryResourceResponse) GetCreatorWorkerId 

func (x *QueryResourceResponse) GetCreatorWorkerId() string

func (*QueryResourceResponse) GetJobId 

func (x *QueryResourceResponse) GetJobId() string

func (*QueryResourceResponse) ProtoMessage 

func (*QueryResourceResponse) ProtoMessage()

func (*QueryResourceResponse) ProtoReflect 

func (x *QueryResourceResponse) ProtoReflect() protoreflect.Message

func (*QueryResourceResponse) Reset 

func (x *QueryResourceResponse) Reset()

func (*QueryResourceResponse) String 

func (x *QueryResourceResponse) String() string

type QueryStorageConfigRequest 

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

func (*QueryStorageConfigRequest) Descriptor deprecated 

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

Deprecated: Use QueryStorageConfigRequest.ProtoReflect.Descriptor instead.

func (*QueryStorageConfigRequest) ProtoMessage 

func (*QueryStorageConfigRequest) ProtoMessage()

func (*QueryStorageConfigRequest) ProtoReflect 

func (x *QueryStorageConfigRequest) ProtoReflect() protoreflect.Message

func (*QueryStorageConfigRequest) Reset 

func (x *QueryStorageConfigRequest) Reset()

func (*QueryStorageConfigRequest) String 

func (x *QueryStorageConfigRequest) String() string

type QueryStorageConfigResponse 

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

func (*QueryStorageConfigResponse) Descriptor deprecated 

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

Deprecated: Use QueryStorageConfigResponse.ProtoReflect.Descriptor instead.

func (*QueryStorageConfigResponse) GetConfig 

func (x *QueryStorageConfigResponse) GetConfig() []byte

func (*QueryStorageConfigResponse) MarshalLogObject 

func (m *QueryStorageConfigResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error

MarshalLogObject implements zapcore.ObjectMarshaler.

func (*QueryStorageConfigResponse) ProtoMessage 

func (*QueryStorageConfigResponse) ProtoMessage()

func (*QueryStorageConfigResponse) ProtoReflect 

func (x *QueryStorageConfigResponse) ProtoReflect() protoreflect.Message

func (*QueryStorageConfigResponse) Reset 

func (x *QueryStorageConfigResponse) Reset()

func (*QueryStorageConfigResponse) String 

func (x *QueryStorageConfigResponse) String() string

type ReadLinesRequest 

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
}

func (*ReadLinesRequest) Descriptor deprecated 

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

Deprecated: Use ReadLinesRequest.ProtoReflect.Descriptor instead.

func (*ReadLinesRequest) GetFileIdx 

func (x *ReadLinesRequest) GetFileIdx() int32

func (*ReadLinesRequest) GetLineNo 

func (x *ReadLinesRequest) GetLineNo() []byte

func (*ReadLinesRequest) ProtoMessage 

func (*ReadLinesRequest) ProtoMessage()

func (*ReadLinesRequest) ProtoReflect 

func (x *ReadLinesRequest) ProtoReflect() protoreflect.Message

func (*ReadLinesRequest) Reset 

func (x *ReadLinesRequest) Reset()

func (*ReadLinesRequest) String 

func (x *ReadLinesRequest) String() string

type ReadLinesResponse 

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
}

func (*ReadLinesResponse) Descriptor deprecated 

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

Deprecated: Use ReadLinesResponse.ProtoReflect.Descriptor instead.

func (*ReadLinesResponse) GetErrMsg 

func (x *ReadLinesResponse) GetErrMsg() string

func (*ReadLinesResponse) GetIsEof 

func (x *ReadLinesResponse) GetIsEof() bool

func (*ReadLinesResponse) GetKey 

func (x *ReadLinesResponse) GetKey() []byte

func (*ReadLinesResponse) GetVal 

func (x *ReadLinesResponse) GetVal() []byte

func (*ReadLinesResponse) ProtoMessage 

func (*ReadLinesResponse) ProtoMessage()

func (*ReadLinesResponse) ProtoReflect 

func (x *ReadLinesResponse) ProtoReflect() protoreflect.Message

func (*ReadLinesResponse) Reset 

func (x *ReadLinesResponse) Reset()

func (*ReadLinesResponse) String 

func (x *ReadLinesResponse) String() string

type Record 

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
}

func (*Record) Descriptor deprecated 

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

Deprecated: Use Record.ProtoReflect.Descriptor instead.

func (*Record) GetGtid 

func (x *Record) GetGtid() int32

func (*Record) GetPk 

func (x *Record) GetPk() int32

func (*Record) GetSchemaVer 

func (x *Record) GetSchemaVer() int32

func (*Record) GetTid 

func (x *Record) GetTid() int32

func (*Record) GetTimeTracer 

func (x *Record) GetTimeTracer() []int64

func (*Record) GetTp 

func (x *Record) GetTp() Record_RecordType

func (*Record) ProtoMessage 

func (*Record) ProtoMessage()

func (*Record) ProtoReflect 

func (x *Record) ProtoReflect() protoreflect.Message

func (*Record) Reset 

func (x *Record) Reset()

func (*Record) String 

func (x *Record) String() string

type Record_RecordType 

type Record_RecordType int32
const (
	Record_Data Record_RecordType = 0
	Record_DDL  Record_RecordType = 1
)

func (Record_RecordType) Descriptor 

func (Record_RecordType) Descriptor() protoreflect.EnumDescriptor

func (Record_RecordType) Enum 

func (x Record_RecordType) Enum() *Record_RecordType

func (Record_RecordType) EnumDescriptor deprecated 

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

Deprecated: Use Record_RecordType.Descriptor instead.

func (Record_RecordType) Number 

func (x Record_RecordType) Number() protoreflect.EnumNumber

func (Record_RecordType) String 

func (x Record_RecordType) String() string

func (Record_RecordType) Type 

func (Record_RecordType) Type() protoreflect.EnumType

type RegisterExecutorRequest 

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

func (*RegisterExecutorRequest) Descriptor deprecated 

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

Deprecated: Use RegisterExecutorRequest.ProtoReflect.Descriptor instead.

func (*RegisterExecutorRequest) GetExecutor 

func (x *RegisterExecutorRequest) GetExecutor() *Executor

func (*RegisterExecutorRequest) ProtoMessage 

func (*RegisterExecutorRequest) ProtoMessage()

func (*RegisterExecutorRequest) ProtoReflect 

func (x *RegisterExecutorRequest) ProtoReflect() protoreflect.Message

func (*RegisterExecutorRequest) Reset 

func (x *RegisterExecutorRequest) Reset()

func (*RegisterExecutorRequest) String 

func (x *RegisterExecutorRequest) String() string

type RemoveLocalResourceRequest 

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
}

func (*RemoveLocalResourceRequest) Descriptor deprecated 

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

Deprecated: Use RemoveLocalResourceRequest.ProtoReflect.Descriptor instead.

func (*RemoveLocalResourceRequest) GetResourceId 

func (x *RemoveLocalResourceRequest) GetResourceId() string

func (*RemoveLocalResourceRequest) GetWorkerId 

func (x *RemoveLocalResourceRequest) GetWorkerId() string

func (*RemoveLocalResourceRequest) ProtoMessage 

func (*RemoveLocalResourceRequest) ProtoMessage()

func (*RemoveLocalResourceRequest) ProtoReflect 

func (x *RemoveLocalResourceRequest) ProtoReflect() protoreflect.Message

func (*RemoveLocalResourceRequest) Reset 

func (x *RemoveLocalResourceRequest) Reset()

func (*RemoveLocalResourceRequest) String 

func (x *RemoveLocalResourceRequest) String() string

type RemoveLocalResourceResponse 

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

func (*RemoveLocalResourceResponse) Descriptor deprecated 

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

Deprecated: Use RemoveLocalResourceResponse.ProtoReflect.Descriptor instead.

func (*RemoveLocalResourceResponse) ProtoMessage 

func (*RemoveLocalResourceResponse) ProtoMessage()

func (*RemoveLocalResourceResponse) ProtoReflect 

func (x *RemoveLocalResourceResponse) ProtoReflect() protoreflect.Message

func (*RemoveLocalResourceResponse) Reset 

func (x *RemoveLocalResourceResponse) Reset()

func (*RemoveLocalResourceResponse) String 

func (x *RemoveLocalResourceResponse) String() string

type RemoveResourceRequest 

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

func (*RemoveResourceRequest) Descriptor deprecated 

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

Deprecated: Use RemoveResourceRequest.ProtoReflect.Descriptor instead.

func (*RemoveResourceRequest) GetResourceKey 

func (x *RemoveResourceRequest) GetResourceKey() *ResourceKey

func (*RemoveResourceRequest) ProtoMessage 

func (*RemoveResourceRequest) ProtoMessage()

func (*RemoveResourceRequest) ProtoReflect 

func (x *RemoveResourceRequest) ProtoReflect() protoreflect.Message

func (*RemoveResourceRequest) Reset 

func (x *RemoveResourceRequest) Reset()

func (*RemoveResourceRequest) String 

func (x *RemoveResourceRequest) String() string

type RemoveResourceResponse 

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

func (*RemoveResourceResponse) Descriptor deprecated 

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

Deprecated: Use RemoveResourceResponse.ProtoReflect.Descriptor instead.

func (*RemoveResourceResponse) ProtoMessage 

func (*RemoveResourceResponse) ProtoMessage()

func (*RemoveResourceResponse) ProtoReflect 

func (x *RemoveResourceResponse) ProtoReflect() protoreflect.Message

func (*RemoveResourceResponse) Reset 

func (x *RemoveResourceResponse) Reset()

func (*RemoveResourceResponse) String 

func (x *RemoveResourceResponse) String() string

type ResignLeaderRequest 

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

func (*ResignLeaderRequest) Descriptor deprecated 

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

Deprecated: Use ResignLeaderRequest.ProtoReflect.Descriptor instead.

func (*ResignLeaderRequest) ProtoMessage 

func (*ResignLeaderRequest) ProtoMessage()

func (*ResignLeaderRequest) ProtoReflect 

func (x *ResignLeaderRequest) ProtoReflect() protoreflect.Message

func (*ResignLeaderRequest) Reset 

func (x *ResignLeaderRequest) Reset()

func (*ResignLeaderRequest) String 

func (x *ResignLeaderRequest) String() string

type ResourceKey 

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
}

func (*ResourceKey) Descriptor deprecated 

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

Deprecated: Use ResourceKey.ProtoReflect.Descriptor instead.

func (*ResourceKey) GetJobId 

func (x *ResourceKey) GetJobId() string

func (*ResourceKey) GetResourceId 

func (x *ResourceKey) GetResourceId() string

func (*ResourceKey) ProtoMessage 

func (*ResourceKey) ProtoMessage()

func (*ResourceKey) ProtoReflect 

func (x *ResourceKey) ProtoReflect() protoreflect.Message

func (*ResourceKey) Reset 

func (x *ResourceKey) Reset()

func (*ResourceKey) String 

func (x *ResourceKey) String() string

type ResourceManagerClient 

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)
}

ResourceManagerClient is the client API for ResourceManager service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewResourceManagerClient 

func NewResourceManagerClient(cc grpc.ClientConnInterface) ResourceManagerClient

type ResourceManagerServer 

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)
}

ResourceManagerServer is the server API for ResourceManager service. All implementations should embed UnimplementedResourceManagerServer for forward compatibility

type ScheduleTaskRequest 

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
}

func (*ScheduleTaskRequest) Descriptor deprecated 

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

Deprecated: Use ScheduleTaskRequest.ProtoReflect.Descriptor instead.

func (*ScheduleTaskRequest) GetResources 

func (x *ScheduleTaskRequest) GetResources() []*ResourceKey

func (*ScheduleTaskRequest) GetSelectors 

func (x *ScheduleTaskRequest) GetSelectors() []*Selector

func (*ScheduleTaskRequest) GetTaskId 

func (x *ScheduleTaskRequest) GetTaskId() string

func (*ScheduleTaskRequest) ProtoMessage 

func (*ScheduleTaskRequest) ProtoMessage()

func (*ScheduleTaskRequest) ProtoReflect 

func (x *ScheduleTaskRequest) ProtoReflect() protoreflect.Message

func (*ScheduleTaskRequest) Reset 

func (x *ScheduleTaskRequest) Reset()

func (*ScheduleTaskRequest) String 

func (x *ScheduleTaskRequest) String() string

type ScheduleTaskResponse 

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
}

func (*ScheduleTaskResponse) Descriptor deprecated 

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

Deprecated: Use ScheduleTaskResponse.ProtoReflect.Descriptor instead.

func (*ScheduleTaskResponse) GetExecutorAddr 

func (x *ScheduleTaskResponse) GetExecutorAddr() string

func (*ScheduleTaskResponse) GetExecutorId 

func (x *ScheduleTaskResponse) GetExecutorId() string

func (*ScheduleTaskResponse) ProtoMessage 

func (*ScheduleTaskResponse) ProtoMessage()

func (*ScheduleTaskResponse) ProtoReflect 

func (x *ScheduleTaskResponse) ProtoReflect() protoreflect.Message

func (*ScheduleTaskResponse) Reset 

func (x *ScheduleTaskResponse) Reset()

func (*ScheduleTaskResponse) String 

func (x *ScheduleTaskResponse) String() string

type Selector 

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
}

func (*Selector) Descriptor deprecated 

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

Deprecated: Use Selector.ProtoReflect.Descriptor instead.

func (*Selector) GetLabel 

func (x *Selector) GetLabel() string

func (*Selector) GetOp 

func (x *Selector) GetOp() Selector_Op

func (*Selector) GetTarget 

func (x *Selector) GetTarget() string

func (*Selector) ProtoMessage 

func (*Selector) ProtoMessage()

func (*Selector) ProtoReflect 

func (x *Selector) ProtoReflect() protoreflect.Message

func (*Selector) Reset 

func (x *Selector) Reset()

func (*Selector) String 

func (x *Selector) String() string

type Selector_Op 

type Selector_Op int32
const (
	Selector_OpUnknown Selector_Op = 0
	Selector_Eq        Selector_Op = 1
	Selector_Neq       Selector_Op = 2
	Selector_Regex     Selector_Op = 3
)

func (Selector_Op) Descriptor 

func (Selector_Op) Descriptor() protoreflect.EnumDescriptor

func (Selector_Op) Enum 

func (x Selector_Op) Enum() *Selector_Op

func (Selector_Op) EnumDescriptor deprecated 

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

Deprecated: Use Selector_Op.Descriptor instead.

func (Selector_Op) Number 

func (x Selector_Op) Number() protoreflect.EnumNumber

func (Selector_Op) String 

func (x Selector_Op) String() string

func (Selector_Op) Type 

func (Selector_Op) Type() protoreflect.EnumType

type StoreType 

type StoreType int32
const (
	StoreType_SystemMetaStore StoreType = 0
	StoreType_AppMetaStore    StoreType = 1
)

func (StoreType) Descriptor 

func (StoreType) Descriptor() protoreflect.EnumDescriptor

func (StoreType) Enum 

func (x StoreType) Enum() *StoreType

func (StoreType) EnumDescriptor deprecated 

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

Deprecated: Use StoreType.Descriptor instead.

func (StoreType) Number 

func (x StoreType) Number() protoreflect.EnumNumber

func (StoreType) String 

func (x StoreType) String() string

func (StoreType) Type 

func (StoreType) Type() protoreflect.EnumType

type TaskSchedulerClient 

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

TaskSchedulerClient is the client API for TaskScheduler service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewTaskSchedulerClient 

func NewTaskSchedulerClient(cc grpc.ClientConnInterface) TaskSchedulerClient

type TaskSchedulerServer 

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

TaskSchedulerServer is the server API for TaskScheduler service. All implementations should embed UnimplementedTaskSchedulerServer for forward compatibility

type TestBinlogRequest 

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

func (*TestBinlogRequest) Descriptor deprecated 

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

Deprecated: Use TestBinlogRequest.ProtoReflect.Descriptor instead.

func (*TestBinlogRequest) GetGtid 

func (x *TestBinlogRequest) GetGtid() int32

func (*TestBinlogRequest) ProtoMessage 

func (*TestBinlogRequest) ProtoMessage()

func (*TestBinlogRequest) ProtoReflect 

func (x *TestBinlogRequest) ProtoReflect() protoreflect.Message

func (*TestBinlogRequest) Reset 

func (x *TestBinlogRequest) Reset()

func (*TestBinlogRequest) String 

func (x *TestBinlogRequest) String() string

type TestServiceClient 

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

TestServiceClient is the client API for TestService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewTestServiceClient 

func NewTestServiceClient(cc grpc.ClientConnInterface) TestServiceClient

type TestServiceServer 

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

TestServiceServer is the server API for TestService service. All implementations should embed UnimplementedTestServiceServer for forward compatibility

type TestService_FeedBinlogClient 

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

type TestService_FeedBinlogServer 

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

type UnimplementedBrokerServiceServer 

type UnimplementedBrokerServiceServer struct {
}

UnimplementedBrokerServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedBrokerServiceServer) RemoveResource 

func (UnimplementedBrokerServiceServer) RemoveResource(context.Context, *RemoveLocalResourceRequest) (*RemoveLocalResourceResponse, error)

type UnimplementedDataRWServiceServer 

type UnimplementedDataRWServiceServer struct {
}

UnimplementedDataRWServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedDataRWServiceServer) CheckDir 

func (UnimplementedDataRWServiceServer) CheckDir(context.Context, *CheckDirRequest) (*CheckDirResponse, error)

func (UnimplementedDataRWServiceServer) GenerateData 

func (UnimplementedDataRWServiceServer) GenerateData(context.Context, *GenerateDataRequest) (*GenerateDataResponse, error)

func (UnimplementedDataRWServiceServer) IsReady 

func (UnimplementedDataRWServiceServer) IsReady(context.Context, *IsReadyRequest) (*IsReadyResponse, error)

func (UnimplementedDataRWServiceServer) ListFiles 

func (UnimplementedDataRWServiceServer) ListFiles(context.Context, *ListFilesReq) (*ListFilesResponse, error)

func (UnimplementedDataRWServiceServer) ReadLines 

func (UnimplementedDataRWServiceServer) ReadLines(*ReadLinesRequest, DataRWService_ReadLinesServer) error

func (UnimplementedDataRWServiceServer) WriteLines 

func (UnimplementedDataRWServiceServer) WriteLines(DataRWService_WriteLinesServer) error

type UnimplementedDiscoveryServer 

type UnimplementedDiscoveryServer struct {
}

UnimplementedDiscoveryServer should be embedded to have forward compatible implementations.

func (UnimplementedDiscoveryServer) GetLeader 

func (UnimplementedDiscoveryServer) GetLeader(context.Context, *GetLeaderRequest) (*GetLeaderResponse, error)

func (UnimplementedDiscoveryServer) Heartbeat 

func (UnimplementedDiscoveryServer) Heartbeat(context.Context, *HeartbeatRequest) (*HeartbeatResponse, error)

func (UnimplementedDiscoveryServer) ListExecutors 

func (UnimplementedDiscoveryServer) ListExecutors(context.Context, *ListExecutorsRequest) (*ListExecutorsResponse, error)

func (UnimplementedDiscoveryServer) ListMasters 

func (UnimplementedDiscoveryServer) ListMasters(context.Context, *ListMastersRequest) (*ListMastersResponse, error)

func (UnimplementedDiscoveryServer) QueryMetaStore 

func (UnimplementedDiscoveryServer) QueryMetaStore(context.Context, *QueryMetaStoreRequest) (*QueryMetaStoreResponse, error)

func (UnimplementedDiscoveryServer) QueryStorageConfig 

func (UnimplementedDiscoveryServer) QueryStorageConfig(context.Context, *QueryStorageConfigRequest) (*QueryStorageConfigResponse, error)

func (UnimplementedDiscoveryServer) RegisterExecutor 

func (UnimplementedDiscoveryServer) RegisterExecutor(context.Context, *RegisterExecutorRequest) (*Executor, error)

func (UnimplementedDiscoveryServer) ResignLeader 

func (UnimplementedDiscoveryServer) ResignLeader(context.Context, *ResignLeaderRequest) (*emptypb.Empty, error)

type UnimplementedExecutorServiceServer 

type UnimplementedExecutorServiceServer struct {
}

UnimplementedExecutorServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedExecutorServiceServer) ConfirmDispatchTask 

func (UnimplementedExecutorServiceServer) ConfirmDispatchTask(context.Context, *ConfirmDispatchTaskRequest) (*ConfirmDispatchTaskResponse, error)

func (UnimplementedExecutorServiceServer) PreDispatchTask 

func (UnimplementedExecutorServiceServer) PreDispatchTask(context.Context, *PreDispatchTaskRequest) (*PreDispatchTaskResponse, error)

type UnimplementedJobManagerServer 

type UnimplementedJobManagerServer struct {
}

UnimplementedJobManagerServer should be embedded to have forward compatible implementations.

func (UnimplementedJobManagerServer) CancelJob 

func (UnimplementedJobManagerServer) CancelJob(context.Context, *CancelJobRequest) (*Job, error)

func (UnimplementedJobManagerServer) CreateJob 

func (UnimplementedJobManagerServer) CreateJob(context.Context, *CreateJobRequest) (*Job, error)

func (UnimplementedJobManagerServer) DeleteJob 

func (UnimplementedJobManagerServer) DeleteJob(context.Context, *DeleteJobRequest) (*emptypb.Empty, error)

func (UnimplementedJobManagerServer) GetJob 

func (UnimplementedJobManagerServer) GetJob(context.Context, *GetJobRequest) (*Job, error)

func (UnimplementedJobManagerServer) ListJobs 

func (UnimplementedJobManagerServer) ListJobs(context.Context, *ListJobsRequest) (*ListJobsResponse, error)

type UnimplementedResourceManagerServer 

type UnimplementedResourceManagerServer struct {
}

UnimplementedResourceManagerServer should be embedded to have forward compatible implementations.

func (UnimplementedResourceManagerServer) CreateResource 

func (UnimplementedResourceManagerServer) CreateResource(context.Context, *CreateResourceRequest) (*CreateResourceResponse, error)

func (UnimplementedResourceManagerServer) QueryResource 

func (UnimplementedResourceManagerServer) QueryResource(context.Context, *QueryResourceRequest) (*QueryResourceResponse, error)

func (UnimplementedResourceManagerServer) RemoveResource 

func (UnimplementedResourceManagerServer) RemoveResource(context.Context, *RemoveResourceRequest) (*RemoveResourceResponse, error)

type UnimplementedTaskSchedulerServer 

type UnimplementedTaskSchedulerServer struct {
}

UnimplementedTaskSchedulerServer should be embedded to have forward compatible implementations.

func (UnimplementedTaskSchedulerServer) ScheduleTask 

func (UnimplementedTaskSchedulerServer) ScheduleTask(context.Context, *ScheduleTaskRequest) (*ScheduleTaskResponse, error)

type UnimplementedTestServiceServer 

type UnimplementedTestServiceServer struct {
}

UnimplementedTestServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedTestServiceServer) FeedBinlog 

func (UnimplementedTestServiceServer) FeedBinlog(*TestBinlogRequest, TestService_FeedBinlogServer) error

type UnsafeBrokerServiceServer 

type UnsafeBrokerServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeBrokerServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to BrokerServiceServer will result in compilation errors.

type UnsafeDataRWServiceServer 

type UnsafeDataRWServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeDataRWServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DataRWServiceServer will result in compilation errors.

type UnsafeDiscoveryServer 

type UnsafeDiscoveryServer interface {
	// contains filtered or unexported methods
}

UnsafeDiscoveryServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DiscoveryServer will result in compilation errors.

type UnsafeExecutorServiceServer 

type UnsafeExecutorServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeExecutorServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ExecutorServiceServer will result in compilation errors.

type UnsafeJobManagerServer 

type UnsafeJobManagerServer interface {
	// contains filtered or unexported methods
}

UnsafeJobManagerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to JobManagerServer will result in compilation errors.

type UnsafeResourceManagerServer 

type UnsafeResourceManagerServer interface {
	// contains filtered or unexported methods
}

UnsafeResourceManagerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ResourceManagerServer will result in compilation errors.

type UnsafeTaskSchedulerServer 

type UnsafeTaskSchedulerServer interface {
	// contains filtered or unexported methods
}

UnsafeTaskSchedulerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TaskSchedulerServer will result in compilation errors.

type UnsafeTestServiceServer 

type UnsafeTestServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeTestServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TestServiceServer will result in compilation errors.

type WriteLinesRequest 

type WriteLinesRequest struct {
	Dir     string `protobuf:"bytes,1,opt,name=dir,proto3" json:"dir,omitempty"`
	FileIdx int32  `protobuf:"varint,2,opt,name=file_idx,json=fileIdx,proto3" json:"file_idx,omitempty"`
	Key     []byte `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	Value   []byte `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*WriteLinesRequest) Descriptor deprecated 

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

Deprecated: Use WriteLinesRequest.ProtoReflect.Descriptor instead.

func (*WriteLinesRequest) GetDir 

func (x *WriteLinesRequest) GetDir() string

func (*WriteLinesRequest) GetFileIdx 

func (x *WriteLinesRequest) GetFileIdx() int32

func (*WriteLinesRequest) GetKey 

func (x *WriteLinesRequest) GetKey() []byte

func (*WriteLinesRequest) GetValue 

func (x *WriteLinesRequest) GetValue() []byte

func (*WriteLinesRequest) ProtoMessage 

func (*WriteLinesRequest) ProtoMessage()

func (*WriteLinesRequest) ProtoReflect 

func (x *WriteLinesRequest) ProtoReflect() protoreflect.Message

func (*WriteLinesRequest) Reset 

func (x *WriteLinesRequest) Reset()

func (*WriteLinesRequest) String 

func (x *WriteLinesRequest) String() string

type WriteLinesResponse 

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

func (*WriteLinesResponse) Descriptor deprecated 

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

Deprecated: Use WriteLinesResponse.ProtoReflect.Descriptor instead.

func (*WriteLinesResponse) GetErrMsg 

func (x *WriteLinesResponse) GetErrMsg() string

func (*WriteLinesResponse) ProtoMessage 

func (*WriteLinesResponse) ProtoMessage()

func (*WriteLinesResponse) ProtoReflect 

func (x *WriteLinesResponse) ProtoReflect() protoreflect.Message

func (*WriteLinesResponse) Reset 

func (x *WriteLinesResponse) Reset()

func (*WriteLinesResponse) String 

func (x *WriteLinesResponse) String() string

Source Files

View all Source files

Directories

Path Synopsis
Package mock is a generated GoMock package.
 Package mock is a generated GoMock package.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.