Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterAnalysisServiceServer(s grpc.ServiceRegistrar, srv AnalysisServiceServer)
- func RegisterHealthServer(s grpc.ServiceRegistrar, srv HealthServer)
- type AnalysisServiceClient
- type AnalysisServiceServer
- type CameraStatus
- func (*CameraStatus) Descriptor() ([]byte, []int)deprecated
- func (x *CameraStatus) GetCameraId() string
- func (x *CameraStatus) GetFramesProcessed() int64
- func (x *CameraStatus) GetLastError() string
- func (x *CameraStatus) GetRetryCount() int32
- func (x *CameraStatus) GetStatus() string
- func (*CameraStatus) ProtoMessage()
- func (x *CameraStatus) ProtoReflect() protoreflect.Message
- func (x *CameraStatus) Reset()
- func (x *CameraStatus) String() string
- type GlobalStats
- func (*GlobalStats) Descriptor() ([]byte, []int)deprecated
- func (x *GlobalStats) GetActiveStreams() int32
- func (x *GlobalStats) GetTotalDetections() int64
- func (x *GlobalStats) GetUptimeSeconds() int64
- func (*GlobalStats) ProtoMessage()
- func (x *GlobalStats) ProtoReflect() protoreflect.Message
- func (x *GlobalStats) Reset()
- func (x *GlobalStats) String() string
- type HealthCheckRequest
- type HealthCheckResponse
- func (*HealthCheckResponse) Descriptor() ([]byte, []int)deprecated
- func (x *HealthCheckResponse) GetStatus() HealthCheckResponse_ServingStatus
- func (*HealthCheckResponse) ProtoMessage()
- func (x *HealthCheckResponse) ProtoReflect() protoreflect.Message
- func (x *HealthCheckResponse) Reset()
- func (x *HealthCheckResponse) String() string
- type HealthCheckResponse_ServingStatus
- func (HealthCheckResponse_ServingStatus) Descriptor() protoreflect.EnumDescriptor
- func (x HealthCheckResponse_ServingStatus) Enum() *HealthCheckResponse_ServingStatus
- func (HealthCheckResponse_ServingStatus) EnumDescriptor() ([]byte, []int)deprecated
- func (x HealthCheckResponse_ServingStatus) Number() protoreflect.EnumNumber
- func (x HealthCheckResponse_ServingStatus) String() string
- func (HealthCheckResponse_ServingStatus) Type() protoreflect.EnumType
- type HealthClient
- type HealthServer
- type StartCameraRequest
- func (*StartCameraRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StartCameraRequest) GetCallbackSecret() string
- func (x *StartCameraRequest) GetCallbackUrl() string
- func (x *StartCameraRequest) GetCameraId() string
- func (x *StartCameraRequest) GetCameraName() string
- func (x *StartCameraRequest) GetDetectFps() int32
- func (x *StartCameraRequest) GetLabels() []string
- func (x *StartCameraRequest) GetRetryLimit() int32
- func (x *StartCameraRequest) GetRoiPoints() []float32
- func (x *StartCameraRequest) GetRtspUrl() string
- func (x *StartCameraRequest) GetThreshold() float32
- func (*StartCameraRequest) ProtoMessage()
- func (x *StartCameraRequest) ProtoReflect() protoreflect.Message
- func (x *StartCameraRequest) Reset()
- func (x *StartCameraRequest) String() string
- type StartCameraResponse
- func (*StartCameraResponse) Descriptor() ([]byte, []int)deprecated
- func (x *StartCameraResponse) GetMessage() string
- func (x *StartCameraResponse) GetSourceFps() float32
- func (x *StartCameraResponse) GetSourceHeight() int32
- func (x *StartCameraResponse) GetSourceWidth() int32
- func (x *StartCameraResponse) GetSuccess() bool
- func (*StartCameraResponse) ProtoMessage()
- func (x *StartCameraResponse) ProtoReflect() protoreflect.Message
- func (x *StartCameraResponse) Reset()
- func (x *StartCameraResponse) String() string
- type StatusRequest
- type StatusResponse
- func (*StatusResponse) Descriptor() ([]byte, []int)deprecated
- func (x *StatusResponse) GetCameras() []*CameraStatus
- func (x *StatusResponse) GetIsReady() bool
- func (x *StatusResponse) GetStats() *GlobalStats
- func (*StatusResponse) ProtoMessage()
- func (x *StatusResponse) ProtoReflect() protoreflect.Message
- func (x *StatusResponse) Reset()
- func (x *StatusResponse) String() string
- type StopCameraRequest
- type StopCameraResponse
- func (*StopCameraResponse) Descriptor() ([]byte, []int)deprecated
- func (x *StopCameraResponse) GetMessage() string
- func (x *StopCameraResponse) GetSuccess() bool
- func (*StopCameraResponse) ProtoMessage()
- func (x *StopCameraResponse) ProtoReflect() protoreflect.Message
- func (x *StopCameraResponse) Reset()
- func (x *StopCameraResponse) String() string
- type UnimplementedAnalysisServiceServer
- func (UnimplementedAnalysisServiceServer) GetStatus(context.Context, *StatusRequest) (*StatusResponse, error)
- func (UnimplementedAnalysisServiceServer) StartCamera(context.Context, *StartCameraRequest) (*StartCameraResponse, error)
- func (UnimplementedAnalysisServiceServer) StopCamera(context.Context, *StopCameraRequest) (*StopCameraResponse, error)
- type UnimplementedHealthServer
- type UnsafeAnalysisServiceServer
- type UnsafeHealthServer
Constants ¶
const ( AnalysisService_StartCamera_FullMethodName = "/analysis.AnalysisService/StartCamera" AnalysisService_StopCamera_FullMethodName = "/analysis.AnalysisService/StopCamera" AnalysisService_GetStatus_FullMethodName = "/analysis.AnalysisService/GetStatus" )
const (
Health_Check_FullMethodName = "/analysis.Health/Check"
)
Variables ¶
var ( HealthCheckResponse_ServingStatus_name = map[int32]string{ 0: "UNKNOWN", 1: "SERVING", 2: "NOT_SERVING", } HealthCheckResponse_ServingStatus_value = map[string]int32{ "UNKNOWN": 0, "SERVING": 1, "NOT_SERVING": 2, } )
Enum value maps for HealthCheckResponse_ServingStatus.
var AnalysisService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "analysis.AnalysisService", HandlerType: (*AnalysisServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "StartCamera", Handler: _AnalysisService_StartCamera_Handler, }, { MethodName: "StopCamera", Handler: _AnalysisService_StopCamera_Handler, }, { MethodName: "GetStatus", Handler: _AnalysisService_GetStatus_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "protos/analysis.proto", }
AnalysisService_ServiceDesc is the grpc.ServiceDesc for AnalysisService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_protos_analysis_proto protoreflect.FileDescriptor
var Health_ServiceDesc = grpc.ServiceDesc{ ServiceName: "analysis.Health", HandlerType: (*HealthServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Check", Handler: _Health_Check_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "protos/analysis.proto", }
Health_ServiceDesc is the grpc.ServiceDesc for Health service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterAnalysisServiceServer ¶
func RegisterAnalysisServiceServer(s grpc.ServiceRegistrar, srv AnalysisServiceServer)
func RegisterHealthServer ¶
func RegisterHealthServer(s grpc.ServiceRegistrar, srv HealthServer)
Types ¶
type AnalysisServiceClient ¶
type AnalysisServiceClient interface {
// 启动摄像头分析
StartCamera(ctx context.Context, in *StartCameraRequest, opts ...grpc.CallOption) (*StartCameraResponse, error)
// 停止摄像头分析
StopCamera(ctx context.Context, in *StopCameraRequest, opts ...grpc.CallOption) (*StopCameraResponse, error)
// 获取服务状态
GetStatus(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*StatusResponse, error)
}
AnalysisServiceClient is the client API for AnalysisService 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 NewAnalysisServiceClient ¶
func NewAnalysisServiceClient(cc grpc.ClientConnInterface) AnalysisServiceClient
type AnalysisServiceServer ¶
type AnalysisServiceServer interface {
// 启动摄像头分析
StartCamera(context.Context, *StartCameraRequest) (*StartCameraResponse, error)
// 停止摄像头分析
StopCamera(context.Context, *StopCameraRequest) (*StopCameraResponse, error)
// 获取服务状态
GetStatus(context.Context, *StatusRequest) (*StatusResponse, error)
// contains filtered or unexported methods
}
AnalysisServiceServer is the server API for AnalysisService service. All implementations must embed UnimplementedAnalysisServiceServer for forward compatibility.
type CameraStatus ¶
type CameraStatus struct {
CameraId string `protobuf:"bytes,1,opt,name=camera_id,json=cameraId,proto3" json:"camera_id,omitempty"`
Status string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"` // "running", "error", "stopped"
FramesProcessed int64 `protobuf:"varint,3,opt,name=frames_processed,json=framesProcessed,proto3" json:"frames_processed,omitempty"` // 已处理帧数
LastError string `protobuf:"bytes,4,opt,name=last_error,json=lastError,proto3" json:"last_error,omitempty"` // 最后一次错误信息
RetryCount int32 `protobuf:"varint,5,opt,name=retry_count,json=retryCount,proto3" json:"retry_count,omitempty"` // 当前重试次数
// contains filtered or unexported fields
}
func (*CameraStatus) Descriptor
deprecated
func (*CameraStatus) Descriptor() ([]byte, []int)
Deprecated: Use CameraStatus.ProtoReflect.Descriptor instead.
func (*CameraStatus) GetCameraId ¶
func (x *CameraStatus) GetCameraId() string
func (*CameraStatus) GetFramesProcessed ¶
func (x *CameraStatus) GetFramesProcessed() int64
func (*CameraStatus) GetLastError ¶
func (x *CameraStatus) GetLastError() string
func (*CameraStatus) GetRetryCount ¶
func (x *CameraStatus) GetRetryCount() int32
func (*CameraStatus) GetStatus ¶
func (x *CameraStatus) GetStatus() string
func (*CameraStatus) ProtoMessage ¶
func (*CameraStatus) ProtoMessage()
func (*CameraStatus) ProtoReflect ¶
func (x *CameraStatus) ProtoReflect() protoreflect.Message
func (*CameraStatus) Reset ¶
func (x *CameraStatus) Reset()
func (*CameraStatus) String ¶
func (x *CameraStatus) String() string
type GlobalStats ¶
type GlobalStats struct {
ActiveStreams int32 `protobuf:"varint,1,opt,name=active_streams,json=activeStreams,proto3" json:"active_streams,omitempty"` // 当前活跃 RTSP 流数量
TotalDetections int64 `protobuf:"varint,2,opt,name=total_detections,json=totalDetections,proto3" json:"total_detections,omitempty"` // 服务启动以来的总检测次数
UptimeSeconds int64 `protobuf:"varint,3,opt,name=uptime_seconds,json=uptimeSeconds,proto3" json:"uptime_seconds,omitempty"` // 运行时间
// contains filtered or unexported fields
}
func (*GlobalStats) Descriptor
deprecated
func (*GlobalStats) Descriptor() ([]byte, []int)
Deprecated: Use GlobalStats.ProtoReflect.Descriptor instead.
func (*GlobalStats) GetActiveStreams ¶
func (x *GlobalStats) GetActiveStreams() int32
func (*GlobalStats) GetTotalDetections ¶
func (x *GlobalStats) GetTotalDetections() int64
func (*GlobalStats) GetUptimeSeconds ¶
func (x *GlobalStats) GetUptimeSeconds() int64
func (*GlobalStats) ProtoMessage ¶
func (*GlobalStats) ProtoMessage()
func (*GlobalStats) ProtoReflect ¶
func (x *GlobalStats) ProtoReflect() protoreflect.Message
func (*GlobalStats) Reset ¶
func (x *GlobalStats) Reset()
func (*GlobalStats) String ¶
func (x *GlobalStats) String() string
type HealthCheckRequest ¶
type HealthCheckRequest struct {
// contains filtered or unexported fields
}
func (*HealthCheckRequest) Descriptor
deprecated
func (*HealthCheckRequest) Descriptor() ([]byte, []int)
Deprecated: Use HealthCheckRequest.ProtoReflect.Descriptor instead.
func (*HealthCheckRequest) ProtoMessage ¶
func (*HealthCheckRequest) ProtoMessage()
func (*HealthCheckRequest) ProtoReflect ¶
func (x *HealthCheckRequest) ProtoReflect() protoreflect.Message
func (*HealthCheckRequest) Reset ¶
func (x *HealthCheckRequest) Reset()
func (*HealthCheckRequest) String ¶
func (x *HealthCheckRequest) String() string
type HealthCheckResponse ¶
type HealthCheckResponse struct {
Status HealthCheckResponse_ServingStatus `protobuf:"varint,1,opt,name=status,proto3,enum=analysis.HealthCheckResponse_ServingStatus" json:"status,omitempty"`
// contains filtered or unexported fields
}
func (*HealthCheckResponse) Descriptor
deprecated
func (*HealthCheckResponse) Descriptor() ([]byte, []int)
Deprecated: Use HealthCheckResponse.ProtoReflect.Descriptor instead.
func (*HealthCheckResponse) GetStatus ¶
func (x *HealthCheckResponse) GetStatus() HealthCheckResponse_ServingStatus
func (*HealthCheckResponse) ProtoMessage ¶
func (*HealthCheckResponse) ProtoMessage()
func (*HealthCheckResponse) ProtoReflect ¶
func (x *HealthCheckResponse) ProtoReflect() protoreflect.Message
func (*HealthCheckResponse) Reset ¶
func (x *HealthCheckResponse) Reset()
func (*HealthCheckResponse) String ¶
func (x *HealthCheckResponse) String() string
type HealthCheckResponse_ServingStatus ¶
type HealthCheckResponse_ServingStatus int32
const ( HealthCheckResponse_UNKNOWN HealthCheckResponse_ServingStatus = 0 HealthCheckResponse_SERVING HealthCheckResponse_ServingStatus = 1 // 服务正常 HealthCheckResponse_NOT_SERVING HealthCheckResponse_ServingStatus = 2 // 服务不可用 (加载模型中) )
func (HealthCheckResponse_ServingStatus) Descriptor ¶
func (HealthCheckResponse_ServingStatus) Descriptor() protoreflect.EnumDescriptor
func (HealthCheckResponse_ServingStatus) Enum ¶
func (x HealthCheckResponse_ServingStatus) Enum() *HealthCheckResponse_ServingStatus
func (HealthCheckResponse_ServingStatus) EnumDescriptor
deprecated
func (HealthCheckResponse_ServingStatus) EnumDescriptor() ([]byte, []int)
Deprecated: Use HealthCheckResponse_ServingStatus.Descriptor instead.
func (HealthCheckResponse_ServingStatus) Number ¶
func (x HealthCheckResponse_ServingStatus) Number() protoreflect.EnumNumber
func (HealthCheckResponse_ServingStatus) String ¶
func (x HealthCheckResponse_ServingStatus) String() string
func (HealthCheckResponse_ServingStatus) Type ¶
func (HealthCheckResponse_ServingStatus) Type() protoreflect.EnumType
type HealthClient ¶
type HealthClient interface {
Check(ctx context.Context, in *HealthCheckRequest, opts ...grpc.CallOption) (*HealthCheckResponse, error)
}
HealthClient is the client API for Health 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 NewHealthClient ¶
func NewHealthClient(cc grpc.ClientConnInterface) HealthClient
type HealthServer ¶
type HealthServer interface {
Check(context.Context, *HealthCheckRequest) (*HealthCheckResponse, error)
// contains filtered or unexported methods
}
HealthServer is the server API for Health service. All implementations must embed UnimplementedHealthServer for forward compatibility.
type StartCameraRequest ¶
type StartCameraRequest struct {
// === 基础信息 ===
CameraId string `protobuf:"bytes,1,opt,name=camera_id,json=cameraId,proto3" json:"camera_id,omitempty"` // 摄像头唯一标识 (必填)
CameraName string `protobuf:"bytes,2,opt,name=camera_name,json=cameraName,proto3" json:"camera_name,omitempty"` // 摄像头名称,用于日志 (可选)
RtspUrl string `protobuf:"bytes,3,opt,name=rtsp_url,json=rtspUrl,proto3" json:"rtsp_url,omitempty"` // RTSP 子码流地址 (必填)
// === 检测配置 ===
DetectFps int32 `protobuf:"varint,4,opt,name=detect_fps,json=detectFps,proto3" json:"detect_fps,omitempty"` // 检测帧率,默认 5
Labels []string `protobuf:"bytes,5,rep,name=labels,proto3" json:"labels,omitempty"` // 要检测的标签,如 ["person", "car"],空则检测全部
Threshold float32 `protobuf:"fixed32,6,opt,name=threshold,proto3" json:"threshold,omitempty"` // 置信度阈值,默认 0.5
// === ROI 区域 (多边形点位) ===
// n 个坐标组合成的多边形,例如 [0.1, 0.2, 0.12, 0.22, 0.1, 0.3...]
// 归一化坐标 (x1, y1, x2, y2, ...)
RoiPoints []float32 `protobuf:"fixed32,7,rep,packed,name=roi_points,json=roiPoints,proto3" json:"roi_points,omitempty"`
// 错误处理
RetryLimit int32 `protobuf:"varint,8,opt,name=retry_limit,json=retryLimit,proto3" json:"retry_limit,omitempty"` // 遇到错误的自动重试次数,默认 10
// === 回调配置 ===
// 优先级高于服务启动时的默认配置
CallbackUrl string `protobuf:"bytes,10,opt,name=callback_url,json=callbackUrl,proto3" json:"callback_url,omitempty"` // HTTP 回调地址 (必填)
CallbackSecret string `protobuf:"bytes,11,opt,name=callback_secret,json=callbackSecret,proto3" json:"callback_secret,omitempty"` // 回调签名密钥 (可选,用于验证)
// contains filtered or unexported fields
}
启动摄像头分析请求
func (*StartCameraRequest) Descriptor
deprecated
func (*StartCameraRequest) Descriptor() ([]byte, []int)
Deprecated: Use StartCameraRequest.ProtoReflect.Descriptor instead.
func (*StartCameraRequest) GetCallbackSecret ¶
func (x *StartCameraRequest) GetCallbackSecret() string
func (*StartCameraRequest) GetCallbackUrl ¶
func (x *StartCameraRequest) GetCallbackUrl() string
func (*StartCameraRequest) GetCameraId ¶
func (x *StartCameraRequest) GetCameraId() string
func (*StartCameraRequest) GetCameraName ¶
func (x *StartCameraRequest) GetCameraName() string
func (*StartCameraRequest) GetDetectFps ¶
func (x *StartCameraRequest) GetDetectFps() int32
func (*StartCameraRequest) GetLabels ¶
func (x *StartCameraRequest) GetLabels() []string
func (*StartCameraRequest) GetRetryLimit ¶
func (x *StartCameraRequest) GetRetryLimit() int32
func (*StartCameraRequest) GetRoiPoints ¶
func (x *StartCameraRequest) GetRoiPoints() []float32
func (*StartCameraRequest) GetRtspUrl ¶
func (x *StartCameraRequest) GetRtspUrl() string
func (*StartCameraRequest) GetThreshold ¶
func (x *StartCameraRequest) GetThreshold() float32
func (*StartCameraRequest) ProtoMessage ¶
func (*StartCameraRequest) ProtoMessage()
func (*StartCameraRequest) ProtoReflect ¶
func (x *StartCameraRequest) ProtoReflect() protoreflect.Message
func (*StartCameraRequest) Reset ¶
func (x *StartCameraRequest) Reset()
func (*StartCameraRequest) String ¶
func (x *StartCameraRequest) String() string
type StartCameraResponse ¶
type StartCameraResponse struct {
Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
// 流信息 (通过 ffprobe 探测返回)
SourceWidth int32 `protobuf:"varint,3,opt,name=source_width,json=sourceWidth,proto3" json:"source_width,omitempty"` // 原始分辨率宽度
SourceHeight int32 `protobuf:"varint,4,opt,name=source_height,json=sourceHeight,proto3" json:"source_height,omitempty"` // 原始分辨率高度
SourceFps float32 `protobuf:"fixed32,5,opt,name=source_fps,json=sourceFps,proto3" json:"source_fps,omitempty"` // 原始帧率
// contains filtered or unexported fields
}
func (*StartCameraResponse) Descriptor
deprecated
func (*StartCameraResponse) Descriptor() ([]byte, []int)
Deprecated: Use StartCameraResponse.ProtoReflect.Descriptor instead.
func (*StartCameraResponse) GetMessage ¶
func (x *StartCameraResponse) GetMessage() string
func (*StartCameraResponse) GetSourceFps ¶
func (x *StartCameraResponse) GetSourceFps() float32
func (*StartCameraResponse) GetSourceHeight ¶
func (x *StartCameraResponse) GetSourceHeight() int32
func (*StartCameraResponse) GetSourceWidth ¶
func (x *StartCameraResponse) GetSourceWidth() int32
func (*StartCameraResponse) GetSuccess ¶
func (x *StartCameraResponse) GetSuccess() bool
func (*StartCameraResponse) ProtoMessage ¶
func (*StartCameraResponse) ProtoMessage()
func (*StartCameraResponse) ProtoReflect ¶
func (x *StartCameraResponse) ProtoReflect() protoreflect.Message
func (*StartCameraResponse) Reset ¶
func (x *StartCameraResponse) Reset()
func (*StartCameraResponse) String ¶
func (x *StartCameraResponse) String() string
type StatusRequest ¶
type StatusRequest struct {
// contains filtered or unexported fields
}
func (*StatusRequest) Descriptor
deprecated
func (*StatusRequest) Descriptor() ([]byte, []int)
Deprecated: Use StatusRequest.ProtoReflect.Descriptor instead.
func (*StatusRequest) ProtoMessage ¶
func (*StatusRequest) ProtoMessage()
func (*StatusRequest) ProtoReflect ¶
func (x *StatusRequest) ProtoReflect() protoreflect.Message
func (*StatusRequest) Reset ¶
func (x *StatusRequest) Reset()
func (*StatusRequest) String ¶
func (x *StatusRequest) String() string
type StatusResponse ¶
type StatusResponse struct {
IsReady bool `protobuf:"varint,1,opt,name=is_ready,json=isReady,proto3" json:"is_ready,omitempty"` // AI 模型是否加载完成
Cameras []*CameraStatus `protobuf:"bytes,2,rep,name=cameras,proto3" json:"cameras,omitempty"` // 摄像头状态列表
Stats *GlobalStats `protobuf:"bytes,3,opt,name=stats,proto3" json:"stats,omitempty"` // 全局统计信息
// contains filtered or unexported fields
}
func (*StatusResponse) Descriptor
deprecated
func (*StatusResponse) Descriptor() ([]byte, []int)
Deprecated: Use StatusResponse.ProtoReflect.Descriptor instead.
func (*StatusResponse) GetCameras ¶
func (x *StatusResponse) GetCameras() []*CameraStatus
func (*StatusResponse) GetIsReady ¶
func (x *StatusResponse) GetIsReady() bool
func (*StatusResponse) GetStats ¶
func (x *StatusResponse) GetStats() *GlobalStats
func (*StatusResponse) ProtoMessage ¶
func (*StatusResponse) ProtoMessage()
func (*StatusResponse) ProtoReflect ¶
func (x *StatusResponse) ProtoReflect() protoreflect.Message
func (*StatusResponse) Reset ¶
func (x *StatusResponse) Reset()
func (*StatusResponse) String ¶
func (x *StatusResponse) String() string
type StopCameraRequest ¶
type StopCameraRequest struct {
CameraId string `protobuf:"bytes,1,opt,name=camera_id,json=cameraId,proto3" json:"camera_id,omitempty"`
// contains filtered or unexported fields
}
func (*StopCameraRequest) Descriptor
deprecated
func (*StopCameraRequest) Descriptor() ([]byte, []int)
Deprecated: Use StopCameraRequest.ProtoReflect.Descriptor instead.
func (*StopCameraRequest) GetCameraId ¶
func (x *StopCameraRequest) GetCameraId() string
func (*StopCameraRequest) ProtoMessage ¶
func (*StopCameraRequest) ProtoMessage()
func (*StopCameraRequest) ProtoReflect ¶
func (x *StopCameraRequest) ProtoReflect() protoreflect.Message
func (*StopCameraRequest) Reset ¶
func (x *StopCameraRequest) Reset()
func (*StopCameraRequest) String ¶
func (x *StopCameraRequest) String() string
type StopCameraResponse ¶
type StopCameraResponse struct {
Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
// contains filtered or unexported fields
}
func (*StopCameraResponse) Descriptor
deprecated
func (*StopCameraResponse) Descriptor() ([]byte, []int)
Deprecated: Use StopCameraResponse.ProtoReflect.Descriptor instead.
func (*StopCameraResponse) GetMessage ¶
func (x *StopCameraResponse) GetMessage() string
func (*StopCameraResponse) GetSuccess ¶
func (x *StopCameraResponse) GetSuccess() bool
func (*StopCameraResponse) ProtoMessage ¶
func (*StopCameraResponse) ProtoMessage()
func (*StopCameraResponse) ProtoReflect ¶
func (x *StopCameraResponse) ProtoReflect() protoreflect.Message
func (*StopCameraResponse) Reset ¶
func (x *StopCameraResponse) Reset()
func (*StopCameraResponse) String ¶
func (x *StopCameraResponse) String() string
type UnimplementedAnalysisServiceServer ¶
type UnimplementedAnalysisServiceServer struct{}
UnimplementedAnalysisServiceServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedAnalysisServiceServer) GetStatus ¶
func (UnimplementedAnalysisServiceServer) GetStatus(context.Context, *StatusRequest) (*StatusResponse, error)
func (UnimplementedAnalysisServiceServer) StartCamera ¶
func (UnimplementedAnalysisServiceServer) StartCamera(context.Context, *StartCameraRequest) (*StartCameraResponse, error)
func (UnimplementedAnalysisServiceServer) StopCamera ¶
func (UnimplementedAnalysisServiceServer) StopCamera(context.Context, *StopCameraRequest) (*StopCameraResponse, error)
type UnimplementedHealthServer ¶
type UnimplementedHealthServer struct{}
UnimplementedHealthServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedHealthServer) Check ¶
func (UnimplementedHealthServer) Check(context.Context, *HealthCheckRequest) (*HealthCheckResponse, error)
type UnsafeAnalysisServiceServer ¶
type UnsafeAnalysisServiceServer interface {
// contains filtered or unexported methods
}
UnsafeAnalysisServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AnalysisServiceServer will result in compilation errors.
type UnsafeHealthServer ¶
type UnsafeHealthServer interface {
// contains filtered or unexported methods
}
UnsafeHealthServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to HealthServer will result in compilation errors.