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.

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) LiveH264Stream

type UnimplementedStorageServer

type UnimplementedStorageServer struct {
}

UnimplementedStorageServer can be embedded to have forward compatible implementations.

func (*UnimplementedStorageServer) DeleteVideoFiles

func (*UnimplementedStorageServer) GetVideoFile

func (*UnimplementedStorageServer) ListDates

func (*UnimplementedStorageServer) ListVideos

Jump to

Keyboard shortcuts

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