pb

package
v0.0.0-...-fe7ef4e Latest Latest
Warning

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

Go to latest
Published: Jun 3, 2022 License: Apache-2.0 Imports: 22 Imported by: 0

Documentation

Overview

Package pb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source
var File_modules_video_pb_message_proto protoreflect.FileDescriptor
View Source
var File_modules_video_pb_rpc_proto protoreflect.FileDescriptor
View Source
var File_modules_video_pb_stream_proto protoreflect.FileDescriptor
View Source
var VideoStream_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "video.pb.VideoStream",
	HandlerType: (*VideoStreamServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "HandleVideoCreated",
			Handler:    _VideoStream_HandleVideoCreated_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "modules/video/pb/stream.proto",
}

VideoStream_ServiceDesc is the grpc.ServiceDesc for VideoStream 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 Video_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "video.pb.Video",
	HandlerType: (*VideoServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Healthz",
			Handler:    _Video_Healthz_Handler,
		},
		{
			MethodName: "GetVideo",
			Handler:    _Video_GetVideo_Handler,
		},
		{
			MethodName: "ListVideo",
			Handler:    _Video_ListVideo_Handler,
		},
		{
			MethodName: "DeleteVideo",
			Handler:    _Video_DeleteVideo_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "UploadVideo",
			Handler:       _Video_UploadVideo_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "modules/video/pb/rpc.proto",
}

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

Functions

func RegisterVideoHandler

func RegisterVideoHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterVideoHandler registers the http handlers for service Video to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterVideoHandlerClient

func RegisterVideoHandlerClient(ctx context.Context, mux *runtime.ServeMux, client VideoClient) error

RegisterVideoHandlerClient registers the http handlers for service Video to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "VideoClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "VideoClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "VideoClient" to call the correct interceptors.

func RegisterVideoHandlerFromEndpoint

func RegisterVideoHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterVideoHandlerFromEndpoint is same as RegisterVideoHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterVideoHandlerServer

func RegisterVideoHandlerServer(ctx context.Context, mux *runtime.ServeMux, server VideoServer) error

RegisterVideoHandlerServer registers the http handlers for service Video to "mux". UnaryRPC :call VideoServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterVideoHandlerFromEndpoint instead.

func RegisterVideoServer

func RegisterVideoServer(s grpc.ServiceRegistrar, srv VideoServer)

func RegisterVideoStreamServer

func RegisterVideoStreamServer(s grpc.ServiceRegistrar, srv VideoStreamServer)

Types

type DeleteVideoRequest

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

func (*DeleteVideoRequest) Descriptor deprecated

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

Deprecated: Use DeleteVideoRequest.ProtoReflect.Descriptor instead.

func (*DeleteVideoRequest) GetId

func (x *DeleteVideoRequest) GetId() string

func (*DeleteVideoRequest) ProtoMessage

func (*DeleteVideoRequest) ProtoMessage()

func (*DeleteVideoRequest) ProtoReflect

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

func (*DeleteVideoRequest) Reset

func (x *DeleteVideoRequest) Reset()

func (*DeleteVideoRequest) String

func (x *DeleteVideoRequest) String() string

type DeleteVideoResponse

type DeleteVideoResponse struct {
	// contains filtered or unexported fields
}

func (*DeleteVideoResponse) Descriptor deprecated

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

Deprecated: Use DeleteVideoResponse.ProtoReflect.Descriptor instead.

func (*DeleteVideoResponse) ProtoMessage

func (*DeleteVideoResponse) ProtoMessage()

func (*DeleteVideoResponse) ProtoReflect

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

func (*DeleteVideoResponse) Reset

func (x *DeleteVideoResponse) Reset()

func (*DeleteVideoResponse) String

func (x *DeleteVideoResponse) String() string

type GetVideoRequest

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

func (*GetVideoRequest) Descriptor deprecated

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

Deprecated: Use GetVideoRequest.ProtoReflect.Descriptor instead.

func (*GetVideoRequest) GetId

func (x *GetVideoRequest) GetId() string

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

type GetVideoResponse

type GetVideoResponse struct {
	Video *VideoInfo `protobuf:"bytes,1,opt,name=video,proto3" json:"video,omitempty"`
	// contains filtered or unexported fields
}

func (*GetVideoResponse) Descriptor deprecated

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

Deprecated: Use GetVideoResponse.ProtoReflect.Descriptor instead.

func (*GetVideoResponse) GetVideo

