blog

package
v0.0.0-...-f4276bb Latest Latest
Warning

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

 Go to latest Published: Sep 23, 2023 License: MIT Imports: 8 Imported by: 0

README

业务定义

// protoc-gen-go 这个插件只生成 数据结构定义代码

// 在项目目录进行代码生成
// /e/Projects/Golang/go11/skill/rpc/protobuf

protoc -I=. --go_out=. --go_opt=module="gitee.com/go-course/go11/skill/rpc/protobuf" blog/pb/blog.proto

// 要生成接口定义的代码，需要使用独立的插件: protoc-gen-go-grpc // protoc-gen-go 插件的参数 --go_out= --go_opt= // protoc-gen-go-grpc 插件参数: --go-grpc_out="." --go-grpc_opt="xx"

// 在项目目录进行代码生成
// /e/Projects/Golang/go11/skill/rpc/protobuf

protoc -I=. --go_out=. --go-grpc_out=. --go_opt=module="gitee.com/go-course/go11/skill/rpc/protobuf" --go-grpc_opt=module="gitee.com/go-course/go11/skill/rpc/protobuf" blog/pb/blog.proto

go get google.golang.org/genproto

业务实现(RPC)

Documentation

Index

Constants

View Source 
const (
	BlogRpc_CreateBlog_FullMethodName   = "/go11.protobuf.blog.BlogRpc/CreateBlog"
	BlogRpc_UploadBlog_FullMethodName   = "/go11.protobuf.blog.BlogRpc/UploadBlog"
	BlogRpc_DownloadBlog_FullMethodName = "/go11.protobuf.blog.BlogRpc/DownloadBlog"
)

Variables

View Source 
var (
	STATUS_name = map[int32]string{
		0: "DRAFT",
		1: "PUBLIESHED",
	}
	STATUS_value = map[string]int32{
		"DRAFT":      0,
		"PUBLIESHED": 1,
	}
)

Enum value maps for STATUS.

View Source 
var BlogRpc_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "go11.protobuf.blog.BlogRpc",
	HandlerType: (*BlogRpcServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateBlog",
			Handler:    _BlogRpc_CreateBlog_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "UploadBlog",
			Handler:       _BlogRpc_UploadBlog_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "DownloadBlog",
			Handler:       _BlogRpc_DownloadBlog_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "blog/pb/blog.proto",
}

BlogRpc_ServiceDesc is the grpc.ServiceDesc for BlogRpc 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_blog_pb_blog_proto protoreflect.FileDescriptor

Functions

func RegisterBlogRpcServer 

func RegisterBlogRpcServer(s grpc.ServiceRegistrar, srv BlogRpcServer)

Types

type Blog 

