grpc

package
v0.0.0-...-32fa971 Latest Latest
Warning

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

Go to latest
Published: Nov 18, 2023 License: MIT Imports: 10 Imported by: 2

Documentation

Overview

* * Generated by go-doudou v2.0.1. * Don't edit!

Index

Constants

This section is empty.

Variables

View Source
var File_transport_grpc_wordcloudtask_proto protoreflect.FileDescriptor
View Source
var MethodAnnotationStore = framework.AnnotationStore{}
View Source
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) Descriptor() ([]byte, []int)

Deprecated: Use Filter.ProtoReflect.Descriptor instead.

func (*Filter) GetUserId

func (x *Filter) GetUserId() int32

func (*Filter) ProtoMessage

func (*Filter) ProtoMessage()

func (*Filter) ProtoReflect

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

func (*Filter) Reset

func (x *Filter) Reset()

func (*Filter) String

func (x *Filter) String() string

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

Deprecated: Use Order.ProtoReflect.Descriptor instead.

func (*Order) GetCol

func (x *Order) GetCol() string

func (*Order) GetSort

func (x *Order) GetSort() string

func (*Order) ProtoMessage

func (*Order) ProtoMessage()

func (*Order) ProtoReflect

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

func (*Order) Reset

func (x *Order) Reset()

func (*Order) String

func (x *Order) String() string

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

Deprecated: Use Page.ProtoReflect.Descriptor instead.

func (*Page) GetOrders

func (x *Page) GetOrders() []*Order

func (*Page) GetPageNo

func (x *Page) GetPageNo() int32

func (*Page) GetSize

func (x *Page) GetSize() int32

func (*Page) ProtoMessage

func (*Page) ProtoMessage()

func (*Page) ProtoReflect

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

func (*Page) Reset

func (x *Page) Reset()

func (*Page) String

func (x *Page) String() string

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

Deprecated: Use PageQuery.ProtoReflect.Descriptor instead.

func (*PageQuery) GetFilter

func (x *PageQuery) GetFilter() *Filter

func (*PageQuery) GetPage

func (x *PageQuery) GetPage() *Page

func (*PageQuery) ProtoMessage

func (*PageQuery) ProtoMessage()

func (*PageQuery) ProtoReflect

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

func (*PageQuery) Reset

func (x *PageQuery) Reset()

func (*PageQuery) String

func (x *PageQuery) String() string

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

Deprecated: Use PageRet.ProtoReflect.Descriptor instead.

func (*PageRet) GetHasNext

func (x *PageRet) GetHasNext() bool

func (*PageRet) GetItems

func (x *PageRet) GetItems() *anypb.Any

func (*PageRet) GetPageNo

func (x *PageRet) GetPageNo() int32

func (*PageRet) GetPageSize

func (x *PageRet) GetPageSize() int32

func (*PageRet) GetTotal

func (x *PageRet) GetTotal() int32

func (*PageRet) ProtoMessage

func (*PageRet) ProtoMessage()

func (*PageRet) ProtoReflect

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

func (*PageRet) Reset

func (x *PageRet) Reset()

func (*PageRet) String

func (x *PageRet) String() string

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

Deprecated: Use TaskFail.ProtoReflect.Descriptor instead.

func (*TaskFail) GetError

func (x *TaskFail) GetError() string

func (*TaskFail) GetTaskId

func (x *TaskFail) GetTaskId() int32

func (*TaskFail) ProtoMessage

func (*TaskFail) ProtoMessage()

func (*TaskFail) ProtoReflect

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

func (*TaskFail) Reset

func (x *TaskFail) Reset()

func (*TaskFail) String

func (x *TaskFail) String() string

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

Deprecated: Use TaskVo.ProtoReflect.Descriptor instead.

func (*TaskVo) GetCreateAt

func (x *TaskVo) GetCreateAt() string

func (*TaskVo) GetError

func (x *TaskVo) GetError() string

func (*TaskVo) GetId

func (x *TaskVo) GetId() int32

func (*TaskVo) GetImgUrl

func (x *TaskVo) GetImgUrl() string

func (*TaskVo) GetLang

func (x *TaskVo) GetLang() string

func (*TaskVo) GetSrcUrl

func (x *TaskVo) GetSrcUrl() string

func (*TaskVo) GetStatus

func (x *TaskVo) GetStatus() int32

func (*TaskVo) GetTop

func (x *TaskVo) GetTop() int32

func (*TaskVo) GetUserId

func (x *TaskVo) GetUserId() int32

func (*TaskVo) ProtoMessage

func (*TaskVo) ProtoMessage()

func (*TaskVo) ProtoReflect

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

func (*TaskVo) Reset

func (x *TaskVo) Reset()

func (*TaskVo) String

func (x *TaskVo) String() string

type UnimplementedWordcloudTaskServiceServer

type UnimplementedWordcloudTaskServiceServer struct {
}

UnimplementedWordcloudTaskServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedWordcloudTaskServiceServer) TaskFailRpc

func (UnimplementedWordcloudTaskServiceServer) TaskPageRpc

func (UnimplementedWordcloudTaskServiceServer) TaskSaveRpc

func (UnimplementedWordcloudTaskServiceServer) TaskSuccessRpc

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.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL