camerapb

package
v1.0.0 Latest Latest
Warning

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

 Go to latest Published: May 22, 2020 License: MIT Imports: 13 Imported by: 0

Documentation

Overview

Package camerapb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package camerapb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterCameraServiceHandler 

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

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

func RegisterCameraServiceHandlerClient 

func RegisterCameraServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client CameraServiceClient) error

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

func RegisterCameraServiceHandlerFromEndpoint 

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

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

func RegisterCameraServiceHandlerServer 

func RegisterCameraServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server CameraServiceServer) error

RegisterCameraServiceHandlerServer registers the http handlers for service CameraService to "mux". UnaryRPC :call CameraServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.

func RegisterCameraServiceServer 

func RegisterCameraServiceServer(s *grpc.Server, srv CameraServiceServer)

func RegisterStorageHandler 

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

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

func RegisterStorageHandlerClient 

func RegisterStorageHandlerClient(ctx context.Context, mux *runtime.ServeMux, client StorageClient) error

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

func RegisterStorageHandlerFromEndpoint 

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

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

func RegisterStorageHandlerServer 

func RegisterStorageHandlerServer(ctx context.Context, mux *runtime.ServeMux, server StorageServer) error

RegisterStorageHandlerServer registers the http handlers for service Storage to "mux". UnaryRPC :call StorageServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.

func RegisterStorageServer 

func RegisterStorageServer(s *grpc.Server, srv StorageServer)

Types

type CameraServiceClient 

type CameraServiceClient interface {
	// LiveH264Stream 获取主摄像头视频流数据
	//
	// 输出数据为H264裸流，无音频，分辨率为960*720
	//
	// 网关不包含当前方法，WebSocket用户请使用独立接口
	// ws://10.10.10.2(:81)/api/v2/camera/ws/h264/live(?token=)
	// web应用中需调整数据类型: ws.binaryType = 'arraybuffer';
	//
	// 开发管理平台功能参考: http://10.10.10.2/camera/live/ws
	LiveH264Stream(ctx context.Context, in *LiveH264StreamRequest, opts ...grpc.CallOption) (CameraService_LiveH264StreamClient, error)
	// LatestImage 获取主摄像头实时图片数据
	//
	// 开发管理平台功能参考: http://10.10.10.2/camera/live/image
	LatestImage(ctx context.Context, in *LatestImageRequest, opts ...grpc.CallOption) (*LatestImageResponse, error)
}

CameraServiceClient is the client API for CameraService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewCameraServiceClient 

func NewCameraServiceClient(cc grpc.ClientConnInterface) CameraServiceClient

type CameraServiceServer 

type CameraServiceServer interface {
	// LiveH264Stream 获取主摄像头视频流数据
	//
	// 输出数据为H264裸流，无音频，分辨率为960*720
	//
	// 网关不包含当前方法，WebSocket用户请使用独立接口
	// ws://10.10.10.2(:81)/api/v2/camera/ws/h264/live(?token=)
	// web应用中需调整数据类型: ws.binaryType = 'arraybuffer';
	//
	// 开发管理平台功能参考: http://10.10.10.2/camera/live/ws
	LiveH264Stream(*LiveH264StreamRequest, CameraService_LiveH264StreamServer) error
	// LatestImage 获取主摄像头实时图片数据
	//
	// 开发管理平台功能参考: http://10.10.10.2/camera/live/image
	LatestImage(context.Context, *LatestImageRequest) (*LatestImageResponse, error)
}

CameraServiceServer is the server API for CameraService service.

type CameraService_LiveH264StreamClient 

type CameraService_LiveH264StreamClient interface {
	Recv() (*LiveH264StreamResponse, error)
	grpc.ClientStream
}

type CameraService_LiveH264StreamServer 

type CameraService_LiveH264StreamServer interface {
	Send(*LiveH264StreamResponse) error
	grpc.ServerStream
}

type DeleteVideoFilesRequest 

