Documentation ¶
Index ¶
- Variables
- func RegisterModelBaseServiceServer(s grpc.ServiceRegistrar, srv ModelBaseServiceServer)
- func RegisterModelDelegateServer(s grpc.ServiceRegistrar, srv ModelDelegateServer)
- func RegisterNodeServiceServer(s grpc.ServiceRegistrar, srv NodeServiceServer)
- func RegisterPluginServiceServer(s grpc.ServiceRegistrar, srv PluginServiceServer)
- func RegisterTaskServiceServer(s grpc.ServiceRegistrar, srv TaskServiceServer)
- type ModelBaseServiceClient
- type ModelBaseServiceServer
- type ModelDelegateClient
- type ModelDelegateServer
- type Node
- func (*Node) Descriptor() ([]byte, []int)deprecated
- func (x *Node) GetCreateTs() string
- func (x *Node) GetDescription() string
- func (x *Node) GetHostname() string
- func (x *Node) GetIp() string
- func (x *Node) GetIsMaster() bool
- func (x *Node) GetKey() string
- func (x *Node) GetMac() string
- func (x *Node) GetName() string
- func (x *Node) GetPort() string
- func (x *Node) GetUpdateTs() string
- func (x *Node) GetUpdateTsUnix() int64
- func (x *Node) GetXId() string
- func (*Node) ProtoMessage()
- func (x *Node) ProtoReflect() protoreflect.Message
- func (x *Node) Reset()
- func (x *Node) String() string
- type NodeInfo
- type NodeServiceClient
- type NodeServiceServer
- type NodeService_SubscribeClient
- type NodeService_SubscribeServer
- type PluginServiceClient
- type PluginServiceServer
- type PluginService_SubscribeClient
- type PluginService_SubscribeServer
- type Request
- type Response
- func (*Response) Descriptor() ([]byte, []int)deprecated
- func (x *Response) GetCode() ResponseCode
- func (x *Response) GetData() []byte
- func (x *Response) GetError() string
- func (x *Response) GetMessage() string
- func (x *Response) GetTotal() int64
- func (*Response) ProtoMessage()
- func (x *Response) ProtoReflect() protoreflect.Message
- func (x *Response) Reset()
- func (x *Response) String() string
- type ResponseCode
- func (ResponseCode) Descriptor() protoreflect.EnumDescriptor
- func (x ResponseCode) Enum() *ResponseCode
- func (ResponseCode) EnumDescriptor() ([]byte, []int)deprecated
- func (x ResponseCode) Number() protoreflect.EnumNumber
- func (x ResponseCode) String() string
- func (ResponseCode) Type() protoreflect.EnumType
- type StreamMessage
- func (*StreamMessage) Descriptor() ([]byte, []int)deprecated
- func (x *StreamMessage) GetCode() StreamMessageCode
- func (x *StreamMessage) GetData() []byte
- func (x *StreamMessage) GetError() string
- func (x *StreamMessage) GetNodeKey() string
- func (*StreamMessage) ProtoMessage()
- func (x *StreamMessage) ProtoReflect() protoreflect.Message
- func (x *StreamMessage) Reset()
- func (x *StreamMessage) String() string
- type StreamMessageCode
- func (StreamMessageCode) Descriptor() protoreflect.EnumDescriptor
- func (x StreamMessageCode) Enum() *StreamMessageCode
- func (StreamMessageCode) EnumDescriptor() ([]byte, []int)deprecated
- func (x StreamMessageCode) Number() protoreflect.EnumNumber
- func (x StreamMessageCode) String() string
- func (StreamMessageCode) Type() protoreflect.EnumType
- type StreamMessageDataTask
- func (*StreamMessageDataTask) Descriptor() ([]byte, []int)deprecated
- func (x *StreamMessageDataTask) GetData() string
- func (x *StreamMessageDataTask) GetTaskId() string
- func (*StreamMessageDataTask) ProtoMessage()
- func (x *StreamMessageDataTask) ProtoReflect() protoreflect.Message
- func (x *StreamMessageDataTask) Reset()
- func (x *StreamMessageDataTask) String() string
- type Task
- func (*Task) Descriptor() ([]byte, []int)deprecated
- func (x *Task) GetCmd() string
- func (x *Task) GetError() string
- func (x *Task) GetNodeId() string
- func (x *Task) GetParam() string
- func (x *Task) GetPid() int32
- func (x *Task) GetRunType() string
- func (x *Task) GetScheduleId() string
- func (x *Task) GetSpiderId() string
- func (x *Task) GetStatus() string
- func (x *Task) GetType() string
- func (x *Task) GetXId() string
- func (*Task) ProtoMessage()
- func (x *Task) ProtoReflect() protoreflect.Message
- func (x *Task) Reset()
- func (x *Task) String() string
- type TaskServiceClient
- type TaskServiceServer
- type TaskService_SubscribeClient
- type TaskService_SubscribeServer
- type UnimplementedModelBaseServiceServer
- func (UnimplementedModelBaseServiceServer) Count(context.Context, *Request) (*Response, error)
- func (UnimplementedModelBaseServiceServer) Delete(context.Context, *Request) (*Response, error)
- func (UnimplementedModelBaseServiceServer) DeleteById(context.Context, *Request) (*Response, error)
- func (UnimplementedModelBaseServiceServer) DeleteList(context.Context, *Request) (*Response, error)
- func (UnimplementedModelBaseServiceServer) ForceDeleteList(context.Context, *Request) (*Response, error)
- func (UnimplementedModelBaseServiceServer) Get(context.Context, *Request) (*Response, error)
- func (UnimplementedModelBaseServiceServer) GetById(context.Context, *Request) (*Response, error)
- func (UnimplementedModelBaseServiceServer) GetList(context.Context, *Request) (*Response, error)
- func (UnimplementedModelBaseServiceServer) Insert(context.Context, *Request) (*Response, error)
- func (UnimplementedModelBaseServiceServer) Update(context.Context, *Request) (*Response, error)
- func (UnimplementedModelBaseServiceServer) UpdateById(context.Context, *Request) (*Response, error)
- func (UnimplementedModelBaseServiceServer) UpdateDoc(context.Context, *Request) (*Response, error)
- type UnimplementedModelDelegateServer
- type UnimplementedNodeServiceServer
- func (UnimplementedNodeServiceServer) Ping(context.Context, *Request) (*Response, error)
- func (UnimplementedNodeServiceServer) Register(context.Context, *Request) (*Response, error)
- func (UnimplementedNodeServiceServer) SendHeartbeat(context.Context, *Request) (*Response, error)
- func (UnimplementedNodeServiceServer) Subscribe(*Request, NodeService_SubscribeServer) error
- func (UnimplementedNodeServiceServer) Unsubscribe(context.Context, *Request) (*Response, error)
- type UnimplementedPluginServiceServer
- type UnimplementedTaskServiceServer
- type UnsafeModelBaseServiceServer
- type UnsafeModelDelegateServer
- type UnsafeNodeServiceServer
- type UnsafePluginServiceServer
- type UnsafeTaskServiceServer
Constants ¶
This section is empty.
Variables ¶
var ( ResponseCode_name = map[int32]string{ 0: "OK", 1: "ERROR", } ResponseCode_value = map[string]int32{ "OK": 0, "ERROR": 1, } )
Enum value maps for ResponseCode.
var ( StreamMessageCode_name = map[int32]string{ 0: "PING", 1: "RUN_TASK", 2: "CANCEL_TASK", 3: "INSERT_DATA", 4: "INSERT_LOGS", } StreamMessageCode_value = map[string]int32{ "PING": 0, "RUN_TASK": 1, "CANCEL_TASK": 2, "INSERT_DATA": 3, "INSERT_LOGS": 4, } )
Enum value maps for StreamMessageCode.
var File_entity_node_info_proto protoreflect.FileDescriptor
var File_entity_request_proto protoreflect.FileDescriptor
var File_entity_response_code_proto protoreflect.FileDescriptor
var File_entity_response_proto protoreflect.FileDescriptor
var File_entity_stream_message_code_proto protoreflect.FileDescriptor
var File_entity_stream_message_data_task_proto protoreflect.FileDescriptor
var File_entity_stream_message_proto protoreflect.FileDescriptor
var File_models_node_proto protoreflect.FileDescriptor
var File_models_task_proto protoreflect.FileDescriptor
var File_services_model_base_service_proto protoreflect.FileDescriptor
var File_services_model_delegate_proto protoreflect.FileDescriptor
var File_services_node_service_proto protoreflect.FileDescriptor
var File_services_plugin_service_proto protoreflect.FileDescriptor
var File_services_task_service_proto protoreflect.FileDescriptor
Functions ¶
func RegisterModelBaseServiceServer ¶
func RegisterModelBaseServiceServer(s grpc.ServiceRegistrar, srv ModelBaseServiceServer)
func RegisterModelDelegateServer ¶
func RegisterModelDelegateServer(s grpc.ServiceRegistrar, srv ModelDelegateServer)
func RegisterNodeServiceServer ¶
func RegisterNodeServiceServer(s grpc.ServiceRegistrar, srv NodeServiceServer)
func RegisterPluginServiceServer ¶
func RegisterPluginServiceServer(s grpc.ServiceRegistrar, srv PluginServiceServer)
func RegisterTaskServiceServer ¶
func RegisterTaskServiceServer(s grpc.ServiceRegistrar, srv TaskServiceServer)
Types ¶
type ModelBaseServiceClient ¶
type ModelBaseServiceClient interface { GetById(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) Get(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) GetList(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) DeleteById(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) Delete(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) DeleteList(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) ForceDeleteList(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) UpdateById(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) Update(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) UpdateDoc(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) Insert(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) Count(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) }
ModelBaseServiceClient is the client API for ModelBaseService 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 NewModelBaseServiceClient ¶
func NewModelBaseServiceClient(cc grpc.ClientConnInterface) ModelBaseServiceClient
type ModelBaseServiceServer ¶
type ModelBaseServiceServer interface { GetById(context.Context, *Request) (*Response, error) Get(context.Context, *Request) (*Response, error) GetList(context.Context, *Request) (*Response, error) DeleteById(context.Context, *Request) (*Response, error) Delete(context.Context, *Request) (*Response, error) DeleteList(context.Context, *Request) (*Response, error) ForceDeleteList(context.Context, *Request) (*Response, error) UpdateById(context.Context, *Request) (*Response, error) Update(context.Context, *Request) (*Response, error) UpdateDoc(context.Context, *Request) (*Response, error) Insert(context.Context, *Request) (*Response, error) Count(context.Context, *Request) (*Response, error) // contains filtered or unexported methods }
ModelBaseServiceServer is the server API for ModelBaseService service. All implementations must embed UnimplementedModelBaseServiceServer for forward compatibility
type ModelDelegateClient ¶
type ModelDelegateClient interface {
Do(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)
}
ModelDelegateClient is the client API for ModelDelegate 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 NewModelDelegateClient ¶
func NewModelDelegateClient(cc grpc.ClientConnInterface) ModelDelegateClient
type ModelDelegateServer ¶
type ModelDelegateServer interface { Do(context.Context, *Request) (*Response, error) // contains filtered or unexported methods }
ModelDelegateServer is the server API for ModelDelegate service. All implementations must embed UnimplementedModelDelegateServer for forward compatibility
type Node ¶
type Node struct { XId string `protobuf:"bytes,1,opt,name=_id,json=Id,proto3" json:"_id,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Ip string `protobuf:"bytes,3,opt,name=ip,proto3" json:"ip,omitempty"` Port string `protobuf:"bytes,5,opt,name=port,proto3" json:"port,omitempty"` Mac string `protobuf:"bytes,6,opt,name=mac,proto3" json:"mac,omitempty"` Hostname string `protobuf:"bytes,7,opt,name=hostname,proto3" json:"hostname,omitempty"` Description string `protobuf:"bytes,8,opt,name=description,proto3" json:"description,omitempty"` Key string `protobuf:"bytes,9,opt,name=key,proto3" json:"key,omitempty"` IsMaster bool `protobuf:"varint,11,opt,name=is_master,json=isMaster,proto3" json:"is_master,omitempty"` UpdateTs string `protobuf:"bytes,12,opt,name=update_ts,json=updateTs,proto3" json:"update_ts,omitempty"` CreateTs string `protobuf:"bytes,13,opt,name=create_ts,json=createTs,proto3" json:"create_ts,omitempty"` UpdateTsUnix int64 `protobuf:"varint,14,opt,name=update_ts_unix,json=updateTsUnix,proto3" json:"update_ts_unix,omitempty"` // contains filtered or unexported fields }
func (*Node) Descriptor
deprecated
func (*Node) GetCreateTs ¶
func (*Node) GetDescription ¶
func (*Node) GetHostname ¶
func (*Node) GetIsMaster ¶
func (*Node) GetUpdateTs ¶
func (*Node) GetUpdateTsUnix ¶
func (*Node) ProtoMessage ¶
func (*Node) ProtoMessage()
func (*Node) ProtoReflect ¶
func (x *Node) ProtoReflect() protoreflect.Message
type NodeInfo ¶
type NodeInfo struct { Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` IsMaster bool `protobuf:"varint,2,opt,name=is_master,json=isMaster,proto3" json:"is_master,omitempty"` // contains filtered or unexported fields }
func (*NodeInfo) Descriptor
deprecated
func (*NodeInfo) GetIsMaster ¶
func (*NodeInfo) ProtoMessage ¶
func (*NodeInfo) ProtoMessage()
func (*NodeInfo) ProtoReflect ¶
func (x *NodeInfo) ProtoReflect() protoreflect.Message
type NodeServiceClient ¶
type NodeServiceClient interface { Register(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) SendHeartbeat(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) Ping(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) Subscribe(ctx context.Context, in *Request, opts ...grpc.CallOption) (NodeService_SubscribeClient, error) Unsubscribe(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) }
NodeServiceClient is the client API for NodeService 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 NewNodeServiceClient ¶
func NewNodeServiceClient(cc grpc.ClientConnInterface) NodeServiceClient
type NodeServiceServer ¶
type NodeServiceServer interface { Register(context.Context, *Request) (*Response, error) SendHeartbeat(context.Context, *Request) (*Response, error) Ping(context.Context, *Request) (*Response, error) Subscribe(*Request, NodeService_SubscribeServer) error Unsubscribe(context.Context, *Request) (*Response, error) // contains filtered or unexported methods }
NodeServiceServer is the server API for NodeService service. All implementations must embed UnimplementedNodeServiceServer for forward compatibility
type NodeService_SubscribeClient ¶
type NodeService_SubscribeClient interface { Recv() (*StreamMessage, error) grpc.ClientStream }
type NodeService_SubscribeServer ¶
type NodeService_SubscribeServer interface { Send(*StreamMessage) error grpc.ServerStream }
type PluginServiceClient ¶
type PluginServiceClient interface { Register(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) Subscribe(ctx context.Context, opts ...grpc.CallOption) (PluginService_SubscribeClient, error) }
PluginServiceClient is the client API for PluginService 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 NewPluginServiceClient ¶
func NewPluginServiceClient(cc grpc.ClientConnInterface) PluginServiceClient
type PluginServiceServer ¶
type PluginServiceServer interface { Register(context.Context, *Request) (*Response, error) Subscribe(PluginService_SubscribeServer) error // contains filtered or unexported methods }
PluginServiceServer is the server API for PluginService service. All implementations must embed UnimplementedPluginServiceServer for forward compatibility
type PluginService_SubscribeClient ¶
type PluginService_SubscribeClient interface { Send(*StreamMessage) error Recv() (*StreamMessage, error) grpc.ClientStream }
type PluginService_SubscribeServer ¶
type PluginService_SubscribeServer interface { Send(*StreamMessage) error Recv() (*StreamMessage, error) grpc.ServerStream }
type Request ¶
type Request struct { NodeKey string `protobuf:"bytes,1,opt,name=node_key,json=nodeKey,proto3" json:"node_key,omitempty"` Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*Request) Descriptor
deprecated
func (*Request) GetNodeKey ¶
func (*Request) ProtoMessage ¶
func (*Request) ProtoMessage()
func (*Request) ProtoReflect ¶
func (x *Request) ProtoReflect() protoreflect.Message
type Response ¶
type Response struct { Code ResponseCode `protobuf:"varint,1,opt,name=code,proto3,enum=ResponseCode" json:"code,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"` Error string `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"` Total int64 `protobuf:"varint,5,opt,name=total,proto3" json:"total,omitempty"` // contains filtered or unexported fields }
func (*Response) Descriptor
deprecated
func (*Response) GetCode ¶
func (x *Response) GetCode() ResponseCode
func (*Response) GetMessage ¶
func (*Response) ProtoMessage ¶
func (*Response) ProtoMessage()
func (*Response) ProtoReflect ¶
func (x *Response) ProtoReflect() protoreflect.Message
type ResponseCode ¶
type ResponseCode int32
const ( ResponseCode_OK ResponseCode = 0 ResponseCode_ERROR ResponseCode = 1 )
func (ResponseCode) Descriptor ¶
func (ResponseCode) Descriptor() protoreflect.EnumDescriptor
func (ResponseCode) Enum ¶
func (x ResponseCode) Enum() *ResponseCode
func (ResponseCode) EnumDescriptor
deprecated
func (ResponseCode) EnumDescriptor() ([]byte, []int)
Deprecated: Use ResponseCode.Descriptor instead.
func (ResponseCode) Number ¶
func (x ResponseCode) Number() protoreflect.EnumNumber
func (ResponseCode) String ¶
func (x ResponseCode) String() string
func (ResponseCode) Type ¶
func (ResponseCode) Type() protoreflect.EnumType
type StreamMessage ¶
type StreamMessage struct { Code StreamMessageCode `protobuf:"varint,1,opt,name=code,proto3,enum=grpc.StreamMessageCode" json:"code,omitempty"` NodeKey string `protobuf:"bytes,2,opt,name=node_key,json=nodeKey,proto3" json:"node_key,omitempty"` Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"` Error string `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"` // contains filtered or unexported fields }
func (*StreamMessage) Descriptor
deprecated
func (*StreamMessage) Descriptor() ([]byte, []int)
Deprecated: Use StreamMessage.ProtoReflect.Descriptor instead.
func (*StreamMessage) GetCode ¶
func (x *StreamMessage) GetCode() StreamMessageCode
func (*StreamMessage) GetData ¶
func (x *StreamMessage) GetData() []byte
func (*StreamMessage) GetError ¶
func (x *StreamMessage) GetError() string
func (*StreamMessage) GetNodeKey ¶
func (x *StreamMessage) GetNodeKey() string
func (*StreamMessage) ProtoMessage ¶
func (*StreamMessage) ProtoMessage()
func (*StreamMessage) ProtoReflect ¶
func (x *StreamMessage) ProtoReflect() protoreflect.Message
func (*StreamMessage) Reset ¶
func (x *StreamMessage) Reset()
func (*StreamMessage) String ¶
func (x *StreamMessage) String() string
type StreamMessageCode ¶
type StreamMessageCode int32
const ( // ping worker nodes to check their health StreamMessageCode_PING StreamMessageCode = 0 // ask worker node(s) to run task with given id StreamMessageCode_RUN_TASK StreamMessageCode = 1 // ask worker node(s) to cancel task with given id StreamMessageCode_CANCEL_TASK StreamMessageCode = 2 // insert data StreamMessageCode_INSERT_DATA StreamMessageCode = 3 // insert logs StreamMessageCode_INSERT_LOGS StreamMessageCode = 4 )
func (StreamMessageCode) Descriptor ¶
func (StreamMessageCode) Descriptor() protoreflect.EnumDescriptor
func (StreamMessageCode) Enum ¶
func (x StreamMessageCode) Enum() *StreamMessageCode
func (StreamMessageCode) EnumDescriptor
deprecated
func (StreamMessageCode) EnumDescriptor() ([]byte, []int)
Deprecated: Use StreamMessageCode.Descriptor instead.
func (StreamMessageCode) Number ¶
func (x StreamMessageCode) Number() protoreflect.EnumNumber
func (StreamMessageCode) String ¶
func (x StreamMessageCode) String() string
func (StreamMessageCode) Type ¶
func (StreamMessageCode) Type() protoreflect.EnumType
type StreamMessageDataTask ¶
type StreamMessageDataTask struct { TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"` Data string `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*StreamMessageDataTask) Descriptor
deprecated
func (*StreamMessageDataTask) Descriptor() ([]byte, []int)
Deprecated: Use StreamMessageDataTask.ProtoReflect.Descriptor instead.
func (*StreamMessageDataTask) GetData ¶
func (x *StreamMessageDataTask) GetData() string
func (*StreamMessageDataTask) GetTaskId ¶
func (x *StreamMessageDataTask) GetTaskId() string
func (*StreamMessageDataTask) ProtoMessage ¶
func (*StreamMessageDataTask) ProtoMessage()
func (*StreamMessageDataTask) ProtoReflect ¶
func (x *StreamMessageDataTask) ProtoReflect() protoreflect.Message
func (*StreamMessageDataTask) Reset ¶
func (x *StreamMessageDataTask) Reset()
func (*StreamMessageDataTask) String ¶
func (x *StreamMessageDataTask) String() string
type Task ¶
type Task struct { XId string `protobuf:"bytes,1,opt,name=_id,json=Id,proto3" json:"_id,omitempty"` SpiderId string `protobuf:"bytes,2,opt,name=spider_id,json=spiderId,proto3" json:"spider_id,omitempty"` Status string `protobuf:"bytes,5,opt,name=status,proto3" json:"status,omitempty"` NodeId string `protobuf:"bytes,6,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"` Cmd string `protobuf:"bytes,8,opt,name=cmd,proto3" json:"cmd,omitempty"` Param string `protobuf:"bytes,9,opt,name=param,proto3" json:"param,omitempty"` Error string `protobuf:"bytes,10,opt,name=error,proto3" json:"error,omitempty"` Pid int32 `protobuf:"varint,16,opt,name=pid,proto3" json:"pid,omitempty"` RunType string `protobuf:"bytes,17,opt,name=run_type,json=runType,proto3" json:"run_type,omitempty"` ScheduleId string `protobuf:"bytes,18,opt,name=schedule_id,json=scheduleId,proto3" json:"schedule_id,omitempty"` Type string `protobuf:"bytes,19,opt,name=type,proto3" json:"type,omitempty"` // contains filtered or unexported fields }
func (*Task) Descriptor
deprecated
func (*Task) GetRunType ¶
func (*Task) GetScheduleId ¶
func (*Task) GetSpiderId ¶
func (*Task) ProtoMessage ¶
func (*Task) ProtoMessage()
func (*Task) ProtoReflect ¶
func (x *Task) ProtoReflect() protoreflect.Message
type TaskServiceClient ¶
type TaskServiceClient interface { Subscribe(ctx context.Context, opts ...grpc.CallOption) (TaskService_SubscribeClient, error) GetDataSource(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error) }
TaskServiceClient is the client API for TaskService 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 NewTaskServiceClient ¶
func NewTaskServiceClient(cc grpc.ClientConnInterface) TaskServiceClient
type TaskServiceServer ¶
type TaskServiceServer interface { Subscribe(TaskService_SubscribeServer) error GetDataSource(context.Context, *Request) (*Response, error) // contains filtered or unexported methods }
TaskServiceServer is the server API for TaskService service. All implementations must embed UnimplementedTaskServiceServer for forward compatibility
type TaskService_SubscribeClient ¶
type TaskService_SubscribeClient interface { Send(*StreamMessage) error CloseAndRecv() (*Response, error) grpc.ClientStream }
type TaskService_SubscribeServer ¶
type TaskService_SubscribeServer interface { SendAndClose(*Response) error Recv() (*StreamMessage, error) grpc.ServerStream }
type UnimplementedModelBaseServiceServer ¶
type UnimplementedModelBaseServiceServer struct { }
UnimplementedModelBaseServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedModelBaseServiceServer) DeleteById ¶
func (UnimplementedModelBaseServiceServer) DeleteList ¶
func (UnimplementedModelBaseServiceServer) ForceDeleteList ¶
func (UnimplementedModelBaseServiceServer) UpdateById ¶
type UnimplementedModelDelegateServer ¶
type UnimplementedModelDelegateServer struct { }
UnimplementedModelDelegateServer must be embedded to have forward compatible implementations.
type UnimplementedNodeServiceServer ¶
type UnimplementedNodeServiceServer struct { }
UnimplementedNodeServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedNodeServiceServer) SendHeartbeat ¶
func (UnimplementedNodeServiceServer) Subscribe ¶
func (UnimplementedNodeServiceServer) Subscribe(*Request, NodeService_SubscribeServer) error
func (UnimplementedNodeServiceServer) Unsubscribe ¶
type UnimplementedPluginServiceServer ¶
type UnimplementedPluginServiceServer struct { }
UnimplementedPluginServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedPluginServiceServer) Subscribe ¶
func (UnimplementedPluginServiceServer) Subscribe(PluginService_SubscribeServer) error
type UnimplementedTaskServiceServer ¶
type UnimplementedTaskServiceServer struct { }
UnimplementedTaskServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedTaskServiceServer) GetDataSource ¶
func (UnimplementedTaskServiceServer) Subscribe ¶
func (UnimplementedTaskServiceServer) Subscribe(TaskService_SubscribeServer) error
type UnsafeModelBaseServiceServer ¶
type UnsafeModelBaseServiceServer interface {
// contains filtered or unexported methods
}
UnsafeModelBaseServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ModelBaseServiceServer will result in compilation errors.
type UnsafeModelDelegateServer ¶
type UnsafeModelDelegateServer interface {
// contains filtered or unexported methods
}
UnsafeModelDelegateServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ModelDelegateServer will result in compilation errors.
type UnsafeNodeServiceServer ¶
type UnsafeNodeServiceServer interface {
// contains filtered or unexported methods
}
UnsafeNodeServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to NodeServiceServer will result in compilation errors.
type UnsafePluginServiceServer ¶
type UnsafePluginServiceServer interface {
// contains filtered or unexported methods
}
UnsafePluginServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to PluginServiceServer will result in compilation errors.
type UnsafeTaskServiceServer ¶
type UnsafeTaskServiceServer interface {
// contains filtered or unexported methods
}
UnsafeTaskServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TaskServiceServer will result in compilation errors.
Source Files ¶
- model_base_service.pb.go
- model_base_service_grpc.pb.go
- model_delegate.pb.go
- model_delegate_grpc.pb.go
- node.pb.go
- node_info.pb.go
- node_service.pb.go
- node_service_grpc.pb.go
- plugin_service.pb.go
- plugin_service_grpc.pb.go
- request.pb.go
- response.pb.go
- response_code.pb.go
- stream_message.pb.go
- stream_message_code.pb.go
- stream_message_data_task.pb.go
- task.pb.go
- task_service.pb.go
- task_service_grpc.pb.go