func (x *GetVideoResponse) GetVideo() *VideoInfo

func (*GetVideoResponse) ProtoMessage

func (*GetVideoResponse) ProtoMessage()

func (*GetVideoResponse) ProtoReflect

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

func (*GetVideoResponse) Reset

func (x *GetVideoResponse) Reset()

func (*GetVideoResponse) String

func (x *GetVideoResponse) String() string

type HandleVideoCreatedHandler

type HandleVideoCreatedHandler struct {
	// contains filtered or unexported fields
}

func (*HandleVideoCreatedHandler) Cleanup

func (*HandleVideoCreatedHandler) ConsumeClaim

func (*HandleVideoCreatedHandler) Setup

type HandleVideoCreatedRequest

type HandleVideoCreatedRequest struct {
	Id    string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Url   string `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"`
	Scale int32  `protobuf:"varint,3,opt,name=scale,proto3" json:"scale,omitempty"`
	// contains filtered or unexported fields
}

func (*HandleVideoCreatedRequest) Descriptor deprecated

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

Deprecated: Use HandleVideoCreatedRequest.ProtoReflect.Descriptor instead.

func (*HandleVideoCreatedRequest) GetId

func (x *HandleVideoCreatedRequest) GetId() string

func (*HandleVideoCreatedRequest) GetScale

func (x *HandleVideoCreatedRequest) GetScale() int32

func (*HandleVideoCreatedRequest) GetUrl

func (x *HandleVideoCreatedRequest) GetUrl() string

func (*HandleVideoCreatedRequest) ProtoMessage

func (*HandleVideoCreatedRequest) ProtoMessage()

func (*HandleVideoCreatedRequest) ProtoReflect

func (*HandleVideoCreatedRequest) Reset

func (x *HandleVideoCreatedRequest) Reset()

func (*HandleVideoCreatedRequest) String

func (x *HandleVideoCreatedRequest) String() string

type HealthzRequest

type HealthzRequest struct {
	// contains filtered or unexported fields
}

func (*HealthzRequest) Descriptor deprecated

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

Deprecated: Use HealthzRequest.ProtoReflect.Descriptor instead.

func (*HealthzRequest) ProtoMessage

func (*HealthzRequest) ProtoMessage()

func (*HealthzRequest) ProtoReflect

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

func (*HealthzRequest) Reset

func (x *HealthzRequest) Reset()

func (*HealthzRequest) String

func (x *HealthzRequest) String() string

type HealthzResponse

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

func (*HealthzResponse) Descriptor deprecated

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

Deprecated: Use HealthzResponse.ProtoReflect.Descriptor instead.

func (*HealthzResponse) GetStatus

func (x *HealthzResponse) GetStatus() string

func (*HealthzResponse) ProtoMessage

func (*HealthzResponse) ProtoMessage()

func (*HealthzResponse) ProtoReflect

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

func (*HealthzResponse) Reset

func (x *HealthzResponse) Reset()

func (*HealthzResponse) String

func (x *HealthzResponse) String() string

type ListVideoRequest

type ListVideoRequest struct {
	Limit int64 `protobuf:"varint,1,opt,name=limit,proto3" json:"limit,omitempty"`
	Skip  int64 `protobuf:"varint,2,opt,name=skip,proto3" json:"skip,omitempty"`
	// contains filtered or unexported fields
}

func (*ListVideoRequest) Descriptor deprecated

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

Deprecated: Use ListVideoRequest.ProtoReflect.Descriptor instead.

func (*ListVideoRequest) GetLimit

func (x *ListVideoRequest) GetLimit() int64

func (*ListVideoRequest) GetSkip

func (x *ListVideoRequest) GetSkip() int64

func (*ListVideoRequest) ProtoMessage

func (*ListVideoRequest) ProtoMessage()

func (*ListVideoRequest) ProtoReflect

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

func (*ListVideoRequest) Reset

func (x *ListVideoRequest) Reset()

func (*ListVideoRequest) String

func (x *ListVideoRequest) String() string

type ListVideoResponse

type ListVideoResponse struct {
	Videos []*VideoInfo `protobuf:"bytes,1,rep,name=videos,proto3" json:"videos,omitempty"`
	// contains filtered or unexported fields
}

func (*ListVideoResponse) Descriptor deprecated

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

Deprecated: Use ListVideoResponse.ProtoReflect.Descriptor instead.

func (*ListVideoResponse) GetVideos

func (x *ListVideoResponse) GetVideos() []*VideoInfo