type Blog struct {

	// Blog Meta数据
	Meta *Meta `protobuf:"bytes,1,opt,name=meta,proto3" json:"meta,omitempty"`
	// Blog具体的定义
	Spec *CreateBlogRequest `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

func (*Blog) Descriptor deprecated 

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

Deprecated: Use Blog.ProtoReflect.Descriptor instead.

func (*Blog) GetMeta 

func (x *Blog) GetMeta() *Meta

func (*Blog) GetSpec 

func (x *Blog) GetSpec() *CreateBlogRequest

func (*Blog) ProtoMessage 

func (*Blog) ProtoMessage()

func (*Blog) ProtoReflect 

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

func (*Blog) Reset 

func (x *Blog) Reset()

func (*Blog) String 

func (x *Blog) String() string

type BlogRpcClient 

type BlogRpcClient interface {
	// 创建博客的RPC
	CreateBlog(ctx context.Context, in *CreateBlogRequest, opts ...grpc.CallOption) (*Blog, error)
	// 定义一个 Client 流式请求
	UploadBlog(ctx context.Context, opts ...grpc.CallOption) (BlogRpc_UploadBlogClient, error)
	// 定义一个 Server 流式请求
	DownloadBlog(ctx context.Context, in *DownloadBlogRequest, opts ...grpc.CallOption) (BlogRpc_DownloadBlogClient, error)
}

BlogRpcClient is the client API for BlogRpc 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 NewBlogRpcClient 

func NewBlogRpcClient(cc grpc.ClientConnInterface) BlogRpcClient

type BlogRpcServer 

type BlogRpcServer interface {
	// 创建博客的RPC
	CreateBlog(context.Context, *CreateBlogRequest) (*Blog, error)
	// 定义一个 Client 流式请求
	UploadBlog(BlogRpc_UploadBlogServer) error
	// 定义一个 Server 流式请求
	DownloadBlog(*DownloadBlogRequest, BlogRpc_DownloadBlogServer) error
	// contains filtered or unexported methods
}

BlogRpcServer is the server API for BlogRpc service. All implementations must embed UnimplementedBlogRpcServer for forward compatibility

type BlogRpc_DownloadBlogClient 

type BlogRpc_DownloadBlogClient interface {
	Recv() (*DownloadBlogResponse, error)
	grpc.ClientStream
}

type BlogRpc_DownloadBlogServer 

type BlogRpc_DownloadBlogServer interface {
	Send(*DownloadBlogResponse) error
	grpc.ServerStream
}

type BlogRpc_UploadBlogClient 

type BlogRpc_UploadBlogClient interface {
	Send(*UploadBlogRequest) error
	CloseAndRecv() (*UploadBlogResponse, error)
	grpc.ClientStream
}

type BlogRpc_UploadBlogServer 

type BlogRpc_UploadBlogServer interface {
	SendAndClose(*UploadBlogResponse) error
	Recv() (*UploadBlogRequest, error)
	grpc.ServerStream
}

type BlogSet 

type BlogSet struct {
	Total int64   `protobuf:"varint,1,opt,name=total,proto3" json:"total,omitempty"`
	Items []*Blog `protobuf:"bytes,2,rep,name=items,proto3" json:"items,omitempty"`
	// contains filtered or unexported fields
}

func (*BlogSet) Descriptor deprecated 

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

Deprecated: Use BlogSet.ProtoReflect.Descriptor instead.

func (*BlogSet) GetItems 

func (x *BlogSet) GetItems() []*Blog

func (*BlogSet) GetTotal 

func (x *BlogSet) GetTotal() int64

func (*BlogSet) ProtoMessage 

func (*BlogSet) ProtoMessage()

func (*BlogSet) ProtoReflect 

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

func (*BlogSet) Reset 

func (x *BlogSet) Reset()

func (*BlogSet) String 

func (x *BlogSet) String() string

type CreateBlogRequest 

type CreateBlogRequest struct {

	// 文章标题
	Title string `protobuf:"bytes,1,opt,name=title,proto3" json:"title,omitempty"`
	// 作者
	Author string `protobuf:"bytes,2,opt,name=author,proto3" json:"author,omitempty"`
	// 文章的内容
	Content string `protobuf:"bytes,3,opt,name=content,proto3" json:"content,omitempty"`
	// map[string]string orm是不知道如何入库的
	// 直接存成json
	Tags map[string]string `` /* 149-byte string literal not displayed */
	// 文章是由状态
	Status STATUS `protobuf:"varint,5,opt,name=status,proto3,enum=go11.protobuf.blog.STATUS" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateBlogRequest) Descriptor deprecated 

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

Deprecated: Use CreateBlogRequest.ProtoReflect.Descriptor instead.

func (*CreateBlogRequest) GetAuthor 

func (x *CreateBlogRequest) GetAuthor() string

func (*CreateBlogRequest) GetContent 

func (x *CreateBlogRequest) GetContent() string

func (*CreateBlogRequest) GetStatus 

func (x *CreateBlogRequest) GetStatus() STATUS

func (*CreateBlogRequest) GetTags 

func (x *CreateBlogRequest) GetTags() map[string]string

func (*CreateBlogRequest) GetTitle 

func (x *CreateBlogRequest) GetTitle() string

func (*CreateBlogRequest) ProtoMessage 

func (*CreateBlogRequest) ProtoMessage()

func (*CreateBlogRequest) ProtoReflect 

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

func (*CreateBlogRequest) Reset 

func (x *CreateBlogRequest) Reset()

func (*CreateBlogRequest) String 

func (x *CreateBlogRequest) String() string

type DownloadBlogRequest 

type DownloadBlogRequest struct {

	// 需要下载的文件名称
	FileName string `protobuf:"bytes,1,opt,name=file_name,json=fileName,proto3" json:"file_name,omitempty"`
	// contains filtered or unexported fields
}

func (*DownloadBlogRequest) Descriptor deprecated 

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

Deprecated: Use DownloadBlogRequest.ProtoReflect.Descriptor instead.

func (*DownloadBlogRequest) GetFileName 

func (x *DownloadBlogRequest) GetFileName() string

func (*DownloadBlogRequest) ProtoMessage 

func (*DownloadBlogRequest) ProtoMessage()

func (*DownloadBlogRequest) ProtoReflect 

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

func (*DownloadBlogRequest) Reset 

func (x *DownloadBlogRequest) Reset()

func (*DownloadBlogRequest) String 

func (x *DownloadBlogRequest) String() string

type DownloadBlogResponse 

type DownloadBlogResponse struct {
	Meta map[string]string `` /* 149-byte string literal not displayed */
	// 上传文件的内容
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*DownloadBlogResponse) Descriptor deprecated 

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

