grpc

package module
v0.1.0 Latest Latest
Warning

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

 Go to latest Published: Jul 15, 2021 License: BSD-3-Clause Imports: 9 Imported by: 44

README

crawlab-grpc

gRPC for Crawlab

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ResponseCode_name = map[int32]string{
		0: "OK",
		1: "ERROR",
	}
	ResponseCode_value = map[string]int32{
		"OK":    0,
		"ERROR": 1,
	}
)

Enum value maps for ResponseCode.

View Source 
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.

View Source 
var File_entity_node_info_proto protoreflect.FileDescriptor
View Source 
var File_entity_request_proto protoreflect.FileDescriptor
View Source 
var File_entity_response_code_proto protoreflect.FileDescriptor
View Source 
var File_entity_response_proto protoreflect.FileDescriptor
View Source 
var File_entity_stream_message_code_proto protoreflect.FileDescriptor
View Source 
var File_entity_stream_message_data_task_proto protoreflect.FileDescriptor
View Source 
var File_entity_stream_message_proto protoreflect.FileDescriptor
View Source 
var File_models_node_proto protoreflect.FileDescriptor
View Source 
var File_models_task_proto protoreflect.FileDescriptor
View Source 
var File_services_model_base_service_proto protoreflect.FileDescriptor
View Source 
var File_services_model_delegate_proto protoreflect.FileDescriptor
View Source 
var File_services_node_service_proto protoreflect.FileDescriptor
View Source 
var File_services_plugin_service_proto protoreflect.FileDescriptor
View Source 
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) Descriptor() ([]byte, []int)

Deprecated: Use Node.ProtoReflect.Descriptor instead.

func (*Node) GetCreateTs 

func (x *Node) GetCreateTs() string

func (*Node) GetDescription 

func (x *Node) GetDescription() string

func (*Node) GetHostname 

func (x *Node) GetHostname() string

func (*Node) GetIp 

func (x *Node) GetIp() string

func (*Node) GetIsMaster 

func (x *Node) GetIsMaster() bool

func (*Node) GetKey 

func (x *Node) GetKey() string

func (*Node) GetMac 

func (x *Node) GetMac() string

func (*Node) GetName 

func (x *Node) GetName() string

func (*Node) GetPort 

func (x *Node) GetPort() string

func (*Node) GetUpdateTs 

func (x *Node) GetUpdateTs() string

func (*Node) GetUpdateTsUnix 

func (x *Node) GetUpdateTsUnix() int64

func (*Node) GetXId 

func (x *Node) GetXId() string

func (*Node) ProtoMessage 

func (*Node) ProtoMessage()

func (*Node) ProtoReflect 

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

func (*Node) Reset 

func (x *Node) Reset()

func (*Node) String 

func (x *Node) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use NodeInfo.ProtoReflect.Descriptor instead.

func (*NodeInfo) GetIsMaster 

func (x *NodeInfo) GetIsMaster() bool

func (*NodeInfo) GetKey 

func (x *NodeInfo) GetKey() string

func (*NodeInfo) ProtoMessage 

func (*NodeInfo) ProtoMessage()

func (*NodeInfo) ProtoReflect 

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

func (*NodeInfo) Reset 

func (x *NodeInfo) Reset()

func (*NodeInfo) String 

func (x *NodeInfo) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Request.ProtoReflect.Descriptor instead.

func (*Request) GetData 

func (x *Request) GetData() []byte

func (*Request) GetNodeKey 

func (x *Request) GetNodeKey() string

func (*Request) ProtoMessage 

func (*Request) ProtoMessage()

func (*Request) ProtoReflect 

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

func (*Request) Reset 

func (x *Request) Reset()

func (*Request) String 

func (x *Request) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Response.ProtoReflect.Descriptor instead.

func (*Response) GetCode 

func (x *Response) GetCode() ResponseCode

func (*Response) GetData 

func (x *Response) GetData() []byte

func (*Response) GetError 

func (x *Response) GetError() string

func (*Response) GetMessage 

func (x *Response) GetMessage() string

func (*Response) GetTotal 

func (x *Response) GetTotal() int64

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) ProtoReflect 

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

func (*Response) Reset 

func (x *Response) Reset()

func (*Response) String 

func (x *Response) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Task.ProtoReflect.Descriptor instead.

func (*Task) GetCmd 

func (x *Task) GetCmd() string

func (*Task) GetError 

func (x *Task) GetError() string

