Documentation ¶
Overview ¶
Package pb is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Index ¶
- Variables
- func RegisterVideoHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterVideoHandlerClient(ctx context.Context, mux *runtime.ServeMux, client VideoClient) error
- func RegisterVideoHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterVideoHandlerServer(ctx context.Context, mux *runtime.ServeMux, server VideoServer) error
- func RegisterVideoServer(s grpc.ServiceRegistrar, srv VideoServer)
- func RegisterVideoStreamServer(s grpc.ServiceRegistrar, srv VideoStreamServer)
- type DeleteVideoRequest
- type DeleteVideoResponse
- type GetVideoRequest
- type GetVideoResponse
- type HandleVideoCreatedHandler
- type HandleVideoCreatedRequest
- func (*HandleVideoCreatedRequest) Descriptor() ([]byte, []int)deprecated
- func (x *HandleVideoCreatedRequest) GetId() string
- func (x *HandleVideoCreatedRequest) GetScale() int32
- func (x *HandleVideoCreatedRequest) GetUrl() string
- func (*HandleVideoCreatedRequest) ProtoMessage()
- func (x *HandleVideoCreatedRequest) ProtoReflect() protoreflect.Message
- func (x *HandleVideoCreatedRequest) Reset()
- func (x *HandleVideoCreatedRequest) String() string
- type HealthzRequest
- type HealthzResponse
- type ListVideoRequest
- func (*ListVideoRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListVideoRequest) GetLimit() int64
- func (x *ListVideoRequest) GetSkip() int64
- func (*ListVideoRequest) ProtoMessage()
- func (x *ListVideoRequest) ProtoReflect() protoreflect.Message
- func (x *ListVideoRequest) Reset()
- func (x *ListVideoRequest) String() string
- type ListVideoResponse
- func (*ListVideoResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListVideoResponse) GetVideos() []*VideoInfo
- func (*ListVideoResponse) ProtoMessage()
- func (x *ListVideoResponse) ProtoReflect() protoreflect.Message
- func (x *ListVideoResponse) Reset()
- func (x *ListVideoResponse) String() string
- type UnimplementedVideoServer
- func (UnimplementedVideoServer) DeleteVideo(context.Context, *DeleteVideoRequest) (*DeleteVideoResponse, error)
- func (UnimplementedVideoServer) GetVideo(context.Context, *GetVideoRequest) (*GetVideoResponse, error)
- func (UnimplementedVideoServer) Healthz(context.Context, *HealthzRequest) (*HealthzResponse, error)
- func (UnimplementedVideoServer) ListVideo(context.Context, *ListVideoRequest) (*ListVideoResponse, error)
- func (UnimplementedVideoServer) UploadVideo(Video_UploadVideoServer) error
- type UnimplementedVideoStreamServer
- type UnsafeVideoServer
- type UnsafeVideoStreamServer
- type UploadVideoRequest
- func (*UploadVideoRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UploadVideoRequest) GetChunkData() []byte
- func (m *UploadVideoRequest) GetData() isUploadVideoRequest_Data
- func (x *UploadVideoRequest) GetHeader() *VideoHeader
- func (*UploadVideoRequest) ProtoMessage()
- func (x *UploadVideoRequest) ProtoReflect() protoreflect.Message
- func (x *UploadVideoRequest) Reset()
- func (x *UploadVideoRequest) String() string
- type UploadVideoRequest_ChunkData
- type UploadVideoRequest_Header
- type UploadVideoResponse
- func (*UploadVideoResponse) Descriptor() ([]byte, []int)deprecated
- func (x *UploadVideoResponse) GetId() string
- func (*UploadVideoResponse) ProtoMessage()
- func (x *UploadVideoResponse) ProtoReflect() protoreflect.Message
- func (x *UploadVideoResponse) Reset()
- func (x *UploadVideoResponse) String() string
- type VideoClient
- type VideoHeader
- func (*VideoHeader) Descriptor() ([]byte, []int)deprecated
- func (x *VideoHeader) GetFilename() string
- func (x *VideoHeader) GetSize() uint64
- func (*VideoHeader) ProtoMessage()
- func (x *VideoHeader) ProtoReflect() protoreflect.Message
- func (x *VideoHeader) Reset()
- func (x *VideoHeader) String() string
- type VideoInfo
- func (*VideoInfo) Descriptor() ([]byte, []int)deprecated
- func (x *VideoInfo) GetCreatedAt() *timestamppb.Timestamp
- func (x *VideoInfo) GetDuration() float64
- func (x *VideoInfo) GetHeight() uint32
- func (x *VideoInfo) GetId() string
- func (x *VideoInfo) GetSize() uint64
- func (x *VideoInfo) GetStatus() string
- func (x *VideoInfo) GetUpdatedAt() *timestamppb.Timestamp
- func (x *VideoInfo) GetUrl() string
- func (x *VideoInfo) GetVariants() map[string]string
- func (x *VideoInfo) GetWidth() uint32
- func (*VideoInfo) ProtoMessage()
- func (x *VideoInfo) ProtoReflect() protoreflect.Message
- func (x *VideoInfo) Reset()
- func (x *VideoInfo) String() string
- type VideoServer
- type VideoStreamClient
- type VideoStreamHandlers
- type VideoStreamServer
- type Video_UploadVideoClient
- type Video_UploadVideoServer
Constants ¶
This section is empty.
Variables ¶
var File_modules_video_pb_message_proto protoreflect.FileDescriptor
var File_modules_video_pb_rpc_proto protoreflect.FileDescriptor
var File_modules_video_pb_stream_proto protoreflect.FileDescriptor
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)
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 ¶
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 (h *HandleVideoCreatedHandler) Cleanup(sarama.ConsumerGroupSession) error
func (*HandleVideoCreatedHandler) ConsumeClaim ¶
func (h *HandleVideoCreatedHandler) ConsumeClaim(sess sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error
func (*HandleVideoCreatedHandler) Setup ¶
func (h *HandleVideoCreatedHandler) Setup(sarama.ConsumerGroupSession) error
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 (x *HandleVideoCreatedRequest) ProtoReflect() protoreflect.Message
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) DeleteVideo(context.Context, *DeleteVideoRequest) (*DeleteVideoResponse, error)
func (UnimplementedVideoServer) GetVideo ¶
func (UnimplementedVideoServer) GetVideo(context.Context, *GetVideoRequest) (*GetVideoResponse, error)
func (UnimplementedVideoServer) Healthz ¶
func (UnimplementedVideoServer) Healthz(context.Context, *HealthzRequest) (*HealthzResponse, error)
func (UnimplementedVideoServer) ListVideo ¶
func (UnimplementedVideoServer) ListVideo(context.Context, *ListVideoRequest) (*ListVideoResponse, error)
func (UnimplementedVideoServer) UploadVideo ¶
func (UnimplementedVideoServer) UploadVideo(Video_UploadVideoServer) error
type UnimplementedVideoStreamServer ¶
type UnimplementedVideoStreamServer struct { }
UnimplementedVideoStreamServer must be embedded to have forward compatible implementations.
func (UnimplementedVideoStreamServer) HandleVideoCreated ¶
func (UnimplementedVideoStreamServer) HandleVideoCreated(context.Context, *HandleVideoCreatedRequest) (*emptypb.Empty, error)
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) GetCreatedAt ¶
func (x *VideoInfo) GetCreatedAt() *timestamppb.Timestamp
func (*VideoInfo) GetDuration ¶
func (*VideoInfo) GetUpdatedAt ¶
func (x *VideoInfo) GetUpdatedAt() *timestamppb.Timestamp
func (*VideoInfo) GetVariants ¶
func (*VideoInfo) ProtoMessage ¶
func (*VideoInfo) ProtoMessage()
func (*VideoInfo) ProtoReflect ¶
func (x *VideoInfo) ProtoReflect() protoreflect.Message
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.
func NewVideoStreamClient ¶
func NewVideoStreamClient(cc grpc.ClientConnInterface) VideoStreamClient
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 }