video

package
v0.0.0-...-8c4fe33 Latest Latest
Warning

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

 Go to latest Published: May 29, 2023 License: MIT Imports: 12 Imported by: 0

Documentation

Overview

@Author: Ciusyan 2023/2/7

Index

Constants

View Source 
const (
	AppName = "video"
)

Variables

View Source 
var File_apps_video_pb_video_proto protoreflect.FileDescriptor
View Source 
var Service_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "dousheng.video.Service",
	HandlerType: (*ServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "FeedVideos",
			Handler:    _Service_FeedVideos_Handler,
		},
		{
			MethodName: "PublishVideo",
			Handler:    _Service_PublishVideo_Handler,
		},
		{
			MethodName: "PublishList",
			Handler:    _Service_PublishList_Handler,
		},
		{
			MethodName: "GetVideo",
			Handler:    _Service_GetVideo_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "apps/video/pb/video.proto",
}

Service_ServiceDesc is the grpc.ServiceDesc for Service service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterServiceServer 

func RegisterServiceServer(s grpc.ServiceRegistrar, srv ServiceServer)

Types

type FeedSetResponse 

type FeedSetResponse struct {

	// 本次返回的视频中，发布最早的时间，作为下次请求的latest_time
	// @gotags: json:"next_time"
	NextTime *int64 `protobuf:"varint,2,opt,name=next_time,json=nextTime,proto3,oneof" json:"next_time"`
	// 视频列表
	// @gotags: json:"video_list"
	VideoList []*Video `protobuf:"bytes,1,rep,name=video_list,json=videoList,proto3" json:"video_list"`
	// contains filtered or unexported fields
}

func NewFeedSet 

func NewFeedSet() *FeedSetResponse

func (*FeedSetResponse) Descriptor deprecated 

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

Deprecated: Use FeedSetResponse.ProtoReflect.Descriptor instead.

func (*FeedSetResponse) GetNextTime 

func (x *FeedSetResponse) GetNextTime() int64

func (*FeedSetResponse) GetVideoList 

func (x *FeedSetResponse) GetVideoList() []*Video

func (*FeedSetResponse) ProtoMessage 

func (*FeedSetResponse) ProtoMessage()

func (*FeedSetResponse) ProtoReflect 

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

func (*FeedSetResponse) Reset 

func (x *FeedSetResponse) Reset()

func (*FeedSetResponse) String 

func (x *FeedSetResponse) String() string

type FeedVideosRequest 

type FeedVideosRequest struct {

	// 分页参数
	// @gotags: json:"page"
	Page *PageRequest `protobuf:"bytes,1,opt,name=page,proto3" json:"page"`
	// 可选参数，限制返回视频的最新投稿时间戳，精确到秒，不填表示当前时间
	// @gotags: json:"latest_time"
	LatestTime *int64 `protobuf:"varint,2,opt,name=latest_time,json=latestTime,proto3,oneof" json:"latest_time"`
	// 可选参数，登录用户ID设置
	// @gotags: json:"login_user_id"
	LoginUserId *int64 `protobuf:"varint,3,opt,name=login_user_id,json=loginUserId,proto3,oneof" json:"login_user_id"`
	// contains filtered or unexported fields
}

func NewFeedVideosRequest 

func NewFeedVideosRequest() *FeedVideosRequest

func (*FeedVideosRequest) Descriptor deprecated 

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

Deprecated: Use FeedVideosRequest.ProtoReflect.Descriptor instead.

func (*FeedVideosRequest) GetLatestTime 

func (x *FeedVideosRequest) GetLatestTime() int64

func (*FeedVideosRequest) GetLoginUserId 

func (x *FeedVideosRequest) GetLoginUserId() int64

func (*FeedVideosRequest) GetPage 

func (x *FeedVideosRequest) GetPage() *PageRequest

func (*FeedVideosRequest) ProtoMessage 

func (*FeedVideosRequest) ProtoMessage()

func (*FeedVideosRequest) ProtoReflect 

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

func (*FeedVideosRequest) Reset 

func (x *FeedVideosRequest) Reset()

func (*FeedVideosRequest) String 

func (x *FeedVideosRequest) String() string

type GetVideoRequest 

type GetVideoRequest struct {

	// 视频ID
	// @gotags: json:"video_id" validate:"required"
	VideoId int64 `protobuf:"varint,1,opt,name=video_id,json=videoId,proto3" json:"video_id" validate:"required"`
	// contains filtered or unexported fields
}

视频ID

func NewGetVideoRequest 

func NewGetVideoRequest() *GetVideoRequest

func (*GetVideoRequest) Descriptor deprecated 

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