type DeleteVideoFilesRequest struct {
	// e.g. [2019-01-01/00:00:00.mp4, 2019-12-01/22:10:00.mp4]
	Videos               []string `protobuf:"bytes,1,rep,name=videos,proto3" json:"videos,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteVideoFilesRequest) Descriptor 

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

func (*DeleteVideoFilesRequest) GetVideos 

func (m *DeleteVideoFilesRequest) GetVideos() []string

func (*DeleteVideoFilesRequest) ProtoMessage 

func (*DeleteVideoFilesRequest) ProtoMessage()

func (*DeleteVideoFilesRequest) Reset 

func (m *DeleteVideoFilesRequest) Reset()

func (*DeleteVideoFilesRequest) String 

func (m *DeleteVideoFilesRequest) String() string

func (*DeleteVideoFilesRequest) XXX_DiscardUnknown 

func (m *DeleteVideoFilesRequest) XXX_DiscardUnknown()

func (*DeleteVideoFilesRequest) XXX_Marshal 

func (m *DeleteVideoFilesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteVideoFilesRequest) XXX_Merge 

func (m *DeleteVideoFilesRequest) XXX_Merge(src proto.Message)

func (*DeleteVideoFilesRequest) XXX_Size 

func (m *DeleteVideoFilesRequest) XXX_Size() int

func (*DeleteVideoFilesRequest) XXX_Unmarshal 

func (m *DeleteVideoFilesRequest) XXX_Unmarshal(b []byte) error

type DeleteVideoFilesResponse 

type DeleteVideoFilesResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteVideoFilesResponse) Descriptor 

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

func (*DeleteVideoFilesResponse) ProtoMessage 

func (*DeleteVideoFilesResponse) ProtoMessage()

func (*DeleteVideoFilesResponse) Reset 

func (m *DeleteVideoFilesResponse) Reset()

func (*DeleteVideoFilesResponse) String 

func (m *DeleteVideoFilesResponse) String() string

func (*DeleteVideoFilesResponse) XXX_DiscardUnknown 

func (m *DeleteVideoFilesResponse) XXX_DiscardUnknown()

func (*DeleteVideoFilesResponse) XXX_Marshal 

func (m *DeleteVideoFilesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteVideoFilesResponse) XXX_Merge 

func (m *DeleteVideoFilesResponse) XXX_Merge(src proto.Message)

func (*DeleteVideoFilesResponse) XXX_Size 

func (m *DeleteVideoFilesResponse) XXX_Size() int

func (*DeleteVideoFilesResponse) XXX_Unmarshal 

func (m *DeleteVideoFilesResponse) XXX_Unmarshal(b []byte) error

type GetVideoFileRequest 

type GetVideoFileRequest struct {
	// e.g. 2019-01-01/00:00:00.mp4
	Video                string   `protobuf:"bytes,1,opt,name=video,proto3" json:"video,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetVideoFileRequest) Descriptor 

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

func (*GetVideoFileRequest) GetVideo 

func (m *GetVideoFileRequest) GetVideo() string

func (*GetVideoFileRequest) ProtoMessage 

func (*GetVideoFileRequest) ProtoMessage()

func (*GetVideoFileRequest) Reset 

func (m *GetVideoFileRequest) Reset()

func (*GetVideoFileRequest) String 

func (m *GetVideoFileRequest) String() string

func (*GetVideoFileRequest) XXX_DiscardUnknown 

func (m *GetVideoFileRequest) XXX_DiscardUnknown()

func (*GetVideoFileRequest) XXX_Marshal 

func (m *GetVideoFileRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetVideoFileRequest) XXX_Merge 

func (m *GetVideoFileRequest) XXX_Merge(src proto.Message)

func (*GetVideoFileRequest) XXX_Size 

func (m *GetVideoFileRequest) XXX_Size() int

func (*GetVideoFileRequest) XXX_Unmarshal 

func (m *GetVideoFileRequest) XXX_Unmarshal(b []byte) error

type GetVideoFileResponse 

type GetVideoFileResponse struct {
	Chunk                []byte   `protobuf:"bytes,1,opt,name=chunk,proto3" json:"chunk,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetVideoFileResponse) Descriptor 

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

func (*GetVideoFileResponse) GetChunk 

func (m *GetVideoFileResponse) GetChunk() []byte

func (*GetVideoFileResponse) ProtoMessage 

func (*GetVideoFileResponse) ProtoMessage()

func (*GetVideoFileResponse) Reset 

func (m *GetVideoFileResponse) Reset()

func (*GetVideoFileResponse) String 

func (m *GetVideoFileResponse) String() string

func (*GetVideoFileResponse) XXX_DiscardUnknown 

func (m *GetVideoFileResponse) XXX_DiscardUnknown()

func (*GetVideoFileResponse) XXX_Marshal 

func (m *GetVideoFileResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetVideoFileResponse) XXX_Merge 

func (m *GetVideoFileResponse) XXX_Merge(src proto.Message)

func (*GetVideoFileResponse) XXX_Size 

func (m *GetVideoFileResponse) XXX_Size() int

func (*GetVideoFileResponse) XXX_Unmarshal 

func (m *GetVideoFileResponse) XXX_Unmarshal(b []byte) error

type LatestImageRequest 

type LatestImageRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LatestImageRequest) Descriptor 

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

func (*LatestImageRequest) ProtoMessage 

func (*LatestImageRequest) ProtoMessage()

func (*LatestImageRequest) Reset 

func (m *LatestImageRequest) Reset()

func (*LatestImageRequest) String 

func (m *LatestImageRequest) String() string

func (*LatestImageRequest) XXX_DiscardUnknown 

func (m *LatestImageRequest) XXX_DiscardUnknown()

func (*LatestImageRequest) XXX_Marshal 

func (m *LatestImageRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LatestImageRequest) XXX_Merge 

func (m *LatestImageRequest) XXX_Merge(src proto.Message)

func (*LatestImageRequest) XXX_Size 

func (m *LatestImageRequest) XXX_Size() int

func (*LatestImageRequest) XXX_Unmarshal 

func (m *LatestImageRequest) XXX_Unmarshal(b []byte) error

type LatestImageResponse 

type LatestImageResponse struct {
	// 截图时间
	// e.g. "1577811723000"
	Time string `protobuf:"bytes,1,opt,name=time,proto3" json:"time,omitempty"`
	// 图片数据内容
	Image                []byte   `protobuf:"bytes,2,opt,name=image,proto3" json:"image,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LatestImageResponse) Descriptor 

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

func (*LatestImageResponse) GetImage 

func (m *LatestImageResponse) GetImage() []byte

func (*LatestImageResponse) GetTime 

func (m *LatestImageResponse) GetTime() string

func (*LatestImageResponse) ProtoMessage 

func (*LatestImageResponse) ProtoMessage()

func (*LatestImageResponse) Reset 

func (m *LatestImageResponse) Reset()

func (*LatestImageResponse) String 

func (m *LatestImageResponse) String() string

func (*LatestImageResponse) XXX_DiscardUnknown 

func (m *LatestImageResponse) XXX_DiscardUnknown()

func (*LatestImageResponse) XXX_Marshal 

func (m *LatestImageResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LatestImageResponse) XXX_Merge 

func (m *LatestImageResponse) XXX_Merge(src proto.Message)

func (*LatestImageResponse) XXX_Size 

func (m *LatestImageResponse) XXX_Size() int

func (*LatestImageResponse) XXX_Unmarshal 

func (m *LatestImageResponse) XXX_Unmarshal(b []byte) error

type ListDatesRequest 

type ListDatesRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListDatesRequest) Descriptor 

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

func (*ListDatesRequest) ProtoMessage 

func (*ListDatesRequest) ProtoMessage()

func (*ListDatesRequest) Reset 

func (m *ListDatesRequest) Reset()

func (*ListDatesRequest) String 

func (m *ListDatesRequest) String() string

func (*ListDatesRequest) XXX_DiscardUnknown 

func (m *ListDatesRequest) XXX_DiscardUnknown()

func (*ListDatesRequest) XXX_Marshal 

func (m *ListDatesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListDatesRequest) XXX_Merge 

func (m *ListDatesRequest) XXX_Merge(src proto.Message)

func (*ListDatesRequest) XXX_Size 

func (m *ListDatesRequest) XXX_Size() int

func (*ListDatesRequest) XXX_Unmarshal 

func (m *ListDatesRequest) XXX_Unmarshal(b []byte) error

type ListDatesResponse 

type ListDatesResponse struct {
	// 日期列表 e.g. [2019-01-01, 2019-01-02]
	Dates                []string `protobuf:"bytes,1,rep,name=dates,proto3" json:"dates,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListDatesResponse) Descriptor 

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

func (*ListDatesResponse) GetDates 

func (m *ListDatesResponse) GetDates() []string

func (*ListDatesResponse) ProtoMessage 

func (*ListDatesResponse) ProtoMessage()

func (*ListDatesResponse) Reset 

func (m *ListDatesResponse) Reset()

func (*ListDatesResponse) String 

func (m *ListDatesResponse) String() string

func (*ListDatesResponse) XXX_DiscardUnknown 

func (m *ListDatesResponse) XXX_DiscardUnknown()

func (*ListDatesResponse) XXX_Marshal 

func (m *ListDatesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListDatesResponse) XXX_Merge 

func (m *ListDatesResponse) XXX_Merge(src proto.Message)

func (*ListDatesResponse) XXX_Size 

func (m *ListDatesResponse) XXX_Size() int

func (*ListDatesResponse) XXX_Unmarshal 

func (m *ListDatesResponse) XXX_Unmarshal(b []byte) error

type ListVideosRequest 

type ListVideosRequest struct {
	// 开始时间
	// 默认为当日00:00:00
	// 格式 2019-01-02_03:04:05
	Start string `protobuf:"bytes,1,opt,name=start,proto3" json:"start,omitempty"`
	// 结束时间
	// 默认为当日23:59:59
	// 格式 2019-01-02_03:04:05
	End                  string   `protobuf:"bytes,2,opt,name=end,proto3" json:"end,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListVideosRequest) Descriptor 

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

func (*ListVideosRequest) GetEnd 

func (m *ListVideosRequest) GetEnd() string

func (*ListVideosRequest) GetStart 

func (m *ListVideosRequest) GetStart() string

func (*ListVideosRequest) ProtoMessage 

func (*ListVideosRequest) ProtoMessage()

func (*ListVideosRequest) Reset 

func (m *ListVideosRequest) Reset()

func (*ListVideosRequest) String 

func (m *ListVideosRequest) String() string

func (*ListVideosRequest) XXX_DiscardUnknown 

func (m *ListVideosRequest) XXX_DiscardUnknown()

func (*ListVideosRequest) XXX_Marshal 

func (m *ListVideosRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListVideosRequest) XXX_Merge 

func (m *ListVideosRequest) XXX_Merge(src proto.Message)

func (*ListVideosRequest) XXX_Size 

func (m *ListVideosRequest) XXX_Size() int

func (*ListVideosRequest) XXX_Unmarshal 

func (m *ListVideosRequest) XXX_Unmarshal(b []byte) error

type ListVideosResponse 

type ListVideosResponse struct {
	// 视频列表 e.g. [2019-01-01/00:00:00.mp4, 2019-01-01/00:10:00.mp4]
	Videos               []string `protobuf:"bytes,1,rep,name=videos,proto3" json:"videos,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListVideosResponse) Descriptor 

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

func (*ListVideosResponse) GetVideos 

func (m *ListVideosResponse) GetVideos() []string

func (*ListVideosResponse) ProtoMessage 

func (*ListVideosResponse) ProtoMessage()

func (*ListVideosResponse) Reset 

func (m *ListVideosResponse) Reset()

func (*ListVideosResponse) String 

func (m *ListVideosResponse) String() string

func (*ListVideosResponse) XXX_DiscardUnknown 

func (m *ListVideosResponse) XXX_DiscardUnknown()

func (*ListVideosResponse) XXX_Marshal 

func (m *ListVideosResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListVideosResponse) XXX_Merge 

func (m *ListVideosResponse) XXX_Merge(src proto.Message)

func (*ListVideosResponse) XXX_Size 

func (m *ListVideosResponse) XXX_Size() int

func (*ListVideosResponse) XXX_Unmarshal 

func (m *ListVideosResponse) XXX_Unmarshal(b []byte) error

type LiveH264StreamRequest 

type LiveH264StreamRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LiveH264StreamRequest) Descriptor 

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

func (*LiveH264StreamRequest) ProtoMessage 

func (*LiveH264StreamRequest) ProtoMessage()

func (*LiveH264StreamRequest) Reset 

func (m *LiveH264StreamRequest) Reset()

func (*LiveH264StreamRequest) String 

func (m *LiveH264StreamRequest) String() string

func (*LiveH264StreamRequest) XXX_DiscardUnknown 

func (m *LiveH264StreamRequest) XXX_DiscardUnknown()

func (*LiveH264StreamRequest) XXX_Marshal 

func (m *LiveH264StreamRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LiveH264StreamRequest) XXX_Merge 

func (m *LiveH264StreamRequest) XXX_Merge(src proto.Message)

func (*LiveH264StreamRequest) XXX_Size 

func (m *LiveH264StreamRequest) XXX_Size() int

func (*LiveH264StreamRequest) XXX_Unmarshal 

func (m *LiveH264StreamRequest) XXX_Unmarshal(b []byte) error

type LiveH264StreamResponse 

type LiveH264StreamResponse struct {
	// H264帧数据
	Frame                []byte   `protobuf:"bytes,1,opt,name=frame,proto3" json:"frame,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LiveH264StreamResponse) Descriptor 

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

func (*LiveH264StreamResponse) GetFrame 

func (m *LiveH264StreamResponse) GetFrame() []byte

func (*LiveH264StreamResponse) ProtoMessage 

func (*LiveH264StreamResponse) ProtoMessage()

func (*LiveH264StreamResponse) Reset 

func (m *LiveH264StreamResponse) Reset()

func (*LiveH264StreamResponse) String 

func (m *LiveH264StreamResponse) String() string

func (*LiveH264StreamResponse) XXX_DiscardUnknown 

func (m *LiveH264StreamResponse) XXX_DiscardUnknown()

func (*LiveH264StreamResponse) XXX_Marshal 

func (m *LiveH264StreamResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LiveH264StreamResponse) XXX_Merge 

func (m *LiveH264StreamResponse) XXX_Merge(src proto.Message)

func (*LiveH264StreamResponse) XXX_Size 

func (m *LiveH264StreamResponse) XXX_Size() int

func (*LiveH264StreamResponse) XXX_Unmarshal 

func (m *LiveH264StreamResponse) XXX_Unmarshal(b []byte) error

type StorageClient 

type StorageClient interface {
	// ListDates 获取监控存储的视频日期列表
	ListDates(ctx context.Context, in *ListDatesRequest, opts ...grpc.CallOption) (*ListDatesResponse, error)
	// ListVideos 获取时间范围内的监控视频列表
	//
	// 未配置时间范围将默认获取当日时间
	ListVideos(ctx context.Context, in *ListVideosRequest, opts ...grpc.CallOption) (*ListVideosResponse, error)
	// GetVideoFile 获取监控视频文件
	//
	// HTTP中可使用文件服务器方法处理，支持HTTP Range
	// http://10.10.10.2(:81)/api/v2/camera/storage/videos/2020-01-02/15:04:05.mp4(?token=)
	GetVideoFile(ctx context.Context, in *GetVideoFileRequest, opts ...grpc.CallOption) (Storage_GetVideoFileClient, error)
	// DeleteVideoFiles 删除多个监控视频文件
	DeleteVideoFiles(ctx context.Context, in *DeleteVideoFilesRequest, opts ...grpc.CallOption) (*DeleteVideoFilesResponse, error)
}

StorageClient is the client API for Storage service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewStorageClient 

func NewStorageClient(cc grpc.ClientConnInterface) StorageClient

type StorageServer 

type StorageServer interface {
	// ListDates 获取监控存储的视频日期列表
	ListDates(context.Context, *ListDatesRequest) (*ListDatesResponse, error)
	// ListVideos 获取时间范围内的监控视频列表
	//
	// 未配置时间范围将默认获取当日时间
	ListVideos(context.Context, *ListVideosRequest) (*ListVideosResponse, error)
	// GetVideoFile 获取监控视频文件
	//
	// HTTP中可使用文件服务器方法处理，支持HTTP Range
	// http://10.10.10.2(:81)/api/v2/camera/storage/videos/2020-01-02/15:04:05.mp4(?token=)
	GetVideoFile(*GetVideoFileRequest, Storage_GetVideoFileServer) error
	// DeleteVideoFiles 删除多个监控视频文件
	DeleteVideoFiles(context.Context, *DeleteVideoFilesRequest) (*DeleteVideoFilesResponse, error)
}

StorageServer is the server API for Storage service.

type Storage_GetVideoFileClient 

type Storage_GetVideoFileClient interface {
	Recv() (*GetVideoFileResponse, error)
	grpc.ClientStream
}

type Storage_GetVideoFileServer 

type Storage_GetVideoFileServer interface {
	Send(*GetVideoFileResponse) error
	grpc.ServerStream
}

type UnimplementedCameraServiceServer 

type UnimplementedCameraServiceServer struct {
}

UnimplementedCameraServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedCameraServiceServer) LatestImage 

func (*UnimplementedCameraServiceServer) LatestImage(ctx context.Context, req *LatestImageRequest) (*LatestImageResponse, error)

func (*UnimplementedCameraServiceServer) LiveH264Stream 

func (*UnimplementedCameraServiceServer) LiveH264Stream(req *LiveH264StreamRequest, srv CameraService_LiveH264StreamServer) error

type UnimplementedStorageServer 

type UnimplementedStorageServer struct {
}

UnimplementedStorageServer can be embedded to have forward compatible implementations.

func (*UnimplementedStorageServer) DeleteVideoFiles 

func (*UnimplementedStorageServer) DeleteVideoFiles(ctx context.Context, req *DeleteVideoFilesRequest) (*DeleteVideoFilesResponse, error)

func (*UnimplementedStorageServer) GetVideoFile 

func (*UnimplementedStorageServer) GetVideoFile(req *GetVideoFileRequest, srv Storage_GetVideoFileServer) error

func (*UnimplementedStorageServer) ListDates 

func (*UnimplementedStorageServer) ListDates(ctx context.Context, req *ListDatesRequest) (*ListDatesResponse, error)

func (*UnimplementedStorageServer) ListVideos 

func (*UnimplementedStorageServer) ListVideos(ctx context.Context, req *ListVideosRequest) (*ListVideosResponse, error)

Source Files

View all Source files

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.