func (*ListVideoResponse) ProtoMessage

func (*ListVideoResponse) ProtoMessage()

func (*ListVideoResponse) ProtoReflect

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

func (*ListVideoResponse) Reset

func (x *ListVideoResponse) Reset()

func (*ListVideoResponse) String

func (x *ListVideoResponse) String() string

type UnimplementedVideoServer

type UnimplementedVideoServer struct {
}

UnimplementedVideoServer must be embedded to have forward compatible implementations.

func (UnimplementedVideoServer) DeleteVideo

func (UnimplementedVideoServer) GetVideo

func (UnimplementedVideoServer) Healthz

func (UnimplementedVideoServer) ListVideo

func (UnimplementedVideoServer) UploadVideo

type UnimplementedVideoStreamServer

type UnimplementedVideoStreamServer struct {
}

UnimplementedVideoStreamServer must be embedded to have forward compatible implementations.

func (UnimplementedVideoStreamServer) HandleVideoCreated

type UnsafeVideoServer

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

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

type UnsafeVideoStreamServer

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

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

type UploadVideoRequest

type UploadVideoRequest struct {

	// Types that are assignable to Data:
	//	*UploadVideoRequest_Header
	//	*UploadVideoRequest_ChunkData
	Data isUploadVideoRequest_Data `protobuf_oneof:"data"`
	// contains filtered or unexported fields
}

func (*UploadVideoRequest) Descriptor deprecated

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

Deprecated: Use UploadVideoRequest.ProtoReflect.Descriptor instead.

func (*UploadVideoRequest) GetChunkData

func (x *UploadVideoRequest) GetChunkData() []byte

func (*UploadVideoRequest) GetData

func (m *UploadVideoRequest) GetData() isUploadVideoRequest_Data

func (*UploadVideoRequest) GetHeader

func (x *UploadVideoRequest) GetHeader() *VideoHeader

func (*UploadVideoRequest) ProtoMessage

func (*UploadVideoRequest) ProtoMessage()

func (*UploadVideoRequest) ProtoReflect

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

func (*UploadVideoRequest) Reset

func (x *UploadVideoRequest) Reset()

func (*UploadVideoRequest) String

func (x *UploadVideoRequest) String() string

type UploadVideoRequest_ChunkData

type UploadVideoRequest_ChunkData struct {
	ChunkData []byte `protobuf:"bytes,2,opt,name=chunk_data,json=chunkData,proto3,oneof"`
}

type UploadVideoRequest_Header

type UploadVideoRequest_Header struct {
	Header *VideoHeader `protobuf:"bytes,1,opt,name=header,proto3,oneof"`
}

type UploadVideoResponse

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

func (*UploadVideoResponse) Descriptor deprecated

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

Deprecated: Use UploadVideoResponse.ProtoReflect.Descriptor instead.

func (*UploadVideoResponse) GetId

func (x *UploadVideoResponse) GetId() string

func (*UploadVideoResponse) ProtoMessage

func (*UploadVideoResponse) ProtoMessage()

func (*UploadVideoResponse) ProtoReflect

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

func (*UploadVideoResponse) Reset

func (x *UploadVideoResponse) Reset()

func (*UploadVideoResponse) String

func (x *UploadVideoResponse) String() string

type VideoClient

type VideoClient interface {
	Healthz(ctx context.Context, in *HealthzRequest, opts ...grpc.CallOption) (*HealthzResponse, error)
	GetVideo(ctx context.Context, in *GetVideoRequest, opts ...grpc.CallOption) (*GetVideoResponse, error)
	ListVideo(ctx context.Context, in *ListVideoRequest, opts ...grpc.CallOption) (*ListVideoResponse, error)
	UploadVideo(ctx context.Context, opts ...grpc.CallOption) (Video_UploadVideoClient, error)
	DeleteVideo(ctx context.Context, in *DeleteVideoRequest, opts ...grpc.CallOption) (*DeleteVideoResponse, error)
}

VideoClient is the client API for Video 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 NewVideoClient

func NewVideoClient(cc grpc.ClientConnInterface) VideoClient

type VideoHeader