Deprecated: Use GetVideoRequest.ProtoReflect.Descriptor instead.

func (*GetVideoRequest) GetVideoId 

func (x *GetVideoRequest) GetVideoId() int64

func (*GetVideoRequest) ProtoMessage 

func (*GetVideoRequest) ProtoMessage()

func (*GetVideoRequest) ProtoReflect 

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

func (*GetVideoRequest) Reset 

func (x *GetVideoRequest) Reset()

func (*GetVideoRequest) String 

func (x *GetVideoRequest) String() string

func (*GetVideoRequest) Validate 

func (r *GetVideoRequest) Validate() error

type PageRequest 

type PageRequest struct {

	// 每页数据数量
	// @gotags: json:"page_size"
	PageSize uint64 `protobuf:"varint,1,opt,name=page_size,json=pageSize,proto3" json:"page_size"`
	// 第几页
	// @gotags: json:"page_number"
	PageNumber uint64 `protobuf:"varint,2,opt,name=page_number,json=pageNumber,proto3" json:"page_number"`
	// 偏移量
	// @gotags: json:"offset"
	Offset int64 `protobuf:"varint,3,opt,name=offset,proto3" json:"offset"`
	// contains filtered or unexported fields
}

分页请求参数 TODO：可以放在公共模块

func NewPageRequest 

func NewPageRequest() *PageRequest

func (*PageRequest) Descriptor deprecated 

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

Deprecated: Use PageRequest.ProtoReflect.Descriptor instead.

func (*PageRequest) GetOffset 

func (x *PageRequest) GetOffset() int64

func (*PageRequest) GetPageNumber 

func (x *PageRequest) GetPageNumber() uint64

func (*PageRequest) GetPageSize 

func (x *PageRequest) GetPageSize() uint64

func (*PageRequest) ProtoMessage 

func (*PageRequest) ProtoMessage()

func (*PageRequest) ProtoReflect 

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

func (*PageRequest) Reset 

func (x *PageRequest) Reset()

func (*PageRequest) String 

func (x *PageRequest) String() string

type PublishListRequest 

type PublishListRequest struct {

	// 用户ID
	// @gotags: json:"user_id" validate:"required"
	UserId int64 `protobuf:"varint,1,opt,name=user_id,json=userId,proto3" json:"user_id" validate:"required"`
	// contains filtered or unexported fields
}

发布列表的 请求 model

func NewPublishListRequest 

func NewPublishListRequest() *PublishListRequest

func (*PublishListRequest) Descriptor deprecated 

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

Deprecated: Use PublishListRequest.ProtoReflect.Descriptor instead.

func (*PublishListRequest) GetUserId 

func (x *PublishListRequest) GetUserId() int64

func (*PublishListRequest) ProtoMessage 

func (*PublishListRequest) ProtoMessage()

func (*PublishListRequest) ProtoReflect 

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

func (*PublishListRequest) Reset 

func (x *PublishListRequest) Reset()

func (*PublishListRequest) String 

func (x *PublishListRequest) String() string

func (*PublishListRequest) Validate 

func (r *PublishListRequest) Validate() error

type PublishListResponse 

type PublishListResponse struct {

	// 用户发布的视频列表
	// @gotags: json:"video_list"
	VideoList []*Video `protobuf:"bytes,1,rep,name=video_list,json=videoList,proto3" json:"video_list"`
	// contains filtered or unexported fields
}

func NewPublishListResponse 

func NewPublishListResponse() *PublishListResponse

func (*PublishListResponse) Descriptor deprecated 

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

Deprecated: Use PublishListResponse.ProtoReflect.Descriptor instead.

func (*PublishListResponse) GetVideoList 

func (x *PublishListResponse) GetVideoList() []*Video

func (*PublishListResponse) ProtoMessage 

func (*PublishListResponse) ProtoMessage()

func (*PublishListResponse) ProtoReflect 

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

func (*PublishListResponse) Reset 

func (x *PublishListResponse) Reset()

func (*PublishListResponse) String 

func (x *PublishListResponse) String() string

type PublishVideoRequest 

