protos

package
v1.3.0 Latest Latest
Warning

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

 Go to latest Published: Jan 13, 2026 License: GPL-3.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	AnalysisService_StartCamera_FullMethodName = "/analysis.AnalysisService/StartCamera"
	AnalysisService_StopCamera_FullMethodName  = "/analysis.AnalysisService/StopCamera"
	AnalysisService_GetStatus_FullMethodName   = "/analysis.AnalysisService/GetStatus"
)
View Source 
const (
	Health_Check_FullMethodName = "/analysis.Health/Check"
)

Variables

View Source 
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.

View Source 
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)

View Source 
var File_protos_analysis_proto protoreflect.FileDescriptor
View Source 
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.

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.