Deprecated: Use DownloadBlogResponse.ProtoReflect.Descriptor instead.

func (*DownloadBlogResponse) GetData 

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

func (*DownloadBlogResponse) GetMeta 

func (x *DownloadBlogResponse) GetMeta() map[string]string

func (*DownloadBlogResponse) ProtoMessage 

func (*DownloadBlogResponse) ProtoMessage()

func (*DownloadBlogResponse) ProtoReflect 

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

func (*DownloadBlogResponse) Reset 

func (x *DownloadBlogResponse) Reset()

func (*DownloadBlogResponse) String 

func (x *DownloadBlogResponse) String() string

type Meta 

type Meta struct {
	Id         int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	CreatedAt  int64 `protobuf:"varint,2,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt  int64 `protobuf:"varint,3,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	PulishedAt int64 `protobuf:"varint,4,opt,name=pulished_at,json=pulishedAt,proto3" json:"pulished_at,omitempty"`
	// contains filtered or unexported fields
}

func (*Meta) Descriptor deprecated 

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

Deprecated: Use Meta.ProtoReflect.Descriptor instead.

func (*Meta) GetCreatedAt 

func (x *Meta) GetCreatedAt() int64

func (*Meta) GetId 

func (x *Meta) GetId() int64

func (*Meta) GetPulishedAt 

func (x *Meta) GetPulishedAt() int64

func (*Meta) GetUpdatedAt 

func (x *Meta) GetUpdatedAt() int64

func (*Meta) ProtoMessage 

func (*Meta) ProtoMessage()

func (*Meta) ProtoReflect 

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

func (*Meta) Reset 

func (x *Meta) Reset()

func (*Meta) String 

func (x *Meta) String() string

type STATUS 

type STATUS int32
const (
	STATUS_DRAFT      STATUS = 0
	STATUS_PUBLIESHED STATUS = 1
)

func (STATUS) Descriptor 

func (STATUS) Descriptor() protoreflect.EnumDescriptor

func (STATUS) Enum 

func (x STATUS) Enum() *STATUS

func (STATUS) EnumDescriptor deprecated 

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

Deprecated: Use STATUS.Descriptor instead.

func (STATUS) Number 

func (x STATUS) Number() protoreflect.EnumNumber

func (STATUS) String 

func (x STATUS) String() string

func (STATUS) Type 

func (STATUS) Type() protoreflect.EnumType

type UnimplementedBlogRpcServer 

type UnimplementedBlogRpcServer struct {
}

UnimplementedBlogRpcServer must be embedded to have forward compatible implementations.

func (UnimplementedBlogRpcServer) CreateBlog 

func (UnimplementedBlogRpcServer) CreateBlog(context.Context, *CreateBlogRequest) (*Blog, error)

func (UnimplementedBlogRpcServer) DownloadBlog 

func (UnimplementedBlogRpcServer) DownloadBlog(*DownloadBlogRequest, BlogRpc_DownloadBlogServer) error

func (UnimplementedBlogRpcServer) UploadBlog 

func (UnimplementedBlogRpcServer) UploadBlog(BlogRpc_UploadBlogServer) error

type UnsafeBlogRpcServer 

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

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

type UploadBlogRequest 

type UploadBlogRequest struct {
	Meta map[string]string `` /* 149-byte string literal not displayed */
	// 上传文件的内容
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

文件上传的数据

func (*UploadBlogRequest) Descriptor deprecated 

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

Deprecated: Use UploadBlogRequest.ProtoReflect.Descriptor instead.

func (*UploadBlogRequest) GetData 

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

func (*UploadBlogRequest) GetMeta 

func (x *UploadBlogRequest) GetMeta() map[string]string

func (*UploadBlogRequest) ProtoMessage 

func (*UploadBlogRequest) ProtoMessage()

func (*UploadBlogRequest) ProtoReflect 

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

func (*UploadBlogRequest) Reset 

func (x *UploadBlogRequest) Reset()

func (*UploadBlogRequest) String 

func (x *UploadBlogRequest) String() string

type UploadBlogResponse 

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

func (*UploadBlogResponse) Descriptor deprecated 

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

Deprecated: Use UploadBlogResponse.ProtoReflect.Descriptor instead.

func (*UploadBlogResponse) GetMessage 

func (x *UploadBlogResponse) GetMessage() string

func (*UploadBlogResponse) ProtoMessage 

func (*UploadBlogResponse) ProtoMessage()

func (*UploadBlogResponse) ProtoReflect 

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

func (*UploadBlogResponse) Reset 

func (x *UploadBlogResponse) Reset()

func (*UploadBlogResponse) String 

func (x *UploadBlogResponse) String() string

Source Files

View all Source files

Directories

Path Synopsis
auth

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.