type PublishVideoRequest struct {

	// 作者ID
	// @gotags: json:"author_id" validate:"required"
	AuthorId int64 `protobuf:"varint,1,opt,name=author_id,json=authorId,proto3" json:"author_id" validate:"required"`
	// 视频标题
	// @gotags: json:"title" form:"title" binding:"required" validate:"required"
	Title string `protobuf:"bytes,2,opt,name=title,proto3" json:"title" form:"title" binding:"required" validate:"required"`
	// 视频播放地址 [经过文件上传后设置]
	// @gotags: json:"play_url" validate:"required"
	PlayUrl string `protobuf:"bytes,3,opt,name=play_url,json=playUrl,proto3" json:"play_url" validate:"required"`
	// 视频封面地址 [经过文件上传后设置]
	// @gotags: json:"cover_url"validate:"required"
	CoverUrl string `protobuf:"bytes,4,opt,name=cover_url,json=coverUrl,proto3" json:"cover_url" validate:"required"`
	// contains filtered or unexported fields
}

func NewPublishVideoRequest 

func NewPublishVideoRequest() *PublishVideoRequest

func (*PublishVideoRequest) Descriptor deprecated 

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

Deprecated: Use PublishVideoRequest.ProtoReflect.Descriptor instead.

func (*PublishVideoRequest) GetAuthorId 

func (x *PublishVideoRequest) GetAuthorId() int64

func (*PublishVideoRequest) GetCoverUrl 

func (x *PublishVideoRequest) GetCoverUrl() string

func (*PublishVideoRequest) GetPlayUrl 

func (x *PublishVideoRequest) GetPlayUrl() string

func (*PublishVideoRequest) GetTitle 

func (x *PublishVideoRequest) GetTitle() string

func (*PublishVideoRequest) ProtoMessage 

func (*PublishVideoRequest) ProtoMessage()

func (*PublishVideoRequest) ProtoReflect 

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

func (*PublishVideoRequest) Reset 

func (x *PublishVideoRequest) Reset()

func (*PublishVideoRequest) String 

func (x *PublishVideoRequest) String() string

func (*PublishVideoRequest) Validate 

func (r *PublishVideoRequest) Validate() error

Validate 参数校验

type PublishVideoResponse 

type PublishVideoResponse struct {

	// 可以携带一些额外属性
	// @gotags: json:"mate"
	Mate map[string]string `` /* 139-byte string literal not displayed */
	// contains filtered or unexported fields
}

func NewPublishVideoResponse 

func NewPublishVideoResponse() *PublishVideoResponse

func (*PublishVideoResponse) Descriptor deprecated 

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

Deprecated: Use PublishVideoResponse.ProtoReflect.Descriptor instead.

func (*PublishVideoResponse) GetMate 

func (x *PublishVideoResponse) GetMate() map[string]string

func (*PublishVideoResponse) ProtoMessage 

func (*PublishVideoResponse) ProtoMessage()

func (*PublishVideoResponse) ProtoReflect 

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

func (*PublishVideoResponse) Reset 

func (x *PublishVideoResponse) Reset()

func (*PublishVideoResponse) String 

func (x *PublishVideoResponse) String() string

type ServiceClient 

type ServiceClient interface {
	// 视频 feed 流
	FeedVideos(ctx context.Context, in *FeedVideosRequest, opts ...grpc.CallOption) (*FeedSetResponse, error)
	// 视频发布
	PublishVideo(ctx context.Context, in *PublishVideoRequest, opts ...grpc.CallOption) (*PublishVideoResponse, error)
	// 用户发布视频的列表
	PublishList(ctx context.Context, in *PublishListRequest, opts ...grpc.CallOption) (*PublishListResponse, error)
	// 根据视频ID获取视频信息
	GetVideo(ctx context.Context, in *GetVideoRequest, opts ...grpc.CallOption) (*Video, error)
}

ServiceClient is the client API for Service 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 NewServiceClient 

func NewServiceClient(cc grpc.ClientConnInterface) ServiceClient

type ServiceServer 

type ServiceServer interface {
	// 视频 feed 流
	FeedVideos(context.Context, *FeedVideosRequest) (*FeedSetResponse, error)
	// 视频发布
	PublishVideo(context.Context, *PublishVideoRequest) (*PublishVideoResponse, error)
	// 用户发布视频的列表
	PublishList(context.Context, *PublishListRequest) (*PublishListResponse, error)
	// 根据视频ID获取视频信息
	GetVideo(context.Context, *GetVideoRequest) (*Video, error)
	// contains filtered or unexported methods
}

ServiceServer is the server API for Service service. All implementations must embed UnimplementedServiceServer for forward compatibility

type UnimplementedServiceServer 

type UnimplementedServiceServer struct {
}

UnimplementedServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedServiceServer) FeedVideos 

func (UnimplementedServiceServer) FeedVideos(context.Context, *FeedVideosRequest) (*FeedSetResponse, error)

func (UnimplementedServiceServer) GetVideo 

func (UnimplementedServiceServer) GetVideo(context.Context, *GetVideoRequest) (*Video, error)