func (*Task) GetNodeId 

func (x *Task) GetNodeId() string

func (*Task) GetParam 

func (x *Task) GetParam() string

func (*Task) GetPid 

func (x *Task) GetPid() int32

func (*Task) GetRunType 

func (x *Task) GetRunType() string

func (*Task) GetScheduleId 

func (x *Task) GetScheduleId() string

func (*Task) GetSpiderId 

func (x *Task) GetSpiderId() string

func (*Task) GetStatus 

func (x *Task) GetStatus() string

func (*Task) GetType 

func (x *Task) GetType() string

func (*Task) GetXId 

func (x *Task) GetXId() string

func (*Task) ProtoMessage 

func (*Task) ProtoMessage()

func (*Task) ProtoReflect 

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

func (*Task) Reset 

func (x *Task) Reset()

func (*Task) String 

func (x *Task) String() string

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

func (UnimplementedModelBaseServiceServer) Count(context.Context, *Request) (*Response, error)

func (UnimplementedModelBaseServiceServer) Delete 

func (UnimplementedModelBaseServiceServer) Delete(context.Context, *Request) (*Response, error)

func (UnimplementedModelBaseServiceServer) DeleteById 

func (UnimplementedModelBaseServiceServer) DeleteById(context.Context, *Request) (*Response, error)

func (UnimplementedModelBaseServiceServer) DeleteList 

func (UnimplementedModelBaseServiceServer) DeleteList(context.Context, *Request) (*Response, error)

func (UnimplementedModelBaseServiceServer) ForceDeleteList 

func (UnimplementedModelBaseServiceServer) ForceDeleteList(context.Context, *Request) (*Response, error)

func (UnimplementedModelBaseServiceServer) Get 

func (UnimplementedModelBaseServiceServer) Get(context.Context, *Request) (*Response, error)

func (UnimplementedModelBaseServiceServer) GetById 

func (UnimplementedModelBaseServiceServer) GetById(context.Context, *Request) (*Response, error)

func (UnimplementedModelBaseServiceServer) GetList 

func (UnimplementedModelBaseServiceServer) GetList(context.Context, *Request) (*Response, error)

func (UnimplementedModelBaseServiceServer) Insert 

func (UnimplementedModelBaseServiceServer) Insert(context.Context, *Request) (*Response, error)

func (UnimplementedModelBaseServiceServer) Update 

func (UnimplementedModelBaseServiceServer) Update(context.Context, *Request) (*Response, error)

func (UnimplementedModelBaseServiceServer) UpdateById 

func (UnimplementedModelBaseServiceServer) UpdateById(context.Context, *Request) (*Response, error)

func (UnimplementedModelBaseServiceServer) UpdateDoc 

func (UnimplementedModelBaseServiceServer) UpdateDoc(context.Context, *Request) (*Response, error)

type UnimplementedModelDelegateServer 

type UnimplementedModelDelegateServer struct {
}

UnimplementedModelDelegateServer must be embedded to have forward compatible implementations.

func (UnimplementedModelDelegateServer) Do 

func (UnimplementedModelDelegateServer) Do(context.Context, *Request) (*Response, error)

type UnimplementedNodeServiceServer 

type UnimplementedNodeServiceServer struct {
}

UnimplementedNodeServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedNodeServiceServer) Ping 

func (UnimplementedNodeServiceServer) Ping(context.Context, *Request) (*Response, error)

func (UnimplementedNodeServiceServer) Register 

func (UnimplementedNodeServiceServer) Register(context.Context, *Request) (*Response, error)

func (UnimplementedNodeServiceServer) SendHeartbeat 

func (UnimplementedNodeServiceServer) SendHeartbeat(context.Context, *Request) (*Response, error)

func (UnimplementedNodeServiceServer) Subscribe 

func (UnimplementedNodeServiceServer) Subscribe(*Request, NodeService_SubscribeServer) error

func (UnimplementedNodeServiceServer) Unsubscribe 

func (UnimplementedNodeServiceServer) Unsubscribe(context.Context, *Request) (*Response, error)

type UnimplementedPluginServiceServer 

type UnimplementedPluginServiceServer struct {
}

UnimplementedPluginServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedPluginServiceServer) Register 

func (UnimplementedPluginServiceServer) Register(context.Context, *Request) (*Response, error)

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) GetDataSource(context.Context, *Request) (*Response, error)

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

View all Source files

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.