Documentation ¶
Overview ¶
* * Generated by go-doudou v2.0.1. * Don't edit!
Index ¶
- Variables
- func RegisterWordcloudTaskServiceServer(s grpc.ServiceRegistrar, srv WordcloudTaskServiceServer)
- type Filter
- type Order
- type Page
- type PageQuery
- type PageRet
- func (*PageRet) Descriptor() ([]byte, []int)deprecated
- func (x *PageRet) GetHasNext() bool
- func (x *PageRet) GetItems() *anypb.Any
- func (x *PageRet) GetPageNo() int32
- func (x *PageRet) GetPageSize() int32
- func (x *PageRet) GetTotal() int32
- func (*PageRet) ProtoMessage()
- func (x *PageRet) ProtoReflect() protoreflect.Message
- func (x *PageRet) Reset()
- func (x *PageRet) String() string
- type TaskFail
- type TaskFailRpcResponse
- func (*TaskFailRpcResponse) Descriptor() ([]byte, []int)deprecated
- func (x *TaskFailRpcResponse) GetData() string
- func (*TaskFailRpcResponse) ProtoMessage()
- func (x *TaskFailRpcResponse) ProtoReflect() protoreflect.Message
- func (x *TaskFailRpcResponse) Reset()
- func (x *TaskFailRpcResponse) String() string
- type TaskPageRet
- func (*TaskPageRet) Descriptor() ([]byte, []int)deprecated
- func (x *TaskPageRet) GetHasNext() bool
- func (x *TaskPageRet) GetItems() []*TaskVo
- func (x *TaskPageRet) GetPageNo() int32
- func (x *TaskPageRet) GetPageSize() int32
- func (x *TaskPageRet) GetTotal() int32
- func (*TaskPageRet) ProtoMessage()
- func (x *TaskPageRet) ProtoReflect() protoreflect.Message
- func (x *TaskPageRet) Reset()
- func (x *TaskPageRet) String() string
- type TaskPayload
- func (*TaskPayload) Descriptor() ([]byte, []int)deprecated
- func (x *TaskPayload) GetLang() string
- func (x *TaskPayload) GetSrcUrl() string
- func (x *TaskPayload) GetTop() int32
- func (x *TaskPayload) GetUserId() int32
- func (*TaskPayload) ProtoMessage()
- func (x *TaskPayload) ProtoReflect() protoreflect.Message
- func (x *TaskPayload) Reset()
- func (x *TaskPayload) String() string
- type TaskSaveRpcResponse
- func (*TaskSaveRpcResponse) Descriptor() ([]byte, []int)deprecated
- func (x *TaskSaveRpcResponse) GetData() int32
- func (*TaskSaveRpcResponse) ProtoMessage()
- func (x *TaskSaveRpcResponse) ProtoReflect() protoreflect.Message
- func (x *TaskSaveRpcResponse) Reset()
- func (x *TaskSaveRpcResponse) String() string
- type TaskSuccess
- func (*TaskSuccess) Descriptor() ([]byte, []int)deprecated
- func (x *TaskSuccess) GetImgUrl() string
- func (x *TaskSuccess) GetTaskId() int32
- func (*TaskSuccess) ProtoMessage()
- func (x *TaskSuccess) ProtoReflect() protoreflect.Message
- func (x *TaskSuccess) Reset()
- func (x *TaskSuccess) String() string
- type TaskSuccessRpcResponse
- func (*TaskSuccessRpcResponse) Descriptor() ([]byte, []int)deprecated
- func (x *TaskSuccessRpcResponse) GetData() string
- func (*TaskSuccessRpcResponse) ProtoMessage()
- func (x *TaskSuccessRpcResponse) ProtoReflect() protoreflect.Message
- func (x *TaskSuccessRpcResponse) Reset()
- func (x *TaskSuccessRpcResponse) String() string
- type TaskVo
- func (*TaskVo) Descriptor() ([]byte, []int)deprecated
- func (x *TaskVo) GetCreateAt() string
- func (x *TaskVo) GetError() string
- func (x *TaskVo) GetId() int32
- func (x *TaskVo) GetImgUrl() string
- func (x *TaskVo) GetLang() string
- func (x *TaskVo) GetSrcUrl() string
- func (x *TaskVo) GetStatus() int32
- func (x *TaskVo) GetTop() int32
- func (x *TaskVo) GetUserId() int32
- func (*TaskVo) ProtoMessage()
- func (x *TaskVo) ProtoReflect() protoreflect.Message
- func (x *TaskVo) Reset()
- func (x *TaskVo) String() string
- type UnimplementedWordcloudTaskServiceServer
- func (UnimplementedWordcloudTaskServiceServer) TaskFailRpc(context.Context, *TaskFail) (*TaskFailRpcResponse, error)
- func (UnimplementedWordcloudTaskServiceServer) TaskPageRpc(context.Context, *PageQuery) (*TaskPageRet, error)
- func (UnimplementedWordcloudTaskServiceServer) TaskSaveRpc(context.Context, *TaskPayload) (*TaskSaveRpcResponse, error)
- func (UnimplementedWordcloudTaskServiceServer) TaskSuccessRpc(context.Context, *TaskSuccess) (*TaskSuccessRpcResponse, error)
- type UnsafeWordcloudTaskServiceServer
- type WordcloudTaskServiceClient
- type WordcloudTaskServiceServer
Constants ¶
This section is empty.
Variables ¶
var File_transport_grpc_wordcloudtask_proto protoreflect.FileDescriptor
var MethodAnnotationStore = framework.AnnotationStore{}
var WordcloudTaskService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "wordcloud_task.WordcloudTaskService", HandlerType: (*WordcloudTaskServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "TaskSaveRpc", Handler: _WordcloudTaskService_TaskSaveRpc_Handler, }, { MethodName: "TaskSuccessRpc", Handler: _WordcloudTaskService_TaskSuccessRpc_Handler, }, { MethodName: "TaskFailRpc", Handler: _WordcloudTaskService_TaskFailRpc_Handler, }, { MethodName: "TaskPageRpc", Handler: _WordcloudTaskService_TaskPageRpc_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "transport/grpc/wordcloudtask.proto", }
WordcloudTaskService_ServiceDesc is the grpc.ServiceDesc for WordcloudTaskService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterWordcloudTaskServiceServer ¶
func RegisterWordcloudTaskServiceServer(s grpc.ServiceRegistrar, srv WordcloudTaskServiceServer)
Types ¶
type Filter ¶
type Filter struct { UserId int32 `protobuf:"varint,1,opt,name=userId,proto3" json:"userId,omitempty"` // contains filtered or unexported fields }
func (*Filter) Descriptor
deprecated
func (*Filter) ProtoMessage ¶
func (*Filter) ProtoMessage()
func (*Filter) ProtoReflect ¶
func (x *Filter) ProtoReflect() protoreflect.Message
type Order ¶
type Order struct { Col string `protobuf:"bytes,1,opt,name=col,proto3" json:"col,omitempty"` Sort string `protobuf:"bytes,2,opt,name=sort,proto3" json:"sort,omitempty"` // contains filtered or unexported fields }
func (*Order) Descriptor
deprecated
func (*Order) ProtoMessage ¶
func (*Order) ProtoMessage()
func (*Order) ProtoReflect ¶
func (x *Order) ProtoReflect() protoreflect.Message
type Page ¶
type Page struct { // 排序规则 Orders []*Order `protobuf:"bytes,1,rep,name=orders,proto3" json:"orders,omitempty"` // 页码 PageNo int32 `protobuf:"varint,2,opt,name=pageNo,proto3" json:"pageNo,omitempty"` // 每页行数 Size int32 `protobuf:"varint,3,opt,name=size,proto3" json:"size,omitempty"` // contains filtered or unexported fields }
func (*Page) Descriptor
deprecated
func (*Page) ProtoMessage ¶
func (*Page) ProtoMessage()
func (*Page) ProtoReflect ¶
func (x *Page) ProtoReflect() protoreflect.Message
type PageQuery ¶
type PageQuery struct { Filter *Filter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"` Page *Page `protobuf:"bytes,2,opt,name=page,proto3" json:"page,omitempty"` // contains filtered or unexported fields }
分页筛选条件
func (*PageQuery) Descriptor
deprecated
func (*PageQuery) ProtoMessage ¶
func (*PageQuery) ProtoMessage()
func (*PageQuery) ProtoReflect ¶
func (x *PageQuery) ProtoReflect() protoreflect.Message
type PageRet ¶
type PageRet struct { Items *anypb.Any `protobuf:"bytes,1,opt,name=items,proto3" json:"items,omitempty"` PageNo int32 `protobuf:"varint,2,opt,name=pageNo,proto3" json:"pageNo,omitempty"` PageSize int32 `protobuf:"varint,3,opt,name=pageSize,proto3" json:"pageSize,omitempty"` Total int32 `protobuf:"varint,4,opt,name=total,proto3" json:"total,omitempty"` HasNext bool `protobuf:"varint,5,opt,name=hasNext,proto3" json:"hasNext,omitempty"` // contains filtered or unexported fields }
func (*PageRet) Descriptor
deprecated
func (*PageRet) GetHasNext ¶
func (*PageRet) GetPageSize ¶
func (*PageRet) ProtoMessage ¶
func (*PageRet) ProtoMessage()
func (*PageRet) ProtoReflect ¶
func (x *PageRet) ProtoReflect() protoreflect.Message
type TaskFail ¶
type TaskFail struct { // task ID // 任务ID TaskId int32 `protobuf:"varint,1,opt,name=taskId,proto3" json:"taskId,omitempty"` // error message // 错误信息 Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"` // contains filtered or unexported fields }
func (*TaskFail) Descriptor
deprecated
func (*TaskFail) ProtoMessage ¶
func (*TaskFail) ProtoMessage()
func (*TaskFail) ProtoReflect ¶
func (x *TaskFail) ProtoReflect() protoreflect.Message
type TaskFailRpcResponse ¶
type TaskFailRpcResponse struct { // return OK if success // 成功返回OK Data string `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*TaskFailRpcResponse) Descriptor
deprecated
func (*TaskFailRpcResponse) Descriptor() ([]byte, []int)
Deprecated: Use TaskFailRpcResponse.ProtoReflect.Descriptor instead.
func (*TaskFailRpcResponse) GetData ¶
func (x *TaskFailRpcResponse) GetData() string
func (*TaskFailRpcResponse) ProtoMessage ¶
func (*TaskFailRpcResponse) ProtoMessage()
func (*TaskFailRpcResponse) ProtoReflect ¶
func (x *TaskFailRpcResponse) ProtoReflect() protoreflect.Message
func (*TaskFailRpcResponse) Reset ¶
func (x *TaskFailRpcResponse) Reset()
func (*TaskFailRpcResponse) String ¶
func (x *TaskFailRpcResponse) String() string
type TaskPageRet ¶
type TaskPageRet struct { Items []*TaskVo `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"` PageSize int32 `protobuf:"varint,2,opt,name=pageSize,proto3" json:"pageSize,omitempty"` Total int32 `protobuf:"varint,3,opt,name=total,proto3" json:"total,omitempty"` HasNext bool `protobuf:"varint,4,opt,name=hasNext,proto3" json:"hasNext,omitempty"` PageNo int32 `protobuf:"varint,5,opt,name=pageNo,proto3" json:"pageNo,omitempty"` // contains filtered or unexported fields }
func (*TaskPageRet) Descriptor
deprecated
func (*TaskPageRet) Descriptor() ([]byte, []int)
Deprecated: Use TaskPageRet.ProtoReflect.Descriptor instead.
func (*TaskPageRet) GetHasNext ¶
func (x *TaskPageRet) GetHasNext() bool
func (*TaskPageRet) GetItems ¶
func (x *TaskPageRet) GetItems() []*TaskVo
func (*TaskPageRet) GetPageNo ¶
func (x *TaskPageRet) GetPageNo() int32
func (*TaskPageRet) GetPageSize ¶
func (x *TaskPageRet) GetPageSize() int32
func (*TaskPageRet) GetTotal ¶
func (x *TaskPageRet) GetTotal() int32
func (*TaskPageRet) ProtoMessage ¶
func (*TaskPageRet) ProtoMessage()
func (*TaskPageRet) ProtoReflect ¶
func (x *TaskPageRet) ProtoReflect() protoreflect.Message
func (*TaskPageRet) Reset ¶
func (x *TaskPageRet) Reset()
func (*TaskPageRet) String ¶
func (x *TaskPageRet) String() string
type TaskPayload ¶
type TaskPayload struct { // 用户ID // user ID UserId int32 `protobuf:"varint,1,opt,name=userId,proto3" json:"userId,omitempty"` // source file url 原文件链接 SrcUrl string `protobuf:"bytes,2,opt,name=srcUrl,proto3" json:"srcUrl,omitempty"` Lang string `protobuf:"bytes,3,opt,name=lang,proto3" json:"lang,omitempty"` Top int32 `protobuf:"varint,4,opt,name=top,proto3" json:"top,omitempty"` // contains filtered or unexported fields }
func (*TaskPayload) Descriptor
deprecated
func (*TaskPayload) Descriptor() ([]byte, []int)
Deprecated: Use TaskPayload.ProtoReflect.Descriptor instead.
func (*TaskPayload) GetLang ¶
func (x *TaskPayload) GetLang() string
func (*TaskPayload) GetSrcUrl ¶
func (x *TaskPayload) GetSrcUrl() string
func (*TaskPayload) GetTop ¶
func (x *TaskPayload) GetTop() int32
func (*TaskPayload) GetUserId ¶
func (x *TaskPayload) GetUserId() int32
func (*TaskPayload) ProtoMessage ¶
func (*TaskPayload) ProtoMessage()
func (*TaskPayload) ProtoReflect ¶
func (x *TaskPayload) ProtoReflect() protoreflect.Message
func (*TaskPayload) Reset ¶
func (x *TaskPayload) Reset()
func (*TaskPayload) String ¶
func (x *TaskPayload) String() string
type TaskSaveRpcResponse ¶
type TaskSaveRpcResponse struct { // task ID 任务ID Data int32 `protobuf:"varint,1,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*TaskSaveRpcResponse) Descriptor
deprecated
func (*TaskSaveRpcResponse) Descriptor() ([]byte, []int)
Deprecated: Use TaskSaveRpcResponse.ProtoReflect.Descriptor instead.
func (*TaskSaveRpcResponse) GetData ¶
func (x *TaskSaveRpcResponse) GetData() int32
func (*TaskSaveRpcResponse) ProtoMessage ¶
func (*TaskSaveRpcResponse) ProtoMessage()
func (*TaskSaveRpcResponse) ProtoReflect ¶
func (x *TaskSaveRpcResponse) ProtoReflect() protoreflect.Message
func (*TaskSaveRpcResponse) Reset ¶
func (x *TaskSaveRpcResponse) Reset()
func (*TaskSaveRpcResponse) String ¶
func (x *TaskSaveRpcResponse) String() string
type TaskSuccess ¶
type TaskSuccess struct { // task ID // 任务ID TaskId int32 `protobuf:"varint,1,opt,name=taskId,proto3" json:"taskId,omitempty"` // word cloud image url // 词云图链接 ImgUrl string `protobuf:"bytes,2,opt,name=imgUrl,proto3" json:"imgUrl,omitempty"` // contains filtered or unexported fields }
func (*TaskSuccess) Descriptor
deprecated
func (*TaskSuccess) Descriptor() ([]byte, []int)
Deprecated: Use TaskSuccess.ProtoReflect.Descriptor instead.
func (*TaskSuccess) GetImgUrl ¶
func (x *TaskSuccess) GetImgUrl() string
func (*TaskSuccess) GetTaskId ¶
func (x *TaskSuccess) GetTaskId() int32
func (*TaskSuccess) ProtoMessage ¶
func (*TaskSuccess) ProtoMessage()
func (*TaskSuccess) ProtoReflect ¶
func (x *TaskSuccess) ProtoReflect() protoreflect.Message
func (*TaskSuccess) Reset ¶
func (x *TaskSuccess) Reset()
func (*TaskSuccess) String ¶
func (x *TaskSuccess) String() string
type TaskSuccessRpcResponse ¶
type TaskSuccessRpcResponse struct { // return OK if success // 成功返回OK Data string `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*TaskSuccessRpcResponse) Descriptor
deprecated
func (*TaskSuccessRpcResponse) Descriptor() ([]byte, []int)
Deprecated: Use TaskSuccessRpcResponse.ProtoReflect.Descriptor instead.
func (*TaskSuccessRpcResponse) GetData ¶
func (x *TaskSuccessRpcResponse) GetData() string
func (*TaskSuccessRpcResponse) ProtoMessage ¶
func (*TaskSuccessRpcResponse) ProtoMessage()
func (*TaskSuccessRpcResponse) ProtoReflect ¶
func (x *TaskSuccessRpcResponse) ProtoReflect() protoreflect.Message
func (*TaskSuccessRpcResponse) Reset ¶
func (x *TaskSuccessRpcResponse) Reset()
func (*TaskSuccessRpcResponse) String ¶
func (x *TaskSuccessRpcResponse) String() string
type TaskVo ¶
type TaskVo struct { Id int32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` SrcUrl string `protobuf:"bytes,2,opt,name=srcUrl,proto3" json:"srcUrl,omitempty"` ImgUrl string `protobuf:"bytes,3,opt,name=imgUrl,proto3" json:"imgUrl,omitempty"` Lang string `protobuf:"bytes,4,opt,name=lang,proto3" json:"lang,omitempty"` Top int32 `protobuf:"varint,5,opt,name=top,proto3" json:"top,omitempty"` Status int32 `protobuf:"varint,6,opt,name=status,proto3" json:"status,omitempty"` Error string `protobuf:"bytes,7,opt,name=error,proto3" json:"error,omitempty"` UserId int32 `protobuf:"varint,8,opt,name=userId,proto3" json:"userId,omitempty"` CreateAt string `protobuf:"bytes,9,opt,name=createAt,proto3" json:"createAt,omitempty"` // contains filtered or unexported fields }
func (*TaskVo) Descriptor
deprecated
func (*TaskVo) GetCreateAt ¶
func (*TaskVo) ProtoMessage ¶
func (*TaskVo) ProtoMessage()
func (*TaskVo) ProtoReflect ¶
func (x *TaskVo) ProtoReflect() protoreflect.Message
type UnimplementedWordcloudTaskServiceServer ¶
type UnimplementedWordcloudTaskServiceServer struct { }
UnimplementedWordcloudTaskServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedWordcloudTaskServiceServer) TaskFailRpc ¶
func (UnimplementedWordcloudTaskServiceServer) TaskFailRpc(context.Context, *TaskFail) (*TaskFailRpcResponse, error)
func (UnimplementedWordcloudTaskServiceServer) TaskPageRpc ¶
func (UnimplementedWordcloudTaskServiceServer) TaskPageRpc(context.Context, *PageQuery) (*TaskPageRet, error)
func (UnimplementedWordcloudTaskServiceServer) TaskSaveRpc ¶
func (UnimplementedWordcloudTaskServiceServer) TaskSaveRpc(context.Context, *TaskPayload) (*TaskSaveRpcResponse, error)
func (UnimplementedWordcloudTaskServiceServer) TaskSuccessRpc ¶
func (UnimplementedWordcloudTaskServiceServer) TaskSuccessRpc(context.Context, *TaskSuccess) (*TaskSuccessRpcResponse, error)
type UnsafeWordcloudTaskServiceServer ¶
type UnsafeWordcloudTaskServiceServer interface {
// contains filtered or unexported methods
}
UnsafeWordcloudTaskServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to WordcloudTaskServiceServer will result in compilation errors.
type WordcloudTaskServiceClient ¶
type WordcloudTaskServiceClient interface { // TaskSave save word cloud task 保存词云图任务 TaskSaveRpc(ctx context.Context, in *TaskPayload, opts ...grpc.CallOption) (*TaskSaveRpcResponse, error) // TaskSuccess task success 任务执行成功接口 TaskSuccessRpc(ctx context.Context, in *TaskSuccess, opts ...grpc.CallOption) (*TaskSuccessRpcResponse, error) // TaskFail task fail 任务执行失败接口 TaskFailRpc(ctx context.Context, in *TaskFail, opts ...grpc.CallOption) (*TaskFailRpcResponse, error) // TaskPage TaskPageRpc(ctx context.Context, in *PageQuery, opts ...grpc.CallOption) (*TaskPageRet, error) }
WordcloudTaskServiceClient is the client API for WordcloudTaskService 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 NewWordcloudTaskServiceClient ¶
func NewWordcloudTaskServiceClient(cc grpc.ClientConnInterface) WordcloudTaskServiceClient
type WordcloudTaskServiceServer ¶
type WordcloudTaskServiceServer interface { // TaskSave save word cloud task 保存词云图任务 TaskSaveRpc(context.Context, *TaskPayload) (*TaskSaveRpcResponse, error) // TaskSuccess task success 任务执行成功接口 TaskSuccessRpc(context.Context, *TaskSuccess) (*TaskSuccessRpcResponse, error) // TaskFail task fail 任务执行失败接口 TaskFailRpc(context.Context, *TaskFail) (*TaskFailRpcResponse, error) // TaskPage TaskPageRpc(context.Context, *PageQuery) (*TaskPageRet, error) // contains filtered or unexported methods }
WordcloudTaskServiceServer is the server API for WordcloudTaskService service. All implementations must embed UnimplementedWordcloudTaskServiceServer for forward compatibility