func (UnimplementedServiceServer) PublishList 

func (UnimplementedServiceServer) PublishList(context.Context, *PublishListRequest) (*PublishListResponse, error)

func (UnimplementedServiceServer) PublishVideo 

func (UnimplementedServiceServer) PublishVideo(context.Context, *PublishVideoRequest) (*PublishVideoResponse, error)

type UnsafeServiceServer 

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

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

type Video 

type Video struct {

	// 视频唯一标识
	// @gotags: json:"id"
	Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id"`
	// 视频作者ID
	// @gotags: json:"author_id"
	AuthorId int64 `protobuf:"varint,2,opt,name=author_id,json=authorId,proto3" json:"author_id"`
	// 视频播放地址
	// @gotags: json:"play_url"
	PlayUrl string `protobuf:"bytes,3,opt,name=play_url,json=playUrl,proto3" json:"play_url"`
	// 视频封面地址
	// @gotags: json:"cover_url"
	CoverUrl string `protobuf:"bytes,4,opt,name=cover_url,json=coverUrl,proto3" json:"cover_url"`
	// 视频标题
	// @gotags: json:"title"
	Title string `protobuf:"bytes,5,opt,name=title,proto3" json:"title"`
	// contains filtered or unexported fields
}

func (*Video) Descriptor deprecated 

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

Deprecated: Use Video.ProtoReflect.Descriptor instead.

func (*Video) GetAuthorId 

func (x *Video) GetAuthorId() int64

func (*Video) GetCoverUrl 

func (x *Video) GetCoverUrl() string

func (*Video) GetId 

func (x *Video) GetId() int64

func (*Video) GetPlayUrl 

func (x *Video) GetPlayUrl() string

func (*Video) GetTitle 

func (x *Video) GetTitle() string

func (*Video) ProtoMessage 

func (*Video) ProtoMessage()

func (*Video) ProtoReflect 

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

func (*Video) Reset 

func (x *Video) Reset()

func (*Video) String 

func (x *Video) String() string

type VideoPo 

type VideoPo struct {

	// 视频唯一标识
	// @gotags: json:"id"
	Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id"`
	// 视频播放地址
	// @gotags: json:"play_url"
	PlayUrl string `protobuf:"bytes,2,opt,name=play_url,json=playUrl,proto3" json:"play_url"`
	// 视频封面地址
	// @gotags: json:"cover_url"
	CoverUrl string `protobuf:"bytes,3,opt,name=cover_url,json=coverUrl,proto3" json:"cover_url"`
	// 视频标题
	// @gotags: json:"title"
	Title string `protobuf:"bytes,4,opt,name=title,proto3" json:"title"`
	// 视频作者ID
	// @gotags: json:"author_id"
	AuthorId int64 `protobuf:"varint,5,opt,name=author_id,json=authorId,proto3" json:"author_id"`
	// @gotags: json:"created_at"
	CreatedAt int64 `protobuf:"varint,6,opt,name=created_at,json=createdAt,proto3" json:"created_at"`
	// contains filtered or unexported fields
}

func NewVideoPo 

func NewVideoPo() *VideoPo

func NewVideoPoWithSave 

func NewVideoPoWithSave(req *PublishVideoRequest) *VideoPo

func (*VideoPo) Descriptor deprecated 

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

Deprecated: Use VideoPo.ProtoReflect.Descriptor instead.

func (*VideoPo) GetAuthorId 

func (x *VideoPo) GetAuthorId() int64

func (*VideoPo) GetCoverUrl 

func (x *VideoPo) GetCoverUrl() string

func (*VideoPo) GetCreatedAt 

func (x *VideoPo) GetCreatedAt() int64

func (*VideoPo) GetId 

func (x *VideoPo) GetId() int64

func (*VideoPo) GetPlayUrl 

func (x *VideoPo) GetPlayUrl() string

func (*VideoPo) GetTitle 

func (x *VideoPo) GetTitle() string

func (*VideoPo) Po2vo 

func (po *VideoPo) Po2vo() *Video

Po2vo 将 videoPo -> video

func (*VideoPo) ProtoMessage 

func (*VideoPo) ProtoMessage()

func (*VideoPo) ProtoReflect 

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

func (*VideoPo) Reset 

func (x *VideoPo) Reset()

func (*VideoPo) String 

func (x *VideoPo) String() string

func (*VideoPo) TableName 

func (*VideoPo) TableName() string

TableName 指明表名 -> gorm 参数映射

Source Files

View all Source files

Directories

Path Synopsis
@Author: Ciusyan 2023/2/7
 @Author: Ciusyan 2023/2/7

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.