type VideoHeader struct {
	Filename string `protobuf:"bytes,1,opt,name=filename,proto3" json:"filename,omitempty"`
	Size     uint64 `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	// contains filtered or unexported fields
}

func (*VideoHeader) Descriptor deprecated

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

Deprecated: Use VideoHeader.ProtoReflect.Descriptor instead.

func (*VideoHeader) GetFilename

func (x *VideoHeader) GetFilename() string

func (*VideoHeader) GetSize

func (x *VideoHeader) GetSize() uint64

func (*VideoHeader) ProtoMessage

func (*VideoHeader) ProtoMessage()

func (*VideoHeader) ProtoReflect

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

func (*VideoHeader) Reset

func (x *VideoHeader) Reset()

func (*VideoHeader) String

func (x *VideoHeader) String() string

type VideoInfo

type VideoInfo struct {
	Id        string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Width     uint32                 `protobuf:"varint,2,opt,name=width,proto3" json:"width,omitempty"`
	Height    uint32                 `protobuf:"varint,3,opt,name=height,proto3" json:"height,omitempty"`
	Size      uint64                 `protobuf:"varint,4,opt,name=size,proto3" json:"size,omitempty"`
	Duration  float64                `protobuf:"fixed64,5,opt,name=duration,proto3" json:"duration,omitempty"`
	Url       string                 `protobuf:"bytes,6,opt,name=url,proto3" json:"url,omitempty"`
	Status    string                 `protobuf:"bytes,7,opt,name=status,proto3" json:"status,omitempty"`
	Variants  map[string]string      `` /* 157-byte string literal not displayed */
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,10,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

func (*VideoInfo) Descriptor deprecated

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

Deprecated: Use VideoInfo.ProtoReflect.Descriptor instead.

func (*VideoInfo) GetCreatedAt

func (x *VideoInfo) GetCreatedAt() *timestamppb.Timestamp

func (*VideoInfo) GetDuration

func (x *VideoInfo) GetDuration() float64

func (*VideoInfo) GetHeight

func (x *VideoInfo) GetHeight() uint32

func (*VideoInfo) GetId

func (x *VideoInfo) GetId() string

func (*VideoInfo) GetSize

func (x *VideoInfo) GetSize() uint64

func (*VideoInfo) GetStatus

func (x *VideoInfo) GetStatus() string

func (*VideoInfo) GetUpdatedAt

func (x *VideoInfo) GetUpdatedAt() *timestamppb.Timestamp

func (*VideoInfo) GetUrl

func (x *VideoInfo) GetUrl() string

func (*VideoInfo) GetVariants

func (x *VideoInfo) GetVariants() map[string]string

func (*VideoInfo) GetWidth

func (x *VideoInfo) GetWidth() uint32

func (*VideoInfo) ProtoMessage

func (*VideoInfo) ProtoMessage()

func (*VideoInfo) ProtoReflect

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

func (*VideoInfo) Reset

func (x *VideoInfo) Reset()

func (*VideoInfo) String

func (x *VideoInfo) String() string

type VideoServer

type VideoServer interface {
	Healthz(context.Context, *HealthzRequest) (*HealthzResponse, error)
	GetVideo(context.Context, *GetVideoRequest) (*GetVideoResponse, error)
	ListVideo(context.Context, *ListVideoRequest) (*ListVideoResponse, error)
	UploadVideo(Video_UploadVideoServer) error
	DeleteVideo(context.Context, *DeleteVideoRequest) (*DeleteVideoResponse, error)
	// contains filtered or unexported methods
}

VideoServer is the server API for Video service. All implementations must embed UnimplementedVideoServer for forward compatibility

type VideoStreamClient

type VideoStreamClient interface {
	HandleVideoCreated(ctx context.Context, in *HandleVideoCreatedRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

VideoStreamClient is the client API for VideoStream 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 VideoStreamHandlers

type VideoStreamHandlers struct {
	*HandleVideoCreatedHandler
}

func NewVideoStreamHandlers

func NewVideoStreamHandlers(server VideoStreamServer, logger saramakit.Logger) *VideoStreamHandlers

type VideoStreamServer

type VideoStreamServer interface {
	HandleVideoCreated(context.Context, *HandleVideoCreatedRequest) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

VideoStreamServer is the server API for VideoStream service. All implementations must embed UnimplementedVideoStreamServer for forward compatibility

type Video_UploadVideoClient

type Video_UploadVideoClient interface {
	Send(*UploadVideoRequest) error
	CloseAndRecv() (*UploadVideoResponse, error)
	grpc.ClientStream
}

type Video_UploadVideoServer

type Video_UploadVideoServer interface {
	SendAndClose(*UploadVideoResponse) error
	Recv() (*UploadVideoRequest, error)
	grpc.ServerStream
}

Jump to

Keyboard shortcuts

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